utils

Documentation

Index

• Constants
• Variables
• func EnhanceJSON(rawMsg []byte, key, val string) []byte
• func EnhanceJsonWithTime(t time.Time, key string, resp []byte) []byte
• func Init()
• func IsNotEmptyString(s string) bool
• func ToBeDrained(job *jobsdb.JobT, destID, toAbortDestinationIDs string, ...) (bool, string)
• type DestinationWithSources
• type DrainStats
• type SendPostResponse

Constants

const (
	DRAIN_ERROR_CODE int = 410
	// transformation(router or batch)
	ERROR_AT_TF = "transformation"
	// event delivery
	ERROR_AT_DEL = "delivery"
	// custom destination manager
	ERROR_AT_CUST = "custom"
)

Variables

var (
	JobRetention time.Duration
	EmptyPayload = []byte(`{}`)
)

Functions

func EnhanceJSON

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

rawMsg passed must be a valid JSON

func EnhanceJsonWithTime

func EnhanceJsonWithTime(t time.Time, key string, resp []byte) []byte

func Init

func Init()

func IsNotEmptyString

func IsNotEmptyString(s string) bool

func ToBeDrained

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

Types

type DestinationWithSources

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

type DrainStats

type DrainStats struct {
	Count     int
	Reasons   []string
	Workspace string
}

type SendPostResponse

type SendPostResponse struct {
	StatusCode          int
	ResponseContentType string
	ResponseBody        []byte
}