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

func NewAdaptersTracker

func NewAdaptersTracker(adapterURLs []string) *AdaptersTracker

func (*AdaptersTracker) AddAdapter

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

func (*AdaptersTracker) GetAdapters

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

func (*AdaptersTracker) RemoveAdapter

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

type GrafanaClient

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

func NewGrafanaClient

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

func NewGrafanaClientForPrometheus

func NewGrafanaClientForPrometheus(promURL string) *GrafanaClient

func (*GrafanaClient) GetGrafanaBoards

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

func (*GrafanaClient) GrafanaConfigValidator

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

func (*GrafanaClient) GrafanaQuery

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

func (*GrafanaClient) GrafanaQueryRange

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

func (*GrafanaClient) ProcessBoard

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

type PrometheusClient

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

func NewPrometheusClient

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

func (*PrometheusClient) ComputeStep

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

func (*PrometheusClient) GetStaticBoard

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

func (*PrometheusClient) ImportGrafanaBoard

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

func (*PrometheusClient) Query

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

func (*PrometheusClient) QueryRange

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

func (*PrometheusClient) QueryRangeUsingClient

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

type UUIDQueryTracker

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

func NewUUIDQueryTracker

func NewUUIDQueryTracker() *UUIDQueryTracker

func (*UUIDQueryTracker) AddOrFlagQuery

func (a *UUIDQueryTracker) AddOrFlagQuery(ctx context.Context, uuid, query string, flag bool)

func (*UUIDQueryTracker) GetQueriesForUUID

func (a *UUIDQueryTracker) GetQueriesForUUID(ctx context.Context, uuid string) map[string]bool

func (*UUIDQueryTracker) RemoveUUID

func (a *UUIDQueryTracker) RemoveUUID(ctx context.Context, uuid string)