helpers

Documentation

Index

• func FetchKubernetesNodes(kubeconfig []byte, contextName string) ([]*models.K8SNode, error)
• func FetchKubernetesVersion(kubeconfig []byte, contextName string) (string, error)
• func FortioLoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)
• func MergeStringMaps(maps ...map[string]string) map[string]string
• func NewDynamicClient(kubeconfig []byte) (dynamic.Interface, error)
• func NewDynamicClientGenerator(path string) func() (dynamic.Interface, error)
• func NewKubeClient(kubeconfig []byte) (*mesherykube.Client, error)
• func NewKubeClientGenerator(path string) func() (*mesherykube.Client, error)
• func NighthawkLoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)
• func ScanGrafana(kubeconfig []byte, contextName string) (map[string][]corev1.Service, error)
• func ScanKubernetes(kubeconfig []byte, contextName string) (map[string][]corev1.Pod, error)
• func ScanPromGrafana(kubeconfig []byte, contextName string) (map[string][]corev1.Service, error)
• func ScanPrometheus(kubeconfig []byte, contextName string) (map[string][]corev1.Service, error)
• func WRK2LoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)
• type AdaptersTracker
  • func NewAdaptersTracker(adapterURLs []string) *AdaptersTracker
  • func (a *AdaptersTracker) AddAdapter(ctx context.Context, adapter models.Adapter)
  • func (a *AdaptersTracker) GetAdapters(ctx context.Context) []models.Adapter
  • func (a *AdaptersTracker) RemoveAdapter(ctx context.Context, adapter models.Adapter)
• type UUIDQueryTracker
  • func NewUUIDQueryTracker() *UUIDQueryTracker
  • func (a *UUIDQueryTracker) AddOrFlagQuery(ctx context.Context, uuid, query string, flag bool)
  • func (a *UUIDQueryTracker) GetQueriesForUUID(ctx context.Context, uuid string) map[string]bool
  • func (a *UUIDQueryTracker) RemoveUUID(ctx context.Context, uuid string)

Functions

func FetchKubernetesNodes

func FetchKubernetesNodes(kubeconfig []byte, contextName string) ([]*models.K8SNode, error)

FetchKubernetesNodes - function used to fetch nodes metadata

func FetchKubernetesVersion

func FetchKubernetesVersion(kubeconfig []byte, contextName string) (string, error)

FetchKubernetesVersion - function used to fetch kubernetes server version

func FortioLoadTest

func FortioLoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)

FortioLoadTest is the actual code which invokes Fortio to run the load test

func MergeStringMaps

func MergeStringMaps(maps ...map[string]string) map[string]string

func NewDynamicClient

func NewDynamicClient(kubeconfig []byte) (dynamic.Interface, error)

NewDynamicClient generates new dynamic go client

func NewDynamicClientGenerator

func NewDynamicClientGenerator(path string) func() (dynamic.Interface, error)

NewDynamicClientGenerator takes in the kube config *directory* path and returns a function which can generate dynamic client

func NewKubeClient

func NewKubeClient(kubeconfig []byte) (*mesherykube.Client, error)

func NewKubeClientGenerator

func NewKubeClientGenerator(path string) func() (*mesherykube.Client, error)

NewKubeClientGenerator takes in the kube config *directory* path and returns a function which can generate dynamic client

func NighthawkLoadTest

func NighthawkLoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)

NighthawkLoadTest is the actual code which invokes nighthawk to run the load test

func ScanGrafana

func ScanGrafana(kubeconfig []byte, contextName string) (map[string][]corev1.Service, error)

ScanGrafana - Runs a quick scan for Grafanas

func ScanKubernetes

func ScanKubernetes(kubeconfig []byte, contextName string) (map[string][]corev1.Pod, error)

ScanKubernetes scans kubernetes to find the pods for each service mesh

func ScanPromGrafana

func ScanPromGrafana(kubeconfig []byte, contextName string) (map[string][]corev1.Service, error)

ScanPromGrafana - Runs a quick scan for Prometheus & Grafanas

func ScanPrometheus

func ScanPrometheus(kubeconfig []byte, contextName string) (map[string][]corev1.Service, error)

ScanPrometheus - Runs a quick scan for Prometheus

func WRK2LoadTest

func WRK2LoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)

WRK2LoadTest is the actual code which invokes Wrk2 to run the load test

Types

type AdaptersTracker

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

AdaptersTracker is used to hold the list of known adapters

func NewAdaptersTracker

func NewAdaptersTracker(adapterURLs []string) *AdaptersTracker

NewAdaptersTracker returns an instance of AdaptersTracker

func (*AdaptersTracker) AddAdapter

func (a *AdaptersTracker) AddAdapter(ctx context.Context, adapter models.Adapter)

AddAdapter is used to add new adapters to the collection

func (*AdaptersTracker) GetAdapters

func (a *AdaptersTracker) GetAdapters(ctx context.Context) []models.Adapter

GetAdapters returns the list of existing adapters

func (*AdaptersTracker) RemoveAdapter

func (a *AdaptersTracker) RemoveAdapter(ctx context.Context, adapter models.Adapter)

RemoveAdapter is used to remove existing adapters from the collection

type UUIDQueryTracker

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

UUIDQueryTracker tracks queries for a load test UUID

func NewUUIDQueryTracker

func NewUUIDQueryTracker() *UUIDQueryTracker

NewUUIDQueryTracker creates a new instance of UUIDQueryTracker

func (*UUIDQueryTracker) AddOrFlagQuery

func (a *UUIDQueryTracker) AddOrFlagQuery(ctx context.Context, uuid, query string, flag bool)

AddOrFlagQuery either adds a new query or flags an existing one

func (*UUIDQueryTracker) GetQueriesForUUID

func (a *UUIDQueryTracker) GetQueriesForUUID(ctx context.Context, uuid string) map[string]bool

GetQueriesForUUID retrieves queries for UUID

func (*UUIDQueryTracker) RemoveUUID

func (a *UUIDQueryTracker) RemoveUUID(ctx context.Context, uuid string)

RemoveUUID removes an existing UUID from the collection