tasks

README

Tasks

An extension to flows that queues and handles long running tasks.

Caveat

The development of this repository is somewhat rushed at the beginning, expect volatile API.

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
  • func (c CronConfiguration[OK, OV, T]) Register(ci inverse.Container)
• type ExecutorConfiguration
  • func (c ExecutorConfiguration[T]) Register(ci inverse.Container)

Constants

const (
	QualifierRabbitProducer         = "QualifierRabbitProducer"
	QualifierRabbitConsumerExecutor = "QualifierRabbitConsumerExecutor"
	QualifierRabbitConsumer         = "QualifierRabbitConsumer"
)

const (
	QualifierCron = "QualifierCron"
)

Functions

func GetRabbitProducer

func GetRabbitProducer(ctx context.Context, ci inverse.Container) (task.Producer, error)

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 RegisterConsumerExecutor

func RegisterConsumerExecutor(ci inverse.Container, injector func(ctx context.Context, ci inverse.Container) (task.Executor[structure.Bytes], error))

func RegisterCron

func RegisterCron(
	container inverse.Container,
	configs []runtime.Configuration[*runtime_cron.Cron],
)

func RegisterCronConfig

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

func ResolveCronConfigTaskProducer(ctx context.Context, ci inverse.Container) (runtime.Configuration[*runtime_cron.Cron], error)

Types

type CronConfiguration

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

func (c CronConfiguration[OK, OV, T]) Register(ci inverse.Container)

type ExecutorConfiguration

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

func (c ExecutorConfiguration[T]) Register(ci inverse.Container)