Function NewRunner

scaletest/notifications/run.go:47–55

(client *codersdk.Client, cfg Config)

}

func NewRunner(client *codersdk.Client, cfg Config) *Runner {
	return &Runner{
		client:                client,
		cfg:                   cfg,
		websocketReceiptTimes: make(map[uuid.UUID]time.Time),
		smtpReceiptTimes:      make(map[uuid.UUID]time.Time),
		clock:                 quartz.NewReal(),
	}
}

func (r *Runner) WithClock(clock quartz.Clock) *Runner {
	r.clock = clock