multiraftbase

package
v0.0.0-...-81f3bb6 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package multiraftbase is a generated protocol buffer package.

It is generated from these files: 

api.proto
config.proto
error.proto
internal_raft.proto
metadata.proto
raft.proto
state.proto

It has these top-level messages: 

ResponseHeader
GetRequest
DeleteRequest
GetResponse
PutRequest
PutResponse
DeleteResponse
TruncateLogResponse
ChangeConfResponse
RequestUnion
ResponseUnion
Header
BatchRequest
BatchResponse
TruncateLogRequest
ChangeConfRequest
WriteBatch
RaftCommand
HasKeyRequest
HasKeyResponse
SystemConfig
NodeUnavailableError
PgNotFoundError
SendError
AmbiguousResultError
RaftGroupDeletedError
ReplicaCorruptionError
ReplicaTooOldError
NodeNotReadyError
GroupNotFoundError
KeyNonExistent
OnodeBroken
DataLost
StoreNotFoundError
ErrorDetail
ErrPosition
Error
RaftTombstone
RaftSnapshotData
Attributes
ReplicationTarget
ReplicaDescriptor
ReplicaIdent
GroupDescriptor
StoreCapacity
NodeDescriptor
StoreDescriptor
StoreDeadReplicas
KeyValue
Onode
StoreIdent
RaftHeartbeat
RaftMessageRequest
RaftMessageRequestBatch
RaftMessageResponseUnion
RaftMessageResponse
SnapshotRequest
SnapshotResponse
ConfChangeContext
RaftTruncatedState
Stats
ReplicaState
PgInfo

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthConfig = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConfig   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthError = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowError   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthInternalRaft = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInternalRaft   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRaft = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaft   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthState = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowState   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ConfType_name = map[int32]string{
	0: "ADD_REPLICA",
	1: "REMOVE_REPLICA",
}
View Source 
var ConfType_value = map[string]int32{
	"ADD_REPLICA":    0,
	"REMOVE_REPLICA": 1,
}
View Source 
var ReadConsistencyType_name = map[int32]string{
	0: "CONSISTENT",
	1: "CONSENSUS",
	2: "INCONSISTENT",
}
View Source 
var ReadConsistencyType_value = map[string]int32{
	"CONSISTENT":   0,
	"CONSENSUS":    1,
	"INCONSISTENT": 2,
}
View Source 
var SnapshotRequest_Priority_name = map[int32]string{
	0: "UNKNOWN",
	1: "RECOVERY",
	2: "REBALANCE",
}
View Source 
var SnapshotRequest_Priority_value = map[string]int32{
	"UNKNOWN":   0,
	"RECOVERY":  1,
	"REBALANCE": 2,
}
View Source 
var SnapshotResponse_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "ACCEPTED",
	2: "APPLIED",
	3: "ERROR",
	4: "DECLINED",
}
View Source 
var SnapshotResponse_Status_value = map[string]int32{
	"UNKNOWN":  0,
	"ACCEPTED": 1,
	"APPLIED":  2,
	"ERROR":    3,
	"DECLINED": 4,
}

Functions

func RegisterExternalServer 

func RegisterExternalServer(s *grpc.Server, srv ExternalServer)

func RegisterInternalServer 

func RegisterInternalServer(s *grpc.Server, srv InternalServer)

func RegisterMultiRaftServer 

func RegisterMultiRaftServer(s *grpc.Server, srv MultiRaftServer)

Types

type AmbiguousResultError 

type AmbiguousResultError struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// This can be set to give extra information about which error was converted
	// into an AmbiguousResultError. Useful for tests.
	WrappedErr *Error `protobuf:"bytes,2,opt,name=wrapped_err,json=wrappedErr" json:"wrapped_err,omitempty"`
}

An AmbiguousResultError indicates that a request may have succeeded or failed, but the response was not received and the final result is ambiguous.

func NewAmbiguousResultError 

func NewAmbiguousResultError(msg string) *AmbiguousResultError

NewAmbiguousResultError initializes a new AmbiguousResultError with an explanatory message.

func (*AmbiguousResultError) Descriptor 

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

func (*AmbiguousResultError) Equal 

func (this *AmbiguousResultError) Equal(that interface{}) bool

func (*AmbiguousResultError) Error 

func (e *AmbiguousResultError) Error() string

func (*AmbiguousResultError) GetMessage 

func (m *AmbiguousResultError) GetMessage() string

func (*AmbiguousResultError) GetWrappedErr 

func (m *AmbiguousResultError) GetWrappedErr() *Error

func (*AmbiguousResultError) Marshal 

func (m *AmbiguousResultError) Marshal() (dAtA []byte, err error)

func (*AmbiguousResultError) MarshalTo 

func (m *AmbiguousResultError) MarshalTo(dAtA []byte) (int, error)

func (*AmbiguousResultError) ProtoMessage 

func (*AmbiguousResultError) ProtoMessage()

func (*AmbiguousResultError) Reset 

func (m *AmbiguousResultError) Reset()

func (*AmbiguousResultError) Size 

func (m *AmbiguousResultError) Size() (n int)

func (*AmbiguousResultError) String 

func (m *AmbiguousResultError) String() string

func (*AmbiguousResultError) Unmarshal 

func (m *AmbiguousResultError) Unmarshal(dAtA []byte) error

type Attributes 

type Attributes struct {
	Attrs []string `protobuf:"bytes,1,rep,name=attrs" json:"attrs,omitempty"`
}

Attributes specifies a list of arbitrary strings describing node topology, store type, and machine capabilities.

func (*Attributes) Descriptor 

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

func (*Attributes) GetAttrs 

func (m *Attributes) GetAttrs() []string

func (*Attributes) Marshal 

func (m *Attributes) Marshal() (dAtA []byte, err error)

func (*Attributes) MarshalTo 

func (m *Attributes) MarshalTo(dAtA []byte) (int, error)

func (*Attributes) ProtoMessage 

func (*Attributes) ProtoMessage()

func (*Attributes) Reset 

func (m *Attributes) Reset()

func (*Attributes) Size 

func (m *Attributes) Size() (n int)

func (*Attributes) String 

func (m *Attributes) String() string

func (*Attributes) Unmarshal 

func (m *Attributes) Unmarshal(dAtA []byte) error

type BatchRequest 

type BatchRequest struct {
	Header  `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
	Request RequestUnion `protobuf:"bytes,2,opt,name=request" json:"request"`
}

A BatchRequest contains one or more requests to be executed in parallel, or if applicable (based on write-only commands and range-locality), as a single update.

func (*BatchRequest) Descriptor 

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

func (*BatchRequest) GetRequest 

func (m *BatchRequest) GetRequest() RequestUnion

func (*BatchRequest) Marshal 

func (m *BatchRequest) Marshal() (dAtA []byte, err error)

func (*BatchRequest) MarshalTo 

func (m *BatchRequest) MarshalTo(dAtA []byte) (int, error)

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) Reset 

func (m *BatchRequest) Reset()

func (*BatchRequest) Size 

func (m *BatchRequest) Size() (n int)

func (*BatchRequest) Unmarshal 

func (m *BatchRequest) Unmarshal(dAtA []byte) error

type BatchResponse 

type BatchResponse struct {
	BatchResponse_Header `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
	Responses            ResponseUnion `protobuf:"bytes,2,opt,name=responses" json:"responses"`
}

A BatchResponse contains one or more responses, one per request corresponding to the requests in the matching BatchRequest. The error in the response header is set to the first error from the slice of responses, if applicable.

func (*BatchResponse) Descriptor 

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

func (*BatchResponse) GetResponses 

func (m *BatchResponse) GetResponses() ResponseUnion

func (*BatchResponse) Marshal 

func (m *BatchResponse) Marshal() (dAtA []byte, err error)

func (*BatchResponse) MarshalTo 

func (m *BatchResponse) MarshalTo(dAtA []byte) (int, error)

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) Reset 

func (m *BatchResponse) Reset()

func (*BatchResponse) Size 

func (m *BatchResponse) Size() (n int)

func (*BatchResponse) Unmarshal 

func (m *BatchResponse) Unmarshal(dAtA []byte) error

type BatchResponse_Header 

type BatchResponse_Header struct {
	// error is non-nil if an error occurred.
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// collected_spans stores trace spans recorded during the execution of this
	// request.
	CollectedSpans []github_com_journeymidnight_nentropy_util_tracing.RecordedSpan `protobuf:"bytes,6,rep,name=collected_spans,json=collectedSpans" json:"collected_spans"`
}

func (*BatchResponse_Header) Descriptor 

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

func (*BatchResponse_Header) GetCollectedSpans 

func (m *BatchResponse_Header) GetCollectedSpans() []github_com_journeymidnight_nentropy_util_tracing.RecordedSpan

func (*BatchResponse_Header) GetError 

func (m *BatchResponse_Header) GetError() *Error

func (*BatchResponse_Header) Marshal 

func (m *BatchResponse_Header) Marshal() (dAtA []byte, err error)

func (*BatchResponse_Header) MarshalTo 

func (m *BatchResponse_Header) MarshalTo(dAtA []byte) (int, error)

func (*BatchResponse_Header) ProtoMessage 

func (*BatchResponse_Header) ProtoMessage()

func (*BatchResponse_Header) Reset 

func (m *BatchResponse_Header) Reset()

func (*BatchResponse_Header) Size 

func (m *BatchResponse_Header) Size() (n int)

func (*BatchResponse_Header) String 

func (m *BatchResponse_Header) String() string

func (*BatchResponse_Header) Unmarshal 

func (m *BatchResponse_Header) Unmarshal(dAtA []byte) error

type ChangeConfRequest 

type ChangeConfRequest struct {
	ConfType  ConfType `protobuf:"varint,1,opt,name=conf_type,json=confType,proto3,enum=multiraftbase.ConfType" json:"conf_type,omitempty"`
	OsdId     int32    `protobuf:"varint,2,opt,name=osd_id,json=osdId,proto3" json:"osd_id,omitempty"`
	ReplicaId int32    `protobuf:"varint,3,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"`
}

func (*ChangeConfRequest) Descriptor 

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

func (*ChangeConfRequest) Equal 

func (this *ChangeConfRequest) Equal(that interface{}) bool

func (*ChangeConfRequest) GetConfType 

func (m *ChangeConfRequest) GetConfType() ConfType

func (*ChangeConfRequest) GetOsdId 

func (m *ChangeConfRequest) GetOsdId() int32

func (*ChangeConfRequest) GetReplicaId 

func (m *ChangeConfRequest) GetReplicaId() int32

func (*ChangeConfRequest) Marshal 

func (m *ChangeConfRequest) Marshal() (dAtA []byte, err error)

func (*ChangeConfRequest) MarshalTo 

func (m *ChangeConfRequest) MarshalTo(dAtA []byte) (int, error)

func (*ChangeConfRequest) Method 

func (*ChangeConfRequest) Method() Method

Method implements the Request interface.

func (*ChangeConfRequest) ProtoMessage 

func (*ChangeConfRequest) ProtoMessage()

func (*ChangeConfRequest) Reset 

func (m *ChangeConfRequest) Reset()

func (*ChangeConfRequest) ShallowCopy 

func (tr *ChangeConfRequest) ShallowCopy() Request

ShallowCopy implements the Request interface.

func (*ChangeConfRequest) Size 

func (m *ChangeConfRequest) Size() (n int)

func (*ChangeConfRequest) String 

func (m *ChangeConfRequest) String() string

func (*ChangeConfRequest) Unmarshal 

func (m *ChangeConfRequest) Unmarshal(dAtA []byte) error

type ChangeConfResponse 

type ChangeConfResponse struct {
	ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}

func (*ChangeConfResponse) Descriptor 

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

func (*ChangeConfResponse) Marshal 

func (m *ChangeConfResponse) Marshal() (dAtA []byte, err error)

func (*ChangeConfResponse) MarshalTo 

func (m *ChangeConfResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChangeConfResponse) Method 

func (*ChangeConfResponse) Method() Method

Method implements the Request interface.

func (*ChangeConfResponse) ProtoMessage 

func (*ChangeConfResponse) ProtoMessage()

func (*ChangeConfResponse) Reset 

func (m *ChangeConfResponse) Reset()

func (*ChangeConfResponse) Size 

func (m *ChangeConfResponse) Size() (n int)

func (*ChangeConfResponse) String 

func (m *ChangeConfResponse) String() string

func (*ChangeConfResponse) Unmarshal 

func (m *ChangeConfResponse) Unmarshal(dAtA []byte) error

type CmdIDKey 

type CmdIDKey string

CmdIDKey is a Raft command id.

type ConfChangeContext 

type ConfChangeContext struct {
	CommandID string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	// Payload is the application-level command (i.e. an encoded
	// storagebase.RaftCommand).
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Replica contains full details about the replica being added or removed.
	Replica ReplicaDescriptor `protobuf:"bytes,3,opt,name=replica" json:"replica"`
}

ConfChangeContext is encoded in the raftpb.ConfChange.Context field.

func (*ConfChangeContext) Descriptor 

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

func (*ConfChangeContext) GetCommandID 

func (m *ConfChangeContext) GetCommandID() string

func (*ConfChangeContext) GetPayload 

func (m *ConfChangeContext) GetPayload() []byte

func (*ConfChangeContext) GetReplica 

func (m *ConfChangeContext) GetReplica() ReplicaDescriptor

func (*ConfChangeContext) Marshal 

func (m *ConfChangeContext) Marshal() (dAtA []byte, err error)

func (*ConfChangeContext) MarshalTo 

func (m *ConfChangeContext) MarshalTo(dAtA []byte) (int, error)

func (*ConfChangeContext) ProtoMessage 

func (*ConfChangeContext) ProtoMessage()

func (*ConfChangeContext) Reset 

func (m *ConfChangeContext) Reset()

func (*ConfChangeContext) Size 

func (m *ConfChangeContext) Size() (n int)

func (*ConfChangeContext) String 

func (m *ConfChangeContext) String() string

func (*ConfChangeContext) Unmarshal 

func (m *ConfChangeContext) Unmarshal(dAtA []byte) error

type ConfType 

type ConfType int32
const (
	ConfType_ADD_REPLICA    ConfType = 0
	ConfType_REMOVE_REPLICA ConfType = 1
)

