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 RpbIndexBodyResp RpbCSBucketReq RpbCSBucketResp RpbIndexObject RpbContent RpbLink RpbCounterUpdateReq RpbCounterUpdateResp RpbCounterGetReq RpbCounterGetResp RpbGetBucketKeyPreflistReq RpbGetBucketKeyPreflistResp RpbBucketKeyPreflistItem RpbCoverageReq RpbCoverageResp RpbCoverageEntry
Index ¶
- Constants
- Variables
- type RpbBucketKeyPreflistItem
- func (*RpbBucketKeyPreflistItem) Descriptor() ([]byte, []int)
- 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 (*RpbCSBucketReq) Descriptor() ([]byte, []int)
- func (m *RpbCSBucketReq) GetBucket() []byte
- func (m *RpbCSBucketReq) GetContinuation() []byte
- func (m *RpbCSBucketReq) GetCoverContext() []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
- func (*RpbCSBucketResp) Descriptor() ([]byte, []int)
- func (m *RpbCSBucketResp) GetContinuation() []byte
- func (m *RpbCSBucketResp) GetDone() bool
- func (m *RpbCSBucketResp) GetObjects() []*RpbIndexObject
- func (*RpbCSBucketResp) ProtoMessage()
- func (m *RpbCSBucketResp) Reset()
- func (m *RpbCSBucketResp) String() string
- type RpbContent
- func (*RpbContent) Descriptor() ([]byte, []int)
- 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 (*RpbCounterGetReq) Descriptor() ([]byte, []int)
- 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 (*RpbCounterUpdateReq) Descriptor() ([]byte, []int)
- 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 RpbCoverageEntry
- func (*RpbCoverageEntry) Descriptor() ([]byte, []int)
- func (m *RpbCoverageEntry) GetCoverContext() []byte
- func (m *RpbCoverageEntry) GetIp() []byte
- func (m *RpbCoverageEntry) GetKeyspaceDesc() []byte
- func (m *RpbCoverageEntry) GetPort() uint32
- func (*RpbCoverageEntry) ProtoMessage()
- func (m *RpbCoverageEntry) Reset()
- func (m *RpbCoverageEntry) String() string
- type RpbCoverageReq
- func (*RpbCoverageReq) Descriptor() ([]byte, []int)
- func (m *RpbCoverageReq) GetBucket() []byte
- func (m *RpbCoverageReq) GetMinPartitions() uint32
- func (m *RpbCoverageReq) GetReplaceCover() []byte
- func (m *RpbCoverageReq) GetType() []byte
- func (m *RpbCoverageReq) GetUnavailableCover() [][]byte
- func (*RpbCoverageReq) ProtoMessage()
- func (m *RpbCoverageReq) Reset()
- func (m *RpbCoverageReq) String() string
- type RpbCoverageResp
- type RpbDelReq
- func (m *RpbDelReq) BucketIsRequired() bool
- func (*RpbDelReq) Descriptor() ([]byte, []int)
- 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 (*RpbGetBucketKeyPreflistReq) Descriptor() ([]byte, []int)
- 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 (*RpbGetReq) Descriptor() ([]byte, []int)
- 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 RpbIndexBodyResp
- func (*RpbIndexBodyResp) Descriptor() ([]byte, []int)
- func (m *RpbIndexBodyResp) GetContinuation() []byte
- func (m *RpbIndexBodyResp) GetDone() bool
- func (m *RpbIndexBodyResp) GetObjects() []*RpbIndexObject
- func (*RpbIndexBodyResp) ProtoMessage()
- func (m *RpbIndexBodyResp) Reset()
- func (m *RpbIndexBodyResp) String() string
- type RpbIndexObject
- type RpbIndexReq
- func (m *RpbIndexReq) BucketIsRequired() bool
- func (*RpbIndexReq) Descriptor() ([]byte, []int)
- func (m *RpbIndexReq) GetBucket() []byte
- func (m *RpbIndexReq) GetContinuation() []byte
- func (m *RpbIndexReq) GetCoverContext() []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) GetReturnBody() bool
- 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
- func (*RpbIndexResp) Descriptor() ([]byte, []int)
- func (m *RpbIndexResp) GetContinuation() []byte
- func (m *RpbIndexResp) GetDone() bool
- func (m *RpbIndexResp) GetKeys() [][]byte
- func (m *RpbIndexResp) GetResults() []*riak.RpbPair
- func (*RpbIndexResp) ProtoMessage()
- func (m *RpbIndexResp) Reset()
- func (m *RpbIndexResp) String() string
- type RpbLink
- type RpbListBucketsReq
- func (m *RpbListBucketsReq) BucketIsRequired() bool
- func (*RpbListBucketsReq) Descriptor() ([]byte, []int)
- 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 (*RpbListKeysReq) Descriptor() ([]byte, []int)
- 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 (*RpbPutReq) Descriptor() ([]byte, []int)
- 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) Descriptor ¶ added in v1.7.0
func (*RpbBucketKeyPreflistItem) Descriptor() ([]byte, []int)
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"` // parallel extraction extension CoverContext []byte `protobuf:"bytes,10,opt,name=cover_context" json:"cover_context,omitempty"` XXX_unrecognized []byte `json:"-"` }
added solely for riak_cs currently for folding over a bucket and returning objects.
func (*RpbCSBucketReq) Descriptor ¶ added in v1.7.0
func (*RpbCSBucketReq) Descriptor() ([]byte, []int)
func (*RpbCSBucketReq) GetBucket ¶
func (m *RpbCSBucketReq) GetBucket() []byte
func (*RpbCSBucketReq) GetContinuation ¶
func (m *RpbCSBucketReq) GetContinuation() []byte
func (*RpbCSBucketReq) GetCoverContext ¶ added in v1.7.0
func (m *RpbCSBucketReq) GetCoverContext() []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) Descriptor ¶ added in v1.7.0
func (*RpbCSBucketResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbContent) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbCounterGetReq) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbCounterGetResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbCounterUpdateReq) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbCounterUpdateResp) Descriptor() ([]byte, []int)
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 RpbCoverageEntry ¶ added in v1.7.0
type RpbCoverageEntry struct { Ip []byte `protobuf:"bytes,1,req,name=ip" json:"ip,omitempty"` Port *uint32 `protobuf:"varint,2,req,name=port" json:"port,omitempty"` KeyspaceDesc []byte `protobuf:"bytes,3,opt,name=keyspace_desc" json:"keyspace_desc,omitempty"` CoverContext []byte `protobuf:"bytes,4,req,name=cover_context" json:"cover_context,omitempty"` XXX_unrecognized []byte `json:"-"` }
Segment of a coverage plan
func (*RpbCoverageEntry) Descriptor ¶ added in v1.7.0
func (*RpbCoverageEntry) Descriptor() ([]byte, []int)
func (*RpbCoverageEntry) GetCoverContext ¶ added in v1.7.0
func (m *RpbCoverageEntry) GetCoverContext() []byte
func (*RpbCoverageEntry) GetIp ¶ added in v1.7.0
func (m *RpbCoverageEntry) GetIp() []byte
func (*RpbCoverageEntry) GetKeyspaceDesc ¶ added in v1.7.0
func (m *RpbCoverageEntry) GetKeyspaceDesc() []byte
func (*RpbCoverageEntry) GetPort ¶ added in v1.7.0
func (m *RpbCoverageEntry) GetPort() uint32
func (*RpbCoverageEntry) ProtoMessage ¶ added in v1.7.0
func (*RpbCoverageEntry) ProtoMessage()
func (*RpbCoverageEntry) Reset ¶ added in v1.7.0
func (m *RpbCoverageEntry) Reset()
func (*RpbCoverageEntry) String ¶ added in v1.7.0
func (m *RpbCoverageEntry) String() string
type RpbCoverageReq ¶ added in v1.7.0
type RpbCoverageReq struct { Type []byte `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"` Bucket []byte `protobuf:"bytes,2,req,name=bucket" json:"bucket,omitempty"` MinPartitions *uint32 `protobuf:"varint,3,opt,name=min_partitions" json:"min_partitions,omitempty"` ReplaceCover []byte `protobuf:"bytes,4,opt,name=replace_cover" json:"replace_cover,omitempty"` XXX_unrecognized []byte `json:"-"` }
Request a segmented coverage plan for the specified bucket
func (*RpbCoverageReq) Descriptor ¶ added in v1.7.0
func (*RpbCoverageReq) Descriptor() ([]byte, []int)
func (*RpbCoverageReq) GetBucket ¶ added in v1.7.0
func (m *RpbCoverageReq) GetBucket() []byte
func (*RpbCoverageReq) GetMinPartitions ¶ added in v1.7.0
func (m *RpbCoverageReq) GetMinPartitions() uint32
func (*RpbCoverageReq) GetReplaceCover ¶ added in v1.7.0
func (m *RpbCoverageReq) GetReplaceCover() []byte
func (*RpbCoverageReq) GetType ¶ added in v1.7.0
func (m *RpbCoverageReq) GetType() []byte
func (*RpbCoverageReq) GetUnavailableCover ¶ added in v1.7.0
func (m *RpbCoverageReq) GetUnavailableCover() [][]byte
func (*RpbCoverageReq) ProtoMessage ¶ added in v1.7.0
func (*RpbCoverageReq) ProtoMessage()
func (*RpbCoverageReq) Reset ¶ added in v1.7.0
func (m *RpbCoverageReq) Reset()
func (*RpbCoverageReq) String ¶ added in v1.7.0
func (m *RpbCoverageReq) String() string
type RpbCoverageResp ¶ added in v1.7.0
type RpbCoverageResp struct { Entries []*RpbCoverageEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"` XXX_unrecognized []byte `json:"-"` }
Segmented coverage plan response
func (*RpbCoverageResp) Descriptor ¶ added in v1.7.0
func (*RpbCoverageResp) Descriptor() ([]byte, []int)
func (*RpbCoverageResp) GetEntries ¶ added in v1.7.0
func (m *RpbCoverageResp) GetEntries() []*RpbCoverageEntry
func (*RpbCoverageResp) ProtoMessage ¶ added in v1.7.0
func (*RpbCoverageResp) ProtoMessage()
func (*RpbCoverageResp) Reset ¶ added in v1.7.0
func (m *RpbCoverageResp) Reset()
func (*RpbCoverageResp) String ¶ added in v1.7.0
func (m *RpbCoverageResp) 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) Descriptor ¶ added in v1.7.0
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) Descriptor ¶ added in v1.7.0
func (*RpbGetBucketKeyPreflistReq) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbGetBucketKeyPreflistResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbGetClientIdResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
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) Descriptor ¶ added in v1.7.0
func (*RpbGetResp) Descriptor() ([]byte, []int)
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 RpbIndexBodyResp ¶ added in v1.7.0
type RpbIndexBodyResp 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:"-"` }
Stolen from CS bucket response, to be used when return_body=true
func (*RpbIndexBodyResp) Descriptor ¶ added in v1.7.0
func (*RpbIndexBodyResp) Descriptor() ([]byte, []int)
func (*RpbIndexBodyResp) GetContinuation ¶ added in v1.7.0
func (m *RpbIndexBodyResp) GetContinuation() []byte
func (*RpbIndexBodyResp) GetDone ¶ added in v1.7.0
func (m *RpbIndexBodyResp) GetDone() bool
func (*RpbIndexBodyResp) GetObjects ¶ added in v1.7.0
func (m *RpbIndexBodyResp) GetObjects() []*RpbIndexObject
func (*RpbIndexBodyResp) ProtoMessage ¶ added in v1.7.0
func (*RpbIndexBodyResp) ProtoMessage()
func (*RpbIndexBodyResp) Reset ¶ added in v1.7.0
func (m *RpbIndexBodyResp) Reset()
func (*RpbIndexBodyResp) String ¶ added in v1.7.0
func (m *RpbIndexBodyResp) 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) Descriptor ¶ added in v1.7.0
func (*RpbIndexObject) Descriptor() ([]byte, []int)
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"` // parallel extraction extension CoverContext []byte `protobuf:"bytes,15,opt,name=cover_context" json:"cover_context,omitempty"` ReturnBody *bool `protobuf:"varint,16,opt,name=return_body" json:"return_body,omitempty"` XXX_unrecognized []byte `json:"-"` }
Secondary Index query request
func (*RpbIndexReq) BucketIsRequired ¶
func (m *RpbIndexReq) BucketIsRequired() bool
func (*RpbIndexReq) Descriptor ¶ added in v1.7.0
func (*RpbIndexReq) Descriptor() ([]byte, []int)
func (*RpbIndexReq) GetBucket ¶
func (m *RpbIndexReq) GetBucket() []byte
func (*RpbIndexReq) GetContinuation ¶
func (m *RpbIndexReq) GetContinuation() []byte
func (*RpbIndexReq) GetCoverContext ¶ added in v1.7.0
func (m *RpbIndexReq) GetCoverContext() []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) GetReturnBody ¶ added in v1.7.0
func (m *RpbIndexReq) GetReturnBody() bool
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) EnumDescriptor ¶ added in v1.7.0
func (RpbIndexReq_IndexQueryType) EnumDescriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbIndexResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
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) Descriptor ¶ added in v1.7.0
func (*RpbListBucketsReq) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbListBucketsResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbListKeysReq) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbListKeysResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbMapRedReq) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbMapRedResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
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) Descriptor ¶ added in v1.7.0
func (*RpbPutResp) Descriptor() ([]byte, []int)
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) Descriptor ¶ added in v1.7.0
func (*RpbSetClientIdReq) Descriptor() ([]byte, []int)
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