provider

package
v0.0.0-...-08d0b3e Latest Latest
Warning

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

 Go to latest Published: May 31, 2024 License: PostgreSQL Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DialRouter 

func DialRouter(r *topology.Router) (*grpc.ClientConn, error)

func NewCoordShardInfo 

func NewCoordShardInfo(conn *routerproto.BackendConnectionsInfo, router string) shard.Shardinfo

func NewCoordinator 

func NewCoordinator(tlsconfig *tls.Config, db qdb.XQDB) *qdbCoordinator

func NewKeyRangeService 

func NewKeyRangeService(impl coordinator.Coordinator) protos.KeyRangeServiceServer

Types

type CoordPool 

type CoordPool struct {
	pool.ConnectionKepperData
}

func NewCoordPool 

func NewCoordPool(info *protos.PoolInfo) *CoordPool

func (*CoordPool) Connection 

func (r *CoordPool) Connection(clid uint, shardKey kr.ShardKey) (shard.Shard, error)

TODO : unit tests TODO : implement

func (*CoordPool) ForEach 

func (r *CoordPool) ForEach(cb func(p shard.Shardinfo) error) error

TODO : unit tests TODO : implement

type CoordShardInfo 

type CoordShardInfo struct {
	// contains filtered or unexported fields
}

func (*CoordShardInfo) DB 

func (c *CoordShardInfo) DB() string

func (*CoordShardInfo) ID 

func (c *CoordShardInfo) ID() uint

func (*CoordShardInfo) InstanceHostname 

func (c *CoordShardInfo) InstanceHostname() string

func (*CoordShardInfo) ListPreparedStatements 

func (c *CoordShardInfo) ListPreparedStatements() []shard.PreparedStatementsMgrDescriptor

ListPreparedStatements implements shard.Shardinfo.

func (*CoordShardInfo) Pid 

func (c *CoordShardInfo) Pid() uint32

Pid implements shard.Shardinfo.

func (*CoordShardInfo) Router 

func (c *CoordShardInfo) Router() string

func (*CoordShardInfo) ShardKeyName 

func (c *CoordShardInfo) ShardKeyName() string

func (*CoordShardInfo) Sync 

func (c *CoordShardInfo) Sync() int64

func (*CoordShardInfo) TxServed 

func (c *CoordShardInfo) TxServed() int64

func (*CoordShardInfo) TxStatus 

func (c *CoordShardInfo) TxStatus() txstatus.TXStatus

func (*CoordShardInfo) Usr 

func (c *CoordShardInfo) Usr() string

type CoordinatorClient 

type CoordinatorClient interface {
	client.Client

	CancelMsg() *pgproto3.CancelRequest
}

type CoordinatorService 

type CoordinatorService struct {
	protos.UnimplementedKeyRangeServiceServer
	// contains filtered or unexported fields
}

func (*CoordinatorService) CreateKeyRange 

func (c *CoordinatorService) CreateKeyRange(ctx context.Context, request *protos.CreateKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*CoordinatorService) DropAllKeyRanges 

func (c *CoordinatorService) DropAllKeyRanges(ctx context.Context, request *protos.DropAllKeyRangesRequest) (*protos.DropAllKeyRangesResponse, error)

DropAllKeyRanges implements proto.KeyRangeServiceServer.

func (*CoordinatorService) DropKeyRange 

func (c *CoordinatorService) DropKeyRange(ctx context.Context, request *protos.DropKeyRangeRequest) (*protos.ModifyReply, error)

DropKeyRange implements proto.KeyRangeServiceServer.

func (*CoordinatorService) GetKeyRange 

func (c *CoordinatorService) GetKeyRange(ctx context.Context, request *protos.GetKeyRangeRequest) (*protos.KeyRangeReply, error)

GetKeyRange gets key ranges with given ids TODO unit tests

func (*CoordinatorService) ListAllKeyRanges 

func (c *CoordinatorService) ListAllKeyRanges(ctx context.Context, _ *protos.ListAllKeyRangesRequest) (*protos.KeyRangeReply, error)

func (*CoordinatorService) ListKeyRange 

func (c *CoordinatorService) ListKeyRange(ctx context.Context, request *protos.ListKeyRangeRequest) (*protos.KeyRangeReply, error)

TODO : unit tests

func (*CoordinatorService) LockKeyRange 

func (c *CoordinatorService) LockKeyRange(ctx context.Context, request *protos.LockKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*CoordinatorService) MergeKeyRange 

func (c *CoordinatorService) MergeKeyRange(ctx context.Context, request *protos.MergeKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*CoordinatorService) MoveKeyRange 

func (c *CoordinatorService) MoveKeyRange(ctx context.Context, request *protos.MoveKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*CoordinatorService) SplitKeyRange 

