talaria

package

Go to main page

Versions in this module

v1

v1.6.1

Aug 1, 2023

Changes in this version

+ type DescribeTableRequest struct

+ Name string

+ func (*DescribeTableRequest) Descriptor() ([]byte, []int)

+ func (*DescribeTableRequest) ProtoMessage()

+ func (m *DescribeTableRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DescribeTableRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DescribeTableRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *DescribeTableRequest) SizeVT() (n int)

+ func (m *DescribeTableRequest) UnmarshalVT(dAtA []byte) error

+ func (x *DescribeTableRequest) GetName() string

+ func (x *DescribeTableRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeTableRequest) Reset()

+ func (x *DescribeTableRequest) String() string

+ type DescribeTableResponse struct

+ Table *TableMeta

+ func (*DescribeTableResponse) Descriptor() ([]byte, []int)

+ func (*DescribeTableResponse) ProtoMessage()

+ func (m *DescribeTableResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DescribeTableResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DescribeTableResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *DescribeTableResponse) SizeVT() (n int)

+ func (m *DescribeTableResponse) UnmarshalVT(dAtA []byte) error

+ func (x *DescribeTableResponse) GetTable() *TableMeta

+ func (x *DescribeTableResponse) ProtoReflect() protoreflect.Message

+ func (x *DescribeTableResponse) Reset()

+ func (x *DescribeTableResponse) String() string

+ type GetNodesRequest struct

+ func (*GetNodesRequest) Descriptor() ([]byte, []int)

+ func (*GetNodesRequest) ProtoMessage()

+ func (m *GetNodesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetNodesRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetNodesRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetNodesRequest) SizeVT() (n int)

+ func (m *GetNodesRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetNodesRequest) ProtoReflect() protoreflect.Message

+ func (x *GetNodesRequest) Reset()

+ func (x *GetNodesRequest) String() string

+ type GetNodesResponse struct

+ Nodes []*Endpoint

+ func (*GetNodesResponse) Descriptor() ([]byte, []int)

+ func (*GetNodesResponse) ProtoMessage()

+ func (m *GetNodesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetNodesResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetNodesResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetNodesResponse) SizeVT() (n int)

+ func (m *GetNodesResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetNodesResponse) GetNodes() []*Endpoint

+ func (x *GetNodesResponse) ProtoReflect() protoreflect.Message

+ func (x *GetNodesResponse) Reset()

+ func (x *GetNodesResponse) String() string

+ type IngestWithTableRequest struct

+ Data isIngestWithTableRequest_Data

+ Tables []string

+ func (*IngestWithTableRequest) Descriptor() ([]byte, []int)

+ func (*IngestWithTableRequest) ProtoMessage()

+ func (m *IngestWithTableRequest) GetData() isIngestWithTableRequest_Data

+ func (m *IngestWithTableRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *IngestWithTableRequest) SizeVT() (n int)

+ func (m *IngestWithTableRequest) UnmarshalVT(dAtA []byte) error

+ func (x *IngestWithTableRequest) GetBatch() *Batch

+ func (x *IngestWithTableRequest) GetCsv() []byte

+ func (x *IngestWithTableRequest) GetOrc() []byte

+ func (x *IngestWithTableRequest) GetParquet() []byte

+ func (x *IngestWithTableRequest) GetTables() []string

+ func (x *IngestWithTableRequest) GetUrl() string

+ func (x *IngestWithTableRequest) ProtoReflect() protoreflect.Message

+ func (x *IngestWithTableRequest) Reset()

+ func (x *IngestWithTableRequest) String() string

+ type IngestWithTableRequest_Batch struct

+ Batch *Batch

+ func (m *IngestWithTableRequest_Batch) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Batch) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Batch) SizeVT() (n int)

+ type IngestWithTableRequest_Csv struct

+ Csv []byte

+ func (m *IngestWithTableRequest_Csv) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Csv) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Csv) SizeVT() (n int)

+ type IngestWithTableRequest_Orc struct

+ Orc []byte

+ func (m *IngestWithTableRequest_Orc) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Orc) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Orc) SizeVT() (n int)

+ type IngestWithTableRequest_Parquet struct

+ Parquet []byte

+ func (m *IngestWithTableRequest_Parquet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Parquet) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Parquet) SizeVT() (n int)

+ type IngestWithTableRequest_Url struct

+ Url string

+ func (m *IngestWithTableRequest_Url) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Url) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestWithTableRequest_Url) SizeVT() (n int)

type IngressClient

+ IngestWithTable func(ctx context.Context, in *IngestWithTableRequest, opts ...grpc.CallOption) (*IngestResponse, error)

type IngressServer

+ IngestWithTable func(context.Context, *IngestWithTableRequest) (*IngestResponse, error)

type QueryClient

+ DescribeTable func(ctx context.Context, in *DescribeTableRequest, opts ...grpc.CallOption) (*DescribeTableResponse, error)

+ GetNodes func(ctx context.Context, in *GetNodesRequest, opts ...grpc.CallOption) (*GetNodesResponse, error)

type QueryServer

+ DescribeTable func(context.Context, *DescribeTableRequest) (*DescribeTableResponse, error)

+ GetNodes func(context.Context, *GetNodesRequest) (*GetNodesResponse, error)

type TableMeta

+ Hashby string

+ Sortby string

+ func (x *TableMeta) GetHashby() string

+ func (x *TableMeta) GetSortby() string

type UnimplementedIngressServer

+ func (UnimplementedIngressServer) IngestWithTable(context.Context, *IngestWithTableRequest) (*IngestResponse, error)

