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)
• 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 BadgerSessionPersister
  • func NewBadgerSessionPersister(folderName string) (*BadgerSessionPersister, error)
  • func (s *BadgerSessionPersister) Close()
  • func (s *BadgerSessionPersister) Delete(userID string) error
  • func (s *BadgerSessionPersister) Read(userID string) (*models.Session, error)
  • func (s *BadgerSessionPersister) Write(userID string, data *models.Session) error
• type BitCaskSessionPersister
  • func NewBitCaskSessionPersister(folderName string) (*BitCaskSessionPersister, error)
  • func (s *BitCaskSessionPersister) Close()
  • func (s *BitCaskSessionPersister) Delete(userID string) error
  • func (s *BitCaskSessionPersister) Read(userID string) (*models.Session, error)
  • func (s *BitCaskSessionPersister) Write(userID string, data *models.Session) error
• type FileSessionPersister
  • func NewFileSessionPersister(folder string) *FileSessionPersister
  • func (s *FileSessionPersister) Close()
  • func (s *FileSessionPersister) Delete(userID string) error
  • func (s *FileSessionPersister) Read(userID string) (*models.Session, error)
  • func (s *FileSessionPersister) Write(userID string, data *models.Session) error
• type MapSessionPersister
  • func NewMapSessionPersister() (*MapSessionPersister, error)
  • func (s *MapSessionPersister) Close()
  • func (s *MapSessionPersister) Delete(userID string) error
  • func (s *MapSessionPersister) Read(userID string) (*models.Session, error)
  • func (s *MapSessionPersister) Write(userID string, data *models.Session) error
• 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

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 BadgerSessionPersister

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

BadgerSessionPersister assists with persisting session in a badger store

func NewBadgerSessionPersister

func NewBadgerSessionPersister(folderName string) (*BadgerSessionPersister, error)

NewBadgerSessionPersister creates a new BadgerSessionPersister instance

func (*BadgerSessionPersister) Close

func (s *BadgerSessionPersister) Close()

Close closes the badger store

func (*BadgerSessionPersister) Delete

func (s *BadgerSessionPersister) Delete(userID string) error

Delete removes the session for the user

func (*BadgerSessionPersister) Read

func (s *BadgerSessionPersister) Read(userID string) (*models.Session, error)

Read reads the session data for the given userID

func (*BadgerSessionPersister) Write

func (s *BadgerSessionPersister) Write(userID string, data *models.Session) error

Write persists session for the user

type BitCaskSessionPersister

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

BitCaskSessionPersister assists with persisting session in a Bitcask store

func NewBitCaskSessionPersister

func NewBitCaskSessionPersister(folderName string) (*BitCaskSessionPersister, error)

NewBitCaskSessionPersister creates a new BitCaskSessionPersister instance

func (*BitCaskSessionPersister) Close

func (s *BitCaskSessionPersister) Close()

Close closes the badger store

func (*BitCaskSessionPersister) Delete

func (s *BitCaskSessionPersister) Delete(userID string) error

Delete removes the session for the user

func (*BitCaskSessionPersister) Read

func (s *BitCaskSessionPersister) Read(userID string) (*models.Session, error)

Read reads the session data for the given userID

func (*BitCaskSessionPersister) Write

func (s *BitCaskSessionPersister) Write(userID string, data *models.Session) error

Write persists session for the user

type FileSessionPersister

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

FileSessionPersister assists with persisting session in a file store

func NewFileSessionPersister

func NewFileSessionPersister(folder string) *FileSessionPersister

NewFileSessionPersister returns a new instance of FileSessionPersister

func (*FileSessionPersister) Close

func (s *FileSessionPersister) Close()

Close closes the persister

func (*FileSessionPersister) Delete

func (s *FileSessionPersister) Delete(userID string) error

Delete removes the session for the user

func (*FileSessionPersister) Read

func (s *FileSessionPersister) Read(userID string) (*models.Session, error)

Read reads the session data for the given userID

func (*FileSessionPersister) Write

func (s *FileSessionPersister) Write(userID string, data *models.Session) error

Write persists session for the user

type MapSessionPersister

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

MapSessionPersister assists with persisting session in a badger store

func NewMapSessionPersister

func NewMapSessionPersister() (*MapSessionPersister, error)

NewMapSessionPersister creates a new MapSessionPersister instance

func (*MapSessionPersister) Close

func (s *MapSessionPersister) Close()

Close closes the DB

func (*MapSessionPersister) Delete

func (s *MapSessionPersister) Delete(userID string) error

Delete removes the session for the user

func (*MapSessionPersister) Read

func (s *MapSessionPersister) Read(userID string) (*models.Session, error)

Read reads the session data for the given userID

func (*MapSessionPersister) Write

func (s *MapSessionPersister) Write(userID string, data *models.Session) error

Write persists session for the user

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