zavro

package

v0.9.1 Latest Latest Go to latest Published: Feb 15, 2024 License: BSD-3-Clause Imports: 11 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ErrBadValue = errors.New("bad zng value in kavro translator")

These errors shouldn't happen because the input should be type checked.

func Decode(b *zcode.Builder, in []byte, schema avro.Schema) error

func DecodeSchema(zctx *zed.Context, schema avro.Schema) (zed.Type, error)

func Encode(dst []byte, id uint32, zv zed.Value) ([]byte, error)

func EncodeSchema(typ zed.Type, namespace string) (avro.Schema, error)

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

func NewDecoder(registry *srclient.SchemaRegistryClient, zctx *zed.Context) *Decoder

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

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

func NewEncoder(namespace string, registry *srclient.SchemaRegistryClient) *Encoder

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

type MicroTimeSchema struct{}

MicroTimeSchema implements avro.Schema and represents Avro long type.

func (*MicroTimeSchema) GetName() string

GetName returns a type name for this MicroTimeSchema.

func (*MicroTimeSchema) MarshalJSON() ([]byte, error)

MarshalJSON serializes the given schema as JSON. Never returns an error.

func (*MicroTimeSchema) Prop(key string) (interface{}, bool)

Prop doesn't return anything valuable for LongSchema.

func (*MicroTimeSchema) String() string

Returns a JSON representation of LongSchema.

func (*MicroTimeSchema) Type() int

Type returns a type constant for this MicroTimeSchema.

func (*MicroTimeSchema) Validate(v reflect.Value) bool

Validate checks whether the given value is writeable to this schema.