framework

package
v0.0.0-...-425e462 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2019 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TestSourceDataVolumeName = "source-data"
	TestSourceDataMountPath  = "/source/data"
)
View Source 
const (
	TEST_HEADLESS_SERVICE = "headless"
)

Variables

This section is empty.

Functions

func PrintSeparately 

func PrintSeparately(a ...interface{})

func StartServer 

func StartServer() *httptest.Server

Types

type Framework 

type Framework struct {
	Provider string
	// contains filtered or unexported fields
}

func New 

func New(kubeClient kubernetes.Interface, apiExtKubeClient crd_cs.ApiextensionsV1beta1Interface, extClient cs.Interface, icingaClient *icinga.Client, provider, storageClass string) *Framework

func (*Framework) AcknowledgeClusterAlertNotification 

func (f *Framework) AcknowledgeClusterAlertNotification(meta metav1.ObjectMeta, hostname string) error

func (*Framework) CleanClusterAlert 

func (f *Framework) CleanClusterAlert()

func (*Framework) CleanNodeAlert 

func (f *Framework) CleanNodeAlert()

func (*Framework) CleanPodAlert 

func (f *Framework) CleanPodAlert()

func (*Framework) CountNode 

func (f *Framework) CountNode() (int32, error)

func (*Framework) CreateClusterAlert 

func (f *Framework) CreateClusterAlert(obj *api.ClusterAlert) error

func (*Framework) CreateDeployment 

func (f *Framework) CreateDeployment(obj *apps.Deployment) error

func (*Framework) CreateNamespace 

func (f *Framework) CreateNamespace() error

func (*Framework) CreateNodeAlert 

func (f *Framework) CreateNodeAlert(obj *api.NodeAlert) error

func (*Framework) CreatePod 

func (f *Framework) CreatePod(obj *core.Pod) (*core.Pod, error)

func (*Framework) CreatePodAlert 

func (f *Framework) CreatePodAlert(obj *api.PodAlert) error

func (*Framework) CreateReplicaSet 

func (f *Framework) CreateReplicaSet(obj *extensions.ReplicaSet) (*extensions.ReplicaSet, error)

func (*Framework) CreateService 

func (f *Framework) CreateService(obj *core.Service) error

func (*Framework) CreateStatefulSet 

func (f *Framework) CreateStatefulSet(obj *apps.StatefulSet) (*apps.StatefulSet, error)

func (*Framework) CreateWebHookSecret 

func (f *Framework) CreateWebHookSecret(obj *core_v1.Secret) error

func (*Framework) DeleteClusterAlert 

func (f *Framework) DeleteClusterAlert(meta metav1.ObjectMeta) error

func (*Framework) DeleteDeployment 

func (f *Framework) DeleteDeployment(obj *apps.Deployment) error

func (*Framework) DeleteNamespace 

func (f *Framework) DeleteNamespace() error

func (*Framework) DeleteNodeAlert 

func (f *Framework) DeleteNodeAlert(meta metav1.ObjectMeta) error

func (*Framework) DeletePod 

func (f *Framework) DeletePod(meta metav1.ObjectMeta) error

func (*Framework) DeletePodAlert 

func (f *Framework) DeletePodAlert(meta metav1.ObjectMeta) error

func (*Framework) DeleteReplicaSet 

func (f *Framework) DeleteReplicaSet(obj *extensions.ReplicaSet) error

func (*Framework) DeleteService 

func (f *Framework) DeleteService(meta metav1.ObjectMeta) error

func (*Framework) DeleteStatefulSet 

func (f *Framework) DeleteStatefulSet(obj *apps.StatefulSet) error

func (*Framework) EventuallyClusterAlertIcingaNotification 

