drummerpb

package
v2.1.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 28, 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 (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 (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 (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 (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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL