paths

package
v2.1.0-rc.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 15, 2023 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ConfigPrefix is key prefix in etcd for config.
	ConfigPrefix = path.Join("/config")
	// DecisionsPrefix is key prefix in etcd for decisions.
	DecisionsPrefix = path.Join("/decisions")
	// StatusPrefix is key prefix in etcd for status.
	StatusPrefix = path.Join("/status")
	// PoliciesAPIConfigPath is config path in etcd for policies via API.
	PoliciesAPIConfigPath = path.Join(ConfigPrefix, "api", "policies")
	// PoliciesAPIDynamicConfigPath is config path in etcd for  dynamic configuration of policies via API.
	PoliciesAPIDynamicConfigPath = path.Join(ConfigPrefix, "api", "dynamic-config-policies")
	// PoliciesConfigPath is config path in etcd for policies.
	PoliciesConfigPath = path.Join(ConfigPrefix, "policies")
	// PoliciesDynamicConfigPath is config path in etcd for dynamic configuration of policies.
	PoliciesDynamicConfigPath = path.Join(ConfigPrefix, "dynamic-config-policies")
	// ClassifiersPath is config path in etcd for classifiers.
	ClassifiersPath = path.Join(ConfigPrefix, "classifiers")
	// LoadSchedulerConfigPath is config path in etcd for load scheduler.
	LoadSchedulerConfigPath = path.Join(ConfigPrefix, "load_scheduler")
	// LoadSchedulerDecisionsPath is decision path in etcd for load decisions.
	LoadSchedulerDecisionsPath = path.Join(DecisionsPrefix, "load_scheduler")
	// RateLimiterConfigPath is config path in etcd for rate limiter.
	RateLimiterConfigPath = path.Join(ConfigPrefix, "rate_limiter")
	// RateLimiterDecisionsPath is decision path in etcd for rate limiter decisions.
	RateLimiterDecisionsPath = path.Join(DecisionsPrefix, "rate_limiter")
	// RateLimiterDynamicConfigPath is config path in etcd for dynamic config of rate limiter.
	RateLimiterDynamicConfigPath = path.Join(ConfigPrefix, "rate_limiter_dynamic_config")
	// FluxMeterConfigPath is config path in etcd for flux meters.
	FluxMeterConfigPath = path.Join(ConfigPrefix, "flux_meter")
	// TelemetryCollectorConfigPath is config path in etcd for telemetry collector.
	TelemetryCollectorConfigPath = path.Join(ConfigPrefix, "telemetry_collector")
	// PodScalerConfigPath is config path in etcd for pod scaler.
	PodScalerConfigPath = path.Join(ConfigPrefix, "pod_scaler")
	// PodScalerDecisionsPath is decision path in etcd for pod scaler decisions.
	PodScalerDecisionsPath = path.Join(DecisionsPrefix, "pod_scaler")
	// PodScalerStatusPath is decision path in etcd for pod scaler status.
	PodScalerStatusPath = path.Join(StatusPrefix, "pod_scaler")
	// PodScalerDynamicConfigPath is config path in etcd for dynamic config of pod scaler.
	PodScalerDynamicConfigPath = path.Join(ConfigPrefix, "pod_scaler_dynamic_config")
	// RegulatorConfigPath is config path in etcd for load regulator.
	RegulatorConfigPath = path.Join(ConfigPrefix, "regulator")
	// RegulatorDecisionsPath is decision path in etcd for load regulator decisions.
	RegulatorDecisionsPath = path.Join(DecisionsPrefix, "regulator")
	// RegulatorDynamicConfigPath is config path in etcd for dynamic config of load regulator.
	RegulatorDynamicConfigPath = path.Join(ConfigPrefix, "regulator_dynamic_config")
)

Functions

func AgentComponentKey

func AgentComponentKey(agentGroupName, policyName string, componentID string) string

AgentComponentKey returns the identifier for a Component in etcd.

func AgentGroupPrefix

func AgentGroupPrefix(agentGroupName string) string

AgentGroupPrefix returns the prefix for an agent group.

func ClassifierKey

func ClassifierKey(agentGroupName, policyName string, classifierIndex int) string

ClassifierKey returns the identifier for a Classifier in etcd.

func FluxMeterKey

func FluxMeterKey(agentGroupName, fluxMeterName string) string

FluxMeterKey returns the identifier for FluxMeter in etcd.

func PolicyPrefix

func PolicyPrefix(agentGroupName, policyName string) string

PolicyPrefix returns the prefix for a policy.

func TelemetryCollectorKey

func TelemetryCollectorKey(agentGroupName string, policyName string, index int) string

TelemetryCollectorKey returns the identifier for TelemetryCollector in etcd.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL