pb

package
v0.0.0-...-e1f8a17 Latest Latest
Warning

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

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

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files: 

vasto.proto

It has these top-level messages: 

BalanceRequest
StoreHeartbeat
StoreMessage
ClientHeartbeat
ClientMessage
Cluster
ClusterNode
StoreResource
LocalShardsInCluster
ShardInfo
Empty
KeyTypeValue
Requests
Responses
Request
PutRequest
MergeRequest
WriteResponse
DeleteRequest
GetRequest
GetResponse
GetByPrefixRequest
GetByPrefixResponse
Response
RawKeyValue
LogEntry
CopyDoneMessge
BootstrapCopyRequest
BootstrapCopyResponse
PullUpdateRequest
PullUpdateResponse
CheckBinlogRequest
CheckBinlogResponse
DescribeRequest
DescribeResponse
CreateClusterRequest
CreateClusterResponse
DeleteClusterRequest
DeleteClusterResponse
CompactClusterRequest
CompactClusterResponse
ReplaceNodeRequest
ReplaceNodeResponse
CreateShardRequest
CreateShardResponse
DeleteKeyspaceRequest
DeleteKeyspaceResponse
CompactKeyspaceRequest
CompactKeyspaceResponse
ReplicateNodePrepareRequest
ReplicateNodePrepareResponse
ReplicateNodeCommitRequest
ReplicateNodeCommitResponse
ReplicateNodeCleanupRequest
ReplicateNodeCleanupResponse
ResizeCreateShardRequest
ResizeCreateShardResponse
ResizeCommitRequest
ResizeCommitResponse
ResizeCleanupRequest
ResizeCleanupResponse
ResizeRequest
ResizeResponse

Index

Constants

This section is empty.

Variables

View Source 
var OpAndDataType_name = map[int32]string{
	0: "BYTES",
	1: "FLOAT64",
	2: "MAX_FLOAT64",
	3: "MIN_FLOAT64",
}
View Source 
var OpAndDataType_value = map[string]int32{
	"BYTES":       0,
	"FLOAT64":     1,
	"MAX_FLOAT64": 2,
	"MIN_FLOAT64": 3,
}
View Source 
var ShardInfo_Status_name = map[int32]string{
	0: "EMPTY",
	1: "BOOTSTRAP",
	2: "READY",
	3: "DELETED",
}
View Source 
var ShardInfo_Status_value = map[string]int32{
	"EMPTY":     0,
	"BOOTSTRAP": 1,
	"READY":     2,
	"DELETED":   3,
}

Functions

func MergeSorted 

func MergeSorted(chans []chan *RawKeyValue, limit int64, fn func(*RawKeyValue) error) (int64, error)

MergeSorted merges multiple channels of sorted RawKeyValue values into a bigger sorted list and processed by the fn function.

func RegisterVastoMasterServer 

func RegisterVastoMasterServer(s *grpc.Server, srv VastoMasterServer)

func RegisterVastoStoreServer 

func RegisterVastoStoreServer(s *grpc.Server, srv VastoStoreServer)

Types

type BalanceRequest 

type BalanceRequest struct {
	StoreGroup string `protobuf:"bytes,2,opt,name=store_group,json=storeGroup" json:"store_group,omitempty"`
	StoreCount uint32 `protobuf:"varint,3,opt,name=store_count,json=storeCount" json:"store_count,omitempty"`
}

//////////////////////////////////////////////// 1. master received request to balance the data

func (*BalanceRequest) Descriptor 

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

func (*BalanceRequest) GetStoreCount 

func (m *BalanceRequest) GetStoreCount() uint32

func (*BalanceRequest) GetStoreGroup 

func (m *BalanceRequest) GetStoreGroup() string

func (*BalanceRequest) ProtoMessage 

func (*BalanceRequest) ProtoMessage()

func (*BalanceRequest) Reset 

func (m *BalanceRequest) Reset()

func (*BalanceRequest) String 

func (m *BalanceRequest) String() string

type BootstrapCopyRequest 

type BootstrapCopyRequest struct {
	Keyspace          string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	ShardId           uint32 `protobuf:"varint,2,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	ClusterSize       uint32 `protobuf:"varint,3,opt,name=cluster_size,json=clusterSize" json:"cluster_size,omitempty"`
	TargetShardId     uint32 `protobuf:"varint,4,opt,name=target_shard_id,json=targetShardId" json:"target_shard_id,omitempty"`
	TargetClusterSize uint32 `protobuf:"varint,5,opt,name=target_cluster_size,json=targetClusterSize" json:"target_cluster_size,omitempty"`
	Origin            string `protobuf:"bytes,6,opt,name=origin" json:"origin,omitempty"`
	Limit             uint64 `protobuf:"varint,7,opt,name=limit" json:"limit,omitempty"`
}

func (*BootstrapCopyRequest) Descriptor 

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

func (*BootstrapCopyRequest) GetClusterSize 

func (m *BootstrapCopyRequest) GetClusterSize() uint32

func (*BootstrapCopyRequest) GetKeyspace 

func (m *BootstrapCopyRequest) GetKeyspace() string

func (*BootstrapCopyRequest) GetLimit 

func (m *BootstrapCopyRequest) GetLimit() uint64

func (*BootstrapCopyRequest) GetOrigin 

func (m *BootstrapCopyRequest) GetOrigin() string

func (*BootstrapCopyRequest) GetShardId 

func (m *BootstrapCopyRequest) GetShardId() uint32

func (*BootstrapCopyRequest) GetTargetClusterSize 

func (m *BootstrapCopyRequest) GetTargetClusterSize() uint32

func (*BootstrapCopyRequest) GetTargetShardId 

func (m *BootstrapCopyRequest) GetTargetShardId() uint32

func (*BootstrapCopyRequest) ProtoMessage 

func (*BootstrapCopyRequest) ProtoMessage()

func (*BootstrapCopyRequest) Reset 

func (m *BootstrapCopyRequest) Reset()

func (*BootstrapCopyRequest) String 

func (m *BootstrapCopyRequest) String() string

type BootstrapCopyResponse 

type BootstrapCopyResponse struct {
	KeyValues          []*RawKeyValue                            `protobuf:"bytes,1,rep,name=key_values,json=keyValues" json:"key_values,omitempty"`
	BinlogTailProgress *BootstrapCopyResponse_BinlogTailProgress `protobuf:"bytes,2,opt,name=binlogTailProgress" json:"binlogTailProgress,omitempty"`
}

func (*BootstrapCopyResponse) Descriptor 

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

func (*BootstrapCopyResponse) GetBinlogTailProgress 

func (m *BootstrapCopyResponse) GetBinlogTailProgress() *BootstrapCopyResponse_BinlogTailProgress

func (*BootstrapCopyResponse) GetKeyValues 

func (m *BootstrapCopyResponse) GetKeyValues() []*RawKeyValue

func (*BootstrapCopyResponse) ProtoMessage 

func (*BootstrapCopyResponse) ProtoMessage()

func (*BootstrapCopyResponse) Reset 

func (m *BootstrapCopyResponse) Reset()

func (*BootstrapCopyResponse) String 

func (m *BootstrapCopyResponse) String() string

type BootstrapCopyResponse_BinlogTailProgress 

type BootstrapCopyResponse_BinlogTailProgress struct {
	Segment uint32 `protobuf:"varint,1,opt,name=segment" json:"segment,omitempty"`
	Offset  uint64 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
}

this message is only sent at the end of copying

func (*BootstrapCopyResponse_BinlogTailProgress) Descriptor 

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

func (*BootstrapCopyResponse_BinlogTailProgress) GetOffset 

func (m *BootstrapCopyResponse_BinlogTailProgress) GetOffset() uint64

func (*BootstrapCopyResponse_BinlogTailProgress) GetSegment 

func (m *BootstrapCopyResponse_BinlogTailProgress) GetSegment() uint32

func (*BootstrapCopyResponse_BinlogTailProgress) ProtoMessage 

func (*BootstrapCopyResponse_BinlogTailProgress) ProtoMessage()

func (*BootstrapCopyResponse_BinlogTailProgress) Reset 

func (m *BootstrapCopyResponse_BinlogTailProgress) Reset()

func (*BootstrapCopyResponse_BinlogTailProgress) String 

func (m *BootstrapCopyResponse_BinlogTailProgress) String() string

type CheckBinlogRequest 

type CheckBinlogRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	ShardId  uint32 `protobuf:"varint,2,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
}

func (*CheckBinlogRequest) Descriptor 

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

func (*CheckBinlogRequest) GetKeyspace 

func (m *CheckBinlogRequest) GetKeyspace() string

func (*CheckBinlogRequest) GetShardId 

func (m *CheckBinlogRequest) GetShardId() uint32

func (*CheckBinlogRequest) ProtoMessage 

func (*CheckBinlogRequest) ProtoMessage()

func (*CheckBinlogRequest) Reset 

func (m *CheckBinlogRequest) Reset()

func (*CheckBinlogRequest) String 

func (m *CheckBinlogRequest) String() string

type CheckBinlogResponse 

