decoders

Documentation

Index

• Constants
• func VarZigZag(d *decode.D) int64
• type BytesCodec
• type DateMapper
  • func (d DateMapper) MapScalar(s scalar.S) (scalar.S, error)
• type DecodeFn
  • func DecodeFnForSchema(s schema.SimplifiedSchema) (DecodeFn, error)
• type EnumMapper
  • func (e EnumMapper) MapScalar(s scalar.S) (scalar.S, error)
• type Precision
• type TimeMapper
  • func (t TimeMapper) MapScalar(s scalar.S) (scalar.S, error)
• type TimestampMapper
  • func (t TimestampMapper) MapScalar(s scalar.S) (scalar.S, error)

Constants

const (
	SECOND = iota
	MILLISECOND
	MICROSECOND
	NANOSECOND
)

Functions

func VarZigZag

func VarZigZag(d *decode.D) int64

VarZigZag reads a variable length zigzag long from the current position in decoder

Types

type BytesCodec

type BytesCodec struct{}

type DateMapper

type DateMapper struct {
}

func (DateMapper) MapScalar

func (d DateMapper) MapScalar(s scalar.S) (scalar.S, error)

type DecodeFn

type DecodeFn func(string, *decode.D) any

func DecodeFnForSchema

func DecodeFnForSchema(s schema.SimplifiedSchema) (DecodeFn, error)

type EnumMapper

type EnumMapper struct {
	Symbols []string
}

func (EnumMapper) MapScalar

func (e EnumMapper) MapScalar(s scalar.S) (scalar.S, error)

type Precision

type Precision int

type TimeMapper

type TimeMapper struct {
	Precision Precision
}

func (TimeMapper) MapScalar

func (t TimeMapper) MapScalar(s scalar.S) (scalar.S, error)

type TimestampMapper

type TimestampMapper struct {
	Precision Precision
}

func (TimestampMapper) MapScalar

func (t TimestampMapper) MapScalar(s scalar.S) (scalar.S, error)