Documentation
¶
Index ¶
- func CreateConfigLoader(filePath string) config.Loader
- func CreateNotificationSender(ctx context.Context, syncProducer kafka.SyncProducer, ...) notification.NotificationPublishCommandSender
- func CreatePublishers(cfg config.Config, sender notification.NotificationPublishCommandSender, ...) []publish.Publisher
- func CreateWatcher(cfg config.Config, publishers []publish.Publisher) watcher.Watcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateConfigLoader ¶ added in v0.5.0
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 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
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.
Types ¶
This section is empty.
Source Files