type CheckBinlogResponse struct {
	ShardId         uint32 `protobuf:"varint,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	EarliestSegment uint32 `protobuf:"varint,2,opt,name=earliest_segment,json=earliestSegment" json:"earliest_segment,omitempty"`
	LatestSegment   uint32 `protobuf:"varint,3,opt,name=latest_segment,json=latestSegment" json:"latest_segment,omitempty"`
}

func (*CheckBinlogResponse) Descriptor 

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

func (*CheckBinlogResponse) GetEarliestSegment 

func (m *CheckBinlogResponse) GetEarliestSegment() uint32

func (*CheckBinlogResponse) GetLatestSegment 

func (m *CheckBinlogResponse) GetLatestSegment() uint32

func (*CheckBinlogResponse) GetShardId 

func (m *CheckBinlogResponse) GetShardId() uint32

func (*CheckBinlogResponse) ProtoMessage 

func (*CheckBinlogResponse) ProtoMessage()

func (*CheckBinlogResponse) Reset 

func (m *CheckBinlogResponse) Reset()

func (*CheckBinlogResponse) String 

func (m *CheckBinlogResponse) String() string

type ClientHeartbeat 

type ClientHeartbeat struct {
	ClientName    string                                `protobuf:"bytes,2,opt,name=client_name,json=clientName" json:"client_name,omitempty"`
	ClusterFollow *ClientHeartbeat_ClusterFollowMessage `protobuf:"bytes,3,opt,name=cluster_follow,json=clusterFollow" json:"cluster_follow,omitempty"`
}

func (*ClientHeartbeat) Descriptor 

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

func (*ClientHeartbeat) GetClientName 

func (m *ClientHeartbeat) GetClientName() string

func (*ClientHeartbeat) GetClusterFollow 

func (m *ClientHeartbeat) GetClusterFollow() *ClientHeartbeat_ClusterFollowMessage

func (*ClientHeartbeat) ProtoMessage 

func (*ClientHeartbeat) ProtoMessage()

func (*ClientHeartbeat) Reset 

func (m *ClientHeartbeat) Reset()

func (*ClientHeartbeat) String 

func (m *ClientHeartbeat) String() string

type ClientHeartbeat_ClusterFollowMessage 

type ClientHeartbeat_ClusterFollowMessage struct {
	Keyspace   string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	IsUnfollow bool   `protobuf:"varint,2,opt,name=is_unfollow,json=isUnfollow" json:"is_unfollow,omitempty"`
}

func (*ClientHeartbeat_ClusterFollowMessage) Descriptor 

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

func (*ClientHeartbeat_ClusterFollowMessage) GetIsUnfollow 

func (m *ClientHeartbeat_ClusterFollowMessage) GetIsUnfollow() bool

func (*ClientHeartbeat_ClusterFollowMessage) GetKeyspace 

func (m *ClientHeartbeat_ClusterFollowMessage) GetKeyspace() string

func (*ClientHeartbeat_ClusterFollowMessage) ProtoMessage 

func (*ClientHeartbeat_ClusterFollowMessage) ProtoMessage()

func (*ClientHeartbeat_ClusterFollowMessage) Reset 

func (m *ClientHeartbeat_ClusterFollowMessage) Reset()

func (*ClientHeartbeat_ClusterFollowMessage) String 

func (m *ClientHeartbeat_ClusterFollowMessage) String() string

type ClientMessage 

type ClientMessage struct {
	Cluster *Cluster                           `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
	Updates *ClientMessage_StoreResourceUpdate `protobuf:"bytes,2,opt,name=updates" json:"updates,omitempty"`
	Resize  *ClientMessage_Resize              `protobuf:"bytes,3,opt,name=resize" json:"resize,omitempty"`
}

func (*ClientMessage) Descriptor 

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

func (*ClientMessage) GetCluster 

func (m *ClientMessage) GetCluster() *Cluster

func (*ClientMessage) GetResize 

func (m *ClientMessage) GetResize() *ClientMessage_Resize

func (*ClientMessage) GetUpdates 

func (m *ClientMessage) GetUpdates() *ClientMessage_StoreResourceUpdate

func (*ClientMessage) ProtoMessage 

func (*ClientMessage) ProtoMessage()

func (*ClientMessage) Reset 

func (m *ClientMessage) Reset()

func (*ClientMessage) String 

func (m *ClientMessage) String() string

type ClientMessage_Resize 

type ClientMessage_Resize struct {
	CurrentClusterSize uint32 `protobuf:"varint,1,opt,name=current_cluster_size,json=currentClusterSize" json:"current_cluster_size,omitempty"`
	TargetClusterSize  uint32 `protobuf:"varint,2,opt,name=target_cluster_size,json=targetClusterSize" json:"target_cluster_size,omitempty"`
	Keyspace           string `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*ClientMessage_Resize) Descriptor 

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

func (*ClientMessage_Resize) GetCurrentClusterSize 

func (m *ClientMessage_Resize) GetCurrentClusterSize() uint32

func (*ClientMessage_Resize) GetKeyspace 

func (m *ClientMessage_Resize) GetKeyspace() string

func (*ClientMessage_Resize) GetTargetClusterSize 

func (m *ClientMessage_Resize) GetTargetClusterSize() uint32

func (*ClientMessage_Resize) ProtoMessage 

func (*ClientMessage_Resize) ProtoMessage()

func (*ClientMessage_Resize) Reset 

func (m *ClientMessage_Resize) Reset()

func (*ClientMessage_Resize) String 

func (m *ClientMessage_Resize) String() string

type ClientMessage_StoreResourceUpdate 

type ClientMessage_StoreResourceUpdate struct {
	Nodes       []*ClusterNode `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
	IsDelete    bool           `protobuf:"varint,2,opt,name=is_delete,json=isDelete" json:"is_delete,omitempty"`
	Keyspace    string         `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"`
	IsPromotion bool           `protobuf:"varint,4,opt,name=is_promotion,json=isPromotion" json:"is_promotion,omitempty"`
}

func (*ClientMessage_StoreResourceUpdate) Descriptor 

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

func (*ClientMessage_StoreResourceUpdate) GetIsDelete 

func (m *ClientMessage_StoreResourceUpdate) GetIsDelete() bool

func (*ClientMessage_StoreResourceUpdate) GetIsPromotion 

func (m *ClientMessage_StoreResourceUpdate) GetIsPromotion() bool

func (*ClientMessage_StoreResourceUpdate) GetKeyspace 

func (m *ClientMessage_StoreResourceUpdate) GetKeyspace() string

func (*ClientMessage_StoreResourceUpdate) GetNodes 

func (m *ClientMessage_StoreResourceUpdate) GetNodes() []*ClusterNode

func (*ClientMessage_StoreResourceUpdate) ProtoMessage 

func (*ClientMessage_StoreResourceUpdate) ProtoMessage()

func (*ClientMessage_StoreResourceUpdate) Reset 

func (m *ClientMessage_StoreResourceUpdate) Reset()

func (*ClientMessage_StoreResourceUpdate) String 

func (m *ClientMessage_StoreResourceUpdate) String() string

type Cluster 

type Cluster struct {
	Keyspace            string         `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	Nodes               []*ClusterNode `protobuf:"bytes,3,rep,name=nodes" json:"nodes,omitempty"`
	ExpectedClusterSize uint32         `protobuf:"varint,4,opt,name=expected_cluster_size,json=expectedClusterSize" json:"expected_cluster_size,omitempty"`
	CurrentClusterSize  uint32         `protobuf:"varint,5,opt,name=current_cluster_size,json=currentClusterSize" json:"current_cluster_size,omitempty"`
	ReplicationFactor   uint32         `protobuf:"varint,6,opt,name=replication_factor,json=replicationFactor" json:"replication_factor,omitempty"`
}

func (*Cluster) Descriptor 

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

func (*Cluster) GetCurrentClusterSize 

func (m *Cluster) GetCurrentClusterSize() uint32

func (*Cluster) GetExpectedClusterSize 

func (m *Cluster) GetExpectedClusterSize() uint32

func (*Cluster) GetKeyspace 

func (m *Cluster) GetKeyspace() string

func (*Cluster) GetNodes 

func (m *Cluster) GetNodes() []*ClusterNode

func (*Cluster) GetReplicationFactor 

func (m *Cluster) GetReplicationFactor() uint32

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) String 

func (m *Cluster) String() string

type ClusterNode 

type ClusterNode struct {
	StoreResource *StoreResource `protobuf:"bytes,1,opt,name=store_resource,json=storeResource" json:"store_resource,omitempty"`
	ShardInfo     *ShardInfo     `protobuf:"bytes,2,opt,name=shard_info,json=shardInfo" json:"shard_info,omitempty"`
}

denormalized

func (*ClusterNode) Descriptor 

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

func (*ClusterNode) GetShardInfo 

func (m *ClusterNode) GetShardInfo() *ShardInfo

func (*ClusterNode) GetStoreResource 

func (m *ClusterNode) GetStoreResource() *StoreResource

func (*ClusterNode) ProtoMessage 

func (*ClusterNode) ProtoMessage()

func (*ClusterNode) Reset 

func (m *ClusterNode) Reset()

func (*ClusterNode) String 

func (m *ClusterNode) String() string

type CompactClusterRequest 

type CompactClusterRequest struct {
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*CompactClusterRequest) Descriptor 

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

func (*CompactClusterRequest) GetKeyspace 

func (m *CompactClusterRequest) GetKeyspace() string

func (*CompactClusterRequest) ProtoMessage 

func (*CompactClusterRequest) ProtoMessage()

func (*CompactClusterRequest) Reset 

func (m *CompactClusterRequest) Reset()

func (*CompactClusterRequest) String 

func (m *CompactClusterRequest) String() string

type CompactClusterResponse 

type CompactClusterResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*CompactClusterResponse) Descriptor 

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

func (*CompactClusterResponse) GetError 

func (m *CompactClusterResponse) GetError() string

func (*CompactClusterResponse) ProtoMessage 

func (*CompactClusterResponse) ProtoMessage()

func (*CompactClusterResponse) Reset 

func (m *CompactClusterResponse) Reset()

func (*CompactClusterResponse) String 

func (m *CompactClusterResponse) String() string

type CompactKeyspaceRequest 

type CompactKeyspaceRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*CompactKeyspaceRequest) Descriptor 

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

func (*CompactKeyspaceRequest) GetKeyspace 

func (m *CompactKeyspaceRequest) GetKeyspace() string

func (*CompactKeyspaceRequest) ProtoMessage 

func (*CompactKeyspaceRequest) ProtoMessage()

func (*CompactKeyspaceRequest) Reset 

func (m *CompactKeyspaceRequest) Reset()

func (*CompactKeyspaceRequest) String 

func (m *CompactKeyspaceRequest) String() string

type CompactKeyspaceResponse 

type CompactKeyspaceResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*CompactKeyspaceResponse) Descriptor 

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

func (*CompactKeyspaceResponse) GetError 

func (m *CompactKeyspaceResponse) GetError() string

func (*CompactKeyspaceResponse) ProtoMessage 

func (*CompactKeyspaceResponse) ProtoMessage()

func (*CompactKeyspaceResponse) Reset 

func (m *CompactKeyspaceResponse) Reset()

func (*CompactKeyspaceResponse) String 

func (m *CompactKeyspaceResponse) String() string

type CopyDoneMessge 

type CopyDoneMessge struct {
	Shard           int32 `protobuf:"varint,1,opt,name=shard" json:"shard,omitempty"`
	CopyStartTimeNs int64 `protobuf:"varint,2,opt,name=copy_start_time_ns,json=copyStartTimeNs" json:"copy_start_time_ns,omitempty"`
}

//////////////////////////////////////////////// // data copying ////////////////////////////////////////////////

func (*CopyDoneMessge) Descriptor 

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

func (*CopyDoneMessge) GetCopyStartTimeNs 

func (m *CopyDoneMessge) GetCopyStartTimeNs() int64

func (*CopyDoneMessge) GetShard 

func (m *CopyDoneMessge) GetShard() int32

func (*CopyDoneMessge) ProtoMessage 

func (*CopyDoneMessge) ProtoMessage()

func (*CopyDoneMessge) Reset 

func (m *CopyDoneMessge) Reset()

func (*CopyDoneMessge) String 

func (m *CopyDoneMessge) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {
	Keyspace          string   `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
	ClusterSize       uint32   `protobuf:"varint,3,opt,name=cluster_size,json=clusterSize" json:"cluster_size,omitempty"`
	ReplicationFactor uint32   `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor" json:"replication_factor,omitempty"`
	TotalDiskSizeGb   uint32   `protobuf:"varint,5,opt,name=total_disk_size_gb,json=totalDiskSizeGb" json:"total_disk_size_gb,omitempty"`
	Tags              []string `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CreateClusterRequest) Descriptor 

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

func (*CreateClusterRequest) GetClusterSize 

func (m *CreateClusterRequest) GetClusterSize() uint32

func (*CreateClusterRequest) GetKeyspace 

func (m *CreateClusterRequest) GetKeyspace() string

func (*CreateClusterRequest) GetReplicationFactor 

func (m *CreateClusterRequest) GetReplicationFactor() uint32

func (*CreateClusterRequest) GetTags 

func (m *CreateClusterRequest) GetTags() []string

func (*CreateClusterRequest) GetTotalDiskSizeGb 

func (m *CreateClusterRequest) GetTotalDiskSizeGb() uint32

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) Reset 

func (m *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String 

func (m *CreateClusterRequest) String() string

type CreateClusterResponse 

type CreateClusterResponse struct {
	Error   string   `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
}

