talaria

package
v1.2.7 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 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 

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

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) Describe(ctx context.Context, req *DescribeRequest) (*DescribeResponse, error)

func (*UnimplementedQueryServer) GetRows added in v1.1.6 

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

func (*UnimplementedQueryServer) GetSplits added in v1.1.6 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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