v1

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2024 License: Apache-2.0 Imports: 8 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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",
		30: "DECIMAL128",
		31: "JSON",
	}
	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,
		"DECIMAL128":              30,
		"JSON":                    31,
	}
)

Enum value maps for ColumnDataType.

View Source 
var (
	JsonTypeExtension_name = map[int32]string{
		0: "JSON_BINARY",
	}
	JsonTypeExtension_value = map[string]int32{
		"JSON_BINARY": 0,
	}
)

Enum value maps for JsonTypeExtension.

View Source 
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.

View Source 
var (
	OpType_name = map[int32]string{
		0: "DELETE",
		1: "PUT",
	}
	OpType_value = map[string]int32{
		"DELETE": 0,
		"PUT":    1,
	}
)

Enum value maps for OpType.

View Source 
var File_greptime_v1_column_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_database_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_ddl_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_health_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_prom_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_row_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_wal_proto protoreflect.FileDescriptor
View Source 
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)

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

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use AddColumn.ProtoReflect.Descriptor instead.

func (*AddColumn) GetColumnDef 

func (x *AddColumn) GetColumnDef() *ColumnDef

func (*AddColumn) GetLocation 

func (x *AddColumn) GetLocation() *AddColumnLocation

func (*AddColumn) ProtoMessage 

func (*AddColumn) ProtoMessage()

func (*AddColumn) ProtoReflect 

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

func (*AddColumn) Reset 

func (x *AddColumn) Reset()

func (*AddColumn) String 

func (x *AddColumn) String() string

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
	//	*AlterExpr_ChangeColumnTypes
	//	*AlterExpr_ChangeTableOptions
	Kind isAlterExpr_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*AlterExpr) Descriptor deprecated 

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

Deprecated: Use AlterExpr.ProtoReflect.Descriptor instead.

func (*AlterExpr) GetAddColumns 

func (x *AlterExpr) GetAddColumns() *AddColumns

func (*AlterExpr) GetCatalogName 

func (x *AlterExpr) GetCatalogName() string

func (*AlterExpr) GetChangeColumnTypes added in v0.7.0 

func (x *AlterExpr) GetChangeColumnTypes() *ChangeColumnTypes

func (*AlterExpr) GetChangeTableOptions added in v0.9.0 

func (x *AlterExpr) GetChangeTableOptions() *ChangeTableOptions

func (*AlterExpr) GetDropColumns 

func (x *AlterExpr) GetDropColumns() *DropColumns

func (*AlterExpr) GetKind 

func (m *AlterExpr) GetKind() isAlterExpr_Kind

func (*AlterExpr) GetRenameTable 

func (x *AlterExpr) GetRenameTable() *RenameTable

func (*AlterExpr) GetSchemaName 

func (x *AlterExpr) GetSchemaName() string

func (*AlterExpr) GetTableName 

func (x *AlterExpr) GetTableName() string

func (*AlterExpr) ProtoMessage 

func (*AlterExpr) ProtoMessage()

func (*AlterExpr) ProtoReflect 

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

func (*AlterExpr) Reset 

func (x *AlterExpr) Reset()

func (*AlterExpr) String 

func (x *AlterExpr) String() string

type AlterExpr_AddColumns 

type AlterExpr_AddColumns struct {
	AddColumns *AddColumns `protobuf:"bytes,4,opt,name=add_columns,json=addColumns,proto3,oneof"`
}

type AlterExpr_ChangeColumnTypes added in v0.7.0 

type AlterExpr_ChangeColumnTypes struct {
	ChangeColumnTypes *ChangeColumnTypes `protobuf:"bytes,7,opt,name=change_column_types,json=changeColumnTypes,proto3,oneof"`
}

type AlterExpr_ChangeTableOptions added in v0.9.0 

type AlterExpr_ChangeTableOptions struct {
	ChangeTableOptions *ChangeTableOptions `protobuf:"bytes,8,opt,name=change_table_options,json=changeTableOptions,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) Descriptor() ([]byte, []int)

Deprecated: Use Basic.ProtoReflect.Descriptor instead.

func (*Basic) GetPassword 

func (x *Basic) GetPassword() string

func (*Basic) GetUsername 

func (x *Basic) GetUsername() string

func (*Basic) ProtoMessage 

func (*Basic) ProtoMessage()

func (*Basic) ProtoReflect 

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

func (*Basic) Reset 

func (x *Basic) Reset()

func (*Basic) String 

func (x *Basic) String() string

type ChangeColumnType added in v0.7.0 

type ChangeColumnType struct {
	ColumnName          string                   `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	TargetType          ColumnDataType           `protobuf:"varint,2,opt,name=target_type,json=targetType,proto3,enum=greptime.v1.ColumnDataType" json:"target_type,omitempty"`
	TargetTypeExtension *ColumnDataTypeExtension `protobuf:"bytes,3,opt,name=target_type_extension,json=targetTypeExtension,proto3" json:"target_type_extension,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeColumnType) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ChangeColumnType.ProtoReflect.Descriptor instead.

func (*ChangeColumnType) GetColumnName added in v0.7.0 

func (x *ChangeColumnType) GetColumnName() string

func (*ChangeColumnType) GetTargetType added in v0.7.0 

func (x *ChangeColumnType) GetTargetType() ColumnDataType

func (*ChangeColumnType) GetTargetTypeExtension added in v0.7.0 

func (x *ChangeColumnType) GetTargetTypeExtension() *ColumnDataTypeExtension

func (*ChangeColumnType) ProtoMessage added in v0.7.0 

func (*ChangeColumnType) ProtoMessage()

func (*ChangeColumnType) ProtoReflect added in v0.7.0 

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

func (*ChangeColumnType) Reset added in v0.7.0 

func (x *ChangeColumnType) Reset()

func (*ChangeColumnType) String added in v0.7.0 

func (x *ChangeColumnType) String() string

type ChangeColumnTypes added in v0.7.0 

type ChangeColumnTypes struct {
	ChangeColumnTypes []*ChangeColumnType `protobuf:"bytes,1,rep,name=change_column_types,json=changeColumnTypes,proto3" json:"change_column_types,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeColumnTypes) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ChangeColumnTypes.ProtoReflect.Descriptor instead.

func (*ChangeColumnTypes) GetChangeColumnTypes added in v0.7.0 

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

func (*ChangeColumnTypes) ProtoMessage added in v0.7.0 

func (*ChangeColumnTypes) ProtoMessage()

func (*ChangeColumnTypes) ProtoReflect added in v0.7.0 

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

func (*ChangeColumnTypes) Reset added in v0.7.0 

func (x *ChangeColumnTypes) Reset()

func (*ChangeColumnTypes) String added in v0.7.0 

func (x *ChangeColumnTypes) String() string

type ChangeTableOption added in v0.9.0 

type ChangeTableOption struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTableOption) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ChangeTableOption.ProtoReflect.Descriptor instead.

