pb

package
v0.5.0-v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2019 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Column_Kind_name = map[int32]string{
	0: "SLICE",
	1: "LABEL",
}
View Source 
var Column_Kind_value = map[string]int32{
	"SLICE": 0,
	"LABEL": 1,
}
View Source 
var DType_name = map[int32]string{
	0: "INTEGER",
	1: "FLOAT",
	2: "STRING",
	3: "TIME",
	4: "BOOLEAN",
}
View Source 
var DType_value = map[string]int32{
	"INTEGER": 0,
	"FLOAT":   1,
	"STRING":  2,
	"TIME":    3,
	"BOOLEAN": 4,
}
View Source 
var ErrorOptions_name = map[int32]string{
	0: "FAIL",
	1: "IGNORE",
}
View Source 
var ErrorOptions_value = map[string]int32{
	"FAIL":   0,
	"IGNORE": 1,
}

Functions

func AsGoMap 

func AsGoMap(mv map[string]*Value) map[string]interface{}

AsGoMap returns map with interface{} values

func AsInt64 

func AsInt64(val interface{}) (int64, bool)

AsInt64 convert val to int64, it'll return 0, false on failure

func FromGoMap 

func FromGoMap(m map[string]interface{}) (map[string]*Value, error)

FromGoMap return map[string]*Value

func NSToTime 

func NSToTime(ns int64) time.Time

NSToTime returns time from epoch nanoseconds

func RegisterFramesServer 

func RegisterFramesServer(s *grpc.Server, srv FramesServer)

Types

type Column 

type Column struct {
	Kind  Column_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=pb.Column_Kind" json:"kind,omitempty"`
	Name  string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Dtype DType       `protobuf:"varint,3,opt,name=dtype,proto3,enum=pb.DType" json:"dtype,omitempty"`
	Size  int64       `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	// In slice columns these arrays will be of length 1
	Ints                 []int64   `protobuf:"varint,5,rep,packed,name=ints,proto3" json:"ints,omitempty"`
	Floats               []float64 `protobuf:"fixed64,6,rep,packed,name=floats,proto3" json:"floats,omitempty"`
	Strings              []string  `protobuf:"bytes,7,rep,name=strings,proto3" json:"strings,omitempty"`
	Times                []int64   `protobuf:"varint,8,rep,packed,name=times,proto3" json:"times,omitempty"`
	Bools                []bool    `protobuf:"varint,9,rep,packed,name=bools,proto3" json:"bools,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Column) Descriptor 

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

func (*Column) GetBools 

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

func (*Column) GetDtype 

func (m *Column) GetDtype() DType

func (*Column) GetFloats 

func (m *Column) GetFloats() []float64

func (*Column) GetInts 

func (m *Column) GetInts() []int64

func (*Column) GetKind 

func (m *Column) GetKind() Column_Kind

func (*Column) GetName 

func (m *Column) GetName() string

func (*Column) GetSize 

func (m *Column) GetSize() int64

func (*Column) GetStrings 

func (m *Column) GetStrings() []string

func (*Column) GetTimes 

func (m *Column) GetTimes() []int64

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) Reset 

func (m *Column) Reset()

func (*Column) String 

func (m *Column) String() string

func (*Column) XXX_DiscardUnknown 

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal 

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

func (*Column) XXX_Merge 

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

func (*Column) XXX_Size 

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal 

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

type Column_Kind 

type Column_Kind int32
const (
	Column_SLICE Column_Kind = 0
	Column_LABEL Column_Kind = 1
)

func (Column_Kind) EnumDescriptor 

func (Column_Kind) EnumDescriptor() ([]byte, []int)

func (Column_Kind) String 

func (x Column_Kind) String() string

type CreateRequest 

type CreateRequest struct {
	Session              *Session          `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend              string            `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	Table                string            `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	AttributeMap         map[string]*Value `` /* 185-byte string literal not displayed */
	Schema               *TableSchema      `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	IfExists             ErrorOptions      `protobuf:"varint,6,opt,name=if_exists,json=ifExists,proto3,enum=pb.ErrorOptions" json:"if_exists,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

CreateRequest is a table creation request

func (*CreateRequest) Attributes added in v0.3.0 

func (r *CreateRequest) Attributes() map[string]interface{}

Attributes return the attibutes TODO: Calculate once (how to add field in generate protobuf code?)

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetAttributeMap added in v0.3.0 

func (m *CreateRequest) GetAttributeMap() map[string]*Value

func (*CreateRequest) GetBackend 

func (m *CreateRequest) GetBackend() string

func (*CreateRequest) GetIfExists 

func (m *CreateRequest) GetIfExists() ErrorOptions

func (*CreateRequest) GetSchema 

func (m *CreateRequest) GetSchema() *TableSchema

func (*CreateRequest) GetSession 

func (m *CreateRequest) GetSession() *Session

func (*CreateRequest) GetTable 

func (m *CreateRequest) GetTable() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) SetAttribute added in v0.3.0 

func (r *CreateRequest) SetAttribute(key string, value interface{}) error

SetAttribute sets an attribute

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

func (dst *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type CreateResponse 

type CreateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

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

func (*CreateResponse) XXX_Merge 

func (dst *CreateResponse) XXX_Merge(src proto.Message)

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

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

type DType 

type DType int32
const (
	DType_INTEGER DType = 0
	DType_FLOAT   DType = 1
	DType_STRING  DType = 2
	DType_TIME    DType = 3
	DType_BOOLEAN DType = 4
)

func (DType) EnumDescriptor 

func (DType) EnumDescriptor() ([]byte, []int)

func (DType) String 

func (x DType) String() string

type DeleteRequest 

type DeleteRequest struct {
	Session   *Session     `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend   string       `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	Table     string       `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	Filter    string       `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	IfMissing ErrorOptions `protobuf:"varint,5,opt,name=if_missing,json=ifMissing,proto3,enum=pb.ErrorOptions" json:"if_missing,omitempty"`
	// TSDB and Stream specific fields
	Start                string   `protobuf:"bytes,6,opt,name=start,proto3" json:"start,omitempty"`
	End                  string   `protobuf:"bytes,7,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeleteRequest is a deletion request

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetBackend 

func (m *DeleteRequest) GetBackend() string

func (*DeleteRequest) GetEnd 

func (m *DeleteRequest) GetEnd() string

func (*DeleteRequest) GetFilter 

func (m *DeleteRequest) GetFilter() string

func (*DeleteRequest) GetIfMissing 

func (m *DeleteRequest) GetIfMissing() ErrorOptions

func (*DeleteRequest) GetSession 

func (m *DeleteRequest) GetSession() *Session

func (*DeleteRequest) GetStart 

func (m *DeleteRequest) GetStart() string

func (*DeleteRequest) GetTable 

func (m *DeleteRequest) GetTable() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

func (dst *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

func (dst *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type ErrorOptions 

type ErrorOptions int32
const (
	ErrorOptions_FAIL   ErrorOptions = 0
	ErrorOptions_IGNORE ErrorOptions = 1
)

func (ErrorOptions) EnumDescriptor 

func (ErrorOptions) EnumDescriptor() ([]byte, []int)

func (ErrorOptions) String 

func (x ErrorOptions) String() string

type ExecRequest 

type ExecRequest struct {
	Session              *Session          `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend              string            `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	Table                string            `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	Command              string            `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"`
	Args                 map[string]*Value `` /* 149-byte string literal not displayed */
	Expression           string            `protobuf:"bytes,6,opt,name=expression,proto3" json:"expression,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ExecRequest) Arg 

func (r *ExecRequest) Arg(name string) (interface{}, error)

Arg returns the value of argument

func (*ExecRequest) Descriptor 

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

func (*ExecRequest) GetArgs 

func (m *ExecRequest) GetArgs() map[string]*Value

func (*ExecRequest) GetBackend 

func (m *ExecRequest) GetBackend() string

func (*ExecRequest) GetCommand 

func (m *ExecRequest) GetCommand() string

func (*ExecRequest) GetExpression 

func (m *ExecRequest) GetExpression() string

func (*ExecRequest) GetSession 

func (m *ExecRequest) GetSession() *Session

func (*ExecRequest) GetTable 

func (m *ExecRequest) GetTable() string

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) Reset 

func (m *ExecRequest) Reset()

func (*ExecRequest) String 

func (m *ExecRequest) String() string

func (*ExecRequest) XXX_DiscardUnknown 

func (m *ExecRequest) XXX_DiscardUnknown()

func (*ExecRequest) XXX_Marshal 

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

func (*ExecRequest) XXX_Merge 

func (dst *ExecRequest) XXX_Merge(src proto.Message)

func (*ExecRequest) XXX_Size 

func (m *ExecRequest) XXX_Size() int

func (*ExecRequest) XXX_Unmarshal 

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

type ExecResponse 

type ExecResponse struct {
	Frame                *Frame   `protobuf:"bytes,1,opt,name=frame,proto3" json:"frame,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecResponse) Descriptor 

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

func (*ExecResponse) GetFrame 

func (m *ExecResponse) GetFrame() *Frame

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) Reset 

func (m *ExecResponse) Reset()

func (*ExecResponse) String 

func (m *ExecResponse) String() string

func (*ExecResponse) XXX_DiscardUnknown 

func (m *ExecResponse) XXX_DiscardUnknown()

func (*ExecResponse) XXX_Marshal 

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

func (*ExecResponse) XXX_Merge 

func (dst *ExecResponse) XXX_Merge(src proto.Message)

func (*ExecResponse) XXX_Size 

func (m *ExecResponse) XXX_Size() int

func (*ExecResponse) XXX_Unmarshal 

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

type Frame 

type Frame struct {
	Columns              []*Column         `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Indices              []*Column         `protobuf:"bytes,2,rep,name=indices,proto3" json:"indices,omitempty"`
	Labels               map[string]*Value `` /* 153-byte string literal not displayed */
	Error                string            `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Frame) Descriptor 

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

func (*Frame) GetColumns 

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

func (*Frame) GetError 

func (m *Frame) GetError() string

func (*Frame) GetIndices 

func (m *Frame) GetIndices() []*Column

func (*Frame) GetLabels 

func (m *Frame) GetLabels() map[string]*Value

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) Reset 

func (m *Frame) Reset()

func (*Frame) String 

func (m *Frame) String() string

func (*Frame) XXX_DiscardUnknown 

func (m *Frame) XXX_DiscardUnknown()

func (*Frame) XXX_Marshal 

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

func (*Frame) XXX_Merge 

func (dst *Frame) XXX_Merge(src proto.Message)

func (*Frame) XXX_Size 

func (m *Frame) XXX_Size() int

func (*Frame) XXX_Unmarshal 

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

type Framed 

type Framed interface {
	Proto() *Frame
}

Framed is a frame based on protobuf

type FramesClient 

type FramesClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (Frames_ReadClient, error)
	Write(ctx context.Context, opts ...grpc.CallOption) (Frames_WriteClient, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
}

FramesClient is the client API for Frames service.

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

func NewFramesClient 

func NewFramesClient(cc *grpc.ClientConn) FramesClient

type FramesServer 

type FramesServer interface {
	Read(*ReadRequest, Frames_ReadServer) error
	Write(Frames_WriteServer) error
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
}

FramesServer is the server API for Frames service.

type Frames_ReadClient 

type Frames_ReadClient interface {
	Recv() (*Frame, error)
	grpc.ClientStream
}

type Frames_ReadServer 

type Frames_ReadServer interface {
	Send(*Frame) error
	grpc.ServerStream
}

type Frames_WriteClient 

type Frames_WriteClient interface {
	Send(*WriteRequest) error
	CloseAndRecv() (*WriteRespose, error)
	grpc.ClientStream
}

type Frames_WriteServer 

type Frames_WriteServer interface {
	SendAndClose(*WriteRespose) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type InitialWriteRequest 

type InitialWriteRequest struct {
	Session              *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend              string   `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	Table                string   `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	InitialData          *Frame   `protobuf:"bytes,4,opt,name=initial_data,json=initialData,proto3" json:"initial_data,omitempty"`
	Expression           string   `protobuf:"bytes,5,opt,name=expression,proto3" json:"expression,omitempty"`
	More                 bool     `protobuf:"varint,6,opt,name=more,proto3" json:"more,omitempty"`
	PartitionKeys        []string `protobuf:"bytes,7,rep,name=partition_keys,json=partitionKeys,proto3" json:"partition_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InitialWriteRequest) Descriptor 

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

func (*InitialWriteRequest) GetBackend 

func (m *InitialWriteRequest) GetBackend() string

func (*InitialWriteRequest) GetExpression 

func (m *InitialWriteRequest) GetExpression() string

func (*InitialWriteRequest) GetInitialData 

func (m *InitialWriteRequest) GetInitialData() *Frame

func (*InitialWriteRequest) GetMore 

func (m *InitialWriteRequest) GetMore() bool

func (*InitialWriteRequest) GetPartitionKeys 

func (m *InitialWriteRequest) GetPartitionKeys() []string

func (*InitialWriteRequest) GetSession 

func (m *InitialWriteRequest) GetSession() *Session

func (*InitialWriteRequest) GetTable 

func (m *InitialWriteRequest) GetTable() string

func (*InitialWriteRequest) ProtoMessage 

func (*InitialWriteRequest) ProtoMessage()

func (*InitialWriteRequest) Reset 

func (m *InitialWriteRequest) Reset()

func (*InitialWriteRequest) String 

func (m *InitialWriteRequest) String() string

func (*InitialWriteRequest) XXX_DiscardUnknown 

func (m *InitialWriteRequest) XXX_DiscardUnknown()

func (*InitialWriteRequest) XXX_Marshal 

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

func (*InitialWriteRequest) XXX_Merge 

func (dst *InitialWriteRequest) XXX_Merge(src proto.Message)

func (*InitialWriteRequest) XXX_Size 

func (m *InitialWriteRequest) XXX_Size() int

func (*InitialWriteRequest) XXX_Unmarshal 

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

type JoinStruct 

type JoinStruct struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinStruct) Descriptor 

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

func (*JoinStruct) ProtoMessage 

func (*JoinStruct) ProtoMessage()

func (*JoinStruct) Reset 

func (m *JoinStruct) Reset()

func (*JoinStruct) String 

func (m *JoinStruct) String() string

func (*JoinStruct) XXX_DiscardUnknown 

func (m *JoinStruct) XXX_DiscardUnknown()

func (*JoinStruct) XXX_Marshal 

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

func (*JoinStruct) XXX_Merge 

func (dst *JoinStruct) XXX_Merge(src proto.Message)

func (*JoinStruct) XXX_Size 

func (m *JoinStruct) XXX_Size() int

func (*JoinStruct) XXX_Unmarshal 

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

type ReadRequest 

type ReadRequest struct {
	Session      *Session      `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend      string        `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	Schema       *TableSchema  `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	DataFormat   string        `protobuf:"bytes,4,opt,name=data_format,json=dataFormat,proto3" json:"data_format,omitempty"`
	RowLayout    bool          `protobuf:"varint,5,opt,name=row_layout,json=rowLayout,proto3" json:"row_layout,omitempty"`
	MultiIndex   bool          `protobuf:"varint,6,opt,name=multi_index,json=multiIndex,proto3" json:"multi_index,omitempty"`
	Query        string        `protobuf:"bytes,7,opt,name=query,proto3" json:"query,omitempty"`
	Table        string        `protobuf:"bytes,8,opt,name=table,proto3" json:"table,omitempty"`
	Columns      []string      `protobuf:"bytes,9,rep,name=columns,proto3" json:"columns,omitempty"`
	Filter       string        `protobuf:"bytes,10,opt,name=filter,proto3" json:"filter,omitempty"`
	GroupBy      string        `protobuf:"bytes,11,opt,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
	Join         []*JoinStruct `protobuf:"bytes,12,rep,name=join,proto3" json:"join,omitempty"`
	Limit        int64         `protobuf:"varint,13,opt,name=limit,proto3" json:"limit,omitempty"`
	MessageLimit int64         `protobuf:"varint,14,opt,name=message_limit,json=messageLimit,proto3" json:"message_limit,omitempty"`
	Marker       string        `protobuf:"bytes,15,opt,name=marker,proto3" json:"marker,omitempty"`
	// NoSQL
	Segments          []int64  `protobuf:"varint,16,rep,packed,name=segments,proto3" json:"segments,omitempty"`
	TotalSegments     int64    `protobuf:"varint,17,opt,name=total_segments,json=totalSegments,proto3" json:"total_segments,omitempty"`
	ShardingKeys      []string `protobuf:"bytes,18,rep,name=sharding_keys,json=shardingKeys,proto3" json:"sharding_keys,omitempty"`
	SortKeyRangeStart string   `protobuf:"bytes,19,opt,name=sort_key_range_start,json=sortKeyRangeStart,proto3" json:"sort_key_range_start,omitempty"`
	SortKeyRangeEnd   string   `protobuf:"bytes,20,opt,name=sort_key_range_end,json=sortKeyRangeEnd,proto3" json:"sort_key_range_end,omitempty"`
	// TSDB
	Start       string `protobuf:"bytes,21,opt,name=start,proto3" json:"start,omitempty"`
	End         string `protobuf:"bytes,22,opt,name=end,proto3" json:"end,omitempty"`
	Step        string `protobuf:"bytes,23,opt,name=step,proto3" json:"step,omitempty"`
	Aggragators string `protobuf:"bytes,24,opt,name=aggragators,proto3" json:"aggragators,omitempty"`
	// Stream
	Seek                 string   `protobuf:"bytes,25,opt,name=seek,proto3" json:"seek,omitempty"`
	ShardId              string   `protobuf:"bytes,26,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Sequence             int64    `protobuf:"varint,27,opt,name=sequence,proto3" json:"sequence,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetAggragators added in v0.3.0 

func (m *ReadRequest) GetAggragators() string

func (*ReadRequest) GetBackend 

func (m *ReadRequest) GetBackend() string

func (*ReadRequest) GetColumns 

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

func (*ReadRequest) GetDataFormat 

func (m *ReadRequest) GetDataFormat() string

func (*ReadRequest) GetEnd 

func (m *ReadRequest) GetEnd() string

func (*ReadRequest) GetFilter 

func (m *ReadRequest) GetFilter() string

func (*ReadRequest) GetGroupBy 

func (m *ReadRequest) GetGroupBy() string

func (*ReadRequest) GetJoin 

func (m *ReadRequest) GetJoin() []*JoinStruct

func (*ReadRequest) GetLimit 

func (m *ReadRequest) GetLimit() int64

func (*ReadRequest) GetMarker 

func (m *ReadRequest) GetMarker() string

func (*ReadRequest) GetMessageLimit 

func (m *ReadRequest) GetMessageLimit() int64

func (*ReadRequest) GetMultiIndex 

func (m *ReadRequest) GetMultiIndex() bool

func (*ReadRequest) GetQuery 

func (m *ReadRequest) GetQuery() string

func (*ReadRequest) GetRowLayout 

func (m *ReadRequest) GetRowLayout() bool

func (*ReadRequest) GetSchema 

func (m *ReadRequest) GetSchema() *TableSchema

func (*ReadRequest) GetSeek 

func (m *ReadRequest) GetSeek() string

func (*ReadRequest) GetSegments 

func (m *ReadRequest) GetSegments() []int64

func (*ReadRequest) GetSequence 

func (m *ReadRequest) GetSequence() int64

func (*ReadRequest) GetSession 

func (m *ReadRequest) GetSession() *Session

func (*ReadRequest) GetShardId 

func (m *ReadRequest) GetShardId() string

func (*ReadRequest) GetShardingKeys 

func (m *ReadRequest) GetShardingKeys() []string

func (*ReadRequest) GetSortKeyRangeEnd 

func (m *ReadRequest) GetSortKeyRangeEnd() string

func (*ReadRequest) GetSortKeyRangeStart 

func (m *ReadRequest) GetSortKeyRangeStart() string

func (*ReadRequest) GetStart 

func (m *ReadRequest) GetStart() string

func (*ReadRequest) GetStep 

func (m *ReadRequest) GetStep() string

func (*ReadRequest) GetTable 

func (m *ReadRequest) GetTable() string

func (*ReadRequest) GetTotalSegments 

func (m *ReadRequest) GetTotalSegments() int64

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

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

func (*ReadRequest) XXX_Merge 

func (dst *ReadRequest) XXX_Merge(src proto.Message)

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

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

type SchemaField 

type SchemaField struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Doc                  string            `protobuf:"bytes,2,opt,name=doc,proto3" json:"doc,omitempty"`
	Default              *Value            `protobuf:"bytes,3,opt,name=default,proto3" json:"default,omitempty"`
	Type                 string            `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Properties           map[string]*Value `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

TODO: Place these under TableSchema

func (*SchemaField) Descriptor 

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

func (*SchemaField) GetDefault 

func (m *SchemaField) GetDefault() *Value

func (*SchemaField) GetDoc 

func (m *SchemaField) GetDoc() string

func (*SchemaField) GetName 

func (m *SchemaField) GetName() string

func (*SchemaField) GetProperties 

func (m *SchemaField) GetProperties() map[string]*Value

func (*SchemaField) GetType 

func (m *SchemaField) GetType() string

func (*SchemaField) Property 

func (s *SchemaField) Property(key string) (interface{}, bool)

Property return a schema property

func (*SchemaField) ProtoMessage 

func (*SchemaField) ProtoMessage()

func (*SchemaField) Reset 

func (m *SchemaField) Reset()

func (*SchemaField) String 

func (m *SchemaField) String() string

func (*SchemaField) XXX_DiscardUnknown 

func (m *SchemaField) XXX_DiscardUnknown()

func (*SchemaField) XXX_Marshal 

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

func (*SchemaField) XXX_Merge 

func (dst *SchemaField) XXX_Merge(src proto.Message)

func (*SchemaField) XXX_Size 

func (m *SchemaField) XXX_Size() int

func (*SchemaField) XXX_Unmarshal 

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

type SchemaKey 

type SchemaKey struct {
	ShardingKey          []string `protobuf:"bytes,1,rep,name=sharding_key,json=shardingKey,proto3" json:"sharding_key,omitempty"`
	SortingKey           []string `protobuf:"bytes,2,rep,name=sorting_key,json=sortingKey,proto3" json:"sorting_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchemaKey) Descriptor 

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

func (*SchemaKey) GetShardingKey 

func (m *SchemaKey) GetShardingKey() []string

func (*SchemaKey) GetSortingKey 

func (m *SchemaKey) GetSortingKey() []string

func (*SchemaKey) ProtoMessage 

func (*SchemaKey) ProtoMessage()

func (*SchemaKey) Reset 

func (m *SchemaKey) Reset()

func (*SchemaKey) String 

func (m *SchemaKey) String() string

func (*SchemaKey) XXX_DiscardUnknown 

func (m *SchemaKey) XXX_DiscardUnknown()

func (*SchemaKey) XXX_Marshal 

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

func (*SchemaKey) XXX_Merge 

func (dst *SchemaKey) XXX_Merge(src proto.Message)

func (*SchemaKey) XXX_Size 

func (m *SchemaKey) XXX_Size() int

func (*SchemaKey) XXX_Unmarshal 

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

type Session 

type Session struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Container            string   `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	User                 string   `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Password             string   `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	Token                string   `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	Id                   string   `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Session) Descriptor 

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

func (*Session) Format 

func (s *Session) Format(state fmt.State, verb rune)

Format implements fmt.Formatter We're doing this to hide passwords from prints

func (*Session) GetContainer 

func (m *Session) GetContainer() string

func (*Session) GetId 

func (m *Session) GetId() string

func (*Session) GetPassword 

func (m *Session) GetPassword() string

func (*Session) GetPath 

func (m *Session) GetPath() string

func (*Session) GetToken 

func (m *Session) GetToken() string

func (*Session) GetUrl 

func (m *Session) GetUrl() string

func (*Session) GetUser 

func (m *Session) GetUser() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

func (dst *Session) XXX_Merge(src proto.Message)

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type TableSchema 

type TableSchema struct {
	Type                 string         `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 string         `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Doc                  string         `protobuf:"bytes,4,opt,name=doc,proto3" json:"doc,omitempty"`
	Aliases              []string       `protobuf:"bytes,5,rep,name=aliases,proto3" json:"aliases,omitempty"`
	Fields               []*SchemaField `protobuf:"bytes,6,rep,name=fields,proto3" json:"fields,omitempty"`
	Key                  *SchemaKey     `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

TODO: Rename to Schema?

func (*TableSchema) Descriptor 

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

func (*TableSchema) GetAliases 

func (m *TableSchema) GetAliases() []string

func (*TableSchema) GetDoc 

func (m *TableSchema) GetDoc() string

func (*TableSchema) GetFields 

func (m *TableSchema) GetFields() []*SchemaField

func (*TableSchema) GetKey 

func (m *TableSchema) GetKey() *SchemaKey

func (*TableSchema) GetName 

func (m *TableSchema) GetName() string

func (*TableSchema) GetNamespace 

func (m *TableSchema) GetNamespace() string

func (*TableSchema) GetType 

func (m *TableSchema) GetType() string

func (*TableSchema) ProtoMessage 

func (*TableSchema) ProtoMessage()

func (*TableSchema) Reset 

func (m *TableSchema) Reset()

func (*TableSchema) String 

func (m *TableSchema) String() string

func (*TableSchema) XXX_DiscardUnknown 

func (m *TableSchema) XXX_DiscardUnknown()

func (*TableSchema) XXX_Marshal 

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

func (*TableSchema) XXX_Merge 

func (dst *TableSchema) XXX_Merge(src proto.Message)

func (*TableSchema) XXX_Size 

func (m *TableSchema) XXX_Size() int

func (*TableSchema) XXX_Unmarshal 

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

type Value 

type Value struct {
	// Types that are valid to be assigned to Value:
	//	*Value_Ival
	//	*Value_Fval
	//	*Value_Sval
	//	*Value_Tval
	//	*Value_Bval
	Value                isValue_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Union of values

func (*Value) Descriptor 

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

func (*Value) GetBval 

func (m *Value) GetBval() bool

func (*Value) GetFval 

func (m *Value) GetFval() float64

func (*Value) GetIval 

func (m *Value) GetIval() int64

func (*Value) GetSval 

func (m *Value) GetSval() string

func (*Value) GetTval 

func (m *Value) GetTval() int64

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) GoValue 

func (v *Value) GoValue() (interface{}, error)

GoValue return value as interface{}

func (*Value) MarshalJSON 

func (v *Value) MarshalJSON() ([]byte, error)

MarshalJSON marshal Value as JSON object

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) SetValue 

func (v *Value) SetValue(i interface{}) error

SetValue sets the value from Go type

func (*Value) String 

func (m *Value) String() string

func (*Value) UnmarshalJSON 

func (v *Value) UnmarshalJSON(data []byte) error

UnmarshalJSON will unmarshal encoded native Go type to value (Implement json.Unmarshaler interface)

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

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

func (*Value) XXX_Merge 

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

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.

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

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

type Value_Bval 

type Value_Bval struct {
	Bval bool `protobuf:"varint,5,opt,name=bval,proto3,oneof"`
}

type Value_Fval 

type Value_Fval struct {
	Fval float64 `protobuf:"fixed64,2,opt,name=fval,proto3,oneof"`
}

type Value_Ival 

type Value_Ival struct {
	Ival int64 `protobuf:"varint,1,opt,name=ival,proto3,oneof"`
}

type Value_Sval 

type Value_Sval struct {
	Sval string `protobuf:"bytes,3,opt,name=sval,proto3,oneof"`
}

type Value_Tval 

type Value_Tval struct {
	Tval int64 `protobuf:"varint,4,opt,name=tval,proto3,oneof"`
}

type WriteRequest 

type WriteRequest struct {
	// Types that are valid to be assigned to Type:
	//	*WriteRequest_Request
	//	*WriteRequest_Frame
	Type                 isWriteRequest_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetFrame 

func (m *WriteRequest) GetFrame() *Frame

func (*WriteRequest) GetRequest 

func (m *WriteRequest) GetRequest() *InitialWriteRequest

func (*WriteRequest) GetType 

func (m *WriteRequest) GetType() isWriteRequest_Type

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

func (dst *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_OneofFuncs 

func (*WriteRequest) 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.

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteRequest_Frame 

type WriteRequest_Frame struct {
	Frame *Frame `protobuf:"bytes,2,opt,name=frame,proto3,oneof"`
}

type WriteRequest_Request 

type WriteRequest_Request struct {
	Request *InitialWriteRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type WriteRespose 

type WriteRespose struct {
	Frames               int64    `protobuf:"varint,1,opt,name=frames,proto3" json:"frames,omitempty"`
	Rows                 int64    `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteRespose) Descriptor 

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

func (*WriteRespose) GetFrames 

func (m *WriteRespose) GetFrames() int64

func (*WriteRespose) GetRows 

func (m *WriteRespose) GetRows() int64

func (*WriteRespose) ProtoMessage 

func (*WriteRespose) ProtoMessage()

func (*WriteRespose) Reset 

func (m *WriteRespose) Reset()

func (*WriteRespose) String 

func (m *WriteRespose) String() string

func (*WriteRespose) XXX_DiscardUnknown 

func (m *WriteRespose) XXX_DiscardUnknown()

func (*WriteRespose) XXX_Marshal 

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

func (*WriteRespose) XXX_Merge 

func (dst *WriteRespose) XXX_Merge(src proto.Message)

func (*WriteRespose) XXX_Size 

func (m *WriteRespose) XXX_Size() int

func (*WriteRespose) XXX_Unmarshal 

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

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.