message_queue

Documentation

Index

• func EmptyQueue()
• func FrontQueue()
• func Run()
• type Body
• type Msg
• type Queue
  • func InitQueue() *Queue
  • func (q *Queue) InQueue(body *Body)
  • func (q *Queue) OutQueue() *Body
• type Ring
  • func NewMessage() *Ring
  • func (r *Ring) Pull(msg *Msg, res *string) error
  • func (r *Ring) Push(msg *Msg, res *string) error

Functions

func EmptyQueue

func EmptyQueue()

func FrontQueue

func FrontQueue()

func Run

func Run()

Types

type Body

type Body struct {
	Next    *Body
	Key     []byte
	Value   interface{}
	Check   bool
	Operate func() error
}

type Msg

type Msg struct {
	From    string
	To      string
	Time    int64
	Content string
	Repeat  int
	Loop    int
	Next    *Msg
}

type Queue

type Queue struct {
	Body   *Body
	Length int
}

func InitQueue

func InitQueue() *Queue

func (*Queue) InQueue

func (q *Queue) InQueue(body *Body)

func (*Queue) OutQueue

func (q *Queue) OutQueue() *Body

type Ring

type Ring struct {
	Now  *Msg
	Dead []*Msg `用来存放没有成功推送出去的消息,消息都会立即推送出去，没推出去下方在Dead`
	All  int    `当前所有的消息数`
	// contains filtered or unexported fields
}

var RING *Ring

func NewMessage

func NewMessage() *Ring

TODO Message 要 new 出一个环形的msg

func (*Ring) Pull

func (r *Ring) Pull(msg *Msg, res *string) error

func (*Ring) Push

func (r *Ring) Push(msg *Msg, res *string) error