router

Documentation

Index

• type Router
• type SimpleRouter
  • func NewSimpleRouter(topicMgr comet.TopicProvidor, sessMgr comet.SessionProvidor, ...) *SimpleRouter
  • func (r *SimpleRouter) Publish(msg comet.Message) error
  • func (r *SimpleRouter) RouteGroupMsg(topic string, byteMsg []byte) error
  • func (r *SimpleRouter) RouteSingleMsg(topic string, byteMsg []byte) error
  • func (r *SimpleRouter) Send(topic string, msg []byte) error

Types

type Router

type Router interface {
	Send(topic string, msg []byte) error
}

type SimpleRouter

type SimpleRouter struct {
	TopicManager comet.TopicProvidor   `inject`
	SessManager  comet.SessionProvidor `inject`

	NsqCli *gonsq.Producer `inject`
}

func NewSimpleRouter

func NewSimpleRouter(topicMgr comet.TopicProvidor, sessMgr comet.SessionProvidor, nsqCli *gonsq.Producer) *SimpleRouter

func (*SimpleRouter) Publish

func (r *SimpleRouter) Publish(msg comet.Message) error

func (*SimpleRouter) RouteGroupMsg

func (r *SimpleRouter) RouteGroupMsg(topic string, byteMsg []byte) error

func (*SimpleRouter) RouteSingleMsg

func (r *SimpleRouter) RouteSingleMsg(topic string, byteMsg []byte) error

func (*SimpleRouter) Send

func (r *SimpleRouter) Send(topic string, msg []byte) error