proto

package
v5.6.0-dev.13 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2023 License: Apache-2.0 Imports: 15 Imported by: 199

Documentation

Overview

Package proto contains [protobuf] definitions and auto generated code for the plugin service interface.

It also contains extension methods for various autogenerated protobuf types.

Index

Constants

This section is empty.

Variables

View Source 
var (
	PluginMessageType_name = map[int32]string{
		0: "SCHEMA_UPDATED",
	}
	PluginMessageType_value = map[string]int32{
		"SCHEMA_UPDATED": 0,
	}
)

Enum value maps for PluginMessageType.

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",
		9:  "INET",
		10: "LTREE",
		-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,
		"INET":      9,
		"LTREE":     10,
		"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: "SetAllConnectionConfigs",
			Handler:    _WrapperPlugin_SetAllConnectionConfigs_Handler,
		},
		{
			MethodName: "UpdateConnectionConfigs",
			Handler:    _WrapperPlugin_UpdateConnectionConfigs_Handler,
		},
		{
			MethodName: "GetSupportedOperations",
			Handler:    _WrapperPlugin_GetSupportedOperations_Handler,
		},
		{
			MethodName: "SetCacheOptions",
			Handler:    _WrapperPlugin_SetCacheOptions_Handler,
		},
		{
			MethodName: "SetRateLimiters",
			Handler:    _WrapperPlugin_SetRateLimiters_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "EstablishMessageStream",
			Handler:       _WrapperPlugin_EstablishMessageStream_Handler,
			ServerStreams: true,
		},
		{
			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
	//	*Column_LtreeValue
	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) GetLtreeValue 

func (x *Column) GetLtreeValue() string

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
	ColumnType_INET      ColumnType = 9
	ColumnType_LTREE     ColumnType = 10
	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_LtreeValue 

