v1

package

Go to main page

Versions in this module

v0

v0.9.0

Oct 30, 2024

Changes in this version

+ var JsonTypeExtension_name = map[int32]string

+ var JsonTypeExtension_value = map[string]int32

type AlterExpr

+ func (x *AlterExpr) GetChangeTableOptions() *ChangeTableOptions

+ type AlterExpr_ChangeTableOptions struct

+ ChangeTableOptions *ChangeTableOptions

+ type ChangeTableOption struct

+ Key string

+ Value string

+ func (*ChangeTableOption) Descriptor() ([]byte, []int)

+ func (*ChangeTableOption) ProtoMessage()

+ func (x *ChangeTableOption) GetKey() string

+ func (x *ChangeTableOption) GetValue() string

+ func (x *ChangeTableOption) ProtoReflect() protoreflect.Message

+ func (x *ChangeTableOption) Reset()

+ func (x *ChangeTableOption) String() string

+ type ChangeTableOptions struct

+ ChangeTableOptions []*ChangeTableOption

+ func (*ChangeTableOptions) Descriptor() ([]byte, []int)

+ func (*ChangeTableOptions) ProtoMessage()

+ func (x *ChangeTableOptions) GetChangeTableOptions() []*ChangeTableOption

+ func (x *ChangeTableOptions) ProtoReflect() protoreflect.Message

+ func (x *ChangeTableOptions) Reset()

+ func (x *ChangeTableOptions) String() string

type Column

+ Options *ColumnOptions

+ func (x *Column) GetOptions() *ColumnOptions

type ColumnDataType

+ const ColumnDataType_JSON

type ColumnDataTypeExtension

+ func (x *ColumnDataTypeExtension) GetJsonType() JsonTypeExtension

+ type ColumnDataTypeExtension_JsonType struct

+ JsonType JsonTypeExtension

type ColumnDef

+ Options *ColumnOptions

+ func (x *ColumnDef) GetOptions() *ColumnOptions

+ type ColumnOptions struct

+ Options map[string]string

+ func (*ColumnOptions) Descriptor() ([]byte, []int)

+ func (*ColumnOptions) ProtoMessage()

+ func (x *ColumnOptions) GetOptions() map[string]string

+ func (x *ColumnOptions) ProtoReflect() protoreflect.Message

+ func (x *ColumnOptions) Reset()

+ func (x *ColumnOptions) String() string

type ColumnSchema

+ Options *ColumnOptions

+ func (x *ColumnSchema) GetOptions() *ColumnOptions

+ type CreateFlowExpr struct

+ CatalogName string

+ Comment string

+ CreateIfNotExists bool

+ ExpireAfter *ExpireAfter

+ FlowName string

+ FlowOptions map[string]string

+ OrReplace bool

+ SinkTableName *TableName

+ SourceTableNames []*TableName

+ Sql string

+ func (*CreateFlowExpr) Descriptor() ([]byte, []int)

+ func (*CreateFlowExpr) ProtoMessage()

+ func (x *CreateFlowExpr) GetCatalogName() string

+ func (x *CreateFlowExpr) GetComment() string

+ func (x *CreateFlowExpr) GetCreateIfNotExists() bool

+ func (x *CreateFlowExpr) GetExpireAfter() *ExpireAfter

+ func (x *CreateFlowExpr) GetFlowName() string

+ func (x *CreateFlowExpr) GetFlowOptions() map[string]string

+ func (x *CreateFlowExpr) GetOrReplace() bool

+ func (x *CreateFlowExpr) GetSinkTableName() *TableName

+ func (x *CreateFlowExpr) GetSourceTableNames() []*TableName

+ func (x *CreateFlowExpr) GetSql() string

+ func (x *CreateFlowExpr) ProtoReflect() protoreflect.Message

+ func (x *CreateFlowExpr) Reset()

+ func (x *CreateFlowExpr) String() string

+ type CreateViewExpr struct

+ CatalogName string

+ Columns []string

+ CreateIfNotExists bool

+ Definition string

+ LogicalPlan []byte

+ OrReplace bool

+ PlanColumns []string

+ SchemaName string

+ TableNames []*TableName

+ ViewName string

+ func (*CreateViewExpr) Descriptor() ([]byte, []int)

+ func (*CreateViewExpr) ProtoMessage()

+ func (x *CreateViewExpr) GetCatalogName() string

+ func (x *CreateViewExpr) GetColumns() []string

+ func (x *CreateViewExpr) GetCreateIfNotExists() bool

+ func (x *CreateViewExpr) GetDefinition() string

+ func (x *CreateViewExpr) GetLogicalPlan() []byte

+ func (x *CreateViewExpr) GetOrReplace() bool

+ func (x *CreateViewExpr) GetPlanColumns() []string

+ func (x *CreateViewExpr) GetSchemaName() string

+ func (x *CreateViewExpr) GetTableNames() []*TableName

+ func (x *CreateViewExpr) GetViewName() string

+ func (x *CreateViewExpr) ProtoReflect() protoreflect.Message

+ func (x *CreateViewExpr) Reset()

+ func (x *CreateViewExpr) String() string

type DdlRequest

+ func (x *DdlRequest) GetCreateFlow() *CreateFlowExpr

+ func (x *DdlRequest) GetCreateView() *CreateViewExpr

+ func (x *DdlRequest) GetDropFlow() *DropFlowExpr

+ func (x *DdlRequest) GetDropView() *DropViewExpr

+ type DdlRequest_CreateFlow struct

+ CreateFlow *CreateFlowExpr

+ type DdlRequest_CreateView struct

+ CreateView *CreateViewExpr

+ type DdlRequest_DropFlow struct

+ DropFlow *DropFlowExpr

+ type DdlRequest_DropView struct

+ DropView *DropViewExpr

+ type DropFlowExpr struct

+ CatalogName string

+ DropIfExists bool

+ FlowId *FlowId

+ FlowName string

+ func (*DropFlowExpr) Descriptor() ([]byte, []int)

+ func (*DropFlowExpr) ProtoMessage()

+ func (x *DropFlowExpr) GetCatalogName() string

+ func (x *DropFlowExpr) GetDropIfExists() bool

+ func (x *DropFlowExpr) GetFlowId() *FlowId

+ func (x *DropFlowExpr) GetFlowName() string

+ func (x *DropFlowExpr) ProtoReflect() protoreflect.Message

+ func (x *DropFlowExpr) Reset()

+ func (x *DropFlowExpr) String() string

+ type DropViewExpr struct

+ CatalogName string

+ DropIfExists bool

+ SchemaName string

+ ViewId *TableId

+ ViewName string

+ func (*DropViewExpr) Descriptor() ([]byte, []int)

+ func (*DropViewExpr) ProtoMessage()

+ func (x *DropViewExpr) GetCatalogName() string

+ func (x *DropViewExpr) GetDropIfExists() bool

+ func (x *DropViewExpr) GetSchemaName() string

+ func (x *DropViewExpr) GetViewId() *TableId

+ func (x *DropViewExpr) GetViewName() string

+ func (x *DropViewExpr) ProtoReflect() protoreflect.Message

+ func (x *DropViewExpr) Reset()

+ func (x *DropViewExpr) String() string

+ type ExpireAfter struct

+ Value int64

+ func (*ExpireAfter) Descriptor() ([]byte, []int)

+ func (*ExpireAfter) ProtoMessage()

+ func (x *ExpireAfter) GetValue() int64

+ func (x *ExpireAfter) ProtoReflect() protoreflect.Message

+ func (x *ExpireAfter) Reset()

+ func (x *ExpireAfter) String() string

+ type FlowId struct

+ Id uint32

+ func (*FlowId) Descriptor() ([]byte, []int)