func (f *Framework) EventuallyClusterAlertIcingaNotification(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyClusterAlertIcingaService 

func (f *Framework) EventuallyClusterAlertIcingaService(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyDeployment 

func (f *Framework) EventuallyDeployment(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyHTTPServerResponse 

func (f *Framework) EventuallyHTTPServerResponse(serverURL string) GomegaAsyncAssertion

func (*Framework) EventuallyIcingaAPI 

func (f *Framework) EventuallyIcingaAPI() GomegaAsyncAssertion

func (*Framework) EventuallyNodeAlertIcingaService 

func (f *Framework) EventuallyNodeAlertIcingaService(meta metav1.ObjectMeta, nodeAlertSpec api.NodeAlertSpec) GomegaAsyncAssertion

func (*Framework) EventuallyPodAlertIcingaService 

func (f *Framework) EventuallyPodAlertIcingaService(meta metav1.ObjectMeta, podAlertSpec api.PodAlertSpec) GomegaAsyncAssertion

func (*Framework) EventuallyPodRunning 

func (f *Framework) EventuallyPodRunning(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyReplicaSet 

func (f *Framework) EventuallyReplicaSet(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyServiceLoadBalancer 

func (f *Framework) EventuallyServiceLoadBalancer(meta metav1.ObjectMeta, portName string) GomegaAsyncAssertion

func (*Framework) EventuallyStatefulSet 

func (f *Framework) EventuallyStatefulSet(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) ForceCheckClusterAlert 

func (f *Framework) ForceCheckClusterAlert(meta metav1.ObjectMeta, hostname string, times int) error

func (*Framework) GetClusterAlert 

func (f *Framework) GetClusterAlert(meta metav1.ObjectMeta) (*api.ClusterAlert, error)

func (*Framework) GetNodeAlert 

func (f *Framework) GetNodeAlert(meta metav1.ObjectMeta) (*api.NodeAlert, error)

func (*Framework) GetPodAlert 

func (f *Framework) GetPodAlert(meta metav1.ObjectMeta) (*api.PodAlert, error)

func (*Framework) GetPodList 

func (f *Framework) GetPodList(actual interface{}) (*core.PodList, error)

func (*Framework) GetReplicaSet 

func (f *Framework) GetReplicaSet(meta metav1.ObjectMeta) (*extensions.ReplicaSet, error)

func (*Framework) GetServiceEndpoint 

func (f *Framework) GetServiceEndpoint(meta metav1.ObjectMeta, portName string) (string, error)

func (*Framework) GetStatefulSet 

func (f *Framework) GetStatefulSet(meta metav1.ObjectMeta) (*apps.StatefulSet, error)

func (*Framework) Invoke 

func (f *Framework) Invoke() *Invocation

func (*Framework) KubeClient 

func (f *Framework) KubeClient() kubernetes.Interface

func (*Framework) MonitoringClient 

func (f *Framework) MonitoringClient() mon_cs.MonitoringV1alpha1Interface

func (*Framework) Namespace 

func (f *Framework) Namespace() string

func (*Framework) SendClusterAlertCustomNotification 

func (f *Framework) SendClusterAlertCustomNotification(meta metav1.ObjectMeta, hostname string) error

func (*Framework) SetIcingaClient 

func (f *Framework) SetIcingaClient(icingaClient *icinga.Client) *Framework

type Invocation 

type Invocation struct {
	*Framework
	// contains filtered or unexported fields
}

func (*Invocation) ClusterAlert 

func (f *Invocation) ClusterAlert() *api.ClusterAlert

func (*Invocation) Deployment 

func (f *Invocation) Deployment() *apps.Deployment

func (*Invocation) GetIcingaApiPassword 

func (f *Invocation) GetIcingaApiPassword(objectMeta metav1.ObjectMeta) (string, error)

func (*Invocation) GetWebHookSecret 

func (f *Invocation) GetWebHookSecret() *core_v1.Secret

func (*Invocation) NodeAlert 

func (f *Invocation) NodeAlert() *api.NodeAlert

func (*Invocation) Pod 

func (f *Invocation) Pod() *core.Pod

func (*Invocation) PodAlert 

func (f *Invocation) PodAlert() *api.PodAlert

func (*Invocation) PodTemplate 

func (f *Invocation) PodTemplate() core.PodTemplateSpec

func (*Invocation) ReplicaSet 

func (f *Invocation) ReplicaSet() *extensions.ReplicaSet

func (*Invocation) StatefulSet 

func (f *Invocation) StatefulSet() *apps.StatefulSet

type Message 

type Message struct {
	To   []string `json:"to,omitempty"`
	Body string   `json:"body,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.