server

Documentation

Index

• Variables
• func SendComplianceReport(ctx context.Context, in *compliance.Report, s *ComplianceIngestServer) error
• type ComplianceIngestServer
  • func NewComplianceIngestServer(esClient *ingestic.ESClient, mgrClient manager.NodeManagerServiceClient, ...) *ComplianceIngestServer
  • func (srv *ComplianceIngestServer) HandleEvent(ctx context.Context, req *automate_event.EventMsg) (*automate_event.EventResponse, error)
  • func (s *ComplianceIngestServer) ProcessComplianceReport(stream ingest_api.ComplianceIngesterService_ProcessComplianceReportServer) error
  • func (srv *ComplianceIngestServer) ProjectUpdateStatus(ctx context.Context, req *ingest_api.ProjectUpdateStatusReq) (*ingest_api.ProjectUpdateStatusResp, error)

Variables

var MinimumSupportedInspecVersion = semver.MustParse("2.0.0")

Functions

func SendComplianceReport

func SendComplianceReport(ctx context.Context, in *compliance.Report, s *ComplianceIngestServer) error

Types

type ComplianceIngestServer

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

func NewComplianceIngestServer

func NewComplianceIngestServer(esClient *ingestic.ESClient, mgrClient manager.NodeManagerServiceClient, reportMgrClient report_manager.ReportManagerServiceClient,
	automateURL string, notifierClient notifier.Notifier, authzProjectsClient authz.ProjectsServiceClient,
	messageBufferSize int, enableLargeReporting bool, cerealManager *cereal.Manager) *ComplianceIngestServer

func (*ComplianceIngestServer) HandleEvent

func (srv *ComplianceIngestServer) HandleEvent(ctx context.Context, req *automate_event.EventMsg) (*automate_event.EventResponse, error)

func (*ComplianceIngestServer) ProcessComplianceReport

func (s *ComplianceIngestServer) ProcessComplianceReport(stream ingest_api.ComplianceIngesterService_ProcessComplianceReportServer) error

ProcessComplianceReport receives messages in chunks and creates report

func (*ComplianceIngestServer) ProjectUpdateStatus

func (srv *ComplianceIngestServer) ProjectUpdateStatus(ctx context.Context,
	req *ingest_api.ProjectUpdateStatusReq) (*ingest_api.ProjectUpdateStatusResp, error)