riak_kv

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2016 License: Apache-2.0 Imports: 4 Imported by: 13

Documentation

Overview

Package riak_kv is a generated protocol buffer package.

It is generated from these files: 

riak_kv.proto

It has these top-level messages: 

RpbGetClientIdResp
RpbSetClientIdReq
RpbGetReq
RpbGetResp
RpbPutReq
RpbPutResp
RpbDelReq
RpbListBucketsReq
RpbListBucketsResp
RpbListKeysReq
RpbListKeysResp
RpbMapRedReq
RpbMapRedResp
RpbIndexReq
RpbIndexResp
RpbIndexBodyResp
RpbCSBucketReq
RpbCSBucketResp
RpbIndexObject
RpbContent
RpbLink
RpbCounterUpdateReq
RpbCounterUpdateResp
RpbCounterGetReq
RpbCounterGetResp
RpbGetBucketKeyPreflistReq
RpbGetBucketKeyPreflistResp
RpbBucketKeyPreflistItem
RpbCoverageReq
RpbCoverageResp
RpbCoverageEntry

Index

Constants

View Source 
const Default_RpbCSBucketReq_EndIncl bool = false
View Source 
const Default_RpbCSBucketReq_StartIncl bool = true

Variables

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 RpbBucketKeyPreflistItem 

type RpbBucketKeyPreflistItem struct {
	Partition        *int64 `protobuf:"varint,1,req,name=partition" json:"partition,omitempty"`
	Node             []byte `protobuf:"bytes,2,req,name=node" json:"node,omitempty"`
	Primary          *bool  `protobuf:"varint,3,req,name=primary" json:"primary,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Preflist item

func (*RpbBucketKeyPreflistItem) Descriptor added in v1.7.0 

func (*RpbBucketKeyPreflistItem) Descriptor() ([]byte, []int)

func (*RpbBucketKeyPreflistItem) GetNode 

func (m *RpbBucketKeyPreflistItem) GetNode() []byte

func (*RpbBucketKeyPreflistItem) GetPartition 

func (m *RpbBucketKeyPreflistItem) GetPartition() int64

func (*RpbBucketKeyPreflistItem) GetPrimary 

func (m *RpbBucketKeyPreflistItem) GetPrimary() bool

func (*RpbBucketKeyPreflistItem) ProtoMessage 

func (*RpbBucketKeyPreflistItem) ProtoMessage()

func (*RpbBucketKeyPreflistItem) Reset 

func (m *RpbBucketKeyPreflistItem) Reset()

func (*RpbBucketKeyPreflistItem) String 

func (m *RpbBucketKeyPreflistItem) String() string

type RpbCSBucketReq 

type RpbCSBucketReq struct {
	Bucket       []byte  `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	StartKey     []byte  `protobuf:"bytes,2,req,name=start_key" json:"start_key,omitempty"`
	EndKey       []byte  `protobuf:"bytes,3,opt,name=end_key" json:"end_key,omitempty"`
	StartIncl    *bool   `protobuf:"varint,4,opt,name=start_incl,def=1" json:"start_incl,omitempty"`
	EndIncl      *bool   `protobuf:"varint,5,opt,name=end_incl,def=0" json:"end_incl,omitempty"`
	Continuation []byte  `protobuf:"bytes,6,opt,name=continuation" json:"continuation,omitempty"`
	MaxResults   *uint32 `protobuf:"varint,7,opt,name=max_results" json:"max_results,omitempty"`
	Timeout      *uint32 `protobuf:"varint,8,opt,name=timeout" json:"timeout,omitempty"`
	Type         []byte  `protobuf:"bytes,9,opt,name=type" json:"type,omitempty"`
	// parallel extraction extension
	CoverContext     []byte `protobuf:"bytes,10,opt,name=cover_context" json:"cover_context,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

added solely for riak_cs currently for folding over a bucket and returning objects.

func (*RpbCSBucketReq) Descriptor added in v1.7.0 

func (*RpbCSBucketReq) Descriptor() ([]byte, []int)

func (*RpbCSBucketReq) GetBucket 

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

func (*RpbCSBucketReq) GetContinuation 

func (m *RpbCSBucketReq) GetContinuation() []byte

func (*RpbCSBucketReq) GetCoverContext added in v1.7.0 

func (m *RpbCSBucketReq) GetCoverContext() []byte

func (*RpbCSBucketReq) GetEndIncl 

func (m *RpbCSBucketReq) GetEndIncl() bool

func (*RpbCSBucketReq) GetEndKey 

func (m *RpbCSBucketReq) GetEndKey() []byte

func (*RpbCSBucketReq) GetMaxResults 

func (m *RpbCSBucketReq) GetMaxResults() uint32

func (*RpbCSBucketReq) GetStartIncl 

func (m *RpbCSBucketReq) GetStartIncl() bool

func (*RpbCSBucketReq) GetStartKey 

func (m *RpbCSBucketReq) GetStartKey() []byte

func (*RpbCSBucketReq) GetTimeout 

func (m *RpbCSBucketReq) GetTimeout() uint32

func (*RpbCSBucketReq) GetType 

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

func (*RpbCSBucketReq) ProtoMessage 

func (*RpbCSBucketReq) ProtoMessage()

func (*RpbCSBucketReq) Reset 

func (m *RpbCSBucketReq) Reset()

func (*RpbCSBucketReq) String 

func (m *RpbCSBucketReq) String() string

type RpbCSBucketResp 

type RpbCSBucketResp struct {
	Objects          []*RpbIndexObject `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"`
	Continuation     []byte            `protobuf:"bytes,2,opt,name=continuation" json:"continuation,omitempty"`
	Done             *bool             `protobuf:"varint,3,opt,name=done" json:"done,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

return for CS bucket fold

func (*RpbCSBucketResp) Descriptor added in v1.7.0 

func (*RpbCSBucketResp) Descriptor() ([]byte, []int)

func (*RpbCSBucketResp) GetContinuation 

func (m *RpbCSBucketResp) GetContinuation() []byte

func (*RpbCSBucketResp) GetDone 

func (m *RpbCSBucketResp) GetDone() bool

func (*RpbCSBucketResp) GetObjects 

func (m *RpbCSBucketResp) GetObjects() []*RpbIndexObject

func (*RpbCSBucketResp) ProtoMessage 

func (*RpbCSBucketResp) ProtoMessage()

func (*RpbCSBucketResp) Reset 

func (m *RpbCSBucketResp) Reset()

func (*RpbCSBucketResp) String 

func (m *RpbCSBucketResp) String() string

type RpbContent 

type RpbContent struct {
	Value            []byte          `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	ContentType      []byte          `protobuf:"bytes,2,opt,name=content_type" json:"content_type,omitempty"`
	Charset          []byte          `protobuf:"bytes,3,opt,name=charset" json:"charset,omitempty"`
	ContentEncoding  []byte          `protobuf:"bytes,4,opt,name=content_encoding" json:"content_encoding,omitempty"`
	Vtag             []byte          `protobuf:"bytes,5,opt,name=vtag" json:"vtag,omitempty"`
	Links            []*RpbLink      `protobuf:"bytes,6,rep,name=links" json:"links,omitempty"`
	LastMod          *uint32         `protobuf:"varint,7,opt,name=last_mod" json:"last_mod,omitempty"`
	LastModUsecs     *uint32         `protobuf:"varint,8,opt,name=last_mod_usecs" json:"last_mod_usecs,omitempty"`
	Usermeta         []*riak.RpbPair `protobuf:"bytes,9,rep,name=usermeta" json:"usermeta,omitempty"`
	Indexes          []*riak.RpbPair `protobuf:"bytes,10,rep,name=indexes" json:"indexes,omitempty"`
	Deleted          *bool           `protobuf:"varint,11,opt,name=deleted" json:"deleted,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

Content message included in get/put responses Holds the value and associated metadata

func (*RpbContent) Descriptor added in v1.7.0 

func (*RpbContent) Descriptor() ([]byte, []int)

func (*RpbContent) GetCharset 

func (m *RpbContent) GetCharset() []byte

func (*RpbContent) GetContentEncoding 

func (m *RpbContent) GetContentEncoding() []byte

func (*RpbContent) GetContentType 

func (m *RpbContent) GetContentType() []byte

func (*RpbContent) GetDeleted 

func (m *RpbContent) GetDeleted() bool

func (*RpbContent) GetIndexes 

func (m *RpbContent) GetIndexes() []*riak.RpbPair

func (*RpbContent) GetLastMod 

func (m *RpbContent) GetLastMod() uint32

func (*RpbContent) GetLastModUsecs 

func (m *RpbContent) GetLastModUsecs() uint32
func (m *RpbContent) GetLinks() []*RpbLink

func (*RpbContent) GetUsermeta 

func (m *RpbContent) GetUsermeta() []*riak.RpbPair

func (*RpbContent) GetValue 

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

func (*RpbContent) GetVtag 

func (m *RpbContent) GetVtag() []byte

func (*RpbContent) ProtoMessage 

func (*RpbContent) ProtoMessage()

func (*RpbContent) Reset 

func (m *RpbContent) Reset()

func (*RpbContent) String 

func (m *RpbContent) String() string

type RpbCounterGetReq 

type RpbCounterGetReq struct {
	Bucket           []byte  `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Key              []byte  `protobuf:"bytes,2,req,name=key" json:"key,omitempty"`
	R                *uint32 `protobuf:"varint,3,opt,name=r" json:"r,omitempty"`
	Pr               *uint32 `protobuf:"varint,4,opt,name=pr" json:"pr,omitempty"`
	BasicQuorum      *bool   `protobuf:"varint,5,opt,name=basic_quorum" json:"basic_quorum,omitempty"`
	NotfoundOk       *bool   `protobuf:"varint,6,opt,name=notfound_ok" json:"notfound_ok,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

counter value

func (*RpbCounterGetReq) Descriptor added in v1.7.0 

func (*RpbCounterGetReq) Descriptor() ([]byte, []int)

func (*RpbCounterGetReq) GetBasicQuorum 

func (m *RpbCounterGetReq) GetBasicQuorum() bool

func (*RpbCounterGetReq) GetBucket 

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

func (*RpbCounterGetReq) GetKey 

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

func (*RpbCounterGetReq) GetNotfoundOk 

func (m *RpbCounterGetReq) GetNotfoundOk() bool

func (*RpbCounterGetReq) GetPr 

func (m *RpbCounterGetReq) GetPr() uint32

func (*RpbCounterGetReq) GetR 

func (m *RpbCounterGetReq) GetR() uint32

func (*RpbCounterGetReq) ProtoMessage 

func (*RpbCounterGetReq) ProtoMessage()

func (*RpbCounterGetReq) Reset 

func (m *RpbCounterGetReq) Reset()

func (*RpbCounterGetReq) String 

func (m *RpbCounterGetReq) String() string

type RpbCounterGetResp 

type RpbCounterGetResp struct {
	Value            *int64 `protobuf:"zigzag64,1,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Counter value response

func (*RpbCounterGetResp) Descriptor added in v1.7.0 

func (*RpbCounterGetResp) Descriptor() ([]byte, []int)

func (*RpbCounterGetResp) GetValue 

func (m *RpbCounterGetResp) GetValue() int64

func (*RpbCounterGetResp) ProtoMessage 

func (*RpbCounterGetResp) ProtoMessage()

func (*RpbCounterGetResp) Reset 

func (m *RpbCounterGetResp) Reset()

func (*RpbCounterGetResp) String 

func (m *RpbCounterGetResp) String() string

type RpbCounterUpdateReq 

type RpbCounterUpdateReq struct {
	Bucket           []byte  `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Key              []byte  `protobuf:"bytes,2,req,name=key" json:"key,omitempty"`
	Amount           *int64  `protobuf:"zigzag64,3,req,name=amount" json:"amount,omitempty"`
	W                *uint32 `protobuf:"varint,4,opt,name=w" json:"w,omitempty"`
	Dw               *uint32 `protobuf:"varint,5,opt,name=dw" json:"dw,omitempty"`
	Pw               *uint32 `protobuf:"varint,6,opt,name=pw" json:"pw,omitempty"`
	Returnvalue      *bool   `protobuf:"varint,7,opt,name=returnvalue" json:"returnvalue,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Counter update request

func (*RpbCounterUpdateReq) BucketIsRequired added in v1.4.0 

func (m *RpbCounterUpdateReq) BucketIsRequired() bool

func (*RpbCounterUpdateReq) Descriptor added in v1.7.0 

func (*RpbCounterUpdateReq) Descriptor() ([]byte, []int)

func (*RpbCounterUpdateReq) GetAmount 

func (m *RpbCounterUpdateReq) GetAmount() int64

func (*RpbCounterUpdateReq) GetBucket 

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

func (*RpbCounterUpdateReq) GetDw 

func (m *RpbCounterUpdateReq) GetDw() uint32

func (*RpbCounterUpdateReq) GetKey 

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

func (*RpbCounterUpdateReq) GetPw 

func (m *RpbCounterUpdateReq) GetPw() uint32

func (*RpbCounterUpdateReq) GetReturnvalue 

func (m *RpbCounterUpdateReq) GetReturnvalue() bool

func (*RpbCounterUpdateReq) GetType added in v1.4.0 

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

func (*RpbCounterUpdateReq) GetW 

func (m *RpbCounterUpdateReq) GetW() uint32

func (*RpbCounterUpdateReq) KeyIsRequired added in v1.4.0 

func (m *RpbCounterUpdateReq) KeyIsRequired() bool

func (*RpbCounterUpdateReq) ProtoMessage 

func (*RpbCounterUpdateReq) ProtoMessage()

func (*RpbCounterUpdateReq) Reset 

func (m *RpbCounterUpdateReq) Reset()

func (*RpbCounterUpdateReq) SetType added in v1.4.0 

func (m *RpbCounterUpdateReq) SetType(bt []byte)

func (*RpbCounterUpdateReq) String 

func (m *RpbCounterUpdateReq) String() string

type RpbCounterUpdateResp 

type RpbCounterUpdateResp struct {
	Value            *int64 `protobuf:"zigzag64,1,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Counter update response? No message | error response

func (*RpbCounterUpdateResp) Descriptor added in v1.7.0 

func (*RpbCounterUpdateResp) Descriptor() ([]byte, []int)

func (*RpbCounterUpdateResp) GetValue 

func (m *RpbCounterUpdateResp) GetValue() int64

func (*RpbCounterUpdateResp) ProtoMessage 

func (*RpbCounterUpdateResp) ProtoMessage()

func (*RpbCounterUpdateResp) Reset 

func (m *RpbCounterUpdateResp) Reset()

func (*RpbCounterUpdateResp) String 

func (m *RpbCounterUpdateResp) String() string

type RpbCoverageEntry added in v1.7.0 

type RpbCoverageEntry struct {
	Ip               []byte  `protobuf:"bytes,1,req,name=ip" json:"ip,omitempty"`
	Port             *uint32 `protobuf:"varint,2,req,name=port" json:"port,omitempty"`
	KeyspaceDesc     []byte  `protobuf:"bytes,3,opt,name=keyspace_desc" json:"keyspace_desc,omitempty"`
	CoverContext     []byte  `protobuf:"bytes,4,req,name=cover_context" json:"cover_context,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Segment of a coverage plan

func (*RpbCoverageEntry) Descriptor added in v1.7.0 

func (*RpbCoverageEntry) Descriptor() ([]byte, []int)

func (*RpbCoverageEntry) GetCoverContext added in v1.7.0 

func (m *RpbCoverageEntry) GetCoverContext() []byte

func (*RpbCoverageEntry) GetIp added in v1.7.0 

func (m *RpbCoverageEntry) GetIp() []byte

func (*RpbCoverageEntry) GetKeyspaceDesc added in v1.7.0 

func (m *RpbCoverageEntry) GetKeyspaceDesc() []byte

func (*RpbCoverageEntry) GetPort added in v1.7.0 

func (m *RpbCoverageEntry) GetPort() uint32

func (*RpbCoverageEntry) ProtoMessage added in v1.7.0 

func (*RpbCoverageEntry) ProtoMessage()

func (*RpbCoverageEntry) Reset added in v1.7.0 

func (m *RpbCoverageEntry) Reset()

func (*RpbCoverageEntry) String added in v1.7.0 

func (m *RpbCoverageEntry) String() string

type RpbCoverageReq added in v1.7.0 

type RpbCoverageReq struct {
	Type             []byte   `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Bucket           []byte   `protobuf:"bytes,2,req,name=bucket" json:"bucket,omitempty"`
	MinPartitions    *uint32  `protobuf:"varint,3,opt,name=min_partitions" json:"min_partitions,omitempty"`
	ReplaceCover     []byte   `protobuf:"bytes,4,opt,name=replace_cover" json:"replace_cover,omitempty"`
	UnavailableCover [][]byte `protobuf:"bytes,5,rep,name=unavailable_cover" json:"unavailable_cover,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Request a segmented coverage plan for the specified bucket

func (*RpbCoverageReq) Descriptor added in v1.7.0 

func (*RpbCoverageReq) Descriptor() ([]byte, []int)

func (*RpbCoverageReq) GetBucket added in v1.7.0 

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

func (*RpbCoverageReq) GetMinPartitions added in v1.7.0 

func (m *RpbCoverageReq) GetMinPartitions() uint32

func (*RpbCoverageReq) GetReplaceCover added in v1.7.0 

func (m *RpbCoverageReq) GetReplaceCover() []byte

func (*RpbCoverageReq) GetType added in v1.7.0 

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

func (*RpbCoverageReq) GetUnavailableCover added in v1.7.0 

func (m *RpbCoverageReq) GetUnavailableCover() [][]byte

func (*RpbCoverageReq) ProtoMessage added in v1.7.0 

func (*RpbCoverageReq) ProtoMessage()

func (*RpbCoverageReq) Reset added in v1.7.0 

func (m *RpbCoverageReq) Reset()

func (*RpbCoverageReq) String added in v1.7.0 

func (m *RpbCoverageReq) String() string

type RpbCoverageResp added in v1.7.0 

type RpbCoverageResp struct {
	Entries          []*RpbCoverageEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

Segmented coverage plan response

func (*RpbCoverageResp) Descriptor added in v1.7.0 

func (*RpbCoverageResp) Descriptor() ([]byte, []int)

func (*RpbCoverageResp) GetEntries added in v1.7.0 

func (m *RpbCoverageResp) GetEntries() []*RpbCoverageEntry

func (*RpbCoverageResp) ProtoMessage added in v1.7.0 

func (*RpbCoverageResp) ProtoMessage()

func (*RpbCoverageResp) Reset added in v1.7.0 

func (m *RpbCoverageResp) Reset()

func (*RpbCoverageResp) String added in v1.7.0 

func (m *RpbCoverageResp) String() string

type RpbDelReq 

type RpbDelReq struct {
	Bucket           []byte  `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Key              []byte  `protobuf:"bytes,2,req,name=key" json:"key,omitempty"`
	Rw               *uint32 `protobuf:"varint,3,opt,name=rw" json:"rw,omitempty"`
	Vclock           []byte  `protobuf:"bytes,4,opt,name=vclock" json:"vclock,omitempty"`
	R                *uint32 `protobuf:"varint,5,opt,name=r" json:"r,omitempty"`
	W                *uint32 `protobuf:"varint,6,opt,name=w" json:"w,omitempty"`
	Pr               *uint32 `protobuf:"varint,7,opt,name=pr" json:"pr,omitempty"`
	Pw               *uint32 `protobuf:"varint,8,opt,name=pw" json:"pw,omitempty"`
	Dw               *uint32 `protobuf:"varint,9,opt,name=dw" json:"dw,omitempty"`
	Timeout          *uint32 `protobuf:"varint,10,opt,name=timeout" json:"timeout,omitempty"`
	SloppyQuorum     *bool   `protobuf:"varint,11,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"`
	NVal             *uint32 `protobuf:"varint,12,opt,name=n_val" json:"n_val,omitempty"`
	Type             []byte  `protobuf:"bytes,13,opt,name=type" json:"type,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Delete request

func (*RpbDelReq) BucketIsRequired 

func (m *RpbDelReq) BucketIsRequired() bool

func (*RpbDelReq) Descriptor added in v1.7.0 

func (*RpbDelReq) Descriptor() ([]byte, []int)

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

func (m *RpbDelReq) KeyIsRequired() bool

func (*RpbDelReq) ProtoMessage 

func (*RpbDelReq) ProtoMessage()

func (*RpbDelReq) Reset 

func (m *RpbDelReq) Reset()

func (*RpbDelReq) SetType 

func (m *RpbDelReq) SetType(bt []byte)

func (*RpbDelReq) String 

func (m *RpbDelReq) String() string

type RpbGetBucketKeyPreflistReq 

type RpbGetBucketKeyPreflistReq struct {
	Bucket           []byte `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Key              []byte `protobuf:"bytes,2,req,name=key" json:"key,omitempty"`
	Type             []byte `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Get bucket-key preflist request

func (*RpbGetBucketKeyPreflistReq) BucketIsRequired 

func (m *RpbGetBucketKeyPreflistReq) BucketIsRequired() bool

func (*RpbGetBucketKeyPreflistReq) Descriptor added in v1.7.0 

func (*RpbGetBucketKeyPreflistReq) Descriptor() ([]byte, []int)

func (*RpbGetBucketKeyPreflistReq) GetBucket 

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

func (*RpbGetBucketKeyPreflistReq) GetKey 

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

func (*RpbGetBucketKeyPreflistReq) GetType 

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

func (*RpbGetBucketKeyPreflistReq) KeyIsRequired 

func (m *RpbGetBucketKeyPreflistReq) KeyIsRequired() bool

func (*RpbGetBucketKeyPreflistReq) ProtoMessage 

func (*RpbGetBucketKeyPreflistReq) ProtoMessage()

func (*RpbGetBucketKeyPreflistReq) Reset 

func (m *RpbGetBucketKeyPreflistReq) Reset()

func (*RpbGetBucketKeyPreflistReq) SetType 

func (m *RpbGetBucketKeyPreflistReq) SetType(bt []byte)

func (*RpbGetBucketKeyPreflistReq) String 

func (m *RpbGetBucketKeyPreflistReq) String() string

type RpbGetBucketKeyPreflistResp 

type RpbGetBucketKeyPreflistResp struct {
	Preflist         []*RpbBucketKeyPreflistItem `protobuf:"bytes,1,rep,name=preflist" json:"preflist,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

Get bucket-key preflist response

func (*RpbGetBucketKeyPreflistResp) Descriptor added in v1.7.0 

func (*RpbGetBucketKeyPreflistResp) Descriptor() ([]byte, []int)

func (*RpbGetBucketKeyPreflistResp) GetPreflist 

func (m *RpbGetBucketKeyPreflistResp) GetPreflist() []*RpbBucketKeyPreflistItem

func (*RpbGetBucketKeyPreflistResp) ProtoMessage 

func (*RpbGetBucketKeyPreflistResp) ProtoMessage()

func (*RpbGetBucketKeyPreflistResp) Reset 

func (m *RpbGetBucketKeyPreflistResp) Reset()

func (*RpbGetBucketKeyPreflistResp) String 

func (m *RpbGetBucketKeyPreflistResp) String() string

type RpbGetClientIdResp 

type RpbGetClientIdResp struct {
	ClientId         []byte `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Get ClientId Request - no message defined, just send RpbGetClientIdReq message code

func (*RpbGetClientIdResp) Descriptor added in v1.7.0 

func (*RpbGetClientIdResp) Descriptor() ([]byte, []int)

func (*RpbGetClientIdResp) GetClientId 

func (m *RpbGetClientIdResp) GetClientId() []byte

func (*RpbGetClientIdResp) ProtoMessage 

func (*RpbGetClientIdResp) ProtoMessage()

func (*RpbGetClientIdResp) Reset 

func (m *RpbGetClientIdResp) Reset()

func (*RpbGetClientIdResp) String 

func (m *RpbGetClientIdResp) String() string

type RpbGetReq 

type RpbGetReq struct {
	Bucket           []byte  `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Key              []byte  `protobuf:"bytes,2,req,name=key" json:"key,omitempty"`
	R                *uint32 `protobuf:"varint,3,opt,name=r" json:"r,omitempty"`
	Pr               *uint32 `protobuf:"varint,4,opt,name=pr" json:"pr,omitempty"`
	BasicQuorum      *bool   `protobuf:"varint,5,opt,name=basic_quorum" json:"basic_quorum,omitempty"`
	NotfoundOk       *bool   `protobuf:"varint,6,opt,name=notfound_ok" json:"notfound_ok,omitempty"`
	IfModified       []byte  `protobuf:"bytes,7,opt,name=if_modified" json:"if_modified,omitempty"`
	Head             *bool   `protobuf:"varint,8,opt,name=head" json:"head,omitempty"`
	Deletedvclock    *bool   `protobuf:"varint,9,opt,name=deletedvclock" json:"deletedvclock,omitempty"`
	Timeout          *uint32 `protobuf:"varint,10,opt,name=timeout" json:"timeout,omitempty"`
	SloppyQuorum     *bool   `protobuf:"varint,11,opt,name=sloppy_quorum" json:"sloppy_quorum,omitempty"`
	NVal             *uint32 `protobuf:"varint,12,opt,name=n_val" json:"n_val,omitempty"`
	Type             []byte  `protobuf:"bytes,13,opt,name=type" json:"type,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Get Request - retrieve bucket/key

func (*RpbGetReq) BucketIsRequired 

func (m *RpbGetReq) BucketIsRequired() bool

func (*RpbGetReq) Descriptor added in v1.7.0 

func (*RpbGetReq) Descriptor() ([]byte, []int)

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

func (m *RpbGetReq) KeyIsRequired() bool

func (*RpbGetReq) ProtoMessage 

func (*RpbGetReq) ProtoMessage()

func (*RpbGetReq) Reset 

func (m *RpbGetReq) Reset()

func (*RpbGetReq) SetType 

func (m *RpbGetReq) SetType(bt []byte)

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) Descriptor added in v1.7.0 

func (*RpbGetResp) Descriptor() ([]byte, []int)

func (*RpbGetResp) GetContent 

func (m *RpbGetResp) GetContent() []*RpbContent

func (*RpbGetResp) GetUnchanged 

func (m *RpbGetResp) GetUnchanged() bool

func (*RpbGetResp) GetVclock 

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

func (*RpbGetResp) ProtoMessage 

func (*RpbGetResp) ProtoMessage()

func (*RpbGetResp) Reset 

func (m *RpbGetResp) Reset()

func (*RpbGetResp) String 

func (m *RpbGetResp) String() string

type RpbIndexBodyResp added in v1.7.0 

type RpbIndexBodyResp struct {
	Objects          []*RpbIndexObject `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"`
	Continuation     []byte            `protobuf:"bytes,2,opt,name=continuation" json:"continuation,omitempty"`
	Done             *bool             `protobuf:"varint,3,opt,name=done" json:"done,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

Stolen from CS bucket response, to be used when return_body=true

func (*RpbIndexBodyResp) Descriptor added in v1.7.0 

func (*RpbIndexBodyResp) Descriptor() ([]byte, []int)

func (*RpbIndexBodyResp) GetContinuation added in v1.7.0 

func (m *RpbIndexBodyResp) GetContinuation() []byte

func (*RpbIndexBodyResp) GetDone added in v1.7.0 

func (m *RpbIndexBodyResp) GetDone() bool

func (*RpbIndexBodyResp) GetObjects added in v1.7.0 

func (m *RpbIndexBodyResp) GetObjects() []*RpbIndexObject

func (*RpbIndexBodyResp) ProtoMessage added in v1.7.0 

func (*RpbIndexBodyResp) ProtoMessage()

func (*RpbIndexBodyResp) Reset added in v1.7.0 

func (m *RpbIndexBodyResp) Reset()

func (*RpbIndexBodyResp) String added in v1.7.0 

func (m *RpbIndexBodyResp) String() string

type RpbIndexObject 

type RpbIndexObject struct {
	Key              []byte      `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Object           *RpbGetResp `protobuf:"bytes,2,req,name=object" json:"object,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*RpbIndexObject) Descriptor added in v1.7.0 

func (*RpbIndexObject) Descriptor() ([]byte, []int)

func (*RpbIndexObject) GetKey 

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

func (*RpbIndexObject) GetObject 

func (m *RpbIndexObject) GetObject() *RpbGetResp

func (*RpbIndexObject) ProtoMessage 

func (*RpbIndexObject) ProtoMessage()

func (*RpbIndexObject) Reset 

func (m *RpbIndexObject) Reset()

func (*RpbIndexObject) String 

func (m *RpbIndexObject) String() string

type RpbIndexReq 

type RpbIndexReq struct {
	Bucket       []byte                      `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Index        []byte                      `protobuf:"bytes,2,req,name=index" json:"index,omitempty"`
	Qtype        *RpbIndexReq_IndexQueryType `protobuf:"varint,3,req,name=qtype,enum=RpbIndexReq_IndexQueryType" json:"qtype,omitempty"`
	Key          []byte                      `protobuf:"bytes,4,opt,name=key" json:"key,omitempty"`
	RangeMin     []byte                      `protobuf:"bytes,5,opt,name=range_min" json:"range_min,omitempty"`
	RangeMax     []byte                      `protobuf:"bytes,6,opt,name=range_max" json:"range_max,omitempty"`
	ReturnTerms  *bool                       `protobuf:"varint,7,opt,name=return_terms" json:"return_terms,omitempty"`
	Stream       *bool                       `protobuf:"varint,8,opt,name=stream" json:"stream,omitempty"`
	MaxResults   *uint32                     `protobuf:"varint,9,opt,name=max_results" json:"max_results,omitempty"`
	Continuation []byte                      `protobuf:"bytes,10,opt,name=continuation" json:"continuation,omitempty"`
	Timeout      *uint32                     `protobuf:"varint,11,opt,name=timeout" json:"timeout,omitempty"`
	Type         []byte                      `protobuf:"bytes,12,opt,name=type" json:"type,omitempty"`
	TermRegex    []byte                      `protobuf:"bytes,13,opt,name=term_regex" json:"term_regex,omitempty"`
	// Whether to use pagination sort for non-paginated queries
	PaginationSort *bool `protobuf:"varint,14,opt,name=pagination_sort" json:"pagination_sort,omitempty"`
	// parallel extraction extension
	CoverContext     []byte `protobuf:"bytes,15,opt,name=cover_context" json:"cover_context,omitempty"`
	ReturnBody       *bool  `protobuf:"varint,16,opt,name=return_body" json:"return_body,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Secondary Index query request

func (*RpbIndexReq) BucketIsRequired 

func (m *RpbIndexReq) BucketIsRequired() bool

func (*RpbIndexReq) Descriptor added in v1.7.0 

func (*RpbIndexReq) Descriptor() ([]byte, []int)

func (*RpbIndexReq) GetBucket 

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

func (*RpbIndexReq) GetContinuation 

func (m *RpbIndexReq) GetContinuation() []byte

func (*RpbIndexReq) GetCoverContext added in v1.7.0 

func (m *RpbIndexReq) GetCoverContext() []byte

func (*RpbIndexReq) GetIndex 

func (m *RpbIndexReq) GetIndex() []byte

func (*RpbIndexReq) GetKey 

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

func (*RpbIndexReq) GetMaxResults 

func (m *RpbIndexReq) GetMaxResults() uint32

func (*RpbIndexReq) GetPaginationSort 

func (m *RpbIndexReq) GetPaginationSort() bool

func (*RpbIndexReq) GetQtype 

func (m *RpbIndexReq) GetQtype() RpbIndexReq_IndexQueryType

func (*RpbIndexReq) GetRangeMax 

func (m *RpbIndexReq) GetRangeMax() []byte

func (*RpbIndexReq) GetRangeMin 

func (m *RpbIndexReq) GetRangeMin() []byte

func (*RpbIndexReq) GetReturnBody added in v1.7.0 

func (m *RpbIndexReq) GetReturnBody() bool

func (*RpbIndexReq) GetReturnTerms 

func (m *RpbIndexReq) GetReturnTerms() bool

func (*RpbIndexReq) GetStream 

func (m *RpbIndexReq) GetStream() bool

func (*RpbIndexReq) GetTermRegex 

func (m *RpbIndexReq) GetTermRegex() []byte

func (*RpbIndexReq) GetTimeout 

func (m *RpbIndexReq) GetTimeout() uint32

func (*RpbIndexReq) GetType 

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

func (*RpbIndexReq) KeyIsRequired 

func (m *RpbIndexReq) KeyIsRequired() bool

func (*RpbIndexReq) ProtoMessage 

func (*RpbIndexReq) ProtoMessage()

func (*RpbIndexReq) Reset 

func (m *RpbIndexReq) Reset()

func (*RpbIndexReq) SetType 

func (m *RpbIndexReq) SetType(bt []byte)

func (*RpbIndexReq) String 

func (m *RpbIndexReq) String() string

type RpbIndexReq_IndexQueryType 

type RpbIndexReq_IndexQueryType int32
const (
	RpbIndexReq_eq    RpbIndexReq_IndexQueryType = 0
	RpbIndexReq_range RpbIndexReq_IndexQueryType = 1
)

func (RpbIndexReq_IndexQueryType) Enum 

func (x RpbIndexReq_IndexQueryType) Enum() *RpbIndexReq_IndexQueryType

func (RpbIndexReq_IndexQueryType) EnumDescriptor added in v1.7.0 

func (RpbIndexReq_IndexQueryType) EnumDescriptor() ([]byte, []int)

func (RpbIndexReq_IndexQueryType) String 

func (x RpbIndexReq_IndexQueryType) String() string

func (*RpbIndexReq_IndexQueryType) UnmarshalJSON 

func (x *RpbIndexReq_IndexQueryType) UnmarshalJSON(data []byte) error

type RpbIndexResp 

type RpbIndexResp struct {
	Keys             [][]byte        `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
	Results          []*riak.RpbPair `protobuf:"bytes,2,rep,name=results" json:"results,omitempty"`
	Continuation     []byte          `protobuf:"bytes,3,opt,name=continuation" json:"continuation,omitempty"`
	Done             *bool           `protobuf:"varint,4,opt,name=done" json:"done,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

Secondary Index query response

func (*RpbIndexResp) Descriptor added in v1.7.0 

func (*RpbIndexResp) Descriptor() ([]byte, []int)

func (*RpbIndexResp) GetContinuation 

func (m *RpbIndexResp) GetContinuation() []byte

func (*RpbIndexResp) GetDone 

func (m *RpbIndexResp) GetDone() bool

func (*RpbIndexResp) GetKeys 

func (m *RpbIndexResp) GetKeys() [][]byte

func (*RpbIndexResp) GetResults 

func (m *RpbIndexResp) GetResults() []*riak.RpbPair

func (*RpbIndexResp) ProtoMessage 

func (*RpbIndexResp) ProtoMessage()

func (*RpbIndexResp) Reset 

func (m *RpbIndexResp) Reset()

func (*RpbIndexResp) String 

func (m *RpbIndexResp) String() string
type RpbLink struct {
	Bucket           []byte `protobuf:"bytes,1,opt,name=bucket" json:"bucket,omitempty"`
	Key              []byte `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Tag              []byte `protobuf:"bytes,3,opt,name=tag" json:"tag,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Link metadata

func (*RpbLink) Descriptor added in v1.7.0 

func (*RpbLink) Descriptor() ([]byte, []int)

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

func (m *RpbListBucketsReq) BucketIsRequired() bool

func (*RpbListBucketsReq) Descriptor added in v1.7.0 

func (*RpbListBucketsReq) Descriptor() ([]byte, []int)

func (*RpbListBucketsReq) GetBucket 

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

func (*RpbListBucketsReq) GetKey 

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

func (*RpbListBucketsReq) GetStream 

func (m *RpbListBucketsReq) GetStream() bool

func (*RpbListBucketsReq) GetTimeout 

func (m *RpbListBucketsReq) GetTimeout() uint32

func (*RpbListBucketsReq) GetType 

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

func (*RpbListBucketsReq) KeyIsRequired 

func (m *RpbListBucketsReq) KeyIsRequired() bool

func (*RpbListBucketsReq) ProtoMessage 

func (*RpbListBucketsReq) ProtoMessage()

func (*RpbListBucketsReq) Reset 

func (m *RpbListBucketsReq) Reset()

func (*RpbListBucketsReq) SetType 

func (m *RpbListBucketsReq) SetType(bt []byte)

func (*RpbListBucketsReq) String 

func (m *RpbListBucketsReq) String() string

type RpbListBucketsResp 

type RpbListBucketsResp struct {
	Buckets          [][]byte `protobuf:"bytes,1,rep,name=buckets" json:"buckets,omitempty"`
	Done             *bool    `protobuf:"varint,2,opt,name=done" json:"done,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

List buckets response - one or more of these packets will be sent the last one will have done set true (and may not have any buckets in it)

func (*RpbListBucketsResp) Descriptor added in v1.7.0 

func (*RpbListBucketsResp) Descriptor() ([]byte, []int)

func (*RpbListBucketsResp) GetBuckets 

func (m *RpbListBucketsResp) GetBuckets() [][]byte

func (*RpbListBucketsResp) GetDone 

func (m *RpbListBucketsResp) GetDone() bool

func (*RpbListBucketsResp) ProtoMessage 

func (*RpbListBucketsResp) ProtoMessage()

func (*RpbListBucketsResp) Reset 

func (m *RpbListBucketsResp) Reset()

func (*RpbListBucketsResp) String 

func (m *RpbListBucketsResp) String() string

type RpbListKeysReq 

type RpbListKeysReq struct {
	Bucket           []byte  `protobuf:"bytes,1,req,name=bucket" json:"bucket,omitempty"`
	Timeout          *uint32 `protobuf:"varint,2,opt,name=timeout" json:"timeout,omitempty"`
	Type             []byte  `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

List keys in bucket request

func (*RpbListKeysReq) BucketIsRequired 

func (m *RpbListKeysReq) BucketIsRequired() bool

func (*RpbListKeysReq) Descriptor added in v1.7.0 

func (*RpbListKeysReq) Descriptor() ([]byte, []int)

func (*RpbListKeysReq) GetBucket 

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

func (*RpbListKeysReq) GetKey 

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

func (*RpbListKeysReq) GetTimeout 

func (m *RpbListKeysReq) GetTimeout() uint32

func (*RpbListKeysReq) GetType 

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

func (*RpbListKeysReq) KeyIsRequired 

func (m *RpbListKeysReq) KeyIsRequired() bool

func (*RpbListKeysReq) ProtoMessage 

func (*RpbListKeysReq) ProtoMessage()

func (*RpbListKeysReq) Reset 

func (m *RpbListKeysReq) Reset()

func (*RpbListKeysReq) SetType 

func (m *RpbListKeysReq) SetType(bt []byte)

func (*RpbListKeysReq) String 

func (m *RpbListKeysReq) String() string

type RpbListKeysResp 

type RpbListKeysResp struct {
	Keys             [][]byte `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
	Done             *bool    `protobuf:"varint,2,opt,name=done" json:"done,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

List keys in bucket response - one or more of these packets will be sent the last one will have done set true (and may not have any keys in it)

func (*RpbListKeysResp) Descriptor added in v1.7.0 

func (*RpbListKeysResp) Descriptor() ([]byte, []int)

func (*RpbListKeysResp) GetDone 

func (m *RpbListKeysResp) GetDone() bool

func (*RpbListKeysResp) GetKeys 

func (m *RpbListKeysResp) GetKeys() [][]byte

func (*RpbListKeysResp) ProtoMessage 

func (*RpbListKeysResp) ProtoMessage()

func (*RpbListKeysResp) Reset 

func (m *RpbListKeysResp) Reset()

func (*RpbListKeysResp) String 

func (m *RpbListKeysResp) String() string

type RpbMapRedReq 

type RpbMapRedReq struct {
	Request          []byte `protobuf:"bytes,1,req,name=request" json:"request,omitempty"`
	ContentType      []byte `protobuf:"bytes,2,req,name=content_type" json:"content_type,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Map/Reduce request

func (*RpbMapRedReq) Descriptor added in v1.7.0 

func (*RpbMapRedReq) Descriptor() ([]byte, []int)

func (*RpbMapRedReq) GetContentType 

func (m *RpbMapRedReq) GetContentType() []byte

func (*RpbMapRedReq) GetRequest 

func (m *RpbMapRedReq) GetRequest() []byte

func (*RpbMapRedReq) ProtoMessage 

func (*RpbMapRedReq) ProtoMessage()

func (*RpbMapRedReq) Reset 

func (m *RpbMapRedReq) Reset()

func (*RpbMapRedReq) String 

func (m *RpbMapRedReq) String() string

type RpbMapRedResp 

type RpbMapRedResp struct {
	Phase            *uint32 `protobuf:"varint,1,opt,name=phase" json:"phase,omitempty"`
	Response         []byte  `protobuf:"bytes,2,opt,name=response" json:"response,omitempty"`
	Done             *bool   `protobuf:"varint,3,opt,name=done" json:"done,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Map/Reduce response one or more of these packets will be sent the last one will have done set true (and may not have phase/data in it)

func (*RpbMapRedResp) Descriptor added in v1.7.0 

func (*RpbMapRedResp) Descriptor() ([]byte, []int)

func (*RpbMapRedResp) GetDone 

func (m *RpbMapRedResp) GetDone() bool

func (*RpbMapRedResp) GetPhase 

func (m *RpbMapRedResp) GetPhase() uint32

func (*RpbMapRedResp) GetResponse 

func (m *RpbMapRedResp) GetResponse() []byte

func (*RpbMapRedResp) ProtoMessage 

func (*RpbMapRedResp) ProtoMessage()

func (*RpbMapRedResp) Reset 

func (m *RpbMapRedResp) Reset()

func (*RpbMapRedResp) String 

func (m *RpbMapRedResp) String() string

type RpbPutReq 

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

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

the key will be returned.

func (*RpbPutReq) BucketIsRequired 

func (m *RpbPutReq) BucketIsRequired() bool

func (*RpbPutReq) Descriptor added in v1.7.0 

func (*RpbPutReq) Descriptor() ([]byte, []int)

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

func (m *RpbPutReq) KeyIsRequired() bool

func (*RpbPutReq) ProtoMessage 

func (*RpbPutReq) ProtoMessage()

func (*RpbPutReq) Reset 

func (m *RpbPutReq) Reset()

func (*RpbPutReq) SetType 

func (m *RpbPutReq) SetType(bt []byte)

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) Descriptor added in v1.7.0 

func (*RpbPutResp) Descriptor() ([]byte, []int)

func (*RpbPutResp) GetContent 

func (m *RpbPutResp) GetContent() []*RpbContent

func (*RpbPutResp) GetKey 

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

func (*RpbPutResp) GetVclock 

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

func (*RpbPutResp) ProtoMessage 

func (*RpbPutResp) ProtoMessage()

func (*RpbPutResp) Reset 

func (m *RpbPutResp) Reset()

func (*RpbPutResp) String 

func (m *RpbPutResp) String() string

type RpbSetClientIdReq 

type RpbSetClientIdReq struct {
	ClientId         []byte `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RpbSetClientIdReq) Descriptor added in v1.7.0 

func (*RpbSetClientIdReq) Descriptor() ([]byte, []int)

func (*RpbSetClientIdReq) GetClientId 

func (m *RpbSetClientIdReq) GetClientId() []byte

func (*RpbSetClientIdReq) ProtoMessage 

func (*RpbSetClientIdReq) ProtoMessage()

func (*RpbSetClientIdReq) Reset 

func (m *RpbSetClientIdReq) Reset()

func (*RpbSetClientIdReq) String 

func (m *RpbSetClientIdReq) String() string

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.