plugins

type DestinationPlugin interface {
	Configure(ctx context.Context, spec specs.DestinationSpec) error
	CreateTables(ctx context.Context, table []*schema.Table) error
	Save(ctx context.Context, resources []*schema.Resource) error
	GetExampleConfig(ctx context.Context) string
}

type DestinationPluginOptions struct {
	Logger zerolog.Logger
}

type ResourceTestCase struct {
	Plugin *SourcePlugin
	Config string
	// we want it to be parallel by default
	NotParallel bool
	// ParallelFetchingLimit limits parallel resources fetch at a time
	ParallelFetchingLimit uint64
	// SkipIgnoreInTest flag which detects if schema.Table or schema.Column should be ignored
	SkipIgnoreInTest bool
	// Verifiers are map from resource name to its verifiers.
	// If no verifiers specified for resource (resource name is not in key set of map),
	// non emptiness check of all columns in table and its relations will be performed.
	Verifiers map[string][]Verifier
}

type Row map[string]interface{}

type SourcePlugin struct {
	// Name of plugin i.e aws,gcp, azure etc'
	Name string
	// Version of the plugin
	Version string
	// Called upon configure call to validate and init configuration
	Configure func(context.Context, *SourcePlugin, specs.SourceSpec) (schema.ClientMeta, error)
	// Tables is all tables supported by this source plugin
	Tables []*schema.Table
	// JsonSchema for specific source plugin spec
	JsonSchema string
	// ExampleConfig is the example configuration for this plugin
	ExampleConfig string
	// Logger to call, this logger is passed to the serve.Serve Client, if not define Serve will create one instead.
	Logger zerolog.Logger
	// contains filtered or unexported fields
}

type Verifier func(t *testing.T, table *schema.Table, conn pgxscan.Querier, shouldSkipIgnoreInTest bool)