type UnimplementedQueryServer

+ func (UnimplementedQueryServer) DescribeTable(context.Context, *DescribeTableRequest) (*DescribeTableResponse, error)

+ func (UnimplementedQueryServer) GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error)

v1.6.0

Jun 7, 2022

v1.5.1

Jun 2, 2022

v1.5.0

May 6, 2022

v1.4.0

Dec 13, 2021

v1.3.1

Sep 17, 2021

Changes in this version

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_talaria_proto protoreflect.FileDescriptor

+ var Ingress_ServiceDesc = grpc.ServiceDesc

+ var Query_ServiceDesc = grpc.ServiceDesc

type Batch

+ func (m *Batch) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Batch) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Batch) MarshalVT() (dAtA []byte, err error)

+ func (m *Batch) SizeVT() (n int)

+ func (m *Batch) UnmarshalVT(dAtA []byte) error

+ func (x *Batch) ProtoReflect() protoreflect.Message

type Column

+ func (m *Column) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column) MarshalVT() (dAtA []byte, err error)

+ func (m *Column) SizeVT() (n int)

+ func (m *Column) UnmarshalVT(dAtA []byte) error

+ func (x *Column) ProtoReflect() protoreflect.Message

type ColumnMeta

+ func (m *ColumnMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ColumnMeta) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ColumnMeta) MarshalVT() (dAtA []byte, err error)

+ func (m *ColumnMeta) SizeVT() (n int)

+ func (m *ColumnMeta) UnmarshalVT(dAtA []byte) error

+ func (x *ColumnMeta) ProtoReflect() protoreflect.Message

type ColumnOfBools

+ func (m *ColumnOfBools) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ColumnOfBools) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ColumnOfBools) MarshalVT() (dAtA []byte, err error)

+ func (m *ColumnOfBools) SizeVT() (n int)

+ func (m *ColumnOfBools) UnmarshalVT(dAtA []byte) error

+ func (x *ColumnOfBools) ProtoReflect() protoreflect.Message

type ColumnOfFloat64

+ func (m *ColumnOfFloat64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ColumnOfFloat64) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ColumnOfFloat64) MarshalVT() (dAtA []byte, err error)

+ func (m *ColumnOfFloat64) SizeVT() (n int)

+ func (m *ColumnOfFloat64) UnmarshalVT(dAtA []byte) error

+ func (x *ColumnOfFloat64) ProtoReflect() protoreflect.Message

type ColumnOfInt32

+ func (m *ColumnOfInt32) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ColumnOfInt32) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ColumnOfInt32) MarshalVT() (dAtA []byte, err error)

+ func (m *ColumnOfInt32) SizeVT() (n int)

+ func (m *ColumnOfInt32) UnmarshalVT(dAtA []byte) error

+ func (x *ColumnOfInt32) ProtoReflect() protoreflect.Message

type ColumnOfInt64

+ func (m *ColumnOfInt64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ColumnOfInt64) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ColumnOfInt64) MarshalVT() (dAtA []byte, err error)

+ func (m *ColumnOfInt64) SizeVT() (n int)

+ func (m *ColumnOfInt64) UnmarshalVT(dAtA []byte) error

+ func (x *ColumnOfInt64) ProtoReflect() protoreflect.Message

type ColumnOfString

+ func (m *ColumnOfString) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ColumnOfString) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ColumnOfString) MarshalVT() (dAtA []byte, err error)

+ func (m *ColumnOfString) SizeVT() (n int)

+ func (m *ColumnOfString) UnmarshalVT(dAtA []byte) error

+ func (x *ColumnOfString) ProtoReflect() protoreflect.Message

type Column_Bool

+ func (m *Column_Bool) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column_Bool) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column_Bool) SizeVT() (n int)

type Column_Float64

+ func (m *Column_Float64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column_Float64) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column_Float64) SizeVT() (n int)

type Column_Int32

+ func (m *Column_Int32) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column_Int32) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column_Int32) SizeVT() (n int)

type Column_Int64

+ func (m *Column_Int64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column_Int64) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column_Int64) SizeVT() (n int)

type Column_Json

+ func (m *Column_Json) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column_Json) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column_Json) SizeVT() (n int)

type Column_String_

+ func (m *Column_String_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column_String_) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column_String_) SizeVT() (n int)

type Column_Time

+ func (m *Column_Time) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Column_Time) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Column_Time) SizeVT() (n int)

type DescribeRequest

+ func (m *DescribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DescribeRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DescribeRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *DescribeRequest) SizeVT() (n int)

+ func (m *DescribeRequest) UnmarshalVT(dAtA []byte) error

+ func (x *DescribeRequest) ProtoReflect() protoreflect.Message

type DescribeResponse

+ func (m *DescribeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DescribeResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DescribeResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *DescribeResponse) SizeVT() (n int)

+ func (m *DescribeResponse) UnmarshalVT(dAtA []byte) error

+ func (x *DescribeResponse) ProtoReflect() protoreflect.Message

type Endpoint

+ func (m *Endpoint) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Endpoint) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Endpoint) MarshalVT() (dAtA []byte, err error)

+ func (m *Endpoint) SizeVT() (n int)

+ func (m *Endpoint) UnmarshalVT(dAtA []byte) error

+ func (x *Endpoint) ProtoReflect() protoreflect.Message

type Event

+ func (m *Event) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Event) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Event) MarshalVT() (dAtA []byte, err error)

+ func (m *Event) SizeVT() (n int)

+ func (m *Event) UnmarshalVT(dAtA []byte) error

+ func (x *Event) ProtoReflect() protoreflect.Message

