k8scontroller

Documentation

Index

• func NewKubernetesNamespace(ctx context.Context, cli kubernetes.Interface) (nsName string, deleteNS func(ctx context.Context) error, err error)
• func RunSloth(ctx context.Context, env []string, cmdApp, cmdArgs string, nolog bool) (stdout, stderr []byte, err error)
• func RunSlothController(ctx context.Context, config Config, ns string, cmdArgs string) (stdout, stderr []byte, err error)
• func SlothVersion(ctx context.Context, config Config) (string, error)
• type Config
  • func NewConfig(t *testing.T) Config
• type KubeClients
  • func NewKubernetesClients(ctx context.Context, config Config) (*KubeClients, error)

Functions

func NewKubernetesNamespace

func NewKubernetesNamespace(ctx context.Context, cli kubernetes.Interface) (nsName string, deleteNS func(ctx context.Context) error, err error)

func RunSloth

func RunSloth(ctx context.Context, env []string, cmdApp, cmdArgs string, nolog bool) (stdout, stderr []byte, err error)

RunSloth executes sloth command.

func RunSlothController

func RunSlothController(ctx context.Context, config Config, ns string, cmdArgs string) (stdout, stderr []byte, err error)

func SlothVersion

func SlothVersion(ctx context.Context, config Config) (string, error)

Types

type Config

type Config struct {
	Binary      string
	KubeConfig  string
	KubeContext string
}

func NewConfig

func NewConfig(t *testing.T) Config

NewIntegrationConfig prepares the configuration for integration tests, if the configuration is not ready it will skip the test.

type KubeClients

type KubeClients struct {
	Std        kubernetes.Interface
	Sloth      slothclientset.Interface
	Monitoring monitoringclientset.Interface
}

func NewKubernetesClients

func NewKubernetesClients(ctx context.Context, config Config) (*KubeClients, error)

NewKubernetesClients returns Kubernetes clients.