proto

package
v0.2.4-rc.5 Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2021 License: MPL-2.0 Imports: 10 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NullValue_name = map[int32]string{
		0: "NULL_VALUE",
	}
	NullValue_value = map[string]int32{
		"NULL_VALUE": 0,
	}
)

Enum value maps for NullValue.

View Source 
var (
	ColumnType_name = map[int32]string{
		0:  "BOOL",
		1:  "INT",
		2:  "DOUBLE",
		3:  "STRING",
		4:  "JSON",
		5:  "DATETIME",
		6:  "IPADDR",
		7:  "CIDR",
		8:  "TIMESTAMP",
		-1: "UNKNOWN",
	}
	ColumnType_value = map[string]int32{
		"BOOL":      0,
		"INT":       1,
		"DOUBLE":    2,
		"STRING":    3,
		"JSON":      4,
		"DATETIME":  5,
		"IPADDR":    6,
		"CIDR":      7,
		"TIMESTAMP": 8,
		"UNKNOWN":   -1,
	}
)

Enum value maps for ColumnType.

View Source 
var (
	Operator_Operation_name = map[int32]string{
		0: "ANY",
		1: "ALL",
	}
	Operator_Operation_value = map[string]int32{
		"ANY": 0,
		"ALL": 1,
	}
)

Enum value maps for Operator_Operation.

View Source 
var File_plugin_proto protoreflect.FileDescriptor

Functions

func RegisterWrapperPluginServer 

func RegisterWrapperPluginServer(s *grpc.Server, srv WrapperPluginServer)

Types

type Column 

