cherryHandler

package
v1.1.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 4, 2021 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultQueueHash 

func DefaultQueueHash(executor IExecutor, queueNum int) int

Types

type Component 

type Component struct {
	facade.Component

	RemoteHandler RemoteHandler
	// contains filtered or unexported fields
}

Component handler component

func NewComponent 

func NewComponent(opts ...Option) *Component

func (*Component) AddAfterFilter added in v1.1.1 

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

func (*Component) AddBeforeFilter added in v1.1.1 

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

func (*Component) DoMessage added in v1.1.9 

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

func (*Component) Init 

func (c *Component) Init()

func (*Component) LocalProcess added in v1.1.9 

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

func (*Component) Name 

func (c *Component) Name() string

func (*Component) OnAfterInit added in v1.1.6 

func (c *Component) OnAfterInit()

func (*Component) OnStop 

func (c *Component) OnStop()

func (*Component) PostEvent 

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

PostEvent 发布事件

func (*Component) Register 

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

func (*Component) Register2Group 

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

func (*Component) RemoteProcess added in v1.1.9 

func (c *Component) RemoteProcess(msg *cherryProto2.RemoteMessage)

type ExecutorEvent added in v1.1.9 

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

func (*ExecutorEvent) Invoke added in v1.1.9 

func (e *ExecutorEvent) Invoke()

func (*ExecutorEvent) String added in v1.1.9 

func (e *ExecutorEvent) String() string

type ExecutorLocal added in v1.1.9 

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

func (*ExecutorLocal) Invoke added in v1.1.9 

func (m *ExecutorLocal) Invoke()

func (*ExecutorLocal) String added in v1.1.9 

func (m *ExecutorLocal) String() string

type ExecutorRemote added in v1.1.9 

type ExecutorRemote struct {
	facade.IApplication
	HandlerFn *facade.HandlerFn
	Msg       *cherryProto2.RemoteMessage
}

func (*ExecutorRemote) Invoke added in v1.1.9 

func (r *ExecutorRemote) Invoke()

func (*ExecutorRemote) String added in v1.1.9 

func (r *ExecutorRemote) String() string

type FilterFn 

type FilterFn func(ctx context.Context, 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 added in v1.1.5 

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

type Option added in v1.1.1 

type Option func(options *options)

func WithAfterFilter added in v1.1.1 

func WithAfterFilter(afterFilters ...FilterFn) Option

func WithBeforeFilter added in v1.1.1 

func WithBeforeFilter(beforeFilters ...FilterFn) Option

func WithNameFunc added in v1.1.1 

func WithNameFunc(fn func(string) string) Option

func WithPrintRouteLog added in v1.1.1 

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 RemoteHandler added in v1.1.9 

type RemoteHandler func(session *cherrySession.Session, msg *cherryMessage.Message)

type ServiceBackend added in v1.1.9 

type ServiceBackend struct {
	cherryFacade.IApplication
	ClusterComponent *cherryCluster.Component
	HandlerComponent *Component
}

ServiceBackend 后端

func (*ServiceBackend) CloseSession added in v1.1.9 

func (c *ServiceBackend) CloseSession(_ context.Context, sessionId *cherryProto2.Session) (*cherryProto2.Response, error)

func (*ServiceBackend) KickUser added in v1.1.9 

func (c *ServiceBackend) KickUser(_ context.Context, msg *cherryProto2.KickMessage) (*cherryProto2.Response, error)

func (*ServiceBackend) LocalHandle added in v1.1.9 

func (c *ServiceBackend) LocalHandle(_ context.Context, msg *cherryProto2.LocalMessage) (*cherryProto2.Response, error)

func (*ServiceBackend) PushToUser added in v1.1.9 

func (c *ServiceBackend) PushToUser(_ context.Context, msg *cherryProto2.PushMessage) (*cherryProto2.Response, error)

func (*ServiceBackend) RemoteHandle added in v1.1.9 

func (c *ServiceBackend) RemoteHandle(_ context.Context, msg *cherryProto2.RemoteMessage) (*cherryProto2.Response, error)

RemoteHandle 收到后端节点的remote消息

type ServiceFrontend added in v1.1.9 

type ServiceFrontend struct {
	HandlerComponent *Component
}

func (*ServiceFrontend) CloseSession added in v1.1.9 

func (c *ServiceFrontend) CloseSession(_ context.Context, sessionId *cherryProto2.Session) (*cherryProto2.Response, error)

func (*ServiceFrontend) KickUser added in v1.1.9 

func (c *ServiceFrontend) KickUser(_ context.Context, msg *cherryProto2.KickMessage) (*cherryProto2.Response, error)

func (*ServiceFrontend) LocalHandle added in v1.1.9 

func (c *ServiceFrontend) LocalHandle(_ context.Context, msg *cherryProto2.LocalMessage) (*cherryProto2.Response, error)

LocalHandle 收到后端节点的request类型消息转发给客户端

func (*ServiceFrontend) PushToUser added in v1.1.9 

func (c *ServiceFrontend) PushToUser(_ context.Context, msg *cherryProto2.PushMessage) (*cherryProto2.Response, error)

func (*ServiceFrontend) RemoteHandle added in v1.1.9 

func (c *ServiceFrontend) RemoteHandle(_ context.Context, msg *cherryProto2.RemoteMessage) (*cherryProto2.Response, error)

RemoteHandle 收到后端节点的remote消息

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.