source

Documentation

Index

• func TestPluginSync(t *testing.T, plugin *Plugin, spec specs.Source, opts ...TestPluginOption)
• type GetTables
• type Metrics
  • func (s *Metrics) Equal(other *Metrics) bool
  • func (s *Metrics) TotalErrors() uint64
  • func (s *Metrics) TotalErrorsAtomic() uint64
  • func (s *Metrics) TotalPanics() uint64
  • func (s *Metrics) TotalPanicsAtomic() uint64
  • func (s *Metrics) TotalResources() uint64
  • func (s *Metrics) TotalResourcesAtomic() uint64
• type NewExecutionClientFunc
• type Option
  • func WithDynamicTableOption(getDynamicTables GetTables) Option
  • func WithNoInternalColumns() Option
  • func WithUnmanaged() Option
• type Options
• type Plugin
  • func NewPlugin(name string, version string, tables []*schema.Table, ...) *Plugin
  • func (p *Plugin) Close(ctx context.Context) error
  • func (p *Plugin) GeneratePluginDocs(dir, format string) error
  • func (p *Plugin) GetDynamicTables() schema.Tables
  • func (p *Plugin) HasDynamicTables() bool
  • func (p *Plugin) Init(ctx context.Context, spec specs.Source) error
  • func (p *Plugin) Metrics() *Metrics
  • func (p *Plugin) Name() string
  • func (p *Plugin) SetLogger(logger zerolog.Logger)
  • func (p *Plugin) Sync(ctx context.Context, res chan<- *schema.Resource) error
  • func (p *Plugin) Tables() schema.Tables
  • func (p *Plugin) TablesForSpec(spec specs.Source) (schema.Tables, error)
  • func (p *Plugin) Version() string
• type TableClientMetrics
  • func (s *TableClientMetrics) Equal(other *TableClientMetrics) bool
• type TestPluginOption
  • func WithTestPluginAdditionalValidators(v Validator) TestPluginOption
  • func WithTestPluginNoParallel() TestPluginOption
• type UnmanagedClient
• type Validator

Functions

func TestPluginSync

func TestPluginSync(t *testing.T, plugin *Plugin, spec specs.Source, opts ...TestPluginOption)

Types

type GetTables

type GetTables func(ctx context.Context, c schema.ClientMeta) (schema.Tables, error)

type Metrics

type Metrics struct {
	TableClient map[string]map[string]*TableClientMetrics
}

func (*Metrics) Equal

func (s *Metrics) Equal(other *Metrics) bool

Equal compares to stats. Mostly useful in testing

func (*Metrics) TotalErrors

func (s *Metrics) TotalErrors() uint64

func (*Metrics) TotalErrorsAtomic

func (s *Metrics) TotalErrorsAtomic() uint64

func (*Metrics) TotalPanics

func (s *Metrics) TotalPanics() uint64

func (*Metrics) TotalPanicsAtomic

func (s *Metrics) TotalPanicsAtomic() uint64

func (*Metrics) TotalResources

func (s *Metrics) TotalResources() uint64

func (*Metrics) TotalResourcesAtomic

func (s *Metrics) TotalResourcesAtomic() uint64

type NewExecutionClientFunc

type NewExecutionClientFunc func(context.Context, zerolog.Logger, specs.Source, Options) (schema.ClientMeta, error)

type Option

type Option func(*Plugin)

func WithDynamicTableOption

func WithDynamicTableOption(getDynamicTables GetTables) Option

WithDynamicTableOption allows the plugin to return list of tables after call to New

func WithNoInternalColumns

func WithNoInternalColumns() Option

WithNoInternalColumns won't add internal columns (_cq_id, _cq_parent_cq_id) to the plugin tables

func WithUnmanaged

func WithUnmanaged() Option

type Options

type Options struct {
	Backend backend.Backend
}

type Plugin

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

Plugin is the base structure required to pass to sdk.serve We take a declarative approach to API here similar to Cobra

func NewPlugin

func NewPlugin(name string, version string, tables []*schema.Table, newExecutionClient NewExecutionClientFunc, options ...Option) *Plugin

NewPlugin returns a new plugin with a given name, version, tables, newExecutionClient and additional options.

func (*Plugin) Close

func (p *Plugin) Close(ctx context.Context) error

func (*Plugin) GeneratePluginDocs

func (p *Plugin) GeneratePluginDocs(dir, format string) error

GeneratePluginDocs creates table documentation for the source plugin based on its list of tables

func (*Plugin) GetDynamicTables

func (p *Plugin) GetDynamicTables() schema.Tables

func (*Plugin) HasDynamicTables

func (p *Plugin) HasDynamicTables() bool

func (*Plugin) Init

func (p *Plugin) Init(ctx context.Context, spec specs.Source) error

func (*Plugin) Metrics

func (p *Plugin) Metrics() *Metrics

func (*Plugin) Name

func (p *Plugin) Name() string

Name return the name of this plugin

func (*Plugin) SetLogger

func (p *Plugin) SetLogger(logger zerolog.Logger)

func (*Plugin) Sync

func (p *Plugin) Sync(ctx context.Context, res chan<- *schema.Resource) error

Sync is syncing data from the requested tables in spec to the given channel

func (*Plugin) Tables

func (p *Plugin) Tables() schema.Tables

Tables returns all tables supported by this source plugin

func (*Plugin) TablesForSpec

func (p *Plugin) TablesForSpec(spec specs.Source) (schema.Tables, error)

TablesForSpec returns all tables supported by this source plugin that match the given spec. It validates the tables part of the spec and will return an error if it is found to be invalid. This is deprecated method

func (*Plugin) Version

func (p *Plugin) Version() string

Version returns the version of this plugin

type TableClientMetrics

type TableClientMetrics struct {
	Resources uint64
	Errors    uint64
	Panics    uint64
	StartTime time.Time
	EndTime   time.Time
}

func (*TableClientMetrics) Equal

func (s *TableClientMetrics) Equal(other *TableClientMetrics) bool

type TestPluginOption

type TestPluginOption func(*testPluginOptions)

func WithTestPluginAdditionalValidators

func WithTestPluginAdditionalValidators(v Validator) TestPluginOption

func WithTestPluginNoParallel

func WithTestPluginNoParallel() TestPluginOption

type UnmanagedClient

type UnmanagedClient interface {
	schema.ClientMeta
	Sync(ctx context.Context, metrics *Metrics, res chan<- *schema.Resource) error
}

type Validator

type Validator func(t *testing.T, plugin *Plugin, resources []*schema.Resource)