cloudsql

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

const DEFAULT_CONFIG_KEY = "cloudsql"

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
}