utils

func GenerateLeaseUpdatePeriod ¶ added in v0.9.2

func GenerateLeaseUpdatePeriod(kubeClient *kubernetes.Clientset) (time.Duration, time.Duration, time.Duration, error)

GenerateLeaseUpdatePeriod generates the lease update period based on the number of nodes in the cluster. The larger the cluster, the longer the lease update period to reduce the frequency of leader elections.

func GenerateStatusUpdateWindow ¶ added in v0.9.2

func GenerateStatusUpdateWindow(nodeCount int) time.Duration

GenerateStatusUpdateWindow generates status update batch window based on number of nodes in the cluster. This is used to throttle status updates in large clusters to reduce API server load. The larger the cluster, the longer the batch window to collect more status updates before processing.

func GetToken ¶ added in v0.5.6

func GetToken() string

func GinLogger ¶ added in v0.5.7

func GinLogger() gin.HandlerFunc

func HTTPPostAndGetResponseWithRetry ¶ added in v0.8.1

func HTTPPostAndGetResponseWithRetry(address string, path string, reqBody []byte) ([]byte, error)

func HTTPSPostWithRetryAndToken ¶ added in v0.8.1

func HTTPSPostWithRetryAndToken(address string, path string, reqBody []byte, inContainer bool) error

func InNetworksArray ¶ added in v0.8.0

func InNetworksArray(i varmor.NetworkContent, array []varmor.NetworkContent) bool

func InPortRangeArray ¶ added in v0.8.0

func InPortRangeArray(i varmor.Port, array []varmor.Port) bool

func InStringArray ¶

func InStringArray(c string, array []string) bool

func InUint16Array ¶ added in v0.8.0

func InUint16Array(i uint16, array []uint16) bool

func InUint32Array ¶

func InUint32Array(i uint32, array []uint32) bool

func InitAndStartTokenRotation ¶ added in v0.5.6

func InitAndStartTokenRotation(interval time.Duration, logger logr.Logger)

InitAndStartTokenRotation initializes and starts the token rotation. The token is used for authenticating with the manager.

func IsAppArmorGA ¶ added in v0.6.0

func IsAppArmorGA(versionInfo *version.Info) (bool, error)

func IsRequestSizeError ¶ added in v0.7.0

func IsRequestSizeError(err error) bool

func RemoveArmorProfileFinalizers ¶ added in v0.6.0

func RemoveArmorProfileFinalizers(i varmorinterface.CrdV1beta1Interface, namespace, name string) error

func TagLeaderPod ¶

func TagLeaderPod(podInterface corev1.PodInterface, name string) error

func UnTagLeaderPod ¶

func UnTagLeaderPod(podInterface corev1.PodInterface) error