periodic

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

type ChannelManagerConfig struct {
	Log               logrus.FieldLogger
	ChannelBufferSize int
}

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

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

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

type OrganizationService interface {
	ListOrganizations(ctx context.Context, params domain.ListOrganizationsParams) (*domain.OrganizationList, domain.Status)
}

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

type PeriodicTaskConsumerConfig struct {
	ChannelManager *ChannelManager
	Log            logrus.FieldLogger
	Executors      map[PeriodicTaskType]PeriodicTaskExecutor
	ConsumerCount  int
}

type PeriodicTaskExecutor interface {
	Execute(ctx context.Context, log logrus.FieldLogger, orgId uuid.UUID)
}

type PeriodicTaskMetadata struct {
	Interval   time.Duration
	SystemWide bool // If true, task runs once for the entire system, not per organization
}

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

type PeriodicTaskPublisherConfig struct {
	Log             logrus.FieldLogger
	OrgService      OrganizationService
	TasksMetadata   map[PeriodicTaskType]PeriodicTaskMetadata
	ChannelManager  TaskChannelManager
	WorkerClient    worker_client.WorkerClient
	OrgSyncInterval time.Duration
	TaskBackoff     *poll.Config
}

type PeriodicTaskReference struct {
	Type  PeriodicTaskType
	OrgID uuid.UUID
}

type PeriodicTaskType string

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

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

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

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

type ScheduledTask struct {
	NextRun  time.Time
	OrgID    uuid.UUID
	TaskType PeriodicTaskType
	Interval time.Duration
	Retries  int
}

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

type TaskChannelManager interface {
	PublishTask(ctx context.Context, taskRef PeriodicTaskReference) error
}

type TaskHeap []*ScheduledTask