func (*ChangeTableOption) GetKey added in v0.9.0 

func (x *ChangeTableOption) GetKey() string

func (*ChangeTableOption) GetValue added in v0.9.0 

func (x *ChangeTableOption) GetValue() string

func (*ChangeTableOption) ProtoMessage added in v0.9.0 

func (*ChangeTableOption) ProtoMessage()

func (*ChangeTableOption) ProtoReflect added in v0.9.0 

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

func (*ChangeTableOption) Reset added in v0.9.0 

func (x *ChangeTableOption) Reset()

func (*ChangeTableOption) String added in v0.9.0 

func (x *ChangeTableOption) String() string

type ChangeTableOptions added in v0.9.0 

type ChangeTableOptions struct {
	ChangeTableOptions []*ChangeTableOption `protobuf:"bytes,1,rep,name=change_table_options,json=changeTableOptions,proto3" json:"change_table_options,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTableOptions) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ChangeTableOptions.ProtoReflect.Descriptor instead.

func (*ChangeTableOptions) GetChangeTableOptions added in v0.9.0 

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

func (*ChangeTableOptions) ProtoMessage added in v0.9.0 

func (*ChangeTableOptions) ProtoMessage()

func (*ChangeTableOptions) ProtoReflect added in v0.9.0 

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

func (*ChangeTableOptions) Reset added in v0.9.0 

func (x *ChangeTableOptions) Reset()

func (*ChangeTableOptions) String added in v0.9.0 

func (x *ChangeTableOptions) String() string

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"`
	// Extension for ColumnDataType.
	DatatypeExtension *ColumnDataTypeExtension `protobuf:"bytes,6,opt,name=datatype_extension,json=datatypeExtension,proto3" json:"datatype_extension,omitempty"`
	// Additional column options.
	Options *ColumnOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetColumnName 

func (x *Column) GetColumnName() string

func (*Column) GetDatatype 

func (x *Column) GetDatatype() ColumnDataType

func (*Column) GetDatatypeExtension added in v0.4.1 

func (x *Column) GetDatatypeExtension() *ColumnDataTypeExtension

func (*Column) GetNullMask 

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

func (*Column) GetOptions added in v0.9.0 

func (x *Column) GetOptions() *ColumnOptions

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

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
	ColumnDataType_DECIMAL128              ColumnDataType = 30
	ColumnDataType_JSON                    ColumnDataType = 31
)

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 ColumnDataTypeExtension added in v0.4.1 

type ColumnDataTypeExtension struct {

	// Types that are assignable to TypeExt:
	//
	//	*ColumnDataTypeExtension_DecimalType
	//	*ColumnDataTypeExtension_JsonType
	TypeExt isColumnDataTypeExtension_TypeExt `protobuf_oneof:"type_ext"`
	// contains filtered or unexported fields
}

Type extension for some complex types

func (*ColumnDataTypeExtension) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use ColumnDataTypeExtension.ProtoReflect.Descriptor instead.

func (*ColumnDataTypeExtension) GetDecimalType added in v0.4.1 

func (x *ColumnDataTypeExtension) GetDecimalType() *DecimalTypeExtension

func (*ColumnDataTypeExtension) GetJsonType added in v0.9.0 

func (x *ColumnDataTypeExtension) GetJsonType() JsonTypeExtension

func (*ColumnDataTypeExtension) GetTypeExt added in v0.4.1 

func (m *ColumnDataTypeExtension) GetTypeExt() isColumnDataTypeExtension_TypeExt

func (*ColumnDataTypeExtension) ProtoMessage added in v0.4.1 

func (*ColumnDataTypeExtension) ProtoMessage()

func (*ColumnDataTypeExtension) ProtoReflect added in v0.4.1 

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

func (*ColumnDataTypeExtension) Reset added in v0.4.1 

func (x *ColumnDataTypeExtension) Reset()

func (*ColumnDataTypeExtension) String added in v0.4.1 

func (x *ColumnDataTypeExtension) String() string

type ColumnDataTypeExtension_DecimalType added in v0.4.1 

type ColumnDataTypeExtension_DecimalType struct {
	DecimalType *DecimalTypeExtension `protobuf:"bytes,1,opt,name=decimal_type,json=decimalType,proto3,oneof"`
}

type ColumnDataTypeExtension_JsonType added in v0.9.0 

