regattaserver

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 13, 2025 License: MIT Imports: 39 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// DefaultMaxGRPCSize is the default maximum size of body of gRPC message to be loaded from dragonboat.
	DefaultMaxGRPCSize = 4 * 1024 * 1024
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BackupServer 

type BackupServer struct {
	regattapb.UnimplementedMaintenanceServer
	Tables   TableService
	AuthFunc func(ctx context.Context) (context.Context, error)
}

BackupServer implements some Maintenance service methods from proto/regatta.proto.

func (*BackupServer) AuthFuncOverride 

func (m *BackupServer) AuthFuncOverride(ctx context.Context, _ string) (context.Context, error)

func (*BackupServer) Backup 

func (m *BackupServer) Backup(req *regattapb.BackupRequest, srv regattapb.Maintenance_BackupServer) error

func (*BackupServer) Restore 

func (m *BackupServer) Restore(srv regattapb.Maintenance_RestoreServer) error

type ClusterServer 

type ClusterServer struct {
	regattapb.UnimplementedClusterServer
	Cluster ClusterService
	Config  ConfigService
}

func (*ClusterServer) MemberList 

func (c *ClusterServer) MemberList(ctx context.Context, req *regattapb.MemberListRequest) (*regattapb.MemberListResponse, error)

func (*ClusterServer) Status 

func (c *ClusterServer) Status(ctx context.Context, req *regattapb.StatusRequest) (*regattapb.StatusResponse, error)

type ClusterService 

type ClusterService interface {
	MemberList(context.Context, *regattapb.MemberListRequest) (*regattapb.MemberListResponse, error)
	Status(context.Context, *regattapb.StatusRequest) (*regattapb.StatusResponse, error)
}

type ConfigService 

type ConfigService func() map[string]any

type ForwardingKVServer 

type ForwardingKVServer struct {
	KVServer
	// contains filtered or unexported fields
}

ForwardingKVServer forwards the write operations to the leader cluster.

func NewForwardingKVServer 

func NewForwardingKVServer(storage KVService, client regattapb.KVClient, q *storage.IndexNotificationQueue) *ForwardingKVServer

func (*ForwardingKVServer) DeleteRange 

func (r *ForwardingKVServer) DeleteRange(ctx context.Context, req *regattapb.DeleteRangeRequest) (*regattapb.DeleteRangeResponse, error)

DeleteRange implements proto/regatta.proto KV.DeleteRange method.

func (*ForwardingKVServer) Put 

func (r *ForwardingKVServer) Put(ctx context.Context, req *regattapb.PutRequest) (*regattapb.PutResponse, error)

Put implements proto/regatta.proto KV.Put method.

func (*ForwardingKVServer) Txn 

func (r *ForwardingKVServer) Txn(ctx context.Context, req *regattapb.TxnRequest) (*regattapb.TxnResponse, error)

Txn processes multiple requests in a single transaction. A txn request increments the revision of the key-value store and generates events with the same revision for every completed request. It is allowed to modify the same key several times within one txn (the result will be the last Op that modified the key). Readonly transactions allowed using follower API.

type KVServer 

type KVServer struct {
	regattapb.UnimplementedKVServer
	Storage KVService
}

KVServer implements KV service from proto/regatta.proto.

func (*KVServer) DeleteRange 

func (s *KVServer) DeleteRange(ctx context.Context, req *regattapb.DeleteRangeRequest) (*regattapb.DeleteRangeResponse, error)

DeleteRange implements proto/regatta.proto KV.DeleteRange method.

func (*KVServer) IterateRange 

func (s *KVServer) IterateRange(req *regattapb.RangeRequest, srv regattapb.KV_IterateRangeServer) error

IterateRange gets the keys in the range from the key-value store.

func (*KVServer) Put 

func (s *KVServer) Put(ctx context.Context, req *regattapb.PutRequest) (*regattapb.PutResponse, error)

Put implements proto/regatta.proto KV.Put method.

func (*KVServer) Range 

func (s *KVServer) Range(ctx context.Context, req *regattapb.RangeRequest) (*regattapb.RangeResponse, error)

Range implements proto/regatta.proto KV.Range method. Currently, only subset of functionality is implemented. The versioning functionality is not available.

func (*KVServer) Txn 

func (s *KVServer) Txn(ctx context.Context, req *regattapb.TxnRequest) (*regattapb.TxnResponse, error)

Txn processes multiple requests in a single transaction. A txn request increments the revision of the key-value store and generates events with the same revision for every completed request. It is allowed to modify the same key several times within one txn (the result will be the last Op that modified the key).

type KVService 

type KVService interface {
	Range(ctx context.Context, req *regattapb.RangeRequest) (*regattapb.RangeResponse, error)
	Put(ctx context.Context, req *regattapb.PutRequest) (*regattapb.PutResponse, error)
	Delete(ctx context.Context, req *regattapb.DeleteRangeRequest) (*regattapb.DeleteRangeResponse, error)
	Txn(ctx context.Context, req *regattapb.TxnRequest) (*regattapb.TxnResponse, error)
	IterateRange(ctx context.Context, req *regattapb.RangeRequest) (iter.Seq[*regattapb.RangeResponse], error)
}

