plugin

Dec 23, 2021

Changes in this version

type KeyColumnEqualsQualMap

+ func (m KeyColumnEqualsQualMap) GetListQualValues() map[string]*proto.QualValueList

Nov 10, 2021

Changes in this version

type Plugin

+ ConnectionConfigChangedFunc func() error

+ Schema map[string]*proto.TableSchema

Oct 18, 2021

Changes in this version

+ const SchemaModeDynamic

+ const SchemaModeStatic

type Plugin

+ SchemaMode string

Oct 8, 2021

Changes in this version

type KeyColumnSlice

+ func (k KeyColumnSlice) IsAnyOf() bool

Sep 21, 2021

Changes in this version

+ type CreatePlugin func(context.Context, string) (*Plugin, error)

+ type NewPluginOptions struct

+ ConnectionConfig string

+ ConnectionName string

type Plugin

+ Connection *Connection

+ TableMapFunc func(p *Plugin) (map[string]*Table, error)

type QueryData

+ QueryStatus *QueryStatus

+ type QueryStatus struct

+ func (s *QueryStatus) RowsRemaining(ctx context.Context) int

Aug 5, 2021

Changes in this version

type KeyColumnQualMap

+ func (m KeyColumnQualMap) GetUnsatisfiedKeyColumns(columns KeyColumnSlice) KeyColumnSlice

Jul 20, 2021

Changes in this version

type HydrateCall

+ Name string

Jul 9, 2021

Changes in this version

+ const AnyOf

+ const Optional

+ const Required

+ func IsCancelled(ctx context.Context) bool

type HydrateFunc

+ func (hydrate HydrateFunc) WithCache(args ...HydrateFunc) HydrateFunc

+ type KeyColumn struct

+ Name string

+ Operators []string

+ Require string

+ func (k *KeyColumn) InitialiseOperators()

+ func (k *KeyColumn) SingleEqualsQual() bool

+ func (k *KeyColumn) ToProtobuf() *proto.KeyColumn

+ func (k *KeyColumn) Validate() []string

+ func (k KeyColumn) String() string

+ type KeyColumnEqualsQualMap map[string]*proto.QualValue

+ func (m KeyColumnEqualsQualMap) String() string

+ type KeyColumnQualMap map[string]*KeyColumnQuals

+ func NewKeyColumnQualValueMap(qualMap map[string]*proto.Quals, keyColumns KeyColumnSlice) KeyColumnQualMap

+ func (m KeyColumnQualMap) SatisfiesKeyColumns(columns KeyColumnSlice) (bool, KeyColumnSlice)

+ func (m KeyColumnQualMap) String() string

+ func (m KeyColumnQualMap) ToEqualsQualValueMap() map[string]*proto.QualValue

+ func (m KeyColumnQualMap) ToQualMap() map[string]quals.QualSlice

+ type KeyColumnQuals struct

+ Name string

+ Quals quals.QualSlice

+ func (k KeyColumnQuals) SatisfiesKeyColumn(keyColumn *KeyColumn) bool

+ func (k KeyColumnQuals) SingleEqualsQual() bool

+ type KeyColumnSlice []*KeyColumn

+ func NewEqualsKeyColumnSlice(columns []string, require string) KeyColumnSlice

+ func OptionalColumns(columns []string) KeyColumnSlice

+ func (k KeyColumnSlice) AllEquals() bool

+ func (k KeyColumnSlice) SingleEqualsQual() *KeyColumn

+ func (k KeyColumnSlice) String() string

+ func (k KeyColumnSlice) StringSlice() []string

+ func (k KeyColumnSlice) ToProtobuf() []*proto.KeyColumn

+ func (k KeyColumnSlice) Validate() []string

+ type QueryContext struct

+ Columns []string

+ Limit *int64

+ UnsafeQuals map[string]*proto.Quals

+ func NewQueryContext(p *proto.QueryContext) *QueryContext

type QueryData

+ Quals KeyColumnQualMap

+ func (d *QueryData) KeyColumnQualString(key string) string

type Table

+ func (t *Table) ValidateColumnsExist(keyColumns KeyColumnSlice) []string

Jun 9, 2021

Changes in this version

type Plugin

+ ConnectionManager *connection_manager.Manager

May 6, 2021

Changes in this version

+ func RetryHydrate(ctx context.Context, d *QueryData, hydrateData *HydrateData, ...) (interface{}, error)

type GetConfig

+ RetryConfig *RetryConfig

type HydrateConfig

+ RetryConfig *RetryConfig

+ ShouldIgnoreError ErrorPredicate

type HydrateFunc

+ func WrapHydrate(hydrateFunc HydrateFunc, shouldIgnoreError ErrorPredicate) HydrateFunc

type ListConfig

+ RetryConfig *RetryConfig

+ ShouldIgnoreError ErrorPredicate

type Plugin

+ DefaultRetryConfig *RetryConfig

+ type RetryConfig struct

+ ShouldRetryError ErrorPredicate

Mar 16, 2021

Changes in this version

type HydrateData

+ ParentItem interface{}

type QueryData

+ func (d *QueryData) ShallowCopy() *QueryData

type RowData

+ ParentItem interface{}

Feb 17, 2021

Changes in this version

+ func ColumnQualValue(qv *proto.QualValue, column *Column) interface

+ func DiagsToError(prefix string, diags hcl.Diagnostics) error

