sink

Documentation

Index

• Variables
• func ConstructBaseSink(transfer *model.Transfer, lgr log.Logger, mtrcs metrics.Registry, ...) (abstract.Sinker, error)
• func MakeAsyncSink(transfer *model.Transfer, lgr log.Logger, mtrcs metrics.Registry, ...) (abstract.AsyncSink, error)

Variables

var NoAsyncSinkErr = xerrors.NewSentinel("no applicable AsyncSink for this transfer")

NoAsyncSinkErr error which indicate that we should try to create sinker from SyncSink

Functions

func ConstructBaseSink

func ConstructBaseSink(transfer *model.Transfer, lgr log.Logger, mtrcs metrics.Registry, cp coordinator.Coordinator, config middlewares.Config) (abstract.Sinker, error)

ConstructBaseSink creates a sink of proper type

func MakeAsyncSink

func MakeAsyncSink(transfer *model.Transfer, lgr log.Logger, mtrcs metrics.Registry, cp coordinator.Coordinator, config middlewares.Config, opts ...abstract.SinkOption) (abstract.AsyncSink, error)

MakeAsyncSink creates a ready-to-use complete sink pipeline, topped with an asynchronous sink wrapper. The pipeline may include multiple middlewares and transformations. Their concrete set depends on transfer settings, its source and destination.