init

Documentation

Index

• func New(provider abstract.ProviderType) ...
• type Provider
  • func (p *Provider) Cleanup(ctx context.Context, task *model.TransferOperation) error
  • func (p *Provider) DataProvider() (provider base.DataProvider, err error)
  • func (p *Provider) Sink(middlewares.Config) (abstract.Sinker, error)
  • func (p *Provider) Storage() (abstract.Storage, error)
  • func (p *Provider) TMPCleaner(ctx context.Context, task *model.TransferOperation) (providers.Cleaner, error)
  • func (p *Provider) Target(...abstract.SinkOption) (base.EventTarget, error)
  • func (p *Provider) Type() abstract.ProviderType
  • func (p *Provider) Verify(ctx context.Context) error

Functions

func New

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

Types

type Provider

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

func (*Provider) Cleanup

func (p *Provider) Cleanup(ctx context.Context, task *model.TransferOperation) error

func (*Provider) DataProvider

func (p *Provider) DataProvider() (provider base.DataProvider, err error)

func (*Provider) Sink

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

func (*Provider) Storage

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

func (*Provider) TMPCleaner

func (p *Provider) TMPCleaner(ctx context.Context, task *model.TransferOperation) (providers.Cleaner, error)

func (*Provider) Target

func (p *Provider) Target(...abstract.SinkOption) (base.EventTarget, error)

func (*Provider) Type

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

func (*Provider) Verify

func (p *Provider) Verify(ctx context.Context) error