resource

Documentation

Index

• Constants
• type DeploymentManager
  • func NewDeploymentManager(cs kubernetes.Interface) *DeploymentManager
  • func (m *DeploymentManager) WaitDeploymentReady(ctx context.Context, dp *appsv1.Deployment) (*appsv1.Deployment, error)
• type IngressManager
  • func NewIngressManager(cs kubernetes.Interface) *IngressManager
  • func (m *IngressManager) WaitIngressReady(ctx context.Context, ing *extensionsv1.Ingress) (*extensionsv1.Ingress, error)
• type Manager
  • func NewManager(cs kubernetes.Interface) *Manager
  • func (f *Manager) Cleanup(ctx context.Context) error
• type NamespaceManager
  • func NewNamespaceManager(cs kubernetes.Interface) *NamespaceManager
  • func (m *NamespaceManager) Cleanup(ctx context.Context) error
  • func (m *NamespaceManager) CreateNamespaceUnique(ctx context.Context, baseName string) (*corev1.Namespace, error)
  • func (m *NamespaceManager) DeleteNamespace(ctx context.Context, namespace string) error
• type ServiceManager
  • func NewServiceManager(cs kubernetes.Interface) *ServiceManager
  • func (m *ServiceManager) WaitServiceHasEndpointsNum(ctx context.Context, svc *corev1.Service, epCounts int) (*corev1.Service, error)

Constants

const (
	DefaultNamespaceDeletionTimeout = 10 * time.Minute
)

Types

type DeploymentManager

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

func NewDeploymentManager

func NewDeploymentManager(cs kubernetes.Interface) *DeploymentManager

func (*DeploymentManager) WaitDeploymentReady

func (m *DeploymentManager) WaitDeploymentReady(ctx context.Context, dp *appsv1.Deployment) (*appsv1.Deployment, error)

type IngressManager

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

func NewIngressManager

func NewIngressManager(cs kubernetes.Interface) *IngressManager

func (*IngressManager) WaitIngressReady

func (m *IngressManager) WaitIngressReady(ctx context.Context, ing *extensionsv1.Ingress) (*extensionsv1.Ingress, error)

type Manager

type Manager struct {
	*NamespaceManager
	*DeploymentManager
	*ServiceManager
	*IngressManager
}

func NewManager

func NewManager(cs kubernetes.Interface) *Manager

func (*Manager) Cleanup

func (f *Manager) Cleanup(ctx context.Context) error

type NamespaceManager

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

func NewNamespaceManager

func NewNamespaceManager(cs kubernetes.Interface) *NamespaceManager

func (*NamespaceManager) Cleanup

func (m *NamespaceManager) Cleanup(ctx context.Context) error

func (*NamespaceManager) CreateNamespaceUnique

func (m *NamespaceManager) CreateNamespaceUnique(ctx context.Context, baseName string) (*corev1.Namespace, error)

func (*NamespaceManager) DeleteNamespace

func (m *NamespaceManager) DeleteNamespace(ctx context.Context, namespace string) error

DeleteNamespace deletes the provided namespace, waits for it to be completely deleted.

type ServiceManager

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

func NewServiceManager

func NewServiceManager(cs kubernetes.Interface) *ServiceManager

func (*ServiceManager) WaitServiceHasEndpointsNum

func (m *ServiceManager) WaitServiceHasEndpointsNum(ctx context.Context, svc *corev1.Service, epCounts int) (*corev1.Service, error)