mapper

Documentation

Index

• type Config
  • func (c Config) Validate() error
• type Mapper
  • func New(cfg Config) (*Mapper, error)
  • func (m Mapper) Process(event entities.PipelineEvent) (entities.PipelineEvent, error)

Types

type Config

type Config struct {
	OutputEvent json.RawMessage `json:"outputEvent"`
}

func (Config) Validate

func (c Config) Validate() error

type Mapper

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

func New

func New(cfg Config) (*Mapper, error)

func (Mapper) Process

func (m Mapper) Process(event entities.PipelineEvent) (entities.PipelineEvent, error)