protobuf

package
v0.0.0-...-b800c40 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package protobuf is a generated protocol buffer package.

It is generated from these files: 

query.proto

It has these top-level messages: 

Error
TsConsistency
QueryPayload
HeloRequest
HeloResponse
StatisticsRequest
StatisticsResponse
ScanRequest
ScanAllRequest
EndStreamRequest
ResponseStream
StreamEndResponse
CountRequest
CountResponse
Span
Range
CompositeElementFilter
Scan
IndexProjection
IndexEntry
IndexStatistics

Index

Constants

View Source 
const (
	LenOffset  int = 0
	LenSize    int = 4
	FlagOffset int = LenOffset + LenSize
	FlagSize   int = 2
	DataOffset int = FlagOffset + FlagSize
)

Variables

View Source 
var ErrorMissingPayload = errors.New("dataport.missingPlayload")

ErrorMissingPayload

View Source 
var ErrorTransportVersion = errors.New("dataport.transportVersion")

ErrorTransportVersion

Functions

func EncodeAndWrite 

func EncodeAndWrite(conn net.Conn, buf []byte, r interface{}) (err error)

func ProtobufDecode 

func ProtobufDecode(data []byte) (value interface{}, err error)

ProtobufDecode complements ProtobufEncode() API. `data` returned by encode is converted back to protobuf message structure.

func ProtobufEncode 

func ProtobufEncode(payload interface{}) (data []byte, err error)

ProtobufEncode encode payload message into protobuf array of bytes. Return `data` can be transported to the other end and decoded back to Payload message.

func ProtobufEncodeInBuf 

func ProtobufEncodeInBuf(payload interface{}, buf []byte) (data []byte, err error)

func ProtobufVersion 

func ProtobufVersion() byte

ProtobufVersion return version of protobuf schema used in packet transport.

Types

type CompositeElementFilter 

type CompositeElementFilter struct {
	Low              []byte  `protobuf:"bytes,1,opt,name=low" json:"low,omitempty"`
	High             []byte  `protobuf:"bytes,2,opt,name=high" json:"high,omitempty"`
	Inclusion        *uint32 `protobuf:"varint,3,req,name=inclusion" json:"inclusion,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CompositeElementFilter) GetHigh 

func (m *CompositeElementFilter) GetHigh() []byte

func (*CompositeElementFilter) GetInclusion 

func (m *CompositeElementFilter) GetInclusion() uint32

func (*CompositeElementFilter) GetLow 

func (m *CompositeElementFilter) GetLow() []byte

func (*CompositeElementFilter) ProtoMessage 

func (*CompositeElementFilter) ProtoMessage()

func (*CompositeElementFilter) Reset 

func (m *CompositeElementFilter) Reset()

func (*CompositeElementFilter) String 

func (m *CompositeElementFilter) String() string

type CountRequest 

type CountRequest struct {
	DefnID           *uint64        `protobuf:"varint,1,req,name=defnID" json:"defnID,omitempty"`
	Span             *Span          `protobuf:"bytes,2,req,name=span" json:"span,omitempty"`
	Cons             *uint32        `protobuf:"varint,3,req,name=cons" json:"cons,omitempty"`
	Vector           *TsConsistency `protobuf:"bytes,4,opt,name=vector" json:"vector,omitempty"`
	RequestId        *string        `protobuf:"bytes,5,opt,name=requestId" json:"requestId,omitempty"`
	Distinct         *bool          `protobuf:"varint,6,opt,name=distinct" json:"distinct,omitempty"`
	Scans            []*Scan        `protobuf:"bytes,7,rep,name=scans" json:"scans,omitempty"`
	RollbackTime     *int64         `protobuf:"varint,8,opt,name=rollbackTime" json:"rollbackTime,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

Count request to indexer.

func (*CountRequest) GetCons 

func (m *CountRequest) GetCons() uint32

func (*CountRequest) GetDefnID 

func (m *CountRequest) GetDefnID() uint64

func (*CountRequest) GetDistinct 

func (m *CountRequest) GetDistinct() bool

func (*CountRequest) GetRequestId 

func (m *CountRequest) GetRequestId() string

func (*CountRequest) GetRollbackTime 

func (m *CountRequest) GetRollbackTime() int64

func (*CountRequest) GetScans 

func (m *CountRequest) GetScans() []*Scan

func (*CountRequest) GetSpan 

func (m *CountRequest) GetSpan() *Span

func (*CountRequest) GetVector 

func (m *CountRequest) GetVector() *TsConsistency

func (*CountRequest) ProtoMessage 

func (*CountRequest) ProtoMessage()

func (*CountRequest) Reset 

func (m *CountRequest) Reset()

func (*CountRequest) String 

func (m *CountRequest) String() string

type CountResponse 

type CountResponse struct {
	Count            *int64 `protobuf:"varint,1,req,name=count" json:"count,omitempty"`
	Err              *Error `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

total number of entries in index.

func (*CountResponse) GetCount 

func (m *CountResponse) GetCount() int64

func (*CountResponse) GetErr 

func (m *CountResponse) GetErr() *Error

func (*CountResponse) ProtoMessage 

func (*CountResponse) ProtoMessage()

func (*CountResponse) Reset 

func (m *CountResponse) Reset()

func (*CountResponse) String 

func (m *CountResponse) String() string

type EndStreamRequest 

type EndStreamRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

Request by client to stop streaming the query results.

func (*EndStreamRequest) ProtoMessage 

func (*EndStreamRequest) ProtoMessage()

func (*EndStreamRequest) Reset 

func (m *EndStreamRequest) Reset()

func (*EndStreamRequest) String 

func (m *EndStreamRequest) String() string

type Error 

type Error struct {
	Error            *string `protobuf:"bytes,1,req,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Error message can be sent back as response or encapsulated in response packets.

func (*Error) GetError 

func (m *Error) GetError() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

type HeloRequest 

type HeloRequest struct {
	Version          *uint32 `protobuf:"varint,1,req,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Get current server version/capabilities

func (*HeloRequest) GetVersion 

func (m *HeloRequest) GetVersion() uint32

func (*HeloRequest) ProtoMessage 

func (*HeloRequest) ProtoMessage()

func (*HeloRequest) Reset 

func (m *HeloRequest) Reset()

func (*HeloRequest) String 

func (m *HeloRequest) String() string

type HeloResponse 

type HeloResponse struct {
	Version          *uint32 `protobuf:"varint,1,req,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*HeloResponse) GetVersion 

func (m *HeloResponse) GetVersion() uint32

func (*HeloResponse) ProtoMessage 

func (*HeloResponse) ProtoMessage()

func (*HeloResponse) Reset 

func (m *HeloResponse) Reset()

func (*HeloResponse) String 

func (m *HeloResponse) String() string

type IndexEntry 

type IndexEntry struct {
	EntryKey         []byte `protobuf:"bytes,1,opt,name=entryKey" json:"entryKey,omitempty"`
	PrimaryKey       []byte `protobuf:"bytes,2,req,name=primaryKey" json:"primaryKey,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IndexEntry) GetEntryKey 

func (m *IndexEntry) GetEntryKey() []byte

func (*IndexEntry) GetPrimaryKey 

func (m *IndexEntry) GetPrimaryKey() []byte

func (*IndexEntry) ProtoMessage 

func (*IndexEntry) ProtoMessage()

func (*IndexEntry) Reset 

func (m *IndexEntry) Reset()

func (*IndexEntry) String 

func (m *IndexEntry) String() string

type IndexProjection 

type IndexProjection struct {
	EntryKeys        []int64 `protobuf:"varint,1,rep" json:"EntryKeys,omitempty"`
	PrimaryKey       *bool   `protobuf:"varint,2,opt" json:"PrimaryKey,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*IndexProjection) GetEntryKeys 

func (m *IndexProjection) GetEntryKeys() []int64

func (*IndexProjection) GetPrimaryKey 

func (m *IndexProjection) GetPrimaryKey() bool

func (*IndexProjection) ProtoMessage 

func (*IndexProjection) ProtoMessage()

func (*IndexProjection) Reset 

func (m *IndexProjection) Reset()

func (*IndexProjection) String 

func (m *IndexProjection) String() string

type IndexStatistics 

type IndexStatistics struct {
	KeysCount        *uint64 `protobuf:"varint,1,req,name=keysCount" json:"keysCount,omitempty"`
	UniqueKeysCount  *uint64 `protobuf:"varint,2,req,name=uniqueKeysCount" json:"uniqueKeysCount,omitempty"`
	KeyMin           []byte  `protobuf:"bytes,3,req,name=keyMin" json:"keyMin,omitempty"`
	KeyMax           []byte  `protobuf:"bytes,4,req,name=keyMax" json:"keyMax,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Statistics of a given index.

func (*IndexStatistics) Bins 

func (s *IndexStatistics) Bins() ([]c.IndexStatistics, error)

Bins implements common.IndexStatistics{} method.

func (*IndexStatistics) Count 

func (s *IndexStatistics) Count() (int64, error)

Count implements common.IndexStatistics{} method.

func (*IndexStatistics) DistinctCount 

func (s *IndexStatistics) DistinctCount() (int64, error)

DistinctCount implements common.IndexStatistics{} method.

func (*IndexStatistics) GetKeyMax 

func (m *IndexStatistics) GetKeyMax() []byte

func (*IndexStatistics) GetKeyMin 

func (m *IndexStatistics) GetKeyMin() []byte

func (*IndexStatistics) GetKeysCount 

func (m *IndexStatistics) GetKeysCount() uint64

func (*IndexStatistics) GetUniqueKeysCount 

func (m *IndexStatistics) GetUniqueKeysCount() uint64

func (*IndexStatistics) MaxKey 

func (s *IndexStatistics) MaxKey() (c.SecondaryKey, error)

Max implements common.IndexStatistics{} method.

func (*IndexStatistics) MinKey 

func (s *IndexStatistics) MinKey() (c.SecondaryKey, error)

Min implements common.IndexStatistics{} method.

func (*IndexStatistics) ProtoMessage 

func (*IndexStatistics) ProtoMessage()

func (*IndexStatistics) Reset 

func (m *IndexStatistics) Reset()

func (*IndexStatistics) String 

func (m *IndexStatistics) String() string

type QueryPayload 

type QueryPayload struct {
	Version           *uint32             `protobuf:"varint,1,req,name=version" json:"version,omitempty"`
	StatisticsRequest *StatisticsRequest  `protobuf:"bytes,2,opt,name=statisticsRequest" json:"statisticsRequest,omitempty"`
	Statistics        *StatisticsResponse `protobuf:"bytes,3,opt,name=statistics" json:"statistics,omitempty"`
	ScanRequest       *ScanRequest        `protobuf:"bytes,4,opt,name=scanRequest" json:"scanRequest,omitempty"`
	ScanAllRequest    *ScanAllRequest     `protobuf:"bytes,5,opt,name=scanAllRequest" json:"scanAllRequest,omitempty"`
	Stream            *ResponseStream     `protobuf:"bytes,6,opt,name=stream" json:"stream,omitempty"`
	CountRequest      *CountRequest       `protobuf:"bytes,7,opt,name=countRequest" json:"countRequest,omitempty"`
	CountResponse     *CountResponse      `protobuf:"bytes,8,opt,name=countResponse" json:"countResponse,omitempty"`
	EndStream         *EndStreamRequest   `protobuf:"bytes,9,opt,name=endStream" json:"endStream,omitempty"`
	StreamEnd         *StreamEndResponse  `protobuf:"bytes,10,opt,name=streamEnd" json:"streamEnd,omitempty"`
	HeloRequest       *HeloRequest        `protobuf:"bytes,11,opt,name=heloRequest" json:"heloRequest,omitempty"`
	HeloResponse      *HeloResponse       `protobuf:"bytes,12,opt,name=heloResponse" json:"heloResponse,omitempty"`
	XXX_unrecognized  []byte              `json:"-"`
}

Request can be one of the optional field.

func (*QueryPayload) GetCountRequest 

func (m *QueryPayload) GetCountRequest() *CountRequest

func (*QueryPayload) GetCountResponse 

func (m *QueryPayload) GetCountResponse() *CountResponse

func (*QueryPayload) GetEndStream 

func (m *QueryPayload) GetEndStream() *EndStreamRequest

func (*QueryPayload) GetHeloRequest 

func (m *QueryPayload) GetHeloRequest() *HeloRequest

func (*QueryPayload) GetHeloResponse 

func (m *QueryPayload) GetHeloResponse() *HeloResponse

func (*QueryPayload) GetScanAllRequest 

func (m *QueryPayload) GetScanAllRequest() *ScanAllRequest

func (*QueryPayload) GetScanRequest 

func (m *QueryPayload) GetScanRequest() *ScanRequest

func (*QueryPayload) GetStatistics 

func (m *QueryPayload) GetStatistics() *StatisticsResponse

func (*QueryPayload) GetStatisticsRequest 

func (m *QueryPayload) GetStatisticsRequest() *StatisticsRequest

func (*QueryPayload) GetStream 

func (m *QueryPayload) GetStream() *ResponseStream

func (*QueryPayload) GetStreamEnd 

func (m *QueryPayload) GetStreamEnd() *StreamEndResponse

func (*QueryPayload) GetVersion 

func (m *QueryPayload) GetVersion() uint32

func (*QueryPayload) ProtoMessage 

func (*QueryPayload) ProtoMessage()

func (*QueryPayload) Reset 

func (m *QueryPayload) Reset()

func (*QueryPayload) String 

func (m *QueryPayload) String() string

type Range 

type Range struct {
	Low              []byte  `protobuf:"bytes,1,opt,name=low" json:"low,omitempty"`
	High             []byte  `protobuf:"bytes,2,opt,name=high" json:"high,omitempty"`
	Inclusion        *uint32 `protobuf:"varint,3,req,name=inclusion" json:"inclusion,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Range) GetHigh 

func (m *Range) GetHigh() []byte

func (*Range) GetInclusion 

func (m *Range) GetInclusion() uint32

func (*Range) GetLow 

func (m *Range) GetLow() []byte

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) Reset 

func (m *Range) Reset()

func (*Range) String 

func (m *Range) String() string

type ResponseStream 

type ResponseStream struct {
	IndexEntries     []*IndexEntry `protobuf:"bytes,1,rep,name=indexEntries" json:"indexEntries,omitempty"`
	Err              *Error        `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ResponseStream) Error 

func (r *ResponseStream) Error() error

Error implements queryport.client.ResponseReader{} method.

func (*ResponseStream) GetEntries 

func (r *ResponseStream) GetEntries() ([]c.SecondaryKey, [][]byte, error)

GetEntries implements queryport.client.ResponseReader{} method.

func (*ResponseStream) GetErr 

func (m *ResponseStream) GetErr() *Error

func (*ResponseStream) GetIndexEntries 

func (m *ResponseStream) GetIndexEntries() []*IndexEntry

func (*ResponseStream) ProtoMessage 

func (*ResponseStream) ProtoMessage()

func (*ResponseStream) Reset 

func (m *ResponseStream) Reset()

func (*ResponseStream) String 

func (m *ResponseStream) String() string

type Scan 

type Scan struct {
	Filters          []*CompositeElementFilter `protobuf:"bytes,1,rep,name=filters" json:"filters,omitempty"`
	Equals           [][]byte                  `protobuf:"bytes,2,rep,name=equals" json:"equals,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*Scan) GetEquals 

func (m *Scan) GetEquals() [][]byte

func (*Scan) GetFilters 

func (m *Scan) GetFilters() []*CompositeElementFilter

func (*Scan) ProtoMessage 

func (*Scan) ProtoMessage()

func (*Scan) Reset 

func (m *Scan) Reset()

func (*Scan) String 

func (m *Scan) String() string

type ScanAllRequest 

type ScanAllRequest struct {
	DefnID           *uint64        `protobuf:"varint,1,req,name=defnID" json:"defnID,omitempty"`
	Limit            *int64         `protobuf:"varint,2,req,name=limit" json:"limit,omitempty"`
	Cons             *uint32        `protobuf:"varint,3,req,name=cons" json:"cons,omitempty"`
	Vector           *TsConsistency `protobuf:"bytes,4,opt,name=vector" json:"vector,omitempty"`
	RequestId        *string        `protobuf:"bytes,5,opt,name=requestId" json:"requestId,omitempty"`
	RollbackTime     *int64         `protobuf:"varint,6,opt,name=rollbackTime" json:"rollbackTime,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

Full table scan request from indexer.

func (*ScanAllRequest) GetCons 

func (m *ScanAllRequest) GetCons() uint32

func (*ScanAllRequest) GetDefnID 

func (m *ScanAllRequest) GetDefnID() uint64

func (*ScanAllRequest) GetLimit 

func (m *ScanAllRequest) GetLimit() int64

func (*ScanAllRequest) GetRequestId 

func (m *ScanAllRequest) GetRequestId() string

func (*ScanAllRequest) GetRollbackTime 

func (m *ScanAllRequest) GetRollbackTime() int64

func (*ScanAllRequest) GetVector 

func (m *ScanAllRequest) GetVector() *TsConsistency

func (*ScanAllRequest) ProtoMessage 

func (*ScanAllRequest) ProtoMessage()

func (*ScanAllRequest) Reset 

func (m *ScanAllRequest) Reset()

func (*ScanAllRequest) String 

func (m *ScanAllRequest) String() string

type ScanRequest 

type ScanRequest struct {
	DefnID           *uint64          `protobuf:"varint,1,req,name=defnID" json:"defnID,omitempty"`
	Span             *Span            `protobuf:"bytes,2,req,name=span" json:"span,omitempty"`
	Distinct         *bool            `protobuf:"varint,3,req,name=distinct" json:"distinct,omitempty"`
	Limit            *int64           `protobuf:"varint,4,req,name=limit" json:"limit,omitempty"`
	Cons             *uint32          `protobuf:"varint,5,req,name=cons" json:"cons,omitempty"`
	Vector           *TsConsistency   `protobuf:"bytes,6,opt,name=vector" json:"vector,omitempty"`
	RequestId        *string          `protobuf:"bytes,7,opt,name=requestId" json:"requestId,omitempty"`
	Scans            []*Scan          `protobuf:"bytes,8,rep,name=scans" json:"scans,omitempty"`
	Indexprojection  *IndexProjection `protobuf:"bytes,9,opt,name=indexprojection" json:"indexprojection,omitempty"`
	Reverse          *bool            `protobuf:"varint,10,opt,name=reverse" json:"reverse,omitempty"`
	Offset           *int64           `protobuf:"varint,11,opt,name=offset" json:"offset,omitempty"`
	RollbackTime     *int64           `protobuf:"varint,12,opt,name=rollbackTime" json:"rollbackTime,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

Scan request to indexer.

func (*ScanRequest) GetCons 

func (m *ScanRequest) GetCons() uint32

func (*ScanRequest) GetDefnID 

func (m *ScanRequest) GetDefnID() uint64

func (*ScanRequest) GetDistinct 

func (m *ScanRequest) GetDistinct() bool

func (*ScanRequest) GetIndexprojection 

func (m *ScanRequest) GetIndexprojection() *IndexProjection

func (*ScanRequest) GetLimit 

func (m *ScanRequest) GetLimit() int64

func (*ScanRequest) GetOffset 

func (m *ScanRequest) GetOffset() int64

func (*ScanRequest) GetRequestId 

func (m *ScanRequest) GetRequestId() string

func (*ScanRequest) GetReverse 

func (m *ScanRequest) GetReverse() bool

func (*ScanRequest) GetRollbackTime 

func (m *ScanRequest) GetRollbackTime() int64

func (*ScanRequest) GetScans 

func (m *ScanRequest) GetScans() []*Scan

func (*ScanRequest) GetSpan 

func (m *ScanRequest) GetSpan() *Span

func (*ScanRequest) GetVector 

func (m *ScanRequest) GetVector() *TsConsistency

func (*ScanRequest) ProtoMessage 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) Reset 

func (m *ScanRequest) Reset()

func (*ScanRequest) String 

func (m *ScanRequest) String() string

type Span 

type Span struct {
	Range            *Range   `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
	Equals           [][]byte `protobuf:"bytes,2,rep,name=equals" json:"equals,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Span) GetEquals 

func (m *Span) GetEquals() [][]byte

func (*Span) GetRange 

func (m *Span) GetRange() *Range

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) Reset 

func (m *Span) Reset()

func (*Span) String 

func (m *Span) String() string

type StatisticsRequest 

type StatisticsRequest struct {
	DefnID           *uint64 `protobuf:"varint,1,req,name=defnID" json:"defnID,omitempty"`
	Span             *Span   `protobuf:"bytes,2,req,name=span" json:"span,omitempty"`
	RequestId        *string `protobuf:"bytes,3,opt,name=requestId" json:"requestId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Get Index statistics. StatisticsResponse is returned back from indexer.

func (*StatisticsRequest) GetDefnID 

func (m *StatisticsRequest) GetDefnID() uint64

func (*StatisticsRequest) GetRequestId 

func (m *StatisticsRequest) GetRequestId() string

func (*StatisticsRequest) GetSpan 

func (m *StatisticsRequest) GetSpan() *Span

func (*StatisticsRequest) ProtoMessage 

func (*StatisticsRequest) ProtoMessage()

func (*StatisticsRequest) Reset 

func (m *StatisticsRequest) Reset()

func (*StatisticsRequest) String 

func (m *StatisticsRequest) String() string

type StatisticsResponse 

type StatisticsResponse struct {
	Stats            *IndexStatistics `protobuf:"bytes,1,req,name=stats" json:"stats,omitempty"`
	Err              *Error           `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*StatisticsResponse) GetErr 

func (m *StatisticsResponse) GetErr() *Error

func (*StatisticsResponse) GetStats 

func (m *StatisticsResponse) GetStats() *IndexStatistics

func (*StatisticsResponse) ProtoMessage 

func (*StatisticsResponse) ProtoMessage()

func (*StatisticsResponse) Reset 

func (m *StatisticsResponse) Reset()

func (*StatisticsResponse) String 

func (m *StatisticsResponse) String() string

type StreamEndResponse 

type StreamEndResponse struct {
	Err              *Error `protobuf:"bytes,1,opt,name=err" json:"err,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Last response packet sent by server to end query results.

func (*StreamEndResponse) Error 

func (r *StreamEndResponse) Error() error

Error implements queryport.client.ResponseReader{} method.

func (*StreamEndResponse) GetEntries 

func (r *StreamEndResponse) GetEntries() ([]c.SecondaryKey, [][]byte, error)

GetEntries implements queryport.client.ResponseReader{} method.

func (*StreamEndResponse) GetErr 

func (m *StreamEndResponse) GetErr() *Error

func (*StreamEndResponse) ProtoMessage 

func (*StreamEndResponse) ProtoMessage()

func (*StreamEndResponse) Reset 

func (m *StreamEndResponse) Reset()

func (*StreamEndResponse) String 

func (m *StreamEndResponse) String() string

type TsConsistency 

type TsConsistency struct {
	Vbnos            []uint32 `protobuf:"varint,1,rep,name=vbnos" json:"vbnos,omitempty"`
	Seqnos           []uint64 `protobuf:"varint,2,rep,name=seqnos" json:"seqnos,omitempty"`
	Vbuuids          []uint64 `protobuf:"varint,3,rep,name=vbuuids" json:"vbuuids,omitempty"`
	Crc64            *uint64  `protobuf:"varint,4,opt,name=crc64" json:"crc64,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

consistency timestamp specifying a subset of vbucket. AnyConsistency, this message is typically ignored. SessionConsistency, {vbnos, seqnos, crc64} are to be considered. QueryConsistency, {vbnos, seqnos, vbuuids} are to be considered.

func NewTsConsistency 

func NewTsConsistency(
	vbnos []uint16, seqnos []uint64, vbuuids []uint64,
	crc64 uint64) *TsConsistency

func (*TsConsistency) GetCrc64 

func (m *TsConsistency) GetCrc64() uint64

func (*TsConsistency) GetSeqnos 

func (m *TsConsistency) GetSeqnos() []uint64

func (*TsConsistency) GetVbnos 

func (m *TsConsistency) GetVbnos() []uint32

func (*TsConsistency) GetVbuuids 

func (m *TsConsistency) GetVbuuids() []uint64

func (*TsConsistency) ProtoMessage 

func (*TsConsistency) ProtoMessage()

func (*TsConsistency) Reset 

func (m *TsConsistency) Reset()

func (*TsConsistency) String 

func (m *TsConsistency) 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.