talaria

package
v1.2.6 Latest Latest
Warning

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

Go to latest
Published: Mar 31, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTalaria        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTalaria          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTalaria = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterIngressServer

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

func RegisterQueryServer

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

Types

type Batch

type Batch struct {
	Strings map[uint32][]byte `` /* 156-byte string literal not displayed */
	Events  []*Event          `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
}

Batch represents an event batch. It contains a map of strings in order to minimize the size.

func (*Batch) Descriptor

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

func (*Batch) Equal

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

func (*Batch) GetEvents

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

func (*Batch) GetStrings

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

func (*Batch) GoString

func (this *Batch) GoString() string

func (*Batch) Marshal

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

func (*Batch) MarshalTo

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

func (*Batch) MarshalToSizedBuffer added in v1.1.6

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

func (*Batch) ProtoMessage

func (*Batch) ProtoMessage()

func (*Batch) Reset

func (m *Batch) Reset()

func (*Batch) Size

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

func (*Batch) String

func (this *Batch) String() string

func (*Batch) Unmarshal

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

func (*Batch) XXX_DiscardUnknown added in v1.1.6

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal added in v1.1.6

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

func (*Batch) XXX_Merge added in v1.1.6

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

func (*Batch) XXX_Size added in v1.1.6

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal added in v1.1.6

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

type Column

type Column struct {
	// Types that are valid to be assigned to Value:
	//	*Column_Int32
	//	*Column_Int64
	//	*Column_Float64
	//	*Column_String_
	//	*Column_Bool
	//	*Column_Time
	//	*Column_Json
	Value isColumn_Value `protobuf_oneof:"value"`
}

Column represents a column.

func (*Column) Descriptor

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

func (*Column) Equal

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

func (*Column) GetBool

func (m *Column) GetBool() *ColumnOfBools

func (*Column) GetFloat64

func (m *Column) GetFloat64() *ColumnOfFloat64

func (*Column) GetInt32

func (m *Column) GetInt32() *ColumnOfInt32

func (*Column) GetInt64

func (m *Column) GetInt64() *ColumnOfInt64

func (*Column) GetJson

func (m *Column) GetJson() *ColumnOfString

func (*Column) GetString_

func (m *Column) GetString_() *ColumnOfString

func (*Column) GetTime

func (m *Column) GetTime() *ColumnOfInt64

func (*Column) GetValue

func (m *Column) GetValue() isColumn_Value

func (*Column) GoString

func (this *Column) GoString() string

func (*Column) Marshal

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

func (*Column) MarshalTo

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

func (*Column) MarshalToSizedBuffer added in v1.1.6

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

func (*Column) ProtoMessage

func (*Column) ProtoMessage()

func (*Column) Reset

func (m *Column) Reset()

func (*Column) Size

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

func (*Column) String

func (this *Column) String() string

func (*Column) Unmarshal

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

func (*Column) XXX_DiscardUnknown added in v1.1.6

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal added in v1.1.6

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

func (*Column) XXX_Merge added in v1.1.6

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

func (*Column) XXX_OneofWrappers added in v1.1.6

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Column) XXX_Size added in v1.1.6

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal added in v1.1.6

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

type ColumnMeta

type ColumnMeta 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"`
	Comment string `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"`
}

ColumnMeta represents a column metadata

func (*ColumnMeta) Descriptor

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

func (*ColumnMeta) Equal

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

func (*ColumnMeta) GetComment

func (m *ColumnMeta) GetComment() string

func (*ColumnMeta) GetName

func (m *ColumnMeta) GetName() string

func (*ColumnMeta) GetType

func (m *ColumnMeta) GetType() string

func (*ColumnMeta) GoString

func (this *ColumnMeta) GoString() string

func (*ColumnMeta) Marshal

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

func (*ColumnMeta) MarshalTo

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

func (*ColumnMeta) MarshalToSizedBuffer added in v1.1.6

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

func (*ColumnMeta) ProtoMessage

func (*ColumnMeta) ProtoMessage()

func (*ColumnMeta) Reset

func (m *ColumnMeta) Reset()

func (*ColumnMeta) Size

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

func (*ColumnMeta) String

func (this *ColumnMeta) String() string

func (*ColumnMeta) Unmarshal

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

func (*ColumnMeta) XXX_DiscardUnknown added in v1.1.6

func (m *ColumnMeta) XXX_DiscardUnknown()

func (*ColumnMeta) XXX_Marshal added in v1.1.6

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

func (*ColumnMeta) XXX_Merge added in v1.1.6

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

func (*ColumnMeta) XXX_Size added in v1.1.6

func (m *ColumnMeta) XXX_Size() int

func (*ColumnMeta) XXX_Unmarshal added in v1.1.6

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

type ColumnOfBools

type ColumnOfBools struct {
	Nulls []bool `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"`
	Bools []bool `protobuf:"varint,2,rep,packed,name=bools,proto3" json:"bools,omitempty"`
}

Column containing Boolean values

func (*ColumnOfBools) Descriptor

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

func (*ColumnOfBools) Equal

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

func (*ColumnOfBools) GetBools

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

func (*ColumnOfBools) GetNulls

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

func (*ColumnOfBools) GoString

func (this *ColumnOfBools) GoString() string

func (*ColumnOfBools) Marshal

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

func (*ColumnOfBools) MarshalTo

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

func (*ColumnOfBools) MarshalToSizedBuffer added in v1.1.6

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

func (*ColumnOfBools) ProtoMessage

func (*ColumnOfBools) ProtoMessage()

func (*ColumnOfBools) Reset

func (m *ColumnOfBools) Reset()

func (*ColumnOfBools) Size

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

func (*ColumnOfBools) String

func (this *ColumnOfBools) String() string

func (*ColumnOfBools) Unmarshal

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

func (*ColumnOfBools) XXX_DiscardUnknown added in v1.1.6

func (m *ColumnOfBools) XXX_DiscardUnknown()

func (*ColumnOfBools) XXX_Marshal added in v1.1.6

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

func (*ColumnOfBools) XXX_Merge added in v1.1.6

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

func (*ColumnOfBools) XXX_Size added in v1.1.6

func (m *ColumnOfBools) XXX_Size() int

func (*ColumnOfBools) XXX_Unmarshal added in v1.1.6

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

type ColumnOfFloat64

type ColumnOfFloat64 struct {
	Nulls   []bool    `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"`
	Doubles []float64 `protobuf:"fixed64,2,rep,packed,name=doubles,proto3" json:"doubles,omitempty"`
}

Column containing Float64 values

func (*ColumnOfFloat64) Descriptor

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

func (*ColumnOfFloat64) Equal

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

func (*ColumnOfFloat64) GetDoubles

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

func (*ColumnOfFloat64) GetNulls

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

func (*ColumnOfFloat64) GoString

func (this *ColumnOfFloat64) GoString() string

func (*ColumnOfFloat64) Marshal

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

func (*ColumnOfFloat64) MarshalTo

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

func (*ColumnOfFloat64) MarshalToSizedBuffer added in v1.1.6

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

func (*ColumnOfFloat64) ProtoMessage

func (*ColumnOfFloat64) ProtoMessage()

func (*ColumnOfFloat64) Reset

func (m *ColumnOfFloat64) Reset()

func (*ColumnOfFloat64) Size

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

func (*ColumnOfFloat64) String

func (this *ColumnOfFloat64) String() string

func (*ColumnOfFloat64) Unmarshal

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

func (*ColumnOfFloat64) XXX_DiscardUnknown added in v1.1.6

func (m *ColumnOfFloat64) XXX_DiscardUnknown()

func (*ColumnOfFloat64) XXX_Marshal added in v1.1.6

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

func (*ColumnOfFloat64) XXX_Merge added in v1.1.6

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

func (*ColumnOfFloat64) XXX_Size added in v1.1.6

func (m *ColumnOfFloat64) XXX_Size() int

func (*ColumnOfFloat64) XXX_Unmarshal added in v1.1.6

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

type ColumnOfInt32

type ColumnOfInt32 struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"`
	Ints  []int32 `protobuf:"varint,2,rep,packed,name=ints,proto3" json:"ints,omitempty"`
}

Column containing Int32 values

func (*ColumnOfInt32) Descriptor

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

func (*ColumnOfInt32) Equal

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

func (*ColumnOfInt32) GetInts

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

func (*ColumnOfInt32) GetNulls

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

func (*ColumnOfInt32) GoString

func (this *ColumnOfInt32) GoString() string

func (*ColumnOfInt32) Marshal

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

func (*ColumnOfInt32) MarshalTo

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

func (*ColumnOfInt32) MarshalToSizedBuffer added in v1.1.6

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

func (*ColumnOfInt32) ProtoMessage

func (*ColumnOfInt32) ProtoMessage()

func (*ColumnOfInt32) Reset

func (m *ColumnOfInt32) Reset()

func (*ColumnOfInt32) Size

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

func (*ColumnOfInt32) String

func (this *ColumnOfInt32) String() string

func (*ColumnOfInt32) Unmarshal

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

func (*ColumnOfInt32) XXX_DiscardUnknown added in v1.1.6

func (m *ColumnOfInt32) XXX_DiscardUnknown()

func (*ColumnOfInt32) XXX_Marshal added in v1.1.6

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

func (*ColumnOfInt32) XXX_Merge added in v1.1.6

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

func (*ColumnOfInt32) XXX_Size added in v1.1.6

func (m *ColumnOfInt32) XXX_Size() int

func (*ColumnOfInt32) XXX_Unmarshal added in v1.1.6

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

type ColumnOfInt64

type ColumnOfInt64 struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"`
	Longs []int64 `protobuf:"varint,2,rep,packed,name=longs,proto3" json:"longs,omitempty"`
}

Column containing Int64 values

func (*ColumnOfInt64) Descriptor

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

func (*ColumnOfInt64) Equal

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

func (*ColumnOfInt64) GetLongs

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

func (*ColumnOfInt64) GetNulls

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

func (*ColumnOfInt64) GoString

func (this *ColumnOfInt64) GoString() string

func (*ColumnOfInt64) Marshal

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

func (*ColumnOfInt64) MarshalTo

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

func (*ColumnOfInt64) MarshalToSizedBuffer added in v1.1.6

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

func (*ColumnOfInt64) ProtoMessage

func (*ColumnOfInt64) ProtoMessage()

func (*ColumnOfInt64) Reset

func (m *ColumnOfInt64) Reset()

func (*ColumnOfInt64) Size

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

func (*ColumnOfInt64) String

func (this *ColumnOfInt64) String() string

func (*ColumnOfInt64) Unmarshal

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

func (*ColumnOfInt64) XXX_DiscardUnknown added in v1.1.6

func (m *ColumnOfInt64) XXX_DiscardUnknown()

func (*ColumnOfInt64) XXX_Marshal added in v1.1.6

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

func (*ColumnOfInt64) XXX_Merge added in v1.1.6

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

func (*ColumnOfInt64) XXX_Size added in v1.1.6

func (m *ColumnOfInt64) XXX_Size() int

func (*ColumnOfInt64) XXX_Unmarshal added in v1.1.6

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

type ColumnOfString

