Documentation ¶
Index ¶
- Constants
- Variables
- func ClusterRoleBindingYaml(user string) string
- func ClusterRoleYaml(user string) string
- func CompletePromote(p *v1.PromoteActivityStep) error
- func CompletePromotionPullRequest(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, ...) error
- func CompletePromotionUpdate(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, ...) error
- func CreateClient(kubeconfig *string) (*kubernetes.Clientset, error)
- func CreateEnvironmentSurvey(out io.Writer, batchMode bool, authConfigSvc auth.AuthConfigService, ...) (gits.GitProvider, error)
- func CreateServiceLink(client *kubernetes.Clientset, ...) error
- func CurrentContext(config *api.Config) *api.Context
- func CurrentNamespace(config *api.Config) string
- func CurrentServer(config *api.Config) string
- func DeleteJob(client *kubernetes.Clientset, namespace, name string) error
- func DeploymentPodCount(client *kubernetes.Clientset, name, namespace string) (int, error)
- func EnableInsecureRegistry(iqJson string, dockerRegistry string) (string, error)
- func EnsureDevEnvironmentSetup(jxClient *versioned.Clientset, ns string) (*v1.Environment, error)
- func EnsureEnvironmentNamespaceSetup(kubeClient *kubernetes.Clientset, jxClient *versioned.Clientset, ...) error
- func EnsureGitServiceExistsForHost(jxClient *versioned.Clientset, devNs string, kind string, name string, ...) error
- func EnsureNamespaceCreated(kubeClient *kubernetes.Clientset, name string, labels map[string]string, ...) error
- func FailedPromote(p *v1.PromoteActivityStep) error
- func FailedPromotionPullRequest(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, ...) error
- func FailedPromotionUpdate(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, ...) error
- func FindServiceURL(client *kubernetes.Clientset, namespace string, name string) (string, error)
- func GetAppName(name string, namespaces ...string) string
- func GetCommitSha(r *metav1.ObjectMeta) string
- func GetCommitURL(r *metav1.ObjectMeta) string
- func GetConfigmapData(client *kubernetes.Clientset, name, ns string) (map[string]string, error)
- func GetCurrentDomain(client *kubernetes.Clientset, ns string) (string, error)
- func GetDeploymentNames(client *kubernetes.Clientset, ns string, filter string) ([]string, error)
- func GetDeploymentPods(client *kubernetes.Clientset, name, namespace string) ([]v1.Pod, error)
- func GetDeployments(kubeClient *kubernetes.Clientset, ns string) (map[string]v1beta1.Deployment, error)
- func GetDevNamespace(kubeClient *kubernetes.Clientset, ns string) (string, string, error)
- func GetDevPodNames(client *kubernetes.Clientset, ns string, username string) ([]string, map[string]*v1.Pod, error)
- func GetEnvironmentNames(jxClient *versioned.Clientset, ns string) ([]string, error)
- func GetEnvironmentNamespace(jxClient *versioned.Clientset, ns, environment string) (string, error)
- func GetEnvironments(jxClient *versioned.Clientset, ns string) (map[string]*v1.Environment, []string, error)
- func GetGitServiceKind(jxClient *versioned.Clientset, kubeClient *kubernetes.Clientset, devNs string, ...) (string, error)
- func GetGitServiceKindFromConfigMap(cm *corev1.ConfigMap, gitServiceUrl string) string
- func GetIngress(client *kubernetes.Clientset, ns, name string) (string, error)
- func GetName(r *metav1.ObjectMeta) string
- func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition)
- func GetPodMetrics(client *metricsclient.Clientset, ns string) (*metricsv1beta1.PodMetricsList, error)
- func GetPodNames(client *kubernetes.Clientset, ns string, filter string) ([]string, error)
- func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition
- func GetPodVersion(pod *corev1.Pod, appName string) string
- func GetReadyPodNames(client *kubernetes.Clientset, ns string, filter string) ([]string, error)
- func GetServiceNames(client *kubernetes.Clientset, ns string, filter string) ([]string, error)
- func GetServiceURL(svc *v1.Service) string
- func GetServiceURLFromMap(services map[string]*v1.Service, name string) string
- func GetServiceURLFromName(c *kubernetes.Clientset, name, ns string) (string, error)
- func GetServices(client *kubernetes.Clientset, ns string) (map[string]*v1.Service, error)
- func GetTeamExposecontrollerConfig(kubeClient *kubernetes.Clientset, ns string) (map[string]string, error)
- func GetVersion(r *metav1.ObjectMeta) string
- func HasExternalAddress(svc *v1.Service) bool
- func IsDeploymentRunning(client *kubernetes.Clientset, name, namespace string) (bool, error)
- func IsJobSucceeded(job *batchv1.Job) bool
- func IsPodReady(pod *v1.Pod) bool
- func IsPodReadyConditionTrue(status v1.PodStatus) bool
- func IsServicePresent(c *kubernetes.Clientset, name, ns string) (bool, error)
- func LoadConfig() (*api.Config, *clientcmd.PathOptions, error)
- func MergeMaps(maps ...map[string]string) map[string]string
- func PickEnvironment(envNames []string, defaultEnv string) (string, error)
- func PodRequestsAndLimits(pod *v1.Pod) (reqs map[v1.ResourceName]resource.Quantity, ...)
- func PodStatus(pod *v1.Pod) string
- func RegisterEnvironmentCRD(apiClient *apiextensionsclientset.Clientset) error
- func RegisterGitServiceCRD(apiClient *apiextensionsclientset.Clientset) error
- func RegisterPipelineActivityCRD(apiClient *apiextensionsclientset.Clientset) error
- func RegisterReleaseCRD(apiClient *apiextensionsclientset.Clientset) error
- func RoleBindingKubeSystemYaml(user string) string
- func RoleBindings(client *kubernetes.Clientset, namespace string) (string, error)
- func RoleKubeSystemYaml(user string) string
- func Server(config *api.Config, context *api.Context) string
- func SortEnvironments(environments []v1.Environment)
- func SortListWatchByName(listWatch *cache.ListWatch)
- func SortRuntimeObjectsByName(objects []runtime.Object)
- func StartPromote(p *v1.PromoteActivityStep) error
- func StartPromotionPullRequest(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, ...) error
- func StartPromotionUpdate(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, ...) error
- func ToValidName(name string) string
- func ToValidNameWithDots(name string) string
- func UpdateJenkinsGitServers(cm *corev1.ConfigMap, server *auth.AuthServer, userAuth *auth.UserAuth, ...) (bool, error)
- func ValidNameOption(option string, value string) error
- func ValidSubDomainOption(option string, value string) error
- func ValidateEnvironmentDoesNotExist(jxClient *versioned.Clientset, ns string, str string) error
- func ValidateName(val interface{}) error
- func ValidateSubDomain(val interface{}) error
- func WaitForAllDeploymentsToBeReady(client *kubernetes.Clientset, namespace string, timeoutPerDeploy time.Duration) error
- func WaitForDeploymentToBeReady(client *kubernetes.Clientset, name, namespace string, timeout time.Duration) error
- func WaitForExternalIP(client *kubernetes.Clientset, name, namespace string, timeout time.Duration) error
- func WaitForJobToSucceeded(client *kubernetes.Clientset, namespace, jobName string, timeout time.Duration) error
- func WaitForPodNameToBeReady(client *kubernetes.Clientset, namespace string, name string, ...) error
- func WaitForPodToBeReady(client *kubernetes.Clientset, selector labels.Selector, namespace string, ...) error
- type ByName
- type ByOrder
- type ClusterStatus
- func (clusterStatus *ClusterStatus) AverageCpuPercent() int
- func (clusterStatus *ClusterStatus) AverageMemPercent() int
- func (clusterStatus *ClusterStatus) CheckResource() string
- func (clusterStatus *ClusterStatus) Info() string
- func (clusterStatus *ClusterStatus) MinimumResourceLimit() int
- func (clusterStatus *ClusterStatus) NodeCount() int
- type HeapterConfig
- type NodeStatus
- type PipelineActivityKey
- type PromotePullRequestFn
- type PromoteStepActivityKey
- func (k *PromoteStepActivityKey) GetOrCreatePromote(activities typev1.PipelineActivityInterface) (*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, bool, ...)
- func (k *PromoteStepActivityKey) GetOrCreatePromotePullRequest(activities typev1.PipelineActivityInterface) (*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, ...)
- func (k *PromoteStepActivityKey) GetOrCreatePromoteUpdate(activities typev1.PipelineActivityInterface) (*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, ...)
- func (k *PromoteStepActivityKey) OnPromotePullRequest(activities typev1.PipelineActivityInterface, fn PromotePullRequestFn) error
- func (k *PromoteStepActivityKey) OnPromoteUpdate(activities typev1.PipelineActivityInterface, fn PromoteUpdateFn) error
- type PromoteUpdateFn
- type ServiceURL
Constants ¶
const ( // ChartAmbassador the default chart for ambassador ChartAmbassador = "datawire/ambassador" // ChartAnchore the default chart for the Anchore plugin ChartAnchore = "stable/anchore-engine" // ChartCDX the default name of the CDX chart ChartCDX = "jenkins-x/cdx" // ChartGitea the default name of the gitea chart ChartGitea = "jenkins-x/gitea" // ChartKubeless the default chart for kubeless ChartKubeless = "incubator/kubeless" // ServiceJenkins is the name of the Jenkins Service ServiceJenkins = "jenkins" // SeriviceCDX the service name of the Helm Chart Museum service ServiceCDX = "cdx-cdx" // ServiceChartMuseum the service name of the Helm Chart Museum service ServiceChartMuseum = "jenkins-x-chartmuseum" // ServiceKubernetesDashboard the kubernetes dashboard ServiceKubernetesDashboard = "jenkins-x-kubernetes-dashboard" // SecretJenkinsGitCredentials the git credentials secret SecretJenkinsGitCredentials = "jenkins-git-credentials" // SecretJenkinsPipelineAddonCredentials the chat credentials secret SecretJenkinsPipelineAddonCredentials = "jx-pipeline-addon-" // SecretJenkinsPipelineChatCredentials the chat credentials secret SecretJenkinsPipelineChatCredentials = "jx-pipeline-chat-" // SecretJenkinsPipelineGitCredentials the git credentials secret SecretJenkinsPipelineGitCredentials = "jx-pipeline-git-" // SecretJenkinsPipelineIssueCredentials the issue tracker credentials secret SecretJenkinsPipelineIssueCredentials = "jx-pipeline-issues-" // ConfigMapJenkinsXGitKinds the name of the ConfigMap in the development namespace that maps kinds to URLs ConfigMapJenkinsXGitKinds = "jenkins-x-git-kinds" // ConfigMapJenkinsX the name of the ConfigMap with the Jenkins configuration ConfigMapJenkinsX = "jenkins" // ConfigMapJenkinsPodTemplates is the ConfigMap containing all the Pod Templates available ConfigMapJenkinsPodTemplates = "jenkins-x-pod-templates" // LocalHelmRepoName is the default name of the local chart repository where CI/CD releases go to LocalHelmRepoName = "releases" DefaultEnvironmentGitRepoURL = "https://github.com/jenkins-x/default-environment-charts.git" // LabelKind to indicate the kind of auth, such as Git or Issue LabelKind = "jenkins.io/kind" // ValueKindAddon an addon auth secret/credentials ValueKindAddon = "addon" // ValueKindChat a chat auth secret/credentials ValueKindChat = "chat" // ValueKindGit a git auth secret/credentials ValueKindGit = "git" // ValueKindIssue an issue auth secret/credentials ValueKindIssue = "issue" // ValueKindCVE an addon auth secret/credentials ValueKindCVE = "cve" // LabelServiceKind the label to indicate the auto Server's Kind LabelServiceKind = "jenkins.io/service-kind" // LabelCreatedBy indicates the service that created this resource LabelCreatedBy = "jenkins.io/created-by" // LabelPodTemplate the name of the pod template for a DevPod LabelPodTemplate = "jenkins.io/pod_template" // LabelDevPodName the name of a dev pod LabelDevPodName = "jenkins.io/devpod" // LabelDevPodUsername the user name owner of the DeVPod LabelDevPodUsername = "jenkins.io/devpod_user" // ValueCreatedByJX for resources created by the Jenkins X CLI ValueCreatedByJX = "jx" // LabelCredentialsType the kind of jenkins credential for a secret LabelCredentialsType = "jenkins.io/credentials-type" // ValueCredentialTypeUsernamePassword for user password credential secrets ValueCredentialTypeUsernamePassword = "usernamePassword" // AnnotationURL indicates a service/server's URL AnnotationURL = "jenkins.io/url" // AnnotationExpose used to expose service using exposecontroller AnnotationExpose = "fabric8.io/expose" // AnnotationName indicates a service/server's textual name (can be mixed case, contain spaces unlike kubernetes resources) AnnotationName = "jenkins.io/name" // AnnotationCredentialsDescription the description text for a Credentian on a Secret AnnotationCredentialsDescription = "jenkins.io/credentials-description" // SecretDataUsername the username in a Secret/Credentials SecretDataUsername = "username" // SecretDataPassword the password in a Secret/Credentials SecretDataPassword = "password" )
const ( LabelValueDevEnvironment = "dev" LabelTeam = "team" LabelEnvironment = "env" )
const ( OptionName = "name" OptionNamespace = "namespace" )
const (
DefaultNamespace = "jx"
)
const (
ExposeURLAnnotation = "fabric8.io/exposeUrl"
)
const (
Exposecontroller = "exposecontroller"
)
Variables ¶
var ( AddonCharts = map[string]string{ "ambassador": ChartAmbassador, "anchore": ChartAnchore, "cdx": ChartCDX, "gitea": ChartGitea, "kubeless": ChartKubeless, "prometheus": "stable/prometheus", "grafana": "stable/grafana", } )
Functions ¶
func ClusterRoleBindingYaml ¶
func ClusterRoleYaml ¶
func CompletePromote ¶
func CompletePromote(p *v1.PromoteActivityStep) error
func CompletePromotionPullRequest ¶
func CompletePromotionPullRequest(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, p *v1.PromotePullRequestStep) error
func CompletePromotionUpdate ¶
func CompletePromotionUpdate(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, p *v1.PromoteUpdateStep) error
func CreateClient ¶
func CreateClient(kubeconfig *string) (*kubernetes.Clientset, error)
CreateClient creates a new kubernetes client
func CreateEnvironmentSurvey ¶
func CreateEnvironmentSurvey(out io.Writer, batchMode bool, authConfigSvc auth.AuthConfigService, devEnv *v1.Environment, data *v1.Environment, config *v1.Environment, forkEnvGitURL string, ns string, jxClient *versioned.Clientset, kubeClient *kubernetes.Clientset, envDir string, gitRepoOptions *gits.GitRepositoryOptions, helmValues config.HelmValuesConfig, prefix string) (gits.GitProvider, error)
CreateEnvironmentSurvey creates a Survey on the given environment using the default options from the CLI
func CreateServiceLink ¶
func CreateServiceLink(client *kubernetes.Clientset, currentNamespace, targetNamespace, serviceName string) error
func CurrentContext ¶
CurrentContext returns the current context
func CurrentNamespace ¶
CurrentNamespace returns the current namespace in the context
func CurrentServer ¶
CurrentServer returns the current context's server
func DeploymentPodCount ¶
func DeploymentPodCount(client *kubernetes.Clientset, name, namespace string) (int, error)
func EnableInsecureRegistry ¶
EnableInsecureRegistry appends the Docker Registry
func EnsureDevEnvironmentSetup ¶
EnsureDevEnvironmentSetup ensures that the Environment is created in the given namespace
func EnsureEnvironmentNamespaceSetup ¶
func EnsureEnvironmentNamespaceSetup(kubeClient *kubernetes.Clientset, jxClient *versioned.Clientset, env *v1.Environment, ns string) error
func EnsureGitServiceExistsForHost ¶
func EnsureGitServiceExistsForHost(jxClient *versioned.Clientset, devNs string, kind string, name string, gitUrl string, out io.Writer) error
EnsureGitServiceExistsForHost ensures that there is a GitService CRD for the given host and kind
func EnsureNamespaceCreated ¶
func EnsureNamespaceCreated(kubeClient *kubernetes.Clientset, name string, labels map[string]string, annotations map[string]string) error
Ensure that the namespace exists for the given name
func FailedPromote ¶
func FailedPromote(p *v1.PromoteActivityStep) error
func FailedPromotionPullRequest ¶
func FailedPromotionPullRequest(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, p *v1.PromotePullRequestStep) error
func FailedPromotionUpdate ¶
func FailedPromotionUpdate(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, p *v1.PromoteUpdateStep) error
func FindServiceURL ¶
func GetAppName ¶
GetAppName returns the app name
func GetCommitSha ¶
func GetCommitSha(r *metav1.ObjectMeta) string
GetCommitSha returns the git commit sha
func GetCommitURL ¶
func GetCommitURL(r *metav1.ObjectMeta) string
GetCommitURL returns the git commit URL
func GetConfigmapData ¶
func GetCurrentDomain ¶
func GetCurrentDomain(client *kubernetes.Clientset, ns string) (string, error)
func GetDeploymentNames ¶
func GetDeploymentPods ¶
func GetDeployments ¶
func GetDeployments(kubeClient *kubernetes.Clientset, ns string) (map[string]v1beta1.Deployment, error)
func GetDevNamespace ¶
GetDevNamespace returns the developer environment namespace which is the namespace that contains the Environments and the developer tools like Jenkins
func GetDevPodNames ¶
func GetDevPodNames(client *kubernetes.Clientset, ns string, username string) ([]string, map[string]*v1.Pod, error)
GetDevPodNames returns the users dev pod names
func GetEnvironmentNames ¶
GetEnvironmentNames returns the sorted list of environment names
func GetEnvironmentNamespace ¶
GetEnvironments returns the namespace name for a given environment
func GetEnvironments ¶
func GetEnvironments(jxClient *versioned.Clientset, ns string) (map[string]*v1.Environment, []string, error)
GetEnvironments returns a map of the enviroments along with a sorted list of names
func GetGitServiceKind ¶
func GetGitServiceKind(jxClient *versioned.Clientset, kubeClient *kubernetes.Clientset, devNs string, gitServiceUrl string) (string, error)
GetGitServiceKind returns the kind of the given host if one can be found or ""
func GetIngress ¶
func GetIngress(client *kubernetes.Clientset, ns, name string) (string, error)
func GetPodCondition ¶
func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition)
credit https://github.com/kubernetes/kubernetes/blob/8719b4a/pkg/api/v1/pod/util.go GetPodCondition extracts the provided condition from the given status and returns that. Returns nil and -1 if the condition is not present, and the index of the located condition.
func GetPodMetrics ¶
func GetPodMetrics(client *metricsclient.Clientset, ns string) (*metricsv1beta1.PodMetricsList, error)
func GetPodNames ¶
func GetPodReadyCondition ¶
func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition
credit https://github.com/kubernetes/kubernetes/blob/8719b4a/pkg/api/v1/pod/util.go Extracts the pod ready condition from the given status and returns that. Returns nil if the condition is not present.
func GetPodVersion ¶
GetPodVersion returns the version for the given app name
func GetReadyPodNames ¶
func GetServiceNames ¶
func GetServiceURL ¶
func GetServiceURLFromMap ¶
func GetServiceURLFromName ¶
func GetServiceURLFromName(c *kubernetes.Clientset, name, ns string) (string, error)
func GetServices ¶
func GetVersion ¶
func GetVersion(r *metav1.ObjectMeta) string
GetVersion returns the version from the labels on the deployment if it can be deduced
func HasExternalAddress ¶
func IsDeploymentRunning ¶
func IsDeploymentRunning(client *kubernetes.Clientset, name, namespace string) (bool, error)
func IsJobSucceeded ¶
func IsPodReady ¶
credit https://github.com/kubernetes/kubernetes/blob/8719b4a/pkg/api/v1/pod/util.go IsPodReady returns true if a pod is ready; false otherwise.
func IsPodReadyConditionTrue ¶
credit https://github.com/kubernetes/kubernetes/blob/8719b4a/pkg/api/v1/pod/util.go IsPodReady retruns true if a pod is ready; false otherwise.
func IsServicePresent ¶
func IsServicePresent(c *kubernetes.Clientset, name, ns string) (bool, error)
func LoadConfig ¶
func LoadConfig() (*api.Config, *clientcmd.PathOptions, error)
LoadConfig loads the kubernetes configuration
func MergeMaps ¶
MergeMaps merges all the maps together with the entries in the last map overwriting any earlier values
so if you want to add some annotations to a resource you can do resource.Annotations = kube.MergeMaps(resource.Annotations, myAnnotations)
func PodRequestsAndLimits ¶
func PodRequestsAndLimits(pod *v1.Pod) (reqs map[v1.ResourceName]resource.Quantity, limits map[v1.ResourceName]resource.Quantity)
func RegisterEnvironmentCRD ¶
func RegisterEnvironmentCRD(apiClient *apiextensionsclientset.Clientset) error
RegisterEnvironmentCRD ensures that the CRD is registered for Environments
func RegisterGitServiceCRD ¶
func RegisterGitServiceCRD(apiClient *apiextensionsclientset.Clientset) error
RegisterGitServiceCRD ensures that the CRD is registered for GitServices
func RegisterPipelineActivityCRD ¶
func RegisterPipelineActivityCRD(apiClient *apiextensionsclientset.Clientset) error
RegisterPipelineActivityCRD ensures that the CRD is registered for PipelineActivity
func RegisterReleaseCRD ¶
func RegisterReleaseCRD(apiClient *apiextensionsclientset.Clientset) error
RegisterReleaseCRD ensures that the CRD is registered for Release
func RoleBindings ¶
func RoleBindings(client *kubernetes.Clientset, namespace string) (string, error)
func RoleKubeSystemYaml ¶
func SortEnvironments ¶
func SortEnvironments(environments []v1.Environment)
func SortListWatchByName ¶
func StartPromote ¶
func StartPromote(p *v1.PromoteActivityStep) error
func StartPromotionPullRequest ¶
func StartPromotionPullRequest(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, p *v1.PromotePullRequestStep) error
func StartPromotionUpdate ¶
func StartPromotionUpdate(a *v1.PipelineActivity, s *v1.PipelineActivityStep, ps *v1.PromoteActivityStep, p *v1.PromoteUpdateStep) error
func ToValidName ¶
ToValidName converts the given string into a valid kubernetes resource name
func ToValidNameWithDots ¶
ToValidNameWithDots converts the given string into a valid kubernetes resource name
func UpdateJenkinsGitServers ¶
func UpdateJenkinsGitServers(cm *corev1.ConfigMap, server *auth.AuthServer, userAuth *auth.UserAuth, credentials string) (bool, error)
UpdateJenkinsGitServers update the Jenkins ConfigMap with any missing git server configurations for the given server and token
func ValidNameOption ¶
func ValidSubDomainOption ¶
func ValidateName ¶
func ValidateName(val interface{}) error
func ValidateSubDomain ¶
func ValidateSubDomain(val interface{}) error
func WaitForDeploymentToBeReady ¶
func WaitForDeploymentToBeReady(client *kubernetes.Clientset, name, namespace string, timeout time.Duration) error
waits for the pods of a deployment to become ready
func WaitForExternalIP ¶
func WaitForExternalIP(client *kubernetes.Clientset, name, namespace string, timeout time.Duration) error
waits for the pods of a deployment to become ready
func WaitForJobToSucceeded ¶
func WaitForJobToSucceeded(client *kubernetes.Clientset, namespace, jobName string, timeout time.Duration) error
waits for the job to complete
func WaitForPodNameToBeReady ¶
func WaitForPodNameToBeReady(client *kubernetes.Clientset, namespace string, name string, timeout time.Duration) error
waits for the pod to become ready using the pod name
func WaitForPodToBeReady ¶
func WaitForPodToBeReady(client *kubernetes.Clientset, selector labels.Selector, namespace string, timeout time.Duration) error
waits for the pod to become ready using label selector to match the pod
Types ¶
type ByOrder ¶
type ByOrder []v1.Environment
type ClusterStatus ¶
type ClusterStatus struct { Name string // contains filtered or unexported fields }
func GetClusterStatus ¶
func GetClusterStatus(client *kubernetes.Clientset, namespace string) (ClusterStatus, error)
func (*ClusterStatus) AverageCpuPercent ¶
func (clusterStatus *ClusterStatus) AverageCpuPercent() int
func (*ClusterStatus) AverageMemPercent ¶
func (clusterStatus *ClusterStatus) AverageMemPercent() int
func (*ClusterStatus) CheckResource ¶
func (clusterStatus *ClusterStatus) CheckResource() string
func (*ClusterStatus) Info ¶
func (clusterStatus *ClusterStatus) Info() string
func (*ClusterStatus) MinimumResourceLimit ¶
func (clusterStatus *ClusterStatus) MinimumResourceLimit() int
func (*ClusterStatus) NodeCount ¶
func (clusterStatus *ClusterStatus) NodeCount() int
type HeapterConfig ¶
type NodeStatus ¶
type NodeStatus struct { Name string AllocatedMemory *resource.Quantity AllocatedCPU *resource.Quantity CpuReqs resource.Quantity CpuLimits resource.Quantity MemReqs resource.Quantity MemLimits resource.Quantity // contains filtered or unexported fields }
func Status ¶
func Status(client *kubernetes.Clientset, namespace string, node v1.Node) (NodeStatus, error)
type PipelineActivityKey ¶
type PipelineActivityKey struct { Name string Pipeline string Build string BuildURL string BuildLogsURL string ReleaseNotesURL string GitInfo *gits.GitRepositoryInfo }
func (*PipelineActivityKey) GetOrCreate ¶
func (k *PipelineActivityKey) GetOrCreate(activities typev1.PipelineActivityInterface) (*v1.PipelineActivity, error)
GetOrCreate gets or creates the pipeline activity
func (*PipelineActivityKey) IsValid ¶
func (k *PipelineActivityKey) IsValid() bool
type PromotePullRequestFn ¶
type PromotePullRequestFn func(*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, *v1.PromotePullRequestStep) error
type PromoteStepActivityKey ¶
type PromoteStepActivityKey struct { PipelineActivityKey Environment string ApplicationURL string }
func (*PromoteStepActivityKey) GetOrCreatePromote ¶
func (k *PromoteStepActivityKey) GetOrCreatePromote(activities typev1.PipelineActivityInterface) (*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, bool, error)
GetOrCreatePromote gets or creates the Promote step for the key
func (*PromoteStepActivityKey) GetOrCreatePromotePullRequest ¶
func (k *PromoteStepActivityKey) GetOrCreatePromotePullRequest(activities typev1.PipelineActivityInterface) (*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, *v1.PromotePullRequestStep, bool, error)
GetOrCreatePromotePullRequest gets or creates the PromotePullRequest for the key
func (*PromoteStepActivityKey) GetOrCreatePromoteUpdate ¶
func (k *PromoteStepActivityKey) GetOrCreatePromoteUpdate(activities typev1.PipelineActivityInterface) (*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, *v1.PromoteUpdateStep, bool, error)
GetOrCreatePromoteUpdate gets or creates the Promote for the key
func (*PromoteStepActivityKey) OnPromotePullRequest ¶
func (k *PromoteStepActivityKey) OnPromotePullRequest(activities typev1.PipelineActivityInterface, fn PromotePullRequestFn) error
func (*PromoteStepActivityKey) OnPromoteUpdate ¶
func (k *PromoteStepActivityKey) OnPromoteUpdate(activities typev1.PipelineActivityInterface, fn PromoteUpdateFn) error
type PromoteUpdateFn ¶
type PromoteUpdateFn func(*v1.PipelineActivity, *v1.PipelineActivityStep, *v1.PromoteActivityStep, *v1.PromoteUpdateStep) error
type ServiceURL ¶
func FindServiceURLs ¶
func FindServiceURLs(client *kubernetes.Clientset, namespace string) ([]ServiceURL, error)
Source Files ¶
- activity.go
- activity_functions.go
- clients.go
- cluster_status.go
- config.go
- configmap.go
- constants.go
- crds.go
- deployments.go
- env.go
- git_services.go
- ingress.go
- install_rbac.go
- jenkins.go
- job.go
- kops.go
- metadata.go
- metrics.go
- names.go
- namespaces.go
- pod.go
- runtime_objects.go
- service_accounts.go
- services.go
- validate.go
- version.go