config

type ConfigSet struct {
	Channels         map[int64]*channel.Channel
	Contacts         map[int64]*recipient.Contact
	ContactAddresses map[int64]*recipient.Address
	Groups           map[int64]*recipient.Group
	TimePeriods      map[int64]*timeperiod.TimePeriod
	Schedules        map[int64]*recipient.Schedule
	Rules            map[int64]*rule.Rule
	Sources          map[int64]*Source
	// contains filtered or unexported fields
}

type IncrementalConfigurable[PK comparable] interface {
	zapcore.ObjectMarshaler

	// GetPrimaryKey returns the primary key value.
	GetPrimaryKey() PK

	// GetChangedAt returns the changed_at value.
	GetChangedAt() types.UnixMilli

	// IsDeleted returns if this entry was marked as deleted.
	IsDeleted() bool
}

type IncrementalConfigurableInitAndValidatable interface {
	// IncrementalInitAndValidate allows both to initialize and validates with an optional error.
	//
	// If an error is returned, the incrementalFetch function aborts the element in question.
	IncrementalInitAndValidate() error
}

type RuntimeConfig struct {
	// ConfigSet is the current live config. It is embedded to allow direct access to its members.
	// Accessing it requires a lock that is obtained with RLock() and released with RUnlock().
	ConfigSet

	// EventStreamLaunchFunc is a callback to launch an Event Stream API Client.
	// This became necessary due to circular imports, either with the incident or icinga2 package.
	EventStreamLaunchFunc func(source *Source)
	// contains filtered or unexported fields
}

type Source struct {
	baseconf.IncrementalPkDbEntry[int64] `db:",inline"`

	Type string `db:"type"`
	Name string `db:"name"`

	ListenerPasswordHash types.String `db:"listener_password_hash"`

	Icinga2BaseURL     types.String `db:"icinga2_base_url"`
	Icinga2AuthUser    types.String `db:"icinga2_auth_user"`
	Icinga2AuthPass    types.String `db:"icinga2_auth_pass"`
	Icinga2CAPem       types.String `db:"icinga2_ca_pem"`
	Icinga2CommonName  types.String `db:"icinga2_common_name"`
	Icinga2InsecureTLS types.Bool   `db:"icinga2_insecure_tls"`

	// Icinga2SourceConf for Event Stream API sources, only if Source.Type == SourceTypeIcinga2.
	Icinga2SourceCancel context.CancelFunc `db:"-" json:"-"`
}