utils

Documentation

Index

• Variables
• func EnhanceResponse(rawMsg []byte, key, val string) []byte
• func ToBeDrained(job *jobsdb.JobT, destID, toAbortDestinationIDs string, ...) (bool, string)
• type BatchDestinationT

Variables

var (
	JobRetention time.Duration
)

Functions

func EnhanceResponse

func EnhanceResponse(rawMsg []byte, key, val string) []byte

rawMsg passed must be a valid JSON

func ToBeDrained

func ToBeDrained(job *jobsdb.JobT, destID, toAbortDestinationIDs string, destinationsMap map[string]*BatchDestinationT) (bool, string)

Types

type BatchDestinationT

type BatchDestinationT struct {
	Destination backendconfig.DestinationT
	Sources     []backendconfig.SourceT
}