Documentation
¶
Index ¶
Constants ¶
const EnvKafkaBrokers = "KAFKA_BROKERS"
EnvKafkaBrokers is the environment variable holding the comma-separated Kafka broker list.
const EnvTopicPrefix = "TOPIC_PREFIX"
EnvTopicPrefix is the environment variable holding the Kafka topic prefix.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Vaults []VaultConfig
Watchers []WatcherConfig
}
Config holds the parsed task-watcher configuration.
type Destination ¶ added in v0.21.0
type Destination struct {
KafkaBrokers kafka.Brokers
TopicPrefix base.TopicPrefix
}
Destination holds the publish destination read from the environment.
func LoadDestinationFromEnv ¶ added in v0.21.0
func LoadDestinationFromEnv(ctx context.Context) (Destination, error)
LoadDestinationFromEnv reads the publish destination from the environment. Both KAFKA_BROKERS (comma-separated) and TOPIC_PREFIX are required; an unset or empty variable is an error naming that variable.
type VaultConfig ¶ added in v0.12.0
VaultConfig holds the configuration for a single vault.
type WatcherConfig ¶ added in v0.16.0
type WatcherConfig struct {
Name string
Assignee string
Statuses []string
Phases []string
DedupTTL time.Duration
}
WatcherConfig holds the configuration for a single watcher entry. An entry is a pure filter: it selects which task events match, and no longer selects a delivery channel.
Source Files