proto

package
v0.0.0-...-096c525 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: PostgreSQL Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TopologyService_OpenRouter_FullMethodName        = "/spqr.TopologyService/OpenRouter"
	TopologyService_GetRouterStatus_FullMethodName   = "/spqr.TopologyService/GetRouterStatus"
	TopologyService_CloseRouter_FullMethodName       = "/spqr.TopologyService/CloseRouter"
	TopologyService_UpdateCoordinator_FullMethodName = "/spqr.TopologyService/UpdateCoordinator"
	TopologyService_GetCoordinator_FullMethodName    = "/spqr.TopologyService/GetCoordinator"
)
View Source 
const (
	DistributionService_CreateDistribution_FullMethodName      = "/spqr.DistributionService/CreateDistribution"
	DistributionService_DropDistribution_FullMethodName        = "/spqr.DistributionService/DropDistribution"
	DistributionService_ListDistributions_FullMethodName       = "/spqr.DistributionService/ListDistributions"
	DistributionService_AlterDistributionAttach_FullMethodName = "/spqr.DistributionService/AlterDistributionAttach"
	DistributionService_AlterDistributionDetach_FullMethodName = "/spqr.DistributionService/AlterDistributionDetach"
	DistributionService_GetDistribution_FullMethodName         = "/spqr.DistributionService/GetDistribution"
	DistributionService_GetRelationDistribution_FullMethodName = "/spqr.DistributionService/GetRelationDistribution"
)
View Source 
const (
	KeyRangeService_GetKeyRange_FullMethodName          = "/spqr.KeyRangeService/GetKeyRange"
	KeyRangeService_ListKeyRange_FullMethodName         = "/spqr.KeyRangeService/ListKeyRange"
	KeyRangeService_ListAllKeyRanges_FullMethodName     = "/spqr.KeyRangeService/ListAllKeyRanges"
	KeyRangeService_LockKeyRange_FullMethodName         = "/spqr.KeyRangeService/LockKeyRange"
	KeyRangeService_CreateKeyRange_FullMethodName       = "/spqr.KeyRangeService/CreateKeyRange"
	KeyRangeService_DropKeyRange_FullMethodName         = "/spqr.KeyRangeService/DropKeyRange"
	KeyRangeService_DropAllKeyRanges_FullMethodName     = "/spqr.KeyRangeService/DropAllKeyRanges"
	KeyRangeService_UnlockKeyRange_FullMethodName       = "/spqr.KeyRangeService/UnlockKeyRange"
	KeyRangeService_SplitKeyRange_FullMethodName        = "/spqr.KeyRangeService/SplitKeyRange"
	KeyRangeService_MergeKeyRange_FullMethodName        = "/spqr.KeyRangeService/MergeKeyRange"
	KeyRangeService_MoveKeyRange_FullMethodName         = "/spqr.KeyRangeService/MoveKeyRange"
	KeyRangeService_ResolveKeyRange_FullMethodName      = "/spqr.KeyRangeService/ResolveKeyRange"
	KeyRangeService_BatchMoveKeyRange_FullMethodName    = "/spqr.KeyRangeService/BatchMoveKeyRange"
	KeyRangeService_RedistributeKeyRange_FullMethodName = "/spqr.KeyRangeService/RedistributeKeyRange"
	KeyRangeService_RenameKeyRange_FullMethodName       = "/spqr.KeyRangeService/RenameKeyRange"
)
View Source 
const (
	RouterService_ListRouters_FullMethodName  = "/spqr.RouterService/ListRouters"
	RouterService_AddRouter_FullMethodName    = "/spqr.RouterService/AddRouter"
	RouterService_RemoveRouter_FullMethodName = "/spqr.RouterService/RemoveRouter"
	RouterService_SyncMetadata_FullMethodName = "/spqr.RouterService/SyncMetadata"
)
View Source 
const (
	ShardService_ListShards_FullMethodName    = "/spqr.ShardService/ListShards"
	ShardService_AddDataShard_FullMethodName  = "/spqr.ShardService/AddDataShard"
	ShardService_AddWorldShard_FullMethodName = "/spqr.ShardService/AddWorldShard"
	ShardService_GetShard_FullMethodName      = "/spqr.ShardService/GetShard"
)
View Source 
const (
	ShardingRulesService_AddShardingRules_FullMethodName  = "/spqr.ShardingRulesService/AddShardingRules"
	ShardingRulesService_DropShardingRules_FullMethodName = "/spqr.ShardingRulesService/DropShardingRules"
	ShardingRulesService_ListShardingRules_FullMethodName = "/spqr.ShardingRulesService/ListShardingRules"
)
View Source 
const (
	MoveTasksService_GetMoveTaskGroup_FullMethodName    = "/spqr.MoveTasksService/GetMoveTaskGroup"
	MoveTasksService_WriteMoveTaskGroup_FullMethodName  = "/spqr.MoveTasksService/WriteMoveTaskGroup"
	MoveTasksService_RemoveMoveTaskGroup_FullMethodName = "/spqr.MoveTasksService/RemoveMoveTaskGroup"
)
View Source 
const (
	BalancerTaskService_GetBalancerTask_FullMethodName    = "/spqr.BalancerTaskService/GetBalancerTask"
	BalancerTaskService_WriteBalancerTask_FullMethodName  = "/spqr.BalancerTaskService/WriteBalancerTask"
	BalancerTaskService_RemoveBalancerTask_FullMethodName = "/spqr.BalancerTaskService/RemoveBalancerTask"
)
View Source 
const (
	RedistributeTaskService_GetRedistributeTask_FullMethodName    = "/spqr.RedistributeTaskService/GetRedistributeTask"
	RedistributeTaskService_WriteRedistributeTask_FullMethodName  = "/spqr.RedistributeTaskService/WriteRedistributeTask"
	RedistributeTaskService_RemoveRedistributeTask_FullMethodName = "/spqr.RedistributeTaskService/RemoveRedistributeTask"
)
View Source 
const (
	BackendConnectionsService_ListBackendConnections_FullMethodName = "/spqr.BackendConnectionsService/ListBackendConnections"
)
View Source 
const (
	ClientInfoService_ListClients_FullMethodName = "/spqr.ClientInfoService/ListClients"
)
View Source 
const (
	OperationService_GetOperation_FullMethodName = "/spqr.OperationService/GetOperation"
)
View Source 
const (
	PoolService_ListPools_FullMethodName = "/spqr.PoolService/ListPools"
)

Variables

View Source 
var (
	KeyRangeStatus_name = map[int32]string{
		0: "LOCKED",
		1: "AVAILABLE",
	}
	KeyRangeStatus_value = map[string]int32{
		"LOCKED":    0,
		"AVAILABLE": 1,
	}
)

Enum value maps for KeyRangeStatus.

View Source 
var (
	RedistributeLimitType_name = map[int32]string{
		0: "RedistributeAllKeys",
		1: "RedistributeKeysLimit",
	}
	RedistributeLimitType_value = map[string]int32{
		"RedistributeAllKeys":   0,
		"RedistributeKeysLimit": 1,
	}
)

Enum value maps for RedistributeLimitType.

View Source 
var (
	OperationStatus_name = map[int32]string{
		0: "PLANNED",
		1: "RUNNING",
		2: "DONE",
	}
	OperationStatus_value = map[string]int32{
		"PLANNED": 0,
		"RUNNING": 1,
		"DONE":    2,
	}
)

Enum value maps for OperationStatus.

View Source 
var (
	RouterStatus_name = map[int32]string{
		0: "CLOSED",
		1: "OPENED",
	}
	RouterStatus_value = map[string]int32{
		"CLOSED": 0,
		"OPENED": 1,
	}
)

Enum value maps for RouterStatus.

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "Planned",
		1: "Split",
		2: "Moved",
	}
	TaskStatus_value = map[string]int32{
		"Planned": 0,
		"Split":   1,
		"Moved":   2,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	JoinType_name = map[int32]string{
		0: "JoinNone",
		1: "JoinLeft",
		2: "JoinRight",
	}
	JoinType_value = map[string]int32{
		"JoinNone":  0,
		"JoinLeft":  1,
		"JoinRight": 2,
	}
)

Enum value maps for JoinType.

View Source 
var (
	SplitType_name = map[int32]string{
		0: "SplitLeft",
		1: "SplitRight",
	}
	SplitType_value = map[string]int32{
		"SplitLeft":  0,
		"SplitRight": 1,
	}
)

Enum value maps for SplitType.

View Source 
var (
	BalancerTaskStatus_name = map[int32]string{
		0: "BalancerTaskPlanned",
		1: "BalancerTaskMoved",
	}
	BalancerTaskStatus_value = map[string]int32{
		"BalancerTaskPlanned": 0,
		"BalancerTaskMoved":   1,
	}
)

Enum value maps for BalancerTaskStatus.

View Source 
var (
	RedistributeTaskState_name = map[int32]string{
		0: "RedistributeTaskPlanned",
		1: "RedistributeTaskMoved",
	}
	RedistributeTaskState_value = map[string]int32{
		"RedistributeTaskPlanned": 0,
		"RedistributeTaskMoved":   1,
	}
)

Enum value maps for RedistributeTaskState.

View Source 
var BackendConnectionsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.BackendConnectionsService",
	HandlerType: (*BackendConnectionsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListBackendConnections",
			Handler:    _BackendConnectionsService_ListBackendConnections_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/backend_connections.proto",
}

BackendConnectionsService_ServiceDesc is the grpc.ServiceDesc for BackendConnectionsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var BalancerTaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.BalancerTaskService",
	HandlerType: (*BalancerTaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBalancerTask",
			Handler:    _BalancerTaskService_GetBalancerTask_Handler,
		},
		{
			MethodName: "WriteBalancerTask",
			Handler:    _BalancerTaskService_WriteBalancerTask_Handler,
		},
		{
			MethodName: "RemoveBalancerTask",
			Handler:    _BalancerTaskService_RemoveBalancerTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/tasks.proto",
}

BalancerTaskService_ServiceDesc is the grpc.ServiceDesc for BalancerTaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ClientInfoService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.ClientInfoService",
	HandlerType: (*ClientInfoServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListClients",
			Handler:    _ClientInfoService_ListClients_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/clients.proto",
}

ClientInfoService_ServiceDesc is the grpc.ServiceDesc for ClientInfoService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DistributionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.DistributionService",
	HandlerType: (*DistributionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateDistribution",
			Handler:    _DistributionService_CreateDistribution_Handler,
		},
		{
			MethodName: "DropDistribution",
			Handler:    _DistributionService_DropDistribution_Handler,
		},
		{
			MethodName: "ListDistributions",
			Handler:    _DistributionService_ListDistributions_Handler,
		},
		{
			MethodName: "AlterDistributionAttach",
			Handler:    _DistributionService_AlterDistributionAttach_Handler,
		},
		{
			MethodName: "AlterDistributionDetach",
			Handler:    _DistributionService_AlterDistributionDetach_Handler,
		},
		{
			MethodName: "GetDistribution",
			Handler:    _DistributionService_GetDistribution_Handler,
		},
		{
			MethodName: "GetRelationDistribution",
			Handler:    _DistributionService_GetRelationDistribution_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/distribution.proto",
}

DistributionService_ServiceDesc is the grpc.ServiceDesc for DistributionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_protos_backend_connections_proto protoreflect.FileDescriptor
View Source 
var File_protos_clients_proto protoreflect.FileDescriptor
View Source 
var File_protos_coordinator_proto protoreflect.FileDescriptor
View Source 
var File_protos_distribution_proto protoreflect.FileDescriptor
View Source 
var File_protos_key_range_proto protoreflect.FileDescriptor
View Source 
var File_protos_operation_proto protoreflect.FileDescriptor
View Source 
var File_protos_pools_proto protoreflect.FileDescriptor
View Source 
var File_protos_router_proto protoreflect.FileDescriptor
View Source 
var File_protos_shard_proto protoreflect.FileDescriptor
View Source 
var File_protos_sharding_rules_proto protoreflect.FileDescriptor
View Source 
var File_protos_tasks_proto protoreflect.FileDescriptor
View Source 
var KeyRangeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.KeyRangeService",
	HandlerType: (*KeyRangeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetKeyRange",
			Handler:    _KeyRangeService_GetKeyRange_Handler,
		},
		{
			MethodName: "ListKeyRange",
			Handler:    _KeyRangeService_ListKeyRange_Handler,
		},
		{
			MethodName: "ListAllKeyRanges",
			Handler:    _KeyRangeService_ListAllKeyRanges_Handler,
		},
		{
			MethodName: "LockKeyRange",
			Handler:    _KeyRangeService_LockKeyRange_Handler,
		},
		{
			MethodName: "CreateKeyRange",
			Handler:    _KeyRangeService_CreateKeyRange_Handler,
		},
		{
			MethodName: "DropKeyRange",
			Handler:    _KeyRangeService_DropKeyRange_Handler,
		},
		{
			MethodName: "DropAllKeyRanges",
			Handler:    _KeyRangeService_DropAllKeyRanges_Handler,
		},
		{
			MethodName: "UnlockKeyRange",
			Handler:    _KeyRangeService_UnlockKeyRange_Handler,
		},
		{
			MethodName: "SplitKeyRange",
			Handler:    _KeyRangeService_SplitKeyRange_Handler,
		},
		{
			MethodName: "MergeKeyRange",
			Handler:    _KeyRangeService_MergeKeyRange_Handler,
		},
		{
			MethodName: "MoveKeyRange",
			Handler:    _KeyRangeService_MoveKeyRange_Handler,
		},
		{
			MethodName: "ResolveKeyRange",
			Handler:    _KeyRangeService_ResolveKeyRange_Handler,
		},
		{
			MethodName: "BatchMoveKeyRange",
			Handler:    _KeyRangeService_BatchMoveKeyRange_Handler,
		},
		{
			MethodName: "RedistributeKeyRange",
			Handler:    _KeyRangeService_RedistributeKeyRange_Handler,
		},
		{
			MethodName: "RenameKeyRange",
			Handler:    _KeyRangeService_RenameKeyRange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/key_range.proto",
}

KeyRangeService_ServiceDesc is the grpc.ServiceDesc for KeyRangeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var MoveTasksService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.MoveTasksService",
	HandlerType: (*MoveTasksServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMoveTaskGroup",
			Handler:    _MoveTasksService_GetMoveTaskGroup_Handler,
		},
		{
			MethodName: "WriteMoveTaskGroup",
			Handler:    _MoveTasksService_WriteMoveTaskGroup_Handler,
		},
		{
			MethodName: "RemoveMoveTaskGroup",
			Handler:    _MoveTasksService_RemoveMoveTaskGroup_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/tasks.proto",
}

MoveTasksService_ServiceDesc is the grpc.ServiceDesc for MoveTasksService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var OperationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.OperationService",
	HandlerType: (*OperationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOperation",
			Handler:    _OperationService_GetOperation_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/operation.proto",
}

OperationService_ServiceDesc is the grpc.ServiceDesc for OperationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PoolService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.PoolService",
	HandlerType: (*PoolServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPools",
			Handler:    _PoolService_ListPools_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/pools.proto",
}

PoolService_ServiceDesc is the grpc.ServiceDesc for PoolService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RedistributeTaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.RedistributeTaskService",
	HandlerType: (*RedistributeTaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRedistributeTask",
			Handler:    _RedistributeTaskService_GetRedistributeTask_Handler,
		},
		{
			MethodName: "WriteRedistributeTask",
			Handler:    _RedistributeTaskService_WriteRedistributeTask_Handler,
		},
		{
			MethodName: "RemoveRedistributeTask",
			Handler:    _RedistributeTaskService_RemoveRedistributeTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/tasks.proto",
}

RedistributeTaskService_ServiceDesc is the grpc.ServiceDesc for RedistributeTaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RouterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.RouterService",
	HandlerType: (*RouterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListRouters",
			Handler:    _RouterService_ListRouters_Handler,
		},
		{
			MethodName: "AddRouter",
			Handler:    _RouterService_AddRouter_Handler,
		},
		{
			MethodName: "RemoveRouter",
			Handler:    _RouterService_RemoveRouter_Handler,
		},
		{
			MethodName: "SyncMetadata",
			Handler:    _RouterService_SyncMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/router.proto",
}

