repository

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 30, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MemoryAlertRepository 

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

func NewMemoryAlertRepository 

func NewMemoryAlertRepository() *MemoryAlertRepository

func (*MemoryAlertRepository) Create 

func (r *MemoryAlertRepository) Create(_ context.Context, alert *domain.Alert) error

func (*MemoryAlertRepository) List 

func (r *MemoryAlertRepository) List(_ context.Context) ([]*domain.Alert, error)

type MemoryAlertRuleRepository 

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

func NewMemoryAlertRuleRepository 

func NewMemoryAlertRuleRepository() *MemoryAlertRuleRepository

func (*MemoryAlertRuleRepository) Create 

func (r *MemoryAlertRuleRepository) Create(_ context.Context, rule *domain.AlertRule) error

func (*MemoryAlertRuleRepository) Delete 

func (r *MemoryAlertRuleRepository) Delete(_ context.Context, id string) error

func (*MemoryAlertRuleRepository) GetByID 

func (r *MemoryAlertRuleRepository) GetByID(_ context.Context, id string) (*domain.AlertRule, error)

func (*MemoryAlertRuleRepository) List 

func (r *MemoryAlertRuleRepository) List(_ context.Context) ([]*domain.AlertRule, error)

func (*MemoryAlertRuleRepository) Update 

func (r *MemoryAlertRuleRepository) Update(_ context.Context, rule *domain.AlertRule) error

type MemoryDashboardRepository 

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

MemoryDashboardRepository provides simulated dashboard data.

func NewMemoryDashboardRepository 

func NewMemoryDashboardRepository() *MemoryDashboardRepository

NewMemoryDashboardRepository constructs a MemoryDashboardRepository.

func (*MemoryDashboardRepository) GetDashboard 

func (r *MemoryDashboardRepository) GetDashboard(_ context.Context) (*domain.Dashboard, error)

GetDashboard returns simulated platform metrics and tool health data.

type PostgresAlertRepository 

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

func NewPostgresAlertRepository 

func NewPostgresAlertRepository(pool *pgxpool.Pool) *PostgresAlertRepository

func (*PostgresAlertRepository) Create 

func (r *PostgresAlertRepository) Create(ctx context.Context, alert *domain.Alert) error

func (*PostgresAlertRepository) List 

func (r *PostgresAlertRepository) List(ctx context.Context) ([]*domain.Alert, error)

type PostgresAlertRuleRepository 

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

func NewPostgresAlertRuleRepository 

func NewPostgresAlertRuleRepository(pool *pgxpool.Pool) *PostgresAlertRuleRepository

func (*PostgresAlertRuleRepository) Create 

func (r *PostgresAlertRuleRepository) Create(ctx context.Context, rule *domain.AlertRule) error

func (*PostgresAlertRuleRepository) Delete 

func (r *PostgresAlertRuleRepository) Delete(ctx context.Context, id string) error

func (*PostgresAlertRuleRepository) GetByID 

func (r *PostgresAlertRuleRepository) GetByID(ctx context.Context, id string) (*domain.AlertRule, error)

func (*PostgresAlertRuleRepository) List 

func (r *PostgresAlertRuleRepository) List(ctx context.Context) ([]*domain.AlertRule, error)

func (*PostgresAlertRuleRepository) Update 

func (r *PostgresAlertRuleRepository) Update(ctx context.Context, rule *domain.AlertRule) error

Update 는 알림 규칙을 고친다.

alert_rules 에는 updated_at 이 없다(000003·000032). 예전 쿼리가 그 열을 써서 수정이 매번 "column updated_at does not exist" 로 실패했다 — 통합 테스트가 CI 에서 돌지 않아 드러나지 않았다.

type PostgresCycleLock added in v0.6.0 

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

PostgresCycleLock 은 port.CycleLock 이다 — 세션 advisory lock 을 연결 하나에 잡고 수집이 끝나면 푼다.

func NewPostgresCycleLock added in v0.6.0 

func NewPostgresCycleLock(pool *pgxpool.Pool) *PostgresCycleLock

func (*PostgresCycleLock) TryAcquire added in v0.6.0 

func (l *PostgresCycleLock) TryAcquire(ctx context.Context) (func(), bool, error)

type PostgresStackAlertRepository added in v0.6.0 

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

PostgresStackAlertRepository 는 stack_alerts 다(000097). 열린 경보는 (stack_id, fingerprint) 마다 한 행이다.

func NewPostgresStackAlertRepository added in v0.6.0 

func NewPostgresStackAlertRepository(pool *pgxpool.Pool) *PostgresStackAlertRepository

func (*PostgresStackAlertRepository) ClaimNotification added in v0.6.0 

func (r *PostgresStackAlertRepository) ClaimNotification(ctx context.Context, id string, now time.Time, repeat time.Duration) (bool, bool, error)

func (*PostgresStackAlertRepository) CloseForMissingStacks added in v0.6.0 

func (r *PostgresStackAlertRepository) CloseForMissingStacks(ctx context.Context, keep []string, at, seenBefore time.Time) (int, error)

func (*PostgresStackAlertRepository) List added in v0.6.0 

func (r *PostgresStackAlertRepository) List(ctx context.Context, orgID string, openOnly bool, limit int) ([]*domain.StackAlert, error)

func (*PostgresStackAlertRepository) ListOpen added in v0.6.0 

func (r *PostgresStackAlertRepository) ListOpen(ctx context.Context, stackID string) ([]*domain.StackAlert, error)

func (*PostgresStackAlertRepository) Resolve added in v0.6.0 

func (r *PostgresStackAlertRepository) Resolve(ctx context.Context, id string, at, staleBefore time.Time) (bool, error)

func (*PostgresStackAlertRepository) Upsert added in v0.6.0 

func (r *PostgresStackAlertRepository) Upsert(ctx context.Context, a *domain.StackAlert) (bool, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.