Versions in this module Expand all Collapse all v0 v0.0.3 Jan 30, 2020 v0.0.2 Dec 10, 2019 Changes in this version + var Error_Code_name = map[int32]string + var Error_Code_value = map[string]int32 + func RegisterClusterManagementServer(s *grpc.Server, srv ClusterManagementServer) + type AddNodeRequest struct + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AddNodeRequest) Descriptor() ([]byte, []int) + func (*AddNodeRequest) ProtoMessage() + func (m *AddNodeRequest) GetNodeId() string + func (m *AddNodeRequest) Reset() + func (m *AddNodeRequest) String() string + func (m *AddNodeRequest) XXX_DiscardUnknown() + func (m *AddNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddNodeRequest) XXX_Merge(src proto.Message) + func (m *AddNodeRequest) XXX_Size() int + func (m *AddNodeRequest) XXX_Unmarshal(b []byte) error + type AddNodeResponse struct + Error *Error + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AddNodeResponse) Descriptor() ([]byte, []int) + func (*AddNodeResponse) ProtoMessage() + func (m *AddNodeResponse) GetError() *Error + func (m *AddNodeResponse) GetNodeId() string + func (m *AddNodeResponse) Reset() + func (m *AddNodeResponse) String() string + func (m *AddNodeResponse) XXX_DiscardUnknown() + func (m *AddNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddNodeResponse) XXX_Merge(src proto.Message) + func (m *AddNodeResponse) XXX_Size() int + func (m *AddNodeResponse) XXX_Unmarshal(b []byte) error + 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.ClientConn) 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointInfo) Descriptor() ([]byte, []int) + func (*EndpointInfo) ProtoMessage() + func (m *EndpointInfo) GetHostPort() string + func (m *EndpointInfo) GetName() string + func (m *EndpointInfo) GetNodeId() string + func (m *EndpointInfo) Reset() + func (m *EndpointInfo) String() string + func (m *EndpointInfo) XXX_DiscardUnknown() + func (m *EndpointInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointInfo) XXX_Merge(src proto.Message) + func (m *EndpointInfo) XXX_Size() int + func (m *EndpointInfo) XXX_Unmarshal(b []byte) error + type EndpointRequest struct + EndpointName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointRequest) Descriptor() ([]byte, []int) + func (*EndpointRequest) ProtoMessage() + func (m *EndpointRequest) GetEndpointName() string + func (m *EndpointRequest) Reset() + func (m *EndpointRequest) String() string + func (m *EndpointRequest) XXX_DiscardUnknown() + func (m *EndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointRequest) XXX_Merge(src proto.Message) + func (m *EndpointRequest) XXX_Size() int + func (m *EndpointRequest) XXX_Unmarshal(b []byte) error + type EndpointResponse struct + Endpoints []*EndpointInfo + Error *Error + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointResponse) Descriptor() ([]byte, []int) + func (*EndpointResponse) ProtoMessage() + func (m *EndpointResponse) GetEndpoints() []*EndpointInfo + func (m *EndpointResponse) GetError() *Error + func (m *EndpointResponse) GetNodeId() string + func (m *EndpointResponse) Reset() + func (m *EndpointResponse) String() string + func (m *EndpointResponse) XXX_DiscardUnknown() + func (m *EndpointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointResponse) XXX_Merge(src proto.Message) + func (m *EndpointResponse) XXX_Size() int + func (m *EndpointResponse) XXX_Unmarshal(b []byte) error + type Error struct + ErrorCode Error_Code + Message string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetErrorCode() Error_Code + func (m *Error) GetMessage() string + func (m *Error) Reset() + func (m *Error) String() string + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type Error_Code int32 + const Error_GENERIC + const Error_INVALID + const Error_NO_LEADER + const Error_OK + const Error_UNKNOWN_ID + func (Error_Code) EnumDescriptor() ([]byte, []int) + func (x Error_Code) String() string + type GetStatusRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetStatusRequest) Descriptor() ([]byte, []int) + func (*GetStatusRequest) ProtoMessage() + func (m *GetStatusRequest) Reset() + func (m *GetStatusRequest) String() string + func (m *GetStatusRequest) XXX_DiscardUnknown() + func (m *GetStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetStatusRequest) XXX_Merge(src proto.Message) + func (m *GetStatusRequest) XXX_Size() int + func (m *GetStatusRequest) XXX_Unmarshal(b []byte) error + type GetStatusResponse struct + ClusterName string + Error *Error + LeaderNodeId string + LocalNodeId string + LocalRole string + LocalState string + RaftNodeCount int32 + SerfNodeCount int32 + ShardCount int32 + ShardWeight int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetStatusResponse) Descriptor() ([]byte, []int) + func (*GetStatusResponse) ProtoMessage() + func (m *GetStatusResponse) GetClusterName() string + func (m *GetStatusResponse) GetError() *Error + func (m *GetStatusResponse) GetLeaderNodeId() string + func (m *GetStatusResponse) GetLocalNodeId() string + func (m *GetStatusResponse) GetLocalRole() string + func (m *GetStatusResponse) GetLocalState() string + func (m *GetStatusResponse) GetRaftNodeCount() int32 + func (m *GetStatusResponse) GetSerfNodeCount() int32 + func (m *GetStatusResponse) GetShardCount() int32 + func (m *GetStatusResponse) GetShardWeight() int32 + func (m *GetStatusResponse) Reset() + func (m *GetStatusResponse) String() string + func (m *GetStatusResponse) XXX_DiscardUnknown() + func (m *GetStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetStatusResponse) XXX_Merge(src proto.Message) + func (m *GetStatusResponse) XXX_Size() int + func (m *GetStatusResponse) XXX_Unmarshal(b []byte) error + type ListEndpointRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListEndpointRequest) Descriptor() ([]byte, []int) + func (*ListEndpointRequest) ProtoMessage() + func (m *ListEndpointRequest) Reset() + func (m *ListEndpointRequest) String() string + func (m *ListEndpointRequest) XXX_DiscardUnknown() + func (m *ListEndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListEndpointRequest) XXX_Merge(src proto.Message) + func (m *ListEndpointRequest) XXX_Size() int + func (m *ListEndpointRequest) XXX_Unmarshal(b []byte) error + type ListEndpointResponse struct + Endpoints []*EndpointInfo + Error *Error + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListEndpointResponse) Descriptor() ([]byte, []int) + func (*ListEndpointResponse) ProtoMessage() + func (m *ListEndpointResponse) GetEndpoints() []*EndpointInfo + func (m *ListEndpointResponse) GetError() *Error + func (m *ListEndpointResponse) GetNodeId() string + func (m *ListEndpointResponse) Reset() + func (m *ListEndpointResponse) String() string + func (m *ListEndpointResponse) XXX_DiscardUnknown() + func (m *ListEndpointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListEndpointResponse) XXX_Merge(src proto.Message) + func (m *ListEndpointResponse) XXX_Size() int + func (m *ListEndpointResponse) XXX_Unmarshal(b []byte) error + type ListNodesRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListNodesRequest) Descriptor() ([]byte, []int) + func (*ListNodesRequest) ProtoMessage() + func (m *ListNodesRequest) Reset() + func (m *ListNodesRequest) String() string + func (m *ListNodesRequest) XXX_DiscardUnknown() + func (m *ListNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListNodesRequest) XXX_Merge(src proto.Message) + func (m *ListNodesRequest) XXX_Size() int + func (m *ListNodesRequest) XXX_Unmarshal(b []byte) error + type ListNodesResponse struct + Error *Error + LeaderId string + NodeId string + Nodes []*NodeInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListNodesResponse) Descriptor() ([]byte, []int) + func (*ListNodesResponse) ProtoMessage() + func (m *ListNodesResponse) GetError() *Error + func (m *ListNodesResponse) GetLeaderId() string + func (m *ListNodesResponse) GetNodeId() string + func (m *ListNodesResponse) GetNodes() []*NodeInfo + func (m *ListNodesResponse) Reset() + func (m *ListNodesResponse) String() string + func (m *ListNodesResponse) XXX_DiscardUnknown() + func (m *ListNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListNodesResponse) XXX_Merge(src proto.Message) + func (m *ListNodesResponse) XXX_Size() int + func (m *ListNodesResponse) XXX_Unmarshal(b []byte) error + type ListShardsRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListShardsRequest) Descriptor() ([]byte, []int) + func (*ListShardsRequest) ProtoMessage() + func (m *ListShardsRequest) Reset() + func (m *ListShardsRequest) String() string + func (m *ListShardsRequest) XXX_DiscardUnknown() + func (m *ListShardsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListShardsRequest) XXX_Merge(src proto.Message) + func (m *ListShardsRequest) XXX_Size() int + func (m *ListShardsRequest) XXX_Unmarshal(b []byte) error + type ListShardsResponse struct + Error *Error + NodeId string + Shards []*ShardInfo + TotalShards int32 + TotalWeight int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListShardsResponse) Descriptor() ([]byte, []int) + func (*ListShardsResponse) ProtoMessage() + func (m *ListShardsResponse) GetError() *Error + func (m *ListShardsResponse) GetNodeId() string + func (m *ListShardsResponse) GetShards() []*ShardInfo + func (m *ListShardsResponse) GetTotalShards() int32 + func (m *ListShardsResponse) GetTotalWeight() int32 + func (m *ListShardsResponse) Reset() + func (m *ListShardsResponse) String() string + func (m *ListShardsResponse) XXX_DiscardUnknown() + func (m *ListShardsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListShardsResponse) XXX_Merge(src proto.Message) + func (m *ListShardsResponse) XXX_Size() int + func (m *ListShardsResponse) XXX_Unmarshal(b []byte) error + type NodeInfo struct + Leader bool + NodeId string + RaftState string + SerfState string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + func (m *NodeInfo) GetLeader() bool + func (m *NodeInfo) GetNodeId() string + func (m *NodeInfo) GetRaftState() string + func (m *NodeInfo) GetSerfState() string + func (m *NodeInfo) Reset() + func (m *NodeInfo) String() string + func (m *NodeInfo) XXX_DiscardUnknown() + func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeInfo) XXX_Merge(src proto.Message) + func (m *NodeInfo) XXX_Size() int + func (m *NodeInfo) XXX_Unmarshal(b []byte) error + type RemoveNodeRequest struct + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoveNodeRequest) Descriptor() ([]byte, []int) + func (*RemoveNodeRequest) ProtoMessage() + func (m *RemoveNodeRequest) GetNodeId() string + func (m *RemoveNodeRequest) Reset() + func (m *RemoveNodeRequest) String() string + func (m *RemoveNodeRequest) XXX_DiscardUnknown() + func (m *RemoveNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoveNodeRequest) XXX_Merge(src proto.Message) + func (m *RemoveNodeRequest) XXX_Size() int + func (m *RemoveNodeRequest) XXX_Unmarshal(b []byte) error + type RemoveNodeResponse struct + Error *Error + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoveNodeResponse) Descriptor() ([]byte, []int) + func (*RemoveNodeResponse) ProtoMessage() + func (m *RemoveNodeResponse) GetError() *Error + func (m *RemoveNodeResponse) GetNodeId() string + func (m *RemoveNodeResponse) Reset() + func (m *RemoveNodeResponse) String() string + func (m *RemoveNodeResponse) XXX_DiscardUnknown() + func (m *RemoveNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoveNodeResponse) XXX_Merge(src proto.Message) + func (m *RemoveNodeResponse) XXX_Size() int + func (m *RemoveNodeResponse) XXX_Unmarshal(b []byte) error + type ShardInfo struct + NodeId string + ShardCount int32 + ShardWeight int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardInfo) Descriptor() ([]byte, []int) + func (*ShardInfo) ProtoMessage() + func (m *ShardInfo) GetNodeId() string + func (m *ShardInfo) GetShardCount() int32 + func (m *ShardInfo) GetShardWeight() int32 + func (m *ShardInfo) Reset() + func (m *ShardInfo) String() string + func (m *ShardInfo) XXX_DiscardUnknown() + func (m *ShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardInfo) XXX_Merge(src proto.Message) + func (m *ShardInfo) XXX_Size() int + func (m *ShardInfo) XXX_Unmarshal(b []byte) error + type StepDownRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StepDownRequest) Descriptor() ([]byte, []int) + func (*StepDownRequest) ProtoMessage() + func (m *StepDownRequest) Reset() + func (m *StepDownRequest) String() string + func (m *StepDownRequest) XXX_DiscardUnknown() + func (m *StepDownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StepDownRequest) XXX_Merge(src proto.Message) + func (m *StepDownRequest) XXX_Size() int + func (m *StepDownRequest) XXX_Unmarshal(b []byte) error + type StepDownResponse struct + Error *Error + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StepDownResponse) Descriptor() ([]byte, []int) + func (*StepDownResponse) ProtoMessage() + func (m *StepDownResponse) GetError() *Error + func (m *StepDownResponse) GetNodeId() string + func (m *StepDownResponse) Reset() + func (m *StepDownResponse) String() string + func (m *StepDownResponse) XXX_DiscardUnknown() + func (m *StepDownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StepDownResponse) XXX_Merge(src proto.Message) + func (m *StepDownResponse) XXX_Size() int + func (m *StepDownResponse) XXX_Unmarshal(b []byte) error
Go to main page