message

Documentation

Index

• type Compliance
  • func (msg *Compliance) ClockProcessingTime() int64
  • func (msg Compliance) FinishProcessingCompliance(err error)
• type CompliancePipe

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
		EndTime        time.Time
		Status         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