Versions in this module Expand all Collapse all v0 v0.2.0 Jan 4, 2021 Changes in this version + func NewQueueDirReader(q *Queue, dir Dir) io.Reader + func NewTraceDirReader(r *Reader, dir Dir) io.Reader + func NewTracer(tw io.Writer, rw io.ReadWriter) io.ReadWriter + type Dir byte + const DirIn + const DirOut + func (d *Dir) UnmarshalText(text []byte) error + func (d Dir) MarshalText() ([]byte, error) + type Msg struct + Data []byte + Dir Dir + TS uint + func (m *Msg) UnmarshalText(text []byte) error + func (m Msg) MarshalText() ([]byte, error) + type Queue struct + func (q *Queue) Dequeue() *Msg + func (q *Queue) DequeueDir(dir Dir) *Msg + func (q *Queue) Enqueue(msg *Msg) + func (q *Queue) Head() *Msg + type Reader struct + func NewReader(r io.Reader) *Reader + func (r *Reader) ReadMsg(m *Msg) error + type Writer struct + func NewWriter(w io.Writer) *Writer + func (w *Writer) WriteMsg(m *Msg) error
Go to main page