Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HasUploadEnabled ¶
func RecordEventDeliveryStatus ¶
func RecordEventDeliveryStatus(destinationID string, deliveryStatus *DeliveryStatusT) bool
RecordEventDeliveryStatus is used to put the delivery status in the deliveryStatusesBatchChannel, which will be processed by handleJobs.
Types ¶
type DeliveryStatusT ¶
type DeliveryStatusT struct {
DestinationID string `json:"destinationId"`
SourceID string `json:"sourceId"`
Payload json.RawMessage `json:"payload"`
AttemptNum int `json:"attemptNum"`
JobState string `json:"jobState"`
ErrorCode string `json:"errorCode"`
ErrorResponse json.RawMessage `json:"errorResponse"`
SentAt string `json:"sentAt"`
EventName string `json:"eventName"`
EventType string `json:"eventType"`
}
DeliveryStatusT is a structure to hold everything related to event delivery
type EventDeliveryStatusUploader ¶
type EventDeliveryStatusUploader struct{}
func (*EventDeliveryStatusUploader) Transform ¶
func (eventDeliveryStatusUploader *EventDeliveryStatusUploader) Transform(data interface{}) ([]byte, error)
Source Files
Click to show internal directories.
Click to hide internal directories.