type ColumnDataTypeExtension_JsonType struct {
	// Marks the binary column in proto is actually a JSON column.
	JsonType JsonTypeExtension `protobuf:"varint,2,opt,name=json_type,json=jsonType,proto3,enum=greptime.v1.JsonTypeExtension,oneof"`
}

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 */
	Comment           string         `protobuf:"bytes,6,opt,name=comment,proto3" json:"comment,omitempty"`
	// Extension for ColumnDataType.
	DatatypeExtension *ColumnDataTypeExtension `protobuf:"bytes,7,opt,name=datatype_extension,json=datatypeExtension,proto3" json:"datatype_extension,omitempty"`
	// Additional column options.
	Options *ColumnOptions `protobuf:"bytes,8,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnDef) Descriptor deprecated 

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

Deprecated: Use ColumnDef.ProtoReflect.Descriptor instead.

func (*ColumnDef) GetComment added in v0.4.1 

func (x *ColumnDef) GetComment() string

func (*ColumnDef) GetDataType added in v0.4.0 

func (x *ColumnDef) GetDataType() ColumnDataType

func (*ColumnDef) GetDatatypeExtension added in v0.4.1 

func (x *ColumnDef) GetDatatypeExtension() *ColumnDataTypeExtension

func (*ColumnDef) GetDefaultConstraint 

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

func (*ColumnDef) GetIsNullable 

func (x *ColumnDef) GetIsNullable() bool

func (*ColumnDef) GetName 

func (x *ColumnDef) GetName() string

func (*ColumnDef) GetOptions added in v0.9.0 

func (x *ColumnDef) GetOptions() *ColumnOptions

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

func (*ColumnDef) Reset 

func (x *ColumnDef) Reset()

func (*ColumnDef) String 

func (x *ColumnDef) String() string

type ColumnOptions added in v0.9.0 

type ColumnOptions struct {

	// Supported keys:
	//
	//	"fulltext":
	//	   A JSON encoded string containing full-text search options for the column.
	//
	//	   The fulltext options JSON structure:
	//	   {
	//	     "enable": bool,          // Indicates whether full-text search is
	//	                              // enabled for the column.
	//
	//	     "analyzer": string,      // The language-specific text analyzer to
	//	                              // use for indexing and searching text.
	//	                              // Supported values: ["English" (Default), "Chinese"].
	//
	//	     "case-sensitive": bool   // Indicates whether the text should be treated
	//	                              // as case-sensitive during full-text search.
	//	   }
	//
	//	   Example:
	//	   "fulltext": "{\"enable\": true, \"analyzer\": \"English\", \"case-sensitive\": false}"
	Options map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Additional options for the column.

func (*ColumnOptions) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ColumnOptions.ProtoReflect.Descriptor instead.

func (*ColumnOptions) GetOptions added in v0.9.0 

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

func (*ColumnOptions) ProtoMessage added in v0.9.0 

func (*ColumnOptions) ProtoMessage()

func (*ColumnOptions) ProtoReflect added in v0.9.0 

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

func (*ColumnOptions) Reset added in v0.9.0 

func (x *ColumnOptions) Reset()

func (*ColumnOptions) String added in v0.9.0 

func (x *ColumnOptions) String() string

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 */
	// Extension for ColumnDataType.
	DatatypeExtension *ColumnDataTypeExtension `protobuf:"bytes,4,opt,name=datatype_extension,json=datatypeExtension,proto3" json:"datatype_extension,omitempty"`
	// Additional column options.
	Options *ColumnOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	// 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) GetDatatypeExtension added in v0.4.1 

func (x *ColumnSchema) GetDatatypeExtension() *ColumnDataTypeExtension

func (*ColumnSchema) GetOptions added in v0.9.0 

func (x *ColumnSchema) GetOptions() *ColumnOptions

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 */
	Decimal128Values           []*Decimal128           `protobuf:"bytes,31,rep,name=decimal128_values,json=decimal128Values,proto3" json:"decimal128_values,omitempty"`
	// 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) GetDecimal128Values added in v0.4.1 

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

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 {
	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"`
	CreateIfNotExists bool              `protobuf:"varint,3,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) GetCatalogName added in v0.7.0 

func (x *CreateDatabaseExpr) GetCatalogName() string

func (*CreateDatabaseExpr) GetCreateIfNotExists 

func (x *CreateDatabaseExpr) GetCreateIfNotExists() bool

func (*CreateDatabaseExpr) GetOptions added in v0.4.0 

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

func (*CreateDatabaseExpr) GetSchemaName added in v0.7.0 

func (x *CreateDatabaseExpr) GetSchemaName() 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 CreateFlowExpr added in v0.9.0 

type CreateFlowExpr struct {
	CatalogName       string       `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	FlowName          string       `protobuf:"bytes,2,opt,name=flow_name,json=flowName,proto3" json:"flow_name,omitempty"`
	SourceTableNames  []*TableName `protobuf:"bytes,3,rep,name=source_table_names,json=sourceTableNames,proto3" json:"source_table_names,omitempty"`
	SinkTableName     *TableName   `protobuf:"bytes,4,opt,name=sink_table_name,json=sinkTableName,proto3" json:"sink_table_name,omitempty"`
	OrReplace         bool         `protobuf:"varint,5,opt,name=or_replace,json=orReplace,proto3" json:"or_replace,omitempty"`
	CreateIfNotExists bool         `protobuf:"varint,6,opt,name=create_if_not_exists,json=createIfNotExists,proto3" json:"create_if_not_exists,omitempty"`
	// Expire data older than the given duration seconds.
	ExpireAfter *ExpireAfter      `protobuf:"bytes,7,opt,name=expire_after,json=expireAfter,proto3" json:"expire_after,omitempty"`
	Comment     string            `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	Sql         string            `protobuf:"bytes,9,opt,name=sql,proto3" json:"sql,omitempty"`
	FlowOptions map[string]string `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

