factory

func CreateKafkaSender ¶

func CreateKafkaSender(
	syncProducer libkafka.SyncProducer,
	topicPrefix base.TopicPrefix,
	defaultVault string,
) task.CreateCommandSender

CreateKafkaSender constructs a typed create-task command sender backed by a Kafka sync producer. defaultVault is the Obsidian vault slug substituted into each command's TargetVault when unset (empty = controller default, openclaw).

func CreateWatcher ¶

func CreateWatcher(
	httpClient *http.Client,
	sender task.CreateCommandSender,
	cursorPath string,
	metrics pkg.Metrics,
	cfg pkg.TaskConfig,
	seedVersion string,
) pkg.Watcher

CreateWatcher wires all dependencies and returns a ready-to-use Watcher.

Pure composition — no I/O. The Kafka sync producer and the task sender are constructed by the caller (so it controls connection lifecycle + cleanup).