proto

package
v2.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2022 License: Apache-2.0 Imports: 14 Imported by: 1

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
View Source 
var WrapperPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.WrapperPlugin",
	HandlerType: (*WrapperPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSchema",
			Handler:    _WrapperPlugin_GetSchema_Handler,
		},
		{
			MethodName: "SetConnectionConfig",
			Handler:    _WrapperPlugin_SetConnectionConfig_Handler,
		},
		{
			MethodName: "GetSupportedOperations",
			Handler:    _WrapperPlugin_GetSupportedOperations_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _WrapperPlugin_Execute_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "plugin.proto",
}

WrapperPlugin_ServiceDesc is the grpc.ServiceDesc for WrapperPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWrapperPluginServer 

func RegisterWrapperPluginServer(s grpc.ServiceRegistrar, 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() *timestamppb.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
	//  INET = 9;
	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 *timestamppb.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"`
	CacheEnabled bool          `protobuf:"varint,4,opt,name=cache_enabled,json=cacheEnabled,proto3" json:"cache_enabled,omitempty"`
	CacheTtl     int64         `protobuf:"varint,5,opt,name=cache_ttl,json=cacheTtl,proto3" json:"cache_ttl,omitempty"`
	CallId       string        `protobuf:"bytes,6,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetCacheEnabled 

func (x *ExecuteRequest) GetCacheEnabled() bool

func (*ExecuteRequest) GetCacheTtl 

func (x *ExecuteRequest) GetCacheTtl() int64

func (*ExecuteRequest) GetCallId 

func (x *ExecuteRequest) GetCallId() string

func (*ExecuteRequest) GetConnection 

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 GetSupportedOperationsRequest 

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

func (*GetSupportedOperationsRequest) Descriptor deprecated 

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

Deprecated: Use GetSupportedOperationsRequest.ProtoReflect.Descriptor instead.

func (*GetSupportedOperationsRequest) ProtoMessage 

func (*GetSupportedOperationsRequest) ProtoMessage()

func (*GetSupportedOperationsRequest) ProtoReflect 

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

func (*GetSupportedOperationsRequest) Reset 

func (x *GetSupportedOperationsRequest) Reset()

func (*GetSupportedOperationsRequest) String 

func (x *GetSupportedOperationsRequest) String() string

type GetSupportedOperationsResponse 

type GetSupportedOperationsResponse struct {
	QueryCache bool `protobuf:"varint,1,opt,name=query_cache,json=queryCache,proto3" json:"query_cache,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSupportedOperationsResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedOperationsResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedOperationsResponse) GetQueryCache 

func (x *GetSupportedOperationsResponse) GetQueryCache() bool

func (*GetSupportedOperationsResponse) ProtoMessage 

func (*GetSupportedOperationsResponse) ProtoMessage()

func (*GetSupportedOperationsResponse) ProtoReflect 

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

func (*GetSupportedOperationsResponse) Reset 

func (x *GetSupportedOperationsResponse) Reset()

func (*GetSupportedOperationsResponse) String 

func (x *GetSupportedOperationsResponse) 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 KeyColumn 

type KeyColumn struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Operators  []string `protobuf:"bytes,2,rep,name=operators,proto3" json:"operators,omitempty"`
	Require    string   `protobuf:"bytes,3,opt,name=require,proto3" json:"require,omitempty"`
	CacheMatch string   `protobuf:"bytes,4,opt,name=cache_match,json=cacheMatch,proto3" json:"cache_match,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyColumn) Descriptor deprecated 

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

Deprecated: Use KeyColumn.ProtoReflect.Descriptor instead.

func (*KeyColumn) GetCacheMatch added in v2.2.0 

func (x *KeyColumn) GetCacheMatch() string

func (*KeyColumn) GetName 

func (x *KeyColumn) GetName() string

func (*KeyColumn) GetOperators 

func (x *KeyColumn) GetOperators() []string

func (*KeyColumn) GetRequire 

func (x *KeyColumn) GetRequire() string

func (*KeyColumn) ProtoMessage 

func (*KeyColumn) ProtoMessage()

func (*KeyColumn) ProtoReflect 

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

func (*KeyColumn) Reset 

func (x *KeyColumn) Reset()

func (*KeyColumn) String 

func (x *KeyColumn) String() string

type KeyColumnsSet deprecated 

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, required for get/list calls deprecated - kept for compatibility

Deprecated: Do not use.

func (*KeyColumnsSet) Descriptor deprecated 

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

Deprecated: Use KeyColumnsSet.ProtoReflect.Descriptor instead.

func (*KeyColumnsSet) GetAll 

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

func (*KeyColumnsSet) GetAny 

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

func (*KeyColumnsSet) GetSingle 

func (x *KeyColumnsSet) GetSingle() string

func (*KeyColumnsSet) ProtoMessage 

func (*KeyColumnsSet) ProtoMessage()

func (*KeyColumnsSet) ProtoReflect 

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

func (*KeyColumnsSet) Reset 

func (x *KeyColumnsSet) Reset()

func (*KeyColumnsSet) String 

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 NullableInt 

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

func (*NullableInt) Descriptor deprecated 

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

Deprecated: Use NullableInt.ProtoReflect.Descriptor instead.

func (*NullableInt) GetValue 

func (x *NullableInt) GetValue() int64

func (*NullableInt) ProtoMessage 

func (*NullableInt) ProtoMessage()

func (*NullableInt) ProtoReflect 

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

func (*NullableInt) Reset 

func (x *NullableInt) Reset()

func (*NullableInt) String 

func (x *NullableInt) String() string

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) Equals 

func (x *Qual) Equals(other *Qual) bool

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) IsASubsetOf 

func (x *Qual) IsASubsetOf(other *Qual) bool

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 NewQualValue 

func NewQualValue(value interface{}) *QualValue

NewQualValue creates a QualValue object from a raw value

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() *timestamppb.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 *timestamppb.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) Append 

func (x *Quals) Append(q *Qual)

func (*Quals) Clone added in v2.2.0 

func (x *Quals) Clone() *Quals

func (*Quals) Descriptor deprecated 

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

Deprecated: Use Quals.ProtoReflect.Descriptor instead.

func (*Quals) Equals added in v2.2.0 

func (x *Quals) Equals(other *Quals) bool

func (*Quals) GetQuals 

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

func (*Quals) IsASubsetOf 

func (x *Quals) IsASubsetOf(other *Quals) bool

IsASubsetOf determines whether we are a subset of other Quals

func (*Quals) Len added in v2.2.0 

func (x *Quals) Len() int

func (*Quals) Less added in v2.2.0 

func (x *Quals) Less(i, j int) bool

func (*Quals) ProtoMessage 

func (*Quals) ProtoMessage()

func (*Quals) ProtoReflect 

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

func (*Quals) QualIsASubset 

func (x *Quals) QualIsASubset(otherQual *Qual) bool

QualIsASubset determines whether otherQual is a subset of all our quals

func (*Quals) Reset 

func (x *Quals) Reset()

func (*Quals) String 

func (x *Quals) String() string

func (*Quals) Swap added in v2.2.0 

func (x *Quals) Swap(i, j int)

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

func NewQueryContext 

func NewQueryContext(columns []string, qualMap map[string]*Quals, limit int64) *QueryContext

NewQueryContext creates a proto.QueryContext from provided columns, qualMap, and if non-nul, the limit

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) GetLimit 

func (x *QueryContext) GetLimit() *NullableInt

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"`
	ProtocolVersion int64                   `protobuf:"varint,3,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	Mode            string                  `protobuf:"bytes,4,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetMode 

func (x *Schema) GetMode() string

func (*Schema) GetProtocolVersion 

func (x *Schema) GetProtocolVersion() int64

func (*Schema) GetSchema 

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

func (*Schema) GetSdkVersion 

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 

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 

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

Deprecated: Use SetConnectionConfigRequest.ProtoReflect.Descriptor instead.

func (*SetConnectionConfigRequest) GetConnectionConfig 

func (x *SetConnectionConfigRequest) GetConnectionConfig() string

func (*SetConnectionConfigRequest) GetConnectionName 

func (x *SetConnectionConfigRequest) GetConnectionName() string

func (*SetConnectionConfigRequest) ProtoMessage 

func (*SetConnectionConfigRequest) ProtoMessage()

func (*SetConnectionConfigRequest) ProtoReflect 

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

func (*SetConnectionConfigRequest) Reset 

func (x *SetConnectionConfigRequest) Reset()

func (*SetConnectionConfigRequest) String 

func (x *SetConnectionConfigRequest) String() string

type SetConnectionConfigResponse 

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

func (*SetConnectionConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetConnectionConfigResponse.ProtoReflect.Descriptor instead.

func (*SetConnectionConfigResponse) ProtoMessage 

func (*SetConnectionConfigResponse) ProtoMessage()

func (*SetConnectionConfigResponse) ProtoReflect 

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

func (*SetConnectionConfigResponse) Reset 

func (x *SetConnectionConfigResponse) Reset()

func (*SetConnectionConfigResponse) String 

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"`
	// Deprecated: Do not use.
	GetCallKeyColumns *KeyColumnsSet `protobuf:"bytes,3,opt,name=getCallKeyColumns,proto3" json:"getCallKeyColumns,omitempty"`
	// Deprecated: Do not use.
	ListCallKeyColumns *KeyColumnsSet `protobuf:"bytes,4,opt,name=listCallKeyColumns,proto3" json:"listCallKeyColumns,omitempty"`
	// Deprecated: Do not use.
	ListCallOptionalKeyColumns *KeyColumnsSet `protobuf:"bytes,5,opt,name=listCallOptionalKeyColumns,proto3" json:"listCallOptionalKeyColumns,omitempty"`
	GetCallKeyColumnList       []*KeyColumn   `protobuf:"bytes,6,rep,name=getCallKeyColumnList,proto3" json:"getCallKeyColumnList,omitempty"`
	ListCallKeyColumnList      []*KeyColumn   `protobuf:"bytes,7,rep,name=listCallKeyColumnList,proto3" json:"listCallKeyColumnList,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) GetGetCallKeyColumnList 

func (x *TableSchema) GetGetCallKeyColumnList() []*KeyColumn

func (*TableSchema) GetGetCallKeyColumns deprecated 

func (x *TableSchema) GetGetCallKeyColumns() *KeyColumnsSet

Deprecated: Do not use.

func (*TableSchema) GetListCallKeyColumnList 

func (x *TableSchema) GetListCallKeyColumnList() []*KeyColumn

func (*TableSchema) GetListCallKeyColumns deprecated 

func (x *TableSchema) GetListCallKeyColumns() *KeyColumnsSet

Deprecated: Do not use.

func (*TableSchema) GetListCallOptionalKeyColumns deprecated 

func (x *TableSchema) GetListCallOptionalKeyColumns() *KeyColumnsSet

Deprecated: Do not use.

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 must 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) GetSupportedOperations 

func (UnimplementedWrapperPluginServer) GetSupportedOperations(context.Context, *GetSupportedOperationsRequest) (*GetSupportedOperationsResponse, error)

func (UnimplementedWrapperPluginServer) SetConnectionConfig 

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

type UnsafeWrapperPluginServer 

type UnsafeWrapperPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeWrapperPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WrapperPluginServer will result in compilation errors.

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)
	GetSupportedOperations(ctx context.Context, in *GetSupportedOperationsRequest, opts ...grpc.CallOption) (*GetSupportedOperationsResponse, error)
}

WrapperPluginClient is the client API for WrapperPlugin 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 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)
	GetSupportedOperations(context.Context, *GetSupportedOperationsRequest) (*GetSupportedOperationsResponse, error)
	// contains filtered or unexported methods
}

WrapperPluginServer is the server API for WrapperPlugin service. All implementations must embed UnimplementedWrapperPluginServer for forward compatibility

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.