drummerpb

package
v2.1.7+incompatible Latest Latest
Warning

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

 Go to latest Published: May 7, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation ¶

Overview ¶

Package drummerpb is a generated protocol buffer package.

Package drummerpb contains definition of internal structs and messages used by the optional Drummer component. Your dragonboat application only needs to import this package when you choose to let drummer to manage your distributed nodehost instances.

It is generated from these files: 

drummer.proto

It has these top-level messages: 

Regions
Cluster
ClusterCollection
KV
Change
ChangeResponse
Update
LookupRequest
LookupResponse
Request
ClusterStateRequest
ClusterState
ClusterInfo
LogInfo
ClusterStates
NodeHostInfo
NodeHostCollection
ConfigChangeIndexList
DeploymentInfo
Empty
NodeHostRequest
NodeHostRequestCollection
DrummerConfigRequest
Config

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source 
var (
	ErrInvalidLengthDrummer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDrummer   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ChangeResponse_Code_name = map[int32]string{
	0: "OK",
	1: "CLUSTER_NOT_FOUND",
	2: "CONFLICT_FOUND",
	3: "UNKNOWN_RETRY",
	4: "CLUSTER_EXIST",
	5: "BOOTSTRAPPED",
	6: "REGIONS_SET",
}
View Source 
var ChangeResponse_Code_value = map[string]int32{
	"OK":                0,
	"CLUSTER_NOT_FOUND": 1,
	"CONFLICT_FOUND":    2,
	"UNKNOWN_RETRY":     3,
	"CLUSTER_EXIST":     4,
	"BOOTSTRAPPED":      5,
	"REGIONS_SET":       6,
}
View Source 
var Change_Type_name = map[int32]string{
	0: "CREATE",
}
View Source 
var Change_Type_value = map[string]int32{
	"CREATE": 0,
}
View Source 
var ClusterState_State_name = map[int32]string{
	0: "OK",
	1: "UNAVAILABLE",
}
View Source 
var ClusterState_State_value = map[string]int32{
	"OK":          0,
	"UNAVAILABLE": 1,
}
View Source 
var LookupRequest_Type_name = map[int32]string{
	0: "CLUSTER",
	1: "KV",
	3: "SCHEDULER_CONTEXT",
	4: "REQUESTS",
	5: "CLUSTER_STATES",
}
View Source 
var LookupRequest_Type_value = map[string]int32{
	"CLUSTER":           0,
	"KV":                1,
	"SCHEDULER_CONTEXT": 3,
	"REQUESTS":          4,
	"CLUSTER_STATES":    5,
}
View Source 
var LookupResponse_Code_name = map[int32]string{
	0: "OK",
	1: "CLUSTER_NOT_FOUND",
}
View Source 
var LookupResponse_Code_value = map[string]int32{
	"OK":                0,
	"CLUSTER_NOT_FOUND": 1,
}
View Source 
var Request_Type_name = map[int32]string{
	0: "CREATE",
	1: "DELETE",
	2: "ADD",
	3: "KILL",
}
View Source 
var Request_Type_value = map[string]int32{
	"CREATE": 0,
	"DELETE": 1,
	"ADD":    2,
	"KILL":   3,
}
View Source 
var Update_Type_name = map[int32]string{
	0: "CLUSTER",
	1: "KV",
	2: "TICK",
	3: "NODEHOST_INFO",
	4: "REQUESTS",
}
View Source 
var Update_Type_value = map[string]int32{
	"CLUSTER":       0,
	"KV":            1,
	"TICK":          2,
	"NODEHOST_INFO": 3,
	"REQUESTS":      4,
}

Functions ¶

func RegisterDrummerServer ¶ 

func RegisterDrummerServer(s *grpc.Server, srv DrummerServer)

Types ¶

type Change ¶ 

type Change struct {
	Type      Change_Type `protobuf:"varint,1,req,name=type,enum=drummerpb.Change_Type" json:"type"`
	ClusterId uint64      `protobuf:"varint,2,req,name=cluster_id,json=clusterId" json:"cluster_id"`
	Members   []uint64    `protobuf:"varint,3,rep,name=members" json:"members,omitempty"`
	AppName   string      `protobuf:"bytes,4,opt,name=app_name,json=appName" json:"app_name"`
}

Change is the message used to define new raft clusters in Drummer.

func (*Change) Descriptor ¶ 

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

func (*Change) GetAppName ¶ 

func (m *Change) GetAppName() string

func (*Change) GetClusterId ¶ 

func (m *Change) GetClusterId() uint64

func (*Change) GetMembers ¶ 

func (m *Change) GetMembers() []uint64

func (*Change) GetType ¶ 

func (m *Change) GetType() Change_Type

func (*Change) Marshal ¶ 

func (m *Change) Marshal() (dAtA []byte, err error)

func (*Change) MarshalTo ¶ 

func (m *Change) MarshalTo(dAtA []byte) (int, error)

func (*Change) ProtoMessage ¶ 

func (*Change) ProtoMessage()

func (*Change) Reset ¶ 

func (m *Change) Reset()

func (*Change) Size ¶ 

func (m *Change) Size() (n int)

func (*Change) String ¶ 

func (m *Change) String() string

func (*Change) Unmarshal ¶ 

func (m *Change) Unmarshal(dAtA []byte) error

type ChangeResponse ¶ 

type ChangeResponse struct {
	Code ChangeResponse_Code `protobuf:"varint,1,req,name=code,enum=drummerpb.ChangeResponse_Code" json:"code"`
}

ChangeResponse is the message issued by Drummer in response to Change messages.

func (*ChangeResponse) Descriptor ¶ 

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

func (*ChangeResponse) GetCode ¶ 

func (m *ChangeResponse) GetCode() ChangeResponse_Code

func (*ChangeResponse) Marshal ¶ 

func (m *ChangeResponse) Marshal() (dAtA []byte, err error)

func (*ChangeResponse) MarshalTo ¶ 

func (m *ChangeResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChangeResponse) ProtoMessage ¶ 

func (*ChangeResponse) ProtoMessage()

func (*ChangeResponse) Reset ¶ 

func (m *ChangeResponse) Reset()

func (*ChangeResponse) Size ¶ 

func (m *ChangeResponse) Size() (n int)

func (*ChangeResponse) String ¶ 

func (m *ChangeResponse) String() string

func (*ChangeResponse) Unmarshal ¶ 

func (m *ChangeResponse) Unmarshal(dAtA []byte) error

type ChangeResponse_Code ¶ 

type ChangeResponse_Code int32
const (
	ChangeResponse_OK                ChangeResponse_Code = 0
	ChangeResponse_CLUSTER_NOT_FOUND ChangeResponse_Code = 1
	ChangeResponse_CONFLICT_FOUND    ChangeResponse_Code = 2
	ChangeResponse_UNKNOWN_RETRY     ChangeResponse_Code = 3
	ChangeResponse_CLUSTER_EXIST     ChangeResponse_Code = 4
	ChangeResponse_BOOTSTRAPPED      ChangeResponse_Code = 5
	ChangeResponse_REGIONS_SET       ChangeResponse_Code = 6
)

func (ChangeResponse_Code) Enum ¶ 

func (x ChangeResponse_Code) Enum() *ChangeResponse_Code

func (ChangeResponse_Code) EnumDescriptor ¶ 

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

func (ChangeResponse_Code) String ¶ 

func (x ChangeResponse_Code) String() string

func (*ChangeResponse_Code) UnmarshalJSON ¶ 

func (x *ChangeResponse_Code) UnmarshalJSON(data []byte) error

type Change_Type ¶ 

type Change_Type int32
const (
	Change_CREATE Change_Type = 0
)

func (Change_Type) Enum ¶ 

func (x Change_Type) Enum() *Change_Type

func (Change_Type) EnumDescriptor ¶ 

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

func (Change_Type) String ¶ 

func (x Change_Type) String() string

func (*Change_Type) UnmarshalJSON ¶ 

func (x *Change_Type) UnmarshalJSON(data []byte) error

type Cluster ¶ 

type Cluster struct {
	Members   []uint64 `protobuf:"varint,1,rep,name=members" json:"members,omitempty"`
	ClusterId uint64   `protobuf:"varint,2,opt,name=cluster_id,json=clusterId" json:"cluster_id"`
	AppName   string   `protobuf:"bytes,3,opt,name=app_name,json=appName" json:"app_name"`
}

Cluster is the message used to describe a defined raft cluster.

func (*Cluster) Descriptor ¶ 

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

func (*Cluster) GetAppName ¶ 

func (m *Cluster) GetAppName() string

func (*Cluster) GetClusterId ¶ 

func (m *Cluster) GetClusterId() uint64

func (*Cluster) GetMembers ¶ 

func (m *Cluster) GetMembers() []uint64

func (*Cluster) Marshal ¶ 

func (m *Cluster) Marshal() (dAtA []byte, err error)

func (*Cluster) MarshalTo ¶ 

func (m *Cluster) MarshalTo(dAtA []byte) (int, error)

func (*Cluster) ProtoMessage ¶ 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset ¶ 

func (m *Cluster) Reset()

func (*Cluster) Size ¶ 

func (m *Cluster) Size() (n int)

func (*Cluster) String ¶ 

func (m *Cluster) String() string

func (*Cluster) Unmarshal ¶ 

func (m *Cluster) Unmarshal(dAtA []byte) error

type ClusterCollection ¶ 

type ClusterCollection struct {
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters" json:"clusters,omitempty"`
}

ClusterCollection is the message used to describe a list of clusters.

func (*ClusterCollection) Descriptor ¶ 

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

func (*ClusterCollection) GetClusters ¶ 

func (m *ClusterCollection) GetClusters() []*Cluster

func (*ClusterCollection) Marshal ¶ 

func (m *ClusterCollection) Marshal() (dAtA []byte, err error)

func (*ClusterCollection) MarshalTo ¶ 

func (m *ClusterCollection) MarshalTo(dAtA []byte) (int, error)

func (*ClusterCollection) ProtoMessage ¶ 

func (*ClusterCollection) ProtoMessage()

func (*ClusterCollection) Reset ¶ 

func (m *ClusterCollection) Reset()

func (*ClusterCollection) Size ¶ 

func (m *ClusterCollection) Size() (n int)

func (*ClusterCollection) String ¶ 

func (m *ClusterCollection) String() string

func (*ClusterCollection) Unmarshal ¶ 

func (m *ClusterCollection) Unmarshal(dAtA []byte) error

type ClusterInfo ¶ 

type ClusterInfo struct {
	ClusterId         uint64            `protobuf:"varint,1,req,name=cluster_id,json=clusterId" json:"cluster_id"`
	NodeId            uint64            `protobuf:"varint,2,req,name=node_id,json=nodeId" json:"node_id"`
	IsLeader          bool              `protobuf:"varint,3,opt,name=is_leader,json=isLeader" json:"is_leader"`
	Nodes             map[uint64]string `` /* 131-byte string literal not displayed */
	ConfigChangeIndex uint64            `protobuf:"varint,5,opt,name=config_change_index,json=configChangeIndex" json:"config_change_index"`
	Incomplete        bool              `protobuf:"varint,6,opt,name=incomplete" json:"incomplete"`
	Pending           bool              `protobuf:"varint,7,opt,name=pending" json:"pending"`
}

func (*ClusterInfo) Descriptor ¶ 

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

func (*ClusterInfo) GetClusterId ¶ 

func (m *ClusterInfo) GetClusterId() uint64

func (*ClusterInfo) GetConfigChangeIndex ¶ 

func (m *ClusterInfo) GetConfigChangeIndex() uint64

func (*ClusterInfo) GetIncomplete ¶ 

func (m *ClusterInfo) GetIncomplete() bool

func (*ClusterInfo) GetIsLeader ¶ 

func (m *ClusterInfo) GetIsLeader() bool

func (*ClusterInfo) GetNodeId ¶ 

func (m *ClusterInfo) GetNodeId() uint64

func (*ClusterInfo) GetNodes ¶ 

func (m *ClusterInfo) GetNodes() map[uint64]string

func (*ClusterInfo) GetPending ¶ 

func (m *ClusterInfo) GetPending() bool

func (*ClusterInfo) Marshal ¶ 

func (m *ClusterInfo) Marshal() (dAtA []byte, err error)

func (*ClusterInfo) MarshalTo ¶ 

func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)

