Documentation ¶
Overview ¶
Package riak_kv is a generated protocol buffer package.
It is generated from these files:
riak_kv.proto
It has these top-level messages:
RpbGetClientIdResp RpbSetClientIdReq RpbGetReq RpbGetResp RpbPutReq RpbPutResp RpbDelReq RpbListBucketsReq RpbListBucketsResp RpbListKeysReq RpbListKeysResp RpbMapRedReq RpbMapRedResp RpbIndexReq RpbIndexResp RpbCSBucketReq RpbCSBucketResp RpbIndexObject RpbContent RpbLink RpbCounterUpdateReq RpbCounterUpdateResp RpbCounterGetReq RpbCounterGetResp RpbGetBucketKeyPreflistReq RpbGetBucketKeyPreflistResp RpbBucketKeyPreflistItem
Index ¶
- Constants
- Variables
- type RpbBucketKeyPreflistItem
- func (m *RpbBucketKeyPreflistItem) GetNode() []byte
- func (m *RpbBucketKeyPreflistItem) GetPartition() int64
- func (m *RpbBucketKeyPreflistItem) GetPrimary() bool
- func (*RpbBucketKeyPreflistItem) ProtoMessage()
- func (m *RpbBucketKeyPreflistItem) Reset()
- func (m *RpbBucketKeyPreflistItem) String() string
- type RpbCSBucketReq
- func (m *RpbCSBucketReq) GetBucket() []byte
- func (m *RpbCSBucketReq) GetContinuation() []byte
- func (m *RpbCSBucketReq) GetEndIncl() bool
- func (m *RpbCSBucketReq) GetEndKey() []byte
- func (m *RpbCSBucketReq) GetMaxResults() uint32
- func (m *RpbCSBucketReq) GetStartIncl() bool
- func (m *RpbCSBucketReq) GetStartKey() []byte
- func (m *RpbCSBucketReq) GetTimeout() uint32
- func (m *RpbCSBucketReq) GetType() []byte
- func (*RpbCSBucketReq) ProtoMessage()
- func (m *RpbCSBucketReq) Reset()
- func (m *RpbCSBucketReq) String() string
- type RpbCSBucketResp
- type RpbContent
- func (m *RpbContent) GetCharset() []byte
- func (m *RpbContent) GetContentEncoding() []byte
- func (m *RpbContent) GetContentType() []byte
- func (m *RpbContent) GetDeleted() bool
- func (m *RpbContent) GetIndexes() []*riak.RpbPair
- func (m *RpbContent) GetLastMod() uint32
- func (m *RpbContent) GetLastModUsecs() uint32
- func (m *RpbContent) GetLinks() []*RpbLink
- func (m *RpbContent) GetUsermeta() []*riak.RpbPair
- func (m *RpbContent) GetValue() []byte
- func (m *RpbContent) GetVtag() []byte
- func (*RpbContent) ProtoMessage()
- func (m *RpbContent) Reset()
- func (m *RpbContent) String() string
- type RpbCounterGetReq
- func (m *RpbCounterGetReq) GetBasicQuorum() bool
- func (m *RpbCounterGetReq) GetBucket() []byte
- func (m *RpbCounterGetReq) GetKey() []byte
- func (m *RpbCounterGetReq) GetNotfoundOk() bool
- func (m *RpbCounterGetReq) GetPr() uint32
- func (m *RpbCounterGetReq) GetR() uint32
- func (*RpbCounterGetReq) ProtoMessage()
- func (m *RpbCounterGetReq) Reset()
- func (m *RpbCounterGetReq) String() string
- type RpbCounterGetResp
- type RpbCounterUpdateReq
- func (m *RpbCounterUpdateReq) BucketIsRequired() bool
- func (m *RpbCounterUpdateReq) GetAmount() int64
- func (m *RpbCounterUpdateReq) GetBucket() []byte
- func (m *RpbCounterUpdateReq) GetDw() uint32
- func (m *RpbCounterUpdateReq) GetKey() []byte
- func (m *RpbCounterUpdateReq) GetPw() uint32
- func (m *RpbCounterUpdateReq) GetReturnvalue() bool
- func (m *RpbCounterUpdateReq) GetType() []byte
- func (m *RpbCounterUpdateReq) GetW() uint32
- func (m *RpbCounterUpdateReq) KeyIsRequired() bool
- func (*RpbCounterUpdateReq) ProtoMessage()
- func (m *RpbCounterUpdateReq) Reset()
- func (m *RpbCounterUpdateReq) SetType(bt []byte)
- func (m *RpbCounterUpdateReq) String() string
- type RpbCounterUpdateResp
- type RpbDelReq
- func (m *RpbDelReq) BucketIsRequired() bool
- func (m *RpbDelReq) GetBucket() []byte
- func (m *RpbDelReq) GetDw() uint32
- func (m *RpbDelReq) GetKey() []byte
- func (m *RpbDelReq) GetNVal() uint32
- func (m *RpbDelReq) GetPr() uint32
- func (m *RpbDelReq) GetPw() uint32
- func (m *RpbDelReq) GetR() uint32
- func (m *RpbDelReq) GetRw() uint32
- func (m *RpbDelReq) GetSloppyQuorum() bool
- func (m *RpbDelReq) GetTimeout() uint32
- func (m *RpbDelReq) GetType() []byte
- func (m *RpbDelReq) GetVclock() []byte
- func (m *RpbDelReq) GetW() uint32
- func (m *RpbDelReq) KeyIsRequired() bool
- func (*RpbDelReq) ProtoMessage()
- func (m *RpbDelReq) Reset()
- func (m *RpbDelReq) SetType(bt []byte)
- func (m *RpbDelReq) String() string
- type RpbGetBucketKeyPreflistReq
- func (m *RpbGetBucketKeyPreflistReq) BucketIsRequired() bool
- func (m *RpbGetBucketKeyPreflistReq) GetBucket() []byte
- func (m *RpbGetBucketKeyPreflistReq) GetKey() []byte
- func (m *RpbGetBucketKeyPreflistReq) GetType() []byte
- func (m *RpbGetBucketKeyPreflistReq) KeyIsRequired() bool
- func (*RpbGetBucketKeyPreflistReq) ProtoMessage()
- func (m *RpbGetBucketKeyPreflistReq) Reset()
- func (m *RpbGetBucketKeyPreflistReq) SetType(bt []byte)
- func (m *RpbGetBucketKeyPreflistReq) String() string
- type RpbGetBucketKeyPreflistResp
- type RpbGetClientIdResp
- type RpbGetReq
- func (m *RpbGetReq) BucketIsRequired() bool
- func (m *RpbGetReq) GetBasicQuorum() bool
- func (m *RpbGetReq) GetBucket() []byte
- func (m *RpbGetReq) GetDeletedvclock() bool
- func (m *RpbGetReq) GetHead() bool
- func (m *RpbGetReq) GetIfModified() []byte
- func (m *RpbGetReq) GetKey() []byte
- func (m *RpbGetReq) GetNVal() uint32
- func (m *RpbGetReq) GetNotfoundOk() bool
- func (m *RpbGetReq) GetPr() uint32
- func (m *RpbGetReq) GetR() uint32
- func (m *RpbGetReq) GetSloppyQuorum() bool
- func (m *RpbGetReq) GetTimeout() uint32
- func (m *RpbGetReq) GetType() []byte
- func (m *RpbGetReq) KeyIsRequired() bool
- func (*RpbGetReq) ProtoMessage()
- func (m *RpbGetReq) Reset()
- func (m *RpbGetReq) SetType(bt []byte)
- func (m *RpbGetReq) String() string
- type RpbGetResp
- type RpbIndexObject
- type RpbIndexReq
- func (m *RpbIndexReq) BucketIsRequired() bool
- func (m *RpbIndexReq) GetBucket() []byte
- func (m *RpbIndexReq) GetContinuation() []byte
- func (m *RpbIndexReq) GetIndex() []byte
- func (m *RpbIndexReq) GetKey() []byte
- func (m *RpbIndexReq) GetMaxResults() uint32
- func (m *RpbIndexReq) GetPaginationSort() bool
- func (m *RpbIndexReq) GetQtype() RpbIndexReq_IndexQueryType
- func (m *RpbIndexReq) GetRangeMax() []byte
- func (m *RpbIndexReq) GetRangeMin() []byte
- func (m *RpbIndexReq) GetReturnTerms() bool
- func (m *RpbIndexReq) GetStream() bool
- func (m *RpbIndexReq) GetTermRegex() []byte
- func (m *RpbIndexReq) GetTimeout() uint32
- func (m *RpbIndexReq) GetType() []byte
- func (m *RpbIndexReq) KeyIsRequired() bool
- func (*RpbIndexReq) ProtoMessage()
- func (m *RpbIndexReq) Reset()
- func (m *RpbIndexReq) SetType(bt []byte)
- func (m *RpbIndexReq) String() string
- type RpbIndexReq_IndexQueryType
- type RpbIndexResp
- type RpbLink
- type RpbListBucketsReq
- func (m *RpbListBucketsReq) BucketIsRequired() bool
- func (m *RpbListBucketsReq) GetBucket() []byte
- func (m *RpbListBucketsReq) GetKey() []byte
- func (m *RpbListBucketsReq) GetStream() bool
- func (m *RpbListBucketsReq) GetTimeout() uint32
- func (m *RpbListBucketsReq) GetType() []byte
- func (m *RpbListBucketsReq) KeyIsRequired() bool
- func (*RpbListBucketsReq) ProtoMessage()
- func (m *RpbListBucketsReq) Reset()
- func (m *RpbListBucketsReq) SetType(bt []byte)
- func (m *RpbListBucketsReq) String() string
- type RpbListBucketsResp
- type RpbListKeysReq
- func (m *RpbListKeysReq) BucketIsRequired() bool
- func (m *RpbListKeysReq) GetBucket() []byte
- func (m *RpbListKeysReq) GetKey() []byte
- func (m *RpbListKeysReq) GetTimeout() uint32
- func (m *RpbListKeysReq) GetType() []byte
- func (m *RpbListKeysReq) KeyIsRequired() bool
- func (*RpbListKeysReq) ProtoMessage()
- func (m *RpbListKeysReq) Reset()
- func (m *RpbListKeysReq) SetType(bt []byte)
- func (m *RpbListKeysReq) String() string
- type RpbListKeysResp
- type RpbMapRedReq
- type RpbMapRedResp
- type RpbPutReq
- func (m *RpbPutReq) BucketIsRequired() bool
- func (m *RpbPutReq) GetAsis() bool
- func (m *RpbPutReq) GetBucket() []byte
- func (m *RpbPutReq) GetContent() *RpbContent
- func (m *RpbPutReq) GetDw() uint32
- func (m *RpbPutReq) GetIfNoneMatch() bool
- func (m *RpbPutReq) GetIfNotModified() bool
- func (m *RpbPutReq) GetKey() []byte
- func (m *RpbPutReq) GetNVal() uint32
- func (m *RpbPutReq) GetPw() uint32
- func (m *RpbPutReq) GetReturnBody() bool
- func (m *RpbPutReq) GetReturnHead() bool
- func (m *RpbPutReq) GetSloppyQuorum() bool
- func (m *RpbPutReq) GetTimeout() uint32
- func (m *RpbPutReq) GetType() []byte
- func (m *RpbPutReq) GetVclock() []byte
- func (m *RpbPutReq) GetW() uint32
- func (m *RpbPutReq) KeyIsRequired() bool
- func (*RpbPutReq) ProtoMessage()
- func (m *RpbPutReq) Reset()
- func (m *RpbPutReq) SetType(bt []byte)
- func (m *RpbPutReq) String() string
- type RpbPutResp
- type RpbSetClientIdReq
Constants ¶
const Default_RpbCSBucketReq_EndIncl bool = false
const Default_RpbCSBucketReq_StartIncl bool = true
Variables ¶
var RpbIndexReq_IndexQueryType_name = map[int32]string{
0: "eq",
1: "range",
}
var RpbIndexReq_IndexQueryType_value = map[string]int32{
"eq": 0,
"range": 1,
}
Functions ¶
This section is empty.
Types ¶
type RpbBucketKeyPreflistItem ¶
type RpbBucketKeyPreflistItem struct { Partition *int64 `protobuf:"varint,1,req,name=partition" json:"partition,omitempty"` Node []byte `protobuf:"bytes,2,req,name=node" json:"node,omitempty"` Primary *bool `protobuf:"varint,3,req,name=primary" json:"primary,omitempty"` XXX_unrecognized []byte `json:"-"` }
Preflist item
func (*RpbBucketKeyPreflistItem) GetNode ¶
func (m *RpbBucketKeyPreflistItem) GetNode() []byte
func (*RpbBucketKeyPreflistItem) GetPartition ¶
func (m *RpbBucketKeyPreflistItem) GetPartition() int64
func (*RpbBucketKeyPreflistItem) GetPrimary ¶
func (m *RpbBucketKeyPreflistItem) GetPrimary() bool
func (*RpbBucketKeyPreflistItem) ProtoMessage ¶
func (*RpbBucketKeyPreflistItem) ProtoMessage()
func (*RpbBucketKeyPreflistItem) Reset ¶
func (m *RpbBucketKeyPreflistItem) Reset()
func (*RpbBucketKeyPreflistItem) String ¶
func (m *RpbBucketKeyPreflistItem) String() string
type RpbCSBucketReq ¶
type RpbCSBucketReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` StartKey []byte `protobuf:"bytes,2,req,name=start_key" json:"start_key,omitempty"` EndKey []byte `protobuf:"bytes,3,opt,name=end_key" json:"end_key,omitempty"` StartIncl *bool `protobuf:"varint,4,opt,name=start_incl,def=1" json:"start_incl,omitempty"` EndIncl *bool `protobuf:"varint,5,opt,name=end_incl,def=0" json:"end_incl,omitempty"` Continuation []byte `protobuf:"bytes,6,opt,name=continuation" json:"continuation,omitempty"` MaxResults *uint32 `protobuf:"varint,7,opt,name=max_results" json:"max_results,omitempty"` Timeout *uint32 `protobuf:"varint,8,opt,name=timeout" json:"timeout,omitempty"` Type []byte `protobuf:"bytes,9,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
added solely for riak_cs currently for folding over a bucket and returning objects.
func (*RpbCSBucketReq) GetBucket ¶
func (m *RpbCSBucketReq) GetBucket() []byte
func (*RpbCSBucketReq) GetContinuation ¶
func (m *RpbCSBucketReq) GetContinuation() []byte
func (*RpbCSBucketReq) GetEndIncl ¶
func (m *RpbCSBucketReq) GetEndIncl() bool
func (*RpbCSBucketReq) GetEndKey ¶
func (m *RpbCSBucketReq) GetEndKey() []byte
func (*RpbCSBucketReq) GetMaxResults ¶
func (m *RpbCSBucketReq) GetMaxResults() uint32
func (*RpbCSBucketReq) GetStartIncl ¶
func (m *RpbCSBucketReq) GetStartIncl() bool
func (*RpbCSBucketReq) GetStartKey ¶
func (m *RpbCSBucketReq) GetStartKey() []byte
func (*RpbCSBucketReq) GetTimeout ¶
func (m *RpbCSBucketReq) GetTimeout() uint32
func (*RpbCSBucketReq) GetType ¶
func (m *RpbCSBucketReq) GetType() []byte
func (*RpbCSBucketReq) ProtoMessage ¶
func (*RpbCSBucketReq) ProtoMessage()
func (*RpbCSBucketReq) Reset ¶
func (m *RpbCSBucketReq) Reset()
func (*RpbCSBucketReq) String ¶
func (m *RpbCSBucketReq) String() string
type RpbCSBucketResp ¶
type RpbCSBucketResp struct { Objects []*RpbIndexObject `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"` Continuation []byte `protobuf:"bytes,2,opt,name=continuation" json:"continuation,omitempty"` Done *bool `protobuf:"varint,3,opt,name=done" json:"done,omitempty"` XXX_unrecognized []byte `json:"-"` }
return for CS bucket fold
func (*RpbCSBucketResp) GetContinuation ¶
func (m *RpbCSBucketResp) GetContinuation() []byte
func (*RpbCSBucketResp) GetDone ¶
func (m *RpbCSBucketResp) GetDone() bool
func (*RpbCSBucketResp) GetObjects ¶
func (m *RpbCSBucketResp) GetObjects() []*RpbIndexObject
func (*RpbCSBucketResp) ProtoMessage ¶
func (*RpbCSBucketResp) ProtoMessage()
func (*RpbCSBucketResp) Reset ¶
func (m *RpbCSBucketResp) Reset()
func (*RpbCSBucketResp) String ¶
func (m *RpbCSBucketResp) String() string
type RpbContent ¶
type RpbContent struct { Value []byte `protobuf:"bytes,1,req,name=value" json:"value,omitempty"` ContentType []byte `protobuf:"bytes,2,opt,name=content_type" json:"content_type,omitempty"` Charset []byte `protobuf:"bytes,3,opt,name=charset" json:"charset,omitempty"` ContentEncoding []byte `protobuf:"bytes,4,opt,name=content_encoding" json:"content_encoding,omitempty"` Vtag []byte `protobuf:"bytes,5,opt,name=vtag" json:"vtag,omitempty"` Links []*RpbLink `protobuf:"bytes,6,rep,name=links" json:"links,omitempty"` LastMod *uint32 `protobuf:"varint,7,opt,name=last_mod" json:"last_mod,omitempty"` LastModUsecs *uint32 `protobuf:"varint,8,opt,name=last_mod_usecs" json:"last_mod_usecs,omitempty"` Usermeta []*riak.RpbPair `protobuf:"bytes,9,rep,name=usermeta" json:"usermeta,omitempty"` Indexes []*riak.RpbPair `protobuf:"bytes,10,rep,name=indexes" json:"indexes,omitempty"` Deleted *bool `protobuf:"varint,11,opt,name=deleted" json:"deleted,omitempty"` XXX_unrecognized []byte `json:"-"` }
Content message included in get/put responses Holds the value and associated metadata
func (*RpbContent) GetCharset ¶
func (m *RpbContent) GetCharset() []byte
func (*RpbContent) GetContentEncoding ¶
func (m *RpbContent) GetContentEncoding() []byte
func (*RpbContent) GetContentType ¶
func (m *RpbContent) GetContentType() []byte
func (*RpbContent) GetDeleted ¶
func (m *RpbContent) GetDeleted() bool
func (*RpbContent) GetIndexes ¶
func (m *RpbContent) GetIndexes() []*riak.RpbPair
func (*RpbContent) GetLastMod ¶
func (m *RpbContent) GetLastMod() uint32
func (*RpbContent) GetLastModUsecs ¶
func (m *RpbContent) GetLastModUsecs() uint32
func (*RpbContent) GetLinks ¶
func (m *RpbContent) GetLinks() []*RpbLink
func (*RpbContent) GetUsermeta ¶
func (m *RpbContent) GetUsermeta() []*riak.RpbPair
func (*RpbContent) GetValue ¶
func (m *RpbContent) GetValue() []byte
func (*RpbContent) GetVtag ¶
func (m *RpbContent) GetVtag() []byte
func (*RpbContent) ProtoMessage ¶
func (*RpbContent) ProtoMessage()
func (*RpbContent) Reset ¶
func (m *RpbContent) Reset()
func (*RpbContent) String ¶
func (m *RpbContent) String() string
type RpbCounterGetReq ¶
type RpbCounterGetReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` R *uint32 `protobuf:"varint,3,opt,name=r" json:"r,omitempty"` Pr *uint32 `protobuf:"varint,4,opt,name=pr" json:"pr,omitempty"` BasicQuorum *bool `protobuf:"varint,5,opt,name=basic_quorum" json:"basic_quorum,omitempty"` NotfoundOk *bool `protobuf:"varint,6,opt,name=notfound_ok" json:"notfound_ok,omitempty"` XXX_unrecognized []byte `json:"-"` }
counter value
func (*RpbCounterGetReq) GetBasicQuorum ¶
func (m *RpbCounterGetReq) GetBasicQuorum() bool
func (*RpbCounterGetReq) GetBucket ¶
func (m *RpbCounterGetReq) GetBucket() []byte
func (*RpbCounterGetReq) GetKey ¶
func (m *RpbCounterGetReq) GetKey() []byte
func (*RpbCounterGetReq) GetNotfoundOk ¶
func (m *RpbCounterGetReq) GetNotfoundOk() bool
func (*RpbCounterGetReq) GetPr ¶
func (m *RpbCounterGetReq) GetPr() uint32
func (*RpbCounterGetReq) GetR ¶
func (m *RpbCounterGetReq) GetR() uint32
func (*RpbCounterGetReq) ProtoMessage ¶
func (*RpbCounterGetReq) ProtoMessage()
func (*RpbCounterGetReq) Reset ¶
func (m *RpbCounterGetReq) Reset()
func (*RpbCounterGetReq) String ¶
func (m *RpbCounterGetReq) String() string
type RpbCounterGetResp ¶
type RpbCounterGetResp struct { Value *int64 `protobuf:"zigzag64,1,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
Counter value response
func (*RpbCounterGetResp) GetValue ¶
func (m *RpbCounterGetResp) GetValue() int64
func (*RpbCounterGetResp) ProtoMessage ¶
func (*RpbCounterGetResp) ProtoMessage()
func (*RpbCounterGetResp) Reset ¶
func (m *RpbCounterGetResp) Reset()
func (*RpbCounterGetResp) String ¶
func (m *RpbCounterGetResp) String() string
type RpbCounterUpdateReq ¶
type RpbCounterUpdateReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` Amount *int64 `protobuf:"zigzag64,3,req,name=amount" json:"amount,omitempty"` W *uint32 `protobuf:"varint,4,opt,name=w" json:"w,omitempty"` Dw *uint32 `protobuf:"varint,5,opt,name=dw" json:"dw,omitempty"` Pw *uint32 `protobuf:"varint,6,opt,name=pw" json:"pw,omitempty"` Returnvalue *bool `protobuf:"varint,7,opt,name=returnvalue" json:"returnvalue,omitempty"` XXX_unrecognized []byte `json:"-"` }
Counter update request
func (*RpbCounterUpdateReq) BucketIsRequired ¶ added in v1.4.0
func (m *RpbCounterUpdateReq) BucketIsRequired() bool
func (*RpbCounterUpdateReq) GetAmount ¶
func (m *RpbCounterUpdateReq) GetAmount() int64
func (*RpbCounterUpdateReq) GetBucket ¶
func (m *RpbCounterUpdateReq) GetBucket() []byte
func (*RpbCounterUpdateReq) GetDw ¶
func (m *RpbCounterUpdateReq) GetDw() uint32
func (*RpbCounterUpdateReq) GetKey ¶
func (m *RpbCounterUpdateReq) GetKey() []byte
func (*RpbCounterUpdateReq) GetPw ¶
func (m *RpbCounterUpdateReq) GetPw() uint32
func (*RpbCounterUpdateReq) GetReturnvalue ¶
func (m *RpbCounterUpdateReq) GetReturnvalue() bool
func (*RpbCounterUpdateReq) GetType ¶ added in v1.4.0
func (m *RpbCounterUpdateReq) GetType() []byte
func (*RpbCounterUpdateReq) GetW ¶
func (m *RpbCounterUpdateReq) GetW() uint32
func (*RpbCounterUpdateReq) KeyIsRequired ¶ added in v1.4.0
func (m *RpbCounterUpdateReq) KeyIsRequired() bool
func (*RpbCounterUpdateReq) ProtoMessage ¶
func (*RpbCounterUpdateReq) ProtoMessage()
func (*RpbCounterUpdateReq) Reset ¶
func (m *RpbCounterUpdateReq) Reset()
func (*RpbCounterUpdateReq) SetType ¶ added in v1.4.0
func (m *RpbCounterUpdateReq) SetType(bt []byte)
func (*RpbCounterUpdateReq) String ¶
func (m *RpbCounterUpdateReq) String() string
type RpbCounterUpdateResp ¶
type RpbCounterUpdateResp struct { Value *int64 `protobuf:"zigzag64,1,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
Counter update response? No message | error response
func (*RpbCounterUpdateResp) GetValue ¶
func (m *RpbCounterUpdateResp) GetValue() int64
func (*RpbCounterUpdateResp) ProtoMessage ¶
func (*RpbCounterUpdateResp) ProtoMessage()
func (*RpbCounterUpdateResp) Reset ¶
func (m *RpbCounterUpdateResp) Reset()
func (*RpbCounterUpdateResp) String ¶
func (m *RpbCounterUpdateResp) String() string
type RpbDelReq ¶
type RpbDelReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` Rw *uint32 `protobuf:"varint,3,opt,name=rw" json:"rw,omitempty"` Vclock []byte `protobuf:"bytes,4,opt,name=vclock" json:"vclock,omitempty"` R *uint32 `protobuf:"varint,5,opt,name=r" json:"r,omitempty"` W *uint32 `protobuf:"varint,6,opt,name=w" json:"w,omitempty"` Pr *uint32 `protobuf:"varint,7,opt,name=pr" json:"pr,omitempty"` Pw *uint32 `protobuf:"varint,8,opt,name=pw" json:"pw,omitempty"` Dw *uint32 `protobuf:"varint,9,opt,name=dw" json:"dw,omitempty"` Timeout *uint32 `protobuf:"varint,10,opt,name=timeout" json:"timeout,omitempty"` SloppyQuorum *bool `protobuf:"varint,11,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"` NVal *uint32 `protobuf:"varint,12,opt,name=n_val" json:"n_val,omitempty"` Type []byte `protobuf:"bytes,13,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Delete request
func (*RpbDelReq) BucketIsRequired ¶
func (*RpbDelReq) GetSloppyQuorum ¶
func (*RpbDelReq) GetTimeout ¶
func (*RpbDelReq) KeyIsRequired ¶
func (*RpbDelReq) ProtoMessage ¶
func (*RpbDelReq) ProtoMessage()
type RpbGetBucketKeyPreflistReq ¶
type RpbGetBucketKeyPreflistReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` Type []byte `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get bucket-key preflist request
func (*RpbGetBucketKeyPreflistReq) BucketIsRequired ¶
func (m *RpbGetBucketKeyPreflistReq) BucketIsRequired() bool
func (*RpbGetBucketKeyPreflistReq) GetBucket ¶
func (m *RpbGetBucketKeyPreflistReq) GetBucket() []byte
func (*RpbGetBucketKeyPreflistReq) GetKey ¶
func (m *RpbGetBucketKeyPreflistReq) GetKey() []byte
func (*RpbGetBucketKeyPreflistReq) GetType ¶
func (m *RpbGetBucketKeyPreflistReq) GetType() []byte
func (*RpbGetBucketKeyPreflistReq) KeyIsRequired ¶
func (m *RpbGetBucketKeyPreflistReq) KeyIsRequired() bool
func (*RpbGetBucketKeyPreflistReq) ProtoMessage ¶
func (*RpbGetBucketKeyPreflistReq) ProtoMessage()
func (*RpbGetBucketKeyPreflistReq) Reset ¶
func (m *RpbGetBucketKeyPreflistReq) Reset()
func (*RpbGetBucketKeyPreflistReq) SetType ¶
func (m *RpbGetBucketKeyPreflistReq) SetType(bt []byte)
func (*RpbGetBucketKeyPreflistReq) String ¶
func (m *RpbGetBucketKeyPreflistReq) String() string
type RpbGetBucketKeyPreflistResp ¶
type RpbGetBucketKeyPreflistResp struct { Preflist []*RpbBucketKeyPreflistItem `protobuf:"bytes,1,rep,name=preflist" json:"preflist,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get bucket-key preflist response
func (*RpbGetBucketKeyPreflistResp) GetPreflist ¶
func (m *RpbGetBucketKeyPreflistResp) GetPreflist() []*RpbBucketKeyPreflistItem
func (*RpbGetBucketKeyPreflistResp) ProtoMessage ¶
func (*RpbGetBucketKeyPreflistResp) ProtoMessage()
func (*RpbGetBucketKeyPreflistResp) Reset ¶
func (m *RpbGetBucketKeyPreflistResp) Reset()
func (*RpbGetBucketKeyPreflistResp) String ¶
func (m *RpbGetBucketKeyPreflistResp) String() string
type RpbGetClientIdResp ¶
type RpbGetClientIdResp struct { ClientId []byte `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get ClientId Request - no message defined, just send RpbGetClientIdReq message code
func (*RpbGetClientIdResp) GetClientId ¶
func (m *RpbGetClientIdResp) GetClientId() []byte
func (*RpbGetClientIdResp) ProtoMessage ¶
func (*RpbGetClientIdResp) ProtoMessage()
func (*RpbGetClientIdResp) Reset ¶
func (m *RpbGetClientIdResp) Reset()
func (*RpbGetClientIdResp) String ¶
func (m *RpbGetClientIdResp) String() string
type RpbGetReq ¶
type RpbGetReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` R *uint32 `protobuf:"varint,3,opt,name=r" json:"r,omitempty"` Pr *uint32 `protobuf:"varint,4,opt,name=pr" json:"pr,omitempty"` BasicQuorum *bool `protobuf:"varint,5,opt,name=basic_quorum" json:"basic_quorum,omitempty"` NotfoundOk *bool `protobuf:"varint,6,opt,name=notfound_ok" json:"notfound_ok,omitempty"` IfModified []byte `protobuf:"bytes,7,opt,name=if_modified" json:"if_modified,omitempty"` Head *bool `protobuf:"varint,8,opt,name=head" json:"head,omitempty"` Deletedvclock *bool `protobuf:"varint,9,opt,name=deletedvclock" json:"deletedvclock,omitempty"` Timeout *uint32 `protobuf:"varint,10,opt,name=timeout" json:"timeout,omitempty"` SloppyQuorum *bool `protobuf:"varint,11,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"` NVal *uint32 `protobuf:"varint,12,opt,name=n_val" json:"n_val,omitempty"` Type []byte `protobuf:"bytes,13,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get Request - retrieve bucket/key
func (*RpbGetReq) BucketIsRequired ¶
func (*RpbGetReq) GetBasicQuorum ¶
func (*RpbGetReq) GetDeletedvclock ¶
func (*RpbGetReq) GetIfModified ¶
func (*RpbGetReq) GetNotfoundOk ¶
func (*RpbGetReq) GetSloppyQuorum ¶
func (*RpbGetReq) GetTimeout ¶
func (*RpbGetReq) KeyIsRequired ¶
func (*RpbGetReq) ProtoMessage ¶
func (*RpbGetReq) ProtoMessage()
type RpbGetResp ¶
type RpbGetResp struct { Content []*RpbContent `protobuf:"bytes,1,rep,name=content" json:"content,omitempty"` Vclock []byte `protobuf:"bytes,2,opt,name=vclock" json:"vclock,omitempty"` Unchanged *bool `protobuf:"varint,3,opt,name=unchanged" json:"unchanged,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get Response - if the record was not found there will be no content/vclock
func (*RpbGetResp) GetContent ¶
func (m *RpbGetResp) GetContent() []*RpbContent
func (*RpbGetResp) GetUnchanged ¶
func (m *RpbGetResp) GetUnchanged() bool
func (*RpbGetResp) GetVclock ¶
func (m *RpbGetResp) GetVclock() []byte
func (*RpbGetResp) ProtoMessage ¶
func (*RpbGetResp) ProtoMessage()
func (*RpbGetResp) Reset ¶
func (m *RpbGetResp) Reset()
func (*RpbGetResp) String ¶
func (m *RpbGetResp) String() string
type RpbIndexObject ¶
type RpbIndexObject struct { Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Object *RpbGetResp `protobuf:"bytes,2,req,name=object" json:"object,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbIndexObject) GetKey ¶
func (m *RpbIndexObject) GetKey() []byte
func (*RpbIndexObject) GetObject ¶
func (m *RpbIndexObject) GetObject() *RpbGetResp
func (*RpbIndexObject) ProtoMessage ¶
func (*RpbIndexObject) ProtoMessage()
func (*RpbIndexObject) Reset ¶
func (m *RpbIndexObject) Reset()
func (*RpbIndexObject) String ¶
func (m *RpbIndexObject) String() string
type RpbIndexReq ¶
type RpbIndexReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Index []byte `protobuf:"bytes,2,req,name=index" json:"index,omitempty"` Qtype *RpbIndexReq_IndexQueryType `protobuf:"varint,3,req,name=qtype,enum=RpbIndexReq_IndexQueryType" json:"qtype,omitempty"` Key []byte `protobuf:"bytes,4,opt,name=key" json:"key,omitempty"` RangeMin []byte `protobuf:"bytes,5,opt,name=range_min" json:"range_min,omitempty"` RangeMax []byte `protobuf:"bytes,6,opt,name=range_max" json:"range_max,omitempty"` ReturnTerms *bool `protobuf:"varint,7,opt,name=return_terms" json:"return_terms,omitempty"` Stream *bool `protobuf:"varint,8,opt,name=stream" json:"stream,omitempty"` MaxResults *uint32 `protobuf:"varint,9,opt,name=max_results" json:"max_results,omitempty"` Continuation []byte `protobuf:"bytes,10,opt,name=continuation" json:"continuation,omitempty"` Timeout *uint32 `protobuf:"varint,11,opt,name=timeout" json:"timeout,omitempty"` Type []byte `protobuf:"bytes,12,opt,name=type" json:"type,omitempty"` TermRegex []byte `protobuf:"bytes,13,opt,name=term_regex" json:"term_regex,omitempty"` // Whether to use pagination sort for non-paginated queries PaginationSort *bool `protobuf:"varint,14,opt,name=pagination_sort" json:"pagination_sort,omitempty"` XXX_unrecognized []byte `json:"-"` }
Secondary Index query request
func (*RpbIndexReq) BucketIsRequired ¶
func (m *RpbIndexReq) BucketIsRequired() bool
func (*RpbIndexReq) GetBucket ¶
func (m *RpbIndexReq) GetBucket() []byte
func (*RpbIndexReq) GetContinuation ¶
func (m *RpbIndexReq) GetContinuation() []byte
func (*RpbIndexReq) GetIndex ¶
func (m *RpbIndexReq) GetIndex() []byte
func (*RpbIndexReq) GetKey ¶
func (m *RpbIndexReq) GetKey() []byte
func (*RpbIndexReq) GetMaxResults ¶
func (m *RpbIndexReq) GetMaxResults() uint32
func (*RpbIndexReq) GetPaginationSort ¶
func (m *RpbIndexReq) GetPaginationSort() bool
func (*RpbIndexReq) GetQtype ¶
func (m *RpbIndexReq) GetQtype() RpbIndexReq_IndexQueryType
func (*RpbIndexReq) GetRangeMax ¶
func (m *RpbIndexReq) GetRangeMax() []byte
func (*RpbIndexReq) GetRangeMin ¶
func (m *RpbIndexReq) GetRangeMin() []byte
func (*RpbIndexReq) GetReturnTerms ¶
func (m *RpbIndexReq) GetReturnTerms() bool
func (*RpbIndexReq) GetStream ¶
func (m *RpbIndexReq) GetStream() bool
func (*RpbIndexReq) GetTermRegex ¶
func (m *RpbIndexReq) GetTermRegex() []byte
func (*RpbIndexReq) GetTimeout ¶
func (m *RpbIndexReq) GetTimeout() uint32
func (*RpbIndexReq) GetType ¶
func (m *RpbIndexReq) GetType() []byte
func (*RpbIndexReq) KeyIsRequired ¶
func (m *RpbIndexReq) KeyIsRequired() bool
func (*RpbIndexReq) ProtoMessage ¶
func (*RpbIndexReq) ProtoMessage()
func (*RpbIndexReq) Reset ¶
func (m *RpbIndexReq) Reset()
func (*RpbIndexReq) SetType ¶
func (m *RpbIndexReq) SetType(bt []byte)
func (*RpbIndexReq) String ¶
func (m *RpbIndexReq) String() string
type RpbIndexReq_IndexQueryType ¶
type RpbIndexReq_IndexQueryType int32
const ( RpbIndexReq_eq RpbIndexReq_IndexQueryType = 0 RpbIndexReq_range RpbIndexReq_IndexQueryType = 1 )
func (RpbIndexReq_IndexQueryType) Enum ¶
func (x RpbIndexReq_IndexQueryType) Enum() *RpbIndexReq_IndexQueryType
func (RpbIndexReq_IndexQueryType) String ¶
func (x RpbIndexReq_IndexQueryType) String() string
func (*RpbIndexReq_IndexQueryType) UnmarshalJSON ¶
func (x *RpbIndexReq_IndexQueryType) UnmarshalJSON(data []byte) error
type RpbIndexResp ¶
type RpbIndexResp struct { Keys [][]byte `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"` Results []*riak.RpbPair `protobuf:"bytes,2,rep,name=results" json:"results,omitempty"` Continuation []byte `protobuf:"bytes,3,opt,name=continuation" json:"continuation,omitempty"` Done *bool `protobuf:"varint,4,opt,name=done" json:"done,omitempty"` XXX_unrecognized []byte `json:"-"` }
Secondary Index query response
func (*RpbIndexResp) GetContinuation ¶
func (m *RpbIndexResp) GetContinuation() []byte
func (*RpbIndexResp) GetDone ¶
func (m *RpbIndexResp) GetDone() bool
func (*RpbIndexResp) GetKeys ¶
func (m *RpbIndexResp) GetKeys() [][]byte
func (*RpbIndexResp) GetResults ¶
func (m *RpbIndexResp) GetResults() []*riak.RpbPair
func (*RpbIndexResp) ProtoMessage ¶
func (*RpbIndexResp) ProtoMessage()
func (*RpbIndexResp) Reset ¶
func (m *RpbIndexResp) Reset()
func (*RpbIndexResp) String ¶
func (m *RpbIndexResp) String() string
type RpbLink ¶
type RpbLink struct { Bucket []byte `protobuf:"bytes,1,opt,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` Tag []byte `protobuf:"bytes,3,opt,name=tag" json:"tag,omitempty"` XXX_unrecognized []byte `json:"-"` }
Link metadata
func (*RpbLink) ProtoMessage ¶
func (*RpbLink) ProtoMessage()
type RpbListBucketsReq ¶
type RpbListBucketsReq struct { Timeout *uint32 `protobuf:"varint,1,opt,name=timeout" json:"timeout,omitempty"` Stream *bool `protobuf:"varint,2,opt,name=stream" json:"stream,omitempty"` Type []byte `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
List buckets request
func (*RpbListBucketsReq) BucketIsRequired ¶
func (m *RpbListBucketsReq) BucketIsRequired() bool
func (*RpbListBucketsReq) GetBucket ¶
func (m *RpbListBucketsReq) GetBucket() []byte
func (*RpbListBucketsReq) GetKey ¶
func (m *RpbListBucketsReq) GetKey() []byte
func (*RpbListBucketsReq) GetStream ¶
func (m *RpbListBucketsReq) GetStream() bool
func (*RpbListBucketsReq) GetTimeout ¶
func (m *RpbListBucketsReq) GetTimeout() uint32
func (*RpbListBucketsReq) GetType ¶
func (m *RpbListBucketsReq) GetType() []byte
func (*RpbListBucketsReq) KeyIsRequired ¶
func (m *RpbListBucketsReq) KeyIsRequired() bool
func (*RpbListBucketsReq) ProtoMessage ¶
func (*RpbListBucketsReq) ProtoMessage()
func (*RpbListBucketsReq) Reset ¶
func (m *RpbListBucketsReq) Reset()
func (*RpbListBucketsReq) SetType ¶
func (m *RpbListBucketsReq) SetType(bt []byte)
func (*RpbListBucketsReq) String ¶
func (m *RpbListBucketsReq) String() string
type RpbListBucketsResp ¶
type RpbListBucketsResp struct { Buckets [][]byte `protobuf:"bytes,1,rep,name=buckets" json:"buckets,omitempty"` Done *bool `protobuf:"varint,2,opt,name=done" json:"done,omitempty"` XXX_unrecognized []byte `json:"-"` }
List buckets response - one or more of these packets will be sent the last one will have done set true (and may not have any buckets in it)
func (*RpbListBucketsResp) GetBuckets ¶
func (m *RpbListBucketsResp) GetBuckets() [][]byte
func (*RpbListBucketsResp) GetDone ¶
func (m *RpbListBucketsResp) GetDone() bool
func (*RpbListBucketsResp) ProtoMessage ¶
func (*RpbListBucketsResp) ProtoMessage()
func (*RpbListBucketsResp) Reset ¶
func (m *RpbListBucketsResp) Reset()
func (*RpbListBucketsResp) String ¶
func (m *RpbListBucketsResp) String() string
type RpbListKeysReq ¶
type RpbListKeysReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Timeout *uint32 `protobuf:"varint,2,opt,name=timeout" json:"timeout,omitempty"` Type []byte `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
List keys in bucket request
func (*RpbListKeysReq) BucketIsRequired ¶
func (m *RpbListKeysReq) BucketIsRequired() bool
func (*RpbListKeysReq) GetBucket ¶
func (m *RpbListKeysReq) GetBucket() []byte
func (*RpbListKeysReq) GetKey ¶
func (m *RpbListKeysReq) GetKey() []byte
func (*RpbListKeysReq) GetTimeout ¶
func (m *RpbListKeysReq) GetTimeout() uint32
func (*RpbListKeysReq) GetType ¶
func (m *RpbListKeysReq) GetType() []byte
func (*RpbListKeysReq) KeyIsRequired ¶
func (m *RpbListKeysReq) KeyIsRequired() bool
func (*RpbListKeysReq) ProtoMessage ¶
func (*RpbListKeysReq) ProtoMessage()
func (*RpbListKeysReq) Reset ¶
func (m *RpbListKeysReq) Reset()
func (*RpbListKeysReq) SetType ¶
func (m *RpbListKeysReq) SetType(bt []byte)
func (*RpbListKeysReq) String ¶
func (m *RpbListKeysReq) String() string
type RpbListKeysResp ¶
type RpbListKeysResp struct { Keys [][]byte `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"` Done *bool `protobuf:"varint,2,opt,name=done" json:"done,omitempty"` XXX_unrecognized []byte `json:"-"` }
List keys in bucket response - one or more of these packets will be sent the last one will have done set true (and may not have any keys in it)
func (*RpbListKeysResp) GetDone ¶
func (m *RpbListKeysResp) GetDone() bool
func (*RpbListKeysResp) GetKeys ¶
func (m *RpbListKeysResp) GetKeys() [][]byte
func (*RpbListKeysResp) ProtoMessage ¶
func (*RpbListKeysResp) ProtoMessage()
func (*RpbListKeysResp) Reset ¶
func (m *RpbListKeysResp) Reset()
func (*RpbListKeysResp) String ¶
func (m *RpbListKeysResp) String() string
type RpbMapRedReq ¶
type RpbMapRedReq struct { Request []byte `protobuf:"bytes,1,req,name=request" json:"request,omitempty"` ContentType []byte `protobuf:"bytes,2,req,name=content_type" json:"content_type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Map/Reduce request
func (*RpbMapRedReq) GetContentType ¶
func (m *RpbMapRedReq) GetContentType() []byte
func (*RpbMapRedReq) GetRequest ¶
func (m *RpbMapRedReq) GetRequest() []byte
func (*RpbMapRedReq) ProtoMessage ¶
func (*RpbMapRedReq) ProtoMessage()
func (*RpbMapRedReq) Reset ¶
func (m *RpbMapRedReq) Reset()
func (*RpbMapRedReq) String ¶
func (m *RpbMapRedReq) String() string
type RpbMapRedResp ¶
type RpbMapRedResp struct { Phase *uint32 `protobuf:"varint,1,opt,name=phase" json:"phase,omitempty"` Response []byte `protobuf:"bytes,2,opt,name=response" json:"response,omitempty"` Done *bool `protobuf:"varint,3,opt,name=done" json:"done,omitempty"` XXX_unrecognized []byte `json:"-"` }
Map/Reduce response one or more of these packets will be sent the last one will have done set true (and may not have phase/data in it)
func (*RpbMapRedResp) GetDone ¶
func (m *RpbMapRedResp) GetDone() bool
func (*RpbMapRedResp) GetPhase ¶
func (m *RpbMapRedResp) GetPhase() uint32
func (*RpbMapRedResp) GetResponse ¶
func (m *RpbMapRedResp) GetResponse() []byte
func (*RpbMapRedResp) ProtoMessage ¶
func (*RpbMapRedResp) ProtoMessage()
func (*RpbMapRedResp) Reset ¶
func (m *RpbMapRedResp) Reset()
func (*RpbMapRedResp) String ¶
func (m *RpbMapRedResp) String() string
type RpbPutReq ¶
type RpbPutReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` Vclock []byte `protobuf:"bytes,3,opt,name=vclock" json:"vclock,omitempty"` Content *RpbContent `protobuf:"bytes,4,req,name=content" json:"content,omitempty"` W *uint32 `protobuf:"varint,5,opt,name=w" json:"w,omitempty"` Dw *uint32 `protobuf:"varint,6,opt,name=dw" json:"dw,omitempty"` ReturnBody *bool `protobuf:"varint,7,opt,name=return_body" json:"return_body,omitempty"` Pw *uint32 `protobuf:"varint,8,opt,name=pw" json:"pw,omitempty"` IfNotModified *bool `protobuf:"varint,9,opt,name=if_not_modified" json:"if_not_modified,omitempty"` IfNoneMatch *bool `protobuf:"varint,10,opt,name=if_none_match" json:"if_none_match,omitempty"` ReturnHead *bool `protobuf:"varint,11,opt,name=return_head" json:"return_head,omitempty"` Timeout *uint32 `protobuf:"varint,12,opt,name=timeout" json:"timeout,omitempty"` Asis *bool `protobuf:"varint,13,opt,name=asis" json:"asis,omitempty"` SloppyQuorum *bool `protobuf:"varint,14,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"` NVal *uint32 `protobuf:"varint,15,opt,name=n_val" json:"n_val,omitempty"` Type []byte `protobuf:"bytes,16,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Put request - if options.return_body is set then the updated metadata/data for
the key will be returned.
func (*RpbPutReq) BucketIsRequired ¶
func (*RpbPutReq) GetContent ¶
func (m *RpbPutReq) GetContent() *RpbContent
func (*RpbPutReq) GetIfNoneMatch ¶
func (*RpbPutReq) GetIfNotModified ¶
func (*RpbPutReq) GetReturnBody ¶
func (*RpbPutReq) GetReturnHead ¶
func (*RpbPutReq) GetSloppyQuorum ¶
func (*RpbPutReq) GetTimeout ¶
func (*RpbPutReq) KeyIsRequired ¶
func (*RpbPutReq) ProtoMessage ¶
func (*RpbPutReq) ProtoMessage()
type RpbPutResp ¶
type RpbPutResp struct { Content []*RpbContent `protobuf:"bytes,1,rep,name=content" json:"content,omitempty"` Vclock []byte `protobuf:"bytes,2,opt,name=vclock" json:"vclock,omitempty"` Key []byte `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"` XXX_unrecognized []byte `json:"-"` }
Put response - same as get response with optional key if one was generated
func (*RpbPutResp) GetContent ¶
func (m *RpbPutResp) GetContent() []*RpbContent
func (*RpbPutResp) GetKey ¶
func (m *RpbPutResp) GetKey() []byte
func (*RpbPutResp) GetVclock ¶
func (m *RpbPutResp) GetVclock() []byte
func (*RpbPutResp) ProtoMessage ¶
func (*RpbPutResp) ProtoMessage()
func (*RpbPutResp) Reset ¶
func (m *RpbPutResp) Reset()
func (*RpbPutResp) String ¶
func (m *RpbPutResp) String() string
type RpbSetClientIdReq ¶
type RpbSetClientIdReq struct { ClientId []byte `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbSetClientIdReq) GetClientId ¶
func (m *RpbSetClientIdReq) GetClientId() []byte
func (*RpbSetClientIdReq) ProtoMessage ¶
func (*RpbSetClientIdReq) ProtoMessage()
func (*RpbSetClientIdReq) Reset ¶
func (m *RpbSetClientIdReq) Reset()
func (*RpbSetClientIdReq) String ¶
func (m *RpbSetClientIdReq) String() string