talaria

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2021 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_talaria_proto protoreflect.FileDescriptor
View Source 
var Ingress_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "talaria.Ingress",
	HandlerType: (*IngressServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ingest",
			Handler:    _Ingress_Ingest_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "talaria.proto",
}

Ingress_ServiceDesc is the grpc.ServiceDesc for Ingress service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Query_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "talaria.Query",
	HandlerType: (*QueryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Describe",
			Handler:    _Query_Describe_Handler,
		},
		{
			MethodName: "GetSplits",
			Handler:    _Query_GetSplits_Handler,
		},
		{
			MethodName: "GetRows",
			Handler:    _Query_GetRows_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "talaria.proto",
}

Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterIngressServer 

func RegisterIngressServer(s grpc.ServiceRegistrar, srv IngressServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc.ServiceRegistrar, 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"`
	// contains filtered or unexported fields
}

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

func (*Batch) Descriptor deprecated 

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

Deprecated: Use Batch.ProtoReflect.Descriptor instead.

func (*Batch) GetEvents 

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

func (*Batch) GetStrings 

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

func (*Batch) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Batch) MarshalToVT added in v1.3.1 

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

func (*Batch) MarshalVT added in v1.3.1 

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

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) ProtoReflect added in v1.3.1 

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

func (*Batch) Reset 

func (x *Batch) Reset()

func (*Batch) SizeVT added in v1.3.1 

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

func (*Batch) String 

func (x *Batch) String() string

func (*Batch) UnmarshalVT added in v1.3.1 

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

type Column 

type Column struct {

	// Types that are assignable to Value:
	//	*Column_Int32
	//	*Column_Int64
	//	*Column_Float64
	//	*Column_String_
	//	*Column_Bool
	//	*Column_Time
	//	*Column_Json
	Value isColumn_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Column represents a column.

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetBool 

func (x *Column) GetBool() *ColumnOfBools

func (*Column) GetFloat64 

func (x *Column) GetFloat64() *ColumnOfFloat64

func (*Column) GetInt32 

func (x *Column) GetInt32() *ColumnOfInt32

func (*Column) GetInt64 

func (x *Column) GetInt64() *ColumnOfInt64

func (*Column) GetJson 

func (x *Column) GetJson() *ColumnOfString

func (*Column) GetString_ 

func (x *Column) GetString_() *ColumnOfString

func (*Column) GetTime 

func (x *Column) GetTime() *ColumnOfInt64

func (*Column) GetValue 

func (m *Column) GetValue() isColumn_Value

func (*Column) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column) MarshalToVT added in v1.3.1 

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

func (*Column) MarshalVT added in v1.3.1 

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

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect added in v1.3.1 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) SizeVT added in v1.3.1 

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

func (*Column) String 

func (x *Column) String() string

func (*Column) UnmarshalVT added in v1.3.1 

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

type ColumnMeta 

type ColumnMeta struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`       // The name of the column (eg. tsi)
	Type    string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`       // The SQL type of the column (eg. varchar)
	Comment string `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"` // The optional comment for the column
	// contains filtered or unexported fields
}

ColumnMeta represents a column metadata

func (*ColumnMeta) Descriptor deprecated 

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

Deprecated: Use ColumnMeta.ProtoReflect.Descriptor instead.

func (*ColumnMeta) GetComment 

func (x *ColumnMeta) GetComment() string

func (*ColumnMeta) GetName 

func (x *ColumnMeta) GetName() string

func (*ColumnMeta) GetType 

func (x *ColumnMeta) GetType() string

func (*ColumnMeta) MarshalToSizedBufferVT added in v1.3.1 

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

func (*ColumnMeta) MarshalToVT added in v1.3.1 

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

func (*ColumnMeta) MarshalVT added in v1.3.1 

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

func (*ColumnMeta) ProtoMessage 

func (*ColumnMeta) ProtoMessage()

func (*ColumnMeta) ProtoReflect added in v1.3.1 

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

func (*ColumnMeta) Reset 

func (x *ColumnMeta) Reset()

func (*ColumnMeta) SizeVT added in v1.3.1 

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

func (*ColumnMeta) String 

