imports

type Import struct {
	Schema            string
	TableName         string
	PrimaryKey        string
	PrimaryKeyScanner textTranscodingScanner
	Relation          *logical.Relation
	Scanners          []decode.Scanner
	Destinations      []interface{}
	Cursor            interface{}
}

type Importer interface {
	Do(ctx context.Context, logger kitlog.Logger, tx pgx.Tx, job model.ImportJobs) error
}

type ImporterOptions struct {
	SnapshotTimeout time.Duration
	BatchLimit      int
	BufferSize      int
}

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

type ManagerOptions struct {
	PollInterval time.Duration
}

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

type WorkerOptions struct {
	SubscriptionID   string        // fixes this worker to only work jobs associated with the current subscription
	PollInterval     time.Duration // interval between polling for new jobs
	RetryInterval    time.Duration // retry interval for the exponential backoff
	RetryExponent    int           // retry exponent to calculate backoff
	MaxRetryInterval time.Duration // maximum interval between retries
}