RouterService_ServiceDesc is the grpc.ServiceDesc for RouterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ShardService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.ShardService",
	HandlerType: (*ShardServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListShards",
			Handler:    _ShardService_ListShards_Handler,
		},
		{
			MethodName: "AddDataShard",
			Handler:    _ShardService_AddDataShard_Handler,
		},
		{
			MethodName: "AddWorldShard",
			Handler:    _ShardService_AddWorldShard_Handler,
		},
		{
			MethodName: "GetShard",
			Handler:    _ShardService_GetShard_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/shard.proto",
}

ShardService_ServiceDesc is the grpc.ServiceDesc for ShardService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ShardingRulesService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.ShardingRulesService",
	HandlerType: (*ShardingRulesServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddShardingRules",
			Handler:    _ShardingRulesService_AddShardingRules_Handler,
		},
		{
			MethodName: "DropShardingRules",
			Handler:    _ShardingRulesService_DropShardingRules_Handler,
		},
		{
			MethodName: "ListShardingRules",
			Handler:    _ShardingRulesService_ListShardingRules_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/sharding_rules.proto",
}

ShardingRulesService_ServiceDesc is the grpc.ServiceDesc for ShardingRulesService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TopologyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spqr.TopologyService",
	HandlerType: (*TopologyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OpenRouter",
			Handler:    _TopologyService_OpenRouter_Handler,
		},
		{
			MethodName: "GetRouterStatus",
			Handler:    _TopologyService_GetRouterStatus_Handler,
		},
		{
			MethodName: "CloseRouter",
			Handler:    _TopologyService_CloseRouter_Handler,
		},
		{
			MethodName: "UpdateCoordinator",
			Handler:    _TopologyService_UpdateCoordinator_Handler,
		},
		{
			MethodName: "GetCoordinator",
			Handler:    _TopologyService_GetCoordinator_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/coordinator.proto",
}

TopologyService_ServiceDesc is the grpc.ServiceDesc for TopologyService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterBackendConnectionsServiceServer 

func RegisterBackendConnectionsServiceServer(s grpc.ServiceRegistrar, srv BackendConnectionsServiceServer)

func RegisterBalancerTaskServiceServer 

func RegisterBalancerTaskServiceServer(s grpc.ServiceRegistrar, srv BalancerTaskServiceServer)

func RegisterClientInfoServiceServer 

func RegisterClientInfoServiceServer(s grpc.ServiceRegistrar, srv ClientInfoServiceServer)

func RegisterDistributionServiceServer 

func RegisterDistributionServiceServer(s grpc.ServiceRegistrar, srv DistributionServiceServer)

func RegisterKeyRangeServiceServer 

func RegisterKeyRangeServiceServer(s grpc.ServiceRegistrar, srv KeyRangeServiceServer)

func RegisterMoveTasksServiceServer 

func RegisterMoveTasksServiceServer(s grpc.ServiceRegistrar, srv MoveTasksServiceServer)

func RegisterOperationServiceServer 

func RegisterOperationServiceServer(s grpc.ServiceRegistrar, srv OperationServiceServer)

func RegisterPoolServiceServer 

func RegisterPoolServiceServer(s grpc.ServiceRegistrar, srv PoolServiceServer)

func RegisterRedistributeTaskServiceServer 

func RegisterRedistributeTaskServiceServer(s grpc.ServiceRegistrar, srv RedistributeTaskServiceServer)

func RegisterRouterServiceServer 

func RegisterRouterServiceServer(s grpc.ServiceRegistrar, srv RouterServiceServer)

func RegisterShardServiceServer 

func RegisterShardServiceServer(s grpc.ServiceRegistrar, srv ShardServiceServer)

func RegisterShardingRulesServiceServer 

func RegisterShardingRulesServiceServer(s grpc.ServiceRegistrar, srv ShardingRulesServiceServer)

func RegisterTopologyServiceServer 

func RegisterTopologyServiceServer(s grpc.ServiceRegistrar, srv TopologyServiceServer)

Types

type AddRouterReply 

type AddRouterReply struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRouterReply) Descriptor deprecated 

func (*AddRouterReply) Descriptor() ([]byte, []int)

Deprecated: Use AddRouterReply.ProtoReflect.Descriptor instead.

func (*AddRouterReply) GetId 

func (x *AddRouterReply) GetId() string

func (*AddRouterReply) ProtoMessage 

func (*AddRouterReply) ProtoMessage()

func (*AddRouterReply) ProtoReflect 

func (x *AddRouterReply) ProtoReflect() protoreflect.Message

func (*AddRouterReply) Reset 

func (x *AddRouterReply) Reset()

func (*AddRouterReply) String 

func (x *AddRouterReply) String() string

type AddRouterRequest 

