Versions in this module Expand all Collapse all v3 v3.35.0 Mar 30, 2023 Changes in this version type FieldOptions + TrackExistence bool + func (m *FieldOptions) GetTrackExistence() bool v3.34.0 Mar 16, 2023 v3.33.0 Mar 2, 2023 v3.32.0 Feb 16, 2023 v3.31.0 Feb 1, 2023 v3.30.0 Feb 1, 2023 v3.29.0 Jan 25, 2023 v3.27.0 Jan 12, 2023 v3.26.0 Dec 12, 2022 Changes in this version + var ErrIntOverflowPrivate = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowPublic = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPrivate = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthPublic = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupPrivate = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupPublic = fmt.Errorf("proto: unexpected end of group") + type ArrowTable struct + Data []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ArrowTable) Descriptor() ([]byte, []int) + func (*ArrowTable) ProtoMessage() + func (m *ArrowTable) GetData() []byte + func (m *ArrowTable) Marshal() (dAtA []byte, err error) + func (m *ArrowTable) MarshalTo(dAtA []byte) (int, error) + func (m *ArrowTable) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ArrowTable) Reset() + func (m *ArrowTable) Size() (n int) + func (m *ArrowTable) String() string + func (m *ArrowTable) Unmarshal(dAtA []byte) error + func (m *ArrowTable) XXX_DiscardUnknown() + func (m *ArrowTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArrowTable) XXX_Merge(src proto.Message) + func (m *ArrowTable) XXX_Size() int + func (m *ArrowTable) XXX_Unmarshal(b []byte) error + type AtomicImportResponse struct + Error string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AtomicImportResponse) Descriptor() ([]byte, []int) + func (*AtomicImportResponse) ProtoMessage() + func (m *AtomicImportResponse) GetError() string + func (m *AtomicImportResponse) Marshal() (dAtA []byte, err error) + func (m *AtomicImportResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AtomicImportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AtomicImportResponse) Reset() + func (m *AtomicImportResponse) Size() (n int) + func (m *AtomicImportResponse) String() string + func (m *AtomicImportResponse) Unmarshal(dAtA []byte) error + func (m *AtomicImportResponse) XXX_DiscardUnknown() + func (m *AtomicImportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AtomicImportResponse) XXX_Merge(src proto.Message) + func (m *AtomicImportResponse) XXX_Size() int + func (m *AtomicImportResponse) XXX_Unmarshal(b []byte) error + type AtomicRecord struct + Index string + Ir []*ImportRequest + Ivr []*ImportValueRequest + Shard uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AtomicRecord) Descriptor() ([]byte, []int) + func (*AtomicRecord) ProtoMessage() + func (m *AtomicRecord) GetIndex() string + func (m *AtomicRecord) GetIr() []*ImportRequest + func (m *AtomicRecord) GetIvr() []*ImportValueRequest + func (m *AtomicRecord) GetShard() uint64 + func (m *AtomicRecord) Marshal() (dAtA []byte, err error) + func (m *AtomicRecord) MarshalTo(dAtA []byte) (int, error) + func (m *AtomicRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AtomicRecord) Reset() + func (m *AtomicRecord) Size() (n int) + func (m *AtomicRecord) String() string + func (m *AtomicRecord) Unmarshal(dAtA []byte) error + func (m *AtomicRecord) XXX_DiscardUnknown() + func (m *AtomicRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AtomicRecord) XXX_Merge(src proto.Message) + func (m *AtomicRecord) XXX_Size() int + func (m *AtomicRecord) XXX_Unmarshal(b []byte) error + type BSIGroup struct + Max int64 + Min int64 + Name string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BSIGroup) Descriptor() ([]byte, []int) + func (*BSIGroup) ProtoMessage() + func (m *BSIGroup) GetMax() int64 + func (m *BSIGroup) GetMin() int64 + func (m *BSIGroup) GetName() string + func (m *BSIGroup) GetType() string + func (m *BSIGroup) Marshal() (dAtA []byte, err error) + func (m *BSIGroup) MarshalTo(dAtA []byte) (int, error) + func (m *BSIGroup) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BSIGroup) Reset() + func (m *BSIGroup) Size() (n int) + func (m *BSIGroup) String() string + func (m *BSIGroup) Unmarshal(dAtA []byte) error + func (m *BSIGroup) XXX_DiscardUnknown() + func (m *BSIGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BSIGroup) XXX_Merge(src proto.Message) + func (m *BSIGroup) XXX_Size() int + func (m *BSIGroup) XXX_Unmarshal(b []byte) error + type BlockDataRequest struct + Block uint64 + Field string + Index string + Shard uint64 + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BlockDataRequest) Descriptor() ([]byte, []int) + func (*BlockDataRequest) ProtoMessage() + func (m *BlockDataRequest) GetBlock() uint64 + func (m *BlockDataRequest) GetField() string + func (m *BlockDataRequest) GetIndex() string + func (m *BlockDataRequest) GetShard() uint64 + func (m *BlockDataRequest) GetView() string + func (m *BlockDataRequest) Marshal() (dAtA []byte, err error) + func (m *BlockDataRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BlockDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BlockDataRequest) Reset() + func (m *BlockDataRequest) Size() (n int) + func (m *BlockDataRequest) String() string + func (m *BlockDataRequest) Unmarshal(dAtA []byte) error + func (m *BlockDataRequest) XXX_DiscardUnknown() + func (m *BlockDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockDataRequest) XXX_Merge(src proto.Message) + func (m *BlockDataRequest) XXX_Size() int + func (m *BlockDataRequest) XXX_Unmarshal(b []byte) error + type BlockDataResponse struct + ColumnIDs []uint64 + RowIDs []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BlockDataResponse) Descriptor() ([]byte, []int) + func (*BlockDataResponse) ProtoMessage() + func (m *BlockDataResponse) GetColumnIDs() []uint64 + func (m *BlockDataResponse) GetRowIDs() []uint64 + func (m *BlockDataResponse) Marshal() (dAtA []byte, err error) + func (m *BlockDataResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BlockDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BlockDataResponse) Reset() + func (m *BlockDataResponse) Size() (n int) + func (m *BlockDataResponse) String() string + func (m *BlockDataResponse) Unmarshal(dAtA []byte) error + func (m *BlockDataResponse) XXX_DiscardUnknown() + func (m *BlockDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockDataResponse) XXX_Merge(src proto.Message) + func (m *BlockDataResponse) XXX_Size() int + func (m *BlockDataResponse) XXX_Unmarshal(b []byte) error + type Cache struct + IDs []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Cache) Descriptor() ([]byte, []int) + func (*Cache) ProtoMessage() + func (m *Cache) GetIDs() []uint64 + func (m *Cache) Marshal() (dAtA []byte, err error) + func (m *Cache) MarshalTo(dAtA []byte) (int, error) + func (m *Cache) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Cache) Reset() + func (m *Cache) Size() (n int) + func (m *Cache) String() string + func (m *Cache) Unmarshal(dAtA []byte) error + func (m *Cache) XXX_DiscardUnknown() + func (m *Cache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cache) XXX_Merge(src proto.Message) + func (m *Cache) XXX_Size() int + func (m *Cache) XXX_Unmarshal(b []byte) error + type ClusterStatus struct + ClusterID string + Nodes []*Node + Schema *Schema + State string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterStatus) Descriptor() ([]byte, []int) + func (*ClusterStatus) ProtoMessage() + func (m *ClusterStatus) GetClusterID() string + func (m *ClusterStatus) GetNodes() []*Node + func (m *ClusterStatus) GetSchema() *Schema + func (m *ClusterStatus) GetState() string + func (m *ClusterStatus) Marshal() (dAtA []byte, err error) + func (m *ClusterStatus) MarshalTo(dAtA []byte) (int, error) + func (m *ClusterStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClusterStatus) Reset() + func (m *ClusterStatus) Size() (n int) + func (m *ClusterStatus) String() string + func (m *ClusterStatus) Unmarshal(dAtA []byte) error + func (m *ClusterStatus) XXX_DiscardUnknown() + func (m *ClusterStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterStatus) XXX_Merge(src proto.Message) + func (m *ClusterStatus) XXX_Size() int + func (m *ClusterStatus) XXX_Unmarshal(b []byte) error + type CreateFieldMessage struct + CreatedAt int64 + Field string + Index string + Meta *FieldOptions + Owner string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateFieldMessage) Descriptor() ([]byte, []int) + func (*CreateFieldMessage) ProtoMessage() + func (m *CreateFieldMessage) GetCreatedAt() int64 + func (m *CreateFieldMessage) GetField() string + func (m *CreateFieldMessage) GetIndex() string + func (m *CreateFieldMessage) GetMeta() *FieldOptions + func (m *CreateFieldMessage) GetOwner() string + func (m *CreateFieldMessage) Marshal() (dAtA []byte, err error) + func (m *CreateFieldMessage) MarshalTo(dAtA []byte) (int, error) + func (m *CreateFieldMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateFieldMessage) Reset() + func (m *CreateFieldMessage) Size() (n int) + func (m *CreateFieldMessage) String() string + func (m *CreateFieldMessage) Unmarshal(dAtA []byte) error + func (m *CreateFieldMessage) XXX_DiscardUnknown() + func (m *CreateFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateFieldMessage) XXX_Merge(src proto.Message) + func (m *CreateFieldMessage) XXX_Size() int + func (m *CreateFieldMessage) XXX_Unmarshal(b []byte) error + type CreateIndexMessage struct + CreatedAt int64 + Index string + Meta *IndexMeta + Owner string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateIndexMessage) Descriptor() ([]byte, []int) + func (*CreateIndexMessage) ProtoMessage() + func (m *CreateIndexMessage) GetCreatedAt() int64 + func (m *CreateIndexMessage) GetIndex() string + func (m *CreateIndexMessage) GetMeta() *IndexMeta + func (m *CreateIndexMessage) GetOwner() string + func (m *CreateIndexMessage) Marshal() (dAtA []byte, err error) + func (m *CreateIndexMessage) MarshalTo(dAtA []byte) (int, error) + func (m *CreateIndexMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateIndexMessage) Reset() + func (m *CreateIndexMessage) Size() (n int) + func (m *CreateIndexMessage) String() string + func (m *CreateIndexMessage) Unmarshal(dAtA []byte) error + func (m *CreateIndexMessage) XXX_DiscardUnknown() + func (m *CreateIndexMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateIndexMessage) XXX_Merge(src proto.Message) + func (m *CreateIndexMessage) XXX_Size() int + func (m *CreateIndexMessage) XXX_Unmarshal(b []byte) error + type CreateShardMessage struct + Field string + Index string + Shard uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateShardMessage) Descriptor() ([]byte, []int) + func (*CreateShardMessage) ProtoMessage() + func (m *CreateShardMessage) GetField() string + func (m *CreateShardMessage) GetIndex() string + func (m *CreateShardMessage) GetShard() uint64 + func (m *CreateShardMessage) Marshal() (dAtA []byte, err error) + func (m *CreateShardMessage) MarshalTo(dAtA []byte) (int, error) + func (m *CreateShardMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateShardMessage) Reset() + func (m *CreateShardMessage) Size() (n int) + func (m *CreateShardMessage) String() string + func (m *CreateShardMessage) Unmarshal(dAtA []byte) error + func (m *CreateShardMessage) XXX_DiscardUnknown() + func (m *CreateShardMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateShardMessage) XXX_Merge(src proto.Message) + func (m *CreateShardMessage) XXX_Size() int + func (m *CreateShardMessage) XXX_Unmarshal(b []byte) error + type CreateViewMessage struct + Field string + Index string + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateViewMessage) Descriptor() ([]byte, []int) + func (*CreateViewMessage) ProtoMessage() + func (m *CreateViewMessage) GetField() string + func (m *CreateViewMessage) GetIndex() string + func (m *CreateViewMessage) GetView() string + func (m *CreateViewMessage) Marshal() (dAtA []byte, err error) + func (m *CreateViewMessage) MarshalTo(dAtA []byte) (int, error) + func (m *CreateViewMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateViewMessage) Reset() + func (m *CreateViewMessage) Size() (n int) + func (m *CreateViewMessage) String() string + func (m *CreateViewMessage) Unmarshal(dAtA []byte) error + func (m *CreateViewMessage) XXX_DiscardUnknown() + func (m *CreateViewMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateViewMessage) XXX_Merge(src proto.Message) + func (m *CreateViewMessage) XXX_Size() int + func (m *CreateViewMessage) XXX_Unmarshal(b []byte) error + type DataFrame struct + Data []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataFrame) Descriptor() ([]byte, []int) + func (*DataFrame) ProtoMessage() + func (m *DataFrame) GetData() []byte + func (m *DataFrame) Marshal() (dAtA []byte, err error) + func (m *DataFrame) MarshalTo(dAtA []byte) (int, error) + func (m *DataFrame) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DataFrame) Reset() + func (m *DataFrame) Size() (n int) + func (m *DataFrame) String() string + func (m *DataFrame) Unmarshal(dAtA []byte) error + func (m *DataFrame) XXX_DiscardUnknown() + func (m *DataFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataFrame) XXX_Merge(src proto.Message) + func (m *DataFrame) XXX_Size() int + func (m *DataFrame) XXX_Unmarshal(b []byte) error + type Decimal struct + NewVersion bool + Scale int64 + ValAbs []byte + ValNeg bool + Value int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Decimal) Descriptor() ([]byte, []int) + func (*Decimal) ProtoMessage() + func (m *Decimal) GetNewVersion() bool + func (m *Decimal) GetScale() int64 + func (m *Decimal) GetValAbs() []byte + func (m *Decimal) GetValNeg() bool + func (m *Decimal) GetValue() int64 + func (m *Decimal) Marshal() (dAtA []byte, err error) + func (m *Decimal) MarshalTo(dAtA []byte) (int, error) + func (m *Decimal) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Decimal) Reset() + func (m *Decimal) Size() (n int) + func (m *Decimal) String() string + func (m *Decimal) Unmarshal(dAtA []byte) error + func (m *Decimal) XXX_DiscardUnknown() + func (m *Decimal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Decimal) XXX_Merge(src proto.Message) + func (m *Decimal) XXX_Size() int + func (m *Decimal) XXX_Unmarshal(b []byte) error + type Decoder struct + func NewDecoder(r io.Reader) *Decoder + func (dec *Decoder) Decode(pb proto.Message) error + type DeleteAvailableShardMessage struct + Field string + Index string + ShardID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteAvailableShardMessage) Descriptor() ([]byte, []int) + func (*DeleteAvailableShardMessage) ProtoMessage() + func (m *DeleteAvailableShardMessage) GetField() string + func (m *DeleteAvailableShardMessage) GetIndex() string + func (m *DeleteAvailableShardMessage) GetShardID() uint64 + func (m *DeleteAvailableShardMessage) Marshal() (dAtA []byte, err error) + func (m *DeleteAvailableShardMessage) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteAvailableShardMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteAvailableShardMessage) Reset() + func (m *DeleteAvailableShardMessage) Size() (n int) + func (m *DeleteAvailableShardMessage) String() string + func (m *DeleteAvailableShardMessage) Unmarshal(dAtA []byte) error + func (m *DeleteAvailableShardMessage) XXX_DiscardUnknown() + func (m *DeleteAvailableShardMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteAvailableShardMessage) XXX_Merge(src proto.Message) + func (m *DeleteAvailableShardMessage) XXX_Size() int + func (m *DeleteAvailableShardMessage) XXX_Unmarshal(b []byte) error + type DeleteDataframeMessage struct + Index string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteDataframeMessage) Descriptor() ([]byte, []int) + func (*DeleteDataframeMessage) ProtoMessage() + func (m *DeleteDataframeMessage) GetIndex() string + func (m *DeleteDataframeMessage) Marshal() (dAtA []byte, err error) + func (m *DeleteDataframeMessage) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteDataframeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteDataframeMessage) Reset() + func (m *DeleteDataframeMessage) Size() (n int) + func (m *DeleteDataframeMessage) String() string + func (m *DeleteDataframeMessage) Unmarshal(dAtA []byte) error + func (m *DeleteDataframeMessage) XXX_DiscardUnknown() + func (m *DeleteDataframeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteDataframeMessage) XXX_Merge(src proto.Message) + func (m *DeleteDataframeMessage) XXX_Size() int + func (m *DeleteDataframeMessage) XXX_Unmarshal(b []byte) error + type DeleteFieldMessage struct + Field string + Index string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteFieldMessage) Descriptor() ([]byte, []int) + func (*DeleteFieldMessage) ProtoMessage() + func (m *DeleteFieldMessage) GetField() string + func (m *DeleteFieldMessage) GetIndex() string + func (m *DeleteFieldMessage) Marshal() (dAtA []byte, err error) + func (m *DeleteFieldMessage) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteFieldMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteFieldMessage) Reset() + func (m *DeleteFieldMessage) Size() (n int) + func (m *DeleteFieldMessage) String() string + func (m *DeleteFieldMessage) Unmarshal(dAtA []byte) error + func (m *DeleteFieldMessage) XXX_DiscardUnknown() + func (m *DeleteFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteFieldMessage) XXX_Merge(src proto.Message) + func (m *DeleteFieldMessage) XXX_Size() int + func (m *DeleteFieldMessage) XXX_Unmarshal(b []byte) error + type DeleteIndexMessage struct + Index string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteIndexMessage) Descriptor() ([]byte, []int) + func (*DeleteIndexMessage) ProtoMessage() + func (m *DeleteIndexMessage) GetIndex() string + func (m *DeleteIndexMessage) Marshal() (dAtA []byte, err error) + func (m *DeleteIndexMessage) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteIndexMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteIndexMessage) Reset() + func (m *DeleteIndexMessage) Size() (n int) + func (m *DeleteIndexMessage) String() string + func (m *DeleteIndexMessage) Unmarshal(dAtA []byte) error + func (m *DeleteIndexMessage) XXX_DiscardUnknown() + func (m *DeleteIndexMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteIndexMessage) XXX_Merge(src proto.Message) + func (m *DeleteIndexMessage) XXX_Size() int + func (m *DeleteIndexMessage) XXX_Unmarshal(b []byte) error + type DeleteViewMessage struct + Field string + Index string + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteViewMessage) Descriptor() ([]byte, []int) + func (*DeleteViewMessage) ProtoMessage() + func (m *DeleteViewMessage) GetField() string + func (m *DeleteViewMessage) GetIndex() string + func (m *DeleteViewMessage) GetView() string + func (m *DeleteViewMessage) Marshal() (dAtA []byte, err error) + func (m *DeleteViewMessage) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteViewMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteViewMessage) Reset() + func (m *DeleteViewMessage) Size() (n int) + func (m *DeleteViewMessage) String() string + func (m *DeleteViewMessage) Unmarshal(dAtA []byte) error + func (m *DeleteViewMessage) XXX_DiscardUnknown() + func (m *DeleteViewMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteViewMessage) XXX_Merge(src proto.Message) + func (m *DeleteViewMessage) XXX_Size() int + func (m *DeleteViewMessage) XXX_Unmarshal(b []byte) error + type DistinctTimestamp struct + Name string + Values []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistinctTimestamp) Descriptor() ([]byte, []int) + func (*DistinctTimestamp) ProtoMessage() + func (m *DistinctTimestamp) GetName() string + func (m *DistinctTimestamp) GetValues() []string + func (m *DistinctTimestamp) Marshal() (dAtA []byte, err error) + func (m *DistinctTimestamp) MarshalTo(dAtA []byte) (int, error) + func (m *DistinctTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DistinctTimestamp) Reset() + func (m *DistinctTimestamp) Size() (n int) + func (m *DistinctTimestamp) String() string + func (m *DistinctTimestamp) Unmarshal(dAtA []byte) error + func (m *DistinctTimestamp) XXX_DiscardUnknown() + func (m *DistinctTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DistinctTimestamp) XXX_Merge(src proto.Message) + func (m *DistinctTimestamp) XXX_Size() int + func (m *DistinctTimestamp) XXX_Unmarshal(b []byte) error + type Encoder struct + func NewEncoder(w io.Writer) *Encoder + func (enc *Encoder) Encode(pb proto.Message) error + type ExtractedIDColumn struct + ID uint64 + Vals []*IDList + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtractedIDColumn) Descriptor() ([]byte, []int) + func (*ExtractedIDColumn) ProtoMessage() + func (m *ExtractedIDColumn) GetID() uint64 + func (m *ExtractedIDColumn) GetVals() []*IDList + func (m *ExtractedIDColumn) Marshal() (dAtA []byte, err error) + func (m *ExtractedIDColumn) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedIDColumn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedIDColumn) Reset() + func (m *ExtractedIDColumn) Size() (n int) + func (m *ExtractedIDColumn) String() string + func (m *ExtractedIDColumn) Unmarshal(dAtA []byte) error + func (m *ExtractedIDColumn) XXX_DiscardUnknown() + func (m *ExtractedIDColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtractedIDColumn) XXX_Merge(src proto.Message) + func (m *ExtractedIDColumn) XXX_Size() int + func (m *ExtractedIDColumn) XXX_Unmarshal(b []byte) error + type ExtractedIDMatrix struct + Columns []*ExtractedIDColumn + Fields []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtractedIDMatrix) Descriptor() ([]byte, []int) + func (*ExtractedIDMatrix) ProtoMessage() + func (m *ExtractedIDMatrix) GetColumns() []*ExtractedIDColumn + func (m *ExtractedIDMatrix) GetFields() []string + func (m *ExtractedIDMatrix) Marshal() (dAtA []byte, err error) + func (m *ExtractedIDMatrix) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedIDMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedIDMatrix) Reset() + func (m *ExtractedIDMatrix) Size() (n int) + func (m *ExtractedIDMatrix) String() string + func (m *ExtractedIDMatrix) Unmarshal(dAtA []byte) error + func (m *ExtractedIDMatrix) XXX_DiscardUnknown() + func (m *ExtractedIDMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtractedIDMatrix) XXX_Merge(src proto.Message) + func (m *ExtractedIDMatrix) XXX_Size() int + func (m *ExtractedIDMatrix) XXX_Unmarshal(b []byte) error + type ExtractedIDMatrixSorted struct + ExtractedIDMatrix *ExtractedIDMatrix + RowKVs []*RowKV + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtractedIDMatrixSorted) Descriptor() ([]byte, []int) + func (*ExtractedIDMatrixSorted) ProtoMessage() + func (m *ExtractedIDMatrixSorted) GetExtractedIDMatrix() *ExtractedIDMatrix + func (m *ExtractedIDMatrixSorted) GetRowKVs() []*RowKV + func (m *ExtractedIDMatrixSorted) Marshal() (dAtA []byte, err error) + func (m *ExtractedIDMatrixSorted) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedIDMatrixSorted) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedIDMatrixSorted) Reset() + func (m *ExtractedIDMatrixSorted) Size() (n int) + func (m *ExtractedIDMatrixSorted) String() string + func (m *ExtractedIDMatrixSorted) Unmarshal(dAtA []byte) error + func (m *ExtractedIDMatrixSorted) XXX_DiscardUnknown() + func (m *ExtractedIDMatrixSorted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtractedIDMatrixSorted) XXX_Merge(src proto.Message) + func (m *ExtractedIDMatrixSorted) XXX_Size() int + func (m *ExtractedIDMatrixSorted) XXX_Unmarshal(b []byte) error + type ExtractedTable struct + Columns []*ExtractedTableColumn + Fields []*ExtractedTableField + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtractedTable) Descriptor() ([]byte, []int) + func (*ExtractedTable) ProtoMessage() + func (m *ExtractedTable) GetColumns() []*ExtractedTableColumn + func (m *ExtractedTable) GetFields() []*ExtractedTableField + func (m *ExtractedTable) Marshal() (dAtA []byte, err error) + func (m *ExtractedTable) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTable) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTable) Reset() + func (m *ExtractedTable) Size() (n int) + func (m *ExtractedTable) String() string + func (m *ExtractedTable) Unmarshal(dAtA []byte) error + func (m *ExtractedTable) XXX_DiscardUnknown() + func (m *ExtractedTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtractedTable) XXX_Merge(src proto.Message) + func (m *ExtractedTable) XXX_Size() int + func (m *ExtractedTable) XXX_Unmarshal(b []byte) error + type ExtractedTableColumn struct + KeyOrID isExtractedTableColumn_KeyOrID + Values []*ExtractedTableValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtractedTableColumn) Descriptor() ([]byte, []int) + func (*ExtractedTableColumn) ProtoMessage() + func (*ExtractedTableColumn) XXX_OneofWrappers() []interface{} + func (m *ExtractedTableColumn) GetID() uint64 + func (m *ExtractedTableColumn) GetKey() string + func (m *ExtractedTableColumn) GetKeyOrID() isExtractedTableColumn_KeyOrID + func (m *ExtractedTableColumn) GetValues() []*ExtractedTableValue + func (m *ExtractedTableColumn) Marshal() (dAtA []byte, err error) + func (m *ExtractedTableColumn) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableColumn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableColumn) Reset() + func (m *ExtractedTableColumn) Size() (n int) + func (m *ExtractedTableColumn) String() string + func (m *ExtractedTableColumn) Unmarshal(dAtA []byte) error + func (m *ExtractedTableColumn) XXX_DiscardUnknown() + func (m *ExtractedTableColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtractedTableColumn) XXX_Merge(src proto.Message) + func (m *ExtractedTableColumn) XXX_Size() int + func (m *ExtractedTableColumn) XXX_Unmarshal(b []byte) error + type ExtractedTableColumn_ID struct + ID uint64 + func (m *ExtractedTableColumn_ID) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableColumn_ID) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableColumn_ID) Size() (n int) + type ExtractedTableColumn_Key struct + Key string + func (m *ExtractedTableColumn_Key) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableColumn_Key) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableColumn_Key) Size() (n int) + type ExtractedTableField struct + Name string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtractedTableField) Descriptor() ([]byte, []int) + func (*ExtractedTableField) ProtoMessage() + func (m *ExtractedTableField) GetName() string + func (m *ExtractedTableField) GetType() string + func (m *ExtractedTableField) Marshal() (dAtA []byte, err error) + func (m *ExtractedTableField) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableField) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableField) Reset() + func (m *ExtractedTableField) Size() (n int) + func (m *ExtractedTableField) String() string + func (m *ExtractedTableField) Unmarshal(dAtA []byte) error + func (m *ExtractedTableField) XXX_DiscardUnknown() + func (m *ExtractedTableField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtractedTableField) XXX_Merge(src proto.Message) + func (m *ExtractedTableField) XXX_Size() int + func (m *ExtractedTableField) XXX_Unmarshal(b []byte) error + type ExtractedTableValue struct + Value isExtractedTableValue_Value + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtractedTableValue) Descriptor() ([]byte, []int) + func (*ExtractedTableValue) ProtoMessage() + func (*ExtractedTableValue) XXX_OneofWrappers() []interface{} + func (m *ExtractedTableValue) GetBSIValue() int64 + func (m *ExtractedTableValue) GetBool() bool + func (m *ExtractedTableValue) GetIDs() *IDList + func (m *ExtractedTableValue) GetKeys() *KeyList + func (m *ExtractedTableValue) GetMutexID() uint64 + func (m *ExtractedTableValue) GetMutexKey() string + func (m *ExtractedTableValue) GetValue() isExtractedTableValue_Value + func (m *ExtractedTableValue) Marshal() (dAtA []byte, err error) + func (m *ExtractedTableValue) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableValue) Reset() + func (m *ExtractedTableValue) Size() (n int) + func (m *ExtractedTableValue) String() string + func (m *ExtractedTableValue) Unmarshal(dAtA []byte) error + func (m *ExtractedTableValue) XXX_DiscardUnknown() + func (m *ExtractedTableValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtractedTableValue) XXX_Merge(src proto.Message) + func (m *ExtractedTableValue) XXX_Size() int + func (m *ExtractedTableValue) XXX_Unmarshal(b []byte) error + type ExtractedTableValue_BSIValue struct + BSIValue int64 + func (m *ExtractedTableValue_BSIValue) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableValue_BSIValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableValue_BSIValue) Size() (n int) + type ExtractedTableValue_Bool struct + Bool bool + func (m *ExtractedTableValue_Bool) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableValue_Bool) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableValue_Bool) Size() (n int) + type ExtractedTableValue_IDs struct + IDs *IDList + func (m *ExtractedTableValue_IDs) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableValue_IDs) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableValue_IDs) Size() (n int) + type ExtractedTableValue_Keys struct + Keys *KeyList + func (m *ExtractedTableValue_Keys) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableValue_Keys) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableValue_Keys) Size() (n int) + type ExtractedTableValue_MutexID struct + MutexID uint64 + func (m *ExtractedTableValue_MutexID) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableValue_MutexID) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableValue_MutexID) Size() (n int) + type ExtractedTableValue_MutexKey struct + MutexKey string + func (m *ExtractedTableValue_MutexKey) MarshalTo(dAtA []byte) (int, error) + func (m *ExtractedTableValue_MutexKey) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtractedTableValue_MutexKey) Size() (n int) + type Field struct + CreatedAt int64 + Meta *FieldOptions + Name string + Views []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Field) Descriptor() ([]byte, []int) + func (*Field) ProtoMessage() + func (m *Field) GetCreatedAt() int64 + func (m *Field) GetMeta() *FieldOptions + func (m *Field) GetName() string + func (m *Field) GetViews() []string + func (m *Field) Marshal() (dAtA []byte, err error) + func (m *Field) MarshalTo(dAtA []byte) (int, error) + func (m *Field) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Field) Reset() + func (m *Field) Size() (n int) + func (m *Field) String() string + func (m *Field) Unmarshal(dAtA []byte) error + func (m *Field) XXX_DiscardUnknown() + func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Field) XXX_Merge(src proto.Message) + func (m *Field) XXX_Size() int + func (m *Field) XXX_Unmarshal(b []byte) error + type FieldOperation struct + RecordIDs []uint64 + Signed []int64 + Values []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldOperation) Descriptor() ([]byte, []int) + func (*FieldOperation) ProtoMessage() + func (m *FieldOperation) GetRecordIDs() []uint64 + func (m *FieldOperation) GetSigned() []int64 + func (m *FieldOperation) GetValues() []uint64 + func (m *FieldOperation) Marshal() (dAtA []byte, err error) + func (m *FieldOperation) MarshalTo(dAtA []byte) (int, error) + func (m *FieldOperation) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FieldOperation) Reset() + func (m *FieldOperation) Size() (n int) + func (m *FieldOperation) String() string + func (m *FieldOperation) Unmarshal(dAtA []byte) error + func (m *FieldOperation) XXX_DiscardUnknown() + func (m *FieldOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldOperation) XXX_Merge(src proto.Message) + func (m *FieldOperation) XXX_Size() int + func (m *FieldOperation) XXX_Unmarshal(b []byte) error + type FieldOptions struct + Base int64 + BitDepth uint64 + CacheSize uint32 + CacheType string + ForeignIndex string + Keys bool + Max *Decimal + Min *Decimal + NoStandardView bool + OldMax int64 + OldMin int64 + Scale int64 + TTL string + TimeQuantum string + TimeUnit string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldOptions) Descriptor() ([]byte, []int) + func (*FieldOptions) ProtoMessage() + func (m *FieldOptions) GetBase() int64 + func (m *FieldOptions) GetBitDepth() uint64 + func (m *FieldOptions) GetCacheSize() uint32 + func (m *FieldOptions) GetCacheType() string + func (m *FieldOptions) GetForeignIndex() string + func (m *FieldOptions) GetKeys() bool + func (m *FieldOptions) GetMax() *Decimal + func (m *FieldOptions) GetMin() *Decimal + func (m *FieldOptions) GetNoStandardView() bool + func (m *FieldOptions) GetOldMax() int64 + func (m *FieldOptions) GetOldMin() int64 + func (m *FieldOptions) GetScale() int64 + func (m *FieldOptions) GetTTL() string + func (m *FieldOptions) GetTimeQuantum() string + func (m *FieldOptions) GetTimeUnit() string + func (m *FieldOptions) GetType() string + func (m *FieldOptions) Marshal() (dAtA []byte, err error) + func (m *FieldOptions) MarshalTo(dAtA []byte) (int, error) + func (m *FieldOptions) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FieldOptions) Reset() + func (m *FieldOptions) Size() (n int) + func (m *FieldOptions) String() string + func (m *FieldOptions) Unmarshal(dAtA []byte) error + func (m *FieldOptions) XXX_DiscardUnknown() + func (m *FieldOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldOptions) XXX_Merge(src proto.Message) + func (m *FieldOptions) XXX_Size() int + func (m *FieldOptions) XXX_Unmarshal(b []byte) error + type FieldRow struct + Field string + RowID uint64 + RowKey string + Value *Int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldRow) Descriptor() ([]byte, []int) + func (*FieldRow) ProtoMessage() + func (m *FieldRow) GetField() string + func (m *FieldRow) GetRowID() uint64 + func (m *FieldRow) GetRowKey() string + func (m *FieldRow) GetValue() *Int64 + func (m *FieldRow) Marshal() (dAtA []byte, err error) + func (m *FieldRow) MarshalTo(dAtA []byte) (int, error) + func (m *FieldRow) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FieldRow) Reset() + func (m *FieldRow) Size() (n int) + func (m *FieldRow) String() string + func (m *FieldRow) Unmarshal(dAtA []byte) error + func (m *FieldRow) XXX_DiscardUnknown() + func (m *FieldRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldRow) XXX_Merge(src proto.Message) + func (m *FieldRow) XXX_Size() int + func (m *FieldRow) XXX_Unmarshal(b []byte) error + type FieldStatus struct + AvailableShards []uint64 + CreatedAt int64 + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldStatus) Descriptor() ([]byte, []int) + func (*FieldStatus) ProtoMessage() + func (m *FieldStatus) GetAvailableShards() []uint64 + func (m *FieldStatus) GetCreatedAt() int64 + func (m *FieldStatus) GetName() string + func (m *FieldStatus) Marshal() (dAtA []byte, err error) + func (m *FieldStatus) MarshalTo(dAtA []byte) (int, error) + func (m *FieldStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FieldStatus) Reset() + func (m *FieldStatus) Size() (n int) + func (m *FieldStatus) String() string + func (m *FieldStatus) Unmarshal(dAtA []byte) error + func (m *FieldStatus) XXX_DiscardUnknown() + func (m *FieldStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldStatus) XXX_Merge(src proto.Message) + func (m *FieldStatus) XXX_Size() int + func (m *FieldStatus) XXX_Unmarshal(b []byte) error + type FieldUpdate struct + Option string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldUpdate) Descriptor() ([]byte, []int) + func (*FieldUpdate) ProtoMessage() + func (m *FieldUpdate) GetOption() string + func (m *FieldUpdate) GetValue() string + func (m *FieldUpdate) Marshal() (dAtA []byte, err error) + func (m *FieldUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *FieldUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FieldUpdate) Reset() + func (m *FieldUpdate) Size() (n int) + func (m *FieldUpdate) String() string + func (m *FieldUpdate) Unmarshal(dAtA []byte) error + func (m *FieldUpdate) XXX_DiscardUnknown() + func (m *FieldUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldUpdate) XXX_Merge(src proto.Message) + func (m *FieldUpdate) XXX_Size() int + func (m *FieldUpdate) XXX_Unmarshal(b []byte) error + type GroupCount struct + Agg int64 + Count uint64 + DecimalAgg *Decimal + Group []*FieldRow + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GroupCount) Descriptor() ([]byte, []int) + func (*GroupCount) ProtoMessage() + func (m *GroupCount) GetAgg() int64 + func (m *GroupCount) GetCount() uint64 + func (m *GroupCount) GetDecimalAgg() *Decimal + func (m *GroupCount) GetGroup() []*FieldRow + func (m *GroupCount) Marshal() (dAtA []byte, err error) + func (m *GroupCount) MarshalTo(dAtA []byte) (int, error) + func (m *GroupCount) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GroupCount) Reset() + func (m *GroupCount) Size() (n int) + func (m *GroupCount) String() string + func (m *GroupCount) Unmarshal(dAtA []byte) error + func (m *GroupCount) XXX_DiscardUnknown() + func (m *GroupCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupCount) XXX_Merge(src proto.Message) + func (m *GroupCount) XXX_Size() int + func (m *GroupCount) XXX_Unmarshal(b []byte) error + type GroupCounts struct + Aggregate string + Groups []*GroupCount + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GroupCounts) Descriptor() ([]byte, []int) + func (*GroupCounts) ProtoMessage() + func (m *GroupCounts) GetAggregate() string + func (m *GroupCounts) GetGroups() []*GroupCount + func (m *GroupCounts) Marshal() (dAtA []byte, err error) + func (m *GroupCounts) MarshalTo(dAtA []byte) (int, error) + func (m *GroupCounts) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GroupCounts) Reset() + func (m *GroupCounts) Size() (n int) + func (m *GroupCounts) String() string + func (m *GroupCounts) Unmarshal(dAtA []byte) error + func (m *GroupCounts) XXX_DiscardUnknown() + func (m *GroupCounts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupCounts) XXX_Merge(src proto.Message) + func (m *GroupCounts) XXX_Size() int + func (m *GroupCounts) XXX_Unmarshal(b []byte) error + type IDList struct + IDs []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IDList) Descriptor() ([]byte, []int) + func (*IDList) ProtoMessage() + func (m *IDList) GetIDs() []uint64 + func (m *IDList) Marshal() (dAtA []byte, err error) + func (m *IDList) MarshalTo(dAtA []byte) (int, error) + func (m *IDList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IDList) Reset() + func (m *IDList) Size() (n int) + func (m *IDList) String() string + func (m *IDList) Unmarshal(dAtA []byte) error + func (m *IDList) XXX_DiscardUnknown() + func (m *IDList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IDList) XXX_Merge(src proto.Message) + func (m *IDList) XXX_Size() int + func (m *IDList) XXX_Unmarshal(b []byte) error + type ImportRequest struct + Clear bool + ColumnIDs []uint64 + ColumnKeys []string + Field string + FieldCreatedAt int64 + Index string + IndexCreatedAt int64 + RowIDs []uint64 + RowKeys []string + Shard uint64 + Timestamps []int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportRequest) Descriptor() ([]byte, []int) + func (*ImportRequest) ProtoMessage() + func (m *ImportRequest) GetClear() bool + func (m *ImportRequest) GetColumnIDs() []uint64 + func (m *ImportRequest) GetColumnKeys() []string + func (m *ImportRequest) GetField() string + func (m *ImportRequest) GetFieldCreatedAt() int64 + func (m *ImportRequest) GetIndex() string + func (m *ImportRequest) GetIndexCreatedAt() int64 + func (m *ImportRequest) GetRowIDs() []uint64 + func (m *ImportRequest) GetRowKeys() []string + func (m *ImportRequest) GetShard() uint64 + func (m *ImportRequest) GetTimestamps() []int64 + func (m *ImportRequest) Marshal() (dAtA []byte, err error) + func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ImportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportRequest) Reset() + func (m *ImportRequest) Size() (n int) + func (m *ImportRequest) String() string + func (m *ImportRequest) Unmarshal(dAtA []byte) error + func (m *ImportRequest) XXX_DiscardUnknown() + func (m *ImportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportRequest) XXX_Merge(src proto.Message) + func (m *ImportRequest) XXX_Size() int + func (m *ImportRequest) XXX_Unmarshal(b []byte) error + type ImportResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportResponse) Descriptor() ([]byte, []int) + func (*ImportResponse) ProtoMessage() + func (m *ImportResponse) GetErr() string + func (m *ImportResponse) Marshal() (dAtA []byte, err error) + func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ImportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportResponse) Reset() + func (m *ImportResponse) Size() (n int) + func (m *ImportResponse) String() string + func (m *ImportResponse) Unmarshal(dAtA []byte) error + func (m *ImportResponse) XXX_DiscardUnknown() + func (m *ImportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportResponse) XXX_Merge(src proto.Message) + func (m *ImportResponse) XXX_Size() int + func (m *ImportResponse) XXX_Unmarshal(b []byte) error + type ImportRoaringRequest struct + Action string + Block uint64 + Clear bool + FieldCreatedAt int64 + IndexCreatedAt int64 + UpdateExistence bool + Views []*ImportRoaringRequestView + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportRoaringRequest) Descriptor() ([]byte, []int) + func (*ImportRoaringRequest) ProtoMessage() + func (m *ImportRoaringRequest) GetAction() string + func (m *ImportRoaringRequest) GetBlock() uint64 + func (m *ImportRoaringRequest) GetClear() bool + func (m *ImportRoaringRequest) GetFieldCreatedAt() int64 + func (m *ImportRoaringRequest) GetIndexCreatedAt() int64 + func (m *ImportRoaringRequest) GetUpdateExistence() bool + func (m *ImportRoaringRequest) GetViews() []*ImportRoaringRequestView + func (m *ImportRoaringRequest) Marshal() (dAtA []byte, err error) + func (m *ImportRoaringRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ImportRoaringRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportRoaringRequest) Reset() + func (m *ImportRoaringRequest) Size() (n int) + func (m *ImportRoaringRequest) String() string + func (m *ImportRoaringRequest) Unmarshal(dAtA []byte) error + func (m *ImportRoaringRequest) XXX_DiscardUnknown() + func (m *ImportRoaringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportRoaringRequest) XXX_Merge(src proto.Message) + func (m *ImportRoaringRequest) XXX_Size() int + func (m *ImportRoaringRequest) XXX_Unmarshal(b []byte) error + type ImportRoaringRequestView struct + Data []byte + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportRoaringRequestView) Descriptor() ([]byte, []int) + func (*ImportRoaringRequestView) ProtoMessage() + func (m *ImportRoaringRequestView) GetData() []byte + func (m *ImportRoaringRequestView) GetName() string + func (m *ImportRoaringRequestView) Marshal() (dAtA []byte, err error) + func (m *ImportRoaringRequestView) MarshalTo(dAtA []byte) (int, error) + func (m *ImportRoaringRequestView) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportRoaringRequestView) Reset() + func (m *ImportRoaringRequestView) Size() (n int) + func (m *ImportRoaringRequestView) String() string + func (m *ImportRoaringRequestView) Unmarshal(dAtA []byte) error + func (m *ImportRoaringRequestView) XXX_DiscardUnknown() + func (m *ImportRoaringRequestView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportRoaringRequestView) XXX_Merge(src proto.Message) + func (m *ImportRoaringRequestView) XXX_Size() int + func (m *ImportRoaringRequestView) XXX_Unmarshal(b []byte) error + type ImportRoaringShardRequest struct + Remote bool + Views []*RoaringUpdate + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportRoaringShardRequest) Descriptor() ([]byte, []int) + func (*ImportRoaringShardRequest) ProtoMessage() + func (m *ImportRoaringShardRequest) GetRemote() bool + func (m *ImportRoaringShardRequest) GetViews() []*RoaringUpdate + func (m *ImportRoaringShardRequest) Marshal() (dAtA []byte, err error) + func (m *ImportRoaringShardRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ImportRoaringShardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportRoaringShardRequest) Reset() + func (m *ImportRoaringShardRequest) Size() (n int) + func (m *ImportRoaringShardRequest) String() string + func (m *ImportRoaringShardRequest) Unmarshal(dAtA []byte) error + func (m *ImportRoaringShardRequest) XXX_DiscardUnknown() + func (m *ImportRoaringShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportRoaringShardRequest) XXX_Merge(src proto.Message) + func (m *ImportRoaringShardRequest) XXX_Size() int + func (m *ImportRoaringShardRequest) XXX_Unmarshal(b []byte) error + type ImportValueRequest struct + Clear bool + ColumnIDs []uint64 + ColumnKeys []string + Field string + FieldCreatedAt int64 + FloatValues []float64 + Index string + IndexCreatedAt int64 + Shard uint64 + StringValues []string + Values []int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportValueRequest) Descriptor() ([]byte, []int) + func (*ImportValueRequest) ProtoMessage() + func (m *ImportValueRequest) GetClear() bool + func (m *ImportValueRequest) GetColumnIDs() []uint64 + func (m *ImportValueRequest) GetColumnKeys() []string + func (m *ImportValueRequest) GetField() string + func (m *ImportValueRequest) GetFieldCreatedAt() int64 + func (m *ImportValueRequest) GetFloatValues() []float64 + func (m *ImportValueRequest) GetIndex() string + func (m *ImportValueRequest) GetIndexCreatedAt() int64 + func (m *ImportValueRequest) GetShard() uint64 + func (m *ImportValueRequest) GetStringValues() []string + func (m *ImportValueRequest) GetValues() []int64 + func (m *ImportValueRequest) Marshal() (dAtA []byte, err error) + func (m *ImportValueRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ImportValueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportValueRequest) Reset() + func (m *ImportValueRequest) Size() (n int) + func (m *ImportValueRequest) String() string + func (m *ImportValueRequest) Unmarshal(dAtA []byte) error + func (m *ImportValueRequest) XXX_DiscardUnknown() + func (m *ImportValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportValueRequest) XXX_Merge(src proto.Message) + func (m *ImportValueRequest) XXX_Size() int + func (m *ImportValueRequest) XXX_Unmarshal(b []byte) error + type Index struct + CreatedAt int64 + Fields []*Field + Name string + Options *IndexMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Index) Descriptor() ([]byte, []int) + func (*Index) ProtoMessage() + func (m *Index) GetCreatedAt() int64 + func (m *Index) GetFields() []*Field + func (m *Index) GetName() string + func (m *Index) GetOptions() *IndexMeta + func (m *Index) Marshal() (dAtA []byte, err error) + func (m *Index) MarshalTo(dAtA []byte) (int, error) + func (m *Index) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Index) Reset() + func (m *Index) Size() (n int) + func (m *Index) String() string + func (m *Index) Unmarshal(dAtA []byte) error + func (m *Index) XXX_DiscardUnknown() + func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Index) XXX_Merge(src proto.Message) + func (m *Index) XXX_Size() int + func (m *Index) XXX_Unmarshal(b []byte) error + type IndexMeta struct + Description string + Keys bool + TrackExistence bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexMeta) Descriptor() ([]byte, []int) + func (*IndexMeta) ProtoMessage() + func (m *IndexMeta) GetDescription() string + func (m *IndexMeta) GetKeys() bool + func (m *IndexMeta) GetTrackExistence() bool + func (m *IndexMeta) Marshal() (dAtA []byte, err error) + func (m *IndexMeta) MarshalTo(dAtA []byte) (int, error) + func (m *IndexMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexMeta) Reset() + func (m *IndexMeta) Size() (n int) + func (m *IndexMeta) String() string + func (m *IndexMeta) Unmarshal(dAtA []byte) error + func (m *IndexMeta) XXX_DiscardUnknown() + func (m *IndexMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexMeta) XXX_Merge(src proto.Message) + func (m *IndexMeta) XXX_Size() int + func (m *IndexMeta) XXX_Unmarshal(b []byte) error + type IndexStatus struct + CreatedAt int64 + Fields []*FieldStatus + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexStatus) Descriptor() ([]byte, []int) + func (*IndexStatus) ProtoMessage() + func (m *IndexStatus) GetCreatedAt() int64 + func (m *IndexStatus) GetFields() []*FieldStatus + func (m *IndexStatus) GetName() string + func (m *IndexStatus) Marshal() (dAtA []byte, err error) + func (m *IndexStatus) MarshalTo(dAtA []byte) (int, error) + func (m *IndexStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexStatus) Reset() + func (m *IndexStatus) Size() (n int) + func (m *IndexStatus) String() string + func (m *IndexStatus) Unmarshal(dAtA []byte) error + func (m *IndexStatus) XXX_DiscardUnknown() + func (m *IndexStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexStatus) XXX_Merge(src proto.Message) + func (m *IndexStatus) XXX_Size() int + func (m *IndexStatus) XXX_Unmarshal(b []byte) error + type Int64 struct + Value int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Int64) Descriptor() ([]byte, []int) + func (*Int64) ProtoMessage() + func (m *Int64) GetValue() int64 + func (m *Int64) Marshal() (dAtA []byte, err error) + func (m *Int64) MarshalTo(dAtA []byte) (int, error) + func (m *Int64) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Int64) Reset() + func (m *Int64) Size() (n int) + func (m *Int64) String() string + func (m *Int64) Unmarshal(dAtA []byte) error + func (m *Int64) XXX_DiscardUnknown() + func (m *Int64) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Int64) XXX_Merge(src proto.Message) + func (m *Int64) XXX_Size() int + func (m *Int64) XXX_Unmarshal(b []byte) error + type KeyList struct + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyList) Descriptor() ([]byte, []int) + func (*KeyList) ProtoMessage() + func (m *KeyList) GetKeys() []string + func (m *KeyList) Marshal() (dAtA []byte, err error) + func (m *KeyList) MarshalTo(dAtA []byte) (int, error) + func (m *KeyList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyList) Reset() + func (m *KeyList) Size() (n int) + func (m *KeyList) String() string + func (m *KeyList) Unmarshal(dAtA []byte) error + func (m *KeyList) XXX_DiscardUnknown() + func (m *KeyList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyList) XXX_Merge(src proto.Message) + func (m *KeyList) XXX_Size() int + func (m *KeyList) XXX_Unmarshal(b []byte) error + type LoadSchemaMessage struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadSchemaMessage) Descriptor() ([]byte, []int) + func (*LoadSchemaMessage) ProtoMessage() + func (m *LoadSchemaMessage) Marshal() (dAtA []byte, err error) + func (m *LoadSchemaMessage) MarshalTo(dAtA []byte) (int, error) + func (m *LoadSchemaMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LoadSchemaMessage) Reset() + func (m *LoadSchemaMessage) Size() (n int) + func (m *LoadSchemaMessage) String() string + func (m *LoadSchemaMessage) Unmarshal(dAtA []byte) error + func (m *LoadSchemaMessage) XXX_DiscardUnknown() + func (m *LoadSchemaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadSchemaMessage) XXX_Merge(src proto.Message) + func (m *LoadSchemaMessage) XXX_Size() int + func (m *LoadSchemaMessage) XXX_Unmarshal(b []byte) error + type MaxShards struct + Standard map[string]uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MaxShards) Descriptor() ([]byte, []int) + func (*MaxShards) ProtoMessage() + func (m *MaxShards) GetStandard() map[string]uint64 + func (m *MaxShards) Marshal() (dAtA []byte, err error) + func (m *MaxShards) MarshalTo(dAtA []byte) (int, error) + func (m *MaxShards) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MaxShards) Reset() + func (m *MaxShards) Size() (n int) + func (m *MaxShards) String() string + func (m *MaxShards) Unmarshal(dAtA []byte) error + func (m *MaxShards) XXX_DiscardUnknown() + func (m *MaxShards) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MaxShards) XXX_Merge(src proto.Message) + func (m *MaxShards) XXX_Size() int + func (m *MaxShards) XXX_Unmarshal(b []byte) error + type Node struct + GRPCURI *URI + ID string + IsPrimary bool + State string + URI *URI + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetGRPCURI() *URI + func (m *Node) GetID() string + func (m *Node) GetIsPrimary() bool + func (m *Node) GetState() string + func (m *Node) GetURI() *URI + func (m *Node) Marshal() (dAtA []byte, err error) + func (m *Node) MarshalTo(dAtA []byte) (int, error) + func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Node) Reset() + func (m *Node) Size() (n int) + func (m *Node) String() string + func (m *Node) Unmarshal(dAtA []byte) error + func (m *Node) XXX_DiscardUnknown() + func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Node) XXX_Merge(src proto.Message) + func (m *Node) XXX_Size() int + func (m *Node) XXX_Unmarshal(b []byte) error + type NodeEventMessage struct + Event uint32 + Node *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeEventMessage) Descriptor() ([]byte, []int) + func (*NodeEventMessage) ProtoMessage() + func (m *NodeEventMessage) GetEvent() uint32 + func (m *NodeEventMessage) GetNode() *Node + func (m *NodeEventMessage) Marshal() (dAtA []byte, err error) + func (m *NodeEventMessage) MarshalTo(dAtA []byte) (int, error) + func (m *NodeEventMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NodeEventMessage) Reset() + func (m *NodeEventMessage) Size() (n int) + func (m *NodeEventMessage) String() string + func (m *NodeEventMessage) Unmarshal(dAtA []byte) error + func (m *NodeEventMessage) XXX_DiscardUnknown() + func (m *NodeEventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeEventMessage) XXX_Merge(src proto.Message) + func (m *NodeEventMessage) XXX_Size() int + func (m *NodeEventMessage) XXX_Unmarshal(b []byte) error + type NodeStateMessage struct + NodeID string + State string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeStateMessage) Descriptor() ([]byte, []int) + func (*NodeStateMessage) ProtoMessage() + func (m *NodeStateMessage) GetNodeID() string + func (m *NodeStateMessage) GetState() string + func (m *NodeStateMessage) Marshal() (dAtA []byte, err error) + func (m *NodeStateMessage) MarshalTo(dAtA []byte) (int, error) + func (m *NodeStateMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NodeStateMessage) Reset() + func (m *NodeStateMessage) Size() (n int) + func (m *NodeStateMessage) String() string + func (m *NodeStateMessage) Unmarshal(dAtA []byte) error + func (m *NodeStateMessage) XXX_DiscardUnknown() + func (m *NodeStateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeStateMessage) XXX_Merge(src proto.Message) + func (m *NodeStateMessage) XXX_Size() int + func (m *NodeStateMessage) XXX_Unmarshal(b []byte) error + type NodeStatus struct + Indexes []*IndexStatus + Node *Node + Schema *Schema + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeStatus) Descriptor() ([]byte, []int) + func (*NodeStatus) ProtoMessage() + func (m *NodeStatus) GetIndexes() []*IndexStatus + func (m *NodeStatus) GetNode() *Node + func (m *NodeStatus) GetSchema() *Schema + func (m *NodeStatus) Marshal() (dAtA []byte, err error) + func (m *NodeStatus) MarshalTo(dAtA []byte) (int, error) + func (m *NodeStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NodeStatus) Reset() + func (m *NodeStatus) Size() (n int) + func (m *NodeStatus) String() string + func (m *NodeStatus) Unmarshal(dAtA []byte) error + func (m *NodeStatus) XXX_DiscardUnknown() + func (m *NodeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeStatus) XXX_Merge(src proto.Message) + func (m *NodeStatus) XXX_Size() int + func (m *NodeStatus) XXX_Unmarshal(b []byte) error + type Pair struct + Count uint64 + ID uint64 + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Pair) Descriptor() ([]byte, []int) + func (*Pair) ProtoMessage() + func (m *Pair) GetCount() uint64 + func (m *Pair) GetID() uint64 + func (m *Pair) GetKey() string + func (m *Pair) Marshal() (dAtA []byte, err error) + func (m *Pair) MarshalTo(dAtA []byte) (int, error) + func (m *Pair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Pair) Reset() + func (m *Pair) Size() (n int) + func (m *Pair) String() string + func (m *Pair) Unmarshal(dAtA []byte) error + func (m *Pair) XXX_DiscardUnknown() + func (m *Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Pair) XXX_Merge(src proto.Message) + func (m *Pair) XXX_Size() int + func (m *Pair) XXX_Unmarshal(b []byte) error + type PairField struct + Field string + Pair *Pair + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PairField) Descriptor() ([]byte, []int) + func (*PairField) ProtoMessage() + func (m *PairField) GetField() string + func (m *PairField) GetPair() *Pair + func (m *PairField) Marshal() (dAtA []byte, err error) + func (m *PairField) MarshalTo(dAtA []byte) (int, error) + func (m *PairField) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PairField) Reset() + func (m *PairField) Size() (n int) + func (m *PairField) String() string + func (m *PairField) Unmarshal(dAtA []byte) error + func (m *PairField) XXX_DiscardUnknown() + func (m *PairField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PairField) XXX_Merge(src proto.Message) + func (m *PairField) XXX_Size() int + func (m *PairField) XXX_Unmarshal(b []byte) error + type PairsField struct + Field string + Pairs []*Pair + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PairsField) Descriptor() ([]byte, []int) + func (*PairsField) ProtoMessage() + func (m *PairsField) GetField() string + func (m *PairsField) GetPairs() []*Pair + func (m *PairsField) Marshal() (dAtA []byte, err error) + func (m *PairsField) MarshalTo(dAtA []byte) (int, error) + func (m *PairsField) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PairsField) Reset() + func (m *PairsField) Size() (n int) + func (m *PairsField) String() string + func (m *PairsField) Unmarshal(dAtA []byte) error + func (m *PairsField) XXX_DiscardUnknown() + func (m *PairsField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PairsField) XXX_Merge(src proto.Message) + func (m *PairsField) XXX_Size() int + func (m *PairsField) XXX_Unmarshal(b []byte) error + type QueryRequest struct + EmbeddedData []*Row + MaxMemory int64 + PreTranslated bool + Query string + Remote bool + Shards []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (m *QueryRequest) GetEmbeddedData() []*Row + func (m *QueryRequest) GetMaxMemory() int64 + func (m *QueryRequest) GetPreTranslated() bool + func (m *QueryRequest) GetQuery() string + func (m *QueryRequest) GetRemote() bool + func (m *QueryRequest) GetShards() []uint64 + func (m *QueryRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest) Reset() + func (m *QueryRequest) Size() (n int) + func (m *QueryRequest) String() string + func (m *QueryRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequest) XXX_DiscardUnknown() + func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequest) XXX_Merge(src proto.Message) + func (m *QueryRequest) XXX_Size() int + func (m *QueryRequest) XXX_Unmarshal(b []byte) error + type QueryResponse struct + Err string + Results []*QueryResult + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueryResponse) Descriptor() ([]byte, []int) + func (*QueryResponse) ProtoMessage() + func (m *QueryResponse) GetErr() string + func (m *QueryResponse) GetResults() []*QueryResult + func (m *QueryResponse) Marshal() (dAtA []byte, err error) + func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse) Reset() + func (m *QueryResponse) Size() (n int) + func (m *QueryResponse) String() string + func (m *QueryResponse) Unmarshal(dAtA []byte) error + func (m *QueryResponse) XXX_DiscardUnknown() + func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponse) XXX_Merge(src proto.Message) + func (m *QueryResponse) XXX_Size() int + func (m *QueryResponse) XXX_Unmarshal(b []byte) error + type QueryResult struct + ArrowTable *ArrowTable + Changed bool + DataFrame *DataFrame + DistinctTimestamp *DistinctTimestamp + ExtractedIDMatrix *ExtractedIDMatrix + ExtractedIDMatrixSorted *ExtractedIDMatrixSorted + ExtractedTable *ExtractedTable + GroupCounts *GroupCounts + N uint64 + OldGroupCounts []*GroupCount + PairField *PairField + Pairs []*Pair + PairsField *PairsField + Row *Row + RowIDs []uint64 + RowIdentifiers *RowIdentifiers + RowMatrix *RowMatrix + SignedRow *SignedRow + Type uint32 + ValCount *ValCount + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueryResult) Descriptor() ([]byte, []int) + func (*QueryResult) ProtoMessage() + func (m *QueryResult) GetArrowTable() *ArrowTable + func (m *QueryResult) GetChanged() bool + func (m *QueryResult) GetDataFrame() *DataFrame + func (m *QueryResult) GetDistinctTimestamp() *DistinctTimestamp + func (m *QueryResult) GetExtractedIDMatrix() *ExtractedIDMatrix + func (m *QueryResult) GetExtractedIDMatrixSorted() *ExtractedIDMatrixSorted + func (m *QueryResult) GetExtractedTable() *ExtractedTable + func (m *QueryResult) GetGroupCounts() *GroupCounts + func (m *QueryResult) GetN() uint64 + func (m *QueryResult) GetOldGroupCounts() []*GroupCount + func (m *QueryResult) GetPairField() *PairField + func (m *QueryResult) GetPairs() []*Pair + func (m *QueryResult) GetPairsField() *PairsField + func (m *QueryResult) GetRow() *Row + func (m *QueryResult) GetRowIDs() []uint64 + func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers + func (m *QueryResult) GetRowMatrix() *RowMatrix + func (m *QueryResult) GetSignedRow() *SignedRow + func (m *QueryResult) GetType() uint32 + func (m *QueryResult) GetValCount() *ValCount + func (m *QueryResult) Marshal() (dAtA []byte, err error) + func (m *QueryResult) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResult) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResult) Reset() + func (m *QueryResult) Size() (n int) + func (m *QueryResult) String() string + func (m *QueryResult) Unmarshal(dAtA []byte) error + func (m *QueryResult) XXX_DiscardUnknown() + func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResult) XXX_Merge(src proto.Message) + func (m *QueryResult) XXX_Size() int + func (m *QueryResult) XXX_Unmarshal(b []byte) error + type RecalculateCaches struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RecalculateCaches) Descriptor() ([]byte, []int) + func (*RecalculateCaches) ProtoMessage() + func (m *RecalculateCaches) Marshal() (dAtA []byte, err error) + func (m *RecalculateCaches) MarshalTo(dAtA []byte) (int, error) + func (m *RecalculateCaches) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RecalculateCaches) Reset() + func (m *RecalculateCaches) Size() (n int) + func (m *RecalculateCaches) String() string + func (m *RecalculateCaches) Unmarshal(dAtA []byte) error + func (m *RecalculateCaches) XXX_DiscardUnknown() + func (m *RecalculateCaches) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RecalculateCaches) XXX_Merge(src proto.Message) + func (m *RecalculateCaches) XXX_Size() int + func (m *RecalculateCaches) XXX_Unmarshal(b []byte) error + type Request proto.Message + type ResizeAbortMessage struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeAbortMessage) Descriptor() ([]byte, []int) + func (*ResizeAbortMessage) ProtoMessage() + func (m *ResizeAbortMessage) Marshal() (dAtA []byte, err error) + func (m *ResizeAbortMessage) MarshalTo(dAtA []byte) (int, error) + func (m *ResizeAbortMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResizeAbortMessage) Reset() + func (m *ResizeAbortMessage) Size() (n int) + func (m *ResizeAbortMessage) String() string + func (m *ResizeAbortMessage) Unmarshal(dAtA []byte) error + func (m *ResizeAbortMessage) XXX_DiscardUnknown() + func (m *ResizeAbortMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeAbortMessage) XXX_Merge(src proto.Message) + func (m *ResizeAbortMessage) XXX_Size() int + func (m *ResizeAbortMessage) XXX_Unmarshal(b []byte) error + type ResizeInstruction struct + ClusterStatus *ClusterStatus + JobID int64 + Node *Node + NodeStatus *NodeStatus + Primary *Node + Sources []*ResizeSource + TranslationSources []*TranslationResizeSource + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeInstruction) Descriptor() ([]byte, []int) + func (*ResizeInstruction) ProtoMessage() + func (m *ResizeInstruction) GetClusterStatus() *ClusterStatus + func (m *ResizeInstruction) GetJobID() int64 + func (m *ResizeInstruction) GetNode() *Node + func (m *ResizeInstruction) GetNodeStatus() *NodeStatus + func (m *ResizeInstruction) GetPrimary() *Node + func (m *ResizeInstruction) GetSources() []*ResizeSource + func (m *ResizeInstruction) GetTranslationSources() []*TranslationResizeSource + func (m *ResizeInstruction) Marshal() (dAtA []byte, err error) + func (m *ResizeInstruction) MarshalTo(dAtA []byte) (int, error) + func (m *ResizeInstruction) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResizeInstruction) Reset() + func (m *ResizeInstruction) Size() (n int) + func (m *ResizeInstruction) String() string + func (m *ResizeInstruction) Unmarshal(dAtA []byte) error + func (m *ResizeInstruction) XXX_DiscardUnknown() + func (m *ResizeInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeInstruction) XXX_Merge(src proto.Message) + func (m *ResizeInstruction) XXX_Size() int + func (m *ResizeInstruction) XXX_Unmarshal(b []byte) error + type ResizeInstructionComplete struct + Error string + JobID int64 + Node *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeInstructionComplete) Descriptor() ([]byte, []int) + func (*ResizeInstructionComplete) ProtoMessage() + func (m *ResizeInstructionComplete) GetError() string + func (m *ResizeInstructionComplete) GetJobID() int64 + func (m *ResizeInstructionComplete) GetNode() *Node + func (m *ResizeInstructionComplete) Marshal() (dAtA []byte, err error) + func (m *ResizeInstructionComplete) MarshalTo(dAtA []byte) (int, error) + func (m *ResizeInstructionComplete) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResizeInstructionComplete) Reset() + func (m *ResizeInstructionComplete) Size() (n int) + func (m *ResizeInstructionComplete) String() string + func (m *ResizeInstructionComplete) Unmarshal(dAtA []byte) error + func (m *ResizeInstructionComplete) XXX_DiscardUnknown() + func (m *ResizeInstructionComplete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeInstructionComplete) XXX_Merge(src proto.Message) + func (m *ResizeInstructionComplete) XXX_Size() int + func (m *ResizeInstructionComplete) XXX_Unmarshal(b []byte) error + type ResizeNodeMessage struct + Action string + NodeID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeNodeMessage) Descriptor() ([]byte, []int) + func (*ResizeNodeMessage) ProtoMessage() + func (m *ResizeNodeMessage) GetAction() string + func (m *ResizeNodeMessage) GetNodeID() string + func (m *ResizeNodeMessage) Marshal() (dAtA []byte, err error) + func (m *ResizeNodeMessage) MarshalTo(dAtA []byte) (int, error) + func (m *ResizeNodeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResizeNodeMessage) Reset() + func (m *ResizeNodeMessage) Size() (n int) + func (m *ResizeNodeMessage) String() string + func (m *ResizeNodeMessage) Unmarshal(dAtA []byte) error + func (m *ResizeNodeMessage) XXX_DiscardUnknown() + func (m *ResizeNodeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeNodeMessage) XXX_Merge(src proto.Message) + func (m *ResizeNodeMessage) XXX_Size() int + func (m *ResizeNodeMessage) XXX_Unmarshal(b []byte) error + type ResizeSource struct + Field string + Index string + Node *Node + Shard uint64 + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeSource) Descriptor() ([]byte, []int) + func (*ResizeSource) ProtoMessage() + func (m *ResizeSource) GetField() string + func (m *ResizeSource) GetIndex() string + func (m *ResizeSource) GetNode() *Node + func (m *ResizeSource) GetShard() uint64 + func (m *ResizeSource) GetView() string + func (m *ResizeSource) Marshal() (dAtA []byte, err error) + func (m *ResizeSource) MarshalTo(dAtA []byte) (int, error) + func (m *ResizeSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResizeSource) Reset() + func (m *ResizeSource) Size() (n int) + func (m *ResizeSource) String() string + func (m *ResizeSource) Unmarshal(dAtA []byte) error + func (m *ResizeSource) XXX_DiscardUnknown() + func (m *ResizeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeSource) XXX_Merge(src proto.Message) + func (m *ResizeSource) XXX_Size() int + func (m *ResizeSource) XXX_Unmarshal(b []byte) error + type Response proto.Message + type RoaringUpdate struct + Clear []byte + ClearRecords bool + Field string + Set []byte + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RoaringUpdate) Descriptor() ([]byte, []int) + func (*RoaringUpdate) ProtoMessage() + func (m *RoaringUpdate) GetClear() []byte + func (m *RoaringUpdate) GetClearRecords() bool + func (m *RoaringUpdate) GetField() string + func (m *RoaringUpdate) GetSet() []byte + func (m *RoaringUpdate) GetView() string + func (m *RoaringUpdate) Marshal() (dAtA []byte, err error) + func (m *RoaringUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *RoaringUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RoaringUpdate) Reset() + func (m *RoaringUpdate) Size() (n int) + func (m *RoaringUpdate) String() string + func (m *RoaringUpdate) Unmarshal(dAtA []byte) error + func (m *RoaringUpdate) XXX_DiscardUnknown() + func (m *RoaringUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RoaringUpdate) XXX_Merge(src proto.Message) + func (m *RoaringUpdate) XXX_Size() int + func (m *RoaringUpdate) XXX_Unmarshal(b []byte) error + type Row struct + Columns []uint64 + Field string + Index string + Keys []string + Roaring []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Row) Descriptor() ([]byte, []int) + func (*Row) ProtoMessage() + func (m *Row) GetColumns() []uint64 + func (m *Row) GetField() string + func (m *Row) GetIndex() string + func (m *Row) GetKeys() []string + func (m *Row) GetRoaring() []byte + func (m *Row) Marshal() (dAtA []byte, err error) + func (m *Row) MarshalTo(dAtA []byte) (int, error) + func (m *Row) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Row) Reset() + func (m *Row) Size() (n int) + func (m *Row) String() string + func (m *Row) Unmarshal(dAtA []byte) error + func (m *Row) XXX_DiscardUnknown() + func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Row) XXX_Merge(src proto.Message) + func (m *Row) XXX_Size() int + func (m *Row) XXX_Unmarshal(b []byte) error + type RowIdentifiers struct + Keys []string + Rows []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RowIdentifiers) Descriptor() ([]byte, []int) + func (*RowIdentifiers) ProtoMessage() + func (m *RowIdentifiers) GetKeys() []string + func (m *RowIdentifiers) GetRows() []uint64 + func (m *RowIdentifiers) Marshal() (dAtA []byte, err error) + func (m *RowIdentifiers) MarshalTo(dAtA []byte) (int, error) + func (m *RowIdentifiers) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RowIdentifiers) Reset() + func (m *RowIdentifiers) Size() (n int) + func (m *RowIdentifiers) String() string + func (m *RowIdentifiers) Unmarshal(dAtA []byte) error + func (m *RowIdentifiers) XXX_DiscardUnknown() + func (m *RowIdentifiers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RowIdentifiers) XXX_Merge(src proto.Message) + func (m *RowIdentifiers) XXX_Size() int + func (m *RowIdentifiers) XXX_Unmarshal(b []byte) error + type RowKV struct + RowID uint64 + Value *ExtractedTableValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RowKV) Descriptor() ([]byte, []int) + func (*RowKV) ProtoMessage() + func (m *RowKV) GetRowID() uint64 + func (m *RowKV) GetValue() *ExtractedTableValue + func (m *RowKV) Marshal() (dAtA []byte, err error) + func (m *RowKV) MarshalTo(dAtA []byte) (int, error) + func (m *RowKV) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RowKV) Reset() + func (m *RowKV) Size() (n int) + func (m *RowKV) String() string + func (m *RowKV) Unmarshal(dAtA []byte) error + func (m *RowKV) XXX_DiscardUnknown() + func (m *RowKV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RowKV) XXX_Merge(src proto.Message) + func (m *RowKV) XXX_Size() int + func (m *RowKV) XXX_Unmarshal(b []byte) error + type RowMatrix struct + Rows []*Row + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RowMatrix) Descriptor() ([]byte, []int) + func (*RowMatrix) ProtoMessage() + func (m *RowMatrix) GetRows() []*Row + func (m *RowMatrix) Marshal() (dAtA []byte, err error) + func (m *RowMatrix) MarshalTo(dAtA []byte) (int, error) + func (m *RowMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RowMatrix) Reset() + func (m *RowMatrix) Size() (n int) + func (m *RowMatrix) String() string + func (m *RowMatrix) Unmarshal(dAtA []byte) error + func (m *RowMatrix) XXX_DiscardUnknown() + func (m *RowMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RowMatrix) XXX_Merge(src proto.Message) + func (m *RowMatrix) XXX_Size() int + func (m *RowMatrix) XXX_Unmarshal(b []byte) error + type Schema struct + Indexes []*Index + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Schema) Descriptor() ([]byte, []int) + func (*Schema) ProtoMessage() + func (m *Schema) GetIndexes() []*Index + func (m *Schema) Marshal() (dAtA []byte, err error) + func (m *Schema) MarshalTo(dAtA []byte) (int, error) + func (m *Schema) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Schema) Reset() + func (m *Schema) Size() (n int) + func (m *Schema) String() string + func (m *Schema) Unmarshal(dAtA []byte) error + func (m *Schema) XXX_DiscardUnknown() + func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Schema) XXX_Merge(src proto.Message) + func (m *Schema) XXX_Size() int + func (m *Schema) XXX_Unmarshal(b []byte) error + type ShardIngestOperation struct + ClearFields []string + ClearRecordIDs []uint64 + FieldOps map[string]*FieldOperation + OpType string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardIngestOperation) Descriptor() ([]byte, []int) + func (*ShardIngestOperation) ProtoMessage() + func (m *ShardIngestOperation) GetClearFields() []string + func (m *ShardIngestOperation) GetClearRecordIDs() []uint64 + func (m *ShardIngestOperation) GetFieldOps() map[string]*FieldOperation + func (m *ShardIngestOperation) GetOpType() string + func (m *ShardIngestOperation) Marshal() (dAtA []byte, err error) + func (m *ShardIngestOperation) MarshalTo(dAtA []byte) (int, error) + func (m *ShardIngestOperation) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardIngestOperation) Reset() + func (m *ShardIngestOperation) Size() (n int) + func (m *ShardIngestOperation) String() string + func (m *ShardIngestOperation) Unmarshal(dAtA []byte) error + func (m *ShardIngestOperation) XXX_DiscardUnknown() + func (m *ShardIngestOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardIngestOperation) XXX_Merge(src proto.Message) + func (m *ShardIngestOperation) XXX_Size() int + func (m *ShardIngestOperation) XXX_Unmarshal(b []byte) error + type ShardIngestOperations struct + Ops []*ShardIngestOperation + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardIngestOperations) Descriptor() ([]byte, []int) + func (*ShardIngestOperations) ProtoMessage() + func (m *ShardIngestOperations) GetOps() []*ShardIngestOperation + func (m *ShardIngestOperations) Marshal() (dAtA []byte, err error) + func (m *ShardIngestOperations) MarshalTo(dAtA []byte) (int, error) + func (m *ShardIngestOperations) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardIngestOperations) Reset() + func (m *ShardIngestOperations) Size() (n int) + func (m *ShardIngestOperations) String() string + func (m *ShardIngestOperations) Unmarshal(dAtA []byte) error + func (m *ShardIngestOperations) XXX_DiscardUnknown() + func (m *ShardIngestOperations) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardIngestOperations) XXX_Merge(src proto.Message) + func (m *ShardIngestOperations) XXX_Size() int + func (m *ShardIngestOperations) XXX_Unmarshal(b []byte) error + type ShardedIngestRequest struct + Ops map[uint64]*ShardIngestOperations + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardedIngestRequest) Descriptor() ([]byte, []int) + func (*ShardedIngestRequest) ProtoMessage() + func (m *ShardedIngestRequest) GetOps() map[uint64]*ShardIngestOperations + func (m *ShardedIngestRequest) Marshal() (dAtA []byte, err error) + func (m *ShardedIngestRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ShardedIngestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardedIngestRequest) Reset() + func (m *ShardedIngestRequest) Size() (n int) + func (m *ShardedIngestRequest) String() string + func (m *ShardedIngestRequest) Unmarshal(dAtA []byte) error + func (m *ShardedIngestRequest) XXX_DiscardUnknown() + func (m *ShardedIngestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardedIngestRequest) XXX_Merge(src proto.Message) + func (m *ShardedIngestRequest) XXX_Size() int + func (m *ShardedIngestRequest) XXX_Unmarshal(b []byte) error + type SignedRow struct + Neg *Row + Pos *Row + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SignedRow) Descriptor() ([]byte, []int) + func (*SignedRow) ProtoMessage() + func (m *SignedRow) GetNeg() *Row + func (m *SignedRow) GetPos() *Row + func (m *SignedRow) Marshal() (dAtA []byte, err error) + func (m *SignedRow) MarshalTo(dAtA []byte) (int, error) + func (m *SignedRow) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SignedRow) Reset() + func (m *SignedRow) Size() (n int) + func (m *SignedRow) String() string + func (m *SignedRow) Unmarshal(dAtA []byte) error + func (m *SignedRow) XXX_DiscardUnknown() + func (m *SignedRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SignedRow) XXX_Merge(src proto.Message) + func (m *SignedRow) XXX_Size() int + func (m *SignedRow) XXX_Unmarshal(b []byte) error + type Topology struct + ClusterID string + NodeIDs []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Topology) Descriptor() ([]byte, []int) + func (*Topology) ProtoMessage() + func (m *Topology) GetClusterID() string + func (m *Topology) GetNodeIDs() []string + func (m *Topology) Marshal() (dAtA []byte, err error) + func (m *Topology) MarshalTo(dAtA []byte) (int, error) + func (m *Topology) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Topology) Reset() + func (m *Topology) Size() (n int) + func (m *Topology) String() string + func (m *Topology) Unmarshal(dAtA []byte) error + func (m *Topology) XXX_DiscardUnknown() + func (m *Topology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Topology) XXX_Merge(src proto.Message) + func (m *Topology) XXX_Size() int + func (m *Topology) XXX_Unmarshal(b []byte) error + type Transaction struct + Active bool + Deadline int64 + Exclusive bool + ID string + Stats *TransactionStats + Timeout int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Transaction) Descriptor() ([]byte, []int) + func (*Transaction) ProtoMessage() + func (m *Transaction) GetActive() bool + func (m *Transaction) GetDeadline() int64 + func (m *Transaction) GetExclusive() bool + func (m *Transaction) GetID() string + func (m *Transaction) GetStats() *TransactionStats + func (m *Transaction) GetTimeout() int64 + func (m *Transaction) Marshal() (dAtA []byte, err error) + func (m *Transaction) MarshalTo(dAtA []byte) (int, error) + func (m *Transaction) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Transaction) Reset() + func (m *Transaction) Size() (n int) + func (m *Transaction) String() string + func (m *Transaction) Unmarshal(dAtA []byte) error + func (m *Transaction) XXX_DiscardUnknown() + func (m *Transaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Transaction) XXX_Merge(src proto.Message) + func (m *Transaction) XXX_Size() int + func (m *Transaction) XXX_Unmarshal(b []byte) error + type TransactionMessage struct + Action string + Transaction *Transaction + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TransactionMessage) Descriptor() ([]byte, []int) + func (*TransactionMessage) ProtoMessage() + func (m *TransactionMessage) GetAction() string + func (m *TransactionMessage) GetTransaction() *Transaction + func (m *TransactionMessage) Marshal() (dAtA []byte, err error) + func (m *TransactionMessage) MarshalTo(dAtA []byte) (int, error) + func (m *TransactionMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransactionMessage) Reset() + func (m *TransactionMessage) Size() (n int) + func (m *TransactionMessage) String() string + func (m *TransactionMessage) Unmarshal(dAtA []byte) error + func (m *TransactionMessage) XXX_DiscardUnknown() + func (m *TransactionMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransactionMessage) XXX_Merge(src proto.Message) + func (m *TransactionMessage) XXX_Size() int + func (m *TransactionMessage) XXX_Unmarshal(b []byte) error + type TransactionStats struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TransactionStats) Descriptor() ([]byte, []int) + func (*TransactionStats) ProtoMessage() + func (m *TransactionStats) Marshal() (dAtA []byte, err error) + func (m *TransactionStats) MarshalTo(dAtA []byte) (int, error) + func (m *TransactionStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransactionStats) Reset() + func (m *TransactionStats) Size() (n int) + func (m *TransactionStats) String() string + func (m *TransactionStats) Unmarshal(dAtA []byte) error + func (m *TransactionStats) XXX_DiscardUnknown() + func (m *TransactionStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransactionStats) XXX_Merge(src proto.Message) + func (m *TransactionStats) XXX_Size() int + func (m *TransactionStats) XXX_Unmarshal(b []byte) error + type TranslateIDsRequest struct + Field string + IDs []uint64 + Index string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TranslateIDsRequest) Descriptor() ([]byte, []int) + func (*TranslateIDsRequest) ProtoMessage() + func (m *TranslateIDsRequest) GetField() string + func (m *TranslateIDsRequest) GetIDs() []uint64 + func (m *TranslateIDsRequest) GetIndex() string + func (m *TranslateIDsRequest) Marshal() (dAtA []byte, err error) + func (m *TranslateIDsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TranslateIDsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TranslateIDsRequest) Reset() + func (m *TranslateIDsRequest) Size() (n int) + func (m *TranslateIDsRequest) String() string + func (m *TranslateIDsRequest) Unmarshal(dAtA []byte) error + func (m *TranslateIDsRequest) XXX_DiscardUnknown() + func (m *TranslateIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TranslateIDsRequest) XXX_Merge(src proto.Message) + func (m *TranslateIDsRequest) XXX_Size() int + func (m *TranslateIDsRequest) XXX_Unmarshal(b []byte) error + type TranslateIDsResponse struct + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TranslateIDsResponse) Descriptor() ([]byte, []int) + func (*TranslateIDsResponse) ProtoMessage() + func (m *TranslateIDsResponse) GetKeys() []string + func (m *TranslateIDsResponse) Marshal() (dAtA []byte, err error) + func (m *TranslateIDsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TranslateIDsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TranslateIDsResponse) Reset() + func (m *TranslateIDsResponse) Size() (n int) + func (m *TranslateIDsResponse) String() string + func (m *TranslateIDsResponse) Unmarshal(dAtA []byte) error + func (m *TranslateIDsResponse) XXX_DiscardUnknown() + func (m *TranslateIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TranslateIDsResponse) XXX_Merge(src proto.Message) + func (m *TranslateIDsResponse) XXX_Size() int + func (m *TranslateIDsResponse) XXX_Unmarshal(b []byte) error + type TranslateKeysRequest struct + Field string + Index string + Keys []string + NotWritable bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TranslateKeysRequest) Descriptor() ([]byte, []int) + func (*TranslateKeysRequest) ProtoMessage() + func (m *TranslateKeysRequest) GetField() string + func (m *TranslateKeysRequest) GetIndex() string + func (m *TranslateKeysRequest) GetKeys() []string + func (m *TranslateKeysRequest) GetNotWritable() bool + func (m *TranslateKeysRequest) Marshal() (dAtA []byte, err error) + func (m *TranslateKeysRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TranslateKeysRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TranslateKeysRequest) Reset() + func (m *TranslateKeysRequest) Size() (n int) + func (m *TranslateKeysRequest) String() string + func (m *TranslateKeysRequest) Unmarshal(dAtA []byte) error + func (m *TranslateKeysRequest) XXX_DiscardUnknown() + func (m *TranslateKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TranslateKeysRequest) XXX_Merge(src proto.Message) + func (m *TranslateKeysRequest) XXX_Size() int + func (m *TranslateKeysRequest) XXX_Unmarshal(b []byte) error + type TranslateKeysResponse struct + IDs []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TranslateKeysResponse) Descriptor() ([]byte, []int) + func (*TranslateKeysResponse) ProtoMessage() + func (m *TranslateKeysResponse) GetIDs() []uint64 + func (m *TranslateKeysResponse) Marshal() (dAtA []byte, err error) + func (m *TranslateKeysResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TranslateKeysResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TranslateKeysResponse) Reset() + func (m *TranslateKeysResponse) Size() (n int) + func (m *TranslateKeysResponse) String() string + func (m *TranslateKeysResponse) Unmarshal(dAtA []byte) error + func (m *TranslateKeysResponse) XXX_DiscardUnknown() + func (m *TranslateKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TranslateKeysResponse) XXX_Merge(src proto.Message) + func (m *TranslateKeysResponse) XXX_Size() int + func (m *TranslateKeysResponse) XXX_Unmarshal(b []byte) error + type TranslationResizeSource struct + Index string + Node *Node + PartitionID int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TranslationResizeSource) Descriptor() ([]byte, []int) + func (*TranslationResizeSource) ProtoMessage() + func (m *TranslationResizeSource) GetIndex() string + func (m *TranslationResizeSource) GetNode() *Node + func (m *TranslationResizeSource) GetPartitionID() int32 + func (m *TranslationResizeSource) Marshal() (dAtA []byte, err error) + func (m *TranslationResizeSource) MarshalTo(dAtA []byte) (int, error) + func (m *TranslationResizeSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TranslationResizeSource) Reset() + func (m *TranslationResizeSource) Size() (n int) + func (m *TranslationResizeSource) String() string + func (m *TranslationResizeSource) Unmarshal(dAtA []byte) error + func (m *TranslationResizeSource) XXX_DiscardUnknown() + func (m *TranslationResizeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TranslationResizeSource) XXX_Merge(src proto.Message) + func (m *TranslationResizeSource) XXX_Size() int + func (m *TranslationResizeSource) XXX_Unmarshal(b []byte) error + type URI struct + Host string + Port uint32 + Scheme string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*URI) Descriptor() ([]byte, []int) + func (*URI) ProtoMessage() + func (m *URI) GetHost() string + func (m *URI) GetPort() uint32 + func (m *URI) GetScheme() string + func (m *URI) Marshal() (dAtA []byte, err error) + func (m *URI) MarshalTo(dAtA []byte) (int, error) + func (m *URI) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *URI) Reset() + func (m *URI) Size() (n int) + func (m *URI) String() string + func (m *URI) Unmarshal(dAtA []byte) error + func (m *URI) XXX_DiscardUnknown() + func (m *URI) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *URI) XXX_Merge(src proto.Message) + func (m *URI) XXX_Size() int + func (m *URI) XXX_Unmarshal(b []byte) error + type UpdateFieldMessage struct + CreateFieldMessage *CreateFieldMessage + Update *FieldUpdate + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateFieldMessage) Descriptor() ([]byte, []int) + func (*UpdateFieldMessage) ProtoMessage() + func (m *UpdateFieldMessage) GetCreateFieldMessage() *CreateFieldMessage + func (m *UpdateFieldMessage) GetUpdate() *FieldUpdate + func (m *UpdateFieldMessage) Marshal() (dAtA []byte, err error) + func (m *UpdateFieldMessage) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateFieldMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateFieldMessage) Reset() + func (m *UpdateFieldMessage) Size() (n int) + func (m *UpdateFieldMessage) String() string + func (m *UpdateFieldMessage) Unmarshal(dAtA []byte) error + func (m *UpdateFieldMessage) XXX_DiscardUnknown() + func (m *UpdateFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateFieldMessage) XXX_Merge(src proto.Message) + func (m *UpdateFieldMessage) XXX_Size() int + func (m *UpdateFieldMessage) XXX_Unmarshal(b []byte) error + type ValCount struct + Count int64 + DecimalVal *Decimal + FloatVal float64 + TimestampVal string + Val int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ValCount) Descriptor() ([]byte, []int) + func (*ValCount) ProtoMessage() + func (m *ValCount) GetCount() int64 + func (m *ValCount) GetDecimalVal() *Decimal + func (m *ValCount) GetFloatVal() float64 + func (m *ValCount) GetTimestampVal() string + func (m *ValCount) GetVal() int64 + func (m *ValCount) Marshal() (dAtA []byte, err error) + func (m *ValCount) MarshalTo(dAtA []byte) (int, error) + func (m *ValCount) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ValCount) Reset() + func (m *ValCount) Size() (n int) + func (m *ValCount) String() string + func (m *ValCount) Unmarshal(dAtA []byte) error + func (m *ValCount) XXX_DiscardUnknown() + func (m *ValCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ValCount) XXX_Merge(src proto.Message) + func (m *ValCount) XXX_Size() int + func (m *ValCount) XXX_Unmarshal(b []byte) error