+ func (*FlowId) ProtoMessage()

+ func (x *FlowId) GetId() uint32

+ func (x *FlowId) ProtoReflect() protoreflect.Message

+ func (x *FlowId) Reset()

+ func (x *FlowId) String() string

+ type JsonTypeExtension int32

+ const JsonTypeExtension_JSON_BINARY

+ func (JsonTypeExtension) Descriptor() protoreflect.EnumDescriptor

+ func (JsonTypeExtension) EnumDescriptor() ([]byte, []int)

+ func (JsonTypeExtension) Type() protoreflect.EnumType

+ func (x JsonTypeExtension) Enum() *JsonTypeExtension

+ func (x JsonTypeExtension) Number() protoreflect.EnumNumber

+ func (x JsonTypeExtension) String() string

+ type QueryContext struct

+ Channel uint32

+ CurrentCatalog string

+ CurrentSchema string

+ Extensions map[string]string

+ Timezone string

+ func (*QueryContext) Descriptor() ([]byte, []int)

+ func (*QueryContext) ProtoMessage()

+ func (x *QueryContext) GetChannel() uint32

+ func (x *QueryContext) GetCurrentCatalog() string

+ func (x *QueryContext) GetCurrentSchema() string

+ func (x *QueryContext) GetExtensions() map[string]string

+ func (x *QueryContext) GetTimezone() string

+ func (x *QueryContext) ProtoReflect() protoreflect.Message

+ func (x *QueryContext) Reset()

+ func (x *QueryContext) String() string

v0.7.0

Apr 29, 2024

Changes in this version

type AlterExpr

+ func (x *AlterExpr) GetChangeColumnTypes() *ChangeColumnTypes

+ type AlterExpr_ChangeColumnTypes struct

+ ChangeColumnTypes *ChangeColumnTypes

+ type ChangeColumnType struct

+ ColumnName string

+ TargetType ColumnDataType

+ TargetTypeExtension *ColumnDataTypeExtension

+ func (*ChangeColumnType) Descriptor() ([]byte, []int)

+ func (*ChangeColumnType) ProtoMessage()

+ func (x *ChangeColumnType) GetColumnName() string

+ func (x *ChangeColumnType) GetTargetType() ColumnDataType

+ func (x *ChangeColumnType) GetTargetTypeExtension() *ColumnDataTypeExtension

+ func (x *ChangeColumnType) ProtoReflect() protoreflect.Message

+ func (x *ChangeColumnType) Reset()

+ func (x *ChangeColumnType) String() string

+ type ChangeColumnTypes struct

+ ChangeColumnTypes []*ChangeColumnType

+ func (*ChangeColumnTypes) Descriptor() ([]byte, []int)

+ func (*ChangeColumnTypes) ProtoMessage()

+ func (x *ChangeColumnTypes) GetChangeColumnTypes() []*ChangeColumnType

+ func (x *ChangeColumnTypes) ProtoReflect() protoreflect.Message

+ func (x *ChangeColumnTypes) Reset()

+ func (x *ChangeColumnTypes) String() string

type CreateDatabaseExpr

+ CatalogName string

+ SchemaName string

+ func (x *CreateDatabaseExpr) GetCatalogName() string

+ func (x *CreateDatabaseExpr) GetSchemaName() string

+ type CreateFlowTaskExpr struct

+ CatalogName string

+ Comment string

+ CreateIfNotExists bool

+ ExpireWhen string

+ OrReplace bool

+ SinkTableName *TableName

+ SourceTableNames []*TableName

+ Sql string

+ TaskName string

+ TaskOptions map[string]string

+ func (*CreateFlowTaskExpr) Descriptor() ([]byte, []int)

+ func (*CreateFlowTaskExpr) ProtoMessage()

+ func (x *CreateFlowTaskExpr) GetCatalogName() string

+ func (x *CreateFlowTaskExpr) GetComment() string

+ func (x *CreateFlowTaskExpr) GetCreateIfNotExists() bool

+ func (x *CreateFlowTaskExpr) GetExpireWhen() string

+ func (x *CreateFlowTaskExpr) GetOrReplace() bool

+ func (x *CreateFlowTaskExpr) GetSinkTableName() *TableName

+ func (x *CreateFlowTaskExpr) GetSourceTableNames() []*TableName

+ func (x *CreateFlowTaskExpr) GetSql() string

+ func (x *CreateFlowTaskExpr) GetTaskName() string

+ func (x *CreateFlowTaskExpr) GetTaskOptions() map[string]string

+ func (x *CreateFlowTaskExpr) ProtoReflect() protoreflect.Message

+ func (x *CreateFlowTaskExpr) Reset()

+ func (x *CreateFlowTaskExpr) String() string

type DdlRequest

+ func (x *DdlRequest) GetCreateFlowTask() *CreateFlowTaskExpr

+ func (x *DdlRequest) GetDropFlowTask() *DropFlowTaskExpr

+ type DdlRequest_CreateFlowTask struct

+ CreateFlowTask *CreateFlowTaskExpr

+ type DdlRequest_DropFlowTask struct

+ DropFlowTask *DropFlowTaskExpr

+ type DropDatabaseExpr struct

+ CatalogName string

+ DropIfExists bool

+ SchemaName string

+ func (*DropDatabaseExpr) Descriptor() ([]byte, []int)

+ func (*DropDatabaseExpr) ProtoMessage()

+ func (x *DropDatabaseExpr) GetCatalogName() string

+ func (x *DropDatabaseExpr) GetDropIfExists() bool

+ func (x *DropDatabaseExpr) GetSchemaName() string

+ func (x *DropDatabaseExpr) ProtoReflect() protoreflect.Message

+ func (x *DropDatabaseExpr) Reset()

+ func (x *DropDatabaseExpr) String() string

+ type DropFlowTaskExpr struct

+ CatalogName string

+ TaskName string

+ func (*DropFlowTaskExpr) Descriptor() ([]byte, []int)

+ func (*DropFlowTaskExpr) ProtoMessage()

+ func (x *DropFlowTaskExpr) GetCatalogName() string

+ func (x *DropFlowTaskExpr) GetTaskName() string

+ func (x *DropFlowTaskExpr) ProtoReflect() protoreflect.Message

+ func (x *DropFlowTaskExpr) Reset()

+ func (x *DropFlowTaskExpr) String() string

type PromInstantQuery

+ Lookback string

+ func (x *PromInstantQuery) GetLookback() string

type PromRangeQuery

+ Lookback string

+ func (x *PromRangeQuery) GetLookback() string

+ type TableName struct

+ CatalogName string

+ SchemaName string

+ TableName string

+ func (*TableName) Descriptor() ([]byte, []int)

+ func (*TableName) ProtoMessage()

+ func (x *TableName) GetCatalogName() string

+ func (x *TableName) GetSchemaName() string

+ func (x *TableName) GetTableName() string

+ func (x *TableName) ProtoReflect() protoreflect.Message

+ func (x *TableName) Reset()

+ func (x *TableName) String() string

v0.4.3

Jan 22, 2024

Changes in this version

type FlightMetadata

+ Metrics *Metrics

+ func (x *FlightMetadata) GetMetrics() *Metrics

+ type Metrics struct

+ Metrics []byte

+ func (*Metrics) Descriptor() ([]byte, []int)

+ func (*Metrics) ProtoMessage()

+ func (x *Metrics) GetMetrics() []byte

+ func (x *Metrics) ProtoReflect() protoreflect.Message

+ func (x *Metrics) Reset()

+ func (x *Metrics) String() string

type RequestHeader

+ Timezone string

+ func (x *RequestHeader) GetTimezone() string

v0.4.2

Dec 15, 2023

Changes in this version

type Value

