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 (m *ImportRoaringRequest) GetViews() []*ImportRoaringRequestView

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 (m *ShardIngestOperations) GetOps() []*ShardIngestOperation

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 (m *ShardedIngestRequest) GetOps() map[uint64]*ShardIngestOperations

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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