rds

Documentation

Overview

Package rds contains business logic of working with AWS RDS.

Index

• type Instance
• type InstanceID
• type Service
  • func NewService(config *ServiceConfig) (*Service, error)
  • func (svc *Service) Add(ctx context.Context, accessKey, secretKey string, id *InstanceID, ...) error
  • func (svc *Service) ApplyPrometheusConfiguration(ctx context.Context, q *reform.Querier) error
  • func (svc *Service) Discover(ctx context.Context, accessKey, secretKey string) ([]Instance, error)
  • func (svc *Service) List(ctx context.Context) ([]Instance, error)
  • func (svc *Service) Remove(ctx context.Context, id *InstanceID) error
  • func (svc *Service) Restore(ctx context.Context, tx *reform.TX) error
• type ServiceConfig

Types

type Instance

type Instance struct {
	Node    models.RDSNode
	Service models.RDSService
}

type InstanceID

type InstanceID struct {
	Region string
	Name   string // DBInstanceIdentifier
}

InstanceID uniquely identifies RDS instance. http://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/Overview.DBInstance.html Each DB instance has a DB instance identifier. This customer-supplied name uniquely identifies the DB instance when interacting with the Amazon RDS API and AWS CLI commands. The DB instance identifier must be unique for that customer in an AWS Region.

type Service

type Service struct {
	*ServiceConfig
	// contains filtered or unexported fields
}

Service is responsible for interactions with AWS RDS.

func NewService

func NewService(config *ServiceConfig) (*Service, error)

NewService creates a new service.

func (*Service) Add

func (svc *Service) Add(ctx context.Context, accessKey, secretKey string, id *InstanceID, username, password string) error

func (*Service) ApplyPrometheusConfiguration

func (svc *Service) ApplyPrometheusConfiguration(ctx context.Context, q *reform.Querier) error

func (*Service) Discover

func (svc *Service) Discover(ctx context.Context, accessKey, secretKey string) ([]Instance, error)

func (*Service) List

func (svc *Service) List(ctx context.Context) ([]Instance, error)

func (*Service) Remove

func (svc *Service) Remove(ctx context.Context, id *InstanceID) error

func (*Service) Restore

func (svc *Service) Restore(ctx context.Context, tx *reform.TX) error

Restore configuration from database.

type ServiceConfig

type ServiceConfig struct {
	MySQLdExporterPath    string
	RDSExporterPath       string
	RDSExporterConfigPath string

	DB            *reform.DB
	Prometheus    *prometheus.Service
	QAN           *qan.Service
	Supervisor    services.Supervisor
	PortsRegistry *ports.Registry
}