transformer

Documentation

Index

• func NewTestBackendConfigServer(transformations map[string]string) *kithttptest.Server
• func WithConfigBackendURL(url string) func(*config)
• func WithDockerImageTag(tag string) func(*config)
• func WithUserTransformations(transformations map[string]string, cleaner resource.Cleaner) func(*config)
• type Resource
  • func Setup(pool *dockertest.Pool, d resource.Cleaner, opts ...func(conf *config)) (*Resource, error)

Functions

func NewTestBackendConfigServer

func NewTestBackendConfigServer(transformations map[string]string) *kithttptest.Server

func WithConfigBackendURL

func WithConfigBackendURL(url string) func(*config)

WithConfigBackendURL lets transformer use custom backend config server for transformations WithConfigBackendURL should not be used with WithUserTransformations option

func WithDockerImageTag

func WithDockerImageTag(tag string) func(*config)

func WithUserTransformations

func WithUserTransformations(transformations map[string]string, cleaner resource.Cleaner) func(*config)

WithUserTransformations will mock BE config to set transformation for given transformation versionID to transformation function map

- events with transformationVersionID not present in map will not be transformed and transformer will return 404 for those requests

- WithUserTransformations should not be used with WithConfigBackendURL option

- only javascript transformation functions are supported

e.g.

WithUserTransformations(map[string]string{
			"transform-version-id-1": `export function transformEvent(event, metadata) {
										event.transformed=true
										return event;
									}`,
		})

Types

type Resource

type Resource struct {
	TransformerURL string
	Port           string
}

func Setup

func Setup(pool *dockertest.Pool, d resource.Cleaner, opts ...func(conf *config)) (*Resource, error)