func (ConfType) EnumDescriptor 

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

func (ConfType) String 

func (x ConfType) String() string

type DataLost 

type DataLost struct {
	Key Key `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
}

func NewDataLost 

func NewDataLost(key Key) *DataLost

NewDataLost initializes a new DataLost.

func (*DataLost) Descriptor 

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

func (*DataLost) Equal 

func (this *DataLost) Equal(that interface{}) bool

func (*DataLost) Error 

func (e *DataLost) Error() string

func (*DataLost) GetKey 

func (m *DataLost) GetKey() Key

func (*DataLost) Marshal 

func (m *DataLost) Marshal() (dAtA []byte, err error)

func (*DataLost) MarshalTo 

func (m *DataLost) MarshalTo(dAtA []byte) (int, error)

func (*DataLost) ProtoMessage 

func (*DataLost) ProtoMessage()

func (*DataLost) Reset 

func (m *DataLost) Reset()

func (*DataLost) Size 

func (m *DataLost) Size() (n int)

func (*DataLost) String 

func (m *DataLost) String() string

func (*DataLost) Unmarshal 

func (m *DataLost) Unmarshal(dAtA []byte) error

type DeleteRequest 

type DeleteRequest struct {
	Key Key `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
}

A GetRequest is the argument for the Get() method.

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) Equal 

func (this *DeleteRequest) Equal(that interface{}) bool

func (*DeleteRequest) GetKey 

func (m *DeleteRequest) GetKey() Key

func (*DeleteRequest) Marshal 

func (m *DeleteRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRequest) MarshalTo 

func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRequest) Method 

func (*DeleteRequest) Method() Method

Method implements the Request interface.

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) ShallowCopy 

func (gr *DeleteRequest) ShallowCopy() Request

ShallowCopy implements the Request interface.

func (*DeleteRequest) Size 

func (m *DeleteRequest) Size() (n int)

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

func (m *DeleteRequest) Unmarshal(dAtA []byte) error

type DeleteResponse 

type DeleteResponse struct {
	ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}

A PutResponse is the return value from the Put() method.

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) Marshal 

func (m *DeleteResponse) Marshal() (dAtA []byte, err error)

func (*DeleteResponse) MarshalTo 

func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteResponse) Method 

func (*DeleteResponse) Method() Method

Method implements the Request interface.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

func (m *DeleteResponse) Size() (n int)

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

func (m *DeleteResponse) Unmarshal(dAtA []byte) error

type ErrPosition 

type ErrPosition struct {
	Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
}

ErrPosition describes the position of an error in a Batch. A simple nullable primitive field would break compatibility with proto3, where primitive fields are no longer allowed to be nullable.

func (*ErrPosition) Descriptor 

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

func (*ErrPosition) Equal 

func (this *ErrPosition) Equal(that interface{}) bool

func (*ErrPosition) GetIndex 

func (m *ErrPosition) GetIndex() int32

func (*ErrPosition) Marshal 

func (m *ErrPosition) Marshal() (dAtA []byte, err error)

func (*ErrPosition) MarshalTo 

func (m *ErrPosition) MarshalTo(dAtA []byte) (int, error)

func (*ErrPosition) ProtoMessage 

func (*ErrPosition) ProtoMessage()

func (*ErrPosition) Reset 

func (m *ErrPosition) Reset()

func (*ErrPosition) Size 

func (m *ErrPosition) Size() (n int)

func (*ErrPosition) String 

func (m *ErrPosition) String() string

func (*ErrPosition) Unmarshal 

func (m *ErrPosition) Unmarshal(dAtA []byte) error

type Error 

type Error struct {
	// message is a human-readable error message.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// Node at which the error was generated (zero if does not apply).
	OriginNode string `protobuf:"bytes,2,opt,name=origin_node,json=originNode,proto3" json:"origin_node,omitempty"`
	// If an ErrorDetail is present, it may contain additional structured data
	// about the error.
	Detail *ErrorDetail `protobuf:"bytes,3,opt,name=detail" json:"detail,omitempty"`
	// The index, if given, contains the index of the request (in the batch)
	// whose execution caused the error.
	Index *ErrPosition `protobuf:"bytes,4,opt,name=index" json:"index,omitempty"`
}

Error is a generic representation including a string message and information about retryability.

func NewError 

func NewError(err error) *Error

NewError creates an Error from the given error.

func NewErrorf 

func NewErrorf(format string, a ...interface{}) *Error

NewErrorf creates an Error from the given error message. It is a passthrough to fmt.Errorf, with an additional prefix containing the filename and line number.

func (*Error) Descriptor 

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

func (*Error) Equal 

func (this *Error) Equal(that interface{}) bool

func (*Error) GetDetail 

func (m *Error) GetDetail() *ErrorDetail

func (*Error) GetDetailType 

func (e *Error) GetDetailType() ErrorDetailInterface

GetDetail returns an error detail associated with the error.

func (*Error) GetIndex 

func (m *Error) GetIndex() *ErrPosition

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetOriginNode 

func (m *Error) GetOriginNode() string

func (*Error) GoError 

func (e *Error) GoError() error

GoError returns a Go error converted from Error.

func (*Error) Marshal 

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo 

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (e *Error) String() string

String implements fmt.Stringer.

func (*Error) Unmarshal 

func (m *Error) Unmarshal(dAtA []byte) error

type ErrorDetail 

type ErrorDetail struct {
	NodeUnavailable *NodeUnavailableError `protobuf:"bytes,1,opt,name=node_unavailable,json=nodeUnavailable" json:"node_unavailable,omitempty"`
	NodeNotReady    *NodeNotReadyError    `protobuf:"bytes,2,opt,name=node_not_ready,json=nodeNotReady" json:"node_not_ready,omitempty"`
	Send            *SendError            `protobuf:"bytes,3,opt,name=send" json:"send,omitempty"`
	// TODO(kaneda): Following three are added to preserve the type when
	// converting Go errors from/to proto Errors. Revisit this design.
	RaftGroupDeleted  *RaftGroupDeletedError  `protobuf:"bytes,4,opt,name=raft_group_deleted,json=raftGroupDeleted" json:"raft_group_deleted,omitempty"`
	ReplicaCorruption *ReplicaCorruptionError `protobuf:"bytes,5,opt,name=replica_corruption,json=replicaCorruption" json:"replica_corruption,omitempty"`
	ReplicaTooOld     *ReplicaTooOldError     `protobuf:"bytes,6,opt,name=replica_too_old,json=replicaTooOld" json:"replica_too_old,omitempty"`
	AmbiguousResult   *AmbiguousResultError   `protobuf:"bytes,8,opt,name=ambiguous_result,json=ambiguousResult" json:"ambiguous_result,omitempty"`
	GroupNotFound     *GroupNotFoundError     `protobuf:"bytes,9,opt,name=group_not_found,json=groupNotFound" json:"group_not_found,omitempty"`
	KeyNonExistent    *KeyNonExistent         `protobuf:"bytes,10,opt,name=key_non_existent,json=keyNonExistent" json:"key_non_existent,omitempty"`
}

ErrorDetail is a union type containing all available errors.

func (*ErrorDetail) Descriptor 

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

func (*ErrorDetail) Equal 

func (this *ErrorDetail) Equal(that interface{}) bool

func (*ErrorDetail) GetAmbiguousResult 

func (m *ErrorDetail) GetAmbiguousResult() *AmbiguousResultError

func (*ErrorDetail) GetGroupNotFound 

func (m *ErrorDetail) GetGroupNotFound() *GroupNotFoundError

func (*ErrorDetail) GetKeyNonExistent 

func (m *ErrorDetail) GetKeyNonExistent() *KeyNonExistent

func (*ErrorDetail) GetNodeNotReady 

func (m *ErrorDetail) GetNodeNotReady() *NodeNotReadyError

func (*ErrorDetail) GetNodeUnavailable 

func (m *ErrorDetail) GetNodeUnavailable() *NodeUnavailableError

func (*ErrorDetail) GetRaftGroupDeleted 

func (m *ErrorDetail) GetRaftGroupDeleted() *RaftGroupDeletedError

func (*ErrorDetail) GetReplicaCorruption 

func (m *ErrorDetail) GetReplicaCorruption() *ReplicaCorruptionError

func (*ErrorDetail) GetReplicaTooOld 

func (m *ErrorDetail) GetReplicaTooOld() *ReplicaTooOldError

func (*ErrorDetail) GetSend 

func (m *ErrorDetail) GetSend() *SendError

func (*ErrorDetail) GetValue 

func (this *ErrorDetail) GetValue() interface{}

func (*ErrorDetail) Marshal 

func (m *ErrorDetail) Marshal() (dAtA []byte, err error)

func (*ErrorDetail) MarshalTo 

func (m *ErrorDetail) MarshalTo(dAtA []byte) (int, error)

func (*ErrorDetail) ProtoMessage 

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) Reset 

func (m *ErrorDetail) Reset()

func (*ErrorDetail) SetValue 

func (this *ErrorDetail) SetValue(value interface{}) bool

func (*ErrorDetail) Size 

func (m *ErrorDetail) Size() (n int)

func (*ErrorDetail) String 

func (m *ErrorDetail) String() string

func (*ErrorDetail) Unmarshal 

func (m *ErrorDetail) Unmarshal(dAtA []byte) error

type ErrorDetailInterface 

type ErrorDetailInterface interface {
	error
	// contains filtered or unexported methods
}

type ExternalClient 

type ExternalClient interface {
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
}

func NewExternalClient 

func NewExternalClient(cc *grpc.ClientConn) ExternalClient

type ExternalServer 

type ExternalServer interface {
	Batch(context.Context, *BatchRequest) (*BatchResponse, error)
}

type GetRequest 

type GetRequest struct {
	Key   Key   `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
	Value Value `protobuf:"bytes,2,opt,name=value,proto3,casttype=Value" json:"value,omitempty"`
}

A GetRequest is the argument for the Get() method.

func (*GetRequest) Descriptor 

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

func (*GetRequest) Equal 

func (this *GetRequest) Equal(that interface{}) bool

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() Key

func (*GetRequest) GetValue 

func (m *GetRequest) GetValue() Value

func (*GetRequest) Marshal 

func (m *GetRequest) Marshal() (dAtA []byte, err error)

func (*GetRequest) MarshalTo 

func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRequest) Method 

func (*GetRequest) Method() Method

Method implements the Request interface.

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) ShallowCopy 

func (gr *GetRequest) ShallowCopy() Request

ShallowCopy implements the Request interface.

func (*GetRequest) Size 

func (m *GetRequest) Size() (n int)

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

func (m *GetRequest) Unmarshal(dAtA []byte) error

type GetResponse 

type GetResponse struct {
	ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
	Value          Value `protobuf:"bytes,2,opt,name=value,proto3,casttype=Value" json:"value,omitempty"`
}

A GetResponse is the return value from the Get() method. If the key doesn't exist, returns nil for Value.Bytes.

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetValue 

func (m *GetResponse) GetValue() Value

func (*GetResponse) Marshal 

func (m *GetResponse) Marshal() (dAtA []byte, err error)

func (*GetResponse) MarshalTo 

func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetResponse) Method 

func (*GetResponse) Method() Method

Method implements the Request interface.

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

func (m *GetResponse) Size() (n int)

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

func (m *GetResponse) Unmarshal(dAtA []byte) error

type GroupDescriptor 

type GroupDescriptor struct {
	PoolId   int64               `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	PgId     int64               `protobuf:"varint,2,opt,name=pg_id,json=pgId,proto3" json:"pg_id,omitempty"`
	GroupID  GroupID             `protobuf:"bytes,3,opt,name=group_id,json=groupId,proto3,casttype=GroupID" json:"group_id,omitempty"`
	Replicas []ReplicaDescriptor `protobuf:"bytes,4,rep,name=replicas" json:"replicas"`
	// next_replica_id is a counter used to generate replica IDs.
	NextReplicaID ReplicaID `protobuf:"varint,5,opt,name=next_replica_id,json=nextReplicaId,proto3,casttype=ReplicaID" json:"next_replica_id,omitempty"`
}

GroupDescriptor is the value stored in a range metadata key. A range is described using an inclusive start key, a non-inclusive end key, and a list of replicas where the range is stored.

func (*GroupDescriptor) Descriptor 

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

func (*GroupDescriptor) Equal 

func (this *GroupDescriptor) Equal(that interface{}) bool

func (*GroupDescriptor) GetGroupID 

func (m *GroupDescriptor) GetGroupID() GroupID

func (*GroupDescriptor) GetNextReplicaID 

func (m *GroupDescriptor) GetNextReplicaID() ReplicaID

func (*GroupDescriptor) GetPgId 

func (m *GroupDescriptor) GetPgId() int64

func (*GroupDescriptor) GetPoolId 

func (m *GroupDescriptor) GetPoolId() int64

func (GroupDescriptor) GetReplicaDescriptor 

func (r GroupDescriptor) GetReplicaDescriptor(nodeID NodeID) (ReplicaDescriptor, bool)

GetReplicaDescriptor returns the replica which matches the specified store ID.

func (GroupDescriptor) GetReplicaDescriptorByID 

func (r GroupDescriptor) GetReplicaDescriptorByID(replicaID ReplicaID) (ReplicaDescriptor, bool)

GetReplicaDescriptorByID returns the replica which matches the specified store ID.

func (*GroupDescriptor) GetReplicas 

func (m *GroupDescriptor) GetReplicas() []ReplicaDescriptor

func (GroupDescriptor) IsInitialized 

func (r GroupDescriptor) IsInitialized() bool

IsInitialized returns false if this descriptor represents an uninitialized range. TODO(bdarnell): unify this with Validate().

func (*GroupDescriptor) Marshal 

func (m *GroupDescriptor) Marshal() (dAtA []byte, err error)

func (*GroupDescriptor) MarshalTo 

func (m *GroupDescriptor) MarshalTo(dAtA []byte) (int, error)

func (*GroupDescriptor) ProtoMessage 

func (*GroupDescriptor) ProtoMessage()

func (*GroupDescriptor) Reset 

func (m *GroupDescriptor) Reset()

func (*GroupDescriptor) Size 

func (m *GroupDescriptor) Size() (n int)

