cloudsql

package

v0.5.1 Latest Latest Go to latest Published: Nov 12, 2025 License: Apache-2.0 Imports: 22 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 CloudSQLHardwareInfo(logger *logrus.Logger, config Config, ...) func(ctx context.Context, metric_state *agent.MetricsState) error
func DetectConfigFromConfigFile() bool
func DetectConfigFromEnv() bool
func GetCPUCount(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetCPUUtilization(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetDiskIOPSRead(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetDiskIOPSWrite(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetDiskSize(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetDiskUsedPercentage(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetMemoryTotal(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetMemoryUsed(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetMemoryUsedPercentage(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetNetworkReceiveCount(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
func GetNetworkSentCount(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (monitoringpb.TypedValue, error)
type CloudMonitoringClient
type CloudSQLAdapter
- func CreateCloudSQLAdapter() (*CloudSQLAdapter, error)
- func (adapter *CloudSQLAdapter) ApplyConfig(proposedConfig *agent.ProposedConfigResponse) error
- func (adapter *CloudSQLAdapter) Collectors() []agent.MetricCollector
- func (adapter *CloudSQLAdapter) GetActiveConfig() (agent.ConfigArraySchema, error)
- func (adapter *CloudSQLAdapter) GetSystemInfo() ([]metrics.FlatValue, error)
- func (adapter *CloudSQLAdapter) Guardrails() *guardrails.Signal
type Config
- func ConfigFromViper() (Config, error)
type MemoryMetrics
- func GetMemoryMetrics(cloudMonitoringClient *CloudMonitoringClient, projectID string, ...) (MemoryMetrics, error)
type QueryLabel
type SqlAdminClient
- func NewSqlAdminClient(client *sqladmin.Service) SqlAdminClient
- func (client *SqlAdminClient) ApplyFlags(projectId string, databaseName string, newFlags []*sqladmin.DatabaseFlags) error
type State

Constants ¶

View Source

const DEFAULT_CONFIG_KEY = "cloudsql"

Variables ¶

This section is empty.

Functions ¶

func CloudSQLHardwareInfo ¶

func CloudSQLHardwareInfo(logger *logrus.Logger, config Config, cloudMonitoringClient *CloudMonitoringClient) func(ctx context.Context, metric_state *agent.MetricsState) error

func DetectConfigFromConfigFile ¶

func DetectConfigFromConfigFile() bool

func DetectConfigFromEnv ¶

func DetectConfigFromEnv() bool

func GetCPUCount ¶

func GetCPUCount(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetCPUUtilization ¶

func GetCPUUtilization(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetDiskIOPSRead ¶

func GetDiskIOPSRead(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetDiskIOPSWrite ¶

func GetDiskIOPSWrite(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetDiskSize ¶

func GetDiskSize(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetDiskUsedPercentage ¶

func GetDiskUsedPercentage(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetMemoryTotal ¶

func GetMemoryTotal(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetMemoryUsed ¶

func GetMemoryUsed(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetMemoryUsedPercentage ¶

func GetMemoryUsedPercentage(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetNetworkReceiveCount ¶

func GetNetworkReceiveCount(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

func GetNetworkSentCount ¶

func GetNetworkSentCount(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (monitoringpb.TypedValue, error)

Types ¶

type CloudMonitoringClient ¶

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

type CloudSQLAdapter ¶

type CloudSQLAdapter struct {
	agent.CommonAgent
	PGDriver              *pgPool.Pool
	State                 *State
	CloudSQLConfig        Config
	CloudMonitoringClient *CloudMonitoringClient
	CloudSQLAdminClient   *SqlAdminClient
	GuardrailSettings     *guardrails.Config

	PGVersion string
	// contains filtered or unexported fields
}

func CreateCloudSQLAdapter ¶

func CreateCloudSQLAdapter() (*CloudSQLAdapter, error)

func (*CloudSQLAdapter) ApplyConfig ¶

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

func (*CloudSQLAdapter) Collectors ¶

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

func (*CloudSQLAdapter) GetActiveConfig ¶

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

func (*CloudSQLAdapter) GetSystemInfo ¶

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

func (*CloudSQLAdapter) Guardrails ¶

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

type Config ¶

type Config struct {
	ProjectID    string `mapstructure:"project_id" validate:"required"`
	DatabaseName string `mapstructure:"database_name" validate:"required"`
}

func ConfigFromViper ¶

func ConfigFromViper() (Config, error)

type MemoryMetrics ¶

type MemoryMetrics struct {
	Total               int64
	Used                int64
	Freeable            int64
	UsedPercentage      float64
	AvailablePercentage float64
}

func GetMemoryMetrics ¶

func GetMemoryMetrics(cloudMonitoringClient *CloudMonitoringClient, projectID string, databaseName string) (MemoryMetrics, error)

type QueryLabel ¶

type QueryLabel struct {
	Name  string
	Value string
}

type SqlAdminClient ¶

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

func NewSqlAdminClient ¶

func NewSqlAdminClient(client *sqladmin.Service) SqlAdminClient

func (*SqlAdminClient) ApplyFlags ¶

func (client *SqlAdminClient) ApplyFlags(projectId string, databaseName string, newFlags []*sqladmin.DatabaseFlags) error

type State ¶

type State struct {
	LastGuardrailCheck time.Time
}

Source Files ¶

View all Source files

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