type ColumnOfString struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"`
	Sizes []int32 `protobuf:"varint,2,rep,packed,name=sizes,proto3" json:"sizes,omitempty"`
	Bytes []byte  `protobuf:"bytes,3,opt,name=bytes,proto3" json:"bytes,omitempty"`
}

Column containing String values

func (*ColumnOfString) Descriptor

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

func (*ColumnOfString) Equal

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

func (*ColumnOfString) GetBytes

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

func (*ColumnOfString) GetNulls

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

func (*ColumnOfString) GetSizes

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

func (*ColumnOfString) GoString

func (this *ColumnOfString) GoString() string

func (*ColumnOfString) Marshal

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

func (*ColumnOfString) MarshalTo

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

func (*ColumnOfString) MarshalToSizedBuffer added in v1.1.6

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

func (*ColumnOfString) ProtoMessage

func (*ColumnOfString) ProtoMessage()

func (*ColumnOfString) Reset

func (m *ColumnOfString) Reset()

func (*ColumnOfString) Size

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

func (*ColumnOfString) String

func (this *ColumnOfString) String() string

func (*ColumnOfString) Unmarshal

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

func (*ColumnOfString) XXX_DiscardUnknown added in v1.1.6

func (m *ColumnOfString) XXX_DiscardUnknown()

func (*ColumnOfString) XXX_Marshal added in v1.1.6

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

func (*ColumnOfString) XXX_Merge added in v1.1.6

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

func (*ColumnOfString) XXX_Size added in v1.1.6

func (m *ColumnOfString) XXX_Size() int

func (*ColumnOfString) XXX_Unmarshal added in v1.1.6

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

type Column_Bool

type Column_Bool struct {
	Bool *ColumnOfBools `protobuf:"bytes,5,opt,name=bool,proto3,oneof" json:"bool,omitempty"`
}

func (*Column_Bool) Equal

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

func (*Column_Bool) GoString

func (this *Column_Bool) GoString() string

func (*Column_Bool) MarshalTo

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

func (*Column_Bool) MarshalToSizedBuffer added in v1.1.6

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

func (*Column_Bool) Size

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

func (*Column_Bool) String

func (this *Column_Bool) String() string

type Column_Float64

type Column_Float64 struct {
	Float64 *ColumnOfFloat64 `protobuf:"bytes,3,opt,name=float64,proto3,oneof" json:"float64,omitempty"`
}

func (*Column_Float64) Equal

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

func (*Column_Float64) GoString

func (this *Column_Float64) GoString() string

func (*Column_Float64) MarshalTo

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

func (*Column_Float64) MarshalToSizedBuffer added in v1.1.6

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

func (*Column_Float64) Size

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

func (*Column_Float64) String

func (this *Column_Float64) String() string

type Column_Int32

type Column_Int32 struct {
	Int32 *ColumnOfInt32 `protobuf:"bytes,1,opt,name=int32,proto3,oneof" json:"int32,omitempty"`
}

func (*Column_Int32) Equal

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

func (*Column_Int32) GoString

func (this *Column_Int32) GoString() string

func (*Column_Int32) MarshalTo

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

func (*Column_Int32) MarshalToSizedBuffer added in v1.1.6

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

func (*Column_Int32) Size

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

func (*Column_Int32) String

func (this *Column_Int32) String() string

type Column_Int64

type Column_Int64 struct {
	Int64 *ColumnOfInt64 `protobuf:"bytes,2,opt,name=int64,proto3,oneof" json:"int64,omitempty"`
}

func (*Column_Int64) Equal

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

func (*Column_Int64) GoString

func (this *Column_Int64) GoString() string

func (*Column_Int64) MarshalTo

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

func (*Column_Int64) MarshalToSizedBuffer added in v1.1.6

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

func (*Column_Int64) Size

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

func (*Column_Int64) String

func (this *Column_Int64) String() string

type Column_Json

type Column_Json struct {
	Json *ColumnOfString `protobuf:"bytes,7,opt,name=json,proto3,oneof" json:"json,omitempty"`
}

func (*Column_Json) Equal

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

func (*Column_Json) GoString

func (this *Column_Json) GoString() string

func (*Column_Json) MarshalTo

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

func (*Column_Json) MarshalToSizedBuffer added in v1.1.6

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

func (*Column_Json) Size

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

func (*Column_Json) String

func (this *Column_Json) String() string

type Column_String_

type Column_String_ struct {
	String_ *ColumnOfString `protobuf:"bytes,4,opt,name=string,proto3,oneof" json:"string,omitempty"`
}

func (*Column_String_) Equal

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

func (*Column_String_) GoString

func (this *Column_String_) GoString() string

func (*Column_String_) MarshalTo

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

func (*Column_String_) MarshalToSizedBuffer added in v1.1.6

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

func (*Column_String_) Size

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

func (*Column_String_) String

func (this *Column_String_) String() string

type Column_Time

type Column_Time struct {
	Time *ColumnOfInt64 `protobuf:"bytes,6,opt,name=time,proto3,oneof" json:"time,omitempty"`
}

func (*Column_Time) Equal

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

func (*Column_Time) GoString

func (this *Column_Time) GoString() string

func (*Column_Time) MarshalTo

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

func (*Column_Time) MarshalToSizedBuffer added in v1.1.6

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

func (*Column_Time) Size

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

func (*Column_Time) String

func (this *Column_Time) String() string

type DescribeRequest

type DescribeRequest struct {
}

DescribeRequest represents an request to list the tables and schemas.

func (*DescribeRequest) Descriptor

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

func (*DescribeRequest) Equal

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

func (*DescribeRequest) GoString

func (this *DescribeRequest) GoString() string

func (*DescribeRequest) Marshal

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