type GetRowsRequest

+ func (m *GetRowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetRowsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetRowsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetRowsRequest) SizeVT() (n int)

+ func (m *GetRowsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetRowsRequest) ProtoReflect() protoreflect.Message

type GetRowsResponse

+ func (m *GetRowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetRowsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetRowsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetRowsResponse) SizeVT() (n int)

+ func (m *GetRowsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetRowsResponse) ProtoReflect() protoreflect.Message

type GetSplitsRequest

+ func (m *GetSplitsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSplitsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSplitsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSplitsRequest) SizeVT() (n int)

+ func (m *GetSplitsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSplitsRequest) ProtoReflect() protoreflect.Message

type GetSplitsResponse

+ func (m *GetSplitsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSplitsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSplitsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSplitsResponse) SizeVT() (n int)

+ func (m *GetSplitsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetSplitsResponse) ProtoReflect() protoreflect.Message

type IngestRequest

+ func (m *IngestRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *IngestRequest) SizeVT() (n int)

+ func (m *IngestRequest) UnmarshalVT(dAtA []byte) error

+ func (x *IngestRequest) ProtoReflect() protoreflect.Message

type IngestRequest_Batch

+ func (m *IngestRequest_Batch) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Batch) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Batch) SizeVT() (n int)

type IngestRequest_Csv

+ func (m *IngestRequest_Csv) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Csv) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Csv) SizeVT() (n int)

type IngestRequest_Orc

+ func (m *IngestRequest_Orc) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Orc) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Orc) SizeVT() (n int)

type IngestRequest_Parquet

+ func (m *IngestRequest_Parquet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Parquet) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Parquet) SizeVT() (n int)

type IngestRequest_Url

+ func (m *IngestRequest_Url) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Url) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestRequest_Url) SizeVT() (n int)

type IngestResponse

+ func (m *IngestResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IngestResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IngestResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *IngestResponse) SizeVT() (n int)

+ func (m *IngestResponse) UnmarshalVT(dAtA []byte) error

+ func (x *IngestResponse) ProtoReflect() protoreflect.Message

type Split

+ func (m *Split) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Split) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Split) MarshalVT() (dAtA []byte, err error)

+ func (m *Split) SizeVT() (n int)

+ func (m *Split) UnmarshalVT(dAtA []byte) error

+ func (x *Split) ProtoReflect() protoreflect.Message

type TableMeta

+ func (m *TableMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TableMeta) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TableMeta) MarshalVT() (dAtA []byte, err error)

+ func (m *TableMeta) SizeVT() (n int)

+ func (m *TableMeta) UnmarshalVT(dAtA []byte) error

+ func (x *TableMeta) ProtoReflect() protoreflect.Message

+ type UnsafeIngressServer interface

+ type UnsafeQueryServer interface

type Value

+ func (m *Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value) MarshalVT() (dAtA []byte, err error)

+ func (m *Value) SizeVT() (n int)

+ func (m *Value) UnmarshalVT(dAtA []byte) error

+ func (x *Value) ProtoReflect() protoreflect.Message

type Value_Bool

+ func (m *Value_Bool) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value_Bool) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value_Bool) SizeVT() (n int)

type Value_Float64

+ func (m *Value_Float64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value_Float64) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value_Float64) SizeVT() (n int)

type Value_Int32

+ func (m *Value_Int32) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value_Int32) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value_Int32) SizeVT() (n int)

type Value_Int64

+ func (m *Value_Int64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value_Int64) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value_Int64) SizeVT() (n int)

type Value_Json

+ func (m *Value_Json) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value_Json) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value_Json) SizeVT() (n int)

type Value_String_

+ func (m *Value_String_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value_String_) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value_String_) SizeVT() (n int)

type Value_Time

+ func (m *Value_Time) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Value_Time) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Value_Time) SizeVT() (n int)

v1.3.0

Jul 2, 2021

v1.2.9

Jun 16, 2021

v1.2.8

May 13, 2021

v1.2.7

Apr 22, 2021

v1.2.6

Mar 31, 2021

Changes in this version

type IngestRequest

+ func (m *IngestRequest) GetParquet() []byte

+ type IngestRequest_Parquet struct

+ Parquet []byte

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

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

+ func (m *IngestRequest_Parquet) Size() (n int)

+ func (this *IngestRequest_Parquet) Equal(that interface{}) bool

+ func (this *IngestRequest_Parquet) GoString() string

+ func (this *IngestRequest_Parquet) String() string

v1.2.5

Mar 17, 2021

v1.1.12

May 13, 2020

v1.1.6

Apr 20, 2020

Changes in this version

+ var ErrUnexpectedEndOfGroupTalaria = fmt.Errorf("proto: unexpected end of group")

type Batch

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

+ func (m *Batch) XXX_DiscardUnknown()

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

+ func (m *Batch) XXX_Merge(src proto.Message)

+ func (m *Batch) XXX_Size() int

+ func (m *Batch) XXX_Unmarshal(b []byte) error

type Column

+ func (*Column) XXX_OneofWrappers() []interface{}

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

+ func (m *Column) XXX_DiscardUnknown()

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

+ func (m *Column) XXX_Merge(src proto.Message)

+ func (m *Column) XXX_Size() int

+ func (m *Column) XXX_Unmarshal(b []byte) error

type ColumnMeta

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

+ func (m *ColumnMeta) XXX_DiscardUnknown()

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

+ func (m *ColumnMeta) XXX_Merge(src proto.Message)

+ func (m *ColumnMeta) XXX_Size() int

+ func (m *ColumnMeta) XXX_Unmarshal(b []byte) error

