rpc

Documentation

Index

• type CacheRpc
  • func NewServer() *CacheRpc
  • func (c *CacheRpc) AddCache(ctx context.Context, req *proto.AddCacheReq) (*emptypb.Empty, error)
  • func (c *CacheRpc) DeleteCache(ctx context.Context, req *proto.DeleteCacheReq) (*emptypb.Empty, error)
  • func (c *CacheRpc) DropTable(_ context.Context, req *proto.DropTableReq) (*emptypb.Empty, error)
  • func (c *CacheRpc) GetCache(_ context.Context, req *proto.GetCacheReq) (*proto.GetCacheResp, error)
  • func (c *CacheRpc) ListCache(_ context.Context, req *proto.ListCacheReq) (*proto.ListCacheResp, error)
  • func (c *CacheRpc) ListTable(_ context.Context, req *proto.ListTableReq) (*proto.ListTableResp, error)
  • func (c *CacheRpc) RegisterTable(ctx context.Context, req *proto.RegisterTableReq) (*proto.RegisterTableResp, error)

Types

type CacheRpc

type CacheRpc struct {
}

func NewServer

func NewServer() *CacheRpc

func (*CacheRpc) AddCache

func (c *CacheRpc) AddCache(ctx context.Context, req *proto.AddCacheReq) (*emptypb.Empty, error)

func (*CacheRpc) DeleteCache

func (c *CacheRpc) DeleteCache(ctx context.Context, req *proto.DeleteCacheReq) (*emptypb.Empty, error)

func (*CacheRpc) DropTable

func (c *CacheRpc) DropTable(_ context.Context, req *proto.DropTableReq) (*emptypb.Empty, error)

func (*CacheRpc) GetCache

func (c *CacheRpc) GetCache(_ context.Context, req *proto.GetCacheReq) (*proto.GetCacheResp, error)

func (*CacheRpc) ListCache

func (c *CacheRpc) ListCache(_ context.Context, req *proto.ListCacheReq) (*proto.ListCacheResp, error)

func (*CacheRpc) ListTable

func (c *CacheRpc) ListTable(_ context.Context, req *proto.ListTableReq) (*proto.ListTableResp, error)

func (*CacheRpc) RegisterTable

func (c *CacheRpc) RegisterTable(ctx context.Context, req *proto.RegisterTableReq) (*proto.RegisterTableResp, error)

RegisterTable create a table named with user custom define