json

Documentation

Index

• func GetConverter() (message.Converter, error)
• type Converter
  • func (c *Converter) Decode(ctx api.StreamContext, b []byte) (m any, err error)
  • func (c *Converter) Encode(ctx api.StreamContext, d any) (b []byte, err error)
• type FastJsonConverter
  • func NewFastJsonConverter(schema map[string]*ast.JsonStreamField) *FastJsonConverter
  • func (c *FastJsonConverter) Decode(ctx api.StreamContext, b []byte) (m any, err error)
  • func (c *FastJsonConverter) Encode(ctx api.StreamContext, d any) (b []byte, err error)
  • func (c *FastJsonConverter) ResetSchema(schema map[string]*ast.JsonStreamField)

Functions

func GetConverter

func GetConverter() (message.Converter, error)

Types

type Converter

type Converter struct{}

func (*Converter) Decode

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

func (*Converter) Encode

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

type FastJsonConverter

type FastJsonConverter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewFastJsonConverter

func NewFastJsonConverter(schema map[string]*ast.JsonStreamField) *FastJsonConverter

func (*FastJsonConverter) Decode

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

func (*FastJsonConverter) Encode

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

func (*FastJsonConverter) ResetSchema

func (c *FastJsonConverter) ResetSchema(schema map[string]*ast.JsonStreamField)