brain

Documentation

Index

• type Server
  • func New(backend b.Backend, metricCli metrics.Metrics, peerServer service.PeerService) *Server
  • func (s *Server) Compact(ctx context.Context, compactRequest *proto.CompactRequest) (*proto.CompactResponse, error)
  • func (s *Server) Count(ctx context.Context, r *proto.CountRequest) (*proto.CountResponse, error)
  • func (s *Server) Create(ctx context.Context, createRequest *proto.CreateRequest) (*proto.CreateResponse, error)
  • func (s *Server) Delete(ctx context.Context, deleteRequest *proto.DeleteRequest) (*proto.DeleteResponse, error)
  • func (s *Server) Get(ctx context.Context, r *proto.GetRequest) (*proto.GetResponse, error)
  • func (s *Server) ListPartition(ctx context.Context, r *proto.ListPartitionRequest) (*proto.ListPartitionResponse, error)
  • func (s *Server) Range(ctx context.Context, r *proto.RangeRequest) (*proto.RangeResponse, error)
  • func (s *Server) RangeStream(r *proto.RangeRequest, server proto.Read_RangeStreamServer) error
  • func (s *Server) Register(server *grpc.Server)
  • func (s *Server) Update(ctx context.Context, updateRequest *proto.UpdateRequest) (*proto.UpdateResponse, error)
  • func (s *Server) Watch(r *proto.WatchRequest, server proto.Watch_WatchServer) error

Types

type Server

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

Server is the KubeWharf grpc api server

func New

func New(backend b.Backend, metricCli metrics.Metrics, peerServer service.PeerService) *Server

func (*Server) Compact

func (s *Server) Compact(ctx context.Context, compactRequest *proto.CompactRequest) (*proto.CompactResponse, error)

func (*Server) Count

func (s *Server) Count(ctx context.Context, r *proto.CountRequest) (*proto.CountResponse, error)

func (*Server) Create

func (s *Server) Create(ctx context.Context, createRequest *proto.CreateRequest) (*proto.CreateResponse, error)

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, deleteRequest *proto.DeleteRequest) (*proto.DeleteResponse, error)

func (*Server) Get

func (s *Server) Get(ctx context.Context, r *proto.GetRequest) (*proto.GetResponse, error)

func (*Server) ListPartition

func (s *Server) ListPartition(ctx context.Context, r *proto.ListPartitionRequest) (*proto.ListPartitionResponse, error)

func (*Server) Range

func (s *Server) Range(ctx context.Context, r *proto.RangeRequest) (*proto.RangeResponse, error)

func (*Server) RangeStream

func (s *Server) RangeStream(r *proto.RangeRequest, server proto.Read_RangeStreamServer) error

func (*Server) Register

func (s *Server) Register(server *grpc.Server)

Register register kube-wharf rpc protocol server

func (*Server) Update

func (s *Server) Update(ctx context.Context, updateRequest *proto.UpdateRequest) (*proto.UpdateResponse, error)

func (*Server) Watch

func (s *Server) Watch(r *proto.WatchRequest, server proto.Watch_WatchServer) error