+ func (x *Value) GetIntervalDayTimeValue() int64

+ func (x *Value) GetIntervalMonthDayNanoValue() *IntervalMonthDayNano

+ func (x *Value) GetIntervalYearMonthValue() int32

+ type Value_IntervalDayTimeValue struct

+ IntervalDayTimeValue int64

+ type Value_IntervalMonthDayNanoValue struct

+ IntervalMonthDayNanoValue *IntervalMonthDayNano

+ type Value_IntervalYearMonthValue struct

+ IntervalYearMonthValue int32

v0.4.1

Dec 14, 2023

Changes in this version

type Column

+ DatatypeExtension *ColumnDataTypeExtension

+ func (x *Column) GetDatatypeExtension() *ColumnDataTypeExtension

type ColumnDataType

+ const ColumnDataType_DECIMAL128

+ const ColumnDataType_DURATION_MICROSECOND

+ const ColumnDataType_DURATION_MILLISECOND

+ const ColumnDataType_DURATION_NANOSECOND

+ const ColumnDataType_DURATION_SECOND

+ type ColumnDataTypeExtension struct

+ TypeExt isColumnDataTypeExtension_TypeExt

+ func (*ColumnDataTypeExtension) Descriptor() ([]byte, []int)

+ func (*ColumnDataTypeExtension) ProtoMessage()

+ func (m *ColumnDataTypeExtension) GetTypeExt() isColumnDataTypeExtension_TypeExt

+ func (x *ColumnDataTypeExtension) GetDecimalType() *DecimalTypeExtension

+ func (x *ColumnDataTypeExtension) ProtoReflect() protoreflect.Message

+ func (x *ColumnDataTypeExtension) Reset()

+ func (x *ColumnDataTypeExtension) String() string

+ type ColumnDataTypeExtension_DecimalType struct

+ DecimalType *DecimalTypeExtension

type ColumnDef

+ Comment string

+ DatatypeExtension *ColumnDataTypeExtension

+ func (x *ColumnDef) GetComment() string

+ func (x *ColumnDef) GetDatatypeExtension() *ColumnDataTypeExtension

type ColumnSchema

+ DatatypeExtension *ColumnDataTypeExtension

+ func (x *ColumnSchema) GetDatatypeExtension() *ColumnDataTypeExtension

type Column_Values

+ Decimal128Values []*Decimal128

+ DurationMicrosecondValues []int64

+ DurationMillisecondValues []int64

+ DurationNanosecondValues []int64

+ DurationSecondValues []int64

+ func (x *Column_Values) GetDecimal128Values() []*Decimal128

+ func (x *Column_Values) GetDurationMicrosecondValues() []int64

+ func (x *Column_Values) GetDurationMillisecondValues() []int64

+ func (x *Column_Values) GetDurationNanosecondValues() []int64

+ func (x *Column_Values) GetDurationSecondValues() []int64

+ type Decimal128 struct

+ Hi int64

+ Lo int64

+ func (*Decimal128) Descriptor() ([]byte, []int)

+ func (*Decimal128) ProtoMessage()

+ func (x *Decimal128) GetHi() int64

+ func (x *Decimal128) GetLo() int64

+ func (x *Decimal128) ProtoReflect() protoreflect.Message

+ func (x *Decimal128) Reset()

+ func (x *Decimal128) String() string

+ type DecimalTypeExtension struct

+ Precision int32

+ Scale int32

+ func (*DecimalTypeExtension) Descriptor() ([]byte, []int)

+ func (*DecimalTypeExtension) ProtoMessage()

+ func (x *DecimalTypeExtension) GetPrecision() int32

+ func (x *DecimalTypeExtension) GetScale() int32

+ func (x *DecimalTypeExtension) ProtoReflect() protoreflect.Message

+ func (x *DecimalTypeExtension) Reset()

+ func (x *DecimalTypeExtension) String() string

type DropTableExpr

+ DropIfExists bool

+ func (x *DropTableExpr) GetDropIfExists() bool

type RequestHeader

+ TracingContext map[string]string

+ func (x *RequestHeader) GetTracingContext() map[string]string

type Value

+ func (x *Value) GetDecimal128Value() *Decimal128

+ func (x *Value) GetDurationMicrosecondValue() int64

+ func (x *Value) GetDurationMillisecondValue() int64

+ func (x *Value) GetDurationNanosecondValue() int64

+ func (x *Value) GetDurationSecondValue() int64

+ type Value_Decimal128Value struct

+ Decimal128Value *Decimal128

+ type Value_DurationMicrosecondValue struct

+ DurationMicrosecondValue int64

+ type Value_DurationMillisecondValue struct

+ DurationMillisecondValue int64

+ type Value_DurationNanosecondValue struct

+ DurationNanosecondValue int64

+ type Value_DurationSecondValue struct

+ DurationSecondValue int64

v0.4.0

Sep 6, 2023

Changes in this version

+ var AddColumnLocation_LocationType_name = map[int32]string

+ var AddColumnLocation_LocationType_value = map[string]int32

+ var File_greptime_v1_row_proto protoreflect.FileDescriptor

+ var File_greptime_v1_wal_proto protoreflect.FileDescriptor

+ var OpType_name = map[int32]string

+ var OpType_value = map[string]int32

+ var SemanticType_name = map[int32]string

+ var SemanticType_value = map[string]int32

+ type AddColumnLocation struct

+ AfterColumnName string

+ LocationType AddColumnLocation_LocationType

+ func (*AddColumnLocation) Descriptor() ([]byte, []int)

+ func (*AddColumnLocation) ProtoMessage()

+ func (x *AddColumnLocation) GetAfterColumnName() string

+ func (x *AddColumnLocation) GetLocationType() AddColumnLocation_LocationType

+ func (x *AddColumnLocation) ProtoReflect() protoreflect.Message

+ func (x *AddColumnLocation) Reset()

+ func (x *AddColumnLocation) String() string

+ type AddColumnLocation_LocationType int32

+ const AddColumnLocation_AFTER

+ const AddColumnLocation_FIRST

+ func (AddColumnLocation_LocationType) Descriptor() protoreflect.EnumDescriptor

+ func (AddColumnLocation_LocationType) EnumDescriptor() ([]byte, []int)

+ func (AddColumnLocation_LocationType) Type() protoreflect.EnumType

+ func (x AddColumnLocation_LocationType) Enum() *AddColumnLocation_LocationType

+ func (x AddColumnLocation_LocationType) Number() protoreflect.EnumNumber

+ func (x AddColumnLocation_LocationType) String() string

type ColumnDataType

+ const ColumnDataType_INTERVAL_DAY_TIME

+ const ColumnDataType_INTERVAL_MONTH_DAY_NANO

+ const ColumnDataType_INTERVAL_YEAR_MONTH

type ColumnDef

+ DataType ColumnDataType

+ SemanticType SemanticType

+ func (x *ColumnDef) GetDataType() ColumnDataType

+ func (x *ColumnDef) GetSemanticType() SemanticType

+ type ColumnSchema struct

+ ColumnName string

+ Datatype ColumnDataType

+ SemanticType SemanticType

+ func (*ColumnSchema) Descriptor() ([]byte, []int)

+ func (*ColumnSchema) ProtoMessage()

+ func (x *ColumnSchema) GetColumnName() string

+ func (x *ColumnSchema) GetDatatype() ColumnDataType

+ func (x *ColumnSchema) GetSemanticType() SemanticType

+ func (x *ColumnSchema) ProtoReflect() protoreflect.Message

+ func (x *ColumnSchema) Reset()

+ func (x *ColumnSchema) String() string

type Column_Values

+ IntervalDayTimeValues []int64

+ IntervalMonthDayNanoValues []*IntervalMonthDayNano

