destinationdebugger

Documentation

Index

• func HasUploadEnabled(destID string) bool
• func Init()
• func RecordEventDeliveryStatus(destinationID string, deliveryStatus *DeliveryStatusT) bool
• func Setup(backendConfig backendconfig.BackendConfig)
• type DeliveryStatusT
• type EventDeliveryStatusUploader
  • func (*EventDeliveryStatusUploader) Transform(deliveryStatusesBuffer []*DeliveryStatusT) ([]byte, error)

Functions

func HasUploadEnabled

func HasUploadEnabled(destID string) bool

func Init

func Init()

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.

func Setup

func Setup(backendConfig backendconfig.BackendConfig)

Setup initializes this module

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) Transform(deliveryStatusesBuffer []*DeliveryStatusT) ([]byte, error)