upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Enhance dependency syncs & add missing required fields

Browse source
This commit is contained in:
Yonas Habteab 2024-12-09 10:42:18 +01:00
parent a0307088f6
commit b2af3e0962
2 changed files with 19 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
pkg/icingadb/v1/dependency.go
View file

@ -5,23 +5,13 @@ import (
"github.com/icinga/icinga-go-library/types"
)
type Dependency struct {
EntityWithoutChecksum `json:",inline"`
EnvironmentMeta `json:",inline"`
NameMeta `json:",inline"`
RedundancyGroupId types.Binary `json:"redundancy_group_id"`
}
type Redundancygroup struct {
EntityWithoutChecksum `json:",inline"`
EnvironmentMeta `json:",inline"`
Name string `json:"name"`
DisplayName string `json:"display_name"`
}
// TableName implements [database.TableNamer].
//
// Unless I am missing something, there is no way to change a type's name for the Redis, see common.SyncSubject.Name().
func (r Redundancygroup) TableName() string {
return "redundancy_group"
}
@ -31,6 +21,7 @@ type RedundancygroupState struct {
EnvironmentMeta `json:",inline"`
RedundancyGroupId types.Binary `json:"redundancy_group_id"`
Failed types.Bool `json:"failed"`
IsReachable types.Bool `json:"is_reachable"`
LastStateChange types.UnixMilli `json:"last_state_change"`
}
@ -47,16 +38,19 @@ type DependencyNode struct {
RedundancyGroupId types.Binary `json:"redundancy_group_id"`
}
type DependencyEdgeState struct {
EntityWithoutChecksum `json:",inline"`
EnvironmentMeta `json:",inline"`
Failed types.Bool `json:"failed"`
}
type DependencyEdge struct {
EntityWithoutChecksum `json:",inline"`
EnvironmentMeta `json:",inline"`
FromNodeId types.Binary `json:"from_node_id"`
ToNodeId types.Binary `json:"to_node_id"`
DependencyId types.Binary `json:"dependency_id"`
}
func NewDependency() database.Entity {
return &Dependency{}
DependencyEdgeStateId types.Binary `json:"dependency_edge_state_id"`
DisplayName string `json:"display_name"`
}
func NewRedundancygroup() database.Entity {
@ -71,6 +65,10 @@ func NewDependencyNode() database.Entity {
return &DependencyNode{}
}
func NewDependencyEdgeState() database.Entity {
return &DependencyEdgeState{}
}
func NewDependencyEdge() database.Entity {
return &DependencyEdge{}
}

9
pkg/icingadb/v1/v1.go
View file

@ -4,7 +4,12 @@ import (
"github.com/icinga/icinga-go-library/database"
)
var StateFactories = []database.EntityFactoryFunc{NewHostState, NewServiceState}
var StateFactories = []database.EntityFactoryFunc{
NewHostState,
NewServiceState,
NewDependencyEdgeState,
NewRedundancygroupState,
}
var ConfigFactories = []database.EntityFactoryFunc{
NewActionUrl,
@ -51,9 +56,7 @@ var ConfigFactories = []database.EntityFactoryFunc{
NewUsergroupCustomvar,
NewUsergroupMember,
NewZone,
NewDependency,
NewRedundancygroup,
NewRedundancygroupState,
NewDependencyNode,
NewDependencyEdge,
}