transformationdebugger

Documentation

Index

• func WithDisableTransformationStatusUploads(disableTransformationStatusUploads bool) func(h *Handle)
• type EventBeforeTransform
• type EventPayloadAfterTransform
• type EventsAfterTransform
• type Handle
  • func (h *Handle) IsUploadEnabled(id string) bool
  • func (h *Handle) RecordTransformationStatus(transformStatus *TransformStatusT)
  • func (h *Handle) Stop()
  • func (h *Handle) UploadTransformationStatus(tStatus *TransformationStatusT) bool
• type Opt
• type TransformStatusT
• type TransformationDebugger
  • func NewHandle(backendConfig backendconfig.BackendConfig, opts ...Opt) (TransformationDebugger, error)
  • func NewNoOpService() TransformationDebugger
• type TransformationStatusT
  • func (ts *TransformationStatusT) Limit(limit int, transformation backendconfig.TransformationT) *TransformationStatusT
• type TransformationStatusUploader
  • func (t *TransformationStatusUploader) Transform(eventBuffer []*TransformStatusT) ([]byte, error)
• type UploadT

Functions

func WithDisableTransformationStatusUploads

func WithDisableTransformationStatusUploads(disableTransformationStatusUploads bool) func(h *Handle)

Types

type EventBeforeTransform

type EventBeforeTransform struct {
	EventName  string               `json:"eventName"`
	EventType  string               `json:"eventType"`
	ReceivedAt string               `json:"receivedAt"`
	Payload    types.SingularEventT `json:"payload"`
}

type EventPayloadAfterTransform

type EventPayloadAfterTransform struct {
	EventName string               `json:"eventName"`
	EventType string               `json:"eventType"`
	Payload   types.SingularEventT `json:"payload"`
}

type EventsAfterTransform

type EventsAfterTransform struct {
	ReceivedAt    string                        `json:"receivedAt"`
	IsDropped     bool                          `json:"isDropped"`
	Error         string                        `json:"error"`
	StatusCode    int                           `json:"statusCode"`
	EventPayloads []*EventPayloadAfterTransform `json:"payload"`
}

type Handle

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

func (*Handle) IsUploadEnabled

func (h *Handle) IsUploadEnabled(id string) bool

func (*Handle) RecordTransformationStatus

func (h *Handle) RecordTransformationStatus(transformStatus *TransformStatusT)

RecordTransformationStatus is used to put the transform event in the eventBatchChannel, which will be processed by handleEvents.

func (*Handle) Stop

func (h *Handle) Stop()

func (*Handle) UploadTransformationStatus

func (h *Handle) UploadTransformationStatus(tStatus *TransformationStatusT) bool

type Opt

type Opt func(*Handle)

type TransformStatusT

type TransformStatusT struct {
	TransformationID string                `json:"transformationId"`
	SourceID         string                `json:"sourceId"`
	DestinationID    string                `json:"destinationId"`
	EventBefore      *EventBeforeTransform `json:"eventBefore"`
	EventsAfter      *EventsAfterTransform `json:"eventsAfter"`
	IsError          bool                  `json:"error"`
}

TransformStatusT is a structure to hold transformation status

type TransformationDebugger

type TransformationDebugger interface {
	IsUploadEnabled(id string) bool
	RecordTransformationStatus(transformStatus *TransformStatusT)
	UploadTransformationStatus(tStatus *TransformationStatusT) bool
	Stop()
}

func NewHandle

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

func NewNoOpService

func NewNoOpService() TransformationDebugger

type TransformationStatusT

type TransformationStatusT struct {
	SourceID              string
	DestID                string
	Destination           *backendconfig.DestinationT
	UserTransformedEvents []transformer.TransformerEventT
	EventsByMessageID     map[string]types.SingularEventWithReceivedAt
	FailedEvents          []transformer.TransformerResponseT
	UniqueMessageIds      map[string]struct{}
}

func (*TransformationStatusT) Limit

func (ts *TransformationStatusT) Limit(
	limit int,
	transformation backendconfig.TransformationT,
) *TransformationStatusT

limit the number of stored events

type TransformationStatusUploader

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

func (*TransformationStatusUploader) Transform

func (t *TransformationStatusUploader) Transform(eventBuffer []*TransformStatusT) ([]byte, error)

type UploadT

type UploadT struct {
	Payload []*TransformStatusT `json:"payload"`
}