Documentation ¶
Index ¶
Constants ¶
View Source
const (
RouterTimedOutStatusCode = 1113
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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"` WorkspaceId string `json:"workspaceId"` Secret json.RawMessage `json:"secret"` JobT *jobsdb.JobT `json:"jobsT"` PickedAtTime time.Time `json:"pickedAtTime"` ResultSetID int64 `json:"resultSetID"` }
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
Click to show internal directories.
Click to hide internal directories.