alert

type Alert struct {
	ID        int       `json:"_id"`
	Status    Status    `json:"status"`
	Summary   string    `json:"summary"`
	Details   string    `json:"details"`
	Source    Source    `json:"source"`
	ServiceID string    `json:"service_id"`
	CreatedAt time.Time `json:"created_at"`
	Dedup     *DedupID  `json:"dedup"`
}

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

type DedupID struct {
	Type    DedupType
	Version int
	Payload string
}

type DedupType string

type LegacySearchOptions struct {
	// Search is matched case-insensitive against the alert summary, id and service name.
	Search string

	// ServiceID, if specified, will restrict alerts to those with a matching ServiceID.
	ServiceID string

	OmitTriggered bool
	OmitActive    bool
	OmitClosed    bool

	// Limit restricts the maximum number of rows returned. Default is 50.
	// Note: Limit is applied AFTER offset is taken into account.
	Limit int

	// Offset indicates the starting row of the returned results.
	Offset int

	// SortBy specifies the column to sort by. If anything other than ID,
	// ID is used as a secondary sort in descending (newest first) order.
	SortBy SortBy

	// SortDesc controls ascending or descending results of the primary sort (SortBy field).
	SortDesc bool

	//FavoriteServicesOnlyUserID, if populated, filters all those alerts which belong to this user's favorite services, if empty, it is ignored.
	FavoriteServicesOnlyUserID string
}

type Log struct {
	Timestamp time.Time `json:"timestamp"`
	Event     LogEvent  `json:"event"`
	Message   string    `json:"message"`
}

type LogEntryFetcher interface {
	// LogEntry fetchs the latest log entry for a given alertID and type.
	LogEntry(ctx context.Context) (alertlog.Entry, error)
}

type LogEvent string

type Manager interface {
	FindOne(context.Context, int) (*Alert, error)
	FindMany(context.Context, []int) ([]Alert, error)
	UpdateStatus(context.Context, int, Status) error
	UpdateStatusByService(ctx context.Context, serviceID string, status Status) error
	UpdateManyAlertStatus(ctx context.Context, status Status, alertIDs []int) (updatedAlertIDs []int, err error)
	UpdateStatusTx(context.Context, *sql.Tx, int, Status) error
	EPID(ctx context.Context, alertID int) (string, error)
}

type SearchCursor struct {
	ID     int    `json:"i,omitempty"`
	Status Status `json:"s,omitempty"`
}

type SearchOptions struct {
	// Search is matched case-insensitive against the alert summary, id and service name.
	Search string `json:"s,omitempty"`

	// Status, if specified, will restrict alerts to those with a matching status.
	Status []Status `json:"t,omitempty"`

	// Services, if specified, will restrict alerts to those with a matching ServiceID.
	Services []string `json:"v,omitempty"`

	After SearchCursor `json:"a,omitempty"`

	// Omit specifies a list of alert IDs to exclude from the results.
	Omit []int

	// Limit restricts the maximum number of rows returned. Default is 50.
	// Note: Limit is applied AFTER AfterID is taken into account.
	Limit int `json:"-"`
}

type SortBy int

type Source string

type State struct {
	AlertID        int
	StepNumber     int
	RepeatCount    int
	LastEscalation time.Time
}

type Status string

type Store interface {
	Manager
	Create(context.Context, *Alert) (*Alert, error)

	// CreateOrUpdate will create an alert or log a "duplicate suppressed message" if
	// Status is Triggered. If Status is Closed, it will close and return the result.
	//
	// In the case that Status is closed but a matching alert is not present, nil is returned.
	// Otherwise the current alert is returned.
	CreateOrUpdate(context.Context, *Alert) (*Alert, error)

	// CreateOrUpdateTx returns `isNew` to indicate if the returned alert was a new one.
	// It is the caller's responsibility to log alert creation if the transaction is committed (and isNew is true).
	CreateOrUpdateTx(context.Context, *sql.Tx, *Alert) (a *Alert, isNew bool, err error)

	FindAllSummary(ctx context.Context) ([]Summary, error)
	Escalate(ctx context.Context, alertID int, currentLevel int) error
	EscalateMany(ctx context.Context, alertIDs []int) ([]int, error)
	GetCreationTime(ctx context.Context, alertID int) (time.Time, error)

	LegacySearch(ctx context.Context, opt *LegacySearchOptions) ([]Alert, int, error)
	Search(ctx context.Context, opts *SearchOptions) ([]Alert, error)
	State(ctx context.Context, alertIDs []int) ([]State, error)
}

type Summary struct {
	ServiceID   string `json:"service_id"`
	ServiceName string `json:"service_name"`
	Totals      struct {
		Unack  int `json:"unacknowledged"`
		Ack    int `json:"acknowledged"`
		Closed int `json:"closed"`
	} `json:"totals"`
}

type Trigger interface {
	TriggerAlert(int)
}