db

Documentation

Index

• type Config
• type DbClient
  • func NewDbClientFromEnvironment(lg *zap.Logger) (*DbClient, error)
  • func (d *DbClient) AutoMigrate(ctx context.Context) error
  • func (d *DbClient) CreateOrUpdateIncidents(ctx context.Context, incidents []api.Incident) error
  • func (d *DbClient) DeleteStatusPage(background context.Context, url string) error
  • func (d *DbClient) GetAllStatusPages(ctx context.Context) ([]api.StatusPage, error)
  • func (d *DbClient) GetCurrentIncidents(ctx context.Context, statusPageUrl string) ([]api.Incident, error)
  • func (d *DbClient) GetIncidents(ctx context.Context, statusPageUrl string) ([]api.Incident, error)
  • func (d *DbClient) GetIncidentsWithoutJobsStarted(ctx context.Context, limit int) ([]api.Incident, error)
  • func (d *DbClient) GetStatusPage(ctx context.Context, url string) (*api.StatusPage, error)
  • func (d *DbClient) InsertStatusPage(ctx context.Context, statusPage api.StatusPage) error
  • func (d *DbClient) SeedStatusPages() error
  • func (d *DbClient) SetIncidentNotificationStartedToTrue(ctx context.Context, incidents []api.Incident) error
  • func (d *DbClient) UpdateStatusPage(ctx context.Context, statusPage api.StatusPage) error

Types

type Config

type Config struct {
	Host     string `envconfig:"POSTGRES_HOST"`
	Port     string `envconfig:"POSTGRES_PORT"`
	User     string `envconfig:"POSTGRES_USER"`
	Password string `envconfig:"POSTGRES_PASSWORD"`
	Database string `envconfig:"POSTGRES_DATABASE"`
}

type DbClient

type DbClient struct {
	PgxPool *pgxpool.Pool
	// contains filtered or unexported fields
}

func NewDbClientFromEnvironment

func NewDbClientFromEnvironment(lg *zap.Logger) (*DbClient, error)

func (*DbClient) AutoMigrate

func (d *DbClient) AutoMigrate(ctx context.Context) error

func (*DbClient) CreateOrUpdateIncidents

func (d *DbClient) CreateOrUpdateIncidents(ctx context.Context, incidents []api.Incident) error

func (*DbClient) DeleteStatusPage

func (d *DbClient) DeleteStatusPage(background context.Context, url string) error

func (*DbClient) GetAllStatusPages

func (d *DbClient) GetAllStatusPages(ctx context.Context) ([]api.StatusPage, error)

func (*DbClient) GetCurrentIncidents

func (d *DbClient) GetCurrentIncidents(ctx context.Context, statusPageUrl string) ([]api.Incident, error)

Current incidents are incidents that have not ended and have a start time in the last two weeks The two week cutiff is not ideal but some incidents don't have a specified end time

func (*DbClient) GetIncidents

func (d *DbClient) GetIncidents(ctx context.Context, statusPageUrl string) ([]api.Incident, error)

func (*DbClient) GetIncidentsWithoutJobsStarted

func (d *DbClient) GetIncidentsWithoutJobsStarted(ctx context.Context, limit int) ([]api.Incident, error)

func (*DbClient) GetStatusPage

func (d *DbClient) GetStatusPage(ctx context.Context, url string) (*api.StatusPage, error)

func (*DbClient) InsertStatusPage

func (d *DbClient) InsertStatusPage(ctx context.Context, statusPage api.StatusPage) error

func (*DbClient) SeedStatusPages

func (d *DbClient) SeedStatusPages() error

func (*DbClient) SetIncidentNotificationStartedToTrue

func (d *DbClient) SetIncidentNotificationStartedToTrue(ctx context.Context, incidents []api.Incident) error

func (*DbClient) UpdateStatusPage

func (d *DbClient) UpdateStatusPage(ctx context.Context, statusPage api.StatusPage) error