itest

Documentation

Index

• Constants
• func NewPodLogChan(ctx context.Context, cs kubernetes.Interface, labelSelector, ns string, ...) (<-chan string, error)
• func PodExec(config *rest.Config, ns, podName string, cmd ...string) (stdout, stderr []byte, err error)
• func RunningPods(ctx context.Context, cs kubernetes.Interface, labelSelector, ns string) ([]string, error)
• type AESTestSuite
  • func (s *AESTestSuite) SetupSuite()
• 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 BasicTestSuite
  • func (s *BasicTestSuite) SetupSuite()
• type CleanupFunc
  • func InstallHelmChart(ctx context.Context, config InstallationConfig) (CleanupFunc, error)
• type CloudTokenTestSuite
  • func (s *CloudTokenTestSuite) SetupSuite()
• type InstallationConfig
• type Suite
  • func (s *Suite) Cleanup(f func(context.Context) error)
  • func (s *Suite) Config() *rest.Config
  • func (s *Suite) Context() context.Context
  • func (s *Suite) CreateNamespace(ctx context.Context, ns string) error
  • func (s *Suite) DeleteNamespace(ctx context.Context, ns string) error
  • func (s *Suite) Init()
  • func (s *Suite) K8sIf() kubernetes.Interface
  • func (s *Suite) Name() string
  • func (s *Suite) Namespace() string
  • func (s *Suite) TearDownSuite()

Constants

const AgentLabelSelector = "app.kubernetes.io/name=ambassador-agent"

Functions

func NewPodLogChan

func NewPodLogChan(ctx context.Context, cs kubernetes.Interface, labelSelector, 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...`.

func RunningPods

func RunningPods(ctx context.Context, cs kubernetes.Interface, labelSelector, ns string) ([]string, error)

RunningPods return the names of running pods with the given label selector in the form label=value. Running here means that at least one container is still running. I.e. the pod might well be terminating but still considered running.

Types

type AESTestSuite

type AESTestSuite struct {
	Suite
	// contains filtered or unexported fields
}

func (*AESTestSuite) SetupSuite

func (s *AESTestSuite) SetupSuite()

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 BasicTestSuite

type BasicTestSuite struct {
	Suite
	// contains filtered or unexported fields
}

func (*BasicTestSuite) SetupSuite

func (s *BasicTestSuite) SetupSuite()

type CleanupFunc

type CleanupFunc func(context.Context) error

func InstallHelmChart

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

type CloudTokenTestSuite

type CloudTokenTestSuite struct {
	Suite
}

func (*CloudTokenTestSuite) SetupSuite

func (s *CloudTokenTestSuite) SetupSuite()

type InstallationConfig

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

	RESTConfig *rest.Config
	Log        action.DebugLog
}

type Suite

type Suite struct {
	suite.Suite
	// contains filtered or unexported fields
}

func (*Suite) Cleanup

func (s *Suite) Cleanup(f func(context.Context) error)

func (*Suite) Config

func (s *Suite) Config() *rest.Config

func (*Suite) Context

func (s *Suite) Context() context.Context

func (*Suite) CreateNamespace

func (s *Suite) CreateNamespace(ctx context.Context, ns string) error

func (*Suite) DeleteNamespace

func (s *Suite) DeleteNamespace(ctx context.Context, ns string) error

func (*Suite) Init

func (s *Suite) Init()

func (*Suite) K8sIf

func (s *Suite) K8sIf() kubernetes.Interface

func (*Suite) Name

func (s *Suite) Name() string

func (*Suite) Namespace

func (s *Suite) Namespace() string

func (*Suite) TearDownSuite

func (s *Suite) TearDownSuite()