func (*DescribeRequest) MarshalTo

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

func (*DescribeRequest) MarshalToSizedBuffer added in v1.1.6

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

func (*DescribeRequest) ProtoMessage

func (*DescribeRequest) ProtoMessage()

func (*DescribeRequest) Reset

func (m *DescribeRequest) Reset()

func (*DescribeRequest) Size

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

func (*DescribeRequest) String

func (this *DescribeRequest) String() string

func (*DescribeRequest) Unmarshal

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

func (*DescribeRequest) XXX_DiscardUnknown added in v1.1.6

func (m *DescribeRequest) XXX_DiscardUnknown()

func (*DescribeRequest) XXX_Marshal added in v1.1.6

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

func (*DescribeRequest) XXX_Merge added in v1.1.6

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

func (*DescribeRequest) XXX_Size added in v1.1.6

func (m *DescribeRequest) XXX_Size() int

func (*DescribeRequest) XXX_Unmarshal added in v1.1.6

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

type DescribeResponse

type DescribeResponse struct {
	Tables []*TableMeta `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
}

DescribeResponse represents an response that returns tables and their schemas.

func (*DescribeResponse) Descriptor

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

func (*DescribeResponse) Equal

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

func (*DescribeResponse) GetTables

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

func (*DescribeResponse) GoString

func (this *DescribeResponse) GoString() string

func (*DescribeResponse) Marshal

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

func (*DescribeResponse) MarshalTo

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

func (*DescribeResponse) MarshalToSizedBuffer added in v1.1.6

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

func (*DescribeResponse) ProtoMessage

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) Reset

func (m *DescribeResponse) Reset()

func (*DescribeResponse) Size

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

func (*DescribeResponse) String

func (this *DescribeResponse) String() string

func (*DescribeResponse) Unmarshal

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

func (*DescribeResponse) XXX_DiscardUnknown added in v1.1.6

func (m *DescribeResponse) XXX_DiscardUnknown()

func (*DescribeResponse) XXX_Marshal added in v1.1.6

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

func (*DescribeResponse) XXX_Merge added in v1.1.6

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

func (*DescribeResponse) XXX_Size added in v1.1.6

func (m *DescribeResponse) XXX_Size() int

func (*DescribeResponse) XXX_Unmarshal added in v1.1.6

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

type Endpoint

type Endpoint struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
}

Endpoint represents a host/port combination

func (*Endpoint) Descriptor

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

func (*Endpoint) Equal

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

func (*Endpoint) GetHost

func (m *Endpoint) GetHost() string

func (*Endpoint) GetPort

func (m *Endpoint) GetPort() int32

func (*Endpoint) GoString

func (this *Endpoint) GoString() string

func (*Endpoint) Marshal

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

func (*Endpoint) MarshalTo

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

func (*Endpoint) MarshalToSizedBuffer added in v1.1.6

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

func (*Endpoint) ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset

func (m *Endpoint) Reset()

func (*Endpoint) Size

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

func (*Endpoint) String

func (this *Endpoint) String() string

func (*Endpoint) Unmarshal

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

func (*Endpoint) XXX_DiscardUnknown added in v1.1.6

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal added in v1.1.6

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

func (*Endpoint) XXX_Merge added in v1.1.6

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

func (*Endpoint) XXX_Size added in v1.1.6

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal added in v1.1.6

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

type Event

type Event struct {
	Value map[uint32]*Value `` /* 152-byte string literal not displayed */
}

Event represents a single event. Name as well as value columns are interned strings which are present in a batch.

func (*Event) Descriptor

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

func (*Event) Equal

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

func (*Event) GetValue

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

func (*Event) GoString

func (this *Event) GoString() string

func (*Event) Marshal

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

func (*Event) MarshalTo

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

func (*Event) MarshalToSizedBuffer added in v1.1.6

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

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) Size

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

func (*Event) String

func (this *Event) String() string

func (*Event) Unmarshal

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

func (*Event) XXX_DiscardUnknown added in v1.1.6

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal added in v1.1.6

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

func (*Event) XXX_Merge added in v1.1.6

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

func (*Event) XXX_Size added in v1.1.6

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal added in v1.1.6

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

type GetRowsRequest

type GetRowsRequest struct {
	SplitID   []byte   `protobuf:"bytes,1,opt,name=splitID,proto3" json:"splitID,omitempty"`
	Columns   []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	MaxBytes  int64    `protobuf:"varint,3,opt,name=maxBytes,proto3" json:"maxBytes,omitempty"`
	NextToken []byte   `protobuf:"bytes,4,opt,name=nextToken,proto3" json:"nextToken,omitempty"`
}

GetRowsRequest represents an request to get the rows for a split.

func (*GetRowsRequest) Descriptor

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

func (*GetRowsRequest) Equal

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

func (*GetRowsRequest) GetColumns

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

func (*GetRowsRequest) GetMaxBytes

func (m *GetRowsRequest) GetMaxBytes() int64

func (*GetRowsRequest) GetNextToken

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

func (*GetRowsRequest) GetSplitID

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

func (*GetRowsRequest) GoString

func (this *GetRowsRequest) GoString() string

func (*GetRowsRequest) Marshal

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

func (*GetRowsRequest) MarshalTo

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

func (*GetRowsRequest) MarshalToSizedBuffer added in v1.1.6

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

func (*GetRowsRequest) ProtoMessage

func (*GetRowsRequest) ProtoMessage()

func (*GetRowsRequest) Reset

func (m *GetRowsRequest) Reset()

func (*GetRowsRequest) Size

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

func (*GetRowsRequest) String

func (this *GetRowsRequest) String() string

func (*GetRowsRequest) Unmarshal

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

func (*GetRowsRequest) XXX_DiscardUnknown added in v1.1.6

func (m *GetRowsRequest) XXX_DiscardUnknown()

func (*GetRowsRequest) XXX_Marshal added in v1.1.6

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

func (*GetRowsRequest) XXX_Merge added in v1.1.6

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

func (*GetRowsRequest) XXX_Size added in v1.1.6

func (m *GetRowsRequest) XXX_Size() int

func (*GetRowsRequest) XXX_Unmarshal added in v1.1.6

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

type GetRowsResponse

type GetRowsResponse struct {
	Columns   []*Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	RowCount  int32     `protobuf:"varint,2,opt,name=rowCount,proto3" json:"rowCount,omitempty"`
	NextToken []byte    `protobuf:"bytes,3,opt,name=nextToken,proto3" json:"nextToken,omitempty"`
}

GetRowsResponse represents a response that returns the rows.

func (*GetRowsResponse) Descriptor

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

func (*GetRowsResponse) Equal

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

func (*GetRowsResponse) GetColumns

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

func (*GetRowsResponse) GetNextToken

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

func (*GetRowsResponse) GetRowCount

func (m *GetRowsResponse) GetRowCount() int32

func (*GetRowsResponse) GoString

func (this *GetRowsResponse) GoString() string

func (*GetRowsResponse) Marshal

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

func (*GetRowsResponse) MarshalTo

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

func (*GetRowsResponse) MarshalToSizedBuffer added in v1.1.6

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

func (*GetRowsResponse) ProtoMessage

func (*GetRowsResponse) ProtoMessage()

func (*GetRowsResponse) Reset

func (m *GetRowsResponse) Reset()

func (*GetRowsResponse) Size

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

func (*GetRowsResponse) String

func (this *GetRowsResponse) String() string

func (*GetRowsResponse) Unmarshal

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

func (*GetRowsResponse) XXX_DiscardUnknown added in v1.1.6

func (m *GetRowsResponse) XXX_DiscardUnknown()

func (*GetRowsResponse) XXX_Marshal added in v1.1.6

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

func (*GetRowsResponse) XXX_Merge added in v1.1.6

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

func (*GetRowsResponse) XXX_Size added in v1.1.6

func (m *GetRowsResponse) XXX_Size() int

func (*GetRowsResponse) XXX_Unmarshal added in v1.1.6

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

type GetSplitsRequest

type GetSplitsRequest struct {
	Schema    string   `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Table     string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Columns   []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	Filters   []string `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"`
	MaxSplits int32    `protobuf:"varint,5,opt,name=maxSplits,proto3" json:"maxSplits,omitempty"`
	NextToken []byte   `protobuf:"bytes,6,opt,name=nextToken,proto3" json:"nextToken,omitempty"`
}

