A PostgreSQL storage backend for Slack Manager. Implements the types.DB interface using pgxpool for connection pooling.

go get github.com/slackmgr/slack-manager-postgres-plugin

Requires Go 1.25+ and PostgreSQL 13+.

import (
    postgres "github.com/slackmgr/slack-manager-postgres-plugin"
)

client := postgres.New(
    postgres.WithHost("localhost"),
    postgres.WithPort(5432),
    postgres.WithUser("myuser"),
    postgres.WithPassword("mypassword"),
    postgres.WithDatabase("mydb"),
    postgres.WithSSLMode(postgres.SSLModeRequire),
)

if err := client.Connect(ctx); err != nil {
    log.Fatal(err)
}
defer client.Close(ctx)

if err := client.Init(ctx, false); err != nil {
    log.Fatal(err)
}

Init creates the required tables if they do not exist, validates the schema, and starts the background TTL cleanup goroutine. It is idempotent — calling it multiple times on the same Client is safe. Pass skipSchemaValidation: true to skip the schema validation step.

All options are provided via With* constructor functions. Only WithUser and WithDatabase are required — everything else has a sensible default.

postgres.SSLModeDisable    // No SSL
postgres.SSLModeAllow      // Try non-SSL first, then SSL
postgres.SSLModePrefer     // Try SSL first, then non-SSL (default)
postgres.SSLModeRequire    // SSL only, no certificate verification
postgres.SSLModeVerifyCA   // SSL with CA certificate verification
postgres.SSLModeVerifyFull // SSL with CA and hostname verification

Custom table names are useful for multi-tenant setups or running integration tests alongside production data:

client := postgres.New(
    postgres.WithUser("myuser"),
    postgres.WithDatabase("mydb"),
    postgres.WithIssuesTable("myapp_issues"),
    postgres.WithAlertsTable("myapp_alerts"),
    postgres.WithMoveMappingsTable("myapp_move_mappings"),
    postgres.WithChannelProcessingStateTable("myapp_channel_processing_state"),
)

Table names must be valid PostgreSQL unquoted identifiers (letters, digits, underscores; must not start with a digit).

TTL is always active. By default, alert records expire after 30 days and closed issue records expire after 180 days. Open issues never expire.

When a record's TTL expires it is immediately excluded from all read operations. A background goroutine (started by Init, stopped by Close) periodically runs a DELETE to physically remove expired rows. The cleanup interval defaults to 1 hour and is configurable via WithTTLCleanupInterval. The goroutine can be disabled entirely with WithTTLCleanupDisabled — expired rows will still be excluded from reads, but never physically deleted.

To override the defaults:

client := postgres.New(
    postgres.WithUser("myuser"),
    postgres.WithDatabase("mydb"),
    postgres.WithAlertsTimeToLive(7 * 24 * time.Hour),   // 7 days
    postgres.WithIssuesTimeToLive(90 * 24 * time.Hour),  // 90 days
    postgres.WithTTLCleanupInterval(15 * time.Minute),
)

Four tables are created by Init:

• issues — Slack issues with correlation IDs and open/closed state
• alerts — Alert records
• move_mappings — Issue move tracking between channels
• channel_processing_state — Per-channel processing timestamps

All tables include a version column for schema evolution and an attrs JSONB column for flexible storage. The issues and alerts tables additionally include an expires_at column used for TTL.

This project is licensed under the MIT License — see the LICENSE file for details.

Copyright (c) 2026 Peter Aglen