Documentation ¶
Index ¶
- Constants
- Variables
- func EnhanceJSON(rawMsg []byte, key, val string) []byte
- func GetAuthType(dest backendconfig.DestinationT) (authType string)
- func GetRudderAccountId(destination *backendconfig.DestinationT) string
- func Init()
- func IsNotEmptyString(s string) bool
- func ToBeDrained(job *jobsdb.JobT, destID, toAbortDestinationIDs string, ...) (bool, string)
- type BatchDestinationT
- type DrainStats
- type SendPostResponse
Constants ¶
View Source
const (
DRAIN_ERROR_CODE int = 410
)
Variables ¶
View Source
var ( JobRetention time.Duration EmptyPayload = []byte(`{}`) )
Functions ¶
func EnhanceJSON ¶
rawMsg passed must be a valid JSON
func GetAuthType ¶
func GetAuthType(dest backendconfig.DestinationT) (authType string)
func GetRudderAccountId ¶
func GetRudderAccountId(destination *backendconfig.DestinationT) string
func IsNotEmptyString ¶
func ToBeDrained ¶
Types ¶
type BatchDestinationT ¶
type BatchDestinationT struct { Destination backendconfig.DestinationT Sources []backendconfig.SourceT }
type DrainStats ¶
type SendPostResponse ¶
Click to show internal directories.
Click to hide internal directories.