decoding

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 8, 2020 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AvroMessageDecoder

type AvroMessageDecoder struct {
	SchemaSpec string
	Binary     bool
}

func (*AvroMessageDecoder) Decode

func (amd *AvroMessageDecoder) Decode(val []byte) (interface{}, error)

type JSONExtMessageDecoder

type JSONExtMessageDecoder struct{}

func (*JSONExtMessageDecoder) Decode

func (jmd *JSONExtMessageDecoder) Decode(val []byte) (interface{}, error)

type JSONMessageDecoder

type JSONMessageDecoder struct{}

func (*JSONMessageDecoder) Decode

func (jmd *JSONMessageDecoder) Decode(val []byte) (interface{}, error)

type MessageDecoder

type MessageDecoder interface {
	Decode([]byte) (interface{}, error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL