server

Documentation

Index

• Variables
• 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(ctx context.Context, in *compliance.Report) (*gp.Empty, error)
  • func (srv *ComplianceIngestServer) ProjectUpdateStatus(ctx context.Context, req *ingest_api.ProjectUpdateStatusReq) (*ingest_api.ProjectUpdateStatusResp, error)

Variables

var MinimumSupportedInspecVersion = semver.MustParse("2.0.0")

Types

type ComplianceIngestServer

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

func NewComplianceIngestServer

func NewComplianceIngestServer(esClient *ingestic.ESClient, mgrClient manager.NodeManagerServiceClient,
	automateURL string, notifierClient notifier.Notifier, authzProjectsClient authz.ProjectsServiceClient,
	messageBufferSize int) *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(ctx context.Context, in *compliance.Report) (*gp.Empty, error)

func (*ComplianceIngestServer) ProjectUpdateStatus

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