fakes

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Jul 14, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package fakes provides in-memory implementations of every db.*Store interface. They satisfy the same contracts as the production stores but hold state in maps; pair with testutil/testserver for handler tests, or inject directly into services that need stores without Postgres.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigStore 

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

func (*ConfigStore) Get 

func (s *ConfigStore) Get(_ context.Context, key string) (json.RawMessage, error)

func (*ConfigStore) GetAll 

func (s *ConfigStore) GetAll(_ context.Context) (map[string]json.RawMessage, error)

func (*ConfigStore) GetAppConfig 

func (s *ConfigStore) GetAppConfig(_ context.Context) (config.AppConfig, error)

GetAppConfig assembles the typed AppConfig from the stored JSON keys. When a key is missing or malformed, falls back to that field's default — matches the production store's tolerant parsing.

func (*ConfigStore) Set 

func (s *ConfigStore) Set(_ context.Context, key string, value json.RawMessage) error

func (*ConfigStore) UpdateAppConfig 

func (s *ConfigStore) UpdateAppConfig(_ context.Context, c config.AppConfig) error

type ConnectorStore 

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

func (*ConnectorStore) All 

func (s *ConnectorStore) All() []db.Connector

All returns a snapshot of all connectors (test-only convenience).

func (*ConnectorStore) Delete 

func (s *ConnectorStore) Delete(_ context.Context, id uuid.UUID) error

func (*ConnectorStore) Get 

func (s *ConnectorStore) Get(_ context.Context, id uuid.UUID) (*db.Connector, error)

func (*ConnectorStore) GetByName 

func (s *ConnectorStore) GetByName(_ context.Context, name string) (*db.Connector, error)

func (*ConnectorStore) GetDefault 

func (s *ConnectorStore) GetDefault(_ context.Context, connectorType string) (*db.Connector, error)

func (*ConnectorStore) List 

func (s *ConnectorStore) List(_ context.Context) ([]db.Connector, error)

func (*ConnectorStore) Save 

func (s *ConnectorStore) Save(_ context.Context, name, connectorType, description string, secretGroupID *uuid.UUID, cfg json.RawMessage, isDefault bool, createdBy string) (*db.Connector, error)

func (*ConnectorStore) Update 

func (s *ConnectorStore) Update(_ context.Context, id uuid.UUID, name, description string, secretGroupID *uuid.UUID, cfg json.RawMessage, enabled bool, isDefault bool, updatedBy string) error

type PackStore 

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

func (*PackStore) Delete 

func (s *PackStore) Delete(_ context.Context, name string) error

func (*PackStore) Get 

func (s *PackStore) Get(_ context.Context, name string) (*db.Pack, error)

func (*PackStore) List 

func (s *PackStore) List(_ context.Context) ([]db.Pack, error)

func (*PackStore) UpdateParameters 

func (s *PackStore) UpdateParameters(_ context.Context, name string, parameters map[string]any) error

func (*PackStore) Upsert 

func (s *PackStore) Upsert(_ context.Context, pack *db.Pack, installedBy string) error

type RunStore 

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

func (*RunStore) AddScenarioResult 

func (s *RunStore) AddScenarioResult(_ context.Context, runID uuid.UUID, result *db.ScenarioResult) error

func (*RunStore) All 

func (s *RunStore) All() []db.Run

All returns a snapshot of all runs (test-only convenience).

func (*RunStore) CompleteRun 

func (s *RunStore) CompleteRun(_ context.Context, id uuid.UUID, endTime *time.Time) error

func (*RunStore) CompleteScenarioResult 

func (s *RunStore) CompleteScenarioResult(_ context.Context, id uuid.UUID, result *db.ScenarioResult) error

func (*RunStore) Create 

func (s *RunStore) Create(_ context.Context, run *db.Run) error

func (*RunStore) CreateScenarioStatus 

func (s *RunStore) CreateScenarioStatus(_ context.Context, runID uuid.UUID, name string) (uuid.UUID, error)

func (*RunStore) Delete 

func (s *RunStore) Delete(_ context.Context, id uuid.UUID) error

func (*RunStore) Get 

func (s *RunStore) Get(_ context.Context, id uuid.UUID) (*db.Run, error)

func (*RunStore) GetLatestExpectationResults added in v0.4.0 

func (s *RunStore) GetLatestExpectationResults(_ context.Context) ([]db.LatestExpectationResult, error)

func (*RunStore) GetScenarioResult 

func (s *RunStore) GetScenarioResult(_ context.Context, id uuid.UUID) (*db.ScenarioResult, error)

func (*RunStore) GetScenarioResults 

func (s *RunStore) GetScenarioResults(_ context.Context, runID uuid.UUID) ([]db.ScenarioResult, error)

func (*RunStore) IncrementRunCounters 

func (s *RunStore) IncrementRunCounters(_ context.Context, id uuid.UUID, successDelta, failDelta int) error

func (*RunStore) List 

func (s *RunStore) List(_ context.Context, filters db.ListRunsFilters, limit, offset int) (db.RunPage, error)

func (*RunStore) ListExpired added in v0.2.0 

func (s *RunStore) ListExpired(_ context.Context, cutoff time.Time) ([]uuid.UUID, error)

