adapter

Documentation

Index

• Variables
• type GRPCServer
  • func NewGRPCServer(store store.ScanStore, coordinate *kv.Coordinate) *GRPCServer
  • func (r GRPCServer) Commit(ctx context.Context, req *pb.CommitRequest) (*pb.CommitResponse, error)
  • func (r GRPCServer) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteResponse, error)
  • func (r GRPCServer) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetResponse, error)
  • func (r GRPCServer) PreWrite(ctx context.Context, req *pb.PreWriteRequest) (*pb.PreCommitResponse, error)
  • func (r GRPCServer) Put(ctx context.Context, req *pb.PutRequest) (*pb.PutResponse, error)
  • func (r GRPCServer) RawDelete(ctx context.Context, req *pb.RawDeleteRequest) (*pb.RawDeleteResponse, error)
  • func (r GRPCServer) RawGet(ctx context.Context, req *pb.RawGetRequest) (*pb.RawGetResponse, error)
  • func (r GRPCServer) RawPut(_ context.Context, req *pb.RawPutRequest) (*pb.RawPutResponse, error)
  • func (r GRPCServer) Rollback(ctx context.Context, req *pb.RollbackRequest) (*pb.RollbackResponse, error)
  • func (r GRPCServer) Scan(ctx context.Context, req *pb.ScanRequest) (*pb.ScanResponse, error)
• type Internal
  • func NewInternal(txm kv.Transactional, r *raft.Raft) *Internal
  • func (i *Internal) Forward(_ context.Context, req *pb.ForwardRequest) (*pb.ForwardResponse, error)
• type Node
• type RedisServer
  • func NewRedisServer(listen net.Listener, store store.ScanStore, coordinate *kv.Coordinate) *RedisServer
  • func (r *RedisServer) Run() error
  • func (r *RedisServer) Stop()

Variables

var ErrNotLeader = errors.New("not leader")

Types

type GRPCServer

type GRPCServer struct {
	pb.UnimplementedRawKVServer
	pb.UnimplementedTransactionalKVServer
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(store store.ScanStore, coordinate *kv.Coordinate) *GRPCServer

func (GRPCServer) Commit

func (r GRPCServer) Commit(ctx context.Context, req *pb.CommitRequest) (*pb.CommitResponse, error)

func (GRPCServer) Delete

func (r GRPCServer) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteResponse, error)

func (GRPCServer) Get

func (r GRPCServer) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetResponse, error)

func (GRPCServer) PreWrite

func (r GRPCServer) PreWrite(ctx context.Context, req *pb.PreWriteRequest) (*pb.PreCommitResponse, error)

func (GRPCServer) Put

func (r GRPCServer) Put(ctx context.Context, req *pb.PutRequest) (*pb.PutResponse, error)

func (GRPCServer) RawDelete

func (r GRPCServer) RawDelete(ctx context.Context, req *pb.RawDeleteRequest) (*pb.RawDeleteResponse, error)

func (GRPCServer) RawGet

func (r GRPCServer) RawGet(ctx context.Context, req *pb.RawGetRequest) (*pb.RawGetResponse, error)

func (GRPCServer) RawPut

func (r GRPCServer) RawPut(_ context.Context, req *pb.RawPutRequest) (*pb.RawPutResponse, error)

func (GRPCServer) Rollback

func (r GRPCServer) Rollback(ctx context.Context, req *pb.RollbackRequest) (*pb.RollbackResponse, error)

func (GRPCServer) Scan

func (r GRPCServer) Scan(ctx context.Context, req *pb.ScanRequest) (*pb.ScanResponse, error)

type Internal

type Internal struct {
	pb.UnimplementedInternalServer
	// contains filtered or unexported fields
}

func NewInternal

func NewInternal(txm kv.Transactional, r *raft.Raft) *Internal

func (*Internal) Forward

func (i *Internal) Forward(_ context.Context, req *pb.ForwardRequest) (*pb.ForwardResponse, error)

type Node

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

type RedisServer

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

func NewRedisServer

func NewRedisServer(listen net.Listener, store store.ScanStore, coordinate *kv.Coordinate) *RedisServer

func (*RedisServer) Run

func (r *RedisServer) Run() error

func (*RedisServer) Stop

func (r *RedisServer) Stop()