actions

Documentation

Index

• func AddPeer(conf config.Configuration, iam uuid.UUID, ep string)
• func ConfigureAgent(conf config.Configuration, name string, roles []string) (model.AgentConfig, error)
• func DataStats(conf config.Configuration) (map[string]int, error)
• func DeletedCheckCleanup(conf config.Configuration, id uuid.UUID)
• func DeletedSubjectCleanup(conf config.Configuration, id uuid.UUID)
• func FillCheckStateDetails(ctx model.AppContext, states []model.CheckState) ([]model.CheckStateDetail, error)
• func GetPeers(conf config.Configuration) map[string]string
• func Info(conf config.Configuration) model.CoordinatorInfo
• func RecordCheckResult(result model.CheckResult, ctx model.AppContext, conf config.Configuration) error
• func UpdatedCheckCleanup(conf config.Configuration, checkID uuid.UUID, oldRoles, newRoles []string)
• func UpdatedSubjectCleanup(conf config.Configuration, subjectID uuid.UUID, oldRoles, newRoles []string)

Functions

func AddPeer

func AddPeer(conf config.Configuration, iam uuid.UUID, ep string)

AddPeer registers a new peer coordinator.

func ConfigureAgent

func ConfigureAgent(conf config.Configuration, name string, roles []string) (model.AgentConfig, error)

ConfigureAgent builds an agent config, creating the Subject if necessary.

func DataStats

func DataStats(conf config.Configuration) (map[string]int, error)

DataStats returns counts of each entity type.

func DeletedCheckCleanup

func DeletedCheckCleanup(conf config.Configuration, id uuid.UUID)

DeletedCheckCleanup handles removing states & results for a check that's been deleted.

func DeletedSubjectCleanup

func DeletedSubjectCleanup(conf config.Configuration, id uuid.UUID)

DeletedSubjectCleanup handles removing states & results for a subject that's been deleted.

func FillCheckStateDetails

func FillCheckStateDetails(ctx model.AppContext, states []model.CheckState) ([]model.CheckStateDetail, error)

FillCheckStateDetails transforms a collection of CheckStates into CheckStateDetails by looking up the check & subject for each.

func GetPeers

func GetPeers(conf config.Configuration) map[string]string

GetPeers returns all currently known live peers. If an id of the requesting coordinator is provided, it will be added to this node's known peers.

func Info

func Info(conf config.Configuration) model.CoordinatorInfo

Info returns information about the running Coordinator instance.

func RecordCheckResult

func RecordCheckResult(result model.CheckResult, ctx model.AppContext, conf config.Configuration) error

RecordCheckResult including updating check state.

func UpdatedCheckCleanup

func UpdatedCheckCleanup(conf config.Configuration, checkID uuid.UUID, oldRoles, newRoles []string)

UpdatedCheckCleanup handles cleaning up check states and results when a check is modified to no longer apply to some subjects.

func UpdatedSubjectCleanup

func UpdatedSubjectCleanup(conf config.Configuration, subjectID uuid.UUID, oldRoles, newRoles []string)

UpdatedSubjectCleanup handles cleaning up check states and results when a subject is modified to no longer apply to some checks.