drummerpb

package
v2.1.5+incompatible Latest Latest
Warning

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

 Go to latest Published: Apr 5, 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.