type ColumnOfBools

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

+ func (m *ColumnOfBools) XXX_DiscardUnknown()

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

+ func (m *ColumnOfBools) XXX_Merge(src proto.Message)

+ func (m *ColumnOfBools) XXX_Size() int

+ func (m *ColumnOfBools) XXX_Unmarshal(b []byte) error

type ColumnOfFloat64

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

+ func (m *ColumnOfFloat64) XXX_DiscardUnknown()

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

+ func (m *ColumnOfFloat64) XXX_Merge(src proto.Message)

+ func (m *ColumnOfFloat64) XXX_Size() int

+ func (m *ColumnOfFloat64) XXX_Unmarshal(b []byte) error

type ColumnOfInt32

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

+ func (m *ColumnOfInt32) XXX_DiscardUnknown()

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

+ func (m *ColumnOfInt32) XXX_Merge(src proto.Message)

+ func (m *ColumnOfInt32) XXX_Size() int

+ func (m *ColumnOfInt32) XXX_Unmarshal(b []byte) error

type ColumnOfInt64

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

+ func (m *ColumnOfInt64) XXX_DiscardUnknown()

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

+ func (m *ColumnOfInt64) XXX_Merge(src proto.Message)

+ func (m *ColumnOfInt64) XXX_Size() int

+ func (m *ColumnOfInt64) XXX_Unmarshal(b []byte) error

type ColumnOfString

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

+ func (m *ColumnOfString) XXX_DiscardUnknown()

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

+ func (m *ColumnOfString) XXX_Merge(src proto.Message)

+ func (m *ColumnOfString) XXX_Size() int

+ func (m *ColumnOfString) XXX_Unmarshal(b []byte) error

type Column_Bool

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

type Column_Float64

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

type Column_Int32

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

type Column_Int64

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

type Column_Json

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

type Column_String_

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

type Column_Time

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

type DescribeRequest

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

+ func (m *DescribeRequest) XXX_DiscardUnknown()

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

+ func (m *DescribeRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeRequest) XXX_Size() int

+ func (m *DescribeRequest) XXX_Unmarshal(b []byte) error

type DescribeResponse

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

+ func (m *DescribeResponse) XXX_DiscardUnknown()

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

+ func (m *DescribeResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeResponse) XXX_Size() int

+ func (m *DescribeResponse) XXX_Unmarshal(b []byte) error

type Endpoint

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

+ func (m *Endpoint) XXX_DiscardUnknown()

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

+ func (m *Endpoint) XXX_Merge(src proto.Message)

+ func (m *Endpoint) XXX_Size() int

+ func (m *Endpoint) XXX_Unmarshal(b []byte) error

type Event

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

+ func (m *Event) XXX_DiscardUnknown()

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

+ func (m *Event) XXX_Merge(src proto.Message)

+ func (m *Event) XXX_Size() int

+ func (m *Event) XXX_Unmarshal(b []byte) error

type GetRowsRequest

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

+ func (m *GetRowsRequest) XXX_DiscardUnknown()

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

+ func (m *GetRowsRequest) XXX_Merge(src proto.Message)

+ func (m *GetRowsRequest) XXX_Size() int

+ func (m *GetRowsRequest) XXX_Unmarshal(b []byte) error

type GetRowsResponse

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

+ func (m *GetRowsResponse) XXX_DiscardUnknown()

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

+ func (m *GetRowsResponse) XXX_Merge(src proto.Message)

+ func (m *GetRowsResponse) XXX_Size() int

+ func (m *GetRowsResponse) XXX_Unmarshal(b []byte) error

type GetSplitsRequest

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

+ func (m *GetSplitsRequest) XXX_DiscardUnknown()

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

+ func (m *GetSplitsRequest) XXX_Merge(src proto.Message)

+ func (m *GetSplitsRequest) XXX_Size() int

+ func (m *GetSplitsRequest) XXX_Unmarshal(b []byte) error

type GetSplitsResponse

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

+ func (m *GetSplitsResponse) XXX_DiscardUnknown()

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

+ func (m *GetSplitsResponse) XXX_Merge(src proto.Message)

+ func (m *GetSplitsResponse) XXX_Size() int

+ func (m *GetSplitsResponse) XXX_Unmarshal(b []byte) error

type IngestRequest

+ func (*IngestRequest) XXX_OneofWrappers() []interface{}

+ func (m *IngestRequest) GetCsv() []byte

+ func (m *IngestRequest) GetUrl() string

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

+ func (m *IngestRequest) XXX_DiscardUnknown()

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

+ func (m *IngestRequest) XXX_Merge(src proto.Message)

+ func (m *IngestRequest) XXX_Size() int

+ func (m *IngestRequest) XXX_Unmarshal(b []byte) error

type IngestRequest_Batch

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

+ type IngestRequest_Csv struct

+ Csv []byte

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

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

+ func (m *IngestRequest_Csv) Size() (n int)

+ func (this *IngestRequest_Csv) Equal(that interface{}) bool

+ func (this *IngestRequest_Csv) GoString() string

+ func (this *IngestRequest_Csv) String() string

type IngestRequest_Orc

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

+ type IngestRequest_Url struct

+ Url string

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

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

+ func (m *IngestRequest_Url) Size() (n int)

+ func (this *IngestRequest_Url) Equal(that interface{}) bool

+ func (this *IngestRequest_Url) GoString() string

+ func (this *IngestRequest_Url) String() string

type IngestResponse

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

+ func (m *IngestResponse) XXX_DiscardUnknown()

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

+ func (m *IngestResponse) XXX_Merge(src proto.Message)

+ func (m *IngestResponse) XXX_Size() int

+ func (m *IngestResponse) XXX_Unmarshal(b []byte) error

type Split

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

+ func (m *Split) XXX_DiscardUnknown()

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

+ func (m *Split) XXX_Merge(src proto.Message)

+ func (m *Split) XXX_Size() int

+ func (m *Split) XXX_Unmarshal(b []byte) error

type TableMeta

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

+ func (m *TableMeta) XXX_DiscardUnknown()

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

+ func (m *TableMeta) XXX_Merge(src proto.Message)

+ func (m *TableMeta) XXX_Size() int

+ func (m *TableMeta) XXX_Unmarshal(b []byte) error

+ type UnimplementedIngressServer struct

+ func (*UnimplementedIngressServer) Ingest(ctx context.Context, req *IngestRequest) (*IngestResponse, error)

+ type UnimplementedQueryServer struct

+ func (*UnimplementedQueryServer) Describe(ctx context.Context, req *DescribeRequest) (*DescribeResponse, error)

+ func (*UnimplementedQueryServer) GetRows(ctx context.Context, req *GetRowsRequest) (*GetRowsResponse, error)

+ func (*UnimplementedQueryServer) GetSplits(ctx context.Context, req *GetSplitsRequest) (*GetSplitsResponse, error)

type Value

+ func (*Value) XXX_OneofWrappers() []interface{}

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

+ func (m *Value) XXX_DiscardUnknown()

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

+ func (m *Value) XXX_Merge(src proto.Message)

+ func (m *Value) XXX_Size() int

+ func (m *Value) XXX_Unmarshal(b []byte) error

type Value_Bool

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

type Value_Float64

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

type Value_Int32

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

type Value_Int64

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

type Value_Json

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

type Value_String_

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

type Value_Time

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

v1.1.5

Apr 17, 2020

v1.1.4

Apr 14, 2020

Changes in this version

+ var ErrIntOverflowTalaria = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTalaria = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterIngressServer(s *grpc.Server, srv IngressServer)

+ func RegisterQueryServer(s *grpc.Server, srv QueryServer)

+ type Batch struct

+ Events []*Event

+ Strings map[uint32][]byte

+ func (*Batch) Descriptor() ([]byte, []int)

+ func (*Batch) ProtoMessage()

+ func (m *Batch) GetEvents() []*Event

+ func (m *Batch) GetStrings() map[uint32][]byte

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

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

+ func (m *Batch) Reset()

+ func (m *Batch) Size() (n int)

+ func (m *Batch) Unmarshal(dAtA []byte) error

+ func (this *Batch) Equal(that interface{}) bool

+ func (this *Batch) GoString() string

+ func (this *Batch) String() string

+ type Column struct

+ Value isColumn_Value

+ func (*Column) Descriptor() ([]byte, []int)

+ func (*Column) ProtoMessage()

+ func (*Column) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Column) GetBool() *ColumnOfBools

+ func (m *Column) GetFloat64() *ColumnOfFloat64

+ func (m *Column) GetInt32() *ColumnOfInt32

+ func (m *Column) GetInt64() *ColumnOfInt64

+ func (m *Column) GetJson() *ColumnOfString

+ func (m *Column) GetString_() *ColumnOfString

+ func (m *Column) GetTime() *ColumnOfInt64

+ func (m *Column) GetValue() isColumn_Value

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

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

+ func (m *Column) Reset()

+ func (m *Column) Size() (n int)

+ func (m *Column) Unmarshal(dAtA []byte) error

+ func (this *Column) Equal(that interface{}) bool

+ func (this *Column) GoString() string

+ func (this *Column) String() string

+ type ColumnMeta struct

+ Comment string

+ Name string

+ Type string

+ func (*ColumnMeta) Descriptor() ([]byte, []int)

+ func (*ColumnMeta) ProtoMessage()

+ func (m *ColumnMeta) GetComment() string

+ func (m *ColumnMeta) GetName() string

+ func (m *ColumnMeta) GetType() string

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

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

+ func (m *ColumnMeta) Reset()

+ func (m *ColumnMeta) Size() (n int)

+ func (m *ColumnMeta) Unmarshal(dAtA []byte) error

+ func (this *ColumnMeta) Equal(that interface{}) bool

+ func (this *ColumnMeta) GoString() string

+ func (this *ColumnMeta) String() string

+ type ColumnOfBools struct

+ Bools []bool

+ Nulls []bool

+ func (*ColumnOfBools) Descriptor() ([]byte, []int)

+ func (*ColumnOfBools) ProtoMessage()

+ func (m *ColumnOfBools) GetBools() []bool

+ func (m *ColumnOfBools) GetNulls() []bool

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

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

+ func (m *ColumnOfBools) Reset()

+ func (m *ColumnOfBools) Size() (n int)

+ func (m *ColumnOfBools) Unmarshal(dAtA []byte) error

+ func (this *ColumnOfBools) Equal(that interface{}) bool

+ func (this *ColumnOfBools) GoString() string

+ func (this *ColumnOfBools) String() string

+ type ColumnOfFloat64 struct

+ Doubles []float64

+ Nulls []bool

+ func (*ColumnOfFloat64) Descriptor() ([]byte, []int)

+ func (*ColumnOfFloat64) ProtoMessage()

+ func (m *ColumnOfFloat64) GetDoubles() []float64

+ func (m *ColumnOfFloat64) GetNulls() []bool

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

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

+ func (m *ColumnOfFloat64) Reset()

+ func (m *ColumnOfFloat64) Size() (n int)

+ func (m *ColumnOfFloat64) Unmarshal(dAtA []byte) error

