delimited

Documentation

Index

• func NewConverter(props map[string]any) (message.Converter, error)
• type Converter
  • func (c *Converter) Decode(ctx api.StreamContext, b []byte) (ma any, err error)
  • func (c *Converter) Encode(ctx api.StreamContext, d any) (b []byte, err error)
  • func (c *Converter) SetColumns(cols []string)

Functions

func NewConverter

func NewConverter(props map[string]any) (message.Converter, error)

Types

type Converter

type Converter struct {
	Delimiter string   `json:"delimiter"`
	Cols      []string `json:"fields"`
	HasHeader bool     `json:"hasHeader"`
}

func (*Converter) Decode

func (c *Converter) Decode(ctx api.StreamContext, b []byte) (ma any, err error)

Decode If the cols is not set, the default key name is col1, col2, col3... The return value is always a map

func (*Converter) Encode

func (c *Converter) Encode(ctx api.StreamContext, d any) (b []byte, err error)

Encode If no columns defined, the default order is sort by key

func (*Converter) SetColumns

func (c *Converter) SetColumns(cols []string)