test

Documentation

Index

• Constants
• Variables
• func DemoDeployment() *appsv1.Deployment
• func GetFreePort() (int, error)
• func NewDeployment() *unstructured.Unstructured
• func NewPod() *unstructured.Unstructured
• func NewService() *unstructured.Unstructured
• func StartInformer(informer cache.SharedIndexInformer) context.CancelFunc
• func WaitForPortListen(addr string, timeout time.Duration) error

Constants

const (
	FakeArgoCDNamespace = "fake-argocd-ns"
	FakeDestNamespace   = "fake-dest-ns"
	FakeClusterURL      = "https://fake-cluster:443"
	TestAppInstanceName = "test-app-instance"
)

Variables

var (
	BuiltinPolicy string
)

var DeploymentManifest = []byte(`
{
  "apiVersion": "apps/v1",
  "kind": "Deployment",
  "metadata": {
    "name": "nginx-deployment",
    "labels": {
      "app": "nginx"
    }
  },
  "spec": {
    "replicas": 3,
    "selector": {
      "matchLabels": {
        "app": "nginx"
      }
    },
    "template": {
      "metadata": {
        "labels": {
          "app": "nginx"
        }
      },
      "spec": {
        "containers": [
          {
            "name": "nginx",
            "image": "nginx:1.15.4",
            "ports": [
              {
                "containerPort": 80
              }
            ]
          }
        ]
      }
    }
  }
}
`)

var PodManifest = []byte(`
{
  "apiVersion": "v1",
  "kind": "Pod",
  "metadata": {
    "name": "my-pod"
  },
  "spec": {
    "containers": [
      {
        "image": "nginx:1.7.9",
        "name": "nginx",
        "resources": {
          "requests": {
            "cpu": 0.2
          }
        }
      }
    ]
  }
}
`)

var ServiceManifest = []byte(`
{
  "apiVersion": "v1",
  "kind": "Service",
  "metadata": {
    "name": "my-service"
  },
  "spec": {
    "ports": [
      {
        "name": "http",
        "protocol": "TCP",
        "port": 80,
        "targetPort": 8080
      }
    ],
    "selector": {
      "app": "my-service"
    }
  }
}
`)

Functions

func DemoDeployment

func DemoDeployment() *appsv1.Deployment

func GetFreePort

func GetFreePort() (int, error)

GetFreePort finds an available free port on the OS

func NewDeployment

func NewDeployment() *unstructured.Unstructured

func NewPod

func NewPod() *unstructured.Unstructured

func NewService

func NewService() *unstructured.Unstructured

func StartInformer

func StartInformer(informer cache.SharedIndexInformer) context.CancelFunc

StartInformer is a helper to start an informer, wait for its cache to sync and return a cancel func

func WaitForPortListen

func WaitForPortListen(addr string, timeout time.Duration) error

WaitForPortListen waits until the given address is listening on the port