managepb

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

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
}

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)
}

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)
}

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
}

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

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
}

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
}

type Error_Code int32

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

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
}

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

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
}

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

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
}

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

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
}

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
}

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

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
}

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
}

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

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
}

type UnimplementedClusterManagementServer struct {
}