statusmanagerv1

Documentation

Index

• func UpdateArmorProfileModelStatus(i varmorinterface.CrdV1beta1Interface, apm *varmor.ArmorProfileModel, ...) error
• func UpdateArmorProfileStatus(i varmorinterface.CrdV1beta1Interface, ap *varmor.ArmorProfile, ...) error
• func UpdateVarmorClusterPolicyStatus(i varmorinterface.CrdV1beta1Interface, vcp *varmor.VarmorClusterPolicy, ...) error
• func UpdateVarmorPolicyStatus(i varmorinterface.CrdV1beta1Interface, vp *varmor.VarmorPolicy, ...) error
• type StatusManager
  • func NewStatusManager(coreInterface corev1.CoreV1Interface, appsInterface appsv1.AppsV1Interface, ...) *StatusManager
  • func (m *StatusManager) CleanUp()
  • func (m *StatusManager) Data(c *gin.Context)
  • func (m *StatusManager) Run(stopCh <-chan struct{})
  • func (m *StatusManager) Status(c *gin.Context)

Functions

func UpdateArmorProfileModelStatus

func UpdateArmorProfileModelStatus(
	i varmorinterface.CrdV1beta1Interface,
	apm *varmor.ArmorProfileModel,
	modelingStatus *varmortypes.ModelingStatus,
	desiredNumber int,
	complete bool) error

func UpdateArmorProfileStatus

func UpdateArmorProfileStatus(
	i varmorinterface.CrdV1beta1Interface,
	ap *varmor.ArmorProfile,
	policyStatus *varmortypes.PolicyStatus,
	desiredNumber int) error

func UpdateVarmorClusterPolicyStatus

func UpdateVarmorClusterPolicyStatus(
	i varmorinterface.CrdV1beta1Interface,
	vcp *varmor.VarmorClusterPolicy,
	profileName string,
	ready bool,
	phase varmor.VarmorPolicyPhase,
	condType varmor.VarmorPolicyConditionType,
	status v1.ConditionStatus,
	reason, message string) error

func UpdateVarmorPolicyStatus

func UpdateVarmorPolicyStatus(
	i varmorinterface.CrdV1beta1Interface,
	vp *varmor.VarmorPolicy,
	profileName string,
	ready bool,
	phase varmor.VarmorPolicyPhase,
	condType varmor.VarmorPolicyConditionType,
	status v1.ConditionStatus,
	reason, message string) error

Types

type StatusManager

type StatusManager struct {
	UpdateDesiredNumber bool

	// Use "namespace/VarmorPolicyName" or "VarmorClusterPolicyName" as key.
	// One VarmorPolicy/ClusterPolicyName object corresponds to one PolicyStatus
	PolicyStatuses map[string]varmortypes.PolicyStatus
	// Use "namespace/VarmorPolicyName" as key. One VarmorPolicy object corresponds to one ModelingStatus
	// TODO: Rebuild ModelingStatuses from ArmorProfile object when leader change occurs.
	ModelingStatuses map[string]varmortypes.ModelingStatus
	ResetCh          chan string
	DeleteCh         chan string
	UpdateStatusCh   chan string
	UpdateModeCh     chan string
	// contains filtered or unexported fields
}

func NewStatusManager

func NewStatusManager(coreInterface corev1.CoreV1Interface,
	appsInterface appsv1.AppsV1Interface,
	varmorInterface varmorinterface.CrdV1beta1Interface,
	statusUpdateCycle time.Duration,
	debug bool,
	inContainer bool,
	metricsModule *varmormetrics.MetricsModule,
	log logr.Logger) *StatusManager

NewStatusManager creates a StatusManager instance to manage the status of all CRD objects.

func (*StatusManager) CleanUp

func (m *StatusManager) CleanUp()

CleanUp shutdown all queues.

func (*StatusManager) Data

func (m *StatusManager) Data(c *gin.Context)

Data is the API interface that receives the behavior data from agents. The behavioral data is cached to a queue and then processed asynchronously.

func (*StatusManager) Run

func (m *StatusManager) Run(stopCh <-chan struct{})

Run begins syncing the status of VarmorPolicy & ArmorPolicy.

func (*StatusManager) Status

func (m *StatusManager) Status(c *gin.Context)

Status is the API interface which receives the status come from agents. The status is cached to a queue and then processed asynchronously.