clustermgmt

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package clustermgmt 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",
}
View Source 
var Error_Code_value = map[string]int32{
	"OK":         0,
	"INVALID":    1,
	"NO_LEADER":  2,
	"GENERIC":    3,
	"UNKNOWN_ID": 4,
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Messages for the AddNode method

func (*AddNodeRequest) Descriptor 

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

func (*AddNodeRequest) GetNodeId 

func (m *AddNodeRequest) GetNodeId() string

func (*AddNodeRequest) ProtoMessage 

func (*AddNodeRequest) ProtoMessage()

func (*AddNodeRequest) Reset 

func (m *AddNodeRequest) Reset()

func (*AddNodeRequest) String 

func (m *AddNodeRequest) String() string

func (*AddNodeRequest) XXX_DiscardUnknown 

func (m *AddNodeRequest) XXX_DiscardUnknown()

func (*AddNodeRequest) XXX_Marshal 

func (m *AddNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddNodeRequest) XXX_Merge 

func (m *AddNodeRequest) XXX_Merge(src proto.Message)

func (*AddNodeRequest) XXX_Size 

func (m *AddNodeRequest) XXX_Size() int

func (*AddNodeRequest) XXX_Unmarshal 

func (m *AddNodeRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AddNodeResponse

func (*AddNodeResponse) Descriptor 

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

func (*AddNodeResponse) GetError 

func (m *AddNodeResponse) GetError() *Error

func (*AddNodeResponse) GetNodeId 

func (m *AddNodeResponse) GetNodeId() string

func (*AddNodeResponse) ProtoMessage 

func (*AddNodeResponse) ProtoMessage()

func (*AddNodeResponse) Reset 

func (m *AddNodeResponse) Reset()

func (*AddNodeResponse) String 

func (m *AddNodeResponse) String() string

func (*AddNodeResponse) XXX_DiscardUnknown 

func (m *AddNodeResponse) XXX_DiscardUnknown()

func (*AddNodeResponse) XXX_Marshal 

func (m *AddNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddNodeResponse) XXX_Merge 

func (m *AddNodeResponse) XXX_Merge(src proto.Message)

func (*AddNodeResponse) XXX_Size 

func (m *AddNodeResponse) XXX_Size() int

func (*AddNodeResponse) XXX_Unmarshal 

func (m *AddNodeResponse) XXX_Unmarshal(b []byte) error

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.ClientConn) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EndpointInfo) Descriptor 

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

func (*EndpointInfo) GetHostPort 

func (m *EndpointInfo) GetHostPort() string

func (*EndpointInfo) GetName 

func (m *EndpointInfo) GetName() string

func (*EndpointInfo) GetNodeId 

func (m *EndpointInfo) GetNodeId() string

func (*EndpointInfo) ProtoMessage 

func (*EndpointInfo) ProtoMessage()

func (*EndpointInfo) Reset 

func (m *EndpointInfo) Reset()

func (*EndpointInfo) String 

func (m *EndpointInfo) String() string

func (*EndpointInfo) XXX_DiscardUnknown 

func (m *EndpointInfo) XXX_DiscardUnknown()

func (*EndpointInfo) XXX_Marshal 

func (m *EndpointInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointInfo) XXX_Merge 

func (m *EndpointInfo) XXX_Merge(src proto.Message)

func (*EndpointInfo) XXX_Size 

func (m *EndpointInfo) XXX_Size() int

func (*EndpointInfo) XXX_Unmarshal 

func (m *EndpointInfo) XXX_Unmarshal(b []byte) error

type EndpointRequest 

type EndpointRequest struct {
	EndpointName         string   `protobuf:"bytes,1,opt,name=EndpointName,proto3" json:"EndpointName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EndpointRequest) Descriptor 

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

func (*EndpointRequest) GetEndpointName 

func (m *EndpointRequest) GetEndpointName() string

func (*EndpointRequest) ProtoMessage 

func (*EndpointRequest) ProtoMessage()

func (*EndpointRequest) Reset 

func (m *EndpointRequest) Reset()

func (*EndpointRequest) String 

func (m *EndpointRequest) String() string

func (*EndpointRequest) XXX_DiscardUnknown 

func (m *EndpointRequest) XXX_DiscardUnknown()

func (*EndpointRequest) XXX_Marshal 

func (m *EndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointRequest) XXX_Merge 

func (m *EndpointRequest) XXX_Merge(src proto.Message)

func (*EndpointRequest) XXX_Size 

func (m *EndpointRequest) XXX_Size() int

func (*EndpointRequest) XXX_Unmarshal 

func (m *EndpointRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*EndpointResponse) Descriptor 

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

func (*EndpointResponse) GetEndpoints 

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

func (*EndpointResponse) GetError 

func (m *EndpointResponse) GetError() *Error

func (*EndpointResponse) GetNodeId 

func (m *EndpointResponse) GetNodeId() string

func (*EndpointResponse) ProtoMessage 

func (*EndpointResponse) ProtoMessage()

func (*EndpointResponse) Reset 

func (m *EndpointResponse) Reset()

func (*EndpointResponse) String 

func (m *EndpointResponse) String() string

func (*EndpointResponse) XXX_DiscardUnknown 

func (m *EndpointResponse) XXX_DiscardUnknown()

func (*EndpointResponse) XXX_Marshal 

func (m *EndpointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointResponse) XXX_Merge 

func (m *EndpointResponse) XXX_Merge(src proto.Message)

func (*EndpointResponse) XXX_Size 

func (m *EndpointResponse) XXX_Size() int

func (*EndpointResponse) XXX_Unmarshal 

func (m *EndpointResponse) XXX_Unmarshal(b []byte) error

type Error 

type Error struct {
	ErrorCode            Error_Code `protobuf:"varint,1,opt,name=ErrorCode,proto3,enum=clustermgmt.Error_Code" json:"ErrorCode,omitempty"`
	Message              string     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

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

func (*Error) Descriptor 

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

func (*Error) GetErrorCode 

func (m *Error) GetErrorCode() Error_Code

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

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

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

func (Error_Code) String 

func (x Error_Code) String() string

type GetStatusRequest 

type GetStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStatusRequest

func (*GetStatusRequest) Descriptor 

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

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) Reset 

func (m *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (m *GetStatusRequest) String() string

func (*GetStatusRequest) XXX_DiscardUnknown 

func (m *GetStatusRequest) XXX_DiscardUnknown()

func (*GetStatusRequest) XXX_Marshal 

func (m *GetStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStatusRequest) XXX_Merge 

func (m *GetStatusRequest) XXX_Merge(src proto.Message)

func (*GetStatusRequest) XXX_Size 

func (m *GetStatusRequest) XXX_Size() int

func (*GetStatusRequest) XXX_Unmarshal 

func (m *GetStatusRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStatusResponse

func (*GetStatusResponse) Descriptor 

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

func (*GetStatusResponse) GetClusterName 

func (m *GetStatusResponse) GetClusterName() string

func (*GetStatusResponse) GetError 

func (m *GetStatusResponse) GetError() *Error

func (*GetStatusResponse) GetLeaderNodeId 

func (m *GetStatusResponse) GetLeaderNodeId() string

func (*GetStatusResponse) GetLocalNodeId 

func (m *GetStatusResponse) GetLocalNodeId() string

func (*GetStatusResponse) GetLocalRole 

func (m *GetStatusResponse) GetLocalRole() string

func (*GetStatusResponse) GetLocalState 

func (m *GetStatusResponse) GetLocalState() string

func (*GetStatusResponse) GetRaftNodeCount 

func (m *GetStatusResponse) GetRaftNodeCount() int32

func (*GetStatusResponse) GetSerfNodeCount 

func (m *GetStatusResponse) GetSerfNodeCount() int32

func (*GetStatusResponse) GetShardCount 

func (m *GetStatusResponse) GetShardCount() int32

func (*GetStatusResponse) GetShardWeight 

func (m *GetStatusResponse) GetShardWeight() int32

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) Reset 

func (m *GetStatusResponse) Reset()

func (*GetStatusResponse) String 

func (m *GetStatusResponse) String() string

func (*GetStatusResponse) XXX_DiscardUnknown 

func (m *GetStatusResponse) XXX_DiscardUnknown()

func (*GetStatusResponse) XXX_Marshal 

func (m *GetStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStatusResponse) XXX_Merge 

func (m *GetStatusResponse) XXX_Merge(src proto.Message)

func (*GetStatusResponse) XXX_Size 

func (m *GetStatusResponse) XXX_Size() int

func (*GetStatusResponse) XXX_Unmarshal 

func (m *GetStatusResponse) XXX_Unmarshal(b []byte) error

type ListEndpointRequest 

type ListEndpointRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListEndpointRequest is a request to list all known endpoints

func (*ListEndpointRequest) Descriptor 

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

func (*ListEndpointRequest) ProtoMessage 

func (*ListEndpointRequest) ProtoMessage()

func (*ListEndpointRequest) Reset 

func (m *ListEndpointRequest) Reset()

func (*ListEndpointRequest) String 

func (m *ListEndpointRequest) String() string

func (*ListEndpointRequest) XXX_DiscardUnknown 

func (m *ListEndpointRequest) XXX_DiscardUnknown()

func (*ListEndpointRequest) XXX_Marshal 

func (m *ListEndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListEndpointRequest) XXX_Merge 

func (m *ListEndpointRequest) XXX_Merge(src proto.Message)

func (*ListEndpointRequest) XXX_Size 

func (m *ListEndpointRequest) XXX_Size() int

func (*ListEndpointRequest) XXX_Unmarshal 

func (m *ListEndpointRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*ListEndpointResponse) Descriptor 

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

func (*ListEndpointResponse) GetEndpoints 

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

func (*ListEndpointResponse) GetError 

func (m *ListEndpointResponse) GetError() *Error

func (*ListEndpointResponse) GetNodeId 

func (m *ListEndpointResponse) GetNodeId() string

func (*ListEndpointResponse) ProtoMessage 

func (*ListEndpointResponse) ProtoMessage()

func (*ListEndpointResponse) Reset 

func (m *ListEndpointResponse) Reset()

func (*ListEndpointResponse) String 

func (m *ListEndpointResponse) String() string

func (*ListEndpointResponse) XXX_DiscardUnknown 

func (m *ListEndpointResponse) XXX_DiscardUnknown()

func (*ListEndpointResponse) XXX_Marshal 

func (m *ListEndpointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListEndpointResponse) XXX_Merge 

func (m *ListEndpointResponse) XXX_Merge(src proto.Message)

func (*ListEndpointResponse) XXX_Size 

func (m *ListEndpointResponse) XXX_Size() int

func (*ListEndpointResponse) XXX_Unmarshal 

func (m *ListEndpointResponse) XXX_Unmarshal(b []byte) error

type ListNodesRequest 

type ListNodesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListNodesRequest

func (*ListNodesRequest) Descriptor 

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

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) Reset 

func (m *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (m *ListNodesRequest) String() string

func (*ListNodesRequest) XXX_DiscardUnknown 

func (m *ListNodesRequest) XXX_DiscardUnknown()

func (*ListNodesRequest) XXX_Marshal 

func (m *ListNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListNodesRequest) XXX_Merge 

func (m *ListNodesRequest) XXX_Merge(src proto.Message)

func (*ListNodesRequest) XXX_Size 

func (m *ListNodesRequest) XXX_Size() int

func (*ListNodesRequest) XXX_Unmarshal 

func (m *ListNodesRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

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 

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

func (*ListNodesResponse) GetError 

func (m *ListNodesResponse) GetError() *Error

func (*ListNodesResponse) GetLeaderId 

func (m *ListNodesResponse) GetLeaderId() string

func (*ListNodesResponse) GetNodeId 

func (m *ListNodesResponse) GetNodeId() string

func (*ListNodesResponse) GetNodes 

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

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) Reset 

func (m *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (m *ListNodesResponse) String() string

func (*ListNodesResponse) XXX_DiscardUnknown 

func (m *ListNodesResponse) XXX_DiscardUnknown()

func (*ListNodesResponse) XXX_Marshal 

func (m *ListNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListNodesResponse) XXX_Merge 

func (m *ListNodesResponse) XXX_Merge(src proto.Message)

func (*ListNodesResponse) XXX_Size 

func (m *ListNodesResponse) XXX_Size() int

func (*ListNodesResponse) XXX_Unmarshal 

func (m *ListNodesResponse) XXX_Unmarshal(b []byte) error

type ListShardsRequest 

type ListShardsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListShardsRequest

func (*ListShardsRequest) Descriptor 

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

func (*ListShardsRequest) ProtoMessage 

func (*ListShardsRequest) ProtoMessage()

func (*ListShardsRequest) Reset 

func (m *ListShardsRequest) Reset()

func (*ListShardsRequest) String 

func (m *ListShardsRequest) String() string

func (*ListShardsRequest) XXX_DiscardUnknown 

func (m *ListShardsRequest) XXX_DiscardUnknown()

func (*ListShardsRequest) XXX_Marshal 

func (m *ListShardsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListShardsRequest) XXX_Merge 

func (m *ListShardsRequest) XXX_Merge(src proto.Message)

func (*ListShardsRequest) XXX_Size 

func (m *ListShardsRequest) XXX_Size() int

func (*ListShardsRequest) XXX_Unmarshal 

func (m *ListShardsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ListShardsResponse

func (*ListShardsResponse) Descriptor 

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

func (*ListShardsResponse) GetError 

func (m *ListShardsResponse) GetError() *Error

func (*ListShardsResponse) GetNodeId 

func (m *ListShardsResponse) GetNodeId() string

func (*ListShardsResponse) GetShards 

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

func (*ListShardsResponse) GetTotalShards 

func (m *ListShardsResponse) GetTotalShards() int32

func (*ListShardsResponse) GetTotalWeight 

func (m *ListShardsResponse) GetTotalWeight() int32

func (*ListShardsResponse) ProtoMessage 

func (*ListShardsResponse) ProtoMessage()

func (*ListShardsResponse) Reset 

func (m *ListShardsResponse) Reset()

func (*ListShardsResponse) String 

func (m *ListShardsResponse) String() string

func (*ListShardsResponse) XXX_DiscardUnknown 

func (m *ListShardsResponse) XXX_DiscardUnknown()

func (*ListShardsResponse) XXX_Marshal 

func (m *ListShardsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListShardsResponse) XXX_Merge 

func (m *ListShardsResponse) XXX_Merge(src proto.Message)

func (*ListShardsResponse) XXX_Size 

func (m *ListShardsResponse) XXX_Size() int

func (*ListShardsResponse) XXX_Unmarshal 

func (m *ListShardsResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetLeader 

func (m *NodeInfo) GetLeader() bool

func (*NodeInfo) GetNodeId 

func (m *NodeInfo) GetNodeId() string

func (*NodeInfo) GetRaftState 

func (m *NodeInfo) GetRaftState() string

func (*NodeInfo) GetSerfState 

func (m *NodeInfo) GetSerfState() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeInfo) XXX_Merge 

func (m *NodeInfo) XXX_Merge(src proto.Message)

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

func (m *NodeInfo) XXX_Unmarshal(b []byte) error

type RemoveNodeRequest 

type RemoveNodeRequest struct {
	NodeId               string   `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RemoveNodeRequest

func (*RemoveNodeRequest) Descriptor 

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

func (*RemoveNodeRequest) GetNodeId 

func (m *RemoveNodeRequest) GetNodeId() string

func (*RemoveNodeRequest) ProtoMessage 

func (*RemoveNodeRequest) ProtoMessage()

func (*RemoveNodeRequest) Reset 

func (m *RemoveNodeRequest) Reset()

func (*RemoveNodeRequest) String 

func (m *RemoveNodeRequest) String() string

func (*RemoveNodeRequest) XXX_DiscardUnknown 

func (m *RemoveNodeRequest) XXX_DiscardUnknown()

func (*RemoveNodeRequest) XXX_Marshal 

func (m *RemoveNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveNodeRequest) XXX_Merge 

func (m *RemoveNodeRequest) XXX_Merge(src proto.Message)

func (*RemoveNodeRequest) XXX_Size 

func (m *RemoveNodeRequest) XXX_Size() int

func (*RemoveNodeRequest) XXX_Unmarshal 

func (m *RemoveNodeRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RemoveNodeResponse

func (*RemoveNodeResponse) Descriptor 

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

func (*RemoveNodeResponse) GetError 

func (m *RemoveNodeResponse) GetError() *Error

func (*RemoveNodeResponse) GetNodeId 

func (m *RemoveNodeResponse) GetNodeId() string

func (*RemoveNodeResponse) ProtoMessage 

func (*RemoveNodeResponse) ProtoMessage()

func (*RemoveNodeResponse) Reset 

func (m *RemoveNodeResponse) Reset()

func (*RemoveNodeResponse) String 

func (m *RemoveNodeResponse) String() string

func (*RemoveNodeResponse) XXX_DiscardUnknown 

func (m *RemoveNodeResponse) XXX_DiscardUnknown()

func (*RemoveNodeResponse) XXX_Marshal 

func (m *RemoveNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveNodeResponse) XXX_Merge 

func (m *RemoveNodeResponse) XXX_Merge(src proto.Message)

func (*RemoveNodeResponse) XXX_Size 

func (m *RemoveNodeResponse) XXX_Size() int

func (*RemoveNodeResponse) XXX_Unmarshal 

func (m *RemoveNodeResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardInfo) Descriptor 

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

func (*ShardInfo) GetNodeId 

func (m *ShardInfo) GetNodeId() string

func (*ShardInfo) GetShardCount 

func (m *ShardInfo) GetShardCount() int32

func (*ShardInfo) GetShardWeight 

func (m *ShardInfo) GetShardWeight() int32

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) Reset 

func (m *ShardInfo) Reset()

func (*ShardInfo) String 

func (m *ShardInfo) String() string

func (*ShardInfo) XXX_DiscardUnknown 

func (m *ShardInfo) XXX_DiscardUnknown()

func (*ShardInfo) XXX_Marshal 

func (m *ShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardInfo) XXX_Merge 

func (m *ShardInfo) XXX_Merge(src proto.Message)

func (*ShardInfo) XXX_Size 

func (m *ShardInfo) XXX_Size() int

func (*ShardInfo) XXX_Unmarshal 

func (m *ShardInfo) XXX_Unmarshal(b []byte) error

type StepDownRequest 

type StepDownRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StepDownRequest) Descriptor 

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

