provider

Documentation

Index

• func New(lgr log.Logger, registry metrics.Registry, cp cpclient.Coordinator, ...) providers.Provider
• type Provider
  • func (p *Provider) Activate(ctx context.Context, task *model.TransferOperation, tables abstract.TableMap, ...) error
  • func (p *Provider) Sink(middlewares.Config) (abstract.Sinker, error)
  • func (p *Provider) Source() (abstract.Source, error)
  • func (p *Provider) Storage() (abstract.Storage, error)
  • func (p *Provider) Type() abstract.ProviderType

Functions

func New

func New(lgr log.Logger, registry metrics.Registry, cp cpclient.Coordinator, transfer *model.Transfer) providers.Provider

Types

type Provider

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

func (*Provider) Activate

func (p *Provider) Activate(ctx context.Context, task *model.TransferOperation, tables abstract.TableMap, callbacks providers.ActivateCallbacks) error

func (*Provider) Sink

func (p *Provider) Sink(middlewares.Config) (abstract.Sinker, error)

func (*Provider) Source

func (p *Provider) Source() (abstract.Source, error)

func (*Provider) Storage

func (p *Provider) Storage() (abstract.Storage, error)

func (*Provider) Type

func (p *Provider) Type() abstract.ProviderType