postgres

Documentation

Index

• type DB
  • func New(uri, migrationsDir string) (DB, error)
  • func (d DB) Close() error
  • func (d DB) DeactivateConfig(ctx context.Context, userID string) error
  • func (d DB) GetAllConfigs(ctx context.Context) (map[string]configs.View, error)
  • func (d DB) GetAllRulesConfigs(ctx context.Context) (map[string]configs.VersionedRulesConfig, error)
  • func (d DB) GetConfig(ctx context.Context, userID string) (configs.View, error)
  • func (d DB) GetConfigs(ctx context.Context, since configs.ID) (map[string]configs.View, error)
  • func (d DB) GetRulesConfig(ctx context.Context, userID string) (configs.VersionedRulesConfig, error)
  • func (d DB) GetRulesConfigs(ctx context.Context, since configs.ID) (map[string]configs.VersionedRulesConfig, error)
  • func (d DB) RestoreConfig(ctx context.Context, userID string) error
  • func (d DB) SetConfig(ctx context.Context, userID string, cfg configs.Config) error
  • func (d DB) SetDeletedAtConfig(ctx context.Context, userID string, deletedAt pq.NullTime, cfg configs.Config) error
  • func (d DB) SetRulesConfig(ctx context.Context, userID string, oldConfig, newConfig configs.RulesConfig) (bool, error)
  • func (d DB) Transaction(f func(DB) error) error

Types

type DB

type DB struct {
	squirrel.StatementBuilderType
	// contains filtered or unexported fields
}

DB is a postgres db, for dev and production

func New

func New(uri, migrationsDir string) (DB, error)

New creates a new postgres DB

func (DB) Close

func (d DB) Close() error

Close finishes using the db

func (DB) DeactivateConfig

func (d DB) DeactivateConfig(ctx context.Context, userID string) error

DeactivateConfig deactivates a configuration.

func (DB) GetAllConfigs

func (d DB) GetAllConfigs(ctx context.Context) (map[string]configs.View, error)

GetAllConfigs gets all of the configs.

func (DB) GetAllRulesConfigs

func (d DB) GetAllRulesConfigs(ctx context.Context) (map[string]configs.VersionedRulesConfig, error)

GetAllRulesConfigs gets all alertmanager configs for all users.

func (DB) GetConfig

func (d DB) GetConfig(ctx context.Context, userID string) (configs.View, error)

GetConfig gets a configuration.

func (DB) GetConfigs

func (d DB) GetConfigs(ctx context.Context, since configs.ID) (map[string]configs.View, error)

GetConfigs gets all of the configs that have changed recently.

func (DB) GetRulesConfig

func (d DB) GetRulesConfig(ctx context.Context, userID string) (configs.VersionedRulesConfig, error)

GetRulesConfig gets the latest alertmanager config for a user.

func (DB) GetRulesConfigs

func (d DB) GetRulesConfigs(ctx context.Context, since configs.ID) (map[string]configs.VersionedRulesConfig, error)

GetRulesConfigs gets all the alertmanager configs that have changed since a given config.

func (DB) RestoreConfig

func (d DB) RestoreConfig(ctx context.Context, userID string) error

RestoreConfig restores configuration.

func (DB) SetConfig

func (d DB) SetConfig(ctx context.Context, userID string, cfg configs.Config) error

SetConfig sets a configuration.

func (DB) SetDeletedAtConfig

func (d DB) SetDeletedAtConfig(ctx context.Context, userID string, deletedAt pq.NullTime, cfg configs.Config) error

SetDeletedAtConfig sets a deletedAt for configuration by adding a single new row with deleted_at set the same as SetConfig is actually insert

func (DB) SetRulesConfig

func (d DB) SetRulesConfig(ctx context.Context, userID string, oldConfig, newConfig configs.RulesConfig) (bool, error)

SetRulesConfig sets the current alertmanager config for a user.

func (DB) Transaction

func (d DB) Transaction(f func(DB) error) error

Transaction runs the given function in a postgres transaction. If fn returns an error the txn will be rolled back.