regattaserver

Apr 5, 2024

Changes in this version

type BackupServer

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

+ type ForwardingKVServer struct

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

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

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

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

+ type ReadonlyTablesServer struct

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

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

type ResetServer

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

type TableService

+ CreateTable func(name string) (table.Table, error)

+ DeleteTable func(name string) error

+ type TablesServer struct

+ AuthFunc func(ctx context.Context) (context.Context, error)

+ Tables TableService

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

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

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

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

Jan 5, 2024

Changes in this version

type BackupServer

+ AuthFunc func(ctx context.Context) (context.Context, error)

type ClusterServer

+ Config ConfigService

+ type ConfigService func() map[string]any

type KVServer

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

type KVService

+ IterateRange func(ctx context.Context, req *regattapb.RangeRequest) (iter.Seq[*regattapb.RangeResponse], error)

type ResetServer

+ AuthFunc func(ctx context.Context) (context.Context, error)

Nov 30, 2023

Changes in this version

+ type ClusterServer struct

+ Cluster ClusterService

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

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

+ type ClusterService interface

+ MemberList func(context.Context, *regattapb.MemberListRequest) (*regattapb.MemberListResponse, error)

+ Status func(context.Context, *regattapb.StatusRequest) (*regattapb.StatusResponse, error)

Nov 22, 2022

Changes in this version

+ const DefaultCacheSize

+ const DefaultMaxGRPCSize

+ const Name

+ type BackupServer struct

+ Tables TableService

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

+ func (m *BackupServer) Restore(srv proto.Maintenance_RestoreServer) error

+ type Codec struct

+ func (Codec) Marshal(v interface{}) ([]byte, error)

+ func (Codec) Name() string

+ func (Codec) Unmarshal(data []byte, v interface{}) error

+ type KVServer struct

+ Storage KVService

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

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

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

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

+ type KVService interface

+ Delete func(ctx context.Context, req *proto.DeleteRangeRequest) (*proto.DeleteRangeResponse, error)

+ Put func(ctx context.Context, req *proto.PutRequest) (*proto.PutResponse, error)

+ Range func(ctx context.Context, req *proto.RangeRequest) (*proto.RangeResponse, error)

+ Txn func(ctx context.Context, req *proto.TxnRequest) (*proto.TxnResponse, error)

+ type LogReaderService interface

+ QueryRaftLog func(ctx context.Context, clusterID uint64, logRange dragonboat.LogRange, ...) ([]raftpb.Entry, error)

+ type LogServer struct

+ Log *zap.SugaredLogger

+ LogReader LogReaderService

+ Tables TableService

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

+ func (l *LogServer) Collect(ch chan<- prometheus.Metric)

+ func (l *LogServer) Describe(ch chan<- *prometheus.Desc)

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

+ type MetadataServer struct

+ Tables TableService

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

+ type RESTServer struct

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

+ func (s *RESTServer) ListenAndServe() error

+ func (s *RESTServer) Shutdown()

+ type ReadonlyKVServer struct

+ func (r *ReadonlyKVServer) DeleteRange(_ context.Context, _ *proto.DeleteRangeRequest) (*proto.DeleteRangeResponse, error)

+ func (r *ReadonlyKVServer) Put(_ context.Context, _ *proto.PutRequest) (*proto.PutResponse, error)

+ func (r *ReadonlyKVServer) Txn(ctx context.Context, req *proto.TxnRequest) (*proto.TxnResponse, error)

+ type RegattaServer struct

+ Addr string

+ func NewServer(addr string, reflectionAPI bool, opts ...grpc.ServerOption) *RegattaServer

+ func (s *RegattaServer) ListenAndServe() error

+ func (s *RegattaServer) RegisterService(desc *grpc.ServiceDesc, impl interface{})

+ func (s *RegattaServer) Shutdown()

+ type ResetServer struct

+ Tables TableService

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

+ type SnapshotServer struct

+ Tables TableService

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

+ type SnapshotService interface

+ Snapshot func(ctx context.Context, writer io.Writer) error

+ type TableService interface

+ GetTable func(name string) (table.ActiveTable, error)

+ GetTables func() ([]table.Table, error)

+ Restore func(name string, reader io.Reader) error