setup

Documentation

Index

• func AllocateParallelPort(basePort int) int
• func Curl(opts CurlOpts, namespace string) (string, error)
• func CurlEventuallyShouldRespond(opts CurlOpts, namespace, substr string, ginkgoOffset int, ...)
• func DeleteCrd(crd string) error
• func KubeLogs(pod string) string
• func Kubectl(args ...string) error
• func KubectlOut(args ...string) (string, error)
• func KubectlOutAsync(args ...string) (*bytes.Buffer, chan struct{}, error)
• func SetupKubeForTest(namespace string) error
• func TeardownKube(namespace string) error
• func TestRunner(namespace string, command ...string) (string, error)
• func TestRunnerAsync(args ...string) (*bytes.Buffer, chan struct{}, error)
• func WaitNamespaceStatus(namespace, status string, finished func(output string) bool) error
• func WaitPodStatus(pod, status string, finished func(output string) bool) error
• func WaitPodsRunning(podNames ...string) error
• func WaitPodsTerminated(podNames ...string) error
• type ConsulFactory
  • func NewConsulFactory() (*ConsulFactory, error)
  • func (ef *ConsulFactory) Clean() error
  • func (ef *ConsulFactory) NewConsulInstance() (*ConsulInstance, error)
• type ConsulInstance
  • func (i *ConsulInstance) Binary() string
  • func (i *ConsulInstance) Clean() error
  • func (i *ConsulInstance) Run() error
  • func (i *ConsulInstance) RunWithPort() error
  • func (i *ConsulInstance) Silence()
• type ConsulPorts
  • func NewRandomConsulPorts() ConsulPorts
  • func (p ConsulPorts) Flags() []string
• type CurlOpts
• type VaultFactory
  • func NewVaultFactory() (*VaultFactory, error)
  • func (ef *VaultFactory) Clean() error
  • func (ef *VaultFactory) NewVaultInstance() (*VaultInstance, error)
• type VaultInstance
  • func (i *VaultInstance) Binary() string
  • func (i *VaultInstance) Clean() error
  • func (i *VaultInstance) Exec(args ...string) (string, error)
  • func (i *VaultInstance) Run() error
  • func (i *VaultInstance) RunWithPort() error
  • func (i *VaultInstance) Token() string

Functions

func AllocateParallelPort

func AllocateParallelPort(basePort int) int

func Curl

func Curl(opts CurlOpts, namespace string) (string, error)

func CurlEventuallyShouldRespond

func CurlEventuallyShouldRespond(opts CurlOpts, namespace, substr string, ginkgoOffset int, timeout ...time.Duration)

func DeleteCrd

func DeleteCrd(crd string) error

func KubeLogs

func KubeLogs(pod string) string

func Kubectl

func Kubectl(args ...string) error

func KubectlOut

func KubectlOut(args ...string) (string, error)

func KubectlOutAsync

func KubectlOutAsync(args ...string) (*bytes.Buffer, chan struct{}, error)

func SetupKubeForTest

func SetupKubeForTest(namespace string) error

Deprecated: This function is slower than it's go client counterpart, and changes the kube context which can have unintended consequences

func TeardownKube

func TeardownKube(namespace string) error

Deprecated: This function is much slower than it's go client counterpart because it is blocking. If that is the intended behavior, go ahead and and use this function, but just no that it is quite slow.

func TestRunner

func TestRunner(namespace string, command ...string) (string, error)

TestRunner executes a command inside the TestRunner container

func TestRunnerAsync

func TestRunnerAsync(args ...string) (*bytes.Buffer, chan struct{}, error)

TestRunnerAsync executes a command inside the TestRunner container returning a buffer that can be read from as it executes

func WaitNamespaceStatus

func WaitNamespaceStatus(namespace, status string, finished func(output string) bool) error

func WaitPodStatus

func WaitPodStatus(pod, status string, finished func(output string) bool) error

func WaitPodsRunning

func WaitPodsRunning(podNames ...string) error

WaitPodsRunning waits for all pods to be running

func WaitPodsTerminated

func WaitPodsTerminated(podNames ...string) error

waitPodsTerminated waits for all pods to be terminated

Types

type ConsulFactory

type ConsulFactory struct {
	Ports ConsulPorts
	// contains filtered or unexported fields
}

func NewConsulFactory

func NewConsulFactory() (*ConsulFactory, error)

func (*ConsulFactory) Clean

func (ef *ConsulFactory) Clean() error

func (*ConsulFactory) NewConsulInstance

func (ef *ConsulFactory) NewConsulInstance() (*ConsulInstance, error)

type ConsulInstance

type ConsulInstance struct {
	Ports ConsulPorts
	// contains filtered or unexported fields
}

func (*ConsulInstance) Binary

func (i *ConsulInstance) Binary() string

func (*ConsulInstance) Clean

func (i *ConsulInstance) Clean() error

func (*ConsulInstance) Run

func (i *ConsulInstance) Run() error

func (*ConsulInstance) RunWithPort

func (i *ConsulInstance) RunWithPort() error

func (*ConsulInstance) Silence

func (i *ConsulInstance) Silence()

type ConsulPorts

type ConsulPorts struct {
	DnsPort, HttpPort, GrpcPort, ServerPort, SerfLanPort, SerfWanPort int
}

func NewRandomConsulPorts

func NewRandomConsulPorts() ConsulPorts

func (ConsulPorts) Flags

func (p ConsulPorts) Flags() []string

return flags to set each port type as a string

type CurlOpts

type CurlOpts struct {
	Protocol      string
	Path          string
	Method        string
	Host          string
	Service       string
	CaFile        string
	Body          string
	Headers       map[string]string
	Port          int
	ReturnHeaders bool
}

type VaultFactory

type VaultFactory struct {
	Port int
	// contains filtered or unexported fields
}

func NewVaultFactory

func NewVaultFactory() (*VaultFactory, error)

func (*VaultFactory) Clean

func (ef *VaultFactory) Clean() error

func (*VaultFactory) NewVaultInstance

func (ef *VaultFactory) NewVaultInstance() (*VaultInstance, error)

type VaultInstance

type VaultInstance struct {
	Port int
	// contains filtered or unexported fields
}

func (*VaultInstance) Binary

func (i *VaultInstance) Binary() string

func (*VaultInstance) Clean

func (i *VaultInstance) Clean() error

func (*VaultInstance) Exec

func (i *VaultInstance) Exec(args ...string) (string, error)

func (*VaultInstance) Run

func (i *VaultInstance) Run() error

func (*VaultInstance) RunWithPort

func (i *VaultInstance) RunWithPort() error

func (*VaultInstance) Token

func (i *VaultInstance) Token() string