helpers

Documentation

Index

• func FortioLoadTest(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 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 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 GrafanaClient
  • func NewGrafanaClient(BaseURL, APIKey string, validateConfig bool) (*GrafanaClient, error)
  • func NewGrafanaClientForPrometheus(promURL string) *GrafanaClient
  • func (g *GrafanaClient) GetGrafanaBoards(dashboardSearch string) ([]*models.GrafanaBoard, error)
  • func (g *GrafanaClient) GrafanaConfigValidator() (uint, error)
  • func (g *GrafanaClient) GrafanaQuery(ctx context.Context, queryData *url.Values) ([]byte, error)
  • func (g *GrafanaClient) GrafanaQueryRange(ctx context.Context, queryData *url.Values) ([]byte, error)
  • func (g *GrafanaClient) ProcessBoard(board *sdk.Board, link *sdk.FoundBoard) (*models.GrafanaBoard, error)
• type PrometheusClient
  • func NewPrometheusClient(ctx context.Context, promURL string, validate bool) (*PrometheusClient, error)
  • func (p *PrometheusClient) ComputeStep(ctx context.Context, start, end time.Time) time.Duration
  • func (p *PrometheusClient) GetStaticBoard(ctx context.Context) (*models.GrafanaBoard, error)
  • func (p *PrometheusClient) ImportGrafanaBoard(ctx context.Context, boardData []byte) (*models.GrafanaBoard, error)
  • func (p *PrometheusClient) Query(ctx context.Context, queryData *url.Values) ([]byte, error)
  • func (p *PrometheusClient) QueryRange(ctx context.Context, queryData *url.Values) ([]byte, error)
  • func (p *PrometheusClient) QueryRangeUsingClient(ctx context.Context, query string, startTime, endTime time.Time, ...) (promModel.Value, 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 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

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

type GrafanaClient struct {
	BaseURL string
	APIKey  string
	OrgID   uint
	// contains filtered or unexported fields
}

GrafanaClient represents a client to Grafana in Meshery

func NewGrafanaClient

func NewGrafanaClient(BaseURL, APIKey string, validateConfig bool) (*GrafanaClient, error)

NewGrafanaClient returns a new GrafanaClient

func NewGrafanaClientForPrometheus

func NewGrafanaClientForPrometheus(promURL string) *GrafanaClient

NewGrafanaClientForPrometheus returns a limited GrafanaClient for use with Prometheus

func (*GrafanaClient) GetGrafanaBoards

func (g *GrafanaClient) GetGrafanaBoards(dashboardSearch string) ([]*models.GrafanaBoard, error)

GetGrafanaBoards retrieves all the Grafana boards matching a search

func (*GrafanaClient) GrafanaConfigValidator

func (g *GrafanaClient) GrafanaConfigValidator() (uint, error)

GrafanaConfigValidator validates connection to Grafana

func (*GrafanaClient) GrafanaQuery

func (g *GrafanaClient) GrafanaQuery(ctx context.Context, queryData *url.Values) ([]byte, error)

GrafanaQuery parses the provided query data and queries Grafana and streams response

func (*GrafanaClient) GrafanaQueryRange

func (g *GrafanaClient) GrafanaQueryRange(ctx context.Context, queryData *url.Values) ([]byte, error)

GrafanaQueryRange parses the given params and performs Grafana range queries

func (*GrafanaClient) ProcessBoard

func (g *GrafanaClient) ProcessBoard(board *sdk.Board, link *sdk.FoundBoard) (*models.GrafanaBoard, error)

ProcessBoard accepts raw Grafana board and returns a processed GrafanaBoard to be used in Meshery

type PrometheusClient

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

PrometheusClient represents a prometheus client in Meshery

func NewPrometheusClient

func NewPrometheusClient(ctx context.Context, promURL string, validate bool) (*PrometheusClient, error)

NewPrometheusClient returns a PrometheusClient

func (*PrometheusClient) ComputeStep

func (p *PrometheusClient) ComputeStep(ctx context.Context, start, end time.Time) time.Duration

ComputeStep computes the step size for a window

func (*PrometheusClient) GetStaticBoard

func (p *PrometheusClient) GetStaticBoard(ctx context.Context) (*models.GrafanaBoard, error)

GetStaticBoard retrieves the static board config

func (*PrometheusClient) ImportGrafanaBoard

func (p *PrometheusClient) ImportGrafanaBoard(ctx context.Context, boardData []byte) (*models.GrafanaBoard, error)

ImportGrafanaBoard takes raw Grafana board json and returns GrafanaBoard pointer for use in Meshery

func (*PrometheusClient) Query

func (p *PrometheusClient) Query(ctx context.Context, queryData *url.Values) ([]byte, error)

Query queries prometheus using the GrafanaClient

func (*PrometheusClient) QueryRange

func (p *PrometheusClient) QueryRange(ctx context.Context, queryData *url.Values) ([]byte, error)

QueryRange queries prometheus using the GrafanaClient

func (*PrometheusClient) QueryRangeUsingClient

func (p *PrometheusClient) QueryRangeUsingClient(ctx context.Context, query string, startTime, endTime time.Time, step time.Duration) (promModel.Value, error)

QueryRangeUsingClient performs a range query within a window

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