+ func (this *ColumnOfFloat64) Equal(that interface{}) bool

+ func (this *ColumnOfFloat64) GoString() string

+ func (this *ColumnOfFloat64) String() string

+ type ColumnOfInt32 struct

+ Ints []int32

+ Nulls []bool

+ func (*ColumnOfInt32) Descriptor() ([]byte, []int)

+ func (*ColumnOfInt32) ProtoMessage()

+ func (m *ColumnOfInt32) GetInts() []int32

+ func (m *ColumnOfInt32) GetNulls() []bool

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

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

+ func (m *ColumnOfInt32) Reset()

+ func (m *ColumnOfInt32) Size() (n int)

+ func (m *ColumnOfInt32) Unmarshal(dAtA []byte) error

+ func (this *ColumnOfInt32) Equal(that interface{}) bool

+ func (this *ColumnOfInt32) GoString() string

+ func (this *ColumnOfInt32) String() string

+ type ColumnOfInt64 struct

+ Longs []int64

+ Nulls []bool

+ func (*ColumnOfInt64) Descriptor() ([]byte, []int)

+ func (*ColumnOfInt64) ProtoMessage()

+ func (m *ColumnOfInt64) GetLongs() []int64

+ func (m *ColumnOfInt64) GetNulls() []bool

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

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

+ func (m *ColumnOfInt64) Reset()

+ func (m *ColumnOfInt64) Size() (n int)

+ func (m *ColumnOfInt64) Unmarshal(dAtA []byte) error

+ func (this *ColumnOfInt64) Equal(that interface{}) bool

+ func (this *ColumnOfInt64) GoString() string

+ func (this *ColumnOfInt64) String() string

+ type ColumnOfString struct

+ Bytes []byte

+ Nulls []bool

+ Sizes []int32

+ func (*ColumnOfString) Descriptor() ([]byte, []int)

+ func (*ColumnOfString) ProtoMessage()

+ func (m *ColumnOfString) GetBytes() []byte

+ func (m *ColumnOfString) GetNulls() []bool

+ func (m *ColumnOfString) GetSizes() []int32

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

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

+ func (m *ColumnOfString) Reset()

+ func (m *ColumnOfString) Size() (n int)

+ func (m *ColumnOfString) Unmarshal(dAtA []byte) error

+ func (this *ColumnOfString) Equal(that interface{}) bool

+ func (this *ColumnOfString) GoString() string

+ func (this *ColumnOfString) String() string

+ type Column_Bool struct

+ Bool *ColumnOfBools

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

+ func (m *Column_Bool) Size() (n int)

+ func (this *Column_Bool) Equal(that interface{}) bool

+ func (this *Column_Bool) GoString() string

+ func (this *Column_Bool) String() string

+ type Column_Float64 struct

+ Float64 *ColumnOfFloat64

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

+ func (m *Column_Float64) Size() (n int)

+ func (this *Column_Float64) Equal(that interface{}) bool

+ func (this *Column_Float64) GoString() string

+ func (this *Column_Float64) String() string

+ type Column_Int32 struct

+ Int32 *ColumnOfInt32

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

+ func (m *Column_Int32) Size() (n int)

+ func (this *Column_Int32) Equal(that interface{}) bool

+ func (this *Column_Int32) GoString() string

+ func (this *Column_Int32) String() string

+ type Column_Int64 struct

+ Int64 *ColumnOfInt64

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

+ func (m *Column_Int64) Size() (n int)

+ func (this *Column_Int64) Equal(that interface{}) bool

+ func (this *Column_Int64) GoString() string

+ func (this *Column_Int64) String() string

+ type Column_Json struct

+ Json *ColumnOfString

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

+ func (m *Column_Json) Size() (n int)

+ func (this *Column_Json) Equal(that interface{}) bool

+ func (this *Column_Json) GoString() string

+ func (this *Column_Json) String() string

+ type Column_String_ struct

+ String_ *ColumnOfString

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

+ func (m *Column_String_) Size() (n int)

+ func (this *Column_String_) Equal(that interface{}) bool

+ func (this *Column_String_) GoString() string

+ func (this *Column_String_) String() string

+ type Column_Time struct

+ Time *ColumnOfInt64

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

+ func (m *Column_Time) Size() (n int)

+ func (this *Column_Time) Equal(that interface{}) bool

+ func (this *Column_Time) GoString() string

+ func (this *Column_Time) String() string

+ type DescribeRequest struct

+ func (*DescribeRequest) Descriptor() ([]byte, []int)

+ func (*DescribeRequest) ProtoMessage()

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

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

+ func (m *DescribeRequest) Reset()

+ func (m *DescribeRequest) Size() (n int)

+ func (m *DescribeRequest) Unmarshal(dAtA []byte) error

+ func (this *DescribeRequest) Equal(that interface{}) bool

+ func (this *DescribeRequest) GoString() string

+ func (this *DescribeRequest) String() string

+ type DescribeResponse struct

+ Tables []*TableMeta

+ func (*DescribeResponse) Descriptor() ([]byte, []int)

+ func (*DescribeResponse) ProtoMessage()

+ func (m *DescribeResponse) GetTables() []*TableMeta

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

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

+ func (m *DescribeResponse) Reset()

+ func (m *DescribeResponse) Size() (n int)

+ func (m *DescribeResponse) Unmarshal(dAtA []byte) error

+ func (this *DescribeResponse) Equal(that interface{}) bool

+ func (this *DescribeResponse) GoString() string

+ func (this *DescribeResponse) String() string

+ type Endpoint struct