type Column_LtreeValue struct {
	// Represents an ltree value
	LtreeValue string `protobuf:"bytes,11,opt,name=ltree_value,json=ltreeValue,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 ConnectionConfig 

type ConnectionConfig struct {
	Connection       string   `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	Plugin           string   `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	PluginShortName  string   `protobuf:"bytes,3,opt,name=plugin_short_name,json=pluginShortName,proto3" json:"plugin_short_name,omitempty"`
	Config           string   `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	ChildConnections []string `protobuf:"bytes,5,rep,name=child_connections,json=childConnections,proto3" json:"child_connections,omitempty"`
	Type             string   `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionConfig) Descriptor deprecated 

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

Deprecated: Use ConnectionConfig.ProtoReflect.Descriptor instead.

func (*ConnectionConfig) Equals 

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

func (*ConnectionConfig) GetChildConnections 

func (x *ConnectionConfig) GetChildConnections() []string

func (*ConnectionConfig) GetConfig 

func (x *ConnectionConfig) GetConfig() string

func (*ConnectionConfig) GetConnection 

func (x *ConnectionConfig) GetConnection() string

func (*ConnectionConfig) GetPlugin 

func (x *ConnectionConfig) GetPlugin() string

func (*ConnectionConfig) GetPluginShortName 

func (x *ConnectionConfig) GetPluginShortName() string

func (*ConnectionConfig) GetType added in v5.6.0 

func (x *ConnectionConfig) GetType() string

func (*ConnectionConfig) IsAggregator added in v5.6.0 

func (x *ConnectionConfig) IsAggregator() bool

func (*ConnectionConfig) ProtoMessage 

func (*ConnectionConfig) ProtoMessage()

func (*ConnectionConfig) ProtoReflect 

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

func (*ConnectionConfig) Reset 

func (x *ConnectionConfig) Reset()

func (*ConnectionConfig) String 

func (x *ConnectionConfig) String() string

type ConnectionConfigPayload 

type ConnectionConfigPayload 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 (*ConnectionConfigPayload) Descriptor deprecated 

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

Deprecated: Use ConnectionConfigPayload.ProtoReflect.Descriptor instead.

func (*ConnectionConfigPayload) GetConnectionConfig 

func (x *ConnectionConfigPayload) GetConnectionConfig() string

func (*ConnectionConfigPayload) GetConnectionName 

func (x *ConnectionConfigPayload) GetConnectionName() string

func (*ConnectionConfigPayload) ProtoMessage 

func (*ConnectionConfigPayload) ProtoMessage()

func (*ConnectionConfigPayload) ProtoReflect 

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

func (*ConnectionConfigPayload) Reset 

func (x *ConnectionConfigPayload) Reset()

func (*ConnectionConfigPayload) String 

func (x *ConnectionConfigPayload) String() string

type EstablishMessageStreamRequest 

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

func (*EstablishMessageStreamRequest) Descriptor deprecated 

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

Deprecated: Use EstablishMessageStreamRequest.ProtoReflect.Descriptor instead.

func (*EstablishMessageStreamRequest) ProtoMessage 

func (*EstablishMessageStreamRequest) ProtoMessage()

func (*EstablishMessageStreamRequest) ProtoReflect 

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

func (*EstablishMessageStreamRequest) Reset 

func (x *EstablishMessageStreamRequest) Reset()

func (*EstablishMessageStreamRequest) String 

func (x *EstablishMessageStreamRequest) String() string

type ExecuteConnectionData 

type ExecuteConnectionData struct {
	Limit        *NullableInt `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	CacheEnabled bool         `protobuf:"varint,3,opt,name=cache_enabled,json=cacheEnabled,proto3" json:"cache_enabled,omitempty"`
	CacheTtl     int64        `protobuf:"varint,4,opt,name=cache_ttl,json=cacheTtl,proto3" json:"cache_ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteConnectionData) Descriptor deprecated 

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

Deprecated: Use ExecuteConnectionData.ProtoReflect.Descriptor instead.

func (*ExecuteConnectionData) GetCacheEnabled 

func (x *ExecuteConnectionData) GetCacheEnabled() bool

func (*ExecuteConnectionData) GetCacheTtl 

func (x *ExecuteConnectionData) GetCacheTtl() int64

func (*ExecuteConnectionData) GetLimit 

func (x *ExecuteConnectionData) GetLimit() *NullableInt

func (*ExecuteConnectionData) ProtoMessage 

func (*ExecuteConnectionData) ProtoMessage()

func (*ExecuteConnectionData) ProtoReflect 

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

func (*ExecuteConnectionData) Reset 

func (x *ExecuteConnectionData) Reset()

func (*ExecuteConnectionData) String 

func (x *ExecuteConnectionData) String() string

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"`
	// Deprecated: Do not use.
	CacheEnabled bool `protobuf:"varint,4,opt,name=cache_enabled,json=cacheEnabled,proto3" json:"cache_enabled,omitempty"`
	// Deprecated: Do not use.
	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"`
	TraceContext          *TraceContext                     `protobuf:"bytes,7,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"`
	ExecuteConnectionData map[string]*ExecuteConnectionData `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetCacheEnabled deprecated 

func (x *ExecuteRequest) GetCacheEnabled() bool

Deprecated: Do not use.

func (*ExecuteRequest) GetCacheTtl deprecated 

func (x *ExecuteRequest) GetCacheTtl() int64

Deprecated: Do not use.

func (*ExecuteRequest) GetCallId 

func (x *ExecuteRequest) GetCallId() string

func (*ExecuteRequest) GetConnection 

func (x *ExecuteRequest) GetConnection() string

func (*ExecuteRequest) GetExecuteConnectionData 

func (x *ExecuteRequest) GetExecuteConnectionData() map[string]*ExecuteConnectionData

func (*ExecuteRequest) GetQueryContext 

func (x *ExecuteRequest) GetQueryContext() *QueryContext

func (*ExecuteRequest) GetTable 

func (x *ExecuteRequest) GetTable() string

func (*ExecuteRequest) GetTraceContext 

func (x *ExecuteRequest) GetTraceContext() *TraceContext

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"`
	Metadata   *QueryMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Connection string         `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetConnection 

func (x *ExecuteResponse) GetConnection() string

func (*ExecuteResponse) GetMetadata 

func (x *ExecuteResponse) GetMetadata() *QueryMetadata

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

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetConnection 

func (x *GetSchemaRequest) GetConnection() string

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"`
	MultipleConnections bool `protobuf:"varint,2,opt,name=multiple_connections,json=multipleConnections,proto3" json:"multiple_connections,omitempty"`
	MessageStream       bool `protobuf:"varint,3,opt,name=message_stream,json=messageStream,proto3" json:"message_stream,omitempty"`
	SetCacheOptions     bool `protobuf:"varint,4,opt,name=set_cache_options,json=setCacheOptions,proto3" json:"set_cache_options,omitempty"`
	SetRateLimiters     bool `protobuf:"varint,5,opt,name=set_rate_limiters,json=setRateLimiters,proto3" json:"set_rate_limiters,omitempty"`
	// contains filtered or unexported fields
}