+ IntervalYearMonthValues []int32

+ TimestampMicrosecondValues []int64

+ TimestampMillisecondValues []int64

+ TimestampNanosecondValues []int64

+ TimestampSecondValues []int64

+ func (x *Column_Values) GetIntervalDayTimeValues() []int64

+ func (x *Column_Values) GetIntervalMonthDayNanoValues() []*IntervalMonthDayNano

+ func (x *Column_Values) GetIntervalYearMonthValues() []int32

+ func (x *Column_Values) GetTimestampMicrosecondValues() []int64

+ func (x *Column_Values) GetTimestampMillisecondValues() []int64

+ func (x *Column_Values) GetTimestampNanosecondValues() []int64

+ func (x *Column_Values) GetTimestampSecondValues() []int64

type CreateDatabaseExpr

+ Options map[string]string

+ func (x *CreateDatabaseExpr) GetOptions() map[string]string

+ type DeleteRequests struct

+ Deletes []*DeleteRequest

+ func (*DeleteRequests) Descriptor() ([]byte, []int)

+ func (*DeleteRequests) ProtoMessage()

+ func (x *DeleteRequests) GetDeletes() []*DeleteRequest

+ func (x *DeleteRequests) ProtoReflect() protoreflect.Message

+ func (x *DeleteRequests) Reset()

+ func (x *DeleteRequests) String() string

type GreptimeRequest

+ func (x *GreptimeRequest) GetDeletes() *DeleteRequests

+ func (x *GreptimeRequest) GetRowDeletes() *RowDeleteRequests

+ func (x *GreptimeRequest) GetRowInserts() *RowInsertRequests

+ type GreptimeRequest_Deletes struct

+ Deletes *DeleteRequests

+ type GreptimeRequest_RowDeletes struct

+ RowDeletes *RowDeleteRequests

+ type GreptimeRequest_RowInserts struct

+ RowInserts *RowInsertRequests

+ type IntervalMonthDayNano struct

+ Days int32

+ Months int32

+ Nanoseconds int64

+ func (*IntervalMonthDayNano) Descriptor() ([]byte, []int)

+ func (*IntervalMonthDayNano) ProtoMessage()

+ func (x *IntervalMonthDayNano) GetDays() int32

+ func (x *IntervalMonthDayNano) GetMonths() int32

+ func (x *IntervalMonthDayNano) GetNanoseconds() int64

+ func (x *IntervalMonthDayNano) ProtoReflect() protoreflect.Message

+ func (x *IntervalMonthDayNano) Reset()

+ func (x *IntervalMonthDayNano) String() string

+ type Mutation struct

+ OpType OpType

+ Rows *Rows

+ Sequence uint64

+ func (*Mutation) Descriptor() ([]byte, []int)

+ func (*Mutation) ProtoMessage()

+ func (x *Mutation) GetOpType() OpType

+ func (x *Mutation) GetRows() *Rows

+ func (x *Mutation) GetSequence() uint64

+ func (x *Mutation) ProtoReflect() protoreflect.Message

+ func (x *Mutation) Reset()

+ func (x *Mutation) String() string

+ type OpType int32

+ const OpType_DELETE

+ const OpType_PUT

+ func (OpType) Descriptor() protoreflect.EnumDescriptor

+ func (OpType) EnumDescriptor() ([]byte, []int)

+ func (OpType) Type() protoreflect.EnumType

+ func (x OpType) Enum() *OpType

+ func (x OpType) Number() protoreflect.EnumNumber

+ func (x OpType) String() string

+ type Row struct

+ Values []*Value

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

+ func (*Row) ProtoMessage()

+ func (x *Row) GetValues() []*Value

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

+ func (x *Row) Reset()

+ func (x *Row) String() string

+ type RowDeleteRequest struct

+ Rows *Rows

+ TableName string

+ func (*RowDeleteRequest) Descriptor() ([]byte, []int)

+ func (*RowDeleteRequest) ProtoMessage()

+ func (x *RowDeleteRequest) GetRows() *Rows

+ func (x *RowDeleteRequest) GetTableName() string

+ func (x *RowDeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *RowDeleteRequest) Reset()

+ func (x *RowDeleteRequest) String() string

+ type RowDeleteRequests struct

+ Deletes []*RowDeleteRequest

+ func (*RowDeleteRequests) Descriptor() ([]byte, []int)

+ func (*RowDeleteRequests) ProtoMessage()

+ func (x *RowDeleteRequests) GetDeletes() []*RowDeleteRequest

+ func (x *RowDeleteRequests) ProtoReflect() protoreflect.Message

+ func (x *RowDeleteRequests) Reset()

+ func (x *RowDeleteRequests) String() string

+ type RowInsertRequest struct

+ Rows *Rows

+ TableName string

+ func (*RowInsertRequest) Descriptor() ([]byte, []int)

+ func (*RowInsertRequest) ProtoMessage()

+ func (x *RowInsertRequest) GetRows() *Rows

+ func (x *RowInsertRequest) GetTableName() string

+ func (x *RowInsertRequest) ProtoReflect() protoreflect.Message

+ func (x *RowInsertRequest) Reset()

+ func (x *RowInsertRequest) String() string

+ type RowInsertRequests struct

+ Inserts []*RowInsertRequest

+ func (*RowInsertRequests) Descriptor() ([]byte, []int)

+ func (*RowInsertRequests) ProtoMessage()

+ func (x *RowInsertRequests) GetInserts() []*RowInsertRequest

+ func (x *RowInsertRequests) ProtoReflect() protoreflect.Message

+ func (x *RowInsertRequests) Reset()

+ func (x *RowInsertRequests) String() string

+ type Rows struct

+ Rows []*Row

+ Schema []*ColumnSchema

+ func (*Rows) Descriptor() ([]byte, []int)

+ func (*Rows) ProtoMessage()

+ func (x *Rows) GetRows() []*Row

+ func (x *Rows) GetSchema() []*ColumnSchema

+ func (x *Rows) ProtoReflect() protoreflect.Message

+ func (x *Rows) Reset()

+ func (x *Rows) String() string

+ type SemanticType int32

+ const SemanticType_FIELD

+ const SemanticType_TAG

+ const SemanticType_TIMESTAMP

+ func (SemanticType) Descriptor() protoreflect.EnumDescriptor

+ func (SemanticType) EnumDescriptor() ([]byte, []int)

+ func (SemanticType) Type() protoreflect.EnumType

+ func (x SemanticType) Enum() *SemanticType

+ func (x SemanticType) Number() protoreflect.EnumNumber

+ func (x SemanticType) String() string

+ type Value struct

+ ValueData isValue_ValueData

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

+ func (*Value) ProtoMessage()

+ func (m *Value) GetValueData() isValue_ValueData

+ 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 (x *Value) ProtoReflect() protoreflect.Message

+ func (x *Value) Reset()

+ func (x *Value) String() string

+ type Value_BinaryValue struct

+ BinaryValue []byte

+ type Value_BoolValue struct

+ BoolValue bool

+ type Value_DateValue struct

+ DateValue int32

+ type Value_DatetimeValue struct

+ DatetimeValue int64

+ type Value_F32Value struct

+ F32Value float32

+ type Value_F64Value struct

+ F64Value float64

+ type Value_I16Value struct

+ I16Value int32

+ type Value_I32Value struct

+ I32Value int32

+ type Value_I64Value struct

+ I64Value int64

+ type Value_I8Value struct

+ I8Value int32

+ type Value_IntervalDayTimeValues struct

+ IntervalDayTimeValues int64

+ type Value_IntervalMonthDayNanoValues struct

+ IntervalMonthDayNanoValues *IntervalMonthDayNano

+ type Value_IntervalYearMonthValues struct