Create a flow to run the SQL when new data arrives.

func (*CreateFlowExpr) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use CreateFlowExpr.ProtoReflect.Descriptor instead.

func (*CreateFlowExpr) GetCatalogName added in v0.9.0 

func (x *CreateFlowExpr) GetCatalogName() string

func (*CreateFlowExpr) GetComment added in v0.9.0 

func (x *CreateFlowExpr) GetComment() string

func (*CreateFlowExpr) GetCreateIfNotExists added in v0.9.0 

func (x *CreateFlowExpr) GetCreateIfNotExists() bool

func (*CreateFlowExpr) GetExpireAfter added in v0.9.0 

func (x *CreateFlowExpr) GetExpireAfter() *ExpireAfter

func (*CreateFlowExpr) GetFlowName added in v0.9.0 

func (x *CreateFlowExpr) GetFlowName() string

func (*CreateFlowExpr) GetFlowOptions added in v0.9.0 

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

func (*CreateFlowExpr) GetOrReplace added in v0.9.0 

func (x *CreateFlowExpr) GetOrReplace() bool

func (*CreateFlowExpr) GetSinkTableName added in v0.9.0 

func (x *CreateFlowExpr) GetSinkTableName() *TableName

func (*CreateFlowExpr) GetSourceTableNames added in v0.9.0 

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

func (*CreateFlowExpr) GetSql added in v0.9.0 

func (x *CreateFlowExpr) GetSql() string

func (*CreateFlowExpr) ProtoMessage added in v0.9.0 

func (*CreateFlowExpr) ProtoMessage()

func (*CreateFlowExpr) ProtoReflect added in v0.9.0 

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

func (*CreateFlowExpr) Reset added in v0.9.0 

func (x *CreateFlowExpr) Reset()

func (*CreateFlowExpr) String added in v0.9.0 

func (x *CreateFlowExpr) 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 CreateViewExpr added in v0.9.0 

