cherryHandler

Documentation

Index

• func DefaultQueueHash(executor IExecutor, queueNum int) int
• type Component
  • func NewComponent(opts ...Option) *Component
  • func (c *Component) AddAfterFilter(afterFilters ...FilterFn)
  • func (c *Component) AddBeforeFilter(beforeFilters ...FilterFn)
  • func (c *Component) Init()
  • func (c *Component) Name() string
  • func (c *Component) OnAfterInit()
  • func (c *Component) OnStop()
  • func (c *Component) PostEvent(event facade.IEvent)
  • func (c *Component) PostMessage(session *cherrySession.Session, msg *cherryMessage.Message)
  • func (c *Component) Register(handlerGroup *HandlerGroup)
  • func (c *Component) Register2Group(handler ...facade.IHandler)
• type EventExecutor
  • func (e *EventExecutor) Invoke()
  • func (e *EventExecutor) String() string
• type FilterFn
• type Handler
  • func (h *Handler) AddAfterFilter(afterFilters ...FilterFn)
  • func (h *Handler) AddBeforeFilter(beforeFilters ...FilterFn)
  • func (h *Handler) AddEvent(eventName string, fn facade.EventFunc)
  • func (h *Handler) AddLocal(name string, fn interface{})
  • func (h *Handler) AddLocals(localFns ...interface{})
  • func (h *Handler) AddRemote(name string, fn interface{})
  • func (h *Handler) AddRemotes(remoteFns ...interface{})
  • func (h *Handler) Component() *Component
  • func (h *Handler) Event(name string) ([]facade.EventFunc, bool)
  • func (h *Handler) Events() map[string][]facade.EventFunc
  • func (h *Handler) LocalHandler(funcName string) (*facade.HandlerFn, bool)
  • func (h *Handler) LocalHandlers() map[string]*facade.HandlerFn
  • func (h *Handler) Name() string
  • func (h *Handler) OnAfterInit()
  • func (h *Handler) OnInit()
  • func (h *Handler) OnPreInit()
  • func (h *Handler) OnStop()
  • func (h *Handler) PostEvent(e facade.IEvent)
  • func (h *Handler) RemoteHandler(funcName string) (*facade.HandlerFn, bool)
  • func (h *Handler) RemoteHandlers() map[string]*facade.HandlerFn
  • func (h *Handler) SetName(name string)
• type HandlerGroup
  • func NewGroup(queueNum, queueCap int) *HandlerGroup
  • func NewGroupWithHandler(handlers ...facade.IHandler) *HandlerGroup
  • func (h *HandlerGroup) AddHandlers(handlers ...facade.IHandler)
  • func (h *HandlerGroup) SetQueueHash(fn QueueHash)
• type IExecutor
• type MessageExecutor
  • func (m *MessageExecutor) Invoke()
  • func (m *MessageExecutor) String() string
• type Option
  • func WithAfterFilter(afterFilters ...FilterFn) Option
  • func WithBeforeFilter(beforeFilters ...FilterFn) Option
  • func WithNameFunc(fn func(string) string) Option
  • func WithPrintRouteLog(enable bool) Option
• type Queue
• type QueueHash
• type SysRPCExecutor
  • func (s *SysRPCExecutor) Invoke()
  • func (s *SysRPCExecutor) String() string
• type UserRPCExecutor
  • func (u *UserRPCExecutor) Invoke()
  • func (u *UserRPCExecutor) String() string

Functions

func DefaultQueueHash

func DefaultQueueHash(executor IExecutor, queueNum int) int

Types

type Component

type Component struct {
	facade.Component

	RemoteHandler cherryAgent.RPCHandler
	// contains filtered or unexported fields
}

Component handler component

func NewComponent

func NewComponent(opts ...Option) *Component

func (*Component) AddAfterFilter

func (c *Component) AddAfterFilter(afterFilters ...FilterFn)

func (*Component) AddBeforeFilter

func (c *Component) AddBeforeFilter(beforeFilters ...FilterFn)

func (*Component) Init

func (c *Component) Init()

func (*Component) Name

func (c *Component) Name() string

func (*Component) OnAfterInit

func (c *Component) OnAfterInit()

func (*Component) OnStop

func (c *Component) OnStop()

func (*Component) PostEvent

func (c *Component) PostEvent(event facade.IEvent)

PostEvent 发布事件

func (*Component) PostMessage

func (c *Component) PostMessage(session *cherrySession.Session, msg *cherryMessage.Message)

func (*Component) Register

func (c *Component) Register(handlerGroup *HandlerGroup)

func (*Component) Register2Group

