transformer

Documentation

Index

• Constants
• func Init()
• type HandleT
  • func NewTransformer() *HandleT
  • func (trans *HandleT) ProxyRequest(ctx context.Context, responseData integrations.PostParametersT, ...) (int, string)
  • func (trans *HandleT) Setup()
  • func (trans *HandleT) Transform(transformType string, transformMessage *types.TransformMessageT) []types.DestinationJobT
• type Transformer

Constants

const (
	BATCH            = "BATCH"
	ROUTER_TRANSFORM = "ROUTER_TRANSFORM"
)

Functions

func Init

func Init()

Types

type HandleT

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

HandleT is the handle for this class

func NewTransformer

func NewTransformer() *HandleT

NewTransformer creates a new transformer

func (*HandleT) ProxyRequest

func (trans *HandleT) ProxyRequest(ctx context.Context, responseData integrations.PostParametersT, destName string, jobId int64) (int, string)

func (*HandleT) Setup

func (trans *HandleT) Setup()

is it ok to use same client for network and transformer calls? need to understand timeout setup in router

func (*HandleT) Transform

func (trans *HandleT) Transform(transformType string, transformMessage *types.TransformMessageT) []types.DestinationJobT

Transform transforms router jobs to destination jobs

type Transformer

type Transformer interface {
	Setup()
	Transform(transformType string, transformMessage *types.TransformMessageT) []types.DestinationJobT
	ProxyRequest(ctx context.Context, responseData integrations.PostParametersT, destName string, jobId int64) (statusCode int, respBody string)
}

Transformer provides methods to transform events