azureflex

package

v0.5.3 Latest Latest Go to latest Published: Nov 21, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dbtuneai/agent

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ApplyParameter(ctx context.Context, logger *logrus.Logger, ...) (bool, error)
func AsCollector(metricGetter func() (float64, error), metric metrics.MetricDef) func(ctx context.Context, metric_state *agent.MetricsState) error
func CPUUtilization(subscriptionId string, resourceGroupName string, serverName string) func() (float64, error)
func DetectConfigFromConfigFile() bool
func DetectConfigFromEnv() bool
func GetMostRecentAzureMetric(subscriptionId string, resourceGroupName string, serverName string, ...) (float64, error)
func MemoryPercent(subscriptionId string, resourceGroupName string, serverName string) func() (float64, error)
type AzureFlexAdapter
- func CreateAzureFlexAdapter() (*AzureFlexAdapter, error)
type Config
- func ConfigFromViper() (Config, error)
type GetMostRecentAzureMetricOpts
- func DefaultGetMostRecentAzureMetricOpts() GetMostRecentAzureMetricOpts

Constants ¶

View Source

const DEFAULT_CONFIG_KEY = "azure_flex"

Variables ¶

This section is empty.

Functions ¶

func ApplyParameter ¶

func ApplyParameter(ctx context.Context, logger *logrus.Logger, paramsClient *armpostgresqlflexibleservers.ConfigurationsClient, resourceGroupName string, serverName string, config agent.PGConfigRow) (bool, error)

func AsCollector ¶

func AsCollector(metricGetter func() (float64, error), metric metrics.MetricDef) func(ctx context.Context, metric_state *agent.MetricsState) error

func CPUUtilization ¶

func CPUUtilization(subscriptionId string, resourceGroupName string, serverName string) func() (float64, error)

func DetectConfigFromConfigFile ¶

func DetectConfigFromConfigFile() bool

func DetectConfigFromEnv ¶

func DetectConfigFromEnv() bool

func GetMostRecentAzureMetric ¶

func GetMostRecentAzureMetric(subscriptionId string, resourceGroupName string, serverName string, metricName string, opts GetMostRecentAzureMetricOpts) (float64, error)

func MemoryPercent ¶

func MemoryPercent(subscriptionId string, resourceGroupName string, serverName string) func() (float64, error)

Types ¶

type AzureFlexAdapter ¶

type AzureFlexAdapter struct {
	agent.CommonAgent
	AzureFlexConfig Config
	PGDriver        *pgxpool.Pool
	GuardrailConfig guardrails.Config

	PGVersion string
	// contains filtered or unexported fields
}

func CreateAzureFlexAdapter ¶

func CreateAzureFlexAdapter() (*AzureFlexAdapter, error)

func (*AzureFlexAdapter) ApplyConfig ¶

func (adapter *AzureFlexAdapter) ApplyConfig(proposedConfig *agent.ProposedConfigResponse) error

func (*AzureFlexAdapter) Collectors ¶

func (adapter *AzureFlexAdapter) Collectors() []agent.MetricCollector

func (*AzureFlexAdapter) GetActiveConfig ¶

func (adapter *AzureFlexAdapter) GetActiveConfig() (agent.ConfigArraySchema, error)

func (*AzureFlexAdapter) GetSystemInfo ¶

func (adapter *AzureFlexAdapter) GetSystemInfo() ([]metrics.FlatValue, error)

func (*AzureFlexAdapter) Guardrails ¶

func (adapter *AzureFlexAdapter) Guardrails() *guardrails.Signal

type Config ¶

type Config struct {
	SubscriptionID    string `mapstructure:"subscription_id" validate:"required"`
	ResourceGroupName string `mapstructure:"resource_group_name" validate:"required"`
	ServerName        string `mapstructure:"server_name" validate:"required"`
}

func ConfigFromViper ¶

func ConfigFromViper() (Config, error)

type GetMostRecentAzureMetricOpts ¶

type GetMostRecentAzureMetricOpts struct {
	Aggregation string
	Interval    string
}

func DefaultGetMostRecentAzureMetricOpts ¶

func DefaultGetMostRecentAzureMetricOpts() GetMostRecentAzureMetricOpts

Source Files ¶

View all Source files

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