Help us shape the future of Go! Take the 2026 Go Developer Survey

voldemort

package module
v0.0.0-...-900e4f1 Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2017 License: Apache-2.0 Imports: 3 Imported by: 1

README

go-voldemort-protobufs

Protocol buffer bindings for current Voldemort version 1.6.0

Details

These bindings were generated with the Protocol buffers https://code.google.com/p/protobuf/ There's a good guide about them here - https://developers.google.com/protocol-buffers/docs/overview

To create these for yourself

  1. Install protocol buffers - see link below
  2. Download current Voldemort code - see link below
  3. Using the .proto files under src/ generate the language specific bindings using
$ protoc --go_out=. *.proto
  1. Include these files in your Go program
$ go get github.com/matzhouse/go-voldemort-protobufs

package main

import (
    "github.com/matzhouse/go-voldemort-protobufs"
    )

I'll link to some example code at some point in the future when I have it sorted.

Questions?

Find me on twitter, and ask me a question :)

@mattalkingshit

Project Voldemort http://www.project-voldemort.com/

Protocol Buffers https://code.google.com/p/protobuf/

Go Protocol Buffers https://code.google.com/p/goprotobuf/

Documentation

Overview

Package voldemort is a generated protocol buffer package.

It is generated from these files: 

slop.proto
voldemort-admin.proto
voldemort-client.proto

It has these top-level messages: 

Slop
GetMetadataRequest
GetMetadataResponse
UpdateMetadataRequest
UpdateStoreDefinitions
UpdateMetadataPairRequest
UpdateMetadataPairResponse
UpdateMetadataResponse
FileEntry
PartitionEntry
UpdatePartitionEntriesRequest
UpdatePartitionEntriesResponse
VoldemortFilter
UpdateSlopEntriesRequest
UpdateSlopEntriesResponse
FetchPartitionFilesRequest
FetchPartitionEntriesRequest
FetchPartitionEntriesResponse
DeletePartitionEntriesRequest
DeletePartitionEntriesResponse
InitiateFetchAndUpdateRequest
AsyncOperationStatusRequest
AsyncOperationStatusResponse
AsyncOperationStopRequest
AsyncOperationStopResponse
AsyncOperationListRequest
AsyncOperationListResponse
ListScheduledJobsRequest
ListScheduledJobsResponse
GetScheduledJobStatusRequest
GetScheduledJobStatusResponse
StopScheduledJobRequest
StopScheduledJobResponse
EnableScheduledJobRequest
EnableScheduledJobResponse
PartitionTuple
PerStorePartitionTuple
RebalancePartitionInfoMap
StoreToPartitionsIds
RebalanceTaskInfoMap
InitiateRebalanceNodeRequest
InitiateRebalanceNodeOnDonorRequest
TruncateEntriesRequest
TruncateEntriesResponse
AddStoreRequest
AddStoreResponse
DeleteStoreRequest
DeleteStoreResponse
FetchStoreRequest
SwapStoreRequest
SwapStoreResponse
RollbackStoreRequest
RollbackStoreResponse
RepairJobRequest
RepairJobResponse
PruneJobRequest
PruneJobResponse
SlopPurgeJobRequest
SlopPurgeJobResponse
ROStoreVersionDirMap
GetROMaxVersionDirRequest
GetROMaxVersionDirResponse
GetROCurrentVersionDirRequest
GetROCurrentVersionDirResponse
GetROStorageFormatRequest
GetROStorageFormatResponse
GetROStorageFileListRequest
GetROStorageFileListResponse
GetROStorageCompressionCodecListRequest
GetROStorageCompressionCodecListResponse
FailedFetchStoreRequest
FailedFetchStoreResponse
RebalanceStateChangeRequest
RebalanceStateChangeResponse
DeleteStoreRebalanceStateRequest
DeleteStoreRebalanceStateResponse
SetOfflineStateRequest
SetOfflineStateResponse
NativeBackupRequest
ReserveMemoryRequest
ReserveMemoryResponse
GetHighAvailabilitySettingsRequest
GetHighAvailabilitySettingsResponse
DisableStoreVersionRequest
DisableStoreVersionResponse
HandleFetchFailureRequest
HandleFetchFailureResponse
GetConfigRequest
GetConfigResponse
MapFieldEntry
VoldemortAdminRequest
ClockEntry
VectorClock
Versioned
Error
KeyedVersions
GetRequest
GetResponse
GetVersionResponse
GetAllRequest
GetAllResponse
PutRequest
PutResponse
DeleteRequest
DeleteResponse
VoldemortRequest

Index

Constants

View Source 
const Default_VoldemortRequest_ShouldRoute bool = false

Variables

View Source 
var AdminRequestType_name = map[int32]string{
	0:  "GET_METADATA",
	1:  "UPDATE_METADATA",
	2:  "UPDATE_PARTITION_ENTRIES",
	3:  "FETCH_PARTITION_ENTRIES",
	4:  "DELETE_PARTITION_ENTRIES",
	5:  "INITIATE_FETCH_AND_UPDATE",
	6:  "ASYNC_OPERATION_STATUS",
	7:  "INITIATE_REBALANCE_NODE",
	8:  "ASYNC_OPERATION_STOP",
	9:  "ASYNC_OPERATION_LIST",
	10: "TRUNCATE_ENTRIES",
	11: "ADD_STORE",
	12: "DELETE_STORE",
	13: "FETCH_STORE",
	14: "SWAP_STORE",
	15: "ROLLBACK_STORE",
	16: "GET_RO_MAX_VERSION_DIR",
	17: "GET_RO_CURRENT_VERSION_DIR",
	18: "FETCH_PARTITION_FILES",
	20: "UPDATE_SLOP_ENTRIES",
	22: "FAILED_FETCH_STORE",
	23: "GET_RO_STORAGE_FORMAT",
	24: "REBALANCE_STATE_CHANGE",
	25: "REPAIR_JOB",
	27: "DELETE_STORE_REBALANCE_STATE",
	28: "NATIVE_BACKUP",
	29: "RESERVE_MEMORY",
	30: "PRUNE_JOB",
	31: "SLOP_PURGE_JOB",
	32: "UPDATE_METADATA_PAIR",
	33: "UPDATE_STORE_DEFINITIONS",
	34: "SET_OFFLINE_STATE",
	35: "GET_RO_STORAGE_FILE_LIST",
	36: "GET_RO_COMPRESSION_CODEC_LIST",
	37: "LIST_SCHEDULED_JOBS",
	38: "GET_SCHEDULED_JOB_STATUS",
	39: "STOP_SCHEDULED_JOB",
	40: "ENABLE_SCHEDULED_JOB",
	41: "GET_HA_SETTINGS",
	42: "DISABLE_STORE_VERSION",
	43: "HANDLE_FETCH_FAILURE",
	44: "GET_CONFIG",
}
View Source 
var AdminRequestType_value = map[string]int32{
	"GET_METADATA":                  0,
	"UPDATE_METADATA":               1,
	"UPDATE_PARTITION_ENTRIES":      2,
	"FETCH_PARTITION_ENTRIES":       3,
	"DELETE_PARTITION_ENTRIES":      4,
	"INITIATE_FETCH_AND_UPDATE":     5,
	"ASYNC_OPERATION_STATUS":        6,
	"INITIATE_REBALANCE_NODE":       7,
	"ASYNC_OPERATION_STOP":          8,
	"ASYNC_OPERATION_LIST":          9,
	"TRUNCATE_ENTRIES":              10,
	"ADD_STORE":                     11,
	"DELETE_STORE":                  12,
	"FETCH_STORE":                   13,
	"SWAP_STORE":                    14,
	"ROLLBACK_STORE":                15,
	"GET_RO_MAX_VERSION_DIR":        16,
	"GET_RO_CURRENT_VERSION_DIR":    17,
	"FETCH_PARTITION_FILES":         18,
	"UPDATE_SLOP_ENTRIES":           20,
	"FAILED_FETCH_STORE":            22,
	"GET_RO_STORAGE_FORMAT":         23,
	"REBALANCE_STATE_CHANGE":        24,
	"REPAIR_JOB":                    25,
	"DELETE_STORE_REBALANCE_STATE":  27,
	"NATIVE_BACKUP":                 28,
	"RESERVE_MEMORY":                29,
	"PRUNE_JOB":                     30,
	"SLOP_PURGE_JOB":                31,
	"UPDATE_METADATA_PAIR":          32,
	"UPDATE_STORE_DEFINITIONS":      33,
	"SET_OFFLINE_STATE":             34,
	"GET_RO_STORAGE_FILE_LIST":      35,
	"GET_RO_COMPRESSION_CODEC_LIST": 36,
	"LIST_SCHEDULED_JOBS":           37,
	"GET_SCHEDULED_JOB_STATUS":      38,
	"STOP_SCHEDULED_JOB":            39,
	"ENABLE_SCHEDULED_JOB":          40,
	"GET_HA_SETTINGS":               41,
	"DISABLE_STORE_VERSION":         42,
	"HANDLE_FETCH_FAILURE":          43,
	"GET_CONFIG":                    44,
}
View Source 
var RequestType_name = map[int32]string{
	0: "GET",
	1: "GET_ALL",
	2: "PUT",
	3: "DELETE",
	4: "GET_VERSION",
}
View Source 
var RequestType_value = map[string]int32{
	"GET":         0,
	"GET_ALL":     1,
	"PUT":         2,
	"DELETE":      3,
	"GET_VERSION": 4,
}

Functions

This section is empty.

Types

type AddStoreRequest 

type AddStoreRequest struct {
	StoreDefinition  *string `protobuf:"bytes,1,req,name=storeDefinition" json:"storeDefinition,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AddStoreRequest) Descriptor 

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

func (*AddStoreRequest) GetStoreDefinition 

func (m *AddStoreRequest) GetStoreDefinition() string

func (*AddStoreRequest) ProtoMessage 

func (*AddStoreRequest) ProtoMessage()

func (*AddStoreRequest) Reset 

func (m *AddStoreRequest) Reset()

func (*AddStoreRequest) String 

func (m *AddStoreRequest) String() string

type AddStoreResponse 

type AddStoreResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AddStoreResponse) Descriptor 

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

func (*AddStoreResponse) GetError 

func (m *AddStoreResponse) GetError() *Error

func (*AddStoreResponse) ProtoMessage 

func (*AddStoreResponse) ProtoMessage()

func (*AddStoreResponse) Reset 

func (m *AddStoreResponse) Reset()

func (*AddStoreResponse) String 

func (m *AddStoreResponse) String() string

type AdminRequestType 

type AdminRequestType int32
const (
	AdminRequestType_GET_METADATA               AdminRequestType = 0
	AdminRequestType_UPDATE_METADATA            AdminRequestType = 1
	AdminRequestType_UPDATE_PARTITION_ENTRIES   AdminRequestType = 2
	AdminRequestType_FETCH_PARTITION_ENTRIES    AdminRequestType = 3
	AdminRequestType_DELETE_PARTITION_ENTRIES   AdminRequestType = 4
	AdminRequestType_INITIATE_FETCH_AND_UPDATE  AdminRequestType = 5
	AdminRequestType_ASYNC_OPERATION_STATUS     AdminRequestType = 6
	AdminRequestType_INITIATE_REBALANCE_NODE    AdminRequestType = 7
	AdminRequestType_ASYNC_OPERATION_STOP       AdminRequestType = 8
	AdminRequestType_ASYNC_OPERATION_LIST       AdminRequestType = 9
	AdminRequestType_TRUNCATE_ENTRIES           AdminRequestType = 10
	AdminRequestType_ADD_STORE                  AdminRequestType = 11
	AdminRequestType_DELETE_STORE               AdminRequestType = 12
	AdminRequestType_FETCH_STORE                AdminRequestType = 13
	AdminRequestType_SWAP_STORE                 AdminRequestType = 14
	AdminRequestType_ROLLBACK_STORE             AdminRequestType = 15
	AdminRequestType_GET_RO_MAX_VERSION_DIR     AdminRequestType = 16
	AdminRequestType_GET_RO_CURRENT_VERSION_DIR AdminRequestType = 17
	AdminRequestType_FETCH_PARTITION_FILES      AdminRequestType = 18
	AdminRequestType_UPDATE_SLOP_ENTRIES        AdminRequestType = 20
	AdminRequestType_FAILED_FETCH_STORE         AdminRequestType = 22
	AdminRequestType_GET_RO_STORAGE_FORMAT      AdminRequestType = 23
	AdminRequestType_REBALANCE_STATE_CHANGE     AdminRequestType = 24
	AdminRequestType_REPAIR_JOB                 AdminRequestType = 25
	// INITIATE_REBALANCE_NODE_ON_DONOR = 26;
	AdminRequestType_DELETE_STORE_REBALANCE_STATE  AdminRequestType = 27
	AdminRequestType_NATIVE_BACKUP                 AdminRequestType = 28
	AdminRequestType_RESERVE_MEMORY                AdminRequestType = 29
	AdminRequestType_PRUNE_JOB                     AdminRequestType = 30
	AdminRequestType_SLOP_PURGE_JOB                AdminRequestType = 31
	AdminRequestType_UPDATE_METADATA_PAIR          AdminRequestType = 32
	AdminRequestType_UPDATE_STORE_DEFINITIONS      AdminRequestType = 33
	AdminRequestType_SET_OFFLINE_STATE             AdminRequestType = 34
	AdminRequestType_GET_RO_STORAGE_FILE_LIST      AdminRequestType = 35
	AdminRequestType_GET_RO_COMPRESSION_CODEC_LIST AdminRequestType = 36
	AdminRequestType_LIST_SCHEDULED_JOBS           AdminRequestType = 37
	AdminRequestType_GET_SCHEDULED_JOB_STATUS      AdminRequestType = 38
	AdminRequestType_STOP_SCHEDULED_JOB            AdminRequestType = 39
	AdminRequestType_ENABLE_SCHEDULED_JOB          AdminRequestType = 40
	AdminRequestType_GET_HA_SETTINGS               AdminRequestType = 41
	AdminRequestType_DISABLE_STORE_VERSION         AdminRequestType = 42
	AdminRequestType_HANDLE_FETCH_FAILURE          AdminRequestType = 43
	AdminRequestType_GET_CONFIG                    AdminRequestType = 44
)

func (AdminRequestType) Enum 

func (x AdminRequestType) Enum() *AdminRequestType

func (AdminRequestType) EnumDescriptor 

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

func (AdminRequestType) String 

func (x AdminRequestType) String() string

func (*AdminRequestType) UnmarshalJSON 

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

type AsyncOperationListRequest 

type AsyncOperationListRequest struct {
	ShowComplete     *bool  `protobuf:"varint,2,req,name=show_complete,json=showComplete" json:"show_complete,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AsyncOperationListRequest) Descriptor 

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

func (*AsyncOperationListRequest) GetShowComplete 

func (m *AsyncOperationListRequest) GetShowComplete() bool

func (*AsyncOperationListRequest) ProtoMessage 

func (*AsyncOperationListRequest) ProtoMessage()

func (*AsyncOperationListRequest) Reset 

func (m *AsyncOperationListRequest) Reset()

func (*AsyncOperationListRequest) String 

func (m *AsyncOperationListRequest) String() string

type AsyncOperationListResponse 

type AsyncOperationListResponse struct {
	RequestIds       []int32 `protobuf:"varint,1,rep,name=request_ids,json=requestIds" json:"request_ids,omitempty"`
	Error            *Error  `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AsyncOperationListResponse) Descriptor 

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

func (*AsyncOperationListResponse) GetError 

func (m *AsyncOperationListResponse) GetError() *Error

func (*AsyncOperationListResponse) GetRequestIds 

func (m *AsyncOperationListResponse) GetRequestIds() []int32

func (*AsyncOperationListResponse) ProtoMessage 

func (*AsyncOperationListResponse) ProtoMessage()

func (*AsyncOperationListResponse) Reset 

func (m *AsyncOperationListResponse) Reset()

func (*AsyncOperationListResponse) String 

func (m *AsyncOperationListResponse) String() string

type AsyncOperationStatusRequest 

type AsyncOperationStatusRequest struct {
	RequestId        *int32 `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AsyncOperationStatusRequest) Descriptor 

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

func (*AsyncOperationStatusRequest) GetRequestId 

func (m *AsyncOperationStatusRequest) GetRequestId() int32

func (*AsyncOperationStatusRequest) ProtoMessage 

func (*AsyncOperationStatusRequest) ProtoMessage()

func (*AsyncOperationStatusRequest) Reset 

func (m *AsyncOperationStatusRequest) Reset()

func (*AsyncOperationStatusRequest) String 

func (m *AsyncOperationStatusRequest) String() string

type AsyncOperationStatusResponse 

type AsyncOperationStatusResponse struct {
	RequestId        *int32  `protobuf:"varint,1,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	Description      *string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
	Status           *string `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
	Complete         *bool   `protobuf:"varint,4,opt,name=complete" json:"complete,omitempty"`
	Error            *Error  `protobuf:"bytes,5,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AsyncOperationStatusResponse) Descriptor 

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

func (*AsyncOperationStatusResponse) GetComplete 

func (m *AsyncOperationStatusResponse) GetComplete() bool

func (*AsyncOperationStatusResponse) GetDescription 

func (m *AsyncOperationStatusResponse) GetDescription() string

func (*AsyncOperationStatusResponse) GetError 

func (m *AsyncOperationStatusResponse) GetError() *Error

func (*AsyncOperationStatusResponse) GetRequestId 

func (m *AsyncOperationStatusResponse) GetRequestId() int32

func (*AsyncOperationStatusResponse) GetStatus 

func (m *AsyncOperationStatusResponse) GetStatus() string

func (*AsyncOperationStatusResponse) ProtoMessage 

func (*AsyncOperationStatusResponse) ProtoMessage()

func (*AsyncOperationStatusResponse) Reset 

func (m *AsyncOperationStatusResponse) Reset()

func (*AsyncOperationStatusResponse) String 

func (m *AsyncOperationStatusResponse) String() string

type AsyncOperationStopRequest 

type AsyncOperationStopRequest struct {
	RequestId        *int32 `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AsyncOperationStopRequest) Descriptor 

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

func (*AsyncOperationStopRequest) GetRequestId 

func (m *AsyncOperationStopRequest) GetRequestId() int32

func (*AsyncOperationStopRequest) ProtoMessage 

func (*AsyncOperationStopRequest) ProtoMessage()

func (*AsyncOperationStopRequest) Reset 

func (m *AsyncOperationStopRequest) Reset()

func (*AsyncOperationStopRequest) String 

func (m *AsyncOperationStopRequest) String() string

type AsyncOperationStopResponse 

type AsyncOperationStopResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AsyncOperationStopResponse) Descriptor 

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

func (*AsyncOperationStopResponse) GetError 

func (m *AsyncOperationStopResponse) GetError() *Error

func (*AsyncOperationStopResponse) ProtoMessage 

func (*AsyncOperationStopResponse) ProtoMessage()

func (*AsyncOperationStopResponse) Reset 

func (m *AsyncOperationStopResponse) Reset()

func (*AsyncOperationStopResponse) String 

func (m *AsyncOperationStopResponse) String() string

type ClockEntry 

type ClockEntry struct {
	NodeId           *int32 `protobuf:"varint,1,req,name=node_id,json=nodeId" json:"node_id,omitempty"`
	Version          *int64 `protobuf:"varint,2,req,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ClockEntry) Descriptor 

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

func (*ClockEntry) GetNodeId 

func (m *ClockEntry) GetNodeId() int32

func (*ClockEntry) GetVersion 

func (m *ClockEntry) GetVersion() int64

func (*ClockEntry) ProtoMessage 

func (*ClockEntry) ProtoMessage()

func (*ClockEntry) Reset 

func (m *ClockEntry) Reset()

func (*ClockEntry) String 

func (m *ClockEntry) String() string

type DeletePartitionEntriesRequest 

type DeletePartitionEntriesRequest struct {
	Store            *string          `protobuf:"bytes,1,req,name=store" json:"store,omitempty"`
	PartitionIds     []int32          `protobuf:"varint,2,rep,name=partition_ids,json=partitionIds" json:"partition_ids,omitempty"`
	Filter           *VoldemortFilter `protobuf:"bytes,3,opt,name=filter" json:"filter,omitempty"`
	InitialCluster   *string          `protobuf:"bytes,4,opt,name=initial_cluster,json=initialCluster" json:"initial_cluster,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*DeletePartitionEntriesRequest) Descriptor 

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

func (*DeletePartitionEntriesRequest) GetFilter 

func (m *DeletePartitionEntriesRequest) GetFilter() *VoldemortFilter

func (*DeletePartitionEntriesRequest) GetInitialCluster 

func (m *DeletePartitionEntriesRequest) GetInitialCluster() string

func (*DeletePartitionEntriesRequest) GetPartitionIds 

func (m *DeletePartitionEntriesRequest) GetPartitionIds() []int32

func (*DeletePartitionEntriesRequest) GetStore 

func (m *DeletePartitionEntriesRequest) GetStore() string

func (*DeletePartitionEntriesRequest) ProtoMessage 

func (*DeletePartitionEntriesRequest) ProtoMessage()

func (*DeletePartitionEntriesRequest) Reset 

func (m *DeletePartitionEntriesRequest) Reset()

func (*DeletePartitionEntriesRequest) String 

func (m *DeletePartitionEntriesRequest) String() string

type DeletePartitionEntriesResponse 

type DeletePartitionEntriesResponse struct {
	Count            *int64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
	Error            *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*DeletePartitionEntriesResponse) Descriptor 

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

func (*DeletePartitionEntriesResponse) GetCount 

func (m *DeletePartitionEntriesResponse) GetCount() int64

func (*DeletePartitionEntriesResponse) GetError 

func (m *DeletePartitionEntriesResponse) GetError() *Error

func (*DeletePartitionEntriesResponse) ProtoMessage 

func (*DeletePartitionEntriesResponse) ProtoMessage()

func (*DeletePartitionEntriesResponse) Reset 

func (m *DeletePartitionEntriesResponse) Reset()

func (*DeletePartitionEntriesResponse) String 

func (m *DeletePartitionEntriesResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	Key              []byte       `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Version          *VectorClock `protobuf:"bytes,2,req,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) GetVersion 

func (m *DeleteRequest) GetVersion() *VectorClock

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Success          *bool  `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Error            *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetError 

func (m *DeleteResponse) GetError() *Error

func (*DeleteResponse) GetSuccess 

func (m *DeleteResponse) GetSuccess() bool

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

type DeleteStoreRebalanceStateRequest 

type DeleteStoreRebalanceStateRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	NodeId           *int32  `protobuf:"varint,2,req,name=node_id,json=nodeId" json:"node_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteStoreRebalanceStateRequest) Descriptor 

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

func (*DeleteStoreRebalanceStateRequest) GetNodeId 

func (m *DeleteStoreRebalanceStateRequest) GetNodeId() int32

func (*DeleteStoreRebalanceStateRequest) GetStoreName 

func (m *DeleteStoreRebalanceStateRequest) GetStoreName() string

func (*DeleteStoreRebalanceStateRequest) ProtoMessage 

func (*DeleteStoreRebalanceStateRequest) ProtoMessage()

func (*DeleteStoreRebalanceStateRequest) Reset 

func (m *DeleteStoreRebalanceStateRequest) Reset()

func (*DeleteStoreRebalanceStateRequest) String 

func (m *DeleteStoreRebalanceStateRequest) String() string

type DeleteStoreRebalanceStateResponse 

type DeleteStoreRebalanceStateResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteStoreRebalanceStateResponse) Descriptor 

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

func (*DeleteStoreRebalanceStateResponse) GetError 

func (m *DeleteStoreRebalanceStateResponse) GetError() *Error

func (*DeleteStoreRebalanceStateResponse) ProtoMessage 

func (*DeleteStoreRebalanceStateResponse) ProtoMessage()

func (*DeleteStoreRebalanceStateResponse) Reset 

func (m *DeleteStoreRebalanceStateResponse) Reset()

func (*DeleteStoreRebalanceStateResponse) String 

func (m *DeleteStoreRebalanceStateResponse) String() string

type DeleteStoreRequest 

type DeleteStoreRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=storeName" json:"storeName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteStoreRequest) Descriptor 

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

func (*DeleteStoreRequest) GetStoreName 

func (m *DeleteStoreRequest) GetStoreName() string

func (*DeleteStoreRequest) ProtoMessage 

func (*DeleteStoreRequest) ProtoMessage()

func (*DeleteStoreRequest) Reset 

func (m *DeleteStoreRequest) Reset()

func (*DeleteStoreRequest) String 

func (m *DeleteStoreRequest) String() string

type DeleteStoreResponse 

type DeleteStoreResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteStoreResponse) Descriptor 

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

func (*DeleteStoreResponse) GetError 

func (m *DeleteStoreResponse) GetError() *Error

func (*DeleteStoreResponse) ProtoMessage 

func (*DeleteStoreResponse) ProtoMessage()

func (*DeleteStoreResponse) Reset 

func (m *DeleteStoreResponse) Reset()

func (*DeleteStoreResponse) String 

func (m *DeleteStoreResponse) String() string

type DisableStoreVersionRequest 

type DisableStoreVersionRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	PushVersion      *int64  `protobuf:"varint,2,req,name=push_version,json=pushVersion" json:"push_version,omitempty"`
	Info             *string `protobuf:"bytes,3,opt,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DisableStoreVersionRequest) Descriptor 

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

func (*DisableStoreVersionRequest) GetInfo 

func (m *DisableStoreVersionRequest) GetInfo() string

func (*DisableStoreVersionRequest) GetPushVersion 

func (m *DisableStoreVersionRequest) GetPushVersion() int64

func (*DisableStoreVersionRequest) GetStoreName 

func (m *DisableStoreVersionRequest) GetStoreName() string

func (*DisableStoreVersionRequest) ProtoMessage 

func (*DisableStoreVersionRequest) ProtoMessage()

func (*DisableStoreVersionRequest) Reset 

func (m *DisableStoreVersionRequest) Reset()

func (*DisableStoreVersionRequest) String 

func (m *DisableStoreVersionRequest) String() string

type DisableStoreVersionResponse 

type DisableStoreVersionResponse struct {
	DisableSuccess            *bool   `protobuf:"varint,1,req,name=disable_success,json=disableSuccess" json:"disable_success,omitempty"`
	DisablePersistenceSuccess *bool   `` /* 132-byte string literal not displayed */
	Info                      *string `protobuf:"bytes,3,opt,name=info" json:"info,omitempty"`
	NodeId                    *int32  `protobuf:"varint,4,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	XXX_unrecognized          []byte  `json:"-"`
}

func (*DisableStoreVersionResponse) Descriptor 

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

func (*DisableStoreVersionResponse) GetDisablePersistenceSuccess 

func (m *DisableStoreVersionResponse) GetDisablePersistenceSuccess() bool

func (*DisableStoreVersionResponse) GetDisableSuccess 

func (m *DisableStoreVersionResponse) GetDisableSuccess() bool

func (*DisableStoreVersionResponse) GetInfo 

func (m *DisableStoreVersionResponse) GetInfo() string

func (*DisableStoreVersionResponse) GetNodeId 

func (m *DisableStoreVersionResponse) GetNodeId() int32

func (*DisableStoreVersionResponse) ProtoMessage 

func (*DisableStoreVersionResponse) ProtoMessage()

func (*DisableStoreVersionResponse) Reset 

func (m *DisableStoreVersionResponse) Reset()

func (*DisableStoreVersionResponse) String 

func (m *DisableStoreVersionResponse) String() string

type EnableScheduledJobRequest 

type EnableScheduledJobRequest struct {
	JobId            *string `protobuf:"bytes,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*EnableScheduledJobRequest) Descriptor 

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

func (*EnableScheduledJobRequest) GetJobId 

func (m *EnableScheduledJobRequest) GetJobId() string

func (*EnableScheduledJobRequest) ProtoMessage 

func (*EnableScheduledJobRequest) ProtoMessage()

func (*EnableScheduledJobRequest) Reset 

func (m *EnableScheduledJobRequest) Reset()

func (*EnableScheduledJobRequest) String 

func (m *EnableScheduledJobRequest) String() string

type EnableScheduledJobResponse 

type EnableScheduledJobResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*EnableScheduledJobResponse) Descriptor 

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

func (*EnableScheduledJobResponse) GetError 

func (m *EnableScheduledJobResponse) GetError() *Error

func (*EnableScheduledJobResponse) ProtoMessage 

func (*EnableScheduledJobResponse) ProtoMessage()

func (*EnableScheduledJobResponse) Reset 

func (m *EnableScheduledJobResponse) Reset()

func (*EnableScheduledJobResponse) String 

func (m *EnableScheduledJobResponse) String() string

type Error 

type Error struct {
	ErrorCode        *int32  `protobuf:"varint,1,req,name=error_code,json=errorCode" json:"error_code,omitempty"`
	ErrorMessage     *string `protobuf:"bytes,2,req,name=error_message,json=errorMessage" json:"error_message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetErrorCode 

func (m *Error) GetErrorCode() int32

func (*Error) GetErrorMessage 

func (m *Error) GetErrorMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

type FailedFetchStoreRequest 

type FailedFetchStoreRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	StoreDir         *string `protobuf:"bytes,2,req,name=store_dir,json=storeDir" json:"store_dir,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FailedFetchStoreRequest) Descriptor 

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

func (*FailedFetchStoreRequest) GetStoreDir 

func (m *FailedFetchStoreRequest) GetStoreDir() string

func (*FailedFetchStoreRequest) GetStoreName 

func (m *FailedFetchStoreRequest) GetStoreName() string

func (*FailedFetchStoreRequest) ProtoMessage 

func (*FailedFetchStoreRequest) ProtoMessage()

func (*FailedFetchStoreRequest) Reset 

func (m *FailedFetchStoreRequest) Reset()

func (*FailedFetchStoreRequest) String 

func (m *FailedFetchStoreRequest) String() string

type FailedFetchStoreResponse 

type FailedFetchStoreResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*FailedFetchStoreResponse) Descriptor 

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

func (*FailedFetchStoreResponse) GetError 

func (m *FailedFetchStoreResponse) GetError() *Error

func (*FailedFetchStoreResponse) ProtoMessage 

func (*FailedFetchStoreResponse) ProtoMessage()

func (*FailedFetchStoreResponse) Reset 

func (m *FailedFetchStoreResponse) Reset()

func (*FailedFetchStoreResponse) String 

func (m *FailedFetchStoreResponse) String() string

type FetchPartitionEntriesRequest 

type FetchPartitionEntriesRequest struct {
	PartitionIds                     []int32          `protobuf:"varint,1,rep,name=partition_ids,json=partitionIds" json:"partition_ids,omitempty"`
	Store                            *string          `protobuf:"bytes,2,req,name=store" json:"store,omitempty"`
	Filter                           *VoldemortFilter `protobuf:"bytes,3,opt,name=filter" json:"filter,omitempty"`
	FetchValues                      *bool            `protobuf:"varint,4,opt,name=fetch_values,json=fetchValues" json:"fetch_values,omitempty"`
	OBSOLETE__DO_NOT_USE_SkipRecords *int64           `` /* 148-byte string literal not displayed */
	InitialCluster                   *string          `protobuf:"bytes,6,opt,name=initial_cluster,json=initialCluster" json:"initial_cluster,omitempty"`
	FetchOrphaned                    *bool            `protobuf:"varint,7,opt,name=fetch_orphaned,json=fetchOrphaned" json:"fetch_orphaned,omitempty"`
	RecordsPerPartition              *int64           `protobuf:"varint,8,opt,name=records_per_partition,json=recordsPerPartition" json:"records_per_partition,omitempty"`
	XXX_unrecognized                 []byte           `json:"-"`
}

func (*FetchPartitionEntriesRequest) Descriptor 

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

func (*FetchPartitionEntriesRequest) GetFetchOrphaned 

func (m *FetchPartitionEntriesRequest) GetFetchOrphaned() bool

func (*FetchPartitionEntriesRequest) GetFetchValues 

func (m *FetchPartitionEntriesRequest) GetFetchValues() bool

func (*FetchPartitionEntriesRequest) GetFilter 

func (m *FetchPartitionEntriesRequest) GetFilter() *VoldemortFilter

func (*FetchPartitionEntriesRequest) GetInitialCluster 

func (m *FetchPartitionEntriesRequest) GetInitialCluster() string

func (*FetchPartitionEntriesRequest) GetOBSOLETE__DO_NOT_USE_SkipRecords 

func (m *FetchPartitionEntriesRequest) GetOBSOLETE__DO_NOT_USE_SkipRecords() int64

func (*FetchPartitionEntriesRequest) GetPartitionIds 

func (m *FetchPartitionEntriesRequest) GetPartitionIds() []int32

func (*FetchPartitionEntriesRequest) GetRecordsPerPartition 

func (m *FetchPartitionEntriesRequest) GetRecordsPerPartition() int64

func (*FetchPartitionEntriesRequest) GetStore 

func (m *FetchPartitionEntriesRequest) GetStore() string

func (*FetchPartitionEntriesRequest) ProtoMessage 

func (*FetchPartitionEntriesRequest) ProtoMessage()

func (*FetchPartitionEntriesRequest) Reset 

func (m *FetchPartitionEntriesRequest) Reset()

func (*FetchPartitionEntriesRequest) String 

func (m *FetchPartitionEntriesRequest) String() string

type FetchPartitionEntriesResponse 

type FetchPartitionEntriesResponse struct {
	PartitionEntry   *PartitionEntry `protobuf:"bytes,1,opt,name=partition_entry,json=partitionEntry" json:"partition_entry,omitempty"`
	Key              []byte          `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Error            *Error          `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*FetchPartitionEntriesResponse) Descriptor 

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

func (*FetchPartitionEntriesResponse) GetError 

func (m *FetchPartitionEntriesResponse) GetError() *Error

func (*FetchPartitionEntriesResponse) GetKey 

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

func (*FetchPartitionEntriesResponse) GetPartitionEntry 

func (m *FetchPartitionEntriesResponse) GetPartitionEntry() *PartitionEntry

func (*FetchPartitionEntriesResponse) ProtoMessage 

func (*FetchPartitionEntriesResponse) ProtoMessage()

func (*FetchPartitionEntriesResponse) Reset 

func (m *FetchPartitionEntriesResponse) Reset()

func (*FetchPartitionEntriesResponse) String 

func (m *FetchPartitionEntriesResponse) String() string

type FetchPartitionFilesRequest 

type FetchPartitionFilesRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	PartitionIds     []int32 `protobuf:"varint,2,rep,name=partition_ids,json=partitionIds" json:"partition_ids,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FetchPartitionFilesRequest) Descriptor 

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

func (*FetchPartitionFilesRequest) GetPartitionIds 

func (m *FetchPartitionFilesRequest) GetPartitionIds() []int32

func (*FetchPartitionFilesRequest) GetStoreName 

func (m *FetchPartitionFilesRequest) GetStoreName() string

func (*FetchPartitionFilesRequest) ProtoMessage 

func (*FetchPartitionFilesRequest) ProtoMessage()

func (*FetchPartitionFilesRequest) Reset 

func (m *FetchPartitionFilesRequest) Reset()

func (*FetchPartitionFilesRequest) String 

func (m *FetchPartitionFilesRequest) String() string

type FetchStoreRequest 

type FetchStoreRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	StoreDir         *string `protobuf:"bytes,2,req,name=store_dir,json=storeDir" json:"store_dir,omitempty"`
	PushVersion      *int64  `protobuf:"varint,3,opt,name=push_version,json=pushVersion" json:"push_version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FetchStoreRequest) Descriptor 

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

func (*FetchStoreRequest) GetPushVersion 

func (m *FetchStoreRequest) GetPushVersion() int64

func (*FetchStoreRequest) GetStoreDir 

func (m *FetchStoreRequest) GetStoreDir() string

func (*FetchStoreRequest) GetStoreName 

func (m *FetchStoreRequest) GetStoreName() string

func (*FetchStoreRequest) ProtoMessage 

func (*FetchStoreRequest) ProtoMessage()

func (*FetchStoreRequest) Reset 

func (m *FetchStoreRequest) Reset()

func (*FetchStoreRequest) String 

func (m *FetchStoreRequest) String() string

type FileEntry 

type FileEntry struct {
	FileName         *string `protobuf:"bytes,1,req,name=file_name,json=fileName" json:"file_name,omitempty"`
	FileSizeBytes    *int64  `protobuf:"varint,2,req,name=file_size_bytes,json=fileSizeBytes" json:"file_size_bytes,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FileEntry) Descriptor 

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

func (*FileEntry) GetFileName 

func (m *FileEntry) GetFileName() string

func (*FileEntry) GetFileSizeBytes 

func (m *FileEntry) GetFileSizeBytes() int64

func (*FileEntry) ProtoMessage 

func (*FileEntry) ProtoMessage()

func (*FileEntry) Reset 

func (m *FileEntry) Reset()

func (*FileEntry) String 

func (m *FileEntry) String() string

type GetAllRequest 

type GetAllRequest struct {
	Keys             [][]byte                         `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
	Transforms       []*GetAllRequest_GetAllTransform `protobuf:"bytes,2,rep,name=transforms" json:"transforms,omitempty"`
	XXX_unrecognized []byte                           `json:"-"`
}

func (*GetAllRequest) Descriptor 

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

func (*GetAllRequest) GetKeys 

func (m *GetAllRequest) GetKeys() [][]byte

func (*GetAllRequest) GetTransforms 

func (m *GetAllRequest) GetTransforms() []*GetAllRequest_GetAllTransform

func (*GetAllRequest) ProtoMessage 

func (*GetAllRequest) ProtoMessage()

func (*GetAllRequest) Reset 

func (m *GetAllRequest) Reset()

func (*GetAllRequest) String 

func (m *GetAllRequest) String() string

type GetAllRequest_GetAllTransform 

type GetAllRequest_GetAllTransform struct {
	Key              []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Transform        []byte `protobuf:"bytes,2,req,name=transform" json:"transform,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetAllRequest_GetAllTransform) Descriptor 

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

func (*GetAllRequest_GetAllTransform) GetKey 

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

func (*GetAllRequest_GetAllTransform) GetTransform 

func (m *GetAllRequest_GetAllTransform) GetTransform() []byte

func (*GetAllRequest_GetAllTransform) ProtoMessage 

func (*GetAllRequest_GetAllTransform) ProtoMessage()

func (*GetAllRequest_GetAllTransform) Reset 

func (m *GetAllRequest_GetAllTransform) Reset()

func (*GetAllRequest_GetAllTransform) String 

func (m *GetAllRequest_GetAllTransform) String() string

type GetAllResponse 

type GetAllResponse struct {
	Values           []*KeyedVersions `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
	Error            *Error           `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GetAllResponse) Descriptor 

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

func (*GetAllResponse) GetError 

func (m *GetAllResponse) GetError() *Error

func (*GetAllResponse) GetValues 

func (m *GetAllResponse) GetValues() []*KeyedVersions

func (*GetAllResponse) ProtoMessage 

func (*GetAllResponse) ProtoMessage()

func (*GetAllResponse) Reset 

func (m *GetAllResponse) Reset()

func (*GetAllResponse) String 

func (m *GetAllResponse) String() string

type GetConfigRequest 

type GetConfigRequest struct {
	ConfigKey        []string `protobuf:"bytes,1,rep,name=config_key,json=configKey" json:"config_key,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GetConfigRequest) Descriptor 

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

func (*GetConfigRequest) GetConfigKey 

func (m *GetConfigRequest) GetConfigKey() []string

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) Reset 

func (m *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (m *GetConfigRequest) String() string

type GetConfigResponse 

type GetConfigResponse struct {
	// Key/value pairs of each requested config key
	ConfigMap []*MapFieldEntry `protobuf:"bytes,1,rep,name=config_map,json=configMap" json:"config_map,omitempty"`
	// Requested config keys which cannot be provided, along with the reason why in the value.
	InvalidConfigMap []*MapFieldEntry `protobuf:"bytes,2,rep,name=invalid_config_map,json=invalidConfigMap" json:"invalid_config_map,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GetConfigResponse) Descriptor 

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

func (*GetConfigResponse) GetConfigMap 

func (m *GetConfigResponse) GetConfigMap() []*MapFieldEntry

func (*GetConfigResponse) GetInvalidConfigMap 

func (m *GetConfigResponse) GetInvalidConfigMap() []*MapFieldEntry

func (*GetConfigResponse) ProtoMessage 

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) Reset 

func (m *GetConfigResponse) Reset()

func (*GetConfigResponse) String 

func (m *GetConfigResponse) String() string

type GetHighAvailabilitySettingsRequest 

type GetHighAvailabilitySettingsRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetHighAvailabilitySettingsRequest) Descriptor 

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

func (*GetHighAvailabilitySettingsRequest) ProtoMessage 

func (*GetHighAvailabilitySettingsRequest) ProtoMessage()

func (*GetHighAvailabilitySettingsRequest) Reset 

func (m *GetHighAvailabilitySettingsRequest) Reset()

func (*GetHighAvailabilitySettingsRequest) String 

func (m *GetHighAvailabilitySettingsRequest) String() string

type GetHighAvailabilitySettingsResponse 

type GetHighAvailabilitySettingsResponse struct {
	Enabled            *bool   `protobuf:"varint,1,req,name=enabled" json:"enabled,omitempty"`
	ClusterId          *string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId" json:"cluster_id,omitempty"`
	MaxNodeFailure     *int32  `protobuf:"varint,3,opt,name=max_node_failure,json=maxNodeFailure" json:"max_node_failure,omitempty"`
	LockPath           *string `protobuf:"bytes,4,opt,name=lock_path,json=lockPath" json:"lock_path,omitempty"`
	LockImplementation *string `protobuf:"bytes,5,opt,name=lock_implementation,json=lockImplementation" json:"lock_implementation,omitempty"`
	XXX_unrecognized   []byte  `json:"-"`
}

func (*GetHighAvailabilitySettingsResponse) Descriptor 

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

func (*GetHighAvailabilitySettingsResponse) GetClusterId 

func (m *GetHighAvailabilitySettingsResponse) GetClusterId() string

func (*GetHighAvailabilitySettingsResponse) GetEnabled 

func (m *GetHighAvailabilitySettingsResponse) GetEnabled() bool

func (*GetHighAvailabilitySettingsResponse) GetLockImplementation 

func (m *GetHighAvailabilitySettingsResponse) GetLockImplementation() string

func (*GetHighAvailabilitySettingsResponse) GetLockPath 

func (m *GetHighAvailabilitySettingsResponse) GetLockPath() string

func (*GetHighAvailabilitySettingsResponse) GetMaxNodeFailure 

func (m *GetHighAvailabilitySettingsResponse) GetMaxNodeFailure() int32

func (*GetHighAvailabilitySettingsResponse) ProtoMessage 

func (*GetHighAvailabilitySettingsResponse) ProtoMessage()

func (*GetHighAvailabilitySettingsResponse) Reset 

func (m *GetHighAvailabilitySettingsResponse) Reset()

func (*GetHighAvailabilitySettingsResponse) String 

func (m *GetHighAvailabilitySettingsResponse) String() string

type GetMetadataRequest 

type GetMetadataRequest struct {
	Key              []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetMetadataRequest) Descriptor 

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

func (*GetMetadataRequest) GetKey 

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

func (*GetMetadataRequest) ProtoMessage 

func (*GetMetadataRequest) ProtoMessage()

func (*GetMetadataRequest) Reset 

func (m *GetMetadataRequest) Reset()

func (*GetMetadataRequest) String 

func (m *GetMetadataRequest) String() string

type GetMetadataResponse 

type GetMetadataResponse struct {
	Version          *Versioned `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	Error            *Error     `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*GetMetadataResponse) Descriptor 

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

func (*GetMetadataResponse) GetError 

func (m *GetMetadataResponse) GetError() *Error

func (*GetMetadataResponse) GetVersion 

func (m *GetMetadataResponse) GetVersion() *Versioned

func (*GetMetadataResponse) ProtoMessage 

func (*GetMetadataResponse) ProtoMessage()

func (*GetMetadataResponse) Reset 

func (m *GetMetadataResponse) Reset()

func (*GetMetadataResponse) String 

func (m *GetMetadataResponse) String() string

type GetROCurrentVersionDirRequest 

type GetROCurrentVersionDirRequest struct {
	StoreName        []string `protobuf:"bytes,1,rep,name=store_name,json=storeName" json:"store_name,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GetROCurrentVersionDirRequest) Descriptor 

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

func (*GetROCurrentVersionDirRequest) GetStoreName 

func (m *GetROCurrentVersionDirRequest) GetStoreName() []string

func (*GetROCurrentVersionDirRequest) ProtoMessage 

func (*GetROCurrentVersionDirRequest) ProtoMessage()

func (*GetROCurrentVersionDirRequest) Reset 

func (m *GetROCurrentVersionDirRequest) Reset()

func (*GetROCurrentVersionDirRequest) String 

func (m *GetROCurrentVersionDirRequest) String() string

type GetROCurrentVersionDirResponse 

type GetROCurrentVersionDirResponse struct {
	RoStoreVersions  []*ROStoreVersionDirMap `protobuf:"bytes,1,rep,name=ro_store_versions,json=roStoreVersions" json:"ro_store_versions,omitempty"`
	Error            *Error                  `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*GetROCurrentVersionDirResponse) Descriptor 

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

func (*GetROCurrentVersionDirResponse) GetError 

func (m *GetROCurrentVersionDirResponse) GetError() *Error

func (*GetROCurrentVersionDirResponse) GetRoStoreVersions 

func (m *GetROCurrentVersionDirResponse) GetRoStoreVersions() []*ROStoreVersionDirMap

func (*GetROCurrentVersionDirResponse) ProtoMessage 

func (*GetROCurrentVersionDirResponse) ProtoMessage()

func (*GetROCurrentVersionDirResponse) Reset 

func (m *GetROCurrentVersionDirResponse) Reset()

func (*GetROCurrentVersionDirResponse) String 

func (m *GetROCurrentVersionDirResponse) String() string

type GetROMaxVersionDirRequest 

type GetROMaxVersionDirRequest struct {
	StoreName        []string `protobuf:"bytes,1,rep,name=store_name,json=storeName" json:"store_name,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GetROMaxVersionDirRequest) Descriptor 

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

func (*GetROMaxVersionDirRequest) GetStoreName 

func (m *GetROMaxVersionDirRequest) GetStoreName() []string

func (*GetROMaxVersionDirRequest) ProtoMessage 

func (*GetROMaxVersionDirRequest) ProtoMessage()

func (*GetROMaxVersionDirRequest) Reset 

func (m *GetROMaxVersionDirRequest) Reset()

func (*GetROMaxVersionDirRequest) String 

func (m *GetROMaxVersionDirRequest) String() string

type GetROMaxVersionDirResponse 

type GetROMaxVersionDirResponse struct {
	RoStoreVersions  []*ROStoreVersionDirMap `protobuf:"bytes,1,rep,name=ro_store_versions,json=roStoreVersions" json:"ro_store_versions,omitempty"`
	Error            *Error                  `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*GetROMaxVersionDirResponse) Descriptor 

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

func (*GetROMaxVersionDirResponse) GetError 

func (m *GetROMaxVersionDirResponse) GetError() *Error

func (*GetROMaxVersionDirResponse) GetRoStoreVersions 

func (m *GetROMaxVersionDirResponse) GetRoStoreVersions() []*ROStoreVersionDirMap

func (*GetROMaxVersionDirResponse) ProtoMessage 

func (*GetROMaxVersionDirResponse) ProtoMessage()

func (*GetROMaxVersionDirResponse) Reset 

func (m *GetROMaxVersionDirResponse) Reset()

func (*GetROMaxVersionDirResponse) String 

func (m *GetROMaxVersionDirResponse) String() string

type GetROStorageCompressionCodecListRequest 

type GetROStorageCompressionCodecListRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetROStorageCompressionCodecListRequest) Descriptor 

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

func (*GetROStorageCompressionCodecListRequest) ProtoMessage 

func (*GetROStorageCompressionCodecListRequest) ProtoMessage()

func (*GetROStorageCompressionCodecListRequest) Reset 

func (m *GetROStorageCompressionCodecListRequest) Reset()

func (*GetROStorageCompressionCodecListRequest) String 

func (m *GetROStorageCompressionCodecListRequest) String() string

type GetROStorageCompressionCodecListResponse 

type GetROStorageCompressionCodecListResponse struct {
	CompressionCodecs []string `protobuf:"bytes,1,rep,name=compression_codecs,json=compressionCodecs" json:"compression_codecs,omitempty"`
	Error             *Error   `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized  []byte   `json:"-"`
}

func (*GetROStorageCompressionCodecListResponse) Descriptor 

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

func (*GetROStorageCompressionCodecListResponse) GetCompressionCodecs 

func (m *GetROStorageCompressionCodecListResponse) GetCompressionCodecs() []string

func (*GetROStorageCompressionCodecListResponse) GetError 

func (m *GetROStorageCompressionCodecListResponse) GetError() *Error

func (*GetROStorageCompressionCodecListResponse) ProtoMessage 

func (*GetROStorageCompressionCodecListResponse) ProtoMessage()

func (*GetROStorageCompressionCodecListResponse) Reset 

func (m *GetROStorageCompressionCodecListResponse) Reset()

func (*GetROStorageCompressionCodecListResponse) String 

func (m *GetROStorageCompressionCodecListResponse) String() string

type GetROStorageFileListRequest 

type GetROStorageFileListRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetROStorageFileListRequest) Descriptor 

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

func (*GetROStorageFileListRequest) GetStoreName 

func (m *GetROStorageFileListRequest) GetStoreName() string

func (*GetROStorageFileListRequest) ProtoMessage 

func (*GetROStorageFileListRequest) ProtoMessage()

func (*GetROStorageFileListRequest) Reset 

func (m *GetROStorageFileListRequest) Reset()

func (*GetROStorageFileListRequest) String 

func (m *GetROStorageFileListRequest) String() string

type GetROStorageFileListResponse 

type GetROStorageFileListResponse struct {
	FileName         []string `protobuf:"bytes,1,rep,name=file_name,json=fileName" json:"file_name,omitempty"`
	Error            *Error   `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	DataFileSize     []int32  `protobuf:"varint,3,rep,name=data_file_size,json=dataFileSize" json:"data_file_size,omitempty"`
	IndexFileSize    []int32  `protobuf:"varint,4,rep,name=index_file_size,json=indexFileSize" json:"index_file_size,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GetROStorageFileListResponse) Descriptor 

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

func (*GetROStorageFileListResponse) GetDataFileSize 

func (m *GetROStorageFileListResponse) GetDataFileSize() []int32

func (*GetROStorageFileListResponse) GetError 

func (m *GetROStorageFileListResponse) GetError() *Error

func (*GetROStorageFileListResponse) GetFileName 

func (m *GetROStorageFileListResponse) GetFileName() []string

func (*GetROStorageFileListResponse) GetIndexFileSize 

func (m *GetROStorageFileListResponse) GetIndexFileSize() []int32

func (*GetROStorageFileListResponse) ProtoMessage 

func (*GetROStorageFileListResponse) ProtoMessage()

func (*GetROStorageFileListResponse) Reset 

func (m *GetROStorageFileListResponse) Reset()

func (*GetROStorageFileListResponse) String 

func (m *GetROStorageFileListResponse) String() string

type GetROStorageFormatRequest 

type GetROStorageFormatRequest struct {
	StoreName        []string `protobuf:"bytes,1,rep,name=store_name,json=storeName" json:"store_name,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GetROStorageFormatRequest) Descriptor 

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

func (*GetROStorageFormatRequest) GetStoreName 

func (m *GetROStorageFormatRequest) GetStoreName() []string

func (*GetROStorageFormatRequest) ProtoMessage 

func (*GetROStorageFormatRequest) ProtoMessage()

func (*GetROStorageFormatRequest) Reset 

func (m *GetROStorageFormatRequest) Reset()

func (*GetROStorageFormatRequest) String 

func (m *GetROStorageFormatRequest) String() string

type GetROStorageFormatResponse 

type GetROStorageFormatResponse struct {
	RoStoreVersions  []*ROStoreVersionDirMap `protobuf:"bytes,1,rep,name=ro_store_versions,json=roStoreVersions" json:"ro_store_versions,omitempty"`
	Error            *Error                  `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*GetROStorageFormatResponse) Descriptor 

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

func (*GetROStorageFormatResponse) GetError 

func (m *GetROStorageFormatResponse) GetError() *Error

func (*GetROStorageFormatResponse) GetRoStoreVersions 

func (m *GetROStorageFormatResponse) GetRoStoreVersions() []*ROStoreVersionDirMap

func (*GetROStorageFormatResponse) ProtoMessage 

func (*GetROStorageFormatResponse) ProtoMessage()

func (*GetROStorageFormatResponse) Reset 

func (m *GetROStorageFormatResponse) Reset()

func (*GetROStorageFormatResponse) String 

func (m *GetROStorageFormatResponse) String() string

type GetRequest 

type GetRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Transforms       []byte `protobuf:"bytes,2,opt,name=transforms" json:"transforms,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

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

func (*GetRequest) GetTransforms 

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

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 {
	Versioned        []*Versioned `protobuf:"bytes,1,rep,name=versioned" json:"versioned,omitempty"`
	Error            *Error       `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetError 

func (m *GetResponse) GetError() *Error

func (*GetResponse) GetVersioned 

func (m *GetResponse) GetVersioned() []*Versioned

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

type GetScheduledJobStatusRequest 

type GetScheduledJobStatusRequest struct {
	JobId            *string `protobuf:"bytes,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetScheduledJobStatusRequest) Descriptor 

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

func (*GetScheduledJobStatusRequest) GetJobId 

func (m *GetScheduledJobStatusRequest) GetJobId() string

func (*GetScheduledJobStatusRequest) ProtoMessage 

func (*GetScheduledJobStatusRequest) ProtoMessage()

func (*GetScheduledJobStatusRequest) Reset 

func (m *GetScheduledJobStatusRequest) Reset()

func (*GetScheduledJobStatusRequest) String 

func (m *GetScheduledJobStatusRequest) String() string

type GetScheduledJobStatusResponse 

type GetScheduledJobStatusResponse struct {
	Enabled          *bool  `protobuf:"varint,1,req,name=enabled" json:"enabled,omitempty"`
	Error            *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetScheduledJobStatusResponse) Descriptor 

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

func (*GetScheduledJobStatusResponse) GetEnabled 

func (m *GetScheduledJobStatusResponse) GetEnabled() bool

func (*GetScheduledJobStatusResponse) GetError 

func (m *GetScheduledJobStatusResponse) GetError() *Error

func (*GetScheduledJobStatusResponse) ProtoMessage 

func (*GetScheduledJobStatusResponse) ProtoMessage()

func (*GetScheduledJobStatusResponse) Reset 

func (m *GetScheduledJobStatusResponse) Reset()

func (*GetScheduledJobStatusResponse) String 

func (m *GetScheduledJobStatusResponse) String() string

type GetVersionResponse 

type GetVersionResponse struct {
	Versions         []*VectorClock `protobuf:"bytes,1,rep,name=versions" json:"versions,omitempty"`
	Error            *Error         `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*GetVersionResponse) Descriptor 

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

func (*GetVersionResponse) GetError 

func (m *GetVersionResponse) GetError() *Error

func (*GetVersionResponse) GetVersions 

func (m *GetVersionResponse) GetVersions() []*VectorClock

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) Reset 

func (m *GetVersionResponse) Reset()

func (*GetVersionResponse) String 

func (m *GetVersionResponse) String() string

type HandleFetchFailureRequest 

type HandleFetchFailureRequest struct {
	FailedNodes      []int32 `protobuf:"varint,1,rep,name=failed_nodes,json=failedNodes" json:"failed_nodes,omitempty"`
	StoreName        *string `protobuf:"bytes,2,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	PushVersion      *int64  `protobuf:"varint,3,req,name=push_version,json=pushVersion" json:"push_version,omitempty"`
	Info             *string `protobuf:"bytes,4,opt,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*HandleFetchFailureRequest) Descriptor 

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

func (*HandleFetchFailureRequest) GetFailedNodes 

func (m *HandleFetchFailureRequest) GetFailedNodes() []int32

func (*HandleFetchFailureRequest) GetInfo 

func (m *HandleFetchFailureRequest) GetInfo() string

func (*HandleFetchFailureRequest) GetPushVersion 

func (m *HandleFetchFailureRequest) GetPushVersion() int64

func (*HandleFetchFailureRequest) GetStoreName 

func (m *HandleFetchFailureRequest) GetStoreName() string

func (*HandleFetchFailureRequest) ProtoMessage 

func (*HandleFetchFailureRequest) ProtoMessage()

func (*HandleFetchFailureRequest) Reset 

func (m *HandleFetchFailureRequest) Reset()

func (*HandleFetchFailureRequest) String 

func (m *HandleFetchFailureRequest) String() string

type HandleFetchFailureResponse 

type HandleFetchFailureResponse struct {
	SwapIsPossible        *bool                          `protobuf:"varint,1,req,name=swap_is_possible,json=swapIsPossible" json:"swap_is_possible,omitempty"`
	Info                  *string                        `protobuf:"bytes,2,opt,name=info" json:"info,omitempty"`
	DisableStoreResponses []*DisableStoreVersionResponse `protobuf:"bytes,3,rep,name=disable_store_responses,json=disableStoreResponses" json:"disable_store_responses,omitempty"`
	XXX_unrecognized      []byte                         `json:"-"`
}

func (*HandleFetchFailureResponse) Descriptor 

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

func (*HandleFetchFailureResponse) GetDisableStoreResponses 

func (m *HandleFetchFailureResponse) GetDisableStoreResponses() []*DisableStoreVersionResponse

func (*HandleFetchFailureResponse) GetInfo 

func (m *HandleFetchFailureResponse) GetInfo() string

func (*HandleFetchFailureResponse) GetSwapIsPossible 

func (m *HandleFetchFailureResponse) GetSwapIsPossible() bool

func (*HandleFetchFailureResponse) ProtoMessage 

func (*HandleFetchFailureResponse) ProtoMessage()

func (*HandleFetchFailureResponse) Reset 

func (m *HandleFetchFailureResponse) Reset()

func (*HandleFetchFailureResponse) String 

func (m *HandleFetchFailureResponse) String() string

type InitiateFetchAndUpdateRequest 

type InitiateFetchAndUpdateRequest struct {
	NodeId                        *int32           `protobuf:"varint,1,req,name=node_id,json=nodeId" json:"node_id,omitempty"`
	Store                         *string          `protobuf:"bytes,2,req,name=store" json:"store,omitempty"`
	Filter                        *VoldemortFilter `protobuf:"bytes,3,opt,name=filter" json:"filter,omitempty"`
	PartitionIds                  []int32          `protobuf:"varint,4,rep,name=partition_ids,json=partitionIds" json:"partition_ids,omitempty"`
	InitialCluster                *string          `protobuf:"bytes,5,opt,name=initial_cluster,json=initialCluster" json:"initial_cluster,omitempty"`
	OBSOLETE__DO_NOT_USE_Optimize *bool            `` /* 137-byte string literal not displayed */
	XXX_unrecognized              []byte           `json:"-"`
}

func (*InitiateFetchAndUpdateRequest) Descriptor 

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

func (*InitiateFetchAndUpdateRequest) GetFilter 

func (m *InitiateFetchAndUpdateRequest) GetFilter() *VoldemortFilter

func (*InitiateFetchAndUpdateRequest) GetInitialCluster 

func (m *InitiateFetchAndUpdateRequest) GetInitialCluster() string

func (*InitiateFetchAndUpdateRequest) GetNodeId 

func (m *InitiateFetchAndUpdateRequest) GetNodeId() int32

func (*InitiateFetchAndUpdateRequest) GetOBSOLETE__DO_NOT_USE_Optimize 

func (m *InitiateFetchAndUpdateRequest) GetOBSOLETE__DO_NOT_USE_Optimize() bool

func (*InitiateFetchAndUpdateRequest) GetPartitionIds 

func (m *InitiateFetchAndUpdateRequest) GetPartitionIds() []int32

func (*InitiateFetchAndUpdateRequest) GetStore 

func (m *InitiateFetchAndUpdateRequest) GetStore() string

func (*InitiateFetchAndUpdateRequest) ProtoMessage 

func (*InitiateFetchAndUpdateRequest) ProtoMessage()

func (*InitiateFetchAndUpdateRequest) Reset 

func (m *InitiateFetchAndUpdateRequest) Reset()

func (*InitiateFetchAndUpdateRequest) String 

func (m *InitiateFetchAndUpdateRequest) String() string

type InitiateRebalanceNodeOnDonorRequest 

type InitiateRebalanceNodeOnDonorRequest struct {
	RebalancePartitionInfo []*RebalancePartitionInfoMap `protobuf:"bytes,1,rep,name=rebalance_partition_info,json=rebalancePartitionInfo" json:"rebalance_partition_info,omitempty"`
	XXX_unrecognized       []byte                       `json:"-"`
}

func (*InitiateRebalanceNodeOnDonorRequest) Descriptor 

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

func (*InitiateRebalanceNodeOnDonorRequest) GetRebalancePartitionInfo 

func (m *InitiateRebalanceNodeOnDonorRequest) GetRebalancePartitionInfo() []*RebalancePartitionInfoMap

func (*InitiateRebalanceNodeOnDonorRequest) ProtoMessage 

func (*InitiateRebalanceNodeOnDonorRequest) ProtoMessage()

func (*InitiateRebalanceNodeOnDonorRequest) Reset 

func (m *InitiateRebalanceNodeOnDonorRequest) Reset()

func (*InitiateRebalanceNodeOnDonorRequest) String 

func (m *InitiateRebalanceNodeOnDonorRequest) String() string

type InitiateRebalanceNodeRequest 

type InitiateRebalanceNodeRequest struct {
	RebalanceTaskInfo *RebalanceTaskInfoMap `protobuf:"bytes,1,req,name=rebalance_task_info,json=rebalanceTaskInfo" json:"rebalance_task_info,omitempty"`
	XXX_unrecognized  []byte                `json:"-"`
}

func (*InitiateRebalanceNodeRequest) Descriptor 

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

func (*InitiateRebalanceNodeRequest) GetRebalanceTaskInfo 

func (m *InitiateRebalanceNodeRequest) GetRebalanceTaskInfo() *RebalanceTaskInfoMap

func (*InitiateRebalanceNodeRequest) ProtoMessage 

func (*InitiateRebalanceNodeRequest) ProtoMessage()

func (*InitiateRebalanceNodeRequest) Reset 

func (m *InitiateRebalanceNodeRequest) Reset()

func (*InitiateRebalanceNodeRequest) String 

func (m *InitiateRebalanceNodeRequest) String() string

type KeyedVersions 

type KeyedVersions struct {
	Key              []byte       `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Versions         []*Versioned `protobuf:"bytes,2,rep,name=versions" json:"versions,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*KeyedVersions) Descriptor 

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

func (*KeyedVersions) GetKey 

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

func (*KeyedVersions) GetVersions 

func (m *KeyedVersions) GetVersions() []*Versioned

func (*KeyedVersions) ProtoMessage 

func (*KeyedVersions) ProtoMessage()

func (*KeyedVersions) Reset 

func (m *KeyedVersions) Reset()

func (*KeyedVersions) String 

func (m *KeyedVersions) String() string

type ListScheduledJobsRequest 

type ListScheduledJobsRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ListScheduledJobsRequest) Descriptor 

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

func (*ListScheduledJobsRequest) ProtoMessage 

func (*ListScheduledJobsRequest) ProtoMessage()

func (*ListScheduledJobsRequest) Reset 

func (m *ListScheduledJobsRequest) Reset()

func (*ListScheduledJobsRequest) String 

func (m *ListScheduledJobsRequest) String() string

type ListScheduledJobsResponse 

type ListScheduledJobsResponse struct {
	JobIds           []string `protobuf:"bytes,1,rep,name=job_ids,json=jobIds" json:"job_ids,omitempty"`
	Error            *Error   `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ListScheduledJobsResponse) Descriptor 

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

func (*ListScheduledJobsResponse) GetError 

func (m *ListScheduledJobsResponse) GetError() *Error

func (*ListScheduledJobsResponse) GetJobIds 

func (m *ListScheduledJobsResponse) GetJobIds() []string

func (*ListScheduledJobsResponse) ProtoMessage 

func (*ListScheduledJobsResponse) ProtoMessage()

func (*ListScheduledJobsResponse) Reset 

func (m *ListScheduledJobsResponse) Reset()

func (*ListScheduledJobsResponse) String 

func (m *ListScheduledJobsResponse) String() string

type MapFieldEntry 

type MapFieldEntry struct {
	Key              *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*MapFieldEntry) Descriptor 

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

func (*MapFieldEntry) GetKey 

func (m *MapFieldEntry) GetKey() string

func (*MapFieldEntry) GetValue 

func (m *MapFieldEntry) GetValue() string

func (*MapFieldEntry) ProtoMessage 

func (*MapFieldEntry) ProtoMessage()

func (*MapFieldEntry) Reset 

func (m *MapFieldEntry) Reset()

func (*MapFieldEntry) String 

func (m *MapFieldEntry) String() string

type NativeBackupRequest 

type NativeBackupRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	BackupDir        *string `protobuf:"bytes,2,req,name=backup_dir,json=backupDir" json:"backup_dir,omitempty"`
	VerifyFiles      *bool   `protobuf:"varint,3,req,name=verify_files,json=verifyFiles" json:"verify_files,omitempty"`
	Incremental      *bool   `protobuf:"varint,4,req,name=incremental" json:"incremental,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NativeBackupRequest) Descriptor 

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

func (*NativeBackupRequest) GetBackupDir 

func (m *NativeBackupRequest) GetBackupDir() string

func (*NativeBackupRequest) GetIncremental 

func (m *NativeBackupRequest) GetIncremental() bool

func (*NativeBackupRequest) GetStoreName 

func (m *NativeBackupRequest) GetStoreName() string

func (*NativeBackupRequest) GetVerifyFiles 

func (m *NativeBackupRequest) GetVerifyFiles() bool

func (*NativeBackupRequest) ProtoMessage 

func (*NativeBackupRequest) ProtoMessage()

func (*NativeBackupRequest) Reset 

func (m *NativeBackupRequest) Reset()

func (*NativeBackupRequest) String 

func (m *NativeBackupRequest) String() string

type PartitionEntry 

type PartitionEntry struct {
	Key              []byte     `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Versioned        *Versioned `protobuf:"bytes,2,req,name=versioned" json:"versioned,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*PartitionEntry) Descriptor 

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

func (*PartitionEntry) GetKey 

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

func (*PartitionEntry) GetVersioned 

func (m *PartitionEntry) GetVersioned() *Versioned

func (*PartitionEntry) ProtoMessage 

func (*PartitionEntry) ProtoMessage()

func (*PartitionEntry) Reset 

func (m *PartitionEntry) Reset()

func (*PartitionEntry) String 

func (m *PartitionEntry) String() string

type PartitionTuple 

type PartitionTuple struct {
	ReplicaType      *int32  `protobuf:"varint,1,req,name=replica_type,json=replicaType" json:"replica_type,omitempty"`
	Partitions       []int32 `protobuf:"varint,2,rep,name=partitions" json:"partitions,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*PartitionTuple) Descriptor 

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

func (*PartitionTuple) GetPartitions 

func (m *PartitionTuple) GetPartitions() []int32

func (*PartitionTuple) GetReplicaType 

func (m *PartitionTuple) GetReplicaType() int32

func (*PartitionTuple) ProtoMessage 

func (*PartitionTuple) ProtoMessage()

func (*PartitionTuple) Reset 

func (m *PartitionTuple) Reset()

func (*PartitionTuple) String 

func (m *PartitionTuple) String() string

type PerStorePartitionTuple 

type PerStorePartitionTuple struct {
	StoreName          *string           `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	ReplicaToPartition []*PartitionTuple `protobuf:"bytes,2,rep,name=replica_to_partition,json=replicaToPartition" json:"replica_to_partition,omitempty"`
	XXX_unrecognized   []byte            `json:"-"`
}

func (*PerStorePartitionTuple) Descriptor 

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

func (*PerStorePartitionTuple) GetReplicaToPartition 

func (m *PerStorePartitionTuple) GetReplicaToPartition() []*PartitionTuple

func (*PerStorePartitionTuple) GetStoreName 

func (m *PerStorePartitionTuple) GetStoreName() string

func (*PerStorePartitionTuple) ProtoMessage 

func (*PerStorePartitionTuple) ProtoMessage()

func (*PerStorePartitionTuple) Reset 

func (m *PerStorePartitionTuple) Reset()

func (*PerStorePartitionTuple) String 

func (m *PerStorePartitionTuple) String() string

type PruneJobRequest 

type PruneJobRequest struct {
	StoreName        *string `protobuf:"bytes,1,opt,name=store_name,json=storeName" json:"store_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*PruneJobRequest) Descriptor 

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

func (*PruneJobRequest) GetStoreName 

func (m *PruneJobRequest) GetStoreName() string

func (*PruneJobRequest) ProtoMessage 

func (*PruneJobRequest) ProtoMessage()

func (*PruneJobRequest) Reset 

func (m *PruneJobRequest) Reset()

func (*PruneJobRequest) String 

func (m *PruneJobRequest) String() string

type PruneJobResponse 

type PruneJobResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*PruneJobResponse) Descriptor 

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

func (*PruneJobResponse) GetError 

func (m *PruneJobResponse) GetError() *Error

func (*PruneJobResponse) ProtoMessage 

func (*PruneJobResponse) ProtoMessage()

func (*PruneJobResponse) Reset 

func (m *PruneJobResponse) Reset()

func (*PruneJobResponse) String 

func (m *PruneJobResponse) String() string

type PutRequest 

type PutRequest struct {
	Key              []byte     `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Versioned        *Versioned `protobuf:"bytes,2,req,name=versioned" json:"versioned,omitempty"`
	Transforms       []byte     `protobuf:"bytes,3,opt,name=transforms" json:"transforms,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetKey 

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

func (*PutRequest) GetTransforms 

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

func (*PutRequest) GetVersioned 

func (m *PutRequest) GetVersioned() *Versioned

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

type PutResponse 

type PutResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) GetError 

func (m *PutResponse) GetError() *Error

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) String 

func (m *PutResponse) String() string

type ROStoreVersionDirMap 

type ROStoreVersionDirMap struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	StoreDir         *string `protobuf:"bytes,2,req,name=store_dir,json=storeDir" json:"store_dir,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ROStoreVersionDirMap) Descriptor 

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

func (*ROStoreVersionDirMap) GetStoreDir 

func (m *ROStoreVersionDirMap) GetStoreDir() string

func (*ROStoreVersionDirMap) GetStoreName 

func (m *ROStoreVersionDirMap) GetStoreName() string

func (*ROStoreVersionDirMap) ProtoMessage 

func (*ROStoreVersionDirMap) ProtoMessage()

func (*ROStoreVersionDirMap) Reset 

func (m *ROStoreVersionDirMap) Reset()

func (*ROStoreVersionDirMap) String 

func (m *ROStoreVersionDirMap) String() string

type RebalancePartitionInfoMap 

type RebalancePartitionInfoMap struct {
	StealerId                    *int32                    `protobuf:"varint,1,req,name=stealer_id,json=stealerId" json:"stealer_id,omitempty"`
	DonorId                      *int32                    `protobuf:"varint,2,req,name=donor_id,json=donorId" json:"donor_id,omitempty"`
	OBSOLETE__DO_NOT_USE_Attempt *int32                    `` /* 134-byte string literal not displayed */
	ReplicaToAddPartition        []*PerStorePartitionTuple `protobuf:"bytes,4,rep,name=replica_to_add_partition,json=replicaToAddPartition" json:"replica_to_add_partition,omitempty"`
	ReplicaToDeletePartition     []*PerStorePartitionTuple `` /* 130-byte string literal not displayed */
	InitialCluster               *string                   `protobuf:"bytes,6,req,name=initial_cluster,json=initialCluster" json:"initial_cluster,omitempty"`
	XXX_unrecognized             []byte                    `json:"-"`
}

func (*RebalancePartitionInfoMap) Descriptor 

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

func (*RebalancePartitionInfoMap) GetDonorId 

func (m *RebalancePartitionInfoMap) GetDonorId() int32

func (*RebalancePartitionInfoMap) GetInitialCluster 

func (m *RebalancePartitionInfoMap) GetInitialCluster() string

func (*RebalancePartitionInfoMap) GetOBSOLETE__DO_NOT_USE_Attempt 

func (m *RebalancePartitionInfoMap) GetOBSOLETE__DO_NOT_USE_Attempt() int32

func (*RebalancePartitionInfoMap) GetReplicaToAddPartition 

func (m *RebalancePartitionInfoMap) GetReplicaToAddPartition() []*PerStorePartitionTuple

func (*RebalancePartitionInfoMap) GetReplicaToDeletePartition 

func (m *RebalancePartitionInfoMap) GetReplicaToDeletePartition() []*PerStorePartitionTuple

func (*RebalancePartitionInfoMap) GetStealerId 

func (m *RebalancePartitionInfoMap) GetStealerId() int32

func (*RebalancePartitionInfoMap) ProtoMessage 

func (*RebalancePartitionInfoMap) ProtoMessage()

func (*RebalancePartitionInfoMap) Reset 

func (m *RebalancePartitionInfoMap) Reset()

func (*RebalancePartitionInfoMap) String 

func (m *RebalancePartitionInfoMap) String() string

type RebalanceStateChangeRequest 

type RebalanceStateChangeRequest struct {
	RebalanceTaskList     []*RebalanceTaskInfoMap `protobuf:"bytes,1,rep,name=rebalance_task_list,json=rebalanceTaskList" json:"rebalance_task_list,omitempty"`
	ClusterString         *string                 `protobuf:"bytes,2,req,name=cluster_string,json=clusterString" json:"cluster_string,omitempty"`
	StoresString          *string                 `protobuf:"bytes,3,req,name=stores_string,json=storesString" json:"stores_string,omitempty"`
	SwapRo                *bool                   `protobuf:"varint,4,req,name=swap_ro,json=swapRo" json:"swap_ro,omitempty"`
	ChangeClusterMetadata *bool                   `protobuf:"varint,5,req,name=change_cluster_metadata,json=changeClusterMetadata" json:"change_cluster_metadata,omitempty"`
	ChangeRebalanceState  *bool                   `protobuf:"varint,6,req,name=change_rebalance_state,json=changeRebalanceState" json:"change_rebalance_state,omitempty"`
	Rollback              *bool                   `protobuf:"varint,7,req,name=rollback" json:"rollback,omitempty"`
	XXX_unrecognized      []byte                  `json:"-"`
}

func (*RebalanceStateChangeRequest) Descriptor 

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

func (*RebalanceStateChangeRequest) GetChangeClusterMetadata 

func (m *RebalanceStateChangeRequest) GetChangeClusterMetadata() bool

func (*RebalanceStateChangeRequest) GetChangeRebalanceState 

func (m *RebalanceStateChangeRequest) GetChangeRebalanceState() bool

func (*RebalanceStateChangeRequest) GetClusterString 

func (m *RebalanceStateChangeRequest) GetClusterString() string

func (*RebalanceStateChangeRequest) GetRebalanceTaskList 

func (m *RebalanceStateChangeRequest) GetRebalanceTaskList() []*RebalanceTaskInfoMap

func (*RebalanceStateChangeRequest) GetRollback 

func (m *RebalanceStateChangeRequest) GetRollback() bool

func (*RebalanceStateChangeRequest) GetStoresString 

func (m *RebalanceStateChangeRequest) GetStoresString() string

func (*RebalanceStateChangeRequest) GetSwapRo 

func (m *RebalanceStateChangeRequest) GetSwapRo() bool

func (*RebalanceStateChangeRequest) ProtoMessage 

func (*RebalanceStateChangeRequest) ProtoMessage()

func (*RebalanceStateChangeRequest) Reset 

func (m *RebalanceStateChangeRequest) Reset()

func (*RebalanceStateChangeRequest) String 

func (m *RebalanceStateChangeRequest) String() string

type RebalanceStateChangeResponse 

type RebalanceStateChangeResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RebalanceStateChangeResponse) Descriptor 

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

func (*RebalanceStateChangeResponse) GetError 

func (m *RebalanceStateChangeResponse) GetError() *Error

func (*RebalanceStateChangeResponse) ProtoMessage 

func (*RebalanceStateChangeResponse) ProtoMessage()

func (*RebalanceStateChangeResponse) Reset 

func (m *RebalanceStateChangeResponse) Reset()

func (*RebalanceStateChangeResponse) String 

func (m *RebalanceStateChangeResponse) String() string

type RebalanceTaskInfoMap 

type RebalanceTaskInfoMap struct {
	StealerId            *int32                  `protobuf:"varint,1,req,name=stealer_id,json=stealerId" json:"stealer_id,omitempty"`
	DonorId              *int32                  `protobuf:"varint,2,req,name=donor_id,json=donorId" json:"donor_id,omitempty"`
	PerStorePartitionIds []*StoreToPartitionsIds `protobuf:"bytes,3,rep,name=per_store_partition_ids,json=perStorePartitionIds" json:"per_store_partition_ids,omitempty"`
	InitialCluster       *string                 `protobuf:"bytes,4,req,name=initial_cluster,json=initialCluster" json:"initial_cluster,omitempty"`
	XXX_unrecognized     []byte                  `json:"-"`
}

func (*RebalanceTaskInfoMap) Descriptor 

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

func (*RebalanceTaskInfoMap) GetDonorId 

func (m *RebalanceTaskInfoMap) GetDonorId() int32

func (*RebalanceTaskInfoMap) GetInitialCluster 

func (m *RebalanceTaskInfoMap) GetInitialCluster() string

func (*RebalanceTaskInfoMap) GetPerStorePartitionIds 

func (m *RebalanceTaskInfoMap) GetPerStorePartitionIds() []*StoreToPartitionsIds

func (*RebalanceTaskInfoMap) GetStealerId 

func (m *RebalanceTaskInfoMap) GetStealerId() int32

func (*RebalanceTaskInfoMap) ProtoMessage 

func (*RebalanceTaskInfoMap) ProtoMessage()

func (*RebalanceTaskInfoMap) Reset 

func (m *RebalanceTaskInfoMap) Reset()

func (*RebalanceTaskInfoMap) String 

func (m *RebalanceTaskInfoMap) String() string

type RepairJobRequest 

type RepairJobRequest struct {
	StoreName        *string `protobuf:"bytes,1,opt,name=store_name,json=storeName" json:"store_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RepairJobRequest) Descriptor 

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

func (*RepairJobRequest) GetStoreName 

func (m *RepairJobRequest) GetStoreName() string

func (*RepairJobRequest) ProtoMessage 

func (*RepairJobRequest) ProtoMessage()

func (*RepairJobRequest) Reset 

func (m *RepairJobRequest) Reset()

func (*RepairJobRequest) String 

func (m *RepairJobRequest) String() string

type RepairJobResponse 

type RepairJobResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RepairJobResponse) Descriptor 

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

func (*RepairJobResponse) GetError 

func (m *RepairJobResponse) GetError() *Error

func (*RepairJobResponse) ProtoMessage 

func (*RepairJobResponse) ProtoMessage()

func (*RepairJobResponse) Reset 

func (m *RepairJobResponse) Reset()

func (*RepairJobResponse) String 

func (m *RepairJobResponse) String() string

type RequestType 

type RequestType int32
const (
	RequestType_GET         RequestType = 0
	RequestType_GET_ALL     RequestType = 1
	RequestType_PUT         RequestType = 2
	RequestType_DELETE      RequestType = 3
	RequestType_GET_VERSION RequestType = 4
)

func (RequestType) Enum 

func (x RequestType) Enum() *RequestType

func (RequestType) EnumDescriptor 

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

func (RequestType) String 

func (x RequestType) String() string

func (*RequestType) UnmarshalJSON 

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

type ReserveMemoryRequest 

type ReserveMemoryRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	SizeInMb         *int64  `protobuf:"varint,2,req,name=size_in_mb,json=sizeInMb" json:"size_in_mb,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReserveMemoryRequest) Descriptor 

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

func (*ReserveMemoryRequest) GetSizeInMb 

func (m *ReserveMemoryRequest) GetSizeInMb() int64

func (*ReserveMemoryRequest) GetStoreName 

func (m *ReserveMemoryRequest) GetStoreName() string

func (*ReserveMemoryRequest) ProtoMessage 

func (*ReserveMemoryRequest) ProtoMessage()

func (*ReserveMemoryRequest) Reset 

func (m *ReserveMemoryRequest) Reset()

func (*ReserveMemoryRequest) String 

func (m *ReserveMemoryRequest) String() string

type ReserveMemoryResponse 

type ReserveMemoryResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ReserveMemoryResponse) Descriptor 

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

func (*ReserveMemoryResponse) GetError 

func (m *ReserveMemoryResponse) GetError() *Error

func (*ReserveMemoryResponse) ProtoMessage 

func (*ReserveMemoryResponse) ProtoMessage()

func (*ReserveMemoryResponse) Reset 

func (m *ReserveMemoryResponse) Reset()

func (*ReserveMemoryResponse) String 

func (m *ReserveMemoryResponse) String() string

type RollbackStoreRequest 

type RollbackStoreRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	PushVersion      *int64  `protobuf:"varint,2,req,name=push_version,json=pushVersion" json:"push_version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RollbackStoreRequest) Descriptor 

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

func (*RollbackStoreRequest) GetPushVersion 

func (m *RollbackStoreRequest) GetPushVersion() int64

func (*RollbackStoreRequest) GetStoreName 

func (m *RollbackStoreRequest) GetStoreName() string

func (*RollbackStoreRequest) ProtoMessage 

func (*RollbackStoreRequest) ProtoMessage()

func (*RollbackStoreRequest) Reset 

func (m *RollbackStoreRequest) Reset()

func (*RollbackStoreRequest) String 

func (m *RollbackStoreRequest) String() string

type RollbackStoreResponse 

type RollbackStoreResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RollbackStoreResponse) Descriptor 

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

func (*RollbackStoreResponse) GetError 

func (m *RollbackStoreResponse) GetError() *Error

func (*RollbackStoreResponse) ProtoMessage 

func (*RollbackStoreResponse) ProtoMessage()

func (*RollbackStoreResponse) Reset 

func (m *RollbackStoreResponse) Reset()

func (*RollbackStoreResponse) String 

func (m *RollbackStoreResponse) String() string

type SetOfflineStateRequest 

type SetOfflineStateRequest struct {
	OfflineMode      *bool  `protobuf:"varint,1,req,name=offline_mode,json=offlineMode" json:"offline_mode,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetOfflineStateRequest) Descriptor 

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

func (*SetOfflineStateRequest) GetOfflineMode 

func (m *SetOfflineStateRequest) GetOfflineMode() bool

func (*SetOfflineStateRequest) ProtoMessage 

func (*SetOfflineStateRequest) ProtoMessage()

func (*SetOfflineStateRequest) Reset 

func (m *SetOfflineStateRequest) Reset()

func (*SetOfflineStateRequest) String 

func (m *SetOfflineStateRequest) String() string

type SetOfflineStateResponse 

type SetOfflineStateResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetOfflineStateResponse) Descriptor 

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

func (*SetOfflineStateResponse) GetError 

func (m *SetOfflineStateResponse) GetError() *Error

func (*SetOfflineStateResponse) ProtoMessage 

func (*SetOfflineStateResponse) ProtoMessage()

func (*SetOfflineStateResponse) Reset 

func (m *SetOfflineStateResponse) Reset()

func (*SetOfflineStateResponse) String 

func (m *SetOfflineStateResponse) String() string

type Slop 

type Slop struct {
	Store            *string `protobuf:"bytes,1,opt,name=store" json:"store,omitempty"`
	Operation        *string `protobuf:"bytes,2,opt,name=operation" json:"operation,omitempty"`
	Key              []byte  `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
	Value            []byte  `protobuf:"bytes,4,opt,name=value" json:"value,omitempty"`
	NodeId           *int32  `protobuf:"varint,5,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	Arrived          *int64  `protobuf:"varint,6,opt,name=arrived" json:"arrived,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Slop) Descriptor 

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

func (*Slop) GetArrived 

func (m *Slop) GetArrived() int64

func (*Slop) GetKey 

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

func (*Slop) GetNodeId 

func (m *Slop) GetNodeId() int32

func (*Slop) GetOperation 

func (m *Slop) GetOperation() string

func (*Slop) GetStore 

func (m *Slop) GetStore() string

func (*Slop) GetValue 

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

func (*Slop) ProtoMessage 

func (*Slop) ProtoMessage()

func (*Slop) Reset 

func (m *Slop) Reset()

func (*Slop) String 

func (m *Slop) String() string

type SlopPurgeJobRequest 

type SlopPurgeJobRequest struct {
	FilterNodeIds    []int32  `protobuf:"varint,1,rep,name=filter_node_ids,json=filterNodeIds" json:"filter_node_ids,omitempty"`
	FilterZoneId     *int32   `protobuf:"varint,2,opt,name=filter_zone_id,json=filterZoneId" json:"filter_zone_id,omitempty"`
	FilterStoreNames []string `protobuf:"bytes,3,rep,name=filter_store_names,json=filterStoreNames" json:"filter_store_names,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SlopPurgeJobRequest) Descriptor 

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

func (*SlopPurgeJobRequest) GetFilterNodeIds 

func (m *SlopPurgeJobRequest) GetFilterNodeIds() []int32

func (*SlopPurgeJobRequest) GetFilterStoreNames 

func (m *SlopPurgeJobRequest) GetFilterStoreNames() []string

func (*SlopPurgeJobRequest) GetFilterZoneId 

func (m *SlopPurgeJobRequest) GetFilterZoneId() int32

func (*SlopPurgeJobRequest) ProtoMessage 

func (*SlopPurgeJobRequest) ProtoMessage()

func (*SlopPurgeJobRequest) Reset 

func (m *SlopPurgeJobRequest) Reset()

func (*SlopPurgeJobRequest) String 

func (m *SlopPurgeJobRequest) String() string

type SlopPurgeJobResponse 

type SlopPurgeJobResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SlopPurgeJobResponse) Descriptor 

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

func (*SlopPurgeJobResponse) GetError 

func (m *SlopPurgeJobResponse) GetError() *Error

func (*SlopPurgeJobResponse) ProtoMessage 

func (*SlopPurgeJobResponse) ProtoMessage()

func (*SlopPurgeJobResponse) Reset 

func (m *SlopPurgeJobResponse) Reset()

func (*SlopPurgeJobResponse) String 

func (m *SlopPurgeJobResponse) String() string

type StopScheduledJobRequest 

type StopScheduledJobRequest struct {
	JobId            *string `protobuf:"bytes,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StopScheduledJobRequest) Descriptor 

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

func (*StopScheduledJobRequest) GetJobId 

func (m *StopScheduledJobRequest) GetJobId() string

func (*StopScheduledJobRequest) ProtoMessage 

func (*StopScheduledJobRequest) ProtoMessage()

func (*StopScheduledJobRequest) Reset 

func (m *StopScheduledJobRequest) Reset()

func (*StopScheduledJobRequest) String 

func (m *StopScheduledJobRequest) String() string

type StopScheduledJobResponse 

type StopScheduledJobResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*StopScheduledJobResponse) Descriptor 

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

func (*StopScheduledJobResponse) GetError 

func (m *StopScheduledJobResponse) GetError() *Error

func (*StopScheduledJobResponse) ProtoMessage 

func (*StopScheduledJobResponse) ProtoMessage()

func (*StopScheduledJobResponse) Reset 

func (m *StopScheduledJobResponse) Reset()

func (*StopScheduledJobResponse) String 

func (m *StopScheduledJobResponse) String() string

type StoreToPartitionsIds 

type StoreToPartitionsIds struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	PartitionIds     []int32 `protobuf:"varint,2,rep,name=partition_ids,json=partitionIds" json:"partition_ids,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StoreToPartitionsIds) Descriptor 

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

func (*StoreToPartitionsIds) GetPartitionIds 

func (m *StoreToPartitionsIds) GetPartitionIds() []int32

func (*StoreToPartitionsIds) GetStoreName 

func (m *StoreToPartitionsIds) GetStoreName() string

func (*StoreToPartitionsIds) ProtoMessage 

func (*StoreToPartitionsIds) ProtoMessage()

func (*StoreToPartitionsIds) Reset 

func (m *StoreToPartitionsIds) Reset()

func (*StoreToPartitionsIds) String 

func (m *StoreToPartitionsIds) String() string

type SwapStoreRequest 

type SwapStoreRequest struct {
	StoreName        *string `protobuf:"bytes,1,req,name=store_name,json=storeName" json:"store_name,omitempty"`
	StoreDir         *string `protobuf:"bytes,2,req,name=store_dir,json=storeDir" json:"store_dir,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SwapStoreRequest) Descriptor 

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

func (*SwapStoreRequest) GetStoreDir 

func (m *SwapStoreRequest) GetStoreDir() string

func (*SwapStoreRequest) GetStoreName 

func (m *SwapStoreRequest) GetStoreName() string

func (*SwapStoreRequest) ProtoMessage 

func (*SwapStoreRequest) ProtoMessage()

func (*SwapStoreRequest) Reset 

func (m *SwapStoreRequest) Reset()

func (*SwapStoreRequest) String 

func (m *SwapStoreRequest) String() string

type SwapStoreResponse 

type SwapStoreResponse struct {
	Error            *Error  `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PreviousStoreDir *string `protobuf:"bytes,2,opt,name=previous_store_dir,json=previousStoreDir" json:"previous_store_dir,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SwapStoreResponse) Descriptor 

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

func (*SwapStoreResponse) GetError 

func (m *SwapStoreResponse) GetError() *Error

func (*SwapStoreResponse) GetPreviousStoreDir 

func (m *SwapStoreResponse) GetPreviousStoreDir() string

func (*SwapStoreResponse) ProtoMessage 

func (*SwapStoreResponse) ProtoMessage()

func (*SwapStoreResponse) Reset 

func (m *SwapStoreResponse) Reset()

func (*SwapStoreResponse) String 

func (m *SwapStoreResponse) String() string

type TruncateEntriesRequest 

type TruncateEntriesRequest struct {
	Store            *string `protobuf:"bytes,1,req,name=store" json:"store,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TruncateEntriesRequest) Descriptor 

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

func (*TruncateEntriesRequest) GetStore 

func (m *TruncateEntriesRequest) GetStore() string

func (*TruncateEntriesRequest) ProtoMessage 

func (*TruncateEntriesRequest) ProtoMessage()

func (*TruncateEntriesRequest) Reset 

func (m *TruncateEntriesRequest) Reset()

func (*TruncateEntriesRequest) String 

func (m *TruncateEntriesRequest) String() string

type TruncateEntriesResponse 

type TruncateEntriesResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TruncateEntriesResponse) Descriptor 

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

func (*TruncateEntriesResponse) GetError 

func (m *TruncateEntriesResponse) GetError() *Error

func (*TruncateEntriesResponse) ProtoMessage 

func (*TruncateEntriesResponse) ProtoMessage()

func (*TruncateEntriesResponse) Reset 

func (m *TruncateEntriesResponse) Reset()

func (*TruncateEntriesResponse) String 

func (m *TruncateEntriesResponse) String() string

type UpdateMetadataPairRequest 

type UpdateMetadataPairRequest struct {
	ClusterKey       []byte     `protobuf:"bytes,1,req,name=cluster_key,json=clusterKey" json:"cluster_key,omitempty"`
	ClusterValue     *Versioned `protobuf:"bytes,2,req,name=cluster_value,json=clusterValue" json:"cluster_value,omitempty"`
	StoresKey        []byte     `protobuf:"bytes,3,req,name=stores_key,json=storesKey" json:"stores_key,omitempty"`
	StoresValue      *Versioned `protobuf:"bytes,4,req,name=stores_value,json=storesValue" json:"stores_value,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*UpdateMetadataPairRequest) Descriptor 

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

func (*UpdateMetadataPairRequest) GetClusterKey 

func (m *UpdateMetadataPairRequest) GetClusterKey() []byte

func (*UpdateMetadataPairRequest) GetClusterValue 

func (m *UpdateMetadataPairRequest) GetClusterValue() *Versioned

func (*UpdateMetadataPairRequest) GetStoresKey 

func (m *UpdateMetadataPairRequest) GetStoresKey() []byte

func (*UpdateMetadataPairRequest) GetStoresValue 

func (m *UpdateMetadataPairRequest) GetStoresValue() *Versioned

func (*UpdateMetadataPairRequest) ProtoMessage 

func (*UpdateMetadataPairRequest) ProtoMessage()

func (*UpdateMetadataPairRequest) Reset 

func (m *UpdateMetadataPairRequest) Reset()

func (*UpdateMetadataPairRequest) String 

func (m *UpdateMetadataPairRequest) String() string

type UpdateMetadataPairResponse 

type UpdateMetadataPairResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*UpdateMetadataPairResponse) Descriptor 

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

func (*UpdateMetadataPairResponse) GetError 

func (m *UpdateMetadataPairResponse) GetError() *Error

func (*UpdateMetadataPairResponse) ProtoMessage 

func (*UpdateMetadataPairResponse) ProtoMessage()

func (*UpdateMetadataPairResponse) Reset 

func (m *UpdateMetadataPairResponse) Reset()

func (*UpdateMetadataPairResponse) String 

func (m *UpdateMetadataPairResponse) String() string

type UpdateMetadataRequest 

type UpdateMetadataRequest struct {
	Key              []byte     `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Versioned        *Versioned `protobuf:"bytes,2,req,name=versioned" json:"versioned,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*UpdateMetadataRequest) Descriptor 

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

func (*UpdateMetadataRequest) GetKey 

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

func (*UpdateMetadataRequest) GetVersioned 

func (m *UpdateMetadataRequest) GetVersioned() *Versioned

func (*UpdateMetadataRequest) ProtoMessage 

func (*UpdateMetadataRequest) ProtoMessage()

func (*UpdateMetadataRequest) Reset 

func (m *UpdateMetadataRequest) Reset()

func (*UpdateMetadataRequest) String 

func (m *UpdateMetadataRequest) String() string

type UpdateMetadataResponse 

type UpdateMetadataResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*UpdateMetadataResponse) Descriptor 

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

func (*UpdateMetadataResponse) GetError 

func (m *UpdateMetadataResponse) GetError() *Error

func (*UpdateMetadataResponse) ProtoMessage 

func (*UpdateMetadataResponse) ProtoMessage()

func (*UpdateMetadataResponse) Reset 

func (m *UpdateMetadataResponse) Reset()

func (*UpdateMetadataResponse) String 

func (m *UpdateMetadataResponse) String() string

type UpdatePartitionEntriesRequest 

type UpdatePartitionEntriesRequest struct {
	Store               *string          `protobuf:"bytes,1,req,name=store" json:"store,omitempty"`
	PartitionEntry      *PartitionEntry  `protobuf:"bytes,2,req,name=partition_entry,json=partitionEntry" json:"partition_entry,omitempty"`
	Filter              *VoldemortFilter `protobuf:"bytes,3,opt,name=filter" json:"filter,omitempty"`
	OverwriteIfLatestTs *bool            `protobuf:"varint,4,opt,name=overwriteIfLatestTs" json:"overwriteIfLatestTs,omitempty"`
	XXX_unrecognized    []byte           `json:"-"`
}

func (*UpdatePartitionEntriesRequest) Descriptor 

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

func (*UpdatePartitionEntriesRequest) GetFilter 

func (m *UpdatePartitionEntriesRequest) GetFilter() *VoldemortFilter

func (*UpdatePartitionEntriesRequest) GetOverwriteIfLatestTs 

func (m *UpdatePartitionEntriesRequest) GetOverwriteIfLatestTs() bool

func (*UpdatePartitionEntriesRequest) GetPartitionEntry 

func (m *UpdatePartitionEntriesRequest) GetPartitionEntry() *PartitionEntry

func (*UpdatePartitionEntriesRequest) GetStore 

func (m *UpdatePartitionEntriesRequest) GetStore() string

func (*UpdatePartitionEntriesRequest) ProtoMessage 

func (*UpdatePartitionEntriesRequest) ProtoMessage()

func (*UpdatePartitionEntriesRequest) Reset 

func (m *UpdatePartitionEntriesRequest) Reset()

func (*UpdatePartitionEntriesRequest) String 

func (m *UpdatePartitionEntriesRequest) String() string

type UpdatePartitionEntriesResponse 

type UpdatePartitionEntriesResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*UpdatePartitionEntriesResponse) Descriptor 

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

func (*UpdatePartitionEntriesResponse) GetError 

func (m *UpdatePartitionEntriesResponse) GetError() *Error

func (*UpdatePartitionEntriesResponse) ProtoMessage 

func (*UpdatePartitionEntriesResponse) ProtoMessage()

func (*UpdatePartitionEntriesResponse) Reset 

func (m *UpdatePartitionEntriesResponse) Reset()

func (*UpdatePartitionEntriesResponse) String 

func (m *UpdatePartitionEntriesResponse) String() string

type UpdateSlopEntriesRequest 

type UpdateSlopEntriesRequest struct {
	Store            *string      `protobuf:"bytes,1,req,name=store" json:"store,omitempty"`
	Key              []byte       `protobuf:"bytes,2,req,name=key" json:"key,omitempty"`
	Version          *VectorClock `protobuf:"bytes,3,req,name=version" json:"version,omitempty"`
	RequestType      *RequestType `protobuf:"varint,4,req,name=request_type,json=requestType,enum=voldemort.RequestType" json:"request_type,omitempty"`
	Value            []byte       `protobuf:"bytes,5,opt,name=value" json:"value,omitempty"`
	Transform        []byte       `protobuf:"bytes,6,opt,name=transform" json:"transform,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*UpdateSlopEntriesRequest) Descriptor 

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

func (*UpdateSlopEntriesRequest) GetKey 

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

func (*UpdateSlopEntriesRequest) GetRequestType 

func (m *UpdateSlopEntriesRequest) GetRequestType() RequestType

func (*UpdateSlopEntriesRequest) GetStore 

func (m *UpdateSlopEntriesRequest) GetStore() string

func (*UpdateSlopEntriesRequest) GetTransform 

func (m *UpdateSlopEntriesRequest) GetTransform() []byte

func (*UpdateSlopEntriesRequest) GetValue 

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

func (*UpdateSlopEntriesRequest) GetVersion 

func (m *UpdateSlopEntriesRequest) GetVersion() *VectorClock

func (*UpdateSlopEntriesRequest) ProtoMessage 

func (*UpdateSlopEntriesRequest) ProtoMessage()

func (*UpdateSlopEntriesRequest) Reset 

func (m *UpdateSlopEntriesRequest) Reset()

func (*UpdateSlopEntriesRequest) String 

func (m *UpdateSlopEntriesRequest) String() string

type UpdateSlopEntriesResponse 

type UpdateSlopEntriesResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*UpdateSlopEntriesResponse) Descriptor 

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

func (*UpdateSlopEntriesResponse) GetError 

func (m *UpdateSlopEntriesResponse) GetError() *Error

func (*UpdateSlopEntriesResponse) ProtoMessage 

func (*UpdateSlopEntriesResponse) ProtoMessage()

func (*UpdateSlopEntriesResponse) Reset 

func (m *UpdateSlopEntriesResponse) Reset()

func (*UpdateSlopEntriesResponse) String 

func (m *UpdateSlopEntriesResponse) String() string

type UpdateStoreDefinitions 

type UpdateStoreDefinitions struct {
	Key              []byte     `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Versioned        *Versioned `protobuf:"bytes,2,req,name=versioned" json:"versioned,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*UpdateStoreDefinitions) Descriptor 

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

func (*UpdateStoreDefinitions) GetKey 

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

func (*UpdateStoreDefinitions) GetVersioned 

func (m *UpdateStoreDefinitions) GetVersioned() *Versioned

func (*UpdateStoreDefinitions) ProtoMessage 

func (*UpdateStoreDefinitions) ProtoMessage()

func (*UpdateStoreDefinitions) Reset 

func (m *UpdateStoreDefinitions) Reset()

func (*UpdateStoreDefinitions) String 

func (m *UpdateStoreDefinitions) String() string

type VectorClock 

type VectorClock struct {
	Entries          []*ClockEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	Timestamp        *int64        `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*VectorClock) Descriptor 

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

func (*VectorClock) GetEntries 

func (m *VectorClock) GetEntries() []*ClockEntry

func (*VectorClock) GetTimestamp 

func (m *VectorClock) GetTimestamp() int64

func (*VectorClock) ProtoMessage 

func (*VectorClock) ProtoMessage()

func (*VectorClock) Reset 

func (m *VectorClock) Reset()

func (*VectorClock) String 

func (m *VectorClock) String() string

type Versioned 

type Versioned struct {
	Value            []byte       `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	Version          *VectorClock `protobuf:"bytes,2,req,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*Versioned) Descriptor 

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

func (*Versioned) GetValue 

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

func (*Versioned) GetVersion 

func (m *Versioned) GetVersion() *VectorClock

func (*Versioned) ProtoMessage 

func (*Versioned) ProtoMessage()

func (*Versioned) Reset 

func (m *Versioned) Reset()

func (*Versioned) String 

func (m *Versioned) String() string

type VoldemortAdminRequest 

type VoldemortAdminRequest struct {
	Type                   *AdminRequestType              `protobuf:"varint,1,req,name=type,enum=voldemort.AdminRequestType" json:"type,omitempty"`
	GetMetadata            *GetMetadataRequest            `protobuf:"bytes,2,opt,name=get_metadata,json=getMetadata" json:"get_metadata,omitempty"`
	UpdateMetadata         *UpdateMetadataRequest         `protobuf:"bytes,3,opt,name=update_metadata,json=updateMetadata" json:"update_metadata,omitempty"`
	UpdatePartitionEntries *UpdatePartitionEntriesRequest `protobuf:"bytes,4,opt,name=update_partition_entries,json=updatePartitionEntries" json:"update_partition_entries,omitempty"`
	FetchPartitionEntries  *FetchPartitionEntriesRequest  `protobuf:"bytes,5,opt,name=fetch_partition_entries,json=fetchPartitionEntries" json:"fetch_partition_entries,omitempty"`
	DeletePartitionEntries *DeletePartitionEntriesRequest `protobuf:"bytes,6,opt,name=delete_partition_entries,json=deletePartitionEntries" json:"delete_partition_entries,omitempty"`
	InitiateFetchAndUpdate *InitiateFetchAndUpdateRequest `protobuf:"bytes,7,opt,name=initiate_fetch_and_update,json=initiateFetchAndUpdate" json:"initiate_fetch_and_update,omitempty"`
	AsyncOperationStatus   *AsyncOperationStatusRequest   `protobuf:"bytes,8,opt,name=async_operation_status,json=asyncOperationStatus" json:"async_operation_status,omitempty"`
	InitiateRebalanceNode  *InitiateRebalanceNodeRequest  `protobuf:"bytes,9,opt,name=initiate_rebalance_node,json=initiateRebalanceNode" json:"initiate_rebalance_node,omitempty"`
	AsyncOperationStop     *AsyncOperationStopRequest     `protobuf:"bytes,10,opt,name=async_operation_stop,json=asyncOperationStop" json:"async_operation_stop,omitempty"`
	AsyncOperationList     *AsyncOperationListRequest     `protobuf:"bytes,11,opt,name=async_operation_list,json=asyncOperationList" json:"async_operation_list,omitempty"`
	TruncateEntries        *TruncateEntriesRequest        `protobuf:"bytes,12,opt,name=truncate_entries,json=truncateEntries" json:"truncate_entries,omitempty"`
	AddStore               *AddStoreRequest               `protobuf:"bytes,13,opt,name=add_store,json=addStore" json:"add_store,omitempty"`
	DeleteStore            *DeleteStoreRequest            `protobuf:"bytes,14,opt,name=delete_store,json=deleteStore" json:"delete_store,omitempty"`
	FetchStore             *FetchStoreRequest             `protobuf:"bytes,15,opt,name=fetch_store,json=fetchStore" json:"fetch_store,omitempty"`
	SwapStore              *SwapStoreRequest              `protobuf:"bytes,16,opt,name=swap_store,json=swapStore" json:"swap_store,omitempty"`
	RollbackStore          *RollbackStoreRequest          `protobuf:"bytes,17,opt,name=rollback_store,json=rollbackStore" json:"rollback_store,omitempty"`
	GetRoMaxVersionDir     *GetROMaxVersionDirRequest     `protobuf:"bytes,18,opt,name=get_ro_max_version_dir,json=getRoMaxVersionDir" json:"get_ro_max_version_dir,omitempty"`
	GetRoCurrentVersionDir *GetROCurrentVersionDirRequest `` /* 127-byte string literal not displayed */
	FetchPartitionFiles    *FetchPartitionFilesRequest    `protobuf:"bytes,20,opt,name=fetch_partition_files,json=fetchPartitionFiles" json:"fetch_partition_files,omitempty"`
	UpdateSlopEntries      *UpdateSlopEntriesRequest      `protobuf:"bytes,22,opt,name=update_slop_entries,json=updateSlopEntries" json:"update_slop_entries,omitempty"`
	FailedFetchStore       *FailedFetchStoreRequest       `protobuf:"bytes,24,opt,name=failed_fetch_store,json=failedFetchStore" json:"failed_fetch_store,omitempty"`
	GetRoStorageFormat     *GetROStorageFormatRequest     `protobuf:"bytes,25,opt,name=get_ro_storage_format,json=getRoStorageFormat" json:"get_ro_storage_format,omitempty"`
	RebalanceStateChange   *RebalanceStateChangeRequest   `protobuf:"bytes,26,opt,name=rebalance_state_change,json=rebalanceStateChange" json:"rebalance_state_change,omitempty"`
	RepairJob              *RepairJobRequest              `protobuf:"bytes,27,opt,name=repair_job,json=repairJob" json:"repair_job,omitempty"`
	// optional InitiateRebalanceNodeOnDonorRequest initiate_rebalance_node_on_donor = 28;
	DeleteStoreRebalanceState *DeleteStoreRebalanceStateRequest        `` /* 134-byte string literal not displayed */
	NativeBackup              *NativeBackupRequest                     `protobuf:"bytes,30,opt,name=native_backup,json=nativeBackup" json:"native_backup,omitempty"`
	ReserveMemory             *ReserveMemoryRequest                    `protobuf:"bytes,31,opt,name=reserve_memory,json=reserveMemory" json:"reserve_memory,omitempty"`
	PruneJob                  *PruneJobRequest                         `protobuf:"bytes,32,opt,name=prune_job,json=pruneJob" json:"prune_job,omitempty"`
	SlopPurgeJob              *SlopPurgeJobRequest                     `protobuf:"bytes,33,opt,name=slop_purge_job,json=slopPurgeJob" json:"slop_purge_job,omitempty"`
	UpdateMetadataPair        *UpdateMetadataPairRequest               `protobuf:"bytes,34,opt,name=update_metadata_pair,json=updateMetadataPair" json:"update_metadata_pair,omitempty"`
	UpdateStoreDefinitions    *UpdateStoreDefinitions                  `protobuf:"bytes,35,opt,name=update_store_definitions,json=updateStoreDefinitions" json:"update_store_definitions,omitempty"`
	SetOfflineState           *SetOfflineStateRequest                  `protobuf:"bytes,36,opt,name=set_offline_state,json=setOfflineState" json:"set_offline_state,omitempty"`
	GetRoStorageFileList      *GetROStorageFileListRequest             `protobuf:"bytes,37,opt,name=get_ro_storage_file_list,json=getRoStorageFileList" json:"get_ro_storage_file_list,omitempty"`
	GetRoCompressionCodecList *GetROStorageCompressionCodecListRequest `` /* 136-byte string literal not displayed */
	ListScheduledJobs         *ListScheduledJobsRequest                `protobuf:"bytes,39,opt,name=list_scheduled_jobs,json=listScheduledJobs" json:"list_scheduled_jobs,omitempty"`
	GetScheduledJobStatus     *GetScheduledJobStatusRequest            `protobuf:"bytes,40,opt,name=get_scheduled_job_status,json=getScheduledJobStatus" json:"get_scheduled_job_status,omitempty"`
	StopScheduledJob          *StopScheduledJobRequest                 `protobuf:"bytes,41,opt,name=stop_scheduled_job,json=stopScheduledJob" json:"stop_scheduled_job,omitempty"`
	EnableScheduledJob        *EnableScheduledJobRequest               `protobuf:"bytes,42,opt,name=enable_scheduled_job,json=enableScheduledJob" json:"enable_scheduled_job,omitempty"`
	GetHaSettings             *GetHighAvailabilitySettingsRequest      `protobuf:"bytes,43,opt,name=get_ha_settings,json=getHaSettings" json:"get_ha_settings,omitempty"`
	DisableStoreVersion       *DisableStoreVersionRequest              `protobuf:"bytes,44,opt,name=disable_store_version,json=disableStoreVersion" json:"disable_store_version,omitempty"`
	HandleFetchFailure        *HandleFetchFailureRequest               `protobuf:"bytes,45,opt,name=handle_fetch_failure,json=handleFetchFailure" json:"handle_fetch_failure,omitempty"`
	GetConfig                 *GetConfigRequest                        `protobuf:"bytes,46,opt,name=get_config,json=getConfig" json:"get_config,omitempty"`
	XXX_unrecognized          []byte                                   `json:"-"`
}

func (*VoldemortAdminRequest) Descriptor 

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

func (*VoldemortAdminRequest) GetAddStore 

func (m *VoldemortAdminRequest) GetAddStore() *AddStoreRequest

func (*VoldemortAdminRequest) GetAsyncOperationList 

func (m *VoldemortAdminRequest) GetAsyncOperationList() *AsyncOperationListRequest

func (*VoldemortAdminRequest) GetAsyncOperationStatus 

func (m *VoldemortAdminRequest) GetAsyncOperationStatus() *AsyncOperationStatusRequest

func (*VoldemortAdminRequest) GetAsyncOperationStop 

func (m *VoldemortAdminRequest) GetAsyncOperationStop() *AsyncOperationStopRequest

func (*VoldemortAdminRequest) GetDeletePartitionEntries 

func (m *VoldemortAdminRequest) GetDeletePartitionEntries() *DeletePartitionEntriesRequest

func (*VoldemortAdminRequest) GetDeleteStore 

func (m *VoldemortAdminRequest) GetDeleteStore() *DeleteStoreRequest

func (*VoldemortAdminRequest) GetDeleteStoreRebalanceState 

func (m *VoldemortAdminRequest) GetDeleteStoreRebalanceState() *DeleteStoreRebalanceStateRequest

func (*VoldemortAdminRequest) GetDisableStoreVersion 

func (m *VoldemortAdminRequest) GetDisableStoreVersion() *DisableStoreVersionRequest

func (*VoldemortAdminRequest) GetEnableScheduledJob 

func (m *VoldemortAdminRequest) GetEnableScheduledJob() *EnableScheduledJobRequest

func (*VoldemortAdminRequest) GetFailedFetchStore 

func (m *VoldemortAdminRequest) GetFailedFetchStore() *FailedFetchStoreRequest

func (*VoldemortAdminRequest) GetFetchPartitionEntries 

func (m *VoldemortAdminRequest) GetFetchPartitionEntries() *FetchPartitionEntriesRequest

func (*VoldemortAdminRequest) GetFetchPartitionFiles 

func (m *VoldemortAdminRequest) GetFetchPartitionFiles() *FetchPartitionFilesRequest

func (*VoldemortAdminRequest) GetFetchStore 

func (m *VoldemortAdminRequest) GetFetchStore() *FetchStoreRequest

func (*VoldemortAdminRequest) GetGetConfig 

func (m *VoldemortAdminRequest) GetGetConfig() *GetConfigRequest

func (*VoldemortAdminRequest) GetGetHaSettings 

func (m *VoldemortAdminRequest) GetGetHaSettings() *GetHighAvailabilitySettingsRequest

func (*VoldemortAdminRequest) GetGetMetadata 

func (m *VoldemortAdminRequest) GetGetMetadata() *GetMetadataRequest

func (*VoldemortAdminRequest) GetGetRoCompressionCodecList 

func (m *VoldemortAdminRequest) GetGetRoCompressionCodecList() *GetROStorageCompressionCodecListRequest

func (*VoldemortAdminRequest) GetGetRoCurrentVersionDir 

func (m *VoldemortAdminRequest) GetGetRoCurrentVersionDir() *GetROCurrentVersionDirRequest

func (*VoldemortAdminRequest) GetGetRoMaxVersionDir 

func (m *VoldemortAdminRequest) GetGetRoMaxVersionDir() *GetROMaxVersionDirRequest

func (*VoldemortAdminRequest) GetGetRoStorageFileList 

func (m *VoldemortAdminRequest) GetGetRoStorageFileList() *GetROStorageFileListRequest

func (*VoldemortAdminRequest) GetGetRoStorageFormat 

func (m *VoldemortAdminRequest) GetGetRoStorageFormat() *GetROStorageFormatRequest

func (*VoldemortAdminRequest) GetGetScheduledJobStatus 

func (m *VoldemortAdminRequest) GetGetScheduledJobStatus() *GetScheduledJobStatusRequest

func (*VoldemortAdminRequest) GetHandleFetchFailure 

func (m *VoldemortAdminRequest) GetHandleFetchFailure() *HandleFetchFailureRequest

func (*VoldemortAdminRequest) GetInitiateFetchAndUpdate 

func (m *VoldemortAdminRequest) GetInitiateFetchAndUpdate() *InitiateFetchAndUpdateRequest

func (*VoldemortAdminRequest) GetInitiateRebalanceNode 

func (m *VoldemortAdminRequest) GetInitiateRebalanceNode() *InitiateRebalanceNodeRequest

func (*VoldemortAdminRequest) GetListScheduledJobs 

func (m *VoldemortAdminRequest) GetListScheduledJobs() *ListScheduledJobsRequest

func (*VoldemortAdminRequest) GetNativeBackup 

func (m *VoldemortAdminRequest) GetNativeBackup() *NativeBackupRequest

func (*VoldemortAdminRequest) GetPruneJob 

func (m *VoldemortAdminRequest) GetPruneJob() *PruneJobRequest

func (*VoldemortAdminRequest) GetRebalanceStateChange 

func (m *VoldemortAdminRequest) GetRebalanceStateChange() *RebalanceStateChangeRequest

func (*VoldemortAdminRequest) GetRepairJob 

func (m *VoldemortAdminRequest) GetRepairJob() *RepairJobRequest

func (*VoldemortAdminRequest) GetReserveMemory 

func (m *VoldemortAdminRequest) GetReserveMemory() *ReserveMemoryRequest

func (*VoldemortAdminRequest) GetRollbackStore 

func (m *VoldemortAdminRequest) GetRollbackStore() *RollbackStoreRequest

func (*VoldemortAdminRequest) GetSetOfflineState 

func (m *VoldemortAdminRequest) GetSetOfflineState() *SetOfflineStateRequest

func (*VoldemortAdminRequest) GetSlopPurgeJob 

func (m *VoldemortAdminRequest) GetSlopPurgeJob() *SlopPurgeJobRequest

func (*VoldemortAdminRequest) GetStopScheduledJob 

func (m *VoldemortAdminRequest) GetStopScheduledJob() *StopScheduledJobRequest

func (*VoldemortAdminRequest) GetSwapStore 

func (m *VoldemortAdminRequest) GetSwapStore() *SwapStoreRequest

func (*VoldemortAdminRequest) GetTruncateEntries 

func (m *VoldemortAdminRequest) GetTruncateEntries() *TruncateEntriesRequest

func (*VoldemortAdminRequest) GetType 

func (m *VoldemortAdminRequest) GetType() AdminRequestType

func (*VoldemortAdminRequest) GetUpdateMetadata 

func (m *VoldemortAdminRequest) GetUpdateMetadata() *UpdateMetadataRequest

func (*VoldemortAdminRequest) GetUpdateMetadataPair 

func (m *VoldemortAdminRequest) GetUpdateMetadataPair() *UpdateMetadataPairRequest

func (*VoldemortAdminRequest) GetUpdatePartitionEntries 

func (m *VoldemortAdminRequest) GetUpdatePartitionEntries() *UpdatePartitionEntriesRequest

func (*VoldemortAdminRequest) GetUpdateSlopEntries 

func (m *VoldemortAdminRequest) GetUpdateSlopEntries() *UpdateSlopEntriesRequest

func (*VoldemortAdminRequest) GetUpdateStoreDefinitions 

func (m *VoldemortAdminRequest) GetUpdateStoreDefinitions() *UpdateStoreDefinitions

func (*VoldemortAdminRequest) ProtoMessage 

func (*VoldemortAdminRequest) ProtoMessage()

func (*VoldemortAdminRequest) Reset 

func (m *VoldemortAdminRequest) Reset()

func (*VoldemortAdminRequest) String 

func (m *VoldemortAdminRequest) String() string

type VoldemortFilter 

type VoldemortFilter struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Data             []byte  `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*VoldemortFilter) Descriptor 

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

func (*VoldemortFilter) GetData 

func (m *VoldemortFilter) GetData() []byte

func (*VoldemortFilter) GetName 

func (m *VoldemortFilter) GetName() string

func (*VoldemortFilter) ProtoMessage 

func (*VoldemortFilter) ProtoMessage()

func (*VoldemortFilter) Reset 

func (m *VoldemortFilter) Reset()

func (*VoldemortFilter) String 

func (m *VoldemortFilter) String() string

type VoldemortRequest 

type VoldemortRequest struct {
	Type             *RequestType   `protobuf:"varint,1,req,name=type,enum=voldemort.RequestType" json:"type,omitempty"`
	ShouldRoute      *bool          `protobuf:"varint,2,req,name=should_route,json=shouldRoute,def=0" json:"should_route,omitempty"`
	Store            *string        `protobuf:"bytes,3,req,name=store" json:"store,omitempty"`
	Get              *GetRequest    `protobuf:"bytes,4,opt,name=get" json:"get,omitempty"`
	GetAll           *GetAllRequest `protobuf:"bytes,5,opt,name=getAll" json:"getAll,omitempty"`
	Put              *PutRequest    `protobuf:"bytes,6,opt,name=put" json:"put,omitempty"`
	Delete           *DeleteRequest `protobuf:"bytes,7,opt,name=delete" json:"delete,omitempty"`
	RequestRouteType *int32         `protobuf:"varint,8,opt,name=requestRouteType" json:"requestRouteType,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*VoldemortRequest) Descriptor 

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

func (*VoldemortRequest) GetDelete 

func (m *VoldemortRequest) GetDelete() *DeleteRequest

func (*VoldemortRequest) GetGet 

func (m *VoldemortRequest) GetGet() *GetRequest

func (*VoldemortRequest) GetGetAll 

func (m *VoldemortRequest) GetGetAll() *GetAllRequest

func (*VoldemortRequest) GetPut 

func (m *VoldemortRequest) GetPut() *PutRequest

func (*VoldemortRequest) GetRequestRouteType 

func (m *VoldemortRequest) GetRequestRouteType() int32

func (*VoldemortRequest) GetShouldRoute 

func (m *VoldemortRequest) GetShouldRoute() bool

func (*VoldemortRequest) GetStore 

func (m *VoldemortRequest) GetStore() string

func (*VoldemortRequest) GetType 

func (m *VoldemortRequest) GetType() RequestType

func (*VoldemortRequest) ProtoMessage 

func (*VoldemortRequest) ProtoMessage()

func (*VoldemortRequest) Reset 

func (m *VoldemortRequest) Reset()

func (*VoldemortRequest) String 

func (m *VoldemortRequest) 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.