helpers

package
v0.5.45 Latest Latest
Warning

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

 Go to latest Published: Aug 10, 2021 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ErrErrNewDynamicClientGeneratorCode    = "2048"
	ErrInvalidK8SConfigCode                = "2049"
	ErrClientConfigCode                    = "2050"
	ErrFetchKubernetesNodesCode            = "2051"
	ErrFetchNodesCode                      = "2052"
	ErrFetchKubernetesVersionCode          = "2053"
	ErrScanKubernetesCode                  = "2054"
	ErrRetrievePodListCode                 = "2055"
	ErrDetectServiceForDeploymentImageCode = "2056"
	ErrRetrieveNamespacesListCode          = "2057"
	ErrGetNamespaceDeploymentsCode         = "2058"
	ErrDetectServiceWithNameCode           = "2059"
	ErrGeneratingLoadTestCode              = "2060"
	ErrRunningTestCode                     = "2061"
	ErrConvertingResultToMapCode           = "2062"
	ErrUnmarshalCode                       = "2063"
	ErrGrpcSupportCode                     = "2064"
	ErrStartingNighthawkServerCode         = "2065"
	ErrTransformingDataCode                = "2066"
	ErrRunningNighthawkServerCode          = "2067"
	ErrAddAndValidateExtraHeaderCode       = "2068"
	ErrInClusterConfigCode                 = "2069"
	ErrNewKubeClientGeneratorCode          = "2070"
	ErrRestConfigFromKubeConfigCode        = "2071"
	ErrNewKubeClientCode                   = "2072"
)

Variables

This section is empty.

Functions

func ErrAddAndValidateExtraHeader added in v0.5.38 

func ErrAddAndValidateExtraHeader(err error) error

func ErrClientConfig added in v0.5.38 

func ErrClientConfig(err error) error

func ErrClientSet added in v0.5.38 

func ErrClientSet(err error) error

func ErrConvertingResultToMap added in v0.5.38 

func ErrConvertingResultToMap(err error) error

func ErrDetectServiceForDeploymentImage added in v0.5.38 

func ErrDetectServiceForDeploymentImage(err error) error

func ErrDetectServiceWithName added in v0.5.38 

func ErrDetectServiceWithName(err error) error

func ErrFetchKubernetesNodes added in v0.5.38 

func ErrFetchKubernetesNodes(err error) error

func ErrFetchKubernetesVersion added in v0.5.38 

func ErrFetchKubernetesVersion(err error) error

func ErrFetchNodes added in v0.5.38 

func ErrFetchNodes(err error) error

func ErrGeneratingLoadTest added in v0.5.38 

func ErrGeneratingLoadTest(err error) error

func ErrGetNamespaceDeployments added in v0.5.38 

func ErrGetNamespaceDeployments(err error, obj string) error

func ErrGrpcSupport added in v0.5.38 

func ErrGrpcSupport(err error, obj string) error

func ErrInClusterConfig added in v0.5.38 

func ErrInClusterConfig(err error) error

func ErrInvalidK8SConfig added in v0.5.38 

func ErrInvalidK8SConfig(err error) error

func ErrNewDynamicClientGenerator added in v0.5.38 

func ErrNewDynamicClientGenerator(err error) error

func ErrNewKubeClient added in v0.5.38 

func ErrNewKubeClient(err error) error

func ErrNewKubeClientGenerator added in v0.5.38 

func ErrNewKubeClientGenerator(err error) error

func ErrRestConfigFromKubeConfig added in v0.5.38 

func ErrRestConfigFromKubeConfig(err error) error

func ErrRetrieveNamespacesList added in v0.5.38 

func ErrRetrieveNamespacesList(err error) error

func ErrRetrievePodList added in v0.5.38 

func ErrRetrievePodList(err error) error

func ErrRunningNighthawkServer added in v0.5.38 

func ErrRunningNighthawkServer(err error) error

func ErrRunningTest added in v0.5.38 

func ErrRunningTest(err error) error

func ErrScanKubernetes added in v0.5.38 

func ErrScanKubernetes(err error) error

func ErrStartingNighthawkServer added in v0.5.38 

func ErrStartingNighthawkServer(err error) error

func ErrTransformingData added in v0.5.38 

func ErrTransformingData(err error) error

func ErrUnmarshal added in v0.5.38 

func ErrUnmarshal(err error, obj string) error

func FetchKubernetesNodes added in v0.1.6 

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

FetchKubernetesNodes - function used to fetch nodes metadata

func FetchKubernetesVersion added in v0.1.6 

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 added in v0.5.30 

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

func NewDynamicClient added in v0.5.2 

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

NewDynamicClient generates new dynamic go client

func NewDynamicClientGenerator added in v0.5.2 

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 added in v0.5.1 

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

func NewKubeClientGenerator added in v0.5.2 

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 added in v0.4.4 

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 added in v0.3.13 

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

ScanGrafana - Runs a quick scan for Grafanas

func ScanKubernetes added in v0.2.0 

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

ScanKubernetes scans kubernetes to find the pods for each service mesh

func ScanPromGrafana added in v0.2.4 

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

ScanPromGrafana - Runs a quick scan for Prometheus & Grafanas

func ScanPrometheus added in v0.4.4 

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

ScanPrometheus - Runs a quick scan for Prometheus

func WRK2LoadTest added in v0.3.1 

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

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.