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 ScanIstio(kubeconfig []byte, contextName string) (map[string]string, error)
• func ScanKubernetes(kubeconfig []byte, contextName string) (map[string]string, error)
• func ScanPromGrafana(kubeconfig []byte, contextName string) (map[string][]string, 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, adapterURL string)
  • func (a *AdaptersTracker) GetAdapters(ctx context.Context) []string
  • func (a *AdaptersTracker) RemoveAdapter(ctx context.Context, adapterURL string)
• 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 ScanIstio

func ScanIstio(kubeconfig []byte, contextName string) (map[string]string, error)

ScanIstio - lists VirtualServices

func ScanKubernetes

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

ScanKubernetes - Runs a quick scan on kubernetes to find out the version of service meshes deployed

func ScanPromGrafana

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

ScanPromGrafana - Runs a quick scan for Prometheus & Grafanas

func WRK2LoadTest

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

WRK2LoadTest is the actual code which invokes gowrk2 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, adapterURL string)

AddAdapter is used to add new adapters to the collection

func (*AdaptersTracker) GetAdapters

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

GetAdapters returns the list of existing adapters

func (*AdaptersTracker) RemoveAdapter

func (a *AdaptersTracker) RemoveAdapter(ctx context.Context, adapterURL string)

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