Documentation
¶
Index ¶
- Constants
- func GetRabbitProducer(ctx context.Context, ci inverse.Container) (task.Producer, error)
- func InjectorConsumerExecutorConfiguration(ctx context.Context, ci inverse.Container) (runtime.Configuration[*runtime_rabbit.Consumer], error)
- func RegisterConsumer(container inverse.Container, name string, rabbitConnectionString string, ...)
- func RegisterConsumerConfig(ci inverse.Container, ...)
- func RegisterConsumerExecutor(ci inverse.Container, ...)
- func RegisterCron(container inverse.Container, ...)
- func RegisterCronConfig(ci inverse.Container, configs ...runtime.Configuration[*runtime_cron.Cron])
- func RegisterProducer(container inverse.Container, name string, rabbitConnectionString string, ...)
- func RegisterProducerConfig(ci inverse.Container, ...)
- func ResolveCronConfigTaskProducer(ctx context.Context, ci inverse.Container) (runtime.Configuration[*runtime_cron.Cron], error)
- type CronConfiguration
- type ExecutorConfiguration
Constants ¶
View Source
const ( QualifierRabbitProducer = "QualifierRabbitProducer" QualifierRabbitConsumerExecutor = "QualifierRabbitConsumerExecutor" QualifierRabbitConsumer = "QualifierRabbitConsumer" )
View Source
const (
QualifierCron = "QualifierCron"
)
Variables ¶
This section is empty.
Functions ¶
func GetRabbitProducer ¶
func InjectorConsumerExecutorConfiguration ¶
func InjectorConsumerExecutorConfiguration(ctx context.Context, ci inverse.Container) (runtime.Configuration[*runtime_rabbit.Consumer], error)
func RegisterConsumer ¶
func RegisterConsumer( container inverse.Container, name string, rabbitConnectionString string, channel string, configs []runtime.Configuration[*runtime_rabbit.Consumer], )
func RegisterConsumerConfig ¶
func RegisterConsumerConfig(ci inverse.Container, configs ...runtime.Configuration[*runtime_rabbit.Consumer])
func RegisterCron ¶ added in v0.0.5
func RegisterCron( container inverse.Container, configs []runtime.Configuration[*runtime_cron.Cron], )
func RegisterCronConfig ¶ added in v0.0.5
func RegisterCronConfig(ci inverse.Container, configs ...runtime.Configuration[*runtime_cron.Cron])
func RegisterProducer ¶
func RegisterProducer( container inverse.Container, name string, rabbitConnectionString string, configs []runtime.Configuration[*runtime_rabbit.Producer], )
func RegisterProducerConfig ¶
func RegisterProducerConfig(ci inverse.Container, configs ...runtime.Configuration[*runtime_rabbit.Producer])
func ResolveCronConfigTaskProducer ¶ added in v0.1.0
func ResolveCronConfigTaskProducer(ctx context.Context, ci inverse.Container) (runtime.Configuration[*runtime_cron.Cron], error)
Types ¶
type CronConfiguration ¶ added in v0.0.5
type CronConfiguration[OK any, OV any, T any] struct { Name string TaskChannel task.Channel[T] Scheduler task.Scheduler[OK, OV, T] Schedules []string TaskConnectionString string HttpPort int RabbitProducerConfiguration []runtime.Configuration[*runtime_rabbit.Producer] RetryConfiguration []runtime.Configuration[*runtime_retry.Retry] RouteConfiguration []runtime.Configuration[*runtime_bunrouter.Router] }
func (CronConfiguration[OK, OV, T]) Register ¶ added in v0.0.5
func (c CronConfiguration[OK, OV, T]) Register(ci inverse.Container)
type ExecutorConfiguration ¶ added in v0.1.5
type ExecutorConfiguration[T any] struct { Name string TaskChannel task.Channel[T] TaskExecutor task.Executor[T] TaskConnectionString string HttpPort int RabbitConsumerConfiguration []runtime.Configuration[*runtime_rabbit.Consumer] RetryConfiguration []runtime.Configuration[*runtime_retry.Retry] RouteConfiguration []runtime.Configuration[*runtime_bunrouter.Router] }
func (ExecutorConfiguration[T]) Register ¶ added in v0.1.5
func (c ExecutorConfiguration[T]) Register(ci inverse.Container)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.