helpers

Documentation

Index

• Constants
• Variables
• func ErrAddAndValidateExtraHeader(err error) error
• func ErrClientConfig(err error) error
• func ErrClientSet(err error) error
• func ErrConvertingResultToMap(err error) error
• func ErrDetectServiceForDeploymentImage(err error) error
• func ErrDetectServiceWithName(err error) error
• func ErrFetchKubernetesNodes(err error) error
• func ErrFetchKubernetesVersion(err error) error
• func ErrFetchNodes(err error) error
• func ErrGeneratingLoadTest(err error) error
• func ErrGetNamespaceDeployments(err error, obj string) error
• func ErrGrpcSupport(err error, obj string) error
• func ErrInClusterConfig(err error) error
• func ErrInvalidK8SConfig(err error) error
• func ErrNewDynamicClientGenerator(err error) error
• func ErrNewKubeClient(err error) error
• func ErrNewKubeClientGenerator(err error) error
• func ErrRestConfigFromKubeConfig(err error) error
• func ErrRetrieveNamespacesList(err error) error
• func ErrRetrievePodList(err error) error
• func ErrRunningNighthawkServer(err error) error
• func ErrRunningTest(err error) error
• func ErrScanKubernetes(err error) error
• func ErrStartingNighthawkServer(err error) error
• func ErrTransformingData(err error) error
• func ErrUnmarshal(err error, obj string) error
• func FetchKubernetesNodes(kubeconfig []byte, contextName string) ([]*models.K8SNode, error)
• func FetchKubernetesVersion(kubeconfig []byte, contextName string) (string, error)
• func FlattenMinifyKubeConfig(config []byte) ([]byte, error)
• func FortioLoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)
• func MergeStringMaps(maps ...map[string]string) map[string]string
• func NestedMapExplorer(mp map[interface{}]interface{}, ...)
• func NighthawkLoadTest(opts *models.LoadTestOptions) (map[string]interface{}, *periodic.RunnerResults, error)
• func ResolveFSRef(path string) (string, error)
• func ScanKubernetes(kubeconfig []byte, contextName string) (map[string][]corev1.Pod, 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)

Constants

const (
	ErrErrNewDynamicClientGeneratorCode    = "2048"
	ErrInvalidK8SConfigCode                = "2049"
	ErrClientConfigCode                    = "2050"
	ErrFetchKubernetesNodesCode            = "2051"
	ErrFetchNodesCode                      = "2181"
	ErrFetchKubernetesVersionCode          = "2182"
	ErrScanKubernetesCode                  = "2183"
	ErrRetrievePodListCode                 = "2184"
	ErrDetectServiceForDeploymentImageCode = "2185"
	ErrRetrieveNamespacesListCode          = "2186"
	ErrGetNamespaceDeploymentsCode         = "2187"
	ErrDetectServiceWithNameCode           = "2188"
	ErrGeneratingLoadTestCode              = "2189"
	ErrRunningTestCode                     = "2190"
	ErrConvertingResultToMapCode           = "2191"
	ErrUnmarshalCode                       = "2192"
	ErrGrpcSupportCode                     = "2193"
	ErrStartingNighthawkServerCode         = "2194"
	ErrTransformingDataCode                = "2195"
	ErrRunningNighthawkServerCode          = "2196"
	ErrAddAndValidateExtraHeaderCode       = "2197"
	ErrInClusterConfigCode                 = "2198"
	ErrNewKubeClientGeneratorCode          = "2199"
	ErrRestConfigFromKubeConfigCode        = "2200"
	ErrNewKubeClientCode                   = "2201"
)

Variables

var TelemetryComps = []string{
	"prometheus", "grafana",
}

Functions

func ErrAddAndValidateExtraHeader

func ErrAddAndValidateExtraHeader(err error) error

func ErrClientConfig

func ErrClientConfig(err error) error

func ErrClientSet

func ErrClientSet(err error) error

func ErrConvertingResultToMap

func ErrConvertingResultToMap(err error) error

func ErrDetectServiceForDeploymentImage

func ErrDetectServiceForDeploymentImage(err error) error

func ErrDetectServiceWithName

func ErrDetectServiceWithName(err error) error

func ErrFetchKubernetesNodes

func ErrFetchKubernetesNodes(err error) error

func ErrFetchKubernetesVersion

func ErrFetchKubernetesVersion(err error) error

func ErrFetchNodes

func ErrFetchNodes(err error) error

func ErrGeneratingLoadTest

func ErrGeneratingLoadTest(err error) error

func ErrGetNamespaceDeployments

func ErrGetNamespaceDeployments(err error, obj string) error

func ErrGrpcSupport

func ErrGrpcSupport(err error, obj string) error

func ErrInClusterConfig

func ErrInClusterConfig(err error) error

func ErrInvalidK8SConfig

func ErrInvalidK8SConfig(err error) error

func ErrNewDynamicClientGenerator

func ErrNewDynamicClientGenerator(err error) error

func ErrNewKubeClient

func ErrNewKubeClient(err error) error

func ErrNewKubeClientGenerator

func ErrNewKubeClientGenerator(err error) error

func ErrRestConfigFromKubeConfig

func ErrRestConfigFromKubeConfig(err error) error

func ErrRetrieveNamespacesList

func ErrRetrieveNamespacesList(err error) error

func ErrRetrievePodList

func ErrRetrievePodList(err error) error

func ErrRunningNighthawkServer

func ErrRunningNighthawkServer(err error) error

func ErrRunningTest

func ErrRunningTest(err error) error

func ErrScanKubernetes

func ErrScanKubernetes(err error) error

func ErrStartingNighthawkServer

func ErrStartingNighthawkServer(err error) error

func ErrTransformingData

func ErrTransformingData(err error) error

func ErrUnmarshal

func ErrUnmarshal(err error, obj string) error

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 FlattenMinifyKubeConfig

func FlattenMinifyKubeConfig(config []byte) ([]byte, error)

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 NestedMapExplorer

func NestedMapExplorer(
	mp map[interface{}]interface{},
	fn func(key interface{}, value interface{}) (interface{}, interface{}),
)

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 ResolveFSRef

func ResolveFSRef(path string) (string, error)

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 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