+ func GetMatrixItem(ctx context.Context) map[string]interface

type ConcurrencyManager

+ func (c *ConcurrencyManager) Close()

+ func (c *ConcurrencyManager) DisplayConcurrencyStats()

+ type Connection struct

+ Config interface{}

+ Name string

+ type ConnectionConfigInstanceFunc func() interface

+ type ConnectionConfigSchema struct

+ NewInstance ConnectionConfigInstanceFunc

+ Schema map[string]*schema.Attribute

+ func NewConnectionConfigSchema() *ConnectionConfigSchema

+ func (c *ConnectionConfigSchema) Parse(configString string) (config interface{}, err error)

+ func (c *ConnectionConfigSchema) Validate() []string

+ type DefaultConcurrencyConfig struct

+ DefaultMaxConcurrency int

+ TotalMaxConcurrency int

+ type MatrixItemFunc func(context.Context, *Connection) []map[string]interface

type Plugin

+ ConnectionConfigSchema *ConnectionConfigSchema

+ Connections map[string]*Connection

+ DefaultConcurrency *DefaultConcurrencyConfig

+ func (p *Plugin) Initialise()

+ func (p *Plugin) SetConnectionConfig(connectionName, connectionConfigString string) (err error)

type QueryData

+ Connection *Connection

+ Matrix []map[string]interface{}

type Table

+ GetMatrixItem MatrixItemFunc

Feb 11, 2021

Changes in this version

+ func ToError(val interface{}) error

+ type ConcurrencyManager struct

+ func (c *ConcurrencyManager) Finished(name string)

+ func (c *ConcurrencyManager) StartIfAllowed(name string, maxCallConcurrency int) (res bool)

+ type DefaultHydrateConfig struct

+ DefaultMaxConcurrencyPerCall int

+ MaxConcurrency int

type HydrateCall

+ Config *HydrateConfig

+ func (h *HydrateCall) Start(ctx context.Context, r *RowData, hydrateFuncName string, ...)

+ type HydrateConfig struct

+ Depends []HydrateFunc

+ Func HydrateFunc

+ MaxConcurrency int

type Plugin

+ DefaultHydrateConfig *DefaultHydrateConfig

type Table

+ HydrateConfig []HydrateConfig

Jan 21, 2021

Changes in this version

+ var ContextKeyLogger = contextKey("logger")

+ func Logger(ctx context.Context) hclog.Logger

+ func Serve(opts *ServeOpts)

+ type Column struct

+ Default interface{}

+ Description string

+ Hydrate HydrateFunc

+ Name string

+ Transform *transform.ColumnTransforms

+ Type proto.ColumnType

+ type ErrorPredicate func(error) bool

+ type GetConfig struct

+ Hydrate HydrateFunc

+ ItemFromKey HydrateFunc

+ KeyColumns *KeyColumnSet

+ ShouldIgnoreError ErrorPredicate

+ type HydrateCall struct

+ Depends []string

+ Func HydrateFunc

+ func (h HydrateCall) CanStart(rowData *RowData) bool

+ type HydrateData struct

+ HydrateResults map[string]interface{}

+ Item interface{}

+ type HydrateDependencies struct

+ Depends []HydrateFunc

+ Func HydrateFunc

+ type HydrateFunc func(context.Context, *QueryData, *HydrateData) (interface{}, error)

+ type KeyColumnSet struct

+ All []string

+ Any []string

+ Single string

+ func AllColumns(columns []string) *KeyColumnSet

+ func AnyColumn(columns []string) *KeyColumnSet

+ func SingleColumn(column string) *KeyColumnSet

+ func (k *KeyColumnSet) ToString() string

+ type ListConfig struct

+ Hydrate HydrateFunc

+ KeyColumns *KeyColumnSet

+ ParentHydrate HydrateFunc

+ type Plugin struct

+ DefaultGetConfig *GetConfig

+ DefaultTransform *transform.ColumnTransforms

+ Logger hclog.Logger

+ Name string

+ RequiredColumns []*Column

+ TableMap map[string]*Table

+ func (p *Plugin) Execute(req *proto.ExecuteRequest, stream proto.WrapperPlugin_ExecuteServer) (err error)

+ func (p *Plugin) GetSchema() (map[string]*proto.TableSchema, error)

+ func (p *Plugin) Validate() string

+ type PluginFunc func(context.Context) *Plugin

+ type QueryData struct

+ ConnectionManager *connection.Manager

+ FetchType fetchType

+ KeyColumnQuals map[string]*pb.QualValue

+ QueryContext *pb.QueryContext

+ Table *Table

+ func (d *QueryData) SetFetchType(table *Table)

+ func (d *QueryData) StreamLeafListItem(_ context.Context, item interface{})

+ func (d *QueryData) StreamListItem(ctx context.Context, item interface{})

+ type RowData struct

+ Item interface{}

+ func (r *RowData) GetColumnData(column *Column) (interface{}, error)

+ type ServeOpts struct

+ PluginFunc PluginFunc

+ PluginName string

+ type Table struct

+ Columns []*Column

+ DefaultTransform *transform.ColumnTransforms

+ Description string

+ Get *GetConfig

+ HydrateDependencies []HydrateDependencies

+ List *ListConfig

+ Name string

+ Plugin *Plugin

+ func (t *Table) SafeGet() HydrateFunc

+ func (t Table) GetSchema() *pb.TableSchema