pb

package
v3.35.0 Latest Latest
Warning

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

Go to latest
Published: Mar 30, 2023 License: Apache-2.0, Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Copyright 2022 Molecula Corp. (DBA FeatureBase). SPDX-License-Identifier: Apache-2.0

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthPrivate        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrivate          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrivate = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthPublic        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPublic          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPublic = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ArrowTable

type ArrowTable struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArrowTable) Descriptor

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

func (*ArrowTable) GetData

func (m *ArrowTable) GetData() []byte

func (*ArrowTable) Marshal

func (m *ArrowTable) Marshal() (dAtA []byte, err error)

func (*ArrowTable) MarshalTo

func (m *ArrowTable) MarshalTo(dAtA []byte) (int, error)

func (*ArrowTable) MarshalToSizedBuffer

func (m *ArrowTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ArrowTable) ProtoMessage

func (*ArrowTable) ProtoMessage()

func (*ArrowTable) Reset

func (m *ArrowTable) Reset()

func (*ArrowTable) Size

func (m *ArrowTable) Size() (n int)

func (*ArrowTable) String

func (m *ArrowTable) String() string

func (*ArrowTable) Unmarshal

func (m *ArrowTable) Unmarshal(dAtA []byte) error

func (*ArrowTable) XXX_DiscardUnknown

func (m *ArrowTable) XXX_DiscardUnknown()

func (*ArrowTable) XXX_Marshal

func (m *ArrowTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArrowTable) XXX_Merge

func (m *ArrowTable) XXX_Merge(src proto.Message)

func (*ArrowTable) XXX_Size

func (m *ArrowTable) XXX_Size() int

func (*ArrowTable) XXX_Unmarshal

func (m *ArrowTable) XXX_Unmarshal(b []byte) error

type AtomicImportResponse

type AtomicImportResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AtomicImportResponse) Descriptor

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

func (*AtomicImportResponse) GetError

func (m *AtomicImportResponse) GetError() string

func (*AtomicImportResponse) Marshal

func (m *AtomicImportResponse) Marshal() (dAtA []byte, err error)

func (*AtomicImportResponse) MarshalTo

func (m *AtomicImportResponse) MarshalTo(dAtA []byte) (int, error)

func (*AtomicImportResponse) MarshalToSizedBuffer

func (m *AtomicImportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AtomicImportResponse) ProtoMessage

func (*AtomicImportResponse) ProtoMessage()

func (*AtomicImportResponse) Reset

func (m *AtomicImportResponse) Reset()

func (*AtomicImportResponse) Size

func (m *AtomicImportResponse) Size() (n int)

func (*AtomicImportResponse) String

func (m *AtomicImportResponse) String() string

func (*AtomicImportResponse) Unmarshal

func (m *AtomicImportResponse) Unmarshal(dAtA []byte) error

func (*AtomicImportResponse) XXX_DiscardUnknown

func (m *AtomicImportResponse) XXX_DiscardUnknown()

func (*AtomicImportResponse) XXX_Marshal

func (m *AtomicImportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AtomicImportResponse) XXX_Merge

func (m *AtomicImportResponse) XXX_Merge(src proto.Message)

func (*AtomicImportResponse) XXX_Size

func (m *AtomicImportResponse) XXX_Size() int

func (*AtomicImportResponse) XXX_Unmarshal

func (m *AtomicImportResponse) XXX_Unmarshal(b []byte) error

type AtomicRecord

type AtomicRecord struct {
	Index                string                `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Shard                uint64                `protobuf:"varint,2,opt,name=Shard,proto3" json:"Shard,omitempty"`
	Ivr                  []*ImportValueRequest `protobuf:"bytes,3,rep,name=Ivr,proto3" json:"Ivr,omitempty"`
	Ir                   []*ImportRequest      `protobuf:"bytes,4,rep,name=Ir,proto3" json:"Ir,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*AtomicRecord) Descriptor

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

func (*AtomicRecord) GetIndex

func (m *AtomicRecord) GetIndex() string

func (*AtomicRecord) GetIr

func (m *AtomicRecord) GetIr() []*ImportRequest

func (*AtomicRecord) GetIvr

func (m *AtomicRecord) GetIvr() []*ImportValueRequest

func (*AtomicRecord) GetShard

func (m *AtomicRecord) GetShard() uint64

func (*AtomicRecord) Marshal

func (m *AtomicRecord) Marshal() (dAtA []byte, err error)

func (*AtomicRecord) MarshalTo

func (m *AtomicRecord) MarshalTo(dAtA []byte) (int, error)

func (*AtomicRecord) MarshalToSizedBuffer

func (m *AtomicRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AtomicRecord) ProtoMessage

func (*AtomicRecord) ProtoMessage()

func (*AtomicRecord) Reset

func (m *AtomicRecord) Reset()

func (*AtomicRecord) Size

func (m *AtomicRecord) Size() (n int)

func (*AtomicRecord) String

func (m *AtomicRecord) String() string

func (*AtomicRecord) Unmarshal

func (m *AtomicRecord) Unmarshal(dAtA []byte) error

func (*AtomicRecord) XXX_DiscardUnknown

func (m *AtomicRecord) XXX_DiscardUnknown()

func (*AtomicRecord) XXX_Marshal

func (m *AtomicRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AtomicRecord) XXX_Merge

func (m *AtomicRecord) XXX_Merge(src proto.Message)

func (*AtomicRecord) XXX_Size

func (m *AtomicRecord) XXX_Size() int

func (*AtomicRecord) XXX_Unmarshal

func (m *AtomicRecord) XXX_Unmarshal(b []byte) error

type BSIGroup

type BSIGroup struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Type                 string   `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"`
	Min                  int64    `protobuf:"varint,3,opt,name=Min,proto3" json:"Min,omitempty"`
	Max                  int64    `protobuf:"varint,4,opt,name=Max,proto3" json:"Max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BSIGroup) Descriptor

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

func (*BSIGroup) GetMax

func (m *BSIGroup) GetMax() int64

func (*BSIGroup) GetMin

func (m *BSIGroup) GetMin() int64

func (*BSIGroup) GetName

func (m *BSIGroup) GetName() string

func (*BSIGroup) GetType

func (m *BSIGroup) GetType() string

func (*BSIGroup) Marshal

func (m *BSIGroup) Marshal() (dAtA []byte, err error)

func (*BSIGroup) MarshalTo

func (m *BSIGroup) MarshalTo(dAtA []byte) (int, error)

func (*BSIGroup) MarshalToSizedBuffer

func (m *BSIGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BSIGroup) ProtoMessage

func (*BSIGroup) ProtoMessage()

func (*BSIGroup) Reset

func (m *BSIGroup) Reset()

func (*BSIGroup) Size

func (m *BSIGroup) Size() (n int)

func (*BSIGroup) String

func (m *BSIGroup) String() string

func (*BSIGroup) Unmarshal

func (m *BSIGroup) Unmarshal(dAtA []byte) error

func (*BSIGroup) XXX_DiscardUnknown

func (m *BSIGroup) XXX_DiscardUnknown()

func (*BSIGroup) XXX_Marshal

func (m *BSIGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BSIGroup) XXX_Merge

func (m *BSIGroup) XXX_Merge(src proto.Message)

func (*BSIGroup) XXX_Size

func (m *BSIGroup) XXX_Size() int

func (*BSIGroup) XXX_Unmarshal

func (m *BSIGroup) XXX_Unmarshal(b []byte) error

type BlockDataRequest

type BlockDataRequest struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	View                 string   `protobuf:"bytes,5,opt,name=View,proto3" json:"View,omitempty"`
	Shard                uint64   `protobuf:"varint,4,opt,name=Shard,proto3" json:"Shard,omitempty"`
	Block                uint64   `protobuf:"varint,3,opt,name=Block,proto3" json:"Block,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockDataRequest) Descriptor

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

func (*BlockDataRequest) GetBlock

func (m *BlockDataRequest) GetBlock() uint64

func (*BlockDataRequest) GetField

func (m *BlockDataRequest) GetField() string

func (*BlockDataRequest) GetIndex

func (m *BlockDataRequest) GetIndex() string

func (*BlockDataRequest) GetShard

func (m *BlockDataRequest) GetShard() uint64

func (*BlockDataRequest) GetView

func (m *BlockDataRequest) GetView() string

func (*BlockDataRequest) Marshal

func (m *BlockDataRequest) Marshal() (dAtA []byte, err error)

func (*BlockDataRequest) MarshalTo

func (m *BlockDataRequest) MarshalTo(dAtA []byte) (int, error)

func (*BlockDataRequest) MarshalToSizedBuffer

func (m *BlockDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockDataRequest) ProtoMessage

func (*BlockDataRequest) ProtoMessage()

func (*BlockDataRequest) Reset

func (m *BlockDataRequest) Reset()

func (*BlockDataRequest) Size

func (m *BlockDataRequest) Size() (n int)

func (*BlockDataRequest) String

func (m *BlockDataRequest) String() string

func (*BlockDataRequest) Unmarshal

func (m *BlockDataRequest) Unmarshal(dAtA []byte) error

func (*BlockDataRequest) XXX_DiscardUnknown

func (m *BlockDataRequest) XXX_DiscardUnknown()

func (*BlockDataRequest) XXX_Marshal

func (m *BlockDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockDataRequest) XXX_Merge

func (m *BlockDataRequest) XXX_Merge(src proto.Message)

func (*BlockDataRequest) XXX_Size

func (m *BlockDataRequest) XXX_Size() int

func (*BlockDataRequest) XXX_Unmarshal

func (m *BlockDataRequest) XXX_Unmarshal(b []byte) error

type BlockDataResponse

type BlockDataResponse struct {
	RowIDs               []uint64 `protobuf:"varint,1,rep,packed,name=RowIDs,proto3" json:"RowIDs,omitempty"`
	ColumnIDs            []uint64 `protobuf:"varint,2,rep,packed,name=ColumnIDs,proto3" json:"ColumnIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockDataResponse) Descriptor

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

func (*BlockDataResponse) GetColumnIDs

func (m *BlockDataResponse) GetColumnIDs() []uint64

func (*BlockDataResponse) GetRowIDs

func (m *BlockDataResponse) GetRowIDs() []uint64

func (*BlockDataResponse) Marshal

func (m *BlockDataResponse) Marshal() (dAtA []byte, err error)

func (*BlockDataResponse) MarshalTo

func (m *BlockDataResponse) MarshalTo(dAtA []byte) (int, error)

func (*BlockDataResponse) MarshalToSizedBuffer

func (m *BlockDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockDataResponse) ProtoMessage

func (*BlockDataResponse) ProtoMessage()

func (*BlockDataResponse) Reset

func (m *BlockDataResponse) Reset()

func (*BlockDataResponse) Size

func (m *BlockDataResponse) Size() (n int)

func (*BlockDataResponse) String

func (m *BlockDataResponse) String() string

func (*BlockDataResponse) Unmarshal

func (m *BlockDataResponse) Unmarshal(dAtA []byte) error

func (*BlockDataResponse) XXX_DiscardUnknown

func (m *BlockDataResponse) XXX_DiscardUnknown()

func (*BlockDataResponse) XXX_Marshal

func (m *BlockDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockDataResponse) XXX_Merge

func (m *BlockDataResponse) XXX_Merge(src proto.Message)

func (*BlockDataResponse) XXX_Size

func (m *BlockDataResponse) XXX_Size() int

func (*BlockDataResponse) XXX_Unmarshal

func (m *BlockDataResponse) XXX_Unmarshal(b []byte) error

type Cache

type Cache struct {
	IDs                  []uint64 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Cache) Descriptor

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

func (*Cache) GetIDs

func (m *Cache) GetIDs() []uint64

func (*Cache) Marshal

func (m *Cache) Marshal() (dAtA []byte, err error)

func (*Cache) MarshalTo

func (m *Cache) MarshalTo(dAtA []byte) (int, error)

func (*Cache) MarshalToSizedBuffer

func (m *Cache) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Cache) ProtoMessage

func (*Cache) ProtoMessage()

func (*Cache) Reset

func (m *Cache) Reset()

func (*Cache) Size

func (m *Cache) Size() (n int)

func (*Cache) String

func (m *Cache) String() string

func (*Cache) Unmarshal

func (m *Cache) Unmarshal(dAtA []byte) error

func (*Cache) XXX_DiscardUnknown

func (m *Cache) XXX_DiscardUnknown()

func (*Cache) XXX_Marshal

func (m *Cache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cache) XXX_Merge

func (m *Cache) XXX_Merge(src proto.Message)

func (*Cache) XXX_Size

func (m *Cache) XXX_Size() int

func (*Cache) XXX_Unmarshal

func (m *Cache) XXX_Unmarshal(b []byte) error

type ClusterStatus

type ClusterStatus struct {
	ClusterID            string   `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	State                string   `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
	Nodes                []*Node  `protobuf:"bytes,3,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	Schema               *Schema  `protobuf:"bytes,4,opt,name=Schema,proto3" json:"Schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterStatus) Descriptor

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

func (*ClusterStatus) GetClusterID

func (m *ClusterStatus) GetClusterID() string

func (*ClusterStatus) GetNodes

func (m *ClusterStatus) GetNodes() []*Node

func (*ClusterStatus) GetSchema

func (m *ClusterStatus) GetSchema() *Schema

func (*ClusterStatus) GetState

func (m *ClusterStatus) GetState() string

func (*ClusterStatus) Marshal

func (m *ClusterStatus) Marshal() (dAtA []byte, err error)

func (*ClusterStatus) MarshalTo

func (m *ClusterStatus) MarshalTo(dAtA []byte) (int, error)

func (*ClusterStatus) MarshalToSizedBuffer

func (m *ClusterStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterStatus) ProtoMessage

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) Reset

func (m *ClusterStatus) Reset()

func (*ClusterStatus) Size

func (m *ClusterStatus) Size() (n int)

func (*ClusterStatus) String

func (m *ClusterStatus) String() string

func (*ClusterStatus) Unmarshal

func (m *ClusterStatus) Unmarshal(dAtA []byte) error

func (*ClusterStatus) XXX_DiscardUnknown

func (m *ClusterStatus) XXX_DiscardUnknown()

func (*ClusterStatus) XXX_Marshal

func (m *ClusterStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterStatus) XXX_Merge

func (m *ClusterStatus) XXX_Merge(src proto.Message)

func (*ClusterStatus) XXX_Size

func (m *ClusterStatus) XXX_Size() int

func (*ClusterStatus) XXX_Unmarshal

func (m *ClusterStatus) XXX_Unmarshal(b []byte) error

type CreateFieldMessage

type CreateFieldMessage struct {
	Index                string        `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string        `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	Meta                 *FieldOptions `protobuf:"bytes,3,opt,name=Meta,proto3" json:"Meta,omitempty"`
	CreatedAt            int64         `protobuf:"varint,4,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	Owner                string        `protobuf:"bytes,5,opt,name=Owner,proto3" json:"Owner,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CreateFieldMessage) Descriptor

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

func (*CreateFieldMessage) GetCreatedAt

func (m *CreateFieldMessage) GetCreatedAt() int64

func (*CreateFieldMessage) GetField

func (m *CreateFieldMessage) GetField() string

func (*CreateFieldMessage) GetIndex

func (m *CreateFieldMessage) GetIndex() string

func (*CreateFieldMessage) GetMeta

func (m *CreateFieldMessage) GetMeta() *FieldOptions

func (*CreateFieldMessage) GetOwner

func (m *CreateFieldMessage) GetOwner() string

func (*CreateFieldMessage) Marshal

func (m *CreateFieldMessage) Marshal() (dAtA []byte, err error)

func (*CreateFieldMessage) MarshalTo

func (m *CreateFieldMessage) MarshalTo(dAtA []byte) (int, error)

func (*CreateFieldMessage) MarshalToSizedBuffer

func (m *CreateFieldMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateFieldMessage) ProtoMessage

func (*CreateFieldMessage) ProtoMessage()

func (*CreateFieldMessage) Reset

func (m *CreateFieldMessage) Reset()

func (*CreateFieldMessage) Size

func (m *CreateFieldMessage) Size() (n int)

func (*CreateFieldMessage) String

func (m *CreateFieldMessage) String() string

func (*CreateFieldMessage) Unmarshal

func (m *CreateFieldMessage) Unmarshal(dAtA []byte) error

func (*CreateFieldMessage) XXX_DiscardUnknown

func (m *CreateFieldMessage) XXX_DiscardUnknown()

func (*CreateFieldMessage) XXX_Marshal

func (m *CreateFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateFieldMessage) XXX_Merge

func (m *CreateFieldMessage) XXX_Merge(src proto.Message)

func (*CreateFieldMessage) XXX_Size

func (m *CreateFieldMessage) XXX_Size() int

func (*CreateFieldMessage) XXX_Unmarshal

func (m *CreateFieldMessage) XXX_Unmarshal(b []byte) error

type CreateIndexMessage

type CreateIndexMessage struct {
	Index                string     `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Meta                 *IndexMeta `protobuf:"bytes,2,opt,name=Meta,proto3" json:"Meta,omitempty"`
	CreatedAt            int64      `protobuf:"varint,3,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	Owner                string     `protobuf:"bytes,5,opt,name=Owner,proto3" json:"Owner,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CreateIndexMessage) Descriptor

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

func (*CreateIndexMessage) GetCreatedAt

func (m *CreateIndexMessage) GetCreatedAt() int64

func (*CreateIndexMessage) GetIndex

func (m *CreateIndexMessage) GetIndex() string

func (*CreateIndexMessage) GetMeta

func (m *CreateIndexMessage) GetMeta() *IndexMeta

func (*CreateIndexMessage) GetOwner

func (m *CreateIndexMessage) GetOwner() string

func (*CreateIndexMessage) Marshal

func (m *CreateIndexMessage) Marshal() (dAtA []byte, err error)

func (*CreateIndexMessage) MarshalTo

func (m *CreateIndexMessage) MarshalTo(dAtA []byte) (int, error)

func (*CreateIndexMessage) MarshalToSizedBuffer

func (m *CreateIndexMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateIndexMessage) ProtoMessage

func (*CreateIndexMessage) ProtoMessage()

func (*CreateIndexMessage) Reset

func (m *CreateIndexMessage) Reset()

func (*CreateIndexMessage) Size

func (m *CreateIndexMessage) Size() (n int)

func (*CreateIndexMessage) String

func (m *CreateIndexMessage) String() string

func (*CreateIndexMessage) Unmarshal

func (m *CreateIndexMessage) Unmarshal(dAtA []byte) error

func (*CreateIndexMessage) XXX_DiscardUnknown

func (m *CreateIndexMessage) XXX_DiscardUnknown()

func (*CreateIndexMessage) XXX_Marshal

func (m *CreateIndexMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateIndexMessage) XXX_Merge

func (m *CreateIndexMessage) XXX_Merge(src proto.Message)

func (*CreateIndexMessage) XXX_Size

func (m *CreateIndexMessage) XXX_Size() int

func (*CreateIndexMessage) XXX_Unmarshal

func (m *CreateIndexMessage) XXX_Unmarshal(b []byte) error

type CreateShardMessage

type CreateShardMessage struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,3,opt,name=Field,proto3" json:"Field,omitempty"`
	Shard                uint64   `protobuf:"varint,2,opt,name=Shard,proto3" json:"Shard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateShardMessage) Descriptor

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

func (*CreateShardMessage) GetField

func (m *CreateShardMessage) GetField() string

func (*CreateShardMessage) GetIndex

func (m *CreateShardMessage) GetIndex() string

func (*CreateShardMessage) GetShard

func (m *CreateShardMessage) GetShard() uint64

func (*CreateShardMessage) Marshal

func (m *CreateShardMessage) Marshal() (dAtA []byte, err error)

func (*CreateShardMessage) MarshalTo

func (m *CreateShardMessage) MarshalTo(dAtA []byte) (int, error)

func (*CreateShardMessage) MarshalToSizedBuffer

func (m *CreateShardMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateShardMessage) ProtoMessage

func (*CreateShardMessage) ProtoMessage()

func (*CreateShardMessage) Reset

func (m *CreateShardMessage) Reset()

func (*CreateShardMessage) Size

func (m *CreateShardMessage) Size() (n int)

func (*CreateShardMessage) String

func (m *CreateShardMessage) String() string

func (*CreateShardMessage) Unmarshal

func (m *CreateShardMessage) Unmarshal(dAtA []byte) error

func (*CreateShardMessage) XXX_DiscardUnknown

func (m *CreateShardMessage) XXX_DiscardUnknown()

func (*CreateShardMessage) XXX_Marshal

func (m *CreateShardMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateShardMessage) XXX_Merge

func (m *CreateShardMessage) XXX_Merge(src proto.Message)

func (*CreateShardMessage) XXX_Size

func (m *CreateShardMessage) XXX_Size() int

func (*CreateShardMessage) XXX_Unmarshal

func (m *CreateShardMessage) XXX_Unmarshal(b []byte) error

type CreateViewMessage

type CreateViewMessage struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	View                 string   `protobuf:"bytes,3,opt,name=View,proto3" json:"View,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateViewMessage) Descriptor

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

func (*CreateViewMessage) GetField

func (m *CreateViewMessage) GetField() string

func (*CreateViewMessage) GetIndex

func (m *CreateViewMessage) GetIndex() string

func (*CreateViewMessage) GetView

func (m *CreateViewMessage) GetView() string

func (*CreateViewMessage) Marshal

func (m *CreateViewMessage) Marshal() (dAtA []byte, err error)

func (*CreateViewMessage) MarshalTo

func (m *CreateViewMessage) MarshalTo(dAtA []byte) (int, error)

func (*CreateViewMessage) MarshalToSizedBuffer

func (m *CreateViewMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateViewMessage) ProtoMessage

func (*CreateViewMessage) ProtoMessage()

func (*CreateViewMessage) Reset

func (m *CreateViewMessage) Reset()

func (*CreateViewMessage) Size

func (m *CreateViewMessage) Size() (n int)

func (*CreateViewMessage) String

func (m *CreateViewMessage) String() string

func (*CreateViewMessage) Unmarshal

func (m *CreateViewMessage) Unmarshal(dAtA []byte) error

func (*CreateViewMessage) XXX_DiscardUnknown

func (m *CreateViewMessage) XXX_DiscardUnknown()

func (*CreateViewMessage) XXX_Marshal

func (m *CreateViewMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateViewMessage) XXX_Merge

func (m *CreateViewMessage) XXX_Merge(src proto.Message)

func (*CreateViewMessage) XXX_Size

func (m *CreateViewMessage) XXX_Size() int

func (*CreateViewMessage) XXX_Unmarshal

func (m *CreateViewMessage) XXX_Unmarshal(b []byte) error

type DataFrame

type DataFrame struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataFrame) Descriptor

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

