grpc

package
v0.0.0-...-963c118 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 21, 2024 License: PostgreSQL Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClientToProto 

func ClientToProto(cl client.ClientInfo) *protos.ClientInfo

TODO : unit tests

func PoolToProto 

func PoolToProto(p pool.Pool, router string) *protos.PoolInfo

TODO : unit tests

func Register 

func Register(server reflection.GRPCServer, qrouter qrouter.QueryRouter, mgr meta.EntityMgr, rr rulerouter.RuleRouter)

func ShardToProto 

func ShardToProto(sh shard.Shardinfo) *protos.BackendConnectionsInfo

TODO : unit tests

Types

type LocalQrouterServer 

type LocalQrouterServer struct {
	protos.UnimplementedKeyRangeServiceServer
	protos.UnimplementedShardingRulesServiceServer
	protos.UnimplementedRouterServiceServer
	protos.UnimplementedTopologyServiceServer
	protos.UnimplementedClientInfoServiceServer
	protos.UnimplementedBackendConnectionsServiceServer
	protos.UnimplementedPoolServiceServer
	protos.UnimplementedDistributionServiceServer
	protos.UnimplementedMoveTasksServiceServer
	protos.UnimplementedShardServiceServer
	protos.UnimplementedBalancerTaskServiceServer
	// contains filtered or unexported fields
}

func (*LocalQrouterServer) AddDataShard 

func (l *LocalQrouterServer) AddDataShard(ctx context.Context, request *protos.AddShardRequest) (*emptypb.Empty, error)

func (*LocalQrouterServer) AddShardingRules 

func (l *LocalQrouterServer) AddShardingRules(ctx context.Context, request *protos.AddShardingRuleRequest) (*emptypb.Empty, error)

TODO : unit tests

func (*LocalQrouterServer) AddWorldShard 

func (l *LocalQrouterServer) AddWorldShard(ctx context.Context, request *protos.AddWorldShardRequest) (*emptypb.Empty, error)

func (*LocalQrouterServer) AlterDistributionAttach 

func (l *LocalQrouterServer) AlterDistributionAttach(ctx context.Context, request *protos.AlterDistributionAttachRequest) (*emptypb.Empty, error)

AlterDistributionAttach attaches relation to distribution TODO: unit tests

func (*LocalQrouterServer) AlterDistributionDetach 

func (l *LocalQrouterServer) AlterDistributionDetach(ctx context.Context, request *protos.AlterDistributionDetachRequest) (*emptypb.Empty, error)

AlterDistributionDetach detaches relation from distribution TODO: unit tests

func (*LocalQrouterServer) CloseRouter 

