cherryHandler

package
v1.1.29 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2022 License: MIT Imports: 19 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 {
	cfacade.Component
	// 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) GetHandler added in v1.1.17 

func (c *Component) GetHandler(route string) (*cherryMessage.Route, *HandlerGroup, cfacade.IHandler, bool)

func (*Component) Init 

func (c *Component) Init()

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 cfacade.IEvent)

PostEvent 发布事件

func (*Component) ProcessLocal added in v1.1.17 

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

func (*Component) ProcessRemote added in v1.1.17 

func (c *Component) ProcessRemote(route string, data []byte, natsMsg *nats.Msg) int32

func (*Component) Register 

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

func (*Component) Register2Group 

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

type ExecutorEvent added in v1.1.9 

type ExecutorEvent struct {
	Event      cfacade.IEvent
	EventSlice []cfacade.EventFunc
	// contains filtered or unexported fields
}

func (*ExecutorEvent) Index added in v1.1.29 

func (p *ExecutorEvent) Index() int

func (*ExecutorEvent) Invoke added in v1.1.9 

func (p *ExecutorEvent) Invoke()

func (*ExecutorEvent) SetIndex added in v1.1.29 

func (p *ExecutorEvent) SetIndex(index int)

func (*ExecutorEvent) String added in v1.1.9 

func (p *ExecutorEvent) String() string

type ExecutorLocal added in v1.1.9 

type ExecutorLocal struct {
	cfacade.IApplication
	// contains filtered or unexported fields
}

func (*ExecutorLocal) Index added in v1.1.29 

func (p *ExecutorLocal) Index() int

func (*ExecutorLocal) Invoke added in v1.1.9 

func (p *ExecutorLocal) Invoke()

func (*ExecutorLocal) SetIndex added in v1.1.29 

func (p *ExecutorLocal) SetIndex(index int)

func (*ExecutorLocal) String added in v1.1.9 

func (p *ExecutorLocal) String() string

type ExecutorRemote added in v1.1.9 

type ExecutorRemote struct {
	cfacade.IApplication
	// contains filtered or unexported fields
}

func NewExecutorRemote added in v1.1.29 

func NewExecutorRemote(route string, data []byte, natsMsg *nats.Msg) ExecutorRemote

func (*ExecutorRemote) Index added in v1.1.29 

func (p *ExecutorRemote) Index() int

func (*ExecutorRemote) Invoke added in v1.1.9 

func (p *ExecutorRemote) Invoke()

func (*ExecutorRemote) SetIndex added in v1.1.29 

func (p *ExecutorRemote) SetIndex(index int)

func (*ExecutorRemote) String added in v1.1.9 

func (p *ExecutorRemote) String() string

type FilterFn 

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

type Handler 

type Handler struct {
	cfacade.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 cfacade.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) ([]cfacade.EventFunc, bool)

func (*Handler) Events 

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

func (*Handler) LocalHandler 

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

func (*Handler) LocalHandlers 

func (h *Handler) LocalHandlers() map[string]*cfacade.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 cfacade.IEvent)

func (*Handler) RemoteHandler 

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

func (*Handler) RemoteHandlers 

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

func (*Handler) Response added in v1.1.16 

func (h *Handler) Response(ctx context.Context, session *csession.Session, data interface{})

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 ...cfacade.IHandler) *HandlerGroup

func (*HandlerGroup) AddHandlers 

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

func (*HandlerGroup) InQueue added in v1.1.29 

func (h *HandlerGroup) InQueue(executor IExecutor)

func (*HandlerGroup) SetQueueHash 

func (h *HandlerGroup) SetQueueHash(fn QueueHashFn)

type IExecutor added in v1.1.5 

type IExecutor interface {
	Index() int         // execute goroutine index
	SetIndex(index int) // set goroutine index
	Invoke()            // invoke method
	String() 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

type Queue 

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

type QueueHashFn added in v1.1.29 

type QueueHashFn func(executor IExecutor, queueNum int) int

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.