pb

package
v0.0.0-...-97ee455 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2017 License: Apache-2.0 Imports: 2 Imported by: 16

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

View Source 
const Default_DtFetchReq_IncludeContext bool = true
View Source 
const Default_DtUpdateReq_IncludeContext bool = true
View Source 
const Default_DtUpdateReq_ReturnBody bool = false
View Source 
const Default_RpbBucketProps_HasPostcommit bool = false
View Source 
const Default_RpbBucketProps_HasPrecommit bool = false
View Source 
const Default_RpbCSBucketReq_EndIncl bool = false
View Source 
const Default_RpbCSBucketReq_StartIncl bool = true

Variables

View Source 
var DtFetchResp_DataType_name = map[int32]string{
	1: "COUNTER",
	2: "SET",
	3: "MAP",
}
View Source 
var DtFetchResp_DataType_value = map[string]int32{
	"COUNTER": 1,
	"SET":     2,
	"MAP":     3,
}
View Source 
var MapField_MapFieldType_name = map[int32]string{
	1: "COUNTER",
	2: "SET",
	3: "REGISTER",
	4: "FLAG",
	5: "MAP",
}
View Source 
var MapField_MapFieldType_value = map[string]int32{
	"COUNTER":  1,
	"SET":      2,
	"REGISTER": 3,
	"FLAG":     4,
	"MAP":      5,
}
View Source 
var MapUpdate_FlagOp_name = map[int32]string{
	1: "ENABLE",
	2: "DISABLE",
}
View Source 
var MapUpdate_FlagOp_value = map[string]int32{
	"ENABLE":  1,
	"DISABLE": 2,
}
View Source 
var RpbBucketProps_RpbReplMode_name = map[int32]string{
	0: "FALSE",
	1: "REALTIME",
	2: "FULLSYNC",
	3: "TRUE",
}
View Source 
var RpbBucketProps_RpbReplMode_value = map[string]int32{
	"FALSE":    0,
	"REALTIME": 1,
	"FULLSYNC": 2,
	"TRUE":     3,
}
View Source 
var RpbIndexReq_IndexQueryType_name = map[int32]string{
	0: "eq",
	1: "range",
}
View Source 
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 (m *CounterOp) GetIncrement() int64

func (*CounterOp) ProtoMessage 

func (*CounterOp) ProtoMessage()

func (*CounterOp) Reset 

func (m *CounterOp) Reset()

func (*CounterOp) String 

func (m *CounterOp) String() string

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 (m *DtOp) GetCounterOp() *CounterOp

func (*DtOp) GetMapOp 

func (m *DtOp) GetMapOp() *MapOp

func (*DtOp) GetSetOp 

func (m *DtOp) GetSetOp() *SetOp

func (*DtOp) ProtoMessage 

func (*DtOp) ProtoMessage()

func (*DtOp) Reset 

func (m *DtOp) Reset()

func (*DtOp) String 

func (m *DtOp) String() string

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 (m *DtValue) GetCounterValue() int64

func (*DtValue) GetMapValue 

func (m *DtValue) GetMapValue() []*MapEntry

func (*DtValue) GetSetValue 

func (m *DtValue) GetSetValue() [][]byte

func (*DtValue) ProtoMessage 

func (*DtValue) ProtoMessage()

func (*DtValue) Reset 

func (m *DtValue) Reset()

func (*DtValue) String 

func (m *DtValue) String() string

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 (m *MapEntry) GetCounterValue() int64

func (*MapEntry) GetField 

func (m *MapEntry) GetField() *MapField

func (*MapEntry) GetFlagValue 

func (m *MapEntry) GetFlagValue() bool

func (*MapEntry) GetMapValue 

func (m *MapEntry) GetMapValue() []*MapEntry

func (*MapEntry) GetRegisterValue 

func (m *MapEntry) GetRegisterValue() []byte

func (*MapEntry) GetSetValue 

func (m *MapEntry) GetSetValue() [][]byte

func (*MapEntry) ProtoMessage 

func (*MapEntry) ProtoMessage()

func (*MapEntry) Reset 

func (m *MapEntry) Reset()

func (*MapEntry) String 

func (m *MapEntry) String() string

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) GetName 

func (m *MapField) GetName() []byte

func (*MapField) GetType 

func (m *MapField) GetType() MapField_MapFieldType

func (*MapField) ProtoMessage 

func (*MapField) ProtoMessage()

func (*MapField) Reset 

func (m *MapField) Reset()

func (*MapField) String 

func (m *MapField) String() string

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 (m *MapOp) GetRemoves() []*MapField

func (*MapOp) GetUpdates 

