provider

type ApprovedRefreshHandler struct{ *taskengine.FuncHandler }

type BucketReadyDependencies struct{ Scheduler *taskengine.Scheduler }

type EndorsedRefreshHandler struct{ *taskengine.FuncHandler }

type EventPublisher interface{ Publish(string, map[string]any) }

type ObservabilityDependencies struct {
	Repositories                  *repository.Repositories
	Observability                 *observability.Service
	UploadSpeedProbe              providerbenchmark.UploadProbe
	Events                        EventPublisher
	Scheduler                     *taskengine.Scheduler
	UploadSpeedTestAutoScope      string
	UploadSpeedTestRetestInterval time.Duration
}

type ObservabilityHandler struct {
	*taskengine.FuncHandler
	// contains filtered or unexported fields
}

type TierRefreshDependencies struct {
	Observability *observability.Service
	Events        EventPublisher
}

type UploadSpeedTestDependencies struct {
	Observability    *observability.Service
	UploadSpeedProbe providerbenchmark.UploadProbe
	Logger           *slog.Logger
}

type UploadSpeedTestHandler struct {
	*taskengine.FuncHandler
	// contains filtered or unexported fields
}