func (x *ColumnMeta) String() string

func (*ColumnMeta) UnmarshalVT added in v1.3.1 

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

type ColumnOfBools 

type ColumnOfBools struct {
	Nulls []bool `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"` // Determines if a value for a corresponding row is null.
	Bools []bool `protobuf:"varint,2,rep,packed,name=bools,proto3" json:"bools,omitempty"` // Values for each row. If row is null then value is ignored.
	// contains filtered or unexported fields
}

Column containing Boolean values

func (*ColumnOfBools) Descriptor deprecated 

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

Deprecated: Use ColumnOfBools.ProtoReflect.Descriptor instead.

func (*ColumnOfBools) GetBools 

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

func (*ColumnOfBools) GetNulls 

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

func (*ColumnOfBools) MarshalToSizedBufferVT added in v1.3.1 

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

func (*ColumnOfBools) MarshalToVT added in v1.3.1 

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

func (*ColumnOfBools) MarshalVT added in v1.3.1 

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

func (*ColumnOfBools) ProtoMessage 

func (*ColumnOfBools) ProtoMessage()

func (*ColumnOfBools) ProtoReflect added in v1.3.1 

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

func (*ColumnOfBools) Reset 

func (x *ColumnOfBools) Reset()

func (*ColumnOfBools) SizeVT added in v1.3.1 

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

func (*ColumnOfBools) String 

func (x *ColumnOfBools) String() string

func (*ColumnOfBools) UnmarshalVT added in v1.3.1 

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

type ColumnOfFloat64 

type ColumnOfFloat64 struct {
	Nulls   []bool    `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"`      // Determines if a value for a corresponding row is null.
	Doubles []float64 `protobuf:"fixed64,2,rep,packed,name=doubles,proto3" json:"doubles,omitempty"` // Values for each row. If row is null then value is ignored.
	// contains filtered or unexported fields
}

Column containing Float64 values

func (*ColumnOfFloat64) Descriptor deprecated 

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

Deprecated: Use ColumnOfFloat64.ProtoReflect.Descriptor instead.

func (*ColumnOfFloat64) GetDoubles 

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

func (*ColumnOfFloat64) GetNulls 

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

func (*ColumnOfFloat64) MarshalToSizedBufferVT added in v1.3.1 

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

func (*ColumnOfFloat64) MarshalToVT added in v1.3.1 

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

func (*ColumnOfFloat64) MarshalVT added in v1.3.1 

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

func (*ColumnOfFloat64) ProtoMessage 

func (*ColumnOfFloat64) ProtoMessage()

func (*ColumnOfFloat64) ProtoReflect added in v1.3.1 

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

func (*ColumnOfFloat64) Reset 

func (x *ColumnOfFloat64) Reset()

func (*ColumnOfFloat64) SizeVT added in v1.3.1 

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

func (*ColumnOfFloat64) String 

func (x *ColumnOfFloat64) String() string

func (*ColumnOfFloat64) UnmarshalVT added in v1.3.1 

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

type ColumnOfInt32 

type ColumnOfInt32 struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"` // Determines if a value for a corresponding row is null.
	Ints  []int32 `protobuf:"varint,2,rep,packed,name=ints,proto3" json:"ints,omitempty"`   // Values for each row. If row is null then value is ignored.
	// contains filtered or unexported fields
}

Column containing Int32 values

func (*ColumnOfInt32) Descriptor deprecated 

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

Deprecated: Use ColumnOfInt32.ProtoReflect.Descriptor instead.

func (*ColumnOfInt32) GetInts 

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

func (*ColumnOfInt32) GetNulls 

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

func (*ColumnOfInt32) MarshalToSizedBufferVT added in v1.3.1 

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

func (*ColumnOfInt32) MarshalToVT added in v1.3.1 

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

func (*ColumnOfInt32) MarshalVT added in v1.3.1 

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

func (*ColumnOfInt32) ProtoMessage 

func (*ColumnOfInt32) ProtoMessage()

func (*ColumnOfInt32) ProtoReflect added in v1.3.1 

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

func (*ColumnOfInt32) Reset 

func (x *ColumnOfInt32) Reset()

func (*ColumnOfInt32) SizeVT added in v1.3.1 

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

func (*ColumnOfInt32) String 

func (x *ColumnOfInt32) String() string

func (*ColumnOfInt32) UnmarshalVT added in v1.3.1 

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

type ColumnOfInt64 

type ColumnOfInt64 struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"` // Determines if a value for a corresponding row is null.
	Longs []int64 `protobuf:"varint,2,rep,packed,name=longs,proto3" json:"longs,omitempty"` // Values for each row. If row is null then value is ignored.
	// contains filtered or unexported fields
}

Column containing Int64 values

func (*ColumnOfInt64) Descriptor deprecated 

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

Deprecated: Use ColumnOfInt64.ProtoReflect.Descriptor instead.

func (*ColumnOfInt64) GetLongs 

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

func (*ColumnOfInt64) GetNulls 

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

func (*ColumnOfInt64) MarshalToSizedBufferVT added in v1.3.1 

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

func (*ColumnOfInt64) MarshalToVT added in v1.3.1 

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

func (*ColumnOfInt64) MarshalVT added in v1.3.1 

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

func (*ColumnOfInt64) ProtoMessage 

func (*ColumnOfInt64) ProtoMessage()

func (*ColumnOfInt64) ProtoReflect added in v1.3.1 

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

func (*ColumnOfInt64) Reset 

func (x *ColumnOfInt64) Reset()

func (*ColumnOfInt64) SizeVT added in v1.3.1 

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

func (*ColumnOfInt64) String 

func (x *ColumnOfInt64) String() string

func (*ColumnOfInt64) UnmarshalVT added in v1.3.1 

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

type ColumnOfString 

type ColumnOfString struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls,proto3" json:"nulls,omitempty"` // Determines if a value for a corresponding row is null.
	Sizes []int32 `protobuf:"varint,2,rep,packed,name=sizes,proto3" json:"sizes,omitempty"` // Contains the length in bytes for the corresponding element.
	Bytes []byte  `protobuf:"bytes,3,opt,name=bytes,proto3" json:"bytes,omitempty"`         // The UTF-8 encoded byte values.
	// contains filtered or unexported fields
}

Column containing String values

func (*ColumnOfString) Descriptor deprecated 

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

Deprecated: Use ColumnOfString.ProtoReflect.Descriptor instead.

func (*ColumnOfString) GetBytes 

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

func (*ColumnOfString) GetNulls 

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

func (*ColumnOfString) GetSizes 

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

func (*ColumnOfString) MarshalToSizedBufferVT added in v1.3.1 

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

func (*ColumnOfString) MarshalToVT added in v1.3.1 

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

func (*ColumnOfString) MarshalVT added in v1.3.1 

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

func (*ColumnOfString) ProtoMessage 

func (*ColumnOfString) ProtoMessage()

func (*ColumnOfString) ProtoReflect added in v1.3.1 

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

func (*ColumnOfString) Reset 

func (x *ColumnOfString) Reset()

func (*ColumnOfString) SizeVT added in v1.3.1 

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

func (*ColumnOfString) String 

func (x *ColumnOfString) String() string

func (*ColumnOfString) UnmarshalVT added in v1.3.1 

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

type Column_Bool 

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

func (*Column_Bool) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column_Bool) MarshalToVT added in v1.3.1 

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

func (*Column_Bool) SizeVT added in v1.3.1 

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

type Column_Float64 

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

func (*Column_Float64) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column_Float64) MarshalToVT added in v1.3.1 

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

func (*Column_Float64) SizeVT added in v1.3.1 

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

type Column_Int32 

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

func (*Column_Int32) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column_Int32) MarshalToVT added in v1.3.1 

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

func (*Column_Int32) SizeVT added in v1.3.1 

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

type Column_Int64 

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

func (*Column_Int64) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column_Int64) MarshalToVT added in v1.3.1 

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

func (*Column_Int64) SizeVT added in v1.3.1 

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

type Column_Json 

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

func (*Column_Json) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column_Json) MarshalToVT added in v1.3.1 

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

func (*Column_Json) SizeVT added in v1.3.1 

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

type Column_String_ 

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

func (*Column_String_) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column_String_) MarshalToVT added in v1.3.1 

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

func (*Column_String_) SizeVT added in v1.3.1 

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

type Column_Time 

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

func (*Column_Time) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Column_Time) MarshalToVT added in v1.3.1 

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

func (*Column_Time) SizeVT added in v1.3.1 

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

type DescribeRequest 

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

DescribeRequest represents an request to list the tables and schemas.

func (*DescribeRequest) Descriptor deprecated 

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

Deprecated: Use DescribeRequest.ProtoReflect.Descriptor instead.

func (*DescribeRequest) MarshalToSizedBufferVT added in v1.3.1 

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

func (*DescribeRequest) MarshalToVT added in v1.3.1 

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

func (*DescribeRequest) MarshalVT added in v1.3.1 

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

func (*DescribeRequest) ProtoMessage 

func (*DescribeRequest) ProtoMessage()

func (*DescribeRequest) ProtoReflect added in v1.3.1 

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

func (*DescribeRequest) Reset 

func (x *DescribeRequest) Reset()

func (*DescribeRequest) SizeVT added in v1.3.1 

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

func (*DescribeRequest) String 

func (x *DescribeRequest) String() string

func (*DescribeRequest) UnmarshalVT added in v1.3.1 

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

type DescribeResponse 

type DescribeResponse struct {
	Tables []*TableMeta `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` // The set of table metadata
	// contains filtered or unexported fields
}

DescribeResponse represents an response that returns tables and their schemas.

func (*DescribeResponse) Descriptor deprecated 

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

Deprecated: Use DescribeResponse.ProtoReflect.Descriptor instead.

func (*DescribeResponse) GetTables 

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

func (*DescribeResponse) MarshalToSizedBufferVT added in v1.3.1 

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

func (*DescribeResponse) MarshalToVT added in v1.3.1 

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

func (*DescribeResponse) MarshalVT added in v1.3.1 

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

func (*DescribeResponse) ProtoMessage 

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) ProtoReflect added in v1.3.1 

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

func (*DescribeResponse) Reset 

func (x *DescribeResponse) Reset()

func (*DescribeResponse) SizeVT added in v1.3.1 

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

func (*DescribeResponse) String 

func (x *DescribeResponse) String() string

func (*DescribeResponse) UnmarshalVT added in v1.3.1 

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

type Endpoint 

type Endpoint struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`  // The hostname for the endpoint
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // The port for the endpoint
	// contains filtered or unexported fields
}

Endpoint represents a host/port combination

func (*Endpoint) Descriptor deprecated 

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetHost 

func (x *Endpoint) GetHost() string

func (*Endpoint) GetPort 

func (x *Endpoint) GetPort() int32

func (*Endpoint) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Endpoint) MarshalToVT added in v1.3.1 

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

func (*Endpoint) MarshalVT added in v1.3.1 

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

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect added in v1.3.1 

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

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) SizeVT added in v1.3.1 

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

func (*Endpoint) String 

func (x *Endpoint) String() string

func (*Endpoint) UnmarshalVT added in v1.3.1 

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

type Event 

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

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

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetValue 

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

func (*Event) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Event) MarshalToVT added in v1.3.1 

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

func (*Event) MarshalVT added in v1.3.1 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v1.3.1 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) SizeVT added in v1.3.1 

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

func (*Event) String 

func (x *Event) String() string

func (*Event) UnmarshalVT added in v1.3.1 

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

type GetRowsRequest 

type GetRowsRequest struct {
	SplitID   []byte   `protobuf:"bytes,1,opt,name=splitID,proto3" json:"splitID,omitempty"`     // The split identifier
	Columns   []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`     // The set of desired columns
	MaxBytes  int64    `protobuf:"varint,3,opt,name=maxBytes,proto3" json:"maxBytes,omitempty"`  // The maximum bytes that should be returned.
	NextToken []byte   `protobuf:"bytes,4,opt,name=nextToken,proto3" json:"nextToken,omitempty"` // The cursor representing the next token
	// contains filtered or unexported fields
}

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

func (*GetRowsRequest) Descriptor deprecated 

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

Deprecated: Use GetRowsRequest.ProtoReflect.Descriptor instead.

func (*GetRowsRequest) GetColumns 

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

func (*GetRowsRequest) GetMaxBytes 

func (x *GetRowsRequest) GetMaxBytes() int64

func (*GetRowsRequest) GetNextToken 

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

func (*GetRowsRequest) GetSplitID 

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

func (*GetRowsRequest) MarshalToSizedBufferVT added in v1.3.1 

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

func (*GetRowsRequest) MarshalToVT added in v1.3.1 

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

func (*GetRowsRequest) MarshalVT added in v1.3.1 

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

func (*GetRowsRequest) ProtoMessage 

func (*GetRowsRequest) ProtoMessage()

func (*GetRowsRequest) ProtoReflect added in v1.3.1 

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

func (*GetRowsRequest) Reset 

func (x *GetRowsRequest) Reset()

func (*GetRowsRequest) SizeVT added in v1.3.1 

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

func (*GetRowsRequest) String 

func (x *GetRowsRequest) String() string

func (*GetRowsRequest) UnmarshalVT added in v1.3.1 

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

type GetRowsResponse 

type GetRowsResponse struct {
	Columns   []*Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`     // The set of columnar data
	RowCount  int32     `protobuf:"varint,2,opt,name=rowCount,proto3" json:"rowCount,omitempty"`  // The number of rows returned
	NextToken []byte    `protobuf:"bytes,3,opt,name=nextToken,proto3" json:"nextToken,omitempty"` // The cursor representing the next token
	// contains filtered or unexported fields
}

GetRowsResponse represents a response that returns the rows.

func (*GetRowsResponse) Descriptor deprecated 

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

Deprecated: Use GetRowsResponse.ProtoReflect.Descriptor instead.

func (*GetRowsResponse) GetColumns 

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

func (*GetRowsResponse) GetNextToken 

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

func (*GetRowsResponse) GetRowCount 

func (x *GetRowsResponse) GetRowCount() int32

func (*GetRowsResponse) MarshalToSizedBufferVT added in v1.3.1 

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

func (*GetRowsResponse) MarshalToVT added in v1.3.1 

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

func (*GetRowsResponse) MarshalVT added in v1.3.1 

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

func (*GetRowsResponse) ProtoMessage 

func (*GetRowsResponse) ProtoMessage()

func (*GetRowsResponse) ProtoReflect added in v1.3.1 

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

func (*GetRowsResponse) Reset 

func (x *GetRowsResponse) Reset()

func (*GetRowsResponse) SizeVT added in v1.3.1 

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

func (*GetRowsResponse) String 

func (x *GetRowsResponse) String() string

func (*GetRowsResponse) UnmarshalVT added in v1.3.1 

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

type GetSplitsRequest 

type GetSplitsRequest struct {
	Schema    string   `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`        // The schema for the table
	Table     string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`          // The table name
	Columns   []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`      // The set of desired columns
	Filters   []string `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"`      // The set of filters
	MaxSplits int32    `protobuf:"varint,5,opt,name=maxSplits,proto3" json:"maxSplits,omitempty"` // The maximum splits that should be returned.
	NextToken []byte   `protobuf:"bytes,6,opt,name=nextToken,proto3" json:"nextToken,omitempty"`  // The cursor representing the next token
	// contains filtered or unexported fields
}

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

func (*GetSplitsRequest) Descriptor deprecated 

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

Deprecated: Use GetSplitsRequest.ProtoReflect.Descriptor instead.

func (*GetSplitsRequest) GetColumns 

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

func (*GetSplitsRequest) GetFilters 

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

func (*GetSplitsRequest) GetMaxSplits 

func (x *GetSplitsRequest) GetMaxSplits() int32

func (*GetSplitsRequest) GetNextToken 

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

func (*GetSplitsRequest) GetSchema 

func (x *GetSplitsRequest) GetSchema() string

func (*GetSplitsRequest) GetTable 

func (x *GetSplitsRequest) GetTable() string

func (*GetSplitsRequest) MarshalToSizedBufferVT added in v1.3.1 

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

func (*GetSplitsRequest) MarshalToVT added in v1.3.1 

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

func (*GetSplitsRequest) MarshalVT added in v1.3.1 

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

func (*GetSplitsRequest) ProtoMessage 

func (*GetSplitsRequest) ProtoMessage()

func (*GetSplitsRequest) ProtoReflect added in v1.3.1 

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

func (*GetSplitsRequest) Reset 

func (x *GetSplitsRequest) Reset()

func (*GetSplitsRequest) SizeVT added in v1.3.1 

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

func (*GetSplitsRequest) String 

func (x *GetSplitsRequest) String() string

func (*GetSplitsRequest) UnmarshalVT added in v1.3.1 

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

type GetSplitsResponse 

type GetSplitsResponse struct {
	Splits    []*Split `protobuf:"bytes,1,rep,name=splits,proto3" json:"splits,omitempty"`       // The list of splits that can be queried
	NextToken []byte   `protobuf:"bytes,2,opt,name=nextToken,proto3" json:"nextToken,omitempty"` // The cursor representing the next token
	// contains filtered or unexported fields
}

GetSplitsResponse represents an response containing the splits for a table.

func (*GetSplitsResponse) Descriptor deprecated 

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

Deprecated: Use GetSplitsResponse.ProtoReflect.Descriptor instead.

func (*GetSplitsResponse) GetNextToken 

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

func (*GetSplitsResponse) GetSplits 

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

func (*GetSplitsResponse) MarshalToSizedBufferVT added in v1.3.1 

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

func (*GetSplitsResponse) MarshalToVT added in v1.3.1 

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

func (*GetSplitsResponse) MarshalVT added in v1.3.1 

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

func (*GetSplitsResponse) ProtoMessage 

func (*GetSplitsResponse) ProtoMessage()

func (*GetSplitsResponse) ProtoReflect added in v1.3.1 

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

func (*GetSplitsResponse) Reset 

func (x *GetSplitsResponse) Reset()

func (*GetSplitsResponse) SizeVT added in v1.3.1 

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

func (*GetSplitsResponse) String 

func (x *GetSplitsResponse) String() string

func (*GetSplitsResponse) UnmarshalVT added in v1.3.1 

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

type IngestRequest 

type IngestRequest struct {

	// Types that are assignable to Data:
	//	*IngestRequest_Batch
	//	*IngestRequest_Orc
	//	*IngestRequest_Csv
	//	*IngestRequest_Url
	//	*IngestRequest_Parquet
	Data isIngestRequest_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

IngestRequest represents an ingestion request.

func (*IngestRequest) Descriptor deprecated 

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

Deprecated: Use IngestRequest.ProtoReflect.Descriptor instead.

func (*IngestRequest) GetBatch 

func (x *IngestRequest) GetBatch() *Batch

func (*IngestRequest) GetCsv added in v1.1.6 

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

func (*IngestRequest) GetData 

func (m *IngestRequest) GetData() isIngestRequest_Data

func (*IngestRequest) GetOrc 

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

func (*IngestRequest) GetParquet added in v1.2.6 

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

func (*IngestRequest) GetUrl added in v1.1.6 

func (x *IngestRequest) GetUrl() string

func (*IngestRequest) MarshalToSizedBufferVT added in v1.3.1 

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

func (*IngestRequest) MarshalToVT added in v1.3.1 

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

func (*IngestRequest) MarshalVT added in v1.3.1 

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

func (*IngestRequest) ProtoMessage 

func (*IngestRequest) ProtoMessage()

func (*IngestRequest) ProtoReflect added in v1.3.1 

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

func (*IngestRequest) Reset 

func (x *IngestRequest) Reset()

func (*IngestRequest) SizeVT added in v1.3.1 

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

func (*IngestRequest) String 

func (x *IngestRequest) String() string

func (*IngestRequest) UnmarshalVT added in v1.3.1 

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

type IngestRequest_Batch 

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

func (*IngestRequest_Batch) MarshalToSizedBufferVT added in v1.3.1 

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

func (*IngestRequest_Batch) MarshalToVT added in v1.3.1 

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

func (*IngestRequest_Batch) SizeVT added in v1.3.1 

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

type IngestRequest_Csv added in v1.1.6 

type IngestRequest_Csv struct {
	Csv []byte `protobuf:"bytes,3,opt,name=csv,proto3,oneof"` // CSV (comma-separated) file
}

func (*IngestRequest_Csv) MarshalToSizedBufferVT added in v1.3.1 

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

func (*IngestRequest_Csv) MarshalToVT added in v1.3.1 

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

func (*IngestRequest_Csv) SizeVT added in v1.3.1 

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

type IngestRequest_Orc 

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

func (*IngestRequest_Orc) MarshalToSizedBufferVT added in v1.3.1 

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

func (*IngestRequest_Orc) MarshalToVT added in v1.3.1 

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

func (*IngestRequest_Orc) SizeVT added in v1.3.1 

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

type IngestRequest_Parquet added in v1.2.6 

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

func (*IngestRequest_Parquet) MarshalToSizedBufferVT added in v1.3.1 

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

func (*IngestRequest_Parquet) MarshalToVT added in v1.3.1 

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

func (*IngestRequest_Parquet) SizeVT added in v1.3.1 

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

type IngestRequest_Url added in v1.1.6 

type IngestRequest_Url struct {
	Url string `protobuf:"bytes,4,opt,name=url,proto3,oneof"` // A url pointing to a file (.orc, .csv)
}

func (*IngestRequest_Url) MarshalToSizedBufferVT added in v1.3.1 

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

func (*IngestRequest_Url) MarshalToVT added in v1.3.1 

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

func (*IngestRequest_Url) SizeVT added in v1.3.1 

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

type IngestResponse 

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

IngestResponse represents an ingestion response.

func (*IngestResponse) Descriptor deprecated 

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

Deprecated: Use IngestResponse.ProtoReflect.Descriptor instead.

func (*IngestResponse) MarshalToSizedBufferVT added in v1.3.1 

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

func (*IngestResponse) MarshalToVT added in v1.3.1 

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

func (*IngestResponse) MarshalVT added in v1.3.1 

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

func (*IngestResponse) ProtoMessage 

func (*IngestResponse) ProtoMessage()

func (*IngestResponse) ProtoReflect added in v1.3.1 

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

func (*IngestResponse) Reset 

func (x *IngestResponse) Reset()

func (*IngestResponse) SizeVT added in v1.3.1 

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

func (*IngestResponse) String 

func (x *IngestResponse) String() string

func (*IngestResponse) UnmarshalVT added in v1.3.1 

func (m *IngestResponse) UnmarshalVT(dAtA []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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIngressClient 

func NewIngressClient(cc grpc.ClientConnInterface) IngressClient

type IngressServer 

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

IngressServer is the server API for Ingress service. All implementations should embed UnimplementedIngressServer for forward compatibility

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc.ClientConnInterface) 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. All implementations should embed UnimplementedQueryServer for forward compatibility

type Split 

type Split struct {
	SplitID []byte      `protobuf:"bytes,1,opt,name=splitID,proto3" json:"splitID,omitempty"` // The split identifier
	Hosts   []*Endpoint `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`     // The set of hosts
	// contains filtered or unexported fields
}

Split represents the split information

func (*Split) Descriptor deprecated 

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

Deprecated: Use Split.ProtoReflect.Descriptor instead.

func (*Split) GetHosts 

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

func (*Split) GetSplitID 

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

func (*Split) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Split) MarshalToVT added in v1.3.1 

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

func (*Split) MarshalVT added in v1.3.1 

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

func (*Split) ProtoMessage 

func (*Split) ProtoMessage()

func (*Split) ProtoReflect added in v1.3.1 

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

func (*Split) Reset 

func (x *Split) Reset()

func (*Split) SizeVT added in v1.3.1 

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

func (*Split) String 

func (x *Split) String() string

func (*Split) UnmarshalVT added in v1.3.1 

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

type TableMeta 

type TableMeta struct {
	Schema  string        `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`   // The schema for the table
	Table   string        `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`     // The table name
	Columns []*ColumnMeta `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"` // The list of columns of the table
	// contains filtered or unexported fields
}

TableMeta represents table metadata

func (*TableMeta) Descriptor deprecated 

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

Deprecated: Use TableMeta.ProtoReflect.Descriptor instead.

func (*TableMeta) GetColumns 

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

func (*TableMeta) GetSchema 

func (x *TableMeta) GetSchema() string

func (*TableMeta) GetTable 

func (x *TableMeta) GetTable() string

func (*TableMeta) MarshalToSizedBufferVT added in v1.3.1 

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

func (*TableMeta) MarshalToVT added in v1.3.1 

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

func (*TableMeta) MarshalVT added in v1.3.1 

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

func (*TableMeta) ProtoMessage 

func (*TableMeta) ProtoMessage()

func (*TableMeta) ProtoReflect added in v1.3.1 

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

func (*TableMeta) Reset 

func (x *TableMeta) Reset()

func (*TableMeta) SizeVT added in v1.3.1 

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

func (*TableMeta) String 

func (x *TableMeta) String() string

func (*TableMeta) UnmarshalVT added in v1.3.1 

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

type UnimplementedIngressServer added in v1.1.6 

type UnimplementedIngressServer struct {
}

UnimplementedIngressServer should be embedded to have forward compatible implementations.

func (UnimplementedIngressServer) Ingest added in v1.1.6 

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

type UnimplementedQueryServer added in v1.1.6 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer should be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) Describe added in v1.1.6 

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

func (UnimplementedQueryServer) GetRows added in v1.1.6 

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

func (UnimplementedQueryServer) GetSplits added in v1.1.6 

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

type UnsafeIngressServer added in v1.3.1 

type UnsafeIngressServer interface {
	// contains filtered or unexported methods
}

UnsafeIngressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngressServer will result in compilation errors.

type UnsafeQueryServer added in v1.3.1 

type UnsafeQueryServer interface {
	// contains filtered or unexported methods
}

UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.

type Value 

type Value struct {

	// Types that are assignable to Value:
	//	*Value_Int32
	//	*Value_Int64
	//	*Value_Float64
	//	*Value_String_
	//	*Value_Bool
	//	*Value_Time
	//	*Value_Json
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Value represents a value

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBool 

func (x *Value) GetBool() bool

func (*Value) GetFloat64 

func (x *Value) GetFloat64() float64

func (*Value) GetInt32 

func (x *Value) GetInt32() int32

func (*Value) GetInt64 

func (x *Value) GetInt64() int64

func (*Value) GetJson 

func (x *Value) GetJson() uint32

func (*Value) GetString_ 

func (x *Value) GetString_() uint32

func (*Value) GetTime 

func (x *Value) GetTime() int64

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value) MarshalToVT added in v1.3.1 

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

func (*Value) MarshalVT added in v1.3.1 

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

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect added in v1.3.1 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) SizeVT added in v1.3.1 

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

func (*Value) String 

func (x *Value) String() string

func (*Value) UnmarshalVT added in v1.3.1 

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

type Value_Bool 

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

func (*Value_Bool) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value_Bool) MarshalToVT added in v1.3.1 

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

func (*Value_Bool) SizeVT added in v1.3.1 

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

type Value_Float64 

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

func (*Value_Float64) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value_Float64) MarshalToVT added in v1.3.1 

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

func (*Value_Float64) SizeVT added in v1.3.1 

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

type Value_Int32 

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

func (*Value_Int32) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value_Int32) MarshalToVT added in v1.3.1 

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

func (*Value_Int32) SizeVT added in v1.3.1 

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

type Value_Int64 

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

func (*Value_Int64) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value_Int64) MarshalToVT added in v1.3.1 

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

func (*Value_Int64) SizeVT added in v1.3.1 

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

type Value_Json 

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

func (*Value_Json) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value_Json) MarshalToVT added in v1.3.1 

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

func (*Value_Json) SizeVT added in v1.3.1 

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

type Value_String_ 

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

func (*Value_String_) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value_String_) MarshalToVT added in v1.3.1 

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

func (*Value_String_) SizeVT added in v1.3.1 

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

type Value_Time 

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

func (*Value_Time) MarshalToSizedBufferVT added in v1.3.1 

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

func (*Value_Time) MarshalToVT added in v1.3.1 

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

func (*Value_Time) SizeVT added in v1.3.1 

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

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.