pipeline

Documentation

Index

• Variables
• type Compliance
  • func NewCompliancePipeline(client *ingestic.ESClient, authzClient authz.ProjectsServiceClient, ...) Compliance
  • func (s *Compliance) Close()
  • func (s *Compliance) Run(report *compliance.Report) error

Variables

var ErrQueueFull = errors.New("Report processing queue is full")

Types

type Compliance

type Compliance struct {
	// contains filtered or unexported fields
}

func NewCompliancePipeline

func NewCompliancePipeline(client *ingestic.ESClient, authzClient authz.ProjectsServiceClient,
	nodeMgrClient manager.NodeManagerServiceClient, reportMgrClient report_manager.ReportManagerServiceClient,
	messageBufferSize int, notifierClient notifier.Notifier, automateURL string, enableLargeReporting bool, cerealService *cereal.Manager) Compliance

func (*Compliance) Close

func (s *Compliance) Close()

func (*Compliance) Run

func (s *Compliance) Run(report *compliance.Report) error