Documentation ¶
Index ¶
- Variables
- func RegisterGreptimeDatabaseServer(s grpc.ServiceRegistrar, srv GreptimeDatabaseServer)
- func RegisterHealthCheckServer(s grpc.ServiceRegistrar, srv HealthCheckServer)
- func RegisterPrometheusGatewayServer(s grpc.ServiceRegistrar, srv PrometheusGatewayServer)
- type AddColumn
- func (*AddColumn) Descriptor() ([]byte, []int)deprecated
- func (x *AddColumn) GetColumnDef() *ColumnDef
- func (x *AddColumn) GetLocation() *AddColumnLocation
- func (*AddColumn) ProtoMessage()
- func (x *AddColumn) ProtoReflect() protoreflect.Message
- func (x *AddColumn) Reset()
- func (x *AddColumn) String() string
- type AddColumnLocation
- func (*AddColumnLocation) Descriptor() ([]byte, []int)deprecated
- func (x *AddColumnLocation) GetAfterColumnName() string
- func (x *AddColumnLocation) GetLocationType() AddColumnLocation_LocationType
- func (*AddColumnLocation) ProtoMessage()
- func (x *AddColumnLocation) ProtoReflect() protoreflect.Message
- func (x *AddColumnLocation) Reset()
- func (x *AddColumnLocation) String() string
- type AddColumnLocation_LocationType
- func (AddColumnLocation_LocationType) Descriptor() protoreflect.EnumDescriptor
- func (x AddColumnLocation_LocationType) Enum() *AddColumnLocation_LocationType
- func (AddColumnLocation_LocationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x AddColumnLocation_LocationType) Number() protoreflect.EnumNumber
- func (x AddColumnLocation_LocationType) String() string
- func (AddColumnLocation_LocationType) Type() protoreflect.EnumType
- type AddColumns
- type AffectedRows
- type AlterExpr
- func (*AlterExpr) Descriptor() ([]byte, []int)deprecated
- func (x *AlterExpr) GetAddColumns() *AddColumns
- func (x *AlterExpr) GetCatalogName() string
- func (x *AlterExpr) GetDropColumns() *DropColumns
- func (m *AlterExpr) GetKind() isAlterExpr_Kind
- func (x *AlterExpr) GetRenameTable() *RenameTable
- func (x *AlterExpr) GetSchemaName() string
- func (x *AlterExpr) GetTableName() string
- func (*AlterExpr) ProtoMessage()
- func (x *AlterExpr) ProtoReflect() protoreflect.Message
- func (x *AlterExpr) Reset()
- func (x *AlterExpr) String() string
- type AlterExpr_AddColumns
- type AlterExpr_DropColumns
- type AlterExpr_RenameTable
- type AuthHeader
- func (*AuthHeader) Descriptor() ([]byte, []int)deprecated
- func (m *AuthHeader) GetAuthScheme() isAuthHeader_AuthScheme
- func (x *AuthHeader) GetBasic() *Basic
- func (x *AuthHeader) GetToken() *Token
- func (*AuthHeader) ProtoMessage()
- func (x *AuthHeader) ProtoReflect() protoreflect.Message
- func (x *AuthHeader) Reset()
- func (x *AuthHeader) String() string
- type AuthHeader_Basic
- type AuthHeader_Token
- type Basic
- type Column
- func (*Column) Descriptor() ([]byte, []int)deprecated
- func (x *Column) GetColumnName() string
- func (x *Column) GetDatatype() ColumnDataType
- func (x *Column) GetNullMask() []byte
- func (x *Column) GetSemanticType() SemanticType
- func (x *Column) GetValues() *Column_Values
- func (*Column) ProtoMessage()
- func (x *Column) ProtoReflect() protoreflect.Message
- func (x *Column) Reset()
- func (x *Column) String() string
- type ColumnDataType
- func (ColumnDataType) Descriptor() protoreflect.EnumDescriptor
- func (x ColumnDataType) Enum() *ColumnDataType
- func (ColumnDataType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ColumnDataType) Number() protoreflect.EnumNumber
- func (x ColumnDataType) String() string
- func (ColumnDataType) Type() protoreflect.EnumType
- type ColumnDef
- func (*ColumnDef) Descriptor() ([]byte, []int)deprecated
- func (x *ColumnDef) GetDataType() ColumnDataType
- func (x *ColumnDef) GetDefaultConstraint() []byte
- func (x *ColumnDef) GetIsNullable() bool
- func (x *ColumnDef) GetName() string
- func (x *ColumnDef) GetSemanticType() SemanticType
- func (*ColumnDef) ProtoMessage()
- func (x *ColumnDef) ProtoReflect() protoreflect.Message
- func (x *ColumnDef) Reset()
- func (x *ColumnDef) String() string
- type ColumnSchema
- func (*ColumnSchema) Descriptor() ([]byte, []int)deprecated
- func (x *ColumnSchema) GetColumnName() string
- func (x *ColumnSchema) GetDatatype() ColumnDataType
- func (x *ColumnSchema) GetSemanticType() SemanticType
- func (*ColumnSchema) ProtoMessage()
- func (x *ColumnSchema) ProtoReflect() protoreflect.Message
- func (x *ColumnSchema) Reset()
- func (x *ColumnSchema) String() string
- type Column_Values
- func (*Column_Values) Descriptor() ([]byte, []int)deprecated
- func (x *Column_Values) GetBinaryValues() [][]byte
- func (x *Column_Values) GetBoolValues() []bool
- func (x *Column_Values) GetDateValues() []int32
- func (x *Column_Values) GetDatetimeValues() []int64
- func (x *Column_Values) GetF32Values() []float32
- func (x *Column_Values) GetF64Values() []float64
- func (x *Column_Values) GetI16Values() []int32
- func (x *Column_Values) GetI32Values() []int32
- func (x *Column_Values) GetI64Values() []int64
- func (x *Column_Values) GetI8Values() []int32
- func (x *Column_Values) GetIntervalDayTimeValues() []int64
- func (x *Column_Values) GetIntervalMonthDayNanoValues() []*IntervalMonthDayNano
- func (x *Column_Values) GetIntervalYearMonthValues() []int32
- func (x *Column_Values) GetStringValues() []string
- func (x *Column_Values) GetTimeMicrosecondValues() []int64
- func (x *Column_Values) GetTimeMillisecondValues() []int64
- func (x *Column_Values) GetTimeNanosecondValues() []int64
- func (x *Column_Values) GetTimeSecondValues() []int64
- func (x *Column_Values) GetTimestampMicrosecondValues() []int64
- func (x *Column_Values) GetTimestampMillisecondValues() []int64
- func (x *Column_Values) GetTimestampNanosecondValues() []int64
- func (x *Column_Values) GetTimestampSecondValues() []int64
- func (x *Column_Values) GetU16Values() []uint32
- func (x *Column_Values) GetU32Values() []uint32
- func (x *Column_Values) GetU64Values() []uint64
- func (x *Column_Values) GetU8Values() []uint32
- func (*Column_Values) ProtoMessage()
- func (x *Column_Values) ProtoReflect() protoreflect.Message
- func (x *Column_Values) Reset()
- func (x *Column_Values) String() string
- type CreateDatabaseExpr
- func (*CreateDatabaseExpr) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDatabaseExpr) GetCreateIfNotExists() bool
- func (x *CreateDatabaseExpr) GetDatabaseName() string
- func (x *CreateDatabaseExpr) GetOptions() map[string]string
- func (*CreateDatabaseExpr) ProtoMessage()
- func (x *CreateDatabaseExpr) ProtoReflect() protoreflect.Message
- func (x *CreateDatabaseExpr) Reset()
- func (x *CreateDatabaseExpr) String() string
- type CreateTableExpr
- func (*CreateTableExpr) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTableExpr) GetCatalogName() string
- func (x *CreateTableExpr) GetColumnDefs() []*ColumnDef
- func (x *CreateTableExpr) GetCreateIfNotExists() bool
- func (x *CreateTableExpr) GetDesc() string
- func (x *CreateTableExpr) GetEngine() string
- func (x *CreateTableExpr) GetPrimaryKeys() []string
- func (x *CreateTableExpr) GetSchemaName() string
- func (x *CreateTableExpr) GetTableId() *TableId
- func (x *CreateTableExpr) GetTableName() string
- func (x *CreateTableExpr) GetTableOptions() map[string]string
- func (x *CreateTableExpr) GetTimeIndex() string
- func (*CreateTableExpr) ProtoMessage()
- func (x *CreateTableExpr) ProtoReflect() protoreflect.Message
- func (x *CreateTableExpr) Reset()
- func (x *CreateTableExpr) String() string
- type DdlRequest
- func (*DdlRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DdlRequest) GetAlter() *AlterExpr
- func (x *DdlRequest) GetCreateDatabase() *CreateDatabaseExpr
- func (x *DdlRequest) GetCreateTable() *CreateTableExpr
- func (x *DdlRequest) GetDropTable() *DropTableExpr
- func (m *DdlRequest) GetExpr() isDdlRequest_Expr
- func (x *DdlRequest) GetTruncateTable() *TruncateTableExpr
- func (*DdlRequest) ProtoMessage()
- func (x *DdlRequest) ProtoReflect() protoreflect.Message
- func (x *DdlRequest) Reset()
- func (x *DdlRequest) String() string
- type DdlRequest_Alter
- type DdlRequest_CreateDatabase
- type DdlRequest_CreateTable
- type DdlRequest_DropTable
- type DdlRequest_TruncateTable
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetKeyColumns() []*Column
- func (x *DeleteRequest) GetRowCount() uint32
- func (x *DeleteRequest) GetTableName() string
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DeleteRequests
- type DropColumn
- type DropColumns
- type DropTableExpr
- func (*DropTableExpr) Descriptor() ([]byte, []int)deprecated
- func (x *DropTableExpr) GetCatalogName() string
- func (x *DropTableExpr) GetSchemaName() string
- func (x *DropTableExpr) GetTableId() *TableId
- func (x *DropTableExpr) GetTableName() string
- func (*DropTableExpr) ProtoMessage()
- func (x *DropTableExpr) ProtoReflect() protoreflect.Message
- func (x *DropTableExpr) Reset()
- func (x *DropTableExpr) String() string
- type FlightMetadata
- type GreptimeDatabaseClient
- type GreptimeDatabaseServer
- type GreptimeDatabase_HandleRequestsClient
- type GreptimeDatabase_HandleRequestsServer
- type GreptimeRequest
- func (*GreptimeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GreptimeRequest) GetDdl() *DdlRequest
- func (x *GreptimeRequest) GetDeletes() *DeleteRequests
- func (x *GreptimeRequest) GetHeader() *RequestHeader
- func (x *GreptimeRequest) GetInserts() *InsertRequests
- func (x *GreptimeRequest) GetQuery() *QueryRequest
- func (m *GreptimeRequest) GetRequest() isGreptimeRequest_Request
- func (x *GreptimeRequest) GetRowDeletes() *RowDeleteRequests
- func (x *GreptimeRequest) GetRowInserts() *RowInsertRequests
- func (*GreptimeRequest) ProtoMessage()
- func (x *GreptimeRequest) ProtoReflect() protoreflect.Message
- func (x *GreptimeRequest) Reset()
- func (x *GreptimeRequest) String() string
- type GreptimeRequest_Ddl
- type GreptimeRequest_Deletes
- type GreptimeRequest_Inserts
- type GreptimeRequest_Query
- type GreptimeRequest_RowDeletes
- type GreptimeRequest_RowInserts
- type GreptimeResponse
- func (*GreptimeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GreptimeResponse) GetAffectedRows() *AffectedRows
- func (x *GreptimeResponse) GetHeader() *ResponseHeader
- func (m *GreptimeResponse) GetResponse() isGreptimeResponse_Response
- func (*GreptimeResponse) ProtoMessage()
- func (x *GreptimeResponse) ProtoReflect() protoreflect.Message
- func (x *GreptimeResponse) Reset()
- func (x *GreptimeResponse) String() string
- type GreptimeResponse_AffectedRows
- type HealthCheckClient
- type HealthCheckRequest
- type HealthCheckResponse
- type HealthCheckServer
- type InsertRequest
- func (*InsertRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InsertRequest) GetColumns() []*Column
- func (x *InsertRequest) GetRowCount() uint32
- func (x *InsertRequest) GetTableName() string
- func (*InsertRequest) ProtoMessage()
- func (x *InsertRequest) ProtoReflect() protoreflect.Message
- func (x *InsertRequest) Reset()
- func (x *InsertRequest) String() string
- type InsertRequests
- type IntervalMonthDayNano
- func (*IntervalMonthDayNano) Descriptor() ([]byte, []int)deprecated
- func (x *IntervalMonthDayNano) GetDays() int32
- func (x *IntervalMonthDayNano) GetMonths() int32
- func (x *IntervalMonthDayNano) GetNanoseconds() int64
- func (*IntervalMonthDayNano) ProtoMessage()
- func (x *IntervalMonthDayNano) ProtoReflect() protoreflect.Message
- func (x *IntervalMonthDayNano) Reset()
- func (x *IntervalMonthDayNano) String() string
- type Mutation
- func (*Mutation) Descriptor() ([]byte, []int)deprecated
- func (x *Mutation) GetOpType() OpType
- func (x *Mutation) GetRows() *Rows
- func (x *Mutation) GetSequence() uint64
- func (*Mutation) ProtoMessage()
- func (x *Mutation) ProtoReflect() protoreflect.Message
- func (x *Mutation) Reset()
- func (x *Mutation) String() string
- type OpType
- type PromInstantQuery
- func (*PromInstantQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PromInstantQuery) GetQuery() string
- func (x *PromInstantQuery) GetTime() string
- func (*PromInstantQuery) ProtoMessage()
- func (x *PromInstantQuery) ProtoReflect() protoreflect.Message
- func (x *PromInstantQuery) Reset()
- func (x *PromInstantQuery) String() string
- type PromRangeQuery
- func (*PromRangeQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PromRangeQuery) GetEnd() string
- func (x *PromRangeQuery) GetQuery() string
- func (x *PromRangeQuery) GetStart() string
- func (x *PromRangeQuery) GetStep() string
- func (*PromRangeQuery) ProtoMessage()
- func (x *PromRangeQuery) ProtoReflect() protoreflect.Message
- func (x *PromRangeQuery) Reset()
- func (x *PromRangeQuery) String() string
- type PrometheusGatewayClient
- type PrometheusGatewayServer
- type PromqlRequest
- func (*PromqlRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PromqlRequest) GetHeader() *RequestHeader
- func (x *PromqlRequest) GetInstantQuery() *PromInstantQuery
- func (m *PromqlRequest) GetPromql() isPromqlRequest_Promql
- func (x *PromqlRequest) GetRangeQuery() *PromRangeQuery
- func (*PromqlRequest) ProtoMessage()
- func (x *PromqlRequest) ProtoReflect() protoreflect.Message
- func (x *PromqlRequest) Reset()
- func (x *PromqlRequest) String() string
- type PromqlRequest_InstantQuery
- type PromqlRequest_RangeQuery
- type PromqlResponse
- func (*PromqlResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PromqlResponse) GetBody() []byte
- func (x *PromqlResponse) GetHeader() *ResponseHeader
- func (*PromqlResponse) ProtoMessage()
- func (x *PromqlResponse) ProtoReflect() protoreflect.Message
- func (x *PromqlResponse) Reset()
- func (x *PromqlResponse) String() string
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRequest) GetLogicalPlan() []byte
- func (x *QueryRequest) GetPromRangeQuery() *PromRangeQuery
- func (m *QueryRequest) GetQuery() isQueryRequest_Query
- func (x *QueryRequest) GetSql() string
- func (*QueryRequest) ProtoMessage()
- func (x *QueryRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRequest) Reset()
- func (x *QueryRequest) String() string
- type QueryRequest_LogicalPlan
- type QueryRequest_PromRangeQuery
- type QueryRequest_Sql
- type RenameTable
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)deprecated
- func (x *RequestHeader) GetAuthorization() *AuthHeader
- func (x *RequestHeader) GetCatalog() string
- func (x *RequestHeader) GetDbname() string
- func (x *RequestHeader) GetSchema() string
- func (x *RequestHeader) GetSpanId() uint64
- func (x *RequestHeader) GetTraceId() uint64
- func (*RequestHeader) ProtoMessage()
- func (x *RequestHeader) ProtoReflect() protoreflect.Message
- func (x *RequestHeader) Reset()
- func (x *RequestHeader) String() string
- type ResponseHeader
- type Row
- type RowDeleteRequest
- func (*RowDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RowDeleteRequest) GetRows() *Rows
- func (x *RowDeleteRequest) GetTableName() string
- func (*RowDeleteRequest) ProtoMessage()
- func (x *RowDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *RowDeleteRequest) Reset()
- func (x *RowDeleteRequest) String() string
- type RowDeleteRequests
- func (*RowDeleteRequests) Descriptor() ([]byte, []int)deprecated
- func (x *RowDeleteRequests) GetDeletes() []*RowDeleteRequest
- func (*RowDeleteRequests) ProtoMessage()
- func (x *RowDeleteRequests) ProtoReflect() protoreflect.Message
- func (x *RowDeleteRequests) Reset()
- func (x *RowDeleteRequests) String() string
- type RowInsertRequest
- func (*RowInsertRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RowInsertRequest) GetRows() *Rows
- func (x *RowInsertRequest) GetTableName() string
- func (*RowInsertRequest) ProtoMessage()
- func (x *RowInsertRequest) ProtoReflect() protoreflect.Message
- func (x *RowInsertRequest) Reset()
- func (x *RowInsertRequest) String() string
- type RowInsertRequests
- func (*RowInsertRequests) Descriptor() ([]byte, []int)deprecated
- func (x *RowInsertRequests) GetInserts() []*RowInsertRequest
- func (*RowInsertRequests) ProtoMessage()
- func (x *RowInsertRequests) ProtoReflect() protoreflect.Message
- func (x *RowInsertRequests) Reset()
- func (x *RowInsertRequests) String() string
- type Rows
- type SemanticType
- func (SemanticType) Descriptor() protoreflect.EnumDescriptor
- func (x SemanticType) Enum() *SemanticType
- func (SemanticType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SemanticType) Number() protoreflect.EnumNumber
- func (x SemanticType) String() string
- func (SemanticType) Type() protoreflect.EnumType
- type Status
- type TableId
- type Token
- type TruncateTableExpr
- func (*TruncateTableExpr) Descriptor() ([]byte, []int)deprecated
- func (x *TruncateTableExpr) GetCatalogName() string
- func (x *TruncateTableExpr) GetSchemaName() string
- func (x *TruncateTableExpr) GetTableId() *TableId
- func (x *TruncateTableExpr) GetTableName() string
- func (*TruncateTableExpr) ProtoMessage()
- func (x *TruncateTableExpr) ProtoReflect() protoreflect.Message
- func (x *TruncateTableExpr) Reset()
- func (x *TruncateTableExpr) String() string
- type UnimplementedGreptimeDatabaseServer
- type UnimplementedHealthCheckServer
- type UnimplementedPrometheusGatewayServer
- type UnsafeGreptimeDatabaseServer
- type UnsafeHealthCheckServer
- type UnsafePrometheusGatewayServer
- type Value
- func (*Value) Descriptor() ([]byte, []int)deprecated
- func (x *Value) GetBinaryValue() []byte
- func (x *Value) GetBoolValue() bool
- func (x *Value) GetDateValue() int32
- func (x *Value) GetDatetimeValue() int64
- func (x *Value) GetF32Value() float32
- func (x *Value) GetF64Value() float64
- func (x *Value) GetI16Value() int32
- func (x *Value) GetI32Value() int32
- func (x *Value) GetI64Value() int64
- func (x *Value) GetI8Value() int32
- func (x *Value) GetIntervalDayTimeValues() int64
- func (x *Value) GetIntervalMonthDayNanoValues() *IntervalMonthDayNano
- func (x *Value) GetIntervalYearMonthValues() int32
- func (x *Value) GetStringValue() string
- func (x *Value) GetTimeMicrosecondValue() int64
- func (x *Value) GetTimeMillisecondValue() int64
- func (x *Value) GetTimeNanosecondValue() int64
- func (x *Value) GetTimeSecondValue() int64
- func (x *Value) GetTimestampMicrosecondValue() int64
- func (x *Value) GetTimestampMillisecondValue() int64
- func (x *Value) GetTimestampNanosecondValue() int64
- func (x *Value) GetTimestampSecondValue() int64
- func (x *Value) GetU16Value() uint32
- func (x *Value) GetU32Value() uint32
- func (x *Value) GetU64Value() uint64
- func (x *Value) GetU8Value() uint32
- func (m *Value) GetValueData() isValue_ValueData
- func (*Value) ProtoMessage()
- func (x *Value) ProtoReflect() protoreflect.Message
- func (x *Value) Reset()
- func (x *Value) String() string
- type Value_BinaryValue
- type Value_BoolValue
- type Value_DateValue
- type Value_DatetimeValue
- type Value_F32Value
- type Value_F64Value
- type Value_I16Value
- type Value_I32Value
- type Value_I64Value
- type Value_I8Value
- type Value_IntervalDayTimeValues
- type Value_IntervalMonthDayNanoValues
- type Value_IntervalYearMonthValues
- type Value_StringValue
- type Value_TimeMicrosecondValue
- type Value_TimeMillisecondValue
- type Value_TimeNanosecondValue
- type Value_TimeSecondValue
- type Value_TimestampMicrosecondValue
- type Value_TimestampMillisecondValue
- type Value_TimestampNanosecondValue
- type Value_TimestampSecondValue
- type Value_U16Value
- type Value_U32Value
- type Value_U64Value
- type Value_U8Value
- type WalEntry
Constants ¶
This section is empty.
Variables ¶
var ( SemanticType_name = map[int32]string{ 0: "TAG", 1: "FIELD", 2: "TIMESTAMP", } SemanticType_value = map[string]int32{ "TAG": 0, "FIELD": 1, "TIMESTAMP": 2, } )
Enum value maps for SemanticType.
var ( ColumnDataType_name = map[int32]string{ 0: "BOOLEAN", 1: "INT8", 2: "INT16", 3: "INT32", 4: "INT64", 5: "UINT8", 6: "UINT16", 7: "UINT32", 8: "UINT64", 9: "FLOAT32", 10: "FLOAT64", 11: "BINARY", 12: "STRING", 13: "DATE", 14: "DATETIME", 15: "TIMESTAMP_SECOND", 16: "TIMESTAMP_MILLISECOND", 17: "TIMESTAMP_MICROSECOND", 18: "TIMESTAMP_NANOSECOND", 19: "TIME_SECOND", 20: "TIME_MILLISECOND", 21: "TIME_MICROSECOND", 22: "TIME_NANOSECOND", 23: "INTERVAL_YEAR_MONTH", 24: "INTERVAL_DAY_TIME", 25: "INTERVAL_MONTH_DAY_NANO", } ColumnDataType_value = map[string]int32{ "BOOLEAN": 0, "INT8": 1, "INT16": 2, "INT32": 3, "INT64": 4, "UINT8": 5, "UINT16": 6, "UINT32": 7, "UINT64": 8, "FLOAT32": 9, "FLOAT64": 10, "BINARY": 11, "STRING": 12, "DATE": 13, "DATETIME": 14, "TIMESTAMP_SECOND": 15, "TIMESTAMP_MILLISECOND": 16, "TIMESTAMP_MICROSECOND": 17, "TIMESTAMP_NANOSECOND": 18, "TIME_SECOND": 19, "TIME_MILLISECOND": 20, "TIME_MICROSECOND": 21, "TIME_NANOSECOND": 22, "INTERVAL_YEAR_MONTH": 23, "INTERVAL_DAY_TIME": 24, "INTERVAL_MONTH_DAY_NANO": 25, } )
Enum value maps for ColumnDataType.
var ( AddColumnLocation_LocationType_name = map[int32]string{ 0: "FIRST", 1: "AFTER", } AddColumnLocation_LocationType_value = map[string]int32{ "FIRST": 0, "AFTER": 1, } )
Enum value maps for AddColumnLocation_LocationType.
var ( OpType_name = map[int32]string{ 0: "DELETE", 1: "PUT", } OpType_value = map[string]int32{ "DELETE": 0, "PUT": 1, } )
Enum value maps for OpType.
var File_greptime_v1_column_proto protoreflect.FileDescriptor
var File_greptime_v1_common_proto protoreflect.FileDescriptor
var File_greptime_v1_database_proto protoreflect.FileDescriptor
var File_greptime_v1_ddl_proto protoreflect.FileDescriptor
var File_greptime_v1_health_proto protoreflect.FileDescriptor
var File_greptime_v1_prom_proto protoreflect.FileDescriptor
var File_greptime_v1_row_proto protoreflect.FileDescriptor
var File_greptime_v1_wal_proto protoreflect.FileDescriptor
var GreptimeDatabase_ServiceDesc = grpc.ServiceDesc{ ServiceName: "greptime.v1.GreptimeDatabase", HandlerType: (*GreptimeDatabaseServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Handle", Handler: _GreptimeDatabase_Handle_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "HandleRequests", Handler: _GreptimeDatabase_HandleRequests_Handler, ClientStreams: true, }, }, Metadata: "greptime/v1/database.proto", }
GreptimeDatabase_ServiceDesc is the grpc.ServiceDesc for GreptimeDatabase service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var HealthCheck_ServiceDesc = grpc.ServiceDesc{ ServiceName: "greptime.v1.HealthCheck", HandlerType: (*HealthCheckServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "HealthCheck", Handler: _HealthCheck_HealthCheck_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "greptime/v1/health.proto", }
HealthCheck_ServiceDesc is the grpc.ServiceDesc for HealthCheck service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var PrometheusGateway_ServiceDesc = grpc.ServiceDesc{ ServiceName: "greptime.v1.PrometheusGateway", HandlerType: (*PrometheusGatewayServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Handle", Handler: _PrometheusGateway_Handle_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "greptime/v1/prom.proto", }
PrometheusGateway_ServiceDesc is the grpc.ServiceDesc for PrometheusGateway service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGreptimeDatabaseServer ¶
func RegisterGreptimeDatabaseServer(s grpc.ServiceRegistrar, srv GreptimeDatabaseServer)
func RegisterHealthCheckServer ¶
func RegisterHealthCheckServer(s grpc.ServiceRegistrar, srv HealthCheckServer)
func RegisterPrometheusGatewayServer ¶
func RegisterPrometheusGatewayServer(s grpc.ServiceRegistrar, srv PrometheusGatewayServer)
Types ¶
type AddColumn ¶
type AddColumn struct { ColumnDef *ColumnDef `protobuf:"bytes,1,opt,name=column_def,json=columnDef,proto3" json:"column_def,omitempty"` Location *AddColumnLocation `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"` // contains filtered or unexported fields }
func (*AddColumn) Descriptor
deprecated
func (*AddColumn) GetColumnDef ¶
func (*AddColumn) GetLocation ¶
func (x *AddColumn) GetLocation() *AddColumnLocation
func (*AddColumn) ProtoMessage ¶
func (*AddColumn) ProtoMessage()
func (*AddColumn) ProtoReflect ¶
func (x *AddColumn) ProtoReflect() protoreflect.Message
type AddColumnLocation ¶ added in v0.4.0
type AddColumnLocation struct { LocationType AddColumnLocation_LocationType `` /* 146-byte string literal not displayed */ AfterColumnName string `protobuf:"bytes,2,opt,name=after_column_name,json=afterColumnName,proto3" json:"after_column_name,omitempty"` // contains filtered or unexported fields }
func (*AddColumnLocation) Descriptor
deprecated
added in
v0.4.0
func (*AddColumnLocation) Descriptor() ([]byte, []int)
Deprecated: Use AddColumnLocation.ProtoReflect.Descriptor instead.
func (*AddColumnLocation) GetAfterColumnName ¶ added in v0.4.0
func (x *AddColumnLocation) GetAfterColumnName() string
func (*AddColumnLocation) GetLocationType ¶ added in v0.4.0
func (x *AddColumnLocation) GetLocationType() AddColumnLocation_LocationType
func (*AddColumnLocation) ProtoMessage ¶ added in v0.4.0
func (*AddColumnLocation) ProtoMessage()
func (*AddColumnLocation) ProtoReflect ¶ added in v0.4.0
func (x *AddColumnLocation) ProtoReflect() protoreflect.Message
func (*AddColumnLocation) Reset ¶ added in v0.4.0
func (x *AddColumnLocation) Reset()
func (*AddColumnLocation) String ¶ added in v0.4.0
func (x *AddColumnLocation) String() string
type AddColumnLocation_LocationType ¶ added in v0.4.0
type AddColumnLocation_LocationType int32
const ( AddColumnLocation_FIRST AddColumnLocation_LocationType = 0 AddColumnLocation_AFTER AddColumnLocation_LocationType = 1 )
func (AddColumnLocation_LocationType) Descriptor ¶ added in v0.4.0
func (AddColumnLocation_LocationType) Descriptor() protoreflect.EnumDescriptor
func (AddColumnLocation_LocationType) Enum ¶ added in v0.4.0
func (x AddColumnLocation_LocationType) Enum() *AddColumnLocation_LocationType
func (AddColumnLocation_LocationType) EnumDescriptor
deprecated
added in
v0.4.0
func (AddColumnLocation_LocationType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AddColumnLocation_LocationType.Descriptor instead.
func (AddColumnLocation_LocationType) Number ¶ added in v0.4.0
func (x AddColumnLocation_LocationType) Number() protoreflect.EnumNumber
func (AddColumnLocation_LocationType) String ¶ added in v0.4.0
func (x AddColumnLocation_LocationType) String() string
func (AddColumnLocation_LocationType) Type ¶ added in v0.4.0
func (AddColumnLocation_LocationType) Type() protoreflect.EnumType
type AddColumns ¶
type AddColumns struct { AddColumns []*AddColumn `protobuf:"bytes,1,rep,name=add_columns,json=addColumns,proto3" json:"add_columns,omitempty"` // contains filtered or unexported fields }
func (*AddColumns) Descriptor
deprecated
func (*AddColumns) Descriptor() ([]byte, []int)
Deprecated: Use AddColumns.ProtoReflect.Descriptor instead.
func (*AddColumns) GetAddColumns ¶
func (x *AddColumns) GetAddColumns() []*AddColumn
func (*AddColumns) ProtoMessage ¶
func (*AddColumns) ProtoMessage()
func (*AddColumns) ProtoReflect ¶
func (x *AddColumns) ProtoReflect() protoreflect.Message
func (*AddColumns) Reset ¶
func (x *AddColumns) Reset()
func (*AddColumns) String ¶
func (x *AddColumns) String() string
type AffectedRows ¶
type AffectedRows struct { Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*AffectedRows) Descriptor
deprecated
func (*AffectedRows) Descriptor() ([]byte, []int)
Deprecated: Use AffectedRows.ProtoReflect.Descriptor instead.
func (*AffectedRows) GetValue ¶
func (x *AffectedRows) GetValue() uint32
func (*AffectedRows) ProtoMessage ¶
func (*AffectedRows) ProtoMessage()
func (*AffectedRows) ProtoReflect ¶
func (x *AffectedRows) ProtoReflect() protoreflect.Message
func (*AffectedRows) Reset ¶
func (x *AffectedRows) Reset()
func (*AffectedRows) String ¶
func (x *AffectedRows) String() string
type AlterExpr ¶
type AlterExpr struct { CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Types that are assignable to Kind: // // *AlterExpr_AddColumns // *AlterExpr_DropColumns // *AlterExpr_RenameTable Kind isAlterExpr_Kind `protobuf_oneof:"kind"` // contains filtered or unexported fields }
func (*AlterExpr) Descriptor
deprecated
func (*AlterExpr) GetAddColumns ¶
func (x *AlterExpr) GetAddColumns() *AddColumns
func (*AlterExpr) GetCatalogName ¶
func (*AlterExpr) GetDropColumns ¶
func (x *AlterExpr) GetDropColumns() *DropColumns
func (*AlterExpr) GetRenameTable ¶
func (x *AlterExpr) GetRenameTable() *RenameTable
func (*AlterExpr) GetSchemaName ¶
func (*AlterExpr) GetTableName ¶
func (*AlterExpr) ProtoMessage ¶
func (*AlterExpr) ProtoMessage()
func (*AlterExpr) ProtoReflect ¶
func (x *AlterExpr) ProtoReflect() protoreflect.Message
type AlterExpr_AddColumns ¶
type AlterExpr_AddColumns struct {
AddColumns *AddColumns `protobuf:"bytes,4,opt,name=add_columns,json=addColumns,proto3,oneof"`
}
type AlterExpr_DropColumns ¶
type AlterExpr_DropColumns struct {
DropColumns *DropColumns `protobuf:"bytes,5,opt,name=drop_columns,json=dropColumns,proto3,oneof"`
}
type AlterExpr_RenameTable ¶
type AlterExpr_RenameTable struct {
RenameTable *RenameTable `protobuf:"bytes,6,opt,name=rename_table,json=renameTable,proto3,oneof"`
}
type AuthHeader ¶
type AuthHeader struct { // Types that are assignable to AuthScheme: // // *AuthHeader_Basic // *AuthHeader_Token AuthScheme isAuthHeader_AuthScheme `protobuf_oneof:"auth_scheme"` // contains filtered or unexported fields }
func (*AuthHeader) Descriptor
deprecated
func (*AuthHeader) Descriptor() ([]byte, []int)
Deprecated: Use AuthHeader.ProtoReflect.Descriptor instead.
func (*AuthHeader) GetAuthScheme ¶
func (m *AuthHeader) GetAuthScheme() isAuthHeader_AuthScheme
func (*AuthHeader) GetBasic ¶
func (x *AuthHeader) GetBasic() *Basic
func (*AuthHeader) GetToken ¶
func (x *AuthHeader) GetToken() *Token
func (*AuthHeader) ProtoMessage ¶
func (*AuthHeader) ProtoMessage()
func (*AuthHeader) ProtoReflect ¶
func (x *AuthHeader) ProtoReflect() protoreflect.Message
func (*AuthHeader) Reset ¶
func (x *AuthHeader) Reset()
func (*AuthHeader) String ¶
func (x *AuthHeader) String() string
type AuthHeader_Basic ¶
type AuthHeader_Basic struct {
Basic *Basic `protobuf:"bytes,1,opt,name=basic,proto3,oneof"`
}
type AuthHeader_Token ¶
type AuthHeader_Token struct {
Token *Token `protobuf:"bytes,2,opt,name=token,proto3,oneof"`
}
type Basic ¶
type Basic struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*Basic) Descriptor
deprecated
func (*Basic) GetPassword ¶
func (*Basic) GetUsername ¶
func (*Basic) ProtoMessage ¶
func (*Basic) ProtoMessage()
func (*Basic) ProtoReflect ¶
func (x *Basic) ProtoReflect() protoreflect.Message
type Column ¶
type Column struct { ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` SemanticType SemanticType `` /* 128-byte string literal not displayed */ // The array of non-null values in this column. // // For example: suppose there is a column "foo" that contains some int32 // values (1, 2, 3, 4, 5, null, 7, 8, 9, null); // // column: // column_name: foo // semantic_type: Tag // values: 1, 2, 3, 4, 5, 7, 8, 9 // null_masks: 00100000 00000010 Values *Column_Values `protobuf:"bytes,3,opt,name=values,proto3" json:"values,omitempty"` // Mask maps the positions of null values. // If a bit in null_mask is 1, it indicates that the column value at that // position is null. NullMask []byte `protobuf:"bytes,4,opt,name=null_mask,json=nullMask,proto3" json:"null_mask,omitempty"` // Helpful in creating vector from column. Datatype ColumnDataType `protobuf:"varint,5,opt,name=datatype,proto3,enum=greptime.v1.ColumnDataType" json:"datatype,omitempty"` // contains filtered or unexported fields }
func (*Column) Descriptor
deprecated
func (*Column) GetColumnName ¶
func (*Column) GetDatatype ¶
func (x *Column) GetDatatype() ColumnDataType
func (*Column) GetNullMask ¶
func (*Column) GetSemanticType ¶
func (x *Column) GetSemanticType() SemanticType
func (*Column) GetValues ¶
func (x *Column) GetValues() *Column_Values
func (*Column) ProtoMessage ¶
func (*Column) ProtoMessage()
func (*Column) ProtoReflect ¶
func (x *Column) ProtoReflect() protoreflect.Message
type ColumnDataType ¶
type ColumnDataType int32
const ( ColumnDataType_BOOLEAN ColumnDataType = 0 ColumnDataType_INT8 ColumnDataType = 1 ColumnDataType_INT16 ColumnDataType = 2 ColumnDataType_INT32 ColumnDataType = 3 ColumnDataType_INT64 ColumnDataType = 4 ColumnDataType_UINT8 ColumnDataType = 5 ColumnDataType_UINT16 ColumnDataType = 6 ColumnDataType_UINT32 ColumnDataType = 7 ColumnDataType_UINT64 ColumnDataType = 8 ColumnDataType_FLOAT32 ColumnDataType = 9 ColumnDataType_FLOAT64 ColumnDataType = 10 ColumnDataType_BINARY ColumnDataType = 11 ColumnDataType_STRING ColumnDataType = 12 ColumnDataType_DATE ColumnDataType = 13 ColumnDataType_DATETIME ColumnDataType = 14 ColumnDataType_TIMESTAMP_SECOND ColumnDataType = 15 ColumnDataType_TIMESTAMP_MILLISECOND ColumnDataType = 16 ColumnDataType_TIMESTAMP_MICROSECOND ColumnDataType = 17 ColumnDataType_TIMESTAMP_NANOSECOND ColumnDataType = 18 ColumnDataType_TIME_SECOND ColumnDataType = 19 ColumnDataType_TIME_MILLISECOND ColumnDataType = 20 ColumnDataType_TIME_MICROSECOND ColumnDataType = 21 ColumnDataType_TIME_NANOSECOND ColumnDataType = 22 ColumnDataType_INTERVAL_YEAR_MONTH ColumnDataType = 23 ColumnDataType_INTERVAL_DAY_TIME ColumnDataType = 24 ColumnDataType_INTERVAL_MONTH_DAY_NANO ColumnDataType = 25 )
func (ColumnDataType) Descriptor ¶
func (ColumnDataType) Descriptor() protoreflect.EnumDescriptor
func (ColumnDataType) Enum ¶
func (x ColumnDataType) Enum() *ColumnDataType
func (ColumnDataType) EnumDescriptor
deprecated
func (ColumnDataType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ColumnDataType.Descriptor instead.
func (ColumnDataType) Number ¶
func (x ColumnDataType) Number() protoreflect.EnumNumber
func (ColumnDataType) String ¶
func (x ColumnDataType) String() string
func (ColumnDataType) Type ¶
func (ColumnDataType) Type() protoreflect.EnumType
type ColumnDef ¶
type ColumnDef struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DataType ColumnDataType `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=greptime.v1.ColumnDataType" json:"data_type,omitempty"` IsNullable bool `protobuf:"varint,3,opt,name=is_nullable,json=isNullable,proto3" json:"is_nullable,omitempty"` DefaultConstraint []byte `protobuf:"bytes,4,opt,name=default_constraint,json=defaultConstraint,proto3" json:"default_constraint,omitempty"` SemanticType SemanticType `` /* 128-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ColumnDef) Descriptor
deprecated
func (*ColumnDef) GetDataType ¶ added in v0.4.0
func (x *ColumnDef) GetDataType() ColumnDataType
func (*ColumnDef) GetDefaultConstraint ¶
func (*ColumnDef) GetIsNullable ¶
func (*ColumnDef) GetSemanticType ¶ added in v0.4.0
func (x *ColumnDef) GetSemanticType() SemanticType
func (*ColumnDef) ProtoMessage ¶
func (*ColumnDef) ProtoMessage()
func (*ColumnDef) ProtoReflect ¶
func (x *ColumnDef) ProtoReflect() protoreflect.Message
type ColumnSchema ¶ added in v0.4.0
type ColumnSchema struct { ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` Datatype ColumnDataType `protobuf:"varint,2,opt,name=datatype,proto3,enum=greptime.v1.ColumnDataType" json:"datatype,omitempty"` SemanticType SemanticType `` /* 128-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ColumnSchema) Descriptor
deprecated
added in
v0.4.0
func (*ColumnSchema) Descriptor() ([]byte, []int)
Deprecated: Use ColumnSchema.ProtoReflect.Descriptor instead.
func (*ColumnSchema) GetColumnName ¶ added in v0.4.0
func (x *ColumnSchema) GetColumnName() string
func (*ColumnSchema) GetDatatype ¶ added in v0.4.0
func (x *ColumnSchema) GetDatatype() ColumnDataType
func (*ColumnSchema) GetSemanticType ¶ added in v0.4.0
func (x *ColumnSchema) GetSemanticType() SemanticType
func (*ColumnSchema) ProtoMessage ¶ added in v0.4.0
func (*ColumnSchema) ProtoMessage()
func (*ColumnSchema) ProtoReflect ¶ added in v0.4.0
func (x *ColumnSchema) ProtoReflect() protoreflect.Message
func (*ColumnSchema) Reset ¶ added in v0.4.0
func (x *ColumnSchema) Reset()
func (*ColumnSchema) String ¶ added in v0.4.0
func (x *ColumnSchema) String() string
type Column_Values ¶
type Column_Values struct { I8Values []int32 `protobuf:"varint,1,rep,packed,name=i8_values,json=i8Values,proto3" json:"i8_values,omitempty"` I16Values []int32 `protobuf:"varint,2,rep,packed,name=i16_values,json=i16Values,proto3" json:"i16_values,omitempty"` I32Values []int32 `protobuf:"varint,3,rep,packed,name=i32_values,json=i32Values,proto3" json:"i32_values,omitempty"` I64Values []int64 `protobuf:"varint,4,rep,packed,name=i64_values,json=i64Values,proto3" json:"i64_values,omitempty"` U8Values []uint32 `protobuf:"varint,5,rep,packed,name=u8_values,json=u8Values,proto3" json:"u8_values,omitempty"` U16Values []uint32 `protobuf:"varint,6,rep,packed,name=u16_values,json=u16Values,proto3" json:"u16_values,omitempty"` U32Values []uint32 `protobuf:"varint,7,rep,packed,name=u32_values,json=u32Values,proto3" json:"u32_values,omitempty"` U64Values []uint64 `protobuf:"varint,8,rep,packed,name=u64_values,json=u64Values,proto3" json:"u64_values,omitempty"` F32Values []float32 `protobuf:"fixed32,9,rep,packed,name=f32_values,json=f32Values,proto3" json:"f32_values,omitempty"` F64Values []float64 `protobuf:"fixed64,10,rep,packed,name=f64_values,json=f64Values,proto3" json:"f64_values,omitempty"` BoolValues []bool `protobuf:"varint,11,rep,packed,name=bool_values,json=boolValues,proto3" json:"bool_values,omitempty"` BinaryValues [][]byte `protobuf:"bytes,12,rep,name=binary_values,json=binaryValues,proto3" json:"binary_values,omitempty"` StringValues []string `protobuf:"bytes,13,rep,name=string_values,json=stringValues,proto3" json:"string_values,omitempty"` DateValues []int32 `protobuf:"varint,14,rep,packed,name=date_values,json=dateValues,proto3" json:"date_values,omitempty"` DatetimeValues []int64 `protobuf:"varint,15,rep,packed,name=datetime_values,json=datetimeValues,proto3" json:"datetime_values,omitempty"` TimestampSecondValues []int64 `` /* 135-byte string literal not displayed */ TimestampMillisecondValues []int64 `` /* 150-byte string literal not displayed */ TimestampMicrosecondValues []int64 `` /* 150-byte string literal not displayed */ TimestampNanosecondValues []int64 `` /* 147-byte string literal not displayed */ TimeSecondValues []int64 `protobuf:"varint,20,rep,packed,name=time_second_values,json=timeSecondValues,proto3" json:"time_second_values,omitempty"` TimeMillisecondValues []int64 `` /* 135-byte string literal not displayed */ TimeMicrosecondValues []int64 `` /* 135-byte string literal not displayed */ TimeNanosecondValues []int64 `` /* 132-byte string literal not displayed */ IntervalYearMonthValues []int32 `` /* 143-byte string literal not displayed */ IntervalDayTimeValues []int64 `` /* 137-byte string literal not displayed */ IntervalMonthDayNanoValues []*IntervalMonthDayNano `` /* 146-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Column_Values) Descriptor
deprecated
func (*Column_Values) Descriptor() ([]byte, []int)
Deprecated: Use Column_Values.ProtoReflect.Descriptor instead.
func (*Column_Values) GetBinaryValues ¶
func (x *Column_Values) GetBinaryValues() [][]byte
func (*Column_Values) GetBoolValues ¶
func (x *Column_Values) GetBoolValues() []bool
func (*Column_Values) GetDateValues ¶
func (x *Column_Values) GetDateValues() []int32
func (*Column_Values) GetDatetimeValues ¶
func (x *Column_Values) GetDatetimeValues() []int64
func (*Column_Values) GetF32Values ¶
func (x *Column_Values) GetF32Values() []float32
func (*Column_Values) GetF64Values ¶
func (x *Column_Values) GetF64Values() []float64
func (*Column_Values) GetI16Values ¶
func (x *Column_Values) GetI16Values() []int32
func (*Column_Values) GetI32Values ¶
func (x *Column_Values) GetI32Values() []int32
func (*Column_Values) GetI64Values ¶
func (x *Column_Values) GetI64Values() []int64
func (*Column_Values) GetI8Values ¶
func (x *Column_Values) GetI8Values() []int32
func (*Column_Values) GetIntervalDayTimeValues ¶ added in v0.4.0
func (x *Column_Values) GetIntervalDayTimeValues() []int64
func (*Column_Values) GetIntervalMonthDayNanoValues ¶ added in v0.4.0
func (x *Column_Values) GetIntervalMonthDayNanoValues() []*IntervalMonthDayNano
func (*Column_Values) GetIntervalYearMonthValues ¶ added in v0.4.0
func (x *Column_Values) GetIntervalYearMonthValues() []int32
func (*Column_Values) GetStringValues ¶
func (x *Column_Values) GetStringValues() []string
func (*Column_Values) GetTimeMicrosecondValues ¶
func (x *Column_Values) GetTimeMicrosecondValues() []int64
func (*Column_Values) GetTimeMillisecondValues ¶
func (x *Column_Values) GetTimeMillisecondValues() []int64
func (*Column_Values) GetTimeNanosecondValues ¶
func (x *Column_Values) GetTimeNanosecondValues() []int64
func (*Column_Values) GetTimeSecondValues ¶
func (x *Column_Values) GetTimeSecondValues() []int64
func (*Column_Values) GetTimestampMicrosecondValues ¶ added in v0.4.0
func (x *Column_Values) GetTimestampMicrosecondValues() []int64
func (*Column_Values) GetTimestampMillisecondValues ¶ added in v0.4.0
func (x *Column_Values) GetTimestampMillisecondValues() []int64
func (*Column_Values) GetTimestampNanosecondValues ¶ added in v0.4.0
func (x *Column_Values) GetTimestampNanosecondValues() []int64
func (*Column_Values) GetTimestampSecondValues ¶ added in v0.4.0
func (x *Column_Values) GetTimestampSecondValues() []int64
func (*Column_Values) GetU16Values ¶
func (x *Column_Values) GetU16Values() []uint32
func (*Column_Values) GetU32Values ¶
func (x *Column_Values) GetU32Values() []uint32
func (*Column_Values) GetU64Values ¶
func (x *Column_Values) GetU64Values() []uint64
func (*Column_Values) GetU8Values ¶
func (x *Column_Values) GetU8Values() []uint32
func (*Column_Values) ProtoMessage ¶
func (*Column_Values) ProtoMessage()
func (*Column_Values) ProtoReflect ¶
func (x *Column_Values) ProtoReflect() protoreflect.Message
func (*Column_Values) Reset ¶
func (x *Column_Values) Reset()
func (*Column_Values) String ¶
func (x *Column_Values) String() string
type CreateDatabaseExpr ¶
type CreateDatabaseExpr struct { DatabaseName string `protobuf:"bytes,1,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"` CreateIfNotExists bool `protobuf:"varint,2,opt,name=create_if_not_exists,json=createIfNotExists,proto3" json:"create_if_not_exists,omitempty"` Options map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CreateDatabaseExpr) Descriptor
deprecated
func (*CreateDatabaseExpr) Descriptor() ([]byte, []int)
Deprecated: Use CreateDatabaseExpr.ProtoReflect.Descriptor instead.
func (*CreateDatabaseExpr) GetCreateIfNotExists ¶
func (x *CreateDatabaseExpr) GetCreateIfNotExists() bool
func (*CreateDatabaseExpr) GetDatabaseName ¶
func (x *CreateDatabaseExpr) GetDatabaseName() string
func (*CreateDatabaseExpr) GetOptions ¶ added in v0.4.0
func (x *CreateDatabaseExpr) GetOptions() map[string]string
func (*CreateDatabaseExpr) ProtoMessage ¶
func (*CreateDatabaseExpr) ProtoMessage()
func (*CreateDatabaseExpr) ProtoReflect ¶
func (x *CreateDatabaseExpr) ProtoReflect() protoreflect.Message
func (*CreateDatabaseExpr) Reset ¶
func (x *CreateDatabaseExpr) Reset()
func (*CreateDatabaseExpr) String ¶
func (x *CreateDatabaseExpr) String() string
type CreateTableExpr ¶
type CreateTableExpr struct { CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` Desc string `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"` ColumnDefs []*ColumnDef `protobuf:"bytes,5,rep,name=column_defs,json=columnDefs,proto3" json:"column_defs,omitempty"` TimeIndex string `protobuf:"bytes,6,opt,name=time_index,json=timeIndex,proto3" json:"time_index,omitempty"` PrimaryKeys []string `protobuf:"bytes,7,rep,name=primary_keys,json=primaryKeys,proto3" json:"primary_keys,omitempty"` CreateIfNotExists bool `protobuf:"varint,8,opt,name=create_if_not_exists,json=createIfNotExists,proto3" json:"create_if_not_exists,omitempty"` TableOptions map[string]string `` /* 185-byte string literal not displayed */ TableId *TableId `protobuf:"bytes,10,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` Engine string `protobuf:"bytes,12,opt,name=engine,proto3" json:"engine,omitempty"` // contains filtered or unexported fields }
func (*CreateTableExpr) Descriptor
deprecated
func (*CreateTableExpr) Descriptor() ([]byte, []int)
Deprecated: Use CreateTableExpr.ProtoReflect.Descriptor instead.
func (*CreateTableExpr) GetCatalogName ¶
func (x *CreateTableExpr) GetCatalogName() string
func (*CreateTableExpr) GetColumnDefs ¶
func (x *CreateTableExpr) GetColumnDefs() []*ColumnDef
func (*CreateTableExpr) GetCreateIfNotExists ¶
func (x *CreateTableExpr) GetCreateIfNotExists() bool
func (*CreateTableExpr) GetDesc ¶
func (x *CreateTableExpr) GetDesc() string
func (*CreateTableExpr) GetEngine ¶
func (x *CreateTableExpr) GetEngine() string
func (*CreateTableExpr) GetPrimaryKeys ¶
func (x *CreateTableExpr) GetPrimaryKeys() []string
func (*CreateTableExpr) GetSchemaName ¶
func (x *CreateTableExpr) GetSchemaName() string
func (*CreateTableExpr) GetTableId ¶
func (x *CreateTableExpr) GetTableId() *TableId
func (*CreateTableExpr) GetTableName ¶
func (x *CreateTableExpr) GetTableName() string
func (*CreateTableExpr) GetTableOptions ¶
func (x *CreateTableExpr) GetTableOptions() map[string]string
func (*CreateTableExpr) GetTimeIndex ¶
func (x *CreateTableExpr) GetTimeIndex() string
func (*CreateTableExpr) ProtoMessage ¶
func (*CreateTableExpr) ProtoMessage()
func (*CreateTableExpr) ProtoReflect ¶
func (x *CreateTableExpr) ProtoReflect() protoreflect.Message
func (*CreateTableExpr) Reset ¶
func (x *CreateTableExpr) Reset()
func (*CreateTableExpr) String ¶
func (x *CreateTableExpr) String() string
type DdlRequest ¶
type DdlRequest struct { // Types that are assignable to Expr: // // *DdlRequest_CreateDatabase // *DdlRequest_CreateTable // *DdlRequest_Alter // *DdlRequest_DropTable // *DdlRequest_TruncateTable Expr isDdlRequest_Expr `protobuf_oneof:"expr"` // contains filtered or unexported fields }
"Data Definition Language" requests, that create, modify or delete the database structures but not the data. `DdlRequest` could carry more information than plain SQL, for example, the "table_id" in `CreateTableExpr`. So create a new DDL expr if you need it.
func (*DdlRequest) Descriptor
deprecated
func (*DdlRequest) Descriptor() ([]byte, []int)
Deprecated: Use DdlRequest.ProtoReflect.Descriptor instead.
func (*DdlRequest) GetAlter ¶
func (x *DdlRequest) GetAlter() *AlterExpr
func (*DdlRequest) GetCreateDatabase ¶
func (x *DdlRequest) GetCreateDatabase() *CreateDatabaseExpr
func (*DdlRequest) GetCreateTable ¶
func (x *DdlRequest) GetCreateTable() *CreateTableExpr
func (*DdlRequest) GetDropTable ¶
func (x *DdlRequest) GetDropTable() *DropTableExpr
func (*DdlRequest) GetExpr ¶
func (m *DdlRequest) GetExpr() isDdlRequest_Expr
func (*DdlRequest) GetTruncateTable ¶
func (x *DdlRequest) GetTruncateTable() *TruncateTableExpr
func (*DdlRequest) ProtoMessage ¶
func (*DdlRequest) ProtoMessage()
func (*DdlRequest) ProtoReflect ¶
func (x *DdlRequest) ProtoReflect() protoreflect.Message
func (*DdlRequest) Reset ¶
func (x *DdlRequest) Reset()
func (*DdlRequest) String ¶
func (x *DdlRequest) String() string
type DdlRequest_Alter ¶
type DdlRequest_Alter struct {
Alter *AlterExpr `protobuf:"bytes,3,opt,name=alter,proto3,oneof"`
}
type DdlRequest_CreateDatabase ¶
type DdlRequest_CreateDatabase struct {
CreateDatabase *CreateDatabaseExpr `protobuf:"bytes,1,opt,name=create_database,json=createDatabase,proto3,oneof"`
}
type DdlRequest_CreateTable ¶
type DdlRequest_CreateTable struct {
CreateTable *CreateTableExpr `protobuf:"bytes,2,opt,name=create_table,json=createTable,proto3,oneof"`
}
type DdlRequest_DropTable ¶
type DdlRequest_DropTable struct {
DropTable *DropTableExpr `protobuf:"bytes,4,opt,name=drop_table,json=dropTable,proto3,oneof"`
}
type DdlRequest_TruncateTable ¶
type DdlRequest_TruncateTable struct {
TruncateTable *TruncateTableExpr `protobuf:"bytes,7,opt,name=truncate_table,json=truncateTable,proto3,oneof"`
}
type DeleteRequest ¶
type DeleteRequest struct { // The table name to delete from. Catalog name and schema name are in the // `RequestHeader`. TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // The data to delete, indexed by key columns. KeyColumns []*Column `protobuf:"bytes,3,rep,name=key_columns,json=keyColumns,proto3" json:"key_columns,omitempty"` // The row count of all columns above. RowCount uint32 `protobuf:"varint,4,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"` // contains filtered or unexported fields }
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetKeyColumns ¶
func (x *DeleteRequest) GetKeyColumns() []*Column
func (*DeleteRequest) GetRowCount ¶
func (x *DeleteRequest) GetRowCount() uint32
func (*DeleteRequest) GetTableName ¶
func (x *DeleteRequest) GetTableName() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteRequests ¶ added in v0.4.0
type DeleteRequests struct { Deletes []*DeleteRequest `protobuf:"bytes,1,rep,name=deletes,proto3" json:"deletes,omitempty"` // contains filtered or unexported fields }
func (*DeleteRequests) Descriptor
deprecated
added in
v0.4.0
func (*DeleteRequests) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequests.ProtoReflect.Descriptor instead.
func (*DeleteRequests) GetDeletes ¶ added in v0.4.0
func (x *DeleteRequests) GetDeletes() []*DeleteRequest
func (*DeleteRequests) ProtoMessage ¶ added in v0.4.0
func (*DeleteRequests) ProtoMessage()
func (*DeleteRequests) ProtoReflect ¶ added in v0.4.0
func (x *DeleteRequests) ProtoReflect() protoreflect.Message
func (*DeleteRequests) Reset ¶ added in v0.4.0
func (x *DeleteRequests) Reset()
func (*DeleteRequests) String ¶ added in v0.4.0
func (x *DeleteRequests) String() string
type DropColumn ¶
type DropColumn struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DropColumn) Descriptor
deprecated
func (*DropColumn) Descriptor() ([]byte, []int)
Deprecated: Use DropColumn.ProtoReflect.Descriptor instead.
func (*DropColumn) GetName ¶
func (x *DropColumn) GetName() string
func (*DropColumn) ProtoMessage ¶
func (*DropColumn) ProtoMessage()
func (*DropColumn) ProtoReflect ¶
func (x *DropColumn) ProtoReflect() protoreflect.Message
func (*DropColumn) Reset ¶
func (x *DropColumn) Reset()
func (*DropColumn) String ¶
func (x *DropColumn) String() string
type DropColumns ¶
type DropColumns struct { DropColumns []*DropColumn `protobuf:"bytes,1,rep,name=drop_columns,json=dropColumns,proto3" json:"drop_columns,omitempty"` // contains filtered or unexported fields }
func (*DropColumns) Descriptor
deprecated
func (*DropColumns) Descriptor() ([]byte, []int)
Deprecated: Use DropColumns.ProtoReflect.Descriptor instead.
func (*DropColumns) GetDropColumns ¶
func (x *DropColumns) GetDropColumns() []*DropColumn
func (*DropColumns) ProtoMessage ¶
func (*DropColumns) ProtoMessage()
func (*DropColumns) ProtoReflect ¶
func (x *DropColumns) ProtoReflect() protoreflect.Message
func (*DropColumns) Reset ¶
func (x *DropColumns) Reset()
func (*DropColumns) String ¶
func (x *DropColumns) String() string
type DropTableExpr ¶
type DropTableExpr struct { CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` TableId *TableId `protobuf:"bytes,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` // contains filtered or unexported fields }
func (*DropTableExpr) Descriptor
deprecated
func (*DropTableExpr) Descriptor() ([]byte, []int)
Deprecated: Use DropTableExpr.ProtoReflect.Descriptor instead.
func (*DropTableExpr) GetCatalogName ¶
func (x *DropTableExpr) GetCatalogName() string
func (*DropTableExpr) GetSchemaName ¶
func (x *DropTableExpr) GetSchemaName() string
func (*DropTableExpr) GetTableId ¶
func (x *DropTableExpr) GetTableId() *TableId
func (*DropTableExpr) GetTableName ¶
func (x *DropTableExpr) GetTableName() string
func (*DropTableExpr) ProtoMessage ¶
func (*DropTableExpr) ProtoMessage()
func (*DropTableExpr) ProtoReflect ¶
func (x *DropTableExpr) ProtoReflect() protoreflect.Message
func (*DropTableExpr) Reset ¶
func (x *DropTableExpr) Reset()
func (*DropTableExpr) String ¶
func (x *DropTableExpr) String() string
type FlightMetadata ¶
type FlightMetadata struct { AffectedRows *AffectedRows `protobuf:"bytes,1,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"` // contains filtered or unexported fields }
func (*FlightMetadata) Descriptor
deprecated
func (*FlightMetadata) Descriptor() ([]byte, []int)
Deprecated: Use FlightMetadata.ProtoReflect.Descriptor instead.
func (*FlightMetadata) GetAffectedRows ¶
func (x *FlightMetadata) GetAffectedRows() *AffectedRows
func (*FlightMetadata) ProtoMessage ¶
func (*FlightMetadata) ProtoMessage()
func (*FlightMetadata) ProtoReflect ¶
func (x *FlightMetadata) ProtoReflect() protoreflect.Message
func (*FlightMetadata) Reset ¶
func (x *FlightMetadata) Reset()
func (*FlightMetadata) String ¶
func (x *FlightMetadata) String() string
type GreptimeDatabaseClient ¶
type GreptimeDatabaseClient interface { Handle(ctx context.Context, in *GreptimeRequest, opts ...grpc.CallOption) (*GreptimeResponse, error) HandleRequests(ctx context.Context, opts ...grpc.CallOption) (GreptimeDatabase_HandleRequestsClient, error) }
GreptimeDatabaseClient is the client API for GreptimeDatabase service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewGreptimeDatabaseClient ¶
func NewGreptimeDatabaseClient(cc grpc.ClientConnInterface) GreptimeDatabaseClient
type GreptimeDatabaseServer ¶
type GreptimeDatabaseServer interface { Handle(context.Context, *GreptimeRequest) (*GreptimeResponse, error) HandleRequests(GreptimeDatabase_HandleRequestsServer) error // contains filtered or unexported methods }
GreptimeDatabaseServer is the server API for GreptimeDatabase service. All implementations must embed UnimplementedGreptimeDatabaseServer for forward compatibility
type GreptimeDatabase_HandleRequestsClient ¶
type GreptimeDatabase_HandleRequestsClient interface { Send(*GreptimeRequest) error CloseAndRecv() (*GreptimeResponse, error) grpc.ClientStream }
type GreptimeDatabase_HandleRequestsServer ¶
type GreptimeDatabase_HandleRequestsServer interface { SendAndClose(*GreptimeResponse) error Recv() (*GreptimeRequest, error) grpc.ServerStream }
type GreptimeRequest ¶
type GreptimeRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Types that are assignable to Request: // // *GreptimeRequest_Inserts // *GreptimeRequest_Query // *GreptimeRequest_Ddl // *GreptimeRequest_Deletes // *GreptimeRequest_RowInserts // *GreptimeRequest_RowDeletes Request isGreptimeRequest_Request `protobuf_oneof:"request"` // contains filtered or unexported fields }
func (*GreptimeRequest) Descriptor
deprecated
func (*GreptimeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GreptimeRequest.ProtoReflect.Descriptor instead.
func (*GreptimeRequest) GetDdl ¶
func (x *GreptimeRequest) GetDdl() *DdlRequest
func (*GreptimeRequest) GetDeletes ¶ added in v0.4.0
func (x *GreptimeRequest) GetDeletes() *DeleteRequests
func (*GreptimeRequest) GetHeader ¶
func (x *GreptimeRequest) GetHeader() *RequestHeader
func (*GreptimeRequest) GetInserts ¶
func (x *GreptimeRequest) GetInserts() *InsertRequests
func (*GreptimeRequest) GetQuery ¶
func (x *GreptimeRequest) GetQuery() *QueryRequest
func (*GreptimeRequest) GetRequest ¶
func (m *GreptimeRequest) GetRequest() isGreptimeRequest_Request
func (*GreptimeRequest) GetRowDeletes ¶ added in v0.4.0
func (x *GreptimeRequest) GetRowDeletes() *RowDeleteRequests
func (*GreptimeRequest) GetRowInserts ¶ added in v0.4.0
func (x *GreptimeRequest) GetRowInserts() *RowInsertRequests
func (*GreptimeRequest) ProtoMessage ¶
func (*GreptimeRequest) ProtoMessage()
func (*GreptimeRequest) ProtoReflect ¶
func (x *GreptimeRequest) ProtoReflect() protoreflect.Message
func (*GreptimeRequest) Reset ¶
func (x *GreptimeRequest) Reset()
func (*GreptimeRequest) String ¶
func (x *GreptimeRequest) String() string
type GreptimeRequest_Ddl ¶
type GreptimeRequest_Ddl struct {
Ddl *DdlRequest `protobuf:"bytes,4,opt,name=ddl,proto3,oneof"`
}
type GreptimeRequest_Deletes ¶ added in v0.4.0
type GreptimeRequest_Deletes struct {
Deletes *DeleteRequests `protobuf:"bytes,5,opt,name=deletes,proto3,oneof"`
}
type GreptimeRequest_Inserts ¶
type GreptimeRequest_Inserts struct {
Inserts *InsertRequests `protobuf:"bytes,2,opt,name=inserts,proto3,oneof"`
}
type GreptimeRequest_Query ¶
type GreptimeRequest_Query struct {
Query *QueryRequest `protobuf:"bytes,3,opt,name=query,proto3,oneof"`
}
type GreptimeRequest_RowDeletes ¶ added in v0.4.0
type GreptimeRequest_RowDeletes struct {
RowDeletes *RowDeleteRequests `protobuf:"bytes,7,opt,name=row_deletes,json=rowDeletes,proto3,oneof"`
}
type GreptimeRequest_RowInserts ¶ added in v0.4.0
type GreptimeRequest_RowInserts struct {
RowInserts *RowInsertRequests `protobuf:"bytes,6,opt,name=row_inserts,json=rowInserts,proto3,oneof"`
}
type GreptimeResponse ¶
type GreptimeResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Types that are assignable to Response: // // *GreptimeResponse_AffectedRows Response isGreptimeResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
func (*GreptimeResponse) Descriptor
deprecated
func (*GreptimeResponse) Descriptor() ([]byte, []int)
Deprecated: Use GreptimeResponse.ProtoReflect.Descriptor instead.
func (*GreptimeResponse) GetAffectedRows ¶
func (x *GreptimeResponse) GetAffectedRows() *AffectedRows
func (*GreptimeResponse) GetHeader ¶
func (x *GreptimeResponse) GetHeader() *ResponseHeader
func (*GreptimeResponse) GetResponse ¶
func (m *GreptimeResponse) GetResponse() isGreptimeResponse_Response
func (*GreptimeResponse) ProtoMessage ¶
func (*GreptimeResponse) ProtoMessage()
func (*GreptimeResponse) ProtoReflect ¶
func (x *GreptimeResponse) ProtoReflect() protoreflect.Message
func (*GreptimeResponse) Reset ¶
func (x *GreptimeResponse) Reset()
func (*GreptimeResponse) String ¶
func (x *GreptimeResponse) String() string
type GreptimeResponse_AffectedRows ¶
type GreptimeResponse_AffectedRows struct {
AffectedRows *AffectedRows `protobuf:"bytes,2,opt,name=affected_rows,json=affectedRows,proto3,oneof"`
}
type HealthCheckClient ¶
type HealthCheckClient interface {
HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}
HealthCheckClient is the client API for HealthCheck service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewHealthCheckClient ¶
func NewHealthCheckClient(cc grpc.ClientConnInterface) HealthCheckClient
type HealthCheckRequest ¶
type HealthCheckRequest struct {
// contains filtered or unexported fields
}
func (*HealthCheckRequest) Descriptor
deprecated
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) ProtoReflect ¶
func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
func (*HealthCheckRequest) Reset ¶
func (x *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (x *HealthCheckRequest) String() string
type HealthCheckResponse ¶
type HealthCheckResponse struct {
// contains filtered or unexported fields
}
func (*HealthCheckResponse) Descriptor
deprecated
func (*HealthCheckResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.
func (*HealthCheckResponse) ProtoMessage ¶
func (*HealthCheckResponse) ProtoMessage()
func (*HealthCheckResponse) ProtoReflect ¶
func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
func (*HealthCheckResponse) Reset ¶
func (x *HealthCheckResponse) Reset()
func (*HealthCheckResponse) String ¶
func (x *HealthCheckResponse) String() string
type HealthCheckServer ¶
type HealthCheckServer interface { HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error) // contains filtered or unexported methods }
HealthCheckServer is the server API for HealthCheck service. All implementations must embed UnimplementedHealthCheckServer for forward compatibility
type InsertRequest ¶
type InsertRequest struct { TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Data is represented here. Columns []*Column `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"` // The row_count of all columns, which include null and non-null values. // // Note: the row_count of all columns in a InsertRequest must be same. RowCount uint32 `protobuf:"varint,4,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"` // contains filtered or unexported fields }
func (*InsertRequest) Descriptor
deprecated
func (*InsertRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertRequest.ProtoReflect.Descriptor instead.
func (*InsertRequest) GetColumns ¶
func (x *InsertRequest) GetColumns() []*Column
func (*InsertRequest) GetRowCount ¶
func (x *InsertRequest) GetRowCount() uint32
func (*InsertRequest) GetTableName ¶
func (x *InsertRequest) GetTableName() string
func (*InsertRequest) ProtoMessage ¶
func (*InsertRequest) ProtoMessage()
func (*InsertRequest) ProtoReflect ¶
func (x *InsertRequest) ProtoReflect() protoreflect.Message
func (*InsertRequest) Reset ¶
func (x *InsertRequest) Reset()
func (*InsertRequest) String ¶
func (x *InsertRequest) String() string
type InsertRequests ¶
type InsertRequests struct { Inserts []*InsertRequest `protobuf:"bytes,1,rep,name=inserts,proto3" json:"inserts,omitempty"` // contains filtered or unexported fields }
func (*InsertRequests) Descriptor
deprecated
func (*InsertRequests) Descriptor() ([]byte, []int)
Deprecated: Use InsertRequests.ProtoReflect.Descriptor instead.
func (*InsertRequests) GetInserts ¶
func (x *InsertRequests) GetInserts() []*InsertRequest
func (*InsertRequests) ProtoMessage ¶
func (*InsertRequests) ProtoMessage()
func (*InsertRequests) ProtoReflect ¶
func (x *InsertRequests) ProtoReflect() protoreflect.Message
func (*InsertRequests) Reset ¶
func (x *InsertRequests) Reset()
func (*InsertRequests) String ¶
func (x *InsertRequests) String() string
type IntervalMonthDayNano ¶ added in v0.4.0
type IntervalMonthDayNano struct { Months int32 `protobuf:"varint,1,opt,name=months,proto3" json:"months,omitempty"` Days int32 `protobuf:"varint,2,opt,name=days,proto3" json:"days,omitempty"` Nanoseconds int64 `protobuf:"varint,3,opt,name=nanoseconds,proto3" json:"nanoseconds,omitempty"` // contains filtered or unexported fields }
func (*IntervalMonthDayNano) Descriptor
deprecated
added in
v0.4.0
func (*IntervalMonthDayNano) Descriptor() ([]byte, []int)
Deprecated: Use IntervalMonthDayNano.ProtoReflect.Descriptor instead.
func (*IntervalMonthDayNano) GetDays ¶ added in v0.4.0
func (x *IntervalMonthDayNano) GetDays() int32
func (*IntervalMonthDayNano) GetMonths ¶ added in v0.4.0
func (x *IntervalMonthDayNano) GetMonths() int32
func (*IntervalMonthDayNano) GetNanoseconds ¶ added in v0.4.0
func (x *IntervalMonthDayNano) GetNanoseconds() int64
func (*IntervalMonthDayNano) ProtoMessage ¶ added in v0.4.0
func (*IntervalMonthDayNano) ProtoMessage()
func (*IntervalMonthDayNano) ProtoReflect ¶ added in v0.4.0
func (x *IntervalMonthDayNano) ProtoReflect() protoreflect.Message
func (*IntervalMonthDayNano) Reset ¶ added in v0.4.0
func (x *IntervalMonthDayNano) Reset()
func (*IntervalMonthDayNano) String ¶ added in v0.4.0
func (x *IntervalMonthDayNano) String() string
type Mutation ¶ added in v0.4.0
type Mutation struct { // Type of this mutation. OpType OpType `protobuf:"varint,1,opt,name=op_type,json=opType,proto3,enum=greptime.v1.OpType" json:"op_type,omitempty"` // Start WAL sequence of this mutation. Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"` // Row updates to write to the WAL. Rows *Rows `protobuf:"bytes,3,opt,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
Mutation contains updates to a set of rows.
func (*Mutation) Descriptor
deprecated
added in
v0.4.0
func (*Mutation) GetSequence ¶ added in v0.4.0
func (*Mutation) ProtoMessage ¶ added in v0.4.0
func (*Mutation) ProtoMessage()
func (*Mutation) ProtoReflect ¶ added in v0.4.0
func (x *Mutation) ProtoReflect() protoreflect.Message
type OpType ¶ added in v0.4.0
type OpType int32
Type of operation to rows.
func (OpType) Descriptor ¶ added in v0.4.0
func (OpType) Descriptor() protoreflect.EnumDescriptor
func (OpType) EnumDescriptor
deprecated
added in
v0.4.0
func (OpType) Number ¶ added in v0.4.0
func (x OpType) Number() protoreflect.EnumNumber
func (OpType) Type ¶ added in v0.4.0
func (OpType) Type() protoreflect.EnumType
type PromInstantQuery ¶
type PromInstantQuery struct { Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Time string `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*PromInstantQuery) Descriptor
deprecated
func (*PromInstantQuery) Descriptor() ([]byte, []int)
Deprecated: Use PromInstantQuery.ProtoReflect.Descriptor instead.
func (*PromInstantQuery) GetQuery ¶
func (x *PromInstantQuery) GetQuery() string
func (*PromInstantQuery) GetTime ¶
func (x *PromInstantQuery) GetTime() string
func (*PromInstantQuery) ProtoMessage ¶
func (*PromInstantQuery) ProtoMessage()
func (*PromInstantQuery) ProtoReflect ¶
func (x *PromInstantQuery) ProtoReflect() protoreflect.Message
func (*PromInstantQuery) Reset ¶
func (x *PromInstantQuery) Reset()
func (*PromInstantQuery) String ¶
func (x *PromInstantQuery) String() string
type PromRangeQuery ¶
type PromRangeQuery struct { Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Start string `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"` End string `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"` Step string `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"` // contains filtered or unexported fields }
func (*PromRangeQuery) Descriptor
deprecated
func (*PromRangeQuery) Descriptor() ([]byte, []int)
Deprecated: Use PromRangeQuery.ProtoReflect.Descriptor instead.
func (*PromRangeQuery) GetEnd ¶
func (x *PromRangeQuery) GetEnd() string
func (*PromRangeQuery) GetQuery ¶
func (x *PromRangeQuery) GetQuery() string
func (*PromRangeQuery) GetStart ¶
func (x *PromRangeQuery) GetStart() string
func (*PromRangeQuery) GetStep ¶
func (x *PromRangeQuery) GetStep() string
func (*PromRangeQuery) ProtoMessage ¶
func (*PromRangeQuery) ProtoMessage()
func (*PromRangeQuery) ProtoReflect ¶
func (x *PromRangeQuery) ProtoReflect() protoreflect.Message
func (*PromRangeQuery) Reset ¶
func (x *PromRangeQuery) Reset()
func (*PromRangeQuery) String ¶
func (x *PromRangeQuery) String() string
type PrometheusGatewayClient ¶
type PrometheusGatewayClient interface {
Handle(ctx context.Context, in *PromqlRequest, opts ...grpc.CallOption) (*PromqlResponse, error)
}
PrometheusGatewayClient is the client API for PrometheusGateway service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPrometheusGatewayClient ¶
func NewPrometheusGatewayClient(cc grpc.ClientConnInterface) PrometheusGatewayClient
type PrometheusGatewayServer ¶
type PrometheusGatewayServer interface { Handle(context.Context, *PromqlRequest) (*PromqlResponse, error) // contains filtered or unexported methods }
PrometheusGatewayServer is the server API for PrometheusGateway service. All implementations must embed UnimplementedPrometheusGatewayServer for forward compatibility
type PromqlRequest ¶
type PromqlRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Types that are assignable to Promql: // // *PromqlRequest_InstantQuery // *PromqlRequest_RangeQuery Promql isPromqlRequest_Promql `protobuf_oneof:"promql"` // contains filtered or unexported fields }
func (*PromqlRequest) Descriptor
deprecated
func (*PromqlRequest) Descriptor() ([]byte, []int)
Deprecated: Use PromqlRequest.ProtoReflect.Descriptor instead.
func (*PromqlRequest) GetHeader ¶
func (x *PromqlRequest) GetHeader() *RequestHeader
func (*PromqlRequest) GetInstantQuery ¶
func (x *PromqlRequest) GetInstantQuery() *PromInstantQuery
func (*PromqlRequest) GetPromql ¶
func (m *PromqlRequest) GetPromql() isPromqlRequest_Promql
func (*PromqlRequest) GetRangeQuery ¶
func (x *PromqlRequest) GetRangeQuery() *PromRangeQuery
func (*PromqlRequest) ProtoMessage ¶
func (*PromqlRequest) ProtoMessage()
func (*PromqlRequest) ProtoReflect ¶
func (x *PromqlRequest) ProtoReflect() protoreflect.Message
func (*PromqlRequest) Reset ¶
func (x *PromqlRequest) Reset()
func (*PromqlRequest) String ¶
func (x *PromqlRequest) String() string
type PromqlRequest_InstantQuery ¶
type PromqlRequest_InstantQuery struct {
InstantQuery *PromInstantQuery `protobuf:"bytes,2,opt,name=instant_query,json=instantQuery,proto3,oneof"`
}
type PromqlRequest_RangeQuery ¶
type PromqlRequest_RangeQuery struct {
RangeQuery *PromRangeQuery `protobuf:"bytes,3,opt,name=range_query,json=rangeQuery,proto3,oneof"`
}
type PromqlResponse ¶
type PromqlResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // absolutely same format as Prometheus in JSON // contains filtered or unexported fields }
func (*PromqlResponse) Descriptor
deprecated
func (*PromqlResponse) Descriptor() ([]byte, []int)
Deprecated: Use PromqlResponse.ProtoReflect.Descriptor instead.
func (*PromqlResponse) GetBody ¶
func (x *PromqlResponse) GetBody() []byte
func (*PromqlResponse) GetHeader ¶
func (x *PromqlResponse) GetHeader() *ResponseHeader
func (*PromqlResponse) ProtoMessage ¶
func (*PromqlResponse) ProtoMessage()
func (*PromqlResponse) ProtoReflect ¶
func (x *PromqlResponse) ProtoReflect() protoreflect.Message
func (*PromqlResponse) Reset ¶
func (x *PromqlResponse) Reset()
func (*PromqlResponse) String ¶
func (x *PromqlResponse) String() string
type QueryRequest ¶
type QueryRequest struct { // Types that are assignable to Query: // // *QueryRequest_Sql // *QueryRequest_LogicalPlan // *QueryRequest_PromRangeQuery Query isQueryRequest_Query `protobuf_oneof:"query"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetLogicalPlan ¶
func (x *QueryRequest) GetLogicalPlan() []byte
func (*QueryRequest) GetPromRangeQuery ¶
func (x *QueryRequest) GetPromRangeQuery() *PromRangeQuery
func (*QueryRequest) GetQuery ¶
func (m *QueryRequest) GetQuery() isQueryRequest_Query
func (*QueryRequest) GetSql ¶
func (x *QueryRequest) GetSql() string
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type QueryRequest_LogicalPlan ¶
type QueryRequest_LogicalPlan struct {
LogicalPlan []byte `protobuf:"bytes,2,opt,name=logical_plan,json=logicalPlan,proto3,oneof"`
}
type QueryRequest_PromRangeQuery ¶
type QueryRequest_PromRangeQuery struct {
PromRangeQuery *PromRangeQuery `protobuf:"bytes,3,opt,name=prom_range_query,json=promRangeQuery,proto3,oneof"`
}
type QueryRequest_Sql ¶
type QueryRequest_Sql struct {
Sql string `protobuf:"bytes,1,opt,name=sql,proto3,oneof"`
}
type RenameTable ¶
type RenameTable struct { NewTableName string `protobuf:"bytes,1,opt,name=new_table_name,json=newTableName,proto3" json:"new_table_name,omitempty"` // contains filtered or unexported fields }
func (*RenameTable) Descriptor
deprecated
func (*RenameTable) Descriptor() ([]byte, []int)
Deprecated: Use RenameTable.ProtoReflect.Descriptor instead.
func (*RenameTable) GetNewTableName ¶
func (x *RenameTable) GetNewTableName() string
func (*RenameTable) ProtoMessage ¶
func (*RenameTable) ProtoMessage()
func (*RenameTable) ProtoReflect ¶
func (x *RenameTable) ProtoReflect() protoreflect.Message
func (*RenameTable) Reset ¶
func (x *RenameTable) Reset()
func (*RenameTable) String ¶
func (x *RenameTable) String() string
type RequestHeader ¶
type RequestHeader struct { // The `catalog` that is selected to be used in this request. Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"` // The `schema` that is selected to be used in this request. Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` // The `authorization` header, much like http's authorization header. Authorization *AuthHeader `protobuf:"bytes,3,opt,name=authorization,proto3" json:"authorization,omitempty"` // The `dbname` for the request Dbname string `protobuf:"bytes,4,opt,name=dbname,proto3" json:"dbname,omitempty"` // TraceID of request TraceId uint64 `protobuf:"varint,5,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // SpanID of request SpanId uint64 `protobuf:"varint,6,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // contains filtered or unexported fields }
func (*RequestHeader) Descriptor
deprecated
func (*RequestHeader) Descriptor() ([]byte, []int)
Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.
func (*RequestHeader) GetAuthorization ¶
func (x *RequestHeader) GetAuthorization() *AuthHeader
func (*RequestHeader) GetCatalog ¶
func (x *RequestHeader) GetCatalog() string
func (*RequestHeader) GetDbname ¶
func (x *RequestHeader) GetDbname() string
func (*RequestHeader) GetSchema ¶
func (x *RequestHeader) GetSchema() string
func (*RequestHeader) GetSpanId ¶
func (x *RequestHeader) GetSpanId() uint64
func (*RequestHeader) GetTraceId ¶
func (x *RequestHeader) GetTraceId() uint64
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) ProtoReflect ¶
func (x *RequestHeader) ProtoReflect() protoreflect.Message
func (*RequestHeader) Reset ¶
func (x *RequestHeader) Reset()
func (*RequestHeader) String ¶
func (x *RequestHeader) String() string
type ResponseHeader ¶
type ResponseHeader struct { Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ResponseHeader) Descriptor
deprecated
func (*ResponseHeader) Descriptor() ([]byte, []int)
Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.
func (*ResponseHeader) GetStatus ¶
func (x *ResponseHeader) GetStatus() *Status
func (*ResponseHeader) ProtoMessage ¶
func (*ResponseHeader) ProtoMessage()
func (*ResponseHeader) ProtoReflect ¶
func (x *ResponseHeader) ProtoReflect() protoreflect.Message
func (*ResponseHeader) Reset ¶
func (x *ResponseHeader) Reset()
func (*ResponseHeader) String ¶
func (x *ResponseHeader) String() string
type Row ¶ added in v0.4.0
type Row struct { Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*Row) Descriptor
deprecated
added in
v0.4.0
func (*Row) ProtoMessage ¶ added in v0.4.0
func (*Row) ProtoMessage()
func (*Row) ProtoReflect ¶ added in v0.4.0
func (x *Row) ProtoReflect() protoreflect.Message
type RowDeleteRequest ¶ added in v0.4.0
type RowDeleteRequest struct { // The table name to delete from. Catalog name and schema name are in the // `RequestHeader`. TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // The data to delete. Rows *Rows `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
func (*RowDeleteRequest) Descriptor
deprecated
added in
v0.4.0
func (*RowDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use RowDeleteRequest.ProtoReflect.Descriptor instead.
func (*RowDeleteRequest) GetRows ¶ added in v0.4.0
func (x *RowDeleteRequest) GetRows() *Rows
func (*RowDeleteRequest) GetTableName ¶ added in v0.4.0
func (x *RowDeleteRequest) GetTableName() string
func (*RowDeleteRequest) ProtoMessage ¶ added in v0.4.0
func (*RowDeleteRequest) ProtoMessage()
func (*RowDeleteRequest) ProtoReflect ¶ added in v0.4.0
func (x *RowDeleteRequest) ProtoReflect() protoreflect.Message
func (*RowDeleteRequest) Reset ¶ added in v0.4.0
func (x *RowDeleteRequest) Reset()
func (*RowDeleteRequest) String ¶ added in v0.4.0
func (x *RowDeleteRequest) String() string
type RowDeleteRequests ¶ added in v0.4.0
type RowDeleteRequests struct { Deletes []*RowDeleteRequest `protobuf:"bytes,1,rep,name=deletes,proto3" json:"deletes,omitempty"` // contains filtered or unexported fields }
func (*RowDeleteRequests) Descriptor
deprecated
added in
v0.4.0
func (*RowDeleteRequests) Descriptor() ([]byte, []int)
Deprecated: Use RowDeleteRequests.ProtoReflect.Descriptor instead.
func (*RowDeleteRequests) GetDeletes ¶ added in v0.4.0
func (x *RowDeleteRequests) GetDeletes() []*RowDeleteRequest
func (*RowDeleteRequests) ProtoMessage ¶ added in v0.4.0
func (*RowDeleteRequests) ProtoMessage()
func (*RowDeleteRequests) ProtoReflect ¶ added in v0.4.0
func (x *RowDeleteRequests) ProtoReflect() protoreflect.Message
func (*RowDeleteRequests) Reset ¶ added in v0.4.0
func (x *RowDeleteRequests) Reset()
func (*RowDeleteRequests) String ¶ added in v0.4.0
func (x *RowDeleteRequests) String() string
type RowInsertRequest ¶ added in v0.4.0
type RowInsertRequest struct { TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Data is represented here. Rows *Rows `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
func (*RowInsertRequest) Descriptor
deprecated
added in
v0.4.0
func (*RowInsertRequest) Descriptor() ([]byte, []int)
Deprecated: Use RowInsertRequest.ProtoReflect.Descriptor instead.
func (*RowInsertRequest) GetRows ¶ added in v0.4.0
func (x *RowInsertRequest) GetRows() *Rows
func (*RowInsertRequest) GetTableName ¶ added in v0.4.0
func (x *RowInsertRequest) GetTableName() string
func (*RowInsertRequest) ProtoMessage ¶ added in v0.4.0
func (*RowInsertRequest) ProtoMessage()
func (*RowInsertRequest) ProtoReflect ¶ added in v0.4.0
func (x *RowInsertRequest) ProtoReflect() protoreflect.Message
func (*RowInsertRequest) Reset ¶ added in v0.4.0
func (x *RowInsertRequest) Reset()
func (*RowInsertRequest) String ¶ added in v0.4.0
func (x *RowInsertRequest) String() string
type RowInsertRequests ¶ added in v0.4.0
type RowInsertRequests struct { Inserts []*RowInsertRequest `protobuf:"bytes,1,rep,name=inserts,proto3" json:"inserts,omitempty"` // contains filtered or unexported fields }
func (*RowInsertRequests) Descriptor
deprecated
added in
v0.4.0
func (*RowInsertRequests) Descriptor() ([]byte, []int)
Deprecated: Use RowInsertRequests.ProtoReflect.Descriptor instead.
func (*RowInsertRequests) GetInserts ¶ added in v0.4.0
func (x *RowInsertRequests) GetInserts() []*RowInsertRequest
func (*RowInsertRequests) ProtoMessage ¶ added in v0.4.0
func (*RowInsertRequests) ProtoMessage()
func (*RowInsertRequests) ProtoReflect ¶ added in v0.4.0
func (x *RowInsertRequests) ProtoReflect() protoreflect.Message
func (*RowInsertRequests) Reset ¶ added in v0.4.0
func (x *RowInsertRequests) Reset()
func (*RowInsertRequests) String ¶ added in v0.4.0
func (x *RowInsertRequests) String() string
type Rows ¶ added in v0.4.0
type Rows struct { Schema []*ColumnSchema `protobuf:"bytes,1,rep,name=schema,proto3" json:"schema,omitempty"` Rows []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
func (*Rows) Descriptor
deprecated
added in
v0.4.0
func (*Rows) GetSchema ¶ added in v0.4.0
func (x *Rows) GetSchema() []*ColumnSchema
func (*Rows) ProtoMessage ¶ added in v0.4.0
func (*Rows) ProtoMessage()
func (*Rows) ProtoReflect ¶ added in v0.4.0
func (x *Rows) ProtoReflect() protoreflect.Message
type SemanticType ¶ added in v0.4.0
type SemanticType int32
const ( SemanticType_TAG SemanticType = 0 SemanticType_FIELD SemanticType = 1 SemanticType_TIMESTAMP SemanticType = 2 )
func (SemanticType) Descriptor ¶ added in v0.4.0
func (SemanticType) Descriptor() protoreflect.EnumDescriptor
func (SemanticType) Enum ¶ added in v0.4.0
func (x SemanticType) Enum() *SemanticType
func (SemanticType) EnumDescriptor
deprecated
added in
v0.4.0
func (SemanticType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SemanticType.Descriptor instead.
func (SemanticType) Number ¶ added in v0.4.0
func (x SemanticType) Number() protoreflect.EnumNumber
func (SemanticType) String ¶ added in v0.4.0
func (x SemanticType) String() string
func (SemanticType) Type ¶ added in v0.4.0
func (SemanticType) Type() protoreflect.EnumType
type Status ¶
type Status struct { // Corresponding to the `StatusCode` definition of GreptimeDB StatusCode uint32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"` // contains filtered or unexported fields }
func (*Status) Descriptor
deprecated
func (*Status) GetStatusCode ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type TableId ¶
type TableId struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*TableId) Descriptor
deprecated
func (*TableId) ProtoMessage ¶
func (*TableId) ProtoMessage()
func (*TableId) ProtoReflect ¶
func (x *TableId) ProtoReflect() protoreflect.Message
type Token ¶
type Token struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*Token) Descriptor
deprecated
func (*Token) ProtoMessage ¶
func (*Token) ProtoMessage()
func (*Token) ProtoReflect ¶
func (x *Token) ProtoReflect() protoreflect.Message
type TruncateTableExpr ¶
type TruncateTableExpr struct { CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` TableId *TableId `protobuf:"bytes,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` // contains filtered or unexported fields }
func (*TruncateTableExpr) Descriptor
deprecated
func (*TruncateTableExpr) Descriptor() ([]byte, []int)
Deprecated: Use TruncateTableExpr.ProtoReflect.Descriptor instead.
func (*TruncateTableExpr) GetCatalogName ¶
func (x *TruncateTableExpr) GetCatalogName() string
func (*TruncateTableExpr) GetSchemaName ¶
func (x *TruncateTableExpr) GetSchemaName() string
func (*TruncateTableExpr) GetTableId ¶
func (x *TruncateTableExpr) GetTableId() *TableId
func (*TruncateTableExpr) GetTableName ¶
func (x *TruncateTableExpr) GetTableName() string
func (*TruncateTableExpr) ProtoMessage ¶
func (*TruncateTableExpr) ProtoMessage()
func (*TruncateTableExpr) ProtoReflect ¶
func (x *TruncateTableExpr) ProtoReflect() protoreflect.Message
func (*TruncateTableExpr) Reset ¶
func (x *TruncateTableExpr) Reset()
func (*TruncateTableExpr) String ¶
func (x *TruncateTableExpr) String() string
type UnimplementedGreptimeDatabaseServer ¶
type UnimplementedGreptimeDatabaseServer struct { }
UnimplementedGreptimeDatabaseServer must be embedded to have forward compatible implementations.
func (UnimplementedGreptimeDatabaseServer) Handle ¶
func (UnimplementedGreptimeDatabaseServer) Handle(context.Context, *GreptimeRequest) (*GreptimeResponse, error)
func (UnimplementedGreptimeDatabaseServer) HandleRequests ¶
func (UnimplementedGreptimeDatabaseServer) HandleRequests(GreptimeDatabase_HandleRequestsServer) error
type UnimplementedHealthCheckServer ¶
type UnimplementedHealthCheckServer struct { }
UnimplementedHealthCheckServer must be embedded to have forward compatible implementations.
func (UnimplementedHealthCheckServer) HealthCheck ¶
func (UnimplementedHealthCheckServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
type UnimplementedPrometheusGatewayServer ¶
type UnimplementedPrometheusGatewayServer struct { }
UnimplementedPrometheusGatewayServer must be embedded to have forward compatible implementations.
func (UnimplementedPrometheusGatewayServer) Handle ¶
func (UnimplementedPrometheusGatewayServer) Handle(context.Context, *PromqlRequest) (*PromqlResponse, error)
type UnsafeGreptimeDatabaseServer ¶
type UnsafeGreptimeDatabaseServer interface {
// contains filtered or unexported methods
}
UnsafeGreptimeDatabaseServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GreptimeDatabaseServer will result in compilation errors.
type UnsafeHealthCheckServer ¶
type UnsafeHealthCheckServer interface {
// contains filtered or unexported methods
}
UnsafeHealthCheckServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthCheckServer will result in compilation errors.
type UnsafePrometheusGatewayServer ¶
type UnsafePrometheusGatewayServer interface {
// contains filtered or unexported methods
}
UnsafePrometheusGatewayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PrometheusGatewayServer will result in compilation errors.
type Value ¶ added in v0.4.0
type Value struct { // Types that are assignable to ValueData: // // *Value_I8Value // *Value_I16Value // *Value_I32Value // *Value_I64Value // *Value_U8Value // *Value_U16Value // *Value_U32Value // *Value_U64Value // *Value_F32Value // *Value_F64Value // *Value_BoolValue // *Value_BinaryValue // *Value_StringValue // *Value_DateValue // *Value_DatetimeValue // *Value_TimestampSecondValue // *Value_TimestampMillisecondValue // *Value_TimestampMicrosecondValue // *Value_TimestampNanosecondValue // *Value_TimeSecondValue // *Value_TimeMillisecondValue // *Value_TimeMicrosecondValue // *Value_TimeNanosecondValue // *Value_IntervalYearMonthValues // *Value_IntervalDayTimeValues // *Value_IntervalMonthDayNanoValues ValueData isValue_ValueData `protobuf_oneof:"value_data"` // contains filtered or unexported fields }
func (*Value) Descriptor
deprecated
added in
v0.4.0
func (*Value) GetBinaryValue ¶ added in v0.4.0
func (*Value) GetBoolValue ¶ added in v0.4.0
func (*Value) GetDateValue ¶ added in v0.4.0
func (*Value) GetDatetimeValue ¶ added in v0.4.0
func (*Value) GetF32Value ¶ added in v0.4.0
func (*Value) GetF64Value ¶ added in v0.4.0
func (*Value) GetI16Value ¶ added in v0.4.0
func (*Value) GetI32Value ¶ added in v0.4.0
func (*Value) GetI64Value ¶ added in v0.4.0
func (*Value) GetI8Value ¶ added in v0.4.0
func (*Value) GetIntervalDayTimeValues ¶ added in v0.4.0
func (*Value) GetIntervalMonthDayNanoValues ¶ added in v0.4.0
func (x *Value) GetIntervalMonthDayNanoValues() *IntervalMonthDayNano
func (*Value) GetIntervalYearMonthValues ¶ added in v0.4.0
func (*Value) GetStringValue ¶ added in v0.4.0
func (*Value) GetTimeMicrosecondValue ¶ added in v0.4.0
func (*Value) GetTimeMillisecondValue ¶ added in v0.4.0
func (*Value) GetTimeNanosecondValue ¶ added in v0.4.0
func (*Value) GetTimeSecondValue ¶ added in v0.4.0
func (*Value) GetTimestampMicrosecondValue ¶ added in v0.4.0
func (*Value) GetTimestampMillisecondValue ¶ added in v0.4.0
func (*Value) GetTimestampNanosecondValue ¶ added in v0.4.0
func (*Value) GetTimestampSecondValue ¶ added in v0.4.0
func (*Value) GetU16Value ¶ added in v0.4.0
func (*Value) GetU32Value ¶ added in v0.4.0
func (*Value) GetU64Value ¶ added in v0.4.0
func (*Value) GetU8Value ¶ added in v0.4.0
func (*Value) GetValueData ¶ added in v0.4.0
func (m *Value) GetValueData() isValue_ValueData
func (*Value) ProtoMessage ¶ added in v0.4.0
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶ added in v0.4.0
func (x *Value) ProtoReflect() protoreflect.Message
type Value_BinaryValue ¶ added in v0.4.0
type Value_BinaryValue struct {
BinaryValue []byte `protobuf:"bytes,12,opt,name=binary_value,json=binaryValue,proto3,oneof"`
}
type Value_BoolValue ¶ added in v0.4.0
type Value_BoolValue struct {
BoolValue bool `protobuf:"varint,11,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
type Value_DateValue ¶ added in v0.4.0
type Value_DateValue struct {
DateValue int32 `protobuf:"varint,14,opt,name=date_value,json=dateValue,proto3,oneof"`
}
type Value_DatetimeValue ¶ added in v0.4.0
type Value_DatetimeValue struct {
DatetimeValue int64 `protobuf:"varint,15,opt,name=datetime_value,json=datetimeValue,proto3,oneof"`
}
type Value_F32Value ¶ added in v0.4.0
type Value_F32Value struct {
F32Value float32 `protobuf:"fixed32,9,opt,name=f32_value,json=f32Value,proto3,oneof"`
}
type Value_F64Value ¶ added in v0.4.0
type Value_F64Value struct {
F64Value float64 `protobuf:"fixed64,10,opt,name=f64_value,json=f64Value,proto3,oneof"`
}
type Value_I16Value ¶ added in v0.4.0
type Value_I16Value struct {
I16Value int32 `protobuf:"varint,2,opt,name=i16_value,json=i16Value,proto3,oneof"`
}
type Value_I32Value ¶ added in v0.4.0
type Value_I32Value struct {
I32Value int32 `protobuf:"varint,3,opt,name=i32_value,json=i32Value,proto3,oneof"`
}
type Value_I64Value ¶ added in v0.4.0
type Value_I64Value struct {
I64Value int64 `protobuf:"varint,4,opt,name=i64_value,json=i64Value,proto3,oneof"`
}
type Value_I8Value ¶ added in v0.4.0
type Value_I8Value struct {
I8Value int32 `protobuf:"varint,1,opt,name=i8_value,json=i8Value,proto3,oneof"`
}
type Value_IntervalDayTimeValues ¶ added in v0.4.0
type Value_IntervalDayTimeValues struct {
IntervalDayTimeValues int64 `protobuf:"varint,25,opt,name=interval_day_time_values,json=intervalDayTimeValues,proto3,oneof"`
}
type Value_IntervalMonthDayNanoValues ¶ added in v0.4.0
type Value_IntervalMonthDayNanoValues struct {
IntervalMonthDayNanoValues *IntervalMonthDayNano `protobuf:"bytes,26,opt,name=interval_month_day_nano_values,json=intervalMonthDayNanoValues,proto3,oneof"`
}
type Value_IntervalYearMonthValues ¶ added in v0.4.0
type Value_IntervalYearMonthValues struct {
IntervalYearMonthValues int32 `protobuf:"varint,24,opt,name=interval_year_month_values,json=intervalYearMonthValues,proto3,oneof"`
}
type Value_StringValue ¶ added in v0.4.0
type Value_StringValue struct {
StringValue string `protobuf:"bytes,13,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type Value_TimeMicrosecondValue ¶ added in v0.4.0
type Value_TimeMicrosecondValue struct {
TimeMicrosecondValue int64 `protobuf:"varint,22,opt,name=time_microsecond_value,json=timeMicrosecondValue,proto3,oneof"`
}
type Value_TimeMillisecondValue ¶ added in v0.4.0
type Value_TimeMillisecondValue struct {
TimeMillisecondValue int64 `protobuf:"varint,21,opt,name=time_millisecond_value,json=timeMillisecondValue,proto3,oneof"`
}
type Value_TimeNanosecondValue ¶ added in v0.4.0
type Value_TimeNanosecondValue struct {
TimeNanosecondValue int64 `protobuf:"varint,23,opt,name=time_nanosecond_value,json=timeNanosecondValue,proto3,oneof"`
}
type Value_TimeSecondValue ¶ added in v0.4.0
type Value_TimeSecondValue struct {
TimeSecondValue int64 `protobuf:"varint,20,opt,name=time_second_value,json=timeSecondValue,proto3,oneof"`
}
type Value_TimestampMicrosecondValue ¶ added in v0.4.0
type Value_TimestampMicrosecondValue struct {
TimestampMicrosecondValue int64 `protobuf:"varint,18,opt,name=timestamp_microsecond_value,json=timestampMicrosecondValue,proto3,oneof"`
}
type Value_TimestampMillisecondValue ¶ added in v0.4.0
type Value_TimestampMillisecondValue struct {
TimestampMillisecondValue int64 `protobuf:"varint,17,opt,name=timestamp_millisecond_value,json=timestampMillisecondValue,proto3,oneof"`
}
type Value_TimestampNanosecondValue ¶ added in v0.4.0
type Value_TimestampNanosecondValue struct {
TimestampNanosecondValue int64 `protobuf:"varint,19,opt,name=timestamp_nanosecond_value,json=timestampNanosecondValue,proto3,oneof"`
}
type Value_TimestampSecondValue ¶ added in v0.4.0
type Value_TimestampSecondValue struct {
TimestampSecondValue int64 `protobuf:"varint,16,opt,name=timestamp_second_value,json=timestampSecondValue,proto3,oneof"`
}
type Value_U16Value ¶ added in v0.4.0
type Value_U16Value struct {
U16Value uint32 `protobuf:"varint,6,opt,name=u16_value,json=u16Value,proto3,oneof"`
}
type Value_U32Value ¶ added in v0.4.0
type Value_U32Value struct {
U32Value uint32 `protobuf:"varint,7,opt,name=u32_value,json=u32Value,proto3,oneof"`
}
type Value_U64Value ¶ added in v0.4.0
type Value_U64Value struct {
U64Value uint64 `protobuf:"varint,8,opt,name=u64_value,json=u64Value,proto3,oneof"`
}
type Value_U8Value ¶ added in v0.4.0
type Value_U8Value struct {
U8Value uint32 `protobuf:"varint,5,opt,name=u8_value,json=u8Value,proto3,oneof"`
}
type WalEntry ¶ added in v0.4.0
type WalEntry struct { // List of mutations for a region. Mutations []*Mutation `protobuf:"bytes,1,rep,name=mutations,proto3" json:"mutations,omitempty"` // contains filtered or unexported fields }
A WAL entry contains a list of mutations for a region to write.
func (*WalEntry) Descriptor
deprecated
added in
v0.4.0
func (*WalEntry) GetMutations ¶ added in v0.4.0
func (*WalEntry) ProtoMessage ¶ added in v0.4.0
func (*WalEntry) ProtoMessage()
func (*WalEntry) ProtoReflect ¶ added in v0.4.0
func (x *WalEntry) ProtoReflect() protoreflect.Message