grpc

Documentation

Index

• Variables
• type Handler
• type Service
  • func NewService(opTimeout time.Duration, h Handler) *Service
  • func (s *Service) AllocSchemaID(ctx context.Context, req *metaservicepb.AllocSchemaIdRequest) (*metaservicepb.AllocSchemaIdResponse, error)
  • func (s *Service) CreateTable(ctx context.Context, req *metaservicepb.CreateTableRequest) (*metaservicepb.CreateTableResponse, error)
  • func (s *Service) DropTable(ctx context.Context, req *metaservicepb.DropTableRequest) (*metaservicepb.DropTableResponse, error)
  • func (s *Service) GetNodes(ctx context.Context, req *metaservicepb.GetNodesRequest) (*metaservicepb.GetNodesResponse, error)
  • func (s *Service) GetTablesOfShards(ctx context.Context, req *metaservicepb.GetTablesOfShardsRequest) (*metaservicepb.GetTablesOfShardsResponse, error)
  • func (s *Service) NodeHeartbeat(ctx context.Context, req *metaservicepb.NodeHeartbeatRequest) (*metaservicepb.NodeHeartbeatResponse, error)
  • func (s *Service) RouteTables(ctx context.Context, req *metaservicepb.RouteTablesRequest) (*metaservicepb.RouteTablesResponse, error)

Variables

var (
	ErrRecvHeartbeat         = coderr.NewCodeError(coderr.Internal, "receive heartbeat")
	ErrBindHeartbeatStream   = coderr.NewCodeError(coderr.Internal, "bind heartbeat sender")
	ErrUnbindHeartbeatStream = coderr.NewCodeError(coderr.Internal, "unbind heartbeat sender")
	ErrForward               = coderr.NewCodeError(coderr.Internal, "grpc forward")
	ErrFlowLimit             = coderr.NewCodeError(coderr.TooManyRequests, "flow limit")
)

Types

type Handler

type Handler interface {
	GetClusterManager() cluster.Manager
	GetLeader(ctx context.Context) (member.GetLeaderAddrResp, error)
	GetFlowLimiter() (*limiter.FlowLimiter, error)
}

Handler is needed by grpc service to process the requests.

type Service

type Service struct {
	metaservicepb.UnimplementedCeresmetaRpcServiceServer
	// contains filtered or unexported fields
}

func NewService

func NewService(opTimeout time.Duration, h Handler) *Service

func (*Service) AllocSchemaID

func (s *Service) AllocSchemaID(ctx context.Context, req *metaservicepb.AllocSchemaIdRequest) (*metaservicepb.AllocSchemaIdResponse, error)

AllocSchemaID implements gRPC CeresmetaServer.

func (*Service) CreateTable

func (s *Service) CreateTable(ctx context.Context, req *metaservicepb.CreateTableRequest) (*metaservicepb.CreateTableResponse, error)

CreateTable implements gRPC CeresmetaServer.

func (*Service) DropTable

func (s *Service) DropTable(ctx context.Context, req *metaservicepb.DropTableRequest) (*metaservicepb.DropTableResponse, error)

DropTable implements gRPC CeresmetaServer.

func (*Service) GetNodes

func (s *Service) GetNodes(ctx context.Context, req *metaservicepb.GetNodesRequest) (*metaservicepb.GetNodesResponse, error)

GetNodes implements gRPC CeresmetaServer.

func (*Service) GetTablesOfShards

func (s *Service) GetTablesOfShards(ctx context.Context, req *metaservicepb.GetTablesOfShardsRequest) (*metaservicepb.GetTablesOfShardsResponse, error)

GetTablesOfShards implements gRPC CeresmetaServer.

func (*Service) NodeHeartbeat

func (s *Service) NodeHeartbeat(ctx context.Context, req *metaservicepb.NodeHeartbeatRequest) (*metaservicepb.NodeHeartbeatResponse, error)

NodeHeartbeat implements gRPC CeresmetaServer.

func (*Service) RouteTables

func (s *Service) RouteTables(ctx context.Context, req *metaservicepb.RouteTablesRequest) (*metaservicepb.RouteTablesResponse, error)

RouteTables implements gRPC CeresmetaServer.