func (*ClusterInfo) ProtoMessage ¶ 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) Reset ¶ 

func (m *ClusterInfo) Reset()

func (*ClusterInfo) Size ¶ 

func (m *ClusterInfo) Size() (n int)

func (*ClusterInfo) String ¶ 

func (m *ClusterInfo) String() string

func (*ClusterInfo) Unmarshal ¶ 

func (m *ClusterInfo) Unmarshal(dAtA []byte) error

type ClusterState ¶ 

type ClusterState struct {
	ClusterId         uint64             `protobuf:"varint,1,req,name=cluster_id,json=clusterId" json:"cluster_id"`
	LeaderNodeId      uint64             `protobuf:"varint,2,opt,name=leader_node_id,json=leaderNodeId" json:"leader_node_id"`
	Nodes             map[uint64]string  `` /* 131-byte string literal not displayed */
	RPCAddresses      map[uint64]string  `` /* 145-byte string literal not displayed */
	State             ClusterState_State `protobuf:"varint,5,opt,name=state,enum=drummerpb.ClusterState_State" json:"state"`
	ConfigChangeIndex uint64             `protobuf:"varint,6,opt,name=config_change_index,json=configChangeIndex" json:"config_change_index"`
}

ClusterState is the message used to provide cluster state to clients.

func (*ClusterState) Descriptor ¶ 

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

