Documentation ¶
Index ¶
- type Server
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
type Server struct { cachepb.UnimplementedCacheServer // contains filtered or unexported fields }
func (*Server) Clone ¶
func (s *Server) Clone(ctx context.Context, req *cachepb.CloneRequest) (*cachepb.CloneResponse, error)
func (*Server) Commit ¶
func (s *Server) Commit(ctx context.Context, req *cachepb.CommitRequest) (*cachepb.CommitResponse, error)
func (*Server) Create ¶
func (s *Server) Create(ctx context.Context, req *cachepb.CreateRequest) (*cachepb.CreateResponse, error)
func (*Server) CreateCandidate ¶
func (s *Server) CreateCandidate(ctx context.Context, req *cachepb.CreateCandidateRequest) (*cachepb.CreateCandidateResponse, error)
func (*Server) Delete ¶
func (s *Server) Delete(ctx context.Context, req *cachepb.DeleteRequest) (*cachepb.DeleteResponse, error)
func (*Server) Discard ¶
func (s *Server) Discard(ctx context.Context, req *cachepb.DiscardRequest) (*cachepb.DiscardResponse, error)
func (*Server) Exists ¶
func (s *Server) Exists(ctx context.Context, req *cachepb.ExistsRequest) (*cachepb.ExistsResponse, error)
func (*Server) Get ¶
func (s *Server) Get(ctx context.Context, req *cachepb.GetRequest) (*cachepb.GetResponse, error)
func (*Server) GetChanges ¶
func (s *Server) GetChanges(req *cachepb.GetChangesRequest, stream cachepb.Cache_GetChangesServer) error
func (*Server) List ¶
func (s *Server) List(ctx context.Context, req *cachepb.ListRequest) (*cachepb.ListResponse, error)
func (*Server) Prune ¶
func (s *Server) Prune(ctx context.Context, req *cachepb.PruneRequest) (*cachepb.PruneResponse, error)
func (*Server) Read ¶
func (s *Server) Read(req *cachepb.ReadRequest, stream cachepb.Cache_ReadServer) error
func (*Server) Watch ¶
func (s *Server) Watch(req *cachepb.WatchRequest, stream cachepb.Cache_WatchServer) error
Click to show internal directories.
Click to hide internal directories.