connectjson

Documentation

Overview

Package connectjson implements encoding of Zed values to the format produced by org.apache.kafka.connect.json.JsonConverter and decoding of Zed values from that format.

Index

• func Encode(val *zed.Value) ([]byte, error)
• func Walk(typ zed.Type, body zcode.Bytes, visit zed.Visitor) error
• type Decoder
  • func NewDecoder(zctx *zed.Context) *Decoder
  • func (c *Decoder) Decode(b []byte) (*zed.Value, error)

Functions

func Encode

func Encode(val *zed.Value) ([]byte, error)

func Walk

func Walk(typ zed.Type, body zcode.Bytes, visit zed.Visitor) error

Types

type Decoder

type Decoder struct {
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(zctx *zed.Context) *Decoder

func (*Decoder) Decode

func (c *Decoder) Decode(b []byte) (*zed.Value, error)