util

Documentation

Index

• func AmRunningInCluster() bool
• func AmRunningInTest() bool
• func CheckJenkinsReady(service *corev1.Service, masterPort int32) error
• func GetNodePort(servicePorts []corev1.ServicePort, portName string) int32
• func GetServiceEndpoint(service *corev1.Service, path string, internalPort int32) (string, error)
• func MergeData(ms ...map[string]string) map[string]string
• func NewPredicate(namespaces string) predicate.Predicate
• func SafeRestartJenkins(service *corev1.Service, adminSecret *corev1.Secret, masterPort int32) error
• type NamespacedResourceVersionChangedPredicate
  • func (n NamespacedResourceVersionChangedPredicate) Create(event event.CreateEvent) bool
  • func (n NamespacedResourceVersionChangedPredicate) Delete(event event.DeleteEvent) bool
  • func (n NamespacedResourceVersionChangedPredicate) Generic(event event.GenericEvent) bool
  • func (n NamespacedResourceVersionChangedPredicate) Update(event event.UpdateEvent) bool

Functions

func AmRunningInCluster

func AmRunningInCluster() bool

AmRunningInCluster returns true if this binary is running in kubernetes cluster

func AmRunningInTest

func AmRunningInTest() bool

AmRunningInTest returns true if this binary is running under ginkgo

func CheckJenkinsReady

func CheckJenkinsReady(service *corev1.Service, masterPort int32) error

check if jenkins is ready

func GetNodePort

func GetNodePort(servicePorts []corev1.ServicePort, portName string) int32

GetNodePort retrieves node port number of a specified kubernetes service

func GetServiceEndpoint

func GetServiceEndpoint(service *corev1.Service, path string, internalPort int32) (string, error)

gets the correct endpoint for a given service based on whether code is running in cluster or not

func MergeData

func MergeData(ms ...map[string]string) map[string]string

MergeSecretData merges secret Data map

func NewPredicate

func NewPredicate(namespaces string) predicate.Predicate

newPredicate creates a namespace-based predicate for the Watch functions or returns a default one if no namespace was specified

func SafeRestartJenkins

func SafeRestartJenkins(service *corev1.Service, adminSecret *corev1.Secret, masterPort int32) error

SafeRestartJenkins does a safe jenkins restart

Types

type NamespacedResourceVersionChangedPredicate

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

func (NamespacedResourceVersionChangedPredicate) Create

func (n NamespacedResourceVersionChangedPredicate) Create(event event.CreateEvent) bool

func (NamespacedResourceVersionChangedPredicate) Delete

func (n NamespacedResourceVersionChangedPredicate) Delete(event event.DeleteEvent) bool

func (NamespacedResourceVersionChangedPredicate) Generic

func (n NamespacedResourceVersionChangedPredicate) Generic(event event.GenericEvent) bool

func (NamespacedResourceVersionChangedPredicate) Update

func (n NamespacedResourceVersionChangedPredicate) Update(event event.UpdateEvent) bool