server

package

v0.0.34 Latest Latest Go to latest Published: Jun 24, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Server struct {
	cachepb.UnimplementedCacheServer
	// contains filtered or unexported fields
}

func NewServer(ctx context.Context, cfg *config.Config) (*Server, error)

func (s *Server) Clone(ctx context.Context, req *cachepb.CloneRequest) (*cachepb.CloneResponse, error)

func (s *Server) Commit(ctx context.Context, req *cachepb.CommitRequest) (*cachepb.CommitResponse, error)

func (s *Server) Create(ctx context.Context, req *cachepb.CreateRequest) (*cachepb.CreateResponse, error)

func (s *Server) CreateCandidate(ctx context.Context, req *cachepb.CreateCandidateRequest) (*cachepb.CreateCandidateResponse, error)

func (s *Server) Delete(ctx context.Context, req *cachepb.DeleteRequest) (*cachepb.DeleteResponse, error)

func (s *Server) Discard(ctx context.Context, req *cachepb.DiscardRequest) (*cachepb.DiscardResponse, error)

func (s *Server) Exists(ctx context.Context, req *cachepb.ExistsRequest) (*cachepb.ExistsResponse, error)

func (s *Server) Get(ctx context.Context, req *cachepb.GetRequest) (*cachepb.GetResponse, error)

func (s *Server) GetChanges(req *cachepb.GetChangesRequest, stream cachepb.Cache_GetChangesServer) error

func (s *Server) List(ctx context.Context, req *cachepb.ListRequest) (*cachepb.ListResponse, error)

func (s *Server) Modify(stream cachepb.Cache_ModifyServer) error

func (s *Server) Prune(ctx context.Context, req *cachepb.PruneRequest) (*cachepb.PruneResponse, error)

func (s *Server) Read(req *cachepb.ReadRequest, stream cachepb.Cache_ReadServer) error

func (s *Server) ServeHTTP()

func (s *Server) Start(ctx context.Context) error

func (s *Server) Stop()

func (s *Server) Watch(req *cachepb.WatchRequest, stream cachepb.Cache_WatchServer) error