module

type DelayEventFunction func(message []byte) (retry bool, err error)

type DelayEventHandler interface {
	GetTopic() string
	Handle(ctx context.Context, logger types.LoggerProvider, msgChan <-chan *types.Message)
}

type DelayEventModule interface {
	Module
	RegisterHandlers(functions map[string]DelayEventFunction) error // 注册Handlers
	GetHandlers() []DelayEventHandler                               // 获取handlers
	GetAckTimeout() time.Duration
	GetBackOffPolicy() backoff.BackOff
}

type DelayEventModuleOption func(*delayEventModuleImpl)

type EventFunction func(ctx biz.Context, data []byte) (retry bool, err error)

type EventModule interface {
	Module
	RegisterHandlers(functions map[string]EventFunction) error // 注册Handlers
	GetHandlers() []eventHandler                               // 获取handlers
	GetPubSub() string
	GetAckTimeout() time.Duration
}

type EventModuleOption func(*eventModuleImpl)

type HandlerMatcher func(methodName string) (string, bool) // 传入receiver.methodName, 判断是否匹配，然后取出处理后的handlerName

type HealthCheckFunction func(context.Context) error

type HealthModule interface {
	Module
	GetHandler() common.HealthCheckHandler
}

type Info struct {
	ApiVersion int    // API版本
	Name       string // 规范化的模块名
	Dir        string // 模块所在目录
}

type InvocationFunction func(ctx biz.Context, data []byte) (any, error)

type InvocationModule interface {
	Module
	RegisterHandlers(functions map[string]InvocationFunction) error // 注册Handlers
	GetHandlers() []invocationHandler                               // 获取handlers
}

type Module interface {
	GetApp() string
	GetInfo() *Info
	GetKind() ModuleKind
}

type ModuleKind int