warning

type Warning struct {
	ID              int64             `json:"-"`
	UUID            uuid.UUID         `json:"uuid"         db:"primary=yes"`
	Type            api.WarningType   `json:"type"`
	Scope           string            `json:"scope"`
	EntityType      string            `json:"entity_type"`
	Entity          string            `json:"entity"`
	Status          api.WarningStatus `json:"status"`
	FirstOccurrence time.Time         `json:"first_occurrence"`
	LastOccurrence  time.Time         `json:"last_occurrence"`
	LastUpdated     time.Time         `json:"last_updated" db:"update_timestamp"`
	Messages        []string          `json:"messages"     db:"marshal=json"`
	Count           int
}

type WarningEmitter interface {
	Emit(ctx context.Context, w Warning)
	RemoveStale(ctx context.Context, scope api.WarningScope, newWarnings Warnings)
}

type WarningFilter struct {
	ID         *int64
	UUID       *uuid.UUID
	Scope      *string
	EntityType *string
	Entity     *string
	Type       *api.WarningType
}

type WarningRepo interface {
	Upsert(ctx context.Context, w Warning) (int64, error)
	GetAll(ctx context.Context) (Warnings, error)
	GetByScopeAndType(ctx context.Context, scope api.WarningScope, wType api.WarningType) (Warnings, error)
	GetByUUID(ctx context.Context, id uuid.UUID) (*Warning, error)
	Update(ctx context.Context, id uuid.UUID, w Warning) error
	DeleteByUUID(ctx context.Context, id uuid.UUID) error
}

type WarningService interface {
	GetAll(ctx context.Context) (Warnings, error)
	GetByScopeAndType(ctx context.Context, scope api.WarningScope, wType api.WarningType) (Warnings, error)
	GetByUUID(ctx context.Context, id uuid.UUID) (*Warning, error)
	UpdateStatusByUUID(ctx context.Context, id uuid.UUID, status api.WarningStatus) (*Warning, error)
	DeleteByUUID(ctx context.Context, id uuid.UUID) error

	WarningEmitter
}

type WarningServiceOption func(s *warningService)

type Warnings []Warning