router

Documentation

Index

• func DestroyItem(item *Item)
• func DestroyRouter(router *Router)
• type Handler
• type Item
  • func NewItem(topic string, handlers []Handler) (*Item, error)
  • func (item *Item) CallHandlers(data []byte)
  • func (item *Item) DoIfUnSubscribe(doFunc func() error) error
  • func (item *Item) GetData() []byte
  • func (item *Item) Next()
  • func (item *Item) SetUnSubscribe()
• type OnAddItemFunc
• type Router
  • func NewRouter(group string, handlers []Handler, onAddItemFunc OnAddItemFunc) *Router
  • func (router *Router) AddItem(item *Item) error
  • func (router *Router) AddTopic(topic string, handlers ...Handler) error
  • func (router *Router) RangeItem(rangeFunc func(item *Item) error) error

Functions

func DestroyItem

func DestroyItem(item *Item)

func DestroyRouter

func DestroyRouter(router *Router)

Types

type Handler

type Handler func(item *Item, data []byte)

type Item

type Item struct {
	Topic string
	// contains filtered or unexported fields
}

func NewItem

func NewItem(topic string, handlers []Handler) (*Item, error)

func (*Item) CallHandlers

func (item *Item) CallHandlers(data []byte)

func (*Item) DoIfUnSubscribe

func (item *Item) DoIfUnSubscribe(doFunc func() error) error

func (*Item) GetData

func (item *Item) GetData() []byte

func (*Item) Next

func (item *Item) Next()

func (*Item) SetUnSubscribe

func (item *Item) SetUnSubscribe()

type OnAddItemFunc

type OnAddItemFunc func(item *Item) error

type Router

type Router struct {
	Group string
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(group string, handlers []Handler, onAddItemFunc OnAddItemFunc) *Router

func (*Router) AddItem

func (router *Router) AddItem(item *Item) error

func (*Router) AddTopic

func (router *Router) AddTopic(topic string, handlers ...Handler) error

func (*Router) RangeItem

func (router *Router) RangeItem(rangeFunc func(item *Item) error) error