time

Documentation

Overview

Package time contains avro decoders for time.Time.

Index

• func RegisterCodecs()
• type LongCodec
  • func (c LongCodec) New(r *avro.Buffer) unsafe.Pointer
  • func (c LongCodec) Read(r *avro.Buffer, p unsafe.Pointer) error
• type StringCodec
  • func (c StringCodec) New(r *avro.Buffer) unsafe.Pointer
  • func (c StringCodec) Read(r *avro.Buffer, p unsafe.Pointer) error

Functions

func RegisterCodecs

func RegisterCodecs()

RegisterCodecs makes the codecs in this package available to avro

Types

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.Buffer) unsafe.Pointer

New create a pointer to a new time.Time

func (LongCodec) Read

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

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.Buffer) unsafe.Pointer

New create a pointer to a new time.Time

func (StringCodec) Read

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