Versions in this module Expand all Collapse all v0 v0.0.5 Jun 15, 2020 Changes in this version + var File_clusterfunk_management_proto protoreflect.FileDescriptor v0.0.4 Jun 10, 2020 Changes in this version + var Error_Code_name = map[int32]string + var Error_Code_value = map[string]int32 + var File_management_proto protoreflect.FileDescriptor + func RegisterClusterManagementServer(s *grpc.Server, srv ClusterManagementServer) + type AddNodeRequest struct + NodeId string + func (*AddNodeRequest) Descriptor() ([]byte, []int) + func (*AddNodeRequest) ProtoMessage() + func (x *AddNodeRequest) GetNodeId() string + func (x *AddNodeRequest) ProtoReflect() protoreflect.Message + func (x *AddNodeRequest) Reset() + func (x *AddNodeRequest) String() string + type AddNodeResponse struct + Error *Error + NodeId string + func (*AddNodeResponse) Descriptor() ([]byte, []int) + func (*AddNodeResponse) ProtoMessage() + func (x *AddNodeResponse) GetError() *Error + func (x *AddNodeResponse) GetNodeId() string + func (x *AddNodeResponse) ProtoReflect() protoreflect.Message + func (x *AddNodeResponse) Reset() + func (x *AddNodeResponse) String() string + type ClusterManagementClient interface + AddNode func(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error) + FindEndpoint func(ctx context.Context, in *EndpointRequest, opts ...grpc.CallOption) (*EndpointResponse, error) + GetStatus func(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error) + ListEndpoints func(ctx context.Context, in *ListEndpointRequest, opts ...grpc.CallOption) (*ListEndpointResponse, error) + ListNodes func(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error) + ListShards func(ctx context.Context, in *ListShardsRequest, opts ...grpc.CallOption) (*ListShardsResponse, error) + RemoveNode func(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error) + StepDown func(ctx context.Context, in *StepDownRequest, opts ...grpc.CallOption) (*StepDownResponse, error) + func NewClusterManagementClient(cc grpc.ClientConnInterface) ClusterManagementClient + type ClusterManagementServer interface + AddNode func(context.Context, *AddNodeRequest) (*AddNodeResponse, error) + FindEndpoint func(context.Context, *EndpointRequest) (*EndpointResponse, error) + GetStatus func(context.Context, *GetStatusRequest) (*GetStatusResponse, error) + ListEndpoints func(context.Context, *ListEndpointRequest) (*ListEndpointResponse, error) + ListNodes func(context.Context, *ListNodesRequest) (*ListNodesResponse, error) + ListShards func(context.Context, *ListShardsRequest) (*ListShardsResponse, error) + RemoveNode func(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error) + StepDown func(context.Context, *StepDownRequest) (*StepDownResponse, error) + type EndpointInfo struct + HostPort string + Name string + NodeId string + func (*EndpointInfo) Descriptor() ([]byte, []int) + func (*EndpointInfo) ProtoMessage() + func (x *EndpointInfo) GetHostPort() string + func (x *EndpointInfo) GetName() string + func (x *EndpointInfo) GetNodeId() string + func (x *EndpointInfo) ProtoReflect() protoreflect.Message + func (x *EndpointInfo) Reset() + func (x *EndpointInfo) String() string + type EndpointRequest struct + EndpointName string + func (*EndpointRequest) Descriptor() ([]byte, []int) + func (*EndpointRequest) ProtoMessage() + func (x *EndpointRequest) GetEndpointName() string + func (x *EndpointRequest) ProtoReflect() protoreflect.Message + func (x *EndpointRequest) Reset() + func (x *EndpointRequest) String() string + type EndpointResponse struct + Endpoints []*EndpointInfo + Error *Error + NodeId string + func (*EndpointResponse) Descriptor() ([]byte, []int) + func (*EndpointResponse) ProtoMessage() + func (x *EndpointResponse) GetEndpoints() []*EndpointInfo + func (x *EndpointResponse) GetError() *Error + func (x *EndpointResponse) GetNodeId() string + func (x *EndpointResponse) ProtoReflect() protoreflect.Message + func (x *EndpointResponse) Reset() + func (x *EndpointResponse) String() string + type Error struct + ErrorCode Error_Code + Message string + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (x *Error) GetErrorCode() Error_Code + func (x *Error) GetMessage() string + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + type Error_Code int32 + const Error_GENERIC + const Error_INVALID + const Error_NO_LEADER + const Error_OK + const Error_UNKNOWN_ID + func (Error_Code) Descriptor() protoreflect.EnumDescriptor + func (Error_Code) EnumDescriptor() ([]byte, []int) + func (Error_Code) Type() protoreflect.EnumType + func (x Error_Code) Enum() *Error_Code + func (x Error_Code) Number() protoreflect.EnumNumber + func (x Error_Code) String() string + type GetStatusRequest struct + func (*GetStatusRequest) Descriptor() ([]byte, []int) + func (*GetStatusRequest) ProtoMessage() + func (x *GetStatusRequest) ProtoReflect() protoreflect.Message + func (x *GetStatusRequest) Reset() + func (x *GetStatusRequest) String() string + type GetStatusResponse struct + ClusterName string + Error *Error + LeaderNodeId string + LocalNodeId string + LocalRole string + LocalState string + RaftNodeCount int32 + SerfNodeCount int32 + ShardCount int32 + ShardWeight int32 + func (*GetStatusResponse) Descriptor() ([]byte, []int) + func (*GetStatusResponse) ProtoMessage() + func (x *GetStatusResponse) GetClusterName() string + func (x *GetStatusResponse) GetError() *Error + func (x *GetStatusResponse) GetLeaderNodeId() string + func (x *GetStatusResponse) GetLocalNodeId() string + func (x *GetStatusResponse) GetLocalRole() string + func (x *GetStatusResponse) GetLocalState() string + func (x *GetStatusResponse) GetRaftNodeCount() int32 + func (x *GetStatusResponse) GetSerfNodeCount() int32 + func (x *GetStatusResponse) GetShardCount() int32 + func (x *GetStatusResponse) GetShardWeight() int32 + func (x *GetStatusResponse) ProtoReflect() protoreflect.Message + func (x *GetStatusResponse) Reset() + func (x *GetStatusResponse) String() string + type ListEndpointRequest struct + func (*ListEndpointRequest) Descriptor() ([]byte, []int) + func (*ListEndpointRequest) ProtoMessage() + func (x *ListEndpointRequest) ProtoReflect() protoreflect.Message + func (x *ListEndpointRequest) Reset() + func (x *ListEndpointRequest) String() string + type ListEndpointResponse struct + Endpoints []*EndpointInfo + Error *Error + NodeId string + func (*ListEndpointResponse) Descriptor() ([]byte, []int) + func (*ListEndpointResponse) ProtoMessage() + func (x *ListEndpointResponse) GetEndpoints() []*EndpointInfo + func (x *ListEndpointResponse) GetError() *Error + func (x *ListEndpointResponse) GetNodeId() string + func (x *ListEndpointResponse) ProtoReflect() protoreflect.Message + func (x *ListEndpointResponse) Reset() + func (x *ListEndpointResponse) String() string + type ListNodesRequest struct + func (*ListNodesRequest) Descriptor() ([]byte, []int) + func (*ListNodesRequest) ProtoMessage() + func (x *ListNodesRequest) ProtoReflect() protoreflect.Message + func (x *ListNodesRequest) Reset() + func (x *ListNodesRequest) String() string + type ListNodesResponse struct + Error *Error + LeaderId string + NodeId string + Nodes []*NodeInfo + func (*ListNodesResponse) Descriptor() ([]byte, []int) + func (*ListNodesResponse) ProtoMessage() + func (x *ListNodesResponse) GetError() *Error + func (x *ListNodesResponse) GetLeaderId() string + func (x *ListNodesResponse) GetNodeId() string + func (x *ListNodesResponse) GetNodes() []*NodeInfo + func (x *ListNodesResponse) ProtoReflect() protoreflect.Message + func (x *ListNodesResponse) Reset() + func (x *ListNodesResponse) String() string + type ListShardsRequest struct + func (*ListShardsRequest) Descriptor() ([]byte, []int) + func (*ListShardsRequest) ProtoMessage() + func (x *ListShardsRequest) ProtoReflect() protoreflect.Message + func (x *ListShardsRequest) Reset() + func (x *ListShardsRequest) String() string + type ListShardsResponse struct + Error *Error + NodeId string + Shards []*ShardInfo + TotalShards int32 + TotalWeight int32 + func (*ListShardsResponse) Descriptor() ([]byte, []int) + func (*ListShardsResponse) ProtoMessage() + func (x *ListShardsResponse) GetError() *Error + func (x *ListShardsResponse) GetNodeId() string + func (x *ListShardsResponse) GetShards() []*ShardInfo + func (x *ListShardsResponse) GetTotalShards() int32 + func (x *ListShardsResponse) GetTotalWeight() int32 + func (x *ListShardsResponse) ProtoReflect() protoreflect.Message + func (x *ListShardsResponse) Reset() + func (x *ListShardsResponse) String() string + type NodeInfo struct + Leader bool + NodeId string + RaftState string + SerfState string + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + func (x *NodeInfo) GetLeader() bool + func (x *NodeInfo) GetNodeId() string + func (x *NodeInfo) GetRaftState() string + func (x *NodeInfo) GetSerfState() string + func (x *NodeInfo) ProtoReflect() protoreflect.Message + func (x *NodeInfo) Reset() + func (x *NodeInfo) String() string + type RemoveNodeRequest struct + NodeId string + func (*RemoveNodeRequest) Descriptor() ([]byte, []int) + func (*RemoveNodeRequest) ProtoMessage() + func (x *RemoveNodeRequest) GetNodeId() string + func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message + func (x *RemoveNodeRequest) Reset() + func (x *RemoveNodeRequest) String() string + type RemoveNodeResponse struct + Error *Error + NodeId string + func (*RemoveNodeResponse) Descriptor() ([]byte, []int) + func (*RemoveNodeResponse) ProtoMessage() + func (x *RemoveNodeResponse) GetError() *Error + func (x *RemoveNodeResponse) GetNodeId() string + func (x *RemoveNodeResponse) ProtoReflect() protoreflect.Message + func (x *RemoveNodeResponse) Reset() + func (x *RemoveNodeResponse) String() string + type ShardInfo struct + NodeId string + ShardCount int32 + ShardWeight int32 + func (*ShardInfo) Descriptor() ([]byte, []int) + func (*ShardInfo) ProtoMessage() + func (x *ShardInfo) GetNodeId() string + func (x *ShardInfo) GetShardCount() int32 + func (x *ShardInfo) GetShardWeight() int32 + func (x *ShardInfo) ProtoReflect() protoreflect.Message + func (x *ShardInfo) Reset() + func (x *ShardInfo) String() string + type StepDownRequest struct + func (*StepDownRequest) Descriptor() ([]byte, []int) + func (*StepDownRequest) ProtoMessage() + func (x *StepDownRequest) ProtoReflect() protoreflect.Message + func (x *StepDownRequest) Reset() + func (x *StepDownRequest) String() string + type StepDownResponse struct + Error *Error + NodeId string + func (*StepDownResponse) Descriptor() ([]byte, []int) + func (*StepDownResponse) ProtoMessage() + func (x *StepDownResponse) GetError() *Error + func (x *StepDownResponse) GetNodeId() string + func (x *StepDownResponse) ProtoReflect() protoreflect.Message + func (x *StepDownResponse) Reset() + func (x *StepDownResponse) String() string + type UnimplementedClusterManagementServer struct + func (*UnimplementedClusterManagementServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error) + func (*UnimplementedClusterManagementServer) FindEndpoint(context.Context, *EndpointRequest) (*EndpointResponse, error) + func (*UnimplementedClusterManagementServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error) + func (*UnimplementedClusterManagementServer) ListEndpoints(context.Context, *ListEndpointRequest) (*ListEndpointResponse, error) + func (*UnimplementedClusterManagementServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error) + func (*UnimplementedClusterManagementServer) ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error) + func (*UnimplementedClusterManagementServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error) + func (*UnimplementedClusterManagementServer) StepDown(context.Context, *StepDownRequest) (*StepDownResponse, error)
Go to main page