func (*RunStore) Update 

func (s *RunStore) Update(_ context.Context, id uuid.UUID, status string, total, succeeded, failed int, endTime *time.Time) error

func (*RunStore) UpdateScenarioExpectations added in v0.4.0 

func (s *RunStore) UpdateScenarioExpectations(_ context.Context, id uuid.UUID, expectationsJSON []byte) error

func (*RunStore) UpdateScenarioIdentity added in v0.3.0 

func (s *RunStore) UpdateScenarioIdentity(_ context.Context, id uuid.UUID, executorName, executorType, executionID, simulationID string) error

func (*RunStore) UpdateScenarioPhase 

func (s *RunStore) UpdateScenarioPhase(_ context.Context, id uuid.UUID, phase string) error

type ScenarioStore 

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

func (*ScenarioStore) Delete 

func (s *ScenarioStore) Delete(_ context.Context, id uuid.UUID) error

func (*ScenarioStore) Get 

func (s *ScenarioStore) Get(_ context.Context, id uuid.UUID) (*db.Assessment, error)

func (*ScenarioStore) GetByName added in v0.4.0 

func (s *ScenarioStore) GetByName(_ context.Context, name string) (*db.Assessment, error)

func (*ScenarioStore) List 

func (s *ScenarioStore) List(_ context.Context, filters db.ListAssessmentsFilters, limit, offset int) (db.AssessmentPage, error)

func (*ScenarioStore) ListAll 

func (s *ScenarioStore) ListAll(_ context.Context) ([]db.Assessment, error)

func (*ScenarioStore) Save 

func (s *ScenarioStore) Save(_ context.Context, name, scenarioType, yaml, createdBy string) (*db.Assessment, error)

func (*ScenarioStore) SetUpdatedAt 

func (s *ScenarioStore) SetUpdatedAt(id uuid.UUID, t time.Time)

SetUpdatedAt backdates a scenario's UpdatedAt for tests exercising the `since` filter; no-op if the scenario is unknown.

func (*ScenarioStore) Update 

func (s *ScenarioStore) Update(_ context.Context, id uuid.UUID, name, scenarioType, yaml, updatedBy string) error

type ScheduleStore 

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

func (*ScheduleStore) Create 

func (s *ScheduleStore) Create(_ context.Context, assessmentID uuid.UUID, cronExpr string, enabled bool, parallelism int, createdBy string) (*db.Schedule, error)

func (*ScheduleStore) Delete 

func (s *ScheduleStore) Delete(_ context.Context, id uuid.UUID) error

func (*ScheduleStore) Get 

func (s *ScheduleStore) Get(_ context.Context, id uuid.UUID) (*db.Schedule, error)

func (*ScheduleStore) GetByAssessmentID added in v0.4.0 

func (s *ScheduleStore) GetByAssessmentID(_ context.Context, assessmentID uuid.UUID) (*db.Schedule, error)

func (*ScheduleStore) List 

func (s *ScheduleStore) List(_ context.Context) ([]db.Schedule, error)

func (*ScheduleStore) ListEnabled 

func (s *ScheduleStore) ListEnabled(ctx context.Context) ([]db.Schedule, error)

func (*ScheduleStore) Update 

func (s *ScheduleStore) Update(_ context.Context, id uuid.UUID, cronExpr string, enabled bool, parallelism int, updatedBy string) error

func (*ScheduleStore) UpdateLastRun 

func (s *ScheduleStore) UpdateLastRun(_ context.Context, id uuid.UUID, lastRunAt time.Time) error

type SecretStore 

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

func (*SecretStore) Delete 

func (s *SecretStore) Delete(_ context.Context, id uuid.UUID) error

func (*SecretStore) Get 

func (s *SecretStore) Get(_ context.Context, id uuid.UUID) (*db.SecretGroup, error)

func (*SecretStore) List 

func (s *SecretStore) List(_ context.Context) ([]db.SecretGroup, error)

func (*SecretStore) Save 

func (s *SecretStore) Save(_ context.Context, name, description string, entries json.RawMessage, createdBy string) (*db.SecretGroup, error)

func (*SecretStore) Update 

func (s *SecretStore) Update(_ context.Context, id uuid.UUID, name, description string, entries json.RawMessage, updatedBy string) error

type SessionStore 

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

func (*SessionStore) Create 

func (s *SessionStore) Create(_ context.Context, email, name, picture string, ttl time.Duration) (string, error)

func (*SessionStore) Delete 

func (s *SessionStore) Delete(_ context.Context, sessionID string) error

func (*SessionStore) DeleteExpired 

func (s *SessionStore) DeleteExpired(_ context.Context) error

func (*SessionStore) Get 

func (s *SessionStore) Get(_ context.Context, sessionID string) (*db.AuthSession, error)

type Stores 

type Stores struct {
	Run       *RunStore
	Scenario  *ScenarioStore
	Pack      *PackStore
	Secret    *SecretStore
	Connector *ConnectorStore
	Config    *ConfigStore
	Schedule  *ScheduleStore
	Session   *SessionStore
}

Stores bundles every fake store. Use New() to construct a wired-up bundle.

func New 

func New() *Stores

New returns a bundle with every store initialized to an empty map.

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.