json

Documentation

Index

• type FastJsonConverter
  • func NewFastJsonConverter(schema map[string]*ast.JsonStreamField, props map[string]any) *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)
• type FastJsonConverterConf

Types

type FastJsonConverter

type FastJsonConverter struct {
	sync.RWMutex

	FastJsonConverterConf
	// contains filtered or unexported fields
}

func NewFastJsonConverter

func NewFastJsonConverter(schema map[string]*ast.JsonStreamField, props map[string]any) *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)

type FastJsonConverterConf

type FastJsonConverterConf struct {
	UseInt64        bool              `json:"useInt64ForWholeNumber"`
	ColAliasMapping map[string]string `json:"colAliasMapping"`
}