plugin

Sep 8, 2022

Changes in this version

+ func IsCancelled(ctx context.Context) bool

Aug 24, 2022

Changes in this version

type Plugin

+ ConnectionConfigChangedFunc func(ctx context.Context, p *Plugin, old, new *Connection) error

+ func (p *Plugin) ClearConnectionCache(ctx context.Context, connectionName string)

+ func (p *Plugin) ClearQueryCache(ctx context.Context, connectionName string)

Aug 4, 2022

Changes in this version

+ const AnyOf

+ const ContextColumnName

+ const Optional

+ const Required

+ const SchemaModeDynamic

+ const SchemaModeStatic

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

+ func GetFreeMemInterval() int64

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

+ func GetMaxMemoryBytes() int64

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

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

+ func Serve(opts *ServeOpts)

+ type Column struct

+ Default interface{}

+ Description string

+ Hydrate HydrateFunc

+ Name string

+ Transform *transform.ColumnTransforms

+ Type proto.ColumnType

+ type ConcurrencyManager struct

+ func (c *ConcurrencyManager) Close()

+ func (c *ConcurrencyManager) DisplayConcurrencyStats()

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

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

+ 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 ConnectionData struct

+ Connection *Connection

+ Schema map[string]*proto.TableSchema

+ TableMap map[string]*Table

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

+ type DefaultConcurrencyConfig struct

+ DefaultMaxConcurrency int

+ TotalMaxConcurrency int

+ type ErrorPredicate func(error) bool

+ type ErrorPredicateWithContext func(context.Context, *QueryData, *HydrateData, error) bool

+ type GetConfig struct

+ Hydrate HydrateFunc

+ IgnoreConfig *IgnoreConfig

+ KeyColumns KeyColumnSlice

+ MaxConcurrency int

+ RetryConfig *RetryConfig

+ ShouldIgnoreError ErrorPredicate

+ func (c *GetConfig) Validate(table *Table) []string

+ type HydrateCall struct

+ Config *HydrateConfig

+ Depends []string

+ Func HydrateFunc

+ Name string

+ func (h *HydrateCall) Start(ctx context.Context, r *RowData, d *QueryData, ...)

+ func (h HydrateCall) CanStart(rowData *RowData, name string, concurrencyManager *ConcurrencyManager) bool

+ type HydrateConfig struct

+ Depends []HydrateFunc

+ Func HydrateFunc

+ IgnoreConfig *IgnoreConfig

+ MaxConcurrency int

+ RetryConfig *RetryConfig

+ ShouldIgnoreError ErrorPredicate

+ func (c *HydrateConfig) String() interface{}

+ func (c *HydrateConfig) Validate(table *Table) []string

+ type HydrateData struct

+ HydrateResults map[string]interface{}

+ Item interface{}

+ ParentItem interface{}

+ type HydrateDependencies struct

+ Depends []HydrateFunc

+ Func HydrateFunc

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

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

+ func WrapHydrate(hydrateFunc HydrateFunc, ignoreConfig *IgnoreConfig) HydrateFunc

+ type IgnoreConfig struct

+ ShouldIgnoreError ErrorPredicate

+ ShouldIgnoreErrorFunc ErrorPredicateWithContext

+ func (c *IgnoreConfig) DefaultTo(other *IgnoreConfig)

+ func (c *IgnoreConfig) String() interface{}

+ func (c *IgnoreConfig) Validate(table *Table) []string

+ type KeyColumn struct

+ CacheMatch string

+ 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) GetListQualValues() map[string]*proto.QualValueList

+ func (m KeyColumnEqualsQualMap) String() string

+ type KeyColumnQualMap map[string]*KeyColumnQuals

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

+ func (m KeyColumnQualMap) GetListQualValues() quals.QualSlice

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

+ func (m KeyColumnQualMap) String() string

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

+ func (m KeyColumnQualMap) ToProtoQualMap() map[string]*proto.Quals

+ 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 AllColumns(columns []string) KeyColumnSlice

+ func AnyColumn(columns []string) KeyColumnSlice

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

+ func OptionalColumns(columns []string) KeyColumnSlice

+ func SingleColumn(column string) KeyColumnSlice

+ func (k *KeyColumnSlice) Find(name string) *KeyColumn

+ func (k KeyColumnSlice) AllEquals() bool

+ func (k KeyColumnSlice) IsAnyOf() bool

+ func (k KeyColumnSlice) String() string

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

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

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

+ type ListConfig struct

+ Hydrate HydrateFunc

+ IgnoreConfig *IgnoreConfig

+ KeyColumns KeyColumnSlice

+ ParentHydrate HydrateFunc

+ RetryConfig *RetryConfig

+ ShouldIgnoreError ErrorPredicate

+ func (c *ListConfig) Validate(table *Table) []string

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

+ type MatrixItemMapFunc func(context.Context, *QueryData) []map[string]interface

+ type NewPluginOptions struct

+ ConnectionConfig string

+ ConnectionName string

+ type Plugin struct

+ ConnectionConfigSchema *ConnectionConfigSchema

+ ConnectionMap map[string]*ConnectionData

+ DefaultConcurrency *DefaultConcurrencyConfig

+ DefaultGetConfig *GetConfig

+ DefaultIgnoreConfig *IgnoreConfig

+ DefaultRetryConfig *RetryConfig

+ DefaultShouldIgnoreError ErrorPredicate

+ DefaultTransform *transform.ColumnTransforms

+ Logger hclog.Logger

+ Name string

+ RequiredColumns []*Column

+ SchemaMode string

+ TableMap map[string]*Table

+ TableMapFunc func(ctx context.Context, connection *Connection) (map[string]*Table, error)

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

+ func (p *Plugin) GetSchema(connectionName string) (*grpc.PluginSchema, error)

+ func (p *Plugin) Initialise()

+ func (p *Plugin) SetAllConnectionConfigs(configs []*proto.ConnectionConfig, maxCacheSizeMb int) (err error)

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

+ func (p *Plugin) UpdateConnectionConfigs(added []*proto.ConnectionConfig, deleted []*proto.ConnectionConfig, ...) error

+ func (p *Plugin) Validate() string

+ type PluginFunc func(context.Context) *Plugin

+ type QueryColumn struct

+ func NewQueryColumn(column *Column, hydrateName string) *QueryColumn

+ type QueryContext struct

+ CacheEnabled bool

+ CacheTTL int64

+ Columns []string

+ Limit *int64

+ UnsafeQuals map[string]*proto.Quals

+ func NewQueryContext(p *proto.QueryContext, limit *proto.NullableInt, cacheEnabled bool, ...) *QueryContext

+ func (q QueryContext) GetLimit() int64

+ type QueryData struct

+ Connection *Connection

+ ConnectionCache *connection_manager.ConnectionCache

+ ConnectionManager *connection_manager.Manager

+ FetchType fetchType

+ KeyColumnQuals KeyColumnEqualsQualMap

+ Matrix []map[string]interface{}

+ Quals KeyColumnQualMap

+ QueryContext *QueryContext

+ QueryStatus *QueryStatus

+ StreamLeafListItem func(context.Context, ...interface{})

+ StreamListItem func(context.Context, ...interface{})

+ Table *Table

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

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

+ type QueryStatus struct

+ StreamingComplete bool

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

+ type RetryConfig struct

+ ShouldRetryError ErrorPredicate

+ ShouldRetryErrorFunc ErrorPredicateWithContext

+ func (c *RetryConfig) DefaultTo(other *RetryConfig)

+ func (c *RetryConfig) GetListRetryConfig() *RetryConfig

+ func (c *RetryConfig) String() interface{}

+ func (c *RetryConfig) Validate(table *Table) []string

+ type RowData struct

+ Item interface{}

+ ParentItem interface{}

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

+ type ServeOpts struct

+ PluginFunc PluginFunc

+ PluginName string

+ type Table struct

+ Cache *TableCacheOptions

+ Columns []*Column

+ DefaultIgnoreConfig *IgnoreConfig

+ DefaultRetryConfig *RetryConfig

+ DefaultShouldIgnoreError ErrorPredicate

+ DefaultTransform *transform.ColumnTransforms

+ Description string

+ Get *GetConfig

+ GetMatrixItem MatrixItemFunc

+ GetMatrixItemFunc MatrixItemMapFunc

+ HydrateConfig []HydrateConfig

+ HydrateDependencies []HydrateDependencies

+ List *ListConfig

+ Name string

+ Plugin *Plugin

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

+ func (t Table) GetSchema() (*proto.TableSchema, error)

+ type TableCacheOptions struct

+ Enabled bool