+ Host string

+ Port int32

+ func (*Endpoint) Descriptor() ([]byte, []int)

+ func (*Endpoint) ProtoMessage()

+ func (m *Endpoint) GetHost() string

+ func (m *Endpoint) GetPort() int32

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

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

+ func (m *Endpoint) Reset()

+ func (m *Endpoint) Size() (n int)

+ func (m *Endpoint) Unmarshal(dAtA []byte) error

+ func (this *Endpoint) Equal(that interface{}) bool

+ func (this *Endpoint) GoString() string

+ func (this *Endpoint) String() string

+ type Event struct

+ Value map[uint32]*Value

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (m *Event) GetValue() map[uint32]*Value

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

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

+ func (m *Event) Reset()

+ func (m *Event) Size() (n int)

+ func (m *Event) Unmarshal(dAtA []byte) error

+ func (this *Event) Equal(that interface{}) bool

+ func (this *Event) GoString() string

+ func (this *Event) String() string

+ type GetRowsRequest struct

+ Columns []string

+ MaxBytes int64

+ NextToken []byte

+ SplitID []byte

+ func (*GetRowsRequest) Descriptor() ([]byte, []int)

+ func (*GetRowsRequest) ProtoMessage()

+ func (m *GetRowsRequest) GetColumns() []string

+ func (m *GetRowsRequest) GetMaxBytes() int64

+ func (m *GetRowsRequest) GetNextToken() []byte

+ func (m *GetRowsRequest) GetSplitID() []byte

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

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

+ func (m *GetRowsRequest) Reset()

+ func (m *GetRowsRequest) Size() (n int)

+ func (m *GetRowsRequest) Unmarshal(dAtA []byte) error

+ func (this *GetRowsRequest) Equal(that interface{}) bool

+ func (this *GetRowsRequest) GoString() string

+ func (this *GetRowsRequest) String() string

+ type GetRowsResponse struct

+ Columns []*Column

+ NextToken []byte

+ RowCount int32

+ func (*GetRowsResponse) Descriptor() ([]byte, []int)

+ func (*GetRowsResponse) ProtoMessage()

+ func (m *GetRowsResponse) GetColumns() []*Column

+ func (m *GetRowsResponse) GetNextToken() []byte

+ func (m *GetRowsResponse) GetRowCount() int32

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

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

+ func (m *GetRowsResponse) Reset()

+ func (m *GetRowsResponse) Size() (n int)

+ func (m *GetRowsResponse) Unmarshal(dAtA []byte) error

+ func (this *GetRowsResponse) Equal(that interface{}) bool

+ func (this *GetRowsResponse) GoString() string

+ func (this *GetRowsResponse) String() string

+ type GetSplitsRequest struct

+ Columns []string

+ Filters []string

+ MaxSplits int32

+ NextToken []byte

+ Schema string

+ Table string

+ func (*GetSplitsRequest) Descriptor() ([]byte, []int)

+ func (*GetSplitsRequest) ProtoMessage()

+ func (m *GetSplitsRequest) GetColumns() []string

+ func (m *GetSplitsRequest) GetFilters() []string

+ func (m *GetSplitsRequest) GetMaxSplits() int32

+ func (m *GetSplitsRequest) GetNextToken() []byte

+ func (m *GetSplitsRequest) GetSchema() string

+ func (m *GetSplitsRequest) GetTable() string

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

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

+ func (m *GetSplitsRequest) Reset()

+ func (m *GetSplitsRequest) Size() (n int)

+ func (m *GetSplitsRequest) Unmarshal(dAtA []byte) error

+ func (this *GetSplitsRequest) Equal(that interface{}) bool

+ func (this *GetSplitsRequest) GoString() string

+ func (this *GetSplitsRequest) String() string

+ type GetSplitsResponse struct

+ NextToken []byte

+ Splits []*Split

+ func (*GetSplitsResponse) Descriptor() ([]byte, []int)

+ func (*GetSplitsResponse) ProtoMessage()

+ func (m *GetSplitsResponse) GetNextToken() []byte

+ func (m *GetSplitsResponse) GetSplits() []*Split

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

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

+ func (m *GetSplitsResponse) Reset()

+ func (m *GetSplitsResponse) Size() (n int)

+ func (m *GetSplitsResponse) Unmarshal(dAtA []byte) error

+ func (this *GetSplitsResponse) Equal(that interface{}) bool

+ func (this *GetSplitsResponse) GoString() string

+ func (this *GetSplitsResponse) String() string

+ type IngestRequest struct

+ Data isIngestRequest_Data

+ func (*IngestRequest) Descriptor() ([]byte, []int)

+ func (*IngestRequest) ProtoMessage()

+ func (*IngestRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *IngestRequest) GetBatch() *Batch

+ func (m *IngestRequest) GetData() isIngestRequest_Data

+ func (m *IngestRequest) GetOrc() []byte

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

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

+ func (m *IngestRequest) Reset()

+ func (m *IngestRequest) Size() (n int)

+ func (m *IngestRequest) Unmarshal(dAtA []byte) error

+ func (this *IngestRequest) Equal(that interface{}) bool

+ func (this *IngestRequest) GoString() string

+ func (this *IngestRequest) String() string

+ type IngestRequest_Batch struct

+ Batch *Batch

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

+ func (m *IngestRequest_Batch) Size() (n int)

+ func (this *IngestRequest_Batch) Equal(that interface{}) bool

+ func (this *IngestRequest_Batch) GoString() string

+ func (this *IngestRequest_Batch) String() string

+ type IngestRequest_Orc struct

+ Orc []byte

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

