avro

Documentation

Index

• func NewMessageWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type ByteWriter
• type Message
  • func DeserializeMessage(r io.Reader) (*Message, error)
  • func NewMessage() *Message
  • func NewMessageFromCommonMessage(channel string, m *common.Message) *Message
  • func (r *Message) Schema() string
  • func (r *Message) Serialize(w io.Writer) error
• type StringWriter

Functions

func NewMessageWriter

func NewMessageWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

Types

type ByteWriter

type ByteWriter interface {
	Grow(int)
	WriteByte(byte) error
}

type Message

type Message struct {
	Time    int64
	Channel string
	Nick    string
	Message string
}

func DeserializeMessage

func DeserializeMessage(r io.Reader) (*Message, error)

func NewMessage

func NewMessage() *Message

func NewMessageFromCommonMessage

func NewMessageFromCommonMessage(channel string, m *common.Message) *Message

NewMessageFromCommonMessage ...

func (*Message) Schema

func (r *Message) Schema() string

func (*Message) Serialize

func (r *Message) Serialize(w io.Writer) error

type StringWriter

type StringWriter interface {
	WriteString(string) (int, error)
}