GetSplitsRequest represents an request to get the splits for a table.

func (*GetSplitsRequest) Descriptor

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

func (*GetSplitsRequest) Equal

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

func (*GetSplitsRequest) GetColumns

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

func (*GetSplitsRequest) GetFilters

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

func (*GetSplitsRequest) GetMaxSplits

func (m *GetSplitsRequest) GetMaxSplits() int32

func (*GetSplitsRequest) GetNextToken

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

func (*GetSplitsRequest) GetSchema

func (m *GetSplitsRequest) GetSchema() string

func (*GetSplitsRequest) GetTable

func (m *GetSplitsRequest) GetTable() string

func (*GetSplitsRequest) GoString

func (this *GetSplitsRequest) GoString() string

func (*GetSplitsRequest) Marshal

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

func (*GetSplitsRequest) MarshalTo

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

func (*GetSplitsRequest) MarshalToSizedBuffer added in v1.1.6

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

func (*GetSplitsRequest) ProtoMessage

func (*GetSplitsRequest) ProtoMessage()

func (*GetSplitsRequest) Reset

func (m *GetSplitsRequest) Reset()

func (*GetSplitsRequest) Size

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

func (*GetSplitsRequest) String

func (this *GetSplitsRequest) String() string

func (*GetSplitsRequest) Unmarshal

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

func (*GetSplitsRequest) XXX_DiscardUnknown added in v1.1.6

func (m *GetSplitsRequest) XXX_DiscardUnknown()

func (*GetSplitsRequest) XXX_Marshal added in v1.1.6

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

func (*GetSplitsRequest) XXX_Merge added in v1.1.6

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

func (*GetSplitsRequest) XXX_Size added in v1.1.6

func (m *GetSplitsRequest) XXX_Size() int

func (*GetSplitsRequest) XXX_Unmarshal added in v1.1.6

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

type GetSplitsResponse

type GetSplitsResponse struct {
	Splits    []*Split `protobuf:"bytes,1,rep,name=splits,proto3" json:"splits,omitempty"`
	NextToken []byte   `protobuf:"bytes,2,opt,name=nextToken,proto3" json:"nextToken,omitempty"`
}

GetSplitsResponse represents an response containing the splits for a table.

func (*GetSplitsResponse) Descriptor

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

func (*GetSplitsResponse) Equal

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

func (*GetSplitsResponse) GetNextToken

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

func (*GetSplitsResponse) GetSplits

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

func (*GetSplitsResponse) GoString

func (this *GetSplitsResponse) GoString() string

func (*GetSplitsResponse) Marshal

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

func (*GetSplitsResponse) MarshalTo

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

func (*GetSplitsResponse) MarshalToSizedBuffer added in v1.1.6

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

func (*GetSplitsResponse) ProtoMessage

func (*GetSplitsResponse) ProtoMessage()

func (*GetSplitsResponse) Reset

func (m *GetSplitsResponse) Reset()

