json

Documentation

Index

• func GetConverter() (message.Converter, error)
• type Converter
  • func (c *Converter) Decode(b []byte) (m interface{}, err error)
  • func (c *Converter) Encode(d interface{}) (b []byte, err error)
• type FastJsonConverter
  • func NewFastJsonConverter(ruleID, streamName string, schema map[string]*ast.JsonStreamField, ...) *FastJsonConverter
  • func (c *FastJsonConverter) Decode(b []byte) (m interface{}, err error)
  • func (c *FastJsonConverter) DetachSchema(ruleID string) error
  • func (c *FastJsonConverter) Encode(d interface{}) (b []byte, err error)
  • func (c *FastJsonConverter) MergeSchema(ruleID, dataSource string, newSchema map[string]*ast.JsonStreamField, ...) error

Functions

func GetConverter

func GetConverter() (message.Converter, error)

Types

type Converter

type Converter struct{}

func (*Converter) Decode

func (c *Converter) Decode(b []byte) (m interface{}, err error)

func (*Converter) Encode

func (c *Converter) Encode(d interface{}) (b []byte, err error)

type FastJsonConverter

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

func NewFastJsonConverter

func NewFastJsonConverter(ruleID, streamName string, schema map[string]*ast.JsonStreamField, isWildcard, isSchemaLess bool) *FastJsonConverter

func (*FastJsonConverter) Decode

func (c *FastJsonConverter) Decode(b []byte) (m interface{}, err error)

func (*FastJsonConverter) DetachSchema

func (c *FastJsonConverter) DetachSchema(ruleID string) error

func (*FastJsonConverter) Encode

func (c *FastJsonConverter) Encode(d interface{}) (b []byte, err error)

func (*FastJsonConverter) MergeSchema

func (c *FastJsonConverter) MergeSchema(ruleID, dataSource string, newSchema map[string]*ast.JsonStreamField, isWildcard bool) error