func (*CreateClusterResponse) Descriptor 

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

func (*CreateClusterResponse) GetCluster 

func (m *CreateClusterResponse) GetCluster() *Cluster

func (*CreateClusterResponse) GetError 

func (m *CreateClusterResponse) GetError() string

func (*CreateClusterResponse) ProtoMessage 

func (*CreateClusterResponse) ProtoMessage()

func (*CreateClusterResponse) Reset 

func (m *CreateClusterResponse) Reset()

func (*CreateClusterResponse) String 

func (m *CreateClusterResponse) String() string

type CreateShardRequest 

type CreateShardRequest struct {
	Keyspace          string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	ServerId          uint32 `protobuf:"varint,2,opt,name=server_id,json=serverId" json:"server_id,omitempty"`
	ClusterSize       uint32 `protobuf:"varint,3,opt,name=cluster_size,json=clusterSize" json:"cluster_size,omitempty"`
	ReplicationFactor uint32 `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor" json:"replication_factor,omitempty"`
	ShardDiskSizeGb   uint32 `protobuf:"varint,5,opt,name=shard_disk_size_gb,json=shardDiskSizeGb" json:"shard_disk_size_gb,omitempty"`
}

////// request response with store

func (*CreateShardRequest) Descriptor 

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

func (*CreateShardRequest) GetClusterSize 

func (m *CreateShardRequest) GetClusterSize() uint32

func (*CreateShardRequest) GetKeyspace 

func (m *CreateShardRequest) GetKeyspace() string

func (*CreateShardRequest) GetReplicationFactor 

func (m *CreateShardRequest) GetReplicationFactor() uint32

func (*CreateShardRequest) GetServerId 

func (m *CreateShardRequest) GetServerId() uint32

func (*CreateShardRequest) GetShardDiskSizeGb 

func (m *CreateShardRequest) GetShardDiskSizeGb() uint32

func (*CreateShardRequest) ProtoMessage 

func (*CreateShardRequest) ProtoMessage()

func (*CreateShardRequest) Reset 

func (m *CreateShardRequest) Reset()

func (*CreateShardRequest) String 

func (m *CreateShardRequest) String() string

type CreateShardResponse 

type CreateShardResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*CreateShardResponse) Descriptor 

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

func (*CreateShardResponse) GetError 

func (m *CreateShardResponse) GetError() string

func (*CreateShardResponse) ProtoMessage 

func (*CreateShardResponse) ProtoMessage()

func (*CreateShardResponse) Reset 

func (m *CreateShardResponse) Reset()

func (*CreateShardResponse) String 

func (m *CreateShardResponse) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*DeleteClusterRequest) Descriptor 

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

func (*DeleteClusterRequest) GetKeyspace 

func (m *DeleteClusterRequest) GetKeyspace() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) Reset 

func (m *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (m *DeleteClusterRequest) String() string

type DeleteClusterResponse 

type DeleteClusterResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*DeleteClusterResponse) Descriptor 

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

func (*DeleteClusterResponse) GetError 

func (m *DeleteClusterResponse) GetError() string

func (*DeleteClusterResponse) ProtoMessage 

func (*DeleteClusterResponse) ProtoMessage()

func (*DeleteClusterResponse) Reset 

func (m *DeleteClusterResponse) Reset()

func (*DeleteClusterResponse) String 

func (m *DeleteClusterResponse) String() string

type DeleteKeyspaceRequest 

type DeleteKeyspaceRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*DeleteKeyspaceRequest) Descriptor 

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

func (*DeleteKeyspaceRequest) GetKeyspace 

func (m *DeleteKeyspaceRequest) GetKeyspace() string

func (*DeleteKeyspaceRequest) ProtoMessage 

func (*DeleteKeyspaceRequest) ProtoMessage()

func (*DeleteKeyspaceRequest) Reset 

func (m *DeleteKeyspaceRequest) Reset()

func (*DeleteKeyspaceRequest) String 

func (m *DeleteKeyspaceRequest) String() string

type DeleteKeyspaceResponse 

type DeleteKeyspaceResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*DeleteKeyspaceResponse) Descriptor 

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

func (*DeleteKeyspaceResponse) GetError 

func (m *DeleteKeyspaceResponse) GetError() string

func (*DeleteKeyspaceResponse) ProtoMessage 

func (*DeleteKeyspaceResponse) ProtoMessage()

func (*DeleteKeyspaceResponse) Reset 

func (m *DeleteKeyspaceResponse) Reset()

func (*DeleteKeyspaceResponse) String 

