target

Documentation

Index

• func NewTarget(logger log.Logger, metrics metrics.Registry, ...) (base.EventTarget, error)
• type YtCopyTarget
  • func (t *YtCopyTarget) AsyncPush(in base.EventBatch) chan error
  • func (t *YtCopyTarget) Close() error

Functions

func NewTarget

func NewTarget(logger log.Logger, metrics metrics.Registry, cfg *yt_provider.YtCopyDestination, transferID string) (base.EventTarget, error)

Types

type YtCopyTarget

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

func (*YtCopyTarget) AsyncPush

func (t *YtCopyTarget) AsyncPush(in base.EventBatch) chan error

func (*YtCopyTarget) Close

func (t *YtCopyTarget) Close() error