state

type RegistryStateService interface {
	// Initialize populates the state store with the set of registries.
	// It is intended that this is called at application startup, and it
	// will overwrite any previous state.
	Initialize(ctx context.Context, registryConfigs []config.RegistryConfig) error
	// ListSyncStatuses lists all available sync statuses.
	ListSyncStatuses(ctx context.Context) (map[string]*status.SyncStatus, error)
	// GetSyncStatus lists the status of the named registry.
	GetSyncStatus(ctx context.Context, registryName string) (*status.SyncStatus, error)
	// UpdateSyncStatus overrides the value of the named registry with the syncStatus parameter.
	UpdateSyncStatus(ctx context.Context, registryName string, syncStatus *status.SyncStatus) error
	// GetNextSyncJob returns the next registry configuration that needs syncing.
	// The predicate function is used to filter registries based on their config and sync status.
	// The registry configs are cached from the Initialize call.
	GetNextSyncJob(
		ctx context.Context,
		predicate func(*config.RegistryConfig, *status.SyncStatus) bool,
	) (*config.RegistryConfig, error)
}