NOTE: this must be consistent with GetSupportedOperationsResponse in steampipe/pkg/pluginmanager_service/grpc/proto/plugin_manager.proto

func (*GetSupportedOperationsResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedOperationsResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedOperationsResponse) GetMessageStream 

func (x *GetSupportedOperationsResponse) GetMessageStream() bool

func (*GetSupportedOperationsResponse) GetMultipleConnections 

func (x *GetSupportedOperationsResponse) GetMultipleConnections() bool

func (*GetSupportedOperationsResponse) GetQueryCache 

func (x *GetSupportedOperationsResponse) GetQueryCache() bool

func (*GetSupportedOperationsResponse) GetSetCacheOptions added in v5.4.0 

func (x *GetSupportedOperationsResponse) GetSetCacheOptions() bool

func (*GetSupportedOperationsResponse) GetSetRateLimiters 

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

type IndexBucket struct {
	Items []*IndexItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexBucket) Descriptor deprecated 

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

Deprecated: Use IndexBucket.ProtoReflect.Descriptor instead.

func (*IndexBucket) GetItems 

func (x *IndexBucket) GetItems() []*IndexItem

func (*IndexBucket) ProtoMessage 

func (*IndexBucket) ProtoMessage()

func (*IndexBucket) ProtoReflect 

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

func (*IndexBucket) Reset 

func (x *IndexBucket) Reset()

func (*IndexBucket) String 

func (x *IndexBucket) String() string

type IndexItem 

type IndexItem struct {
	Key           string                 `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Quals         map[string]*Quals      `` /* 151-byte string literal not displayed */
	Columns       []string               `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
	Limit         int64                  `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	PageCount     int64                  `protobuf:"varint,6,opt,name=page_count,json=pageCount,proto3" json:"page_count,omitempty"`
	InsertionTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=insertion_time,json=insertionTime,proto3" json:"insertion_time,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexItem) Descriptor deprecated 

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

Deprecated: Use IndexItem.ProtoReflect.Descriptor instead.

func (*IndexItem) GetColumns 

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

func (*IndexItem) GetInsertionTime 

func (x *IndexItem) GetInsertionTime() *timestamppb.Timestamp

func (*IndexItem) GetKey 

func (x *IndexItem) GetKey() string

func (*IndexItem) GetLimit 

func (x *IndexItem) GetLimit() int64

func (*IndexItem) GetPageCount 

func (x *IndexItem) GetPageCount() int64

func (*IndexItem) GetQuals 

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

func (*IndexItem) ProtoMessage 

func (*IndexItem) ProtoMessage()

func (*IndexItem) ProtoReflect 

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

func (*IndexItem) Reset 

func (x *IndexItem) Reset()

func (*IndexItem) String 

func (x *IndexItem) 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) Equals added in v5.2.0 

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

func (*KeyColumn) GetCacheMatch 

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 PluginMessage 

type PluginMessage struct {
	MessageType PluginMessageType `protobuf:"varint,1,opt,name=messageType,proto3,enum=proto.PluginMessageType" json:"messageType,omitempty"`
	Connection  string            `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginMessage) Descriptor deprecated 

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

Deprecated: Use PluginMessage.ProtoReflect.Descriptor instead.

func (*PluginMessage) GetConnection 

func (x *PluginMessage) GetConnection() string

func (*PluginMessage) GetMessageType 

func (x *PluginMessage) GetMessageType() PluginMessageType

func (*PluginMessage) ProtoMessage 

func (*PluginMessage) ProtoMessage()

func (*PluginMessage) ProtoReflect 

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

func (*PluginMessage) Reset 

func (x *PluginMessage) Reset()

func (*PluginMessage) String 

func (x *PluginMessage) String() string

type PluginMessageType 

type PluginMessageType int32
const (
	PluginMessageType_SCHEMA_UPDATED PluginMessageType = 0
)

func (PluginMessageType) Descriptor 

func (PluginMessageType) Descriptor() protoreflect.EnumDescriptor

func (PluginMessageType) Enum 

func (x PluginMessageType) Enum() *PluginMessageType

func (PluginMessageType) EnumDescriptor deprecated 

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

Deprecated: Use PluginMessageType.Descriptor instead.

func (PluginMessageType) Number 

