json

Documentation

Index

• type FastJsonConverter
  • func NewFastJsonConverter(schema map[string]*ast.JsonStreamField) *FastJsonConverter
  • func (f *FastJsonConverter) Decode(ctx api.StreamContext, b []byte) (m any, err error)
  • func (f *FastJsonConverter) DecodeField(_ api.StreamContext, b []byte, field string) (any, error)
  • func (f *FastJsonConverter) Encode(ctx api.StreamContext, d any) (b []byte, err error)
  • func (f *FastJsonConverter) ResetSchema(schema map[string]*ast.JsonStreamField)

Types

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 (f *FastJsonConverter) Decode(ctx api.StreamContext, b []byte) (m any, err error)

func (*FastJsonConverter) DecodeField

func (f *FastJsonConverter) DecodeField(_ api.StreamContext, b []byte, field string) (any, error)

func (*FastJsonConverter) Encode

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

func (*FastJsonConverter) ResetSchema

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