Documentation
¶
Overview ¶
Package e2e contains the end-to-end tests for the meta-collector
Index ¶
- Constants
- func MetaToString(meta *v1.ObjectMeta) (string, error)
- func NewLogger(writer io.Writer) terratestlogger.TestLogger
- func PodStatusToString(status *corev1.PodStatus) (string, error)
- type Client
- type Deployer
- func (dpl *Deployer) CleanUp(t testing.TestingT, writer io.Writer) error
- func (dpl *Deployer) DeployAll(t testing.TestingT, writer io.Writer, namespace string, expectedPods int) error
- func (dpl *Deployer) ListDaemonsets(t testing.TestingT, writer io.Writer, node string) ([]appsv1.DaemonSet, error)
- func (dpl *Deployer) ListDeployments(t testing.TestingT, writer io.Writer, node string) ([]appsv1.Deployment, error)
- func (dpl *Deployer) ListNamespaces(t testing.TestingT, writer io.Writer, node string) ([]corev1.Namespace, error)
- func (dpl *Deployer) ListPods(t testing.TestingT, writer io.Writer, node string) ([]corev1.Pod, error)
- func (dpl *Deployer) ListReplicaSets(t testing.TestingT, writer io.Writer, node string) ([]appsv1.ReplicaSet, error)
- func (dpl *Deployer) ListReplicationControllers(t testing.TestingT, writer io.Writer, node string) ([]corev1.ReplicationController, error)
- func (dpl *Deployer) ListServices(t testing.TestingT, writer io.Writer, node string) ([]corev1.Service, error)
- type Logger
Constants ¶
const ( // NodeNameEnv name of the environment variable that holds the node name. NodeNameEnv = "NODENAME" // NodeFieldSelector selector used to get pods for a specific node. NodeFieldSelector = "spec.nodeName=" )
NodeNameEnv variable name that contains the node name used to subscribe to the collector.
Variables ¶
This section is empty.
Functions ¶
func MetaToString ¶
func MetaToString(meta *v1.ObjectMeta) (string, error)
MetaToString returns the metadata to string. But before removes all the unnecessary fields.
func NewLogger ¶
func NewLogger(writer io.Writer) terratestlogger.TestLogger
NewLogger returns a new logger for terratest modules.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a client that subscribes to the metacollector.
func (*Client) NumMessages ¶
func (m *Client) NumMessages() int
func (*Client) NumMessagesForKind ¶
type Deployer ¶
type Deployer struct {
// contains filtered or unexported fields
}
Deployer knows how to deploy resources.
func NewDeployer ¶
NewDeployer returns a new deployer.
func (*Deployer) DeployAll ¶
func (dpl *Deployer) DeployAll(t testing.TestingT, writer io.Writer, namespace string, expectedPods int) error
DeployAll deploys all resources and waits until the expected pods are running.
func (*Deployer) ListDaemonsets ¶
func (dpl *Deployer) ListDaemonsets(t testing.TestingT, writer io.Writer, node string) ([]appsv1.DaemonSet, error)
ListDaemonsets returns all the daemonsets related to the given node.
func (*Deployer) ListDeployments ¶
func (dpl *Deployer) ListDeployments(t testing.TestingT, writer io.Writer, node string) ([]appsv1.Deployment, error)
ListDeployments returns all the deployments related to the given node.
func (*Deployer) ListNamespaces ¶
func (dpl *Deployer) ListNamespaces(t testing.TestingT, writer io.Writer, node string) ([]corev1.Namespace, error)
ListNamespaces returns all the namespaces related to the given node.
func (*Deployer) ListPods ¶
func (dpl *Deployer) ListPods(t testing.TestingT, writer io.Writer, node string) ([]corev1.Pod, error)
ListPods returns all the pods running on the given node.
func (*Deployer) ListReplicaSets ¶
func (dpl *Deployer) ListReplicaSets(t testing.TestingT, writer io.Writer, node string) ([]appsv1.ReplicaSet, error)
ListReplicaSets returns all the replicasets related to the given node.
Source Files