func (m *DeleteKeyspaceResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	Key           []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	PartitionHash uint64 `protobuf:"varint,2,opt,name=partition_hash,json=partitionHash" json:"partition_hash,omitempty"`
	UpdatedAtNs   uint64 `protobuf:"varint,3,opt,name=updated_at_ns,json=updatedAtNs" json:"updated_at_ns,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetKey 

func (m *DeleteRequest) GetKey() []byte

func (*DeleteRequest) GetPartitionHash 

func (m *DeleteRequest) GetPartitionHash() uint64

func (*DeleteRequest) GetUpdatedAtNs 

func (m *DeleteRequest) GetUpdatedAtNs() uint64

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

type DescribeRequest 

type DescribeRequest struct {
	DescDataCenters *DescribeRequest_DescDataCenters `protobuf:"bytes,1,opt,name=desc_data_centers,json=descDataCenters" json:"desc_data_centers,omitempty"`
	DescKeyspaces   *DescribeRequest_DescKeyspaces   `protobuf:"bytes,2,opt,name=desc_keyspaces,json=descKeyspaces" json:"desc_keyspaces,omitempty"`
	DescCluster     *DescribeRequest_DescCluster     `protobuf:"bytes,3,opt,name=desc_cluster,json=descCluster" json:"desc_cluster,omitempty"`
	DescClients     *DescribeRequest_DescClients     `protobuf:"bytes,4,opt,name=desc_clients,json=descClients" json:"desc_clients,omitempty"`
}

//////////////////////////////////////////////// // admin ////////////////////////////////////////////////

func (*DescribeRequest) Descriptor 

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

func (*DescribeRequest) GetDescClients 

func (m *DescribeRequest) GetDescClients() *DescribeRequest_DescClients

func (*DescribeRequest) GetDescCluster 

func (m *DescribeRequest) GetDescCluster() *DescribeRequest_DescCluster

func (*DescribeRequest) GetDescDataCenters 

func (m *DescribeRequest) GetDescDataCenters() *DescribeRequest_DescDataCenters

func (*DescribeRequest) GetDescKeyspaces 

func (m *DescribeRequest) GetDescKeyspaces() *DescribeRequest_DescKeyspaces

func (*DescribeRequest) ProtoMessage 

func (*DescribeRequest) ProtoMessage()

func (*DescribeRequest) Reset 

func (m *DescribeRequest) Reset()

func (*DescribeRequest) String 

func (m *DescribeRequest) String() string

type DescribeRequest_DescClients 

type DescribeRequest_DescClients struct {
}

func (*DescribeRequest_DescClients) Descriptor 

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

func (*DescribeRequest_DescClients) ProtoMessage 

func (*DescribeRequest_DescClients) ProtoMessage()

func (*DescribeRequest_DescClients) Reset 

func (m *DescribeRequest_DescClients) Reset()

func (*DescribeRequest_DescClients) String 

func (m *DescribeRequest_DescClients) String() string

type DescribeRequest_DescCluster 

type DescribeRequest_DescCluster struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*DescribeRequest_DescCluster) Descriptor 

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

func (*DescribeRequest_DescCluster) GetKeyspace 

func (m *DescribeRequest_DescCluster) GetKeyspace() string

func (*DescribeRequest_DescCluster) ProtoMessage 

func (*DescribeRequest_DescCluster) ProtoMessage()

func (*DescribeRequest_DescCluster) Reset 

func (m *DescribeRequest_DescCluster) Reset()

func (*DescribeRequest_DescCluster) String 

func (m *DescribeRequest_DescCluster) String() string

type DescribeRequest_DescDataCenters 

type DescribeRequest_DescDataCenters struct {
}

func (*DescribeRequest_DescDataCenters) Descriptor 

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

func (*DescribeRequest_DescDataCenters) ProtoMessage 

func (*DescribeRequest_DescDataCenters) ProtoMessage()

func (*DescribeRequest_DescDataCenters) Reset 

func (m *DescribeRequest_DescDataCenters) Reset()

func (*DescribeRequest_DescDataCenters) String 

func (m *DescribeRequest_DescDataCenters) String() string

type DescribeRequest_DescKeyspaces 

type DescribeRequest_DescKeyspaces struct {
}

func (*DescribeRequest_DescKeyspaces) Descriptor 

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

func (*DescribeRequest_DescKeyspaces) ProtoMessage 

func (*DescribeRequest_DescKeyspaces) ProtoMessage()

func (*DescribeRequest_DescKeyspaces) Reset 

func (m *DescribeRequest_DescKeyspaces) Reset()

func (*DescribeRequest_DescKeyspaces) String 

func (m *DescribeRequest_DescKeyspaces) String() string

type DescribeResponse 

type DescribeResponse struct {
	DescDataCenter *DescribeResponse_DescDataCenter `protobuf:"bytes,1,opt,name=desc_data_center,json=descDataCenter" json:"desc_data_center,omitempty"`
	DescKeyspaces  *DescribeResponse_DescKeyspaces  `protobuf:"bytes,2,opt,name=desc_keyspaces,json=descKeyspaces" json:"desc_keyspaces,omitempty"`
	DescCluster    *DescribeResponse_DescCluster    `protobuf:"bytes,3,opt,name=desc_cluster,json=descCluster" json:"desc_cluster,omitempty"`
	ClientCount    uint32                           `protobuf:"varint,4,opt,name=client_count,json=clientCount" json:"client_count,omitempty"`
}

func (*DescribeResponse) Descriptor 

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

func (*DescribeResponse) GetClientCount 

func (m *DescribeResponse) GetClientCount() uint32

func (*DescribeResponse) GetDescCluster 

func (m *DescribeResponse) GetDescCluster() *DescribeResponse_DescCluster

func (*DescribeResponse) GetDescDataCenter 

func (m *DescribeResponse) GetDescDataCenter() *DescribeResponse_DescDataCenter

func (*DescribeResponse) GetDescKeyspaces 

func (m *DescribeResponse) GetDescKeyspaces() *DescribeResponse_DescKeyspaces

func (*DescribeResponse) ProtoMessage 

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) Reset 

func (m *DescribeResponse) Reset()

func (*DescribeResponse) String 

func (m *DescribeResponse) String() string

type DescribeResponse_DescCluster 

type DescribeResponse_DescCluster struct {
	Cluster     *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
	NextCluster *Cluster `protobuf:"bytes,2,opt,name=next_cluster,json=nextCluster" json:"next_cluster,omitempty"`
	ClientCount uint32   `protobuf:"varint,3,opt,name=client_count,json=clientCount" json:"client_count,omitempty"`
}

func (*DescribeResponse_DescCluster) Descriptor 

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

func (*DescribeResponse_DescCluster) GetClientCount 

func (m *DescribeResponse_DescCluster) GetClientCount() uint32

func (*DescribeResponse_DescCluster) GetCluster 

func (m *DescribeResponse_DescCluster) GetCluster() *Cluster

func (*DescribeResponse_DescCluster) GetNextCluster 

func (m *DescribeResponse_DescCluster) GetNextCluster() *Cluster

func (*DescribeResponse_DescCluster) ProtoMessage 

func (*DescribeResponse_DescCluster) ProtoMessage()

func (*DescribeResponse_DescCluster) Reset 

func (m *DescribeResponse_DescCluster) Reset()

func (*DescribeResponse_DescCluster) String 

func (m *DescribeResponse_DescCluster) String() string

type DescribeResponse_DescDataCenter 

type DescribeResponse_DescDataCenter struct {
	DataCenter *DescribeResponse_DescDataCenter_DataCenter `protobuf:"bytes,1,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
}

func (*DescribeResponse_DescDataCenter) Descriptor 

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

func (*DescribeResponse_DescDataCenter) GetDataCenter 

func (m *DescribeResponse_DescDataCenter) GetDataCenter() *DescribeResponse_DescDataCenter_DataCenter

func (*DescribeResponse_DescDataCenter) ProtoMessage 

func (*DescribeResponse_DescDataCenter) ProtoMessage()

func (*DescribeResponse_DescDataCenter) Reset 

func (m *DescribeResponse_DescDataCenter) Reset()

func (*DescribeResponse_DescDataCenter) String 

func (m *DescribeResponse_DescDataCenter) String() string

type DescribeResponse_DescDataCenter_DataCenter 

type DescribeResponse_DescDataCenter_DataCenter struct {
	StoreResources []*StoreResource `protobuf:"bytes,2,rep,name=store_resources,json=storeResources" json:"store_resources,omitempty"`
}

func (*DescribeResponse_DescDataCenter_DataCenter) Descriptor 

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

func (*DescribeResponse_DescDataCenter_DataCenter) GetStoreResources 

func (m *DescribeResponse_DescDataCenter_DataCenter) GetStoreResources() []*StoreResource

func (*DescribeResponse_DescDataCenter_DataCenter) ProtoMessage 

func (*DescribeResponse_DescDataCenter_DataCenter) ProtoMessage()

func (*DescribeResponse_DescDataCenter_DataCenter) Reset 

func (m *DescribeResponse_DescDataCenter_DataCenter) Reset()

func (*DescribeResponse_DescDataCenter_DataCenter) String 

func (m *DescribeResponse_DescDataCenter_DataCenter) String() string

type DescribeResponse_DescKeyspaces 

type DescribeResponse_DescKeyspaces struct {
	Keyspaces []*DescribeResponse_DescKeyspaces_Keyspace `protobuf:"bytes,1,rep,name=keyspaces" json:"keyspaces,omitempty"`
}

func (*DescribeResponse_DescKeyspaces) Descriptor 

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

func (*DescribeResponse_DescKeyspaces) GetKeyspaces 

func (m *DescribeResponse_DescKeyspaces) GetKeyspaces() []*DescribeResponse_DescKeyspaces_Keyspace

func (*DescribeResponse_DescKeyspaces) ProtoMessage 

func (*DescribeResponse_DescKeyspaces) ProtoMessage()

func (*DescribeResponse_DescKeyspaces) Reset 

func (m *DescribeResponse_DescKeyspaces) Reset()

func (*DescribeResponse_DescKeyspaces) String 

func (m *DescribeResponse_DescKeyspaces) String() string

type DescribeResponse_DescKeyspaces_Keyspace 

type DescribeResponse_DescKeyspaces_Keyspace struct {
	Keyspace    string     `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	Clusters    []*Cluster `protobuf:"bytes,2,rep,name=clusters" json:"clusters,omitempty"`
	ClientCount uint32     `protobuf:"varint,3,opt,name=client_count,json=clientCount" json:"client_count,omitempty"`
}

func (*DescribeResponse_DescKeyspaces_Keyspace) Descriptor 

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

func (*DescribeResponse_DescKeyspaces_Keyspace) GetClientCount 

func (m *DescribeResponse_DescKeyspaces_Keyspace) GetClientCount() uint32

func (*DescribeResponse_DescKeyspaces_Keyspace) GetClusters 

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

func (*DescribeResponse_DescKeyspaces_Keyspace) GetKeyspace 

func (m *DescribeResponse_DescKeyspaces_Keyspace) GetKeyspace() string

func (*DescribeResponse_DescKeyspaces_Keyspace) ProtoMessage 

func (*DescribeResponse_DescKeyspaces_Keyspace) ProtoMessage()

func (*DescribeResponse_DescKeyspaces_Keyspace) Reset 

func (m *DescribeResponse_DescKeyspaces_Keyspace) Reset()

func (*DescribeResponse_DescKeyspaces_Keyspace) String 

func (m *DescribeResponse_DescKeyspaces_Keyspace) String() string

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type GetByPrefixRequest 

type GetByPrefixRequest struct {
	Prefix      []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Limit       uint32 `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	LastSeenKey []byte `protobuf:"bytes,3,opt,name=last_seen_key,json=lastSeenKey,proto3" json:"last_seen_key,omitempty"`
}

func (*GetByPrefixRequest) Descriptor 

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

func (*GetByPrefixRequest) GetLastSeenKey 

func (m *GetByPrefixRequest) GetLastSeenKey() []byte

func (*GetByPrefixRequest) GetLimit 

func (m *GetByPrefixRequest) GetLimit() uint32

func (*GetByPrefixRequest) GetPrefix 

func (m *GetByPrefixRequest) GetPrefix() []byte

func (*GetByPrefixRequest) ProtoMessage 

func (*GetByPrefixRequest) ProtoMessage()

func (*GetByPrefixRequest) Reset 

func (m *GetByPrefixRequest) Reset()

func (*GetByPrefixRequest) String 

func (m *GetByPrefixRequest) String() string

type GetByPrefixResponse 

type GetByPrefixResponse struct {
	Ok        bool            `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
	Status    string          `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
	KeyValues []*KeyTypeValue `protobuf:"bytes,3,rep,name=key_values,json=keyValues" json:"key_values,omitempty"`
}

func (*GetByPrefixResponse) Descriptor 

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

func (*GetByPrefixResponse) GetKeyValues 

func (m *GetByPrefixResponse) GetKeyValues() []*KeyTypeValue

func (*GetByPrefixResponse) GetOk 

func (m *GetByPrefixResponse) GetOk() bool

func (*GetByPrefixResponse) GetStatus 

func (m *GetByPrefixResponse) GetStatus() string

func (*GetByPrefixResponse) ProtoMessage 

func (*GetByPrefixResponse) ProtoMessage()

func (*GetByPrefixResponse) Reset 

func (m *GetByPrefixResponse) Reset()

func (*GetByPrefixResponse) String 

func (m *GetByPrefixResponse) String() string

type GetRequest 

type GetRequest struct {
	Key           []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	PartitionHash uint64 `protobuf:"varint,2,opt,name=partition_hash,json=partitionHash" json:"partition_hash,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() []byte

func (*GetRequest) GetPartitionHash 

func (m *GetRequest) GetPartitionHash() uint64

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Ok       bool          `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
	Status   string        `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
	KeyValue *KeyTypeValue `protobuf:"bytes,3,opt,name=key_value,json=keyValue" json:"key_value,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetKeyValue 

func (m *GetResponse) GetKeyValue() *KeyTypeValue

func (*GetResponse) GetOk 

func (m *GetResponse) GetOk() bool

func (*GetResponse) GetStatus 

func (m *GetResponse) GetStatus() string

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

type KeyTypeValue 

type KeyTypeValue struct {
	Key           []byte        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	PartitionHash uint64        `protobuf:"varint,2,opt,name=partition_hash,json=partitionHash" json:"partition_hash,omitempty"`
	DataType      OpAndDataType `protobuf:"varint,3,opt,name=data_type,json=dataType,enum=pb.OpAndDataType" json:"data_type,omitempty"`
	Value         []byte        `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KeyTypeValue) Descriptor 

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

func (*KeyTypeValue) GetDataType 

func (m *KeyTypeValue) GetDataType() OpAndDataType

func (*KeyTypeValue) GetKey 

func (m *KeyTypeValue) GetKey() []byte

func (*KeyTypeValue) GetPartitionHash 

func (m *KeyTypeValue) GetPartitionHash() uint64

func (*KeyTypeValue) GetValue 

func (m *KeyTypeValue) GetValue() []byte

func (*KeyTypeValue) ProtoMessage 

func (*KeyTypeValue) ProtoMessage()

func (*KeyTypeValue) Reset 

func (m *KeyTypeValue) Reset()

func (*KeyTypeValue) String 

func (m *KeyTypeValue) String() string

type LocalShardsInCluster 

type LocalShardsInCluster struct {
	Id       uint32                `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	ShardMap map[uint32]*ShardInfo `` /* 153-byte string literal not displayed */
	// duplicated info, need to validate on master when reconvene
	ClusterSize uint32 `protobuf:"varint,3,opt,name=cluster_size,json=clusterSize" json:"cluster_size,omitempty"`
	// duplicated info, need to validate on master when reconvene
	ReplicationFactor uint32 `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor" json:"replication_factor,omitempty"`
}

LocalShardsInCluster is saved to and load from disk

func (*LocalShardsInCluster) Descriptor 

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

func (*LocalShardsInCluster) GetClusterSize 

func (m *LocalShardsInCluster) GetClusterSize() uint32

func (*LocalShardsInCluster) GetId 

func (m *LocalShardsInCluster) GetId() uint32

func (*LocalShardsInCluster) GetReplicationFactor 

func (m *LocalShardsInCluster) GetReplicationFactor() uint32

func (*LocalShardsInCluster) GetShardMap 

func (m *LocalShardsInCluster) GetShardMap() map[uint32]*ShardInfo

func (*LocalShardsInCluster) ProtoMessage 

func (*LocalShardsInCluster) ProtoMessage()

func (*LocalShardsInCluster) Reset 

func (m *LocalShardsInCluster) Reset()

func (*LocalShardsInCluster) String 

func (m *LocalShardsInCluster) String() string

type LogEntry 

type LogEntry struct {
	UpdatedAtNs uint64         `protobuf:"varint,1,opt,name=updated_at_ns,json=updatedAtNs" json:"updated_at_ns,omitempty"`
	Put         *PutRequest    `protobuf:"bytes,2,opt,name=put" json:"put,omitempty"`
	Delete      *DeleteRequest `protobuf:"bytes,3,opt,name=delete" json:"delete,omitempty"`
	Merge       *MergeRequest  `protobuf:"bytes,4,opt,name=merge" json:"merge,omitempty"`
}

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetDelete 

func (m *LogEntry) GetDelete() *DeleteRequest

func (*LogEntry) GetKey 

func (entry *LogEntry) GetKey() []byte

GetKey returns the key bytes

func (*LogEntry) GetMerge 

func (m *LogEntry) GetMerge() *MergeRequest

func (*LogEntry) GetPartitionHash 

func (entry *LogEntry) GetPartitionHash() uint64

GetPartitionHash returns the partition hash value

func (*LogEntry) GetPut 

func (m *LogEntry) GetPut() *PutRequest

func (*LogEntry) GetUpdatedAtNs 

func (m *LogEntry) GetUpdatedAtNs() uint64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) String 

func (m *LogEntry) String() string

type MergeRequest 

type MergeRequest struct {
	Key           []byte        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	PartitionHash uint64        `protobuf:"varint,2,opt,name=partition_hash,json=partitionHash" json:"partition_hash,omitempty"`
	UpdatedAtNs   uint64        `protobuf:"varint,3,opt,name=updated_at_ns,json=updatedAtNs" json:"updated_at_ns,omitempty"`
	OpAndDataType OpAndDataType `protobuf:"varint,4,opt,name=op_and_data_type,json=opAndDataType,enum=pb.OpAndDataType" json:"op_and_data_type,omitempty"`
	Value         []byte        `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
}

func (*MergeRequest) Descriptor 

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

func (*MergeRequest) GetKey 

func (m *MergeRequest) GetKey() []byte

func (*MergeRequest) GetOpAndDataType 

func (m *MergeRequest) GetOpAndDataType() OpAndDataType

func (*MergeRequest) GetPartitionHash 

func (m *MergeRequest) GetPartitionHash() uint64

func (*MergeRequest) GetUpdatedAtNs 

func (m *MergeRequest) GetUpdatedAtNs() uint64

func (*MergeRequest) GetValue 

func (m *MergeRequest) GetValue() []byte

func (*MergeRequest) ProtoMessage 

func (*MergeRequest) ProtoMessage()

func (*MergeRequest) Reset 

func (m *MergeRequest) Reset()

func (*MergeRequest) String 

func (m *MergeRequest) String() string

type OpAndDataType 

type OpAndDataType int32
const (
	OpAndDataType_BYTES       OpAndDataType = 0
	OpAndDataType_FLOAT64     OpAndDataType = 1
	OpAndDataType_MAX_FLOAT64 OpAndDataType = 2
	OpAndDataType_MIN_FLOAT64 OpAndDataType = 3
)

func (OpAndDataType) EnumDescriptor 

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

func (OpAndDataType) String 

func (x OpAndDataType) String() string

type PullUpdateRequest 

type PullUpdateRequest struct {
	Keyspace          string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	ShardId           uint32 `protobuf:"varint,2,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	Segment           uint32 `protobuf:"varint,3,opt,name=segment" json:"segment,omitempty"`
	Offset            uint64 `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
	Limit             uint32 `protobuf:"varint,5,opt,name=limit" json:"limit,omitempty"`
	TargetShardId     uint32 `protobuf:"varint,6,opt,name=target_shard_id,json=targetShardId" json:"target_shard_id,omitempty"`
	TargetClusterSize uint32 `protobuf:"varint,7,opt,name=target_cluster_size,json=targetClusterSize" json:"target_cluster_size,omitempty"`
	Origin            string `protobuf:"bytes,8,opt,name=origin" json:"origin,omitempty"`
}

func (*PullUpdateRequest) Descriptor 

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

func (*PullUpdateRequest) GetKeyspace 

func (m *PullUpdateRequest) GetKeyspace() string

func (*PullUpdateRequest) GetLimit 

func (m *PullUpdateRequest) GetLimit() uint32

func (*PullUpdateRequest) GetOffset 

func (m *PullUpdateRequest) GetOffset() uint64

func (*PullUpdateRequest) GetOrigin 

func (m *PullUpdateRequest) GetOrigin() string

func (*PullUpdateRequest) GetSegment 

func (m *PullUpdateRequest) GetSegment() uint32

func (*PullUpdateRequest) GetShardId 

func (m *PullUpdateRequest) GetShardId() uint32

func (*PullUpdateRequest) GetTargetClusterSize 

func (m *PullUpdateRequest) GetTargetClusterSize() uint32

func (*PullUpdateRequest) GetTargetShardId 

func (m *PullUpdateRequest) GetTargetShardId() uint32

func (*PullUpdateRequest) ProtoMessage 

func (*PullUpdateRequest) ProtoMessage()

func (*PullUpdateRequest) Reset 

func (m *PullUpdateRequest) Reset()

func (*PullUpdateRequest) String 

func (m *PullUpdateRequest) String() string

type PullUpdateResponse 

type PullUpdateResponse struct {
	NextSegment uint32      `protobuf:"varint,1,opt,name=next_segment,json=nextSegment" json:"next_segment,omitempty"`
	NextOffset  uint64      `protobuf:"varint,2,opt,name=next_offset,json=nextOffset" json:"next_offset,omitempty"`
	Entries     []*LogEntry `protobuf:"bytes,3,rep,name=entries" json:"entries,omitempty"`
	OutOfSync   bool        `protobuf:"varint,4,opt,name=out_of_sync,json=outOfSync" json:"out_of_sync,omitempty"`
}

func (*PullUpdateResponse) Descriptor 

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

func (*PullUpdateResponse) GetEntries 

func (m *PullUpdateResponse) GetEntries() []*LogEntry

func (*PullUpdateResponse) GetNextOffset 

func (m *PullUpdateResponse) GetNextOffset() uint64

func (*PullUpdateResponse) GetNextSegment 

func (m *PullUpdateResponse) GetNextSegment() uint32

func (*PullUpdateResponse) GetOutOfSync 

func (m *PullUpdateResponse) GetOutOfSync() bool

func (*PullUpdateResponse) ProtoMessage 

func (*PullUpdateResponse) ProtoMessage()

func (*PullUpdateResponse) Reset 

func (m *PullUpdateResponse) Reset()

func (*PullUpdateResponse) String 

func (m *PullUpdateResponse) String() string

type PutRequest 

type PutRequest struct {
	Key           []byte        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	PartitionHash uint64        `protobuf:"varint,2,opt,name=partition_hash,json=partitionHash" json:"partition_hash,omitempty"`
	UpdatedAtNs   uint64        `protobuf:"varint,3,opt,name=updated_at_ns,json=updatedAtNs" json:"updated_at_ns,omitempty"`
	TtlSecond     uint32        `protobuf:"varint,4,opt,name=ttl_second,json=ttlSecond" json:"ttl_second,omitempty"`
	OpAndDataType OpAndDataType `protobuf:"varint,5,opt,name=op_and_data_type,json=opAndDataType,enum=pb.OpAndDataType" json:"op_and_data_type,omitempty"`
	Value         []byte        `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetKey 

func (m *PutRequest) GetKey() []byte

func (*PutRequest) GetOpAndDataType 

func (m *PutRequest) GetOpAndDataType() OpAndDataType

func (*PutRequest) GetPartitionHash 

func (m *PutRequest) GetPartitionHash() uint64

func (*PutRequest) GetTtlSecond 

func (m *PutRequest) GetTtlSecond() uint32

func (*PutRequest) GetUpdatedAtNs 

func (m *PutRequest) GetUpdatedAtNs() uint64

func (*PutRequest) GetValue 

func (m *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

type RawKeyValue 

type RawKeyValue struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RawKeyValue) Descriptor 

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

func (*RawKeyValue) GetKey 

func (m *RawKeyValue) GetKey() []byte

func (*RawKeyValue) GetValue 

func (m *RawKeyValue) GetValue() []byte

func (*RawKeyValue) ProtoMessage 

func (*RawKeyValue) ProtoMessage()

func (*RawKeyValue) Reset 

func (m *RawKeyValue) Reset()

func (*RawKeyValue) String 

func (m *RawKeyValue) String() string

type ReplaceNodeRequest 

type ReplaceNodeRequest struct {
	Keyspace   string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
	NodeId     uint32 `protobuf:"varint,3,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	NewAddress string `protobuf:"bytes,4,opt,name=new_address,json=newAddress" json:"new_address,omitempty"`
}

func (*ReplaceNodeRequest) Descriptor 

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

func (*ReplaceNodeRequest) GetKeyspace 

func (m *ReplaceNodeRequest) GetKeyspace() string

func (*ReplaceNodeRequest) GetNewAddress 

func (m *ReplaceNodeRequest) GetNewAddress() string

func (*ReplaceNodeRequest) GetNodeId 

func (m *ReplaceNodeRequest) GetNodeId() uint32

func (*ReplaceNodeRequest) ProtoMessage 

func (*ReplaceNodeRequest) ProtoMessage()

func (*ReplaceNodeRequest) Reset 

func (m *ReplaceNodeRequest) Reset()

func (*ReplaceNodeRequest) String 

func (m *ReplaceNodeRequest) String() string

type ReplaceNodeResponse 

type ReplaceNodeResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ReplaceNodeResponse) Descriptor 

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

func (*ReplaceNodeResponse) GetError 

func (m *ReplaceNodeResponse) GetError() string

func (*ReplaceNodeResponse) ProtoMessage 

func (*ReplaceNodeResponse) ProtoMessage()

func (*ReplaceNodeResponse) Reset 

func (m *ReplaceNodeResponse) Reset()

func (*ReplaceNodeResponse) String 

func (m *ReplaceNodeResponse) String() string

type ReplicateNodeCleanupRequest 

type ReplicateNodeCleanupRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*ReplicateNodeCleanupRequest) Descriptor 

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

func (*ReplicateNodeCleanupRequest) GetKeyspace 

func (m *ReplicateNodeCleanupRequest) GetKeyspace() string

func (*ReplicateNodeCleanupRequest) ProtoMessage 

func (*ReplicateNodeCleanupRequest) ProtoMessage()

func (*ReplicateNodeCleanupRequest) Reset 

func (m *ReplicateNodeCleanupRequest) Reset()

func (*ReplicateNodeCleanupRequest) String 

func (m *ReplicateNodeCleanupRequest) String() string

type ReplicateNodeCleanupResponse 

type ReplicateNodeCleanupResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ReplicateNodeCleanupResponse) Descriptor 

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

func (*ReplicateNodeCleanupResponse) GetError 

func (m *ReplicateNodeCleanupResponse) GetError() string

func (*ReplicateNodeCleanupResponse) ProtoMessage 

func (*ReplicateNodeCleanupResponse) ProtoMessage()

func (*ReplicateNodeCleanupResponse) Reset 

func (m *ReplicateNodeCleanupResponse) Reset()

func (*ReplicateNodeCleanupResponse) String 

func (m *ReplicateNodeCleanupResponse) String() string

type ReplicateNodeCommitRequest 

type ReplicateNodeCommitRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
}

func (*ReplicateNodeCommitRequest) Descriptor 

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

func (*ReplicateNodeCommitRequest) GetKeyspace 

func (m *ReplicateNodeCommitRequest) GetKeyspace() string

func (*ReplicateNodeCommitRequest) ProtoMessage 

func (*ReplicateNodeCommitRequest) ProtoMessage()

func (*ReplicateNodeCommitRequest) Reset 

func (m *ReplicateNodeCommitRequest) Reset()

func (*ReplicateNodeCommitRequest) String 

func (m *ReplicateNodeCommitRequest) String() string

type ReplicateNodeCommitResponse 

type ReplicateNodeCommitResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ReplicateNodeCommitResponse) Descriptor 

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

func (*ReplicateNodeCommitResponse) GetError 

func (m *ReplicateNodeCommitResponse) GetError() string

func (*ReplicateNodeCommitResponse) ProtoMessage 

func (*ReplicateNodeCommitResponse) ProtoMessage()

func (*ReplicateNodeCommitResponse) Reset 

func (m *ReplicateNodeCommitResponse) Reset()

func (*ReplicateNodeCommitResponse) String 

func (m *ReplicateNodeCommitResponse) String() string

type ReplicateNodePrepareRequest 

type ReplicateNodePrepareRequest struct {
	Keyspace          string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	ServerId          uint32 `protobuf:"varint,2,opt,name=server_id,json=serverId" json:"server_id,omitempty"`
	ClusterSize       uint32 `protobuf:"varint,3,opt,name=cluster_size,json=clusterSize" json:"cluster_size,omitempty"`
	ReplicationFactor uint32 `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor" json:"replication_factor,omitempty"`
}

func (*ReplicateNodePrepareRequest) Descriptor 

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

func (*ReplicateNodePrepareRequest) GetClusterSize 

func (m *ReplicateNodePrepareRequest) GetClusterSize() uint32

func (*ReplicateNodePrepareRequest) GetKeyspace 

func (m *ReplicateNodePrepareRequest) GetKeyspace() string

func (*ReplicateNodePrepareRequest) GetReplicationFactor 

func (m *ReplicateNodePrepareRequest) GetReplicationFactor() uint32

func (*ReplicateNodePrepareRequest) GetServerId 

func (m *ReplicateNodePrepareRequest) GetServerId() uint32

func (*ReplicateNodePrepareRequest) ProtoMessage 

func (*ReplicateNodePrepareRequest) ProtoMessage()

func (*ReplicateNodePrepareRequest) Reset 

func (m *ReplicateNodePrepareRequest) Reset()

func (*ReplicateNodePrepareRequest) String 

func (m *ReplicateNodePrepareRequest) String() string

type ReplicateNodePrepareResponse 

type ReplicateNodePrepareResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ReplicateNodePrepareResponse) Descriptor 

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

func (*ReplicateNodePrepareResponse) GetError 

func (m *ReplicateNodePrepareResponse) GetError() string

func (*ReplicateNodePrepareResponse) ProtoMessage 

func (*ReplicateNodePrepareResponse) ProtoMessage()

func (*ReplicateNodePrepareResponse) Reset 

func (m *ReplicateNodePrepareResponse) Reset()

func (*ReplicateNodePrepareResponse) String 

func (m *ReplicateNodePrepareResponse) String() string

type Request 

type Request struct {
	ShardId     uint32              `protobuf:"varint,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	Put         *PutRequest         `protobuf:"bytes,2,opt,name=put" json:"put,omitempty"`
	Get         *GetRequest         `protobuf:"bytes,3,opt,name=get" json:"get,omitempty"`
	GetByPrefix *GetByPrefixRequest `protobuf:"bytes,4,opt,name=get_by_prefix,json=getByPrefix" json:"get_by_prefix,omitempty"`
	Delete      *DeleteRequest      `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"`
	Merge       *MergeRequest       `protobuf:"bytes,6,opt,name=merge" json:"merge,omitempty"`
}

func (*Request) Descriptor 

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

func (*Request) GetDelete 

func (m *Request) GetDelete() *DeleteRequest

func (*Request) GetGet 

func (m *Request) GetGet() *GetRequest

func (*Request) GetGetByPrefix 

func (m *Request) GetGetByPrefix() *GetByPrefixRequest

func (*Request) GetMerge 

func (m *Request) GetMerge() *MergeRequest

func (*Request) GetPartitionHash 

func (r *Request) GetPartitionHash() uint64

GetPartitionHash returns the partition hash of Get, Put, Delete, and Merge requests

func (*Request) GetPut 

func (m *Request) GetPut() *PutRequest

func (*Request) GetShardId 

func (m *Request) GetShardId() uint32

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

type Requests 

type Requests struct {
	Keyspace string     `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	Requests []*Request `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"`
}

//////////////////////////////////////////////// // data queries ////////////////////////////////////////////////

func (*Requests) Descriptor 

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

func (*Requests) GetKeyspace 

func (m *Requests) GetKeyspace() string

func (*Requests) GetRequests 

func (m *Requests) GetRequests() []*Request

func (*Requests) ProtoMessage 

func (*Requests) ProtoMessage()

func (*Requests) Reset 

func (m *Requests) Reset()

func (*Requests) String 

func (m *Requests) String() string

type ResizeCleanupRequest 

type ResizeCleanupRequest struct {
	Keyspace          string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	TargetClusterSize uint32 `protobuf:"varint,2,opt,name=target_cluster_size,json=targetClusterSize" json:"target_cluster_size,omitempty"`
}

func (*ResizeCleanupRequest) Descriptor 

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

func (*ResizeCleanupRequest) GetKeyspace 

func (m *ResizeCleanupRequest) GetKeyspace() string

func (*ResizeCleanupRequest) GetTargetClusterSize 

func (m *ResizeCleanupRequest) GetTargetClusterSize() uint32

func (*ResizeCleanupRequest) ProtoMessage 

func (*ResizeCleanupRequest) ProtoMessage()

func (*ResizeCleanupRequest) Reset 

func (m *ResizeCleanupRequest) Reset()

func (*ResizeCleanupRequest) String 

func (m *ResizeCleanupRequest) String() string

type ResizeCleanupResponse 

type ResizeCleanupResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ResizeCleanupResponse) Descriptor 

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

func (*ResizeCleanupResponse) GetError 

func (m *ResizeCleanupResponse) GetError() string

func (*ResizeCleanupResponse) ProtoMessage 

func (*ResizeCleanupResponse) ProtoMessage()

func (*ResizeCleanupResponse) Reset 

func (m *ResizeCleanupResponse) Reset()

func (*ResizeCleanupResponse) String 

func (m *ResizeCleanupResponse) String() string

type ResizeCommitRequest 

type ResizeCommitRequest struct {
	Keyspace          string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	TargetClusterSize uint32 `protobuf:"varint,2,opt,name=target_cluster_size,json=targetClusterSize" json:"target_cluster_size,omitempty"`
}

func (*ResizeCommitRequest) Descriptor 

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

func (*ResizeCommitRequest) GetKeyspace 

func (m *ResizeCommitRequest) GetKeyspace() string

func (*ResizeCommitRequest) GetTargetClusterSize 

func (m *ResizeCommitRequest) GetTargetClusterSize() uint32

func (*ResizeCommitRequest) ProtoMessage 

func (*ResizeCommitRequest) ProtoMessage()

func (*ResizeCommitRequest) Reset 

func (m *ResizeCommitRequest) Reset()

func (*ResizeCommitRequest) String 

func (m *ResizeCommitRequest) String() string

type ResizeCommitResponse 

type ResizeCommitResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ResizeCommitResponse) Descriptor 

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

func (*ResizeCommitResponse) GetError 

func (m *ResizeCommitResponse) GetError() string

func (*ResizeCommitResponse) ProtoMessage 

func (*ResizeCommitResponse) ProtoMessage()

func (*ResizeCommitResponse) Reset 

func (m *ResizeCommitResponse) Reset()

func (*ResizeCommitResponse) String 

func (m *ResizeCommitResponse) String() string

type ResizeCreateShardRequest 

type ResizeCreateShardRequest struct {
	Keyspace          string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	ServerId          uint32 `protobuf:"varint,2,opt,name=server_id,json=serverId" json:"server_id,omitempty"`
	ClusterSize       uint32 `protobuf:"varint,3,opt,name=cluster_size,json=clusterSize" json:"cluster_size,omitempty"`
	ReplicationFactor uint32 `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor" json:"replication_factor,omitempty"`
	TargetClusterSize uint32 `protobuf:"varint,5,opt,name=target_cluster_size,json=targetClusterSize" json:"target_cluster_size,omitempty"`
}

func (*ResizeCreateShardRequest) Descriptor 

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

func (*ResizeCreateShardRequest) GetClusterSize 

func (m *ResizeCreateShardRequest) GetClusterSize() uint32

func (*ResizeCreateShardRequest) GetKeyspace 

func (m *ResizeCreateShardRequest) GetKeyspace() string

func (*ResizeCreateShardRequest) GetReplicationFactor 

func (m *ResizeCreateShardRequest) GetReplicationFactor() uint32

func (*ResizeCreateShardRequest) GetServerId 

func (m *ResizeCreateShardRequest) GetServerId() uint32

func (*ResizeCreateShardRequest) GetTargetClusterSize 

func (m *ResizeCreateShardRequest) GetTargetClusterSize() uint32

func (*ResizeCreateShardRequest) ProtoMessage 

func (*ResizeCreateShardRequest) ProtoMessage()

func (*ResizeCreateShardRequest) Reset 

func (m *ResizeCreateShardRequest) Reset()

func (*ResizeCreateShardRequest) String 

func (m *ResizeCreateShardRequest) String() string

type ResizeCreateShardResponse 

type ResizeCreateShardResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ResizeCreateShardResponse) Descriptor 

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

func (*ResizeCreateShardResponse) GetError 

func (m *ResizeCreateShardResponse) GetError() string

func (*ResizeCreateShardResponse) ProtoMessage 

func (*ResizeCreateShardResponse) ProtoMessage()

func (*ResizeCreateShardResponse) Reset 

func (m *ResizeCreateShardResponse) Reset()

func (*ResizeCreateShardResponse) String 

func (m *ResizeCreateShardResponse) String() string

type ResizeRequest 

type ResizeRequest struct {
	Keyspace          string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
	TargetClusterSize uint32 `protobuf:"varint,3,opt,name=target_cluster_size,json=targetClusterSize" json:"target_cluster_size,omitempty"`
}

func (*ResizeRequest) Descriptor 

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

func (*ResizeRequest) GetKeyspace 

func (m *ResizeRequest) GetKeyspace() string

func (*ResizeRequest) GetTargetClusterSize 

func (m *ResizeRequest) GetTargetClusterSize() uint32

func (*ResizeRequest) ProtoMessage 

func (*ResizeRequest) ProtoMessage()

func (*ResizeRequest) Reset 

func (m *ResizeRequest) Reset()

func (*ResizeRequest) String 

func (m *ResizeRequest) String() string

type ResizeResponse 

type ResizeResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ResizeResponse) Descriptor 

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

func (*ResizeResponse) GetError 

func (m *ResizeResponse) GetError() string

func (*ResizeResponse) ProtoMessage 

func (*ResizeResponse) ProtoMessage()

func (*ResizeResponse) Reset 

func (m *ResizeResponse) Reset()

func (*ResizeResponse) String 

func (m *ResizeResponse) String() string

type Response 

type Response struct {
	Write       *WriteResponse       `protobuf:"bytes,1,opt,name=write" json:"write,omitempty"`
	Get         *GetResponse         `protobuf:"bytes,2,opt,name=get" json:"get,omitempty"`
	GetByPrefix *GetByPrefixResponse `protobuf:"bytes,3,opt,name=get_by_prefix,json=getByPrefix" json:"get_by_prefix,omitempty"`
}

func (*Response) Descriptor 

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

func (*Response) GetGet 

func (m *Response) GetGet() *GetResponse

func (*Response) GetGetByPrefix 

func (m *Response) GetGetByPrefix() *GetByPrefixResponse

func (*Response) GetWrite 

func (m *Response) GetWrite() *WriteResponse

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

type Responses 

type Responses struct {
	Responses []*Response `protobuf:"bytes,1,rep,name=responses" json:"responses,omitempty"`
}

func SendRequests 

func SendRequests(conn io.ReadWriter, requests *Requests) (*Responses, error)

SendRequests sends requests by the connection

func (*Responses) Descriptor 

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

func (*Responses) GetResponses 

func (m *Responses) GetResponses() []*Response

func (*Responses) ProtoMessage 

func (*Responses) ProtoMessage()

func (*Responses) Reset 

func (m *Responses) Reset()

func (*Responses) String 

func (m *Responses) String() string

type ShardInfo 

