asyncdestinationmanager

Documentation

Index

• Variables
• func GetMarshalledData(payload string, jobID int64) string
• func Init()
• func NewManager(destination *backendconfig.DestinationT, ...) (common.AsyncDestinationManager, error)

Variables

var HTTPTimeout time.Duration

Functions

func GetMarshalledData

func GetMarshalledData(payload string, jobID int64) string

func Init

func Init()

func NewManager

func NewManager(destination *backendconfig.DestinationT, backendConfig backendconfig.BackendConfig) (common.AsyncDestinationManager, error)