itest

Documentation

Index

• func NewPodLogChan(ctx context.Context, cs *kubernetes.Clientset, name, ns string, follow bool) (<-chan string, error)
• func PodExec(config *rest.Config, ns, podName string, cmd ...string) (stdout, stderr []byte, err error)
• type AgentCom
  • func NewAgentCom(name, ns string, restConfig *rest.Config) (*AgentCom, error)
  • func (ac *AgentCom) GetSnapshot(ctx context.Context) (*agent.Snapshot, error)
  • func (ac *AgentCom) Install(ctx context.Context) (CleanupFunc, error)
  • func (ac *AgentCom) RPCAddress() string
  • func (ac *AgentCom) SetKATServerImage(image string)
  • func (ac *AgentCom) SetPort(p int)
• type CleanupFunc
  • func InstallHelmChart(ctx context.Context, config InstallationConfig) (CleanupFunc, error)
• type InstallationConfig

Functions

func NewPodLogChan

func NewPodLogChan(ctx context.Context, cs *kubernetes.Clientset, name, ns string, follow bool) (<-chan string, error)

NewPodLogChan returns a chan with the specified pods logs entry-by-entry

func PodExec

func PodExec(config *rest.Config, ns, podName string, cmd ...string) (stdout, stderr []byte, err error)

PodExec provides the functionality of `kubectl exec -n ns podName -- cmd...`

Types

type AgentCom

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

func NewAgentCom

func NewAgentCom(name, ns string, restConfig *rest.Config) (*AgentCom, error)

func (*AgentCom) GetSnapshot

func (ac *AgentCom) GetSnapshot(ctx context.Context) (*agent.Snapshot, error)

func (*AgentCom) Install

func (ac *AgentCom) Install(ctx context.Context) (CleanupFunc, error)

func (*AgentCom) RPCAddress

func (ac *AgentCom) RPCAddress() string

func (*AgentCom) SetKATServerImage

func (ac *AgentCom) SetKATServerImage(image string)

func (*AgentCom) SetPort

func (ac *AgentCom) SetPort(p int)

type CleanupFunc

type CleanupFunc func(context.Context) error

func InstallHelmChart

func InstallHelmChart(ctx context.Context, config InstallationConfig) (CleanupFunc, error)

type InstallationConfig

type InstallationConfig struct {
	ReleaseName string
	Namespace   string
	ChartDir    string
	Values      map[string]any

	RESTConfig *rest.Config
	Log        action.DebugLog
}