cherryHandler

package
v1.2.10 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2022 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Name = "handler_component"
)

Variables

This section is empty.

Functions

func RandomQueueHash added in v1.2.6 

func RandomQueueHash(_ cfacade.IExecutor, queueNum int) int

RandomQueueHash 随机handler queue

func RoundQueueHash added in v1.2.6 

func RoundQueueHash(_ cfacade.IExecutor, queueNum int) int

RoundQueueHash 轮询handler queue

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(handlerName string) (*HandlerGroup, cfacade.IHandler, bool)

func (*Component) Init 

func (c *Component) Init()

func (*Component) Name 

func (*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(ctx context.Context, session *csession.Session, msg *cmsg.Message)

func (*Component) ProcessRemote added in v1.1.17 

func (c *Component) ProcessRemote(ctx context.Context, 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 Executor added in v1.1.30 

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

func (*Executor) Index added in v1.1.30 

func (p *Executor) Index() int

func (*Executor) SetIndex added in v1.1.30 

func (p *Executor) SetIndex(index int)

type ExecutorEvent added in v1.1.9 

type ExecutorEvent struct {
	Executor
	// contains filtered or unexported fields
}

func (*ExecutorEvent) EventData added in v1.2.10 

func (p *ExecutorEvent) EventData() cfacade.IEvent

func (*ExecutorEvent) Invoke added in v1.1.9 

func (p *ExecutorEvent) Invoke()

func (*ExecutorEvent) QueueHash added in v1.1.30 

func (p *ExecutorEvent) QueueHash(queueNum int) int

type ExecutorLocal added in v1.1.9 

type ExecutorLocal struct {
	Executor
	// contains filtered or unexported fields
}

func (*ExecutorLocal) Context added in v1.1.30 

func (p *ExecutorLocal) Context() context.Context

func (*ExecutorLocal) Invoke added in v1.1.9 

func (p *ExecutorLocal) Invoke()

func (*ExecutorLocal) Message added in v1.1.30 

func (p *ExecutorLocal) Message() *cmsg.Message

func (*ExecutorLocal) QueueHash added in v1.1.30 

func (p *ExecutorLocal) QueueHash(queueNum int) int

func (*ExecutorLocal) Session added in v1.1.9 

func (p *ExecutorLocal) Session() *csession.Session

type ExecutorRemote added in v1.1.9 

type ExecutorRemote struct {
	Executor
	// contains filtered or unexported fields
}

func (*ExecutorRemote) Data added in v1.1.30 

func (p *ExecutorRemote) Data() []byte

func (*ExecutorRemote) Invoke added in v1.1.9 

func (p *ExecutorRemote) Invoke()

func (*ExecutorRemote) QueueHash added in v1.1.30 

func (p *ExecutorRemote) QueueHash(queueNum int) int

func (*ExecutorRemote) Route added in v1.1.30 

func (p *ExecutorRemote) Route() *cmessage.Route

func (*ExecutorRemote) UnmarshalData added in v1.1.30 

func (p *ExecutorRemote) UnmarshalData() (interface{}, error)

type FilterFn 

type FilterFn func(ctx context.Context, session *csession.Session, message *cmsg.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.EventFn, hashFn ...cfacade.QueueHashFn)

func (*Handler) AddLocal 

func (h *Handler) AddLocal(name string, fn interface{}, hashFn ...cfacade.QueueHashFn)

func (*Handler) AddLocalWithNames added in v1.2.5 

func (h *Handler) AddLocalWithNames(names []string, fn interface{}, hashFn ...cfacade.QueueHashFn)

func (*Handler) AddLocals 

func (h *Handler) AddLocals(localFns []interface{}, hashFn ...cfacade.QueueHashFn)

func (*Handler) AddRemote 

func (h *Handler) AddRemote(name string, fn interface{}, hashFn ...cfacade.QueueHashFn)

func (*Handler) AddRemoteWithNames added in v1.2.5 

func (h *Handler) AddRemoteWithNames(names []string, fn interface{}, hashFn ...cfacade.QueueHashFn)

func (*Handler) AddRemotes 

func (h *Handler) AddRemotes(remoteFns []interface{}, hashFn ...cfacade.QueueHashFn)

func (*Handler) Component 

func (h *Handler) Component() *Component

func (*Handler) Event 

func (h *Handler) Event(name string) (*cfacade.EventInfo, bool)

func (*Handler) Events 

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

func (*Handler) LocalHandler 

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

func (*Handler) LocalHandlers 

func (h *Handler) LocalHandlers() map[string]*cfacade.MethodInfo

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.MethodInfo, bool)

func (*Handler) RemoteHandlers 

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

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(hashFn cfacade.QueueHashFn, executor cfacade.IExecutor)

func (*HandlerGroup) SetQueueHash 

func (h *HandlerGroup) SetQueueHash(fn cfacade.QueueHashFn)

type Option added in v1.1.1 

type Option func(*Component)

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 WithName added in v1.2.6 

func WithName(fn func(string) string) Option

func WithProcessTimeout added in v1.2.10 

func WithProcessTimeout(d time.Duration) Option

type Queue 

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

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.