common

Documentation

Index

• func AddContainerPort(ports *[]core.ContainerPort, port *core.ContainerPort)
• func AddPortToService(service *core.Service, port *core.ServicePort)
• func AddRuleToNetworkPolicy(policy *networking.NetworkPolicy, rule *networking.NetworkPolicyIngressRule)
• func AddVolumeMountToContainer(container *core.Container, volumeMount *core.VolumeMount)
• func AssertEquals(t *testing.T, expected interface{}, actual interface{})
• func AssertIsInOrder(t *testing.T, list []interface{}, before interface{}, after interface{})
• func AssertSliceContains(t *testing.T, haystack []interface{}, needle interface{})
• func FindIndex(haystack []interface{}, needle interface{}) (int, error)
• func FindString(haystack []string, needle string) (int, bool)
• func GetContainerByName(containers []core.Container, name string) *core.Container
• func GetRootLogger(devMode bool) *zap.Logger
• func HasPort(port string, ports []core.ServicePort) bool
• func IsInOrder(list []interface{}, before interface{}, after interface{}) bool
• func LabelsEqual(target map[string]string, source map[string]string) bool
• func LabelsUpdate(target *map[string]string, source map[string]string)
• func RemovePortFromContainer(container *core.Container, port *core.ContainerPort)
• func RemovePortFromService(service *core.Service, port *core.ServicePort)
• func RemoveRuleFromNetworkPolicy(policy *networking.NetworkPolicy, rule *networking.NetworkPolicyIngressRule)
• func RemoveVolumeFromDeployment(deployment *apps.Deployment, volume *core.Volume)
• func RemoveVolumeMountFromContainer(container *core.Container, volumeMount *core.VolumeMount)
• func SecretHasField(secret *core.Secret, field string) bool
• func SetVolume(volumes *[]core.Volume, volume *core.Volume)
• func SetVolumeInDeployment(deployment *apps.Deployment, volume *core.Volume)
• func SetVolumeMount(volumeMounts *[]core.VolumeMount, volumeMount *core.VolumeMount)
• type Name
  • func (s Name) Str() string
• type Namespace
  • func (s Namespace) Str() string
• type SupportedFeatures
• type TestSupport
  • func NewTestSupport(rootLog *zap.Logger, enabled bool) *TestSupport
  • func (this *TestSupport) GetMockCanMakeHTTPRequestToOperand(namespace string) bool
  • func (this *TestSupport) GetMockOperandMetricsReportReady(namespace string) bool
  • func (this *TestSupport) GetSupportedFeatures() *SupportedFeatures
  • func (this *TestSupport) IsEnabled() bool
  • func (this *TestSupport) ResetTimer(namespace string)
  • func (this *TestSupport) SetMockCanMakeHTTPRequestToOperand(namespace string, value bool)
  • func (this *TestSupport) SetMockOperandMetricsReportReady(namespace string, value bool)
  • func (this *TestSupport) SetSupportedFeatures(features *SupportedFeatures)
  • func (this *TestSupport) TimerDuration(namespace string) time.Duration

Functions

func AddContainerPort

func AddContainerPort(ports *[]core.ContainerPort, port *core.ContainerPort)

func AddPortToService

func AddPortToService(service *core.Service, port *core.ServicePort)

func AddRuleToNetworkPolicy

func AddRuleToNetworkPolicy(policy *networking.NetworkPolicy, rule *networking.NetworkPolicyIngressRule)

func AddVolumeMountToContainer

func AddVolumeMountToContainer(container *core.Container, volumeMount *core.VolumeMount)

func AssertEquals

func AssertEquals(t *testing.T, expected interface{}, actual interface{})

func AssertIsInOrder

func AssertIsInOrder(t *testing.T, list []interface{}, before interface{}, after interface{})

func AssertSliceContains

func AssertSliceContains(t *testing.T, haystack []interface{}, needle interface{})

func FindIndex

func FindIndex(haystack []interface{}, needle interface{}) (int, error)

func FindString

func FindString(haystack []string, needle string) (int, bool)

func GetContainerByName

func GetContainerByName(containers []core.Container, name string) *core.Container

func GetRootLogger

func GetRootLogger(devMode bool) *zap.Logger

func HasPort

func HasPort(port string, ports []core.ServicePort) bool

func IsInOrder

func IsInOrder(list []interface{}, before interface{}, after interface{}) bool

func LabelsEqual

func LabelsEqual(target map[string]string, source map[string]string) bool

Return *true* if, for given source labels, the target label values exist and have the same value

func LabelsUpdate

func LabelsUpdate(target *map[string]string, source map[string]string)

func RemovePortFromContainer

func RemovePortFromContainer(container *core.Container, port *core.ContainerPort)

func RemovePortFromService

func RemovePortFromService(service *core.Service, port *core.ServicePort)

func RemoveRuleFromNetworkPolicy

func RemoveRuleFromNetworkPolicy(policy *networking.NetworkPolicy, rule *networking.NetworkPolicyIngressRule)

func RemoveVolumeFromDeployment

func RemoveVolumeFromDeployment(deployment *apps.Deployment, volume *core.Volume)

func RemoveVolumeMountFromContainer

func RemoveVolumeMountFromContainer(container *core.Container, volumeMount *core.VolumeMount)

func SecretHasField

func SecretHasField(secret *core.Secret, field string) bool

func SetVolume

func SetVolume(volumes *[]core.Volume, volume *core.Volume)

func SetVolumeInDeployment

func SetVolumeInDeployment(deployment *apps.Deployment, volume *core.Volume)

TODO Refactor

func SetVolumeMount

func SetVolumeMount(volumeMounts *[]core.VolumeMount, volumeMount *core.VolumeMount)

Types

type Name

type Name string

func (Name) Str

func (s Name) Str() string

type Namespace

type Namespace string

func (Namespace) Str

func (s Namespace) Str() string

type SupportedFeatures

type SupportedFeatures struct {
	IsOCP               bool
	SupportsPDBv1       bool
	SupportsPDBv1beta1  bool
	PreferredPDBVersion string
	SupportsMonitoring  bool
}

type TestSupport

type TestSupport struct {
	// contains filtered or unexported fields
}

func NewTestSupport

func NewTestSupport(rootLog *zap.Logger, enabled bool) *TestSupport

func (*TestSupport) GetMockCanMakeHTTPRequestToOperand

func (this *TestSupport) GetMockCanMakeHTTPRequestToOperand(namespace string) bool

func (*TestSupport) GetMockOperandMetricsReportReady

func (this *TestSupport) GetMockOperandMetricsReportReady(namespace string) bool

func (*TestSupport) GetSupportedFeatures

func (this *TestSupport) GetSupportedFeatures() *SupportedFeatures

func (*TestSupport) IsEnabled

func (this *TestSupport) IsEnabled() bool

func (*TestSupport) ResetTimer

func (this *TestSupport) ResetTimer(namespace string)

func (*TestSupport) SetMockCanMakeHTTPRequestToOperand

func (this *TestSupport) SetMockCanMakeHTTPRequestToOperand(namespace string, value bool)

func (*TestSupport) SetMockOperandMetricsReportReady

func (this *TestSupport) SetMockOperandMetricsReportReady(namespace string, value bool)

func (*TestSupport) SetSupportedFeatures

func (this *TestSupport) SetSupportedFeatures(features *SupportedFeatures)

func (*TestSupport) TimerDuration

func (this *TestSupport) TimerDuration(namespace string) time.Duration