+ IntervalYearMonthValues int32

+ type Value_StringValue struct

+ StringValue string

+ type Value_TimeMicrosecondValue struct

+ TimeMicrosecondValue int64

+ type Value_TimeMillisecondValue struct

+ TimeMillisecondValue int64

+ type Value_TimeNanosecondValue struct

+ TimeNanosecondValue int64

+ type Value_TimeSecondValue struct

+ TimeSecondValue int64

+ type Value_TimestampMicrosecondValue struct

+ TimestampMicrosecondValue int64

+ type Value_TimestampMillisecondValue struct

+ TimestampMillisecondValue int64

+ type Value_TimestampNanosecondValue struct

+ TimestampNanosecondValue int64

+ type Value_TimestampSecondValue struct

+ TimestampSecondValue int64

+ type Value_U16Value struct

+ U16Value uint32

+ type Value_U32Value struct

+ U32Value uint32

+ type Value_U64Value struct

+ U64Value uint64

+ type Value_U8Value struct

+ U8Value uint32

+ type WalEntry struct

+ Mutations []*Mutation

+ func (*WalEntry) Descriptor() ([]byte, []int)

+ func (*WalEntry) ProtoMessage()

+ func (x *WalEntry) GetMutations() []*Mutation

+ func (x *WalEntry) ProtoReflect() protoreflect.Message

+ func (x *WalEntry) Reset()

+ func (x *WalEntry) String() string

v0.4.0-test

Oct 31, 2023

v0.3.0

Jul 20, 2023

Changes in this version

+ var AddColumn_Location_LocationType_name = map[int32]string

+ var AddColumn_Location_LocationType_value = map[string]int32

+ var ColumnDataType_name = map[int32]string

+ var ColumnDataType_value = map[string]int32

+ var Column_SemanticType_name = map[int32]string

+ var Column_SemanticType_value = map[string]int32

+ 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 GreptimeDatabase_ServiceDesc = grpc.ServiceDesc

+ var HealthCheck_ServiceDesc = grpc.ServiceDesc

+ var PrometheusGateway_ServiceDesc = grpc.ServiceDesc

+ func RegisterGreptimeDatabaseServer(s grpc.ServiceRegistrar, srv GreptimeDatabaseServer)

+ func RegisterHealthCheckServer(s grpc.ServiceRegistrar, srv HealthCheckServer)

+ func RegisterPrometheusGatewayServer(s grpc.ServiceRegistrar, srv PrometheusGatewayServer)

+ type AddColumn struct

+ ColumnDef *ColumnDef

+ IsKey bool

+ Location *AddColumn_Location

+ func (*AddColumn) Descriptor() ([]byte, []int)

+ func (*AddColumn) ProtoMessage()

+ func (x *AddColumn) GetColumnDef() *ColumnDef

+ func (x *AddColumn) GetIsKey() bool

+ func (x *AddColumn) GetLocation() *AddColumn_Location

+ func (x *AddColumn) ProtoReflect() protoreflect.Message

+ func (x *AddColumn) Reset()

+ func (x *AddColumn) String() string

+ type AddColumn_Location struct

+ AfterCloumnName string

+ LocationType AddColumn_Location_LocationType

+ func (*AddColumn_Location) Descriptor() ([]byte, []int)

+ func (*AddColumn_Location) ProtoMessage()

+ func (x *AddColumn_Location) GetAfterCloumnName() string

+ func (x *AddColumn_Location) GetLocationType() AddColumn_Location_LocationType

+ func (x *AddColumn_Location) ProtoReflect() protoreflect.Message

+ func (x *AddColumn_Location) Reset()

+ func (x *AddColumn_Location) String() string

+ type AddColumn_Location_LocationType int32

+ const AddColumn_Location_AFTER

+ const AddColumn_Location_FIRST

+ func (AddColumn_Location_LocationType) Descriptor() protoreflect.EnumDescriptor

+ func (AddColumn_Location_LocationType) EnumDescriptor() ([]byte, []int)

+ func (AddColumn_Location_LocationType) Type() protoreflect.EnumType

+ func (x AddColumn_Location_LocationType) Enum() *AddColumn_Location_LocationType

+ func (x AddColumn_Location_LocationType) Number() protoreflect.EnumNumber

+ func (x AddColumn_Location_LocationType) String() string

+ type AddColumns struct

+ AddColumns []*AddColumn

+ func (*AddColumns) Descriptor() ([]byte, []int)

+ func (*AddColumns) ProtoMessage()

+ func (x *AddColumns) GetAddColumns() []*AddColumn

+ func (x *AddColumns) ProtoReflect() protoreflect.Message

+ func (x *AddColumns) Reset()

+ func (x *AddColumns) String() string

+ type AffectedRows struct

+ Value uint32

+ func (*AffectedRows) Descriptor() ([]byte, []int)

+ func (*AffectedRows) ProtoMessage()

+ func (x *AffectedRows) GetValue() uint32

+ func (x *AffectedRows) ProtoReflect() protoreflect.Message

+ func (x *AffectedRows) Reset()

+ func (x *AffectedRows) String() string

+ type AlterExpr struct

+ CatalogName string

+ Kind isAlterExpr_Kind

+ SchemaName string

+ TableId *TableId

+ TableName string

+ TableVersion uint64

+ func (*AlterExpr) Descriptor() ([]byte, []int)

+ func (*AlterExpr) ProtoMessage()

+ func (m *AlterExpr) GetKind() isAlterExpr_Kind

+ func (x *AlterExpr) GetAddColumns() *AddColumns

+ func (x *AlterExpr) GetCatalogName() string

+ func (x *AlterExpr) GetDropColumns() *DropColumns

+ func (x *AlterExpr) GetRenameTable() *RenameTable

+ func (x *AlterExpr) GetSchemaName() string

+ func (x *AlterExpr) GetTableId() *TableId

+ func (x *AlterExpr) GetTableName() string

+ func (x *AlterExpr) GetTableVersion() uint64

+ func (x *AlterExpr) ProtoReflect() protoreflect.Message

+ func (x *AlterExpr) Reset()

+ func (x *AlterExpr) String() string

+ type AlterExpr_AddColumns struct

+ AddColumns *AddColumns

+ type AlterExpr_DropColumns struct

+ DropColumns *DropColumns

+ type AlterExpr_RenameTable struct

+ RenameTable *RenameTable

+ type AuthHeader struct

+ AuthScheme isAuthHeader_AuthScheme

+ func (*AuthHeader) Descriptor() ([]byte, []int)

+ func (*AuthHeader) ProtoMessage()

+ func (m *AuthHeader) GetAuthScheme() isAuthHeader_AuthScheme

+ func (x *AuthHeader) GetBasic() *Basic

+ func (x *AuthHeader) GetToken() *Token

+ func (x *AuthHeader) ProtoReflect() protoreflect.Message

+ func (x *AuthHeader) Reset()

+ func (x *AuthHeader) String() string

+ type AuthHeader_Basic struct

+ Basic *Basic

+ type AuthHeader_Token struct

+ Token *Token

+ type Basic struct

+ Password string

+ Username string

+ func (*Basic) Descriptor() ([]byte, []int)

+ func (*Basic) ProtoMessage()

+ func (x *Basic) GetPassword() string

+ func (x *Basic) GetUsername() string

+ func (x *Basic) ProtoReflect() protoreflect.Message

+ func (x *Basic) Reset()

+ func (x *Basic) String() string

+ type Column struct

+ ColumnName string

+ Datatype ColumnDataType

+ NullMask []byte

+ SemanticType Column_SemanticType

+ Values *Column_Values

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

+ func (*Column) ProtoMessage()

+ func (x *Column) GetColumnName() string

