utils

Documentation

Index

• Constants
• Variables
• func CeilDivision(x, y int) int
• func CopyMap(original map[string]string) map[string]string
• func DeconstructIPsFromPrefix(prefix string) ([]string, error)
• func Difference[T comparable](a, b []T) (diff []T)
• func GetKeyValSlice(m map[string]string) (key []string, val []string)
• func IntPower(n, m int) int
• func IsNitroInstance(instanceType string) (bool, error)
• func MaxOf[T constraints.Ordered](vars ...T) T
• func Maximum[T constraints.Ordered](a, b T) T
• func MinOf[T constraints.Ordered](vars ...T) T
• func Minimum[T constraints.Ordered](a, b T) T
• func NewRateLimitedClient(qps int, burst int) (*http.Client, error)
• func RemoveDuplicatedSg(list []string) []string
• func SendNodeEventWithNodeName(client k8s.K8sWrapper, nodeName, reason, msg, eventType string, ...)
• func SendNodeEventWithNodeObject(client k8s.K8sWrapper, node *v1.Node, reason, msg, eventType string, ...)
• func ShouldRetryOnError(err error) bool
• type SecurityGroupForPods
  • func (s *SecurityGroupForPods) GetMatchingSecurityGroupForPods(pod *corev1.Pod) ([]string, error)
• type SecurityGroupForPodsAPI
  • func NewSecurityGroupForPodsAPI(client client.Client, log logr.Logger) SecurityGroupForPodsAPI

Constants

const (
	UnsupportedInstanceTypeReason       = "Unsupported"
	InsufficientCidrBlocksReason        = "InsufficientCidrBlocks"
	CNINodeCreatedReason                = "CNINodeCreation"
	NodeTrunkInitiatedReason            = "NodeTrunkInitiated"
	NodeTrunkFailedInitializationReason = "NodeTrunkFailedInit"
	EniConfigNameNotFoundReason         = "EniConfigNameNotFound"
)

Variables

var (
	ErrNotFound                   = errors.New("resource was not found")
	ErrInsufficientCidrBlocks     = errors.New("InsufficientCidrBlocks: The specified subnet does not have enough free cidr blocks to satisfy the request")
	ErrMsgProviderAndPoolNotFound = "cannot find the instance provider and pool from the cache"
	NotRetryErrors                = []string{InsufficientCidrBlocksReason}
)

Functions

func CeilDivision

func CeilDivision(x, y int) int

CeilDivision returns the ceiling result of numerator x divided by denominator y. y should be non-zero

func CopyMap

func CopyMap(original map[string]string) map[string]string

func DeconstructIPsFromPrefix

func DeconstructIPsFromPrefix(prefix string) ([]string, error)

DeconstructIPsFromPrefix deconstructs a IPv4 prefix into a list of /32 IPv4 addresses

func Difference

func Difference[T comparable](a, b []T) (diff []T)

Difference returns a-b, elements present in a and not in b

func GetKeyValSlice

func GetKeyValSlice(m map[string]string) (key []string, val []string)

func IntPower

func IntPower(n, m int) int

IntPower calculates n to the mth power. m should be a non-negative power to have an int return value

func IsNitroInstance

func IsNitroInstance(instanceType string) (bool, error)

func MaxOf

func MaxOf[T constraints.Ordered](vars ...T) T

func Maximum

func Maximum[T constraints.Ordered](a, b T) T

func MinOf

func MinOf[T constraints.Ordered](vars ...T) T

func Minimum

func Minimum[T constraints.Ordered](a, b T) T

func NewRateLimitedClient

func NewRateLimitedClient(qps int, burst int) (*http.Client, error)

NewRateLimitedClient returns a new HTTP client with rate limiter.

func RemoveDuplicatedSg

func RemoveDuplicatedSg(list []string) []string

RemoveDuplicatedSg removes duplicated items from a string slice. It returns a no duplicates string slice.

func SendNodeEventWithNodeName

func SendNodeEventWithNodeName(client k8s.K8sWrapper, nodeName, reason, msg, eventType string, logger logr.Logger)

func SendNodeEventWithNodeObject

func SendNodeEventWithNodeObject(client k8s.K8sWrapper, node *v1.Node, reason, msg, eventType string, logger logr.Logger)

func ShouldRetryOnError

func ShouldRetryOnError(err error) bool

ShouldRetryOnError returns true if the error is retryable, else returns false

Types

type SecurityGroupForPods

type SecurityGroupForPods struct {
	Client client.Client
	Log    logr.Logger
}

func (*SecurityGroupForPods) GetMatchingSecurityGroupForPods

func (s *SecurityGroupForPods) GetMatchingSecurityGroupForPods(pod *corev1.Pod) ([]string, error)

GetMatchingSecurityGroupForPods returns the list of security groups that should be associated with the Pod by matching against all the SecurityGroupPolicy

type SecurityGroupForPodsAPI

type SecurityGroupForPodsAPI interface {
	GetMatchingSecurityGroupForPods(pod *corev1.Pod) ([]string, error)
}

func NewSecurityGroupForPodsAPI

func NewSecurityGroupForPodsAPI(client client.Client, log logr.Logger) SecurityGroupForPodsAPI

NewSecurityGroupForPodsAPI returns the SecurityGroupForPod APIs for common operations on objects Using Security Group Policy