managepb

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package managepb contains the protobuf-generate code for the cluster management interface

Index

Constants

This section is empty.

Variables

View Source 
var (
	Error_Code_name = map[int32]string{
		0: "OK",
		1: "INVALID",
		2: "NO_LEADER",
		3: "GENERIC",
		4: "UNKNOWN_ID",
	}
	Error_Code_value = map[string]int32{
		"OK":         0,
		"INVALID":    1,
		"NO_LEADER":  2,
		"GENERIC":    3,
		"UNKNOWN_ID": 4,
	}
)

Enum value maps for Error_Code.

View Source 
var File_clusterfunk_management_proto protoreflect.FileDescriptor

Functions

func RegisterClusterManagementServer 

func RegisterClusterManagementServer(s *grpc.Server, srv ClusterManagementServer)

Types

type AddNodeRequest 

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

Messages for the AddNode method

func (*AddNodeRequest) Descriptor deprecated 

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

Deprecated: Use AddNodeRequest.ProtoReflect.Descriptor instead.

func (*AddNodeRequest) GetNodeId 

func (x *AddNodeRequest) GetNodeId() string

func (*AddNodeRequest) ProtoMessage 

func (*AddNodeRequest) ProtoMessage()

func (*AddNodeRequest) ProtoReflect 

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

func (*AddNodeRequest) Reset 

func (x *AddNodeRequest) Reset()

func (*AddNodeRequest) String 

func (x *AddNodeRequest) String() string

type AddNodeResponse 