type AddRouterRequest struct {
	Router *Router `protobuf:"bytes,1,opt,name=router,proto3" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRouterRequest) Descriptor deprecated 

func (*AddRouterRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddRouterRequest.ProtoReflect.Descriptor instead.

func (*AddRouterRequest) GetRouter 

func (x *AddRouterRequest) GetRouter() *Router

func (*AddRouterRequest) ProtoMessage 

func (*AddRouterRequest) ProtoMessage()

func (*AddRouterRequest) ProtoReflect 

func (x *AddRouterRequest) ProtoReflect() protoreflect.Message

func (*AddRouterRequest) Reset 

func (x *AddRouterRequest) Reset()

func (*AddRouterRequest) String 

func (x *AddRouterRequest) String() string

type AddShardRequest 

type AddShardRequest struct {
	Shard *Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*AddShardRequest) Descriptor deprecated 

func (*AddShardRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddShardRequest.ProtoReflect.Descriptor instead.

func (*AddShardRequest) GetShard 

func (x *AddShardRequest) GetShard() *Shard

func (*AddShardRequest) ProtoMessage 

func (*AddShardRequest) ProtoMessage()

func (*AddShardRequest) ProtoReflect 

func (x *AddShardRequest) ProtoReflect() protoreflect.Message

func (*AddShardRequest) Reset 

func (x *AddShardRequest) Reset()

func (*AddShardRequest) String 

func (x *AddShardRequest) String() string

type AddShardingRuleRequest 

type AddShardingRuleRequest struct {
	Rules []*ShardingRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*AddShardingRuleRequest) Descriptor deprecated 

func (*AddShardingRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddShardingRuleRequest.ProtoReflect.Descriptor instead.

func (*AddShardingRuleRequest) GetRules 

func (x *AddShardingRuleRequest) GetRules() []*ShardingRule

func (*AddShardingRuleRequest) ProtoMessage 

func (*AddShardingRuleRequest) ProtoMessage()

func (*AddShardingRuleRequest) ProtoReflect 

func (x *AddShardingRuleRequest) ProtoReflect() protoreflect.Message

func (*AddShardingRuleRequest) Reset 

func (x *AddShardingRuleRequest) Reset()

func (*AddShardingRuleRequest) String 

func (x *AddShardingRuleRequest) String() string

type AddWorldShardRequest 

type AddWorldShardRequest struct {
	Shard *Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorldShardRequest) Descriptor deprecated 

func (*AddWorldShardRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddWorldShardRequest.ProtoReflect.Descriptor instead.

func (*AddWorldShardRequest) GetShard 

func (x *AddWorldShardRequest) GetShard() *Shard

func (*AddWorldShardRequest) ProtoMessage 

func (*AddWorldShardRequest) ProtoMessage()

func (*AddWorldShardRequest) ProtoReflect 

func (x *AddWorldShardRequest) ProtoReflect() protoreflect.Message

func (*AddWorldShardRequest) Reset 

func (x *AddWorldShardRequest) Reset()

func (*AddWorldShardRequest) String 

func (x *AddWorldShardRequest) String() string

type AlterDistributionAttachRequest 

type AlterDistributionAttachRequest struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ColumnNames []string               `protobuf:"bytes,2,rep,name=ColumnNames,proto3" json:"ColumnNames,omitempty"`
	Relations   []*DistributedRelation `protobuf:"bytes,3,rep,name=relations,proto3" json:"relations,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterDistributionAttachRequest) Descriptor deprecated 

func (*AlterDistributionAttachRequest) Descriptor() ([]byte, []int)

Deprecated: Use AlterDistributionAttachRequest.ProtoReflect.Descriptor instead.

func (*AlterDistributionAttachRequest) GetColumnNames 

func (x *AlterDistributionAttachRequest) GetColumnNames() []string

func (*AlterDistributionAttachRequest) GetId 

func (x *AlterDistributionAttachRequest) GetId() string

func (*AlterDistributionAttachRequest) GetRelations 

func (x *AlterDistributionAttachRequest) GetRelations() []*DistributedRelation

func (*AlterDistributionAttachRequest) ProtoMessage 

func (*AlterDistributionAttachRequest) ProtoMessage()

func (*AlterDistributionAttachRequest) ProtoReflect 

func (x *AlterDistributionAttachRequest) ProtoReflect() protoreflect.Message

func (*AlterDistributionAttachRequest) Reset 

func (x *AlterDistributionAttachRequest) Reset()

func (*AlterDistributionAttachRequest) String 

func (x *AlterDistributionAttachRequest) String() string

type AlterDistributionDetachRequest 

type AlterDistributionDetachRequest struct {
	Id       string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RelNames []string `protobuf:"bytes,2,rep,name=relNames,proto3" json:"relNames,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterDistributionDetachRequest) Descriptor deprecated 

func (*AlterDistributionDetachRequest) Descriptor() ([]byte, []int)

Deprecated: Use AlterDistributionDetachRequest.ProtoReflect.Descriptor instead.

func (*AlterDistributionDetachRequest) GetId 

func (x *AlterDistributionDetachRequest) GetId() string

func (*AlterDistributionDetachRequest) GetRelNames 

func (x *AlterDistributionDetachRequest) GetRelNames() []string

func (*AlterDistributionDetachRequest) ProtoMessage 

func (*AlterDistributionDetachRequest) ProtoMessage()

func (*AlterDistributionDetachRequest) ProtoReflect 

func (x *AlterDistributionDetachRequest) ProtoReflect() protoreflect.Message

func (*AlterDistributionDetachRequest) Reset 

func (x *AlterDistributionDetachRequest) Reset()

func (*AlterDistributionDetachRequest) String 

func (x *AlterDistributionDetachRequest) String() string

type BackendConnectionsInfo 

type BackendConnectionsInfo struct {
	BackendConnectionId uint64 `protobuf:"varint,1,opt,name=backend_connection_id,json=backendConnectionId,proto3" json:"backend_connection_id,omitempty"`
	ShardKeyName        string `protobuf:"bytes,2,opt,name=shard_key_name,json=shardKeyName,proto3" json:"shard_key_name,omitempty"`
	Hostname            string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	User                string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Dbname              string `protobuf:"bytes,5,opt,name=dbname,proto3" json:"dbname,omitempty"`
	Sync                int64  `protobuf:"varint,6,opt,name=sync,proto3" json:"sync,omitempty"`
	TxServed            int64  `protobuf:"varint,7,opt,name=tx_served,json=txServed,proto3" json:"tx_served,omitempty"`
	TxStatus            int64  `protobuf:"varint,8,opt,name=tx_status,json=txStatus,proto3" json:"tx_status,omitempty"`
	// contains filtered or unexported fields
}

func (*BackendConnectionsInfo) Descriptor deprecated 

func (*BackendConnectionsInfo) Descriptor() ([]byte, []int)

Deprecated: Use BackendConnectionsInfo.ProtoReflect.Descriptor instead.

func (*BackendConnectionsInfo) GetBackendConnectionId 

func (x *BackendConnectionsInfo) GetBackendConnectionId() uint64

func (*BackendConnectionsInfo) GetDbname 

func (x *BackendConnectionsInfo) GetDbname() string

func (*BackendConnectionsInfo) GetHostname 

func (x *BackendConnectionsInfo) GetHostname() string

func (*BackendConnectionsInfo) GetShardKeyName 

func (x *BackendConnectionsInfo) GetShardKeyName() string

func (*BackendConnectionsInfo) GetSync 

func (x *BackendConnectionsInfo) GetSync() int64

func (*BackendConnectionsInfo) GetTxServed 

func (x *BackendConnectionsInfo) GetTxServed() int64

func (*BackendConnectionsInfo) GetTxStatus 

func (x *BackendConnectionsInfo) GetTxStatus() int64

func (*BackendConnectionsInfo) GetUser 

func (x *BackendConnectionsInfo) GetUser() string

func (*BackendConnectionsInfo) ProtoMessage 

func (*BackendConnectionsInfo) ProtoMessage()

func (*BackendConnectionsInfo) ProtoReflect 

func (x *BackendConnectionsInfo) ProtoReflect() protoreflect.Message

func (*BackendConnectionsInfo) Reset 

func (x *BackendConnectionsInfo) Reset()

func (*BackendConnectionsInfo) String 

func (x *BackendConnectionsInfo) String() string

type BackendConnectionsServiceClient 

type BackendConnectionsServiceClient interface {
	ListBackendConnections(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBackendConntionsReply, error)
}

BackendConnectionsServiceClient is the client API for BackendConnectionsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBackendConnectionsServiceClient 

func NewBackendConnectionsServiceClient(cc grpc.ClientConnInterface) BackendConnectionsServiceClient

type BackendConnectionsServiceServer 

type BackendConnectionsServiceServer interface {
	ListBackendConnections(context.Context, *emptypb.Empty) (*ListBackendConntionsReply, error)
	// contains filtered or unexported methods
}

BackendConnectionsServiceServer is the server API for BackendConnectionsService service. All implementations must embed UnimplementedBackendConnectionsServiceServer for forward compatibility

type BalancerTask 

type BalancerTask struct {
	Type           JoinType           `protobuf:"varint,1,opt,name=type,proto3,enum=spqr.JoinType" json:"type,omitempty"`
	KeyRangeIdFrom string             `protobuf:"bytes,2,opt,name=keyRangeIdFrom,proto3" json:"keyRangeIdFrom,omitempty"`
	KeyRangeIdTo   string             `protobuf:"bytes,3,opt,name=keyRangeIdTo,proto3" json:"keyRangeIdTo,omitempty"`
	KeyRangeIdTemp string             `protobuf:"bytes,4,opt,name=keyRangeIdTemp,proto3" json:"keyRangeIdTemp,omitempty"`
	ShardIdTo      string             `protobuf:"bytes,5,opt,name=shardIdTo,proto3" json:"shardIdTo,omitempty"`
	KeyCount       int64              `protobuf:"varint,6,opt,name=keyCount,proto3" json:"keyCount,omitempty"`
	State          BalancerTaskStatus `protobuf:"varint,7,opt,name=state,proto3,enum=spqr.BalancerTaskStatus" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*BalancerTask) Descriptor deprecated 

func (*BalancerTask) Descriptor() ([]byte, []int)

Deprecated: Use BalancerTask.ProtoReflect.Descriptor instead.

func (*BalancerTask) GetKeyCount 

func (x *BalancerTask) GetKeyCount() int64

func (*BalancerTask) GetKeyRangeIdFrom 

func (x *BalancerTask) GetKeyRangeIdFrom() string

func (*BalancerTask) GetKeyRangeIdTemp 

func (x *BalancerTask) GetKeyRangeIdTemp() string

func (*BalancerTask) GetKeyRangeIdTo 

func (x *BalancerTask) GetKeyRangeIdTo() string

func (*BalancerTask) GetShardIdTo 

func (x *BalancerTask) GetShardIdTo() string

func (*BalancerTask) GetState 

func (x *BalancerTask) GetState() BalancerTaskStatus

func (*BalancerTask) GetType 

func (x *BalancerTask) GetType() JoinType

func (*BalancerTask) ProtoMessage 

func (*BalancerTask) ProtoMessage()

func (*BalancerTask) ProtoReflect 

func (x *BalancerTask) ProtoReflect() protoreflect.Message

func (*BalancerTask) Reset 

func (x *BalancerTask) Reset()

func (*BalancerTask) String 

func (x *BalancerTask) String() string

type BalancerTaskServiceClient 

type BalancerTaskServiceClient interface {
	GetBalancerTask(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetBalancerTaskReply, error)
	WriteBalancerTask(ctx context.Context, in *WriteBalancerTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveBalancerTask(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

BalancerTaskServiceClient is the client API for BalancerTaskService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBalancerTaskServiceClient 

func NewBalancerTaskServiceClient(cc grpc.ClientConnInterface) BalancerTaskServiceClient

type BalancerTaskServiceServer 

type BalancerTaskServiceServer interface {
	GetBalancerTask(context.Context, *emptypb.Empty) (*GetBalancerTaskReply, error)
	WriteBalancerTask(context.Context, *WriteBalancerTaskRequest) (*emptypb.Empty, error)
	RemoveBalancerTask(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

BalancerTaskServiceServer is the server API for BalancerTaskService service. All implementations must embed UnimplementedBalancerTaskServiceServer for forward compatibility

type BalancerTaskStatus 

type BalancerTaskStatus int32
const (
	BalancerTaskStatus_BalancerTaskPlanned BalancerTaskStatus = 0
	BalancerTaskStatus_BalancerTaskMoved   BalancerTaskStatus = 1
)

func (BalancerTaskStatus) Descriptor 

func (BalancerTaskStatus) Descriptor() protoreflect.EnumDescriptor

func (BalancerTaskStatus) Enum 

func (x BalancerTaskStatus) Enum() *BalancerTaskStatus

func (BalancerTaskStatus) EnumDescriptor deprecated 

func (BalancerTaskStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use BalancerTaskStatus.Descriptor instead.

func (BalancerTaskStatus) Number 

func (x BalancerTaskStatus) Number() protoreflect.EnumNumber

func (BalancerTaskStatus) String 

func (x BalancerTaskStatus) String() string

func (BalancerTaskStatus) Type 

func (BalancerTaskStatus) Type() protoreflect.EnumType

type BatchMoveKeyRangeRequest 

type BatchMoveKeyRangeRequest struct {
	Id        string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ToShardId string                `protobuf:"bytes,2,opt,name=toShardId,proto3" json:"toShardId,omitempty"`
	ToKrId    string                `protobuf:"bytes,3,opt,name=toKrId,proto3" json:"toKrId,omitempty"`
	LimitType RedistributeLimitType `protobuf:"varint,4,opt,name=limitType,proto3,enum=spqr.RedistributeLimitType" json:"limitType,omitempty"`
	Limit     int64                 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	BatchSize int64                 `protobuf:"varint,6,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	SplitType SplitType             `protobuf:"varint,7,opt,name=splitType,proto3,enum=spqr.SplitType" json:"splitType,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchMoveKeyRangeRequest) Descriptor deprecated 

func (*BatchMoveKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use BatchMoveKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*BatchMoveKeyRangeRequest) GetBatchSize 

func (x *BatchMoveKeyRangeRequest) GetBatchSize() int64

func (*BatchMoveKeyRangeRequest) GetId 

func (x *BatchMoveKeyRangeRequest) GetId() string

func (*BatchMoveKeyRangeRequest) GetLimit 

func (x *BatchMoveKeyRangeRequest) GetLimit() int64

func (*BatchMoveKeyRangeRequest) GetLimitType 

func (x *BatchMoveKeyRangeRequest) GetLimitType() RedistributeLimitType

func (*BatchMoveKeyRangeRequest) GetSplitType 

func (x *BatchMoveKeyRangeRequest) GetSplitType() SplitType

func (*BatchMoveKeyRangeRequest) GetToKrId 

func (x *BatchMoveKeyRangeRequest) GetToKrId() string

func (*BatchMoveKeyRangeRequest) GetToShardId 

func (x *BatchMoveKeyRangeRequest) GetToShardId() string

func (*BatchMoveKeyRangeRequest) ProtoMessage 

func (*BatchMoveKeyRangeRequest) ProtoMessage()

func (*BatchMoveKeyRangeRequest) ProtoReflect 

func (x *BatchMoveKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*BatchMoveKeyRangeRequest) Reset 

func (x *BatchMoveKeyRangeRequest) Reset()

func (*BatchMoveKeyRangeRequest) String 

func (x *BatchMoveKeyRangeRequest) String() string

type ClientInfo 

type ClientInfo struct {
	ClientId uint64           `protobuf:"varint,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	User     string           `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Dbname   string           `protobuf:"bytes,3,opt,name=dbname,proto3" json:"dbname,omitempty"`
	Dsname   string           `protobuf:"bytes,4,opt,name=dsname,proto3" json:"dsname,omitempty"`
	Shards   []*UsedShardInfo `protobuf:"bytes,5,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientInfo) Descriptor deprecated 

func (*ClientInfo) Descriptor() ([]byte, []int)

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetClientId 

func (x *ClientInfo) GetClientId() uint64

func (*ClientInfo) GetDbname 

func (x *ClientInfo) GetDbname() string

func (*ClientInfo) GetDsname 

func (x *ClientInfo) GetDsname() string

func (*ClientInfo) GetShards 

func (x *ClientInfo) GetShards() []*UsedShardInfo

func (*ClientInfo) GetUser 

func (x *ClientInfo) GetUser() string

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect 

func (x *ClientInfo) ProtoReflect() protoreflect.Message

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) String 

func (x *ClientInfo) String() string

type ClientInfoServiceClient 

type ClientInfoServiceClient interface {
	ListClients(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListClientsReply, error)
}

ClientInfoServiceClient is the client API for ClientInfoService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewClientInfoServiceClient 

func NewClientInfoServiceClient(cc grpc.ClientConnInterface) ClientInfoServiceClient

type ClientInfoServiceServer 

type ClientInfoServiceServer interface {
	ListClients(context.Context, *emptypb.Empty) (*ListClientsReply, error)
	// contains filtered or unexported methods
}

ClientInfoServiceServer is the server API for ClientInfoService service. All implementations must embed UnimplementedClientInfoServiceServer for forward compatibility

type CreateDistributionRequest 

type CreateDistributionRequest struct {
	Distributions []*Distribution `protobuf:"bytes,1,rep,name=distributions,proto3" json:"distributions,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDistributionRequest) Descriptor deprecated 

func (*CreateDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateDistributionRequest.ProtoReflect.Descriptor instead.

func (*CreateDistributionRequest) GetDistributions 

func (x *CreateDistributionRequest) GetDistributions() []*Distribution

func (*CreateDistributionRequest) ProtoMessage 

func (*CreateDistributionRequest) ProtoMessage()

func (*CreateDistributionRequest) ProtoReflect 

func (x *CreateDistributionRequest) ProtoReflect() protoreflect.Message

func (*CreateDistributionRequest) Reset 

func (x *CreateDistributionRequest) Reset()

func (*CreateDistributionRequest) String 

func (x *CreateDistributionRequest) String() string

type CreateKeyRangeRequest 

type CreateKeyRangeRequest struct {
	KeyRangeInfo *KeyRangeInfo `protobuf:"bytes,1,opt,name=key_range_info,json=keyRangeInfo,proto3" json:"key_range_info,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyRangeRequest) Descriptor deprecated 

func (*CreateKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*CreateKeyRangeRequest) GetKeyRangeInfo 

func (x *CreateKeyRangeRequest) GetKeyRangeInfo() *KeyRangeInfo

func (*CreateKeyRangeRequest) ProtoMessage 

func (*CreateKeyRangeRequest) ProtoMessage()

func (*CreateKeyRangeRequest) ProtoReflect 

func (x *CreateKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*CreateKeyRangeRequest) Reset 

func (x *CreateKeyRangeRequest) Reset()

func (*CreateKeyRangeRequest) String 

func (x *CreateKeyRangeRequest) String() string

type DBInstaceInfo 

type DBInstaceInfo struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*DBInstaceInfo) Descriptor deprecated 

func (*DBInstaceInfo) Descriptor() ([]byte, []int)

Deprecated: Use DBInstaceInfo.ProtoReflect.Descriptor instead.

func (*DBInstaceInfo) GetHostname 

func (x *DBInstaceInfo) GetHostname() string

func (*DBInstaceInfo) ProtoMessage 

func (*DBInstaceInfo) ProtoMessage()

func (*DBInstaceInfo) ProtoReflect 

func (x *DBInstaceInfo) ProtoReflect() protoreflect.Message

func (*DBInstaceInfo) Reset 

func (x *DBInstaceInfo) Reset()

func (*DBInstaceInfo) String 

func (x *DBInstaceInfo) String() string

type DistributedRelation 

type DistributedRelation struct {
	Name               string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DistributionKey    []*DistributionKeyEntry `protobuf:"bytes,2,rep,name=distributionKey,proto3" json:"distributionKey,omitempty"`
	ReplicatedRelation bool                    `protobuf:"varint,3,opt,name=ReplicatedRelation,proto3" json:"ReplicatedRelation,omitempty"`
	// contains filtered or unexported fields
}

func (*DistributedRelation) Descriptor deprecated 

func (*DistributedRelation) Descriptor() ([]byte, []int)

Deprecated: Use DistributedRelation.ProtoReflect.Descriptor instead.

func (*DistributedRelation) GetDistributionKey 

func (x *DistributedRelation) GetDistributionKey() []*DistributionKeyEntry

func (*DistributedRelation) GetName 

func (x *DistributedRelation) GetName() string

func (*DistributedRelation) GetReplicatedRelation 

func (x *DistributedRelation) GetReplicatedRelation() bool

func (*DistributedRelation) ProtoMessage 

func (*DistributedRelation) ProtoMessage()

func (*DistributedRelation) ProtoReflect 

func (x *DistributedRelation) ProtoReflect() protoreflect.Message

func (*DistributedRelation) Reset 

func (x *DistributedRelation) Reset()

func (*DistributedRelation) String 

func (x *DistributedRelation) String() string

type Distribution 

type Distribution struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ColumnTypes []string               `protobuf:"bytes,2,rep,name=ColumnTypes,proto3" json:"ColumnTypes,omitempty"`
	Relations   []*DistributedRelation `protobuf:"bytes,3,rep,name=relations,proto3" json:"relations,omitempty"`
	// contains filtered or unexported fields
}

func (*Distribution) Descriptor deprecated 

func (*Distribution) Descriptor() ([]byte, []int)

Deprecated: Use Distribution.ProtoReflect.Descriptor instead.

func (*Distribution) GetColumnTypes 

func (x *Distribution) GetColumnTypes() []string

func (*Distribution) GetId 

func (x *Distribution) GetId() string

func (*Distribution) GetRelations 

func (x *Distribution) GetRelations() []*DistributedRelation

func (*Distribution) ProtoMessage 

func (*Distribution) ProtoMessage()

func (*Distribution) ProtoReflect 

func (x *Distribution) ProtoReflect() protoreflect.Message

func (*Distribution) Reset 

func (x *Distribution) Reset()

func (*Distribution) String 

func (x *Distribution) String() string

type DistributionKeyEntry 

type DistributionKeyEntry struct {
	Column       string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	HashFunction string `protobuf:"bytes,2,opt,name=hashFunction,proto3" json:"hashFunction,omitempty"`
	// contains filtered or unexported fields
}

func (*DistributionKeyEntry) Descriptor deprecated 

func (*DistributionKeyEntry) Descriptor() ([]byte, []int)

Deprecated: Use DistributionKeyEntry.ProtoReflect.Descriptor instead.

func (*DistributionKeyEntry) GetColumn 

func (x *DistributionKeyEntry) GetColumn() string

func (*DistributionKeyEntry) GetHashFunction 

func (x *DistributionKeyEntry) GetHashFunction() string

func (*DistributionKeyEntry) ProtoMessage 

func (*DistributionKeyEntry) ProtoMessage()

func (*DistributionKeyEntry) ProtoReflect 

func (x *DistributionKeyEntry) ProtoReflect() protoreflect.Message

func (*DistributionKeyEntry) Reset 

func (x *DistributionKeyEntry) Reset()

func (*DistributionKeyEntry) String 

func (x *DistributionKeyEntry) String() string

type DistributionServiceClient 

type DistributionServiceClient interface {
	CreateDistribution(ctx context.Context, in *CreateDistributionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DropDistribution(ctx context.Context, in *DropDistributionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListDistributions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListDistributionsReply, error)
	AlterDistributionAttach(ctx context.Context, in *AlterDistributionAttachRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AlterDistributionDetach(ctx context.Context, in *AlterDistributionDetachRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetDistribution(ctx context.Context, in *GetDistributionRequest, opts ...grpc.CallOption) (*GetDistributionReply, error)
	GetRelationDistribution(ctx context.Context, in *GetRelationDistributionRequest, opts ...grpc.CallOption) (*GetRelationDistributionReply, error)
}

DistributionServiceClient is the client API for DistributionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDistributionServiceClient 

func NewDistributionServiceClient(cc grpc.ClientConnInterface) DistributionServiceClient

type DistributionServiceServer 

type DistributionServiceServer interface {
	CreateDistribution(context.Context, *CreateDistributionRequest) (*emptypb.Empty, error)
	DropDistribution(context.Context, *DropDistributionRequest) (*emptypb.Empty, error)
	ListDistributions(context.Context, *emptypb.Empty) (*ListDistributionsReply, error)
	AlterDistributionAttach(context.Context, *AlterDistributionAttachRequest) (*emptypb.Empty, error)
	AlterDistributionDetach(context.Context, *AlterDistributionDetachRequest) (*emptypb.Empty, error)
	GetDistribution(context.Context, *GetDistributionRequest) (*GetDistributionReply, error)
	GetRelationDistribution(context.Context, *GetRelationDistributionRequest) (*GetRelationDistributionReply, error)
	// contains filtered or unexported methods
}

DistributionServiceServer is the server API for DistributionService service. All implementations must embed UnimplementedDistributionServiceServer for forward compatibility

type DropAllKeyRangesResponse 

type DropAllKeyRangesResponse struct {
	KeyRange []*KeyRangeInfo `protobuf:"bytes,1,rep,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	// contains filtered or unexported fields
}

func (*DropAllKeyRangesResponse) Descriptor deprecated 

func (*DropAllKeyRangesResponse) Descriptor() ([]byte, []int)

Deprecated: Use DropAllKeyRangesResponse.ProtoReflect.Descriptor instead.

func (*DropAllKeyRangesResponse) GetKeyRange 

func (x *DropAllKeyRangesResponse) GetKeyRange() []*KeyRangeInfo

func (*DropAllKeyRangesResponse) ProtoMessage 

func (*DropAllKeyRangesResponse) ProtoMessage()

func (*DropAllKeyRangesResponse) ProtoReflect 

func (x *DropAllKeyRangesResponse) ProtoReflect() protoreflect.Message

func (*DropAllKeyRangesResponse) Reset 

func (x *DropAllKeyRangesResponse) Reset()

func (*DropAllKeyRangesResponse) String 

func (x *DropAllKeyRangesResponse) String() string

type DropDistributionRequest 

type DropDistributionRequest struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DropDistributionRequest) Descriptor deprecated 

func (*DropDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropDistributionRequest.ProtoReflect.Descriptor instead.

func (*DropDistributionRequest) GetIds 

func (x *DropDistributionRequest) GetIds() []string

func (*DropDistributionRequest) ProtoMessage 

func (*DropDistributionRequest) ProtoMessage()

func (*DropDistributionRequest) ProtoReflect 

func (x *DropDistributionRequest) ProtoReflect() protoreflect.Message

func (*DropDistributionRequest) Reset 

func (x *DropDistributionRequest) Reset()

func (*DropDistributionRequest) String 

func (x *DropDistributionRequest) String() string

type DropKeyRangeRequest 

type DropKeyRangeRequest struct {
	Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DropKeyRangeRequest) Descriptor deprecated 

func (*DropKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*DropKeyRangeRequest) GetId 

func (x *DropKeyRangeRequest) GetId() []string

func (*DropKeyRangeRequest) ProtoMessage 

func (*DropKeyRangeRequest) ProtoMessage()

func (*DropKeyRangeRequest) ProtoReflect 

func (x *DropKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*DropKeyRangeRequest) Reset 

func (x *DropKeyRangeRequest) Reset()

func (*DropKeyRangeRequest) String 

func (x *DropKeyRangeRequest) String() string

type DropShardingRuleRequest 

type DropShardingRuleRequest struct {
	Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DropShardingRuleRequest) Descriptor deprecated 

func (*DropShardingRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropShardingRuleRequest.ProtoReflect.Descriptor instead.

func (*DropShardingRuleRequest) GetId 

func (x *DropShardingRuleRequest) GetId() []string

func (*DropShardingRuleRequest) ProtoMessage 

func (*DropShardingRuleRequest) ProtoMessage()

func (*DropShardingRuleRequest) ProtoReflect 

func (x *DropShardingRuleRequest) ProtoReflect() protoreflect.Message

func (*DropShardingRuleRequest) Reset 

func (x *DropShardingRuleRequest) Reset()

func (*DropShardingRuleRequest) String 

func (x *DropShardingRuleRequest) String() string

type GetBalancerTaskReply 

type GetBalancerTaskReply struct {
	Task *BalancerTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBalancerTaskReply) Descriptor deprecated 

func (*GetBalancerTaskReply) Descriptor() ([]byte, []int)

Deprecated: Use GetBalancerTaskReply.ProtoReflect.Descriptor instead.

func (*GetBalancerTaskReply) GetTask 

func (x *GetBalancerTaskReply) GetTask() *BalancerTask

func (*GetBalancerTaskReply) ProtoMessage 

func (*GetBalancerTaskReply) ProtoMessage()

func (*GetBalancerTaskReply) ProtoReflect 

func (x *GetBalancerTaskReply) ProtoReflect() protoreflect.Message

func (*GetBalancerTaskReply) Reset 

func (x *GetBalancerTaskReply) Reset()

func (*GetBalancerTaskReply) String 

func (x *GetBalancerTaskReply) String() string

type GetCoordinatorResponse 

type GetCoordinatorResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCoordinatorResponse) Descriptor deprecated 

func (*GetCoordinatorResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetCoordinatorResponse.ProtoReflect.Descriptor instead.

func (*GetCoordinatorResponse) GetAddress 

func (x *GetCoordinatorResponse) GetAddress() string

func (*GetCoordinatorResponse) ProtoMessage 

func (*GetCoordinatorResponse) ProtoMessage()

func (*GetCoordinatorResponse) ProtoReflect 

func (x *GetCoordinatorResponse) ProtoReflect() protoreflect.Message

func (*GetCoordinatorResponse) Reset 

func (x *GetCoordinatorResponse) Reset()

func (*GetCoordinatorResponse) String 

func (x *GetCoordinatorResponse) String() string

type GetDistributionReply 

type GetDistributionReply struct {
	Distribution *Distribution `protobuf:"bytes,1,opt,name=distribution,proto3" json:"distribution,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDistributionReply) Descriptor deprecated 

func (*GetDistributionReply) Descriptor() ([]byte, []int)

Deprecated: Use GetDistributionReply.ProtoReflect.Descriptor instead.

func (*GetDistributionReply) GetDistribution 

func (x *GetDistributionReply) GetDistribution() *Distribution

func (*GetDistributionReply) ProtoMessage 

func (*GetDistributionReply) ProtoMessage()

func (*GetDistributionReply) ProtoReflect 

func (x *GetDistributionReply) ProtoReflect() protoreflect.Message

func (*GetDistributionReply) Reset 

func (x *GetDistributionReply) Reset()

func (*GetDistributionReply) String 

func (x *GetDistributionReply) String() string

type GetDistributionRequest 

type GetDistributionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDistributionRequest) Descriptor deprecated 

func (*GetDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDistributionRequest.ProtoReflect.Descriptor instead.

func (*GetDistributionRequest) GetId 

func (x *GetDistributionRequest) GetId() string

func (*GetDistributionRequest) ProtoMessage 

func (*GetDistributionRequest) ProtoMessage()

func (*GetDistributionRequest) ProtoReflect 

func (x *GetDistributionRequest) ProtoReflect() protoreflect.Message

func (*GetDistributionRequest) Reset 

func (x *GetDistributionRequest) Reset()

func (*GetDistributionRequest) String 

func (x *GetDistributionRequest) String() string

type GetKeyRangeRequest 

type GetKeyRangeRequest struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyRangeRequest) Descriptor deprecated 

func (*GetKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*GetKeyRangeRequest) GetIds 

func (x *GetKeyRangeRequest) GetIds() []string

func (*GetKeyRangeRequest) ProtoMessage 

func (*GetKeyRangeRequest) ProtoMessage()

func (*GetKeyRangeRequest) ProtoReflect 

func (x *GetKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*GetKeyRangeRequest) Reset 

func (x *GetKeyRangeRequest) Reset()

func (*GetKeyRangeRequest) String 

func (x *GetKeyRangeRequest) String() string

type GetMoveTaskGroupReply 

type GetMoveTaskGroupReply struct {
	TaskGroup *MoveTaskGroup `protobuf:"bytes,1,opt,name=taskGroup,proto3" json:"taskGroup,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMoveTaskGroupReply) Descriptor deprecated 

func (*GetMoveTaskGroupReply) Descriptor() ([]byte, []int)

Deprecated: Use GetMoveTaskGroupReply.ProtoReflect.Descriptor instead.

func (*GetMoveTaskGroupReply) GetTaskGroup 

func (x *GetMoveTaskGroupReply) GetTaskGroup() *MoveTaskGroup

func (*GetMoveTaskGroupReply) ProtoMessage 

func (*GetMoveTaskGroupReply) ProtoMessage()

func (*GetMoveTaskGroupReply) ProtoReflect 

func (x *GetMoveTaskGroupReply) ProtoReflect() protoreflect.Message

func (*GetMoveTaskGroupReply) Reset 

func (x *GetMoveTaskGroupReply) Reset()

func (*GetMoveTaskGroupReply) String 

func (x *GetMoveTaskGroupReply) String() string

type GetOperationReply 

type GetOperationReply struct {
	Operation *Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationReply) Descriptor deprecated 

func (*GetOperationReply) Descriptor() ([]byte, []int)

Deprecated: Use GetOperationReply.ProtoReflect.Descriptor instead.

func (*GetOperationReply) GetOperation 

func (x *GetOperationReply) GetOperation() *Operation

func (*GetOperationReply) ProtoMessage 

func (*GetOperationReply) ProtoMessage()

func (*GetOperationReply) ProtoReflect 

func (x *GetOperationReply) ProtoReflect() protoreflect.Message

func (*GetOperationReply) Reset 

func (x *GetOperationReply) Reset()

func (*GetOperationReply) String 

func (x *GetOperationReply) String() string

type GetOperationRequest 

type GetOperationRequest struct {
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationRequest) Descriptor deprecated 

func (*GetOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetOperationRequest.ProtoReflect.Descriptor instead.

func (*GetOperationRequest) GetOperationId 

func (x *GetOperationRequest) GetOperationId() string

func (*GetOperationRequest) ProtoMessage 

func (*GetOperationRequest) ProtoMessage()

func (*GetOperationRequest) ProtoReflect 

func (x *GetOperationRequest) ProtoReflect() protoreflect.Message

func (*GetOperationRequest) Reset 

func (x *GetOperationRequest) Reset()

func (*GetOperationRequest) String 

func (x *GetOperationRequest) String() string

type GetRedistributeTaskReply 

type GetRedistributeTaskReply struct {
	Task *RedistributeTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRedistributeTaskReply) Descriptor deprecated 

func (*GetRedistributeTaskReply) Descriptor() ([]byte, []int)

Deprecated: Use GetRedistributeTaskReply.ProtoReflect.Descriptor instead.

func (*GetRedistributeTaskReply) GetTask 

func (x *GetRedistributeTaskReply) GetTask() *RedistributeTask

func (*GetRedistributeTaskReply) ProtoMessage 

func (*GetRedistributeTaskReply) ProtoMessage()

func (*GetRedistributeTaskReply) ProtoReflect 

func (x *GetRedistributeTaskReply) ProtoReflect() protoreflect.Message

func (*GetRedistributeTaskReply) Reset 

func (x *GetRedistributeTaskReply) Reset()

func (*GetRedistributeTaskReply) String 

func (x *GetRedistributeTaskReply) String() string

type GetRelationDistributionReply 

type GetRelationDistributionReply struct {
	Distribution *Distribution `protobuf:"bytes,1,opt,name=distribution,proto3" json:"distribution,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRelationDistributionReply) Descriptor deprecated 

func (*GetRelationDistributionReply) Descriptor() ([]byte, []int)

Deprecated: Use GetRelationDistributionReply.ProtoReflect.Descriptor instead.

func (*GetRelationDistributionReply) GetDistribution 

func (x *GetRelationDistributionReply) GetDistribution() *Distribution

func (*GetRelationDistributionReply) ProtoMessage 

func (*GetRelationDistributionReply) ProtoMessage()

func (*GetRelationDistributionReply) ProtoReflect 

func (x *GetRelationDistributionReply) ProtoReflect() protoreflect.Message

func (*GetRelationDistributionReply) Reset 

func (x *GetRelationDistributionReply) Reset()

func (*GetRelationDistributionReply) String 

func (x *GetRelationDistributionReply) String() string

type GetRelationDistributionRequest 

type GetRelationDistributionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRelationDistributionRequest) Descriptor deprecated 

func (*GetRelationDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRelationDistributionRequest.ProtoReflect.Descriptor instead.

func (*GetRelationDistributionRequest) GetId 

func (x *GetRelationDistributionRequest) GetId() string

func (*GetRelationDistributionRequest) ProtoMessage 

func (*GetRelationDistributionRequest) ProtoMessage()

func (*GetRelationDistributionRequest) ProtoReflect 

func (x *GetRelationDistributionRequest) ProtoReflect() protoreflect.Message

func (*GetRelationDistributionRequest) Reset 

func (x *GetRelationDistributionRequest) Reset()

func (*GetRelationDistributionRequest) String 

func (x *GetRelationDistributionRequest) String() string

type GetRouterStatusReply 

type GetRouterStatusReply struct {
	Status RouterStatus `protobuf:"varint,1,opt,name=status,proto3,enum=spqr.RouterStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRouterStatusReply) Descriptor deprecated 

func (*GetRouterStatusReply) Descriptor() ([]byte, []int)

Deprecated: Use GetRouterStatusReply.ProtoReflect.Descriptor instead.

func (*GetRouterStatusReply) GetStatus 

func (x *GetRouterStatusReply) GetStatus() RouterStatus

func (*GetRouterStatusReply) ProtoMessage 

func (*GetRouterStatusReply) ProtoMessage()

func (*GetRouterStatusReply) ProtoReflect 

func (x *GetRouterStatusReply) ProtoReflect() protoreflect.Message

func (*GetRouterStatusReply) Reset 

func (x *GetRouterStatusReply) Reset()

func (*GetRouterStatusReply) String 

func (x *GetRouterStatusReply) String() string

type JoinType 

type JoinType int32
const (
	JoinType_JoinNone  JoinType = 0
	JoinType_JoinLeft  JoinType = 1
	JoinType_JoinRight JoinType = 2
)

func (JoinType) Descriptor 

func (JoinType) Descriptor() protoreflect.EnumDescriptor

func (JoinType) Enum 

func (x JoinType) Enum() *JoinType

func (JoinType) EnumDescriptor deprecated 

func (JoinType) EnumDescriptor() ([]byte, []int)

Deprecated: Use JoinType.Descriptor instead.

func (JoinType) Number 

func (x JoinType) Number() protoreflect.EnumNumber

func (JoinType) String 

func (x JoinType) String() string

func (JoinType) Type 

func (JoinType) Type() protoreflect.EnumType

type KeyRangeBound 

type KeyRangeBound struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyRangeBound) Descriptor deprecated 

func (*KeyRangeBound) Descriptor() ([]byte, []int)

Deprecated: Use KeyRangeBound.ProtoReflect.Descriptor instead.

func (*KeyRangeBound) GetValues 

func (x *KeyRangeBound) GetValues() [][]byte

func (*KeyRangeBound) ProtoMessage 

func (*KeyRangeBound) ProtoMessage()

func (*KeyRangeBound) ProtoReflect 

func (x *KeyRangeBound) ProtoReflect() protoreflect.Message

func (*KeyRangeBound) Reset 

func (x *KeyRangeBound) Reset()

func (*KeyRangeBound) String 

func (x *KeyRangeBound) String() string

type KeyRangeInfo 

type KeyRangeInfo struct {
	Bound          *KeyRangeBound `protobuf:"bytes,1,opt,name=bound,proto3" json:"bound,omitempty"`
	Krid           string         `protobuf:"bytes,2,opt,name=krid,proto3" json:"krid,omitempty"`
	ShardId        string         `protobuf:"bytes,3,opt,name=shardId,proto3" json:"shardId,omitempty"`
	DistributionId string         `protobuf:"bytes,4,opt,name=distributionId,proto3" json:"distributionId,omitempty"`
	// contains filtered or unexported fields
}

key range info is mapped to shard

func (*KeyRangeInfo) Descriptor deprecated 

func (*KeyRangeInfo) Descriptor() ([]byte, []int)

Deprecated: Use KeyRangeInfo.ProtoReflect.Descriptor instead.

func (*KeyRangeInfo) GetBound 

func (x *KeyRangeInfo) GetBound() *KeyRangeBound

func (*KeyRangeInfo) GetDistributionId 

func (x *KeyRangeInfo) GetDistributionId() string

func (*KeyRangeInfo) GetKrid 

func (x *KeyRangeInfo) GetKrid() string

func (*KeyRangeInfo) GetShardId 

func (x *KeyRangeInfo) GetShardId() string

func (*KeyRangeInfo) ProtoMessage 

func (*KeyRangeInfo) ProtoMessage()

func (*KeyRangeInfo) ProtoReflect 

func (x *KeyRangeInfo) ProtoReflect() protoreflect.Message

func (*KeyRangeInfo) Reset 

func (x *KeyRangeInfo) Reset()

func (*KeyRangeInfo) String 

func (x *KeyRangeInfo) String() string

type KeyRangeReply 

type KeyRangeReply struct {
	KeyRangesInfo []*KeyRangeInfo `protobuf:"bytes,1,rep,name=key_ranges_info,json=keyRangesInfo,proto3" json:"key_ranges_info,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyRangeReply) Descriptor deprecated 

func (*KeyRangeReply) Descriptor() ([]byte, []int)

Deprecated: Use KeyRangeReply.ProtoReflect.Descriptor instead.

func (*KeyRangeReply) GetKeyRangesInfo 

func (x *KeyRangeReply) GetKeyRangesInfo() []*KeyRangeInfo

func (*KeyRangeReply) ProtoMessage 

func (*KeyRangeReply) ProtoMessage()

func (*KeyRangeReply) ProtoReflect 

func (x *KeyRangeReply) ProtoReflect() protoreflect.Message

func (*KeyRangeReply) Reset 

func (x *KeyRangeReply) Reset()

func (*KeyRangeReply) String 

func (x *KeyRangeReply) String() string

type KeyRangeServiceClient 

type KeyRangeServiceClient interface {
	GetKeyRange(ctx context.Context, in *GetKeyRangeRequest, opts ...grpc.CallOption) (*KeyRangeReply, error)
	ListKeyRange(ctx context.Context, in *ListKeyRangeRequest, opts ...grpc.CallOption) (*KeyRangeReply, error)
	ListAllKeyRanges(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*KeyRangeReply, error)
	LockKeyRange(ctx context.Context, in *LockKeyRangeRequest, opts ...grpc.CallOption) (*ModifyReply, error)
	CreateKeyRange(ctx context.Context, in *CreateKeyRangeRequest, opts ...grpc.CallOption) (*ModifyReply, error)
	DropKeyRange(ctx context.Context, in *DropKeyRangeRequest, opts ...grpc.CallOption) (*ModifyReply, error)
	DropAllKeyRanges(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DropAllKeyRangesResponse, error)
	UnlockKeyRange(ctx context.Context, in *UnlockKeyRangeRequest, opts ...grpc.CallOption) (*ModifyReply, error)
	SplitKeyRange(ctx context.Context, in *SplitKeyRangeRequest, opts ...grpc.CallOption) (*ModifyReply, error)
	MergeKeyRange(ctx context.Context, in *MergeKeyRangeRequest, opts ...grpc.CallOption) (*ModifyReply, error)
	MoveKeyRange(ctx context.Context, in *MoveKeyRangeRequest, opts ...grpc.CallOption) (*ModifyReply, error)
	ResolveKeyRange(ctx context.Context, in *ResolveKeyRangeRequest, opts ...grpc.CallOption) (*ResolveKeyRangeReply, error)
	BatchMoveKeyRange(ctx context.Context, in *BatchMoveKeyRangeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RedistributeKeyRange(ctx context.Context, in *RedistributeKeyRangeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RenameKeyRange(ctx context.Context, in *RenameKeyRangeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

KeyRangeServiceClient is the client API for KeyRangeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewKeyRangeServiceClient 

func NewKeyRangeServiceClient(cc grpc.ClientConnInterface) KeyRangeServiceClient

type KeyRangeServiceServer 

type KeyRangeServiceServer interface {
	GetKeyRange(context.Context, *GetKeyRangeRequest) (*KeyRangeReply, error)
	ListKeyRange(context.Context, *ListKeyRangeRequest) (*KeyRangeReply, error)
	ListAllKeyRanges(context.Context, *emptypb.Empty) (*KeyRangeReply, error)
	LockKeyRange(context.Context, *LockKeyRangeRequest) (*ModifyReply, error)
	CreateKeyRange(context.Context, *CreateKeyRangeRequest) (*ModifyReply, error)
	DropKeyRange(context.Context, *DropKeyRangeRequest) (*ModifyReply, error)
	DropAllKeyRanges(context.Context, *emptypb.Empty) (*DropAllKeyRangesResponse, error)
	UnlockKeyRange(context.Context, *UnlockKeyRangeRequest) (*ModifyReply, error)
	SplitKeyRange(context.Context, *SplitKeyRangeRequest) (*ModifyReply, error)
	MergeKeyRange(context.Context, *MergeKeyRangeRequest) (*ModifyReply, error)
	MoveKeyRange(context.Context, *MoveKeyRangeRequest) (*ModifyReply, error)
	ResolveKeyRange(context.Context, *ResolveKeyRangeRequest) (*ResolveKeyRangeReply, error)
	BatchMoveKeyRange(context.Context, *BatchMoveKeyRangeRequest) (*emptypb.Empty, error)
	RedistributeKeyRange(context.Context, *RedistributeKeyRangeRequest) (*emptypb.Empty, error)
	RenameKeyRange(context.Context, *RenameKeyRangeRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

KeyRangeServiceServer is the server API for KeyRangeService service. All implementations must embed UnimplementedKeyRangeServiceServer for forward compatibility

type KeyRangeStatus 

type KeyRangeStatus int32
const (
	KeyRangeStatus_LOCKED    KeyRangeStatus = 0
	KeyRangeStatus_AVAILABLE KeyRangeStatus = 1
)

func (KeyRangeStatus) Descriptor 

func (KeyRangeStatus) Descriptor() protoreflect.EnumDescriptor

func (KeyRangeStatus) Enum 

func (x KeyRangeStatus) Enum() *KeyRangeStatus

func (KeyRangeStatus) EnumDescriptor deprecated 

func (KeyRangeStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use KeyRangeStatus.Descriptor instead.

func (KeyRangeStatus) Number 

func (x KeyRangeStatus) Number() protoreflect.EnumNumber

func (KeyRangeStatus) String 

func (x KeyRangeStatus) String() string

func (KeyRangeStatus) Type 

func (KeyRangeStatus) Type() protoreflect.EnumType

type ListBackendConntionsReply 

type ListBackendConntionsReply struct {
	Conns []*BackendConnectionsInfo `protobuf:"bytes,1,rep,name=conns,proto3" json:"conns,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBackendConntionsReply) Descriptor deprecated 

func (*ListBackendConntionsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListBackendConntionsReply.ProtoReflect.Descriptor instead.

func (*ListBackendConntionsReply) GetConns 

func (x *ListBackendConntionsReply) GetConns() []*BackendConnectionsInfo

func (*ListBackendConntionsReply) ProtoMessage 

func (*ListBackendConntionsReply) ProtoMessage()

func (*ListBackendConntionsReply) ProtoReflect 

func (x *ListBackendConntionsReply) ProtoReflect() protoreflect.Message

func (*ListBackendConntionsReply) Reset 

func (x *ListBackendConntionsReply) Reset()

func (*ListBackendConntionsReply) String 

func (x *ListBackendConntionsReply) String() string

type ListClientsReply 

type ListClientsReply struct {
	Clients []*ClientInfo `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClientsReply) Descriptor deprecated 

func (*ListClientsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListClientsReply.ProtoReflect.Descriptor instead.

func (*ListClientsReply) GetClients 

func (x *ListClientsReply) GetClients() []*ClientInfo

func (*ListClientsReply) ProtoMessage 

func (*ListClientsReply) ProtoMessage()

func (*ListClientsReply) ProtoReflect 

func (x *ListClientsReply) ProtoReflect() protoreflect.Message

func (*ListClientsReply) Reset 

func (x *ListClientsReply) Reset()

func (*ListClientsReply) String 

func (x *ListClientsReply) String() string

type ListDistributionsReply 

type ListDistributionsReply struct {
	Distributions []*Distribution `protobuf:"bytes,1,rep,name=distributions,proto3" json:"distributions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDistributionsReply) Descriptor deprecated 

func (*ListDistributionsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListDistributionsReply.ProtoReflect.Descriptor instead.

func (*ListDistributionsReply) GetDistributions 

func (x *ListDistributionsReply) GetDistributions() []*Distribution

func (*ListDistributionsReply) ProtoMessage 

func (*ListDistributionsReply) ProtoMessage()

func (*ListDistributionsReply) ProtoReflect 

func (x *ListDistributionsReply) ProtoReflect() protoreflect.Message

func (*ListDistributionsReply) Reset 

func (x *ListDistributionsReply) Reset()

func (*ListDistributionsReply) String 

func (x *ListDistributionsReply) String() string

type ListKeyRangeRequest 

type ListKeyRangeRequest struct {
	Distribution string `protobuf:"bytes,1,opt,name=distribution,proto3" json:"distribution,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeyRangeRequest) Descriptor deprecated 

func (*ListKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*ListKeyRangeRequest) GetDistribution 

func (x *ListKeyRangeRequest) GetDistribution() string

func (*ListKeyRangeRequest) ProtoMessage 

func (*ListKeyRangeRequest) ProtoMessage()

func (*ListKeyRangeRequest) ProtoReflect 

func (x *ListKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*ListKeyRangeRequest) Reset 

func (x *ListKeyRangeRequest) Reset()

func (*ListKeyRangeRequest) String 

func (x *ListKeyRangeRequest) String() string

type ListPoolsResponse 

type ListPoolsResponse struct {
	Pools []*PoolInfo `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPoolsResponse) Descriptor deprecated 

func (*ListPoolsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListPoolsResponse.ProtoReflect.Descriptor instead.

func (*ListPoolsResponse) GetPools 

func (x *ListPoolsResponse) GetPools() []*PoolInfo

func (*ListPoolsResponse) ProtoMessage 

func (*ListPoolsResponse) ProtoMessage()

func (*ListPoolsResponse) ProtoReflect 

func (x *ListPoolsResponse) ProtoReflect() protoreflect.Message

func (*ListPoolsResponse) Reset 

func (x *ListPoolsResponse) Reset()

func (*ListPoolsResponse) String 

func (x *ListPoolsResponse) String() string

type ListRoutersReply 

type ListRoutersReply struct {
	Routers []*Router `protobuf:"bytes,1,rep,name=routers,proto3" json:"routers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRoutersReply) Descriptor deprecated 

func (*ListRoutersReply) Descriptor() ([]byte, []int)

Deprecated: Use ListRoutersReply.ProtoReflect.Descriptor instead.

func (*ListRoutersReply) GetRouters 

func (x *ListRoutersReply) GetRouters() []*Router

func (*ListRoutersReply) ProtoMessage 

func (*ListRoutersReply) ProtoMessage()

func (*ListRoutersReply) ProtoReflect 

func (x *ListRoutersReply) ProtoReflect() protoreflect.Message

func (*ListRoutersReply) Reset 

func (x *ListRoutersReply) Reset()

func (*ListRoutersReply) String 

func (x *ListRoutersReply) String() string

type ListShardingRuleReply 

type ListShardingRuleReply struct {
	Rules []*ShardingRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*ListShardingRuleReply) Descriptor deprecated 

func (*ListShardingRuleReply) Descriptor() ([]byte, []int)

Deprecated: Use ListShardingRuleReply.ProtoReflect.Descriptor instead.

func (*ListShardingRuleReply) GetRules 

func (x *ListShardingRuleReply) GetRules() []*ShardingRule

func (*ListShardingRuleReply) ProtoMessage 

func (*ListShardingRuleReply) ProtoMessage()

func (*ListShardingRuleReply) ProtoReflect 

func (x *ListShardingRuleReply) ProtoReflect() protoreflect.Message

func (*ListShardingRuleReply) Reset 

func (x *ListShardingRuleReply) Reset()

func (*ListShardingRuleReply) String 

func (x *ListShardingRuleReply) String() string

type ListShardingRuleRequest 

type ListShardingRuleRequest struct {
	Distribution string `protobuf:"bytes,1,opt,name=distribution,proto3" json:"distribution,omitempty"`
	// contains filtered or unexported fields
}

func (*ListShardingRuleRequest) Descriptor deprecated 

func (*ListShardingRuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListShardingRuleRequest.ProtoReflect.Descriptor instead.

func (*ListShardingRuleRequest) GetDistribution 

func (x *ListShardingRuleRequest) GetDistribution() string

func (*ListShardingRuleRequest) ProtoMessage 

func (*ListShardingRuleRequest) ProtoMessage()

func (*ListShardingRuleRequest) ProtoReflect 

func (x *ListShardingRuleRequest) ProtoReflect() protoreflect.Message

func (*ListShardingRuleRequest) Reset 

func (x *ListShardingRuleRequest) Reset()

func (*ListShardingRuleRequest) String 

func (x *ListShardingRuleRequest) String() string

type ListShardsReply 

type ListShardsReply struct {
	Shards []*Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

func (*ListShardsReply) Descriptor deprecated 

func (*ListShardsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListShardsReply.ProtoReflect.Descriptor instead.

func (*ListShardsReply) GetShards 

func (x *ListShardsReply) GetShards() []*Shard

func (*ListShardsReply) ProtoMessage 

func (*ListShardsReply) ProtoMessage()

func (*ListShardsReply) ProtoReflect 

func (x *ListShardsReply) ProtoReflect() protoreflect.Message

func (*ListShardsReply) Reset 

func (x *ListShardsReply) Reset()

func (*ListShardsReply) String 

func (x *ListShardsReply) String() string

type LockKeyRangeRequest 

type LockKeyRangeRequest struct {
	Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*LockKeyRangeRequest) Descriptor deprecated 

func (*LockKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use LockKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*LockKeyRangeRequest) GetId 

func (x *LockKeyRangeRequest) GetId() []string

func (*LockKeyRangeRequest) ProtoMessage 

func (*LockKeyRangeRequest) ProtoMessage()

func (*LockKeyRangeRequest) ProtoReflect 

func (x *LockKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*LockKeyRangeRequest) Reset 

func (x *LockKeyRangeRequest) Reset()

func (*LockKeyRangeRequest) String 

func (x *LockKeyRangeRequest) String() string

type MergeKeyRangeRequest 

type MergeKeyRangeRequest struct {
	BaseId      string `protobuf:"bytes,1,opt,name=base_id,json=baseId,proto3" json:"base_id,omitempty"`
	AppendageId string `protobuf:"bytes,2,opt,name=appendage_id,json=appendageId,proto3" json:"appendage_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MergeKeyRangeRequest) Descriptor deprecated 

func (*MergeKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use MergeKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*MergeKeyRangeRequest) GetAppendageId 

func (x *MergeKeyRangeRequest) GetAppendageId() string

func (*MergeKeyRangeRequest) GetBaseId 

func (x *MergeKeyRangeRequest) GetBaseId() string

func (*MergeKeyRangeRequest) ProtoMessage 

func (*MergeKeyRangeRequest) ProtoMessage()

func (*MergeKeyRangeRequest) ProtoReflect 

func (x *MergeKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*MergeKeyRangeRequest) Reset 

func (x *MergeKeyRangeRequest) Reset()

func (*MergeKeyRangeRequest) String 

func (x *MergeKeyRangeRequest) String() string

type ModifyReply 

type ModifyReply struct {
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyReply) Descriptor deprecated 

func (*ModifyReply) Descriptor() ([]byte, []int)

Deprecated: Use ModifyReply.ProtoReflect.Descriptor instead.

func (*ModifyReply) GetOperationId 

func (x *ModifyReply) GetOperationId() string

func (*ModifyReply) ProtoMessage 

func (*ModifyReply) ProtoMessage()

func (*ModifyReply) ProtoReflect 

func (x *ModifyReply) ProtoReflect() protoreflect.Message

func (*ModifyReply) Reset 

func (x *ModifyReply) Reset()

func (*ModifyReply) String 

func (x *ModifyReply) String() string

type MoveKeyRangeRequest 

type MoveKeyRangeRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ToShardId string `protobuf:"bytes,2,opt,name=toShardId,proto3" json:"toShardId,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveKeyRangeRequest) Descriptor deprecated 

func (*MoveKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use MoveKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*MoveKeyRangeRequest) GetId 

func (x *MoveKeyRangeRequest) GetId() string

func (*MoveKeyRangeRequest) GetToShardId 

func (x *MoveKeyRangeRequest) GetToShardId() string

func (*MoveKeyRangeRequest) ProtoMessage 

func (*MoveKeyRangeRequest) ProtoMessage()

func (*MoveKeyRangeRequest) ProtoReflect 

func (x *MoveKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*MoveKeyRangeRequest) Reset 

func (x *MoveKeyRangeRequest) Reset()

func (*MoveKeyRangeRequest) String 

func (x *MoveKeyRangeRequest) String() string

type MoveTask 

type MoveTask struct {
	KeyRangeIdTemp string     `protobuf:"bytes,1,opt,name=keyRangeIdTemp,proto3" json:"keyRangeIdTemp,omitempty"`
	Bound          [][]byte   `protobuf:"bytes,2,rep,name=bound,proto3" json:"bound,omitempty"`
	Status         TaskStatus `protobuf:"varint,3,opt,name=status,proto3,enum=spqr.TaskStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTask) Descriptor deprecated 

func (*MoveTask) Descriptor() ([]byte, []int)

Deprecated: Use MoveTask.ProtoReflect.Descriptor instead.

func (*MoveTask) GetBound 

func (x *MoveTask) GetBound() [][]byte

func (*MoveTask) GetKeyRangeIdTemp 

func (x *MoveTask) GetKeyRangeIdTemp() string

func (*MoveTask) GetStatus 

func (x *MoveTask) GetStatus() TaskStatus

func (*MoveTask) ProtoMessage 

func (*MoveTask) ProtoMessage()

func (*MoveTask) ProtoReflect 

func (x *MoveTask) ProtoReflect() protoreflect.Message

func (*MoveTask) Reset 

func (x *MoveTask) Reset()

func (*MoveTask) String 

func (x *MoveTask) String() string

type MoveTaskGroup 

type MoveTaskGroup struct {
	Tasks          []*MoveTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Type           SplitType   `protobuf:"varint,2,opt,name=type,proto3,enum=spqr.SplitType" json:"type,omitempty"`
	ShardIdTo      string      `protobuf:"bytes,4,opt,name=shardIdTo,proto3" json:"shardIdTo,omitempty"`
	KeyRangeIdFrom string      `protobuf:"bytes,5,opt,name=keyRangeIdFrom,proto3" json:"keyRangeIdFrom,omitempty"`
	KeyRangeIdTo   string      `protobuf:"bytes,6,opt,name=keyRangeIdTo,proto3" json:"keyRangeIdTo,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTaskGroup) Descriptor deprecated 

func (*MoveTaskGroup) Descriptor() ([]byte, []int)

Deprecated: Use MoveTaskGroup.ProtoReflect.Descriptor instead.

func (*MoveTaskGroup) GetKeyRangeIdFrom 

func (x *MoveTaskGroup) GetKeyRangeIdFrom() string

func (*MoveTaskGroup) GetKeyRangeIdTo 

func (x *MoveTaskGroup) GetKeyRangeIdTo() string

func (*MoveTaskGroup) GetShardIdTo 

func (x *MoveTaskGroup) GetShardIdTo() string

func (*MoveTaskGroup) GetTasks 

func (x *MoveTaskGroup) GetTasks() []*MoveTask

func (*MoveTaskGroup) GetType 

func (x *MoveTaskGroup) GetType() SplitType

func (*MoveTaskGroup) ProtoMessage 

func (*MoveTaskGroup) ProtoMessage()

func (*MoveTaskGroup) ProtoReflect 

func (x *MoveTaskGroup) ProtoReflect() protoreflect.Message

func (*MoveTaskGroup) Reset 

func (x *MoveTaskGroup) Reset()

func (*MoveTaskGroup) String 

func (x *MoveTaskGroup) String() string

type MoveTasksServiceClient 

type MoveTasksServiceClient interface {
	GetMoveTaskGroup(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMoveTaskGroupReply, error)
	WriteMoveTaskGroup(ctx context.Context, in *WriteMoveTaskGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveMoveTaskGroup(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

MoveTasksServiceClient is the client API for MoveTasksService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMoveTasksServiceClient 

func NewMoveTasksServiceClient(cc grpc.ClientConnInterface) MoveTasksServiceClient

type MoveTasksServiceServer 

type MoveTasksServiceServer interface {
	GetMoveTaskGroup(context.Context, *emptypb.Empty) (*GetMoveTaskGroupReply, error)
	WriteMoveTaskGroup(context.Context, *WriteMoveTaskGroupRequest) (*emptypb.Empty, error)
	RemoveMoveTaskGroup(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

MoveTasksServiceServer is the server API for MoveTasksService service. All implementations must embed UnimplementedMoveTasksServiceServer for forward compatibility

type Operation 

type Operation struct {
	Id     string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status OperationStatus `protobuf:"varint,2,opt,name=status,proto3,enum=spqr.OperationStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Operation) Descriptor deprecated 

func (*Operation) Descriptor() ([]byte, []int)

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetId 

func (x *Operation) GetId() string

func (*Operation) GetStatus 

func (x *Operation) GetStatus() OperationStatus

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect 

func (x *Operation) ProtoReflect() protoreflect.Message

func (*Operation) Reset 

func (x *Operation) Reset()

func (*Operation) String 

func (x *Operation) String() string

type OperationServiceClient 

type OperationServiceClient interface {
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*GetOperationReply, error)
}

OperationServiceClient is the client API for OperationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOperationServiceClient 

func NewOperationServiceClient(cc grpc.ClientConnInterface) OperationServiceClient

type OperationServiceServer 

type OperationServiceServer interface {
	GetOperation(context.Context, *GetOperationRequest) (*GetOperationReply, error)
	// contains filtered or unexported methods
}

OperationServiceServer is the server API for OperationService service. All implementations must embed UnimplementedOperationServiceServer for forward compatibility

type OperationStatus 

type OperationStatus int32
const (
	OperationStatus_PLANNED OperationStatus = 0
	OperationStatus_RUNNING OperationStatus = 1
	OperationStatus_DONE    OperationStatus = 2
)

func (OperationStatus) Descriptor 

func (OperationStatus) Descriptor() protoreflect.EnumDescriptor

func (OperationStatus) Enum 

func (x OperationStatus) Enum() *OperationStatus

func (OperationStatus) EnumDescriptor deprecated 

func (OperationStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use OperationStatus.Descriptor instead.

func (OperationStatus) Number 

func (x OperationStatus) Number() protoreflect.EnumNumber

func (OperationStatus) String 

func (x OperationStatus) String() string

func (OperationStatus) Type 

func (OperationStatus) Type() protoreflect.EnumType

type PoolInfo 

type PoolInfo struct {
	Id            string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	DB            string `protobuf:"bytes,2,opt,name=DB,proto3" json:"DB,omitempty"`
	Usr           string `protobuf:"bytes,3,opt,name=Usr,proto3" json:"Usr,omitempty"`
	Host          string `protobuf:"bytes,4,opt,name=Host,proto3" json:"Host,omitempty"`
	ConnCount     int64  `protobuf:"varint,5,opt,name=ConnCount,proto3" json:"ConnCount,omitempty"`
	IdleConnCount int64  `protobuf:"varint,6,opt,name=IdleConnCount,proto3" json:"IdleConnCount,omitempty"`
	QueueSize     int64  `protobuf:"varint,7,opt,name=QueueSize,proto3" json:"QueueSize,omitempty"`
	RouterName    string `protobuf:"bytes,8,opt,name=RouterName,proto3" json:"RouterName,omitempty"`
	// contains filtered or unexported fields
}

func (*PoolInfo) Descriptor deprecated 

func (*PoolInfo) Descriptor() ([]byte, []int)

Deprecated: Use PoolInfo.ProtoReflect.Descriptor instead.

func (*PoolInfo) GetConnCount 

func (x *PoolInfo) GetConnCount() int64

func (*PoolInfo) GetDB 

func (x *PoolInfo) GetDB() string

func (*PoolInfo) GetHost 

func (x *PoolInfo) GetHost() string

func (*PoolInfo) GetId 

func (x *PoolInfo) GetId() string

func (*PoolInfo) GetIdleConnCount 

func (x *PoolInfo) GetIdleConnCount() int64

func (*PoolInfo) GetQueueSize 

func (x *PoolInfo) GetQueueSize() int64

func (*PoolInfo) GetRouterName 

func (x *PoolInfo) GetRouterName() string

func (*PoolInfo) GetUsr 

func (x *PoolInfo) GetUsr() string

func (*PoolInfo) ProtoMessage 

func (*PoolInfo) ProtoMessage()

func (*PoolInfo) ProtoReflect 

func (x *PoolInfo) ProtoReflect() protoreflect.Message

func (*PoolInfo) Reset 

func (x *PoolInfo) Reset()

func (*PoolInfo) String 

func (x *PoolInfo) String() string

type PoolServiceClient 

type PoolServiceClient interface {
	ListPools(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListPoolsResponse, error)
}

PoolServiceClient is the client API for PoolService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPoolServiceClient 

func NewPoolServiceClient(cc grpc.ClientConnInterface) PoolServiceClient

type PoolServiceServer 

type PoolServiceServer interface {
	ListPools(context.Context, *emptypb.Empty) (*ListPoolsResponse, error)
	// contains filtered or unexported methods
}

PoolServiceServer is the server API for PoolService service. All implementations must embed UnimplementedPoolServiceServer for forward compatibility

type RedistributeKeyRangeRequest 

type RedistributeKeyRangeRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ShardId   string `protobuf:"bytes,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	BatchSize int64  `protobuf:"varint,3,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	// contains filtered or unexported fields
}

func (*RedistributeKeyRangeRequest) Descriptor deprecated 

func (*RedistributeKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use RedistributeKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*RedistributeKeyRangeRequest) GetBatchSize 

func (x *RedistributeKeyRangeRequest) GetBatchSize() int64

func (*RedistributeKeyRangeRequest) GetId 

func (x *RedistributeKeyRangeRequest) GetId() string

func (*RedistributeKeyRangeRequest) GetShardId 

func (x *RedistributeKeyRangeRequest) GetShardId() string

func (*RedistributeKeyRangeRequest) ProtoMessage 

func (*RedistributeKeyRangeRequest) ProtoMessage()

func (*RedistributeKeyRangeRequest) ProtoReflect 

func (x *RedistributeKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*RedistributeKeyRangeRequest) Reset 

func (x *RedistributeKeyRangeRequest) Reset()

func (*RedistributeKeyRangeRequest) String 

func (x *RedistributeKeyRangeRequest) String() string

type RedistributeLimitType 

type RedistributeLimitType int32
const (
	RedistributeLimitType_RedistributeAllKeys   RedistributeLimitType = 0
	RedistributeLimitType_RedistributeKeysLimit RedistributeLimitType = 1
)

func (RedistributeLimitType) Descriptor 

func (RedistributeLimitType) Descriptor() protoreflect.EnumDescriptor

func (RedistributeLimitType) Enum 

func (x RedistributeLimitType) Enum() *RedistributeLimitType

func (RedistributeLimitType) EnumDescriptor deprecated 

func (RedistributeLimitType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RedistributeLimitType.Descriptor instead.

func (RedistributeLimitType) Number 

func (x RedistributeLimitType) Number() protoreflect.EnumNumber

func (RedistributeLimitType) String 

func (x RedistributeLimitType) String() string

func (RedistributeLimitType) Type 

func (RedistributeLimitType) Type() protoreflect.EnumType

type RedistributeTask 

type RedistributeTask struct {
	KeyRangeId string                `protobuf:"bytes,1,opt,name=keyRangeId,proto3" json:"keyRangeId,omitempty"`
	ShardId    string                `protobuf:"bytes,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	BatchSize  int64                 `protobuf:"varint,3,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	State      RedistributeTaskState `protobuf:"varint,4,opt,name=state,proto3,enum=spqr.RedistributeTaskState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*RedistributeTask) Descriptor deprecated 

func (*RedistributeTask) Descriptor() ([]byte, []int)

Deprecated: Use RedistributeTask.ProtoReflect.Descriptor instead.

func (*RedistributeTask) GetBatchSize 

func (x *RedistributeTask) GetBatchSize() int64

func (*RedistributeTask) GetKeyRangeId 

func (x *RedistributeTask) GetKeyRangeId() string

func (*RedistributeTask) GetShardId 

func (x *RedistributeTask) GetShardId() string

func (*RedistributeTask) GetState 

func (x *RedistributeTask) GetState() RedistributeTaskState

func (*RedistributeTask) ProtoMessage 

func (*RedistributeTask) ProtoMessage()

func (*RedistributeTask) ProtoReflect 

func (x *RedistributeTask) ProtoReflect() protoreflect.Message

func (*RedistributeTask) Reset 

func (x *RedistributeTask) Reset()

func (*RedistributeTask) String 

func (x *RedistributeTask) String() string

type RedistributeTaskServiceClient 

type RedistributeTaskServiceClient interface {
	GetRedistributeTask(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetRedistributeTaskReply, error)
	WriteRedistributeTask(ctx context.Context, in *WriteRedistributeTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveRedistributeTask(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RedistributeTaskServiceClient is the client API for RedistributeTaskService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRedistributeTaskServiceClient 

func NewRedistributeTaskServiceClient(cc grpc.ClientConnInterface) RedistributeTaskServiceClient

type RedistributeTaskServiceServer 

type RedistributeTaskServiceServer interface {
	GetRedistributeTask(context.Context, *emptypb.Empty) (*GetRedistributeTaskReply, error)
	WriteRedistributeTask(context.Context, *WriteRedistributeTaskRequest) (*emptypb.Empty, error)
	RemoveRedistributeTask(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

RedistributeTaskServiceServer is the server API for RedistributeTaskService service. All implementations must embed UnimplementedRedistributeTaskServiceServer for forward compatibility

type RedistributeTaskState 

type RedistributeTaskState int32
const (
	RedistributeTaskState_RedistributeTaskPlanned RedistributeTaskState = 0
	RedistributeTaskState_RedistributeTaskMoved   RedistributeTaskState = 1
)

func (RedistributeTaskState) Descriptor 

func (RedistributeTaskState) Descriptor() protoreflect.EnumDescriptor

func (RedistributeTaskState) Enum 

func (x RedistributeTaskState) Enum() *RedistributeTaskState

func (RedistributeTaskState) EnumDescriptor deprecated 

func (RedistributeTaskState) EnumDescriptor() ([]byte, []int)

Deprecated: Use RedistributeTaskState.Descriptor instead.

func (RedistributeTaskState) Number 

func (x RedistributeTaskState) Number() protoreflect.EnumNumber

func (RedistributeTaskState) String 

func (x RedistributeTaskState) String() string

func (RedistributeTaskState) Type 

func (RedistributeTaskState) Type() protoreflect.EnumType

type RemoveRouterRequest 

type RemoveRouterRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRouterRequest) Descriptor deprecated 

func (*RemoveRouterRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveRouterRequest.ProtoReflect.Descriptor instead.

func (*RemoveRouterRequest) GetId 

func (x *RemoveRouterRequest) GetId() string

func (*RemoveRouterRequest) ProtoMessage 

func (*RemoveRouterRequest) ProtoMessage()

func (*RemoveRouterRequest) ProtoReflect 

func (x *RemoveRouterRequest) ProtoReflect() protoreflect.Message

func (*RemoveRouterRequest) Reset 

func (x *RemoveRouterRequest) Reset()

func (*RemoveRouterRequest) String 

func (x *RemoveRouterRequest) String() string

type RenameKeyRangeRequest 

type RenameKeyRangeRequest struct {
	KeyRangeId    string `protobuf:"bytes,1,opt,name=keyRangeId,proto3" json:"keyRangeId,omitempty"`
	NewKeyRangeId string `protobuf:"bytes,2,opt,name=newKeyRangeId,proto3" json:"newKeyRangeId,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameKeyRangeRequest) Descriptor deprecated 

func (*RenameKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*RenameKeyRangeRequest) GetKeyRangeId 

func (x *RenameKeyRangeRequest) GetKeyRangeId() string

func (*RenameKeyRangeRequest) GetNewKeyRangeId 

func (x *RenameKeyRangeRequest) GetNewKeyRangeId() string

func (*RenameKeyRangeRequest) ProtoMessage 

func (*RenameKeyRangeRequest) ProtoMessage()

func (*RenameKeyRangeRequest) ProtoReflect 

func (x *RenameKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*RenameKeyRangeRequest) Reset 

func (x *RenameKeyRangeRequest) Reset()

func (*RenameKeyRangeRequest) String 

func (x *RenameKeyRangeRequest) String() string

type ResolveKeyRangeReply 

type ResolveKeyRangeReply struct {
	KeyRangeD []string `protobuf:"bytes,1,rep,name=key_range_d,json=keyRangeD,proto3" json:"key_range_d,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveKeyRangeReply) Descriptor deprecated 

func (*ResolveKeyRangeReply) Descriptor() ([]byte, []int)

Deprecated: Use ResolveKeyRangeReply.ProtoReflect.Descriptor instead.

func (*ResolveKeyRangeReply) GetKeyRangeD 

func (x *ResolveKeyRangeReply) GetKeyRangeD() []string

func (*ResolveKeyRangeReply) ProtoMessage 

func (*ResolveKeyRangeReply) ProtoMessage()

func (*ResolveKeyRangeReply) ProtoReflect 

func (x *ResolveKeyRangeReply) ProtoReflect() protoreflect.Message

func (*ResolveKeyRangeReply) Reset 

func (x *ResolveKeyRangeReply) Reset()

func (*ResolveKeyRangeReply) String 

func (x *ResolveKeyRangeReply) String() string

type ResolveKeyRangeRequest 

type ResolveKeyRangeRequest struct {
	Bound string `protobuf:"bytes,1,opt,name=bound,proto3" json:"bound,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveKeyRangeRequest) Descriptor deprecated 

func (*ResolveKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResolveKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*ResolveKeyRangeRequest) GetBound 

func (x *ResolveKeyRangeRequest) GetBound() string

func (*ResolveKeyRangeRequest) ProtoMessage 

func (*ResolveKeyRangeRequest) ProtoMessage()

func (*ResolveKeyRangeRequest) ProtoReflect 

func (x *ResolveKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*ResolveKeyRangeRequest) Reset 

func (x *ResolveKeyRangeRequest) Reset()

func (*ResolveKeyRangeRequest) String 

func (x *ResolveKeyRangeRequest) String() string

type Router 

type Router struct {
	Id      string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string       `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Status  RouterStatus `protobuf:"varint,3,opt,name=status,proto3,enum=spqr.RouterStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Router) Descriptor deprecated 

func (*Router) Descriptor() ([]byte, []int)

Deprecated: Use Router.ProtoReflect.Descriptor instead.

func (*Router) GetAddress 

func (x *Router) GetAddress() string

func (*Router) GetId 

func (x *Router) GetId() string

func (*Router) GetStatus 

func (x *Router) GetStatus() RouterStatus

func (*Router) ProtoMessage 

func (*Router) ProtoMessage()

func (*Router) ProtoReflect 

func (x *Router) ProtoReflect() protoreflect.Message

func (*Router) Reset 

func (x *Router) Reset()

func (*Router) String 

func (x *Router) String() string

type RouterServiceClient 

type RouterServiceClient interface {
	ListRouters(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListRoutersReply, error)
	AddRouter(ctx context.Context, in *AddRouterRequest, opts ...grpc.CallOption) (*AddRouterReply, error)
	RemoveRouter(ctx context.Context, in *RemoveRouterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SyncMetadata(ctx context.Context, in *SyncMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RouterServiceClient is the client API for RouterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRouterServiceClient 

func NewRouterServiceClient(cc grpc.ClientConnInterface) RouterServiceClient

type RouterServiceServer 

type RouterServiceServer interface {
	ListRouters(context.Context, *emptypb.Empty) (*ListRoutersReply, error)
	AddRouter(context.Context, *AddRouterRequest) (*AddRouterReply, error)
	RemoveRouter(context.Context, *RemoveRouterRequest) (*emptypb.Empty, error)
	SyncMetadata(context.Context, *SyncMetadataRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

RouterServiceServer is the server API for RouterService service. All implementations must embed UnimplementedRouterServiceServer for forward compatibility

type RouterStatus 

type RouterStatus int32
const (
	RouterStatus_CLOSED RouterStatus = 0
	RouterStatus_OPENED RouterStatus = 1
)

func (RouterStatus) Descriptor 

func (RouterStatus) Descriptor() protoreflect.EnumDescriptor

func (RouterStatus) Enum 

func (x RouterStatus) Enum() *RouterStatus

func (RouterStatus) EnumDescriptor deprecated 

func (RouterStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use RouterStatus.Descriptor instead.

func (RouterStatus) Number 

func (x RouterStatus) Number() protoreflect.EnumNumber

func (RouterStatus) String 

func (x RouterStatus) String() string

func (RouterStatus) Type 

func (RouterStatus) Type() protoreflect.EnumType

type Shard 

type Shard struct {
	Id    string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hosts []string `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*Shard) Descriptor deprecated 

func (*Shard) Descriptor() ([]byte, []int)

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetHosts 

func (x *Shard) GetHosts() []string

func (*Shard) GetId 

func (x *Shard) GetId() string

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect 

func (x *Shard) ProtoReflect() protoreflect.Message

func (*Shard) Reset 

func (x *Shard) Reset()

func (*Shard) String 

func (x *Shard) String() string

type ShardInfo 

type ShardInfo struct {
	Id    string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hosts []string `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardInfo) Descriptor deprecated 

func (*ShardInfo) Descriptor() ([]byte, []int)

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) GetHosts 

func (x *ShardInfo) GetHosts() []string

func (*ShardInfo) GetId 

func (x *ShardInfo) GetId() string

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect 

func (x *ShardInfo) ProtoReflect() protoreflect.Message

func (*ShardInfo) Reset 

func (x *ShardInfo) Reset()

func (*ShardInfo) String 

func (x *ShardInfo) String() string

type ShardReply 

type ShardReply struct {
	Shard *Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardReply) Descriptor deprecated 

func (*ShardReply) Descriptor() ([]byte, []int)

Deprecated: Use ShardReply.ProtoReflect.Descriptor instead.

func (*ShardReply) GetShard 

func (x *ShardReply) GetShard() *Shard

func (*ShardReply) ProtoMessage 

func (*ShardReply) ProtoMessage()

func (*ShardReply) ProtoReflect 

func (x *ShardReply) ProtoReflect() protoreflect.Message

func (*ShardReply) Reset 

func (x *ShardReply) Reset()

func (*ShardReply) String 

func (x *ShardReply) String() string

type ShardRequest 

type ShardRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardRequest) Descriptor deprecated 

func (*ShardRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShardRequest.ProtoReflect.Descriptor instead.

func (*ShardRequest) GetId 

func (x *ShardRequest) GetId() string

func (*ShardRequest) ProtoMessage 

func (*ShardRequest) ProtoMessage()

func (*ShardRequest) ProtoReflect 

func (x *ShardRequest) ProtoReflect() protoreflect.Message

func (*ShardRequest) Reset 

func (x *ShardRequest) Reset()

func (*ShardRequest) String 

func (x *ShardRequest) String() string

type ShardServiceClient 

type ShardServiceClient interface {
	ListShards(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListShardsReply, error)
	AddDataShard(ctx context.Context, in *AddShardRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AddWorldShard(ctx context.Context, in *AddWorldShardRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetShard(ctx context.Context, in *ShardRequest, opts ...grpc.CallOption) (*ShardReply, error)
}

ShardServiceClient is the client API for ShardService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewShardServiceClient 

func NewShardServiceClient(cc grpc.ClientConnInterface) ShardServiceClient

type ShardServiceServer 

type ShardServiceServer interface {
	ListShards(context.Context, *emptypb.Empty) (*ListShardsReply, error)
	AddDataShard(context.Context, *AddShardRequest) (*emptypb.Empty, error)
	AddWorldShard(context.Context, *AddWorldShardRequest) (*emptypb.Empty, error)
	GetShard(context.Context, *ShardRequest) (*ShardReply, error)
	// contains filtered or unexported methods
}

ShardServiceServer is the server API for ShardService service. All implementations must embed UnimplementedShardServiceServer for forward compatibility

type ShardingRule 

type ShardingRule struct {

	// Deprecated: Marked as deprecated in protos/sharding_rules.proto.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Deprecated: Marked as deprecated in protos/sharding_rules.proto.
	TableName string `protobuf:"bytes,2,opt,name=tableName,proto3" json:"tableName,omitempty"`
	// Deprecated: Marked as deprecated in protos/sharding_rules.proto.
	ShardingRuleEntry []*ShardingRuleEntry `protobuf:"bytes,3,rep,name=ShardingRuleEntry,proto3" json:"ShardingRuleEntry,omitempty"`
	// Deprecated: Marked as deprecated in protos/sharding_rules.proto.
	DistributionId string `protobuf:"bytes,4,opt,name=distributionId,proto3" json:"distributionId,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardingRule) Descriptor deprecated 

func (*ShardingRule) Descriptor() ([]byte, []int)

Deprecated: Use ShardingRule.ProtoReflect.Descriptor instead.

func (*ShardingRule) GetDistributionId deprecated 

func (x *ShardingRule) GetDistributionId() string

Deprecated: Marked as deprecated in protos/sharding_rules.proto.

func (*ShardingRule) GetId deprecated 

func (x *ShardingRule) GetId() string

Deprecated: Marked as deprecated in protos/sharding_rules.proto.

func (*ShardingRule) GetShardingRuleEntry deprecated 

func (x *ShardingRule) GetShardingRuleEntry() []*ShardingRuleEntry

Deprecated: Marked as deprecated in protos/sharding_rules.proto.

func (*ShardingRule) GetTableName deprecated 

func (x *ShardingRule) GetTableName() string

Deprecated: Marked as deprecated in protos/sharding_rules.proto.

func (*ShardingRule) ProtoMessage 

func (*ShardingRule) ProtoMessage()

func (*ShardingRule) ProtoReflect 

func (x *ShardingRule) ProtoReflect() protoreflect.Message

func (*ShardingRule) Reset 

func (x *ShardingRule) Reset()

func (*ShardingRule) String 

func (x *ShardingRule) String() string

type ShardingRuleEntry 

type ShardingRuleEntry struct {

	// Deprecated: Marked as deprecated in protos/sharding_rules.proto.
	Column string `protobuf:"bytes,2,opt,name=column,proto3" json:"column,omitempty"`
	// Deprecated: Marked as deprecated in protos/sharding_rules.proto.
	HashFunction string `protobuf:"bytes,3,opt,name=hashFunction,proto3" json:"hashFunction,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardingRuleEntry) Descriptor deprecated 

func (*ShardingRuleEntry) Descriptor() ([]byte, []int)

Deprecated: Use ShardingRuleEntry.ProtoReflect.Descriptor instead.

func (*ShardingRuleEntry) GetColumn deprecated 

func (x *ShardingRuleEntry) GetColumn() string

Deprecated: Marked as deprecated in protos/sharding_rules.proto.

func (*ShardingRuleEntry) GetHashFunction deprecated 

func (x *ShardingRuleEntry) GetHashFunction() string

Deprecated: Marked as deprecated in protos/sharding_rules.proto.

func (*ShardingRuleEntry) ProtoMessage 

func (*ShardingRuleEntry) ProtoMessage()

func (*ShardingRuleEntry) ProtoReflect 

func (x *ShardingRuleEntry) ProtoReflect() protoreflect.Message

func (*ShardingRuleEntry) Reset 

func (x *ShardingRuleEntry) Reset()

func (*ShardingRuleEntry) String 

func (x *ShardingRuleEntry) String() string

type ShardingRulesServiceClient 

type ShardingRulesServiceClient interface {
	// Deprecated: Do not use.
	AddShardingRules(ctx context.Context, in *AddShardingRuleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	DropShardingRules(ctx context.Context, in *DropShardingRuleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	ListShardingRules(ctx context.Context, in *ListShardingRuleRequest, opts ...grpc.CallOption) (*ListShardingRuleReply, error)
}

ShardingRulesServiceClient is the client API for ShardingRulesService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewShardingRulesServiceClient 

func NewShardingRulesServiceClient(cc grpc.ClientConnInterface) ShardingRulesServiceClient

type ShardingRulesServiceServer 

type ShardingRulesServiceServer interface {
	// Deprecated: Do not use.
	AddShardingRules(context.Context, *AddShardingRuleRequest) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	DropShardingRules(context.Context, *DropShardingRuleRequest) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	ListShardingRules(context.Context, *ListShardingRuleRequest) (*ListShardingRuleReply, error)
	// contains filtered or unexported methods
}

ShardingRulesServiceServer is the server API for ShardingRulesService service. All implementations must embed UnimplementedShardingRulesServiceServer for forward compatibility

type SplitKeyRangeRequest 

type SplitKeyRangeRequest struct {
	NewId     string `protobuf:"bytes,1,opt,name=new_id,json=newId,proto3" json:"new_id,omitempty"`
	Bound     []byte `protobuf:"bytes,2,opt,name=bound,proto3" json:"bound,omitempty"`
	SourceId  string `protobuf:"bytes,3,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	SplitLeft bool   `protobuf:"varint,4,opt,name=split_left,json=splitLeft,proto3" json:"split_left,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitKeyRangeRequest) Descriptor deprecated 

func (*SplitKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SplitKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*SplitKeyRangeRequest) GetBound 

func (x *SplitKeyRangeRequest) GetBound() []byte

func (*SplitKeyRangeRequest) GetNewId 

func (x *SplitKeyRangeRequest) GetNewId() string

func (*SplitKeyRangeRequest) GetSourceId 

func (x *SplitKeyRangeRequest) GetSourceId() string

func (*SplitKeyRangeRequest) GetSplitLeft 

func (x *SplitKeyRangeRequest) GetSplitLeft() bool

func (*SplitKeyRangeRequest) ProtoMessage 

func (*SplitKeyRangeRequest) ProtoMessage()

func (*SplitKeyRangeRequest) ProtoReflect 

func (x *SplitKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*SplitKeyRangeRequest) Reset 

func (x *SplitKeyRangeRequest) Reset()

func (*SplitKeyRangeRequest) String 

func (x *SplitKeyRangeRequest) String() string

type SplitType 

type SplitType int32
const (
	SplitType_SplitLeft  SplitType = 0
	SplitType_SplitRight SplitType = 1
)

func (SplitType) Descriptor 

func (SplitType) Descriptor() protoreflect.EnumDescriptor

func (SplitType) Enum 

func (x SplitType) Enum() *SplitType

func (SplitType) EnumDescriptor deprecated 

func (SplitType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SplitType.Descriptor instead.

func (SplitType) Number 

func (x SplitType) Number() protoreflect.EnumNumber

func (SplitType) String 

func (x SplitType) String() string

func (SplitType) Type 

func (SplitType) Type() protoreflect.EnumType

type SyncMetadataRequest 

type SyncMetadataRequest struct {
	Router *Router `protobuf:"bytes,1,opt,name=router,proto3" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncMetadataRequest) Descriptor deprecated 

func (*SyncMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncMetadataRequest.ProtoReflect.Descriptor instead.

func (*SyncMetadataRequest) GetRouter 

func (x *SyncMetadataRequest) GetRouter() *Router

func (*SyncMetadataRequest) ProtoMessage 

func (*SyncMetadataRequest) ProtoMessage()

func (*SyncMetadataRequest) ProtoReflect 

func (x *SyncMetadataRequest) ProtoReflect() protoreflect.Message

func (*SyncMetadataRequest) Reset 

func (x *SyncMetadataRequest) Reset()

func (*SyncMetadataRequest) String 

func (x *SyncMetadataRequest) String() string

type TaskStatus 

type TaskStatus int32
const (
	TaskStatus_Planned TaskStatus = 0
	TaskStatus_Split   TaskStatus = 1
	TaskStatus_Moved   TaskStatus = 2
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

func (TaskStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type TopologyServiceClient 

type TopologyServiceClient interface {
	OpenRouter(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetRouterStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetRouterStatusReply, error)
	CloseRouter(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpdateCoordinator(ctx context.Context, in *UpdateCoordinatorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetCoordinator(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetCoordinatorResponse, error)
}

TopologyServiceClient is the client API for TopologyService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTopologyServiceClient 

func NewTopologyServiceClient(cc grpc.ClientConnInterface) TopologyServiceClient

type TopologyServiceServer 

type TopologyServiceServer interface {
	OpenRouter(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetRouterStatus(context.Context, *emptypb.Empty) (*GetRouterStatusReply, error)
	CloseRouter(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	UpdateCoordinator(context.Context, *UpdateCoordinatorRequest) (*emptypb.Empty, error)
	GetCoordinator(context.Context, *emptypb.Empty) (*GetCoordinatorResponse, error)
	// contains filtered or unexported methods
}

TopologyServiceServer is the server API for TopologyService service. All implementations must embed UnimplementedTopologyServiceServer for forward compatibility

type UnimplementedBackendConnectionsServiceServer 

type UnimplementedBackendConnectionsServiceServer struct {
}

UnimplementedBackendConnectionsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBackendConnectionsServiceServer) ListBackendConnections 

func (UnimplementedBackendConnectionsServiceServer) ListBackendConnections(context.Context, *emptypb.Empty) (*ListBackendConntionsReply, error)

type UnimplementedBalancerTaskServiceServer 

type UnimplementedBalancerTaskServiceServer struct {
}

UnimplementedBalancerTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBalancerTaskServiceServer) GetBalancerTask 

func (UnimplementedBalancerTaskServiceServer) GetBalancerTask(context.Context, *emptypb.Empty) (*GetBalancerTaskReply, error)

func (UnimplementedBalancerTaskServiceServer) RemoveBalancerTask 

func (UnimplementedBalancerTaskServiceServer) RemoveBalancerTask(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedBalancerTaskServiceServer) WriteBalancerTask 

func (UnimplementedBalancerTaskServiceServer) WriteBalancerTask(context.Context, *WriteBalancerTaskRequest) (*emptypb.Empty, error)

type UnimplementedClientInfoServiceServer 

type UnimplementedClientInfoServiceServer struct {
}

UnimplementedClientInfoServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClientInfoServiceServer) ListClients 

func (UnimplementedClientInfoServiceServer) ListClients(context.Context, *emptypb.Empty) (*ListClientsReply, error)

type UnimplementedDistributionServiceServer 

type UnimplementedDistributionServiceServer struct {
}

UnimplementedDistributionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDistributionServiceServer) AlterDistributionAttach 

func (UnimplementedDistributionServiceServer) AlterDistributionAttach(context.Context, *AlterDistributionAttachRequest) (*emptypb.Empty, error)

func (UnimplementedDistributionServiceServer) AlterDistributionDetach 

func (UnimplementedDistributionServiceServer) AlterDistributionDetach(context.Context, *AlterDistributionDetachRequest) (*emptypb.Empty, error)

func (UnimplementedDistributionServiceServer) CreateDistribution 

func (UnimplementedDistributionServiceServer) CreateDistribution(context.Context, *CreateDistributionRequest) (*emptypb.Empty, error)

func (UnimplementedDistributionServiceServer) DropDistribution 

func (UnimplementedDistributionServiceServer) DropDistribution(context.Context, *DropDistributionRequest) (*emptypb.Empty, error)

func (UnimplementedDistributionServiceServer) GetDistribution 

func (UnimplementedDistributionServiceServer) GetDistribution(context.Context, *GetDistributionRequest) (*GetDistributionReply, error)

func (UnimplementedDistributionServiceServer) GetRelationDistribution 

func (UnimplementedDistributionServiceServer) GetRelationDistribution(context.Context, *GetRelationDistributionRequest) (*GetRelationDistributionReply, error)

func (UnimplementedDistributionServiceServer) ListDistributions 

func (UnimplementedDistributionServiceServer) ListDistributions(context.Context, *emptypb.Empty) (*ListDistributionsReply, error)

type UnimplementedKeyRangeServiceServer 

type UnimplementedKeyRangeServiceServer struct {
}

UnimplementedKeyRangeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedKeyRangeServiceServer) BatchMoveKeyRange 

func (UnimplementedKeyRangeServiceServer) BatchMoveKeyRange(context.Context, *BatchMoveKeyRangeRequest) (*emptypb.Empty, error)

func (UnimplementedKeyRangeServiceServer) CreateKeyRange 

func (UnimplementedKeyRangeServiceServer) CreateKeyRange(context.Context, *CreateKeyRangeRequest) (*ModifyReply, error)

func (UnimplementedKeyRangeServiceServer) DropAllKeyRanges 

func (UnimplementedKeyRangeServiceServer) DropAllKeyRanges(context.Context, *emptypb.Empty) (*DropAllKeyRangesResponse, error)

func (UnimplementedKeyRangeServiceServer) DropKeyRange 

func (UnimplementedKeyRangeServiceServer) DropKeyRange(context.Context, *DropKeyRangeRequest) (*ModifyReply, error)

func (UnimplementedKeyRangeServiceServer) GetKeyRange 

func (UnimplementedKeyRangeServiceServer) GetKeyRange(context.Context, *GetKeyRangeRequest) (*KeyRangeReply, error)

func (UnimplementedKeyRangeServiceServer) ListAllKeyRanges 

func (UnimplementedKeyRangeServiceServer) ListAllKeyRanges(context.Context, *emptypb.Empty) (*KeyRangeReply, error)

func (UnimplementedKeyRangeServiceServer) ListKeyRange 

func (UnimplementedKeyRangeServiceServer) ListKeyRange(context.Context, *ListKeyRangeRequest) (*KeyRangeReply, error)

func (UnimplementedKeyRangeServiceServer) LockKeyRange 

func (UnimplementedKeyRangeServiceServer) LockKeyRange(context.Context, *LockKeyRangeRequest) (*ModifyReply, error)

func (UnimplementedKeyRangeServiceServer) MergeKeyRange 

func (UnimplementedKeyRangeServiceServer) MergeKeyRange(context.Context, *MergeKeyRangeRequest) (*ModifyReply, error)

func (UnimplementedKeyRangeServiceServer) MoveKeyRange 

func (UnimplementedKeyRangeServiceServer) MoveKeyRange(context.Context, *MoveKeyRangeRequest) (*ModifyReply, error)

func (UnimplementedKeyRangeServiceServer) RedistributeKeyRange 

func (UnimplementedKeyRangeServiceServer) RedistributeKeyRange(context.Context, *RedistributeKeyRangeRequest) (*emptypb.Empty, error)

func (UnimplementedKeyRangeServiceServer) RenameKeyRange 

func (UnimplementedKeyRangeServiceServer) RenameKeyRange(context.Context, *RenameKeyRangeRequest) (*emptypb.Empty, error)

func (UnimplementedKeyRangeServiceServer) ResolveKeyRange 

func (UnimplementedKeyRangeServiceServer) ResolveKeyRange(context.Context, *ResolveKeyRangeRequest) (*ResolveKeyRangeReply, error)

func (UnimplementedKeyRangeServiceServer) SplitKeyRange 

func (UnimplementedKeyRangeServiceServer) SplitKeyRange(context.Context, *SplitKeyRangeRequest) (*ModifyReply, error)

func (UnimplementedKeyRangeServiceServer) UnlockKeyRange 

func (UnimplementedKeyRangeServiceServer) UnlockKeyRange(context.Context, *UnlockKeyRangeRequest) (*ModifyReply, error)

type UnimplementedMoveTasksServiceServer 

type UnimplementedMoveTasksServiceServer struct {
}

UnimplementedMoveTasksServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMoveTasksServiceServer) GetMoveTaskGroup 

func (UnimplementedMoveTasksServiceServer) GetMoveTaskGroup(context.Context, *emptypb.Empty) (*GetMoveTaskGroupReply, error)

func (UnimplementedMoveTasksServiceServer) RemoveMoveTaskGroup 

func (UnimplementedMoveTasksServiceServer) RemoveMoveTaskGroup(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedMoveTasksServiceServer) WriteMoveTaskGroup 

func (UnimplementedMoveTasksServiceServer) WriteMoveTaskGroup(context.Context, *WriteMoveTaskGroupRequest) (*emptypb.Empty, error)

type UnimplementedOperationServiceServer 

type UnimplementedOperationServiceServer struct {
}

UnimplementedOperationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOperationServiceServer) GetOperation 

func (UnimplementedOperationServiceServer) GetOperation(context.Context, *GetOperationRequest) (*GetOperationReply, error)

type UnimplementedPoolServiceServer 

type UnimplementedPoolServiceServer struct {
}

UnimplementedPoolServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPoolServiceServer) ListPools 

func (UnimplementedPoolServiceServer) ListPools(context.Context, *emptypb.Empty) (*ListPoolsResponse, error)

type UnimplementedRedistributeTaskServiceServer 

type UnimplementedRedistributeTaskServiceServer struct {
}

UnimplementedRedistributeTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRedistributeTaskServiceServer) GetRedistributeTask 

func (UnimplementedRedistributeTaskServiceServer) GetRedistributeTask(context.Context, *emptypb.Empty) (*GetRedistributeTaskReply, error)

func (UnimplementedRedistributeTaskServiceServer) RemoveRedistributeTask 

func (UnimplementedRedistributeTaskServiceServer) RemoveRedistributeTask(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedRedistributeTaskServiceServer) WriteRedistributeTask 

func (UnimplementedRedistributeTaskServiceServer) WriteRedistributeTask(context.Context, *WriteRedistributeTaskRequest) (*emptypb.Empty, error)

type UnimplementedRouterServiceServer 

type UnimplementedRouterServiceServer struct {
}

UnimplementedRouterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRouterServiceServer) AddRouter 

func (UnimplementedRouterServiceServer) AddRouter(context.Context, *AddRouterRequest) (*AddRouterReply, error)

func (UnimplementedRouterServiceServer) ListRouters 

func (UnimplementedRouterServiceServer) ListRouters(context.Context, *emptypb.Empty) (*ListRoutersReply, error)

func (UnimplementedRouterServiceServer) RemoveRouter 

func (UnimplementedRouterServiceServer) RemoveRouter(context.Context, *RemoveRouterRequest) (*emptypb.Empty, error)

func (UnimplementedRouterServiceServer) SyncMetadata 

func (UnimplementedRouterServiceServer) SyncMetadata(context.Context, *SyncMetadataRequest) (*emptypb.Empty, error)

type UnimplementedShardServiceServer 

type UnimplementedShardServiceServer struct {
}

UnimplementedShardServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedShardServiceServer) AddDataShard 

func (UnimplementedShardServiceServer) AddDataShard(context.Context, *AddShardRequest) (*emptypb.Empty, error)

func (UnimplementedShardServiceServer) AddWorldShard 

func (UnimplementedShardServiceServer) AddWorldShard(context.Context, *AddWorldShardRequest) (*emptypb.Empty, error)

func (UnimplementedShardServiceServer) GetShard 

func (UnimplementedShardServiceServer) GetShard(context.Context, *ShardRequest) (*ShardReply, error)

func (UnimplementedShardServiceServer) ListShards 

func (UnimplementedShardServiceServer) ListShards(context.Context, *emptypb.Empty) (*ListShardsReply, error)

type UnimplementedShardingRulesServiceServer 

type UnimplementedShardingRulesServiceServer struct {
}

UnimplementedShardingRulesServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedShardingRulesServiceServer) AddShardingRules 

func (UnimplementedShardingRulesServiceServer) AddShardingRules(context.Context, *AddShardingRuleRequest) (*emptypb.Empty, error)

func (UnimplementedShardingRulesServiceServer) DropShardingRules 

func (UnimplementedShardingRulesServiceServer) DropShardingRules(context.Context, *DropShardingRuleRequest) (*emptypb.Empty, error)

func (UnimplementedShardingRulesServiceServer) ListShardingRules 

func (UnimplementedShardingRulesServiceServer) ListShardingRules(context.Context, *ListShardingRuleRequest) (*ListShardingRuleReply, error)

type UnimplementedTopologyServiceServer 

type UnimplementedTopologyServiceServer struct {
}

UnimplementedTopologyServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTopologyServiceServer) CloseRouter 

func (UnimplementedTopologyServiceServer) CloseRouter(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedTopologyServiceServer) GetCoordinator 

func (UnimplementedTopologyServiceServer) GetCoordinator(context.Context, *emptypb.Empty) (*GetCoordinatorResponse, error)

func (UnimplementedTopologyServiceServer) GetRouterStatus 

func (UnimplementedTopologyServiceServer) GetRouterStatus(context.Context, *emptypb.Empty) (*GetRouterStatusReply, error)

func (UnimplementedTopologyServiceServer) OpenRouter 

func (UnimplementedTopologyServiceServer) OpenRouter(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedTopologyServiceServer) UpdateCoordinator 

func (UnimplementedTopologyServiceServer) UpdateCoordinator(context.Context, *UpdateCoordinatorRequest) (*emptypb.Empty, error)

type UnlockKeyRangeRequest 

type UnlockKeyRangeRequest struct {
	Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlockKeyRangeRequest) Descriptor deprecated 

func (*UnlockKeyRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnlockKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*UnlockKeyRangeRequest) GetId 

func (x *UnlockKeyRangeRequest) GetId() []string

func (*UnlockKeyRangeRequest) ProtoMessage 

func (*UnlockKeyRangeRequest) ProtoMessage()

func (*UnlockKeyRangeRequest) ProtoReflect 

func (x *UnlockKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*UnlockKeyRangeRequest) Reset 

func (x *UnlockKeyRangeRequest) Reset()

func (*UnlockKeyRangeRequest) String 

func (x *UnlockKeyRangeRequest) String() string

type UnsafeBackendConnectionsServiceServer 

type UnsafeBackendConnectionsServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBackendConnectionsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BackendConnectionsServiceServer will result in compilation errors.

type UnsafeBalancerTaskServiceServer 

type UnsafeBalancerTaskServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBalancerTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BalancerTaskServiceServer will result in compilation errors.

type UnsafeClientInfoServiceServer 

type UnsafeClientInfoServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClientInfoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClientInfoServiceServer will result in compilation errors.

type UnsafeDistributionServiceServer 

type UnsafeDistributionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDistributionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DistributionServiceServer will result in compilation errors.

type UnsafeKeyRangeServiceServer 

type UnsafeKeyRangeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeKeyRangeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KeyRangeServiceServer will result in compilation errors.

type UnsafeMoveTasksServiceServer 

type UnsafeMoveTasksServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeMoveTasksServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MoveTasksServiceServer will result in compilation errors.

type UnsafeOperationServiceServer 

type UnsafeOperationServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeOperationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperationServiceServer will result in compilation errors.

type UnsafePoolServiceServer 

type UnsafePoolServiceServer interface {
	// contains filtered or unexported methods
}

UnsafePoolServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PoolServiceServer will result in compilation errors.

type UnsafeRedistributeTaskServiceServer 

type UnsafeRedistributeTaskServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRedistributeTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RedistributeTaskServiceServer will result in compilation errors.

type UnsafeRouterServiceServer 

type UnsafeRouterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRouterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RouterServiceServer will result in compilation errors.

type UnsafeShardServiceServer 

type UnsafeShardServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeShardServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ShardServiceServer will result in compilation errors.

type UnsafeShardingRulesServiceServer 

type UnsafeShardingRulesServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeShardingRulesServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ShardingRulesServiceServer will result in compilation errors.

type UnsafeTopologyServiceServer 

type UnsafeTopologyServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTopologyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TopologyServiceServer will result in compilation errors.

type UpdateCoordinatorRequest 

type UpdateCoordinatorRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCoordinatorRequest) Descriptor deprecated 

func (*UpdateCoordinatorRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateCoordinatorRequest.ProtoReflect.Descriptor instead.

func (*UpdateCoordinatorRequest) GetAddress 

func (x *UpdateCoordinatorRequest) GetAddress() string

func (*UpdateCoordinatorRequest) ProtoMessage 

func (*UpdateCoordinatorRequest) ProtoMessage()

func (*UpdateCoordinatorRequest) ProtoReflect 

func (x *UpdateCoordinatorRequest) ProtoReflect() protoreflect.Message

func (*UpdateCoordinatorRequest) Reset 

func (x *UpdateCoordinatorRequest) Reset()

func (*UpdateCoordinatorRequest) String 

func (x *UpdateCoordinatorRequest) String() string

type UsedShardInfo 

type UsedShardInfo struct {
	Instance *DBInstaceInfo `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*UsedShardInfo) Descriptor deprecated 

func (*UsedShardInfo) Descriptor() ([]byte, []int)

Deprecated: Use UsedShardInfo.ProtoReflect.Descriptor instead.

func (*UsedShardInfo) GetInstance 

func (x *UsedShardInfo) GetInstance() *DBInstaceInfo

func (*UsedShardInfo) ProtoMessage 

func (*UsedShardInfo) ProtoMessage()

func (*UsedShardInfo) ProtoReflect 

func (x *UsedShardInfo) ProtoReflect() protoreflect.Message

func (*UsedShardInfo) Reset 

func (x *UsedShardInfo) Reset()

func (*UsedShardInfo) String 

func (x *UsedShardInfo) String() string

type WriteBalancerTaskRequest 

type WriteBalancerTaskRequest struct {
	Task *BalancerTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteBalancerTaskRequest) Descriptor deprecated 

func (*WriteBalancerTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteBalancerTaskRequest.ProtoReflect.Descriptor instead.

func (*WriteBalancerTaskRequest) GetTask 

func (x *WriteBalancerTaskRequest) GetTask() *BalancerTask

func (*WriteBalancerTaskRequest) ProtoMessage 

func (*WriteBalancerTaskRequest) ProtoMessage()

func (*WriteBalancerTaskRequest) ProtoReflect 

func (x *WriteBalancerTaskRequest) ProtoReflect() protoreflect.Message

func (*WriteBalancerTaskRequest) Reset 

func (x *WriteBalancerTaskRequest) Reset()

func (*WriteBalancerTaskRequest) String 

func (x *WriteBalancerTaskRequest) String() string

type WriteMoveTaskGroupRequest 

type WriteMoveTaskGroupRequest struct {
	TaskGroup *MoveTaskGroup `protobuf:"bytes,1,opt,name=taskGroup,proto3" json:"taskGroup,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteMoveTaskGroupRequest) Descriptor deprecated 

func (*WriteMoveTaskGroupRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteMoveTaskGroupRequest.ProtoReflect.Descriptor instead.

func (*WriteMoveTaskGroupRequest) GetTaskGroup 

func (x *WriteMoveTaskGroupRequest) GetTaskGroup() *MoveTaskGroup

func (*WriteMoveTaskGroupRequest) ProtoMessage 

func (*WriteMoveTaskGroupRequest) ProtoMessage()

func (*WriteMoveTaskGroupRequest) ProtoReflect 

func (x *WriteMoveTaskGroupRequest) ProtoReflect() protoreflect.Message

func (*WriteMoveTaskGroupRequest) Reset 

func (x *WriteMoveTaskGroupRequest) Reset()

func (*WriteMoveTaskGroupRequest) String 

func (x *WriteMoveTaskGroupRequest) String() string

type WriteRedistributeTaskRequest 

type WriteRedistributeTaskRequest struct {
	Task *RedistributeTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRedistributeTaskRequest) Descriptor deprecated 

func (*WriteRedistributeTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteRedistributeTaskRequest.ProtoReflect.Descriptor instead.

func (*WriteRedistributeTaskRequest) GetTask 

func (x *WriteRedistributeTaskRequest) GetTask() *RedistributeTask

func (*WriteRedistributeTaskRequest) ProtoMessage 

func (*WriteRedistributeTaskRequest) ProtoMessage()

func (*WriteRedistributeTaskRequest) ProtoReflect 

func (x *WriteRedistributeTaskRequest) ProtoReflect() protoreflect.Message

func (*WriteRedistributeTaskRequest) Reset 

func (x *WriteRedistributeTaskRequest) Reset()

func (*WriteRedistributeTaskRequest) String 

func (x *WriteRedistributeTaskRequest) String() string

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.