func (m *MapOp) GetUpdates() []*MapUpdate

func (*MapOp) ProtoMessage 

func (*MapOp) ProtoMessage()

func (*MapOp) Reset 

func (m *MapOp) Reset()

func (*MapOp) String 

func (m *MapOp) String() string

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 (m *MapUpdate) GetCounterOp() *CounterOp

func (*MapUpdate) GetField 

func (m *MapUpdate) GetField() *MapField

func (*MapUpdate) GetFlagOp 

func (m *MapUpdate) GetFlagOp() MapUpdate_FlagOp

func (*MapUpdate) GetMapOp 

func (m *MapUpdate) GetMapOp() *MapOp

func (*MapUpdate) GetRegisterOp 

func (m *MapUpdate) GetRegisterOp() []byte

func (*MapUpdate) GetSetOp 

func (m *MapUpdate) GetSetOp() *SetOp

func (*MapUpdate) ProtoMessage 

func (*MapUpdate) ProtoMessage()

func (*MapUpdate) Reset 

func (m *MapUpdate) Reset()

func (*MapUpdate) String 

func (m *MapUpdate) String() string

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 (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) GetBucket 

func (m *RpbDelReq) GetBucket() []byte

func (*RpbDelReq) GetDw 

func (m *RpbDelReq) GetDw() uint32

func (*RpbDelReq) GetKey 

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

func (*RpbDelReq) GetNVal 

func (m *RpbDelReq) GetNVal() uint32

func (*RpbDelReq) GetPr 

func (m *RpbDelReq) GetPr() uint32

func (*RpbDelReq) GetPw 

func (m *RpbDelReq) GetPw() uint32

func (*RpbDelReq) GetR 

func (m *RpbDelReq) GetR() uint32

func (*RpbDelReq) GetRw 

func (m *RpbDelReq) GetRw() uint32

func (*RpbDelReq) GetSloppyQuorum 

func (m *RpbDelReq) GetSloppyQuorum() bool

func (*RpbDelReq) GetTimeout 

func (m *RpbDelReq) GetTimeout() uint32

func (*RpbDelReq) GetType 

func (m *RpbDelReq) GetType() []byte

func (*RpbDelReq) GetVclock 

func (m *RpbDelReq) GetVclock() []byte

func (*RpbDelReq) GetW 

func (m *RpbDelReq) GetW() uint32

func (*RpbDelReq) ProtoMessage 

func (*RpbDelReq) ProtoMessage()

func (*RpbDelReq) Reset 

func (m *RpbDelReq) Reset()

func (*RpbDelReq) String 

func (m *RpbDelReq) String() string

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 (m *RpbGetReq) GetBasicQuorum() bool

func (*RpbGetReq) GetBucket 

func (m *RpbGetReq) GetBucket() []byte

func (*RpbGetReq) GetDeletedvclock 

func (m *RpbGetReq) GetDeletedvclock() bool

func (*RpbGetReq) GetHead 

func (m *RpbGetReq) GetHead() bool

func (*RpbGetReq) GetIfModified 

func (m *RpbGetReq) GetIfModified() []byte

func (*RpbGetReq) GetKey 

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

func (*RpbGetReq) GetNVal 

func (m *RpbGetReq) GetNVal() uint32

func (*RpbGetReq) GetNotfoundOk 

func (m *RpbGetReq) GetNotfoundOk() bool

func (*RpbGetReq) GetPr 

func (m *RpbGetReq) GetPr() uint32

func (*RpbGetReq) GetR 

func (m *RpbGetReq) GetR() uint32

func (*RpbGetReq) GetSloppyQuorum 

func (m *RpbGetReq) GetSloppyQuorum() bool

func (*RpbGetReq) GetTimeout 

func (m *RpbGetReq) GetTimeout() uint32

func (*RpbGetReq) GetType 

func (m *RpbGetReq) GetType() []byte

func (*RpbGetReq) ProtoMessage 

func (*RpbGetReq) ProtoMessage()

func (*RpbGetReq) Reset 

func (m *RpbGetReq) Reset()

func (*RpbGetReq) String 

func (m *RpbGetReq) String() string

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 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) GetBucket 

func (m *RpbLink) GetBucket() []byte

func (*RpbLink) GetKey 

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

func (*RpbLink) GetTag 

func (m *RpbLink) GetTag() []byte

func (*RpbLink) ProtoMessage 

func (*RpbLink) ProtoMessage()

func (*RpbLink) Reset 

func (m *RpbLink) Reset()

func (*RpbLink) String 

func (m *RpbLink) String() string

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 (m *RpbModFun) GetFunction() []byte