type CreateViewExpr 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"`
	ViewName          string       `protobuf:"bytes,3,opt,name=view_name,json=viewName,proto3" json:"view_name,omitempty"`
	LogicalPlan       []byte       `protobuf:"bytes,4,opt,name=logical_plan,json=logicalPlan,proto3" json:"logical_plan,omitempty"`
	CreateIfNotExists bool         `protobuf:"varint,5,opt,name=create_if_not_exists,json=createIfNotExists,proto3" json:"create_if_not_exists,omitempty"`
	OrReplace         bool         `protobuf:"varint,6,opt,name=or_replace,json=orReplace,proto3" json:"or_replace,omitempty"`
	TableNames        []*TableName `protobuf:"bytes,7,rep,name=table_names,json=tableNames,proto3" json:"table_names,omitempty"`
	Columns           []string     `protobuf:"bytes,8,rep,name=columns,proto3" json:"columns,omitempty"`
	PlanColumns       []string     `protobuf:"bytes,9,rep,name=plan_columns,json=planColumns,proto3" json:"plan_columns,omitempty"`
	Definition        string       `protobuf:"bytes,10,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

Create a view

func (*CreateViewExpr) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use CreateViewExpr.ProtoReflect.Descriptor instead.

func (*CreateViewExpr) GetCatalogName added in v0.9.0 

func (x *CreateViewExpr) GetCatalogName() string

func (*CreateViewExpr) GetColumns added in v0.9.0 

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

func (*CreateViewExpr) GetCreateIfNotExists added in v0.9.0 

func (x *CreateViewExpr) GetCreateIfNotExists() bool

func (*CreateViewExpr) GetDefinition added in v0.9.0 

func (x *CreateViewExpr) GetDefinition() string

func (*CreateViewExpr) GetLogicalPlan added in v0.9.0 

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

func (*CreateViewExpr) GetOrReplace added in v0.9.0 

func (x *CreateViewExpr) GetOrReplace() bool

func (*CreateViewExpr) GetPlanColumns added in v0.9.0 

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

func (*CreateViewExpr) GetSchemaName added in v0.9.0 

func (x *CreateViewExpr) GetSchemaName() string

func (*CreateViewExpr) GetTableNames added in v0.9.0 

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

func (*CreateViewExpr) GetViewName added in v0.9.0 

func (x *CreateViewExpr) GetViewName() string

func (*CreateViewExpr) ProtoMessage added in v0.9.0 

func (*CreateViewExpr) ProtoMessage()

func (*CreateViewExpr) ProtoReflect added in v0.9.0 

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

func (*CreateViewExpr) Reset added in v0.9.0 

func (x *CreateViewExpr) Reset()

func (*CreateViewExpr) String added in v0.9.0 

func (x *CreateViewExpr) String() string

type DdlRequest 

type DdlRequest struct {

	// Types that are assignable to Expr:
	//
	//	*DdlRequest_CreateDatabase
	//	*DdlRequest_CreateTable
	//	*DdlRequest_Alter
	//	*DdlRequest_DropTable
	//	*DdlRequest_TruncateTable
	//	*DdlRequest_CreateFlow
	//	*DdlRequest_DropFlow
	//	*DdlRequest_CreateView
	//	*DdlRequest_DropView
	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) GetCreateFlow added in v0.9.0 

func (x *DdlRequest) GetCreateFlow() *CreateFlowExpr

func (*DdlRequest) GetCreateTable 

func (x *DdlRequest) GetCreateTable() *CreateTableExpr

func (*DdlRequest) GetCreateView added in v0.9.0 

func (x *DdlRequest) GetCreateView() *CreateViewExpr

func (*DdlRequest) GetDropFlow added in v0.9.0 

func (x *DdlRequest) GetDropFlow() *DropFlowExpr

func (*DdlRequest) GetDropTable 

func (x *DdlRequest) GetDropTable() *DropTableExpr

func (*DdlRequest) GetDropView added in v0.9.0 

func (x *DdlRequest) GetDropView() *DropViewExpr

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_CreateFlow added in v0.9.0 

type DdlRequest_CreateFlow struct {
	CreateFlow *CreateFlowExpr `protobuf:"bytes,8,opt,name=create_flow,json=createFlow,proto3,oneof"`
}

type DdlRequest_CreateTable 

type DdlRequest_CreateTable struct {
	CreateTable *CreateTableExpr `protobuf:"bytes,2,opt,name=create_table,json=createTable,proto3,oneof"`
}

type DdlRequest_CreateView added in v0.9.0 

type DdlRequest_CreateView struct {
	CreateView *CreateViewExpr `protobuf:"bytes,10,opt,name=create_view,json=createView,proto3,oneof"`
}

type DdlRequest_DropFlow added in v0.9.0 

type DdlRequest_DropFlow struct {
	DropFlow *DropFlowExpr `protobuf:"bytes,9,opt,name=drop_flow,json=dropFlow,proto3,oneof"`
}

type DdlRequest_DropTable 

type DdlRequest_DropTable struct {
	DropTable *DropTableExpr `protobuf:"bytes,4,opt,name=drop_table,json=dropTable,proto3,oneof"`
}

type DdlRequest_DropView added in v0.9.0 

type DdlRequest_DropView struct {
	DropView *DropViewExpr `protobuf:"bytes,11,opt,name=drop_view,json=dropView,proto3,oneof"`
}

type DdlRequest_TruncateTable 

type DdlRequest_TruncateTable struct {
	TruncateTable *TruncateTableExpr `protobuf:"bytes,7,opt,name=truncate_table,json=truncateTable,proto3,oneof"`
}

type Decimal128 added in v0.4.1 

type Decimal128 struct {
	Hi int64 `protobuf:"varint,1,opt,name=hi,proto3" json:"hi,omitempty"`
	Lo int64 `protobuf:"varint,2,opt,name=lo,proto3" json:"lo,omitempty"`
	// contains filtered or unexported fields
}

(hi: high 64 bits, lo: low 64 bits) are used to keep the decimal128 value.

func (*Decimal128) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use Decimal128.ProtoReflect.Descriptor instead.

func (*Decimal128) GetHi added in v0.4.1 

func (x *Decimal128) GetHi() int64

func (*Decimal128) GetLo added in v0.4.1 

func (x *Decimal128) GetLo() int64

func (*Decimal128) ProtoMessage added in v0.4.1 

func (*Decimal128) ProtoMessage()

func (*Decimal128) ProtoReflect added in v0.4.1 

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

func (*Decimal128) Reset added in v0.4.1 

func (x *Decimal128) Reset()

func (*Decimal128) String added in v0.4.1 

func (x *Decimal128) String() string

type DecimalTypeExtension added in v0.4.1 

type DecimalTypeExtension struct {
	Precision int32 `protobuf:"varint,1,opt,name=precision,proto3" json:"precision,omitempty"`
	Scale     int32 `protobuf:"varint,2,opt,name=scale,proto3" json:"scale,omitempty"`
	// contains filtered or unexported fields
}

func (*DecimalTypeExtension) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use DecimalTypeExtension.ProtoReflect.Descriptor instead.

func (*DecimalTypeExtension) GetPrecision added in v0.4.1 

func (x *DecimalTypeExtension) GetPrecision() int32

func (*DecimalTypeExtension) GetScale added in v0.4.1 

func (x *DecimalTypeExtension) GetScale() int32

func (*DecimalTypeExtension) ProtoMessage added in v0.4.1 

func (*DecimalTypeExtension) ProtoMessage()

func (*DecimalTypeExtension) ProtoReflect added in v0.4.1 

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

func (*DecimalTypeExtension) Reset added in v0.4.1 

func (x *DecimalTypeExtension) Reset()

func (*DecimalTypeExtension) String added in v0.4.1 

func (x *DecimalTypeExtension) String() string

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 DropDatabaseExpr added in v0.7.0 

type DropDatabaseExpr 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"`
	DropIfExists bool   `protobuf:"varint,3,opt,name=drop_if_exists,json=dropIfExists,proto3" json:"drop_if_exists,omitempty"`
	// contains filtered or unexported fields
}

func (*DropDatabaseExpr) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use DropDatabaseExpr.ProtoReflect.Descriptor instead.

func (*DropDatabaseExpr) GetCatalogName added in v0.7.0 

func (x *DropDatabaseExpr) GetCatalogName() string

func (*DropDatabaseExpr) GetDropIfExists added in v0.7.0 

func (x *DropDatabaseExpr) GetDropIfExists() bool

func (*DropDatabaseExpr) GetSchemaName added in v0.7.0 

func (x *DropDatabaseExpr) GetSchemaName() string

func (*DropDatabaseExpr) ProtoMessage added in v0.7.0 

func (*DropDatabaseExpr) ProtoMessage()

func (*DropDatabaseExpr) ProtoReflect added in v0.7.0 

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

func (*DropDatabaseExpr) Reset added in v0.7.0 

func (x *DropDatabaseExpr) Reset()

func (*DropDatabaseExpr) String added in v0.7.0 

func (x *DropDatabaseExpr) String() string

type DropFlowExpr added in v0.9.0 