func (*ClusterState) GetClusterId ¶ 

func (m *ClusterState) GetClusterId() uint64

func (*ClusterState) GetConfigChangeIndex ¶ 

func (m *ClusterState) GetConfigChangeIndex() uint64

func (*ClusterState) GetLeaderNodeId ¶ 

func (m *ClusterState) GetLeaderNodeId() uint64

func (*ClusterState) GetNodes ¶ 

func (m *ClusterState) GetNodes() map[uint64]string

func (*ClusterState) GetRPCAddresses ¶ 

func (m *ClusterState) GetRPCAddresses() map[uint64]string

func (*ClusterState) GetState ¶ 

func (m *ClusterState) GetState() ClusterState_State

func (*ClusterState) Marshal ¶ 

func (m *ClusterState) Marshal() (dAtA []byte, err error)

func (*ClusterState) MarshalTo ¶ 

func (m *ClusterState) MarshalTo(dAtA []byte) (int, error)

func (*ClusterState) ProtoMessage ¶ 

func (*ClusterState) ProtoMessage()

func (*ClusterState) Reset ¶ 

func (m *ClusterState) Reset()

func (*ClusterState) Size ¶ 

func (m *ClusterState) Size() (n int)

func (*ClusterState) String ¶ 

func (m *ClusterState) String() string

func (*ClusterState) Unmarshal ¶ 

func (m *ClusterState) Unmarshal(dAtA []byte) error

type ClusterStateRequest ¶ 

type ClusterStateRequest struct {
	ClusterIdList []uint64 `protobuf:"varint,1,rep,name=cluster_id_list,json=clusterIdList" json:"cluster_id_list,omitempty"`
}

ClusterStateRequest is the message used to send a list of cluster id values to Drummer for requesting cluster state details.

func (*ClusterStateRequest) Descriptor ¶ 

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

func (*ClusterStateRequest) GetClusterIdList ¶ 

func (m *ClusterStateRequest) GetClusterIdList() []uint64

func (*ClusterStateRequest) Marshal ¶ 

func (m *ClusterStateRequest) Marshal() (dAtA []byte, err error)

func (*ClusterStateRequest) MarshalTo ¶ 

func (m *ClusterStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClusterStateRequest) ProtoMessage ¶ 

func (*ClusterStateRequest) ProtoMessage()

func (*ClusterStateRequest) Reset ¶ 

func (m *ClusterStateRequest) Reset()

func (*ClusterStateRequest) Size ¶ 

func (m *ClusterStateRequest) Size() (n int)

func (*ClusterStateRequest) String ¶ 

func (m *ClusterStateRequest) String() string

func (*ClusterStateRequest) Unmarshal ¶ 

func (m *ClusterStateRequest) Unmarshal(dAtA []byte) error

type ClusterState_State ¶ 

type ClusterState_State int32
const (
	ClusterState_OK          ClusterState_State = 0
	ClusterState_UNAVAILABLE ClusterState_State = 1
)

func (ClusterState_State) Enum ¶ 

func (x ClusterState_State) Enum() *ClusterState_State

func (ClusterState_State) EnumDescriptor ¶ 

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

func (ClusterState_State) String ¶ 

func (x ClusterState_State) String() string

func (*ClusterState_State) UnmarshalJSON ¶ 

func (x *ClusterState_State) UnmarshalJSON(data []byte) error

type ClusterStates ¶ 

type ClusterStates struct {
	Collection []*ClusterState `protobuf:"bytes,1,rep,name=collection" json:"collection,omitempty"`
}

ClusterStates contains a list of ClusterState messages.

func (*ClusterStates) Descriptor ¶ 

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

func (*ClusterStates) GetCollection ¶ 

func (m *ClusterStates) GetCollection() []*ClusterState

func (*ClusterStates) Marshal ¶ 

func (m *ClusterStates) Marshal() (dAtA []byte, err error)

func (*ClusterStates) MarshalTo ¶ 

func (m *ClusterStates) MarshalTo(dAtA []byte) (int, error)

func (*ClusterStates) ProtoMessage ¶ 

func (*ClusterStates) ProtoMessage()

func (*ClusterStates) Reset ¶ 

func (m *ClusterStates) Reset()

func (*ClusterStates) Size ¶ 

func (m *ClusterStates) Size() (n int)

func (*ClusterStates) String ¶ 

func (m *ClusterStates) String() string

func (*ClusterStates) Unmarshal ¶ 

func (m *ClusterStates) Unmarshal(dAtA []byte) error

type Config ¶ 

type Config struct {
	ElectionRTT              uint64 `protobuf:"varint,1,opt,name=ElectionRTT" json:"ElectionRTT"`
	HeartbeatRTT             uint64 `protobuf:"varint,2,opt,name=HeartbeatRTT" json:"HeartbeatRTT"`
	CheckQuorum              bool   `protobuf:"varint,5,opt,name=CheckQuorum" json:"CheckQuorum"`
	CompactionOverhead       uint64 `protobuf:"varint,6,opt,name=CompactionOverhead" json:"CompactionOverhead"`
	SnapshotEntries          uint64 `protobuf:"varint,7,opt,name=SnapshotEntries" json:"SnapshotEntries"`
	RaftClusterAddresses     string `protobuf:"bytes,8,opt,name=RaftClusterAddresses" json:"RaftClusterAddresses"`
	DrummerAddress           string `protobuf:"bytes,9,opt,name=DrummerAddress" json:"DrummerAddress"`
	DrummerNodeID            uint64 `protobuf:"varint,10,opt,name=DrummerNodeID" json:"DrummerNodeID"`
	DrummerNodeHostDirectory string `protobuf:"bytes,11,opt,name=DrummerNodeHostDirectory" json:"DrummerNodeHostDirectory"`
	DrummerWALDirectory      string `protobuf:"bytes,12,opt,name=DrummerWALDirectory" json:"DrummerWALDirectory"`
	MutualTLS                bool   `protobuf:"varint,13,opt,name=MutualTLS" json:"MutualTLS"`
	CAFile                   string `protobuf:"bytes,14,opt,name=CAFile" json:"CAFile"`
	CertFile                 string `protobuf:"bytes,15,opt,name=CertFile" json:"CertFile"`
	KeyFile                  string `protobuf:"bytes,16,opt,name=KeyFile" json:"KeyFile"`
}

Config is the message used to describe configurations for raft clusters.

func (*Config) Descriptor ¶ 

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

func (*Config) GetCAFile ¶ 

func (m *Config) GetCAFile() string

func (*Config) GetCertFile ¶ 

func (m *Config) GetCertFile() string

func (*Config) GetCheckQuorum ¶ 

func (m *Config) GetCheckQuorum() bool

func (*Config) GetCompactionOverhead ¶ 

func (m *Config) GetCompactionOverhead() uint64

