transformer

Documentation

Index

• func NewTransformerBackendConfigHandler(transformations map[string]string) http.Handler
• type Option
  • func WithConfigBackendURL(url string) Option
  • func WithConnectionToHostEnabled() Option
  • func WithDockerImageTag(tag string) Option
  • func WithDockerNetwork(network *docker.Network) Option
  • func WithEnv(env string) Option
  • func WithRepository(repository string) Option
  • func WithUserTransformations(transformations map[string]string, cleaner resource.Cleaner) Option
• type Resource
  • func Setup(pool *dockertest.Pool, d resource.Cleaner, opts ...Option) (*Resource, error)

Functions

func NewTransformerBackendConfigHandler

func NewTransformerBackendConfigHandler(transformations map[string]string) http.Handler

NewTransformerBackendConfigHandler returns http request handler to handle all backend config requests by transformer

Types

type Option

type Option func(*config)

func WithConfigBackendURL

func WithConfigBackendURL(url string) Option

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

func WithConnectionToHostEnabled

func WithConnectionToHostEnabled() Option

WithConnectionToHostEnabled lets transformer container connect with the host machine i.e. transformer container will be able to access localhost of the host machine

func WithDockerImageTag

func WithDockerImageTag(tag string) Option

func WithDockerNetwork

func WithDockerNetwork(network *docker.Network) Option

func WithEnv

func WithEnv(env string) Option

func WithRepository

func WithRepository(repository string) Option

func WithUserTransformations

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

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;
									}`,
		})

type Resource

type Resource struct {
	TransformerURL string
}

func Setup

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