Versions in this module Expand all Collapse all v0 v0.0.2 Jun 17, 2026 v0.0.1 Jun 17, 2026 Changes in this version + func CreateCommandSender(syncProducer libkafka.SyncProducer, branch cqrsbase.Branch, dryRun bool) task.CreateCommandSender + func CreateHealthzHandler() http.Handler + func CreatePublisher(sender task.CreateCommandSender, dryRun bool) publisher.Publisher + func CreateScheduleStore(client versioned.Interface, namespace string) (externalversions.SharedInformerFactory, store.ScheduleStore) + func CreateTick(ctx context.Context, scheduleStore store.ScheduleStore, ...) tick.Tick + func CreateTickLoop(ctx context.Context, scheduleStore store.ScheduleStore, ...) tick.Tick + func CreateTriggerHandler(scheduleStore store.ScheduleStore, pub publisher.Publisher) http.Handler
Go to main page