func (*Config) GetDrummerAddress ¶ 

func (m *Config) GetDrummerAddress() string

func (*Config) GetDrummerNodeHostDirectory ¶ 

func (m *Config) GetDrummerNodeHostDirectory() string

func (*Config) GetDrummerNodeID ¶ 

func (m *Config) GetDrummerNodeID() uint64

func (*Config) GetDrummerWALDirectory ¶ 

func (m *Config) GetDrummerWALDirectory() string

func (*Config) GetElectionRTT ¶ 

func (m *Config) GetElectionRTT() uint64

func (*Config) GetHeartbeatRTT ¶ 

func (m *Config) GetHeartbeatRTT() uint64

func (*Config) GetKeyFile ¶ 

func (m *Config) GetKeyFile() string

func (*Config) GetMutualTLS ¶ 

func (m *Config) GetMutualTLS() bool

func (*Config) GetRaftClusterAddresses ¶ 

func (m *Config) GetRaftClusterAddresses() string

func (*Config) GetSnapshotEntries ¶ 

func (m *Config) GetSnapshotEntries() uint64

func (*Config) Marshal ¶ 

func (m *Config) Marshal() (dAtA []byte, err error)

func (*Config) MarshalTo ¶ 

func (m *Config) MarshalTo(dAtA []byte) (int, error)

func (*Config) ProtoMessage ¶ 

func (*Config) ProtoMessage()

func (*Config) Reset ¶ 

func (m *Config) Reset()

func (*Config) Size ¶ 

func (m *Config) Size() (n int)

func (*Config) String ¶ 

func (m *Config) String() string

func (*Config) Unmarshal ¶ 

func (m *Config) Unmarshal(dAtA []byte) error

type ConfigChangeIndexList ¶ 

type ConfigChangeIndexList struct {
	Indexes map[uint64]uint64 `` /* 136-byte string literal not displayed */
}

ConfigChangeIndexList is the message used to report ConfChangeIndex values of clusters.

func (*ConfigChangeIndexList) Descriptor ¶ 

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

func (*ConfigChangeIndexList) GetIndexes ¶ 

func (m *ConfigChangeIndexList) GetIndexes() map[uint64]uint64

func (*ConfigChangeIndexList) Marshal ¶ 

func (m *ConfigChangeIndexList) Marshal() (dAtA []byte, err error)

func (*ConfigChangeIndexList) MarshalTo ¶ 

func (m *ConfigChangeIndexList) MarshalTo(dAtA []byte) (int, error)

func (*ConfigChangeIndexList) ProtoMessage ¶ 

func (*ConfigChangeIndexList) ProtoMessage()

func (*ConfigChangeIndexList) Reset ¶ 

func (m *ConfigChangeIndexList) Reset()

func (*ConfigChangeIndexList) Size ¶ 

func (m *ConfigChangeIndexList) Size() (n int)

func (*ConfigChangeIndexList) String ¶ 

func (m *ConfigChangeIndexList) String() string

func (*ConfigChangeIndexList) Unmarshal ¶ 

func (m *ConfigChangeIndexList) Unmarshal(dAtA []byte) error

type DeploymentInfo ¶ 

type DeploymentInfo struct {
	DeploymentId uint64 `protobuf:"varint,1,req,name=deployment_id,json=deploymentId" json:"deployment_id"`
}

DeploymentInfo is a message that contains the deployment id generated by Drummer.

func (*DeploymentInfo) Descriptor ¶ 

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

func (*DeploymentInfo) GetDeploymentId ¶ 

func (m *DeploymentInfo) GetDeploymentId() uint64

func (*DeploymentInfo) Marshal ¶ 

func (m *DeploymentInfo) Marshal() (dAtA []byte, err error)

func (*DeploymentInfo) MarshalTo ¶ 

func (m *DeploymentInfo) MarshalTo(dAtA []byte) (int, error)

func (*DeploymentInfo) ProtoMessage ¶ 

func (*DeploymentInfo) ProtoMessage()

func (*DeploymentInfo) Reset ¶ 

func (m *DeploymentInfo) Reset()

func (*DeploymentInfo) Size ¶ 

func (m *DeploymentInfo) Size() (n int)

func (*DeploymentInfo) String ¶ 

func (m *DeploymentInfo) String() string

func (*DeploymentInfo) Unmarshal ¶ 

func (m *DeploymentInfo) Unmarshal(dAtA []byte) error

type DrummerClient ¶ 

type DrummerClient interface {
	// AddDrummerServer adds a new server to the Drummer cluster.
	AddDrummerServer(ctx context.Context, in *DrummerConfigRequest, opts ...grpc.CallOption) (*Empty, error)
	// RemoveDrummerServer removes an existing server from the Drummer cluster.
	RemoveDrummerServer(ctx context.Context, in *DrummerConfigRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetDeploymentInfo returns the DeploymentID value from Drummer.
	GetDeploymentInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DeploymentInfo, error)
	// GetClusterConfigChangeIndexList returns the ConfChangeIndex values of all
	// known clusters.
	GetClusterConfigChangeIndexList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ConfigChangeIndexList, error)
	// ReportAvailableNodeHost is used by nodehost to report its state details to
	// Drummer.
	ReportAvailableNodeHost(ctx context.Context, in *NodeHostInfo, opts ...grpc.CallOption) (*NodeHostRequestCollection, error)
	// GetNodeHostCollection returns a list of all known nodehosts from Drummer.
	GetNodeHostCollection(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NodeHostCollection, error)
	// GetClusters returns a list of all known clusters from Drummer.
	GetClusters(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ClusterCollection, error)
	// SubmitChange is used by Drummer clients to submit DrummerDB updates.
	SubmitChange(ctx context.Context, in *Change, opts ...grpc.CallOption) (*ChangeResponse, error)
	// SetBootstrapped sets the Drummer as bootstrapped. No more clusters can be defined
	// once Drummer is set as bootstrapped. Bootstrapped Drummer will start to schedule
	// raft nodes.
	SetBootstrapped(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChangeResponse, error)
	// SetRegions sets region info for defined clusters.
	SetRegions(ctx context.Context, in *Regions, opts ...grpc.CallOption) (*ChangeResponse, error)
	// GetClusterStates returns ClusterStates for selected raft clusters.
	GetClusterStates(ctx context.Context, in *ClusterStateRequest, opts ...grpc.CallOption) (*ClusterStates, error)
}

func NewDrummerClient ¶ 

func NewDrummerClient(cc *grpc.ClientConn) DrummerClient

type DrummerConfigRequest ¶ 

type DrummerConfigRequest struct {
	NodeId  uint64 `protobuf:"varint,1,req,name=node_id,json=nodeId" json:"node_id"`
	Address string `protobuf:"bytes,2,opt,name=address" json:"address"`
}

func (*DrummerConfigRequest) Descriptor ¶ 

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