func (c *Component) Register2Group(handler ...facade.IHandler)

type EventExecutor

type EventExecutor struct {
	Event      facade.IEvent
	EventSlice []facade.EventFunc
}

func (*EventExecutor) Invoke

func (e *EventExecutor) Invoke()

func (*EventExecutor) String

func (e *EventExecutor) String() string

type FilterFn

type FilterFn func(session *cherrySession.Session, message *cherryMessage.Message) bool

type Handler

type Handler struct {
	facade.AppContext
	// contains filtered or unexported fields
}

func (*Handler) AddAfterFilter

func (h *Handler) AddAfterFilter(afterFilters ...FilterFn)

func (*Handler) AddBeforeFilter

func (h *Handler) AddBeforeFilter(beforeFilters ...FilterFn)

func (*Handler) AddEvent

func (h *Handler) AddEvent(eventName string, fn facade.EventFunc)

func (*Handler) AddLocal

func (h *Handler) AddLocal(name string, fn interface{})

func (*Handler) AddLocals

func (h *Handler) AddLocals(localFns ...interface{})

func (*Handler) AddRemote

func (h *Handler) AddRemote(name string, fn interface{})

func (*Handler) AddRemotes

func (h *Handler) AddRemotes(remoteFns ...interface{})

func (*Handler) Component

func (h *Handler) Component() *Component

func (*Handler) Event

func (h *Handler) Event(name string) ([]facade.EventFunc, bool)

func (*Handler) Events

func (h *Handler) Events() map[string][]facade.EventFunc

func (*Handler) LocalHandler

func (h *Handler) LocalHandler(funcName string) (*facade.HandlerFn, bool)

func (*Handler) LocalHandlers

func (h *Handler) LocalHandlers() map[string]*facade.HandlerFn

func (*Handler) Name

func (h *Handler) Name() string

func (*Handler) OnAfterInit

func (h *Handler) OnAfterInit()

func (*Handler) OnInit

func (h *Handler) OnInit()

func (*Handler) OnPreInit

func (h *Handler) OnPreInit()

func (*Handler) OnStop

func (h *Handler) OnStop()

func (*Handler) PostEvent

func (h *Handler) PostEvent(e facade.IEvent)

func (*Handler) RemoteHandler

func (h *Handler) RemoteHandler(funcName string) (*facade.HandlerFn, bool)

func (*Handler) RemoteHandlers

func (h *Handler) RemoteHandlers() map[string]*facade.HandlerFn

func (*Handler) SetName

func (h *Handler) SetName(name string)

type HandlerGroup

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

func NewGroup

func NewGroup(queueNum, queueCap int) *HandlerGroup

func NewGroupWithHandler

func NewGroupWithHandler(handlers ...facade.IHandler) *HandlerGroup

func (*HandlerGroup) AddHandlers

func (h *HandlerGroup) AddHandlers(handlers ...facade.IHandler)

func (*HandlerGroup) SetQueueHash

func (h *HandlerGroup) SetQueueHash(fn QueueHash)

type IExecutor

type IExecutor interface {
	Invoke()
	String() string
}

type MessageExecutor

type MessageExecutor struct {
	App           facade.IApplication
	Session       *cherrySession.Session
	Msg           *cherryMessage.Message
	HandlerFn     *facade.HandlerFn
	BeforeFilters []FilterFn
	AfterFilters  []FilterFn
}

func (*MessageExecutor) Invoke

func (m *MessageExecutor) Invoke()

func (*MessageExecutor) String

func (m *MessageExecutor) String() string

type Option

type Option func(options *options)

func WithAfterFilter

func WithAfterFilter(afterFilters ...FilterFn) Option

func WithBeforeFilter

func WithBeforeFilter(beforeFilters ...FilterFn) Option

func WithNameFunc

func WithNameFunc(fn func(string) string) Option

func WithPrintRouteLog

func WithPrintRouteLog(enable bool) Option

type Queue

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

type QueueHash

type QueueHash func(executor IExecutor, queueNum int) int

type SysRPCExecutor

type SysRPCExecutor struct {
	HandlerFn *facade.HandlerFn
}

func (*SysRPCExecutor) Invoke

func (s *SysRPCExecutor) Invoke()

func (*SysRPCExecutor) String

func (s *SysRPCExecutor) String() string

type UserRPCExecutor

type UserRPCExecutor struct {
	HandlerFn *facade.HandlerFn
}

func (*UserRPCExecutor) Invoke

func (u *UserRPCExecutor) Invoke()

func (*UserRPCExecutor) String

func (u *UserRPCExecutor) String() string