func (*StepDownRequest) ProtoMessage 

func (*StepDownRequest) ProtoMessage()

func (*StepDownRequest) Reset 

func (m *StepDownRequest) Reset()

func (*StepDownRequest) String 

func (m *StepDownRequest) String() string

func (*StepDownRequest) XXX_DiscardUnknown 

func (m *StepDownRequest) XXX_DiscardUnknown()

func (*StepDownRequest) XXX_Marshal 

func (m *StepDownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepDownRequest) XXX_Merge 

func (m *StepDownRequest) XXX_Merge(src proto.Message)

func (*StepDownRequest) XXX_Size 

func (m *StepDownRequest) XXX_Size() int

func (*StepDownRequest) XXX_Unmarshal 

func (m *StepDownRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StepDownResponse) Descriptor 

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

func (*StepDownResponse) GetError 

func (m *StepDownResponse) GetError() *Error

func (*StepDownResponse) GetNodeId 

func (m *StepDownResponse) GetNodeId() string

func (*StepDownResponse) ProtoMessage 

func (*StepDownResponse) ProtoMessage()

func (*StepDownResponse) Reset 

func (m *StepDownResponse) Reset()

func (*StepDownResponse) String 

func (m *StepDownResponse) String() string

func (*StepDownResponse) XXX_DiscardUnknown 

func (m *StepDownResponse) XXX_DiscardUnknown()

func (*StepDownResponse) XXX_Marshal 

func (m *StepDownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepDownResponse) XXX_Merge 

func (m *StepDownResponse) XXX_Merge(src proto.Message)

func (*StepDownResponse) XXX_Size 

func (m *StepDownResponse) XXX_Size() int

func (*StepDownResponse) XXX_Unmarshal 

func (m *StepDownResponse) XXX_Unmarshal(b []byte) 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.