fixtures

Documentation

Index

• Constants
• type Generator
  • func New(application *app.App, logger *slog.Logger) *Generator
  • func (g *Generator) Start(ctx context.Context) error
• type RelayScaleConfig
  • func DefaultRelayScaleConfig() RelayScaleConfig
• type RelayScaleScenario
  • func NewRelayScaleScenario(config RelayScaleConfig) (*RelayScaleScenario, error)
  • func (s *RelayScaleScenario) Load(ctx context.Context, application *app.App, at time.Time) error
  • func (s *RelayScaleScenario) NodeCount() int
  • func (s *RelayScaleScenario) RelayCount() int
  • func (s *RelayScaleScenario) Reports(at time.Time, sequence int64) []TimedReport
  • func (s *RelayScaleScenario) SessionCount() int
• type ScaleConfig
  • func DefaultScaleConfig() ScaleConfig
• type ScaleScenario
  • func NewScaleScenario(config ScaleConfig) (*ScaleScenario, error)
  • func (s *ScaleScenario) EdgeCount() int
  • func (s *ScaleScenario) EdgeMutationObserver() int
  • func (s *ScaleScenario) EdgeMutationReport(at time.Time, sequence int64) domain.ReportEnvelope
  • func (s *ScaleScenario) ExporterSnapshots(at time.Time, sequence int64) []exporter.Snapshot
  • func (s *ScaleScenario) HelloReports(at time.Time) []domain.ReportEnvelope
  • func (s *ScaleScenario) Load(ctx context.Context, application *app.App, at time.Time) error
  • func (s *ScaleScenario) NodeCount() int
  • func (s *ScaleScenario) ObserverHelloReport(node int, at time.Time, sequence int64) domain.ReportEnvelope
  • func (s *ScaleScenario) ObserverWithdrawalReport(node int, at time.Time, sequence int64) domain.ReportEnvelope
  • func (s *ScaleScenario) RefreshRuntime(aggregator *aggregate.Aggregator, at time.Time, sequence int64) error
  • func (s *ScaleScenario) RefreshRuntimeExcluding(aggregator *aggregate.Aggregator, at time.Time, sequence int64, ...) error
  • func (s *ScaleScenario) RefreshRuntimeSequences(aggregator *aggregate.Aggregator, at time.Time, sequences []int64, ...) error
  • func (s *ScaleScenario) Reports(at time.Time) []TimedReport
  • func (s *ScaleScenario) SteadyReports(at time.Time, sequence int64) []domain.ReportEnvelope
• type TimedReport

Constants

const (
	DefaultRelayScaleNodeCount    = 250
	DefaultRelayScaleSessionCount = 1000
	DefaultRelayScaleRelayCount   = 8
	RelayScaleEndpointCanary      = "192.0.2."
	RelayScaleDiscoCanary         = "d:feed"
)

const (
	DefaultScaleSeed      int64 = 0x7461696c70617468
	DefaultScaleNodeCount       = 250
	DefaultScaleEdgeCount       = 1000
)

Types

type Generator

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

func New

func New(application *app.App, logger *slog.Logger) *Generator

func (*Generator) Start

func (g *Generator) Start(ctx context.Context) error

type RelayScaleConfig

type RelayScaleConfig struct {
	Seed         int64
	NodeCount    int
	SessionCount int
	RelayCount   int
}

func DefaultRelayScaleConfig

func DefaultRelayScaleConfig() RelayScaleConfig

type RelayScaleScenario

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

func NewRelayScaleScenario

func NewRelayScaleScenario(config RelayScaleConfig) (*RelayScaleScenario, error)

func (*RelayScaleScenario) Load

func (s *RelayScaleScenario) Load(ctx context.Context, application *app.App, at time.Time) error

func (*RelayScaleScenario) NodeCount

func (s *RelayScaleScenario) NodeCount() int

func (*RelayScaleScenario) RelayCount

func (s *RelayScaleScenario) RelayCount() int

func (*RelayScaleScenario) Reports

func (s *RelayScaleScenario) Reports(at time.Time, sequence int64) []TimedReport

func (*RelayScaleScenario) SessionCount

func (s *RelayScaleScenario) SessionCount() int

type ScaleConfig

type ScaleConfig struct {
	Seed      int64
	NodeCount int
	EdgeCount int
}

func DefaultScaleConfig

func DefaultScaleConfig() ScaleConfig

type ScaleScenario

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

func NewScaleScenario

func NewScaleScenario(config ScaleConfig) (*ScaleScenario, error)

func (*ScaleScenario) EdgeCount

func (s *ScaleScenario) EdgeCount() int

func (*ScaleScenario) EdgeMutationObserver

func (s *ScaleScenario) EdgeMutationObserver() int

func (*ScaleScenario) EdgeMutationReport

func (s *ScaleScenario) EdgeMutationReport(at time.Time, sequence int64) domain.ReportEnvelope

func (*ScaleScenario) ExporterSnapshots

func (s *ScaleScenario) ExporterSnapshots(at time.Time, sequence int64) []exporter.Snapshot

ExporterSnapshots projects the fixed scale topology through the public exporter contract. The sequence controls monotonically increasing absolute counters; it is deliberately not a reporter sequence.

func (*ScaleScenario) HelloReports

func (s *ScaleScenario) HelloReports(at time.Time) []domain.ReportEnvelope

func (*ScaleScenario) Load

func (s *ScaleScenario) Load(ctx context.Context, application *app.App, at time.Time) error

func (*ScaleScenario) NodeCount

func (s *ScaleScenario) NodeCount() int

func (*ScaleScenario) ObserverHelloReport

func (s *ScaleScenario) ObserverHelloReport(node int, at time.Time, sequence int64) domain.ReportEnvelope

func (*ScaleScenario) ObserverWithdrawalReport

func (s *ScaleScenario) ObserverWithdrawalReport(node int, at time.Time, sequence int64) domain.ReportEnvelope

func (*ScaleScenario) RefreshRuntime

func (s *ScaleScenario) RefreshRuntime(aggregator *aggregate.Aggregator, at time.Time, sequence int64) error

RefreshRuntime keeps the test-only browser fixture inside the ten-second active window after the intentionally unoptimized persistent load finishes.

func (*ScaleScenario) RefreshRuntimeExcluding

func (s *ScaleScenario) RefreshRuntimeExcluding(
	aggregator *aggregate.Aggregator,
	at time.Time,
	sequence int64,
	excludedNode int,
) error

func (*ScaleScenario) RefreshRuntimeSequences

func (s *ScaleScenario) RefreshRuntimeSequences(
	aggregator *aggregate.Aggregator,
	at time.Time,
	sequences []int64,
	excludedNode int,
) error

func (*ScaleScenario) Reports

func (s *ScaleScenario) Reports(at time.Time) []TimedReport

func (*ScaleScenario) SteadyReports

func (s *ScaleScenario) SteadyReports(at time.Time, sequence int64) []domain.ReportEnvelope

type TimedReport

type TimedReport struct {
	Report     domain.ReportEnvelope
	ReceivedAt time.Time
}