transformationdebugger

Documentation

Index

• func Init()
• func IsUploadEnabled(id string) bool
• func RecordTransformationStatus(transformStatus *TransformStatusT) bool
• func Setup()
• func UploadTransformationStatus(tStatus *TransformationStatusT)
• type EventBeforeTransform
• type EventPayloadAfterTransform
• type EventsAfterTransform
• type TransformStatusT
• type TransformationStatusT
• type TransformationStatusUploader
  • func (*TransformationStatusUploader) Transform(data interface{}) ([]byte, error)
• type UploadT

Functions

func Init

func Init()

func IsUploadEnabled

func IsUploadEnabled(id string) bool

func RecordTransformationStatus

func RecordTransformationStatus(transformStatus *TransformStatusT) bool

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

func Setup

func Setup()

Setup initializes this module

func UploadTransformationStatus

func UploadTransformationStatus(tStatus *TransformationStatusT)

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 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 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{}
}

type TransformationStatusUploader

type TransformationStatusUploader struct{}

func (*TransformationStatusUploader) Transform

func (*TransformationStatusUploader) Transform(data interface{}) ([]byte, error)

type UploadT

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