factory

func CreateConfigLoader ¶ added in v0.5.0

func CreateConfigLoader(filePath string) config.Loader

CreateConfigLoader constructs a config.Loader for the given file path. Pure composition: no I/O, no context creation.

func CreateNotificationSender ¶ added in v0.22.0

func CreateNotificationSender(
	ctx context.Context,
	syncProducer kafka.SyncProducer,
	topicPrefix base.TopicPrefix,
) notification.NotificationPublishCommandSender

CreateNotificationSender constructs the shared-core notification command sender backed by the given Kafka sync producer; topicPrefix selects the command topic. ctx feeds the request-ID channel so downstream cancellation propagates. Pure composition: no network calls at construction time.

func CreateNotifiers ¶ added in v0.18.0

func CreateNotifiers(cfg config.Config) []notify.Notifier

CreateNotifiers builds one Notifier per WatcherConfig entry in the order they appear. Pure composition: no network calls at construction time.

CreateNotifiers is an interim placeholder: watcher entries are filter-only, so the bespoke path can no longer be selected per type. Delivery is log-only until the shared publish path lands in the next prompt; this constructor and pkg/notify are removed by the gated deletion prompt of spec 004.

func CreatePublishers ¶ added in v0.22.0

func CreatePublishers(
	cfg config.Config,
	sender notification.NotificationPublishCommandSender,
	topicPrefix base.TopicPrefix,
	currentDateTimeGetter libtime.CurrentDateTimeGetter,
) []publish.Publisher

CreatePublishers builds one Publisher per watcher entry, in config order, each with that entry's dedup window. Pure composition: no network calls at construction time.

func CreateWatcher ¶ added in v0.5.0

func CreateWatcher(cfg config.Config, publishers []publish.Publisher) watcher.Watcher

CreateWatcher constructs a watcher.Watcher that observes all configured vaults and fans out matching task events to all watcher entries. Pure composition: no filesystem access at construction time.