func (*DrummerConfigRequest) GetAddress ¶ 

func (m *DrummerConfigRequest) GetAddress() string

func (*DrummerConfigRequest) GetNodeId ¶ 

func (m *DrummerConfigRequest) GetNodeId() uint64

func (*DrummerConfigRequest) Marshal ¶ 

func (m *DrummerConfigRequest) Marshal() (dAtA []byte, err error)

func (*DrummerConfigRequest) MarshalTo ¶ 

func (m *DrummerConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*DrummerConfigRequest) ProtoMessage ¶ 

func (*DrummerConfigRequest) ProtoMessage()

func (*DrummerConfigRequest) Reset ¶ 

func (m *DrummerConfigRequest) Reset()

func (*DrummerConfigRequest) Size ¶ 

func (m *DrummerConfigRequest) Size() (n int)

func (*DrummerConfigRequest) String ¶ 

func (m *DrummerConfigRequest) String() string

func (*DrummerConfigRequest) Unmarshal ¶ 

func (m *DrummerConfigRequest) Unmarshal(dAtA []byte) error

type DrummerServer ¶ 

type DrummerServer interface {
	// AddDrummerServer adds a new server to the Drummer cluster.
	AddDrummerServer(context.Context, *DrummerConfigRequest) (*Empty, error)
	// RemoveDrummerServer removes an existing server from the Drummer cluster.
	RemoveDrummerServer(context.Context, *DrummerConfigRequest) (*Empty, error)
	// GetDeploymentInfo returns the DeploymentID value from Drummer.
	GetDeploymentInfo(context.Context, *Empty) (*DeploymentInfo, error)
	// GetClusterConfigChangeIndexList returns the ConfChangeIndex values of all
	// known clusters.
	GetClusterConfigChangeIndexList(context.Context, *Empty) (*ConfigChangeIndexList, error)
	// ReportAvailableNodeHost is used by nodehost to report its state details to
	// Drummer.
	ReportAvailableNodeHost(context.Context, *NodeHostInfo) (*NodeHostRequestCollection, error)
	// GetNodeHostCollection returns a list of all known nodehosts from Drummer.
	GetNodeHostCollection(context.Context, *Empty) (*NodeHostCollection, error)
	// GetClusters returns a list of all known clusters from Drummer.
	GetClusters(context.Context, *Empty) (*ClusterCollection, error)
	// SubmitChange is used by Drummer clients to submit DrummerDB updates.
	SubmitChange(context.Context, *Change) (*ChangeResponse, error)
	// SetBootstrapped sets the Drummer as bootstrapped. No more clusters can be defined
	// once Drummer is set as bootstrapped. Bootstrapped Drummer will start to schedule
	// raft nodes.
	SetBootstrapped(context.Context, *Empty) (*ChangeResponse, error)
	// SetRegions sets region info for defined clusters.
	SetRegions(context.Context, *Regions) (*ChangeResponse, error)
	// GetClusterStates returns ClusterStates for selected raft clusters.
	GetClusterStates(context.Context, *ClusterStateRequest) (*ClusterStates, error)
}

type Empty ¶ 

type Empty struct {
}

Empty is a dummy message.

func (*Empty) Descriptor ¶ 

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

func (*Empty) Marshal ¶ 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo ¶ 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) ProtoMessage ¶ 

func (*Empty) ProtoMessage()

func (*Empty) Reset ¶ 

func (m *Empty) Reset()

func (*Empty) Size ¶ 

func (m *Empty) Size() (n int)

func (*Empty) String ¶ 

func (m *Empty) String() string

func (*Empty) Unmarshal ¶ 

func (m *Empty) Unmarshal(dAtA []byte) error

type KV ¶ 

type KV struct {
	Key           string `protobuf:"bytes,1,req,name=key" json:"key"`
	Value         string `protobuf:"bytes,2,req,name=value" json:"value"`
	InstanceId    uint64 `protobuf:"varint,3,opt,name=instance_id,json=instanceId" json:"instance_id"`
	Tick          uint64 `protobuf:"varint,4,opt,name=tick" json:"tick"`
	OldInstanceId uint64 `protobuf:"varint,5,opt,name=old_instance_id,json=oldInstanceId" json:"old_instance_id"`
	Finalized     bool   `protobuf:"varint,6,opt,name=finalized" json:"finalized"`
}

KV is the message used to describe a Key-Value request.

func (*KV) Descriptor ¶ 

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

func (*KV) GetFinalized ¶ 

func (m *KV) GetFinalized() bool

func (*KV) GetInstanceId ¶ 

func (m *KV) GetInstanceId() uint64

func (*KV) GetKey ¶ 

func (m *KV) GetKey() string

func (*KV) GetOldInstanceId ¶ 

func (m *KV) GetOldInstanceId() uint64

func (*KV) GetTick ¶ 

func (m *KV) GetTick() uint64

func (*KV) GetValue ¶ 

func (m *KV) GetValue() string

func (*KV) Marshal ¶ 

func (m *KV) Marshal() (dAtA []byte, err error)

func (*KV) MarshalTo ¶ 

func (m *KV) MarshalTo(dAtA []byte) (int, error)

func (*KV) ProtoMessage ¶ 

func (*KV) ProtoMessage()

func (*KV) Reset ¶ 

func (m *KV) Reset()

func (*KV) Size ¶ 

func (m *KV) Size() (n int)

func (*KV) String ¶ 

func (m *KV) String() string

func (*KV) Unmarshal ¶ 

func (m *KV) Unmarshal(dAtA []byte) error

type LogInfo ¶ 

type LogInfo struct {
	ClusterId uint64 `protobuf:"varint,1,req,name=cluster_id,json=clusterId" json:"cluster_id"`
	NodeId    uint64 `protobuf:"varint,2,req,name=node_id,json=nodeId" json:"node_id"`
}

LogInfo is the message used by nodehost to notify Drummer that it has raft log that belongs to the specified raft cluster.

func (*LogInfo) Descriptor ¶ 

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

func (*LogInfo) GetClusterId ¶ 

func (m *LogInfo) GetClusterId() uint64

func (*LogInfo) GetNodeId ¶ 

func (m *LogInfo) GetNodeId() uint64

func (*LogInfo) Marshal ¶ 

func (m *LogInfo) Marshal() (dAtA []byte, err error)

func (*LogInfo) MarshalTo ¶ 

func (m *LogInfo) MarshalTo(dAtA []byte) (int, error)

func (*LogInfo) ProtoMessage ¶ 

func (*LogInfo) ProtoMessage()

func (*LogInfo) Reset ¶ 

func (m *LogInfo) Reset()

func (*LogInfo) Size ¶ 

func (m *LogInfo) Size() (n int)

func (*LogInfo) String ¶ 

func (m *LogInfo) String() string

func (*LogInfo) Unmarshal ¶ 

func (m *LogInfo) Unmarshal(dAtA []byte) error

