util

Documentation

Index

• func CreateFromYAML(ctx context.Context, kc *kubernetes.Clientset, rc *rest.Config, ...) error
• func CreateResources(ctx context.Context, resources []*unstructured.Unstructured, ...) error
• func GetDynamicClient(rc *rest.Config) (*dynamic.DynamicClient, error)
• func GetJoinToken(kc *kubernetes.Clientset, rc *rest.Config, name string, namespace string) (string, error)
• func GetKMCClientSet(ctx context.Context, kc *kubernetes.Clientset, name string, namespace string, ...) (*kubernetes.Clientset, error)
• func GetNodeAddress(ctx context.Context, kc *kubernetes.Clientset, node string) (string, error)
• func InstallK0smotronOperator(ctx context.Context, kc *kubernetes.Clientset, rc *rest.Config) error
• func InstallLocalPathStorage(ctx context.Context, kc *kubernetes.Clientset, rc *rest.Config) error
• func NewSuiteContext(t *testing.T) (context.Context, context.CancelCauseFunc)
• func ParseManifests(data []byte) ([]*unstructured.Unstructured, error)
• func WaitForSecret(ctx context.Context, kc *kubernetes.Clientset, name string, namespace string) error
• type ErrorHandler
• type PortForwarder
  • func GetPortForwarder(cfg *rest.Config, name string, namespace string, port int) (*PortForwarder, error)
  • func (pf *PortForwarder) Close()
  • func (pf *PortForwarder) LocalPort() (int, error)
  • func (pf *PortForwarder) Start(errorHandler ErrorHandler)

Functions

func CreateFromYAML

func CreateFromYAML(ctx context.Context, kc *kubernetes.Clientset, rc *rest.Config, filename string) error

func CreateResources

func CreateResources(ctx context.Context, resources []*unstructured.Unstructured, kc *kubernetes.Clientset, client *dynamic.DynamicClient) error

func GetDynamicClient

func GetDynamicClient(rc *rest.Config) (*dynamic.DynamicClient, error)

func GetJoinToken

func GetJoinToken(kc *kubernetes.Clientset, rc *rest.Config, name string, namespace string) (string, error)

func GetKMCClientSet

func GetKMCClientSet(ctx context.Context, kc *kubernetes.Clientset, name string, namespace string, port int) (*kubernetes.Clientset, error)

GetKMCClientSet returns a kubernetes clientset for the cluster given the name and the namespace of the cluster.k0smotron.io

func GetNodeAddress

func GetNodeAddress(ctx context.Context, kc *kubernetes.Clientset, node string) (string, error)

func InstallK0smotronOperator

func InstallK0smotronOperator(ctx context.Context, kc *kubernetes.Clientset, rc *rest.Config) error

func InstallLocalPathStorage

func InstallLocalPathStorage(ctx context.Context, kc *kubernetes.Clientset, rc *rest.Config) error

func NewSuiteContext

func NewSuiteContext(t *testing.T) (context.Context, context.CancelCauseFunc)

func ParseManifests

func ParseManifests(data []byte) ([]*unstructured.Unstructured, error)

func WaitForSecret

func WaitForSecret(ctx context.Context, kc *kubernetes.Clientset, name string, namespace string) error

Types

type ErrorHandler

type ErrorHandler func(err error, msgAndArgs ...interface{})

type PortForwarder

type PortForwarder struct {
	ReadyChan chan struct{}
	// contains filtered or unexported fields
}

func GetPortForwarder

func GetPortForwarder(cfg *rest.Config, name string, namespace string, port int) (*PortForwarder, error)

func (*PortForwarder) Close

func (pf *PortForwarder) Close()

Close closes the forwarder

func (*PortForwarder) LocalPort

func (pf *PortForwarder) LocalPort() (int, error)

Get the local port that is forwarded to the remote port

func (*PortForwarder) Start

func (pf *PortForwarder) Start(errorHandler ErrorHandler)

Start runs ForwardPorts. The errorHandler is expected to be s.Require().NoError