+ func (x *Column) GetDatatype() ColumnDataType

+ func (x *Column) GetNullMask() []byte

+ func (x *Column) GetSemanticType() Column_SemanticType

+ func (x *Column) GetValues() *Column_Values

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

+ func (x *Column) Reset()

+ func (x *Column) String() string

+ type ColumnDataType int32

+ const ColumnDataType_BINARY

+ const ColumnDataType_BOOLEAN

+ const ColumnDataType_DATE

+ const ColumnDataType_DATETIME

+ const ColumnDataType_FLOAT32

+ const ColumnDataType_FLOAT64

+ const ColumnDataType_INT16

+ const ColumnDataType_INT32

+ const ColumnDataType_INT64

+ const ColumnDataType_INT8

+ const ColumnDataType_STRING

+ const ColumnDataType_TIMESTAMP_MICROSECOND

+ const ColumnDataType_TIMESTAMP_MILLISECOND

+ const ColumnDataType_TIMESTAMP_NANOSECOND

+ const ColumnDataType_TIMESTAMP_SECOND

+ const ColumnDataType_TIME_MICROSECOND

+ const ColumnDataType_TIME_MILLISECOND

+ const ColumnDataType_TIME_NANOSECOND

+ const ColumnDataType_TIME_SECOND

+ const ColumnDataType_UINT16

+ const ColumnDataType_UINT32

+ const ColumnDataType_UINT64

+ const ColumnDataType_UINT8

+ func (ColumnDataType) Descriptor() protoreflect.EnumDescriptor

+ func (ColumnDataType) EnumDescriptor() ([]byte, []int)

+ func (ColumnDataType) Type() protoreflect.EnumType

+ func (x ColumnDataType) Enum() *ColumnDataType

+ func (x ColumnDataType) Number() protoreflect.EnumNumber

+ func (x ColumnDataType) String() string

+ type ColumnDef struct

+ Datatype ColumnDataType

+ DefaultConstraint []byte

+ IsNullable bool

+ Name string

+ func (*ColumnDef) Descriptor() ([]byte, []int)

+ func (*ColumnDef) ProtoMessage()

+ func (x *ColumnDef) GetDatatype() ColumnDataType

+ func (x *ColumnDef) GetDefaultConstraint() []byte

+ func (x *ColumnDef) GetIsNullable() bool

+ func (x *ColumnDef) GetName() string

+ func (x *ColumnDef) ProtoReflect() protoreflect.Message

+ func (x *ColumnDef) Reset()

+ func (x *ColumnDef) String() string

+ type Column_SemanticType int32

+ const Column_FIELD

+ const Column_TAG

+ const Column_TIMESTAMP

+ func (Column_SemanticType) Descriptor() protoreflect.EnumDescriptor

+ func (Column_SemanticType) EnumDescriptor() ([]byte, []int)

+ func (Column_SemanticType) Type() protoreflect.EnumType

+ func (x Column_SemanticType) Enum() *Column_SemanticType

+ func (x Column_SemanticType) Number() protoreflect.EnumNumber

+ func (x Column_SemanticType) String() string

+ type Column_Values struct

+ BinaryValues [][]byte

+ BoolValues []bool

+ DateValues []int32

+ DatetimeValues []int64

+ F32Values []float32

+ F64Values []float64

+ I16Values []int32

+ I32Values []int32

+ I64Values []int64

+ I8Values []int32

+ StringValues []string

+ TimeMicrosecondValues []int64

+ TimeMillisecondValues []int64

+ TimeNanosecondValues []int64

+ TimeSecondValues []int64

+ TsMicrosecondValues []int64

+ TsMillisecondValues []int64

+ TsNanosecondValues []int64

+ TsSecondValues []int64

+ U16Values []uint32

+ U32Values []uint32

+ U64Values []uint64

+ U8Values []uint32

+ func (*Column_Values) Descriptor() ([]byte, []int)

+ func (*Column_Values) ProtoMessage()

+ 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) 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) GetTsMicrosecondValues() []int64

+ func (x *Column_Values) GetTsMillisecondValues() []int64

+ func (x *Column_Values) GetTsNanosecondValues() []int64

+ func (x *Column_Values) GetTsSecondValues() []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 (x *Column_Values) ProtoReflect() protoreflect.Message

+ func (x *Column_Values) Reset()

+ func (x *Column_Values) String() string

+ type CompactTableExpr struct

+ CatalogName string

+ RegionNumber *uint32

+ SchemaName string

+ TableName string

+ func (*CompactTableExpr) Descriptor() ([]byte, []int)

+ func (*CompactTableExpr) ProtoMessage()

+ func (x *CompactTableExpr) GetCatalogName() string

+ func (x *CompactTableExpr) GetRegionNumber() uint32

+ func (x *CompactTableExpr) GetSchemaName() string

+ func (x *CompactTableExpr) GetTableName() string

+ func (x *CompactTableExpr) ProtoReflect() protoreflect.Message

+ func (x *CompactTableExpr) Reset()

+ func (x *CompactTableExpr) String() string

+ type CreateDatabaseExpr struct

+ CreateIfNotExists bool

+ DatabaseName string

+ func (*CreateDatabaseExpr) Descriptor() ([]byte, []int)

+ func (*CreateDatabaseExpr) ProtoMessage()

+ func (x *CreateDatabaseExpr) GetCreateIfNotExists() bool

+ func (x *CreateDatabaseExpr) GetDatabaseName() string

+ func (x *CreateDatabaseExpr) ProtoReflect() protoreflect.Message

+ func (x *CreateDatabaseExpr) Reset()

+ func (x *CreateDatabaseExpr) String() string

+ type CreateTableExpr struct

+ CatalogName string

+ ColumnDefs []*ColumnDef

+ CreateIfNotExists bool

+ Desc string

+ Engine string

+ PrimaryKeys []string

+ RegionNumbers []uint32

+ SchemaName string

+ TableId *TableId

+ TableName string

+ TableOptions map[string]string

+ TimeIndex string

+ func (*CreateTableExpr) Descriptor() ([]byte, []int)

+ func (*CreateTableExpr) ProtoMessage()

+ 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) GetRegionNumbers() []uint32

+ 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 (x *CreateTableExpr) ProtoReflect() protoreflect.Message

+ func (x *CreateTableExpr) Reset()

+ func (x *CreateTableExpr) String() string

+ type DdlRequest struct

+ Expr isDdlRequest_Expr

+ func (*DdlRequest) Descriptor() ([]byte, []int)

+ func (*DdlRequest) ProtoMessage()

+ func (m *DdlRequest) GetExpr() isDdlRequest_Expr

+ func (x *DdlRequest) GetAlter() *AlterExpr

+ func (x *DdlRequest) GetCompactTable() *CompactTableExpr

+ func (x *DdlRequest) GetCreateDatabase() *CreateDatabaseExpr

+ func (x *DdlRequest) GetCreateTable() *CreateTableExpr

+ func (x *DdlRequest) GetDropTable() *DropTableExpr

+ func (x *DdlRequest) GetFlushTable() *FlushTableExpr

+ func (x *DdlRequest) GetTruncateTable() *TruncateTableExpr

+ func (x *DdlRequest) ProtoReflect() protoreflect.Message

+ func (x *DdlRequest) Reset()

+ func (x *DdlRequest) String() string

+ type DdlRequest_Alter struct

+ Alter *AlterExpr

+ type DdlRequest_CompactTable struct

+ CompactTable *CompactTableExpr

+ type DdlRequest_CreateDatabase struct

+ CreateDatabase *CreateDatabaseExpr

+ type DdlRequest_CreateTable struct

+ CreateTable *CreateTableExpr

+ type DdlRequest_DropTable struct

