ksuite

Documentation

Index

• func DeleteCluster(ctx context.Context, cl *Cluster) error
• func FindFreePort(from uint16) uint16
• func GetInternalIP() (string, error)
• func IsPortFree(port int) bool
• type Cluster
  • func CreateCluster(ctx context.Context, o ...CreateClusterOpt) (*Cluster, error)
• type CreateClusterOpt
  • func WithIngressPort(host, con uint16) CreateClusterOpt
  • func WithNodePort(host, con uint16) CreateClusterOpt
  • func WithUseRegistry(reg string) CreateClusterOpt
• type CreateClusterOpts
• type KubeSuite
  • func (k *KubeSuite) AfterTest(_, _ string)
  • func (k *KubeSuite) SetupSuite()
  • func (k *KubeSuite) TearDownSuite()

Functions

func DeleteCluster

func DeleteCluster(ctx context.Context, cl *Cluster) error

func FindFreePort

func FindFreePort(from uint16) uint16

func GetInternalIP

func GetInternalIP() (string, error)

func IsPortFree

func IsPortFree(port int) bool

Types

type Cluster

type Cluster struct {
	Context      context.Context
	Cancel       context.CancelCauseFunc
	KubeConfPath string
	KubeConfig   clientcmd.ClientConfig
	K3D          *k3d.Cluster
	RegistryAddr string
	HostIP       string
}

func CreateCluster

func CreateCluster(ctx context.Context, o ...CreateClusterOpt) (*Cluster, error)

type CreateClusterOpt

type CreateClusterOpt func(c *CreateClusterOpts)

func WithIngressPort

func WithIngressPort(host, con uint16) CreateClusterOpt

func WithNodePort

func WithNodePort(host, con uint16) CreateClusterOpt

func WithUseRegistry

func WithUseRegistry(reg string) CreateClusterOpt

type CreateClusterOpts

type CreateClusterOpts struct {
	Use         []string
	ExposePorts []v1alpha5.PortWithNodeFilters
}

type KubeSuite

type KubeSuite struct {
	suite.Suite
	Cluster *Cluster
	Kube    kubernetes.Interface
	Config  *rest.Config

	// Don't touch the namespaces specified.
	SkipCleanNamespaces []string
	// Don't touch the namespaces that match the selectors.
	SkipCleanNamespaceSelectors []string
	// A K3D registry string pointing to external registry.
	UseRegistry string
}

func (*KubeSuite) AfterTest

func (k *KubeSuite) AfterTest(_, _ string)

func (*KubeSuite) SetupSuite

func (k *KubeSuite) SetupSuite()

func (*KubeSuite) TearDownSuite

func (k *KubeSuite) TearDownSuite()