targets

Documentation

Index

• Variables
• func NewTarget(transfer *model.Transfer, lgr log.Logger, mtrcs metrics.Registry, ...) (t base.EventTarget, err error)

Variables

var UnknownTargetError = xerrors.New("unknown event target for destination, try legacy sinker instead")

Functions

func NewTarget

func NewTarget(transfer *model.Transfer, lgr log.Logger, mtrcs metrics.Registry, cp coordinator.Coordinator, opts ...abstract.SinkOption) (t base.EventTarget, err error)