msg

Documentation

Index

• type Filter
  • func NewFilter() *Filter
  • func (f *Filter) GetIn() []int
  • func (f *Filter) GetOut() []int
  • func (f *Filter) In(id int)
  • func (f *Filter) Out(id int)
  • func (f *Filter) String() string
• type Format
• type Message
  • func Cast(i interface{}) Message
  • func Msg(senderID int, data []byte) Message
  • func Parse(msg []byte) (Message, error)
  • func (m *Message) Allowed(f *Filter) bool
  • func (m Message) Data() []byte
  • func (m Message) Format(f Format) string
  • func (m Message) String() string
  • func (m Message) WriteFormat(w io.Writer, f Format) (int, error)

Types

type Filter

type Filter struct {
	Included []int
	Excluded []int
}

func NewFilter

func NewFilter() *Filter

func (*Filter) GetIn

func (f *Filter) GetIn() []int

func (*Filter) GetOut

func (f *Filter) GetOut() []int

func (*Filter) In

func (f *Filter) In(id int)

func (*Filter) Out

func (f *Filter) Out(id int)

func (*Filter) String

func (f *Filter) String() string

type Format

type Format int

const (
	FORMAT_NULL Format = 1 << iota
	FORMAT_ID
	FORMAT_TIMESTAMP
	FORMAT_DATA
	FORMAT_NEWLINE
	FORMAT_META = FORMAT_ID | FORMAT_TIMESTAMP | FORMAT_DATA
)

type Message

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

func Cast

func Cast(i interface{}) Message

func Msg

func Msg(senderID int, data []byte) Message

func Parse

func Parse(msg []byte) (Message, error)

func (*Message) Allowed

func (m *Message) Allowed(f *Filter) bool

func (Message) Data

func (m Message) Data() []byte

func (Message) Format

func (m Message) Format(f Format) string

func (Message) String

func (m Message) String() string

func (Message) WriteFormat

func (m Message) WriteFormat(w io.Writer, f Format) (int, error)

XXX: We implement only the combinations we actually use.