grpc

package

v1.2.1 Latest Latest Go to latest Published: May 29, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/CeresDB/ceresmeta

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

View Source

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")
)

Functions ¶

This section is empty.

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL