queen

Documentation

Index

• Constants
• func GetI32(b []byte, pos int) int32
• func InitConnect(queen *Queen)
• func MqttRun(topic string, mqttClient mqtt.Client, queen *Queen)
• type CContext
• type CHandler
• type Center
  • func NewCenter() *Center
  • func (self *Center) All(fn func(CContext)) (id int32)
  • func (self *Center) Get(key string) (nson.Value, bool)
  • func (self *Center) InitCenter()
  • func (self *Center) Insert(key string, value nson.Value) (nson.Value, bool)
  • func (self *Center) InsertSkipAll(key string, value nson.Value) (nson.Value, bool)
  • func (self *Center) Off(id int32) (ok bool)
  • func (self *Center) On(key string, fn func(CContext)) (id int32)
  • func (self *Center) Remove(key string) (nson.Value, bool)
  • func (self *Center) Run(queen *Queen, event string)
  • func (self *Center) Set(key string, value nson.Value) (nson.Value, bool)
• type Context
• type Handler
• type Queen
  • func NewQueen() *Queen
  • func (self *Queen) Emit(event string, message nson.Message)
  • func (self *Queen) InitQueen()
  • func (self *Queen) Off(id int32) (ok bool)
  • func (self *Queen) On(event string, fn func(Context)) (id int32)
  • func (self *Queen) Push(event string, message nson.Message)
• type Task
• type Tasks
  • func (h Tasks) Len() int
  • func (h Tasks) Less(i, j int) bool
  • func (h *Tasks) Pop() interface{}
  • func (h *Tasks) Push(x interface{})
  • func (h Tasks) Swap(i, j int)
• type Timer
  • func NewTimer() *Timer
  • func (t *Timer) Pop() interface{}
  • func (t *Timer) Push(task Task)
  • func (t *Timer) Run(queen *Queen)

Constants

const (
	LINK   = "sys:link"
	UNLINK = "sys:unlink"
	REMOVE = "sys:remove"
	HAND   = "sys:hand"
	HANDED = "sys:handed"
	ATTACH = "sys:attach"
	DETACH = "sys:detach"
	SEND   = "sys:send"
	RECV   = "sys:recv"
)

Functions

func GetI32

func GetI32(b []byte, pos int) int32

func InitConnect

func InitConnect(queen *Queen)

func MqttRun

func MqttRun(topic string, mqttClient mqtt.Client, queen *Queen)

Types

type CContext

type CContext struct {
	Center   *Center
	Id       int32
	Key      string
	OldValue nson.Value
	Value    nson.Value
}

type CHandler

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

type Center

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

func NewCenter

func NewCenter() *Center

func (*Center) All

func (self *Center) All(fn func(CContext)) (id int32)

func (*Center) Get

func (self *Center) Get(key string) (nson.Value, bool)

func (*Center) InitCenter

func (self *Center) InitCenter()

func (*Center) Insert

func (self *Center) Insert(key string, value nson.Value) (nson.Value, bool)

func (*Center) InsertSkipAll

func (self *Center) InsertSkipAll(key string, value nson.Value) (nson.Value, bool)

func (*Center) Off

func (self *Center) Off(id int32) (ok bool)

func (*Center) On

func (self *Center) On(key string, fn func(CContext)) (id int32)

func (*Center) Remove

func (self *Center) Remove(key string) (nson.Value, bool)

func (*Center) Run

func (self *Center) Run(queen *Queen, event string)

func (*Center) Set

func (self *Center) Set(key string, value nson.Value) (nson.Value, bool)

type Context

type Context struct {
	Queen   *Queen
	Id      int32
	Event   string
	Message nson.Message
}

type Handler

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

type Queen

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

func NewQueen

func NewQueen() *Queen

func (*Queen) Emit

func (self *Queen) Emit(event string, message nson.Message)

func (*Queen) InitQueen

func (self *Queen) InitQueen()

func (*Queen) Off

func (self *Queen) Off(id int32) (ok bool)

func (*Queen) On

func (self *Queen) On(event string, fn func(Context)) (id int32)

func (*Queen) Push

func (self *Queen) Push(event string, message nson.Message)

type Task

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

type Tasks

type Tasks []Task

func (Tasks) Len

func (h Tasks) Len() int

func (Tasks) Less

func (h Tasks) Less(i, j int) bool

func (*Tasks) Pop

func (h *Tasks) Pop() interface{}

func (*Tasks) Push

func (h *Tasks) Push(x interface{})

func (Tasks) Swap

func (h Tasks) Swap(i, j int)

type Timer

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

func NewTimer

func NewTimer() *Timer

func (*Timer) Pop

func (t *Timer) Pop() interface{}

func (*Timer) Push

func (t *Timer) Push(task Task)

func (*Timer) Run

func (t *Timer) Run(queen *Queen)