Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var WithDisableEventUploads = func(disableEventDeliveryStatusUploads bool) func(h *Handle) { return func(h *Handle) { h.disableEventDeliveryStatusUploads = disableEventDeliveryStatusUploads } }
Functions ¶
This section is empty.
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 DestinationDebugger ¶ added in v1.6.0
type DestinationDebugger interface {
RecordEventDeliveryStatus(destinationID string, deliveryStatus *DeliveryStatusT) bool
HasUploadEnabled(destID string) bool
Stop()
}
func NewHandle ¶ added in v1.6.0
func NewHandle(backendConfig backendconfig.BackendConfig, opts ...Opt) (DestinationDebugger, error)
func NewNoOpService ¶ added in v1.6.0
func NewNoOpService() DestinationDebugger
type EventDeliveryStatusUploader ¶
type EventDeliveryStatusUploader struct {
// contains filtered or unexported fields
}
func NewEventDeliveryStatusUploader ¶ added in v1.6.0
func NewEventDeliveryStatusUploader(log logger.Logger) *EventDeliveryStatusUploader
func (*EventDeliveryStatusUploader) Transform ¶
func (e *EventDeliveryStatusUploader) Transform(deliveryStatusesBuffer []*DeliveryStatusT) ([]byte, error)
type Handle ¶ added in v1.6.0
type Handle struct {
// contains filtered or unexported fields
}
func (*Handle) HasUploadEnabled ¶ added in v1.6.0
func (*Handle) RecordEventDeliveryStatus ¶ added in v1.6.0
func (h *Handle) RecordEventDeliveryStatus(destinationID string, deliveryStatus *DeliveryStatusT) bool
RecordEventDeliveryStatus is used to put the delivery status in the deliveryStatusesBatchChannel, which will be processed by handleJobs.
Source Files
Click to show internal directories.
Click to hide internal directories.