service

Documentation

Index

• type GRPCService
  • func NewGrpcService(fsm *fsm.StateMachine, kv KV) *GRPCService
  • func (r *GRPCService) Add(ctx context.Context, req *pb.AddRequest) (*pb.AddResponse, error)
  • func (r *GRPCService) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetResponse, error)
  • func (r *GRPCService) Stat(ctx context.Context, req *pb.StatRequest) (*pb.StatResponse, error)
• type KV

Types

type GRPCService

type GRPCService struct {
	pb.UnimplementedExampleServer
	// contains filtered or unexported fields
}

func NewGrpcService

func NewGrpcService(fsm *fsm.StateMachine, kv KV) *GRPCService

func (*GRPCService) Add

func (r *GRPCService) Add(ctx context.Context, req *pb.AddRequest) (*pb.AddResponse, error)

func (*GRPCService) Get

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

func (*GRPCService) Stat

func (r *GRPCService) Stat(ctx context.Context, req *pb.StatRequest) (*pb.StatResponse, error)

type KV

type KV interface {
	Apply(ctx context.Context, key, val string) (uint64, error)
	Query(ctx context.Context, key []byte, consistent bool) (uint64, []byte, error)
	Stats() (map[string]any, error)
	GetLeader() (bool, raft.ServerAddress, error)
}