Documentation ¶
Overview ¶
Package riak is a generated protocol buffer package.
It is generated from these files:
riak.proto
It has these top-level messages:
RpbErrorResp RpbGetServerInfoResp RpbPair RpbGetBucketReq RpbGetBucketResp RpbSetBucketReq RpbResetBucketReq RpbGetBucketTypeReq RpbSetBucketTypeReq RpbModFun RpbCommitHook RpbBucketProps RpbAuthReq MapField MapEntry DtFetchReq DtValue DtFetchResp CounterOp SetOp MapUpdate MapOp DtOp DtUpdateReq DtUpdateResp RpbGetClientIdResp RpbSetClientIdReq RpbGetReq RpbGetResp RpbPutReq RpbPutResp RpbDelReq RpbListBucketsReq RpbListBucketsResp RpbListKeysReq RpbListKeysResp RpbMapRedReq RpbMapRedResp RpbIndexReq RpbIndexResp RpbCSBucketReq RpbCSBucketResp RpbIndexObject RpbContent RpbLink RpbCounterUpdateReq RpbCounterUpdateResp RpbCounterGetReq RpbCounterGetResp RpbSearchDoc RpbSearchQueryReq RpbSearchQueryResp RpbYokozunaIndex RpbYokozunaIndexGetReq RpbYokozunaIndexGetResp RpbYokozunaIndexPutReq RpbYokozunaIndexDeleteReq RpbYokozunaSchema RpbYokozunaSchemaPutReq RpbYokozunaSchemaGetReq RpbYokozunaSchemaGetResp
Index ¶
- Constants
- Variables
- type CounterOp
- type DtFetchReq
- func (m *DtFetchReq) GetBasicQuorum() bool
- func (m *DtFetchReq) GetBucket() []byte
- func (m *DtFetchReq) GetIncludeContext() bool
- func (m *DtFetchReq) GetKey() []byte
- func (m *DtFetchReq) GetNVal() uint32
- func (m *DtFetchReq) GetNotfoundOk() bool
- func (m *DtFetchReq) GetPr() uint32
- func (m *DtFetchReq) GetR() uint32
- func (m *DtFetchReq) GetSloppyQuorum() bool
- func (m *DtFetchReq) GetTimeout() uint32
- func (m *DtFetchReq) GetType() []byte
- func (*DtFetchReq) ProtoMessage()
- func (m *DtFetchReq) Reset()
- func (m *DtFetchReq) String() string
- type DtFetchResp
- type DtFetchResp_DataType
- type DtOp
- type DtUpdateReq
- func (m *DtUpdateReq) GetBucket() []byte
- func (m *DtUpdateReq) GetContext() []byte
- func (m *DtUpdateReq) GetDw() uint32
- func (m *DtUpdateReq) GetIncludeContext() bool
- func (m *DtUpdateReq) GetKey() []byte
- func (m *DtUpdateReq) GetNVal() uint32
- func (m *DtUpdateReq) GetOp() *DtOp
- func (m *DtUpdateReq) GetPw() uint32
- func (m *DtUpdateReq) GetReturnBody() bool
- func (m *DtUpdateReq) GetSloppyQuorum() bool
- func (m *DtUpdateReq) GetTimeout() uint32
- func (m *DtUpdateReq) GetType() []byte
- func (m *DtUpdateReq) GetW() uint32
- func (*DtUpdateReq) ProtoMessage()
- func (m *DtUpdateReq) Reset()
- func (m *DtUpdateReq) String() string
- type DtUpdateResp
- func (m *DtUpdateResp) GetContext() []byte
- func (m *DtUpdateResp) GetCounterValue() int64
- func (m *DtUpdateResp) GetKey() []byte
- func (m *DtUpdateResp) GetMapValue() []*MapEntry
- func (m *DtUpdateResp) GetSetValue() [][]byte
- func (*DtUpdateResp) ProtoMessage()
- func (m *DtUpdateResp) Reset()
- func (m *DtUpdateResp) String() string
- type DtValue
- type MapEntry
- func (m *MapEntry) GetCounterValue() int64
- func (m *MapEntry) GetField() *MapField
- func (m *MapEntry) GetFlagValue() bool
- func (m *MapEntry) GetMapValue() []*MapEntry
- func (m *MapEntry) GetRegisterValue() []byte
- func (m *MapEntry) GetSetValue() [][]byte
- func (*MapEntry) ProtoMessage()
- func (m *MapEntry) Reset()
- func (m *MapEntry) String() string
- type MapField
- type MapField_MapFieldType
- type MapOp
- type MapUpdate
- func (m *MapUpdate) GetCounterOp() *CounterOp
- func (m *MapUpdate) GetField() *MapField
- func (m *MapUpdate) GetFlagOp() MapUpdate_FlagOp
- func (m *MapUpdate) GetMapOp() *MapOp
- func (m *MapUpdate) GetRegisterOp() []byte
- func (m *MapUpdate) GetSetOp() *SetOp
- func (*MapUpdate) ProtoMessage()
- func (m *MapUpdate) Reset()
- func (m *MapUpdate) String() string
- type MapUpdate_FlagOp
- type RpbAuthReq
- 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) GetConsistent() bool
- func (m *RpbBucketProps) GetDatatype() []byte
- 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) GetSearchIndex() []byte
- 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 (m *RpbCSBucketReq) GetTimeout() uint32
- func (m *RpbCSBucketReq) GetType() []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) GetType() []byte
- 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 RpbGetBucketTypeReq
- 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 (m *RpbGetReq) GetType() []byte
- 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) GetPaginationSort() bool
- func (m *RpbIndexReq) GetQtype() RpbIndexReq_IndexQueryType
- func (m *RpbIndexReq) GetRangeMax() []byte
- func (m *RpbIndexReq) GetRangeMin() []byte
- func (m *RpbIndexReq) GetReturnTerms() bool
- func (m *RpbIndexReq) GetStream() bool
- func (m *RpbIndexReq) GetTermRegex() []byte
- func (m *RpbIndexReq) GetTimeout() uint32
- func (m *RpbIndexReq) GetType() []byte
- func (*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) GetType() []byte
- 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 RpbSetBucketTypeReq
- type RpbSetClientIdReq
- type RpbYokozunaIndex
- type RpbYokozunaIndexDeleteReq
- type RpbYokozunaIndexGetReq
- type RpbYokozunaIndexGetResp
- type RpbYokozunaIndexPutReq
- type RpbYokozunaSchema
- type RpbYokozunaSchemaGetReq
- type RpbYokozunaSchemaGetResp
- type RpbYokozunaSchemaPutReq
- type SetOp
Constants ¶
const Default_DtFetchReq_IncludeContext bool = true
const Default_DtUpdateReq_IncludeContext bool = true
const Default_DtUpdateReq_ReturnBody bool = false
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 DtFetchResp_DataType_name = map[int32]string{
1: "COUNTER",
2: "SET",
3: "MAP",
}
var DtFetchResp_DataType_value = map[string]int32{
"COUNTER": 1,
"SET": 2,
"MAP": 3,
}
var MapField_MapFieldType_name = map[int32]string{
1: "COUNTER",
2: "SET",
3: "REGISTER",
4: "FLAG",
5: "MAP",
}
var MapField_MapFieldType_value = map[string]int32{
"COUNTER": 1,
"SET": 2,
"REGISTER": 3,
"FLAG": 4,
"MAP": 5,
}
var MapUpdate_FlagOp_name = map[int32]string{
1: "ENABLE",
2: "DISABLE",
}
var MapUpdate_FlagOp_value = map[string]int32{
"ENABLE": 1,
"DISABLE": 2,
}
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 CounterOp ¶
type CounterOp struct { Increment *int64 `protobuf:"zigzag64,1,opt,name=increment" json:"increment,omitempty"` XXX_unrecognized []byte `json:"-"` }
An operation to update a Counter, either on its own or inside a Map. The `increment` field can be positive or negative. When absent, the meaning is an increment by 1.
func (*CounterOp) GetIncrement ¶
func (*CounterOp) ProtoMessage ¶
func (*CounterOp) ProtoMessage()
type DtFetchReq ¶
type DtFetchReq struct { // The identifier: bucket, key and bucket-type 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,req,name=type" json:"type,omitempty"` // Request options R *uint32 `protobuf:"varint,4,opt,name=r" json:"r,omitempty"` Pr *uint32 `protobuf:"varint,5,opt,name=pr" json:"pr,omitempty"` BasicQuorum *bool `protobuf:"varint,6,opt,name=basic_quorum" json:"basic_quorum,omitempty"` NotfoundOk *bool `protobuf:"varint,7,opt,name=notfound_ok" json:"notfound_ok,omitempty"` Timeout *uint32 `protobuf:"varint,8,opt,name=timeout" json:"timeout,omitempty"` SloppyQuorum *bool `protobuf:"varint,9,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"` NVal *uint32 `protobuf:"varint,10,opt,name=n_val" json:"n_val,omitempty"` // For read-only requests or context-free operations, you can set // this to false to reduce the size of the response payload. IncludeContext *bool `protobuf:"varint,11,opt,name=include_context,def=1" json:"include_context,omitempty"` XXX_unrecognized []byte `json:"-"` }
The equivalent of KV's "RpbGetReq", results in a DtFetchResp. The request-time options are limited to ones that are relevant to structured data-types.
func (*DtFetchReq) GetBasicQuorum ¶
func (m *DtFetchReq) GetBasicQuorum() bool
func (*DtFetchReq) GetBucket ¶
func (m *DtFetchReq) GetBucket() []byte
func (*DtFetchReq) GetIncludeContext ¶
func (m *DtFetchReq) GetIncludeContext() bool
func (*DtFetchReq) GetKey ¶
func (m *DtFetchReq) GetKey() []byte
func (*DtFetchReq) GetNVal ¶
func (m *DtFetchReq) GetNVal() uint32
func (*DtFetchReq) GetNotfoundOk ¶
func (m *DtFetchReq) GetNotfoundOk() bool
func (*DtFetchReq) GetPr ¶
func (m *DtFetchReq) GetPr() uint32
func (*DtFetchReq) GetR ¶
func (m *DtFetchReq) GetR() uint32
func (*DtFetchReq) GetSloppyQuorum ¶
func (m *DtFetchReq) GetSloppyQuorum() bool
func (*DtFetchReq) GetTimeout ¶
func (m *DtFetchReq) GetTimeout() uint32
func (*DtFetchReq) GetType ¶
func (m *DtFetchReq) GetType() []byte
func (*DtFetchReq) ProtoMessage ¶
func (*DtFetchReq) ProtoMessage()
func (*DtFetchReq) Reset ¶
func (m *DtFetchReq) Reset()
func (*DtFetchReq) String ¶
func (m *DtFetchReq) String() string
type DtFetchResp ¶
type DtFetchResp struct { Context []byte `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"` Type *DtFetchResp_DataType `protobuf:"varint,2,req,name=type,enum=DtFetchResp_DataType" json:"type,omitempty"` Value *DtValue `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
The response to a "Fetch" request. If the `include_context` option is specified, an opaque "context" value will be returned along with the user-friendly data. When sending an "Update" request, the client should send this context as well, similar to how one would send a vclock for KV updates. The `type` field indicates which value type to expect. When the `value` field is missing from the message, the client should interpret it as a "not found".
func (*DtFetchResp) GetContext ¶
func (m *DtFetchResp) GetContext() []byte
func (*DtFetchResp) GetType ¶
func (m *DtFetchResp) GetType() DtFetchResp_DataType
func (*DtFetchResp) GetValue ¶
func (m *DtFetchResp) GetValue() *DtValue
func (*DtFetchResp) ProtoMessage ¶
func (*DtFetchResp) ProtoMessage()
func (*DtFetchResp) Reset ¶
func (m *DtFetchResp) Reset()
func (*DtFetchResp) String ¶
func (m *DtFetchResp) String() string
type DtFetchResp_DataType ¶
type DtFetchResp_DataType int32
const ( DtFetchResp_COUNTER DtFetchResp_DataType = 1 DtFetchResp_SET DtFetchResp_DataType = 2 DtFetchResp_MAP DtFetchResp_DataType = 3 )
func (DtFetchResp_DataType) Enum ¶
func (x DtFetchResp_DataType) Enum() *DtFetchResp_DataType
func (DtFetchResp_DataType) String ¶
func (x DtFetchResp_DataType) String() string
func (*DtFetchResp_DataType) UnmarshalJSON ¶
func (x *DtFetchResp_DataType) UnmarshalJSON(data []byte) error
type DtOp ¶
type DtOp struct { CounterOp *CounterOp `protobuf:"bytes,1,opt,name=counter_op" json:"counter_op,omitempty"` SetOp *SetOp `protobuf:"bytes,2,opt,name=set_op" json:"set_op,omitempty"` MapOp *MapOp `protobuf:"bytes,3,opt,name=map_op" json:"map_op,omitempty"` XXX_unrecognized []byte `json:"-"` }
A "union" type for update operations. The included operation depends on the datatype being updated.
func (*DtOp) GetCounterOp ¶
func (*DtOp) ProtoMessage ¶
func (*DtOp) ProtoMessage()
type DtUpdateReq ¶
type DtUpdateReq struct { // The identifier Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` Type []byte `protobuf:"bytes,3,req,name=type" json:"type,omitempty"` // Opaque update-context Context []byte `protobuf:"bytes,4,opt,name=context" json:"context,omitempty"` // The operations Op *DtOp `protobuf:"bytes,5,req,name=op" json:"op,omitempty"` // Request options W *uint32 `protobuf:"varint,6,opt,name=w" json:"w,omitempty"` Dw *uint32 `protobuf:"varint,7,opt,name=dw" json:"dw,omitempty"` Pw *uint32 `protobuf:"varint,8,opt,name=pw" json:"pw,omitempty"` ReturnBody *bool `protobuf:"varint,9,opt,name=return_body,def=0" json:"return_body,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"` IncludeContext *bool `protobuf:"varint,13,opt,name=include_context,def=1" json:"include_context,omitempty"` XXX_unrecognized []byte `json:"-"` }
The equivalent of KV's "RpbPutReq", results in an empty response or "DtUpdateResp" if `return_body` is specified, or the key is assigned by the server. The request-time options are limited to ones that are relevant to structured data-types.
func (*DtUpdateReq) GetBucket ¶
func (m *DtUpdateReq) GetBucket() []byte
func (*DtUpdateReq) GetContext ¶
func (m *DtUpdateReq) GetContext() []byte
func (*DtUpdateReq) GetDw ¶
func (m *DtUpdateReq) GetDw() uint32
func (*DtUpdateReq) GetIncludeContext ¶
func (m *DtUpdateReq) GetIncludeContext() bool
func (*DtUpdateReq) GetKey ¶
func (m *DtUpdateReq) GetKey() []byte
func (*DtUpdateReq) GetNVal ¶
func (m *DtUpdateReq) GetNVal() uint32
func (*DtUpdateReq) GetOp ¶
func (m *DtUpdateReq) GetOp() *DtOp
func (*DtUpdateReq) GetPw ¶
func (m *DtUpdateReq) GetPw() uint32
func (*DtUpdateReq) GetReturnBody ¶
func (m *DtUpdateReq) GetReturnBody() bool
func (*DtUpdateReq) GetSloppyQuorum ¶
func (m *DtUpdateReq) GetSloppyQuorum() bool
func (*DtUpdateReq) GetTimeout ¶
func (m *DtUpdateReq) GetTimeout() uint32
func (*DtUpdateReq) GetType ¶
func (m *DtUpdateReq) GetType() []byte
func (*DtUpdateReq) GetW ¶
func (m *DtUpdateReq) GetW() uint32
func (*DtUpdateReq) ProtoMessage ¶
func (*DtUpdateReq) ProtoMessage()
func (*DtUpdateReq) Reset ¶
func (m *DtUpdateReq) Reset()
func (*DtUpdateReq) String ¶
func (m *DtUpdateReq) String() string
type DtUpdateResp ¶
type DtUpdateResp struct { // The key, if assigned by the server Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` // The opaque update context and value, if return_body was set. Context []byte `protobuf:"bytes,2,opt,name=context" json:"context,omitempty"` CounterValue *int64 `protobuf:"zigzag64,3,opt,name=counter_value" json:"counter_value,omitempty"` SetValue [][]byte `protobuf:"bytes,4,rep,name=set_value" json:"set_value,omitempty"` MapValue []*MapEntry `protobuf:"bytes,5,rep,name=map_value" json:"map_value,omitempty"` XXX_unrecognized []byte `json:"-"` }
The equivalent of KV's "RpbPutResp", contains the assigned key if it was assigned by the server, and the resulting value and context if return_body was set.
func (*DtUpdateResp) GetContext ¶
func (m *DtUpdateResp) GetContext() []byte
func (*DtUpdateResp) GetCounterValue ¶
func (m *DtUpdateResp) GetCounterValue() int64
func (*DtUpdateResp) GetKey ¶
func (m *DtUpdateResp) GetKey() []byte
func (*DtUpdateResp) GetMapValue ¶
func (m *DtUpdateResp) GetMapValue() []*MapEntry
func (*DtUpdateResp) GetSetValue ¶
func (m *DtUpdateResp) GetSetValue() [][]byte
func (*DtUpdateResp) ProtoMessage ¶
func (*DtUpdateResp) ProtoMessage()
func (*DtUpdateResp) Reset ¶
func (m *DtUpdateResp) Reset()
func (*DtUpdateResp) String ¶
func (m *DtUpdateResp) String() string
type DtValue ¶
type DtValue struct { CounterValue *int64 `protobuf:"zigzag64,1,opt,name=counter_value" json:"counter_value,omitempty"` SetValue [][]byte `protobuf:"bytes,2,rep,name=set_value" json:"set_value,omitempty"` MapValue []*MapEntry `protobuf:"bytes,3,rep,name=map_value" json:"map_value,omitempty"` XXX_unrecognized []byte `json:"-"` }
The value of the fetched data type. If present in the response, then empty values (sets, maps) should be treated as such.
func (*DtValue) GetCounterValue ¶
func (*DtValue) GetMapValue ¶
func (*DtValue) GetSetValue ¶
func (*DtValue) ProtoMessage ¶
func (*DtValue) ProtoMessage()
type MapEntry ¶
type MapEntry struct { Field *MapField `protobuf:"bytes,1,req,name=field" json:"field,omitempty"` CounterValue *int64 `protobuf:"zigzag64,2,opt,name=counter_value" json:"counter_value,omitempty"` SetValue [][]byte `protobuf:"bytes,3,rep,name=set_value" json:"set_value,omitempty"` RegisterValue []byte `protobuf:"bytes,4,opt,name=register_value" json:"register_value,omitempty"` FlagValue *bool `protobuf:"varint,5,opt,name=flag_value" json:"flag_value,omitempty"` MapValue []*MapEntry `protobuf:"bytes,6,rep,name=map_value" json:"map_value,omitempty"` XXX_unrecognized []byte `json:"-"` }
An entry in a map is a pair of a field-name and value. The type defined in the field determines which value type is expected.
func (*MapEntry) GetCounterValue ¶
func (*MapEntry) GetFlagValue ¶
func (*MapEntry) GetMapValue ¶
func (*MapEntry) GetRegisterValue ¶
func (*MapEntry) GetSetValue ¶
func (*MapEntry) ProtoMessage ¶
func (*MapEntry) ProtoMessage()
type MapField ¶
type MapField struct { Name []byte `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Type *MapField_MapFieldType `protobuf:"varint,2,req,name=type,enum=MapField_MapFieldType" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Field names in maps are composed of a binary identifier and a type. This is so that two clients can create fields with the same name but different types, and they converge independently.
func (*MapField) GetType ¶
func (m *MapField) GetType() MapField_MapFieldType
func (*MapField) ProtoMessage ¶
func (*MapField) ProtoMessage()
type MapField_MapFieldType ¶
type MapField_MapFieldType int32
The types that can be stored in a map are limited to counters, sets, registers, flags, and maps.
const ( MapField_COUNTER MapField_MapFieldType = 1 MapField_SET MapField_MapFieldType = 2 MapField_REGISTER MapField_MapFieldType = 3 MapField_FLAG MapField_MapFieldType = 4 MapField_MAP MapField_MapFieldType = 5 )
func (MapField_MapFieldType) Enum ¶
func (x MapField_MapFieldType) Enum() *MapField_MapFieldType
func (MapField_MapFieldType) String ¶
func (x MapField_MapFieldType) String() string
func (*MapField_MapFieldType) UnmarshalJSON ¶
func (x *MapField_MapFieldType) UnmarshalJSON(data []byte) error
type MapOp ¶
type MapOp struct { // // REMOVE removes a field and value from the Map. // UPDATE applies type-specific // operations to the values stored in the Map. Removes []*MapField `protobuf:"bytes,1,rep,name=removes" json:"removes,omitempty"` Updates []*MapUpdate `protobuf:"bytes,2,rep,name=updates" json:"updates,omitempty"` XXX_unrecognized []byte `json:"-"` }
An operation to update a Map. All operations apply to individual fields in the Map.
func (*MapOp) GetRemoves ¶
func (*MapOp) GetUpdates ¶
func (*MapOp) ProtoMessage ¶
func (*MapOp) ProtoMessage()
type MapUpdate ¶
type MapUpdate struct { Field *MapField `protobuf:"bytes,1,req,name=field" json:"field,omitempty"` CounterOp *CounterOp `protobuf:"bytes,2,opt,name=counter_op" json:"counter_op,omitempty"` SetOp *SetOp `protobuf:"bytes,3,opt,name=set_op" json:"set_op,omitempty"` // // There is only one operation on a register, which is to set its // value, therefore the "operation" is the new value. RegisterOp []byte `protobuf:"bytes,4,opt,name=register_op" json:"register_op,omitempty"` FlagOp *MapUpdate_FlagOp `protobuf:"varint,5,opt,name=flag_op,enum=MapUpdate_FlagOp" json:"flag_op,omitempty"` MapOp *MapOp `protobuf:"bytes,6,opt,name=map_op" json:"map_op,omitempty"` XXX_unrecognized []byte `json:"-"` }
An operation to be applied to a value stored in a Map -- the contents of an UPDATE operation. The operation field that is present depends on the type of the field to which it is applied.
func (*MapUpdate) GetCounterOp ¶
func (*MapUpdate) GetFlagOp ¶
func (m *MapUpdate) GetFlagOp() MapUpdate_FlagOp
func (*MapUpdate) GetRegisterOp ¶
func (*MapUpdate) ProtoMessage ¶
func (*MapUpdate) ProtoMessage()
type MapUpdate_FlagOp ¶
type MapUpdate_FlagOp int32
Flags only exist inside Maps and can only be enabled or disabled, and there are no arguments to the operations.
const ( MapUpdate_ENABLE MapUpdate_FlagOp = 1 MapUpdate_DISABLE MapUpdate_FlagOp = 2 )
func (MapUpdate_FlagOp) Enum ¶
func (x MapUpdate_FlagOp) Enum() *MapUpdate_FlagOp
func (MapUpdate_FlagOp) String ¶
func (x MapUpdate_FlagOp) String() string
func (*MapUpdate_FlagOp) UnmarshalJSON ¶
func (x *MapUpdate_FlagOp) UnmarshalJSON(data []byte) error
type RpbAuthReq ¶
type RpbAuthReq struct { User []byte `protobuf:"bytes,1,req,name=user" json:"user,omitempty"` Password []byte `protobuf:"bytes,2,req,name=password" json:"password,omitempty"` XXX_unrecognized []byte `json:"-"` }
Authentication request
func (*RpbAuthReq) GetPassword ¶
func (m *RpbAuthReq) GetPassword() []byte
func (*RpbAuthReq) GetUser ¶
func (m *RpbAuthReq) GetUser() []byte
func (*RpbAuthReq) ProtoMessage ¶
func (*RpbAuthReq) ProtoMessage()
func (*RpbAuthReq) Reset ¶
func (m *RpbAuthReq) Reset()
func (*RpbAuthReq) String ¶
func (m *RpbAuthReq) String() string
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"` // Search index SearchIndex []byte `protobuf:"bytes,25,opt,name=search_index" json:"search_index,omitempty"` // KV Datatypes Datatype []byte `protobuf:"bytes,26,opt,name=datatype" json:"datatype,omitempty"` // KV strong consistency Consistent *bool `protobuf:"varint,27,opt,name=consistent" json:"consistent,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) GetConsistent ¶
func (m *RpbBucketProps) GetConsistent() bool
func (*RpbBucketProps) GetDatatype ¶
func (m *RpbBucketProps) GetDatatype() []byte
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) GetSearchIndex ¶
func (m *RpbBucketProps) GetSearchIndex() []byte
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"` Timeout *uint32 `protobuf:"varint,8,opt,name=timeout" json:"timeout,omitempty"` Type []byte `protobuf:"bytes,9,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
added solely for riak_cs currently for folding over a bucket and returning objects.
func (*RpbCSBucketReq) GetBucket ¶
func (m *RpbCSBucketReq) GetBucket() []byte
func (*RpbCSBucketReq) GetContinuation ¶
func (m *RpbCSBucketReq) GetContinuation() []byte
func (*RpbCSBucketReq) GetEndIncl ¶
func (m *RpbCSBucketReq) GetEndIncl() bool
func (*RpbCSBucketReq) GetEndKey ¶
func (m *RpbCSBucketReq) GetEndKey() []byte
func (*RpbCSBucketReq) GetMaxResults ¶
func (m *RpbCSBucketReq) GetMaxResults() uint32
func (*RpbCSBucketReq) GetStartIncl ¶
func (m *RpbCSBucketReq) GetStartIncl() bool
func (*RpbCSBucketReq) GetStartKey ¶
func (m *RpbCSBucketReq) GetStartKey() []byte
func (*RpbCSBucketReq) GetTimeout ¶
func (m *RpbCSBucketReq) GetTimeout() uint32
func (*RpbCSBucketReq) GetType ¶
func (m *RpbCSBucketReq) GetType() []byte
func (*RpbCSBucketReq) ProtoMessage ¶
func (*RpbCSBucketReq) ProtoMessage()
func (*RpbCSBucketReq) Reset ¶
func (m *RpbCSBucketReq) Reset()
func (*RpbCSBucketReq) String ¶
func (m *RpbCSBucketReq) String() string
type RpbCSBucketResp ¶
type RpbCSBucketResp struct { Objects []*RpbIndexObject `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"` Continuation []byte `protobuf:"bytes,2,opt,name=continuation" json:"continuation,omitempty"` Done *bool `protobuf:"varint,3,opt,name=done" json:"done,omitempty"` XXX_unrecognized []byte `json:"-"` }
return for CS bucket fold
func (*RpbCSBucketResp) GetContinuation ¶
func (m *RpbCSBucketResp) GetContinuation() []byte
func (*RpbCSBucketResp) GetDone ¶
func (m *RpbCSBucketResp) GetDone() bool
func (*RpbCSBucketResp) GetObjects ¶
func (m *RpbCSBucketResp) GetObjects() []*RpbIndexObject
func (*RpbCSBucketResp) ProtoMessage ¶
func (*RpbCSBucketResp) ProtoMessage()
func (*RpbCSBucketResp) Reset ¶
func (m *RpbCSBucketResp) Reset()
func (*RpbCSBucketResp) String ¶
func (m *RpbCSBucketResp) String() string
type 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"` Type []byte `protobuf:"bytes,13,opt,name=type" json:"type,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"` Type []byte `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get bucket properties request
func (*RpbGetBucketReq) GetBucket ¶
func (m *RpbGetBucketReq) GetBucket() []byte
func (*RpbGetBucketReq) GetType ¶
func (m *RpbGetBucketReq) GetType() []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 RpbGetBucketTypeReq ¶
type RpbGetBucketTypeReq struct { Type []byte `protobuf:"bytes,1,req,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get bucket properties request
func (*RpbGetBucketTypeReq) GetType ¶
func (m *RpbGetBucketTypeReq) GetType() []byte
func (*RpbGetBucketTypeReq) ProtoMessage ¶
func (*RpbGetBucketTypeReq) ProtoMessage()
func (*RpbGetBucketTypeReq) Reset ¶
func (m *RpbGetBucketTypeReq) Reset()
func (*RpbGetBucketTypeReq) String ¶
func (m *RpbGetBucketTypeReq) String() string
type RpbGetClientIdResp ¶
type RpbGetClientIdResp struct { ClientId []byte `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get ClientId Request - no message defined, just send RpbGetClientIdReq message code
func (*RpbGetClientIdResp) GetClientId ¶
func (m *RpbGetClientIdResp) GetClientId() []byte
func (*RpbGetClientIdResp) ProtoMessage ¶
func (*RpbGetClientIdResp) ProtoMessage()
func (*RpbGetClientIdResp) Reset ¶
func (m *RpbGetClientIdResp) Reset()
func (*RpbGetClientIdResp) String ¶
func (m *RpbGetClientIdResp) String() string
type RpbGetReq ¶
type RpbGetReq struct { Bucket []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"` Key []byte `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` R *uint32 `protobuf:"varint,3,opt,name=r" json:"r,omitempty"` Pr *uint32 `protobuf:"varint,4,opt,name=pr" json:"pr,omitempty"` BasicQuorum *bool `protobuf:"varint,5,opt,name=basic_quorum" json:"basic_quorum,omitempty"` NotfoundOk *bool `protobuf:"varint,6,opt,name=notfound_ok" json:"notfound_ok,omitempty"` IfModified []byte `protobuf:"bytes,7,opt,name=if_modified" json:"if_modified,omitempty"` Head *bool `protobuf:"varint,8,opt,name=head" json:"head,omitempty"` Deletedvclock *bool `protobuf:"varint,9,opt,name=deletedvclock" json:"deletedvclock,omitempty"` Timeout *uint32 `protobuf:"varint,10,opt,name=timeout" json:"timeout,omitempty"` SloppyQuorum *bool `protobuf:"varint,11,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"` NVal *uint32 `protobuf:"varint,12,opt,name=n_val" json:"n_val,omitempty"` Type []byte `protobuf:"bytes,13,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Get Request - retrieve bucket/key
func (*RpbGetReq) 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"` Timeout *uint32 `protobuf:"varint,11,opt,name=timeout" json:"timeout,omitempty"` Type []byte `protobuf:"bytes,12,opt,name=type" json:"type,omitempty"` TermRegex []byte `protobuf:"bytes,13,opt,name=term_regex" json:"term_regex,omitempty"` // Whether to use pagination sort for non-paginated queries PaginationSort *bool `protobuf:"varint,14,opt,name=pagination_sort" json:"pagination_sort,omitempty"` XXX_unrecognized []byte `json:"-"` }
Secondary Index query request
func (*RpbIndexReq) GetBucket ¶
func (m *RpbIndexReq) GetBucket() []byte
func (*RpbIndexReq) GetContinuation ¶
func (m *RpbIndexReq) GetContinuation() []byte
func (*RpbIndexReq) GetIndex ¶
func (m *RpbIndexReq) GetIndex() []byte
func (*RpbIndexReq) GetKey ¶
func (m *RpbIndexReq) GetKey() []byte
func (*RpbIndexReq) GetMaxResults ¶
func (m *RpbIndexReq) GetMaxResults() uint32
func (*RpbIndexReq) GetPaginationSort ¶
func (m *RpbIndexReq) GetPaginationSort() bool
func (*RpbIndexReq) GetQtype ¶
func (m *RpbIndexReq) GetQtype() RpbIndexReq_IndexQueryType
func (*RpbIndexReq) GetRangeMax ¶
func (m *RpbIndexReq) GetRangeMax() []byte
func (*RpbIndexReq) GetRangeMin ¶
func (m *RpbIndexReq) GetRangeMin() []byte
func (*RpbIndexReq) GetReturnTerms ¶
func (m *RpbIndexReq) GetReturnTerms() bool
func (*RpbIndexReq) GetStream ¶
func (m *RpbIndexReq) GetStream() bool
func (*RpbIndexReq) GetTermRegex ¶
func (m *RpbIndexReq) GetTermRegex() []byte
func (*RpbIndexReq) GetTimeout ¶
func (m *RpbIndexReq) GetTimeout() uint32
func (*RpbIndexReq) GetType ¶
func (m *RpbIndexReq) GetType() []byte
func (*RpbIndexReq) 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"` Type []byte `protobuf:"bytes,3,opt,name=type" json:"type,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) GetType ¶
func (m *RpbListBucketsReq) GetType() []byte
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"` Type []byte `protobuf:"bytes,3,opt,name=type" json:"type,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) GetType ¶
func (m *RpbListKeysReq) GetType() []byte
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"` 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) 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"` Type []byte `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"` XXX_unrecognized []byte `json:"-"` }
Reset bucket properties request
func (*RpbResetBucketReq) GetBucket ¶
func (m *RpbResetBucketReq) GetBucket() []byte
func (*RpbResetBucketReq) GetType ¶
func (m *RpbResetBucketReq) GetType() []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:"-"` }
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"` Type []byte `protobuf:"bytes,3,opt,name=type" json:"type,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) GetType ¶
func (m *RpbSetBucketReq) GetType() []byte
func (*RpbSetBucketReq) ProtoMessage ¶
func (*RpbSetBucketReq) ProtoMessage()
func (*RpbSetBucketReq) Reset ¶
func (m *RpbSetBucketReq) Reset()
func (*RpbSetBucketReq) String ¶
func (m *RpbSetBucketReq) String() string
type RpbSetBucketTypeReq ¶
type RpbSetBucketTypeReq struct { Type []byte `protobuf:"bytes,1,req,name=type" json:"type,omitempty"` Props *RpbBucketProps `protobuf:"bytes,2,req,name=props" json:"props,omitempty"` XXX_unrecognized []byte `json:"-"` }
Set bucket properties request
func (*RpbSetBucketTypeReq) GetProps ¶
func (m *RpbSetBucketTypeReq) GetProps() *RpbBucketProps
func (*RpbSetBucketTypeReq) GetType ¶
func (m *RpbSetBucketTypeReq) GetType() []byte
func (*RpbSetBucketTypeReq) ProtoMessage ¶
func (*RpbSetBucketTypeReq) ProtoMessage()
func (*RpbSetBucketTypeReq) Reset ¶
func (m *RpbSetBucketTypeReq) Reset()
func (*RpbSetBucketTypeReq) String ¶
func (m *RpbSetBucketTypeReq) 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
type RpbYokozunaIndex ¶
type RpbYokozunaIndex struct { Name []byte `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Schema []byte `protobuf:"bytes,2,opt,name=schema" json:"schema,omitempty"` NVal *uint32 `protobuf:"varint,3,opt,name=n_val" json:"n_val,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbYokozunaIndex) GetNVal ¶
func (m *RpbYokozunaIndex) GetNVal() uint32
func (*RpbYokozunaIndex) GetName ¶
func (m *RpbYokozunaIndex) GetName() []byte
func (*RpbYokozunaIndex) GetSchema ¶
func (m *RpbYokozunaIndex) GetSchema() []byte
func (*RpbYokozunaIndex) ProtoMessage ¶
func (*RpbYokozunaIndex) ProtoMessage()
func (*RpbYokozunaIndex) Reset ¶
func (m *RpbYokozunaIndex) Reset()
func (*RpbYokozunaIndex) String ¶
func (m *RpbYokozunaIndex) String() string
type RpbYokozunaIndexDeleteReq ¶
type RpbYokozunaIndexDeleteReq struct { Name []byte `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` XXX_unrecognized []byte `json:"-"` }
DELETE request - Remove an index
func (*RpbYokozunaIndexDeleteReq) GetName ¶
func (m *RpbYokozunaIndexDeleteReq) GetName() []byte
func (*RpbYokozunaIndexDeleteReq) ProtoMessage ¶
func (*RpbYokozunaIndexDeleteReq) ProtoMessage()
func (*RpbYokozunaIndexDeleteReq) Reset ¶
func (m *RpbYokozunaIndexDeleteReq) Reset()
func (*RpbYokozunaIndexDeleteReq) String ¶
func (m *RpbYokozunaIndexDeleteReq) String() string
type RpbYokozunaIndexGetReq ¶
type RpbYokozunaIndexGetReq struct { Name []byte `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` XXX_unrecognized []byte `json:"-"` }
GET request - If a name is given, return matching index, else return all
func (*RpbYokozunaIndexGetReq) GetName ¶
func (m *RpbYokozunaIndexGetReq) GetName() []byte
func (*RpbYokozunaIndexGetReq) ProtoMessage ¶
func (*RpbYokozunaIndexGetReq) ProtoMessage()
func (*RpbYokozunaIndexGetReq) Reset ¶
func (m *RpbYokozunaIndexGetReq) Reset()
func (*RpbYokozunaIndexGetReq) String ¶
func (m *RpbYokozunaIndexGetReq) String() string
type RpbYokozunaIndexGetResp ¶
type RpbYokozunaIndexGetResp struct { Index []*RpbYokozunaIndex `protobuf:"bytes,1,rep,name=index" json:"index,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbYokozunaIndexGetResp) GetIndex ¶
func (m *RpbYokozunaIndexGetResp) GetIndex() []*RpbYokozunaIndex
func (*RpbYokozunaIndexGetResp) ProtoMessage ¶
func (*RpbYokozunaIndexGetResp) ProtoMessage()
func (*RpbYokozunaIndexGetResp) Reset ¶
func (m *RpbYokozunaIndexGetResp) Reset()
func (*RpbYokozunaIndexGetResp) String ¶
func (m *RpbYokozunaIndexGetResp) String() string
type RpbYokozunaIndexPutReq ¶
type RpbYokozunaIndexPutReq struct { Index *RpbYokozunaIndex `protobuf:"bytes,1,req,name=index" json:"index,omitempty"` XXX_unrecognized []byte `json:"-"` }
PUT request - Create a new index
func (*RpbYokozunaIndexPutReq) GetIndex ¶
func (m *RpbYokozunaIndexPutReq) GetIndex() *RpbYokozunaIndex
func (*RpbYokozunaIndexPutReq) ProtoMessage ¶
func (*RpbYokozunaIndexPutReq) ProtoMessage()
func (*RpbYokozunaIndexPutReq) Reset ¶
func (m *RpbYokozunaIndexPutReq) Reset()
func (*RpbYokozunaIndexPutReq) String ¶
func (m *RpbYokozunaIndexPutReq) String() string
type RpbYokozunaSchema ¶
type RpbYokozunaSchema struct { Name []byte `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=content" json:"content,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbYokozunaSchema) GetContent ¶
func (m *RpbYokozunaSchema) GetContent() []byte
func (*RpbYokozunaSchema) GetName ¶
func (m *RpbYokozunaSchema) GetName() []byte
func (*RpbYokozunaSchema) ProtoMessage ¶
func (*RpbYokozunaSchema) ProtoMessage()
func (*RpbYokozunaSchema) Reset ¶
func (m *RpbYokozunaSchema) Reset()
func (*RpbYokozunaSchema) String ¶
func (m *RpbYokozunaSchema) String() string
type RpbYokozunaSchemaGetReq ¶
type RpbYokozunaSchemaGetReq struct { Name []byte `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` XXX_unrecognized []byte `json:"-"` }
GET request - Return matching schema by name
func (*RpbYokozunaSchemaGetReq) GetName ¶
func (m *RpbYokozunaSchemaGetReq) GetName() []byte
func (*RpbYokozunaSchemaGetReq) ProtoMessage ¶
func (*RpbYokozunaSchemaGetReq) ProtoMessage()
func (*RpbYokozunaSchemaGetReq) Reset ¶
func (m *RpbYokozunaSchemaGetReq) Reset()
func (*RpbYokozunaSchemaGetReq) String ¶
func (m *RpbYokozunaSchemaGetReq) String() string
type RpbYokozunaSchemaGetResp ¶
type RpbYokozunaSchemaGetResp struct { Schema *RpbYokozunaSchema `protobuf:"bytes,1,req,name=schema" json:"schema,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RpbYokozunaSchemaGetResp) GetSchema ¶
func (m *RpbYokozunaSchemaGetResp) GetSchema() *RpbYokozunaSchema
func (*RpbYokozunaSchemaGetResp) ProtoMessage ¶
func (*RpbYokozunaSchemaGetResp) ProtoMessage()
func (*RpbYokozunaSchemaGetResp) Reset ¶
func (m *RpbYokozunaSchemaGetResp) Reset()
func (*RpbYokozunaSchemaGetResp) String ¶
func (m *RpbYokozunaSchemaGetResp) String() string
type RpbYokozunaSchemaPutReq ¶
type RpbYokozunaSchemaPutReq struct { Schema *RpbYokozunaSchema `protobuf:"bytes,1,req,name=schema" json:"schema,omitempty"` XXX_unrecognized []byte `json:"-"` }
PUT request - create or potentially update a new schema
func (*RpbYokozunaSchemaPutReq) GetSchema ¶
func (m *RpbYokozunaSchemaPutReq) GetSchema() *RpbYokozunaSchema
func (*RpbYokozunaSchemaPutReq) ProtoMessage ¶
func (*RpbYokozunaSchemaPutReq) ProtoMessage()
func (*RpbYokozunaSchemaPutReq) Reset ¶
func (m *RpbYokozunaSchemaPutReq) Reset()
func (*RpbYokozunaSchemaPutReq) String ¶
func (m *RpbYokozunaSchemaPutReq) String() string
type SetOp ¶
type SetOp struct { Adds [][]byte `protobuf:"bytes,1,rep,name=adds" json:"adds,omitempty"` Removes [][]byte `protobuf:"bytes,2,rep,name=removes" json:"removes,omitempty"` XXX_unrecognized []byte `json:"-"` }
An operation to update a Set, either on its own or inside a Map. Set members are opaque binary values, you can only add or remove them from a Set.
func (*SetOp) GetRemoves ¶
func (*SetOp) ProtoMessage ¶
func (*SetOp) ProtoMessage()