Documentation
¶
Index ¶
- func BuildNodeManagerPublisher(nodeManagerClient manager.NodeManagerServiceClient) message.CompliancePipe
- func ReportManagerPublisher(reportMgrClient manager.ReportManagerServiceClient) message.CompliancePipe
- func StoreCompliance(cerealService *cereal.Manager, client *ingestic.ESClient, ...) message.CompliancePipe
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildNodeManagerPublisher ¶
func BuildNodeManagerPublisher(nodeManagerClient manager.NodeManagerServiceClient) message.CompliancePipe
func ReportManagerPublisher ¶
func ReportManagerPublisher(reportMgrClient manager.ReportManagerServiceClient) message.CompliancePipe
func StoreCompliance ¶
func StoreCompliance(cerealService *cereal.Manager, client *ingestic.ESClient, numberOfPublishers int) message.CompliancePipe
StoreCompliance uses the publishers to save the data in ElasticSearch
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.