func (*DataFrame) GetData

func (m *DataFrame) GetData() []byte

func (*DataFrame) Marshal

func (m *DataFrame) Marshal() (dAtA []byte, err error)

func (*DataFrame) MarshalTo

func (m *DataFrame) MarshalTo(dAtA []byte) (int, error)

func (*DataFrame) MarshalToSizedBuffer

func (m *DataFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataFrame) ProtoMessage

func (*DataFrame) ProtoMessage()

func (*DataFrame) Reset

func (m *DataFrame) Reset()

func (*DataFrame) Size

func (m *DataFrame) Size() (n int)

func (*DataFrame) String

func (m *DataFrame) String() string

func (*DataFrame) Unmarshal

func (m *DataFrame) Unmarshal(dAtA []byte) error

func (*DataFrame) XXX_DiscardUnknown

func (m *DataFrame) XXX_DiscardUnknown()

func (*DataFrame) XXX_Marshal

func (m *DataFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataFrame) XXX_Merge

func (m *DataFrame) XXX_Merge(src proto.Message)

func (*DataFrame) XXX_Size

func (m *DataFrame) XXX_Size() int

func (*DataFrame) XXX_Unmarshal

func (m *DataFrame) XXX_Unmarshal(b []byte) error

type Decimal

type Decimal struct {
	Value                int64    `protobuf:"varint,1,opt,name=Value,proto3" json:"Value,omitempty"`
	Scale                int64    `protobuf:"varint,2,opt,name=Scale,proto3" json:"Scale,omitempty"`
	NewVersion           bool     `protobuf:"varint,3,opt,name=NewVersion,proto3" json:"NewVersion,omitempty"`
	ValAbs               []byte   `protobuf:"bytes,4,opt,name=ValAbs,proto3" json:"ValAbs,omitempty"`
	ValNeg               bool     `protobuf:"varint,5,opt,name=ValNeg,proto3" json:"ValNeg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Decimal) Descriptor

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

func (*Decimal) GetNewVersion

func (m *Decimal) GetNewVersion() bool

func (*Decimal) GetScale

func (m *Decimal) GetScale() int64

func (*Decimal) GetValAbs

func (m *Decimal) GetValAbs() []byte

func (*Decimal) GetValNeg

func (m *Decimal) GetValNeg() bool

func (*Decimal) GetValue

func (m *Decimal) GetValue() int64

func (*Decimal) Marshal

func (m *Decimal) Marshal() (dAtA []byte, err error)

func (*Decimal) MarshalTo

func (m *Decimal) MarshalTo(dAtA []byte) (int, error)

func (*Decimal) MarshalToSizedBuffer

func (m *Decimal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Decimal) ProtoMessage

func (*Decimal) ProtoMessage()

func (*Decimal) Reset

func (m *Decimal) Reset()

func (*Decimal) Size

func (m *Decimal) Size() (n int)

func (*Decimal) String

func (m *Decimal) String() string

func (*Decimal) Unmarshal

func (m *Decimal) Unmarshal(dAtA []byte) error

func (*Decimal) XXX_DiscardUnknown

func (m *Decimal) XXX_DiscardUnknown()

func (*Decimal) XXX_Marshal

func (m *Decimal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Decimal) XXX_Merge

func (m *Decimal) XXX_Merge(src proto.Message)

func (*Decimal) XXX_Size

func (m *Decimal) XXX_Size() int

func (*Decimal) XXX_Unmarshal

func (m *Decimal) XXX_Unmarshal(b []byte) error

type Decoder

type Decoder struct {
	// contains filtered or unexported fields
}

Decoder decodes messages from a reader.

func NewDecoder

func NewDecoder(r io.Reader) *Decoder

NewDecoder returns a new instance of Decoder.

func (*Decoder) Decode

func (dec *Decoder) Decode(pb proto.Message) error

Decode reads all bytes from the reader and unmarshals them into pb.

type DeleteAvailableShardMessage

type DeleteAvailableShardMessage struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	ShardID              uint64   `protobuf:"varint,3,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteAvailableShardMessage) Descriptor

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

func (*DeleteAvailableShardMessage) GetField

func (m *DeleteAvailableShardMessage) GetField() string

func (*DeleteAvailableShardMessage) GetIndex

func (m *DeleteAvailableShardMessage) GetIndex() string

func (*DeleteAvailableShardMessage) GetShardID

func (m *DeleteAvailableShardMessage) GetShardID() uint64

func (*DeleteAvailableShardMessage) Marshal

func (m *DeleteAvailableShardMessage) Marshal() (dAtA []byte, err error)

func (*DeleteAvailableShardMessage) MarshalTo

func (m *DeleteAvailableShardMessage) MarshalTo(dAtA []byte) (int, error)

func (*DeleteAvailableShardMessage) MarshalToSizedBuffer

func (m *DeleteAvailableShardMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteAvailableShardMessage) ProtoMessage

func (*DeleteAvailableShardMessage) ProtoMessage()

func (*DeleteAvailableShardMessage) Reset

func (m *DeleteAvailableShardMessage) Reset()

func (*DeleteAvailableShardMessage) Size

func (m *DeleteAvailableShardMessage) Size() (n int)

func (*DeleteAvailableShardMessage) String

func (m *DeleteAvailableShardMessage) String() string

func (*DeleteAvailableShardMessage) Unmarshal

func (m *DeleteAvailableShardMessage) Unmarshal(dAtA []byte) error

func (*DeleteAvailableShardMessage) XXX_DiscardUnknown

func (m *DeleteAvailableShardMessage) XXX_DiscardUnknown()

func (*DeleteAvailableShardMessage) XXX_Marshal

func (m *DeleteAvailableShardMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteAvailableShardMessage) XXX_Merge

func (m *DeleteAvailableShardMessage) XXX_Merge(src proto.Message)

func (*DeleteAvailableShardMessage) XXX_Size

func (m *DeleteAvailableShardMessage) XXX_Size() int

func (*DeleteAvailableShardMessage) XXX_Unmarshal

func (m *DeleteAvailableShardMessage) XXX_Unmarshal(b []byte) error

type DeleteDataframeMessage

type DeleteDataframeMessage struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteDataframeMessage) Descriptor

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

func (*DeleteDataframeMessage) GetIndex

func (m *DeleteDataframeMessage) GetIndex() string

func (*DeleteDataframeMessage) Marshal

func (m *DeleteDataframeMessage) Marshal() (dAtA []byte, err error)

func (*DeleteDataframeMessage) MarshalTo

func (m *DeleteDataframeMessage) MarshalTo(dAtA []byte) (int, error)

func (*DeleteDataframeMessage) MarshalToSizedBuffer

func (m *DeleteDataframeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteDataframeMessage) ProtoMessage

func (*DeleteDataframeMessage) ProtoMessage()

func (*DeleteDataframeMessage) Reset

func (m *DeleteDataframeMessage) Reset()

func (*DeleteDataframeMessage) Size

func (m *DeleteDataframeMessage) Size() (n int)

func (*DeleteDataframeMessage) String

func (m *DeleteDataframeMessage) String() string

func (*DeleteDataframeMessage) Unmarshal

func (m *DeleteDataframeMessage) Unmarshal(dAtA []byte) error

func (*DeleteDataframeMessage) XXX_DiscardUnknown

func (m *DeleteDataframeMessage) XXX_DiscardUnknown()

func (*DeleteDataframeMessage) XXX_Marshal

func (m *DeleteDataframeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteDataframeMessage) XXX_Merge

func (m *DeleteDataframeMessage) XXX_Merge(src proto.Message)

func (*DeleteDataframeMessage) XXX_Size

func (m *DeleteDataframeMessage) XXX_Size() int

func (*DeleteDataframeMessage) XXX_Unmarshal

func (m *DeleteDataframeMessage) XXX_Unmarshal(b []byte) error

type DeleteFieldMessage

type DeleteFieldMessage struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteFieldMessage) Descriptor

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

func (*DeleteFieldMessage) GetField

func (m *DeleteFieldMessage) GetField() string

func (*DeleteFieldMessage) GetIndex

func (m *DeleteFieldMessage) GetIndex() string

func (*DeleteFieldMessage) Marshal

func (m *DeleteFieldMessage) Marshal() (dAtA []byte, err error)

func (*DeleteFieldMessage) MarshalTo

func (m *DeleteFieldMessage) MarshalTo(dAtA []byte) (int, error)

func (*DeleteFieldMessage) MarshalToSizedBuffer

func (m *DeleteFieldMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteFieldMessage) ProtoMessage

func (*DeleteFieldMessage) ProtoMessage()

func (*DeleteFieldMessage) Reset

func (m *DeleteFieldMessage) Reset()

func (*DeleteFieldMessage) Size

func (m *DeleteFieldMessage) Size() (n int)

func (*DeleteFieldMessage) String

func (m *DeleteFieldMessage) String() string

func (*DeleteFieldMessage) Unmarshal

func (m *DeleteFieldMessage) Unmarshal(dAtA []byte) error

func (*DeleteFieldMessage) XXX_DiscardUnknown

func (m *DeleteFieldMessage) XXX_DiscardUnknown()

func (*DeleteFieldMessage) XXX_Marshal

func (m *DeleteFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteFieldMessage) XXX_Merge

func (m *DeleteFieldMessage) XXX_Merge(src proto.Message)

func (*DeleteFieldMessage) XXX_Size

func (m *DeleteFieldMessage) XXX_Size() int

func (*DeleteFieldMessage) XXX_Unmarshal

func (m *DeleteFieldMessage) XXX_Unmarshal(b []byte) error

type DeleteIndexMessage

type DeleteIndexMessage struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteIndexMessage) Descriptor

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

func (*DeleteIndexMessage) GetIndex

func (m *DeleteIndexMessage) GetIndex() string

func (*DeleteIndexMessage) Marshal

func (m *DeleteIndexMessage) Marshal() (dAtA []byte, err error)

func (*DeleteIndexMessage) MarshalTo

func (m *DeleteIndexMessage) MarshalTo(dAtA []byte) (int, error)

func (*DeleteIndexMessage) MarshalToSizedBuffer

func (m *DeleteIndexMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteIndexMessage) ProtoMessage

func (*DeleteIndexMessage) ProtoMessage()

func (*DeleteIndexMessage) Reset

func (m *DeleteIndexMessage) Reset()

func (*DeleteIndexMessage) Size

func (m *DeleteIndexMessage) Size() (n int)

func (*DeleteIndexMessage) String

func (m *DeleteIndexMessage) String() string

func (*DeleteIndexMessage) Unmarshal

func (m *DeleteIndexMessage) Unmarshal(dAtA []byte) error

func (*DeleteIndexMessage) XXX_DiscardUnknown

func (m *DeleteIndexMessage) XXX_DiscardUnknown()

func (*DeleteIndexMessage) XXX_Marshal

func (m *DeleteIndexMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteIndexMessage) XXX_Merge

func (m *DeleteIndexMessage) XXX_Merge(src proto.Message)

func (*DeleteIndexMessage) XXX_Size

func (m *DeleteIndexMessage) XXX_Size() int

func (*DeleteIndexMessage) XXX_Unmarshal

func (m *DeleteIndexMessage) XXX_Unmarshal(b []byte) error

type DeleteViewMessage

type DeleteViewMessage struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	View                 string   `protobuf:"bytes,3,opt,name=View,proto3" json:"View,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteViewMessage) Descriptor

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

func (*DeleteViewMessage) GetField

func (m *DeleteViewMessage) GetField() string

func (*DeleteViewMessage) GetIndex

func (m *DeleteViewMessage) GetIndex() string

func (*DeleteViewMessage) GetView

func (m *DeleteViewMessage) GetView() string

func (*DeleteViewMessage) Marshal

func (m *DeleteViewMessage) Marshal() (dAtA []byte, err error)

func (*DeleteViewMessage) MarshalTo

func (m *DeleteViewMessage) MarshalTo(dAtA []byte) (int, error)

func (*DeleteViewMessage) MarshalToSizedBuffer

func (m *DeleteViewMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteViewMessage) ProtoMessage

func (*DeleteViewMessage) ProtoMessage()

func (*DeleteViewMessage) Reset

func (m *DeleteViewMessage) Reset()

func (*DeleteViewMessage) Size

func (m *DeleteViewMessage) Size() (n int)

func (*DeleteViewMessage) String

func (m *DeleteViewMessage) String() string

func (*DeleteViewMessage) Unmarshal

func (m *DeleteViewMessage) Unmarshal(dAtA []byte) error

func (*DeleteViewMessage) XXX_DiscardUnknown

func (m *DeleteViewMessage) XXX_DiscardUnknown()

func (*DeleteViewMessage) XXX_Marshal

func (m *DeleteViewMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteViewMessage) XXX_Merge

func (m *DeleteViewMessage) XXX_Merge(src proto.Message)

func (*DeleteViewMessage) XXX_Size

func (m *DeleteViewMessage) XXX_Size() int

func (*DeleteViewMessage) XXX_Unmarshal

func (m *DeleteViewMessage) XXX_Unmarshal(b []byte) error

type DistinctTimestamp

type DistinctTimestamp struct {
	Values               []string `protobuf:"bytes,1,rep,name=Values,proto3" json:"Values,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DistinctTimestamp) Descriptor

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

func (*DistinctTimestamp) GetName

func (m *DistinctTimestamp) GetName() string

func (*DistinctTimestamp) GetValues

func (m *DistinctTimestamp) GetValues() []string

func (*DistinctTimestamp) Marshal

func (m *DistinctTimestamp) Marshal() (dAtA []byte, err error)

func (*DistinctTimestamp) MarshalTo

func (m *DistinctTimestamp) MarshalTo(dAtA []byte) (int, error)

func (*DistinctTimestamp) MarshalToSizedBuffer

func (m *DistinctTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DistinctTimestamp) ProtoMessage

func (*DistinctTimestamp) ProtoMessage()

func (*DistinctTimestamp) Reset

func (m *DistinctTimestamp) Reset()

func (*DistinctTimestamp) Size

func (m *DistinctTimestamp) Size() (n int)

func (*DistinctTimestamp) String

func (m *DistinctTimestamp) String() string

func (*DistinctTimestamp) Unmarshal

func (m *DistinctTimestamp) Unmarshal(dAtA []byte) error

func (*DistinctTimestamp) XXX_DiscardUnknown

func (m *DistinctTimestamp) XXX_DiscardUnknown()

func (*DistinctTimestamp) XXX_Marshal

func (m *DistinctTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DistinctTimestamp) XXX_Merge

func (m *DistinctTimestamp) XXX_Merge(src proto.Message)

func (*DistinctTimestamp) XXX_Size

func (m *DistinctTimestamp) XXX_Size() int

func (*DistinctTimestamp) XXX_Unmarshal

func (m *DistinctTimestamp) XXX_Unmarshal(b []byte) error

type Encoder

type Encoder struct {
	// contains filtered or unexported fields
}

Encoder encodes messages to a writer.

func NewEncoder

func NewEncoder(w io.Writer) *Encoder

NewEncoder returns a new instance of Encoder.

func (*Encoder) Encode

func (enc *Encoder) Encode(pb proto.Message) error

Encode marshals m into bytes and writes them to r.

type ExtractedIDColumn

type ExtractedIDColumn struct {
	ID                   uint64    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Vals                 []*IDList `protobuf:"bytes,2,rep,name=Vals,proto3" json:"Vals,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ExtractedIDColumn) Descriptor

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

func (*ExtractedIDColumn) GetID

func (m *ExtractedIDColumn) GetID() uint64

func (*ExtractedIDColumn) GetVals

func (m *ExtractedIDColumn) GetVals() []*IDList

func (*ExtractedIDColumn) Marshal

func (m *ExtractedIDColumn) Marshal() (dAtA []byte, err error)

func (*ExtractedIDColumn) MarshalTo

func (m *ExtractedIDColumn) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedIDColumn) MarshalToSizedBuffer

func (m *ExtractedIDColumn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedIDColumn) ProtoMessage

func (*ExtractedIDColumn) ProtoMessage()

func (*ExtractedIDColumn) Reset

func (m *ExtractedIDColumn) Reset()

func (*ExtractedIDColumn) Size

func (m *ExtractedIDColumn) Size() (n int)

func (*ExtractedIDColumn) String

func (m *ExtractedIDColumn) String() string

func (*ExtractedIDColumn) Unmarshal

func (m *ExtractedIDColumn) Unmarshal(dAtA []byte) error

func (*ExtractedIDColumn) XXX_DiscardUnknown

func (m *ExtractedIDColumn) XXX_DiscardUnknown()

func (*ExtractedIDColumn) XXX_Marshal

func (m *ExtractedIDColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExtractedIDColumn) XXX_Merge

func (m *ExtractedIDColumn) XXX_Merge(src proto.Message)

func (*ExtractedIDColumn) XXX_Size

func (m *ExtractedIDColumn) XXX_Size() int

func (*ExtractedIDColumn) XXX_Unmarshal

func (m *ExtractedIDColumn) XXX_Unmarshal(b []byte) error

type ExtractedIDMatrix

type ExtractedIDMatrix struct {
	Fields               []string             `protobuf:"bytes,1,rep,name=Fields,proto3" json:"Fields,omitempty"`
	Columns              []*ExtractedIDColumn `protobuf:"bytes,2,rep,name=Columns,proto3" json:"Columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ExtractedIDMatrix) Descriptor

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

func (*ExtractedIDMatrix) GetColumns

func (m *ExtractedIDMatrix) GetColumns() []*ExtractedIDColumn

func (*ExtractedIDMatrix) GetFields

func (m *ExtractedIDMatrix) GetFields() []string

func (*ExtractedIDMatrix) Marshal

func (m *ExtractedIDMatrix) Marshal() (dAtA []byte, err error)

func (*ExtractedIDMatrix) MarshalTo

func (m *ExtractedIDMatrix) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedIDMatrix) MarshalToSizedBuffer

func (m *ExtractedIDMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedIDMatrix) ProtoMessage

func (*ExtractedIDMatrix) ProtoMessage()

func (*ExtractedIDMatrix) Reset

func (m *ExtractedIDMatrix) Reset()

func (*ExtractedIDMatrix) Size

func (m *ExtractedIDMatrix) Size() (n int)

func (*ExtractedIDMatrix) String

func (m *ExtractedIDMatrix) String() string

func (*ExtractedIDMatrix) Unmarshal

func (m *ExtractedIDMatrix) Unmarshal(dAtA []byte) error

func (*ExtractedIDMatrix) XXX_DiscardUnknown

func (m *ExtractedIDMatrix) XXX_DiscardUnknown()

func (*ExtractedIDMatrix) XXX_Marshal

func (m *ExtractedIDMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExtractedIDMatrix) XXX_Merge

func (m *ExtractedIDMatrix) XXX_Merge(src proto.Message)

func (*ExtractedIDMatrix) XXX_Size

func (m *ExtractedIDMatrix) XXX_Size() int

func (*ExtractedIDMatrix) XXX_Unmarshal

func (m *ExtractedIDMatrix) XXX_Unmarshal(b []byte) error

type ExtractedIDMatrixSorted

