aggregation

Documentation

Index

• type ObsAggregationOptions
• type ObservationListenerExtended
  • func NewObsAggregator(options *ObsAggregationOptions) (ObservationListenerExtended, error)
• type ValidEdges

Types

type ObsAggregationOptions

type ObsAggregationOptions struct {
	// Log is the used logger
	Log logrus.FieldLogger
	// NodeName is the hostname of this node
	NodeName string
	// ReportPeriod is the period between two reports
	ReportPeriod time.Duration
	// TimeWindow is the window after which aggregations are removed if no new ones are added
	TimeWindow time.Duration
	// LogDirectory is an optional parameter to write the report to (in addition to log output)
	LogDirectory string
	// HostNetwork is true if agent runs on host network
	HostNetwork bool
	// K8sExporterConfig configuration for patching conditions in node status and creating events
	K8sExporterConfig config.K8sExporterConfig
}

type ObservationListenerExtended

type ObservationListenerExtended interface {
	nwpd.ObservationListener

	UpdateValidEdges(edges ValidEdges)
}

func NewObsAggregator

func NewObsAggregator(options *ObsAggregationOptions) (ObservationListenerExtended, error)

type ValidEdges

type ValidEdges struct {
	JobIDs        common.StringSet
	SrcHosts      common.StringSet
	DestHosts     common.StringSet
	PeerNodeCount int
}