Documentation ¶
Index ¶
- Constants
- Variables
- type RpbBucketProps
- func (m *RpbBucketProps) GetAllowMult() bool
- func (m *RpbBucketProps) GetBackend() []byte
- func (m *RpbBucketProps) GetBasicQuorum() bool
- func (m *RpbBucketProps) GetBigVclock() uint32
- func (m *RpbBucketProps) GetChashKeyfun() *RpbModFun
- func (m *RpbBucketProps) GetDw() uint32
- func (m *RpbBucketProps) GetHasPostcommit() bool
- func (m *RpbBucketProps) GetHasPrecommit() bool
- func (m *RpbBucketProps) GetLastWriteWins() bool
- func (m *RpbBucketProps) GetLinkfun() *RpbModFun
- func (m *RpbBucketProps) GetNVal() uint32
- func (m *RpbBucketProps) GetNotfoundOk() bool
- func (m *RpbBucketProps) GetOldVclock() uint32
- func (m *RpbBucketProps) GetPostcommit() []*RpbCommitHook
- func (m *RpbBucketProps) GetPr() uint32
- func (m *RpbBucketProps) GetPrecommit() []*RpbCommitHook
- func (m *RpbBucketProps) GetPw() uint32
- func (m *RpbBucketProps) GetR() uint32
- func (m *RpbBucketProps) GetRepl() RpbBucketProps_RpbReplMode
- func (m *RpbBucketProps) GetRw() uint32
- func (m *RpbBucketProps) GetSearch() bool
- func (m *RpbBucketProps) GetSmallVclock() uint32
- func (m *RpbBucketProps) GetW() uint32
- func (m *RpbBucketProps) GetYoungVclock() uint32
- func (*RpbBucketProps) ProtoMessage()
- func (m *RpbBucketProps) Reset()
- func (m *RpbBucketProps) String() string
- type RpbBucketProps_RpbReplMode
- 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 (*RpbCSBucketReq) ProtoMessage()
- func (m *RpbCSBucketReq) Reset()
- func (m *RpbCSBucketReq) String() string
- type RpbCSBucketResp
- type RpbCommitHook
- 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() []*RpbPair
- func (m *RpbContent) GetLastMod() uint32
- func (m *RpbContent) GetLastModUsecs() uint32
- func (m *RpbContent) GetLinks() []*RpbLink
- func (m *RpbContent) GetUsermeta() []*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) 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) GetW() uint32
- func (*RpbCounterUpdateReq) ProtoMessage()
- func (m *RpbCounterUpdateReq) Reset()
- func (m *RpbCounterUpdateReq) String() string
- type RpbCounterUpdateResp
- type RpbDelReq
- 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) GetVclock() []byte
- func (m *RpbDelReq) GetW() uint32
- func (*RpbDelReq) ProtoMessage()
- func (m *RpbDelReq) Reset()
- func (m *RpbDelReq) String() string
- type RpbErrorResp
- type RpbGetBucketReq
- type RpbGetBucketResp
- type RpbGetClientIdResp
- type RpbGetReq
- 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 (*RpbGetReq) ProtoMessage()
- func (m *RpbGetReq) Reset()
- func (m *RpbGetReq) String() string
- type RpbGetResp
- type RpbGetServerInfoResp
- type RpbIndexObject
- type RpbIndexReq
- 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) GetQtype() RpbIndexReq_IndexQueryType
- func (m *RpbIndexReq) GetRangeMax() []byte
- func (m *RpbIndexReq) GetRangeMin() []byte
- func (m *RpbIndexReq) GetReturnTerms() bool
- func (m *RpbIndexReq) GetStream() bool
- func (*RpbIndexReq) ProtoMessage()
- func (m *RpbIndexReq) Reset()
- func (m *RpbIndexReq) String() string
- type RpbIndexReq_IndexQueryType
- type RpbIndexResp
- type RpbLink
- type RpbListBucketsReq
- type RpbListBucketsResp
- type RpbListKeysReq
- type RpbListKeysResp
- type RpbMapRedReq
- type RpbMapRedResp
- type RpbModFun
- type RpbPair
- type RpbPutReq
- 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) GetVclock() []byte
- func (m *RpbPutReq) GetW() uint32
- func (*RpbPutReq) ProtoMessage()
- func (m *RpbPutReq) Reset()
- func (m *RpbPutReq) String() string
- type RpbPutResp
- type RpbResetBucketReq
- type RpbSearchDoc
- type RpbSearchQueryReq
- func (m *RpbSearchQueryReq) GetDf() []byte
- func (m *RpbSearchQueryReq) GetFilter() []byte
- func (m *RpbSearchQueryReq) GetFl() [][]byte
- func (m *RpbSearchQueryReq) GetIndex() []byte
- func (m *RpbSearchQueryReq) GetOp() []byte
- func (m *RpbSearchQueryReq) GetPresort() []byte
- func (m *RpbSearchQueryReq) GetQ() []byte
- func (m *RpbSearchQueryReq) GetRows() uint32
- func (m *RpbSearchQueryReq) GetSort() []byte
- func (m *RpbSearchQueryReq) GetStart() uint32
- func (*RpbSearchQueryReq) ProtoMessage()
- func (m *RpbSearchQueryReq) Reset()
- func (m *RpbSearchQueryReq) String() string
- type RpbSearchQueryResp
- type RpbSetBucketReq
- type RpbSetClientIdReq
Constants ¶
const Default_RpbBucketProps_HasPostcommit bool = false
const Default_RpbBucketProps_HasPrecommit bool = false
const Default_RpbCSBucketReq_EndIncl bool = false
const Default_RpbCSBucketReq_StartIncl bool = true
Variables ¶
var RpbBucketProps_RpbReplMode_name = map[int32]string{
0: "FALSE",
1: "REALTIME",
2: "FULLSYNC",
3: "TRUE",
}
var RpbBucketProps_RpbReplMode_value = map[string]int32{
"FALSE": 0,
"REALTIME": 1,
"FULLSYNC": 2,
"TRUE": 3,
}
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 RpbBucketProps ¶
type RpbBucketProps struct { // Declared in riak_core_app NVal *uint32 `protobuf:"varint,1,opt,name=n_val" json:"n_val,omitempty"` AllowMult *bool `protobuf:"varint,2,opt,name=allow_mult" json:"allow_mult,omitempty"` LastWriteWins *bool `protobuf:"varint,3,opt,name=last_write_wins" json:"last_write_wins,omitempty"` Precommit []*RpbCommitHook `protobuf:"bytes,4,rep,name=precommit" json:"precommit,omitempty"` HasPrecommit *bool `protobuf:"varint,5,opt,name=has_precommit,def=0" json:"has_precommit,omitempty"` Postcommit []*RpbCommitHook `protobuf:"bytes,6,rep,name=postcommit" json:"postcommit,omitempty"` HasPostcommit *bool `protobuf:"varint,7,opt,name=has_postcommit,def=0" json:"has_postcommit,omitempty"` ChashKeyfun *RpbModFun `protobuf:"bytes,8,opt,name=chash_keyfun" json:"chash_keyfun,omitempty"` // Declared in riak_kv_app Linkfun *RpbModFun `protobuf:"bytes,9,opt,name=linkfun" json:"linkfun,omitempty"` OldVclock *uint32 `protobuf:"varint,10,opt,name=old_vclock" json:"old_vclock,omitempty"` YoungVclock *uint32 `protobuf:"varint,11,opt,name=young_vclock" json:"young_vclock,omitempty"` BigVclock *uint32 `protobuf:"varint,12,opt,name=big_vclock" json:"big_vclock,omitempty"` SmallVclock *uint32 `protobuf:"varint,13,opt,name=small_vclock" json:"small_vclock,omitempty"` Pr *uint32 `protobuf:"varint,14,opt,name=pr" json:"pr,omitempty"` R *uint32 `protobuf:"varint,15,opt,name=r" json:"r,omitempty"` W *uint32 `protobuf:"varint,16,opt,name=w" json:"w,omitempty"` Pw *uint32 `protobuf:"varint,17,opt,name=pw" json:"pw,omitempty"` Dw *uint32 `protobuf:"varint,18,opt,name=dw" json:"dw,omitempty"` Rw *uint32 `protobuf:"varint,19,opt,name=rw" json:"rw,omitempty"` BasicQuorum *bool `protobuf:"varint,20,opt,name=basic_quorum" json:"basic_quorum,omitempty"` NotfoundOk *bool `protobuf:"varint,21,opt,name=notfound_ok" json:"notfound_ok,omitempty"` // Used by riak_kv_multi_backend Backend []byte `protobuf:"bytes,22,opt,name=backend" json:"backend,omitempty"` // Used by riak_search bucket fixup Search *bool `protobuf:"varint,23,opt,name=search" json:"search,omitempty"` Repl *RpbBucketProps_RpbReplMode `protobuf:"varint,24,opt,name=repl,enum=RpbBucketProps_RpbReplMode" json:"repl,omitempty"` XXX_unrecognized []byte `json:"-"` }
Bucket properties
func (*RpbBucketProps) GetAllowMult ¶
func (m *RpbBucketProps) GetAllowMult() bool
func (*RpbBucketProps) GetBackend ¶
func (m *RpbBucketProps) GetBackend() []byte
func (*RpbBucketProps) GetBasicQuorum ¶
func (m *RpbBucketProps) GetBasicQuorum() bool
func (*RpbBucketProps) GetBigVclock ¶
func (m *RpbBucketProps) GetBigVclock() uint32
func (*RpbBucketProps) GetChashKeyfun ¶
func (m *RpbBucketProps) GetChashKeyfun() *RpbModFun
func (*RpbBucketProps) GetDw ¶
func (m *RpbBucketProps) GetDw() uint32
func (*RpbBucketProps) GetHasPostcommit ¶
func (m *RpbBucketProps) GetHasPostcommit() bool
func (*RpbBucketProps) GetHasPrecommit ¶
func (m *RpbBucketProps) GetHasPrecommit() bool
func (*RpbBucketProps) GetLastWriteWins ¶
func (m *RpbBucketProps) GetLastWriteWins() bool
func (*RpbBucketProps) GetLinkfun ¶
func (m *RpbBucketProps) GetLinkfun() *RpbModFun
func (*RpbBucketProps) GetNVal ¶
func (m *RpbBucketProps) GetNVal() uint32
func (*RpbBucketProps) GetNotfoundOk ¶
func (m *RpbBucketProps) GetNotfoundOk() bool
func (*RpbBucketProps) GetOldVclock ¶
func (m *RpbBucketProps) GetOldVclock() uint32
func (*RpbBucketProps) GetPostcommit ¶
func (m *RpbBucketProps) GetPostcommit() []*RpbCommitHook
func (*RpbBucketProps) GetPr ¶
func (m *RpbBucketProps) GetPr() uint32
func (*RpbBucketProps) GetPrecommit ¶
func (m *RpbBucketProps) GetPrecommit() []*RpbCommitHook
func (*RpbBucketProps) GetPw ¶
func (m *RpbBucketProps) GetPw() uint32
func (*RpbBucketProps) GetR ¶
func (m *RpbBucketProps) GetR() uint32
func (*RpbBucketProps) GetRepl ¶
func (m *RpbBucketProps) GetRepl() RpbBucketProps_RpbReplMode
func (*RpbBucketProps) GetRw ¶
func (m *RpbBucketProps) GetRw() uint32
func (*RpbBucketProps) GetSearch ¶
func (m *RpbBucketProps) GetSearch() bool
func (*RpbBucketProps) GetSmallVclock ¶
func (m *RpbBucketProps) GetSmallVclock() uint32
func (*RpbBucketProps) GetW ¶
func (m *RpbBucketProps) GetW() uint32
func (*RpbBucketProps) GetYoungVclock ¶
func (m *RpbBucketProps) GetYoungVclock() uint32
func (*RpbBucketProps) ProtoMessage ¶
func (*RpbBucketProps) ProtoMessage()
func (*RpbBucketProps) Reset ¶
func (m *RpbBucketProps) Reset()
func (*RpbBucketProps) String ¶
func (m *RpbBucketProps) String() string
type RpbBucketProps_RpbReplMode ¶
type RpbBucketProps_RpbReplMode int32
Used by riak_repl bucket fixup
const ( RpbBucketProps_FALSE RpbBucketProps_RpbReplMode = 0 RpbBucketProps_REALTIME RpbBucketProps_RpbReplMode = 1 RpbBucketProps_FULLSYNC RpbBucketProps_RpbReplMode = 2 RpbBucketProps_TRUE RpbBucketProps_RpbReplMode = 3 )
func (RpbBucketProps_RpbReplMode) Enum ¶
func (x RpbBucketProps_RpbReplMode) Enum() *RpbBucketProps_RpbReplMode
func (RpbBucketProps_RpbReplMode) String ¶
func (x RpbBucketProps_RpbReplMode) String() string
func (*RpbBucketProps_RpbReplMode) UnmarshalJSON ¶
func (x *RpbBucketProps_RpbReplMode) UnmarshalJSON(data []byte) error
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"` 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) 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 RpbCommitHook ¶
type RpbCommitHook struct { Modfun *RpbModFun `protobuf:"bytes,1,opt,name=modfun" json:"modfun,omitempty"` Name []byte `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"` XXX_unrecognized []byte `json:"-"` }
A commit hook, which may either be a modfun or a JavaScript named function
func (*RpbCommitHook) GetModfun ¶
func (m *RpbCommitHook) GetModfun() *RpbModFun
func (*RpbCommitHook) GetName ¶
func (m *RpbCommitHook) GetName() []byte
func (*RpbCommitHook) ProtoMessage ¶
func (*RpbCommitHook) ProtoMessage()
func (*RpbCommitHook) Reset ¶
func (m *RpbCommitHook) Reset()
func (*RpbCommitHook) String ¶
func (m *RpbCommitHook) 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 []*RpbPair `protobuf:"bytes,9,rep,name=usermeta" json:"usermeta,omitempty"` Indexes []*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() []*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() []*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) 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) GetW ¶
func (m *RpbCounterUpdateReq) GetW() uint32
func (*RpbCounterUpdateReq) ProtoMessage ¶
func (*RpbCounterUpdateReq) ProtoMessage()
func (*RpbCounterUpdateReq) Reset ¶
func (m *RpbCounterUpdateReq) Reset()
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"` XXX_unrecognized []byte `json:"-"` }
Delete request
func (*RpbDelReq) GetSloppyQuorum ¶
func (*RpbDelReq) GetTimeout ¶
func (*RpbDelReq) ProtoMessage ¶
func (*RpbDelReq) ProtoMessage()
type RpbErrorResp ¶
type RpbErrorResp struct { Errmsg []byte `protobuf:"bytes,1,req,name=errmsg" json:"errmsg,omitempty"` Errcode *uint32 `protobuf:"varint,2,req,name=errcode" json:"errcode,omitempty"` XXX_unrecognized []byte `json:"-"` }
Error response - may be generated for any Req
func (*RpbErrorResp) GetErrcode ¶
func (m *RpbErrorResp) GetErrcode() uint32
func (*RpbErrorResp) GetErrmsg ¶
func (m *RpbErrorResp) GetErrmsg() []byte
func (*RpbErrorResp) ProtoMessage ¶
func (*RpbErrorResp) ProtoMessage()
func (*RpbErrorResp) Reset ¶
func (m *RpbErrorResp) Reset()
func (*RpbErrorResp) String ¶
func (m *RpbErrorResp) String() string
type RpbGetBucketReq ¶
type RpbGetBucketReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get bucket properties request
func (*RpbGetBucketReq) GetBucket ¶
func (m *RpbGetBucketReq) GetBucket() []byte
func (*RpbGetBucketReq) ProtoMessage ¶
func (*RpbGetBucketReq) ProtoMessage()
func (*RpbGetBucketReq) Reset ¶
func (m *RpbGetBucketReq) Reset()
func (*RpbGetBucketReq) String ¶
func (m *RpbGetBucketReq) String() string
type RpbGetBucketResp ¶
type RpbGetBucketResp struct { Props *RpbBucketProps `protobuf:"bytes,1,req,name=props" json:"props,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get bucket properties response
func (*RpbGetBucketResp) GetProps ¶
func (m *RpbGetBucketResp) GetProps() *RpbBucketProps
func (*RpbGetBucketResp) ProtoMessage ¶
func (*RpbGetBucketResp) ProtoMessage()
func (*RpbGetBucketResp) Reset ¶
func (m *RpbGetBucketResp) Reset()
func (*RpbGetBucketResp) String ¶
func (m *RpbGetBucketResp) 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"` XXX_unrecognized []byte `json:"-"` }
Get Request - retrieve bucket/key
func (*RpbGetReq) GetBasicQuorum ¶
func (*RpbGetReq) GetDeletedvclock ¶
func (*RpbGetReq) GetIfModified ¶
func (*RpbGetReq) GetNotfoundOk ¶
func (*RpbGetReq) GetSloppyQuorum ¶
func (*RpbGetReq) GetTimeout ¶
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 RpbGetServerInfoResp ¶
type RpbGetServerInfoResp struct { Node []byte `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"` ServerVersion []byte `protobuf:"bytes,2,opt,name=server_version" json:"server_version,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get server info request - no message defined, just send RpbGetServerInfoReq message code
func (*RpbGetServerInfoResp) GetNode ¶
func (m *RpbGetServerInfoResp) GetNode() []byte
func (*RpbGetServerInfoResp) GetServerVersion ¶
func (m *RpbGetServerInfoResp) GetServerVersion() []byte
func (*RpbGetServerInfoResp) ProtoMessage ¶
func (*RpbGetServerInfoResp) ProtoMessage()
func (*RpbGetServerInfoResp) Reset ¶
func (m *RpbGetServerInfoResp) Reset()
func (*RpbGetServerInfoResp) String ¶
func (m *RpbGetServerInfoResp) 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"` XXX_unrecognized []byte `json:"-"` }
Secondary Index query request
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) 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) ProtoMessage ¶
func (*RpbIndexReq) ProtoMessage()
func (*RpbIndexReq) Reset ¶
func (m *RpbIndexReq) Reset()
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 []*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() []*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"` XXX_unrecognized []byte `json:"-"` }
List buckets request
func (*RpbListBucketsReq) GetStream ¶
func (m *RpbListBucketsReq) GetStream() bool
func (*RpbListBucketsReq) GetTimeout ¶
func (m *RpbListBucketsReq) GetTimeout() uint32
func (*RpbListBucketsReq) ProtoMessage ¶
func (*RpbListBucketsReq) ProtoMessage()
func (*RpbListBucketsReq) Reset ¶
func (m *RpbListBucketsReq) Reset()
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"` XXX_unrecognized []byte `json:"-"` }
List keys in bucket request
func (*RpbListKeysReq) GetBucket ¶
func (m *RpbListKeysReq) GetBucket() []byte
func (*RpbListKeysReq) GetTimeout ¶
func (m *RpbListKeysReq) GetTimeout() uint32
func (*RpbListKeysReq) ProtoMessage ¶
func (*RpbListKeysReq) ProtoMessage()
func (*RpbListKeysReq) Reset ¶
func (m *RpbListKeysReq) Reset()
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 RpbModFun ¶
type RpbModFun struct { Module []byte `protobuf:"bytes,1,req,name=module" json:"module,omitempty"` Function []byte `protobuf:"bytes,2,req,name=function" json:"function,omitempty"` XXX_unrecognized []byte `json:"-"` }
Module-Function pairs for commit hooks and other bucket properties that take functions
func (*RpbModFun) GetFunction ¶
func (*RpbModFun) ProtoMessage ¶
func (*RpbModFun) ProtoMessage()
type RpbPair ¶
type RpbPair struct { Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
Key/value pair - used for user metadata, indexes, search doc fields
func (*RpbPair) ProtoMessage ¶
func (*RpbPair) ProtoMessage()
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"` 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) 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) 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 RpbResetBucketReq ¶
type RpbResetBucketReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` XXX_unrecognized []byte `json:"-"` }
Reset bucket properties request
func (*RpbResetBucketReq) GetBucket ¶
func (m *RpbResetBucketReq) GetBucket() []byte
func (*RpbResetBucketReq) ProtoMessage ¶
func (*RpbResetBucketReq) ProtoMessage()
func (*RpbResetBucketReq) Reset ¶
func (m *RpbResetBucketReq) Reset()
func (*RpbResetBucketReq) String ¶
func (m *RpbResetBucketReq) String() string
type RpbSearchDoc ¶
type RpbSearchDoc struct { Fields []*RpbPair `protobuf:"bytes,1,rep,name=fields" json:"fields,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbSearchDoc) GetFields ¶
func (m *RpbSearchDoc) GetFields() []*RpbPair
func (*RpbSearchDoc) ProtoMessage ¶
func (*RpbSearchDoc) ProtoMessage()
func (*RpbSearchDoc) Reset ¶
func (m *RpbSearchDoc) Reset()
func (*RpbSearchDoc) String ¶
func (m *RpbSearchDoc) String() string
type RpbSearchQueryReq ¶
type RpbSearchQueryReq struct { Q []byte `protobuf:"bytes,1,req,name=q" json:"q,omitempty"` Index []byte `protobuf:"bytes,2,req,name=index" json:"index,omitempty"` Rows *uint32 `protobuf:"varint,3,opt,name=rows" json:"rows,omitempty"` Start *uint32 `protobuf:"varint,4,opt,name=start" json:"start,omitempty"` Sort []byte `protobuf:"bytes,5,opt,name=sort" json:"sort,omitempty"` Filter []byte `protobuf:"bytes,6,opt,name=filter" json:"filter,omitempty"` Df []byte `protobuf:"bytes,7,opt,name=df" json:"df,omitempty"` Op []byte `protobuf:"bytes,8,opt,name=op" json:"op,omitempty"` Fl [][]byte `protobuf:"bytes,9,rep,name=fl" json:"fl,omitempty"` Presort []byte `protobuf:"bytes,10,opt,name=presort" json:"presort,omitempty"` XXX_unrecognized []byte `json:"-"` }
These were missing from the 1.4 version of the source riak_kv.proto file, and are here from monkey+c, monkey+v.
func (*RpbSearchQueryReq) GetDf ¶
func (m *RpbSearchQueryReq) GetDf() []byte
func (*RpbSearchQueryReq) GetFilter ¶
func (m *RpbSearchQueryReq) GetFilter() []byte
func (*RpbSearchQueryReq) GetFl ¶
func (m *RpbSearchQueryReq) GetFl() [][]byte
func (*RpbSearchQueryReq) GetIndex ¶
func (m *RpbSearchQueryReq) GetIndex() []byte
func (*RpbSearchQueryReq) GetOp ¶
func (m *RpbSearchQueryReq) GetOp() []byte
func (*RpbSearchQueryReq) GetPresort ¶
func (m *RpbSearchQueryReq) GetPresort() []byte
func (*RpbSearchQueryReq) GetQ ¶
func (m *RpbSearchQueryReq) GetQ() []byte
func (*RpbSearchQueryReq) GetRows ¶
func (m *RpbSearchQueryReq) GetRows() uint32
func (*RpbSearchQueryReq) GetSort ¶
func (m *RpbSearchQueryReq) GetSort() []byte
func (*RpbSearchQueryReq) GetStart ¶
func (m *RpbSearchQueryReq) GetStart() uint32
func (*RpbSearchQueryReq) ProtoMessage ¶
func (*RpbSearchQueryReq) ProtoMessage()
func (*RpbSearchQueryReq) Reset ¶
func (m *RpbSearchQueryReq) Reset()
func (*RpbSearchQueryReq) String ¶
func (m *RpbSearchQueryReq) String() string
type RpbSearchQueryResp ¶
type RpbSearchQueryResp struct { Docs []*RpbSearchDoc `protobuf:"bytes,1,rep,name=docs" json:"docs,omitempty"` MaxScore *float32 `protobuf:"fixed32,2,opt,name=max_score" json:"max_score,omitempty"` NumFound *uint32 `protobuf:"varint,3,opt,name=num_found" json:"num_found,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbSearchQueryResp) GetDocs ¶
func (m *RpbSearchQueryResp) GetDocs() []*RpbSearchDoc
func (*RpbSearchQueryResp) GetMaxScore ¶
func (m *RpbSearchQueryResp) GetMaxScore() float32
func (*RpbSearchQueryResp) GetNumFound ¶
func (m *RpbSearchQueryResp) GetNumFound() uint32
func (*RpbSearchQueryResp) ProtoMessage ¶
func (*RpbSearchQueryResp) ProtoMessage()
func (*RpbSearchQueryResp) Reset ¶
func (m *RpbSearchQueryResp) Reset()
func (*RpbSearchQueryResp) String ¶
func (m *RpbSearchQueryResp) String() string
type RpbSetBucketReq ¶
type RpbSetBucketReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Props *RpbBucketProps `protobuf:"bytes,2,req,name=props" json:"props,omitempty"` XXX_unrecognized []byte `json:"-"` }
Set bucket properties request
func (*RpbSetBucketReq) GetBucket ¶
func (m *RpbSetBucketReq) GetBucket() []byte
func (*RpbSetBucketReq) GetProps ¶
func (m *RpbSetBucketReq) GetProps() *RpbBucketProps
func (*RpbSetBucketReq) ProtoMessage ¶
func (*RpbSetBucketReq) ProtoMessage()
func (*RpbSetBucketReq) Reset ¶
func (m *RpbSetBucketReq) Reset()
func (*RpbSetBucketReq) String ¶
func (m *RpbSetBucketReq) 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