time

Documentation

Overview

Package time contains avro decoders for time.Time.

Index

• func RegisterCodecs()
• type DateCodec
  • func (c DateCodec) New(r *avro.ReadBuf) unsafe.Pointer
  • func (c DateCodec) Omit(p unsafe.Pointer) bool
  • func (c DateCodec) Read(r *avro.ReadBuf, p unsafe.Pointer) error
  • func (c DateCodec) Write(w *avro.WriteBuf, p unsafe.Pointer)
• type LongCodec
  • func (c LongCodec) New(r *avro.ReadBuf) unsafe.Pointer
  • func (c LongCodec) Omit(p unsafe.Pointer) bool
  • func (c LongCodec) Read(r *avro.ReadBuf, p unsafe.Pointer) error
  • func (c LongCodec) Write(w *avro.WriteBuf, p unsafe.Pointer)
• type StringCodec
  • func (c StringCodec) New(r *avro.ReadBuf) unsafe.Pointer
  • func (c StringCodec) Omit(p unsafe.Pointer) bool
  • func (c StringCodec) Read(r *avro.ReadBuf, p unsafe.Pointer) error
  • func (c StringCodec) Write(w *avro.WriteBuf, p unsafe.Pointer)

Functions

func RegisterCodecs

func RegisterCodecs()

RegisterCodecs makes the codecs in this package available to avro

Types

type DateCodec

type DateCodec struct{ avro.Int32Codec }

DateCodec is a decoder from an AVRO date logical type, which is a number of days since 1 Jan 1970

func (DateCodec) New

func (c DateCodec) New(r *avro.ReadBuf) unsafe.Pointer

New create a pointer to a new time.Time

func (DateCodec) Omit

func (c DateCodec) Omit(p unsafe.Pointer) bool

func (DateCodec) Read

func (c DateCodec) Read(r *avro.ReadBuf, p unsafe.Pointer) error

func (DateCodec) Write

func (c DateCodec) Write(w *avro.WriteBuf, p unsafe.Pointer)

type LongCodec

type LongCodec struct {
	avro.Int64Codec
	// contains filtered or unexported fields
}

LongCodec is a decoder from an AVRO long where the time is encoded as nanoseconds since the UNIX epoch

func (LongCodec) New

func (c LongCodec) New(r *avro.ReadBuf) unsafe.Pointer

New create a pointer to a new time.Time

func (LongCodec) Omit

func (c LongCodec) Omit(p unsafe.Pointer) bool

func (LongCodec) Read

func (c LongCodec) Read(r *avro.ReadBuf, p unsafe.Pointer) error

func (LongCodec) Write

func (c LongCodec) Write(w *avro.WriteBuf, p unsafe.Pointer)

type StringCodec

type StringCodec struct{ avro.StringCodec }

StringCodec is a decoder from an AVRO string with RFC3339 encoding to a time.Time

func (StringCodec) New

func (c StringCodec) New(r *avro.ReadBuf) unsafe.Pointer

New create a pointer to a new time.Time

func (StringCodec) Omit

func (c StringCodec) Omit(p unsafe.Pointer) bool

func (StringCodec) Read

func (c StringCodec) Read(r *avro.ReadBuf, p unsafe.Pointer) error

func (StringCodec) Write

func (c StringCodec) Write(w *avro.WriteBuf, p unsafe.Pointer)