service

Documentation

Index

• type ReplicationService
  • func New(cluster membership.Cluster, logger kitlog.Logger) *ReplicationService
  • func (s *ReplicationService) Delete(ctx context.Context, req *proto.DeleteRequest) (*proto.DeleteResponse, error)
  • func (s *ReplicationService) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error)
  • func (s *ReplicationService) Put(ctx context.Context, req *proto.PutRequest) (*proto.PutResponse, error)
  • func (s *ReplicationService) RegisterGet(ctx context.Context, req *proto.RegisterGetRequest) (*proto.RegisterGetResponse, error)
  • func (s *ReplicationService) RegisterPut(ctx context.Context, req *proto.RegisterPutRequest) (*proto.RegisterPutResponse, error)

Types

type ReplicationService

type ReplicationService struct {
	proto.UnimplementedReplicationServer
	// contains filtered or unexported fields
}

func New

func New(cluster membership.Cluster, logger kitlog.Logger) *ReplicationService

func (*ReplicationService) Delete

func (s *ReplicationService) Delete(ctx context.Context, req *proto.DeleteRequest) (*proto.DeleteResponse, error)

func (*ReplicationService) Get

func (s *ReplicationService) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error)

func (*ReplicationService) Put

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

func (*ReplicationService) RegisterGet

func (s *ReplicationService) RegisterGet(ctx context.Context, req *proto.RegisterGetRequest) (*proto.RegisterGetResponse, error)

func (*ReplicationService) RegisterPut

func (s *ReplicationService) RegisterPut(ctx context.Context, req *proto.RegisterPutRequest) (*proto.RegisterPutResponse, error)