type ShardInfo struct {
	KeyspaceName      string           `protobuf:"bytes,1,opt,name=keyspace_name,json=keyspaceName" json:"keyspace_name,omitempty"`
	ServerId          uint32           `protobuf:"varint,2,opt,name=server_id,json=serverId" json:"server_id,omitempty"`
	ShardId           uint32           `protobuf:"varint,3,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	ClusterSize       uint32           `protobuf:"varint,4,opt,name=cluster_size,json=clusterSize" json:"cluster_size,omitempty"`
	ReplicationFactor uint32           `protobuf:"varint,5,opt,name=replication_factor,json=replicationFactor" json:"replication_factor,omitempty"`
	Status            ShardInfo_Status `protobuf:"varint,6,opt,name=status,enum=pb.ShardInfo_Status" json:"status,omitempty"`
	IsCandidate       bool             `protobuf:"varint,7,opt,name=is_candidate,json=isCandidate" json:"is_candidate,omitempty"`
	IsPermanentDelete bool             `protobuf:"varint,8,opt,name=is_permanent_delete,json=isPermanentDelete" json:"is_permanent_delete,omitempty"`
}

func (*ShardInfo) Clone 

func (s *ShardInfo) Clone() *ShardInfo

Clone creates a new copy of ShardInfo

func (*ShardInfo) Descriptor 

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

func (*ShardInfo) GetClusterSize 

func (m *ShardInfo) GetClusterSize() uint32

func (*ShardInfo) GetIsCandidate 

func (m *ShardInfo) GetIsCandidate() bool

func (*ShardInfo) GetIsPermanentDelete 

func (m *ShardInfo) GetIsPermanentDelete() bool

func (*ShardInfo) GetKeyspaceName 

func (m *ShardInfo) GetKeyspaceName() string

func (*ShardInfo) GetReplicationFactor 

func (m *ShardInfo) GetReplicationFactor() uint32

func (*ShardInfo) GetServerId 

func (m *ShardInfo) GetServerId() uint32

func (*ShardInfo) GetShardId 

func (m *ShardInfo) GetShardId() uint32

func (*ShardInfo) GetStatus 

func (m *ShardInfo) GetStatus() ShardInfo_Status

func (*ShardInfo) IdentifierOnThisServer 

func (s *ShardInfo) IdentifierOnThisServer() string

IdentifierOnThisServer prints out the keyspace_name.server_id.shard_id

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) Reset 

func (m *ShardInfo) Reset()

func (*ShardInfo) String 

func (m *ShardInfo) String() string

type ShardInfo_Status 

type ShardInfo_Status int32
const (
	ShardInfo_EMPTY     ShardInfo_Status = 0
	ShardInfo_BOOTSTRAP ShardInfo_Status = 1
	ShardInfo_READY     ShardInfo_Status = 2
	ShardInfo_DELETED   ShardInfo_Status = 3
)

func (ShardInfo_Status) EnumDescriptor 

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

func (ShardInfo_Status) String 

func (x ShardInfo_Status) String() string

type StoreHeartbeat 

type StoreHeartbeat struct {
	// only in the initial heartbeat
	StoreResource *StoreResource `protobuf:"bytes,1,opt,name=store_resource,json=storeResource" json:"store_resource,omitempty"`
	// sent to master one at a time, after the initial heartbeat
	ShardInfo *ShardInfo `protobuf:"bytes,2,opt,name=ShardInfo" json:"ShardInfo,omitempty"`
}

func (*StoreHeartbeat) Descriptor 

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

func (*StoreHeartbeat) GetShardInfo 

func (m *StoreHeartbeat) GetShardInfo() *ShardInfo

func (*StoreHeartbeat) GetStoreResource 

func (m *StoreHeartbeat) GetStoreResource() *StoreResource

func (*StoreHeartbeat) ProtoMessage 

func (*StoreHeartbeat) ProtoMessage()

func (*StoreHeartbeat) Reset 

func (m *StoreHeartbeat) Reset()

func (*StoreHeartbeat) String 

func (m *StoreHeartbeat) String() string

type StoreMessage 

type StoreMessage struct {
}

func (*StoreMessage) Descriptor 

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

func (*StoreMessage) ProtoMessage 

func (*StoreMessage) ProtoMessage()

func (*StoreMessage) Reset 

func (m *StoreMessage) Reset()

func (*StoreMessage) String 

func (m *StoreMessage) String() string

type StoreResource 

type StoreResource struct {
	Network         string   `protobuf:"bytes,2,opt,name=network" json:"network,omitempty"`
	Address         string   `protobuf:"bytes,3,opt,name=address" json:"address,omitempty"`
	AdminAddress    string   `protobuf:"bytes,4,opt,name=admin_address,json=adminAddress" json:"admin_address,omitempty"`
	Tags            []string `protobuf:"bytes,7,rep,name=tags" json:"tags,omitempty"`
	DiskSizeGb      uint32   `protobuf:"varint,8,opt,name=disk_size_gb,json=diskSizeGb" json:"disk_size_gb,omitempty"`
	AllocatedSizeGb uint32   `protobuf:"varint,9,opt,name=allocated_size_gb,json=allocatedSizeGb" json:"allocated_size_gb,omitempty"`
}

func (*StoreResource) Descriptor 

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

func (*StoreResource) GetAddress 

func (m *StoreResource) GetAddress() string

func (*StoreResource) GetAdminAddress 

func (m *StoreResource) GetAdminAddress() string

func (*StoreResource) GetAllocatedSizeGb 

func (m *StoreResource) GetAllocatedSizeGb() uint32

func (*StoreResource) GetDiskSizeGb 

func (m *StoreResource) GetDiskSizeGb() uint32

func (*StoreResource) GetNetwork 

func (m *StoreResource) GetNetwork() string

func (*StoreResource) GetTags 

func (m *StoreResource) GetTags() []string

func (*StoreResource) ProtoMessage 

func (*StoreResource) ProtoMessage()

func (*StoreResource) Reset 

func (m *StoreResource) Reset()

func (*StoreResource) String 

func (m *StoreResource) String() string

type VastoMasterClient 

type VastoMasterClient interface {
	RegisterStore(ctx context.Context, opts ...grpc.CallOption) (VastoMaster_RegisterStoreClient, error)
	RegisterClient(ctx context.Context, opts ...grpc.CallOption) (VastoMaster_RegisterClientClient, error)
	Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeResponse, error)
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*CreateClusterResponse, error)
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*DeleteClusterResponse, error)
	CompactCluster(ctx context.Context, in *CompactClusterRequest, opts ...grpc.CallOption) (*CompactClusterResponse, error)
	ResizeCluster(ctx context.Context, in *ResizeRequest, opts ...grpc.CallOption) (*ResizeResponse, error)
	ReplaceNode(ctx context.Context, in *ReplaceNodeRequest, opts ...grpc.CallOption) (*ReplaceNodeResponse, error)
	DebugMaster(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

func NewVastoMasterClient 

func NewVastoMasterClient(cc *grpc.ClientConn) VastoMasterClient

type VastoMasterServer 

type VastoMasterServer interface {
	RegisterStore(VastoMaster_RegisterStoreServer) error
	RegisterClient(VastoMaster_RegisterClientServer) error
	Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
	CreateCluster(context.Context, *CreateClusterRequest) (*CreateClusterResponse, error)
	DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)
	CompactCluster(context.Context, *CompactClusterRequest) (*CompactClusterResponse, error)
	ResizeCluster(context.Context, *ResizeRequest) (*ResizeResponse, error)
	ReplaceNode(context.Context, *ReplaceNodeRequest) (*ReplaceNodeResponse, error)
	DebugMaster(context.Context, *Empty) (*Empty, error)
}

type VastoMaster_RegisterClientClient 

type VastoMaster_RegisterClientClient interface {
	Send(*ClientHeartbeat) error
	Recv() (*ClientMessage, error)
	grpc.ClientStream
}

type VastoMaster_RegisterClientServer 

type VastoMaster_RegisterClientServer interface {
	Send(*ClientMessage) error
	Recv() (*ClientHeartbeat, error)
	grpc.ServerStream
}

type VastoMaster_RegisterStoreClient 

type VastoMaster_RegisterStoreClient interface {
	Send(*StoreHeartbeat) error
	Recv() (*StoreMessage, error)
	grpc.ClientStream
}

type VastoMaster_RegisterStoreServer 

type VastoMaster_RegisterStoreServer interface {
	Send(*StoreMessage) error
	Recv() (*StoreHeartbeat, error)
	grpc.ServerStream
}

type VastoStoreClient 

type VastoStoreClient interface {
	BootstrapCopy(ctx context.Context, in *BootstrapCopyRequest, opts ...grpc.CallOption) (VastoStore_BootstrapCopyClient, error)
	TailBinlog(ctx context.Context, in *PullUpdateRequest, opts ...grpc.CallOption) (VastoStore_TailBinlogClient, error)
	CheckBinlog(ctx context.Context, in *CheckBinlogRequest, opts ...grpc.CallOption) (*CheckBinlogResponse, error)
	CreateShard(ctx context.Context, in *CreateShardRequest, opts ...grpc.CallOption) (*CreateShardResponse, error)
	DeleteKeyspace(ctx context.Context, in *DeleteKeyspaceRequest, opts ...grpc.CallOption) (*DeleteKeyspaceResponse, error)
	CompactKeyspace(ctx context.Context, in *CompactKeyspaceRequest, opts ...grpc.CallOption) (*CompactKeyspaceResponse, error)
	ReplicateNodePrepare(ctx context.Context, in *ReplicateNodePrepareRequest, opts ...grpc.CallOption) (*ReplicateNodePrepareResponse, error)
	ReplicateNodeCommit(ctx context.Context, in *ReplicateNodeCommitRequest, opts ...grpc.CallOption) (*ReplicateNodeCommitResponse, error)
	ReplicateNodeCleanup(ctx context.Context, in *ReplicateNodeCleanupRequest, opts ...grpc.CallOption) (*ReplicateNodeCleanupResponse, error)
	ResizePrepare(ctx context.Context, in *ResizeCreateShardRequest, opts ...grpc.CallOption) (*ResizeCreateShardResponse, error)
	ResizeCommit(ctx context.Context, in *ResizeCommitRequest, opts ...grpc.CallOption) (*ResizeCommitResponse, error)
	ResizeCleanup(ctx context.Context, in *ResizeCleanupRequest, opts ...grpc.CallOption) (*ResizeCleanupResponse, error)
	DebugStore(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

func NewVastoStoreClient 

func NewVastoStoreClient(cc *grpc.ClientConn) VastoStoreClient

type VastoStoreServer 

type VastoStoreServer interface {
	BootstrapCopy(*BootstrapCopyRequest, VastoStore_BootstrapCopyServer) error
	TailBinlog(*PullUpdateRequest, VastoStore_TailBinlogServer) error
	CheckBinlog(context.Context, *CheckBinlogRequest) (*CheckBinlogResponse, error)
	CreateShard(context.Context, *CreateShardRequest) (*CreateShardResponse, error)
	DeleteKeyspace(context.Context, *DeleteKeyspaceRequest) (*DeleteKeyspaceResponse, error)
	CompactKeyspace(context.Context, *CompactKeyspaceRequest) (*CompactKeyspaceResponse, error)
	ReplicateNodePrepare(context.Context, *ReplicateNodePrepareRequest) (*ReplicateNodePrepareResponse, error)
	ReplicateNodeCommit(context.Context, *ReplicateNodeCommitRequest) (*ReplicateNodeCommitResponse, error)
	ReplicateNodeCleanup(context.Context, *ReplicateNodeCleanupRequest) (*ReplicateNodeCleanupResponse, error)
	ResizePrepare(context.Context, *ResizeCreateShardRequest) (*ResizeCreateShardResponse, error)
	ResizeCommit(context.Context, *ResizeCommitRequest) (*ResizeCommitResponse, error)
	ResizeCleanup(context.Context, *ResizeCleanupRequest) (*ResizeCleanupResponse, error)
	DebugStore(context.Context, *Empty) (*Empty, error)
}

type VastoStore_BootstrapCopyClient 

type VastoStore_BootstrapCopyClient interface {
	Recv() (*BootstrapCopyResponse, error)
	grpc.ClientStream
}

type VastoStore_BootstrapCopyServer 

type VastoStore_BootstrapCopyServer interface {
	Send(*BootstrapCopyResponse) error
	grpc.ServerStream
}

type VastoStore_TailBinlogClient 

type VastoStore_TailBinlogClient interface {
	Recv() (*PullUpdateResponse, error)
	grpc.ClientStream
}

type VastoStore_TailBinlogServer 

type VastoStore_TailBinlogServer interface {
	Send(*PullUpdateResponse) error
	grpc.ServerStream
}

type WriteResponse 

type WriteResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
	Status string `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) GetOk 

func (m *WriteResponse) GetOk() bool

func (*WriteResponse) GetStatus 

func (m *WriteResponse) GetStatus() string

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) String 

func (m *WriteResponse) String() string

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.