func (*GroupDescriptor) String 

func (m *GroupDescriptor) String() string

func (*GroupDescriptor) Unmarshal 

func (m *GroupDescriptor) Unmarshal(dAtA []byte) error

func (GroupDescriptor) Validate 

func (r GroupDescriptor) Validate() error

Validate performs some basic validation of the contents of a range descriptor.

type GroupID 

type GroupID string

type GroupNotFoundError 

type GroupNotFoundError struct {
	GroupID GroupID `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3,casttype=GroupID" json:"group_id,omitempty"`
}

A GroupNotFoundError indicates that a command was sent to a range which is not hosted on this store.

func NewGroupNotFoundError 

func NewGroupNotFoundError(groupID GroupID) *GroupNotFoundError

NewGroupNotFoundError initializes a new GroupNotFoundError.

func (*GroupNotFoundError) Descriptor 

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

func (*GroupNotFoundError) Equal 

func (this *GroupNotFoundError) Equal(that interface{}) bool

func (*GroupNotFoundError) Error 

func (e *GroupNotFoundError) Error() string

func (*GroupNotFoundError) GetGroupID 

func (m *GroupNotFoundError) GetGroupID() GroupID

func (*GroupNotFoundError) Marshal 

func (m *GroupNotFoundError) Marshal() (dAtA []byte, err error)

func (*GroupNotFoundError) MarshalTo 

func (m *GroupNotFoundError) MarshalTo(dAtA []byte) (int, error)

func (*GroupNotFoundError) ProtoMessage 

func (*GroupNotFoundError) ProtoMessage()

func (*GroupNotFoundError) Reset 

func (m *GroupNotFoundError) Reset()

func (*GroupNotFoundError) Size 

func (m *GroupNotFoundError) Size() (n int)

func (*GroupNotFoundError) String 

func (m *GroupNotFoundError) String() string

func (*GroupNotFoundError) Unmarshal 

func (m *GroupNotFoundError) Unmarshal(dAtA []byte) error

type HasKeyRequest 

type HasKeyRequest struct {
	Key Key `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
}

A HasKeyRequest is the argument for the Get() method.

func (*HasKeyRequest) Descriptor 

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

func (*HasKeyRequest) Equal 

func (this *HasKeyRequest) Equal(that interface{}) bool

func (*HasKeyRequest) GetKey 

func (m *HasKeyRequest) GetKey() Key

func (*HasKeyRequest) Marshal 

func (m *HasKeyRequest) Marshal() (dAtA []byte, err error)

func (*HasKeyRequest) MarshalTo 

func (m *HasKeyRequest) MarshalTo(dAtA []byte) (int, error)

func (*HasKeyRequest) Method 

func (*HasKeyRequest) Method() Method

Method implements the Request interface.

func (*HasKeyRequest) ProtoMessage 

func (*HasKeyRequest) ProtoMessage()

func (*HasKeyRequest) Reset 

func (m *HasKeyRequest) Reset()

func (*HasKeyRequest) ShallowCopy 

func (tr *HasKeyRequest) ShallowCopy() Request

ShallowCopy implements the Request interface.

func (*HasKeyRequest) Size 

func (m *HasKeyRequest) Size() (n int)

func (*HasKeyRequest) String 

func (m *HasKeyRequest) String() string

func (*HasKeyRequest) Unmarshal 

func (m *HasKeyRequest) Unmarshal(dAtA []byte) error

type HasKeyResponse 

type HasKeyResponse struct {
	ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
	Processed      bool `protobuf:"varint,2,opt,name=processed,proto3" json:"processed,omitempty"`
}

A HasKeyResponse is the return value from the Get() method. If the key doesn't exist, returns nil for Value.Bytes.

func (*HasKeyResponse) Descriptor 

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

func (*HasKeyResponse) GetProcessed 

func (m *HasKeyResponse) GetProcessed() bool

func (*HasKeyResponse) Marshal 

func (m *HasKeyResponse) Marshal() (dAtA []byte, err error)

func (*HasKeyResponse) MarshalTo 

func (m *HasKeyResponse) MarshalTo(dAtA []byte) (int, error)

func (*HasKeyResponse) Method 

func (*HasKeyResponse) Method() Method

Method implements the Request interface.

func (*HasKeyResponse) ProtoMessage 

func (*HasKeyResponse) ProtoMessage()

func (*HasKeyResponse) Reset 

func (m *HasKeyResponse) Reset()

func (*HasKeyResponse) Size 

func (m *HasKeyResponse) Size() (n int)

func (*HasKeyResponse) String 

func (m *HasKeyResponse) String() string

func (*HasKeyResponse) Unmarshal 

func (m *HasKeyResponse) Unmarshal(dAtA []byte) error
type Header struct {
	// replica specifies the destination of the request.
	Replica ReplicaDescriptor `protobuf:"bytes,2,opt,name=replica" json:"replica"`
	// range_id specifies the ID of the Raft consensus group which the key
	// range belongs to. This is used by the receiving node to route the
	// request to the correct range.
	GroupID GroupID `protobuf:"bytes,3,opt,name=group_id,json=groupId,proto3,casttype=GroupID" json:"group_id,omitempty"`
}

A Header is attached to a BatchRequest, encapsulating routing and auxiliary information required for executing it.

func (*Header) Descriptor 

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

func (*Header) GetGroupID 

func (m *Header) GetGroupID() GroupID

func (*Header) GetReplica 

func (m *Header) GetReplica() ReplicaDescriptor

func (*Header) Marshal 

func (m *Header) Marshal() (dAtA []byte, err error)

func (*Header) MarshalTo 

func (m *Header) MarshalTo(dAtA []byte) (int, error)

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

func (m *Header) Size() (n int)

func (*Header) String 

func (m *Header) String() string

func (*Header) Unmarshal 

func (m *Header) Unmarshal(dAtA []byte) error

type InternalClient 

type InternalClient interface {
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
}

func NewInternalClient 

func NewInternalClient(cc *grpc.ClientConn) InternalClient

type InternalServer 

type InternalServer interface {
	Batch(context.Context, *BatchRequest) (*BatchResponse, error)
}

type Key 

type Key []byte

Key is a custom type for a byte string in proto messages which refer to Cockroach keys.

func (Key) String 

func (k Key) String() string

String returns a string-formatted version of the key.

type KeyNonExistent 

type KeyNonExistent struct {
	Key Key `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
}

A GroupNotFoundError indicates that a command was sent to a range which is not hosted on this store.

func NewKeyNonExistent 

func NewKeyNonExistent(key Key) *KeyNonExistent

NewKeyNonExistent initializes a new KeyNonExistent.

func (*KeyNonExistent) Descriptor 

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

func (*KeyNonExistent) Equal 

func (this *KeyNonExistent) Equal(that interface{}) bool

func (*KeyNonExistent) Error 

func (e *KeyNonExistent) Error() string

func (*KeyNonExistent) GetKey 

func (m *KeyNonExistent) GetKey() Key

func (*KeyNonExistent) Marshal 

func (m *KeyNonExistent) Marshal() (dAtA []byte, err error)

func (*KeyNonExistent) MarshalTo 

func (m *KeyNonExistent) MarshalTo(dAtA []byte) (int, error)

func (*KeyNonExistent) ProtoMessage 

func (*KeyNonExistent) ProtoMessage()

func (*KeyNonExistent) Reset 

func (m *KeyNonExistent) Reset()

func (*KeyNonExistent) Size 

func (m *KeyNonExistent) Size() (n int)

func (*KeyNonExistent) String 

func (m *KeyNonExistent) String() string

func (*KeyNonExistent) Unmarshal 

func (m *KeyNonExistent) Unmarshal(dAtA []byte) error

type KeyValue 

type KeyValue struct {
	Key   Key   `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
	Value Value `protobuf:"bytes,2,opt,name=value,proto3,casttype=Value" json:"value,omitempty"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() Key

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() Value

func (*KeyValue) Marshal 

func (m *KeyValue) Marshal() (dAtA []byte, err error)

func (*KeyValue) MarshalTo 

func (m *KeyValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) Size 

func (m *KeyValue) Size() (n int)

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal 

func (m *KeyValue) Unmarshal(dAtA []byte) error

type Method 

type Method int
const (
	// Get fetches the value for a key from the KV map, respecting a
	// possibly historical timestamp. If the timestamp is 0, returns
	// the most recent value.
	Get Method = iota
	// Put sets the value for a key at the specified timestamp. If the
	// timestamp is 0, the value is set with the current time as timestamp.
	Put
	// TruncateLog discards a prefix of the raft log.
	TruncateLog
	// HasKey check that the key exist
	HasKey
	// Delete removes the value for the specified key.
	Delete
	// change raft conf
	ChangeConf
)

type MultiRaftClient 

type MultiRaftClient interface {
	RaftMessageBatch(ctx context.Context, opts ...grpc.CallOption) (MultiRaft_RaftMessageBatchClient, error)
	RaftSnapshot(ctx context.Context, opts ...grpc.CallOption) (MultiRaft_RaftSnapshotClient, error)
}

func NewMultiRaftClient 

func NewMultiRaftClient(cc *grpc.ClientConn) MultiRaftClient

type MultiRaftServer 

type MultiRaftServer interface {
	RaftMessageBatch(MultiRaft_RaftMessageBatchServer) error
	RaftSnapshot(MultiRaft_RaftSnapshotServer) error
}

type MultiRaft_RaftMessageBatchClient 

type MultiRaft_RaftMessageBatchClient interface {
	Send(*RaftMessageRequestBatch) error
	Recv() (*RaftMessageResponse, error)
	grpc.ClientStream
}

type MultiRaft_RaftMessageBatchServer 

type MultiRaft_RaftMessageBatchServer interface {
	Send(*RaftMessageResponse) error
	Recv() (*RaftMessageRequestBatch, error)
	grpc.ServerStream
}

type MultiRaft_RaftSnapshotClient 

type MultiRaft_RaftSnapshotClient interface {
	Send(*SnapshotRequest) error
	Recv() (*SnapshotResponse, error)
	grpc.ClientStream
}

type MultiRaft_RaftSnapshotServer 

type MultiRaft_RaftSnapshotServer interface {
	Send(*SnapshotResponse) error
	Recv() (*SnapshotRequest, error)
	grpc.ServerStream
}

type NodeDescriptor 

type NodeDescriptor struct {
	NodeID NodeID `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,casttype=NodeID" json:"node_id,omitempty"`
}

NodeDescriptor holds details on node physical/network topology.

func (*NodeDescriptor) Descriptor 

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

func (*NodeDescriptor) GetNodeID 

func (m *NodeDescriptor) GetNodeID() NodeID

func (*NodeDescriptor) Marshal 

func (m *NodeDescriptor) Marshal() (dAtA []byte, err error)

func (*NodeDescriptor) MarshalTo 

func (m *NodeDescriptor) MarshalTo(dAtA []byte) (int, error)

func (*NodeDescriptor) ProtoMessage 

func (*NodeDescriptor) ProtoMessage()

func (*NodeDescriptor) Reset 

func (m *NodeDescriptor) Reset()

func (*NodeDescriptor) Size 

func (m *NodeDescriptor) Size() (n int)

func (*NodeDescriptor) String 

func (m *NodeDescriptor) String() string

func (*NodeDescriptor) Unmarshal 

func (m *NodeDescriptor) Unmarshal(dAtA []byte) error

type NodeID 

type NodeID string

func (NodeID) String 

func (n NodeID) String() string

String implements the fmt.Stringer interface. It is used to format the ID for use in Gossip keys.

type NodeNotReadyError 

type NodeNotReadyError struct {
	NodeID NodeID `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,casttype=NodeID" json:"node_id,omitempty"`
}

func NewNodeNotReadyError 

func NewNodeNotReadyError(nodeID NodeID) *NodeNotReadyError

func (*NodeNotReadyError) Descriptor 

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

func (*NodeNotReadyError) Equal 

func (this *NodeNotReadyError) Equal(that interface{}) bool

func (*NodeNotReadyError) Error 

func (e *NodeNotReadyError) Error() string

func (*NodeNotReadyError) GetNodeID 

func (m *NodeNotReadyError) GetNodeID() NodeID

func (*NodeNotReadyError) Marshal 

func (m *NodeNotReadyError) Marshal() (dAtA []byte, err error)

func (*NodeNotReadyError) MarshalTo 

func (m *NodeNotReadyError) MarshalTo(dAtA []byte) (int, error)

func (*NodeNotReadyError) ProtoMessage 

func (*NodeNotReadyError) ProtoMessage()

func (*NodeNotReadyError) Reset 

func (m *NodeNotReadyError) Reset()

func (*NodeNotReadyError) Size 

func (m *NodeNotReadyError) Size() (n int)

func (*NodeNotReadyError) String 

func (m *NodeNotReadyError) String() string

func (*NodeNotReadyError) Unmarshal 

func (m *NodeNotReadyError) Unmarshal(dAtA []byte) error

type NodeUnavailableError 

type NodeUnavailableError struct {
}

A NodeUnavailableError indicates that the sending gateway can not process requests at the time, and that the client should retry the request with another peer.

func (*NodeUnavailableError) Descriptor 

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

func (*NodeUnavailableError) Equal 

func (this *NodeUnavailableError) Equal(that interface{}) bool

func (*NodeUnavailableError) Marshal 

func (m *NodeUnavailableError) Marshal() (dAtA []byte, err error)

func (*NodeUnavailableError) MarshalTo 

func (m *NodeUnavailableError) MarshalTo(dAtA []byte) (int, error)

func (*NodeUnavailableError) ProtoMessage 

func (*NodeUnavailableError) ProtoMessage()

func (*NodeUnavailableError) Reset 

func (m *NodeUnavailableError) Reset()

func (*NodeUnavailableError) Size 

func (m *NodeUnavailableError) Size() (n int)

func (*NodeUnavailableError) String 

func (m *NodeUnavailableError) String() string

func (*NodeUnavailableError) Unmarshal 

func (m *NodeUnavailableError) Unmarshal(dAtA []byte) error

type Onode 

type Onode struct {
	Key   Key   `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
	Size_ int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
}

func (*Onode) Descriptor 

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

func (*Onode) GetKey 

func (m *Onode) GetKey() Key

func (*Onode) GetSize_ 

func (m *Onode) GetSize_() int32

func (*Onode) Marshal 

func (m *Onode) Marshal() (dAtA []byte, err error)

func (*Onode) MarshalTo 

func (m *Onode) MarshalTo(dAtA []byte) (int, error)

func (*Onode) ProtoMessage 

func (*Onode) ProtoMessage()

func (*Onode) Reset 

func (m *Onode) Reset()

func (*Onode) Size 

func (m *Onode) Size() (n int)

func (*Onode) String 

func (m *Onode) String() string

func (*Onode) Unmarshal 

func (m *Onode) Unmarshal(dAtA []byte) error

type OnodeBroken 

type OnodeBroken struct {
	Key Key `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
}

func NewOnodeBroken 

func NewOnodeBroken(key Key) *OnodeBroken

NewOnodeBroken initializes a new OnodeBroken.

func (*OnodeBroken) Descriptor 

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

func (*OnodeBroken) Equal 

func (this *OnodeBroken) Equal(that interface{}) bool

func (*OnodeBroken) Error 

func (e *OnodeBroken) Error() string

func (*OnodeBroken) GetKey 

func (m *OnodeBroken) GetKey() Key

func (*OnodeBroken) Marshal 

func (m *OnodeBroken) Marshal() (dAtA []byte, err error)

func (*OnodeBroken) MarshalTo 

func (m *OnodeBroken) MarshalTo(dAtA []byte) (int, error)

func (*OnodeBroken) ProtoMessage 

func (*OnodeBroken) ProtoMessage()

func (*OnodeBroken) Reset 

func (m *OnodeBroken) Reset()

func (*OnodeBroken) Size 

func (m *OnodeBroken) Size() (n int)

func (*OnodeBroken) String 

func (m *OnodeBroken) String() string

func (*OnodeBroken) Unmarshal 

func (m *OnodeBroken) Unmarshal(dAtA []byte) error

type PgInfo 

type PgInfo struct {
	ReplicaState `protobuf:"bytes,1,opt,name=state,embedded=state" json:"state"`
	// The highest (and last) index in the Raft log.
	LastIndex  uint64 `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"`
	NumPending uint64 `protobuf:"varint,3,opt,name=num_pending,json=numPending,proto3" json:"num_pending,omitempty"`
	NumDropped uint64 `protobuf:"varint,5,opt,name=num_dropped,json=numDropped,proto3" json:"num_dropped,omitempty"`
	// raft_log_size may be initially inaccurate after a server restart.
	// See storage.Replica.mu.raftLogSize.
	RaftLogSize int64 `protobuf:"varint,6,opt,name=raft_log_size,json=raftLogSize,proto3" json:"raft_log_size,omitempty"`
	// Approximately the amount of quota available.
	ApproximateProposalQuota int64 `` /* 136-byte string literal not displayed */
}

func (*PgInfo) Descriptor 

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

func (*PgInfo) Equal 

func (this *PgInfo) Equal(that interface{}) bool

func (*PgInfo) GetApproximateProposalQuota 

func (m *PgInfo) GetApproximateProposalQuota() int64

func (*PgInfo) GetLastIndex 

func (m *PgInfo) GetLastIndex() uint64

func (*PgInfo) GetNumDropped 

func (m *PgInfo) GetNumDropped() uint64

func (*PgInfo) GetNumPending 

func (m *PgInfo) GetNumPending() uint64

func (*PgInfo) GetRaftLogSize 

func (m *PgInfo) GetRaftLogSize() int64

func (*PgInfo) Marshal 

func (m *PgInfo) Marshal() (dAtA []byte, err error)

func (*PgInfo) MarshalTo 

func (m *PgInfo) MarshalTo(dAtA []byte) (int, error)

func (*PgInfo) ProtoMessage 

func (*PgInfo) ProtoMessage()

func (*PgInfo) Reset 

func (m *PgInfo) Reset()

func (*PgInfo) Size 

func (m *PgInfo) Size() (n int)

func (*PgInfo) String 

func (m *PgInfo) String() string

func (*PgInfo) Unmarshal 

func (m *PgInfo) Unmarshal(dAtA []byte) error

type PgNotFoundError 

type PgNotFoundError struct {
	PgName string `protobuf:"bytes,1,opt,name=pg_name,json=pgName,proto3" json:"pg_name,omitempty"`
}

A RangeNotFoundError indicates that a command was sent to a range which is not hosted on this store.

func (*PgNotFoundError) Descriptor 

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

func (*PgNotFoundError) GetPgName 

func (m *PgNotFoundError) GetPgName() string

func (*PgNotFoundError) Marshal 

func (m *PgNotFoundError) Marshal() (dAtA []byte, err error)

func (*PgNotFoundError) MarshalTo 

func (m *PgNotFoundError) MarshalTo(dAtA []byte) (int, error)

func (*PgNotFoundError) ProtoMessage 

func (*PgNotFoundError) ProtoMessage()

func (*PgNotFoundError) Reset 

func (m *PgNotFoundError) Reset()

func (*PgNotFoundError) Size 

func (m *PgNotFoundError) Size() (n int)

func (*PgNotFoundError) String 

func (m *PgNotFoundError) String() string

func (*PgNotFoundError) Unmarshal 

func (m *PgNotFoundError) Unmarshal(dAtA []byte) error

type PutRequest 

type PutRequest struct {
	Key   Key    `protobuf:"bytes,1,opt,name=key,proto3,casttype=Key" json:"key,omitempty"`
	Value Value  `protobuf:"bytes,2,opt,name=value,proto3,casttype=Value" json:"value,omitempty"`
	Size_ uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
}

A PutRequest is the argument to the Put() method.

func (*PutRequest) Descriptor 

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

func (*PutRequest) Equal 

func (this *PutRequest) Equal(that interface{}) bool

func (*PutRequest) GetKey 

func (m *PutRequest) GetKey() Key

func (*PutRequest) GetSize_ 

func (m *PutRequest) GetSize_() uint64

func (*PutRequest) GetValue 

func (m *PutRequest) GetValue() Value

func (*PutRequest) Marshal 

func (m *PutRequest) Marshal() (dAtA []byte, err error)

func (*PutRequest) MarshalTo 

func (m *PutRequest) MarshalTo(dAtA []byte) (int, error)

func (*PutRequest) Method 

func (*PutRequest) Method() Method

Method implements the Request interface.

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) ShallowCopy 