type LogReaderService 

type LogReaderService interface {
	QueryRaftLog(ctx context.Context, clusterID uint64, logRange raft.LogRange, maxSize uint64) ([]raftpb.Entry, error)
}

type LogServer 

type LogServer struct {
	Tables    TableService
	LogReader LogReaderService
	Log       *zap.SugaredLogger

	regattapb.UnimplementedLogServer
	// contains filtered or unexported fields
}

LogServer implements Log service from proto/replication.proto.

func NewLogServer 

func NewLogServer(ts TableService, lr LogReaderService, logger *zap.Logger, maxMessageSize uint64) *LogServer

func (*LogServer) Replicate 

func (l *LogServer) Replicate(req *regattapb.ReplicateRequest, server regattapb.Log_ReplicateServer) error

Replicate entries from the leader's log.

type MetadataServer 

type MetadataServer struct {
	regattapb.UnimplementedMetadataServer
	Tables TableService
}

MetadataServer implements Metadata service from proto/replication.proto.

func (*MetadataServer) Get 

func (m *MetadataServer) Get(context.Context, *regattapb.MetadataRequest) (*regattapb.MetadataResponse, error)

type RESTServer 

type RESTServer struct {
	// contains filtered or unexported fields
}

RESTServer is server exposing debug/healthcheck/metrics services of Regatta.

func NewRESTServer 

func NewRESTServer(addr string, readTimeout time.Duration) *RESTServer

NewRESTServer returns initialized REST server.

func (*RESTServer) ListenAndServe 

func (s *RESTServer) ListenAndServe() error

ListenAndServe starts underlying HTTP server.

func (*RESTServer) Shutdown 

func (s *RESTServer) Shutdown()

Shutdown stops underlying HTTP server.

type ReadonlyTablesServer 

type ReadonlyTablesServer struct {
	TablesServer
}

func (*ReadonlyTablesServer) Create 

func (t *ReadonlyTablesServer) Create(context.Context, *regattapb.CreateTableRequest) (*regattapb.CreateTableResponse, error)

func (*ReadonlyTablesServer) Delete 

func (t *ReadonlyTablesServer) Delete(context.Context, *regattapb.DeleteTableRequest) (*regattapb.DeleteTableResponse, error)

type RegattaServer 

type RegattaServer struct {
	*grpc.Server
	// contains filtered or unexported fields
}

RegattaServer is server where gRPC services can be registered in.

func NewServer 

func NewServer(l net.Listener, logger *zap.SugaredLogger, opts ...grpc.ServerOption) *RegattaServer

NewServer returns initialized gRPC server.

func (*RegattaServer) Addr 

func (s *RegattaServer) Addr() net.Addr

func (*RegattaServer) Serve 

func (s *RegattaServer) Serve() error

Serve starts underlying gRPC server.

func (*RegattaServer) Shutdown 

func (s *RegattaServer) Shutdown()

Shutdown stops underlying gRPC server.

type ResetServer 

type ResetServer struct {
	regattapb.UnimplementedMaintenanceServer
	Tables   TableService
	AuthFunc func(ctx context.Context) (context.Context, error)
}

ResetServer implements some Maintenance service methods from proto/regatta.proto.

func (*ResetServer) AuthFuncOverride 

func (m *ResetServer) AuthFuncOverride(ctx context.Context, _ string) (context.Context, error)

func (*ResetServer) Reset 

func (m *ResetServer) Reset(ctx context.Context, req *regattapb.ResetRequest) (*regattapb.ResetResponse, error)

type SnapshotServer 

type SnapshotServer struct {
	regattapb.UnimplementedSnapshotServer
	Tables TableService
}

SnapshotServer implements Snapshot service from proto/replication.proto.

func (*SnapshotServer) Stream 

func (s *SnapshotServer) Stream(req *regattapb.SnapshotRequest, srv regattapb.Snapshot_StreamServer) error

type SnapshotService 

type SnapshotService interface {
	Snapshot(ctx context.Context, writer io.Writer) error
}

type TableService 

type TableService interface {
	GetTables() ([]table.Table, error)
	GetTable(name string) (table.ActiveTable, error)
	Restore(name string, reader io.Reader) error
	CreateTable(name string) (table.Table, error)
	DeleteTable(name string) error
}

type TablesServer 

type TablesServer struct {
	regattapb.UnimplementedTablesServer
	Tables   TableService
	AuthFunc func(ctx context.Context) (context.Context, error)
}

func (*TablesServer) AuthFuncOverride 

func (t *TablesServer) AuthFuncOverride(ctx context.Context, _ string) (context.Context, error)

func (*TablesServer) Create 

func (t *TablesServer) Create(ctx context.Context, req *regattapb.CreateTableRequest) (*regattapb.CreateTableResponse, error)

func (*TablesServer) Delete 

func (t *TablesServer) Delete(ctx context.Context, req *regattapb.DeleteTableRequest) (*regattapb.DeleteTableResponse, error)

func (*TablesServer) List 

func (t *TablesServer) List(ctx context.Context, _ *regattapb.ListTablesRequest) (*regattapb.ListTablesResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
encoding
gzip
proto
snappy
zstd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.