core

package

v1.3.2 Latest Latest Go to latest Published: May 4, 2025 License: GPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var CreateOnCallProvider func(cfg *config.Config, awsClient *ssmincidents.Client) (OnCallProvider, error)

Function that will be implemented in the common package to avoid circular imports

func InitOnCallWorkflow(awsClient *ssmincidents.Client, redisClient *redis.Client)

InitOnCallWorkflow initializes the global singleton instance This is called once from main.go with the Redis client and AWS client

type Alert struct {
	// contains filtered or unexported fields
}

func NewAlert(providers ...AlertProvider) *Alert

func (a *Alert) SendAlert(incident *m.Incident) error

type AlertProvider interface {
	SendAlert(incident *m.Incident) error
}

AlertProvider interface remains the same

type OnCallProvider interface {
	TriggerOnCall(ctx context.Context, incidentID string) error
}

OnCallProvider defines the interface for on-call notification providers

type OnCallWorkflow struct {
	// contains filtered or unexported fields
}

OnCallWorkflow coordinates on-call escalation with a single provider

func GetOnCallWorkflow() *OnCallWorkflow

GetOnCallWorkflow returns the global singleton instance This maintains compatibility with existing code

func NewOnCallWorkflow(redisClient *redis.Client, provider OnCallProvider) *OnCallWorkflow

NewOnCallWorkflow creates a new on-call workflow with the given provider

func (w *OnCallWorkflow) Ack(incidentID string) error

Ack acknowledges an incident to prevent escalation

func (w *OnCallWorkflow) Start(incidentID string, oc config.OnCallConfig) error

Start initiates the on-call workflow for an incident

type QueueListener interface {
	StartListening(handler func(content *map[string]interface{}) error) error
}