type LookupRequest ¶ 

type LookupRequest struct {
	Type          LookupRequest_Type  `protobuf:"varint,1,req,name=type,enum=drummerpb.LookupRequest_Type" json:"type"`
	ClusterIdList []uint64            `protobuf:"varint,2,rep,name=cluster_id_list,json=clusterIdList" json:"cluster_id_list,omitempty"`
	KvLookup      KV                  `protobuf:"bytes,3,opt,name=kv_lookup,json=kvLookup" json:"kv_lookup"`
	RequestsId    uint64              `protobuf:"varint,4,opt,name=requests_id,json=requestsId" json:"requests_id"`
	Address       string              `protobuf:"bytes,5,opt,name=address" json:"address"`
	Stats         ClusterStateRequest `protobuf:"bytes,6,opt,name=stats" json:"stats"`
}

LookupRequest is the lookup request message.

func (*LookupRequest) Descriptor ¶ 

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

func (*LookupRequest) GetAddress ¶ 

func (m *LookupRequest) GetAddress() string

func (*LookupRequest) GetClusterIdList ¶ 

func (m *LookupRequest) GetClusterIdList() []uint64

func (*LookupRequest) GetKvLookup ¶ 

func (m *LookupRequest) GetKvLookup() KV

func (*LookupRequest) GetRequestsId ¶ 

func (m *LookupRequest) GetRequestsId() uint64

func (*LookupRequest) GetStats ¶ 

func (m *LookupRequest) GetStats() ClusterStateRequest

func (*LookupRequest) GetType ¶ 

func (m *LookupRequest) GetType() LookupRequest_Type

func (*LookupRequest) Marshal ¶ 

func (m *LookupRequest) Marshal() (dAtA []byte, err error)

func (*LookupRequest) MarshalTo ¶ 

func (m *LookupRequest) MarshalTo(dAtA []byte) (int, error)

func (*LookupRequest) ProtoMessage ¶ 

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) Reset ¶ 

func (m *LookupRequest) Reset()

func (*LookupRequest) Size ¶ 

func (m *LookupRequest) Size() (n int)

func (*LookupRequest) String ¶ 

func (m *LookupRequest) String() string

func (*LookupRequest) Unmarshal ¶ 

func (m *LookupRequest) Unmarshal(dAtA []byte) error

type LookupRequest_Type ¶ 

type LookupRequest_Type int32
const (
	LookupRequest_CLUSTER           LookupRequest_Type = 0
	LookupRequest_KV                LookupRequest_Type = 1
	LookupRequest_SCHEDULER_CONTEXT LookupRequest_Type = 3
	LookupRequest_REQUESTS          LookupRequest_Type = 4
	LookupRequest_CLUSTER_STATES    LookupRequest_Type = 5
)

func (LookupRequest_Type) Enum ¶ 

func (x LookupRequest_Type) Enum() *LookupRequest_Type

func (LookupRequest_Type) EnumDescriptor ¶ 

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

func (LookupRequest_Type) String ¶ 

func (x LookupRequest_Type) String() string

func (*LookupRequest_Type) UnmarshalJSON ¶ 

func (x *LookupRequest_Type) UnmarshalJSON(data []byte) error

type LookupResponse ¶ 

type LookupResponse struct {
	Code     LookupResponse_Code       `protobuf:"varint,1,opt,name=code,enum=drummerpb.LookupResponse_Code" json:"code"`
	Clusters []*Cluster                `protobuf:"bytes,2,rep,name=clusters" json:"clusters,omitempty"`
	KvResult KV                        `protobuf:"bytes,3,opt,name=kv_result,json=kvResult" json:"kv_result"`
	Requests NodeHostRequestCollection `protobuf:"bytes,4,opt,name=requests" json:"requests"`
}

LookupResponse is the lookup response message.

func (*LookupResponse) Descriptor ¶ 

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

func (*LookupResponse) GetClusters ¶ 

func (m *LookupResponse) GetClusters() []*Cluster

func (*LookupResponse) GetCode ¶ 

func (m *LookupResponse) GetCode() LookupResponse_Code

func (*LookupResponse) GetKvResult ¶ 

func (m *LookupResponse) GetKvResult() KV

func (*LookupResponse) GetRequests ¶ 

func (m *LookupResponse) GetRequests() NodeHostRequestCollection

func (*LookupResponse) Marshal ¶ 

func (m *LookupResponse) Marshal() (dAtA []byte, err error)

func (*LookupResponse) MarshalTo ¶ 

func (m *LookupResponse) MarshalTo(dAtA []byte) (int, error)

func (*LookupResponse) ProtoMessage ¶ 

func (*LookupResponse) ProtoMessage()

func (*LookupResponse) Reset ¶ 

func (m *LookupResponse) Reset()

func (*LookupResponse) Size ¶ 

func (m *LookupResponse) Size() (n int)

func (*LookupResponse) String ¶ 

func (m *LookupResponse) String() string

func (*LookupResponse) Unmarshal ¶ 

func (m *LookupResponse) Unmarshal(dAtA []byte) error

type LookupResponse_Code ¶ 

type LookupResponse_Code int32
const (
	LookupResponse_OK                LookupResponse_Code = 0
	LookupResponse_CLUSTER_NOT_FOUND LookupResponse_Code = 1
)

func (LookupResponse_Code) Enum ¶ 

func (x LookupResponse_Code) Enum() *LookupResponse_Code

func (LookupResponse_Code) EnumDescriptor ¶ 

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

func (LookupResponse_Code) String ¶ 

func (x LookupResponse_Code) String() string

func (*LookupResponse_Code) UnmarshalJSON ¶ 

func (x *LookupResponse_Code) UnmarshalJSON(data []byte) error

type NodeHostCollection ¶ 

type NodeHostCollection struct {
	Collection []NodeHostInfo `protobuf:"bytes,1,rep,name=collection" json:"collection"`
	Tick       uint64         `protobuf:"varint,2,opt,name=tick" json:"tick"`
}

NodeHostCollection contains a list of NodeHostInfo messages.

func (*NodeHostCollection) Descriptor ¶ 

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

func (*NodeHostCollection) GetCollection ¶ 

func (m *NodeHostCollection) GetCollection() []NodeHostInfo

func (*NodeHostCollection) GetTick ¶ 

func (m *NodeHostCollection) GetTick() uint64

func (*NodeHostCollection) Marshal ¶ 

func (m *NodeHostCollection) Marshal() (dAtA []byte, err error)

func (*NodeHostCollection) MarshalTo ¶ 

func (m *NodeHostCollection) MarshalTo(dAtA []byte) (int, error)

func (*NodeHostCollection) ProtoMessage ¶ 

func (*NodeHostCollection) ProtoMessage()

func (*NodeHostCollection) Reset ¶ 

func (m *NodeHostCollection) Reset()

func (*NodeHostCollection) Size ¶ 

func (m *NodeHostCollection) Size() (n int)

