resource_updates_receiver

var Module = fx.Module(
	"resource_updates_receiver",
	fx.Invoke(
		func(lf fx.Lifecycle, ruc ResourceUpdateConsumer, eoa ErrorOnApplyConsumer, d domain.Domain, logger *slog.Logger) {
			lf.Append(fx.Hook{
				OnStart: func(context.Context) error {
					go Start(StartArgs{
						ResourceUpdateConsumer: ruc,
						ErrorOnApplyConsumer:   eoa,
						Domain:                 d,
						Logger:                 logger,
					})
					return nil
				},
				OnStop: func(ctx context.Context) error {
					return Stop(ctx, StopArgs{
						ResourceUpdateConsumer: ruc,
						ErrorOnApplyConsumer:   eoa,
					})
				},
			})
		}),
)