controls

Documentation

Index

• Variables
• func CheckNodeExist(ctx context.Context, nodeID string) error
• func CompleteAgentUpgrade(ctx context.Context, version string, nodeID string, nodeType string) error
• func DisableCloudNodeComplianceControls(ctx context.Context, nodeID string, controlIDs []string) error
• func EnableCloudNodeComplianceControls(ctx context.Context, nodeID string, controlIds []string) error
• func ExtractAgentDiagnosticLogRequests(ctx context.Context, nodeID string, nodeType controls.ScanResource, ...) ([]controls.Action, error)
• func ExtractPendingAgentThreatIntelTask(ctx context.Context, nodeID string, agentType string, consoleURL string, ...) ([]controls.Action, error)
• func ExtractPendingAgentUpgrade(ctx context.Context, nodeID string, maxWork int, consoleURL string, ...) ([]controls.Action, error)
• func ExtractPendingKubernetesClusterUpgrade(ctx context.Context, nodeID string, maxWork int) ([]controls.Action, error)
• func ExtractRefreshResourceAction(ctx context.Context, nodeID string, maxWork int) ([]controls.Action, error)
• func ExtractStartingAgentScans(ctx context.Context, nodeID string, agentType string, maxWork int) ([]controls.Action, error)
• func ExtractStartingKubernetesClusterScans(ctx context.Context, nodeID string, maxWork int) ([]controls.Action, error)
• func ExtractStoppingAgentScans(ctx context.Context, nodeID string, maxWrok int) ([]controls.Action, error)
• func GetAgentActions(ctx context.Context, agentID model.AgentID, consoleURL string, ...) ([]controls.Action, []error)
• func GetAgentPluginVersionTarball(ctx context.Context, version, pluginName string) (string, error)
• func GetAgentVersionTarball(ctx context.Context, version string) (string, error)
• func GetCloudNodeComplianceControls(ctx context.Context, nodeID string, cloudProvider string, ...) ([]model.CloudNodeComplianceControl, error)
• func GetKubernetesClusterActions(ctx context.Context, nodeID string, workNumToExtract int, consoleURL string) ([]controls.Action, []error)
• func GetPendingAgentScans(ctx context.Context, nodeID string, availableWorkload int, ...) ([]controls.Action, error)
• func PrepareAgentUpgradeAction(ctx context.Context, version string) (controls.Action, error)
• func ScheduleAgentPluginDisable(ctx context.Context, pluginName string, nodeIDs []string, ...) error
• func ScheduleAgentPluginEnable(ctx context.Context, version, pluginName string, nodeIDs []string, ...) error
• func ScheduleAgentUpgrade(ctx context.Context, version string, nodeIDs []string, action controls.Action) error

Variables

var (
	ErrMissingNodeID = errors.New("missing node_id")
)

Functions

func CheckNodeExist

func CheckNodeExist(ctx context.Context, nodeID string) error

func CompleteAgentUpgrade

func CompleteAgentUpgrade(ctx context.Context, version string,
	nodeID string, nodeType string) error

func DisableCloudNodeComplianceControls

func DisableCloudNodeComplianceControls(ctx context.Context, nodeID string, controlIDs []string) error

func EnableCloudNodeComplianceControls

func EnableCloudNodeComplianceControls(ctx context.Context, nodeID string, controlIds []string) error

func ExtractAgentDiagnosticLogRequests

func ExtractAgentDiagnosticLogRequests(ctx context.Context, nodeID string, nodeType controls.ScanResource, maxWork int, consoleURL string) ([]controls.Action, error)

func ExtractPendingAgentThreatIntelTask

func ExtractPendingAgentThreatIntelTask(ctx context.Context, nodeID string, agentType string, consoleURL string, ttlCache *ttlcache.Cache[string, string]) ([]controls.Action, error)

func ExtractPendingAgentUpgrade

func ExtractPendingAgentUpgrade(ctx context.Context, nodeID string, maxWork int, consoleURL string, ttlCache *ttlcache.Cache[string, string]) ([]controls.Action, error)

func ExtractPendingKubernetesClusterUpgrade

func ExtractPendingKubernetesClusterUpgrade(ctx context.Context, nodeID string, maxWork int) ([]controls.Action, error)

func ExtractRefreshResourceAction

func ExtractRefreshResourceAction(ctx context.Context, nodeID string, maxWork int) ([]controls.Action, error)

func ExtractStartingAgentScans

func ExtractStartingAgentScans(ctx context.Context, nodeID string, agentType string, maxWork int) ([]controls.Action, error)

func ExtractStartingKubernetesClusterScans

func ExtractStartingKubernetesClusterScans(ctx context.Context, nodeID string, maxWork int) ([]controls.Action, error)

func ExtractStoppingAgentScans

func ExtractStoppingAgentScans(ctx context.Context, nodeID string, maxWrok int) ([]controls.Action, error)

func GetAgentActions

func GetAgentActions(ctx context.Context, agentID model.AgentID, consoleURL string,
	ttlCache *ttlcache.Cache[string, string]) ([]controls.Action, []error)

func GetAgentPluginVersionTarball

func GetAgentPluginVersionTarball(ctx context.Context, version, pluginName string) (string, error)

func GetAgentVersionTarball

func GetAgentVersionTarball(ctx context.Context, version string) (string, error)

func GetCloudNodeComplianceControls

func GetCloudNodeComplianceControls(ctx context.Context, nodeID string, cloudProvider string, complianceType []string) ([]model.CloudNodeComplianceControl, error)

func GetKubernetesClusterActions

func GetKubernetesClusterActions(ctx context.Context, nodeID string, workNumToExtract int, consoleURL string) ([]controls.Action, []error)

func GetPendingAgentScans

func GetPendingAgentScans(ctx context.Context, nodeID string, availableWorkload int,
	ttlCache *ttlcache.Cache[string, string]) ([]controls.Action, error)

func PrepareAgentUpgradeAction

func PrepareAgentUpgradeAction(ctx context.Context, version string) (controls.Action, error)

func ScheduleAgentPluginDisable

func ScheduleAgentPluginDisable(ctx context.Context, pluginName string, nodeIDs []string, action controls.Action) error

func ScheduleAgentPluginEnable

func ScheduleAgentPluginEnable(ctx context.Context, version, pluginName string, nodeIDs []string, action controls.Action) error

func ScheduleAgentUpgrade

func ScheduleAgentUpgrade(ctx context.Context, version string, nodeIDs []string, action controls.Action) error