func (*NodeHostCollection) String ¶ 

func (m *NodeHostCollection) String() string

func (*NodeHostCollection) Unmarshal ¶ 

func (m *NodeHostCollection) Unmarshal(dAtA []byte) error

type NodeHostInfo ¶ 

type NodeHostInfo struct {
	RaftAddress      string        `protobuf:"bytes,1,req,name=raft_address,json=raftAddress" json:"raft_address"`
	ClusterInfo      []ClusterInfo `protobuf:"bytes,2,rep,name=cluster_info,json=clusterInfo" json:"cluster_info"`
	ClusterIdList    []uint64      `protobuf:"varint,3,rep,name=cluster_id_list,json=clusterIdList" json:"cluster_id_list,omitempty"`
	LastTick         uint64        `protobuf:"varint,4,opt,name=last_tick,json=lastTick" json:"last_tick"`
	PlogInfoIncluded bool          `protobuf:"varint,5,opt,name=plog_info_included,json=plogInfoIncluded" json:"plog_info_included"`
	PlogInfo         []LogInfo     `protobuf:"bytes,6,rep,name=plog_info,json=plogInfo" json:"plog_info"`
	Region           string        `protobuf:"bytes,7,opt,name=region" json:"region"`
	RPCAddress       string        `protobuf:"bytes,8,opt,name=RPCAddress" json:"RPCAddress"`
}

NodeHostInfo is the message used by nodehost to report its state, including managed raft clusters and local persistent logs to Drummer.

func (*NodeHostInfo) Descriptor ¶ 

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

func (*NodeHostInfo) GetClusterIdList ¶ 

func (m *NodeHostInfo) GetClusterIdList() []uint64

func (*NodeHostInfo) GetClusterInfo ¶ 

func (m *NodeHostInfo) GetClusterInfo() []ClusterInfo

func (*NodeHostInfo) GetLastTick ¶ 

func (m *NodeHostInfo) GetLastTick() uint64

func (*NodeHostInfo) GetPlogInfo ¶ 

func (m *NodeHostInfo) GetPlogInfo() []LogInfo

func (*NodeHostInfo) GetPlogInfoIncluded ¶ 

func (m *NodeHostInfo) GetPlogInfoIncluded() bool

func (*NodeHostInfo) GetRPCAddress ¶ 

func (m *NodeHostInfo) GetRPCAddress() string

func (*NodeHostInfo) GetRaftAddress ¶ 

func (m *NodeHostInfo) GetRaftAddress() string

func (*NodeHostInfo) GetRegion ¶ 

func (m *NodeHostInfo) GetRegion() string

func (*NodeHostInfo) Marshal ¶ 

func (m *NodeHostInfo) Marshal() (dAtA []byte, err error)

func (*NodeHostInfo) MarshalTo ¶ 

func (m *NodeHostInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeHostInfo) ProtoMessage ¶ 

func (*NodeHostInfo) ProtoMessage()

func (*NodeHostInfo) Reset ¶ 

func (m *NodeHostInfo) Reset()

func (*NodeHostInfo) Size ¶ 

func (m *NodeHostInfo) Size() (n int)

func (*NodeHostInfo) String ¶ 

func (m *NodeHostInfo) String() string

func (*NodeHostInfo) Unmarshal ¶ 

func (m *NodeHostInfo) Unmarshal(dAtA []byte) error

type NodeHostRequest ¶ 

type NodeHostRequest struct {
	Change            Request  `protobuf:"bytes,1,opt,name=change" json:"change"`
	NodeIdList        []uint64 `protobuf:"varint,2,rep,name=node_id_list,json=nodeIdList" json:"node_id_list,omitempty"`
	AddressList       []string `protobuf:"bytes,3,rep,name=address_list,json=addressList" json:"address_list,omitempty"`
	InstantiateNodeId uint64   `protobuf:"varint,4,opt,name=instantiate_node_id,json=instantiateNodeId" json:"instantiate_node_id"`
	RaftAddress       string   `protobuf:"bytes,5,opt,name=raft_address,json=raftAddress" json:"raft_address"`
	Join              bool     `protobuf:"varint,6,opt,name=join" json:"join"`
	Restore           bool     `protobuf:"varint,7,opt,name=restore" json:"restore"`
	AppName           string   `protobuf:"bytes,8,opt,name=app_name,json=appName" json:"app_name"`
	Config            Config   `protobuf:"bytes,9,opt,name=config" json:"config"`
}

NodeHostRequest is the request message sent to NodeHost by Drummer.

func (*NodeHostRequest) Descriptor ¶ 

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

func (*NodeHostRequest) GetAddressList ¶ 

func (m *NodeHostRequest) GetAddressList() []string

func (*NodeHostRequest) GetAppName ¶ 

func (m *NodeHostRequest) GetAppName() string

func (*NodeHostRequest) GetChange ¶ 

func (m *NodeHostRequest) GetChange() Request

func (*NodeHostRequest) GetConfig ¶ 

func (m *NodeHostRequest) GetConfig() Config

func (*NodeHostRequest) GetInstantiateNodeId ¶ 

func (m *NodeHostRequest) GetInstantiateNodeId() uint64

func (*NodeHostRequest) GetJoin ¶ 

func (m *NodeHostRequest) GetJoin() bool

func (*NodeHostRequest) GetNodeIdList ¶ 

func (m *NodeHostRequest) GetNodeIdList() []uint64

func (*NodeHostRequest) GetRaftAddress ¶ 

func (m *NodeHostRequest) GetRaftAddress() string

func (*NodeHostRequest) GetRestore ¶ 

func (m *NodeHostRequest) GetRestore() bool

func (*NodeHostRequest) Marshal ¶ 

func (m *NodeHostRequest) Marshal() (dAtA []byte, err error)

func (*NodeHostRequest) MarshalTo ¶ 

func (m *NodeHostRequest) MarshalTo(dAtA []byte) (int, error)

func (*NodeHostRequest) ProtoMessage ¶ 

func (*NodeHostRequest) ProtoMessage()

func (*NodeHostRequest) Reset ¶ 

func (m *NodeHostRequest) Reset()

func (*NodeHostRequest) Size ¶ 

func (m *NodeHostRequest) Size() (n int)

func (*NodeHostRequest) String ¶ 

func (m *NodeHostRequest) String() string

func (*NodeHostRequest) Unmarshal ¶ 

func (m *NodeHostRequest) Unmarshal(dAtA []byte) error

type NodeHostRequestCollection ¶ 

type NodeHostRequestCollection struct {
	Requests []NodeHostRequest `protobuf:"bytes,1,rep,name=requests" json:"requests"`
}

NodeHostRequestCollection contains a list of NodeHostRequest messages.

func (*NodeHostRequestCollection) Descriptor ¶ 

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

func (*NodeHostRequestCollection) GetRequests ¶ 

