event

Documentation

Index

• type Event
  • func NewSingleService[T any]() Event[T]
• type Handler
• type MutiEventMsg
• type MutiEventServ
  • func NewMultiService(cfg *config.Config) (MutiEventServ, error)

Types

type Event

type Event[T any] interface {
	UnRegister(service, model string, handler Handler[T])
	Register(service, model string, handler Handler[T]) error
	RegisterFunc(service, model string, handler func(T)) Handler[T]
	Emit(service, model string, msg T) error
}

func NewSingleService

func NewSingleService[T any]() Event[T]

type Handler

type Handler[T any] interface {
	EventHandle(service, model string, msg T) error
}

type MutiEventMsg

type MutiEventMsg interface {
	GetId() string
}

type MutiEventServ

type MutiEventServ interface {
	Emit(service, model string, msg MutiEventMsg) error
	Register(service, model, msgId string, handler trans.Trans) error
	UnRegister(service, model, msgId string, handler trans.Trans)
	Run(context.Context)
}

func NewMultiService

func NewMultiService(cfg *config.Config) (MutiEventServ, error)