type DropFlowExpr struct {
	CatalogName  string  `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	FlowName     string  `protobuf:"bytes,2,opt,name=flow_name,json=flowName,proto3" json:"flow_name,omitempty"`
	FlowId       *FlowId `protobuf:"bytes,3,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	DropIfExists bool    `protobuf:"varint,5,opt,name=drop_if_exists,json=dropIfExists,proto3" json:"drop_if_exists,omitempty"`
	// contains filtered or unexported fields
}

Drop a flow.

func (*DropFlowExpr) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use DropFlowExpr.ProtoReflect.Descriptor instead.

func (*DropFlowExpr) GetCatalogName added in v0.9.0 

func (x *DropFlowExpr) GetCatalogName() string

func (*DropFlowExpr) GetDropIfExists added in v0.9.0 

func (x *DropFlowExpr) GetDropIfExists() bool

func (*DropFlowExpr) GetFlowId added in v0.9.0 

func (x *DropFlowExpr) GetFlowId() *FlowId

func (*DropFlowExpr) GetFlowName added in v0.9.0 

func (x *DropFlowExpr) GetFlowName() string

func (*DropFlowExpr) ProtoMessage added in v0.9.0 

func (*DropFlowExpr) ProtoMessage()

func (*DropFlowExpr) ProtoReflect added in v0.9.0 

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

func (*DropFlowExpr) Reset added in v0.9.0 

func (x *DropFlowExpr) Reset()

func (*DropFlowExpr) String added in v0.9.0 

func (x *DropFlowExpr) 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"`
	DropIfExists bool     `protobuf:"varint,5,opt,name=drop_if_exists,json=dropIfExists,proto3" json:"drop_if_exists,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) GetDropIfExists added in v0.4.1 

func (x *DropTableExpr) GetDropIfExists() bool

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 DropViewExpr added in v0.9.0 

type DropViewExpr 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"`
	ViewName     string   `protobuf:"bytes,3,opt,name=view_name,json=viewName,proto3" json:"view_name,omitempty"`
	ViewId       *TableId `protobuf:"bytes,4,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	DropIfExists bool     `protobuf:"varint,5,opt,name=drop_if_exists,json=dropIfExists,proto3" json:"drop_if_exists,omitempty"`
	// contains filtered or unexported fields
}

Drop a view

func (*DropViewExpr) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use DropViewExpr.ProtoReflect.Descriptor instead.

func (*DropViewExpr) GetCatalogName added in v0.9.0 

func (x *DropViewExpr) GetCatalogName() string

func (*DropViewExpr) GetDropIfExists added in v0.9.0 

func (x *DropViewExpr) GetDropIfExists() bool

func (*DropViewExpr) GetSchemaName added in v0.9.0 

func (x *DropViewExpr) GetSchemaName() string

func (*DropViewExpr) GetViewId added in v0.9.0 

func (x *DropViewExpr) GetViewId() *TableId

func (*DropViewExpr) GetViewName added in v0.9.0 

func (x *DropViewExpr) GetViewName() string

func (*DropViewExpr) ProtoMessage added in v0.9.0 

func (*DropViewExpr) ProtoMessage()

func (*DropViewExpr) ProtoReflect added in v0.9.0 

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

func (*DropViewExpr) Reset added in v0.9.0 

func (x *DropViewExpr) Reset()

func (*DropViewExpr) String added in v0.9.0 

func (x *DropViewExpr) String() string

type ExpireAfter added in v0.9.0 

type ExpireAfter struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ExpireAfter) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ExpireAfter.ProtoReflect.Descriptor instead.

func (*ExpireAfter) GetValue added in v0.9.0 

func (x *ExpireAfter) GetValue() int64

func (*ExpireAfter) ProtoMessage added in v0.9.0 

func (*ExpireAfter) ProtoMessage()

func (*ExpireAfter) ProtoReflect added in v0.9.0 

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

func (*ExpireAfter) Reset added in v0.9.0 

func (x *ExpireAfter) Reset()

func (*ExpireAfter) String added in v0.9.0 

func (x *ExpireAfter) String() string

type FlightMetadata 

type FlightMetadata struct {
	AffectedRows *AffectedRows `protobuf:"bytes,1,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"`
	Metrics      *Metrics      `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,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) GetMetrics added in v0.4.3 

func (x *FlightMetadata) GetMetrics() *Metrics

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 FlowId added in v0.9.0 

type FlowId struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowId) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use FlowId.ProtoReflect.Descriptor instead.

func (*FlowId) GetId added in v0.9.0 

func (x *FlowId) GetId() uint32

func (*FlowId) ProtoMessage added in v0.9.0 

func (*FlowId) ProtoMessage()

func (*FlowId) ProtoReflect added in v0.9.0 

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

func (*FlowId) Reset added in v0.9.0 

func (x *FlowId) Reset()

func (*FlowId) String added in v0.9.0 

func (x *FlowId) 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 JsonTypeExtension added in v0.9.0 

type JsonTypeExtension int32
const (
	JsonTypeExtension_JSON_BINARY JsonTypeExtension = 0
)

func (JsonTypeExtension) Descriptor added in v0.9.0 

func (JsonTypeExtension) Descriptor() protoreflect.EnumDescriptor

func (JsonTypeExtension) Enum added in v0.9.0 

func (x JsonTypeExtension) Enum() *JsonTypeExtension

func (JsonTypeExtension) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use JsonTypeExtension.Descriptor instead.

func (JsonTypeExtension) Number added in v0.9.0 

func (x JsonTypeExtension) Number() protoreflect.EnumNumber

func (JsonTypeExtension) String added in v0.9.0 

func (x JsonTypeExtension) String() string

func (JsonTypeExtension) Type added in v0.9.0 

func (JsonTypeExtension) Type() protoreflect.EnumType

