metrics

Documentation

Index

• func FetchDeploymentStatus(ctx context.Context, namespace, name string, duration time.Duration) <-chan DeploymentStatus
• func FetchDeploymentsStatus(ctx context.Context, namespace string, selector labels.Selector, ...) <-chan DeploymentStatus
• func FetchRouteStatus(ctx context.Context, namespace, name string, duration time.Duration) <-chan RouteStatus
• func FetchSKSStatus(ctx context.Context, namespace string, selector labels.Selector, ...) <-chan ServerlessServiceStatus
• func HandleResult(q *quickstore.Quickstore, res vegeta.Result, latencyKey string, ...)
• type AggregateResult
  • func NewAggregateResult(initialSize int) *AggregateResult
• type DeploymentStatus
• type RouteStatus
• type ServerlessServiceStatus

Functions

func FetchDeploymentStatus

func FetchDeploymentStatus(
	ctx context.Context, namespace, name string, duration time.Duration,
) <-chan DeploymentStatus

FetchDeploymentStatus creates a channel that can return the up-to-date DeploymentStatus periodically, selected via deployment name (at most one deployment).

func FetchDeploymentsStatus

func FetchDeploymentsStatus(
	ctx context.Context, namespace string, selector labels.Selector,
	duration time.Duration,
) <-chan DeploymentStatus

FetchDeploymentsStatus creates a channel that can return the up-to-date DeploymentStatus periodically, selected via a label selector (can be more than one deployment).

func FetchRouteStatus

func FetchRouteStatus(ctx context.Context, namespace, name string, duration time.Duration) <-chan RouteStatus

FetchRouteStatus returns a channel that will contain the traffic distribution at regular time intervals.

func FetchSKSStatus

func FetchSKSStatus(
	ctx context.Context, namespace string, selector labels.Selector,
	duration time.Duration,
) <-chan ServerlessServiceStatus

FetchSKSStatus creates a channel that can return the up-to-date ServerlessServiceOperationMode periodically.

func HandleResult

func HandleResult(q *quickstore.Quickstore, res vegeta.Result, latencyKey string, ar *AggregateResult)

HandleResult will handle the attack result by: 1. Adding its latency as a sample point if no error, or adding it as an error if there is 2. Updating the aggregate results

Types

type AggregateResult

type AggregateResult struct {
	// ErrorRates is a map that saves the number of errors for each timestamp (in secs)
	ErrorRates map[int64]int64
	// RequestRates is a map that saves the number of requests for each timestamp (in secs)
	RequestRates map[int64]int64
}

AggregateResult is the aggregated result of requests for better visualization.

func NewAggregateResult

func NewAggregateResult(initialSize int) *AggregateResult

NewAggregateResult returns the pointer of a new AggregateResult object.

type DeploymentStatus

type DeploymentStatus struct {
	DesiredReplicas int32
	ReadyReplicas   int32
	DeploymentName  string
	// Time is the time when the status is fetched
	Time time.Time
}

DeploymentStatus is a struct that wraps the status of a deployment.

type RouteStatus

type RouteStatus struct {
	Traffic []v1.TrafficTarget
	Time    time.Time
}

RouteStatus contains the traffic distribution at the probe time.

type ServerlessServiceStatus

type ServerlessServiceStatus struct {
	Mode          netv1alpha1.ServerlessServiceOperationMode
	NumActivators int32
	// Time is the time when the status is fetched
	Time time.Time
}

ServerlessServiceStatus is a struct that wraps the status of a serverless service.