func (m *NodeHostRequestCollection) GetRequests() []NodeHostRequest

func (*NodeHostRequestCollection) Marshal ¶ 

func (m *NodeHostRequestCollection) Marshal() (dAtA []byte, err error)

func (*NodeHostRequestCollection) MarshalTo ¶ 

func (m *NodeHostRequestCollection) MarshalTo(dAtA []byte) (int, error)

func (*NodeHostRequestCollection) ProtoMessage ¶ 

func (*NodeHostRequestCollection) ProtoMessage()

func (*NodeHostRequestCollection) Reset ¶ 

func (m *NodeHostRequestCollection) Reset()

func (*NodeHostRequestCollection) Size ¶ 

func (m *NodeHostRequestCollection) Size() (n int)

func (*NodeHostRequestCollection) String ¶ 

func (m *NodeHostRequestCollection) String() string

func (*NodeHostRequestCollection) Unmarshal ¶ 

func (m *NodeHostRequestCollection) Unmarshal(dAtA []byte) error

type Regions ¶ 

type Regions struct {
	Region []string `protobuf:"bytes,1,rep,name=region" json:"region,omitempty"`
	Count  []uint64 `protobuf:"varint,2,rep,name=count" json:"count,omitempty"`
}

Regions is the message used to describe the requested region.

func (*Regions) Descriptor ¶ 

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

func (*Regions) GetCount ¶ 

func (m *Regions) GetCount() []uint64

func (*Regions) GetRegion ¶ 

func (m *Regions) GetRegion() []string

func (*Regions) Marshal ¶ 

func (m *Regions) Marshal() (dAtA []byte, err error)

func (*Regions) MarshalTo ¶ 

func (m *Regions) MarshalTo(dAtA []byte) (int, error)

func (*Regions) ProtoMessage ¶ 

func (*Regions) ProtoMessage()

func (*Regions) Reset ¶ 

func (m *Regions) Reset()

func (*Regions) Size ¶ 

func (m *Regions) Size() (n int)

func (*Regions) String ¶ 

func (m *Regions) String() string

func (*Regions) Unmarshal ¶ 

func (m *Regions) Unmarshal(dAtA []byte) error

type Request ¶ 

type Request struct {
	Type         Request_Type `protobuf:"varint,1,req,name=type,enum=drummerpb.Request_Type" json:"type"`
	ClusterId    uint64       `protobuf:"varint,2,req,name=cluster_id,json=clusterId" json:"cluster_id"`
	Members      []uint64     `protobuf:"varint,3,rep,name=members" json:"members,omitempty"`
	AppName      string       `protobuf:"bytes,4,opt,name=app_name,json=appName" json:"app_name"`
	ConfChangeId uint64       `protobuf:"varint,5,opt,name=conf_change_id,json=confChangeId" json:"conf_change_id"`
}

Request is the Request sent to Nodehosts.

func (*Request) Descriptor ¶ 

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

func (*Request) GetAppName ¶ 

func (m *Request) GetAppName() string

func (*Request) GetClusterId ¶ 

func (m *Request) GetClusterId() uint64

func (*Request) GetConfChangeId ¶ 

func (m *Request) GetConfChangeId() uint64

func (*Request) GetMembers ¶ 

func (m *Request) GetMembers() []uint64

func (*Request) GetType ¶ 

func (m *Request) GetType() Request_Type

func (*Request) Marshal ¶ 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo ¶ 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) ProtoMessage ¶ 

func (*Request) ProtoMessage()

func (*Request) Reset ¶ 

func (m *Request) Reset()

func (*Request) Size ¶ 

func (m *Request) Size() (n int)

func (*Request) String ¶ 

func (m *Request) String() string

func (*Request) Unmarshal ¶ 

func (m *Request) Unmarshal(dAtA []byte) error

type Request_Type ¶ 

type Request_Type int32
const (
	Request_CREATE Request_Type = 0
	Request_DELETE Request_Type = 1
	Request_ADD    Request_Type = 2
	Request_KILL   Request_Type = 3
)

func (Request_Type) Enum ¶ 

func (x Request_Type) Enum() *Request_Type

func (Request_Type) EnumDescriptor ¶ 

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

func (Request_Type) String ¶ 

func (x Request_Type) String() string

func (*Request_Type) UnmarshalJSON ¶ 

func (x *Request_Type) UnmarshalJSON(data []byte) error

type Update ¶ 

type Update struct {
	Change       Change                    `protobuf:"bytes,1,opt,name=change" json:"change"`
	Type         Update_Type               `protobuf:"varint,2,req,name=type,enum=drummerpb.Update_Type" json:"type"`
	KvUpdate     KV                        `protobuf:"bytes,3,opt,name=kv_update,json=kvUpdate" json:"kv_update"`
	NodehostInfo NodeHostInfo              `protobuf:"bytes,4,opt,name=nodehost_info,json=nodehostInfo" json:"nodehost_info"`
	Requests     NodeHostRequestCollection `protobuf:"bytes,5,opt,name=requests" json:"requests"`
}

Update is the message used for updating DrummerDB. DrummerDB is used to store raft cluster definitions and Drummer key-value pairs.

func (*Update) Descriptor ¶ 

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

func (*Update) GetChange ¶ 

func (m *Update) GetChange() Change

func (*Update) GetKvUpdate ¶ 

func (m *Update) GetKvUpdate() KV

func (*Update) GetNodehostInfo ¶ 

func (m *Update) GetNodehostInfo() NodeHostInfo

func (*Update) GetRequests ¶ 

func (m *Update) GetRequests() NodeHostRequestCollection

func (*Update) GetType ¶ 

func (m *Update) GetType() Update_Type

func (*Update) Marshal ¶ 

func (m *Update) Marshal() (dAtA []byte, err error)

func (*Update) MarshalTo ¶ 

func (m *Update) MarshalTo(dAtA []byte) (int, error)

func (*Update) ProtoMessage ¶ 

func (*Update) ProtoMessage()

func (*Update) Reset ¶ 

func (m *Update) Reset()

func (*Update) Size ¶ 

func (m *Update) Size() (n int)

func (*Update) String ¶ 

func (m *Update) String() string

func (*Update) Unmarshal ¶ 

func (m *Update) Unmarshal(dAtA []byte) error

type Update_Type ¶ 

type Update_Type int32
const (
	Update_CLUSTER       Update_Type = 0
	Update_KV            Update_Type = 1
	Update_TICK          Update_Type = 2
	Update_NODEHOST_INFO Update_Type = 3
	Update_REQUESTS      Update_Type = 4
)

func (Update_Type) Enum ¶ 

func (x Update_Type) Enum() *Update_Type

func (Update_Type) EnumDescriptor ¶ 

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

func (Update_Type) String ¶ 

func (x Update_Type) String() string

func (*Update_Type) UnmarshalJSON ¶ 

func (x *Update_Type) UnmarshalJSON(data []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.