framework

Documentation

Index

• func ApplyJSONPatch(cluster framework.Cluster, namespace, deployment string, ...) error
• func EnablePrometheusAdminAPIPatch() []json.RawMessage
• func InstallPrometheusPushgateway(cluster *framework.K8sCluster, ns string) error
• func PortForwardPrometheusPushgateway(cluster *framework.K8sCluster, ns string) error
• func PortForwardPrometheusServer(cluster *framework.K8sCluster, ns string) error
• func ReportSpecEnd(cluster *framework.K8sCluster) error
• func ReportSpecStart(cluster *framework.K8sCluster) error
• func SavePrometheusSnapshot(cluster framework.Cluster, namespace string, hostPath string) error
• func SetPrometheusResourcesPatch() []json.RawMessage
• func WatchXdsDeliveryCount(promClient *PromClient, stopCh <-chan struct{}, metricCh chan<- int, ...)
• func XdsAckRequestsReceived(promClient *PromClient) (int, error)
• func XdsDeliveryCount(promClient *PromClient) (int, error)
• type PromClient
  • func NewPromClient(url string) (*PromClient, error)
  • func (p *PromClient) QueryIntValue(query string) (int, error)
• type SpecReport
  • func MakeSpecReports(ginkgoReport ginkgo.Report) []SpecReport

Functions

func ApplyJSONPatch

func ApplyJSONPatch(cluster framework.Cluster, namespace, deployment string, operations []json.RawMessage) error

func EnablePrometheusAdminAPIPatch

func EnablePrometheusAdminAPIPatch() []json.RawMessage

func InstallPrometheusPushgateway

func InstallPrometheusPushgateway(cluster *framework.K8sCluster, ns string) error

func PortForwardPrometheusPushgateway

func PortForwardPrometheusPushgateway(cluster *framework.K8sCluster, ns string) error

func PortForwardPrometheusServer

func PortForwardPrometheusServer(cluster *framework.K8sCluster, ns string) error

func ReportSpecEnd

func ReportSpecEnd(cluster *framework.K8sCluster) error

func ReportSpecStart

func ReportSpecStart(cluster *framework.K8sCluster) error

func SavePrometheusSnapshot

func SavePrometheusSnapshot(cluster framework.Cluster, namespace string, hostPath string) error

SavePrometheusSnapshot triggers tsdb snapshot and copies it from kube container to hostPath

func SetPrometheusResourcesPatch

func SetPrometheusResourcesPatch() []json.RawMessage

func WatchXdsDeliveryCount

func WatchXdsDeliveryCount(promClient *PromClient, stopCh <-chan struct{}, metricCh chan<- int, errCh chan<- error)

func XdsAckRequestsReceived

func XdsAckRequestsReceived(promClient *PromClient) (int, error)

func XdsDeliveryCount

func XdsDeliveryCount(promClient *PromClient) (int, error)

Types

type PromClient

type PromClient struct {
	// contains filtered or unexported fields
}

func NewPromClient

func NewPromClient(url string) (*PromClient, error)

func (*PromClient) QueryIntValue

func (p *PromClient) QueryIntValue(query string) (int, error)

type SpecReport

type SpecReport struct {
	Parameters       map[string]string `json:"parameters"`
	SuitePath        string            `json:"suitePath"`
	SuiteDescription string            `json:"suiteDescription"`
	State            string            `json:"state"`
	Description      string            `json:"description"`
	ReportEntries    map[string]string `json:"reportEntries"`
}

func MakeSpecReports

func MakeSpecReports(ginkgoReport ginkgo.Report) []SpecReport