func (*RpbModFun) GetModule 

func (m *RpbModFun) GetModule() []byte

func (*RpbModFun) ProtoMessage 

func (*RpbModFun) ProtoMessage()

func (*RpbModFun) Reset 

func (m *RpbModFun) Reset()

func (*RpbModFun) String 

func (m *RpbModFun) String() string

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) GetKey 

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

func (*RpbPair) GetValue 

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

func (*RpbPair) ProtoMessage 

func (*RpbPair) ProtoMessage()

func (*RpbPair) Reset 

func (m *RpbPair) Reset()

func (*RpbPair) String 

func (m *RpbPair) String() string

type RpbPutReq 

type RpbPutReq struct {
	Bucket           []byte      `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Key              []byte      `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Vclock           []byte      `protobuf:"bytes,3,opt,name=vclock" json:"vclock,omitempty"`
	Content          *RpbContent `protobuf:"bytes,4,req,name=content" json:"content,omitempty"`
	W                *uint32     `protobuf:"varint,5,opt,name=w" json:"w,omitempty"`
	Dw               *uint32     `protobuf:"varint,6,opt,name=dw" json:"dw,omitempty"`
	ReturnBody       *bool       `protobuf:"varint,7,opt,name=return_body" json:"return_body,omitempty"`
	Pw               *uint32     `protobuf:"varint,8,opt,name=pw" json:"pw,omitempty"`
	IfNotModified    *bool       `protobuf:"varint,9,opt,name=if_not_modified" json:"if_not_modified,omitempty"`
	IfNoneMatch      *bool       `protobuf:"varint,10,opt,name=if_none_match" json:"if_none_match,omitempty"`
	ReturnHead       *bool       `protobuf:"varint,11,opt,name=return_head" json:"return_head,omitempty"`
	Timeout          *uint32     `protobuf:"varint,12,opt,name=timeout" json:"timeout,omitempty"`
	Asis             *bool       `protobuf:"varint,13,opt,name=asis" json:"asis,omitempty"`
	SloppyQuorum     *bool       `protobuf:"varint,14,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"`
	NVal             *uint32     `protobuf:"varint,15,opt,name=n_val" json:"n_val,omitempty"`
	Type             []byte      `protobuf:"bytes,16,opt,name=type" json:"type,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

Put request - if options.return_body is set then the updated metadata/data for 

the key will be returned.

func (*RpbPutReq) GetAsis 

func (m *RpbPutReq) GetAsis() bool

func (*RpbPutReq) GetBucket 

func (m *RpbPutReq) GetBucket() []byte

func (*RpbPutReq) GetContent 

func (m *RpbPutReq) GetContent() *RpbContent

func (*RpbPutReq) GetDw 

func (m *RpbPutReq) GetDw() uint32

func (*RpbPutReq) GetIfNoneMatch 

func (m *RpbPutReq) GetIfNoneMatch() bool

func (*RpbPutReq) GetIfNotModified 

func (m *RpbPutReq) GetIfNotModified() bool

func (*RpbPutReq) GetKey 

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

func (*RpbPutReq) GetNVal 

func (m *RpbPutReq) GetNVal() uint32

func (*RpbPutReq) GetPw 

func (m *RpbPutReq) GetPw() uint32

func (*RpbPutReq) GetReturnBody 

func (m *RpbPutReq) GetReturnBody() bool

func (*RpbPutReq) GetReturnHead 

func (m *RpbPutReq) GetReturnHead() bool

func (*RpbPutReq) GetSloppyQuorum 

func (m *RpbPutReq) GetSloppyQuorum() bool

func (*RpbPutReq) GetTimeout 

func (m *RpbPutReq) GetTimeout() uint32

func (*RpbPutReq) GetType 

func (m *RpbPutReq) GetType() []byte

func (*RpbPutReq) GetVclock 

func (m *RpbPutReq) GetVclock() []byte

func (*RpbPutReq) GetW 

func (m *RpbPutReq) GetW() uint32

func (*RpbPutReq) ProtoMessage 

func (*RpbPutReq) ProtoMessage()

func (*RpbPutReq) Reset 

func (m *RpbPutReq) Reset()

func (*RpbPutReq) String 

func (m *RpbPutReq) String() string

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) GetAdds 

func (m *SetOp) GetAdds() [][]byte

func (*SetOp) GetRemoves 

func (m *SetOp) GetRemoves() [][]byte

func (*SetOp) ProtoMessage 

func (*SetOp) ProtoMessage()

func (*SetOp) Reset 

func (m *SetOp) Reset()

func (*SetOp) String 

func (m *SetOp) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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