func (l *LocalQrouterServer) CloseRouter(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

TODO : implement, unit tests

func (*LocalQrouterServer) CreateDistribution 

func (l *LocalQrouterServer) CreateDistribution(ctx context.Context, request *protos.CreateDistributionRequest) (*emptypb.Empty, error)

CreateDistribution creates distribution in QDB TODO: unit tests

func (*LocalQrouterServer) CreateKeyRange 

func (l *LocalQrouterServer) CreateKeyRange(ctx context.Context, request *protos.CreateKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*LocalQrouterServer) DropAllKeyRanges 

func (l *LocalQrouterServer) DropAllKeyRanges(ctx context.Context, _ *emptypb.Empty) (*protos.DropAllKeyRangesResponse, error)

TODO : unit tests

func (*LocalQrouterServer) DropDistribution 

func (l *LocalQrouterServer) DropDistribution(ctx context.Context, request *protos.DropDistributionRequest) (*emptypb.Empty, error)

DropDistribution deletes distribution from QDB TODO: unit tests

func (*LocalQrouterServer) DropKeyRange 

func (l *LocalQrouterServer) DropKeyRange(ctx context.Context, request *protos.DropKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*LocalQrouterServer) DropShardingRules 

func (l *LocalQrouterServer) DropShardingRules(ctx context.Context, request *protos.DropShardingRuleRequest) (*emptypb.Empty, error)

TODO : unit tests

func (*LocalQrouterServer) GetBalancerTask 

func (l *LocalQrouterServer) GetBalancerTask(ctx context.Context, _ *emptypb.Empty) (*protos.GetBalancerTaskReply, error)

TODO: unit tests

func (*LocalQrouterServer) GetCoordinator 

func (l *LocalQrouterServer) GetCoordinator(ctx context.Context, _ *emptypb.Empty) (*protos.GetCoordinatorResponse, error)

func (*LocalQrouterServer) GetDistribution 

func (l *LocalQrouterServer) GetDistribution(ctx context.Context, request *protos.GetDistributionRequest) (*protos.GetDistributionReply, error)

GetDistribution retrieves info about distribution from QDB TODO: unit tests

func (*LocalQrouterServer) GetKeyRange 

func (l *LocalQrouterServer) GetKeyRange(ctx context.Context, request *protos.GetKeyRangeRequest) (*protos.KeyRangeReply, error)

GetKeyRange gets key ranges with given ids TODO unit tests

func (*LocalQrouterServer) GetMoveTaskGroup 

func (l *LocalQrouterServer) GetMoveTaskGroup(ctx context.Context, _ *emptypb.Empty) (*protos.GetMoveTaskGroupReply, error)

TODO: unit tests

func (*LocalQrouterServer) GetRelationDistribution 

func (l *LocalQrouterServer) GetRelationDistribution(ctx context.Context, request *protos.GetRelationDistributionRequest) (*protos.GetRelationDistributionReply, error)

GetRelationDistribution retrieves info about distribution attached to relation from QDB TODO: unit tests

func (*LocalQrouterServer) GetRouterStatus 

func (l *LocalQrouterServer) GetRouterStatus(ctx context.Context, _ *emptypb.Empty) (*protos.GetRouterStatusReply, error)

TODO : unit tests

func (*LocalQrouterServer) GetShard 

func (l *LocalQrouterServer) GetShard(ctx context.Context, request *protos.ShardRequest) (*protos.ShardReply, error)

func (*LocalQrouterServer) ListAllKeyRanges 

func (l *LocalQrouterServer) ListAllKeyRanges(ctx context.Context, _ *emptypb.Empty) (*protos.KeyRangeReply, error)

TODO : unit tests

func (*LocalQrouterServer) ListBackendConnections 

func (l *LocalQrouterServer) ListBackendConnections(context.Context, *emptypb.Empty) (*protos.ListBackendConntionsReply, error)

TODO : unit tests

func (*LocalQrouterServer) ListClients 

func (l *LocalQrouterServer) ListClients(context.Context, *emptypb.Empty) (*protos.ListClientsReply, error)

TODO : unit tests

func (*LocalQrouterServer) ListDistributions 

func (l *LocalQrouterServer) ListDistributions(ctx context.Context, _ *emptypb.Empty) (*protos.ListDistributionsReply, error)

ListDistributions returns all distributions from QDB TODO: unit tests

func (*LocalQrouterServer) ListKeyRange 

func (l *LocalQrouterServer) ListKeyRange(ctx context.Context, request *protos.ListKeyRangeRequest) (*protos.KeyRangeReply, error)

TODO : unit tests

func (*LocalQrouterServer) ListPools 

func (l *LocalQrouterServer) ListPools(context.Context, *emptypb.Empty) (*protos.ListPoolsResponse, error)

TODO : unit tests

func (*LocalQrouterServer) ListShardingRules 

func (l *LocalQrouterServer) ListShardingRules(ctx context.Context, request *protos.ListShardingRuleRequest) (*protos.ListShardingRuleReply, error)

TODO : unit tests

func (*LocalQrouterServer) ListShards 

func (l *LocalQrouterServer) ListShards(ctx context.Context, _ *emptypb.Empty) (*protos.ListShardsReply, error)

func (*LocalQrouterServer) LockKeyRange 

func (l *LocalQrouterServer) LockKeyRange(ctx context.Context, request *protos.LockKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*LocalQrouterServer) MergeKeyRange 

func (l *LocalQrouterServer) MergeKeyRange(ctx context.Context, request *protos.MergeKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*LocalQrouterServer) MoveKeyRange 

func (l *LocalQrouterServer) MoveKeyRange(ctx context.Context, request *protos.MoveKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*LocalQrouterServer) OpenRouter 

func (l *LocalQrouterServer) OpenRouter(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

TODO : unit tests

func (*LocalQrouterServer) RemoveBalancerTask 

func (l *LocalQrouterServer) RemoveBalancerTask(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

TODO: unit tests

func (*LocalQrouterServer) RemoveMoveTaskGroup 

func (l *LocalQrouterServer) RemoveMoveTaskGroup(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

TODO: unit tests

func (*LocalQrouterServer) RenameKeyRange 

func (l *LocalQrouterServer) RenameKeyRange(ctx context.Context, request *protos.RenameKeyRangeRequest) (*emptypb.Empty, error)

TODO: unit tests

func (*LocalQrouterServer) SplitKeyRange 

func (l *LocalQrouterServer) SplitKeyRange(ctx context.Context, request *protos.SplitKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*LocalQrouterServer) UnlockKeyRange 

func (l *LocalQrouterServer) UnlockKeyRange(ctx context.Context, request *protos.UnlockKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*LocalQrouterServer) UpdateCoordinator 

func (l *LocalQrouterServer) UpdateCoordinator(ctx context.Context, req *protos.UpdateCoordinatorRequest) (*emptypb.Empty, error)

TODO : unit tests

func (*LocalQrouterServer) WriteBalancerTask 

func (l *LocalQrouterServer) WriteBalancerTask(ctx context.Context, request *protos.WriteBalancerTaskRequest) (*emptypb.Empty, error)

TODO: unit tests

func (*LocalQrouterServer) WriteMoveTaskGroup 

func (l *LocalQrouterServer) WriteMoveTaskGroup(ctx context.Context, request *protos.WriteMoveTaskGroupRequest) (*emptypb.Empty, error)

TODO: unit tests

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.