manager

Mar 23, 2026

Changes in this version

+ type Hooks struct

+ OnShutdown func()

+ OnStartup func()

type Manager

+ func (m *Manager) WithHooks(hooks Hooks) *Manager

Feb 24, 2026

Changes in this version

type Manager

+ func (m *Manager) WithCacheStore(cacheStore store.StoreInterface) *Manager

+ func (m *Manager) WithLocker(locker ChannelLocker) *Manager

+ func (m *Manager) WithMetrics(metrics types.Metrics) *Manager

+ func (m *Manager) WithSettings(settings *config.ManagerSettings) *Manager

type RedisChannelLocker

+ func (r *RedisChannelLocker) WithMaxDrainWait(d time.Duration) *RedisChannelLocker

Feb 24, 2026

Changes in this version

+ type RedisRateLimitGateOption func(*redisRateLimitGateOptions)

+ func WithRateLimitGateKeyPrefix(prefix string) RedisRateLimitGateOption

+ func WithRateLimitGateMaxDrainWait(d time.Duration) RedisRateLimitGateOption

Feb 24, 2026

Changes in this version

+ type LocalRateLimitGate struct

+ func NewLocalRateLimitGate(logger types.Logger, maxDrainWait time.Duration) *LocalRateLimitGate

+ func (g *LocalRateLimitGate) IsBlocked(_ context.Context) (bool, error)

+ func (g *LocalRateLimitGate) SetReadyCheck(fn func() bool)

+ func (g *LocalRateLimitGate) Signal(_ context.Context, until time.Time) error

+ func (g *LocalRateLimitGate) Wait(ctx context.Context) error

+ type NoopRateLimitGate struct

+ func (n *NoopRateLimitGate) IsBlocked(_ context.Context) (bool, error)

+ func (n *NoopRateLimitGate) SetReadyCheck(_ func() bool)

+ func (n *NoopRateLimitGate) Signal(_ context.Context, _ time.Time) error

+ func (n *NoopRateLimitGate) Wait(_ context.Context) error

+ type RateLimitGate interface

+ IsBlocked func(ctx context.Context) (bool, error)

+ SetReadyCheck func(fn func() bool)

+ Signal func(ctx context.Context, until time.Time) error

+ Wait func(ctx context.Context) error

+ type RedisRateLimitGate struct

+ func NewRedisRateLimitGate(client redis.UniversalClient, logger types.Logger, keyPrefix string, ...) *RedisRateLimitGate

+ func (g *RedisRateLimitGate) IsBlocked(ctx context.Context) (bool, error)

+ func (g *RedisRateLimitGate) SetReadyCheck(fn func() bool)

+ func (g *RedisRateLimitGate) Signal(ctx context.Context, until time.Time) error

+ func (g *RedisRateLimitGate) Wait(ctx context.Context) error

Feb 19, 2026

Changes in this version

+ var ErrChannelLockUnavailable = errors.New("channel lock unavailable")

+ type ChannelLock interface

+ Key func() string

+ Release func() error

+ type ChannelLocker interface

+ Obtain func(ctx context.Context, key string, ttl time.Duration, maxWait time.Duration) (ChannelLock, error)

+ type FifoQueue interface

+ Name func() string

+ Receive func(ctx context.Context, sinkCh chan<- *types.FifoQueueItem) error

+ Send func(ctx context.Context, slackChannelID, dedupID, body string) error

+ type HTTPWebhookHandler struct

+ func NewHTTPWebhookHandler(logger types.Logger) *HTTPWebhookHandler

+ func (h *HTTPWebhookHandler) HandleWebhook(ctx context.Context, target string, data *types.WebhookCallback, ...) error

+ func (h *HTTPWebhookHandler) ShouldHandleWebhook(_ context.Context, target string) bool

+ func (h *HTTPWebhookHandler) WithRequestTimeout(timeout time.Duration) *HTTPWebhookHandler