func (c *CoordinatorService) SplitKeyRange(ctx context.Context, request *protos.SplitKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

func (*CoordinatorService) UnlockKeyRange 

func (c *CoordinatorService) UnlockKeyRange(ctx context.Context, request *protos.UnlockKeyRangeRequest) (*protos.ModifyReply, error)

TODO : unit tests

type DistributionsServer 

type DistributionsServer struct {
	protos.UnimplementedDistributionServiceServer
	// contains filtered or unexported fields
}

func NewDistributionServer 

func NewDistributionServer(impl coordinator.Coordinator) *DistributionsServer

func (*DistributionsServer) AlterDistributionAttach 

func (d *DistributionsServer) AlterDistributionAttach(ctx context.Context, req *protos.AlterDistributionAttachRequest) (*protos.AlterDistributionAttachReply, error)

func (*DistributionsServer) AlterDistributionDetach 

func (d *DistributionsServer) AlterDistributionDetach(ctx context.Context, req *protos.AlterDistributionDetachRequest) (*protos.AlterDistributionDetachReply, error)

func (*DistributionsServer) CreateDistribution 

func (d *DistributionsServer) CreateDistribution(ctx context.Context, req *protos.CreateDistributionRequest) (*protos.CreateDistributionReply, error)

func (*DistributionsServer) DropDistribution 

func (d *DistributionsServer) DropDistribution(ctx context.Context, req *protos.DropDistributionRequest) (*protos.DropDistributionReply, error)

func (*DistributionsServer) GetDistribution 

func (d *DistributionsServer) GetDistribution(ctx context.Context, req *protos.GetDistributionRequest) (*protos.GetDistributionReply, error)

func (*DistributionsServer) GetRelationDistribution 

func (d *DistributionsServer) GetRelationDistribution(ctx context.Context, req *protos.GetRelationDistributionRequest) (*protos.GetRelationDistributionReply, error)

func (*DistributionsServer) ListDistributions 

func (d *DistributionsServer) ListDistributions(ctx context.Context, req *protos.ListDistributionsRequest) (*protos.ListDistributionsReply, error)

type RouterService 

type RouterService struct {
	protos.UnimplementedRouterServiceServer
	// contains filtered or unexported fields
}

func NewRouterService 

func NewRouterService(impl coordinator.Coordinator) *RouterService

func (RouterService) AddRouter 

func (r RouterService) AddRouter(ctx context.Context, request *protos.AddRouterRequest) (*protos.AddRouterReply, error)

TODO : unit tests

func (RouterService) ListRouters 

func (r RouterService) ListRouters(ctx context.Context, request *protos.ListRoutersRequest) (*protos.ListRoutersReply, error)

TODO : unit tests

func (RouterService) RemoveRouter 

func (r RouterService) RemoveRouter(ctx context.Context, request *protos.RemoveRouterRequest) (*protos.RemoveRouterReply, error)

TODO : unit tests

func (RouterService) SyncMetadata 

func (r RouterService) SyncMetadata(ctx context.Context, request *protos.SyncMetadataRequest) (*protos.SyncMetadataReply, error)

TODO : unit tests

type ShardServer 

type ShardServer struct {
	protos.UnimplementedShardServiceServer
	// contains filtered or unexported fields
}

func NewShardServer 

func NewShardServer(impl coordinator.Coordinator) *ShardServer

func (*ShardServer) AddDataShard 

func (s *ShardServer) AddDataShard(ctx context.Context, request *protos.AddShardRequest) (*protos.AddShardReply, error)

TODO : unit tests

func (*ShardServer) AddWorldShard 

func (s *ShardServer) AddWorldShard(ctx context.Context, request *protos.AddWorldShardRequest) (*protos.AddShardReply, error)

func (*ShardServer) GetShard 

func (s *ShardServer) GetShard(ctx context.Context, shardRequest *protos.ShardRequest) (*protos.ShardReply, error)

TODO : unit tests

func (*ShardServer) ListShards 

func (s *ShardServer) ListShards(ctx context.Context, _ *protos.ListShardsRequest) (*protos.ListShardsReply, error)

TODO : unit tests TODO: remove ShardRequest.

type TasksServer 

type TasksServer struct {
	protos.UnimplementedTasksServiceServer
	// contains filtered or unexported fields
}

func NewTasksServer 

func NewTasksServer(impl coordinator.Coordinator) *TasksServer

func (TasksServer) GetTaskGroup 

func (t TasksServer) GetTaskGroup(ctx context.Context, _ *protos.GetTaskGroupRequest) (*protos.GetTaskGroupReply, error)

func (TasksServer) RemoveTaskGroup 

func (t TasksServer) RemoveTaskGroup(ctx context.Context, _ *protos.RemoveTaskGroupRequest) (*protos.RemoveTaskGroupReply, error)

func (TasksServer) WriteTaskGroup 

func (t TasksServer) WriteTaskGroup(ctx context.Context, request *protos.WriteTaskGroupRequest) (*protos.WriteTaskGroupReply, error)

type TopologyService 

type TopologyService struct {
	protos.UnimplementedTopologyServiceServer
	// contains filtered or unexported fields
}

func NewTopologyService 

func NewTopologyService(impl coordinator.Coordinator) *TopologyService

func (*TopologyService) CloseRouter 

func (r *TopologyService) CloseRouter(ctx context.Context, request *protos.CloseRouterRequest) (*protos.CloseRouterReply, error)

TODO : implement

func (*TopologyService) OpenRouter 

func (r *TopologyService) OpenRouter(ctx context.Context, request *protos.OpenRouterRequest) (*protos.OpenRouterReply, error)

TODO : implement

func (*TopologyService) UpdateCoordinator 

func (r *TopologyService) UpdateCoordinator(ctx context.Context, in *protos.UpdateCoordinatorRequest) (*protos.UpdateCoordinatorResponse, error)

TODO : implement

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.