func (x PluginMessageType) Number() protoreflect.EnumNumber

func (PluginMessageType) String 

func (x PluginMessageType) String() string

func (PluginMessageType) Type 

func (PluginMessageType) 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
	//	*QualValue_LtreeValue
	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) GetLtreeValue 

func (x *QualValue) GetLtreeValue() string

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_LtreeValue 

type QualValue_LtreeValue struct {
	LtreeValue string `protobuf:"bytes,9,opt,name=ltree_value,json=ltreeValue,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 

func (x *Quals) Clone() *Quals

func (*Quals) Descriptor deprecated 

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

Deprecated: Use Quals.ProtoReflect.Descriptor instead.

func (*Quals) Equals 

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 

func (x *Quals) Len() int

func (*Quals) Less 

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 

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 */
	// Deprecated: Do not use.
	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 deprecated 

func (x *QueryContext) GetLimit() *NullableInt

Deprecated: Do not use.

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 QueryMetadata 

type QueryMetadata struct {
	HydrateCalls int64 `protobuf:"varint,1,opt,name=hydrate_calls,json=hydrateCalls,proto3" json:"hydrate_calls,omitempty"`
	RowsFetched  int64 `protobuf:"varint,2,opt,name=rows_fetched,json=rowsFetched,proto3" json:"rows_fetched,omitempty"`
	CacheHit     bool  `protobuf:"varint,3,opt,name=cache_hit,json=cacheHit,proto3" json:"cache_hit,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetadata) Descriptor deprecated 

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

Deprecated: Use QueryMetadata.ProtoReflect.Descriptor instead.

func (*QueryMetadata) GetCacheHit 

func (x *QueryMetadata) GetCacheHit() bool

func (*QueryMetadata) GetHydrateCalls 

func (x *QueryMetadata) GetHydrateCalls() int64

func (*QueryMetadata) GetRowsFetched 

func (x *QueryMetadata) GetRowsFetched() int64

func (*QueryMetadata) ProtoMessage 

func (*QueryMetadata) ProtoMessage()

func (*QueryMetadata) ProtoReflect 

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

func (*QueryMetadata) Reset 

func (x *QueryMetadata) Reset()

func (*QueryMetadata) String 

func (x *QueryMetadata) String() string

type QueryResult 

type QueryResult struct {
	Rows []*Row `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResult) Append 

func (q *QueryResult) Append(row *Row)

func (*QueryResult) Descriptor deprecated 

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

Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.

func (*QueryResult) GetRows 

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

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect 

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

func (*QueryResult) Reset 

func (x *QueryResult) Reset()

func (*QueryResult) String 

func (x *QueryResult) String() string

type RateLimiterDefinition added in v5.6.0 

type RateLimiterDefinition struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	FillRate   float32  `protobuf:"fixed32,2,opt,name=fill_rate,json=fillRate,proto3" json:"fill_rate,omitempty"`
	BucketSize int64    `protobuf:"varint,3,opt,name=bucket_size,json=bucketSize,proto3" json:"bucket_size,omitempty"`
	Scope      []string `protobuf:"bytes,4,rep,name=scope,proto3" json:"scope,omitempty"`
	Where      string   `protobuf:"bytes,5,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

func (*RateLimiterDefinition) Descriptor deprecated added in v5.6.0 

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

Deprecated: Use RateLimiterDefinition.ProtoReflect.Descriptor instead.

func (*RateLimiterDefinition) GetBucketSize added in v5.6.0 

func (x *RateLimiterDefinition) GetBucketSize() int64

func (*RateLimiterDefinition) GetFillRate added in v5.6.0 

func (x *RateLimiterDefinition) GetFillRate() float32

func (*RateLimiterDefinition) GetName added in v5.6.0 

func (x *RateLimiterDefinition) GetName() string

func (*RateLimiterDefinition) GetScope added in v5.6.0 

func (x *RateLimiterDefinition) GetScope() []string

func (*RateLimiterDefinition) GetWhere added in v5.6.0 

func (x *RateLimiterDefinition) GetWhere() string

func (*RateLimiterDefinition) ProtoMessage added in v5.6.0 

func (*RateLimiterDefinition) ProtoMessage()

func (*RateLimiterDefinition) ProtoReflect added in v5.6.0 

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

func (*RateLimiterDefinition) Reset added in v5.6.0 

func (x *RateLimiterDefinition) Reset()

func (*RateLimiterDefinition) String added in v5.6.0 

func (x *RateLimiterDefinition) 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 SetAllConnectionConfigsRequest 

type SetAllConnectionConfigsRequest struct {
	Configs        []*ConnectionConfig `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	MaxCacheSizeMb int64               `protobuf:"varint,2,opt,name=max_cache_size_mb,json=maxCacheSizeMb,proto3" json:"max_cache_size_mb,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAllConnectionConfigsRequest) Descriptor deprecated 

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

Deprecated: Use SetAllConnectionConfigsRequest.ProtoReflect.Descriptor instead.

func (*SetAllConnectionConfigsRequest) GetConfigs 

func (x *SetAllConnectionConfigsRequest) GetConfigs() []*ConnectionConfig

func (*SetAllConnectionConfigsRequest) GetMaxCacheSizeMb 

func (x *SetAllConnectionConfigsRequest) GetMaxCacheSizeMb() int64

func (*SetAllConnectionConfigsRequest) ProtoMessage 

func (*SetAllConnectionConfigsRequest) ProtoMessage()

func (*SetAllConnectionConfigsRequest) ProtoReflect 

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

func (*SetAllConnectionConfigsRequest) Reset 

func (x *SetAllConnectionConfigsRequest) Reset()

func (*SetAllConnectionConfigsRequest) String 

func (x *SetAllConnectionConfigsRequest) String() string

type SetCacheOptionsRequest added in v5.4.0 

type SetCacheOptionsRequest struct {
	Enabled   bool  `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Ttl       int64 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	MaxSizeMb int64 `protobuf:"varint,4,opt,name=max_size_mb,json=maxSizeMb,proto3" json:"max_size_mb,omitempty"`
	// contains filtered or unexported fields
}

func (*SetCacheOptionsRequest) Descriptor deprecated added in v5.4.0 

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

Deprecated: Use SetCacheOptionsRequest.ProtoReflect.Descriptor instead.

func (*SetCacheOptionsRequest) GetEnabled added in v5.4.0 

func (x *SetCacheOptionsRequest) GetEnabled() bool

func (*SetCacheOptionsRequest) GetMaxSizeMb added in v5.4.0 

func (x *SetCacheOptionsRequest) GetMaxSizeMb() int64

func (*SetCacheOptionsRequest) GetTtl added in v5.4.0 

func (x *SetCacheOptionsRequest) GetTtl() int64

func (*SetCacheOptionsRequest) ProtoMessage added in v5.4.0 

func (*SetCacheOptionsRequest) ProtoMessage()

func (*SetCacheOptionsRequest) ProtoReflect added in v5.4.0 

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

func (*SetCacheOptionsRequest) Reset added in v5.4.0 

func (x *SetCacheOptionsRequest) Reset()

func (*SetCacheOptionsRequest) String added in v5.4.0 

func (x *SetCacheOptionsRequest) String() string

type SetCacheOptionsResponse added in v5.4.0 

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

func (*SetCacheOptionsResponse) Descriptor deprecated added in v5.4.0 

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

Deprecated: Use SetCacheOptionsResponse.ProtoReflect.Descriptor instead.

func (*SetCacheOptionsResponse) ProtoMessage added in v5.4.0 

func (*SetCacheOptionsResponse) ProtoMessage()

func (*SetCacheOptionsResponse) ProtoReflect added in v5.4.0 

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

func (*SetCacheOptionsResponse) Reset added in v5.4.0 

func (x *SetCacheOptionsResponse) Reset()

func (*SetCacheOptionsResponse) String added in v5.4.0 

func (x *SetCacheOptionsResponse) String() string

type SetConnectionConfigRequest deprecated 

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
}

Deprecated: Do not use.

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 {
	FailedConnections map[string]string `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetConnectionConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetConnectionConfigResponse.ProtoReflect.Descriptor instead.

func (*SetConnectionConfigResponse) GetFailedConnections added in v5.2.0 

func (x *SetConnectionConfigResponse) GetFailedConnections() map[string]string

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 SetRateLimitersRequest added in v5.6.0 

type SetRateLimitersRequest struct {
	Definitions []*RateLimiterDefinition `protobuf:"bytes,1,rep,name=definitions,proto3" json:"definitions,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRateLimitersRequest) Descriptor deprecated added in v5.6.0 

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

Deprecated: Use SetRateLimitersRequest.ProtoReflect.Descriptor instead.

func (*SetRateLimitersRequest) GetDefinitions added in v5.6.0 

func (x *SetRateLimitersRequest) GetDefinitions() []*RateLimiterDefinition

func (*SetRateLimitersRequest) ProtoMessage added in v5.6.0 

func (*SetRateLimitersRequest) ProtoMessage()

func (*SetRateLimitersRequest) ProtoReflect added in v5.6.0 

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

func (*SetRateLimitersRequest) Reset added in v5.6.0 

func (x *SetRateLimitersRequest) Reset()

func (*SetRateLimitersRequest) String added in v5.6.0 

func (x *SetRateLimitersRequest) String() string

type SetRateLimitersResponse added in v5.6.0 

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

func (*SetRateLimitersResponse) Descriptor deprecated added in v5.6.0 

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

Deprecated: Use SetRateLimitersResponse.ProtoReflect.Descriptor instead.

func (*SetRateLimitersResponse) ProtoMessage added in v5.6.0 

func (*SetRateLimitersResponse) ProtoMessage()

func (*SetRateLimitersResponse) ProtoReflect added in v5.6.0 

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

func (*SetRateLimitersResponse) Reset added in v5.6.0 

func (x *SetRateLimitersResponse) Reset()

func (*SetRateLimitersResponse) String added in v5.6.0 

func (x *SetRateLimitersResponse) 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) Diff added in v5.2.0 

func (x *TableSchema) Diff(other *TableSchema) *TableSchemaDiff

func (*TableSchema) Equals added in v5.2.0 

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

func (*TableSchema) GetColumnMap 

func (x *TableSchema) GetColumnMap() map[string]*ColumnDefinition

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 TableSchemaDiff added in v5.2.0 

type TableSchemaDiff struct {
	MissingColumns      map[string]struct{}
	TypeMismatchColumns map[string]struct{}
	KeyColumnsEqual     bool
}

func NewTableSchemaDiff added in v5.2.0 

func NewTableSchemaDiff() *TableSchemaDiff

func (*TableSchemaDiff) HasDiffs added in v5.2.0 

func (d *TableSchemaDiff) HasDiffs() bool

func (*TableSchemaDiff) Merge added in v5.2.0 

func (d *TableSchemaDiff) Merge(other *TableSchemaDiff)

type TraceContext 

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

func (*TraceContext) Descriptor deprecated 

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

func (*TraceContext) GetValue 

func (x *TraceContext) GetValue() string

func (*TraceContext) ProtoMessage 

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect 

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

func (*TraceContext) Reset 

func (x *TraceContext) Reset()

func (*TraceContext) String 

func (x *TraceContext) String() string

type UnimplementedWrapperPluginServer 

type UnimplementedWrapperPluginServer struct {
}

UnimplementedWrapperPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedWrapperPluginServer) EstablishMessageStream 

func (UnimplementedWrapperPluginServer) EstablishMessageStream(*EstablishMessageStreamRequest, WrapperPlugin_EstablishMessageStreamServer) error

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

func (UnimplementedWrapperPluginServer) SetAllConnectionConfigs(context.Context, *SetAllConnectionConfigsRequest) (*SetConnectionConfigResponse, error)

func (UnimplementedWrapperPluginServer) SetCacheOptions added in v5.4.0 

func (UnimplementedWrapperPluginServer) SetCacheOptions(context.Context, *SetCacheOptionsRequest) (*SetCacheOptionsResponse, error)

func (UnimplementedWrapperPluginServer) SetConnectionConfig 

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

func (UnimplementedWrapperPluginServer) SetRateLimiters added in v5.6.0 

func (UnimplementedWrapperPluginServer) SetRateLimiters(context.Context, *SetRateLimitersRequest) (*SetRateLimitersResponse, error)

func (UnimplementedWrapperPluginServer) UpdateConnectionConfigs 

func (UnimplementedWrapperPluginServer) UpdateConnectionConfigs(context.Context, *UpdateConnectionConfigsRequest) (*UpdateConnectionConfigsResponse, 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 UpdateConnectionConfigsRequest 

type UpdateConnectionConfigsRequest struct {
	Added   []*ConnectionConfig `protobuf:"bytes,1,rep,name=added,proto3" json:"added,omitempty"`
	Deleted []*ConnectionConfig `protobuf:"bytes,2,rep,name=deleted,proto3" json:"deleted,omitempty"`
	Changed []*ConnectionConfig `protobuf:"bytes,3,rep,name=changed,proto3" json:"changed,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectionConfigsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConnectionConfigsRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectionConfigsRequest) GetAdded 

func (x *UpdateConnectionConfigsRequest) GetAdded() []*ConnectionConfig

func (*UpdateConnectionConfigsRequest) GetChanged 

func (x *UpdateConnectionConfigsRequest) GetChanged() []*ConnectionConfig

func (*UpdateConnectionConfigsRequest) GetDeleted 

func (x *UpdateConnectionConfigsRequest) GetDeleted() []*ConnectionConfig

func (*UpdateConnectionConfigsRequest) ProtoMessage 

func (*UpdateConnectionConfigsRequest) ProtoMessage()

func (*UpdateConnectionConfigsRequest) ProtoReflect 

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

func (*UpdateConnectionConfigsRequest) Reset 

func (x *UpdateConnectionConfigsRequest) Reset()

func (*UpdateConnectionConfigsRequest) String 

func (x *UpdateConnectionConfigsRequest) String() string

type UpdateConnectionConfigsResponse 

type UpdateConnectionConfigsResponse struct {
	FailedConnections map[string]string `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateConnectionConfigsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateConnectionConfigsResponse.ProtoReflect.Descriptor instead.

func (*UpdateConnectionConfigsResponse) GetFailedConnections added in v5.2.0 

func (x *UpdateConnectionConfigsResponse) GetFailedConnections() map[string]string

func (*UpdateConnectionConfigsResponse) ProtoMessage 

func (*UpdateConnectionConfigsResponse) ProtoMessage()

func (*UpdateConnectionConfigsResponse) ProtoReflect 

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

func (*UpdateConnectionConfigsResponse) Reset 

func (x *UpdateConnectionConfigsResponse) Reset()

func (*UpdateConnectionConfigsResponse) String 

func (x *UpdateConnectionConfigsResponse) String() string

type WrapperPluginClient 

type WrapperPluginClient interface {
	EstablishMessageStream(ctx context.Context, in *EstablishMessageStreamRequest, opts ...grpc.CallOption) (WrapperPlugin_EstablishMessageStreamClient, error)
	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)
	SetAllConnectionConfigs(ctx context.Context, in *SetAllConnectionConfigsRequest, opts ...grpc.CallOption) (*SetConnectionConfigResponse, error)
	UpdateConnectionConfigs(ctx context.Context, in *UpdateConnectionConfigsRequest, opts ...grpc.CallOption) (*UpdateConnectionConfigsResponse, error)
	GetSupportedOperations(ctx context.Context, in *GetSupportedOperationsRequest, opts ...grpc.CallOption) (*GetSupportedOperationsResponse, error)
	SetCacheOptions(ctx context.Context, in *SetCacheOptionsRequest, opts ...grpc.CallOption) (*SetCacheOptionsResponse, error)
	SetRateLimiters(ctx context.Context, in *SetRateLimitersRequest, opts ...grpc.CallOption) (*SetRateLimitersResponse, 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 {
	EstablishMessageStream(*EstablishMessageStreamRequest, WrapperPlugin_EstablishMessageStreamServer) error
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	Execute(*ExecuteRequest, WrapperPlugin_ExecuteServer) error
	SetConnectionConfig(context.Context, *SetConnectionConfigRequest) (*SetConnectionConfigResponse, error)
	SetAllConnectionConfigs(context.Context, *SetAllConnectionConfigsRequest) (*SetConnectionConfigResponse, error)
	UpdateConnectionConfigs(context.Context, *UpdateConnectionConfigsRequest) (*UpdateConnectionConfigsResponse, error)
	GetSupportedOperations(context.Context, *GetSupportedOperationsRequest) (*GetSupportedOperationsResponse, error)
	SetCacheOptions(context.Context, *SetCacheOptionsRequest) (*SetCacheOptionsResponse, error)
	SetRateLimiters(context.Context, *SetRateLimitersRequest) (*SetRateLimitersResponse, error)
	// contains filtered or unexported methods
}

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

type WrapperPlugin_EstablishMessageStreamClient 

type WrapperPlugin_EstablishMessageStreamClient interface {
	Recv() (*PluginMessage, error)
	grpc.ClientStream
}

type WrapperPlugin_EstablishMessageStreamServer 

type WrapperPlugin_EstablishMessageStreamServer interface {
	Send(*PluginMessage) error
	grpc.ServerStream
}

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.