+ func (m *IngestRequest_Orc) Size() (n int)

+ func (this *IngestRequest_Orc) Equal(that interface{}) bool

+ func (this *IngestRequest_Orc) GoString() string

+ func (this *IngestRequest_Orc) String() string

+ type IngestResponse struct

+ func (*IngestResponse) Descriptor() ([]byte, []int)

+ func (*IngestResponse) ProtoMessage()

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

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

+ func (m *IngestResponse) Reset()

+ func (m *IngestResponse) Size() (n int)

+ func (m *IngestResponse) Unmarshal(dAtA []byte) error

+ func (this *IngestResponse) Equal(that interface{}) bool

+ func (this *IngestResponse) GoString() string

+ func (this *IngestResponse) String() string

+ type IngressClient interface

+ Ingest func(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)

+ func NewIngressClient(cc *grpc.ClientConn) IngressClient

+ type IngressServer interface

+ Ingest func(context.Context, *IngestRequest) (*IngestResponse, error)

+ type QueryClient interface

+ Describe func(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeResponse, error)

+ GetRows func(ctx context.Context, in *GetRowsRequest, opts ...grpc.CallOption) (*GetRowsResponse, error)

+ GetSplits func(ctx context.Context, in *GetSplitsRequest, opts ...grpc.CallOption) (*GetSplitsResponse, error)

+ func NewQueryClient(cc *grpc.ClientConn) QueryClient

+ type QueryServer interface

+ Describe func(context.Context, *DescribeRequest) (*DescribeResponse, error)

+ GetRows func(context.Context, *GetRowsRequest) (*GetRowsResponse, error)

+ GetSplits func(context.Context, *GetSplitsRequest) (*GetSplitsResponse, error)

+ type Split struct

+ Hosts []*Endpoint

+ SplitID []byte

+ func (*Split) Descriptor() ([]byte, []int)

+ func (*Split) ProtoMessage()

+ func (m *Split) GetHosts() []*Endpoint

+ func (m *Split) GetSplitID() []byte

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

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

+ func (m *Split) Reset()

+ func (m *Split) Size() (n int)

+ func (m *Split) Unmarshal(dAtA []byte) error

+ func (this *Split) Equal(that interface{}) bool

+ func (this *Split) GoString() string

+ func (this *Split) String() string

+ type TableMeta struct

+ Columns []*ColumnMeta

+ Schema string

+ Table string

+ func (*TableMeta) Descriptor() ([]byte, []int)

+ func (*TableMeta) ProtoMessage()

+ func (m *TableMeta) GetColumns() []*ColumnMeta

+ func (m *TableMeta) GetSchema() string

+ func (m *TableMeta) GetTable() string

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

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

+ func (m *TableMeta) Reset()

+ func (m *TableMeta) Size() (n int)

+ func (m *TableMeta) Unmarshal(dAtA []byte) error

+ func (this *TableMeta) Equal(that interface{}) bool

+ func (this *TableMeta) GoString() string

+ func (this *TableMeta) String() string

+ type Value struct

+ Value isValue_Value

+ func (*Value) Descriptor() ([]byte, []int)

+ func (*Value) ProtoMessage()

+ func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Value) GetBool() bool

+ func (m *Value) GetFloat64() float64

+ func (m *Value) GetInt32() int32

+ func (m *Value) GetInt64() int64

+ func (m *Value) GetJson() uint32

+ func (m *Value) GetString_() uint32

+ func (m *Value) GetTime() int64

+ func (m *Value) GetValue() isValue_Value

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

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

+ func (m *Value) Reset()

+ func (m *Value) Size() (n int)

+ func (m *Value) Unmarshal(dAtA []byte) error

+ func (this *Value) Equal(that interface{}) bool

+ func (this *Value) GoString() string

+ func (this *Value) String() string

+ type Value_Bool struct

+ Bool bool

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

+ func (m *Value_Bool) Size() (n int)

+ func (this *Value_Bool) Equal(that interface{}) bool

+ func (this *Value_Bool) GoString() string

+ func (this *Value_Bool) String() string

+ type Value_Float64 struct

+ Float64 float64

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

+ func (m *Value_Float64) Size() (n int)

+ func (this *Value_Float64) Equal(that interface{}) bool

+ func (this *Value_Float64) GoString() string

+ func (this *Value_Float64) String() string

+ type Value_Int32 struct

+ Int32 int32

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

+ func (m *Value_Int32) Size() (n int)

+ func (this *Value_Int32) Equal(that interface{}) bool

+ func (this *Value_Int32) GoString() string

+ func (this *Value_Int32) String() string

+ type Value_Int64 struct

+ Int64 int64

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

+ func (m *Value_Int64) Size() (n int)

+ func (this *Value_Int64) Equal(that interface{}) bool

+ func (this *Value_Int64) GoString() string

+ func (this *Value_Int64) String() string

+ type Value_Json struct

+ Json uint32

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

+ func (m *Value_Json) Size() (n int)

+ func (this *Value_Json) Equal(that interface{}) bool

+ func (this *Value_Json) GoString() string

+ func (this *Value_Json) String() string

+ type Value_String_ struct

+ String_ uint32

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

+ func (m *Value_String_) Size() (n int)

+ func (this *Value_String_) Equal(that interface{}) bool

+ func (this *Value_String_) GoString() string

+ func (this *Value_String_) String() string

+ type Value_Time struct

+ Time int64

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

+ func (m *Value_Time) Size() (n int)

+ func (this *Value_Time) Equal(that interface{}) bool

+ func (this *Value_Time) GoString() string

+ func (this *Value_Time) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL