table

package
v0.0.0-...-6850833 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2024 License: LGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PartitioningInfo_PartitioningType_name = map[int32]string{
		1: "TIME",
		2: "VALUE",
		3: "TIME_AND_VALUE",
	}
	PartitioningInfo_PartitioningType_value = map[string]int32{
		"TIME":           1,
		"VALUE":          2,
		"TIME_AND_VALUE": 3,
	}
)

Enum value maps for PartitioningInfo_PartitioningType.

View Source 
var File_yamcs_protobuf_table_table_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ColumnData 

type ColumnData struct {
	Name  *string         `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Value *protobuf.Value `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnData) Descriptor deprecated 

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

Deprecated: Use ColumnData.ProtoReflect.Descriptor instead.

func (*ColumnData) GetName 

func (x *ColumnData) GetName() string

func (*ColumnData) GetValue 

func (x *ColumnData) GetValue() *protobuf.Value

func (*ColumnData) ProtoMessage 

func (*ColumnData) ProtoMessage()

func (*ColumnData) ProtoReflect 

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

func (*ColumnData) Reset 

func (x *ColumnData) Reset()

func (*ColumnData) String 

func (x *ColumnData) String() string

type ColumnInfo 

type ColumnInfo struct {

	// Colum name
	Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// Column type
	Type      *string      `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	EnumValue []*EnumValue `protobuf:"bytes,3,rep,name=enumValue" json:"enumValue,omitempty"`
	// Attribute indicating automatic auto increment upon
	// record insertion. Only set for table column info.
	AutoIncrement *bool `protobuf:"varint,4,opt,name=autoIncrement" json:"autoIncrement,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnInfo) Descriptor deprecated 

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

Deprecated: Use ColumnInfo.ProtoReflect.Descriptor instead.

func (*ColumnInfo) GetAutoIncrement 

func (x *ColumnInfo) GetAutoIncrement() bool

func (*ColumnInfo) GetEnumValue 

func (x *ColumnInfo) GetEnumValue() []*EnumValue

func (*ColumnInfo) GetName 

func (x *ColumnInfo) GetName() string

func (*ColumnInfo) GetType 

func (x *ColumnInfo) GetType() string

func (*ColumnInfo) ProtoMessage 

func (*ColumnInfo) ProtoMessage()

func (*ColumnInfo) ProtoReflect 

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

func (*ColumnInfo) Reset 

func (x *ColumnInfo) Reset()

func (*ColumnInfo) String 

func (x *ColumnInfo) String() string

type EnumValue 

type EnumValue struct {
	Value *int32  `protobuf:"varint,1,opt,name=value" json:"value,omitempty"`
	Label *string `protobuf:"bytes,2,opt,name=label" json:"label,omitempty"`
	// contains filtered or unexported fields
}

func (*EnumValue) Descriptor deprecated 

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

Deprecated: Use EnumValue.ProtoReflect.Descriptor instead.

func (*EnumValue) GetLabel 

func (x *EnumValue) GetLabel() string

func (*EnumValue) GetValue 

func (x *EnumValue) GetValue() int32

func (*EnumValue) ProtoMessage 

func (*EnumValue) ProtoMessage()

func (*EnumValue) ProtoReflect 

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

func (*EnumValue) Reset 

func (x *EnumValue) Reset()

func (*EnumValue) String 

func (x *EnumValue) String() string

type ExecuteSqlRequest 

type ExecuteSqlRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// StreamSQL statement
	Statement *string `protobuf:"bytes,2,opt,name=statement" json:"statement,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteSqlRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteSqlRequest.ProtoReflect.Descriptor instead.

func (*ExecuteSqlRequest) GetInstance 

func (x *ExecuteSqlRequest) GetInstance() string

func (*ExecuteSqlRequest) GetStatement 

func (x *ExecuteSqlRequest) GetStatement() string

func (*ExecuteSqlRequest) ProtoMessage 

func (*ExecuteSqlRequest) ProtoMessage()

func (*ExecuteSqlRequest) ProtoReflect 

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

func (*ExecuteSqlRequest) Reset 

func (x *ExecuteSqlRequest) Reset()

func (*ExecuteSqlRequest) String 

func (x *ExecuteSqlRequest) String() string

type GetStreamRequest 

type GetStreamRequest struct {

	// Yamcs instance name
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// Stream name
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.

func (*GetStreamRequest) GetInstance 

func (x *GetStreamRequest) GetInstance() string

func (*GetStreamRequest) GetName 

func (x *GetStreamRequest) GetName() string

func (*GetStreamRequest) ProtoMessage 

func (*GetStreamRequest) ProtoMessage()

func (*GetStreamRequest) ProtoReflect 

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

func (*GetStreamRequest) Reset 

func (x *GetStreamRequest) Reset()

func (*GetStreamRequest) String 

func (x *GetStreamRequest) String() string

type GetTableDataRequest 

type GetTableDataRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// Table name.
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// The columns to be included in the result. If unspecified, all table
	// and/or additional tuple columns will be included.
	Cols []string `protobuf:"bytes,3,rep,name=cols" json:"cols,omitempty"`
	// The zero-based row number at which to start outputting results. Default: “0“
	// Note that in the current rocksdb storage engine there is no way to jump to a row by its number.
	// This is why such a request will do a table scan and can be slow for large values of pos.
	Pos *int64 `protobuf:"varint,4,opt,name=pos" json:"pos,omitempty"`
	// The maximum number of returned records per page. Choose this value
	// too high and you risk hitting the maximum response size limit
	// enforced by the server. Default: “100“
	Limit *int32 `protobuf:"varint,5,opt,name=limit" json:"limit,omitempty"`
	// The direction of the sort. Sorting is always done on the key of the
	// table. Can be either “asc“ or “desc“. Default: “desc“
	Order *string `protobuf:"bytes,6,opt,name=order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableDataRequest) Descriptor deprecated 

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

Deprecated: Use GetTableDataRequest.ProtoReflect.Descriptor instead.

func (*GetTableDataRequest) GetCols 

func (x *GetTableDataRequest) GetCols() []string

func (*GetTableDataRequest) GetInstance 

func (x *GetTableDataRequest) GetInstance() string

func (*GetTableDataRequest) GetLimit 

func (x *GetTableDataRequest) GetLimit() int32

func (*GetTableDataRequest) GetName 

func (x *GetTableDataRequest) GetName() string

func (*GetTableDataRequest) GetOrder 

func (x *GetTableDataRequest) GetOrder() string

func (*GetTableDataRequest) GetPos 

func (x *GetTableDataRequest) GetPos() int64

func (*GetTableDataRequest) ProtoMessage 

func (*GetTableDataRequest) ProtoMessage()

func (*GetTableDataRequest) ProtoReflect 

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

func (*GetTableDataRequest) Reset 

func (x *GetTableDataRequest) Reset()

func (*GetTableDataRequest) String 

func (x *GetTableDataRequest) String() string

type GetTableRequest 

type GetTableRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// Table name.
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableRequest) Descriptor deprecated 

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

Deprecated: Use GetTableRequest.ProtoReflect.Descriptor instead.

func (*GetTableRequest) GetInstance 

func (x *GetTableRequest) GetInstance() string

func (*GetTableRequest) GetName 

func (x *GetTableRequest) GetName() string

func (*GetTableRequest) ProtoMessage 

func (*GetTableRequest) ProtoMessage()

func (*GetTableRequest) ProtoReflect 

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

func (*GetTableRequest) Reset 

func (x *GetTableRequest) Reset()

func (*GetTableRequest) String 

func (x *GetTableRequest) String() string

type ListStreamsRequest 

type ListStreamsRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamsRequest) Descriptor deprecated 

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

Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamsRequest) GetInstance 

func (x *ListStreamsRequest) GetInstance() string

func (*ListStreamsRequest) ProtoMessage 

func (*ListStreamsRequest) ProtoMessage()

func (*ListStreamsRequest) ProtoReflect 

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

func (*ListStreamsRequest) Reset 

func (x *ListStreamsRequest) Reset()

func (*ListStreamsRequest) String 

func (x *ListStreamsRequest) String() string

type ListStreamsResponse 

type ListStreamsResponse struct {
	Streams []*StreamInfo `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamsResponse) Descriptor deprecated 

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

Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamsResponse) GetStreams 

func (x *ListStreamsResponse) GetStreams() []*StreamInfo

func (*ListStreamsResponse) ProtoMessage 

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) ProtoReflect 

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

func (*ListStreamsResponse) Reset 

func (x *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String 

func (x *ListStreamsResponse) String() string

type ListTablesRequest 

type ListTablesRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTablesRequest) Descriptor deprecated 

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

Deprecated: Use ListTablesRequest.ProtoReflect.Descriptor instead.

func (*ListTablesRequest) GetInstance 

func (x *ListTablesRequest) GetInstance() string

func (*ListTablesRequest) ProtoMessage 

func (*ListTablesRequest) ProtoMessage()

func (*ListTablesRequest) ProtoReflect 

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

func (*ListTablesRequest) Reset 

func (x *ListTablesRequest) Reset()

func (*ListTablesRequest) String 

func (x *ListTablesRequest) String() string

type ListTablesResponse 

type ListTablesResponse struct {
	Tables []*TableInfo `protobuf:"bytes,1,rep,name=tables" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTablesResponse) Descriptor deprecated 

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

Deprecated: Use ListTablesResponse.ProtoReflect.Descriptor instead.

func (*ListTablesResponse) GetTables 

func (x *ListTablesResponse) GetTables() []*TableInfo

func (*ListTablesResponse) ProtoMessage 

func (*ListTablesResponse) ProtoMessage()

func (*ListTablesResponse) ProtoReflect 

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

func (*ListTablesResponse) Reset 

func (x *ListTablesResponse) Reset()

func (*ListTablesResponse) String 

func (x *ListTablesResponse) String() string

type ListValue 

type ListValue struct {
	Values []*protobuf.Value `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ListValue) Descriptor deprecated 

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

Deprecated: Use ListValue.ProtoReflect.Descriptor instead.

func (*ListValue) GetValues 

func (x *ListValue) GetValues() []*protobuf.Value

func (*ListValue) ProtoMessage 

func (*ListValue) ProtoMessage()

func (*ListValue) ProtoReflect 

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

func (*ListValue) Reset 

func (x *ListValue) Reset()

func (*ListValue) String 

func (x *ListValue) String() string

type PartitioningInfo 

type PartitioningInfo struct {
	Type                *PartitioningInfo_PartitioningType `protobuf:"varint,1,opt,name=type,enum=yamcs.protobuf.table.PartitioningInfo_PartitioningType" json:"type,omitempty"`
	TimeColumn          *string                            `protobuf:"bytes,2,opt,name=timeColumn" json:"timeColumn,omitempty"`
	TimePartitionSchema *string                            `protobuf:"bytes,3,opt,name=timePartitionSchema" json:"timePartitionSchema,omitempty"`
	ValueColumn         *string                            `protobuf:"bytes,4,opt,name=valueColumn" json:"valueColumn,omitempty"`
	ValueColumnType     *string                            `protobuf:"bytes,5,opt,name=valueColumnType" json:"valueColumnType,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitioningInfo) Descriptor deprecated 

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

Deprecated: Use PartitioningInfo.ProtoReflect.Descriptor instead.

func (*PartitioningInfo) GetTimeColumn 

func (x *PartitioningInfo) GetTimeColumn() string

func (*PartitioningInfo) GetTimePartitionSchema 

func (x *PartitioningInfo) GetTimePartitionSchema() string

func (*PartitioningInfo) GetType 

func (x *PartitioningInfo) GetType() PartitioningInfo_PartitioningType

func (*PartitioningInfo) GetValueColumn 

func (x *PartitioningInfo) GetValueColumn() string

func (*PartitioningInfo) GetValueColumnType 

func (x *PartitioningInfo) GetValueColumnType() string

func (*PartitioningInfo) ProtoMessage 

func (*PartitioningInfo) ProtoMessage()

func (*PartitioningInfo) ProtoReflect 

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

func (*PartitioningInfo) Reset 

func (x *PartitioningInfo) Reset()

func (*PartitioningInfo) String 

func (x *PartitioningInfo) String() string

type PartitioningInfo_PartitioningType 

type PartitioningInfo_PartitioningType int32
const (
	PartitioningInfo_TIME           PartitioningInfo_PartitioningType = 1
	PartitioningInfo_VALUE          PartitioningInfo_PartitioningType = 2
	PartitioningInfo_TIME_AND_VALUE PartitioningInfo_PartitioningType = 3
)

func (PartitioningInfo_PartitioningType) Descriptor 

func (PartitioningInfo_PartitioningType) Descriptor() protoreflect.EnumDescriptor

func (PartitioningInfo_PartitioningType) Enum 

func (x PartitioningInfo_PartitioningType) Enum() *PartitioningInfo_PartitioningType

func (PartitioningInfo_PartitioningType) EnumDescriptor deprecated 

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

Deprecated: Use PartitioningInfo_PartitioningType.Descriptor instead.

func (PartitioningInfo_PartitioningType) Number 

func (x PartitioningInfo_PartitioningType) Number() protoreflect.EnumNumber

func (PartitioningInfo_PartitioningType) String 

func (x PartitioningInfo_PartitioningType) String() string

func (PartitioningInfo_PartitioningType) Type 

func (PartitioningInfo_PartitioningType) Type() protoreflect.EnumType

func (*PartitioningInfo_PartitioningType) UnmarshalJSON deprecated 

func (x *PartitioningInfo_PartitioningType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ReadRowsRequest 

type ReadRowsRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// Table name.
	Table *string `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
	// The columns to be included in the result. If unspecified, all
	// table and/or additional tuple columns will be included.
	Cols []string `protobuf:"bytes,3,rep,name=cols" json:"cols,omitempty"`
	// Limit the results by specifying a SQL WHERE clause.
	//
	// Examples:
	// - pname = '/YSS/SIMULATOR/FlightData'
	// - gentime > '2023-01-01T00:00:00.000Z'
	// - pname = '/YSS/SIMULATOR/FlightData' and gentime > '2023-01-01T00:00:00.000Z'
	Query *string `protobuf:"bytes,4,opt,name=query" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRowsRequest) Descriptor deprecated 

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

Deprecated: Use ReadRowsRequest.ProtoReflect.Descriptor instead.

func (*ReadRowsRequest) GetCols 

func (x *ReadRowsRequest) GetCols() []string

func (*ReadRowsRequest) GetInstance 

func (x *ReadRowsRequest) GetInstance() string

func (*ReadRowsRequest) GetQuery 

func (x *ReadRowsRequest) GetQuery() string

func (*ReadRowsRequest) GetTable 

func (x *ReadRowsRequest) GetTable() string

func (*ReadRowsRequest) ProtoMessage 

func (*ReadRowsRequest) ProtoMessage()

func (*ReadRowsRequest) ProtoReflect 

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

func (*ReadRowsRequest) Reset 

func (x *ReadRowsRequest) Reset()

func (*ReadRowsRequest) String 

func (x *ReadRowsRequest) String() string

type RebuildHistogramRequest 

type RebuildHistogramRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// Table name.
	Table *string `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
	// Specify a date string in ISO 8601 format. The histogram data for all
	// partitions overlapping with the [start, stop] interval will be
	// recreated.
	// If not specified, it is assumed as the start of the archive.
	Start *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start" json:"start,omitempty"`
	// Specify a date string in ISO 8601 format. The histogram data for all
	// partitions overlapping with the [start, stop] interval will be
	// recreated.
	// If not specified, it is assumed as the end of of the archive.
	Stop *timestamp.Timestamp `protobuf:"bytes,4,opt,name=stop" json:"stop,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildHistogramRequest) Descriptor deprecated 

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

Deprecated: Use RebuildHistogramRequest.ProtoReflect.Descriptor instead.

func (*RebuildHistogramRequest) GetInstance 

func (x *RebuildHistogramRequest) GetInstance() string

func (*RebuildHistogramRequest) GetStart 

func (x *RebuildHistogramRequest) GetStart() *timestamp.Timestamp

func (*RebuildHistogramRequest) GetStop 

func (x *RebuildHistogramRequest) GetStop() *timestamp.Timestamp

func (*RebuildHistogramRequest) GetTable 

func (x *RebuildHistogramRequest) GetTable() string

func (*RebuildHistogramRequest) ProtoMessage 

func (*RebuildHistogramRequest) ProtoMessage()

func (*RebuildHistogramRequest) ProtoReflect 

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

func (*RebuildHistogramRequest) Reset 

func (x *RebuildHistogramRequest) Reset()

func (*RebuildHistogramRequest) String 

func (x *RebuildHistogramRequest) String() string

type RebuildHistogramResponse 

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

func (*RebuildHistogramResponse) Descriptor deprecated 

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

Deprecated: Use RebuildHistogramResponse.ProtoReflect.Descriptor instead.

func (*RebuildHistogramResponse) ProtoMessage 

func (*RebuildHistogramResponse) ProtoMessage()

func (*RebuildHistogramResponse) ProtoReflect 

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

func (*RebuildHistogramResponse) Reset 

func (x *RebuildHistogramResponse) Reset()

func (*RebuildHistogramResponse) String 

func (x *RebuildHistogramResponse) String() string

type ResultSet 

type ResultSet struct {
	Columns []*ColumnInfo `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
	Rows    []*ListValue  `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultSet) Descriptor deprecated 

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

Deprecated: Use ResultSet.ProtoReflect.Descriptor instead.

func (*ResultSet) GetColumns 

func (x *ResultSet) GetColumns() []*ColumnInfo

func (*ResultSet) GetRows 

func (x *ResultSet) GetRows() []*ListValue

func (*ResultSet) ProtoMessage 

func (*ResultSet) ProtoMessage()

func (*ResultSet) ProtoReflect 

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

func (*ResultSet) Reset 

func (x *ResultSet) Reset()

func (*ResultSet) String 

func (x *ResultSet) String() string

type Row 

type Row struct {

	// the column info is only present for new columns in a stream of Row messages
	Columns []*Row_ColumnInfo `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
	Cells   []*Row_Cell       `protobuf:"bytes,2,rep,name=cells" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetCells 

func (x *Row) GetCells() []*Row_Cell

func (*Row) GetColumns 

func (x *Row) GetColumns() []*Row_ColumnInfo

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

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

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

type Row_Cell 

type Row_Cell struct {
	ColumnId *uint32 `protobuf:"varint,1,opt,name=columnId" json:"columnId,omitempty"`
	Data     []byte  `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Row_Cell) Descriptor deprecated 

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

Deprecated: Use Row_Cell.ProtoReflect.Descriptor instead.

func (*Row_Cell) GetColumnId 

func (x *Row_Cell) GetColumnId() uint32

func (*Row_Cell) GetData 

func (x *Row_Cell) GetData() []byte

func (*Row_Cell) ProtoMessage 

func (*Row_Cell) ProtoMessage()

func (*Row_Cell) ProtoReflect 

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

func (*Row_Cell) Reset 

func (x *Row_Cell) Reset()

func (*Row_Cell) String 

func (x *Row_Cell) String() string

type Row_ColumnInfo 

type Row_ColumnInfo struct {
	Id   *uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Name *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Type *string `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
	// The name of the class implementing the proto object if dataType is PROTOBUF
	ProtoClass *string `protobuf:"bytes,4,opt,name=protoClass" json:"protoClass,omitempty"`
	// contains filtered or unexported fields
}

func (*Row_ColumnInfo) Descriptor deprecated 

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

Deprecated: Use Row_ColumnInfo.ProtoReflect.Descriptor instead.

func (*Row_ColumnInfo) GetId 

func (x *Row_ColumnInfo) GetId() uint32

func (*Row_ColumnInfo) GetName 

func (x *Row_ColumnInfo) GetName() string

func (*Row_ColumnInfo) GetProtoClass 

func (x *Row_ColumnInfo) GetProtoClass() string

func (*Row_ColumnInfo) GetType 

func (x *Row_ColumnInfo) GetType() string

func (*Row_ColumnInfo) ProtoMessage 

func (*Row_ColumnInfo) ProtoMessage()

func (*Row_ColumnInfo) ProtoReflect 

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

func (*Row_ColumnInfo) Reset 

func (x *Row_ColumnInfo) Reset()

func (*Row_ColumnInfo) String 

func (x *Row_ColumnInfo) String() string

type StreamData 

type StreamData struct {
	Stream *string       `protobuf:"bytes,1,opt,name=stream" json:"stream,omitempty"`
	Column []*ColumnData `protobuf:"bytes,2,rep,name=column" json:"column,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamData) Descriptor deprecated 

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

Deprecated: Use StreamData.ProtoReflect.Descriptor instead.

func (*StreamData) GetColumn 

func (x *StreamData) GetColumn() []*ColumnData

func (*StreamData) GetStream 

func (x *StreamData) GetStream() string

func (*StreamData) ProtoMessage 

func (*StreamData) ProtoMessage()

func (*StreamData) ProtoReflect 

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

func (*StreamData) Reset 

func (x *StreamData) Reset()

func (*StreamData) String 

func (x *StreamData) String() string

type StreamInfo 

type StreamInfo struct {

	// Stream name
	Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// Deprecated: Do not use.
	Column    []*ColumnInfo `protobuf:"bytes,2,rep,name=column" json:"column,omitempty"`
	Columns   []*ColumnInfo `protobuf:"bytes,5,rep,name=columns" json:"columns,omitempty"`
	Script    *string       `protobuf:"bytes,3,opt,name=script" json:"script,omitempty"`
	DataCount *int64        `protobuf:"varint,4,opt,name=dataCount" json:"dataCount,omitempty"`
	// Subscribers represented in the format “className@hashCode“.
	Subscribers []string `protobuf:"bytes,6,rep,name=subscribers" json:"subscribers,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamInfo) Descriptor deprecated 

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

Deprecated: Use StreamInfo.ProtoReflect.Descriptor instead.

func (*StreamInfo) GetColumn deprecated 

func (x *StreamInfo) GetColumn() []*ColumnInfo

Deprecated: Do not use.

func (*StreamInfo) GetColumns 

func (x *StreamInfo) GetColumns() []*ColumnInfo

func (*StreamInfo) GetDataCount 

func (x *StreamInfo) GetDataCount() int64

func (*StreamInfo) GetName 

func (x *StreamInfo) GetName() string

func (*StreamInfo) GetScript 

func (x *StreamInfo) GetScript() string

func (*StreamInfo) GetSubscribers 

func (x *StreamInfo) GetSubscribers() []string

func (*StreamInfo) ProtoMessage 

func (*StreamInfo) ProtoMessage()

func (*StreamInfo) ProtoReflect 

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

func (*StreamInfo) Reset 

func (x *StreamInfo) Reset()

func (*StreamInfo) String 

func (x *StreamInfo) String() string

type SubscribeStreamRequest 

type SubscribeStreamRequest struct {

	// Yamcs instance name
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// Stream name
	Stream *string `protobuf:"bytes,2,opt,name=stream" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamRequest.ProtoReflect.Descriptor instead.

func (*SubscribeStreamRequest) GetInstance 

func (x *SubscribeStreamRequest) GetInstance() string

func (*SubscribeStreamRequest) GetStream 

func (x *SubscribeStreamRequest) GetStream() string

func (*SubscribeStreamRequest) ProtoMessage 

func (*SubscribeStreamRequest) ProtoMessage()

func (*SubscribeStreamRequest) ProtoReflect 

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

func (*SubscribeStreamRequest) Reset 

func (x *SubscribeStreamRequest) Reset()

func (*SubscribeStreamRequest) String 

func (x *SubscribeStreamRequest) String() string

type SubscribeStreamStatisticsRequest 

type SubscribeStreamStatisticsRequest struct {
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamStatisticsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeStreamStatisticsRequest) GetInstance 

func (x *SubscribeStreamStatisticsRequest) GetInstance() string

func (*SubscribeStreamStatisticsRequest) ProtoMessage 

func (*SubscribeStreamStatisticsRequest) ProtoMessage()

func (*SubscribeStreamStatisticsRequest) ProtoReflect 

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

func (*SubscribeStreamStatisticsRequest) Reset 

func (x *SubscribeStreamStatisticsRequest) Reset()

func (*SubscribeStreamStatisticsRequest) String 

func (x *SubscribeStreamStatisticsRequest) String() string

type TableData 

type TableData struct {
	Record []*TableData_TableRecord `protobuf:"bytes,1,rep,name=record" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*TableData) Descriptor deprecated 

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

Deprecated: Use TableData.ProtoReflect.Descriptor instead.

func (*TableData) GetRecord 

func (x *TableData) GetRecord() []*TableData_TableRecord

func (*TableData) ProtoMessage 

func (*TableData) ProtoMessage()

func (*TableData) ProtoReflect 

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

func (*TableData) Reset 

func (x *TableData) Reset()

func (*TableData) String 

func (x *TableData) String() string

type TableData_TableRecord 

type TableData_TableRecord struct {
	Column []*ColumnData `protobuf:"bytes,1,rep,name=column" json:"column,omitempty"`
	// contains filtered or unexported fields
}

func (*TableData_TableRecord) Descriptor deprecated 

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

Deprecated: Use TableData_TableRecord.ProtoReflect.Descriptor instead.

func (*TableData_TableRecord) GetColumn 

func (x *TableData_TableRecord) GetColumn() []*ColumnData

func (*TableData_TableRecord) ProtoMessage 

func (*TableData_TableRecord) ProtoMessage()

func (*TableData_TableRecord) ProtoReflect 

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

func (*TableData_TableRecord) Reset 

func (x *TableData_TableRecord) Reset()

func (*TableData_TableRecord) String 

func (x *TableData_TableRecord) String() string

type TableInfo 

type TableInfo struct {

	// Table name
	Name             *string           `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	KeyColumn        []*ColumnInfo     `protobuf:"bytes,2,rep,name=keyColumn" json:"keyColumn,omitempty"`
	ValueColumn      []*ColumnInfo     `protobuf:"bytes,3,rep,name=valueColumn" json:"valueColumn,omitempty"`
	Script           *string           `protobuf:"bytes,4,opt,name=script" json:"script,omitempty"`
	HistogramColumn  []string          `protobuf:"bytes,5,rep,name=histogramColumn" json:"histogramColumn,omitempty"`
	StorageEngine    *string           `protobuf:"bytes,6,opt,name=storageEngine" json:"storageEngine,omitempty"`
	FormatVersion    *int32            `protobuf:"varint,7,opt,name=formatVersion" json:"formatVersion,omitempty"`
	Tablespace       *string           `protobuf:"bytes,8,opt,name=tablespace" json:"tablespace,omitempty"`
	Compressed       *bool             `protobuf:"varint,9,opt,name=compressed" json:"compressed,omitempty"`
	PartitioningInfo *PartitioningInfo `protobuf:"bytes,10,opt,name=partitioningInfo" json:"partitioningInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*TableInfo) Descriptor deprecated 

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

Deprecated: Use TableInfo.ProtoReflect.Descriptor instead.

func (*TableInfo) GetCompressed 

func (x *TableInfo) GetCompressed() bool

func (*TableInfo) GetFormatVersion 

func (x *TableInfo) GetFormatVersion() int32

func (*TableInfo) GetHistogramColumn 

func (x *TableInfo) GetHistogramColumn() []string

func (*TableInfo) GetKeyColumn 

func (x *TableInfo) GetKeyColumn() []*ColumnInfo

func (*TableInfo) GetName 

func (x *TableInfo) GetName() string

func (*TableInfo) GetPartitioningInfo 

func (x *TableInfo) GetPartitioningInfo() *PartitioningInfo

func (*TableInfo) GetScript 

func (x *TableInfo) GetScript() string

func (*TableInfo) GetStorageEngine 

func (x *TableInfo) GetStorageEngine() string

func (*TableInfo) GetTablespace 

func (x *TableInfo) GetTablespace() string

func (*TableInfo) GetValueColumn 

func (x *TableInfo) GetValueColumn() []*ColumnInfo

func (*TableInfo) ProtoMessage 

func (*TableInfo) ProtoMessage()

func (*TableInfo) ProtoReflect 

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

func (*TableInfo) Reset 

func (x *TableInfo) Reset()

func (*TableInfo) String 

func (x *TableInfo) String() string

type WriteRowsExceptionDetail 

type WriteRowsExceptionDetail struct {
	Count *uint32 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRowsExceptionDetail) Descriptor deprecated 

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

Deprecated: Use WriteRowsExceptionDetail.ProtoReflect.Descriptor instead.

func (*WriteRowsExceptionDetail) GetCount 

func (x *WriteRowsExceptionDetail) GetCount() uint32

func (*WriteRowsExceptionDetail) ProtoMessage 

func (*WriteRowsExceptionDetail) ProtoMessage()

func (*WriteRowsExceptionDetail) ProtoReflect 

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

func (*WriteRowsExceptionDetail) Reset 

func (x *WriteRowsExceptionDetail) Reset()

func (*WriteRowsExceptionDetail) String 

func (x *WriteRowsExceptionDetail) String() string

type WriteRowsRequest 

type WriteRowsRequest struct {

	// Yamcs instance name.
	Instance *string `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
	// Table name.
	Table *string `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
	Row   *Row    `protobuf:"bytes,3,opt,name=row" json:"row,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRowsRequest) Descriptor deprecated 

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

Deprecated: Use WriteRowsRequest.ProtoReflect.Descriptor instead.

func (*WriteRowsRequest) GetInstance 

func (x *WriteRowsRequest) GetInstance() string

func (*WriteRowsRequest) GetRow 

func (x *WriteRowsRequest) GetRow() *Row

func (*WriteRowsRequest) GetTable 

func (x *WriteRowsRequest) GetTable() string

func (*WriteRowsRequest) ProtoMessage 

func (*WriteRowsRequest) ProtoMessage()

func (*WriteRowsRequest) ProtoReflect 

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

func (*WriteRowsRequest) Reset 

func (x *WriteRowsRequest) Reset()

func (*WriteRowsRequest) String 

func (x *WriteRowsRequest) String() string

type WriteRowsResponse 

type WriteRowsResponse struct {

	// The number of rows that were written
	Count *uint32 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRowsResponse) Descriptor deprecated 

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

Deprecated: Use WriteRowsResponse.ProtoReflect.Descriptor instead.

func (*WriteRowsResponse) GetCount 

func (x *WriteRowsResponse) GetCount() uint32

func (*WriteRowsResponse) ProtoMessage 

func (*WriteRowsResponse) ProtoMessage()

func (*WriteRowsResponse) ProtoReflect 

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

func (*WriteRowsResponse) Reset 

func (x *WriteRowsResponse) Reset()

func (*WriteRowsResponse) String 

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