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) errordeprecated
- func TeardownKube(namespace string) errordeprecated
- 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
- type ConsulInstance
- type ConsulPorts
- type CurlOpts
- type VaultFactory
- type VaultInstance
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AllocateParallelPort ¶ added in v0.10.4
func AllocateParallelPort(basePort int) int
func CurlEventuallyShouldRespond ¶
func CurlEventuallyShouldRespond(opts CurlOpts, namespace, substr string, ginkgoOffset int, timeout ...time.Duration)
func KubectlOut ¶
func KubectlOut(args ...string) (string, error)
func KubectlOutAsync ¶
func KubectlOutAsync(args ...string) (*bytes.Buffer, chan struct{}, error)
func SetupKubeForTest
deprecated
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
deprecated
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) NewConsulInstance ¶
func (ef *ConsulFactory) NewConsulInstance() (*ConsulInstance, error)
type ConsulInstance ¶
type ConsulInstance struct {
Ports ConsulPorts
// contains filtered or unexported fields
}
func (*ConsulInstance) RunWithPort ¶
func (i *ConsulInstance) RunWithPort() error
type ConsulPorts ¶ added in v0.10.4
type ConsulPorts struct {
DnsPort, HttpPort, GrpcPort, ServerPort, SerfLanPort, SerfWanPort int
}
func NewRandomConsulPorts ¶ added in v0.10.4
func NewRandomConsulPorts() ConsulPorts
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) NewVaultInstance ¶
func (ef *VaultFactory) NewVaultInstance() (*VaultInstance, error)
type VaultInstance ¶
type VaultInstance struct {
Port int
// contains filtered or unexported fields
}
func (*VaultInstance) RunWithPort ¶
func (i *VaultInstance) RunWithPort() error
Source Files
Click to show internal directories.
Click to hide internal directories.