part

Documentation

Index

• type FuncMap
• type Msgq
  • func New(want_max_data_mun int) *Msgq
  • func (m *Msgq) Pull(old_sig uint64) (data interface{}, sig uint64)
  • func (m *Msgq) Pull_tag(func_map map[string]func(interface{}) bool)
  • func (m *Msgq) Push(msg interface{})
  • func (m *Msgq) Push_tag(Tag string, Data interface{})
  • func (m *Msgq) Sig() (sig uint64)
• type Msgq_item
• type Msgq_tag_data

Types

type FuncMap

type FuncMap map[string]func(interface{}) bool

type Msgq

type Msgq struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(want_max_data_mun int) *Msgq

func (*Msgq) Pull

func (m *Msgq) Pull(old_sig uint64) (data interface{}, sig uint64)

func (*Msgq) Pull_tag

func (m *Msgq) Pull_tag(func_map map[string]func(interface{}) bool)

func (*Msgq) Push

func (m *Msgq) Push(msg interface{})

func (*Msgq) Push_tag

func (m *Msgq) Push_tag(Tag string, Data interface{})

func (*Msgq) Sig

func (m *Msgq) Sig() (sig uint64)

type Msgq_item

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

type Msgq_tag_data

type Msgq_tag_data struct {
	Tag  string
	Data interface{}
}