Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proto

package

Go to main page

Versions in this module

v2

v2.2.0

Mar 30, 2022

Changes in this version

type KeyColumn

+ CacheMatch string

+ func (x *KeyColumn) GetCacheMatch() string

type Quals

+ func (x *Quals) Clone() *Quals

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

+ func (x *Quals) Len() int

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

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

v2.1.1

Mar 10, 2022

v2.1.0

Mar 4, 2022

v2.0.3

Feb 14, 2022

v2.0.2

Feb 14, 2022

Changes in this version

+ var ColumnType_name = map[int32]string

+ var ColumnType_value = map[string]int32

+ var File_plugin_proto protoreflect.FileDescriptor

+ var NullValue_name = map[int32]string

+ var NullValue_value = map[string]int32

+ var Operator_Operation_name = map[int32]string

+ var Operator_Operation_value = map[string]int32

+ var WrapperPlugin_ServiceDesc = grpc.ServiceDesc

+ func RegisterWrapperPluginServer(s grpc.ServiceRegistrar, srv WrapperPluginServer)

+ type Column struct

+ Value isColumn_Value

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

+ func (*Column) ProtoMessage()

+ func (m *Column) GetValue() isColumn_Value

+ func (x *Column) GetBoolValue() bool

+ func (x *Column) GetCidrRangeValue() string

+ func (x *Column) GetDoubleValue() float64

+ func (x *Column) GetIntValue() int64

+ func (x *Column) GetIpAddrValue() string

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

+ func (x *Column) GetNullValue() NullValue

+ func (x *Column) GetStringValue() string

+ func (x *Column) GetTimestampValue() *timestamppb.Timestamp

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

+ func (x *Column) Reset()

+ func (x *Column) String() string

+ type ColumnDefinition struct

+ Description string

+ Name string

+ Type ColumnType

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

+ func (*ColumnDefinition) ProtoMessage()

+ func (x *ColumnDefinition) GetDescription() string

+ func (x *ColumnDefinition) GetName() string

+ func (x *ColumnDefinition) GetType() ColumnType

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

+ func (x *ColumnDefinition) Reset()

+ func (x *ColumnDefinition) String() string

+ type ColumnType int32

+ const ColumnType_BOOL

+ const ColumnType_CIDR

+ const ColumnType_DATETIME

+ const ColumnType_DOUBLE

+ const ColumnType_INT

+ const ColumnType_IPADDR

+ const ColumnType_JSON

+ const ColumnType_STRING

+ const ColumnType_TIMESTAMP

+ const ColumnType_UNKNOWN

+ func (ColumnType) Descriptor() protoreflect.EnumDescriptor

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

+ func (ColumnType) Type() protoreflect.EnumType

+ func (x ColumnType) Enum() *ColumnType

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

+ func (x ColumnType) String() string

+ type Column_BoolValue struct

+ BoolValue bool

+ type Column_CidrRangeValue struct

+ CidrRangeValue string

+ type Column_DoubleValue struct

+ DoubleValue float64

+ type Column_IntValue struct

+ IntValue int64

+ type Column_IpAddrValue struct

+ IpAddrValue string

+ type Column_JsonValue struct

+ JsonValue []byte

+ type Column_NullValue struct

+ NullValue NullValue

+ type Column_StringValue struct

+ StringValue string

+ type Column_TimestampValue struct

+ TimestampValue *timestamppb.Timestamp

+ type ExecuteRequest struct

+ CacheEnabled bool

+ CacheTtl int64

+ CallId string

+ Connection string

+ QueryContext *QueryContext

+ Table string

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

+ func (*ExecuteRequest) ProtoMessage()

+ func (x *ExecuteRequest) GetCacheEnabled() bool

+ func (x *ExecuteRequest) GetCacheTtl() int64

+ func (x *ExecuteRequest) GetCallId() string

+ func (x *ExecuteRequest) GetConnection() string

+ func (x *ExecuteRequest) GetQueryContext() *QueryContext

+ func (x *ExecuteRequest) GetTable() string

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

+ func (x *ExecuteRequest) Reset()

+ func (x *ExecuteRequest) String() string

+ type ExecuteResponse struct

+ Row *Row

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

+ func (*ExecuteResponse) ProtoMessage()

+ func (x *ExecuteResponse) GetRow() *Row

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

+ func (x *ExecuteResponse) Reset()

+ func (x *ExecuteResponse) String() string

+ type GetSchemaRequest struct

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

+ func (*GetSchemaRequest) ProtoMessage()

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

+ func (x *GetSchemaRequest) Reset()

+ func (x *GetSchemaRequest) String() string

+ type GetSchemaResponse struct

+ Schema *Schema

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

+ func (*GetSchemaResponse) ProtoMessage()

+ func (x *GetSchemaResponse) GetSchema() *Schema

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

+ func (x *GetSchemaResponse) Reset()

+ func (x *GetSchemaResponse) String() string

+ type GetSupportedOperationsRequest struct

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

+ func (*GetSupportedOperationsRequest) ProtoMessage()

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

+ func (x *GetSupportedOperationsRequest) Reset()

+ func (x *GetSupportedOperationsRequest) String() string

+ type GetSupportedOperationsResponse struct

+ QueryCache bool

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

+ func (*GetSupportedOperationsResponse) ProtoMessage()

+ func (x *GetSupportedOperationsResponse) GetQueryCache() bool

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

+ func (x *GetSupportedOperationsResponse) Reset()

+ func (x *GetSupportedOperationsResponse) String() string

+ type Inet struct

+ Addr string

+ Cidr string

+ Mask int32

+ ProtocolVersion string

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

+ func (*Inet) ProtoMessage()

+ func (x *Inet) GetAddr() string

+ func (x *Inet) GetCidr() string

+ func (x *Inet) GetMask() int32

+ func (x *Inet) GetProtocolVersion() string

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

+ func (x *Inet) Reset()

+ func (x *Inet) String() string

+ type KeyColumn struct

+ Name string

+ Operators []string

+ Require string

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

+ func (*KeyColumn) ProtoMessage()

+ func (x *KeyColumn) GetName() string

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

+ func (x *KeyColumn) GetRequire() string

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

+ func (x *KeyColumn) Reset()

+ func (x *KeyColumn) String() string

+ type KeyColumnsSet struct

+ All []string

+ Any []string

+ Single string

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

+ func (*KeyColumnsSet) ProtoMessage()

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

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

+ func (x *KeyColumnsSet) GetSingle() string

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

+ func (x *KeyColumnsSet) Reset()

+ func (x *KeyColumnsSet) String() string

+ type NullValue int32

+ const NullValue_NULL_VALUE

+ func (NullValue) Descriptor() protoreflect.EnumDescriptor

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

+ func (NullValue) Type() protoreflect.EnumType

+ func (x NullValue) Enum() *NullValue

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

+ func (x NullValue) String() string

+ type NullableInt struct

+ Value int64

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

+ func (*NullableInt) ProtoMessage()

+ func (x *NullableInt) GetValue() int64

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

+ func (x *NullableInt) Reset()

+ func (x *NullableInt) String() string

+ type Operator struct

+ Name string

+ Operation Operator_Operation

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

+ func (*Operator) ProtoMessage()

+ func (x *Operator) GetName() string

+ func (x *Operator) GetOperation() Operator_Operation

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

+ func (x *Operator) Reset()

+ func (x *Operator) String() string

+ type Operator_Operation int32

+ const Operator_ALL

+ const Operator_ANY

+ func (Operator_Operation) Descriptor() protoreflect.EnumDescriptor

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

+ func (Operator_Operation) Type() protoreflect.EnumType

+ func (x Operator_Operation) Enum() *Operator_Operation

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

+ func (x Operator_Operation) String() string

+ type Qual struct

+ FieldName string

+ Operator isQual_Operator

+ Value *QualValue

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

+ func (*Qual) ProtoMessage()

+ func (m *Qual) GetOperator() isQual_Operator

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

+ func (x *Qual) GetFieldName() string

+ func (x *Qual) GetStringValue() string

+ func (x *Qual) GetTupleValue() *Operator

+ func (x *Qual) GetValue() *QualValue

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

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

+ func (x *Qual) Reset()

+ func (x *Qual) String() string

+ type QualValue struct

+ Value isQualValue_Value

+ func NewQualValue(value interface{}) *QualValue

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

+ func (*QualValue) ProtoMessage()

+ func (m *QualValue) GetValue() isQualValue_Value

+ func (x *QualValue) GetBoolValue() bool

+ func (x *QualValue) GetDoubleValue() float64

+ func (x *QualValue) GetInetValue() *Inet

+ func (x *QualValue) GetInt64Value() int64

+ func (x *QualValue) GetJsonbValue() string

+ func (x *QualValue) GetListValue() *QualValueList

+ func (x *QualValue) GetStringValue() string

+ func (x *QualValue) GetTimestampValue() *timestamppb.Timestamp

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

+ func (x *QualValue) Reset()

+ func (x *QualValue) String() string

+ type QualValueList struct

+ Values []*QualValue

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

+ func (*QualValueList) ProtoMessage()

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

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

+ func (x *QualValueList) Reset()

+ func (x *QualValueList) String() string

+ type QualValue_BoolValue struct

+ BoolValue bool

+ type QualValue_DoubleValue struct

+ DoubleValue float64

+ type QualValue_InetValue struct

+ InetValue *Inet

+ type QualValue_Int64Value struct

+ Int64Value int64

+ type QualValue_JsonbValue struct

+ JsonbValue string

+ type QualValue_ListValue struct

+ ListValue *QualValueList

+ type QualValue_StringValue struct

+ StringValue string

+ type QualValue_TimestampValue struct

+ TimestampValue *timestamppb.Timestamp

+ type Qual_StringValue struct

+ StringValue string

+ type Qual_TupleValue struct

+ TupleValue *Operator

+ type Quals struct

+ Quals []*Qual

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

+ func (*Quals) ProtoMessage()

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

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

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

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

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

+ func (x *Quals) Reset()

+ func (x *Quals) String() string

+ type QueryContext struct

+ Columns []string

+ Limit *NullableInt

+ Quals map[string]*Quals

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

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

+ func (*QueryContext) ProtoMessage()

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

+ func (x *QueryContext) GetLimit() *NullableInt

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

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

+ func (x *QueryContext) Reset()

+ func (x *QueryContext) String() string

+ type Row struct

+ Columns map[string]*Column

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

+ func (*Row) ProtoMessage()

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

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

+ func (x *Row) Reset()

+ func (x *Row) String() string

+ type Schema struct

+ Mode string

+ ProtocolVersion int64

+ Schema map[string]*TableSchema

+ SdkVersion string

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

+ func (*Schema) ProtoMessage()

+ func (x *Schema) GetMode() string

+ func (x *Schema) GetProtocolVersion() int64

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

+ func (x *Schema) GetSdkVersion() string

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

+ func (x *Schema) Reset()

+ func (x *Schema) String() string

+ type SetConnectionConfigRequest struct

+ ConnectionConfig string

+ ConnectionName string

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

+ func (*SetConnectionConfigRequest) ProtoMessage()

+ func (x *SetConnectionConfigRequest) GetConnectionConfig() string

+ func (x *SetConnectionConfigRequest) GetConnectionName() string

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

+ func (x *SetConnectionConfigRequest) Reset()

+ func (x *SetConnectionConfigRequest) String() string

+ type SetConnectionConfigResponse struct

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

+ func (*SetConnectionConfigResponse) ProtoMessage()

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

+ func (x *SetConnectionConfigResponse) Reset()

+ func (x *SetConnectionConfigResponse) String() string

+ type TableSchema struct

+ Columns []*ColumnDefinition

+ Description string

+ GetCallKeyColumnList []*KeyColumn

+ GetCallKeyColumns *KeyColumnsSet

+ ListCallKeyColumnList []*KeyColumn

+ ListCallKeyColumns *KeyColumnsSet

+ ListCallOptionalKeyColumns *KeyColumnsSet

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

+ func (*TableSchema) ProtoMessage()

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

+ func (x *TableSchema) GetDescription() string

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

+ func (x *TableSchema) GetGetCallKeyColumns() *KeyColumnsSet

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

+ func (x *TableSchema) GetListCallKeyColumns() *KeyColumnsSet

+ func (x *TableSchema) GetListCallOptionalKeyColumns() *KeyColumnsSet

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

+ func (x *TableSchema) Reset()

+ func (x *TableSchema) String() string

+ type UnimplementedWrapperPluginServer struct

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

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

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

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

+ type UnsafeWrapperPluginServer interface

+ type WrapperPluginClient interface

+ Execute func(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (WrapperPlugin_ExecuteClient, error)

+ GetSchema func(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)

+ GetSupportedOperations func(ctx context.Context, in *GetSupportedOperationsRequest, ...) (*GetSupportedOperationsResponse, error)

+ SetConnectionConfig func(ctx context.Context, in *SetConnectionConfigRequest, opts ...grpc.CallOption) (*SetConnectionConfigResponse, error)

+ func NewWrapperPluginClient(cc grpc.ClientConnInterface) WrapperPluginClient

+ type WrapperPluginServer interface

+ Execute func(*ExecuteRequest, WrapperPlugin_ExecuteServer) error

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

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

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

+ type WrapperPlugin_ExecuteClient interface

+ Recv func() (*ExecuteResponse, error)

+ type WrapperPlugin_ExecuteServer interface

+ Send func(*ExecuteResponse) error

Other modules containing this package

github.com/turbot/steampipe-plugin-sdk

github.com/turbot/steampipe-plugin-sdk/v3

github.com/turbot/steampipe-plugin-sdk/v4

github.com/turbot/steampipe-plugin-sdk/v5