destinationdebugger

Documentation

Index

• Variables
• type DeliveryStatusT
• type DestinationDebugger
  • func NewHandle(backendConfig backendconfig.BackendConfig, opts ...Opt) (DestinationDebugger, error)
  • func NewNoOpService() DestinationDebugger
• type EventDeliveryStatusUploader
  • func NewEventDeliveryStatusUploader(log logger.Logger) *EventDeliveryStatusUploader
  • func (e *EventDeliveryStatusUploader) Transform(deliveryStatusesBuffer []*DeliveryStatusT) ([]byte, error)
• type Handle
  • func (h *Handle) HasUploadEnabled(destID string) bool
  • func (h *Handle) RecordEventDeliveryStatus(destinationID string, deliveryStatus *DeliveryStatusT) bool
  • func (h *Handle) Stop()
• type Opt

Variables

var WithDisableEventUploads = func(disableEventDeliveryStatusUploads bool) func(h *Handle) {
	return func(h *Handle) {
		h.disableEventDeliveryStatusUploads = disableEventDeliveryStatusUploads
	}
}

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

type DestinationDebugger interface {
	RecordEventDeliveryStatus(destinationID string, deliveryStatus *DeliveryStatusT) bool
	HasUploadEnabled(destID string) bool
	Stop()
}

func NewHandle

func NewHandle(backendConfig backendconfig.BackendConfig, opts ...Opt) (DestinationDebugger, error)

func NewNoOpService

func NewNoOpService() DestinationDebugger

type EventDeliveryStatusUploader

type EventDeliveryStatusUploader struct {
	// contains filtered or unexported fields
}

func NewEventDeliveryStatusUploader

func NewEventDeliveryStatusUploader(log logger.Logger) *EventDeliveryStatusUploader

func (*EventDeliveryStatusUploader) Transform

func (e *EventDeliveryStatusUploader) Transform(deliveryStatusesBuffer []*DeliveryStatusT) ([]byte, error)

type Handle

type Handle struct {
	// contains filtered or unexported fields
}

func (*Handle) HasUploadEnabled

func (h *Handle) HasUploadEnabled(destID string) bool

func (*Handle) RecordEventDeliveryStatus

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.

func (*Handle) Stop

func (h *Handle) Stop()

type Opt

type Opt func(*Handle)