kubernetes

package

v0.0.0-...-8e01d1d Latest Latest Go to latest Published: May 14, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func GetClientset() (kubernetes.Interface, error)

func IsRetryableAPIError(err error) bool

func StartPods(c kubernetes.Interface, namespace string, pod v1.Pod, waitForRunning bool) error

func WaitForDeploymentToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForDeploymentToStabilize waits till the Deployment has a matching generation/replica count between spec and status.

func WaitForPodComplete(pods corev1.PodInterface, podName string) error

func WaitForPodReady(pods corev1.PodInterface, podName string) error

func WaitForPodsWithLabelRunning(c kubernetes.Interface, ns string, label labels.Selector) error

WaitForPodsWithLabelRunning waits up to 10 minutes for all matching pods to become Running and at least one matching pod exists.

func WaitForRCToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForRCToStabilize waits till the RC has a matching generation/replica count between spec and status.

func WaitForReplicaSetToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForReplicaSetToStabilize waits till the ReplicaSet has a matching generation/replica count between spec and status.

func WaitForService(c kubernetes.Interface, namespace, name string, exist bool, interval, timeout time.Duration) error

WaitForService waits until the service appears (exist == true), or disappears (exist == false)

func WaitForServiceEndpointsNum(c kubernetes.Interface, namespace, serviceName string, expectNum int, interval, timeout time.Duration) error

WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.

type PodStore struct {
	cache.Store

	Reflector *cache.Reflector
	// contains filtered or unexported fields
}

func NewPodStore(c kubernetes.Interface, namespace string, label fmt.Stringer, field fmt.Stringer) *PodStore

func (s *PodStore) List() []*v1.Pod

func (s *PodStore) Stop()