grpcservice

package

v0.3.0 Latest Latest Go to latest Published: Aug 29, 2022 License: Apache-2.0 Imports: 15 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 HeartbeatStreamSender
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")
	ErrParseURL              = coderr.NewCodeError(coderr.Internal, "parse url")
	ErrGRPCDial              = coderr.NewCodeError(coderr.Internal, "grpc dial")
	ErrForward               = coderr.NewCodeError(coderr.Internal, "grpc forward")
)

Functions ¶

This section is empty.

Types ¶

type Handler ¶

type Handler interface {
	GetClusterManager() cluster.Manager
	GetLeader(ctx context.Context) (*member.GetLeaderResp, error)
	UnbindHeartbeatStream(ctx context.Context, node string) error
	BindHeartbeatStream(ctx context.Context, node string, sender HeartbeatStreamSender) error
	ProcessHeartbeat(ctx context.Context, req *metaservicepb.NodeHeartbeatRequest) error
}

Handler is needed by grpc service to process the requests.

type HeartbeatStreamSender ¶

type HeartbeatStreamSender interface {
	Send(response *metaservicepb.NodeHeartbeatResponse) error
}

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) AllocTableID ¶

func (s *Service) AllocTableID(ctx context.Context, req *metaservicepb.AllocTableIdRequest) (*metaservicepb.AllocTableIdResponse, error)

AllocTableID 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) GetShardTables ¶

func (s *Service) GetShardTables(ctx context.Context, req *metaservicepb.GetShardTablesRequest) (*metaservicepb.GetShardTablesResponse, error)

GetShardTables implements gRPC CeresmetaServer.

func (*Service) NodeHeartbeat ¶

func (s *Service) NodeHeartbeat(heartbeatSrv metaservicepb.CeresmetaRpcService_NodeHeartbeatServer) 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