type Column struct {

	// Types that are assignable to Value:
	//	*Column_NullValue
	//	*Column_DoubleValue
	//	*Column_IntValue
	//	*Column_StringValue
	//	*Column_BoolValue
	//	*Column_JsonValue
	//	*Column_TimestampValue
	//	*Column_IpAddrValue
	//	*Column_CidrRangeValue
	Value isColumn_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetBoolValue 

func (x *Column) GetBoolValue() bool

func (*Column) GetCidrRangeValue 

func (x *Column) GetCidrRangeValue() string

func (*Column) GetDoubleValue 

func (x *Column) GetDoubleValue() float64

func (*Column) GetIntValue 

func (x *Column) GetIntValue() int64

func (*Column) GetIpAddrValue 

func (x *Column) GetIpAddrValue() string

func (*Column) GetJsonValue 

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

func (*Column) GetNullValue 

func (x *Column) GetNullValue() NullValue

func (*Column) GetStringValue 

func (x *Column) GetStringValue() string

func (*Column) GetTimestampValue 

func (x *Column) GetTimestampValue() *timestamp.Timestamp

func (*Column) GetValue 

func (m *Column) GetValue() isColumn_Value

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 ColumnDefinition 

type ColumnDefinition struct {
	Name        string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        ColumnType `protobuf:"varint,2,opt,name=type,proto3,enum=proto.ColumnType" json:"type,omitempty"`
	Description string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnDefinition) Descriptor deprecated 

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

Deprecated: Use ColumnDefinition.ProtoReflect.Descriptor instead.

func (*ColumnDefinition) GetDescription 

func (x *ColumnDefinition) GetDescription() string

func (*ColumnDefinition) GetName 

func (x *ColumnDefinition) GetName() string

func (*ColumnDefinition) GetType 

func (x *ColumnDefinition) GetType() ColumnType

func (*ColumnDefinition) ProtoMessage 

func (*ColumnDefinition) ProtoMessage()

func (*ColumnDefinition) ProtoReflect 

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

func (*ColumnDefinition) Reset 

func (x *ColumnDefinition) Reset()

func (*ColumnDefinition) String 

func (x *ColumnDefinition) String() string

type ColumnType 

type ColumnType int32
const (
	ColumnType_BOOL   ColumnType = 0
	ColumnType_INT    ColumnType = 1
	ColumnType_DOUBLE ColumnType = 2
	ColumnType_STRING ColumnType = 3
	ColumnType_JSON   ColumnType = 4
	// Deprecated: ColumnType_DATETIME is deprecated. Instead, use ColumnType_TIMESTAMP
	ColumnType_DATETIME  ColumnType = 5
	ColumnType_IPADDR    ColumnType = 6
	ColumnType_CIDR      ColumnType = 7
	ColumnType_TIMESTAMP ColumnType = 8
	ColumnType_UNKNOWN   ColumnType = -1
)

func (ColumnType) Descriptor 

func (ColumnType) Descriptor() protoreflect.EnumDescriptor

func (ColumnType) Enum 

func (x ColumnType) Enum() *ColumnType

func (ColumnType) EnumDescriptor deprecated 

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

Deprecated: Use ColumnType.Descriptor instead.

func (ColumnType) Number 

func (x ColumnType) Number() protoreflect.EnumNumber

func (ColumnType) String 

func (x ColumnType) String() string

func (ColumnType) Type 

func (ColumnType) Type() protoreflect.EnumType

type Column_BoolValue 

type Column_BoolValue struct {
	// Represents a boolean value.
	BoolValue bool `protobuf:"varint,6,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Column_CidrRangeValue 

type Column_CidrRangeValue struct {
	// Represents an cidr range value
	CidrRangeValue string `protobuf:"bytes,10,opt,name=cidr_range_value,json=cidrRangeValue,proto3,oneof"`
}

type Column_DoubleValue 

type Column_DoubleValue struct {
	// Represents a double value.
	DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Column_IntValue 

type Column_IntValue struct {
	// Represents an int value
	IntValue int64 `protobuf:"varint,4,opt,name=int_value,json=intValue,proto3,oneof"`
}

type Column_IpAddrValue 

type Column_IpAddrValue struct {
	// Represents an ip address value
	IpAddrValue string `protobuf:"bytes,9,opt,name=ip_addr_value,json=ipAddrValue,proto3,oneof"`
}

type Column_JsonValue 

type Column_JsonValue struct {
	// JSON string
	JsonValue []byte `protobuf:"bytes,7,opt,name=json_value,json=jsonValue,proto3,oneof"`
}

type Column_NullValue 

type Column_NullValue struct {
	// Represents a null value.
	NullValue NullValue `protobuf:"varint,2,opt,name=null_value,json=nullValue,proto3,enum=proto.NullValue,oneof"`
}

type Column_StringValue 

type Column_StringValue struct {
	// Represents a string value.
	StringValue string `protobuf:"bytes,5,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Column_TimestampValue 

type Column_TimestampValue struct {
	// Represents a datetime value
	TimestampValue *timestamp.Timestamp `protobuf:"bytes,8,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type ExecuteRequest 

type ExecuteRequest struct {
	Table        string        `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	QueryContext *QueryContext `protobuf:"bytes,2,opt,name=query_context,json=queryContext,proto3" json:"query_context,omitempty"`
	Connection   string        `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetConnection added in v0.2.0 

func (x *ExecuteRequest) GetConnection() string

func (*ExecuteRequest) GetQueryContext 

func (x *ExecuteRequest) GetQueryContext() *QueryContext

func (*ExecuteRequest) GetTable 

func (x *ExecuteRequest) GetTable() string

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

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

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteResponse 

type ExecuteResponse struct {
	Row *Row `protobuf:"bytes,1,opt,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetRow 

func (x *ExecuteResponse) GetRow() *Row

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

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

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type GetSchemaRequest 

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

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

type GetSchemaResponse 

type GetSchemaResponse struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchema 

func (x *GetSchemaResponse) GetSchema() *Schema

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

type Inet 

type Inet struct {
	Mask            int32  `protobuf:"varint,1,opt,name=mask,proto3" json:"mask,omitempty"`
	Addr            string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Cidr            string `protobuf:"bytes,3,opt,name=cidr,proto3" json:"cidr,omitempty"`
	ProtocolVersion string `protobuf:"bytes,4,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// contains filtered or unexported fields
}

func (*Inet) Descriptor deprecated 

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

Deprecated: Use Inet.ProtoReflect.Descriptor instead.

func (*Inet) GetAddr 

func (x *Inet) GetAddr() string

func (*Inet) GetCidr 

func (x *Inet) GetCidr() string

func (*Inet) GetMask 

func (x *Inet) GetMask() int32

func (*Inet) GetProtocolVersion 

func (x *Inet) GetProtocolVersion() string

func (*Inet) ProtoMessage 

func (*Inet) ProtoMessage()

func (*Inet) ProtoReflect 

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

func (*Inet) Reset 

func (x *Inet) Reset()

func (*Inet) String 

func (x *Inet) String() string

type KeyColumnsSet added in v0.2.4 

type KeyColumnsSet struct {
	Single string   `protobuf:"bytes,1,opt,name=single,proto3" json:"single,omitempty"`
	All    []string `protobuf:"bytes,2,rep,name=all,proto3" json:"all,omitempty"`
	Any    []string `protobuf:"bytes,3,rep,name=any,proto3" json:"any,omitempty"`
	// contains filtered or unexported fields
}

a set of Key Columns, all of which are reuired

func (*KeyColumnsSet) Descriptor deprecated added in v0.2.4 

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

Deprecated: Use KeyColumnsSet.ProtoReflect.Descriptor instead.

func (*KeyColumnsSet) GetAll added in v0.2.4 

func (x *KeyColumnsSet) GetAll() []string

func (*KeyColumnsSet) GetAny added in v0.2.4 

func (x *KeyColumnsSet) GetAny() []string

func (*KeyColumnsSet) GetSingle added in v0.2.4 

func (x *KeyColumnsSet) GetSingle() string

func (*KeyColumnsSet) ProtoMessage added in v0.2.4 

func (*KeyColumnsSet) ProtoMessage()

func (*KeyColumnsSet) ProtoReflect added in v0.2.4 

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

func (*KeyColumnsSet) Reset added in v0.2.4 

func (x *KeyColumnsSet) Reset()

func (*KeyColumnsSet) String added in v0.2.4 

func (x *KeyColumnsSet) String() string

type NullValue 

type NullValue int32

`NullValue` is a singleton enumeration to represent the null value for the `Value` type union. 

The JSON representation for `NullValue` is JSON `null`.

const (
	// Null value.
	NullValue_NULL_VALUE NullValue = 0
)

func (NullValue) Descriptor 

func (NullValue) Descriptor() protoreflect.EnumDescriptor

func (NullValue) Enum 

func (x NullValue) Enum() *NullValue

func (NullValue) EnumDescriptor deprecated 

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

Deprecated: Use NullValue.Descriptor instead.

func (NullValue) Number 

func (x NullValue) Number() protoreflect.EnumNumber

func (NullValue) String 

func (x NullValue) String() string

func (NullValue) Type 

func (NullValue) Type() protoreflect.EnumType

type Operator deprecated 

type Operator struct {
	Name      string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Operation Operator_Operation `protobuf:"varint,2,opt,name=operation,proto3,enum=proto.Operator_Operation" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Do not use.

func (*Operator) Descriptor deprecated 

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

Deprecated: Use Operator.ProtoReflect.Descriptor instead.

func (*Operator) GetName 

func (x *Operator) GetName() string

func (*Operator) GetOperation 

func (x *Operator) GetOperation() Operator_Operation

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) ProtoReflect 

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

func (*Operator) Reset 

func (x *Operator) Reset()

func (*Operator) String 

func (x *Operator) String() string

type Operator_Operation 

type Operator_Operation int32
const (
	Operator_ANY Operator_Operation = 0
	Operator_ALL Operator_Operation = 1
)

func (Operator_Operation) Descriptor 

func (Operator_Operation) Descriptor() protoreflect.EnumDescriptor

func (Operator_Operation) Enum 

func (x Operator_Operation) Enum() *Operator_Operation

func (Operator_Operation) EnumDescriptor deprecated 

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

Deprecated: Use Operator_Operation.Descriptor instead.

func (Operator_Operation) Number 

func (x Operator_Operation) Number() protoreflect.EnumNumber

func (Operator_Operation) String 

func (x Operator_Operation) String() string

func (Operator_Operation) Type 

func (Operator_Operation) Type() protoreflect.EnumType

type Qual 

type Qual struct {
	FieldName string `protobuf:"bytes,1,opt,name=fieldName,proto3" json:"fieldName,omitempty"`
	// Types that are assignable to Operator:
	//	*Qual_StringValue
	//	*Qual_TupleValue
	Operator isQual_Operator `protobuf_oneof:"operator"`
	Value    *QualValue      `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Qual) Descriptor deprecated 

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

Deprecated: Use Qual.ProtoReflect.Descriptor instead.

func (*Qual) GetFieldName 

func (x *Qual) GetFieldName() string

func (*Qual) GetOperator 

func (m *Qual) GetOperator() isQual_Operator

func (*Qual) GetStringValue 

func (x *Qual) GetStringValue() string

func (*Qual) GetTupleValue deprecated 

func (x *Qual) GetTupleValue() *Operator

Deprecated: Do not use.

func (*Qual) GetValue 

func (x *Qual) GetValue() *QualValue

func (*Qual) ProtoMessage 

func (*Qual) ProtoMessage()

func (*Qual) ProtoReflect 

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

func (*Qual) Reset 

func (x *Qual) Reset()

func (*Qual) String 

func (x *Qual) String() string

type QualValue 

type QualValue struct {

	// Types that are assignable to Value:
	//	*QualValue_StringValue
	//	*QualValue_Int64Value
	//	*QualValue_DoubleValue
	//	*QualValue_BoolValue
	//	*QualValue_InetValue
	//	*QualValue_JsonbValue
	//	*QualValue_TimestampValue
	//	*QualValue_ListValue
	Value isQualValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*QualValue) Descriptor deprecated 

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

Deprecated: Use QualValue.ProtoReflect.Descriptor instead.

func (*QualValue) GetBoolValue 

func (x *QualValue) GetBoolValue() bool

func (*QualValue) GetDoubleValue 

func (x *QualValue) GetDoubleValue() float64

func (*QualValue) GetInetValue 

func (x *QualValue) GetInetValue() *Inet

func (*QualValue) GetInt64Value 

func (x *QualValue) GetInt64Value() int64

func (*QualValue) GetJsonbValue 

func (x *QualValue) GetJsonbValue() string

func (*QualValue) GetListValue 

func (x *QualValue) GetListValue() *QualValueList

func (*QualValue) GetStringValue 

func (x *QualValue) GetStringValue() string

func (*QualValue) GetTimestampValue 

func (x *QualValue) GetTimestampValue() *timestamp.Timestamp

func (*QualValue) GetValue 

func (m *QualValue) GetValue() isQualValue_Value

func (*QualValue) ProtoMessage 

func (*QualValue) ProtoMessage()

func (*QualValue) ProtoReflect 

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

func (*QualValue) Reset 

func (x *QualValue) Reset()

func (*QualValue) String 

func (x *QualValue) String() string

type QualValueList 

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

func (*QualValueList) Descriptor deprecated 

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

Deprecated: Use QualValueList.ProtoReflect.Descriptor instead.

func (*QualValueList) GetValues 

func (x *QualValueList) GetValues() []*QualValue

func (*QualValueList) ProtoMessage 

func (*QualValueList) ProtoMessage()

func (*QualValueList) ProtoReflect 

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

func (*QualValueList) Reset 

func (x *QualValueList) Reset()

func (*QualValueList) String 

func (x *QualValueList) String() string

type QualValue_BoolValue 

type QualValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type QualValue_DoubleValue 

type QualValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type QualValue_InetValue 

type QualValue_InetValue struct {
	InetValue *Inet `protobuf:"bytes,5,opt,name=inet_value,json=inetValue,proto3,oneof"`
}

type QualValue_Int64Value 

type QualValue_Int64Value struct {
	Int64Value int64 `protobuf:"varint,2,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type QualValue_JsonbValue 

type QualValue_JsonbValue struct {
	JsonbValue string `protobuf:"bytes,6,opt,name=jsonb_value,json=jsonbValue,proto3,oneof"`
}

type QualValue_ListValue 

type QualValue_ListValue struct {
	ListValue *QualValueList `protobuf:"bytes,8,opt,name=list_value,json=listValue,proto3,oneof"`
}

type QualValue_StringValue 

type QualValue_StringValue struct {
	StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type QualValue_TimestampValue 

type QualValue_TimestampValue struct {
	TimestampValue *timestamp.Timestamp `protobuf:"bytes,7,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type Qual_StringValue 

type Qual_StringValue struct {
	StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Qual_TupleValue 

type Qual_TupleValue struct {
	// Deprecated: Do not use.
	TupleValue *Operator `protobuf:"bytes,3,opt,name=tuple_value,json=tupleValue,proto3,oneof"`
}

type Quals 

type Quals struct {
	Quals []*Qual `protobuf:"bytes,1,rep,name=quals,proto3" json:"quals,omitempty"`
	// contains filtered or unexported fields
}

func (*Quals) Descriptor deprecated 

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

Deprecated: Use Quals.ProtoReflect.Descriptor instead.

func (*Quals) GetQuals 

func (x *Quals) GetQuals() []*Qual

func (*Quals) ProtoMessage 

func (*Quals) ProtoMessage()

func (*Quals) ProtoReflect 

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

func (*Quals) Reset 

func (x *Quals) Reset()

func (*Quals) String 

func (x *Quals) String() string

type QueryContext 

type QueryContext struct {
	Columns []string          `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Quals   map[string]*Quals `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryContext) Descriptor deprecated 

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

Deprecated: Use QueryContext.ProtoReflect.Descriptor instead.

func (*QueryContext) GetColumns 

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

func (*QueryContext) GetQuals 

func (x *QueryContext) GetQuals() map[string]*Quals

func (*QueryContext) ProtoMessage 

func (*QueryContext) ProtoMessage()

func (*QueryContext) ProtoReflect 

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

func (*QueryContext) Reset 

func (x *QueryContext) Reset()

func (*QueryContext) String 

func (x *QueryContext) String() string

type Row 

type Row struct {
	Columns map[string]*Column `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetColumns 

func (x *Row) GetColumns() map[string]*Column

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

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

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

type Schema 

type Schema struct {
	Schema     map[string]*TableSchema `` /* 153-byte string literal not displayed */
	SdkVersion string                  `protobuf:"bytes,2,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetSchema 

func (x *Schema) GetSchema() map[string]*TableSchema

func (*Schema) GetSdkVersion added in v0.2.0 

func (x *Schema) GetSdkVersion() string

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type SetConnectionConfigRequest added in v0.2.0 

type SetConnectionConfigRequest struct {
	ConnectionName   string `protobuf:"bytes,1,opt,name=connection_name,json=connectionName,proto3" json:"connection_name,omitempty"`
	ConnectionConfig string `protobuf:"bytes,2,opt,name=connection_config,json=connectionConfig,proto3" json:"connection_config,omitempty"`
	// contains filtered or unexported fields
}

func (*SetConnectionConfigRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use SetConnectionConfigRequest.ProtoReflect.Descriptor instead.

func (*SetConnectionConfigRequest) GetConnectionConfig added in v0.2.0 

func (x *SetConnectionConfigRequest) GetConnectionConfig() string

func (*SetConnectionConfigRequest) GetConnectionName added in v0.2.0 

func (x *SetConnectionConfigRequest) GetConnectionName() string

func (*SetConnectionConfigRequest) ProtoMessage added in v0.2.0 

func (*SetConnectionConfigRequest) ProtoMessage()

func (*SetConnectionConfigRequest) ProtoReflect added in v0.2.0 

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

func (*SetConnectionConfigRequest) Reset added in v0.2.0 

func (x *SetConnectionConfigRequest) Reset()

func (*SetConnectionConfigRequest) String added in v0.2.0 

func (x *SetConnectionConfigRequest) String() string

type SetConnectionConfigResponse added in v0.2.0 

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

func (*SetConnectionConfigResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use SetConnectionConfigResponse.ProtoReflect.Descriptor instead.

func (*SetConnectionConfigResponse) ProtoMessage added in v0.2.0 

func (*SetConnectionConfigResponse) ProtoMessage()

func (*SetConnectionConfigResponse) ProtoReflect added in v0.2.0 

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

func (*SetConnectionConfigResponse) Reset added in v0.2.0 

func (x *SetConnectionConfigResponse) Reset()

func (*SetConnectionConfigResponse) String added in v0.2.0 

func (x *SetConnectionConfigResponse) String() string

type TableSchema 

type TableSchema struct {
	Columns            []*ColumnDefinition `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Description        string              `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	GetCallKeyColumns  *KeyColumnsSet      `protobuf:"bytes,3,opt,name=getCallKeyColumns,proto3" json:"getCallKeyColumns,omitempty"`
	ListCallKeyColumns *KeyColumnsSet      `protobuf:"bytes,4,opt,name=listCallKeyColumns,proto3" json:"listCallKeyColumns,omitempty"`
	// contains filtered or unexported fields
}

func (*TableSchema) Descriptor deprecated 

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

Deprecated: Use TableSchema.ProtoReflect.Descriptor instead.

func (*TableSchema) GetColumns 

func (x *TableSchema) GetColumns() []*ColumnDefinition

func (*TableSchema) GetDescription 

func (x *TableSchema) GetDescription() string

func (*TableSchema) GetGetCallKeyColumns added in v0.2.4 

func (x *TableSchema) GetGetCallKeyColumns() *KeyColumnsSet

func (*TableSchema) GetListCallKeyColumns added in v0.2.4 

func (x *TableSchema) GetListCallKeyColumns() *KeyColumnsSet

func (*TableSchema) ProtoMessage 

func (*TableSchema) ProtoMessage()

func (*TableSchema) ProtoReflect 

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

func (*TableSchema) Reset 

func (x *TableSchema) Reset()

func (*TableSchema) String 

func (x *TableSchema) String() string

type UnimplementedWrapperPluginServer 

type UnimplementedWrapperPluginServer struct {
}

UnimplementedWrapperPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedWrapperPluginServer) Execute 

func (*UnimplementedWrapperPluginServer) Execute(*ExecuteRequest, WrapperPlugin_ExecuteServer) error

func (*UnimplementedWrapperPluginServer) GetSchema 

func (*UnimplementedWrapperPluginServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)

func (*UnimplementedWrapperPluginServer) SetConnectionConfig added in v0.2.0 

func (*UnimplementedWrapperPluginServer) SetConnectionConfig(context.Context, *SetConnectionConfigRequest) (*SetConnectionConfigResponse, error)

type WrapperPluginClient 

type WrapperPluginClient interface {
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (WrapperPlugin_ExecuteClient, error)
	SetConnectionConfig(ctx context.Context, in *SetConnectionConfigRequest, opts ...grpc.CallOption) (*SetConnectionConfigResponse, error)
}

WrapperPluginClient is the client API for WrapperPlugin service.

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

func NewWrapperPluginClient 

func NewWrapperPluginClient(cc grpc.ClientConnInterface) WrapperPluginClient

type WrapperPluginServer 

type WrapperPluginServer interface {
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	Execute(*ExecuteRequest, WrapperPlugin_ExecuteServer) error
	SetConnectionConfig(context.Context, *SetConnectionConfigRequest) (*SetConnectionConfigResponse, error)
}

WrapperPluginServer is the server API for WrapperPlugin service.

type WrapperPlugin_ExecuteClient 

type WrapperPlugin_ExecuteClient interface {
	Recv() (*ExecuteResponse, error)
	grpc.ClientStream
}

type WrapperPlugin_ExecuteServer 

type WrapperPlugin_ExecuteServer interface {
	Send(*ExecuteResponse) error
	grpc.ServerStream
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

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