type ExtractedIDMatrixSorted struct {
	ExtractedIDMatrix    *ExtractedIDMatrix `protobuf:"bytes,1,opt,name=ExtractedIDMatrix,proto3" json:"ExtractedIDMatrix,omitempty"`
	RowKVs               []*RowKV           `protobuf:"bytes,2,rep,name=RowKVs,proto3" json:"RowKVs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ExtractedIDMatrixSorted) Descriptor

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

func (*ExtractedIDMatrixSorted) GetExtractedIDMatrix

func (m *ExtractedIDMatrixSorted) GetExtractedIDMatrix() *ExtractedIDMatrix

func (*ExtractedIDMatrixSorted) GetRowKVs

func (m *ExtractedIDMatrixSorted) GetRowKVs() []*RowKV

func (*ExtractedIDMatrixSorted) Marshal

func (m *ExtractedIDMatrixSorted) Marshal() (dAtA []byte, err error)

func (*ExtractedIDMatrixSorted) MarshalTo

func (m *ExtractedIDMatrixSorted) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedIDMatrixSorted) MarshalToSizedBuffer

func (m *ExtractedIDMatrixSorted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedIDMatrixSorted) ProtoMessage

func (*ExtractedIDMatrixSorted) ProtoMessage()

func (*ExtractedIDMatrixSorted) Reset

func (m *ExtractedIDMatrixSorted) Reset()

func (*ExtractedIDMatrixSorted) Size

func (m *ExtractedIDMatrixSorted) Size() (n int)

func (*ExtractedIDMatrixSorted) String

func (m *ExtractedIDMatrixSorted) String() string

func (*ExtractedIDMatrixSorted) Unmarshal

func (m *ExtractedIDMatrixSorted) Unmarshal(dAtA []byte) error

func (*ExtractedIDMatrixSorted) XXX_DiscardUnknown

func (m *ExtractedIDMatrixSorted) XXX_DiscardUnknown()

func (*ExtractedIDMatrixSorted) XXX_Marshal

func (m *ExtractedIDMatrixSorted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExtractedIDMatrixSorted) XXX_Merge

func (m *ExtractedIDMatrixSorted) XXX_Merge(src proto.Message)

func (*ExtractedIDMatrixSorted) XXX_Size

func (m *ExtractedIDMatrixSorted) XXX_Size() int

func (*ExtractedIDMatrixSorted) XXX_Unmarshal

func (m *ExtractedIDMatrixSorted) XXX_Unmarshal(b []byte) error

type ExtractedTable

type ExtractedTable struct {
	Fields               []*ExtractedTableField  `protobuf:"bytes,1,rep,name=Fields,proto3" json:"Fields,omitempty"`
	Columns              []*ExtractedTableColumn `protobuf:"bytes,2,rep,name=Columns,proto3" json:"Columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ExtractedTable) Descriptor

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

func (*ExtractedTable) GetColumns

func (m *ExtractedTable) GetColumns() []*ExtractedTableColumn

func (*ExtractedTable) GetFields

func (m *ExtractedTable) GetFields() []*ExtractedTableField

func (*ExtractedTable) Marshal

func (m *ExtractedTable) Marshal() (dAtA []byte, err error)

func (*ExtractedTable) MarshalTo

func (m *ExtractedTable) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTable) MarshalToSizedBuffer

func (m *ExtractedTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTable) ProtoMessage

func (*ExtractedTable) ProtoMessage()

func (*ExtractedTable) Reset

func (m *ExtractedTable) Reset()

func (*ExtractedTable) Size

func (m *ExtractedTable) Size() (n int)

func (*ExtractedTable) String

func (m *ExtractedTable) String() string

func (*ExtractedTable) Unmarshal

func (m *ExtractedTable) Unmarshal(dAtA []byte) error

func (*ExtractedTable) XXX_DiscardUnknown

func (m *ExtractedTable) XXX_DiscardUnknown()

func (*ExtractedTable) XXX_Marshal

func (m *ExtractedTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExtractedTable) XXX_Merge

func (m *ExtractedTable) XXX_Merge(src proto.Message)

func (*ExtractedTable) XXX_Size

func (m *ExtractedTable) XXX_Size() int

func (*ExtractedTable) XXX_Unmarshal

func (m *ExtractedTable) XXX_Unmarshal(b []byte) error

type ExtractedTableColumn

type ExtractedTableColumn struct {
	// Types that are valid to be assigned to KeyOrID:
	//	*ExtractedTableColumn_Key
	//	*ExtractedTableColumn_ID
	KeyOrID              isExtractedTableColumn_KeyOrID `protobuf_oneof:"KeyOrID"`
	Values               []*ExtractedTableValue         `protobuf:"bytes,3,rep,name=Values,proto3" json:"Values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ExtractedTableColumn) Descriptor

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

func (*ExtractedTableColumn) GetID

func (m *ExtractedTableColumn) GetID() uint64

func (*ExtractedTableColumn) GetKey

func (m *ExtractedTableColumn) GetKey() string

func (*ExtractedTableColumn) GetKeyOrID

func (m *ExtractedTableColumn) GetKeyOrID() isExtractedTableColumn_KeyOrID

func (*ExtractedTableColumn) GetValues

func (m *ExtractedTableColumn) GetValues() []*ExtractedTableValue

func (*ExtractedTableColumn) Marshal

func (m *ExtractedTableColumn) Marshal() (dAtA []byte, err error)

func (*ExtractedTableColumn) MarshalTo

func (m *ExtractedTableColumn) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableColumn) MarshalToSizedBuffer

func (m *ExtractedTableColumn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableColumn) ProtoMessage

func (*ExtractedTableColumn) ProtoMessage()

func (*ExtractedTableColumn) Reset

func (m *ExtractedTableColumn) Reset()

func (*ExtractedTableColumn) Size

func (m *ExtractedTableColumn) Size() (n int)

func (*ExtractedTableColumn) String

func (m *ExtractedTableColumn) String() string

func (*ExtractedTableColumn) Unmarshal

func (m *ExtractedTableColumn) Unmarshal(dAtA []byte) error

func (*ExtractedTableColumn) XXX_DiscardUnknown

func (m *ExtractedTableColumn) XXX_DiscardUnknown()

func (*ExtractedTableColumn) XXX_Marshal

func (m *ExtractedTableColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExtractedTableColumn) XXX_Merge

func (m *ExtractedTableColumn) XXX_Merge(src proto.Message)

func (*ExtractedTableColumn) XXX_OneofWrappers

func (*ExtractedTableColumn) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExtractedTableColumn) XXX_Size

func (m *ExtractedTableColumn) XXX_Size() int

func (*ExtractedTableColumn) XXX_Unmarshal

func (m *ExtractedTableColumn) XXX_Unmarshal(b []byte) error

type ExtractedTableColumn_ID

type ExtractedTableColumn_ID struct {
	ID uint64 `protobuf:"varint,2,opt,name=ID,proto3,oneof" json:"ID,omitempty"`
}

func (*ExtractedTableColumn_ID) MarshalTo

func (m *ExtractedTableColumn_ID) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableColumn_ID) MarshalToSizedBuffer

func (m *ExtractedTableColumn_ID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableColumn_ID) Size

func (m *ExtractedTableColumn_ID) Size() (n int)

type ExtractedTableColumn_Key

type ExtractedTableColumn_Key struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3,oneof" json:"Key,omitempty"`
}

func (*ExtractedTableColumn_Key) MarshalTo

func (m *ExtractedTableColumn_Key) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableColumn_Key) MarshalToSizedBuffer

func (m *ExtractedTableColumn_Key) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableColumn_Key) Size

func (m *ExtractedTableColumn_Key) Size() (n int)

type ExtractedTableField

type ExtractedTableField struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Type                 string   `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExtractedTableField) Descriptor

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

func (*ExtractedTableField) GetName

func (m *ExtractedTableField) GetName() string

func (*ExtractedTableField) GetType

func (m *ExtractedTableField) GetType() string

func (*ExtractedTableField) Marshal

func (m *ExtractedTableField) Marshal() (dAtA []byte, err error)

func (*ExtractedTableField) MarshalTo

func (m *ExtractedTableField) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableField) MarshalToSizedBuffer

func (m *ExtractedTableField) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableField) ProtoMessage

func (*ExtractedTableField) ProtoMessage()

func (*ExtractedTableField) Reset

func (m *ExtractedTableField) Reset()

func (*ExtractedTableField) Size

func (m *ExtractedTableField) Size() (n int)

func (*ExtractedTableField) String

func (m *ExtractedTableField) String() string

func (*ExtractedTableField) Unmarshal

func (m *ExtractedTableField) Unmarshal(dAtA []byte) error

func (*ExtractedTableField) XXX_DiscardUnknown

func (m *ExtractedTableField) XXX_DiscardUnknown()

func (*ExtractedTableField) XXX_Marshal

func (m *ExtractedTableField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExtractedTableField) XXX_Merge

func (m *ExtractedTableField) XXX_Merge(src proto.Message)

func (*ExtractedTableField) XXX_Size

func (m *ExtractedTableField) XXX_Size() int

func (*ExtractedTableField) XXX_Unmarshal

func (m *ExtractedTableField) XXX_Unmarshal(b []byte) error

type ExtractedTableValue

type ExtractedTableValue struct {
	// Types that are valid to be assigned to Value:
	//	*ExtractedTableValue_IDs
	//	*ExtractedTableValue_Keys
	//	*ExtractedTableValue_BSIValue
	//	*ExtractedTableValue_MutexID
	//	*ExtractedTableValue_MutexKey
	//	*ExtractedTableValue_Bool
	Value                isExtractedTableValue_Value `protobuf_oneof:"Value"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ExtractedTableValue) Descriptor

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

func (*ExtractedTableValue) GetBSIValue

func (m *ExtractedTableValue) GetBSIValue() int64

func (*ExtractedTableValue) GetBool

func (m *ExtractedTableValue) GetBool() bool

func (*ExtractedTableValue) GetIDs

func (m *ExtractedTableValue) GetIDs() *IDList

func (*ExtractedTableValue) GetKeys

func (m *ExtractedTableValue) GetKeys() *KeyList

func (*ExtractedTableValue) GetMutexID

func (m *ExtractedTableValue) GetMutexID() uint64

func (*ExtractedTableValue) GetMutexKey

func (m *ExtractedTableValue) GetMutexKey() string

func (*ExtractedTableValue) GetValue

func (m *ExtractedTableValue) GetValue() isExtractedTableValue_Value

func (*ExtractedTableValue) Marshal

func (m *ExtractedTableValue) Marshal() (dAtA []byte, err error)

func (*ExtractedTableValue) MarshalTo

func (m *ExtractedTableValue) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableValue) MarshalToSizedBuffer

func (m *ExtractedTableValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableValue) ProtoMessage

func (*ExtractedTableValue) ProtoMessage()

func (*ExtractedTableValue) Reset

func (m *ExtractedTableValue) Reset()

func (*ExtractedTableValue) Size

func (m *ExtractedTableValue) Size() (n int)

func (*ExtractedTableValue) String

func (m *ExtractedTableValue) String() string

func (*ExtractedTableValue) Unmarshal

func (m *ExtractedTableValue) Unmarshal(dAtA []byte) error

func (*ExtractedTableValue) XXX_DiscardUnknown

func (m *ExtractedTableValue) XXX_DiscardUnknown()

func (*ExtractedTableValue) XXX_Marshal

func (m *ExtractedTableValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExtractedTableValue) XXX_Merge

func (m *ExtractedTableValue) XXX_Merge(src proto.Message)

func (*ExtractedTableValue) XXX_OneofWrappers

func (*ExtractedTableValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExtractedTableValue) XXX_Size

func (m *ExtractedTableValue) XXX_Size() int

func (*ExtractedTableValue) XXX_Unmarshal

func (m *ExtractedTableValue) XXX_Unmarshal(b []byte) error

type ExtractedTableValue_BSIValue

type ExtractedTableValue_BSIValue struct {
	BSIValue int64 `protobuf:"varint,3,opt,name=BSIValue,proto3,oneof" json:"BSIValue,omitempty"`
}

func (*ExtractedTableValue_BSIValue) MarshalTo

func (m *ExtractedTableValue_BSIValue) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableValue_BSIValue) MarshalToSizedBuffer

func (m *ExtractedTableValue_BSIValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableValue_BSIValue) Size

func (m *ExtractedTableValue_BSIValue) Size() (n int)

type ExtractedTableValue_Bool

type ExtractedTableValue_Bool struct {
	Bool bool `protobuf:"varint,6,opt,name=Bool,proto3,oneof" json:"Bool,omitempty"`
}

func (*ExtractedTableValue_Bool) MarshalTo

func (m *ExtractedTableValue_Bool) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableValue_Bool) MarshalToSizedBuffer

func (m *ExtractedTableValue_Bool) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableValue_Bool) Size

func (m *ExtractedTableValue_Bool) Size() (n int)

type ExtractedTableValue_IDs

type ExtractedTableValue_IDs struct {
	IDs *IDList `protobuf:"bytes,1,opt,name=IDs,proto3,oneof" json:"IDs,omitempty"`
}

func (*ExtractedTableValue_IDs) MarshalTo

func (m *ExtractedTableValue_IDs) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableValue_IDs) MarshalToSizedBuffer

func (m *ExtractedTableValue_IDs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableValue_IDs) Size

func (m *ExtractedTableValue_IDs) Size() (n int)

type ExtractedTableValue_Keys

type ExtractedTableValue_Keys struct {
	Keys *KeyList `protobuf:"bytes,2,opt,name=Keys,proto3,oneof" json:"Keys,omitempty"`
}

func (*ExtractedTableValue_Keys) MarshalTo

func (m *ExtractedTableValue_Keys) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableValue_Keys) MarshalToSizedBuffer

func (m *ExtractedTableValue_Keys) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableValue_Keys) Size

func (m *ExtractedTableValue_Keys) Size() (n int)

type ExtractedTableValue_MutexID

type ExtractedTableValue_MutexID struct {
	MutexID uint64 `protobuf:"varint,4,opt,name=MutexID,proto3,oneof" json:"MutexID,omitempty"`
}

func (*ExtractedTableValue_MutexID) MarshalTo

func (m *ExtractedTableValue_MutexID) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableValue_MutexID) MarshalToSizedBuffer

func (m *ExtractedTableValue_MutexID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableValue_MutexID) Size

func (m *ExtractedTableValue_MutexID) Size() (n int)

type ExtractedTableValue_MutexKey

type ExtractedTableValue_MutexKey struct {
	MutexKey string `protobuf:"bytes,5,opt,name=MutexKey,proto3,oneof" json:"MutexKey,omitempty"`
}

func (*ExtractedTableValue_MutexKey) MarshalTo

func (m *ExtractedTableValue_MutexKey) MarshalTo(dAtA []byte) (int, error)

func (*ExtractedTableValue_MutexKey) MarshalToSizedBuffer

func (m *ExtractedTableValue_MutexKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExtractedTableValue_MutexKey) Size

func (m *ExtractedTableValue_MutexKey) Size() (n int)

type Field

type Field struct {
	Name                 string        `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Meta                 *FieldOptions `protobuf:"bytes,2,opt,name=Meta,proto3" json:"Meta,omitempty"`
	Views                []string      `protobuf:"bytes,3,rep,name=Views,proto3" json:"Views,omitempty"`
	CreatedAt            int64         `protobuf:"varint,4,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Field) Descriptor

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

func (*Field) GetCreatedAt

func (m *Field) GetCreatedAt() int64

func (*Field) GetMeta

func (m *Field) GetMeta() *FieldOptions

func (*Field) GetName

func (m *Field) GetName() string

func (*Field) GetViews

func (m *Field) GetViews() []string

func (*Field) Marshal

func (m *Field) Marshal() (dAtA []byte, err error)

func (*Field) MarshalTo

func (m *Field) MarshalTo(dAtA []byte) (int, error)

func (*Field) MarshalToSizedBuffer

func (m *Field) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Field) ProtoMessage

func (*Field) ProtoMessage()

func (*Field) Reset

func (m *Field) Reset()

func (*Field) Size

func (m *Field) Size() (n int)

func (*Field) String

func (m *Field) String() string

func (*Field) Unmarshal

func (m *Field) Unmarshal(dAtA []byte) error

func (*Field) XXX_DiscardUnknown

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal

func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Field) XXX_Merge

func (m *Field) XXX_Merge(src proto.Message)

func (*Field) XXX_Size

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal

func (m *Field) XXX_Unmarshal(b []byte) error

type FieldOperation

type FieldOperation struct {
	RecordIDs            []uint64 `protobuf:"varint,1,rep,packed,name=RecordIDs,proto3" json:"RecordIDs,omitempty"`
	Values               []uint64 `protobuf:"varint,2,rep,packed,name=Values,proto3" json:"Values,omitempty"`
	Signed               []int64  `protobuf:"varint,3,rep,packed,name=Signed,proto3" json:"Signed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldOperation) Descriptor

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

func (*FieldOperation) GetRecordIDs

func (m *FieldOperation) GetRecordIDs() []uint64

func (*FieldOperation) GetSigned

func (m *FieldOperation) GetSigned() []int64

func (*FieldOperation) GetValues

func (m *FieldOperation) GetValues() []uint64

func (*FieldOperation) Marshal

func (m *FieldOperation) Marshal() (dAtA []byte, err error)

func (*FieldOperation) MarshalTo

func (m *FieldOperation) MarshalTo(dAtA []byte) (int, error)

func (*FieldOperation) MarshalToSizedBuffer

func (m *FieldOperation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FieldOperation) ProtoMessage

func (*FieldOperation) ProtoMessage()

func (*FieldOperation) Reset

func (m *FieldOperation) Reset()

func (*FieldOperation) Size

func (m *FieldOperation) Size() (n int)

func (*FieldOperation) String

func (m *FieldOperation) String() string

func (*FieldOperation) Unmarshal

func (m *FieldOperation) Unmarshal(dAtA []byte) error

func (*FieldOperation) XXX_DiscardUnknown

func (m *FieldOperation) XXX_DiscardUnknown()

func (*FieldOperation) XXX_Marshal

func (m *FieldOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldOperation) XXX_Merge

func (m *FieldOperation) XXX_Merge(src proto.Message)

func (*FieldOperation) XXX_Size

func (m *FieldOperation) XXX_Size() int

func (*FieldOperation) XXX_Unmarshal

func (m *FieldOperation) XXX_Unmarshal(b []byte) error

type FieldOptions

type FieldOptions struct {
	Type                 string   `protobuf:"bytes,8,opt,name=Type,proto3" json:"Type,omitempty"`
	CacheType            string   `protobuf:"bytes,3,opt,name=CacheType,proto3" json:"CacheType,omitempty"`
	CacheSize            uint32   `protobuf:"varint,4,opt,name=CacheSize,proto3" json:"CacheSize,omitempty"`
	TimeQuantum          string   `protobuf:"bytes,5,opt,name=TimeQuantum,proto3" json:"TimeQuantum,omitempty"`
	OldMin               int64    `protobuf:"varint,9,opt,name=OldMin,proto3" json:"OldMin,omitempty"`
	OldMax               int64    `protobuf:"varint,10,opt,name=OldMax,proto3" json:"OldMax,omitempty"`
	Keys                 bool     `protobuf:"varint,11,opt,name=Keys,proto3" json:"Keys,omitempty"`
	NoStandardView       bool     `protobuf:"varint,12,opt,name=NoStandardView,proto3" json:"NoStandardView,omitempty"`
	Base                 int64    `protobuf:"varint,13,opt,name=Base,proto3" json:"Base,omitempty"`
	BitDepth             uint64   `protobuf:"varint,14,opt,name=BitDepth,proto3" json:"BitDepth,omitempty"`
	Scale                int64    `protobuf:"varint,15,opt,name=Scale,proto3" json:"Scale,omitempty"`
	ForeignIndex         string   `protobuf:"bytes,16,opt,name=ForeignIndex,proto3" json:"ForeignIndex,omitempty"`
	Min                  *Decimal `protobuf:"bytes,17,opt,name=Min,proto3" json:"Min,omitempty"`
	Max                  *Decimal `protobuf:"bytes,18,opt,name=Max,proto3" json:"Max,omitempty"`
	TimeUnit             string   `protobuf:"bytes,19,opt,name=TimeUnit,proto3" json:"TimeUnit,omitempty"`
	TTL                  string   `protobuf:"bytes,20,opt,name=TTL,proto3" json:"TTL,omitempty"`
	TrackExistence       bool     `protobuf:"varint,21,opt,name=TrackExistence,proto3" json:"TrackExistence,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldOptions) Descriptor

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

func (*FieldOptions) GetBase

func (m *FieldOptions) GetBase() int64

func (*FieldOptions) GetBitDepth

func (m *FieldOptions) GetBitDepth() uint64

func (*FieldOptions) GetCacheSize

func (m *FieldOptions) GetCacheSize() uint32

func (*FieldOptions) GetCacheType

func (m *FieldOptions) GetCacheType() string

func (*FieldOptions) GetForeignIndex

func (m *FieldOptions) GetForeignIndex() string

func (*FieldOptions) GetKeys

func (m *FieldOptions) GetKeys() bool

func (*FieldOptions) GetMax

func (m *FieldOptions) GetMax() *Decimal

func (*FieldOptions) GetMin

func (m *FieldOptions) GetMin() *Decimal

func (*FieldOptions) GetNoStandardView

func (m *FieldOptions) GetNoStandardView() bool

func (*FieldOptions) GetOldMax

func (m *FieldOptions) GetOldMax() int64

func (*FieldOptions) GetOldMin

func (m *FieldOptions) GetOldMin() int64

func (*FieldOptions) GetScale

func (m *FieldOptions) GetScale() int64

func (*FieldOptions) GetTTL

func (m *FieldOptions) GetTTL() string

func (*FieldOptions) GetTimeQuantum

func (m *FieldOptions) GetTimeQuantum() string

func (*FieldOptions) GetTimeUnit

func (m *FieldOptions) GetTimeUnit() string

func (*FieldOptions) GetTrackExistence added in v3.35.0

func (m *FieldOptions) GetTrackExistence() bool

func (*FieldOptions) GetType

func (m *FieldOptions) GetType() string

func (*FieldOptions) Marshal

func (m *FieldOptions) Marshal() (dAtA []byte, err error)

func (*FieldOptions) MarshalTo

func (m *FieldOptions) MarshalTo(dAtA []byte) (int, error)

func (*FieldOptions) MarshalToSizedBuffer

func (m *FieldOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FieldOptions) ProtoMessage

func (*FieldOptions) ProtoMessage()

func (*FieldOptions) Reset

func (m *FieldOptions) Reset()

func (*FieldOptions) Size

func (m *FieldOptions) Size() (n int)

func (*FieldOptions) String

func (m *FieldOptions) String() string

func (*FieldOptions) Unmarshal

func (m *FieldOptions) Unmarshal(dAtA []byte) error

func (*FieldOptions) XXX_DiscardUnknown

func (m *FieldOptions) XXX_DiscardUnknown()

func (*FieldOptions) XXX_Marshal

func (m *FieldOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldOptions) XXX_Merge

func (m *FieldOptions) XXX_Merge(src proto.Message)

func (*FieldOptions) XXX_Size

func (m *FieldOptions) XXX_Size() int

func (*FieldOptions) XXX_Unmarshal

func (m *FieldOptions) XXX_Unmarshal(b []byte) error

type FieldRow

type FieldRow struct {
	Field                string   `protobuf:"bytes,1,opt,name=Field,proto3" json:"Field,omitempty"`
	RowID                uint64   `protobuf:"varint,2,opt,name=RowID,proto3" json:"RowID,omitempty"`
	RowKey               string   `protobuf:"bytes,3,opt,name=RowKey,proto3" json:"RowKey,omitempty"`
	Value                *Int64   `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldRow) Descriptor

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

func (*FieldRow) GetField

func (m *FieldRow) GetField() string

func (*FieldRow) GetRowID

func (m *FieldRow) GetRowID() uint64

func (*FieldRow) GetRowKey

func (m *FieldRow) GetRowKey() string

func (*FieldRow) GetValue

func (m *FieldRow) GetValue() *Int64

func (*FieldRow) Marshal

func (m *FieldRow) Marshal() (dAtA []byte, err error)

func (*FieldRow) MarshalTo

func (m *FieldRow) MarshalTo(dAtA []byte) (int, error)

func (*FieldRow) MarshalToSizedBuffer

func (m *FieldRow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FieldRow) ProtoMessage

func (*FieldRow) ProtoMessage()

func (*FieldRow) Reset

func (m *FieldRow) Reset()

func (*FieldRow) Size

func (m *FieldRow) Size() (n int)

func (*FieldRow) String

func (m *FieldRow) String() string

func (*FieldRow) Unmarshal

func (m *FieldRow) Unmarshal(dAtA []byte) error

func (*FieldRow) XXX_DiscardUnknown

func (m *FieldRow) XXX_DiscardUnknown()

func (*FieldRow) XXX_Marshal

func (m *FieldRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldRow) XXX_Merge

func (m *FieldRow) XXX_Merge(src proto.Message)

func (*FieldRow) XXX_Size

func (m *FieldRow) XXX_Size() int

func (*FieldRow) XXX_Unmarshal

func (m *FieldRow) XXX_Unmarshal(b []byte) error

type FieldStatus

type FieldStatus struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	AvailableShards      []uint64 `protobuf:"varint,2,rep,packed,name=AvailableShards,proto3" json:"AvailableShards,omitempty"`
	CreatedAt            int64    `protobuf:"varint,3,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldStatus) Descriptor

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

func (*FieldStatus) GetAvailableShards

func (m *FieldStatus) GetAvailableShards() []uint64

func (*FieldStatus) GetCreatedAt

func (m *FieldStatus) GetCreatedAt() int64

func (*FieldStatus) GetName

func (m *FieldStatus) GetName() string

func (*FieldStatus) Marshal

func (m *FieldStatus) Marshal() (dAtA []byte, err error)

func (*FieldStatus) MarshalTo

func (m *FieldStatus) MarshalTo(dAtA []byte) (int, error)

func (*FieldStatus) MarshalToSizedBuffer

func (m *FieldStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FieldStatus) ProtoMessage

func (*FieldStatus) ProtoMessage()

func (*FieldStatus) Reset

func (m *FieldStatus) Reset()

func (*FieldStatus) Size

func (m *FieldStatus) Size() (n int)

func (*FieldStatus) String

func (m *FieldStatus) String() string

func (*FieldStatus) Unmarshal

func (m *FieldStatus) Unmarshal(dAtA []byte) error

func (*FieldStatus) XXX_DiscardUnknown

func (m *FieldStatus) XXX_DiscardUnknown()

func (*FieldStatus) XXX_Marshal

func (m *FieldStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldStatus) XXX_Merge

func (m *FieldStatus) XXX_Merge(src proto.Message)

func (*FieldStatus) XXX_Size

func (m *FieldStatus) XXX_Size() int

func (*FieldStatus) XXX_Unmarshal

func (m *FieldStatus) XXX_Unmarshal(b []byte) error

type FieldUpdate

type FieldUpdate struct {
	Option               string   `protobuf:"bytes,1,opt,name=Option,proto3" json:"Option,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldUpdate) Descriptor

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

func (*FieldUpdate) GetOption

func (m *FieldUpdate) GetOption() string

func (*FieldUpdate) GetValue

func (m *FieldUpdate) GetValue() string

func (*FieldUpdate) Marshal

func (m *FieldUpdate) Marshal() (dAtA []byte, err error)

func (*FieldUpdate) MarshalTo

func (m *FieldUpdate) MarshalTo(dAtA []byte) (int, error)

func (*FieldUpdate) MarshalToSizedBuffer

func (m *FieldUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FieldUpdate) ProtoMessage

func (*FieldUpdate) ProtoMessage()

func (*FieldUpdate) Reset

func (m *FieldUpdate) Reset()

func (*FieldUpdate) Size

func (m *FieldUpdate) Size() (n int)

func (*FieldUpdate) String

func (m *FieldUpdate) String() string

func (*FieldUpdate) Unmarshal

func (m *FieldUpdate) Unmarshal(dAtA []byte) error

func (*FieldUpdate) XXX_DiscardUnknown

func (m *FieldUpdate) XXX_DiscardUnknown()

func (*FieldUpdate) XXX_Marshal

func (m *FieldUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldUpdate) XXX_Merge

func (m *FieldUpdate) XXX_Merge(src proto.Message)

func (*FieldUpdate) XXX_Size

func (m *FieldUpdate) XXX_Size() int

func (*FieldUpdate) XXX_Unmarshal

func (m *FieldUpdate) XXX_Unmarshal(b []byte) error

type GroupCount

type GroupCount struct {
	Group                []*FieldRow `protobuf:"bytes,1,rep,name=Group,proto3" json:"Group,omitempty"`
	Count                uint64      `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
	Agg                  int64       `protobuf:"varint,3,opt,name=Agg,proto3" json:"Agg,omitempty"`
	DecimalAgg           *Decimal    `protobuf:"bytes,4,opt,name=DecimalAgg,proto3" json:"DecimalAgg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GroupCount) Descriptor

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

func (*GroupCount) GetAgg

func (m *GroupCount) GetAgg() int64

func (*GroupCount) GetCount

func (m *GroupCount) GetCount() uint64

func (*GroupCount) GetDecimalAgg

func (m *GroupCount) GetDecimalAgg() *Decimal

func (*GroupCount) GetGroup

func (m *GroupCount) GetGroup() []*FieldRow

func (*GroupCount) Marshal

func (m *GroupCount) Marshal() (dAtA []byte, err error)

func (*GroupCount) MarshalTo

func (m *GroupCount) MarshalTo(dAtA []byte) (int, error)

func (*GroupCount) MarshalToSizedBuffer

func (m *GroupCount) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupCount) ProtoMessage

func (*GroupCount) ProtoMessage()

func (*GroupCount) Reset

func (m *GroupCount) Reset()

func (*GroupCount) Size

func (m *GroupCount) Size() (n int)

func (*GroupCount) String

func (m *GroupCount) String() string

func (*GroupCount) Unmarshal

func (m *GroupCount) Unmarshal(dAtA []byte) error

func (*GroupCount) XXX_DiscardUnknown

func (m *GroupCount) XXX_DiscardUnknown()

func (*GroupCount) XXX_Marshal

func (m *GroupCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupCount) XXX_Merge

func (m *GroupCount) XXX_Merge(src proto.Message)

func (*GroupCount) XXX_Size

func (m *GroupCount) XXX_Size() int

func (*GroupCount) XXX_Unmarshal

func (m *GroupCount) XXX_Unmarshal(b []byte) error

type GroupCounts

type GroupCounts struct {
	Aggregate            string        `protobuf:"bytes,1,opt,name=Aggregate,proto3" json:"Aggregate,omitempty"`
	Groups               []*GroupCount `protobuf:"bytes,2,rep,name=Groups,proto3" json:"Groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GroupCounts) Descriptor

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

func (*GroupCounts) GetAggregate

func (m *GroupCounts) GetAggregate() string

func (*GroupCounts) GetGroups

func (m *GroupCounts) GetGroups() []*GroupCount

func (*GroupCounts) Marshal

func (m *GroupCounts) Marshal() (dAtA []byte, err error)

func (*GroupCounts) MarshalTo

func (m *GroupCounts) MarshalTo(dAtA []byte) (int, error)

func (*GroupCounts) MarshalToSizedBuffer

func (m *GroupCounts) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupCounts) ProtoMessage

func (*GroupCounts) ProtoMessage()

func (*GroupCounts) Reset

func (m *GroupCounts) Reset()

func (*GroupCounts) Size

func (m *GroupCounts) Size() (n int)

func (*GroupCounts) String

func (m *GroupCounts) String() string

func (*GroupCounts) Unmarshal

func (m *GroupCounts) Unmarshal(dAtA []byte) error

func (*GroupCounts) XXX_DiscardUnknown

func (m *GroupCounts) XXX_DiscardUnknown()

func (*GroupCounts) XXX_Marshal

func (m *GroupCounts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupCounts) XXX_Merge

func (m *GroupCounts) XXX_Merge(src proto.Message)

func (*GroupCounts) XXX_Size

func (m *GroupCounts) XXX_Size() int

func (*GroupCounts) XXX_Unmarshal

func (m *GroupCounts) XXX_Unmarshal(b []byte) error

type IDList

type IDList struct {
	IDs                  []uint64 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IDList) Descriptor

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

func (*IDList) GetIDs

func (m *IDList) GetIDs() []uint64

func (*IDList) Marshal

func (m *IDList) Marshal() (dAtA []byte, err error)

func (*IDList) MarshalTo

func (m *IDList) MarshalTo(dAtA []byte) (int, error)

func (*IDList) MarshalToSizedBuffer

func (m *IDList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IDList) ProtoMessage

func (*IDList) ProtoMessage()

func (*IDList) Reset

func (m *IDList) Reset()

func (*IDList) Size

func (m *IDList) Size() (n int)

func (*IDList) String

func (m *IDList) String() string

func (*IDList) Unmarshal

func (m *IDList) Unmarshal(dAtA []byte) error

func (*IDList) XXX_DiscardUnknown

func (m *IDList) XXX_DiscardUnknown()

func (*IDList) XXX_Marshal

func (m *IDList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IDList) XXX_Merge

func (m *IDList) XXX_Merge(src proto.Message)

func (*IDList) XXX_Size

func (m *IDList) XXX_Size() int

func (*IDList) XXX_Unmarshal

func (m *IDList) XXX_Unmarshal(b []byte) error

type ImportRequest

type ImportRequest struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	Shard                uint64   `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"`
	RowIDs               []uint64 `protobuf:"varint,4,rep,packed,name=RowIDs,proto3" json:"RowIDs,omitempty"`
	ColumnIDs            []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs,proto3" json:"ColumnIDs,omitempty"`
	RowKeys              []string `protobuf:"bytes,7,rep,name=RowKeys,proto3" json:"RowKeys,omitempty"`
	ColumnKeys           []string `protobuf:"bytes,8,rep,name=ColumnKeys,proto3" json:"ColumnKeys,omitempty"`
	Timestamps           []int64  `protobuf:"varint,6,rep,packed,name=Timestamps,proto3" json:"Timestamps,omitempty"`
	IndexCreatedAt       int64    `protobuf:"varint,9,opt,name=IndexCreatedAt,proto3" json:"IndexCreatedAt,omitempty"`
	FieldCreatedAt       int64    `protobuf:"varint,10,opt,name=FieldCreatedAt,proto3" json:"FieldCreatedAt,omitempty"`
	Clear                bool     `protobuf:"varint,11,opt,name=Clear,proto3" json:"Clear,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportRequest) Descriptor

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

func (*ImportRequest) GetClear

func (m *ImportRequest) GetClear() bool

func (*ImportRequest) GetColumnIDs

func (m *ImportRequest) GetColumnIDs() []uint64

func (*ImportRequest) GetColumnKeys

func (m *ImportRequest) GetColumnKeys() []string

func (*ImportRequest) GetField

func (m *ImportRequest) GetField() string

func (*ImportRequest) GetFieldCreatedAt

func (m *ImportRequest) GetFieldCreatedAt() int64

func (*ImportRequest) GetIndex

func (m *ImportRequest) GetIndex() string

func (*ImportRequest) GetIndexCreatedAt

func (m *ImportRequest) GetIndexCreatedAt() int64

func (*ImportRequest) GetRowIDs

func (m *ImportRequest) GetRowIDs() []uint64

func (*ImportRequest) GetRowKeys

func (m *ImportRequest) GetRowKeys() []string

func (*ImportRequest) GetShard

func (m *ImportRequest) GetShard() uint64

func (*ImportRequest) GetTimestamps

func (m *ImportRequest) GetTimestamps() []int64

func (*ImportRequest) Marshal

func (m *ImportRequest) Marshal() (dAtA []byte, err error)

func (*ImportRequest) MarshalTo

func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error)

func (*ImportRequest) MarshalToSizedBuffer

func (m *ImportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImportRequest) ProtoMessage

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) Reset

func (m *ImportRequest) Reset()

func (*ImportRequest) Size

func (m *ImportRequest) Size() (n int)

func (*ImportRequest) String

func (m *ImportRequest) String() string

func (*ImportRequest) Unmarshal

func (m *ImportRequest) Unmarshal(dAtA []byte) error

func (*ImportRequest) XXX_DiscardUnknown

func (m *ImportRequest) XXX_DiscardUnknown()

func (*ImportRequest) XXX_Marshal

func (m *ImportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportRequest) XXX_Merge

func (m *ImportRequest) XXX_Merge(src proto.Message)

func (*ImportRequest) XXX_Size

func (m *ImportRequest) XXX_Size() int

func (*ImportRequest) XXX_Unmarshal

func (m *ImportRequest) XXX_Unmarshal(b []byte) error

type ImportResponse

type ImportResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportResponse) Descriptor

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

func (*ImportResponse) GetErr

func (m *ImportResponse) GetErr() string

func (*ImportResponse) Marshal

func (m *ImportResponse) Marshal() (dAtA []byte, err error)

func (*ImportResponse) MarshalTo

func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error)

func (*ImportResponse) MarshalToSizedBuffer

func (m *ImportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImportResponse) ProtoMessage

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) Reset

func (m *ImportResponse) Reset()

func (*ImportResponse) Size

func (m *ImportResponse) Size() (n int)

func (*ImportResponse) String

func (m *ImportResponse) String() string

func (*ImportResponse) Unmarshal

func (m *ImportResponse) Unmarshal(dAtA []byte) error

func (*ImportResponse) XXX_DiscardUnknown

func (m *ImportResponse) XXX_DiscardUnknown()

func (*ImportResponse) XXX_Marshal

func (m *ImportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportResponse) XXX_Merge

func (m *ImportResponse) XXX_Merge(src proto.Message)

func (*ImportResponse) XXX_Size

func (m *ImportResponse) XXX_Size() int

func (*ImportResponse) XXX_Unmarshal

func (m *ImportResponse) XXX_Unmarshal(b []byte) error

type ImportRoaringRequest

type ImportRoaringRequest struct {
	Clear                bool                        `protobuf:"varint,1,opt,name=Clear,proto3" json:"Clear,omitempty"`
	Views                []*ImportRoaringRequestView `protobuf:"bytes,2,rep,name=views,proto3" json:"views,omitempty"`
	Action               string                      `protobuf:"bytes,3,opt,name=Action,proto3" json:"Action,omitempty"`
	Block                uint64                      `protobuf:"varint,4,opt,name=Block,proto3" json:"Block,omitempty"`
	IndexCreatedAt       int64                       `protobuf:"varint,5,opt,name=IndexCreatedAt,proto3" json:"IndexCreatedAt,omitempty"`
	FieldCreatedAt       int64                       `protobuf:"varint,6,opt,name=FieldCreatedAt,proto3" json:"FieldCreatedAt,omitempty"`
	UpdateExistence      bool                        `protobuf:"varint,7,opt,name=UpdateExistence,proto3" json:"UpdateExistence,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ImportRoaringRequest) Descriptor

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

func (*ImportRoaringRequest) GetAction

func (m *ImportRoaringRequest) GetAction() string

func (*ImportRoaringRequest) GetBlock

func (m *ImportRoaringRequest) GetBlock() uint64

func (*ImportRoaringRequest) GetClear

func (m *ImportRoaringRequest) GetClear() bool

func (*ImportRoaringRequest) GetFieldCreatedAt

func (m *ImportRoaringRequest) GetFieldCreatedAt() int64

func (*ImportRoaringRequest) GetIndexCreatedAt

func (m *ImportRoaringRequest) GetIndexCreatedAt() int64

func (*ImportRoaringRequest) GetUpdateExistence

func (m *ImportRoaringRequest) GetUpdateExistence() bool

func (*ImportRoaringRequest) GetViews

func (*ImportRoaringRequest) Marshal

func (m *ImportRoaringRequest) Marshal() (dAtA []byte, err error)

func (*ImportRoaringRequest) MarshalTo

func (m *ImportRoaringRequest) MarshalTo(dAtA []byte) (int, error)

func (*ImportRoaringRequest) MarshalToSizedBuffer

func (m *ImportRoaringRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImportRoaringRequest) ProtoMessage

func (*ImportRoaringRequest) ProtoMessage()

func (*ImportRoaringRequest) Reset

func (m *ImportRoaringRequest) Reset()

func (*ImportRoaringRequest) Size

func (m *ImportRoaringRequest) Size() (n int)

func (*ImportRoaringRequest) String

func (m *ImportRoaringRequest) String() string

func (*ImportRoaringRequest) Unmarshal

func (m *ImportRoaringRequest) Unmarshal(dAtA []byte) error

func (*ImportRoaringRequest) XXX_DiscardUnknown

func (m *ImportRoaringRequest) XXX_DiscardUnknown()

func (*ImportRoaringRequest) XXX_Marshal

func (m *ImportRoaringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportRoaringRequest) XXX_Merge

func (m *ImportRoaringRequest) XXX_Merge(src proto.Message)

func (*ImportRoaringRequest) XXX_Size

func (m *ImportRoaringRequest) XXX_Size() int

func (*ImportRoaringRequest) XXX_Unmarshal

func (m *ImportRoaringRequest) XXX_Unmarshal(b []byte) error

type ImportRoaringRequestView

type ImportRoaringRequestView struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportRoaringRequestView) Descriptor

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

func (*ImportRoaringRequestView) GetData

func (m *ImportRoaringRequestView) GetData() []byte

func (*ImportRoaringRequestView) GetName

func (m *ImportRoaringRequestView) GetName() string

func (*ImportRoaringRequestView) Marshal

func (m *ImportRoaringRequestView) Marshal() (dAtA []byte, err error)

func (*ImportRoaringRequestView) MarshalTo

func (m *ImportRoaringRequestView) MarshalTo(dAtA []byte) (int, error)

func (*ImportRoaringRequestView) MarshalToSizedBuffer

func (m *ImportRoaringRequestView) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImportRoaringRequestView) ProtoMessage

func (*ImportRoaringRequestView) ProtoMessage()

func (*ImportRoaringRequestView) Reset

func (m *ImportRoaringRequestView) Reset()

func (*ImportRoaringRequestView) Size

func (m *ImportRoaringRequestView) Size() (n int)

func (*ImportRoaringRequestView) String

func (m *ImportRoaringRequestView) String() string

func (*ImportRoaringRequestView) Unmarshal

func (m *ImportRoaringRequestView) Unmarshal(dAtA []byte) error

func (*ImportRoaringRequestView) XXX_DiscardUnknown

func (m *ImportRoaringRequestView) XXX_DiscardUnknown()

func (*ImportRoaringRequestView) XXX_Marshal

func (m *ImportRoaringRequestView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportRoaringRequestView) XXX_Merge

func (m *ImportRoaringRequestView) XXX_Merge(src proto.Message)

func (*ImportRoaringRequestView) XXX_Size

func (m *ImportRoaringRequestView) XXX_Size() int

func (*ImportRoaringRequestView) XXX_Unmarshal

func (m *ImportRoaringRequestView) XXX_Unmarshal(b []byte) error

type ImportRoaringShardRequest

type ImportRoaringShardRequest struct {
	Remote               bool             `protobuf:"varint,1,opt,name=Remote,proto3" json:"Remote,omitempty"`
	Views                []*RoaringUpdate `protobuf:"bytes,2,rep,name=Views,proto3" json:"Views,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ImportRoaringShardRequest) Descriptor

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

func (*ImportRoaringShardRequest) GetRemote

func (m *ImportRoaringShardRequest) GetRemote() bool

func (*ImportRoaringShardRequest) GetViews

func (m *ImportRoaringShardRequest) GetViews() []*RoaringUpdate

func (*ImportRoaringShardRequest) Marshal

func (m *ImportRoaringShardRequest) Marshal() (dAtA []byte, err error)

func (*ImportRoaringShardRequest) MarshalTo

func (m *ImportRoaringShardRequest) MarshalTo(dAtA []byte) (int, error)

func (*ImportRoaringShardRequest) MarshalToSizedBuffer

func (m *ImportRoaringShardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImportRoaringShardRequest) ProtoMessage

func (*ImportRoaringShardRequest) ProtoMessage()

func (*ImportRoaringShardRequest) Reset

func (m *ImportRoaringShardRequest) Reset()

func (*ImportRoaringShardRequest) Size

func (m *ImportRoaringShardRequest) Size() (n int)

func (*ImportRoaringShardRequest) String

func (m *ImportRoaringShardRequest) String() string

func (*ImportRoaringShardRequest) Unmarshal

func (m *ImportRoaringShardRequest) Unmarshal(dAtA []byte) error

func (*ImportRoaringShardRequest) XXX_DiscardUnknown

func (m *ImportRoaringShardRequest) XXX_DiscardUnknown()

func (*ImportRoaringShardRequest) XXX_Marshal

func (m *ImportRoaringShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportRoaringShardRequest) XXX_Merge

func (m *ImportRoaringShardRequest) XXX_Merge(src proto.Message)

func (*ImportRoaringShardRequest) XXX_Size

func (m *ImportRoaringShardRequest) XXX_Size() int

func (*ImportRoaringShardRequest) XXX_Unmarshal

func (m *ImportRoaringShardRequest) XXX_Unmarshal(b []byte) error

type ImportValueRequest

type ImportValueRequest struct {
	Index                string    `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string    `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	Shard                uint64    `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"`
	ColumnIDs            []uint64  `protobuf:"varint,5,rep,packed,name=ColumnIDs,proto3" json:"ColumnIDs,omitempty"`
	ColumnKeys           []string  `protobuf:"bytes,7,rep,name=ColumnKeys,proto3" json:"ColumnKeys,omitempty"`
	Values               []int64   `protobuf:"varint,6,rep,packed,name=Values,proto3" json:"Values,omitempty"`
	FloatValues          []float64 `protobuf:"fixed64,8,rep,packed,name=FloatValues,proto3" json:"FloatValues,omitempty"`
	StringValues         []string  `protobuf:"bytes,9,rep,name=StringValues,proto3" json:"StringValues,omitempty"`
	IndexCreatedAt       int64     `protobuf:"varint,10,opt,name=IndexCreatedAt,proto3" json:"IndexCreatedAt,omitempty"`
	FieldCreatedAt       int64     `protobuf:"varint,11,opt,name=FieldCreatedAt,proto3" json:"FieldCreatedAt,omitempty"`
	Clear                bool      `protobuf:"varint,12,opt,name=Clear,proto3" json:"Clear,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ImportValueRequest) Descriptor

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

func (*ImportValueRequest) GetClear

func (m *ImportValueRequest) GetClear() bool

func (*ImportValueRequest) GetColumnIDs

func (m *ImportValueRequest) GetColumnIDs() []uint64

func (*ImportValueRequest) GetColumnKeys

func (m *ImportValueRequest) GetColumnKeys() []string

func (*ImportValueRequest) GetField

func (m *ImportValueRequest) GetField() string

func (*ImportValueRequest) GetFieldCreatedAt

func (m *ImportValueRequest) GetFieldCreatedAt() int64

func (*ImportValueRequest) GetFloatValues

func (m *ImportValueRequest) GetFloatValues() []float64

func (*ImportValueRequest) GetIndex

func (m *ImportValueRequest) GetIndex() string

func (*ImportValueRequest) GetIndexCreatedAt

func (m *ImportValueRequest) GetIndexCreatedAt() int64

func (*ImportValueRequest) GetShard

func (m *ImportValueRequest) GetShard() uint64

func (*ImportValueRequest) GetStringValues

func (m *ImportValueRequest) GetStringValues() []string

func (*ImportValueRequest) GetValues

func (m *ImportValueRequest) GetValues() []int64

func (*ImportValueRequest) Marshal

func (m *ImportValueRequest) Marshal() (dAtA []byte, err error)

func (*ImportValueRequest) MarshalTo

func (m *ImportValueRequest) MarshalTo(dAtA []byte) (int, error)

func (*ImportValueRequest) MarshalToSizedBuffer

func (m *ImportValueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImportValueRequest) ProtoMessage

func (*ImportValueRequest) ProtoMessage()

func (*ImportValueRequest) Reset

func (m *ImportValueRequest) Reset()

func (*ImportValueRequest) Size

func (m *ImportValueRequest) Size() (n int)

func (*ImportValueRequest) String

func (m *ImportValueRequest) String() string

func (*ImportValueRequest) Unmarshal

func (m *ImportValueRequest) Unmarshal(dAtA []byte) error

func (*ImportValueRequest) XXX_DiscardUnknown

func (m *ImportValueRequest) XXX_DiscardUnknown()

func (*ImportValueRequest) XXX_Marshal

func (m *ImportValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportValueRequest) XXX_Merge

func (m *ImportValueRequest) XXX_Merge(src proto.Message)

func (*ImportValueRequest) XXX_Size

func (m *ImportValueRequest) XXX_Size() int

func (*ImportValueRequest) XXX_Unmarshal

func (m *ImportValueRequest) XXX_Unmarshal(b []byte) error

type Index

type Index struct {
	Name                 string     `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	CreatedAt            int64      `protobuf:"varint,2,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	Options              *IndexMeta `protobuf:"bytes,5,opt,name=Options,proto3" json:"Options,omitempty"`
	Fields               []*Field   `protobuf:"bytes,4,rep,name=Fields,proto3" json:"Fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Index) Descriptor

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

func (*Index) GetCreatedAt

func (m *Index) GetCreatedAt() int64

func (*Index) GetFields

func (m *Index) GetFields() []*Field

func (*Index) GetName

func (m *Index) GetName() string

func (*Index) GetOptions

func (m *Index) GetOptions() *IndexMeta

func (*Index) Marshal

func (m *Index) Marshal() (dAtA []byte, err error)

func (*Index) MarshalTo

func (m *Index) MarshalTo(dAtA []byte) (int, error)

func (*Index) MarshalToSizedBuffer

func (m *Index) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Index) ProtoMessage

func (*Index) ProtoMessage()

func (*Index) Reset

func (m *Index) Reset()

func (*Index) Size

func (m *Index) Size() (n int)

func (*Index) String

func (m *Index) String() string

func (*Index) Unmarshal

func (m *Index) Unmarshal(dAtA []byte) error

func (*Index) XXX_DiscardUnknown

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal

func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Index) XXX_Merge

func (m *Index) XXX_Merge(src proto.Message)

func (*Index) XXX_Size

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal

func (m *Index) XXX_Unmarshal(b []byte) error

type IndexMeta

type IndexMeta struct {
	Keys                 bool     `protobuf:"varint,3,opt,name=Keys,proto3" json:"Keys,omitempty"`
	TrackExistence       bool     `protobuf:"varint,4,opt,name=TrackExistence,proto3" json:"TrackExistence,omitempty"`
	Description          string   `protobuf:"bytes,5,opt,name=Description,proto3" json:"Description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexMeta) Descriptor

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

func (*IndexMeta) GetDescription

func (m *IndexMeta) GetDescription() string

func (*IndexMeta) GetKeys

func (m *IndexMeta) GetKeys() bool

func (*IndexMeta) GetTrackExistence

func (m *IndexMeta) GetTrackExistence() bool

func (*IndexMeta) Marshal

func (m *IndexMeta) Marshal() (dAtA []byte, err error)

func (*IndexMeta) MarshalTo

func (m *IndexMeta) MarshalTo(dAtA []byte) (int, error)

func (*IndexMeta) MarshalToSizedBuffer

func (m *IndexMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IndexMeta) ProtoMessage

func (*IndexMeta) ProtoMessage()

func (*IndexMeta) Reset

func (m *IndexMeta) Reset()

func (*IndexMeta) Size

func (m *IndexMeta) Size() (n int)

func (*IndexMeta) String

func (m *IndexMeta) String() string

func (*IndexMeta) Unmarshal

func (m *IndexMeta) Unmarshal(dAtA []byte) error

func (*IndexMeta) XXX_DiscardUnknown

func (m *IndexMeta) XXX_DiscardUnknown()

func (*IndexMeta) XXX_Marshal

func (m *IndexMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexMeta) XXX_Merge

func (m *IndexMeta) XXX_Merge(src proto.Message)

func (*IndexMeta) XXX_Size

func (m *IndexMeta) XXX_Size() int

func (*IndexMeta) XXX_Unmarshal

func (m *IndexMeta) XXX_Unmarshal(b []byte) error

type IndexStatus

type IndexStatus struct {
	Name                 string         `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Fields               []*FieldStatus `protobuf:"bytes,2,rep,name=Fields,proto3" json:"Fields,omitempty"`
	CreatedAt            int64          `protobuf:"varint,3,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*IndexStatus) Descriptor

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

func (*IndexStatus) GetCreatedAt

func (m *IndexStatus) GetCreatedAt() int64

func (*IndexStatus) GetFields

func (m *IndexStatus) GetFields() []*FieldStatus

func (*IndexStatus) GetName

func (m *IndexStatus) GetName() string

func (*IndexStatus) Marshal

func (m *IndexStatus) Marshal() (dAtA []byte, err error)

func (*IndexStatus) MarshalTo

func (m *IndexStatus) MarshalTo(dAtA []byte) (int, error)

func (*IndexStatus) MarshalToSizedBuffer

func (m *IndexStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IndexStatus) ProtoMessage

func (*IndexStatus) ProtoMessage()

func (*IndexStatus) Reset

func (m *IndexStatus) Reset()

func (*IndexStatus) Size

func (m *IndexStatus) Size() (n int)

func (*IndexStatus) String

func (m *IndexStatus) String() string

func (*IndexStatus) Unmarshal

func (m *IndexStatus) Unmarshal(dAtA []byte) error

func (*IndexStatus) XXX_DiscardUnknown

func (m *IndexStatus) XXX_DiscardUnknown()

func (*IndexStatus) XXX_Marshal

func (m *IndexStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexStatus) XXX_Merge

func (m *IndexStatus) XXX_Merge(src proto.Message)

func (*IndexStatus) XXX_Size

func (m *IndexStatus) XXX_Size() int

func (*IndexStatus) XXX_Unmarshal

func (m *IndexStatus) XXX_Unmarshal(b []byte) error

type Int64

type Int64 struct {
	Value                int64    `protobuf:"varint,1,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Int64) Descriptor

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

func (*Int64) GetValue

func (m *Int64) GetValue() int64

func (*Int64) Marshal

func (m *Int64) Marshal() (dAtA []byte, err error)

func (*Int64) MarshalTo

func (m *Int64) MarshalTo(dAtA []byte) (int, error)

func (*Int64) MarshalToSizedBuffer

func (m *Int64) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Int64) ProtoMessage

func (*Int64) ProtoMessage()

func (*Int64) Reset

func (m *Int64) Reset()

func (*Int64) Size

func (m *Int64) Size() (n int)

func (*Int64) String

func (m *Int64) String() string

func (*Int64) Unmarshal

func (m *Int64) Unmarshal(dAtA []byte) error

func (*Int64) XXX_DiscardUnknown

func (m *Int64) XXX_DiscardUnknown()

func (*Int64) XXX_Marshal

func (m *Int64) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Int64) XXX_Merge

func (m *Int64) XXX_Merge(src proto.Message)

func (*Int64) XXX_Size

func (m *Int64) XXX_Size() int

func (*Int64) XXX_Unmarshal

func (m *Int64) XXX_Unmarshal(b []byte) error

type KeyList

type KeyList struct {
	Keys                 []string `protobuf:"bytes,1,rep,name=Keys,proto3" json:"Keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyList) Descriptor

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

func (*KeyList) GetKeys

func (m *KeyList) GetKeys() []string

func (*KeyList) Marshal

func (m *KeyList) Marshal() (dAtA []byte, err error)

func (*KeyList) MarshalTo

func (m *KeyList) MarshalTo(dAtA []byte) (int, error)

func (*KeyList) MarshalToSizedBuffer

func (m *KeyList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyList) ProtoMessage

func (*KeyList) ProtoMessage()

func (*KeyList) Reset

func (m *KeyList) Reset()

func (*KeyList) Size

func (m *KeyList) Size() (n int)

func (*KeyList) String

func (m *KeyList) String() string

func (*KeyList) Unmarshal

func (m *KeyList) Unmarshal(dAtA []byte) error

func (*KeyList) XXX_DiscardUnknown

func (m *KeyList) XXX_DiscardUnknown()

func (*KeyList) XXX_Marshal

func (m *KeyList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyList) XXX_Merge

func (m *KeyList) XXX_Merge(src proto.Message)

func (*KeyList) XXX_Size

func (m *KeyList) XXX_Size() int

func (*KeyList) XXX_Unmarshal

func (m *KeyList) XXX_Unmarshal(b []byte) error

type LoadSchemaMessage

type LoadSchemaMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadSchemaMessage) Descriptor

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

func (*LoadSchemaMessage) Marshal

func (m *LoadSchemaMessage) Marshal() (dAtA []byte, err error)

func (*LoadSchemaMessage) MarshalTo

func (m *LoadSchemaMessage) MarshalTo(dAtA []byte) (int, error)

func (*LoadSchemaMessage) MarshalToSizedBuffer

func (m *LoadSchemaMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadSchemaMessage) ProtoMessage

func (*LoadSchemaMessage) ProtoMessage()

func (*LoadSchemaMessage) Reset

func (m *LoadSchemaMessage) Reset()

func (*LoadSchemaMessage) Size

func (m *LoadSchemaMessage) Size() (n int)

func (*LoadSchemaMessage) String

func (m *LoadSchemaMessage) String() string

func (*LoadSchemaMessage) Unmarshal

func (m *LoadSchemaMessage) Unmarshal(dAtA []byte) error

func (*LoadSchemaMessage) XXX_DiscardUnknown

func (m *LoadSchemaMessage) XXX_DiscardUnknown()

func (*LoadSchemaMessage) XXX_Marshal

func (m *LoadSchemaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadSchemaMessage) XXX_Merge

func (m *LoadSchemaMessage) XXX_Merge(src proto.Message)

func (*LoadSchemaMessage) XXX_Size

func (m *LoadSchemaMessage) XXX_Size() int

func (*LoadSchemaMessage) XXX_Unmarshal

func (m *LoadSchemaMessage) XXX_Unmarshal(b []byte) error

type MaxShards

type MaxShards struct {
	Standard             map[string]uint64 `` /* 158-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MaxShards) Descriptor

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

func (*MaxShards) GetStandard

func (m *MaxShards) GetStandard() map[string]uint64

func (*MaxShards) Marshal

func (m *MaxShards) Marshal() (dAtA []byte, err error)

func (*MaxShards) MarshalTo

func (m *MaxShards) MarshalTo(dAtA []byte) (int, error)

func (*MaxShards) MarshalToSizedBuffer

func (m *MaxShards) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MaxShards) ProtoMessage

func (*MaxShards) ProtoMessage()

func (*MaxShards) Reset

func (m *MaxShards) Reset()

func (*MaxShards) Size

func (m *MaxShards) Size() (n int)

func (*MaxShards) String

func (m *MaxShards) String() string

func (*MaxShards) Unmarshal

func (m *MaxShards) Unmarshal(dAtA []byte) error

func (*MaxShards) XXX_DiscardUnknown

func (m *MaxShards) XXX_DiscardUnknown()

func (*MaxShards) XXX_Marshal

func (m *MaxShards) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaxShards) XXX_Merge

func (m *MaxShards) XXX_Merge(src proto.Message)

func (*MaxShards) XXX_Size

func (m *MaxShards) XXX_Size() int

func (*MaxShards) XXX_Unmarshal

func (m *MaxShards) XXX_Unmarshal(b []byte) error

type Node

type Node struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	URI                  *URI     `protobuf:"bytes,2,opt,name=URI,proto3" json:"URI,omitempty"`
	IsPrimary            bool     `protobuf:"varint,3,opt,name=IsPrimary,proto3" json:"IsPrimary,omitempty"`
	State                string   `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"`
	GRPCURI              *URI     `protobuf:"bytes,5,opt,name=GRPCURI,proto3" json:"GRPCURI,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Node) Descriptor

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

func (*Node) GetGRPCURI

func (m *Node) GetGRPCURI() *URI

func (*Node) GetID

func (m *Node) GetID() string

func (*Node) GetIsPrimary

func (m *Node) GetIsPrimary() bool

func (*Node) GetState

func (m *Node) GetState() string

func (*Node) GetURI

func (m *Node) GetURI() *URI

func (*Node) Marshal

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) MarshalToSizedBuffer

func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

func (m *Node) Size() (n int)

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) XXX_DiscardUnknown

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal

func (m *Node) XXX_Unmarshal(b []byte) error

type NodeEventMessage

type NodeEventMessage struct {
	Event                uint32   `protobuf:"varint,1,opt,name=Event,proto3" json:"Event,omitempty"`
	Node                 *Node    `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeEventMessage) Descriptor

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

func (*NodeEventMessage) GetEvent

func (m *NodeEventMessage) GetEvent() uint32

func (*NodeEventMessage) GetNode

func (m *NodeEventMessage) GetNode() *Node

func (*NodeEventMessage) Marshal

func (m *NodeEventMessage) Marshal() (dAtA []byte, err error)

func (*NodeEventMessage) MarshalTo

func (m *NodeEventMessage) MarshalTo(dAtA []byte) (int, error)

func (*NodeEventMessage) MarshalToSizedBuffer

func (m *NodeEventMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeEventMessage) ProtoMessage

func (*NodeEventMessage) ProtoMessage()

func (*NodeEventMessage) Reset

func (m *NodeEventMessage) Reset()

func (*NodeEventMessage) Size

func (m *NodeEventMessage) Size() (n int)

func (*NodeEventMessage) String

func (m *NodeEventMessage) String() string

func (*NodeEventMessage) Unmarshal

func (m *NodeEventMessage) Unmarshal(dAtA []byte) error

func (*NodeEventMessage) XXX_DiscardUnknown

func (m *NodeEventMessage) XXX_DiscardUnknown()

func (*NodeEventMessage) XXX_Marshal

func (m *NodeEventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeEventMessage) XXX_Merge

func (m *NodeEventMessage) XXX_Merge(src proto.Message)

func (*NodeEventMessage) XXX_Size

func (m *NodeEventMessage) XXX_Size() int

func (*NodeEventMessage) XXX_Unmarshal

func (m *NodeEventMessage) XXX_Unmarshal(b []byte) error

type NodeStateMessage

type NodeStateMessage struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	State                string   `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeStateMessage) Descriptor

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

func (*NodeStateMessage) GetNodeID

func (m *NodeStateMessage) GetNodeID() string

func (*NodeStateMessage) GetState

func (m *NodeStateMessage) GetState() string

func (*NodeStateMessage) Marshal

func (m *NodeStateMessage) Marshal() (dAtA []byte, err error)

func (*NodeStateMessage) MarshalTo

func (m *NodeStateMessage) MarshalTo(dAtA []byte) (int, error)

func (*NodeStateMessage) MarshalToSizedBuffer

func (m *NodeStateMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeStateMessage) ProtoMessage

func (*NodeStateMessage) ProtoMessage()

func (*NodeStateMessage) Reset

func (m *NodeStateMessage) Reset()

func (*NodeStateMessage) Size

func (m *NodeStateMessage) Size() (n int)

func (*NodeStateMessage) String

func (m *NodeStateMessage) String() string

func (*NodeStateMessage) Unmarshal

func (m *NodeStateMessage) Unmarshal(dAtA []byte) error

func (*NodeStateMessage) XXX_DiscardUnknown

func (m *NodeStateMessage) XXX_DiscardUnknown()

func (*NodeStateMessage) XXX_Marshal

func (m *NodeStateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeStateMessage) XXX_Merge

func (m *NodeStateMessage) XXX_Merge(src proto.Message)

func (*NodeStateMessage) XXX_Size

func (m *NodeStateMessage) XXX_Size() int

func (*NodeStateMessage) XXX_Unmarshal

func (m *NodeStateMessage) XXX_Unmarshal(b []byte) error

type NodeStatus

type NodeStatus struct {
	Node                 *Node          `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	Schema               *Schema        `protobuf:"bytes,3,opt,name=Schema,proto3" json:"Schema,omitempty"`
	Indexes              []*IndexStatus `protobuf:"bytes,4,rep,name=Indexes,proto3" json:"Indexes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*NodeStatus) Descriptor

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

func (*NodeStatus) GetIndexes

func (m *NodeStatus) GetIndexes() []*IndexStatus

func (*NodeStatus) GetNode

func (m *NodeStatus) GetNode() *Node

func (*NodeStatus) GetSchema

func (m *NodeStatus) GetSchema() *Schema

func (*NodeStatus) Marshal

func (m *NodeStatus) Marshal() (dAtA []byte, err error)

func (*NodeStatus) MarshalTo

func (m *NodeStatus) MarshalTo(dAtA []byte) (int, error)

func (*NodeStatus) MarshalToSizedBuffer

func (m *NodeStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeStatus) ProtoMessage

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset

func (m *NodeStatus) Reset()

func (*NodeStatus) Size

func (m *NodeStatus) Size() (n int)

func (*NodeStatus) String

func (m *NodeStatus) String() string

func (*NodeStatus) Unmarshal

func (m *NodeStatus) Unmarshal(dAtA []byte) error

func (*NodeStatus) XXX_DiscardUnknown

func (m *NodeStatus) XXX_DiscardUnknown()

func (*NodeStatus) XXX_Marshal

func (m *NodeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeStatus) XXX_Merge

func (m *NodeStatus) XXX_Merge(src proto.Message)

func (*NodeStatus) XXX_Size

func (m *NodeStatus) XXX_Size() int

func (*NodeStatus) XXX_Unmarshal

func (m *NodeStatus) XXX_Unmarshal(b []byte) error

type Pair

type Pair struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Key                  string   `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"`
	Count                uint64   `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pair) Descriptor

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

func (*Pair) GetCount

func (m *Pair) GetCount() uint64

func (*Pair) GetID

func (m *Pair) GetID() uint64

func (*Pair) GetKey

func (m *Pair) GetKey() string

func (*Pair) Marshal

func (m *Pair) Marshal() (dAtA []byte, err error)

func (*Pair) MarshalTo

func (m *Pair) MarshalTo(dAtA []byte) (int, error)

func (*Pair) MarshalToSizedBuffer

func (m *Pair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Pair) ProtoMessage

func (*Pair) ProtoMessage()

func (*Pair) Reset

func (m *Pair) Reset()

func (*Pair) Size

func (m *Pair) Size() (n int)

func (*Pair) String

func (m *Pair) String() string

func (*Pair) Unmarshal

func (m *Pair) Unmarshal(dAtA []byte) error

func (*Pair) XXX_DiscardUnknown

func (m *Pair) XXX_DiscardUnknown()

func (*Pair) XXX_Marshal

func (m *Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pair) XXX_Merge

func (m *Pair) XXX_Merge(src proto.Message)

func (*Pair) XXX_Size

func (m *Pair) XXX_Size() int

func (*Pair) XXX_Unmarshal

func (m *Pair) XXX_Unmarshal(b []byte) error

type PairField

type PairField struct {
	Pair                 *Pair    `protobuf:"bytes,1,opt,name=Pair,proto3" json:"Pair,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PairField) Descriptor

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

func (*PairField) GetField

func (m *PairField) GetField() string

func (*PairField) GetPair

func (m *PairField) GetPair() *Pair

func (*PairField) Marshal

func (m *PairField) Marshal() (dAtA []byte, err error)

func (*PairField) MarshalTo

func (m *PairField) MarshalTo(dAtA []byte) (int, error)

func (*PairField) MarshalToSizedBuffer

func (m *PairField) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PairField) ProtoMessage

func (*PairField) ProtoMessage()

func (*PairField) Reset

func (m *PairField) Reset()

func (*PairField) Size

func (m *PairField) Size() (n int)

func (*PairField) String

func (m *PairField) String() string

func (*PairField) Unmarshal

func (m *PairField) Unmarshal(dAtA []byte) error

func (*PairField) XXX_DiscardUnknown

func (m *PairField) XXX_DiscardUnknown()

func (*PairField) XXX_Marshal

func (m *PairField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PairField) XXX_Merge

func (m *PairField) XXX_Merge(src proto.Message)

func (*PairField) XXX_Size

func (m *PairField) XXX_Size() int

func (*PairField) XXX_Unmarshal

func (m *PairField) XXX_Unmarshal(b []byte) error

type PairsField

type PairsField struct {
	Pairs                []*Pair  `protobuf:"bytes,1,rep,name=Pairs,proto3" json:"Pairs,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PairsField) Descriptor

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

func (*PairsField) GetField

func (m *PairsField) GetField() string

func (*PairsField) GetPairs

func (m *PairsField) GetPairs() []*Pair

func (*PairsField) Marshal

func (m *PairsField) Marshal() (dAtA []byte, err error)

func (*PairsField) MarshalTo

func (m *PairsField) MarshalTo(dAtA []byte) (int, error)

func (*PairsField) MarshalToSizedBuffer

func (m *PairsField) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PairsField) ProtoMessage

func (*PairsField) ProtoMessage()

func (*PairsField) Reset

func (m *PairsField) Reset()

func (*PairsField) Size

func (m *PairsField) Size() (n int)

func (*PairsField) String

func (m *PairsField) String() string

func (*PairsField) Unmarshal

func (m *PairsField) Unmarshal(dAtA []byte) error

func (*PairsField) XXX_DiscardUnknown

func (m *PairsField) XXX_DiscardUnknown()

func (*PairsField) XXX_Marshal

func (m *PairsField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PairsField) XXX_Merge

func (m *PairsField) XXX_Merge(src proto.Message)

func (*PairsField) XXX_Size

func (m *PairsField) XXX_Size() int

func (*PairsField) XXX_Unmarshal

func (m *PairsField) XXX_Unmarshal(b []byte) error

type QueryRequest

type QueryRequest struct {
	Query                string   `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
	Shards               []uint64 `protobuf:"varint,2,rep,packed,name=Shards,proto3" json:"Shards,omitempty"`
	Remote               bool     `protobuf:"varint,5,opt,name=Remote,proto3" json:"Remote,omitempty"`
	EmbeddedData         []*Row   `protobuf:"bytes,8,rep,name=EmbeddedData,proto3" json:"EmbeddedData,omitempty"`
	PreTranslated        bool     `protobuf:"varint,9,opt,name=PreTranslated,proto3" json:"PreTranslated,omitempty"`
	MaxMemory            int64    `protobuf:"varint,10,opt,name=MaxMemory,proto3" json:"MaxMemory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryRequest) Descriptor

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

func (*QueryRequest) GetEmbeddedData

func (m *QueryRequest) GetEmbeddedData() []*Row

func (*QueryRequest) GetMaxMemory

func (m *QueryRequest) GetMaxMemory() int64

func (*QueryRequest) GetPreTranslated

func (m *QueryRequest) GetPreTranslated() bool

func (*QueryRequest) GetQuery

func (m *QueryRequest) GetQuery() string

func (*QueryRequest) GetRemote

func (m *QueryRequest) GetRemote() bool

func (*QueryRequest) GetShards

func (m *QueryRequest) GetShards() []uint64

func (*QueryRequest) Marshal

func (m *QueryRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequest) MarshalTo

func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequest) MarshalToSizedBuffer

func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequest) ProtoMessage

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset

func (m *QueryRequest) Reset()

func (*QueryRequest) Size

func (m *QueryRequest) Size() (n int)

func (*QueryRequest) String

func (m *QueryRequest) String() string

func (*QueryRequest) Unmarshal

func (m *QueryRequest) Unmarshal(dAtA []byte) error

func (*QueryRequest) XXX_DiscardUnknown

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type QueryResponse

type QueryResponse struct {
	Err                  string         `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
	Results              []*QueryResult `protobuf:"bytes,2,rep,name=Results,proto3" json:"Results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*QueryResponse) Descriptor

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

func (*QueryResponse) GetErr

func (m *QueryResponse) GetErr() string

func (*QueryResponse) GetResults

func (m *QueryResponse) GetResults() []*QueryResult

func (*QueryResponse) Marshal

func (m *QueryResponse) Marshal() (dAtA []byte, err error)

func (*QueryResponse) MarshalTo

func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponse) MarshalToSizedBuffer

func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponse) ProtoMessage

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset

func (m *QueryResponse) Reset()

func (*QueryResponse) Size

func (m *QueryResponse) Size() (n int)

func (*QueryResponse) String

func (m *QueryResponse) String() string

func (*QueryResponse) Unmarshal

func (m *QueryResponse) Unmarshal(dAtA []byte) error

func (*QueryResponse) XXX_DiscardUnknown

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal

func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponse) XXX_Merge

func (m *QueryResponse) XXX_Merge(src proto.Message)

func (*QueryResponse) XXX_Size

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal

func (m *QueryResponse) XXX_Unmarshal(b []byte) error

type QueryResult

type QueryResult struct {
	Type     uint32    `protobuf:"varint,6,opt,name=Type,proto3" json:"Type,omitempty"`
	Row      *Row      `protobuf:"bytes,1,opt,name=Row,proto3" json:"Row,omitempty"`
	N        uint64    `protobuf:"varint,2,opt,name=N,proto3" json:"N,omitempty"`
	Pairs    []*Pair   `protobuf:"bytes,3,rep,name=Pairs,proto3" json:"Pairs,omitempty"`
	Changed  bool      `protobuf:"varint,4,opt,name=Changed,proto3" json:"Changed,omitempty"`
	ValCount *ValCount `protobuf:"bytes,5,opt,name=ValCount,proto3" json:"ValCount,omitempty"`
	RowIDs   []uint64  `protobuf:"varint,7,rep,packed,name=RowIDs,proto3" json:"RowIDs,omitempty"`
	// In the past, GroupCounts was a []GroupCount which did not indicate
	// whether it had an aggregate, or which aggregate it had. We've
	// updated this, but we keep this here so that messages using the old
	// format can get a best-effort treatment rather than causing panics.
	// Later this can almost certainly go away, but leave a comment warning
	// people that 8 is Spoken For if you do that, please.
	OldGroupCounts          []*GroupCount            `protobuf:"bytes,8,rep,name=OldGroupCounts,proto3" json:"OldGroupCounts,omitempty"`
	RowIdentifiers          *RowIdentifiers          `protobuf:"bytes,9,opt,name=RowIdentifiers,proto3" json:"RowIdentifiers,omitempty"`
	SignedRow               *SignedRow               `protobuf:"bytes,10,opt,name=SignedRow,proto3" json:"SignedRow,omitempty"`
	PairsField              *PairsField              `protobuf:"bytes,11,opt,name=PairsField,proto3" json:"PairsField,omitempty"`
	PairField               *PairField               `protobuf:"bytes,12,opt,name=PairField,proto3" json:"PairField,omitempty"`
	ExtractedIDMatrix       *ExtractedIDMatrix       `protobuf:"bytes,13,opt,name=ExtractedIDMatrix,proto3" json:"ExtractedIDMatrix,omitempty"`
	ExtractedTable          *ExtractedTable          `protobuf:"bytes,14,opt,name=ExtractedTable,proto3" json:"ExtractedTable,omitempty"`
	RowMatrix               *RowMatrix               `protobuf:"bytes,15,opt,name=RowMatrix,proto3" json:"RowMatrix,omitempty"`
	GroupCounts             *GroupCounts             `protobuf:"bytes,16,opt,name=GroupCounts,proto3" json:"GroupCounts,omitempty"`
	DistinctTimestamp       *DistinctTimestamp       `protobuf:"bytes,17,opt,name=DistinctTimestamp,proto3" json:"DistinctTimestamp,omitempty"`
	DataFrame               *DataFrame               `protobuf:"bytes,18,opt,name=DataFrame,proto3" json:"DataFrame,omitempty"`
	ArrowTable              *ArrowTable              `protobuf:"bytes,19,opt,name=ArrowTable,proto3" json:"ArrowTable,omitempty"`
	ExtractedIDMatrixSorted *ExtractedIDMatrixSorted `protobuf:"bytes,20,opt,name=ExtractedIDMatrixSorted,proto3" json:"ExtractedIDMatrixSorted,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}                 `json:"-"`
	XXX_unrecognized        []byte                   `json:"-"`
	XXX_sizecache           int32                    `json:"-"`
}

func (*QueryResult) Descriptor

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

func (*QueryResult) GetArrowTable

func (m *QueryResult) GetArrowTable() *ArrowTable

func (*QueryResult) GetChanged

func (m *QueryResult) GetChanged() bool

func (*QueryResult) GetDataFrame

func (m *QueryResult) GetDataFrame() *DataFrame

func (*QueryResult) GetDistinctTimestamp

func (m *QueryResult) GetDistinctTimestamp() *DistinctTimestamp

func (*QueryResult) GetExtractedIDMatrix

func (m *QueryResult) GetExtractedIDMatrix() *ExtractedIDMatrix

func (*QueryResult) GetExtractedIDMatrixSorted

func (m *QueryResult) GetExtractedIDMatrixSorted() *ExtractedIDMatrixSorted

func (*QueryResult) GetExtractedTable

func (m *QueryResult) GetExtractedTable() *ExtractedTable

func (*QueryResult) GetGroupCounts

func (m *QueryResult) GetGroupCounts() *GroupCounts

func (*QueryResult) GetN

func (m *QueryResult) GetN() uint64

func (*QueryResult) GetOldGroupCounts

func (m *QueryResult) GetOldGroupCounts() []*GroupCount

func (*QueryResult) GetPairField

func (m *QueryResult) GetPairField() *PairField

func (*QueryResult) GetPairs

func (m *QueryResult) GetPairs() []*Pair

func (*QueryResult) GetPairsField

func (m *QueryResult) GetPairsField() *PairsField

func (*QueryResult) GetRow

func (m *QueryResult) GetRow() *Row

func (*QueryResult) GetRowIDs

func (m *QueryResult) GetRowIDs() []uint64

func (*QueryResult) GetRowIdentifiers

func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers

func (*QueryResult) GetRowMatrix

func (m *QueryResult) GetRowMatrix() *RowMatrix

func (*QueryResult) GetSignedRow

func (m *QueryResult) GetSignedRow() *SignedRow

func (*QueryResult) GetType

func (m *QueryResult) GetType() uint32

func (*QueryResult) GetValCount

func (m *QueryResult) GetValCount() *ValCount

func (*QueryResult) Marshal

func (m *QueryResult) Marshal() (dAtA []byte, err error)

func (*QueryResult) MarshalTo

func (m *QueryResult) MarshalTo(dAtA []byte) (int, error)

func (*QueryResult) MarshalToSizedBuffer

func (m *QueryResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResult) ProtoMessage

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset

func (m *QueryResult) Reset()

func (*QueryResult) Size

func (m *QueryResult) Size() (n int)

func (*QueryResult) String

func (m *QueryResult) String() string

func (*QueryResult) Unmarshal

func (m *QueryResult) Unmarshal(dAtA []byte) error

func (*QueryResult) XXX_DiscardUnknown

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal

func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResult) XXX_Merge

func (m *QueryResult) XXX_Merge(src proto.Message)

func (*QueryResult) XXX_Size

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal

func (m *QueryResult) XXX_Unmarshal(b []byte) error

type RecalculateCaches

type RecalculateCaches struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecalculateCaches) Descriptor

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

func (*RecalculateCaches) Marshal

func (m *RecalculateCaches) Marshal() (dAtA []byte, err error)

func (*RecalculateCaches) MarshalTo

func (m *RecalculateCaches) MarshalTo(dAtA []byte) (int, error)

func (*RecalculateCaches) MarshalToSizedBuffer

func (m *RecalculateCaches) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecalculateCaches) ProtoMessage

func (*RecalculateCaches) ProtoMessage()

func (*RecalculateCaches) Reset

func (m *RecalculateCaches) Reset()

func (*RecalculateCaches) Size

func (m *RecalculateCaches) Size() (n int)

func (*RecalculateCaches) String

func (m *RecalculateCaches) String() string

func (*RecalculateCaches) Unmarshal

func (m *RecalculateCaches) Unmarshal(dAtA []byte) error

func (*RecalculateCaches) XXX_DiscardUnknown

func (m *RecalculateCaches) XXX_DiscardUnknown()

func (*RecalculateCaches) XXX_Marshal

func (m *RecalculateCaches) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecalculateCaches) XXX_Merge

func (m *RecalculateCaches) XXX_Merge(src proto.Message)

func (*RecalculateCaches) XXX_Size

func (m *RecalculateCaches) XXX_Size() int

func (*RecalculateCaches) XXX_Unmarshal

func (m *RecalculateCaches) XXX_Unmarshal(b []byte) error

type Request

type Request proto.Message

type ResizeAbortMessage

type ResizeAbortMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeAbortMessage) Descriptor

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

func (*ResizeAbortMessage) Marshal

func (m *ResizeAbortMessage) Marshal() (dAtA []byte, err error)

func (*ResizeAbortMessage) MarshalTo

func (m *ResizeAbortMessage) MarshalTo(dAtA []byte) (int, error)

func (*ResizeAbortMessage) MarshalToSizedBuffer

func (m *ResizeAbortMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResizeAbortMessage) ProtoMessage

func (*ResizeAbortMessage) ProtoMessage()

func (*ResizeAbortMessage) Reset

func (m *ResizeAbortMessage) Reset()

func (*ResizeAbortMessage) Size

func (m *ResizeAbortMessage) Size() (n int)

func (*ResizeAbortMessage) String

func (m *ResizeAbortMessage) String() string

func (*ResizeAbortMessage) Unmarshal

func (m *ResizeAbortMessage) Unmarshal(dAtA []byte) error

func (*ResizeAbortMessage) XXX_DiscardUnknown

func (m *ResizeAbortMessage) XXX_DiscardUnknown()

func (*ResizeAbortMessage) XXX_Marshal

func (m *ResizeAbortMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizeAbortMessage) XXX_Merge

func (m *ResizeAbortMessage) XXX_Merge(src proto.Message)

func (*ResizeAbortMessage) XXX_Size

func (m *ResizeAbortMessage) XXX_Size() int

func (*ResizeAbortMessage) XXX_Unmarshal

func (m *ResizeAbortMessage) XXX_Unmarshal(b []byte) error

type ResizeInstruction

type ResizeInstruction struct {
	JobID                int64                      `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
	Node                 *Node                      `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"`
	Primary              *Node                      `protobuf:"bytes,3,opt,name=Primary,proto3" json:"Primary,omitempty"`
	Sources              []*ResizeSource            `protobuf:"bytes,4,rep,name=Sources,proto3" json:"Sources,omitempty"`
	TranslationSources   []*TranslationResizeSource `protobuf:"bytes,8,rep,name=TranslationSources,proto3" json:"TranslationSources,omitempty"`
	NodeStatus           *NodeStatus                `protobuf:"bytes,7,opt,name=NodeStatus,proto3" json:"NodeStatus,omitempty"`
	ClusterStatus        *ClusterStatus             `protobuf:"bytes,6,opt,name=ClusterStatus,proto3" json:"ClusterStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ResizeInstruction) Descriptor

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

func (*ResizeInstruction) GetClusterStatus

func (m *ResizeInstruction) GetClusterStatus() *ClusterStatus

func (*ResizeInstruction) GetJobID

func (m *ResizeInstruction) GetJobID() int64

func (*ResizeInstruction) GetNode

func (m *ResizeInstruction) GetNode() *Node

func (*ResizeInstruction) GetNodeStatus

func (m *ResizeInstruction) GetNodeStatus() *NodeStatus

func (*ResizeInstruction) GetPrimary

func (m *ResizeInstruction) GetPrimary() *Node

func (*ResizeInstruction) GetSources

func (m *ResizeInstruction) GetSources() []*ResizeSource

func (*ResizeInstruction) GetTranslationSources

func (m *ResizeInstruction) GetTranslationSources() []*TranslationResizeSource

func (*ResizeInstruction) Marshal

func (m *ResizeInstruction) Marshal() (dAtA []byte, err error)

func (*ResizeInstruction) MarshalTo

func (m *ResizeInstruction) MarshalTo(dAtA []byte) (int, error)

func (*ResizeInstruction) MarshalToSizedBuffer

func (m *ResizeInstruction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResizeInstruction) ProtoMessage

func (*ResizeInstruction) ProtoMessage()

func (*ResizeInstruction) Reset

func (m *ResizeInstruction) Reset()

func (*ResizeInstruction) Size

func (m *ResizeInstruction) Size() (n int)

func (*ResizeInstruction) String

func (m *ResizeInstruction) String() string

func (*ResizeInstruction) Unmarshal

func (m *ResizeInstruction) Unmarshal(dAtA []byte) error

func (*ResizeInstruction) XXX_DiscardUnknown

func (m *ResizeInstruction) XXX_DiscardUnknown()

func (*ResizeInstruction) XXX_Marshal

func (m *ResizeInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizeInstruction) XXX_Merge

func (m *ResizeInstruction) XXX_Merge(src proto.Message)

func (*ResizeInstruction) XXX_Size

func (m *ResizeInstruction) XXX_Size() int

func (*ResizeInstruction) XXX_Unmarshal

func (m *ResizeInstruction) XXX_Unmarshal(b []byte) error

type ResizeInstructionComplete

type ResizeInstructionComplete struct {
	JobID                int64    `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
	Node                 *Node    `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"`
	Error                string   `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeInstructionComplete) Descriptor

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

func (*ResizeInstructionComplete) GetError

func (m *ResizeInstructionComplete) GetError() string

func (*ResizeInstructionComplete) GetJobID

func (m *ResizeInstructionComplete) GetJobID() int64

func (*ResizeInstructionComplete) GetNode

func (m *ResizeInstructionComplete) GetNode() *Node

func (*ResizeInstructionComplete) Marshal

func (m *ResizeInstructionComplete) Marshal() (dAtA []byte, err error)

func (*ResizeInstructionComplete) MarshalTo

func (m *ResizeInstructionComplete) MarshalTo(dAtA []byte) (int, error)

func (*ResizeInstructionComplete) MarshalToSizedBuffer

func (m *ResizeInstructionComplete) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResizeInstructionComplete) ProtoMessage

func (*ResizeInstructionComplete) ProtoMessage()

func (*ResizeInstructionComplete) Reset

func (m *ResizeInstructionComplete) Reset()

func (*ResizeInstructionComplete) Size

func (m *ResizeInstructionComplete) Size() (n int)

func (*ResizeInstructionComplete) String

func (m *ResizeInstructionComplete) String() string

func (*ResizeInstructionComplete) Unmarshal

func (m *ResizeInstructionComplete) Unmarshal(dAtA []byte) error

func (*ResizeInstructionComplete) XXX_DiscardUnknown

func (m *ResizeInstructionComplete) XXX_DiscardUnknown()

func (*ResizeInstructionComplete) XXX_Marshal

func (m *ResizeInstructionComplete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizeInstructionComplete) XXX_Merge

func (m *ResizeInstructionComplete) XXX_Merge(src proto.Message)

func (*ResizeInstructionComplete) XXX_Size

func (m *ResizeInstructionComplete) XXX_Size() int

func (*ResizeInstructionComplete) XXX_Unmarshal

func (m *ResizeInstructionComplete) XXX_Unmarshal(b []byte) error

type ResizeNodeMessage

type ResizeNodeMessage struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	Action               string   `protobuf:"bytes,2,opt,name=Action,proto3" json:"Action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeNodeMessage) Descriptor

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

func (*ResizeNodeMessage) GetAction

func (m *ResizeNodeMessage) GetAction() string

func (*ResizeNodeMessage) GetNodeID

func (m *ResizeNodeMessage) GetNodeID() string

func (*ResizeNodeMessage) Marshal

func (m *ResizeNodeMessage) Marshal() (dAtA []byte, err error)

func (*ResizeNodeMessage) MarshalTo

func (m *ResizeNodeMessage) MarshalTo(dAtA []byte) (int, error)

func (*ResizeNodeMessage) MarshalToSizedBuffer

func (m *ResizeNodeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResizeNodeMessage) ProtoMessage

func (*ResizeNodeMessage) ProtoMessage()

func (*ResizeNodeMessage) Reset

func (m *ResizeNodeMessage) Reset()

func (*ResizeNodeMessage) Size

func (m *ResizeNodeMessage) Size() (n int)

func (*ResizeNodeMessage) String

func (m *ResizeNodeMessage) String() string

func (*ResizeNodeMessage) Unmarshal

func (m *ResizeNodeMessage) Unmarshal(dAtA []byte) error

func (*ResizeNodeMessage) XXX_DiscardUnknown

func (m *ResizeNodeMessage) XXX_DiscardUnknown()

func (*ResizeNodeMessage) XXX_Marshal

func (m *ResizeNodeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizeNodeMessage) XXX_Merge

func (m *ResizeNodeMessage) XXX_Merge(src proto.Message)

func (*ResizeNodeMessage) XXX_Size

func (m *ResizeNodeMessage) XXX_Size() int

func (*ResizeNodeMessage) XXX_Unmarshal

func (m *ResizeNodeMessage) XXX_Unmarshal(b []byte) error

type ResizeSource

type ResizeSource struct {
	Node                 *Node    `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	Index                string   `protobuf:"bytes,2,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,3,opt,name=Field,proto3" json:"Field,omitempty"`
	View                 string   `protobuf:"bytes,4,opt,name=View,proto3" json:"View,omitempty"`
	Shard                uint64   `protobuf:"varint,5,opt,name=Shard,proto3" json:"Shard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeSource) Descriptor

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

func (*ResizeSource) GetField

func (m *ResizeSource) GetField() string

func (*ResizeSource) GetIndex

func (m *ResizeSource) GetIndex() string

func (*ResizeSource) GetNode

func (m *ResizeSource) GetNode() *Node

func (*ResizeSource) GetShard

func (m *ResizeSource) GetShard() uint64

func (*ResizeSource) GetView

func (m *ResizeSource) GetView() string

func (*ResizeSource) Marshal

func (m *ResizeSource) Marshal() (dAtA []byte, err error)

func (*ResizeSource) MarshalTo

func (m *ResizeSource) MarshalTo(dAtA []byte) (int, error)

func (*ResizeSource) MarshalToSizedBuffer

func (m *ResizeSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResizeSource) ProtoMessage

func (*ResizeSource) ProtoMessage()

func (*ResizeSource) Reset

func (m *ResizeSource) Reset()

func (*ResizeSource) Size

func (m *ResizeSource) Size() (n int)

func (*ResizeSource) String

func (m *ResizeSource) String() string

func (*ResizeSource) Unmarshal

func (m *ResizeSource) Unmarshal(dAtA []byte) error

func (*ResizeSource) XXX_DiscardUnknown

func (m *ResizeSource) XXX_DiscardUnknown()

func (*ResizeSource) XXX_Marshal

func (m *ResizeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizeSource) XXX_Merge

func (m *ResizeSource) XXX_Merge(src proto.Message)

func (*ResizeSource) XXX_Size

func (m *ResizeSource) XXX_Size() int

func (*ResizeSource) XXX_Unmarshal

func (m *ResizeSource) XXX_Unmarshal(b []byte) error

type Response

type Response proto.Message

type RoaringUpdate

type RoaringUpdate struct {
	Field                string   `protobuf:"bytes,1,opt,name=Field,proto3" json:"Field,omitempty"`
	View                 string   `protobuf:"bytes,2,opt,name=View,proto3" json:"View,omitempty"`
	Clear                []byte   `protobuf:"bytes,3,opt,name=Clear,proto3" json:"Clear,omitempty"`
	Set                  []byte   `protobuf:"bytes,4,opt,name=Set,proto3" json:"Set,omitempty"`
	ClearRecords         bool     `protobuf:"varint,5,opt,name=ClearRecords,proto3" json:"ClearRecords,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RoaringUpdate) Descriptor

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

func (*RoaringUpdate) GetClear

func (m *RoaringUpdate) GetClear() []byte

func (*RoaringUpdate) GetClearRecords

func (m *RoaringUpdate) GetClearRecords() bool

func (*RoaringUpdate) GetField

func (m *RoaringUpdate) GetField() string

func (*RoaringUpdate) GetSet

func (m *RoaringUpdate) GetSet() []byte

func (*RoaringUpdate) GetView

func (m *RoaringUpdate) GetView() string

func (*RoaringUpdate) Marshal

func (m *RoaringUpdate) Marshal() (dAtA []byte, err error)

func (*RoaringUpdate) MarshalTo

func (m *RoaringUpdate) MarshalTo(dAtA []byte) (int, error)

func (*RoaringUpdate) MarshalToSizedBuffer

func (m *RoaringUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RoaringUpdate) ProtoMessage

func (*RoaringUpdate) ProtoMessage()

func (*RoaringUpdate) Reset

func (m *RoaringUpdate) Reset()

func (*RoaringUpdate) Size

func (m *RoaringUpdate) Size() (n int)

func (*RoaringUpdate) String

func (m *RoaringUpdate) String() string

func (*RoaringUpdate) Unmarshal

func (m *RoaringUpdate) Unmarshal(dAtA []byte) error

func (*RoaringUpdate) XXX_DiscardUnknown

func (m *RoaringUpdate) XXX_DiscardUnknown()

func (*RoaringUpdate) XXX_Marshal

func (m *RoaringUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RoaringUpdate) XXX_Merge

func (m *RoaringUpdate) XXX_Merge(src proto.Message)

func (*RoaringUpdate) XXX_Size

func (m *RoaringUpdate) XXX_Size() int

func (*RoaringUpdate) XXX_Unmarshal

func (m *RoaringUpdate) XXX_Unmarshal(b []byte) error

type Row

type Row struct {
	Columns              []uint64 `protobuf:"varint,1,rep,packed,name=Columns,proto3" json:"Columns,omitempty"`
	Keys                 []string `protobuf:"bytes,3,rep,name=Keys,proto3" json:"Keys,omitempty"`
	Roaring              []byte   `protobuf:"bytes,4,opt,name=Roaring,proto3" json:"Roaring,omitempty"`
	Index                string   `protobuf:"bytes,5,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,6,opt,name=Field,proto3" json:"Field,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Row) Descriptor

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

func (*Row) GetColumns

func (m *Row) GetColumns() []uint64

func (*Row) GetField

func (m *Row) GetField() string

func (*Row) GetIndex

func (m *Row) GetIndex() string

func (*Row) GetKeys

func (m *Row) GetKeys() []string

func (*Row) GetRoaring

func (m *Row) GetRoaring() []byte

func (*Row) Marshal

func (m *Row) Marshal() (dAtA []byte, err error)

func (*Row) MarshalTo

func (m *Row) MarshalTo(dAtA []byte) (int, error)

func (*Row) MarshalToSizedBuffer

func (m *Row) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Row) ProtoMessage

func (*Row) ProtoMessage()

func (*Row) Reset

func (m *Row) Reset()

func (*Row) Size

func (m *Row) Size() (n int)

func (*Row) String

func (m *Row) String() string

func (*Row) Unmarshal

func (m *Row) Unmarshal(dAtA []byte) error

func (*Row) XXX_DiscardUnknown

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal

func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Row) XXX_Merge

func (m *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal

func (m *Row) XXX_Unmarshal(b []byte) error

type RowIdentifiers

type RowIdentifiers struct {
	Rows                 []uint64 `protobuf:"varint,1,rep,packed,name=Rows,proto3" json:"Rows,omitempty"`
	Keys                 []string `protobuf:"bytes,2,rep,name=Keys,proto3" json:"Keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RowIdentifiers) Descriptor

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

func (*RowIdentifiers) GetKeys

func (m *RowIdentifiers) GetKeys() []string

func (*RowIdentifiers) GetRows

func (m *RowIdentifiers) GetRows() []uint64

func (*RowIdentifiers) Marshal

func (m *RowIdentifiers) Marshal() (dAtA []byte, err error)

func (*RowIdentifiers) MarshalTo

func (m *RowIdentifiers) MarshalTo(dAtA []byte) (int, error)

func (*RowIdentifiers) MarshalToSizedBuffer

func (m *RowIdentifiers) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowIdentifiers) ProtoMessage

func (*RowIdentifiers) ProtoMessage()

func (*RowIdentifiers) Reset

func (m *RowIdentifiers) Reset()

func (*RowIdentifiers) Size

func (m *RowIdentifiers) Size() (n int)

func (*RowIdentifiers) String

func (m *RowIdentifiers) String() string

func (*RowIdentifiers) Unmarshal

func (m *RowIdentifiers) Unmarshal(dAtA []byte) error

func (*RowIdentifiers) XXX_DiscardUnknown

func (m *RowIdentifiers) XXX_DiscardUnknown()

func (*RowIdentifiers) XXX_Marshal

func (m *RowIdentifiers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowIdentifiers) XXX_Merge

func (m *RowIdentifiers) XXX_Merge(src proto.Message)

func (*RowIdentifiers) XXX_Size

func (m *RowIdentifiers) XXX_Size() int

func (*RowIdentifiers) XXX_Unmarshal

func (m *RowIdentifiers) XXX_Unmarshal(b []byte) error

type RowKV

type RowKV struct {
	RowID                uint64               `protobuf:"varint,1,opt,name=RowID,proto3" json:"RowID,omitempty"`
	Value                *ExtractedTableValue `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RowKV) Descriptor

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

func (*RowKV) GetRowID

func (m *RowKV) GetRowID() uint64

func (*RowKV) GetValue

func (m *RowKV) GetValue() *ExtractedTableValue

func (*RowKV) Marshal

func (m *RowKV) Marshal() (dAtA []byte, err error)

func (*RowKV) MarshalTo

func (m *RowKV) MarshalTo(dAtA []byte) (int, error)

func (*RowKV) MarshalToSizedBuffer

func (m *RowKV) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowKV) ProtoMessage

func (*RowKV) ProtoMessage()

func (*RowKV) Reset

func (m *RowKV) Reset()

func (*RowKV) Size

func (m *RowKV) Size() (n int)

func (*RowKV) String

func (m *RowKV) String() string

func (*RowKV) Unmarshal

func (m *RowKV) Unmarshal(dAtA []byte) error

func (*RowKV) XXX_DiscardUnknown

func (m *RowKV) XXX_DiscardUnknown()

func (*RowKV) XXX_Marshal

func (m *RowKV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowKV) XXX_Merge

func (m *RowKV) XXX_Merge(src proto.Message)

func (*RowKV) XXX_Size

func (m *RowKV) XXX_Size() int

func (*RowKV) XXX_Unmarshal

func (m *RowKV) XXX_Unmarshal(b []byte) error

type RowMatrix

type RowMatrix struct {
	Rows                 []*Row   `protobuf:"bytes,1,rep,name=Rows,proto3" json:"Rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RowMatrix) Descriptor

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

func (*RowMatrix) GetRows

func (m *RowMatrix) GetRows() []*Row

func (*RowMatrix) Marshal

func (m *RowMatrix) Marshal() (dAtA []byte, err error)

func (*RowMatrix) MarshalTo

func (m *RowMatrix) MarshalTo(dAtA []byte) (int, error)

func (*RowMatrix) MarshalToSizedBuffer

func (m *RowMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowMatrix) ProtoMessage

func (*RowMatrix) ProtoMessage()

func (*RowMatrix) Reset

func (m *RowMatrix) Reset()

func (*RowMatrix) Size

func (m *RowMatrix) Size() (n int)

func (*RowMatrix) String

func (m *RowMatrix) String() string

func (*RowMatrix) Unmarshal

func (m *RowMatrix) Unmarshal(dAtA []byte) error

func (*RowMatrix) XXX_DiscardUnknown

func (m *RowMatrix) XXX_DiscardUnknown()

func (*RowMatrix) XXX_Marshal

func (m *RowMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowMatrix) XXX_Merge

func (m *RowMatrix) XXX_Merge(src proto.Message)

func (*RowMatrix) XXX_Size

func (m *RowMatrix) XXX_Size() int

func (*RowMatrix) XXX_Unmarshal

func (m *RowMatrix) XXX_Unmarshal(b []byte) error

type Schema

type Schema struct {
	Indexes              []*Index `protobuf:"bytes,1,rep,name=Indexes,proto3" json:"Indexes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schema) Descriptor

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

func (*Schema) GetIndexes

func (m *Schema) GetIndexes() []*Index

func (*Schema) Marshal

func (m *Schema) Marshal() (dAtA []byte, err error)

func (*Schema) MarshalTo

func (m *Schema) MarshalTo(dAtA []byte) (int, error)

func (*Schema) MarshalToSizedBuffer

func (m *Schema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Schema) ProtoMessage

func (*Schema) ProtoMessage()

func (*Schema) Reset

func (m *Schema) Reset()

func (*Schema) Size

func (m *Schema) Size() (n int)

func (*Schema) String

func (m *Schema) String() string

func (*Schema) Unmarshal

func (m *Schema) Unmarshal(dAtA []byte) error

func (*Schema) XXX_DiscardUnknown

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal

func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schema) XXX_Merge

func (m *Schema) XXX_Merge(src proto.Message)

func (*Schema) XXX_Size

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal

func (m *Schema) XXX_Unmarshal(b []byte) error

type ShardIngestOperation

type ShardIngestOperation struct {
	OpType               string                     `protobuf:"bytes,1,opt,name=OpType,proto3" json:"OpType,omitempty"`
	ClearRecordIDs       []uint64                   `protobuf:"varint,2,rep,packed,name=ClearRecordIDs,proto3" json:"ClearRecordIDs,omitempty"`
	ClearFields          []string                   `protobuf:"bytes,3,rep,name=ClearFields,proto3" json:"ClearFields,omitempty"`
	FieldOps             map[string]*FieldOperation `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ShardIngestOperation) Descriptor

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

func (*ShardIngestOperation) GetClearFields

func (m *ShardIngestOperation) GetClearFields() []string

func (*ShardIngestOperation) GetClearRecordIDs

func (m *ShardIngestOperation) GetClearRecordIDs() []uint64

func (*ShardIngestOperation) GetFieldOps

func (m *ShardIngestOperation) GetFieldOps() map[string]*FieldOperation

func (*ShardIngestOperation) GetOpType

func (m *ShardIngestOperation) GetOpType() string

func (*ShardIngestOperation) Marshal

func (m *ShardIngestOperation) Marshal() (dAtA []byte, err error)

func (*ShardIngestOperation) MarshalTo

func (m *ShardIngestOperation) MarshalTo(dAtA []byte) (int, error)

func (*ShardIngestOperation) MarshalToSizedBuffer

func (m *ShardIngestOperation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShardIngestOperation) ProtoMessage

func (*ShardIngestOperation) ProtoMessage()

func (*ShardIngestOperation) Reset

func (m *ShardIngestOperation) Reset()

func (*ShardIngestOperation) Size

func (m *ShardIngestOperation) Size() (n int)

func (*ShardIngestOperation) String

func (m *ShardIngestOperation) String() string

func (*ShardIngestOperation) Unmarshal

func (m *ShardIngestOperation) Unmarshal(dAtA []byte) error

func (*ShardIngestOperation) XXX_DiscardUnknown

func (m *ShardIngestOperation) XXX_DiscardUnknown()

func (*ShardIngestOperation) XXX_Marshal

func (m *ShardIngestOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardIngestOperation) XXX_Merge

func (m *ShardIngestOperation) XXX_Merge(src proto.Message)

func (*ShardIngestOperation) XXX_Size

func (m *ShardIngestOperation) XXX_Size() int

func (*ShardIngestOperation) XXX_Unmarshal

func (m *ShardIngestOperation) XXX_Unmarshal(b []byte) error

type ShardIngestOperations

type ShardIngestOperations struct {
	Ops                  []*ShardIngestOperation `protobuf:"bytes,1,rep,name=Ops,proto3" json:"Ops,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ShardIngestOperations) Descriptor

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

func (*ShardIngestOperations) GetOps

func (*ShardIngestOperations) Marshal

func (m *ShardIngestOperations) Marshal() (dAtA []byte, err error)

func (*ShardIngestOperations) MarshalTo

func (m *ShardIngestOperations) MarshalTo(dAtA []byte) (int, error)

func (*ShardIngestOperations) MarshalToSizedBuffer

func (m *ShardIngestOperations) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShardIngestOperations) ProtoMessage

func (*ShardIngestOperations) ProtoMessage()

func (*ShardIngestOperations) Reset

func (m *ShardIngestOperations) Reset()

func (*ShardIngestOperations) Size

func (m *ShardIngestOperations) Size() (n int)

func (*ShardIngestOperations) String

func (m *ShardIngestOperations) String() string

func (*ShardIngestOperations) Unmarshal

func (m *ShardIngestOperations) Unmarshal(dAtA []byte) error

func (*ShardIngestOperations) XXX_DiscardUnknown

func (m *ShardIngestOperations) XXX_DiscardUnknown()

func (*ShardIngestOperations) XXX_Marshal

func (m *ShardIngestOperations) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardIngestOperations) XXX_Merge

func (m *ShardIngestOperations) XXX_Merge(src proto.Message)

func (*ShardIngestOperations) XXX_Size

func (m *ShardIngestOperations) XXX_Size() int

func (*ShardIngestOperations) XXX_Unmarshal

func (m *ShardIngestOperations) XXX_Unmarshal(b []byte) error

type ShardedIngestRequest

type ShardedIngestRequest struct {
	Ops                  map[uint64]*ShardIngestOperations `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*ShardedIngestRequest) Descriptor

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

func (*ShardedIngestRequest) GetOps

func (*ShardedIngestRequest) Marshal

func (m *ShardedIngestRequest) Marshal() (dAtA []byte, err error)

func (*ShardedIngestRequest) MarshalTo

func (m *ShardedIngestRequest) MarshalTo(dAtA []byte) (int, error)

func (*ShardedIngestRequest) MarshalToSizedBuffer

func (m *ShardedIngestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShardedIngestRequest) ProtoMessage

func (*ShardedIngestRequest) ProtoMessage()

func (*ShardedIngestRequest) Reset

func (m *ShardedIngestRequest) Reset()

func (*ShardedIngestRequest) Size

func (m *ShardedIngestRequest) Size() (n int)

func (*ShardedIngestRequest) String

func (m *ShardedIngestRequest) String() string

func (*ShardedIngestRequest) Unmarshal

func (m *ShardedIngestRequest) Unmarshal(dAtA []byte) error

func (*ShardedIngestRequest) XXX_DiscardUnknown

func (m *ShardedIngestRequest) XXX_DiscardUnknown()

func (*ShardedIngestRequest) XXX_Marshal

func (m *ShardedIngestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardedIngestRequest) XXX_Merge

func (m *ShardedIngestRequest) XXX_Merge(src proto.Message)

func (*ShardedIngestRequest) XXX_Size

func (m *ShardedIngestRequest) XXX_Size() int

func (*ShardedIngestRequest) XXX_Unmarshal

func (m *ShardedIngestRequest) XXX_Unmarshal(b []byte) error

type SignedRow

type SignedRow struct {
	Pos                  *Row     `protobuf:"bytes,1,opt,name=Pos,proto3" json:"Pos,omitempty"`
	Neg                  *Row     `protobuf:"bytes,2,opt,name=Neg,proto3" json:"Neg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SignedRow) Descriptor

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

func (*SignedRow) GetNeg

func (m *SignedRow) GetNeg() *Row

func (*SignedRow) GetPos

func (m *SignedRow) GetPos() *Row

func (*SignedRow) Marshal

func (m *SignedRow) Marshal() (dAtA []byte, err error)

func (*SignedRow) MarshalTo

func (m *SignedRow) MarshalTo(dAtA []byte) (int, error)

func (*SignedRow) MarshalToSizedBuffer

func (m *SignedRow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignedRow) ProtoMessage

func (*SignedRow) ProtoMessage()

func (*SignedRow) Reset

func (m *SignedRow) Reset()

func (*SignedRow) Size

func (m *SignedRow) Size() (n int)

func (*SignedRow) String

func (m *SignedRow) String() string

func (*SignedRow) Unmarshal

func (m *SignedRow) Unmarshal(dAtA []byte) error

func (*SignedRow) XXX_DiscardUnknown

func (m *SignedRow) XXX_DiscardUnknown()

func (*SignedRow) XXX_Marshal

func (m *SignedRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignedRow) XXX_Merge

func (m *SignedRow) XXX_Merge(src proto.Message)

func (*SignedRow) XXX_Size

func (m *SignedRow) XXX_Size() int

func (*SignedRow) XXX_Unmarshal

func (m *SignedRow) XXX_Unmarshal(b []byte) error

type Topology

type Topology struct {
	ClusterID            string   `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	NodeIDs              []string `protobuf:"bytes,2,rep,name=NodeIDs,proto3" json:"NodeIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Topology) Descriptor

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

func (*Topology) GetClusterID

func (m *Topology) GetClusterID() string

func (*Topology) GetNodeIDs

func (m *Topology) GetNodeIDs() []string

func (*Topology) Marshal

func (m *Topology) Marshal() (dAtA []byte, err error)

func (*Topology) MarshalTo

func (m *Topology) MarshalTo(dAtA []byte) (int, error)

func (*Topology) MarshalToSizedBuffer

func (m *Topology) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Topology) ProtoMessage

func (*Topology) ProtoMessage()

func (*Topology) Reset

func (m *Topology) Reset()

func (*Topology) Size

func (m *Topology) Size() (n int)

func (*Topology) String

func (m *Topology) String() string

func (*Topology) Unmarshal

func (m *Topology) Unmarshal(dAtA []byte) error

func (*Topology) XXX_DiscardUnknown

func (m *Topology) XXX_DiscardUnknown()

func (*Topology) XXX_Marshal

func (m *Topology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Topology) XXX_Merge

func (m *Topology) XXX_Merge(src proto.Message)

func (*Topology) XXX_Size

func (m *Topology) XXX_Size() int

func (*Topology) XXX_Unmarshal

func (m *Topology) XXX_Unmarshal(b []byte) error

type Transaction

type Transaction struct {
	ID                   string            `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Active               bool              `protobuf:"varint,2,opt,name=Active,proto3" json:"Active,omitempty"`
	Exclusive            bool              `protobuf:"varint,3,opt,name=Exclusive,proto3" json:"Exclusive,omitempty"`
	Timeout              int64             `protobuf:"varint,4,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	Deadline             int64             `protobuf:"varint,5,opt,name=Deadline,proto3" json:"Deadline,omitempty"`
	Stats                *TransactionStats `protobuf:"bytes,6,opt,name=Stats,proto3" json:"Stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Transaction) Descriptor

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

func (*Transaction) GetActive

func (m *Transaction) GetActive() bool

func (*Transaction) GetDeadline

func (m *Transaction) GetDeadline() int64

func (*Transaction) GetExclusive

func (m *Transaction) GetExclusive() bool

func (*Transaction) GetID

func (m *Transaction) GetID() string

func (*Transaction) GetStats

func (m *Transaction) GetStats() *TransactionStats

func (*Transaction) GetTimeout

func (m *Transaction) GetTimeout() int64

func (*Transaction) Marshal

func (m *Transaction) Marshal() (dAtA []byte, err error)

func (*Transaction) MarshalTo

func (m *Transaction) MarshalTo(dAtA []byte) (int, error)

func (*Transaction) MarshalToSizedBuffer

func (m *Transaction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Transaction) ProtoMessage

func (*Transaction) ProtoMessage()

func (*Transaction) Reset

func (m *Transaction) Reset()

func (*Transaction) Size

func (m *Transaction) Size() (n int)

func (*Transaction) String

func (m *Transaction) String() string

func (*Transaction) Unmarshal

func (m *Transaction) Unmarshal(dAtA []byte) error

func (*Transaction) XXX_DiscardUnknown

func (m *Transaction) XXX_DiscardUnknown()

func (*Transaction) XXX_Marshal

func (m *Transaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Transaction) XXX_Merge

func (m *Transaction) XXX_Merge(src proto.Message)

func (*Transaction) XXX_Size

func (m *Transaction) XXX_Size() int

func (*Transaction) XXX_Unmarshal

func (m *Transaction) XXX_Unmarshal(b []byte) error

type TransactionMessage

type TransactionMessage struct {
	Action               string       `protobuf:"bytes,1,opt,name=Action,proto3" json:"Action,omitempty"`
	Transaction          *Transaction `protobuf:"bytes,2,opt,name=Transaction,proto3" json:"Transaction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*TransactionMessage) Descriptor

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

func (*TransactionMessage) GetAction

func (m *TransactionMessage) GetAction() string

func (*TransactionMessage) GetTransaction

func (m *TransactionMessage) GetTransaction() *Transaction

func (*TransactionMessage) Marshal

func (m *TransactionMessage) Marshal() (dAtA []byte, err error)

func (*TransactionMessage) MarshalTo

func (m *TransactionMessage) MarshalTo(dAtA []byte) (int, error)

func (*TransactionMessage) MarshalToSizedBuffer

func (m *TransactionMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionMessage) ProtoMessage

func (*TransactionMessage) ProtoMessage()

func (*TransactionMessage) Reset

func (m *TransactionMessage) Reset()

func (*TransactionMessage) Size

func (m *TransactionMessage) Size() (n int)

func (*TransactionMessage) String

func (m *TransactionMessage) String() string

func (*TransactionMessage) Unmarshal

func (m *TransactionMessage) Unmarshal(dAtA []byte) error

func (*TransactionMessage) XXX_DiscardUnknown

func (m *TransactionMessage) XXX_DiscardUnknown()

func (*TransactionMessage) XXX_Marshal

func (m *TransactionMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionMessage) XXX_Merge

func (m *TransactionMessage) XXX_Merge(src proto.Message)

func (*TransactionMessage) XXX_Size

func (m *TransactionMessage) XXX_Size() int

func (*TransactionMessage) XXX_Unmarshal

func (m *TransactionMessage) XXX_Unmarshal(b []byte) error

type TransactionStats

type TransactionStats struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TransactionStats) Descriptor

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

func (*TransactionStats) Marshal

func (m *TransactionStats) Marshal() (dAtA []byte, err error)

func (*TransactionStats) MarshalTo

func (m *TransactionStats) MarshalTo(dAtA []byte) (int, error)

func (*TransactionStats) MarshalToSizedBuffer

func (m *TransactionStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionStats) ProtoMessage

func (*TransactionStats) ProtoMessage()

func (*TransactionStats) Reset

func (m *TransactionStats) Reset()

func (*TransactionStats) Size

func (m *TransactionStats) Size() (n int)

func (*TransactionStats) String

func (m *TransactionStats) String() string

func (*TransactionStats) Unmarshal

func (m *TransactionStats) Unmarshal(dAtA []byte) error

func (*TransactionStats) XXX_DiscardUnknown

func (m *TransactionStats) XXX_DiscardUnknown()

func (*TransactionStats) XXX_Marshal

func (m *TransactionStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionStats) XXX_Merge

func (m *TransactionStats) XXX_Merge(src proto.Message)

func (*TransactionStats) XXX_Size

func (m *TransactionStats) XXX_Size() int

func (*TransactionStats) XXX_Unmarshal

func (m *TransactionStats) XXX_Unmarshal(b []byte) error

type TranslateIDsRequest

type TranslateIDsRequest struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	IDs                  []uint64 `protobuf:"varint,3,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TranslateIDsRequest) Descriptor

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

func (*TranslateIDsRequest) GetField

func (m *TranslateIDsRequest) GetField() string

func (*TranslateIDsRequest) GetIDs

func (m *TranslateIDsRequest) GetIDs() []uint64

func (*TranslateIDsRequest) GetIndex

func (m *TranslateIDsRequest) GetIndex() string

func (*TranslateIDsRequest) Marshal

func (m *TranslateIDsRequest) Marshal() (dAtA []byte, err error)

func (*TranslateIDsRequest) MarshalTo

func (m *TranslateIDsRequest) MarshalTo(dAtA []byte) (int, error)

func (*TranslateIDsRequest) MarshalToSizedBuffer

func (m *TranslateIDsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TranslateIDsRequest) ProtoMessage

func (*TranslateIDsRequest) ProtoMessage()

func (*TranslateIDsRequest) Reset

func (m *TranslateIDsRequest) Reset()

func (*TranslateIDsRequest) Size

func (m *TranslateIDsRequest) Size() (n int)

func (*TranslateIDsRequest) String

func (m *TranslateIDsRequest) String() string

func (*TranslateIDsRequest) Unmarshal

func (m *TranslateIDsRequest) Unmarshal(dAtA []byte) error

func (*TranslateIDsRequest) XXX_DiscardUnknown

func (m *TranslateIDsRequest) XXX_DiscardUnknown()

func (*TranslateIDsRequest) XXX_Marshal

func (m *TranslateIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TranslateIDsRequest) XXX_Merge

func (m *TranslateIDsRequest) XXX_Merge(src proto.Message)

func (*TranslateIDsRequest) XXX_Size

func (m *TranslateIDsRequest) XXX_Size() int

func (*TranslateIDsRequest) XXX_Unmarshal

func (m *TranslateIDsRequest) XXX_Unmarshal(b []byte) error

type TranslateIDsResponse

type TranslateIDsResponse struct {
	Keys                 []string `protobuf:"bytes,3,rep,name=Keys,proto3" json:"Keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TranslateIDsResponse) Descriptor

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

func (*TranslateIDsResponse) GetKeys

func (m *TranslateIDsResponse) GetKeys() []string

func (*TranslateIDsResponse) Marshal

func (m *TranslateIDsResponse) Marshal() (dAtA []byte, err error)

func (*TranslateIDsResponse) MarshalTo

func (m *TranslateIDsResponse) MarshalTo(dAtA []byte) (int, error)

func (*TranslateIDsResponse) MarshalToSizedBuffer

func (m *TranslateIDsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TranslateIDsResponse) ProtoMessage

func (*TranslateIDsResponse) ProtoMessage()

func (*TranslateIDsResponse) Reset

func (m *TranslateIDsResponse) Reset()

func (*TranslateIDsResponse) Size

func (m *TranslateIDsResponse) Size() (n int)

func (*TranslateIDsResponse) String

func (m *TranslateIDsResponse) String() string

func (*TranslateIDsResponse) Unmarshal

func (m *TranslateIDsResponse) Unmarshal(dAtA []byte) error

func (*TranslateIDsResponse) XXX_DiscardUnknown

func (m *TranslateIDsResponse) XXX_DiscardUnknown()

func (*TranslateIDsResponse) XXX_Marshal

func (m *TranslateIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TranslateIDsResponse) XXX_Merge

func (m *TranslateIDsResponse) XXX_Merge(src proto.Message)

func (*TranslateIDsResponse) XXX_Size

func (m *TranslateIDsResponse) XXX_Size() int

func (*TranslateIDsResponse) XXX_Unmarshal

func (m *TranslateIDsResponse) XXX_Unmarshal(b []byte) error

type TranslateKeysRequest

type TranslateKeysRequest struct {
	Index                string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Field                string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
	Keys                 []string `protobuf:"bytes,3,rep,name=Keys,proto3" json:"Keys,omitempty"`
	NotWritable          bool     `protobuf:"varint,4,opt,name=NotWritable,proto3" json:"NotWritable,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TranslateKeysRequest) Descriptor

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

func (*TranslateKeysRequest) GetField

func (m *TranslateKeysRequest) GetField() string

func (*TranslateKeysRequest) GetIndex

func (m *TranslateKeysRequest) GetIndex() string

func (*TranslateKeysRequest) GetKeys

func (m *TranslateKeysRequest) GetKeys() []string

func (*TranslateKeysRequest) GetNotWritable

func (m *TranslateKeysRequest) GetNotWritable() bool

func (*TranslateKeysRequest) Marshal

func (m *TranslateKeysRequest) Marshal() (dAtA []byte, err error)

func (*TranslateKeysRequest) MarshalTo

func (m *TranslateKeysRequest) MarshalTo(dAtA []byte) (int, error)

func (*TranslateKeysRequest) MarshalToSizedBuffer

func (m *TranslateKeysRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TranslateKeysRequest) ProtoMessage

func (*TranslateKeysRequest) ProtoMessage()

func (*TranslateKeysRequest) Reset

func (m *TranslateKeysRequest) Reset()

func (*TranslateKeysRequest) Size

func (m *TranslateKeysRequest) Size() (n int)

func (*TranslateKeysRequest) String

func (m *TranslateKeysRequest) String() string

func (*TranslateKeysRequest) Unmarshal

func (m *TranslateKeysRequest) Unmarshal(dAtA []byte) error

func (*TranslateKeysRequest) XXX_DiscardUnknown

func (m *TranslateKeysRequest) XXX_DiscardUnknown()

func (*TranslateKeysRequest) XXX_Marshal

func (m *TranslateKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TranslateKeysRequest) XXX_Merge

func (m *TranslateKeysRequest) XXX_Merge(src proto.Message)

func (*TranslateKeysRequest) XXX_Size

func (m *TranslateKeysRequest) XXX_Size() int

func (*TranslateKeysRequest) XXX_Unmarshal

func (m *TranslateKeysRequest) XXX_Unmarshal(b []byte) error

type TranslateKeysResponse

type TranslateKeysResponse struct {
	IDs                  []uint64 `protobuf:"varint,3,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TranslateKeysResponse) Descriptor

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

func (*TranslateKeysResponse) GetIDs

func (m *TranslateKeysResponse) GetIDs() []uint64

func (*TranslateKeysResponse) Marshal

func (m *TranslateKeysResponse) Marshal() (dAtA []byte, err error)

func (*TranslateKeysResponse) MarshalTo

func (m *TranslateKeysResponse) MarshalTo(dAtA []byte) (int, error)

func (*TranslateKeysResponse) MarshalToSizedBuffer

func (m *TranslateKeysResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TranslateKeysResponse) ProtoMessage

func (*TranslateKeysResponse) ProtoMessage()

func (*TranslateKeysResponse) Reset

func (m *TranslateKeysResponse) Reset()

func (*TranslateKeysResponse) Size

func (m *TranslateKeysResponse) Size() (n int)

func (*TranslateKeysResponse) String

func (m *TranslateKeysResponse) String() string

func (*TranslateKeysResponse) Unmarshal

func (m *TranslateKeysResponse) Unmarshal(dAtA []byte) error

func (*TranslateKeysResponse) XXX_DiscardUnknown

func (m *TranslateKeysResponse) XXX_DiscardUnknown()

func (*TranslateKeysResponse) XXX_Marshal

func (m *TranslateKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TranslateKeysResponse) XXX_Merge

func (m *TranslateKeysResponse) XXX_Merge(src proto.Message)

func (*TranslateKeysResponse) XXX_Size

func (m *TranslateKeysResponse) XXX_Size() int

func (*TranslateKeysResponse) XXX_Unmarshal

func (m *TranslateKeysResponse) XXX_Unmarshal(b []byte) error

type TranslationResizeSource

type TranslationResizeSource struct {
	Node                 *Node    `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	Index                string   `protobuf:"bytes,2,opt,name=Index,proto3" json:"Index,omitempty"`
	PartitionID          int32    `protobuf:"varint,3,opt,name=PartitionID,proto3" json:"PartitionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TranslationResizeSource) Descriptor

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

func (*TranslationResizeSource) GetIndex

func (m *TranslationResizeSource) GetIndex() string

func (*TranslationResizeSource) GetNode

func (m *TranslationResizeSource) GetNode() *Node

func (*TranslationResizeSource) GetPartitionID

func (m *TranslationResizeSource) GetPartitionID() int32

func (*TranslationResizeSource) Marshal

func (m *TranslationResizeSource) Marshal() (dAtA []byte, err error)

func (*TranslationResizeSource) MarshalTo

func (m *TranslationResizeSource) MarshalTo(dAtA []byte) (int, error)

func (*TranslationResizeSource) MarshalToSizedBuffer

func (m *TranslationResizeSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TranslationResizeSource) ProtoMessage

func (*TranslationResizeSource) ProtoMessage()

func (*TranslationResizeSource) Reset

func (m *TranslationResizeSource) Reset()

func (*TranslationResizeSource) Size

func (m *TranslationResizeSource) Size() (n int)

func (*TranslationResizeSource) String

func (m *TranslationResizeSource) String() string

func (*TranslationResizeSource) Unmarshal

func (m *TranslationResizeSource) Unmarshal(dAtA []byte) error

func (*TranslationResizeSource) XXX_DiscardUnknown

func (m *TranslationResizeSource) XXX_DiscardUnknown()

func (*TranslationResizeSource) XXX_Marshal

func (m *TranslationResizeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TranslationResizeSource) XXX_Merge

func (m *TranslationResizeSource) XXX_Merge(src proto.Message)

func (*TranslationResizeSource) XXX_Size

func (m *TranslationResizeSource) XXX_Size() int

func (*TranslationResizeSource) XXX_Unmarshal

func (m *TranslationResizeSource) XXX_Unmarshal(b []byte) error

type URI

type URI struct {
	Scheme               string   `protobuf:"bytes,1,opt,name=Scheme,proto3" json:"Scheme,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	Port                 uint32   `protobuf:"varint,3,opt,name=Port,proto3" json:"Port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*URI) Descriptor

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

func (*URI) GetHost

func (m *URI) GetHost() string

func (*URI) GetPort

func (m *URI) GetPort() uint32

func (*URI) GetScheme

func (m *URI) GetScheme() string

func (*URI) Marshal

func (m *URI) Marshal() (dAtA []byte, err error)

func (*URI) MarshalTo

func (m *URI) MarshalTo(dAtA []byte) (int, error)

func (*URI) MarshalToSizedBuffer

func (m *URI) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*URI) ProtoMessage

func (*URI) ProtoMessage()

func (*URI) Reset

func (m *URI) Reset()

func (*URI) Size

func (m *URI) Size() (n int)

func (*URI) String

func (m *URI) String() string

func (*URI) Unmarshal

func (m *URI) Unmarshal(dAtA []byte) error

func (*URI) XXX_DiscardUnknown

func (m *URI) XXX_DiscardUnknown()

func (*URI) XXX_Marshal

func (m *URI) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*URI) XXX_Merge

func (m *URI) XXX_Merge(src proto.Message)

func (*URI) XXX_Size

func (m *URI) XXX_Size() int

func (*URI) XXX_Unmarshal

func (m *URI) XXX_Unmarshal(b []byte) error

type UpdateFieldMessage

type UpdateFieldMessage struct {
	CreateFieldMessage   *CreateFieldMessage `protobuf:"bytes,1,opt,name=CreateFieldMessage,proto3" json:"CreateFieldMessage,omitempty"`
	Update               *FieldUpdate        `protobuf:"bytes,2,opt,name=Update,proto3" json:"Update,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*UpdateFieldMessage) Descriptor

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

func (*UpdateFieldMessage) GetCreateFieldMessage

func (m *UpdateFieldMessage) GetCreateFieldMessage() *CreateFieldMessage

func (*UpdateFieldMessage) GetUpdate

func (m *UpdateFieldMessage) GetUpdate() *FieldUpdate

func (*UpdateFieldMessage) Marshal

func (m *UpdateFieldMessage) Marshal() (dAtA []byte, err error)

func (*UpdateFieldMessage) MarshalTo

func (m *UpdateFieldMessage) MarshalTo(dAtA []byte) (int, error)

func (*UpdateFieldMessage) MarshalToSizedBuffer

func (m *UpdateFieldMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateFieldMessage) ProtoMessage

func (*UpdateFieldMessage) ProtoMessage()

func (*UpdateFieldMessage) Reset

func (m *UpdateFieldMessage) Reset()

func (*UpdateFieldMessage) Size

func (m *UpdateFieldMessage) Size() (n int)

func (*UpdateFieldMessage) String

func (m *UpdateFieldMessage) String() string

func (*UpdateFieldMessage) Unmarshal

func (m *UpdateFieldMessage) Unmarshal(dAtA []byte) error

func (*UpdateFieldMessage) XXX_DiscardUnknown

func (m *UpdateFieldMessage) XXX_DiscardUnknown()

func (*UpdateFieldMessage) XXX_Marshal

func (m *UpdateFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateFieldMessage) XXX_Merge

func (m *UpdateFieldMessage) XXX_Merge(src proto.Message)

func (*UpdateFieldMessage) XXX_Size

func (m *UpdateFieldMessage) XXX_Size() int

func (*UpdateFieldMessage) XXX_Unmarshal

func (m *UpdateFieldMessage) XXX_Unmarshal(b []byte) error

type ValCount

type ValCount struct {
	Val                  int64    `protobuf:"varint,1,opt,name=Val,proto3" json:"Val,omitempty"`
	Count                int64    `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
	FloatVal             float64  `protobuf:"fixed64,3,opt,name=FloatVal,proto3" json:"FloatVal,omitempty"`
	DecimalVal           *Decimal `protobuf:"bytes,4,opt,name=DecimalVal,proto3" json:"DecimalVal,omitempty"`
	TimestampVal         string   `protobuf:"bytes,5,opt,name=TimestampVal,proto3" json:"TimestampVal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValCount) Descriptor

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

func (*ValCount) GetCount

func (m *ValCount) GetCount() int64

func (*ValCount) GetDecimalVal

func (m *ValCount) GetDecimalVal() *Decimal

func (*ValCount) GetFloatVal

func (m *ValCount) GetFloatVal() float64

func (*ValCount) GetTimestampVal

func (m *ValCount) GetTimestampVal() string

func (*ValCount) GetVal

func (m *ValCount) GetVal() int64

func (*ValCount) Marshal

func (m *ValCount) Marshal() (dAtA []byte, err error)

func (*ValCount) MarshalTo

func (m *ValCount) MarshalTo(dAtA []byte) (int, error)

func (*ValCount) MarshalToSizedBuffer

func (m *ValCount) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValCount) ProtoMessage

func (*ValCount) ProtoMessage()

func (*ValCount) Reset

func (m *ValCount) Reset()

func (*ValCount) Size

func (m *ValCount) Size() (n int)

func (*ValCount) String

func (m *ValCount) String() string

func (*ValCount) Unmarshal

func (m *ValCount) Unmarshal(dAtA []byte) error

func (*ValCount) XXX_DiscardUnknown

func (m *ValCount) XXX_DiscardUnknown()

func (*ValCount) XXX_Marshal

func (m *ValCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValCount) XXX_Merge

func (m *ValCount) XXX_Merge(src proto.Message)

func (*ValCount) XXX_Size

func (m *ValCount) XXX_Size() int

func (*ValCount) XXX_Unmarshal

func (m *ValCount) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL