talaria

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Package talaria is a generated protocol buffer package.

It is generated from these files: 

talaria.proto

It has these top-level messages: 

IngestRequest
IngestResponse
Batch
Event
Value
DescribeRequest
DescribeResponse
TableMeta
ColumnMeta
GetSplitsRequest
GetSplitsResponse
Endpoint
Split
GetRowsRequest
GetRowsResponse
Column
ColumnOfInt32
ColumnOfInt64
ColumnOfFloat64
ColumnOfBools
ColumnOfString

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")
)

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 `` /* 149-byte string literal not displayed */
	Events  []*Event          `protobuf:"bytes,2,rep,name=events" 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) 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

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) 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_OneofFuncs 

func (*Column) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

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) 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

type ColumnOfBools 

type ColumnOfBools struct {
	Nulls []bool `protobuf:"varint,1,rep,packed,name=nulls" json:"nulls,omitempty"`
	Bools []bool `protobuf:"varint,2,rep,packed,name=bools" 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) 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

type ColumnOfFloat64 

type ColumnOfFloat64 struct {
	Nulls   []bool    `protobuf:"varint,1,rep,packed,name=nulls" json:"nulls,omitempty"`
	Doubles []float64 `protobuf:"fixed64,2,rep,packed,name=doubles" 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) 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

type ColumnOfInt32 

type ColumnOfInt32 struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls" json:"nulls,omitempty"`
	Ints  []int32 `protobuf:"varint,2,rep,packed,name=ints" 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) 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

type ColumnOfInt64 

type ColumnOfInt64 struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls" json:"nulls,omitempty"`
	Longs []int64 `protobuf:"varint,2,rep,packed,name=longs" 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) 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

type ColumnOfString 

type ColumnOfString struct {
	Nulls []bool  `protobuf:"varint,1,rep,packed,name=nulls" json:"nulls,omitempty"`
	Sizes []int32 `protobuf:"varint,2,rep,packed,name=sizes" 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) 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

type Column_Bool 

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

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) 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,oneof"`
}

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) 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,oneof"`
}

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) 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,oneof"`
}

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) 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,oneof"`
}

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) 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,oneof"`
}

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_) 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,oneof"`
}

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) 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) 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

type DescribeResponse 

type DescribeResponse struct {
	Tables []*TableMeta `protobuf:"bytes,1,rep,name=tables" 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) 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

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) 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

type Event 

type Event struct {
	Value map[uint32]*Value `` /* 138-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) 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

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" 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) 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

type GetRowsResponse 

type GetRowsResponse struct {
	Columns   []*Column `protobuf:"bytes,1,rep,name=columns" 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) 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

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" json:"columns,omitempty"`
	Filters   []string `protobuf:"bytes,4,rep,name=filters" 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) 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

type GetSplitsResponse 

type GetSplitsResponse struct {
	Splits    []*Split `protobuf:"bytes,1,rep,name=splits" 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) 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

type IngestRequest 

type IngestRequest struct {
	// Types that are valid to be assigned to Data:
	//	*IngestRequest_Batch
	//	*IngestRequest_Orc
	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) GetData 

func (m *IngestRequest) GetData() isIngestRequest_Data

func (*IngestRequest) GetOrc 

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

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) 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_OneofFuncs 

func (*IngestRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type IngestRequest_Batch 

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

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) Size 

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

func (*IngestRequest_Batch) String 

func (this *IngestRequest_Batch) String() string

type IngestRequest_Orc 

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

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) Size 

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

func (*IngestRequest_Orc) String 

func (this *IngestRequest_Orc) 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) 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

type IngressClient 

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

func NewIngressClient 

func NewIngressClient(cc *grpc.ClientConn) IngressClient

type IngressServer 

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

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)
}

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)
}

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" 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) 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

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" 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) 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

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) 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_OneofFuncs 

func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Value_Bool 

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

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) 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"`
}

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) 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"`
}

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) 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"`
}

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) 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"`
}

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) 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"`
}

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_) 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"`
}

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) 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.