func (*GetSplitsResponse) Size

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

func (*GetSplitsResponse) String

func (this *GetSplitsResponse) String() string

func (*GetSplitsResponse) Unmarshal

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

func (*GetSplitsResponse) XXX_DiscardUnknown added in v1.1.6

func (m *GetSplitsResponse) XXX_DiscardUnknown()

func (*GetSplitsResponse) XXX_Marshal added in v1.1.6

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

func (*GetSplitsResponse) XXX_Merge added in v1.1.6

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

func (*GetSplitsResponse) XXX_Size added in v1.1.6

func (m *GetSplitsResponse) XXX_Size() int

func (*GetSplitsResponse) XXX_Unmarshal added in v1.1.6

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

type IngestRequest

type IngestRequest struct {
	// Types that are valid to be assigned to Data:
	//	*IngestRequest_Batch
	//	*IngestRequest_Orc
	//	*IngestRequest_Csv
	//	*IngestRequest_Url
	//	*IngestRequest_Parquet
	Data isIngestRequest_Data `protobuf_oneof:"data"`
}

IngestRequest represents an ingestion request.

func (*IngestRequest) Descriptor

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

func (*IngestRequest) Equal

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

func (*IngestRequest) GetBatch

func (m *IngestRequest) GetBatch() *Batch

func (*IngestRequest) GetCsv added in v1.1.6

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

func (*IngestRequest) GetData

func (m *IngestRequest) GetData() isIngestRequest_Data

func (*IngestRequest) GetOrc

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

func (*IngestRequest) GetParquet added in v1.2.6

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

func (*IngestRequest) GetUrl added in v1.1.6

func (m *IngestRequest) GetUrl() string

func (*IngestRequest) GoString

func (this *IngestRequest) GoString() string

func (*IngestRequest) Marshal

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

func (*IngestRequest) MarshalTo

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

func (*IngestRequest) MarshalToSizedBuffer added in v1.1.6

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

func (*IngestRequest) ProtoMessage

func (*IngestRequest) ProtoMessage()

func (*IngestRequest) Reset

func (m *IngestRequest) Reset()

func (*IngestRequest) Size

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

func (*IngestRequest) String

func (this *IngestRequest) String() string

func (*IngestRequest) Unmarshal

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

func (*IngestRequest) XXX_DiscardUnknown added in v1.1.6

func (m *IngestRequest) XXX_DiscardUnknown()

func (*IngestRequest) XXX_Marshal added in v1.1.6

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

func (*IngestRequest) XXX_Merge added in v1.1.6

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

func (*IngestRequest) XXX_OneofWrappers added in v1.1.6

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*IngestRequest) XXX_Size added in v1.1.6

func (m *IngestRequest) XXX_Size() int

func (*IngestRequest) XXX_Unmarshal added in v1.1.6

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

type IngestRequest_Batch

type IngestRequest_Batch struct {
	Batch *Batch `protobuf:"bytes,1,opt,name=batch,proto3,oneof" json:"batch,omitempty"`
}

func (*IngestRequest_Batch) Equal

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

func (*IngestRequest_Batch) GoString

func (this *IngestRequest_Batch) GoString() string

func (*IngestRequest_Batch) MarshalTo

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

func (*IngestRequest_Batch) MarshalToSizedBuffer added in v1.1.6

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

func (*IngestRequest_Batch) Size

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

func (*IngestRequest_Batch) String

func (this *IngestRequest_Batch) String() string

type IngestRequest_Csv added in v1.1.6

type IngestRequest_Csv struct {
	Csv []byte `protobuf:"bytes,3,opt,name=csv,proto3,oneof" json:"csv,omitempty"`
}

func (*IngestRequest_Csv) Equal added in v1.1.6

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

func (*IngestRequest_Csv) GoString added in v1.1.6

func (this *IngestRequest_Csv) GoString() string

func (*IngestRequest_Csv) MarshalTo added in v1.1.6

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

func (*IngestRequest_Csv) MarshalToSizedBuffer added in v1.1.6

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

func (*IngestRequest_Csv) Size added in v1.1.6

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

func (*IngestRequest_Csv) String added in v1.1.6

func (this *IngestRequest_Csv) String() string

type IngestRequest_Orc

type IngestRequest_Orc struct {
	Orc []byte `protobuf:"bytes,2,opt,name=orc,proto3,oneof" json:"orc,omitempty"`
}

func (*IngestRequest_Orc) Equal

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

func (*IngestRequest_Orc) GoString

func (this *IngestRequest_Orc) GoString() string

func (*IngestRequest_Orc) MarshalTo

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

func (*IngestRequest_Orc) MarshalToSizedBuffer added in v1.1.6

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

func (*IngestRequest_Orc) Size

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

func (*IngestRequest_Orc) String

func (this *IngestRequest_Orc) String() string

type IngestRequest_Parquet added in v1.2.6

type IngestRequest_Parquet struct {
	Parquet []byte `protobuf:"bytes,5,opt,name=parquet,proto3,oneof" json:"parquet,omitempty"`
}

func (*IngestRequest_Parquet) Equal added in v1.2.6

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

func (*IngestRequest_Parquet) GoString added in v1.2.6

func (this *IngestRequest_Parquet) GoString() string

func (*IngestRequest_Parquet) MarshalTo added in v1.2.6

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

func (*IngestRequest_Parquet) MarshalToSizedBuffer added in v1.2.6

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

func (*IngestRequest_Parquet) Size added in v1.2.6

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

func (*IngestRequest_Parquet) String added in v1.2.6

func (this *IngestRequest_Parquet) String() string

type IngestRequest_Url added in v1.1.6

type IngestRequest_Url struct {
	Url string `protobuf:"bytes,4,opt,name=url,proto3,oneof" json:"url,omitempty"`
}

func (*IngestRequest_Url) Equal added in v1.1.6

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

func (*IngestRequest_Url) GoString added in v1.1.6

func (this *IngestRequest_Url) GoString() string

func (*IngestRequest_Url) MarshalTo added in v1.1.6

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

func (*IngestRequest_Url) MarshalToSizedBuffer added in v1.1.6

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

func (*IngestRequest_Url) Size added in v1.1.6

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

func (*IngestRequest_Url) String added in v1.1.6

func (this *IngestRequest_Url) String() string

type IngestResponse

type IngestResponse struct {
}

IngestResponse represents an ingestion response.

func (*IngestResponse) Descriptor

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

func (*IngestResponse) Equal

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

func (*IngestResponse) GoString

func (this *IngestResponse) GoString() string

func (*IngestResponse) Marshal

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

func (*IngestResponse) MarshalTo

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

func (*IngestResponse) MarshalToSizedBuffer added in v1.1.6

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

func (*IngestResponse) ProtoMessage

func (*IngestResponse) ProtoMessage()

func (*IngestResponse) Reset

func (m *IngestResponse) Reset()

func (*IngestResponse) Size

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

func (*IngestResponse) String

func (this *IngestResponse) String() string

func (*IngestResponse) Unmarshal

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

func (*IngestResponse) XXX_DiscardUnknown added in v1.1.6

func (m *IngestResponse) XXX_DiscardUnknown()

func (*IngestResponse) XXX_Marshal added in v1.1.6

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

func (*IngestResponse) XXX_Merge added in v1.1.6

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

func (*IngestResponse) XXX_Size added in v1.1.6

func (m *IngestResponse) XXX_Size() int

func (*IngestResponse) XXX_Unmarshal added in v1.1.6

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

type IngressClient

type IngressClient interface {
	Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)
}

IngressClient is the client API for Ingress service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIngressClient

func NewIngressClient(cc *grpc.ClientConn) IngressClient

type IngressServer

type IngressServer interface {
	Ingest(context.Context, *IngestRequest) (*IngestResponse, error)
}

IngressServer is the server API for Ingress service.

type QueryClient

type QueryClient interface {
	// Describe returns the list of schema/table combinations and the metadata
	Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeResponse, error)
	// GetSplits returns the list of splits for a particular table/filter combination
	GetSplits(ctx context.Context, in *GetSplitsRequest, opts ...grpc.CallOption) (*GetSplitsResponse, error)
	// GetRows returns the rows for a particular split
	GetRows(ctx context.Context, in *GetRowsRequest, opts ...grpc.CallOption) (*GetRowsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient

func NewQueryClient(cc *grpc.ClientConn) QueryClient

type QueryServer

type QueryServer interface {
	// Describe returns the list of schema/table combinations and the metadata
	Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
	// GetSplits returns the list of splits for a particular table/filter combination
	GetSplits(context.Context, *GetSplitsRequest) (*GetSplitsResponse, error)
	// GetRows returns the rows for a particular split
	GetRows(context.Context, *GetRowsRequest) (*GetRowsResponse, error)
}

QueryServer is the server API for Query service.

type Split

type Split struct {
	SplitID []byte      `protobuf:"bytes,1,opt,name=splitID,proto3" json:"splitID,omitempty"`
	Hosts   []*Endpoint `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
}

Split represents the split information

func (*Split) Descriptor

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

func (*Split) Equal

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

func (*Split) GetHosts

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

func (*Split) GetSplitID

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

func (*Split) GoString

func (this *Split) GoString() string

func (*Split) Marshal

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

func (*Split) MarshalTo

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

func (*Split) MarshalToSizedBuffer added in v1.1.6

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

func (*Split) ProtoMessage

func (*Split) ProtoMessage()

func (*Split) Reset

func (m *Split) Reset()

func (*Split) Size

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

func (*Split) String

func (this *Split) String() string

func (*Split) Unmarshal

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

func (*Split) XXX_DiscardUnknown added in v1.1.6

func (m *Split) XXX_DiscardUnknown()

func (*Split) XXX_Marshal added in v1.1.6

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

func (*Split) XXX_Merge added in v1.1.6

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

func (*Split) XXX_Size added in v1.1.6

func (m *Split) XXX_Size() int

func (*Split) XXX_Unmarshal added in v1.1.6

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

type TableMeta

type TableMeta struct {
	Schema  string        `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Table   string        `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Columns []*ColumnMeta `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
}

TableMeta represents table metadata

func (*TableMeta) Descriptor

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

func (*TableMeta) Equal

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

func (*TableMeta) GetColumns

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

func (*TableMeta) GetSchema

func (m *TableMeta) GetSchema() string

func (*TableMeta) GetTable

func (m *TableMeta) GetTable() string

func (*TableMeta) GoString

func (this *TableMeta) GoString() string

func (*TableMeta) Marshal

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

func (*TableMeta) MarshalTo

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

func (*TableMeta) MarshalToSizedBuffer added in v1.1.6

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

func (*TableMeta) ProtoMessage

func (*TableMeta) ProtoMessage()

func (*TableMeta) Reset

func (m *TableMeta) Reset()

func (*TableMeta) Size

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

func (*TableMeta) String

func (this *TableMeta) String() string

func (*TableMeta) Unmarshal

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

func (*TableMeta) XXX_DiscardUnknown added in v1.1.6

func (m *TableMeta) XXX_DiscardUnknown()

func (*TableMeta) XXX_Marshal added in v1.1.6

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

func (*TableMeta) XXX_Merge added in v1.1.6

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

func (*TableMeta) XXX_Size added in v1.1.6

func (m *TableMeta) XXX_Size() int

func (*TableMeta) XXX_Unmarshal added in v1.1.6

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

type UnimplementedIngressServer added in v1.1.6

type UnimplementedIngressServer struct {
}

UnimplementedIngressServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngressServer) Ingest added in v1.1.6

