dlq

Documentation

Index

• type Decoder
  • func NewDecoder(r io.Reader) *Decoder
  • func (d *Decoder) Err() error
  • func (d *Decoder) Event() (*Event, error)
  • func (d *Decoder) Scan() bool
• type Event
  • func (e *Event) UnmarshalBinary(data []byte) error

Types

type Decoder

type Decoder struct {
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(r io.Reader) *Decoder

func (*Decoder) Err

func (d *Decoder) Err() error

func (*Decoder) Event

func (d *Decoder) Event() (*Event, error)

func (*Decoder) Scan

func (d *Decoder) Scan() bool

type Event

type Event struct {
	Timestamp  time.Time     `json:"timestamp"`
	Event      []interface{} `json:"event"`
	PluginType string        `json:"plugin_type"`
	PluginID   string        `json:"plugin_id"`
	Reason     string        `json:"reason"`
}

func (*Event) UnmarshalBinary

func (e *Event) UnmarshalBinary(data []byte) error