source

May 31, 2023

Changes in this version

type Metrics

+ func (s *Metrics) InProgressTables() []string

+ func (s *Metrics) MarkEnd(table *schema.Table, clientID string)

+ func (s *Metrics) MarkStart(table *schema.Table, clientID string)

+ func (s *Metrics) QueuedTables() []string

May 15, 2023

Changes in this version

+ var DefaultTitleExceptions = map[string]string

+ func DefaultTitleTransformer(table *schema.Table) string

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

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

+ type Metrics struct

+ TableClient map[string]map[string]*TableClientMetrics

+ 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 func(context.Context, zerolog.Logger, specs.Source, Options) (schema.ClientMeta, error)

+ type Option func(*Plugin)

+ func WithDynamicTableOption(getDynamicTables GetTables) Option

+ func WithNoInternalColumns() Option

+ func WithTitleTransformer(t func(*schema.Table) string) Option

+ func WithUnmanaged() Option

+ type Options struct

+ Backend backend.Backend

+ type Plugin struct

+ 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, syncTime time.Time, 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 struct

+ EndTime time.Time

+ Errors uint64

+ Panics uint64

+ Resources uint64

+ StartTime time.Time

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

+ type TestPluginOption func(*testPluginOptions)

+ func WithTestPluginAdditionalValidators(v Validator) TestPluginOption

+ func WithTestPluginNoParallel() TestPluginOption

+ type UnmanagedClient interface

+ Sync func(ctx context.Context, metrics *Metrics, res chan<- *schema.Resource) error

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