type UnimplementedQueryServer added in v1.1.6

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Describe added in v1.1.6

func (*UnimplementedQueryServer) GetRows added in v1.1.6

func (*UnimplementedQueryServer) GetSplits added in v1.1.6

type Value

type Value struct {
	// Types that are valid to be assigned to Value:
	//	*Value_Int32
	//	*Value_Int64
	//	*Value_Float64
	//	*Value_String_
	//	*Value_Bool
	//	*Value_Time
	//	*Value_Json
	Value isValue_Value `protobuf_oneof:"value"`
}

Value represents a value

func (*Value) Descriptor

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

func (*Value) Equal

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

func (*Value) GetBool

func (m *Value) GetBool() bool

func (*Value) GetFloat64

func (m *Value) GetFloat64() float64

func (*Value) GetInt32

func (m *Value) GetInt32() int32

func (*Value) GetInt64

func (m *Value) GetInt64() int64

func (*Value) GetJson

func (m *Value) GetJson() uint32

func (*Value) GetString_

func (m *Value) GetString_() uint32

func (*Value) GetTime

func (m *Value) GetTime() int64

func (*Value) GetValue

func (m *Value) GetValue() isValue_Value

func (*Value) GoString

func (this *Value) GoString() string

func (*Value) Marshal

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

func (*Value) MarshalTo

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

func (*Value) MarshalToSizedBuffer added in v1.1.6

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

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) Size

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

func (*Value) String

func (this *Value) String() string

func (*Value) Unmarshal

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

func (*Value) XXX_DiscardUnknown added in v1.1.6

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal added in v1.1.6

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

func (*Value) XXX_Merge added in v1.1.6

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

func (*Value) XXX_OneofWrappers added in v1.1.6

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Value) XXX_Size added in v1.1.6

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal added in v1.1.6

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

type Value_Bool

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

func (*Value_Bool) Equal

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

func (*Value_Bool) GoString

func (this *Value_Bool) GoString() string

func (*Value_Bool) MarshalTo

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

func (*Value_Bool) MarshalToSizedBuffer added in v1.1.6

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

func (*Value_Bool) Size

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

func (*Value_Bool) String

func (this *Value_Bool) String() string

type Value_Float64

type Value_Float64 struct {
	Float64 float64 `protobuf:"fixed64,3,opt,name=float64,proto3,oneof" json:"float64,omitempty"`
}

func (*Value_Float64) Equal

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

func (*Value_Float64) GoString

func (this *Value_Float64) GoString() string

func (*Value_Float64) MarshalTo

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

func (*Value_Float64) MarshalToSizedBuffer added in v1.1.6

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

func (*Value_Float64) Size

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

func (*Value_Float64) String

func (this *Value_Float64) String() string

type Value_Int32

type Value_Int32 struct {
	Int32 int32 `protobuf:"varint,1,opt,name=int32,proto3,oneof" json:"int32,omitempty"`
}

func (*Value_Int32) Equal

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

func (*Value_Int32) GoString

func (this *Value_Int32) GoString() string

func (*Value_Int32) MarshalTo

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

func (*Value_Int32) MarshalToSizedBuffer added in v1.1.6

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

func (*Value_Int32) Size

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

func (*Value_Int32) String

func (this *Value_Int32) String() string

type Value_Int64

type Value_Int64 struct {
	Int64 int64 `protobuf:"varint,2,opt,name=int64,proto3,oneof" json:"int64,omitempty"`
}

func (*Value_Int64) Equal

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

func (*Value_Int64) GoString

func (this *Value_Int64) GoString() string

func (*Value_Int64) MarshalTo

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

func (*Value_Int64) MarshalToSizedBuffer added in v1.1.6

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

func (*Value_Int64) Size

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

func (*Value_Int64) String

func (this *Value_Int64) String() string

type Value_Json

type Value_Json struct {
	Json uint32 `protobuf:"varint,7,opt,name=json,proto3,oneof" json:"json,omitempty"`
}

func (*Value_Json) Equal

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

func (*Value_Json) GoString

func (this *Value_Json) GoString() string

func (*Value_Json) MarshalTo

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

func (*Value_Json) MarshalToSizedBuffer added in v1.1.6

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

func (*Value_Json) Size

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

func (*Value_Json) String

func (this *Value_Json) String() string

type Value_String_

type Value_String_ struct {
	String_ uint32 `protobuf:"varint,4,opt,name=string,proto3,oneof" json:"string,omitempty"`
}

func (*Value_String_) Equal

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

func (*Value_String_) GoString

func (this *Value_String_) GoString() string

func (*Value_String_) MarshalTo

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

func (*Value_String_) MarshalToSizedBuffer added in v1.1.6

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

func (*Value_String_) Size

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

func (*Value_String_) String

func (this *Value_String_) String() string

type Value_Time

type Value_Time struct {
	Time int64 `protobuf:"varint,6,opt,name=time,proto3,oneof" json:"time,omitempty"`
}

func (*Value_Time) Equal

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

func (*Value_Time) GoString

func (this *Value_Time) GoString() string

func (*Value_Time) MarshalTo

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

func (*Value_Time) MarshalToSizedBuffer added in v1.1.6

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

func (*Value_Time) Size

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

func (*Value_Time) String

func (this *Value_Time) String() string

Jump to

Keyboard shortcuts

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