func (pr *PutRequest) ShallowCopy() Request

ShallowCopy implements the Request interface.

func (*PutRequest) Size 

func (m *PutRequest) Size() (n int)

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) Unmarshal 

func (m *PutRequest) Unmarshal(dAtA []byte) error

type PutResponse 

type PutResponse struct {
	ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}

A PutResponse is the return value from the Put() method.

func (*PutResponse) Descriptor 

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

func (*PutResponse) Marshal 

func (m *PutResponse) Marshal() (dAtA []byte, err error)

func (*PutResponse) MarshalTo 

func (m *PutResponse) MarshalTo(dAtA []byte) (int, error)

func (*PutResponse) Method 

func (*PutResponse) Method() Method

Method implements the Request interface.

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) Size 

func (m *PutResponse) Size() (n int)

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal 

func (m *PutResponse) Unmarshal(dAtA []byte) error

type RKey 

type RKey Key

type RaftCommand 

type RaftCommand struct {
	// proposer_replica is the replica which proposed this command, to be
	// used for lease validation.
	ProposerReplica ReplicaDescriptor `protobuf:"bytes,1,opt,name=proposer_replica,json=proposerReplica" json:"proposer_replica"`
	Method          Method            `protobuf:"varint,2,opt,name=method,proto3,casttype=Method" json:"method,omitempty"`
	WriteBatch      *WriteBatch       `protobuf:"bytes,3,opt,name=write_batch,json=writeBatch" json:"write_batch,omitempty"`
}

RaftCommand is the message written to the raft log. It contains some metadata about the proposal itself, then either a BatchRequest (legacy mode) or a ReplicatedEvalResult + WriteBatch (proposer-evaluated KV mode).

func (*RaftCommand) Descriptor 

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

func (*RaftCommand) GetMethod 

func (m *RaftCommand) GetMethod() Method

func (*RaftCommand) GetProposerReplica 

func (m *RaftCommand) GetProposerReplica() ReplicaDescriptor

func (*RaftCommand) GetWriteBatch 

func (m *RaftCommand) GetWriteBatch() *WriteBatch

func (*RaftCommand) Marshal 

func (m *RaftCommand) Marshal() (dAtA []byte, err error)

func (*RaftCommand) MarshalTo 

func (m *RaftCommand) MarshalTo(dAtA []byte) (int, error)

func (*RaftCommand) ProtoMessage 

func (*RaftCommand) ProtoMessage()

func (*RaftCommand) Reset 

func (m *RaftCommand) Reset()

func (*RaftCommand) Size 

func (m *RaftCommand) Size() (n int)

func (*RaftCommand) String 

func (m *RaftCommand) String() string

func (*RaftCommand) Unmarshal 

func (m *RaftCommand) Unmarshal(dAtA []byte) error

type RaftGroupDeletedError 

type RaftGroupDeletedError struct {
}

A RaftGroupDeletedError indicates a raft group has been deleted for the replica.

func (*RaftGroupDeletedError) Descriptor 

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

func (*RaftGroupDeletedError) Equal 

func (this *RaftGroupDeletedError) Equal(that interface{}) bool

func (*RaftGroupDeletedError) Error 

func (e *RaftGroupDeletedError) Error() string

func (*RaftGroupDeletedError) Marshal 

func (m *RaftGroupDeletedError) Marshal() (dAtA []byte, err error)

func (*RaftGroupDeletedError) MarshalTo 

func (m *RaftGroupDeletedError) MarshalTo(dAtA []byte) (int, error)

func (*RaftGroupDeletedError) ProtoMessage 

func (*RaftGroupDeletedError) ProtoMessage()

func (*RaftGroupDeletedError) Reset 

func (m *RaftGroupDeletedError) Reset()

func (*RaftGroupDeletedError) Size 

func (m *RaftGroupDeletedError) Size() (n int)

func (*RaftGroupDeletedError) String 

func (m *RaftGroupDeletedError) String() string

func (*RaftGroupDeletedError) Unmarshal 

func (m *RaftGroupDeletedError) Unmarshal(dAtA []byte) error

type RaftHeartbeat 

type RaftHeartbeat struct {
	GroupID       GroupID   `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3,casttype=GroupID" json:"group_id,omitempty"`
	FromReplicaID ReplicaID `protobuf:"varint,2,opt,name=from_replica_id,json=fromReplicaId,proto3,casttype=ReplicaID" json:"from_replica_id,omitempty"`
	ToReplicaID   ReplicaID `protobuf:"varint,3,opt,name=to_replica_id,json=toReplicaId,proto3,casttype=ReplicaID" json:"to_replica_id,omitempty"`
	Term          uint64    `protobuf:"varint,4,opt,name=term,proto3" json:"term,omitempty"`
	Commit        uint64    `protobuf:"varint,5,opt,name=commit,proto3" json:"commit,omitempty"`
	Quiesce       bool      `protobuf:"varint,6,opt,name=quiesce,proto3" json:"quiesce,omitempty"`
	Context       []byte    `protobuf:"bytes,7,opt,name=context,proto3" json:"context,omitempty"`
}

func (*RaftHeartbeat) Descriptor 

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

func (*RaftHeartbeat) GetCommit 

func (m *RaftHeartbeat) GetCommit() uint64

func (*RaftHeartbeat) GetContext 

func (m *RaftHeartbeat) GetContext() []byte

func (*RaftHeartbeat) GetFromReplicaID 

func (m *RaftHeartbeat) GetFromReplicaID() ReplicaID

func (*RaftHeartbeat) GetGroupID 

func (m *RaftHeartbeat) GetGroupID() GroupID

func (*RaftHeartbeat) GetQuiesce 

func (m *RaftHeartbeat) GetQuiesce() bool

func (*RaftHeartbeat) GetTerm 

func (m *RaftHeartbeat) GetTerm() uint64

func (*RaftHeartbeat) GetToReplicaID 

func (m *RaftHeartbeat) GetToReplicaID() ReplicaID

func (*RaftHeartbeat) Marshal 

func (m *RaftHeartbeat) Marshal() (dAtA []byte, err error)

func (*RaftHeartbeat) MarshalTo 

func (m *RaftHeartbeat) MarshalTo(dAtA []byte) (int, error)

func (*RaftHeartbeat) ProtoMessage 

func (*RaftHeartbeat) ProtoMessage()

func (*RaftHeartbeat) Reset 

func (m *RaftHeartbeat) Reset()

func (*RaftHeartbeat) Size 

func (m *RaftHeartbeat) Size() (n int)

func (*RaftHeartbeat) String 

func (m *RaftHeartbeat) String() string

func (*RaftHeartbeat) Unmarshal 

func (m *RaftHeartbeat) Unmarshal(dAtA []byte) error

type RaftMessageRequest 

type RaftMessageRequest struct {
	GroupID     GroupID           `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3,casttype=GroupID" json:"group_id,omitempty"`
	FromReplica ReplicaDescriptor `protobuf:"bytes,2,opt,name=from_replica,json=fromReplica" json:"from_replica"`
	ToReplica   ReplicaDescriptor `protobuf:"bytes,3,opt,name=to_replica,json=toReplica" json:"to_replica"`
	Message     raftpb.Message    `protobuf:"bytes,4,opt,name=message" json:"message"`
	// Is this a quiesce request? A quiesce request is a MsgHeartbeat
	// which is requesting the recipient to stop ticking its local
	// replica as long as the current Raft state matches the heartbeat
	// Term/Commit. If the Term/Commit match, the recipient is marked as
	// quiescent. If they don't match, the message is passed along to
	// Raft which will generate a MsgHeartbeatResp that will unquiesce
	// the sender.
	Quiesce bool `protobuf:"varint,5,opt,name=quiesce,proto3" json:"quiesce,omitempty"`
	// A coalesced heartbeat request is any RaftMessageRequest with a nonzero number of
	// heartbeats or heartbeat_resps.
	Heartbeats     []RaftHeartbeat `protobuf:"bytes,6,rep,name=heartbeats" json:"heartbeats"`
	HeartbeatResps []RaftHeartbeat `protobuf:"bytes,7,rep,name=heartbeat_resps,json=heartbeatResps" json:"heartbeat_resps"`
}

RaftMessageRequest is the request used to send raft messages using our protobuf-based RPC codec. If a RaftMessageRequest has a non-empty number of heartbeats or heartbeat_resps, the contents of the message field is treated as a dummy message and discarded. A coalesced heartbeat request's replica descriptor's range ID must be zero.

func (*RaftMessageRequest) Descriptor 

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

func (*RaftMessageRequest) GetFromReplica 

func (m *RaftMessageRequest) GetFromReplica() ReplicaDescriptor

func (*RaftMessageRequest) GetGroupID 

func (m *RaftMessageRequest) GetGroupID() GroupID

func (*RaftMessageRequest) GetHeartbeatResps 

func (m *RaftMessageRequest) GetHeartbeatResps() []RaftHeartbeat

func (*RaftMessageRequest) GetHeartbeats 

func (m *RaftMessageRequest) GetHeartbeats() []RaftHeartbeat

func (*RaftMessageRequest) GetMessage 

func (m *RaftMessageRequest) GetMessage() raftpb.Message

func (*RaftMessageRequest) GetQuiesce 

func (m *RaftMessageRequest) GetQuiesce() bool

func (*RaftMessageRequest) GetToReplica 

func (m *RaftMessageRequest) GetToReplica() ReplicaDescriptor

func (*RaftMessageRequest) Marshal 

func (m *RaftMessageRequest) Marshal() (dAtA []byte, err error)

func (*RaftMessageRequest) MarshalTo 

func (m *RaftMessageRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftMessageRequest) ProtoMessage 

func (*RaftMessageRequest) ProtoMessage()

func (*RaftMessageRequest) Reset 

func (m *RaftMessageRequest) Reset()

func (*RaftMessageRequest) Size 

func (m *RaftMessageRequest) Size() (n int)

func (*RaftMessageRequest) String 

func (m *RaftMessageRequest) String() string

func (*RaftMessageRequest) Unmarshal 

func (m *RaftMessageRequest) Unmarshal(dAtA []byte) error

type RaftMessageRequestBatch 

type RaftMessageRequestBatch struct {
	Requests []RaftMessageRequest `protobuf:"bytes,1,rep,name=requests" json:"requests"`
}

func (*RaftMessageRequestBatch) Descriptor 

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

func (*RaftMessageRequestBatch) GetRequests 

func (m *RaftMessageRequestBatch) GetRequests() []RaftMessageRequest

func (*RaftMessageRequestBatch) Marshal 

func (m *RaftMessageRequestBatch) Marshal() (dAtA []byte, err error)

func (*RaftMessageRequestBatch) MarshalTo 

func (m *RaftMessageRequestBatch) MarshalTo(dAtA []byte) (int, error)

func (*RaftMessageRequestBatch) ProtoMessage 

func (*RaftMessageRequestBatch) ProtoMessage()

func (*RaftMessageRequestBatch) Reset 

func (m *RaftMessageRequestBatch) Reset()

func (*RaftMessageRequestBatch) Size 

func (m *RaftMessageRequestBatch) Size() (n int)

func (*RaftMessageRequestBatch) String 

func (m *RaftMessageRequestBatch) String() string

func (*RaftMessageRequestBatch) Unmarshal 

func (m *RaftMessageRequestBatch) Unmarshal(dAtA []byte) error

type RaftMessageResponse 

type RaftMessageResponse struct {
	GroupID     GroupID                  `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3,casttype=GroupID" json:"group_id,omitempty"`
	FromReplica ReplicaDescriptor        `protobuf:"bytes,2,opt,name=from_replica,json=fromReplica" json:"from_replica"`
	ToReplica   ReplicaDescriptor        `protobuf:"bytes,3,opt,name=to_replica,json=toReplica" json:"to_replica"`
	Union       RaftMessageResponseUnion `protobuf:"bytes,4,opt,name=union" json:"union"`
}

func (*RaftMessageResponse) Descriptor 

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

func (*RaftMessageResponse) GetFromReplica 

func (m *RaftMessageResponse) GetFromReplica() ReplicaDescriptor

func (*RaftMessageResponse) GetGroupID 

func (m *RaftMessageResponse) GetGroupID() GroupID

func (*RaftMessageResponse) GetToReplica 

func (m *RaftMessageResponse) GetToReplica() ReplicaDescriptor

func (*RaftMessageResponse) GetUnion 

func (m *RaftMessageResponse) GetUnion() RaftMessageResponseUnion

func (*RaftMessageResponse) Marshal 

func (m *RaftMessageResponse) Marshal() (dAtA []byte, err error)

func (*RaftMessageResponse) MarshalTo 

func (m *RaftMessageResponse) MarshalTo(dAtA []byte) (int, error)

func (*RaftMessageResponse) ProtoMessage 

func (*RaftMessageResponse) ProtoMessage()

func (*RaftMessageResponse) Reset 

func (m *RaftMessageResponse) Reset()

func (*RaftMessageResponse) Size 

func (m *RaftMessageResponse) Size() (n int)

func (*RaftMessageResponse) String 

func (m *RaftMessageResponse) String() string

func (*RaftMessageResponse) Unmarshal 

func (m *RaftMessageResponse) Unmarshal(dAtA []byte) error

type RaftMessageResponseUnion 

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

func (*RaftMessageResponseUnion) Descriptor 

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

func (*RaftMessageResponseUnion) GetError 

func (m *RaftMessageResponseUnion) GetError() *Error

func (*RaftMessageResponseUnion) GetValue 

func (this *RaftMessageResponseUnion) GetValue() interface{}

func (*RaftMessageResponseUnion) Marshal 

func (m *RaftMessageResponseUnion) Marshal() (dAtA []byte, err error)

func (*RaftMessageResponseUnion) MarshalTo 

func (m *RaftMessageResponseUnion) MarshalTo(dAtA []byte) (int, error)

func (*RaftMessageResponseUnion) ProtoMessage 

func (*RaftMessageResponseUnion) ProtoMessage()

func (*RaftMessageResponseUnion) Reset 

func (m *RaftMessageResponseUnion) Reset()

func (*RaftMessageResponseUnion) SetValue 

func (this *RaftMessageResponseUnion) SetValue(value interface{}) bool

func (*RaftMessageResponseUnion) Size 

func (m *RaftMessageResponseUnion) Size() (n int)

func (*RaftMessageResponseUnion) String 

func (m *RaftMessageResponseUnion) String() string

func (*RaftMessageResponseUnion) Unmarshal 

func (m *RaftMessageResponseUnion) Unmarshal(dAtA []byte) error

type RaftSnapshotData 

type RaftSnapshotData struct {
	// The latest RangeDescriptor
	GroupDescriptor GroupDescriptor             `protobuf:"bytes,1,opt,name=group_descriptor,json=groupDescriptor" json:"group_descriptor"`
	KV              []RaftSnapshotData_KeyValue `protobuf:"bytes,2,rep,name=KV" json:"KV"`
	// These are really raftpb.Entry, but we model them as raw bytes to avoid
	// roundtripping through memory.
	LogEntries [][]byte `protobuf:"bytes,3,rep,name=log_entries,json=logEntries" json:"log_entries,omitempty"`
}

RaftSnapshotData is the payload of a raftpb.Snapshot. It contains a raw copy of all of the range's data and metadata, including the raft log, sequence cache, etc.

func (*RaftSnapshotData) Descriptor 

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

func (*RaftSnapshotData) GetGroupDescriptor 

func (m *RaftSnapshotData) GetGroupDescriptor() GroupDescriptor

func (*RaftSnapshotData) GetKV 

func (m *RaftSnapshotData) GetKV() []RaftSnapshotData_KeyValue

func (*RaftSnapshotData) GetLogEntries 

func (m *RaftSnapshotData) GetLogEntries() [][]byte

func (*RaftSnapshotData) Marshal 

func (m *RaftSnapshotData) Marshal() (dAtA []byte, err error)

func (*RaftSnapshotData) MarshalTo 

func (m *RaftSnapshotData) MarshalTo(dAtA []byte) (int, error)

func (*RaftSnapshotData) ProtoMessage 

func (*RaftSnapshotData) ProtoMessage()

func (*RaftSnapshotData) Reset 

func (m *RaftSnapshotData) Reset()

func (*RaftSnapshotData) Size 

func (m *RaftSnapshotData) Size() (n int)

func (*RaftSnapshotData) String 

func (m *RaftSnapshotData) String() string

func (*RaftSnapshotData) Unmarshal 

func (m *RaftSnapshotData) Unmarshal(dAtA []byte) error

type RaftSnapshotData_KeyValue 

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

func (*RaftSnapshotData_KeyValue) Descriptor 

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

func (*RaftSnapshotData_KeyValue) GetKey 

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

func (*RaftSnapshotData_KeyValue) GetValue 

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

func (*RaftSnapshotData_KeyValue) Marshal 

func (m *RaftSnapshotData_KeyValue) Marshal() (dAtA []byte, err error)

func (*RaftSnapshotData_KeyValue) MarshalTo 

func (m *RaftSnapshotData_KeyValue) MarshalTo(dAtA []byte) (int, error)

func (*RaftSnapshotData_KeyValue) ProtoMessage 

func (*RaftSnapshotData_KeyValue) ProtoMessage()

func (*RaftSnapshotData_KeyValue) Reset 

func (m *RaftSnapshotData_KeyValue) Reset()

func (*RaftSnapshotData_KeyValue) Size 

func (m *RaftSnapshotData_KeyValue) Size() (n int)

func (*RaftSnapshotData_KeyValue) String 

func (m *RaftSnapshotData_KeyValue) String() string

func (*RaftSnapshotData_KeyValue) Unmarshal 

func (m *RaftSnapshotData_KeyValue) Unmarshal(dAtA []byte) error

type RaftTombstone 

type RaftTombstone struct {
	NextReplicaID ReplicaID `protobuf:"varint,1,opt,name=next_replica_id,json=nextReplicaId,proto3,casttype=ReplicaID" json:"next_replica_id,omitempty"`
}

RaftTombstone contains information about a replica that has been deleted.

func (*RaftTombstone) Descriptor 

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

func (*RaftTombstone) GetNextReplicaID 

func (m *RaftTombstone) GetNextReplicaID() ReplicaID

func (*RaftTombstone) Marshal 

func (m *RaftTombstone) Marshal() (dAtA []byte, err error)

func (*RaftTombstone) MarshalTo 

func (m *RaftTombstone) MarshalTo(dAtA []byte) (int, error)

func (*RaftTombstone) ProtoMessage 

func (*RaftTombstone) ProtoMessage()

func (*RaftTombstone) Reset 

func (m *RaftTombstone) Reset()

func (*RaftTombstone) Size 

func (m *RaftTombstone) Size() (n int)

func (*RaftTombstone) String 

func (m *RaftTombstone) String() string

func (*RaftTombstone) Unmarshal 

func (m *RaftTombstone) Unmarshal(dAtA []byte) error

type RaftTruncatedState 

type RaftTruncatedState struct {
	// The highest index that has been removed from the log.
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// The term corresponding to 'index'.
	Term uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
}

func NewPopulatedRaftTruncatedState 

func NewPopulatedRaftTruncatedState(r randyState, easy bool) *RaftTruncatedState

func (*RaftTruncatedState) Descriptor 

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

func (*RaftTruncatedState) Equal 

func (this *RaftTruncatedState) Equal(that interface{}) bool

func (*RaftTruncatedState) GetIndex 

func (m *RaftTruncatedState) GetIndex() uint64

func (*RaftTruncatedState) GetTerm 

func (m *RaftTruncatedState) GetTerm() uint64

func (*RaftTruncatedState) Marshal 

func (m *RaftTruncatedState) Marshal() (dAtA []byte, err error)

func (*RaftTruncatedState) MarshalTo 

func (m *RaftTruncatedState) MarshalTo(dAtA []byte) (int, error)

func (*RaftTruncatedState) ProtoMessage 

func (*RaftTruncatedState) ProtoMessage()

func (*RaftTruncatedState) Reset 

func (m *RaftTruncatedState) Reset()

func (*RaftTruncatedState) Size 

func (m *RaftTruncatedState) Size() (n int)

func (*RaftTruncatedState) String 

func (m *RaftTruncatedState) String() string

func (*RaftTruncatedState) Unmarshal 

func (m *RaftTruncatedState) Unmarshal(dAtA []byte) error

type ReadConsistencyType 

type ReadConsistencyType int32

ReadConsistencyType specifies what type of consistency is observed during read operations. 

const (
	// CONSISTENT reads are guaranteed to read committed data; the
	// mechanism relies on clocks to determine lease expirations.
	CONSISTENT ReadConsistencyType = 0
	// CONSENSUS requires that reads must achieve consensus. This is a
	// stronger guarantee of consistency than CONSISTENT.
	//
	// TODO(spencer): current unimplemented.
	CONSENSUS ReadConsistencyType = 1
	// INCONSISTENT reads return the latest available, committed values.
	// They are more efficient, but may read stale values as pending
	// intents are ignored.
	INCONSISTENT ReadConsistencyType = 2
)

func (ReadConsistencyType) EnumDescriptor 

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

func (ReadConsistencyType) String 

func (x ReadConsistencyType) String() string

type ReplicaCorruptionError 

type ReplicaCorruptionError struct {
	ErrorMsg string `protobuf:"bytes,1,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// processed indicates that the error has been taken into account and
	// necessary steps will be taken. For now, required for testing.
	Processed bool `protobuf:"varint,2,opt,name=processed,proto3" json:"processed,omitempty"`
}

A ReplicaCorruptionError indicates that the replica has experienced an error which puts its integrity at risk.

func (*ReplicaCorruptionError) Descriptor 

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

func (*ReplicaCorruptionError) Equal 

func (this *ReplicaCorruptionError) Equal(that interface{}) bool

func (*ReplicaCorruptionError) GetErrorMsg 

func (m *ReplicaCorruptionError) GetErrorMsg() string

func (*ReplicaCorruptionError) GetProcessed 

func (m *ReplicaCorruptionError) GetProcessed() bool

func (*ReplicaCorruptionError) Marshal 

func (m *ReplicaCorruptionError) Marshal() (dAtA []byte, err error)

func (*ReplicaCorruptionError) MarshalTo 

func (m *ReplicaCorruptionError) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaCorruptionError) ProtoMessage 

func (*ReplicaCorruptionError) ProtoMessage()

func (*ReplicaCorruptionError) Reset 

func (m *ReplicaCorruptionError) Reset()

func (*ReplicaCorruptionError) Size 

func (m *ReplicaCorruptionError) Size() (n int)

func (*ReplicaCorruptionError) String 

func (m *ReplicaCorruptionError) String() string

func (*ReplicaCorruptionError) Unmarshal 

func (m *ReplicaCorruptionError) Unmarshal(dAtA []byte) error

type ReplicaDescriptor 

type ReplicaDescriptor struct {
	// in nentropy node_id here should be osd.id
	NodeID  NodeID  `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,casttype=NodeID" json:"node_id,omitempty"`
	StoreID StoreID `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3,casttype=StoreID" json:"store_id,omitempty"`
	// replica_id uniquely identifies a replica instance. If a range is removed from
	// a store and then re-added to the same store, the new instance will have a
	// higher replica_id.
	ReplicaID ReplicaID `protobuf:"varint,3,opt,name=replica_id,json=replicaId,proto3,casttype=ReplicaID" json:"replica_id,omitempty"`
}

func (*ReplicaDescriptor) Descriptor 

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

func (*ReplicaDescriptor) Equal 

func (this *ReplicaDescriptor) Equal(that interface{}) bool

func (*ReplicaDescriptor) GetNodeID 

func (m *ReplicaDescriptor) GetNodeID() NodeID

func (*ReplicaDescriptor) GetReplicaID 

func (m *ReplicaDescriptor) GetReplicaID() ReplicaID

func (*ReplicaDescriptor) GetStoreID 

func (m *ReplicaDescriptor) GetStoreID() StoreID

func (*ReplicaDescriptor) Marshal 

func (m *ReplicaDescriptor) Marshal() (dAtA []byte, err error)

func (*ReplicaDescriptor) MarshalTo 

func (m *ReplicaDescriptor) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaDescriptor) ProtoMessage 

func (*ReplicaDescriptor) ProtoMessage()

func (*ReplicaDescriptor) Reset 

func (m *ReplicaDescriptor) Reset()

func (*ReplicaDescriptor) Size 

func (m *ReplicaDescriptor) Size() (n int)

func (*ReplicaDescriptor) String 

func (m *ReplicaDescriptor) String() string

func (*ReplicaDescriptor) Unmarshal 

func (m *ReplicaDescriptor) Unmarshal(dAtA []byte) error

func (ReplicaDescriptor) Validate 

func (r ReplicaDescriptor) Validate() error

Validate performs some basic validation of the contents of a replica descriptor.

type ReplicaID 

type ReplicaID int32

ReplicaID is a custom type for a range replica ID.

func (ReplicaID) String 

func (r ReplicaID) String() string

String implements the fmt.Stringer interface.

type ReplicaIdent 

type ReplicaIdent struct {
	PoolId  int64              `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	PgId    int64              `protobuf:"varint,2,opt,name=pg_id,json=pgId,proto3" json:"pg_id,omitempty"`
	Replica *ReplicaDescriptor `protobuf:"bytes,3,opt,name=replica" json:"replica,omitempty"`
}

func (*ReplicaIdent) Descriptor 

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

func (*ReplicaIdent) GetPgId 

func (m *ReplicaIdent) GetPgId() int64

func (*ReplicaIdent) GetPoolId 

func (m *ReplicaIdent) GetPoolId() int64

func (*ReplicaIdent) GetReplica 

func (m *ReplicaIdent) GetReplica() *ReplicaDescriptor

func (*ReplicaIdent) Marshal 

func (m *ReplicaIdent) Marshal() (dAtA []byte, err error)

func (*ReplicaIdent) MarshalTo 

func (m *ReplicaIdent) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaIdent) ProtoMessage 

func (*ReplicaIdent) ProtoMessage()

func (*ReplicaIdent) Reset 

func (m *ReplicaIdent) Reset()

func (*ReplicaIdent) Size 

func (m *ReplicaIdent) Size() (n int)

func (*ReplicaIdent) String 

func (m *ReplicaIdent) String() string

func (*ReplicaIdent) Unmarshal 

func (m *ReplicaIdent) Unmarshal(dAtA []byte) error

type ReplicaState 

type ReplicaState struct {
	RaftAppliedIndex uint64           `protobuf:"varint,1,opt,name=raft_applied_index,json=raftAppliedIndex,proto3" json:"raft_applied_index,omitempty"`
	Desc             *GroupDescriptor `protobuf:"bytes,2,opt,name=desc" json:"desc,omitempty"`
	// The truncation state of the Raft log.
	TruncatedState *RaftTruncatedState `protobuf:"bytes,3,opt,name=truncated_state,json=truncatedState" json:"truncated_state,omitempty"`
	Stats          Stats               `protobuf:"bytes,4,opt,name=Stats" json:"Stats"`
}

func (*ReplicaState) Descriptor 

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

func (*ReplicaState) Equal 

func (this *ReplicaState) Equal(that interface{}) bool

func (*ReplicaState) GetDesc 

func (m *ReplicaState) GetDesc() *GroupDescriptor

func (*ReplicaState) GetRaftAppliedIndex 

func (m *ReplicaState) GetRaftAppliedIndex() uint64

func (*ReplicaState) GetStats 

func (m *ReplicaState) GetStats() Stats

func (*ReplicaState) GetTruncatedState 

func (m *ReplicaState) GetTruncatedState() *RaftTruncatedState

func (*ReplicaState) Marshal 

func (m *ReplicaState) Marshal() (dAtA []byte, err error)

func (*ReplicaState) MarshalTo 

func (m *ReplicaState) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaState) ProtoMessage 

func (*ReplicaState) ProtoMessage()

func (*ReplicaState) Reset 

func (m *ReplicaState) Reset()

func (*ReplicaState) Size 

func (m *ReplicaState) Size() (n int)

func (*ReplicaState) String 

func (m *ReplicaState) String() string

func (*ReplicaState) Unmarshal 

func (m *ReplicaState) Unmarshal(dAtA []byte) error

type ReplicaTooOldError 

type ReplicaTooOldError struct {
	// replica_id is the ID of the replica that is too old.
	ReplicaID ReplicaID `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3,casttype=ReplicaID" json:"replica_id,omitempty"`
}

ReplicaTooOldError is sent in response to a raft message when the recipient of the raft message believes the sender of the raft message to have been removed from the raft group

func NewReplicaTooOldError 

func NewReplicaTooOldError(replicaID ReplicaID) *ReplicaTooOldError

NewReplicaTooOldError initializes a new ReplicaTooOldError.

func (*ReplicaTooOldError) Descriptor 

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

func (*ReplicaTooOldError) Equal 

func (this *ReplicaTooOldError) Equal(that interface{}) bool

func (*ReplicaTooOldError) Error 

func (e *ReplicaTooOldError) Error() string

func (*ReplicaTooOldError) GetReplicaID 

func (m *ReplicaTooOldError) GetReplicaID() ReplicaID

func (*ReplicaTooOldError) Marshal 

func (m *ReplicaTooOldError) Marshal() (dAtA []byte, err error)

func (*ReplicaTooOldError) MarshalTo 

func (m *ReplicaTooOldError) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaTooOldError) ProtoMessage 

func (*ReplicaTooOldError) ProtoMessage()

func (*ReplicaTooOldError) Reset 

func (m *ReplicaTooOldError) Reset()

func (*ReplicaTooOldError) Size 

func (m *ReplicaTooOldError) Size() (n int)

func (*ReplicaTooOldError) String 

func (m *ReplicaTooOldError) String() string

func (*ReplicaTooOldError) Unmarshal 

func (m *ReplicaTooOldError) Unmarshal(dAtA []byte) error

type ReplicationTarget 

type ReplicationTarget struct {
	NodeID  NodeID  `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,casttype=NodeID" json:"node_id,omitempty"`
	StoreID StoreID `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3,casttype=StoreID" json:"store_id,omitempty"`
}

ReplicationTarget identifies a node/store pair.

func (*ReplicationTarget) Descriptor 

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

func (*ReplicationTarget) GetNodeID 

func (m *ReplicationTarget) GetNodeID() NodeID

func (*ReplicationTarget) GetStoreID 

func (m *ReplicationTarget) GetStoreID() StoreID

func (*ReplicationTarget) Marshal 

func (m *ReplicationTarget) Marshal() (dAtA []byte, err error)

func (*ReplicationTarget) MarshalTo 

func (m *ReplicationTarget) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTarget) ProtoMessage 

func (*ReplicationTarget) ProtoMessage()

func (*ReplicationTarget) Reset 

func (m *ReplicationTarget) Reset()

func (*ReplicationTarget) Size 

func (m *ReplicationTarget) Size() (n int)

func (*ReplicationTarget) String 

func (m *ReplicationTarget) String() string

func (*ReplicationTarget) Unmarshal 

func (m *ReplicationTarget) Unmarshal(dAtA []byte) error

type Request 

type Request interface {
	proto.Message
	// Method returns the request method.
	Method() Method
	// ShallowCopy returns a shallow copy of the receiver.
	ShallowCopy() Request
	// contains filtered or unexported methods
}

Request is an interface for RPC requests.

func NewGet 

func NewGet(key Key) Request

NewGet returns a Request initialized to get the value at key.

func NewPut 

func NewPut(key Key, value Value) Request

NewPut returns a Request initialized to put the value at key.

type RequestUnion 

type RequestUnion struct {
	Get      *GetRequest         `protobuf:"bytes,1,opt,name=get" json:"get,omitempty"`
	Put      *PutRequest         `protobuf:"bytes,2,opt,name=put" json:"put,omitempty"`
	HasKey   *HasKeyRequest      `protobuf:"bytes,3,opt,name=hasKey" json:"hasKey,omitempty"`
	Truncate *TruncateLogRequest `protobuf:"bytes,4,opt,name=truncate" json:"truncate,omitempty"`
	Delete   *DeleteRequest      `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"`
	Change   *ChangeConfRequest  `protobuf:"bytes,6,opt,name=change" json:"change,omitempty"`
}

A RequestUnion contains exactly one of the requests. The values added here must match those in ResponseUnion.

WARNING: Do not remove fields from RequestUnion. Instead, remove all non-header fields from the request message and prepend its name with "Deprecated". See DeprecatedVerifyChecksumRequest for an example.

Be cautious about deprecating fields as doing so can lead to inconsistencies between replicas.

func (*RequestUnion) Descriptor 

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

func (*RequestUnion) GetChange 

func (m *RequestUnion) GetChange() *ChangeConfRequest

func (*RequestUnion) GetDelete 

func (m *RequestUnion) GetDelete() *DeleteRequest

func (*RequestUnion) GetGet 

func (m *RequestUnion) GetGet() *GetRequest

func (*RequestUnion) GetHasKey 

func (m *RequestUnion) GetHasKey() *HasKeyRequest

func (RequestUnion) GetInner 

func (ru RequestUnion) GetInner() Request

GetInner returns the Request contained in the union.

func (*RequestUnion) GetPut 

func (m *RequestUnion) GetPut() *PutRequest

func (*RequestUnion) GetTruncate 

func (m *RequestUnion) GetTruncate() *TruncateLogRequest

func (*RequestUnion) GetValue 

func (this *RequestUnion) GetValue() interface{}

func (*RequestUnion) Marshal 

func (m *RequestUnion) Marshal() (dAtA []byte, err error)

func (*RequestUnion) MarshalTo 

func (m *RequestUnion) MarshalTo(dAtA []byte) (int, error)

func (*RequestUnion) MustSetInner 

func (ru *RequestUnion) MustSetInner(args Request)

MustSetInner sets the Request contained in the union. It panics if the request is not recognized by the union type. The RequestUnion is reset before being repopulated.

func (*RequestUnion) ProtoMessage 

func (*RequestUnion) ProtoMessage()

func (*RequestUnion) Reset 

func (m *RequestUnion) Reset()

func (*RequestUnion) SetValue 

func (this *RequestUnion) SetValue(value interface{}) bool

func (*RequestUnion) Size 

func (m *RequestUnion) Size() (n int)

func (*RequestUnion) String 

func (m *RequestUnion) String() string

func (*RequestUnion) Unmarshal 

func (m *RequestUnion) Unmarshal(dAtA []byte) error

type Response 

type Response interface {
	proto.Message
	// Method returns the request method.
	Method() Method
	// Header returns the response header.
	Header() ResponseHeader
	// SetHeader sets the response header.
	SetHeader(ResponseHeader)
}

Response is an interface for RPC result.

type ResponseHeader 

type ResponseHeader struct {
	// The number of keys operated on.
	NumKeys int64 `protobuf:"varint,1,opt,name=num_keys,json=numKeys,proto3" json:"num_keys,omitempty"`
	// Range or list of ranges used to execute the request. Multiple
	// ranges may be returned for Scan, ReverseScan or DeleteRange.
	PgInfos []PgInfo `protobuf:"bytes,2,rep,name=pg_infos,json=pgInfos" json:"pg_infos"`
}

ResponseHeader is returned with every storage node response.

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetNumKeys 

func (m *ResponseHeader) GetNumKeys() int64

func (*ResponseHeader) GetPgInfos 

func (m *ResponseHeader) GetPgInfos() []PgInfo

func (ResponseHeader) Header 

func (rh ResponseHeader) Header() ResponseHeader

Header implements the Response interface for ResponseHeader.

func (*ResponseHeader) Marshal 

func (m *ResponseHeader) Marshal() (dAtA []byte, err error)

func (*ResponseHeader) MarshalTo 

func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) SetHeader 

func (rh *ResponseHeader) SetHeader(other ResponseHeader)

SetHeader implements the Response interface.

func (*ResponseHeader) Size 

func (m *ResponseHeader) Size() (n int)

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

func (m *ResponseHeader) Unmarshal(dAtA []byte) error

type ResponseUnion 

type ResponseUnion struct {
	Get      *GetResponse         `protobuf:"bytes,1,opt,name=get" json:"get,omitempty"`
	Put      *PutResponse         `protobuf:"bytes,2,opt,name=put" json:"put,omitempty"`
	HasKey   *HasKeyResponse      `protobuf:"bytes,3,opt,name=hasKey" json:"hasKey,omitempty"`
	Truncate *TruncateLogResponse `protobuf:"bytes,4,opt,name=truncate" json:"truncate,omitempty"`
	Delete   *DeleteResponse      `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"`
	Change   *ChangeConfResponse  `protobuf:"bytes,6,opt,name=change" json:"change,omitempty"`
}

A ResponseUnion contains exactly one of the responses. The values added here must match those in RequestUnion.

WARNING: Do not remove fields from ResponseUnion. Instead, remove all non-header fields from the response message and prepend its name with "Deprecated". See DeprecatedVerifyChecksumResponse for an example.

func (*ResponseUnion) Descriptor 

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

func (*ResponseUnion) GetChange 

func (m *ResponseUnion) GetChange() *ChangeConfResponse

func (*ResponseUnion) GetDelete 

func (m *ResponseUnion) GetDelete() *DeleteResponse

func (*ResponseUnion) GetGet 

func (m *ResponseUnion) GetGet() *GetResponse

func (*ResponseUnion) GetHasKey 

func (m *ResponseUnion) GetHasKey() *HasKeyResponse

func (ResponseUnion) GetInner 

func (ru ResponseUnion) GetInner() Response

GetInner returns the Response contained in the union.

func (*ResponseUnion) GetPut 

func (m *ResponseUnion) GetPut() *PutResponse

func (*ResponseUnion) GetTruncate 

func (m *ResponseUnion) GetTruncate() *TruncateLogResponse

func (*ResponseUnion) GetValue 

func (this *ResponseUnion) GetValue() interface{}

func (*ResponseUnion) Marshal 

func (m *ResponseUnion) Marshal() (dAtA []byte, err error)

func (*ResponseUnion) MarshalTo 

func (m *ResponseUnion) MarshalTo(dAtA []byte) (int, error)

func (*ResponseUnion) MustSetInner 

func (ru *ResponseUnion) MustSetInner(args Response)

MustSetInner sets the Request contained in the union. It panics if the request is not recognized by the union type. The RequestUnion is reset before being repopulated.

func (*ResponseUnion) ProtoMessage 

func (*ResponseUnion) ProtoMessage()

func (*ResponseUnion) Reset 

func (m *ResponseUnion) Reset()

func (*ResponseUnion) SetValue 

func (this *ResponseUnion) SetValue(value interface{}) bool

func (*ResponseUnion) Size 

func (m *ResponseUnion) Size() (n int)

func (*ResponseUnion) String 

func (m *ResponseUnion) String() string

func (*ResponseUnion) Unmarshal 

func (m *ResponseUnion) Unmarshal(dAtA []byte) error

type SendError 

type SendError struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

A SendError indicates that a message could not be delivered to the desired recipient(s).

func (*SendError) Descriptor 

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

func (*SendError) Equal 

func (this *SendError) Equal(that interface{}) bool

func (*SendError) GetMessage 

func (m *SendError) GetMessage() string

func (*SendError) Marshal 

func (m *SendError) Marshal() (dAtA []byte, err error)

func (*SendError) MarshalTo 

func (m *SendError) MarshalTo(dAtA []byte) (int, error)

func (*SendError) ProtoMessage 

func (*SendError) ProtoMessage()

func (*SendError) Reset 

func (m *SendError) Reset()

func (*SendError) Size 

func (m *SendError) Size() (n int)

func (*SendError) String 

func (m *SendError) String() string

func (*SendError) Unmarshal 

func (m *SendError) Unmarshal(dAtA []byte) error

type SnapshotRequest 

type SnapshotRequest struct {
	Header *SnapshotRequest_Header `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// A RocksDB BatchRepr. Multiple kv_batches may be sent across multiple request messages.
	KVBatch []byte `protobuf:"bytes,2,opt,name=kv_batch,json=kvBatch,proto3" json:"kv_batch,omitempty"`
	Key     []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Val     []byte `protobuf:"bytes,4,opt,name=val,proto3" json:"val,omitempty"`
	Index   int32  `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// These are really raftpb.Entry, but we model them as raw bytes to avoid
	// roundtripping through memory. They are separate from the kv_batch to
	// allow flexibility in log implementations.
	LogEntries [][]byte `protobuf:"bytes,6,rep,name=log_entries,json=logEntries" json:"log_entries,omitempty"`
	Final      bool     `protobuf:"varint,7,opt,name=final,proto3" json:"final,omitempty"`
}

SnapshotRequest is the request used to send streaming snapshot requests.

func (*SnapshotRequest) Descriptor 

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

func (*SnapshotRequest) GetFinal 

func (m *SnapshotRequest) GetFinal() bool

func (*SnapshotRequest) GetHeader 

func (m *SnapshotRequest) GetHeader() *SnapshotRequest_Header

func (*SnapshotRequest) GetIndex 

func (m *SnapshotRequest) GetIndex() int32

func (*SnapshotRequest) GetKVBatch 

func (m *SnapshotRequest) GetKVBatch() []byte

func (*SnapshotRequest) GetKey 

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

func (*SnapshotRequest) GetLogEntries 

func (m *SnapshotRequest) GetLogEntries() [][]byte

func (*SnapshotRequest) GetVal 

func (m *SnapshotRequest) GetVal() []byte

func (*SnapshotRequest) Marshal 

func (m *SnapshotRequest) Marshal() (dAtA []byte, err error)

func (*SnapshotRequest) MarshalTo 

func (m *SnapshotRequest) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotRequest) ProtoMessage 

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) Reset 

func (m *SnapshotRequest) Reset()

func (*SnapshotRequest) Size 

func (m *SnapshotRequest) Size() (n int)

func (*SnapshotRequest) String 

func (m *SnapshotRequest) String() string

func (*SnapshotRequest) Unmarshal 

func (m *SnapshotRequest) Unmarshal(dAtA []byte) error

type SnapshotRequest_Header 

type SnapshotRequest_Header struct {
	// The replica state at the time the snapshot was generated. Note
	// that ReplicaState.Desc differs from the above range_descriptor
	// field which holds the updated descriptor after the new replica
	// has been added while ReplicaState.Desc holds the descriptor
	// before the new replica has been added.
	State ReplicaState `protobuf:"bytes,5,opt,name=state" json:"state"`
	// The inner raft message is of type MsgSnap, and its snapshot data contains a UUID.
	RaftMessageRequest RaftMessageRequest `protobuf:"bytes,2,opt,name=raft_message_request,json=raftMessageRequest" json:"raft_message_request"`
	// The estimated size of the range, to be used in reservation decisions.
	RangeSize int64 `protobuf:"varint,3,opt,name=range_size,json=rangeSize,proto3" json:"range_size,omitempty"`
	// can_decline is set on preemptive snapshots, but not those generated
	// by raft because at that point it is better to queue up the stream
	// than to cancel it.
	CanDecline bool `protobuf:"varint,4,opt,name=can_decline,json=canDecline,proto3" json:"can_decline,omitempty"`
	// The priority of the snapshot.
	Priority SnapshotRequest_Priority `protobuf:"varint,6,opt,name=priority,proto3,enum=multiraftbase.SnapshotRequest_Priority" json:"priority,omitempty"`
}

func (*SnapshotRequest_Header) Descriptor 

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

func (*SnapshotRequest_Header) GetCanDecline 

func (m *SnapshotRequest_Header) GetCanDecline() bool

func (*SnapshotRequest_Header) GetPriority 

func (m *SnapshotRequest_Header) GetPriority() SnapshotRequest_Priority

func (*SnapshotRequest_Header) GetRaftMessageRequest 

func (m *SnapshotRequest_Header) GetRaftMessageRequest() RaftMessageRequest

func (*SnapshotRequest_Header) GetRangeSize 

func (m *SnapshotRequest_Header) GetRangeSize() int64

func (*SnapshotRequest_Header) GetState 

func (m *SnapshotRequest_Header) GetState() ReplicaState

func (*SnapshotRequest_Header) Marshal 

func (m *SnapshotRequest_Header) Marshal() (dAtA []byte, err error)

func (*SnapshotRequest_Header) MarshalTo 

func (m *SnapshotRequest_Header) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotRequest_Header) ProtoMessage 

func (*SnapshotRequest_Header) ProtoMessage()

func (*SnapshotRequest_Header) Reset 

func (m *SnapshotRequest_Header) Reset()

func (*SnapshotRequest_Header) Size 

func (m *SnapshotRequest_Header) Size() (n int)

func (*SnapshotRequest_Header) String 

func (m *SnapshotRequest_Header) String() string

func (*SnapshotRequest_Header) Unmarshal 

func (m *SnapshotRequest_Header) Unmarshal(dAtA []byte) error

type SnapshotRequest_Priority 

type SnapshotRequest_Priority int32
const (
	SnapshotRequest_UNKNOWN SnapshotRequest_Priority = 0
	// RECOVERY is used for a Raft-initiated snapshots and for
	// up-replication snapshots (i.e. when a dead node has been
	// removed and the range needs to be up-replicated).
	SnapshotRequest_RECOVERY SnapshotRequest_Priority = 1
	// REBALANCE is used for snapshots involved in rebalancing.
	SnapshotRequest_REBALANCE SnapshotRequest_Priority = 2
)

func (SnapshotRequest_Priority) EnumDescriptor 

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

func (SnapshotRequest_Priority) String 

func (x SnapshotRequest_Priority) String() string

type SnapshotResponse 

type SnapshotResponse struct {
	Status  SnapshotResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=multiraftbase.SnapshotResponse_Status" json:"status,omitempty"`
	Message string                  `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*SnapshotResponse) Descriptor 

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

func (*SnapshotResponse) GetMessage 

func (m *SnapshotResponse) GetMessage() string

func (*SnapshotResponse) GetStatus 

func (m *SnapshotResponse) GetStatus() SnapshotResponse_Status

func (*SnapshotResponse) Marshal 

func (m *SnapshotResponse) Marshal() (dAtA []byte, err error)

func (*SnapshotResponse) MarshalTo 

func (m *SnapshotResponse) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotResponse) ProtoMessage 

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) Reset 

func (m *SnapshotResponse) Reset()

func (*SnapshotResponse) Size 

func (m *SnapshotResponse) Size() (n int)

func (*SnapshotResponse) String 

func (m *SnapshotResponse) String() string

func (*SnapshotResponse) Unmarshal 

func (m *SnapshotResponse) Unmarshal(dAtA []byte) error

type SnapshotResponse_Status 

type SnapshotResponse_Status int32
const (
	SnapshotResponse_UNKNOWN  SnapshotResponse_Status = 0
	SnapshotResponse_ACCEPTED SnapshotResponse_Status = 1
	SnapshotResponse_APPLIED  SnapshotResponse_Status = 2
	SnapshotResponse_ERROR    SnapshotResponse_Status = 3
	SnapshotResponse_DECLINED SnapshotResponse_Status = 4
)

func (SnapshotResponse_Status) EnumDescriptor 

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

func (SnapshotResponse_Status) String 

func (x SnapshotResponse_Status) String() string

type Stats 

type Stats struct {
	KeyBytes   int64 `protobuf:"varint,1,opt,name=key_bytes,json=keyBytes,proto3" json:"key_bytes,omitempty"`
	ValBytes   int64 `protobuf:"varint,2,opt,name=val_bytes,json=valBytes,proto3" json:"val_bytes,omitempty"`
	TotalBytes int64 `protobuf:"varint,3,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
}

func NewPopulatedStats 

func NewPopulatedStats(r randyState, easy bool) *Stats

func (*Stats) Descriptor 

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

func (*Stats) Equal 

func (this *Stats) Equal(that interface{}) bool

func (*Stats) GetKeyBytes 

func (m *Stats) GetKeyBytes() int64

func (*Stats) GetTotalBytes 

func (m *Stats) GetTotalBytes() int64

func (*Stats) GetValBytes 

func (m *Stats) GetValBytes() int64

func (*Stats) Marshal 

func (m *Stats) Marshal() (dAtA []byte, err error)

func (*Stats) MarshalTo 

func (m *Stats) MarshalTo(dAtA []byte) (int, error)

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) Reset 

func (m *Stats) Reset()

func (*Stats) Size 

func (m *Stats) Size() (n int)

func (*Stats) String 

func (m *Stats) String() string

func (*Stats) Unmarshal 

func (m *Stats) Unmarshal(dAtA []byte) error

type StoreCapacity 

type StoreCapacity struct {
	// Total capacity of the disk used by the store, including space used by the
	// operating system and other applications.
	Capacity int64 `protobuf:"varint,1,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// Available space remaining on the disk used by the store.
	Available int64 `protobuf:"varint,2,opt,name=available,proto3" json:"available,omitempty"`
	// Amount of disk space used by the data in the CockroachDB store. Note that
	// this is going to be less than (capacity - available), because those two
	// fields consider the entire disk and everything on it, while this only
	// tracks the store's disk usage.
	Used int64 `protobuf:"varint,8,opt,name=used,proto3" json:"used,omitempty"`
	// Amount of logical bytes stored in the store, ignoring RocksDB space
	// overhead. Useful for rebalancing so that moving a replica from one store
	// to another actually removes its bytes from the source store even though
	// RocksDB may not actually reclaim the physical disk space for a while.
	LogicalBytes int64 `protobuf:"varint,9,opt,name=logical_bytes,json=logicalBytes,proto3" json:"logical_bytes,omitempty"`
	PgCount      int32 `protobuf:"varint,3,opt,name=pg_count,json=pgCount,proto3" json:"pg_count,omitempty"`
}

StoreCapacity contains capacity information for a storage device.

func (*StoreCapacity) Descriptor 

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

func (*StoreCapacity) GetAvailable 

func (m *StoreCapacity) GetAvailable() int64

func (*StoreCapacity) GetCapacity 

func (m *StoreCapacity) GetCapacity() int64

func (*StoreCapacity) GetLogicalBytes 

func (m *StoreCapacity) GetLogicalBytes() int64

func (*StoreCapacity) GetPgCount 

func (m *StoreCapacity) GetPgCount() int32

func (*StoreCapacity) GetUsed 

func (m *StoreCapacity) GetUsed() int64

func (*StoreCapacity) Marshal 

func (m *StoreCapacity) Marshal() (dAtA []byte, err error)

func (*StoreCapacity) MarshalTo 

func (m *StoreCapacity) MarshalTo(dAtA []byte) (int, error)

func (*StoreCapacity) ProtoMessage 

func (*StoreCapacity) ProtoMessage()

func (*StoreCapacity) Reset 

func (m *StoreCapacity) Reset()

func (*StoreCapacity) Size 

func (m *StoreCapacity) Size() (n int)

func (*StoreCapacity) String 

func (m *StoreCapacity) String() string

func (*StoreCapacity) Unmarshal 

func (m *StoreCapacity) Unmarshal(dAtA []byte) error

type StoreDeadReplicas 

type StoreDeadReplicas struct {
	StoreID  StoreID         `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3,casttype=StoreID" json:"store_id,omitempty"`
	Replicas []*ReplicaIdent `protobuf:"bytes,2,rep,name=replicas" json:"replicas,omitempty"`
}

StoreDeadReplicas holds a storeID and a list of dead replicas on that store. Used to let the range lease holder know about corrupted or otherwise destroyed replicas that should be transferred to a different store.

func (*StoreDeadReplicas) Descriptor 

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

func (*StoreDeadReplicas) GetReplicas 

func (m *StoreDeadReplicas) GetReplicas() []*ReplicaIdent

func (*StoreDeadReplicas) GetStoreID 

func (m *StoreDeadReplicas) GetStoreID() StoreID

func (*StoreDeadReplicas) Marshal 

func (m *StoreDeadReplicas) Marshal() (dAtA []byte, err error)

func (*StoreDeadReplicas) MarshalTo 

func (m *StoreDeadReplicas) MarshalTo(dAtA []byte) (int, error)

func (*StoreDeadReplicas) ProtoMessage 

func (*StoreDeadReplicas) ProtoMessage()

func (*StoreDeadReplicas) Reset 

func (m *StoreDeadReplicas) Reset()

func (*StoreDeadReplicas) Size 

func (m *StoreDeadReplicas) Size() (n int)

func (*StoreDeadReplicas) String 

func (m *StoreDeadReplicas) String() string

func (*StoreDeadReplicas) Unmarshal 

func (m *StoreDeadReplicas) Unmarshal(dAtA []byte) error

type StoreDescriptor 

type StoreDescriptor struct {
	StoreID  StoreID         `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3,casttype=StoreID" json:"store_id,omitempty"`
	Attrs    *Attributes     `protobuf:"bytes,2,opt,name=attrs" json:"attrs,omitempty"`
	Node     *NodeDescriptor `protobuf:"bytes,3,opt,name=node" json:"node,omitempty"`
	Capacity *StoreCapacity  `protobuf:"bytes,4,opt,name=capacity" json:"capacity,omitempty"`
}

StoreDescriptor holds store information including store attributes, node descriptor and store capacity.

func (*StoreDescriptor) Descriptor 

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

func (*StoreDescriptor) GetAttrs 

func (m *StoreDescriptor) GetAttrs() *Attributes

func (*StoreDescriptor) GetCapacity 

func (m *StoreDescriptor) GetCapacity() *StoreCapacity

func (*StoreDescriptor) GetNode 

func (m *StoreDescriptor) GetNode() *NodeDescriptor

func (*StoreDescriptor) GetStoreID 

func (m *StoreDescriptor) GetStoreID() StoreID

func (*StoreDescriptor) Marshal 

func (m *StoreDescriptor) Marshal() (dAtA []byte, err error)

func (*StoreDescriptor) MarshalTo 

func (m *StoreDescriptor) MarshalTo(dAtA []byte) (int, error)

func (*StoreDescriptor) ProtoMessage 

func (*StoreDescriptor) ProtoMessage()

func (*StoreDescriptor) Reset 

func (m *StoreDescriptor) Reset()

func (*StoreDescriptor) Size 

func (m *StoreDescriptor) Size() (n int)

func (*StoreDescriptor) String 

func (m *StoreDescriptor) String() string

func (*StoreDescriptor) Unmarshal 

func (m *StoreDescriptor) Unmarshal(dAtA []byte) error

type StoreID 

type StoreID int32

StoreID is a custom type for a cockroach store ID.

type StoreIdent 

type StoreIdent struct {
	ClusterID *github_com_journeymidnight_nentropy_util_uuid.UUID `` /* 150-byte string literal not displayed */
	NodeID    NodeID                                              `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3,casttype=NodeID" json:"node_id,omitempty"`
	StoreID   StoreID                                             `protobuf:"varint,3,opt,name=store_id,json=storeId,proto3,casttype=StoreID" json:"store_id,omitempty"`
}

A StoreIdent uniquely identifies a store in the cluster. The StoreIdent is written to the underlying storage engine at a store-reserved system key (KeyLocalIdent).

func (*StoreIdent) Descriptor 

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

func (*StoreIdent) GetNodeID 

func (m *StoreIdent) GetNodeID() NodeID

func (*StoreIdent) GetStoreID 

func (m *StoreIdent) GetStoreID() StoreID

func (*StoreIdent) Marshal 

func (m *StoreIdent) Marshal() (dAtA []byte, err error)

func (*StoreIdent) MarshalTo 

func (m *StoreIdent) MarshalTo(dAtA []byte) (int, error)

func (*StoreIdent) ProtoMessage 

func (*StoreIdent) ProtoMessage()

func (*StoreIdent) Reset 

func (m *StoreIdent) Reset()

func (*StoreIdent) Size 

func (m *StoreIdent) Size() (n int)

func (*StoreIdent) String 

func (m *StoreIdent) String() string

func (*StoreIdent) Unmarshal 

func (m *StoreIdent) Unmarshal(dAtA []byte) error

type StoreNotFoundError 

type StoreNotFoundError struct {
	StoreID StoreID `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3,casttype=StoreID" json:"store_id,omitempty"`
}

A StoreNotFoundError indicates that a command was sent to a store which is not hosted on this node.

func NewStoreNotFoundError 

func NewStoreNotFoundError(storeID StoreID) *StoreNotFoundError

NewStoreNotFoundError initializes a new StoreNotFoundError.

func (*StoreNotFoundError) Descriptor 

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

func (*StoreNotFoundError) Equal 

func (this *StoreNotFoundError) Equal(that interface{}) bool

func (*StoreNotFoundError) Error 

func (e *StoreNotFoundError) Error() string

func (*StoreNotFoundError) GetStoreID 

func (m *StoreNotFoundError) GetStoreID() StoreID

func (*StoreNotFoundError) Marshal 

func (m *StoreNotFoundError) Marshal() (dAtA []byte, err error)

func (*StoreNotFoundError) MarshalTo 

func (m *StoreNotFoundError) MarshalTo(dAtA []byte) (int, error)

func (*StoreNotFoundError) ProtoMessage 

func (*StoreNotFoundError) ProtoMessage()

func (*StoreNotFoundError) Reset 

func (m *StoreNotFoundError) Reset()

func (*StoreNotFoundError) Size 

func (m *StoreNotFoundError) Size() (n int)

func (*StoreNotFoundError) String 

func (m *StoreNotFoundError) String() string

func (*StoreNotFoundError) Unmarshal 

func (m *StoreNotFoundError) Unmarshal(dAtA []byte) error

type SystemConfig 

type SystemConfig struct {
	Values []*KeyValue `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

func (*SystemConfig) Descriptor 

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

func (*SystemConfig) GetValues 

func (m *SystemConfig) GetValues() []*KeyValue

func (*SystemConfig) Marshal 

func (m *SystemConfig) Marshal() (dAtA []byte, err error)

func (*SystemConfig) MarshalTo 

func (m *SystemConfig) MarshalTo(dAtA []byte) (int, error)

func (*SystemConfig) ProtoMessage 

func (*SystemConfig) ProtoMessage()

func (*SystemConfig) Reset 

func (m *SystemConfig) Reset()

func (*SystemConfig) Size 

func (m *SystemConfig) Size() (n int)

func (*SystemConfig) String 

func (m *SystemConfig) String() string

func (*SystemConfig) Unmarshal 

func (m *SystemConfig) Unmarshal(dAtA []byte) error

type TruncateLogRequest 

type TruncateLogRequest struct {
	// Log entries < this index are to be discarded.
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Term  uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	// GroupID is used to double check that the correct range is being truncated.
	// The header specifies a span, start and end keys, but not the range id
	// itself. The range may have changed from the one specified in the header
	// in the case of a merge.
	GroupID GroupID `protobuf:"bytes,3,opt,name=group_id,json=groupId,proto3,casttype=GroupID" json:"group_id,omitempty"`
}

TruncateLogRequest is used to remove a prefix of the raft log. While there is no requirement for correctness that the raft log truncation be synchronized across replicas, it is nice to preserve the property that all replicas of a range are as close to identical as possible. The raft leader can also inform decisions about the cutoff point with its knowledge of the replicas' acknowledgment status.

func (*TruncateLogRequest) Descriptor 

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

func (*TruncateLogRequest) Equal 

func (this *TruncateLogRequest) Equal(that interface{}) bool

func (*TruncateLogRequest) GetGroupID 

func (m *TruncateLogRequest) GetGroupID() GroupID

func (*TruncateLogRequest) GetIndex 

func (m *TruncateLogRequest) GetIndex() uint64

func (*TruncateLogRequest) GetTerm 

func (m *TruncateLogRequest) GetTerm() uint64

func (*TruncateLogRequest) Marshal 

func (m *TruncateLogRequest) Marshal() (dAtA []byte, err error)

func (*TruncateLogRequest) MarshalTo 

func (m *TruncateLogRequest) MarshalTo(dAtA []byte) (int, error)

func (*TruncateLogRequest) Method 

func (*TruncateLogRequest) Method() Method

Method implements the Request interface.

func (*TruncateLogRequest) ProtoMessage 

func (*TruncateLogRequest) ProtoMessage()

func (*TruncateLogRequest) Reset 

func (m *TruncateLogRequest) Reset()

func (*TruncateLogRequest) ShallowCopy 

func (tr *TruncateLogRequest) ShallowCopy() Request

ShallowCopy implements the Request interface.

func (*TruncateLogRequest) Size 

func (m *TruncateLogRequest) Size() (n int)

func (*TruncateLogRequest) String 

func (m *TruncateLogRequest) String() string

func (*TruncateLogRequest) Unmarshal 

func (m *TruncateLogRequest) Unmarshal(dAtA []byte) error

type TruncateLogResponse 

type TruncateLogResponse struct {
	ResponseHeader `protobuf:"bytes,1,opt,name=header,embedded=header" json:"header"`
}

A TruncateLogRequest is the return value from the truncatelog() method.

func (*TruncateLogResponse) Descriptor 

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

func (*TruncateLogResponse) Marshal 

func (m *TruncateLogResponse) Marshal() (dAtA []byte, err error)

func (*TruncateLogResponse) MarshalTo 

func (m *TruncateLogResponse) MarshalTo(dAtA []byte) (int, error)

func (*TruncateLogResponse) Method 

func (*TruncateLogResponse) Method() Method

Method implements the Request interface.

func (*TruncateLogResponse) ProtoMessage 

func (*TruncateLogResponse) ProtoMessage()

func (*TruncateLogResponse) Reset 

func (m *TruncateLogResponse) Reset()

func (*TruncateLogResponse) Size 

func (m *TruncateLogResponse) Size() (n int)

func (*TruncateLogResponse) String 

func (m *TruncateLogResponse) String() string

func (*TruncateLogResponse) Unmarshal 

func (m *TruncateLogResponse) Unmarshal(dAtA []byte) error

type Value 

type Value []byte

Key is a custom type for a byte string in proto messages which refer to Cockroach keys.

func (Value) String 

func (k Value) String() string

String returns a string-formatted version of the key.

type ValueType 

type ValueType int32

ValueType defines a set of type constants placed in the "tag" field of Value messages. These are defined as a protocol buffer enumeration so that they can be used portably between our Go and C code. The tags are used by the RocksDB Merge Operator to perform specialized merges. 

const (
	// This is a subset of the SQL column type values, representing the underlying
	// storage for various types. The DELIMITED_foo entries each represent a foo
	// variant that self-delimits length.
	ValueType_UNKNOWN           ValueType = 0
	ValueType_NULL              ValueType = 7
	ValueType_INT               ValueType = 1
	ValueType_FLOAT             ValueType = 2
	ValueType_BYTES             ValueType = 3
	ValueType_DELIMITED_BYTES   ValueType = 8
	ValueType_TIME              ValueType = 4
	ValueType_DECIMAL           ValueType = 5
	ValueType_DELIMITED_DECIMAL ValueType = 9
	ValueType_DURATION          ValueType = 6
	// TUPLE represents a DTuple, encoded as repeated pairs of varint field number
	// followed by a value encoded Datum.
	ValueType_TUPLE ValueType = 10
	// TIMESERIES is applied to values which contain InternalTimeSeriesData.
	ValueType_TIMESERIES ValueType = 100
)

type WriteBatch 

type WriteBatch struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

WriteBatch is the serialized representation of a RocksDB write batch. A wrapper message is used so that the absence of the field can be distinguished from a zero-length batch, and so structs containing pointers to it can be compared with the == operator (we rely on this in storage.EvalResult)

func (*WriteBatch) Descriptor 

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

func (*WriteBatch) GetData 

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

func (*WriteBatch) Marshal 

func (m *WriteBatch) Marshal() (dAtA []byte, err error)

func (*WriteBatch) MarshalTo 

func (m *WriteBatch) MarshalTo(dAtA []byte) (int, error)

func (*WriteBatch) ProtoMessage 

func (*WriteBatch) ProtoMessage()

func (*WriteBatch) Reset 

func (m *WriteBatch) Reset()

func (*WriteBatch) Size 

func (m *WriteBatch) Size() (n int)

func (*WriteBatch) String 

func (m *WriteBatch) String() string

func (*WriteBatch) Unmarshal 

func (m *WriteBatch) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.