type AddNodeResponse struct {
	NodeId string `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

AddNodeResponse

func (*AddNodeResponse) Descriptor deprecated 

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

Deprecated: Use AddNodeResponse.ProtoReflect.Descriptor instead.

func (*AddNodeResponse) GetError 

func (x *AddNodeResponse) GetError() *Error

func (*AddNodeResponse) GetNodeId 

func (x *AddNodeResponse) GetNodeId() string

func (*AddNodeResponse) ProtoMessage 

func (*AddNodeResponse) ProtoMessage()

func (*AddNodeResponse) ProtoReflect 

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

func (*AddNodeResponse) Reset 

func (x *AddNodeResponse) Reset()

func (*AddNodeResponse) String 

func (x *AddNodeResponse) String() string

type ClusterManagementClient 

type ClusterManagementClient interface {
	// GetState returns the cluster state of the local node.
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
	// ListNodes lists the known nodes in the cluster, as seen by the leader.
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
	// FindEndpoint looks up an endpoint and returns the list. The list is
	// retrieved from the local node.
	FindEndpoint(ctx context.Context, in *EndpointRequest, opts ...grpc.CallOption) (*EndpointResponse, error)
	// ListEndpoints lists all of the endpoints in the cluster that this node
	// knows about. Serf propagation time might make an difference here.
	ListEndpoints(ctx context.Context, in *ListEndpointRequest, opts ...grpc.CallOption) (*ListEndpointResponse, error)
	// AddNode adds a node to the cluster. This request is proxied to the leader
	// if it is received by a non-leader node. The request will fail if there's
	// no current leader in the cluster.
	AddNode(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error)
	// RemoveNode removes a node from the cluster. This request is handled by
	// the leader. If the request is sent to one of the non-leaders in the cluster
	// it will be proxied to the leader.
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)
	// StepDown causes the (Raft) leader to step down and a new leader will be
	// elected.
	StepDown(ctx context.Context, in *StepDownRequest, opts ...grpc.CallOption) (*StepDownResponse, error)
	// ListShards dumps the current shard map as seen by the node handling the
	// request.
	ListShards(ctx context.Context, in *ListShardsRequest, opts ...grpc.CallOption) (*ListShardsResponse, error)
}

ClusterManagementClient is the client API for ClusterManagement service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterManagementClient 

func NewClusterManagementClient(cc grpc.ClientConnInterface) ClusterManagementClient

type ClusterManagementServer 

type ClusterManagementServer interface {
	// GetState returns the cluster state of the local node.
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	// ListNodes lists the known nodes in the cluster, as seen by the leader.
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
	// FindEndpoint looks up an endpoint and returns the list. The list is
	// retrieved from the local node.
	FindEndpoint(context.Context, *EndpointRequest) (*EndpointResponse, error)
	// ListEndpoints lists all of the endpoints in the cluster that this node
	// knows about. Serf propagation time might make an difference here.
	ListEndpoints(context.Context, *ListEndpointRequest) (*ListEndpointResponse, error)
	// AddNode adds a node to the cluster. This request is proxied to the leader
	// if it is received by a non-leader node. The request will fail if there's
	// no current leader in the cluster.
	AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
	// RemoveNode removes a node from the cluster. This request is handled by
	// the leader. If the request is sent to one of the non-leaders in the cluster
	// it will be proxied to the leader.
	RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
	// StepDown causes the (Raft) leader to step down and a new leader will be
	// elected.
	StepDown(context.Context, *StepDownRequest) (*StepDownResponse, error)
	// ListShards dumps the current shard map as seen by the node handling the
	// request.
	ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error)
}

ClusterManagementServer is the server API for ClusterManagement service.

type EndpointInfo 

type EndpointInfo struct {
	NodeId   string `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	HostPort string `protobuf:"bytes,3,opt,name=HostPort,proto3" json:"HostPort,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointInfo) Descriptor deprecated 

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

Deprecated: Use EndpointInfo.ProtoReflect.Descriptor instead.

func (*EndpointInfo) GetHostPort 

func (x *EndpointInfo) GetHostPort() string

func (*EndpointInfo) GetName 

func (x *EndpointInfo) GetName() string

func (*EndpointInfo) GetNodeId 

func (x *EndpointInfo) GetNodeId() string

func (*EndpointInfo) ProtoMessage 

func (*EndpointInfo) ProtoMessage()

func (*EndpointInfo) ProtoReflect 

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

func (*EndpointInfo) Reset 

func (x *EndpointInfo) Reset()

func (*EndpointInfo) String 

func (x *EndpointInfo) String() string

type EndpointRequest 

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

func (*EndpointRequest) Descriptor deprecated 

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

Deprecated: Use EndpointRequest.ProtoReflect.Descriptor instead.

func (*EndpointRequest) GetEndpointName 

func (x *EndpointRequest) GetEndpointName() string

func (*EndpointRequest) ProtoMessage 

func (*EndpointRequest) ProtoMessage()

func (*EndpointRequest) ProtoReflect 

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

func (*EndpointRequest) Reset 

func (x *EndpointRequest) Reset()

func (*EndpointRequest) String 

func (x *EndpointRequest) String() string

type EndpointResponse 

type EndpointResponse struct {
	NodeId    string          `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Error     *Error          `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	Endpoints []*EndpointInfo `protobuf:"bytes,3,rep,name=Endpoints,proto3" json:"Endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointResponse) Descriptor deprecated 

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

Deprecated: Use EndpointResponse.ProtoReflect.Descriptor instead.

func (*EndpointResponse) GetEndpoints 

func (x *EndpointResponse) GetEndpoints() []*EndpointInfo

func (*EndpointResponse) GetError 

func (x *EndpointResponse) GetError() *Error

func (*EndpointResponse) GetNodeId 

func (x *EndpointResponse) GetNodeId() string

func (*EndpointResponse) ProtoMessage 

func (*EndpointResponse) ProtoMessage()

func (*EndpointResponse) ProtoReflect 

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

func (*EndpointResponse) Reset 

func (x *EndpointResponse) Reset()

func (*EndpointResponse) String 

func (x *EndpointResponse) String() string

type Error 

type Error struct {
	ErrorCode Error_Code `protobuf:"varint,1,opt,name=ErrorCode,proto3,enum=managepb.Error_Code" json:"ErrorCode,omitempty"`
	Message   string     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

Errors is the various error codes that might be returned. The values are should be fairly obvious.

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetErrorCode 

func (x *Error) GetErrorCode() Error_Code

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type Error_Code 

type Error_Code int32
const (
	Error_OK         Error_Code = 0
	Error_INVALID    Error_Code = 1
	Error_NO_LEADER  Error_Code = 2
	Error_GENERIC    Error_Code = 3
	Error_UNKNOWN_ID Error_Code = 4
)

func (Error_Code) Descriptor 

func (Error_Code) Descriptor() protoreflect.EnumDescriptor

func (Error_Code) Enum 

func (x Error_Code) Enum() *Error_Code

func (Error_Code) EnumDescriptor deprecated 

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

Deprecated: Use Error_Code.Descriptor instead.

func (Error_Code) Number 

func (x Error_Code) Number() protoreflect.EnumNumber

func (Error_Code) String 

func (x Error_Code) String() string

func (Error_Code) Type 

func (Error_Code) Type() protoreflect.EnumType

type GetStatusRequest 

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

GetStatusRequest

func (*GetStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

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

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

type GetStatusResponse 

type GetStatusResponse struct {
	LocalNodeId   string `protobuf:"bytes,1,opt,name=LocalNodeId,proto3" json:"LocalNodeId,omitempty"`
	LeaderNodeId  string `protobuf:"bytes,2,opt,name=LeaderNodeId,proto3" json:"LeaderNodeId,omitempty"`
	RaftNodeCount int32  `protobuf:"varint,3,opt,name=RaftNodeCount,proto3" json:"RaftNodeCount,omitempty"`
	SerfNodeCount int32  `protobuf:"varint,4,opt,name=SerfNodeCount,proto3" json:"SerfNodeCount,omitempty"`
	LocalRole     string `protobuf:"bytes,5,opt,name=LocalRole,proto3" json:"LocalRole,omitempty"`
	LocalState    string `protobuf:"bytes,6,opt,name=LocalState,proto3" json:"LocalState,omitempty"`
	ClusterName   string `protobuf:"bytes,7,opt,name=ClusterName,proto3" json:"ClusterName,omitempty"`
	ShardCount    int32  `protobuf:"varint,8,opt,name=ShardCount,proto3" json:"ShardCount,omitempty"`
	ShardWeight   int32  `protobuf:"varint,9,opt,name=ShardWeight,proto3" json:"ShardWeight,omitempty"`
	Error         *Error `protobuf:"bytes,10,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

GetStatusResponse

func (*GetStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetClusterName 

func (x *GetStatusResponse) GetClusterName() string

func (*GetStatusResponse) GetError 

func (x *GetStatusResponse) GetError() *Error

func (*GetStatusResponse) GetLeaderNodeId 

func (x *GetStatusResponse) GetLeaderNodeId() string

func (*GetStatusResponse) GetLocalNodeId 

func (x *GetStatusResponse) GetLocalNodeId() string

func (*GetStatusResponse) GetLocalRole 

func (x *GetStatusResponse) GetLocalRole() string

func (*GetStatusResponse) GetLocalState 

func (x *GetStatusResponse) GetLocalState() string

func (*GetStatusResponse) GetRaftNodeCount 

func (x *GetStatusResponse) GetRaftNodeCount() int32

func (*GetStatusResponse) GetSerfNodeCount 

func (x *GetStatusResponse) GetSerfNodeCount() int32

func (*GetStatusResponse) GetShardCount 

func (x *GetStatusResponse) GetShardCount() int32

func (*GetStatusResponse) GetShardWeight 

func (x *GetStatusResponse) GetShardWeight() int32

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect 

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

func (*GetStatusResponse) Reset 

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String 

func (x *GetStatusResponse) String() string

type ListEndpointRequest 

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

ListEndpointRequest is a request to list all known endpoints

func (*ListEndpointRequest) Descriptor deprecated 

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

Deprecated: Use ListEndpointRequest.ProtoReflect.Descriptor instead.

func (*ListEndpointRequest) ProtoMessage 

func (*ListEndpointRequest) ProtoMessage()

func (*ListEndpointRequest) ProtoReflect 

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

func (*ListEndpointRequest) Reset 

func (x *ListEndpointRequest) Reset()

func (*ListEndpointRequest) String 

func (x *ListEndpointRequest) String() string

type ListEndpointResponse 

type ListEndpointResponse struct {
	NodeId    string          `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Error     *Error          `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	Endpoints []*EndpointInfo `protobuf:"bytes,3,rep,name=Endpoints,proto3" json:"Endpoints,omitempty"`
	// contains filtered or unexported fields
}

ListEndpointResponse is a list of all known endpoints on this node. There is no filtering on the endpoints.

func (*ListEndpointResponse) Descriptor deprecated 

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

Deprecated: Use ListEndpointResponse.ProtoReflect.Descriptor instead.

func (*ListEndpointResponse) GetEndpoints 

func (x *ListEndpointResponse) GetEndpoints() []*EndpointInfo

func (*ListEndpointResponse) GetError 

func (x *ListEndpointResponse) GetError() *Error

func (*ListEndpointResponse) GetNodeId 

func (x *ListEndpointResponse) GetNodeId() string

func (*ListEndpointResponse) ProtoMessage 

func (*ListEndpointResponse) ProtoMessage()

func (*ListEndpointResponse) ProtoReflect 

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

func (*ListEndpointResponse) Reset 

func (x *ListEndpointResponse) Reset()

func (*ListEndpointResponse) String 

func (x *ListEndpointResponse) String() string

type ListNodesRequest 

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

ListNodesRequest

func (*ListNodesRequest) Descriptor deprecated 

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

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect 

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

func (*ListNodesRequest) Reset 

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (x *ListNodesRequest) String() string

type ListNodesResponse 

type ListNodesResponse struct {
	NodeId   string      `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	LeaderId string      `protobuf:"bytes,2,opt,name=LeaderId,proto3" json:"LeaderId,omitempty"`
	Nodes    []*NodeInfo `protobuf:"bytes,3,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	Error    *Error      `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

ListNodesResponse is the response to a ListSerfNodes call. The number of Serf nodes will initially be quite small so we won't need a stream response here.

func (*ListNodesResponse) Descriptor deprecated 

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

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetError 

func (x *ListNodesResponse) GetError() *Error

func (*ListNodesResponse) GetLeaderId 

func (x *ListNodesResponse) GetLeaderId() string

func (*ListNodesResponse) GetNodeId 

func (x *ListNodesResponse) GetNodeId() string

func (*ListNodesResponse) GetNodes 

func (x *ListNodesResponse) GetNodes() []*NodeInfo

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect 

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

func (*ListNodesResponse) Reset 

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (x *ListNodesResponse) String() string

type ListShardsRequest 

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

ListShardsRequest

func (*ListShardsRequest) Descriptor deprecated 

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

Deprecated: Use ListShardsRequest.ProtoReflect.Descriptor instead.

func (*ListShardsRequest) ProtoMessage 

func (*ListShardsRequest) ProtoMessage()

func (*ListShardsRequest) ProtoReflect 

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

func (*ListShardsRequest) Reset 

func (x *ListShardsRequest) Reset()

func (*ListShardsRequest) String 

func (x *ListShardsRequest) String() string

type ListShardsResponse 

type ListShardsResponse struct {
	NodeId      string       `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Error       *Error       `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	Shards      []*ShardInfo `protobuf:"bytes,3,rep,name=Shards,proto3" json:"Shards,omitempty"`
	TotalShards int32        `protobuf:"varint,4,opt,name=TotalShards,proto3" json:"TotalShards,omitempty"`
	TotalWeight int32        `protobuf:"varint,5,opt,name=TotalWeight,proto3" json:"TotalWeight,omitempty"`
	// contains filtered or unexported fields
}

ListShardsResponse

func (*ListShardsResponse) Descriptor deprecated 

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

Deprecated: Use ListShardsResponse.ProtoReflect.Descriptor instead.

func (*ListShardsResponse) GetError 

func (x *ListShardsResponse) GetError() *Error

func (*ListShardsResponse) GetNodeId 

func (x *ListShardsResponse) GetNodeId() string

func (*ListShardsResponse) GetShards 

func (x *ListShardsResponse) GetShards() []*ShardInfo

func (*ListShardsResponse) GetTotalShards 

func (x *ListShardsResponse) GetTotalShards() int32

func (*ListShardsResponse) GetTotalWeight 

func (x *ListShardsResponse) GetTotalWeight() int32

func (*ListShardsResponse) ProtoMessage 

func (*ListShardsResponse) ProtoMessage()

func (*ListShardsResponse) ProtoReflect 

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

func (*ListShardsResponse) Reset 

func (x *ListShardsResponse) Reset()

func (*ListShardsResponse) String 

func (x *ListShardsResponse) String() string

type NodeInfo 

type NodeInfo struct {

	// NodeId is the node's identifier.
	NodeId    string `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	RaftState string `protobuf:"bytes,2,opt,name=RaftState,proto3" json:"RaftState,omitempty"`
	SerfState string `protobuf:"bytes,3,opt,name=SerfState,proto3" json:"SerfState,omitempty"`
	Leader    bool   `protobuf:"varint,4,opt,name=Leader,proto3" json:"Leader,omitempty"`
	// contains filtered or unexported fields
}

NodeInfo contains information on a single node in the cluster/swarm

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetLeader 

func (x *NodeInfo) GetLeader() bool

func (*NodeInfo) GetNodeId 

func (x *NodeInfo) GetNodeId() string

func (*NodeInfo) GetRaftState 

func (x *NodeInfo) GetRaftState() string

func (*NodeInfo) GetSerfState 

func (x *NodeInfo) GetSerfState() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type RemoveNodeRequest 

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

RemoveNodeRequest

func (*RemoveNodeRequest) Descriptor deprecated 

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

Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.

func (*RemoveNodeRequest) GetNodeId 

func (x *RemoveNodeRequest) GetNodeId() string

func (*RemoveNodeRequest) ProtoMessage 

func (*RemoveNodeRequest) ProtoMessage()

func (*RemoveNodeRequest) ProtoReflect 

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

func (*RemoveNodeRequest) Reset 

func (x *RemoveNodeRequest) Reset()

func (*RemoveNodeRequest) String 

func (x *RemoveNodeRequest) String() string

type RemoveNodeResponse 

type RemoveNodeResponse struct {
	NodeId string `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

RemoveNodeResponse

func (*RemoveNodeResponse) Descriptor deprecated 

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

Deprecated: Use RemoveNodeResponse.ProtoReflect.Descriptor instead.

func (*RemoveNodeResponse) GetError 

func (x *RemoveNodeResponse) GetError() *Error

func (*RemoveNodeResponse) GetNodeId 

func (x *RemoveNodeResponse) GetNodeId() string

func (*RemoveNodeResponse) ProtoMessage 

func (*RemoveNodeResponse) ProtoMessage()

func (*RemoveNodeResponse) ProtoReflect 

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

func (*RemoveNodeResponse) Reset 

func (x *RemoveNodeResponse) Reset()

func (*RemoveNodeResponse) String 

func (x *RemoveNodeResponse) String() string

type ShardInfo 

type ShardInfo struct {
	NodeId      string `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	ShardCount  int32  `protobuf:"varint,2,opt,name=ShardCount,proto3" json:"ShardCount,omitempty"`
	ShardWeight int32  `protobuf:"varint,3,opt,name=ShardWeight,proto3" json:"ShardWeight,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardInfo) Descriptor deprecated 

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

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) GetNodeId 

func (x *ShardInfo) GetNodeId() string

func (*ShardInfo) GetShardCount 

func (x *ShardInfo) GetShardCount() int32

func (*ShardInfo) GetShardWeight 

func (x *ShardInfo) GetShardWeight() int32

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 StepDownRequest 

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

func (*StepDownRequest) Descriptor deprecated 

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

Deprecated: Use StepDownRequest.ProtoReflect.Descriptor instead.

func (*StepDownRequest) ProtoMessage 

func (*StepDownRequest) ProtoMessage()

func (*StepDownRequest) ProtoReflect 

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

func (*StepDownRequest) Reset 

func (x *StepDownRequest) Reset()

func (*StepDownRequest) String 

func (x *StepDownRequest) String() string

type StepDownResponse 

type StepDownResponse struct {
	NodeId string `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*StepDownResponse) Descriptor deprecated 

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

Deprecated: Use StepDownResponse.ProtoReflect.Descriptor instead.

func (*StepDownResponse) GetError 

func (x *StepDownResponse) GetError() *Error

func (*StepDownResponse) GetNodeId 

func (x *StepDownResponse) GetNodeId() string

func (*StepDownResponse) ProtoMessage 

func (*StepDownResponse) ProtoMessage()

func (*StepDownResponse) ProtoReflect 

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

func (*StepDownResponse) Reset 

func (x *StepDownResponse) Reset()

func (*StepDownResponse) String 

func (x *StepDownResponse) String() string

type UnimplementedClusterManagementServer 

type UnimplementedClusterManagementServer struct {
}

UnimplementedClusterManagementServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterManagementServer) AddNode 

func (*UnimplementedClusterManagementServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)

func (*UnimplementedClusterManagementServer) FindEndpoint 

func (*UnimplementedClusterManagementServer) FindEndpoint(context.Context, *EndpointRequest) (*EndpointResponse, error)

func (*UnimplementedClusterManagementServer) GetStatus 

func (*UnimplementedClusterManagementServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

func (*UnimplementedClusterManagementServer) ListEndpoints 

func (*UnimplementedClusterManagementServer) ListEndpoints(context.Context, *ListEndpointRequest) (*ListEndpointResponse, error)

func (*UnimplementedClusterManagementServer) ListNodes 

func (*UnimplementedClusterManagementServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)

func (*UnimplementedClusterManagementServer) ListShards 

func (*UnimplementedClusterManagementServer) ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error)

func (*UnimplementedClusterManagementServer) RemoveNode 

func (*UnimplementedClusterManagementServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)

func (*UnimplementedClusterManagementServer) StepDown 

func (*UnimplementedClusterManagementServer) StepDown(context.Context, *StepDownRequest) (*StepDownResponse, error)

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.