type Metrics added in v0.4.3 

type Metrics struct {
	Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated added in v0.4.3 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetMetrics added in v0.4.3 

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

func (*Metrics) ProtoMessage added in v0.4.3 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect added in v0.4.3 

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

func (*Metrics) Reset added in v0.4.3 

func (x *Metrics) Reset()

func (*Metrics) String added in v0.4.3 

func (x *Metrics) 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) Descriptor() ([]byte, []int)

Deprecated: Use Mutation.ProtoReflect.Descriptor instead.

func (*Mutation) GetOpType added in v0.4.0 

func (x *Mutation) GetOpType() OpType

func (*Mutation) GetRows added in v0.4.0 

func (x *Mutation) GetRows() *Rows

func (*Mutation) GetSequence added in v0.4.0 

func (x *Mutation) GetSequence() uint64

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

func (*Mutation) Reset added in v0.4.0 

func (x *Mutation) Reset()

func (*Mutation) String added in v0.4.0 

func (x *Mutation) String() string

type OpType added in v0.4.0 

type OpType int32

Type of operation to rows. 

const (
	// Delete rows.
	OpType_DELETE OpType = 0
	// Put rows.
	OpType_PUT OpType = 1
)

func (OpType) Descriptor added in v0.4.0 

func (OpType) Descriptor() protoreflect.EnumDescriptor

func (OpType) Enum added in v0.4.0 

func (x OpType) Enum() *OpType

func (OpType) EnumDescriptor deprecated added in v0.4.0 

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

Deprecated: Use OpType.Descriptor instead.

func (OpType) Number added in v0.4.0 

func (x OpType) Number() protoreflect.EnumNumber

func (OpType) String added in v0.4.0 

func (x OpType) String() string

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"`
	Lookback string `protobuf:"bytes,3,opt,name=lookback,proto3" json:"lookback,omitempty"`
	// contains filtered or unexported fields
}

func (*PromInstantQuery) Descriptor deprecated 

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

Deprecated: Use PromInstantQuery.ProtoReflect.Descriptor instead.

func (*PromInstantQuery) GetLookback added in v0.7.0 

func (x *PromInstantQuery) GetLookback() string

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"`
	Lookback string `protobuf:"bytes,5,opt,name=lookback,proto3" json:"lookback,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) GetLookback added in v0.7.0 

func (x *PromRangeQuery) GetLookback() 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 QueryContext added in v0.9.0 

type QueryContext struct {
	CurrentCatalog string            `protobuf:"bytes,1,opt,name=current_catalog,json=currentCatalog,proto3" json:"current_catalog,omitempty"`
	CurrentSchema  string            `protobuf:"bytes,2,opt,name=current_schema,json=currentSchema,proto3" json:"current_schema,omitempty"`
	Timezone       string            `protobuf:"bytes,4,opt,name=timezone,proto3" json:"timezone,omitempty"`
	Extensions     map[string]string `` /* 161-byte string literal not displayed */
	Channel        uint32            `protobuf:"varint,6,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryContext) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use QueryContext.ProtoReflect.Descriptor instead.

func (*QueryContext) GetChannel added in v0.9.0 

func (x *QueryContext) GetChannel() uint32

func (*QueryContext) GetCurrentCatalog added in v0.9.0 

func (x *QueryContext) GetCurrentCatalog() string

func (*QueryContext) GetCurrentSchema added in v0.9.0 

func (x *QueryContext) GetCurrentSchema() string

func (*QueryContext) GetExtensions added in v0.9.0 

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

func (*QueryContext) GetTimezone added in v0.9.0 

func (x *QueryContext) GetTimezone() string

func (*QueryContext) ProtoMessage added in v0.9.0 

func (*QueryContext) ProtoMessage()

func (*QueryContext) ProtoReflect added in v0.9.0 

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

func (*QueryContext) Reset added in v0.9.0 

func (x *QueryContext) Reset()

func (*QueryContext) String added in v0.9.0 

func (x *QueryContext) 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"`
	// Encoded trace_id & span_id, follow the w3c Trace Context
	// https://www.w3.org/TR/trace-context/#header-name
	TracingContext map[string]string `` /* 191-byte string literal not displayed */
	// The `timezone` for the request
	Timezone string `protobuf:"bytes,6,opt,name=timezone,proto3" json:"timezone,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) GetTimezone added in v0.4.3 

func (x *RequestHeader) GetTimezone() string

func (*RequestHeader) GetTracingContext added in v0.4.1 

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetValues added in v0.4.0 

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

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

func (*Row) Reset added in v0.4.0 

func (x *Row) Reset()

func (*Row) String added in v0.4.0 

func (x *Row) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Rows.ProtoReflect.Descriptor instead.

func (*Rows) GetRows added in v0.4.0 

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

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

func (*Rows) Reset added in v0.4.0 

func (x *Rows) Reset()

func (*Rows) String added in v0.4.0 

func (x *Rows) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetErrMsg 

func (x *Status) GetErrMsg() string

func (*Status) GetStatusCode 

func (x *Status) GetStatusCode() uint32

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TableId.ProtoReflect.Descriptor instead.

func (*TableId) GetId 

func (x *TableId) GetId() uint32

func (*TableId) ProtoMessage 

func (*TableId) ProtoMessage()

func (*TableId) ProtoReflect 

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

func (*TableId) Reset 

func (x *TableId) Reset()

func (*TableId) String 

func (x *TableId) String() string

type TableName added in v0.7.0 

type TableName 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"`
	// contains filtered or unexported fields
}

func (*TableName) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use TableName.ProtoReflect.Descriptor instead.

func (*TableName) GetCatalogName added in v0.7.0 

