drummerpb

package
v0.0.0-...-bb37015 Latest Latest
Warning

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

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

Documentation

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

func (*Change) XXX_DiscardUnknown 

func (m *Change) XXX_DiscardUnknown()

func (*Change) XXX_Marshal 

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

func (*Change) XXX_Merge 

func (dst *Change) XXX_Merge(src proto.Message)

func (*Change) XXX_Size 

func (m *Change) XXX_Size() int

func (*Change) XXX_Unmarshal 

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

func (*ChangeResponse) XXX_DiscardUnknown 

func (m *ChangeResponse) XXX_DiscardUnknown()

func (*ChangeResponse) XXX_Marshal 

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

func (*ChangeResponse) XXX_Merge 

func (dst *ChangeResponse) XXX_Merge(src proto.Message)

func (*ChangeResponse) XXX_Size 

func (m *ChangeResponse) XXX_Size() int

func (*ChangeResponse) XXX_Unmarshal 

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

func (*Cluster) XXX_DiscardUnknown 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal 

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

func (*Cluster) XXX_Merge 

func (dst *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal 

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

func (*ClusterCollection) XXX_DiscardUnknown 

func (m *ClusterCollection) XXX_DiscardUnknown()

func (*ClusterCollection) XXX_Marshal 

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

func (*ClusterCollection) XXX_Merge 

func (dst *ClusterCollection) XXX_Merge(src proto.Message)

func (*ClusterCollection) XXX_Size 

func (m *ClusterCollection) XXX_Size() int

func (*ClusterCollection) XXX_Unmarshal 

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

func (*ClusterInfo) XXX_DiscardUnknown 

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal 

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

func (*ClusterInfo) XXX_Merge 

func (dst *ClusterInfo) XXX_Merge(src proto.Message)

func (*ClusterInfo) XXX_Size 

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal 

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

func (*ClusterState) XXX_DiscardUnknown 

func (m *ClusterState) XXX_DiscardUnknown()

func (*ClusterState) XXX_Marshal 

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

func (*ClusterState) XXX_Merge 

func (dst *ClusterState) XXX_Merge(src proto.Message)

func (*ClusterState) XXX_Size 

func (m *ClusterState) XXX_Size() int

func (*ClusterState) XXX_Unmarshal 

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

func (*ClusterStateRequest) XXX_DiscardUnknown 

func (m *ClusterStateRequest) XXX_DiscardUnknown()

func (*ClusterStateRequest) XXX_Marshal 

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

func (*ClusterStateRequest) XXX_Merge 

func (dst *ClusterStateRequest) XXX_Merge(src proto.Message)

func (*ClusterStateRequest) XXX_Size 

func (m *ClusterStateRequest) XXX_Size() int

func (*ClusterStateRequest) XXX_Unmarshal 

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

func (*ClusterStates) XXX_DiscardUnknown 

func (m *ClusterStates) XXX_DiscardUnknown()

func (*ClusterStates) XXX_Marshal 

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

func (*ClusterStates) XXX_Merge 

func (dst *ClusterStates) XXX_Merge(src proto.Message)

func (*ClusterStates) XXX_Size 

func (m *ClusterStates) XXX_Size() int

func (*ClusterStates) XXX_Unmarshal 

func (m *ClusterStates) XXX_Unmarshal(b []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"`
	MaxInMemLogSize          uint64 `protobuf:"varint,17,opt,name=MaxInMemLogSize" json:"MaxInMemLogSize"`
}

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

func (m *Config) GetMaxInMemLogSize() uint64

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

func (*Config) XXX_DiscardUnknown 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal 

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

func (*Config) XXX_Merge 

func (dst *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal 

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

func (*ConfigChangeIndexList) XXX_DiscardUnknown 

func (m *ConfigChangeIndexList) XXX_DiscardUnknown()

func (*ConfigChangeIndexList) XXX_Marshal 

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

func (*ConfigChangeIndexList) XXX_Merge 

func (dst *ConfigChangeIndexList) XXX_Merge(src proto.Message)

func (*ConfigChangeIndexList) XXX_Size 

func (m *ConfigChangeIndexList) XXX_Size() int

func (*ConfigChangeIndexList) XXX_Unmarshal 

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

func (*DeploymentInfo) XXX_DiscardUnknown 

func (m *DeploymentInfo) XXX_DiscardUnknown()

func (*DeploymentInfo) XXX_Marshal 

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

func (*DeploymentInfo) XXX_Merge 

func (dst *DeploymentInfo) XXX_Merge(src proto.Message)

func (*DeploymentInfo) XXX_Size 

func (m *DeploymentInfo) XXX_Size() int

func (*DeploymentInfo) XXX_Unmarshal 

func (m *DeploymentInfo) XXX_Unmarshal(b []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)
}

DrummerClient is the client API for Drummer service.

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

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

func (*DrummerConfigRequest) XXX_DiscardUnknown 

func (m *DrummerConfigRequest) XXX_DiscardUnknown()

func (*DrummerConfigRequest) XXX_Marshal 

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

func (*DrummerConfigRequest) XXX_Merge 

func (dst *DrummerConfigRequest) XXX_Merge(src proto.Message)

func (*DrummerConfigRequest) XXX_Size 

func (m *DrummerConfigRequest) XXX_Size() int

func (*DrummerConfigRequest) XXX_Unmarshal 

func (m *DrummerConfigRequest) XXX_Unmarshal(b []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)
}

DrummerServer is the server API for Drummer service.

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

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

func (*KV) XXX_DiscardUnknown 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal 

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

func (*KV) XXX_Merge 

func (dst *KV) XXX_Merge(src proto.Message)

func (*KV) XXX_Size 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal 

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

func (*LogInfo) XXX_DiscardUnknown 

func (m *LogInfo) XXX_DiscardUnknown()

func (*LogInfo) XXX_Marshal 

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

func (*LogInfo) XXX_Merge 

func (dst *LogInfo) XXX_Merge(src proto.Message)

func (*LogInfo) XXX_Size 

func (m *LogInfo) XXX_Size() int

func (*LogInfo) XXX_Unmarshal 

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

func (*LookupRequest) XXX_DiscardUnknown 

func (m *LookupRequest) XXX_DiscardUnknown()

func (*LookupRequest) XXX_Marshal 

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

func (*LookupRequest) XXX_Merge 

func (dst *LookupRequest) XXX_Merge(src proto.Message)

func (*LookupRequest) XXX_Size 

func (m *LookupRequest) XXX_Size() int

func (*LookupRequest) XXX_Unmarshal 

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

func (*LookupResponse) XXX_DiscardUnknown 

func (m *LookupResponse) XXX_DiscardUnknown()

func (*LookupResponse) XXX_Marshal 

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

func (*LookupResponse) XXX_Merge 

func (dst *LookupResponse) XXX_Merge(src proto.Message)

func (*LookupResponse) XXX_Size 

func (m *LookupResponse) XXX_Size() int

func (*LookupResponse) XXX_Unmarshal 

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

func (*NodeHostCollection) XXX_DiscardUnknown 

func (m *NodeHostCollection) XXX_DiscardUnknown()

func (*NodeHostCollection) XXX_Marshal 

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

func (*NodeHostCollection) XXX_Merge 

func (dst *NodeHostCollection) XXX_Merge(src proto.Message)

func (*NodeHostCollection) XXX_Size 

func (m *NodeHostCollection) XXX_Size() int

func (*NodeHostCollection) XXX_Unmarshal 

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

func (*NodeHostInfo) XXX_DiscardUnknown 

func (m *NodeHostInfo) XXX_DiscardUnknown()

func (*NodeHostInfo) XXX_Marshal 

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

func (*NodeHostInfo) XXX_Merge 

func (dst *NodeHostInfo) XXX_Merge(src proto.Message)

func (*NodeHostInfo) XXX_Size 

func (m *NodeHostInfo) XXX_Size() int

func (*NodeHostInfo) XXX_Unmarshal 

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

func (*NodeHostRequest) XXX_DiscardUnknown 

func (m *NodeHostRequest) XXX_DiscardUnknown()

func (*NodeHostRequest) XXX_Marshal 

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

func (*NodeHostRequest) XXX_Merge 

func (dst *NodeHostRequest) XXX_Merge(src proto.Message)

func (*NodeHostRequest) XXX_Size 

func (m *NodeHostRequest) XXX_Size() int

func (*NodeHostRequest) XXX_Unmarshal 

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

func (*NodeHostRequestCollection) XXX_DiscardUnknown 

func (m *NodeHostRequestCollection) XXX_DiscardUnknown()

func (*NodeHostRequestCollection) XXX_Marshal 

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

func (*NodeHostRequestCollection) XXX_Merge 

func (dst *NodeHostRequestCollection) XXX_Merge(src proto.Message)

func (*NodeHostRequestCollection) XXX_Size 

func (m *NodeHostRequestCollection) XXX_Size() int

func (*NodeHostRequestCollection) XXX_Unmarshal 

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

func (*Regions) XXX_DiscardUnknown 

func (m *Regions) XXX_DiscardUnknown()

func (*Regions) XXX_Marshal 

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

func (*Regions) XXX_Merge 

func (dst *Regions) XXX_Merge(src proto.Message)

func (*Regions) XXX_Size 

func (m *Regions) XXX_Size() int

func (*Regions) XXX_Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

func (dst *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

func (*Update) XXX_DiscardUnknown 

func (m *Update) XXX_DiscardUnknown()

func (*Update) XXX_Marshal 

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

func (*Update) XXX_Merge 

func (dst *Update) XXX_Merge(src proto.Message)

func (*Update) XXX_Size 

func (m *Update) XXX_Size() int

func (*Update) XXX_Unmarshal 

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