execution

Jun 8, 2022

Changes in this version

type TableExecutor

+ ParentExecutor *TableExecutor

+ func (e TableExecutor) IgnoreError(err error) bool

May 24, 2022

Changes in this version

+ type TXQueryExecer interface

+ Commit func(context.Context) error

+ Rollback func(context.Context) error

+ type TXer interface

+ Begin func(context.Context) (TXQueryExecer, error)

Feb 10, 2022

Changes in this version

+ func ClassifyError(err error, opts ...diag.BaseErrorOption) diag.Diagnostics

Feb 2, 2022

Changes in this version

+ type Copier interface

+ RawCopyFrom func(ctx context.Context, r io.Reader, sql string) error

+ RawCopyTo func(ctx context.Context, w io.Writer, sql string) error

Feb 2, 2022

Changes in this version

+ func FromError(err error, opts ...Option) diag.Diagnostics

+ func WithErrorClassifier(e *Error)

+ type Error struct

+ func NewError(severity diag.Severity, dt diag.DiagnosticType, resource, summary string, ...) *Error

+ func (e Error) Description() diag.Description

+ func (e Error) Err() error

+ func (e Error) Error() string

+ func (e Error) Severity() diag.Severity

+ func (e Error) Type() diag.DiagnosticType

+ type ErrorClassifier func(meta schema.ClientMeta, resource string, err error) diag.Diagnostics

+ type Option func(e *Error)

+ func WithDetails(detail string) Option

+ func WithResource(resource string) Option

+ func WithSeverity(s diag.Severity) Option

+ func WithSummary(summary string, args ...interface{}) Option

+ func WithType(dt diag.DiagnosticType) Option

+ type QueryExecer interface

+ Exec func(ctx context.Context, query string, args ...interface{}) error

+ type Storage interface

+ Close func()

+ CopyFrom func(ctx context.Context, resources schema.Resources, shouldCascade bool, ...) error

+ Delete func(ctx context.Context, t *schema.Table, kvFilters []interface{}) error

+ Dialect func() schema.Dialect

+ Insert func(ctx context.Context, t *schema.Table, instance schema.Resources) error

+ RemoveStaleData func(ctx context.Context, t *schema.Table, executionStart time.Time, ...) error

+ type TableExecutor struct

+ Db Storage

+ Logger hclog.Logger

+ ResourceName string

+ Table *schema.Table

+ func NewTableExecutor(resourceName string, db Storage, logger hclog.Logger, table *schema.Table, ...) TableExecutor

+ func (e TableExecutor) Resolve(ctx context.Context, meta schema.ClientMeta) (uint64, diag.Diagnostics)