func (x *TableName) GetCatalogName() string

func (*TableName) GetSchemaName added in v0.7.0 

func (x *TableName) GetSchemaName() string

func (*TableName) GetTableName added in v0.7.0 

func (x *TableName) GetTableName() string

func (*TableName) ProtoMessage added in v0.7.0 

func (*TableName) ProtoMessage()

func (*TableName) ProtoReflect added in v0.7.0 

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

func (*TableName) Reset added in v0.7.0 

func (x *TableName) Reset()

func (*TableName) String added in v0.7.0 

func (x *TableName) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetToken 

func (x *Token) GetToken() string

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) ProtoReflect 

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

func (*Token) Reset 

func (x *Token) Reset()

func (*Token) String 

func (x *Token) String() string

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_IntervalYearMonthValue
	//	*Value_IntervalDayTimeValue
	//	*Value_IntervalMonthDayNanoValue
	//	*Value_Decimal128Value
	ValueData isValue_ValueData `protobuf_oneof:"value_data"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBinaryValue added in v0.4.0 

func (x *Value) GetBinaryValue() []byte

func (*Value) GetBoolValue added in v0.4.0 

func (x *Value) GetBoolValue() bool

func (*Value) GetDateValue added in v0.4.0 

func (x *Value) GetDateValue() int32

func (*Value) GetDatetimeValue added in v0.4.0 

func (x *Value) GetDatetimeValue() int64

func (*Value) GetDecimal128Value added in v0.4.1 

func (x *Value) GetDecimal128Value() *Decimal128

func (*Value) GetF32Value added in v0.4.0 

func (x *Value) GetF32Value() float32

func (*Value) GetF64Value added in v0.4.0 

func (x *Value) GetF64Value() float64

func (*Value) GetI16Value added in v0.4.0 

func (x *Value) GetI16Value() int32

func (*Value) GetI32Value added in v0.4.0 

func (x *Value) GetI32Value() int32

func (*Value) GetI64Value added in v0.4.0 

func (x *Value) GetI64Value() int64

func (*Value) GetI8Value added in v0.4.0 

func (x *Value) GetI8Value() int32

func (*Value) GetIntervalDayTimeValue added in v0.4.2 

func (x *Value) GetIntervalDayTimeValue() int64

func (*Value) GetIntervalMonthDayNanoValue added in v0.4.2 

func (x *Value) GetIntervalMonthDayNanoValue() *IntervalMonthDayNano

func (*Value) GetIntervalYearMonthValue added in v0.4.2 

func (x *Value) GetIntervalYearMonthValue() int32

func (*Value) GetStringValue added in v0.4.0 

func (x *Value) GetStringValue() string

func (*Value) GetTimeMicrosecondValue added in v0.4.0 

func (x *Value) GetTimeMicrosecondValue() int64

func (*Value) GetTimeMillisecondValue added in v0.4.0 

func (x *Value) GetTimeMillisecondValue() int64

func (*Value) GetTimeNanosecondValue added in v0.4.0 

func (x *Value) GetTimeNanosecondValue() int64

func (*Value) GetTimeSecondValue added in v0.4.0 

func (x *Value) GetTimeSecondValue() int64

func (*Value) GetTimestampMicrosecondValue added in v0.4.0 

func (x *Value) GetTimestampMicrosecondValue() int64

func (*Value) GetTimestampMillisecondValue added in v0.4.0 

func (x *Value) GetTimestampMillisecondValue() int64

func (*Value) GetTimestampNanosecondValue added in v0.4.0 

func (x *Value) GetTimestampNanosecondValue() int64

func (*Value) GetTimestampSecondValue added in v0.4.0 

func (x *Value) GetTimestampSecondValue() int64

func (*Value) GetU16Value added in v0.4.0 

func (x *Value) GetU16Value() uint32

func (*Value) GetU32Value added in v0.4.0 

func (x *Value) GetU32Value() uint32

func (*Value) GetU64Value added in v0.4.0 

func (x *Value) GetU64Value() uint64

func (*Value) GetU8Value added in v0.4.0 

func (x *Value) GetU8Value() uint32

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

func (*Value) Reset added in v0.4.0 

func (x *Value) Reset()

func (*Value) String added in v0.4.0 

func (x *Value) String() string

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_Decimal128Value added in v0.4.1 

type Value_Decimal128Value struct {
	Decimal128Value *Decimal128 `protobuf:"bytes,31,opt,name=decimal128_value,json=decimal128Value,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_IntervalDayTimeValue added in v0.4.2 

type Value_IntervalDayTimeValue struct {
	IntervalDayTimeValue int64 `protobuf:"varint,25,opt,name=interval_day_time_value,json=intervalDayTimeValue,proto3,oneof"`
}

type Value_IntervalMonthDayNanoValue added in v0.4.2 

type Value_IntervalMonthDayNanoValue struct {
	IntervalMonthDayNanoValue *IntervalMonthDayNano `protobuf:"bytes,26,opt,name=interval_month_day_nano_value,json=intervalMonthDayNanoValue,proto3,oneof"`
}

type Value_IntervalYearMonthValue added in v0.4.2 

type Value_IntervalYearMonthValue struct {
	IntervalYearMonthValue int32 `protobuf:"varint,24,opt,name=interval_year_month_value,json=intervalYearMonthValue,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) Descriptor() ([]byte, []int)

Deprecated: Use WalEntry.ProtoReflect.Descriptor instead.

func (*WalEntry) GetMutations added in v0.4.0 

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

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

func (*WalEntry) Reset added in v0.4.0 

func (x *WalEntry) Reset()

func (*WalEntry) String added in v0.4.0 

func (x *WalEntry) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.