message

Documentation

Index

• func Propagate(out chan<- Compliance, msg *Compliance)
• type Compliance
  • func (msg *Compliance) ClockProcessingTime() int64
  • func (msg Compliance) FinishProcessingCompliance(err error)
• type CompliancePipe

Functions

func Propagate

func Propagate(out chan<- Compliance, msg *Compliance)

Types

type Compliance

type Compliance struct {
	QueueTime      time.Time
	Report         compliance.Report
	InspecSummary  *relaxting.ESInSpecSummary
	InspecReport   *relaxting.ESInSpecReport
	InspecProfiles []*relaxting.ESInspecProfile
	Ctx            context.Context
	Done           chan<- error

	Shared struct {
		PerProfileSums        []relaxting.ESInSpecSummaryProfile
		AllProfileSums        *reportingTypes.NodeControlSummary
		EsProfilesMissingMeta map[string]interface{}
		EndTime               time.Time
		Status                string
		StatusMessage         string
	}
}

func (*Compliance) ClockProcessingTime

func (msg *Compliance) ClockProcessingTime() int64

ClockProcessingTime will return the time that has passed (in milliseconds) since the message got started until 'Now()'

Useful to check the time that messages take to go through the pipeline

func (Compliance) FinishProcessingCompliance

func (msg Compliance) FinishProcessingCompliance(err error)

type CompliancePipe

type CompliancePipe func(<-chan Compliance) <-chan Compliance