transformer

Documentation

Index

• func Register(name string, t Transformer)
• type CBORTransformer
  • func (c *CBORTransformer) Footer(ctx *etl_core.Context) ([]byte, error)
  • func (c *CBORTransformer) Header(ctx *etl_core.Context) ([]byte, error)
  • func (c *CBORTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)
• type CSVTransformer
  • func (c *CSVTransformer) Footer(ctx *etl_core.Context) ([]byte, error)
  • func (c *CSVTransformer) Header(ctx *etl_core.Context) ([]byte, error)
  • func (c *CSVTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)
• type JSONLTransformer
  • func (c *JSONLTransformer) Footer(ctx *etl_core.Context) ([]byte, error)
  • func (c *JSONLTransformer) Header(ctx *etl_core.Context) ([]byte, error)
  • func (j *JSONLTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)
• type PassthroughTransformer
  • func (c *PassthroughTransformer) Footer(ctx *etl_core.Context) ([]byte, error)
  • func (c *PassthroughTransformer) Header(ctx *etl_core.Context) ([]byte, error)
  • func (c *PassthroughTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)
• type Transformer
  • func ForName(name string) (Transformer, error)

Functions

func Register

func Register(name string, t Transformer)

Types

type CBORTransformer

type CBORTransformer struct{}

func (*CBORTransformer) Footer

func (c *CBORTransformer) Footer(ctx *etl_core.Context) ([]byte, error)

func (*CBORTransformer) Header

func (c *CBORTransformer) Header(ctx *etl_core.Context) ([]byte, error)

func (*CBORTransformer) Transform

func (c *CBORTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)

type CSVTransformer

type CSVTransformer struct{}

func (*CSVTransformer) Footer

func (c *CSVTransformer) Footer(ctx *etl_core.Context) ([]byte, error)

func (*CSVTransformer) Header

func (c *CSVTransformer) Header(ctx *etl_core.Context) ([]byte, error)

func (*CSVTransformer) Transform

func (c *CSVTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)

type JSONLTransformer

type JSONLTransformer struct{}

func (*JSONLTransformer) Footer

func (c *JSONLTransformer) Footer(ctx *etl_core.Context) ([]byte, error)

func (*JSONLTransformer) Header

func (c *JSONLTransformer) Header(ctx *etl_core.Context) ([]byte, error)

func (*JSONLTransformer) Transform

func (j *JSONLTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)

type PassthroughTransformer

type PassthroughTransformer struct{}

func (*PassthroughTransformer) Footer

func (c *PassthroughTransformer) Footer(ctx *etl_core.Context) ([]byte, error)

func (*PassthroughTransformer) Header

func (c *PassthroughTransformer) Header(ctx *etl_core.Context) ([]byte, error)

func (*PassthroughTransformer) Transform

func (c *PassthroughTransformer) Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)

type Transformer

type Transformer interface {
	Transform(ctx *etl_core.Context, data map[string]interface{}) ([]byte, error)

	// Header returns any leading bytes (e.g., header row, opening bracket, etc).
	// Should return nil/empty if not needed.
	Header(ctx *etl_core.Context) ([]byte, error)

	// Footer returns any trailing bytes (e.g., closing bracket, sentinel value, etc).
	// Should return nil/empty if not needed.
	Footer(ctx *etl_core.Context) ([]byte, error)
}

func ForName

func ForName(name string) (Transformer, error)