generation

type ApplicationSelector ¶

type ApplicationSelector struct {
	Application *optimizeappsv1alpha1.Application
	Scenario    *optimizeappsv1alpha1.Scenario
	Objective   *optimizeappsv1alpha1.Objective
}

ApplicationSelector is responsible for "scanning" the application definition itself.

func (s *ApplicationSelector) Map(*yaml.RNode, yaml.ResourceMeta) ([]interface{}, error)

func (s *ApplicationSelector) Select([]*yaml.RNode) ([]*yaml.RNode, error)

type BuiltInPrometheus ¶

type BuiltInPrometheus struct {
	SetupTaskName          string
	ClusterRoleName        string
	ServiceAccountName     string
	ClusterRoleBindingName string

	sfio.ObjectSlice
}

func (p *BuiltInPrometheus) Update(exp *optimizev1beta2.Experiment) error

type ContainerResourcesSelector ¶

type ContainerResourcesSelector optimizeappsv1alpha1.ContainerResources

ContainerResourcesSelector scans for container resources specifications (requests/limits).

func (s *ContainerResourcesSelector) Map(node *yaml.RNode, meta yaml.ResourceMeta) ([]interface{}, error)

func (s *ContainerResourcesSelector) Select(nodes []*yaml.RNode) ([]*yaml.RNode, error)

type CustomSource ¶

type CustomSource struct {
	Scenario    *optimizeappsv1alpha1.Scenario
	Objective   *optimizeappsv1alpha1.Objective
	Application *optimizeappsv1alpha1.Application
}

func (s *CustomSource) Metrics() ([]optimizev1beta2.Metric, error)

func (s *CustomSource) Update(exp *optimizev1beta2.Experiment) error

type DatadogMetricsSource ¶

type DatadogMetricsSource struct {
	Goal *optimizeappsv1alpha1.Goal
}

func (s *DatadogMetricsSource) Metrics() ([]optimizev1beta2.Metric, error)

type DurationMetricsSource ¶

type DurationMetricsSource struct {
	Goal *optimizeappsv1alpha1.Goal
}

func (s *DurationMetricsSource) Metrics() ([]optimizev1beta2.Metric, error)

type EnvironmentVariablesSelector ¶

type EnvironmentVariablesSelector optimizeappsv1alpha1.EnvironmentVariable

EnvironmentVariablesSelector scans for environment variables.

func (s *EnvironmentVariablesSelector) Map(node *yaml.RNode, meta yaml.ResourceMeta) ([]interface{}, error)

func (s *EnvironmentVariablesSelector) Select(nodes []*yaml.RNode) ([]*yaml.RNode, error)

type ExperimentSource ¶

type ExperimentSource interface {
	Update(exp *optimizev1beta2.Experiment) error
}

ExperimentSource allows selectors to modify the experiment directly. Note that for adding parameters, patches, or metrics, the appropriate source should be used instead.

type LocustSource ¶

type LocustSource struct {
	Scenario    *optimizeappsv1alpha1.Scenario
	Objective   *optimizeappsv1alpha1.Objective
	Application *optimizeappsv1alpha1.Application
}

func (s *LocustSource) Metrics() ([]optimizev1beta2.Metric, error)

func (s *LocustSource) Read() ([]*yaml.RNode, error)

func (s *LocustSource) Update(exp *optimizev1beta2.Experiment) error

type MetricSource ¶

type MetricSource interface {
	Metrics() ([]optimizev1beta2.Metric, error)
}

MetricSource allows selectors to contribute metrics to an experiment.

type ParameterNamer ¶

type ParameterNamer func(meta yaml.ResourceMeta, path []string, name string) string

ParameterNamer is used to compute the name of an optimization parameter.

type ParameterSource ¶

type ParameterSource interface {
	Parameters(name ParameterNamer) ([]optimizev1beta2.Parameter, error)
}

ParameterSource allows selectors to add parameters to an experiment. In general PatchSources should also be ParameterSources to ensure the parameters used in the generated patches are configured on the experiment.

type PatchSource ¶

type PatchSource interface {
	TargetRef() *corev1.ObjectReference
	Patch(name ParameterNamer) (yaml.Filter, error)
}

PatchSource allows selectors to contribute changes to the patch of a particular resource. In general, ParameterSource should also be implemented to add any parameters referenced by the generated patches.

type PrometheusMetricsSource ¶

type PrometheusMetricsSource struct {
	Goal *optimizeappsv1alpha1.Goal
}

func (s *PrometheusMetricsSource) Metrics() ([]optimizev1beta2.Metric, error)

type ReplicaSelector ¶

type ReplicaSelector optimizeappsv1alpha1.Replicas

ReplicaSelector identifies zero or more replica specifications.

func (s *ReplicaSelector) Map(node *yaml.RNode, meta yaml.ResourceMeta) ([]interface{}, error)

func (s *ReplicaSelector) Select(nodes []*yaml.RNode) ([]*yaml.RNode, error)

type RequestsMetricsSource ¶

type RequestsMetricsSource struct {
	Goal *optimizeappsv1alpha1.Goal
}

func (s *RequestsMetricsSource) Metrics() ([]optimizev1beta2.Metric, error)

type StormForgePerformanceAuthorization ¶

type StormForgePerformanceAuthorization struct {
	// The configuration to get authorization information from, leave nil to get the default.
	Config *config.OptimizeConfig
	// The function used to lookup environment variables, leave nil to get the default.
	LookupEnvFunc func(string) (string, bool)
	// The label to use to describe the Performance Service Account (if needed)
	ServiceAccountLabel func() string
}

StormForgePerformanceAuthorization is a helper for obtaining StormForge Performance access tokens (JWTs). Normally, low level code like this does not have access to the application layer configuration so this is a bit of a hack to ensure we can talk to the appropriate APIs.

func (az *StormForgePerformanceAuthorization) AccessToken(ctx context.Context, org string) (string, error)

type StormForgePerformanceSource ¶

type StormForgePerformanceSource struct {
	Scenario    *optimizeappsv1alpha1.Scenario
	Objective   *optimizeappsv1alpha1.Objective
	Application *optimizeappsv1alpha1.Application
}

func (s *StormForgePerformanceSource) Metrics() ([]optimizev1beta2.Metric, error)

func (s *StormForgePerformanceSource) Read() ([]*yaml.RNode, error)

func (s *StormForgePerformanceSource) Update(exp *optimizev1beta2.Experiment) error

type Transformer ¶

type Transformer struct {
	// Flag indicating the all of the resources that were scanned should also be included in the output.
	IncludeApplicationResources bool
}

Transformer is used to convert all of the output from the selectors, only selector output matching the "*Source" interfaces are supported.

func (t *Transformer) Transform(nodes []*yaml.RNode, selected []interface{}) ([]*yaml.RNode, error)