+ type Manager struct

+ func New(db types.DB, alertQueue FifoQueue, commandQueue FifoQueue, ...) *Manager

+ func (m *Manager) RegisterWebhookHandler(handler WebhookHandler) *Manager

+ func (m *Manager) Run(ctx context.Context) error

+ func (m *Manager) UpdateSettings(settings *config.ManagerSettings) error

+ type NoopChannelLock struct

+ func (n *NoopChannelLock) Key() string

+ func (n *NoopChannelLock) Release() error

+ type NoopChannelLocker struct

+ func (n *NoopChannelLocker) Obtain(_ context.Context, key string, _ time.Duration, _ time.Duration) (ChannelLock, error)

+ type RedisChannelLock struct

+ func (l *RedisChannelLock) Key() string

+ func (l *RedisChannelLock) Release() error

+ type RedisChannelLocker struct

+ func NewRedisChannelLocker(client *redis.Client) *RedisChannelLocker

+ func (r *RedisChannelLocker) Obtain(ctx context.Context, key string, ttl time.Duration, maxWait time.Duration) (ChannelLock, error)

+ func (r *RedisChannelLocker) WithKeyPrefix(prefix string) *RedisChannelLocker

+ func (r *RedisChannelLocker) WithRetryBackoff(backoff time.Duration) *RedisChannelLocker

+ type RedisFifoQueue struct

+ func NewRedisFifoQueue(client redis.UniversalClient, locker ChannelLocker, name string, ...) *RedisFifoQueue

+ func (q *RedisFifoQueue) Init() (*RedisFifoQueue, error)

+ func (q *RedisFifoQueue) Receive(ctx context.Context, sinkCh chan<- *types.FifoQueueItem) error

+ func (q *RedisFifoQueue) Send(ctx context.Context, slackChannelID, dedupID, body string) error

+ type RedisFifoQueueOption func(*RedisFifoQueueOptions)

+ func WithClaimMinIdleTime(duration time.Duration) RedisFifoQueueOption

+ func WithConsumerGroup(group string) RedisFifoQueueOption

+ func WithKeyPrefix(prefix string) RedisFifoQueueOption

+ func WithLockTTL(ttl time.Duration) RedisFifoQueueOption

+ func WithMaxStreamLength(length int64) RedisFifoQueueOption

+ func WithPollInterval(interval time.Duration) RedisFifoQueueOption

+ func WithStreamInactivityTimeout(timeout time.Duration) RedisFifoQueueOption

+ func WithStreamRefreshInterval(interval time.Duration) RedisFifoQueueOption

+ type RedisFifoQueueOptions struct

+ type RedisFifoQueueProducer struct

+ func NewRedisFifoQueueProducer(client redis.UniversalClient, name string, logger types.Logger, ...) *RedisFifoQueueProducer

+ func (p *RedisFifoQueueProducer) Init() (*RedisFifoQueueProducer, error)

+ func (p *RedisFifoQueueProducer) Name() string

+ func (p *RedisFifoQueueProducer) Send(ctx context.Context, slackChannelID, _, body string) error

+ type SlackClient interface

+ Delete func(ctx context.Context, issue *models.Issue, reason string, ...) error

+ DeletePost func(ctx context.Context, channelID, ts string) error

+ GetChannelName func(ctx context.Context, channelID string) string

+ IsAlertChannel func(ctx context.Context, channelID string) (bool, string, error)

+ Update func(ctx context.Context, channelID string, allChannelIssues []*models.Issue) error

+ UpdateSingleIssue func(ctx context.Context, issue *models.Issue, reason string) error

+ UpdateSingleIssueWithThrottling func(ctx context.Context, issue *models.Issue, reason string, issuesInChannel int) error

+ type WebhookHandler interface

+ HandleWebhook func(ctx context.Context, target string, data *types.WebhookCallback, ...) error

+ ShouldHandleWebhook func(ctx context.Context, target string) bool