Documentation
¶
Index ¶
- func AddResolver(key string, res command.Resolver) error
- func GetCLIOptions() ([]kong.Option, error)
- func HasResolver(key string) bool
- func RegisterCommand[T any](cmd command.Commander[T], runnerOpts ...runner.Option) (dispatcher.Subscription, error)
- func RegisterQuery[T any, R any](qry command.Querier[T, R], runnerOpts ...runner.Option) (dispatcher.Subscription, error)
- func SetCronRegister(fn func(opts command.HandlerConfig, handler any) error)
- func Start(_ context.Context) error
- func Stop(_ context.Context) error
- func WithTestRegistry(fn func())
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCLIOptions ¶
func HasResolver ¶ added in v0.11.0
func RegisterCommand ¶
func RegisterCommand[T any](cmd command.Commander[T], runnerOpts ...runner.Option) (dispatcher.Subscription, error)
func RegisterQuery ¶
func RegisterQuery[T any, R any](qry command.Querier[T, R], runnerOpts ...runner.Option) (dispatcher.Subscription, error)
func SetCronRegister ¶
func SetCronRegister(fn func(opts command.HandlerConfig, handler any) error)
func WithTestRegistry ¶
func WithTestRegistry(fn func())
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.