types

Documentation

Index

• type DestinationJobT
• type JobMetadataT
• type RouterJobT
• type TransformMessageT

Types

type DestinationJobT

type DestinationJobT struct {
	Message          json.RawMessage            `json:"batchedRequest"`
	JobMetadataArray []JobMetadataT             `json:"metadata"`
	Destination      backendconfig.DestinationT `json:"destination"`
	Batched          bool                       `json:"batched"`
	StatusCode       int                        `json:"statusCode"`
	Error            string                     `json:"error"`
}

DestinationJobT holds the job to be sent to destination and metadata of all the router jobs from which this job is cooked up

type JobMetadataT

type JobMetadataT struct {
	UserID           string       `json:"userId"`
	JobID            int64        `json:"jobId"`
	SourceID         string       `json:"sourceId"`
	DestinationID    string       `json:"destinationId"`
	AttemptNum       int          `json:"attemptNum"`
	ReceivedAt       string       `json:"receivedAt"`
	CreatedAt        string       `json:"createdAt"`
	FirstAttemptedAt string       `json:"firstAttemptedAt"`
	TransformAt      string       `json:"transformAt"`
	JobT             *jobsdb.JobT `json:"jobsT"`
}

JobMetadataT holds the job metadata

type RouterJobT

type RouterJobT struct {
	Message     json.RawMessage            `json:"message"`
	JobMetadata JobMetadataT               `json:"metadata"`
	Destination backendconfig.DestinationT `json:"destination"`
}

RouterJobT holds the router job and its related metadata

type TransformMessageT

type TransformMessageT struct {
	Data     []RouterJobT `json:"input"`
	DestType string       `json:"destType"`
}

TransformMessageT is used to pass message to the transformer workers