+ DropTable *DropTableExpr

+ type DdlRequest_FlushTable struct

+ FlushTable *FlushTableExpr

+ type DdlRequest_TruncateTable struct

+ TruncateTable *TruncateTableExpr

+ type DeleteRequest struct

+ KeyColumns []*Column

+ RegionNumber uint32

+ RowCount uint32

+ TableName string

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

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) GetKeyColumns() []*Column

+ func (x *DeleteRequest) GetRegionNumber() uint32

+ func (x *DeleteRequest) GetRowCount() uint32

+ func (x *DeleteRequest) GetTableName() string

+ func (x *DeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type DropColumn struct

+ Name string

+ func (*DropColumn) Descriptor() ([]byte, []int)

+ func (*DropColumn) ProtoMessage()

+ func (x *DropColumn) GetName() string

+ func (x *DropColumn) ProtoReflect() protoreflect.Message

+ func (x *DropColumn) Reset()

+ func (x *DropColumn) String() string

+ type DropColumns struct

+ DropColumns []*DropColumn

+ func (*DropColumns) Descriptor() ([]byte, []int)

+ func (*DropColumns) ProtoMessage()

+ func (x *DropColumns) GetDropColumns() []*DropColumn

+ func (x *DropColumns) ProtoReflect() protoreflect.Message

+ func (x *DropColumns) Reset()

+ func (x *DropColumns) String() string

+ type DropTableExpr struct

+ CatalogName string

+ SchemaName string

+ TableId *TableId

+ TableName string

+ func (*DropTableExpr) Descriptor() ([]byte, []int)

+ func (*DropTableExpr) ProtoMessage()

+ func (x *DropTableExpr) GetCatalogName() string

+ func (x *DropTableExpr) GetSchemaName() string

+ func (x *DropTableExpr) GetTableId() *TableId

+ func (x *DropTableExpr) GetTableName() string

+ func (x *DropTableExpr) ProtoReflect() protoreflect.Message

+ func (x *DropTableExpr) Reset()

+ func (x *DropTableExpr) String() string

+ type FlightMetadata struct

+ AffectedRows *AffectedRows

+ func (*FlightMetadata) Descriptor() ([]byte, []int)

+ func (*FlightMetadata) ProtoMessage()

+ func (x *FlightMetadata) GetAffectedRows() *AffectedRows

+ func (x *FlightMetadata) ProtoReflect() protoreflect.Message

+ func (x *FlightMetadata) Reset()

+ func (x *FlightMetadata) String() string

+ type FlushTableExpr struct

+ CatalogName string

+ RegionNumber *uint32

+ SchemaName string

+ TableId *TableId

+ TableName string

+ func (*FlushTableExpr) Descriptor() ([]byte, []int)

+ func (*FlushTableExpr) ProtoMessage()

+ func (x *FlushTableExpr) GetCatalogName() string

+ func (x *FlushTableExpr) GetRegionNumber() uint32

+ func (x *FlushTableExpr) GetSchemaName() string

+ func (x *FlushTableExpr) GetTableId() *TableId

+ func (x *FlushTableExpr) GetTableName() string

+ func (x *FlushTableExpr) ProtoReflect() protoreflect.Message

+ func (x *FlushTableExpr) Reset()

+ func (x *FlushTableExpr) String() string

+ type GreptimeDatabaseClient interface

+ Handle func(ctx context.Context, in *GreptimeRequest, opts ...grpc.CallOption) (*GreptimeResponse, error)

+ HandleRequests func(ctx context.Context, opts ...grpc.CallOption) (GreptimeDatabase_HandleRequestsClient, error)

+ func NewGreptimeDatabaseClient(cc grpc.ClientConnInterface) GreptimeDatabaseClient

+ type GreptimeDatabaseServer interface

+ Handle func(context.Context, *GreptimeRequest) (*GreptimeResponse, error)

+ HandleRequests func(GreptimeDatabase_HandleRequestsServer) error

+ type GreptimeDatabase_HandleRequestsClient interface

+ CloseAndRecv func() (*GreptimeResponse, error)

+ Send func(*GreptimeRequest) error

+ type GreptimeDatabase_HandleRequestsServer interface

+ Recv func() (*GreptimeRequest, error)

+ SendAndClose func(*GreptimeResponse) error

+ type GreptimeRequest struct

+ Header *RequestHeader

+ Request isGreptimeRequest_Request

+ func (*GreptimeRequest) Descriptor() ([]byte, []int)

+ func (*GreptimeRequest) ProtoMessage()

+ func (m *GreptimeRequest) GetRequest() isGreptimeRequest_Request

+ func (x *GreptimeRequest) GetDdl() *DdlRequest

+ func (x *GreptimeRequest) GetDelete() *DeleteRequest

+ func (x *GreptimeRequest) GetHeader() *RequestHeader

+ func (x *GreptimeRequest) GetInserts() *InsertRequests

+ func (x *GreptimeRequest) GetQuery() *QueryRequest

+ func (x *GreptimeRequest) ProtoReflect() protoreflect.Message

+ func (x *GreptimeRequest) Reset()

+ func (x *GreptimeRequest) String() string

+ type GreptimeRequest_Ddl struct

+ Ddl *DdlRequest

+ type GreptimeRequest_Delete struct

+ Delete *DeleteRequest

+ type GreptimeRequest_Inserts struct

+ Inserts *InsertRequests

+ type GreptimeRequest_Query struct

+ Query *QueryRequest

+ type GreptimeResponse struct

+ Header *ResponseHeader

+ Response isGreptimeResponse_Response

+ func (*GreptimeResponse) Descriptor() ([]byte, []int)

+ func (*GreptimeResponse) ProtoMessage()

+ func (m *GreptimeResponse) GetResponse() isGreptimeResponse_Response

+ func (x *GreptimeResponse) GetAffectedRows() *AffectedRows

+ func (x *GreptimeResponse) GetHeader() *ResponseHeader

+ func (x *GreptimeResponse) ProtoReflect() protoreflect.Message

+ func (x *GreptimeResponse) Reset()

+ func (x *GreptimeResponse) String() string

+ type GreptimeResponse_AffectedRows struct

+ AffectedRows *AffectedRows

+ type HealthCheckClient interface

+ HealthCheck func(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)

+ func NewHealthCheckClient(cc grpc.ClientConnInterface) HealthCheckClient

+ type HealthCheckRequest struct

+ func (*HealthCheckRequest) Descriptor() ([]byte, []int)

+ func (*HealthCheckRequest) ProtoMessage()

+ func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckRequest) Reset()

+ func (x *HealthCheckRequest) String() string

+ type HealthCheckResponse struct

+ func (*HealthCheckResponse) Descriptor() ([]byte, []int)

+ func (*HealthCheckResponse) ProtoMessage()

+ func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckResponse) Reset()

+ func (x *HealthCheckResponse) String() string

+ type HealthCheckServer interface

+ HealthCheck func(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

+ type InsertRequest struct

+ Columns []*Column

+ RegionNumber uint32

+ RowCount uint32

+ TableName string

+ func (*InsertRequest) Descriptor() ([]byte, []int)

+ func (*InsertRequest) ProtoMessage()

+ func (x *InsertRequest) GetColumns() []*Column

+ func (x *InsertRequest) GetRegionNumber() uint32

+ func (x *InsertRequest) GetRowCount() uint32

+ func (x *InsertRequest) GetTableName() string

+ func (x *InsertRequest) ProtoReflect() protoreflect.Message

+ func (x *InsertRequest) Reset()

+ func (x *InsertRequest) String() string

+ type InsertRequests struct

+ Inserts []*InsertRequest

+ func (*InsertRequests) Descriptor() ([]byte, []int)

+ func (*InsertRequests) ProtoMessage()

+ func (x *InsertRequests) GetInserts() []*InsertRequest

+ func (x *InsertRequests) ProtoReflect() protoreflect.Message

+ func (x *InsertRequests) Reset()

+ func (x *InsertRequests) String() string

+ type PromInstantQuery struct

+ Query string

+ Time string

+ func (*PromInstantQuery) Descriptor() ([]byte, []int)

+ func (*PromInstantQuery) ProtoMessage()

+ func (x *PromInstantQuery) GetQuery() string

+ func (x *PromInstantQuery) GetTime() string

+ func (x *PromInstantQuery) ProtoReflect() protoreflect.Message

+ func (x *PromInstantQuery) Reset()

+ func (x *PromInstantQuery) String() string

+ type PromRangeQuery struct

+ End string

+ Query string

+ Start string

+ Step string

+ func (*PromRangeQuery) Descriptor() ([]byte, []int)

+ func (*PromRangeQuery) ProtoMessage()

+ func (x *PromRangeQuery) GetEnd() string

+ func (x *PromRangeQuery) GetQuery() string

+ func (x *PromRangeQuery) GetStart() string

+ func (x *PromRangeQuery) GetStep() string

+ func (x *PromRangeQuery) ProtoReflect() protoreflect.Message

+ func (x *PromRangeQuery) Reset()

+ func (x *PromRangeQuery) String() string

+ type PrometheusGatewayClient interface

+ Handle func(ctx context.Context, in *PromqlRequest, opts ...grpc.CallOption) (*PromqlResponse, error)

+ func NewPrometheusGatewayClient(cc grpc.ClientConnInterface) PrometheusGatewayClient

+ type PrometheusGatewayServer interface

+ Handle func(context.Context, *PromqlRequest) (*PromqlResponse, error)

+ type PromqlRequest struct

+ Header *RequestHeader

+ Promql isPromqlRequest_Promql

+ func (*PromqlRequest) Descriptor() ([]byte, []int)

+ func (*PromqlRequest) ProtoMessage()

+ func (m *PromqlRequest) GetPromql() isPromqlRequest_Promql

+ func (x *PromqlRequest) GetHeader() *RequestHeader

+ func (x *PromqlRequest) GetInstantQuery() *PromInstantQuery

+ func (x *PromqlRequest) GetRangeQuery() *PromRangeQuery

+ func (x *PromqlRequest) ProtoReflect() protoreflect.Message

+ func (x *PromqlRequest) Reset()

+ func (x *PromqlRequest) String() string

+ type PromqlRequest_InstantQuery struct

+ InstantQuery *PromInstantQuery

+ type PromqlRequest_RangeQuery struct

+ RangeQuery *PromRangeQuery

+ type PromqlResponse struct

+ Body []byte

+ Header *ResponseHeader

+ func (*PromqlResponse) Descriptor() ([]byte, []int)

+ func (*PromqlResponse) ProtoMessage()

+ func (x *PromqlResponse) GetBody() []byte

+ func (x *PromqlResponse) GetHeader() *ResponseHeader

+ func (x *PromqlResponse) ProtoReflect() protoreflect.Message

+ func (x *PromqlResponse) Reset()

+ func (x *PromqlResponse) String() string

+ type QueryRequest struct

+ Query isQueryRequest_Query

+ func (*QueryRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequest) ProtoMessage()

+ func (m *QueryRequest) GetQuery() isQueryRequest_Query

+ func (x *QueryRequest) GetLogicalPlan() []byte

+ func (x *QueryRequest) GetPromRangeQuery() *PromRangeQuery

+ func (x *QueryRequest) GetSql() string

+ func (x *QueryRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryRequest) Reset()

+ func (x *QueryRequest) String() string

+ type QueryRequest_LogicalPlan struct

+ LogicalPlan []byte

+ type QueryRequest_PromRangeQuery struct

+ PromRangeQuery *PromRangeQuery

+ type QueryRequest_Sql struct

+ Sql string

+ type RenameTable struct

+ NewTableName string

+ func (*RenameTable) Descriptor() ([]byte, []int)

+ func (*RenameTable) ProtoMessage()

+ func (x *RenameTable) GetNewTableName() string

+ func (x *RenameTable) ProtoReflect() protoreflect.Message

+ func (x *RenameTable) Reset()

+ func (x *RenameTable) String() string

+ type RequestHeader struct

+ Authorization *AuthHeader

+ Catalog string

+ Dbname string

+ Schema string

+ SpanId *uint64

+ TraceId *uint64

+ func (*RequestHeader) Descriptor() ([]byte, []int)

+ func (*RequestHeader) ProtoMessage()

+ 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 (x *RequestHeader) ProtoReflect() protoreflect.Message

+ func (x *RequestHeader) Reset()

+ func (x *RequestHeader) String() string

+ type ResponseHeader struct

+ Status *Status

+ func (*ResponseHeader) Descriptor() ([]byte, []int)

+ func (*ResponseHeader) ProtoMessage()

+ func (x *ResponseHeader) GetStatus() *Status

+ func (x *ResponseHeader) ProtoReflect() protoreflect.Message

+ func (x *ResponseHeader) Reset()

+ func (x *ResponseHeader) String() string

+ type Status struct

+ ErrMsg string

+ StatusCode uint32

+ func (*Status) Descriptor() ([]byte, []int)

+ func (*Status) ProtoMessage()

+ func (x *Status) GetErrMsg() string

+ func (x *Status) GetStatusCode() uint32

+ func (x *Status) ProtoReflect() protoreflect.Message

+ func (x *Status) Reset()

+ func (x *Status) String() string

+ type TableId struct

+ Id uint32

+ func (*TableId) Descriptor() ([]byte, []int)

+ func (*TableId) ProtoMessage()

+ func (x *TableId) GetId() uint32

+ func (x *TableId) ProtoReflect() protoreflect.Message

+ func (x *TableId) Reset()

+ func (x *TableId) String() string

+ type Token struct

+ Token string

+ func (*Token) Descriptor() ([]byte, []int)

+ func (*Token) ProtoMessage()

+ func (x *Token) GetToken() string

+ func (x *Token) ProtoReflect() protoreflect.Message

+ func (x *Token) Reset()

+ func (x *Token) String() string

+ type TruncateTableExpr struct

+ CatalogName string

+ SchemaName string

+ TableId *TableId

+ TableName string

+ func (*TruncateTableExpr) Descriptor() ([]byte, []int)

+ func (*TruncateTableExpr) ProtoMessage()

+ func (x *TruncateTableExpr) GetCatalogName() string

+ func (x *TruncateTableExpr) GetSchemaName() string

+ func (x *TruncateTableExpr) GetTableId() *TableId

+ func (x *TruncateTableExpr) GetTableName() string

+ func (x *TruncateTableExpr) ProtoReflect() protoreflect.Message

+ func (x *TruncateTableExpr) Reset()

+ func (x *TruncateTableExpr) String() string

+ type UnimplementedGreptimeDatabaseServer struct

+ func (UnimplementedGreptimeDatabaseServer) Handle(context.Context, *GreptimeRequest) (*GreptimeResponse, error)

+ func (UnimplementedGreptimeDatabaseServer) HandleRequests(GreptimeDatabase_HandleRequestsServer) error

+ type UnimplementedHealthCheckServer struct

+ func (UnimplementedHealthCheckServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

+ type UnimplementedPrometheusGatewayServer struct

+ func (UnimplementedPrometheusGatewayServer) Handle(context.Context, *PromqlRequest) (*PromqlResponse, error)

+ type UnsafeGreptimeDatabaseServer interface

+ type UnsafeHealthCheckServer interface

+ type UnsafePrometheusGatewayServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL