Package de.dlr.proseo.planner

Class ProductionPlanner

java.lang.Object

de.dlr.proseo.planner.ProductionPlanner

All Implemented Interfaces:

org.springframework.boot.CommandLineRunner

@SpringBootApplication
@EnableConfigurationProperties
@ComponentScan(basePackages="de.dlr.proseo")
@EnableJpaRepositories("de.dlr.proseo.model.dao")
public class ProductionPlanner
extends Object
implements org.springframework.boot.CommandLineRunner

prosEO planner application

Author:

Ernst Melchinger

Field Summary

Fields

Modifier and Type	Field	Description
static ProductionPlannerConfiguration	config	The static production planner configuration
static String	hostIP
static String	hostName
static final String	jobContainerPrefix
static final String	jobNamePrefix
static String	PLAN_THREAD_PREFIX
(package private) ProductionPlannerConfiguration	plannerConfig	The instance production planner configuration
static String	port
static ProductionPlanner	productionPlanner	The production planner instance
static String	RELEASE_THREAD_PREFIX

Constructor Summary

Constructors

Constructor	Description
ProductionPlanner()

Method Summary

Modifier and Type	Method	Description
void	checkNextForRestart()	Checks for the next order to restart.
Map<String,String>	getAuth(Long orderId)	Gets the authentication details of an order (username and password).
jakarta.persistence.EntityManager	getEm()	Gets the entity manager.
Map<String,KubeJobFinish>	getFinishThreads()	Gets the finishThreads map.
KubeConfig	getKubeConfig(String name)	Gets the KubeConfig instance by name.
Collection<KubeConfig>	getKubeConfigs()	Gets all connected KubeConfig instances.
List<Long>	getPlanningOrders()	Gets the planningOrders list.
Map<String,OrderPlanThread>	getPlanThreads()	Gets the planThreads map.
Map<String,OrderReleaseThread>	getReleaseThreads()	Gets the releaseThreads map.
List<Long>	getReleasingOrders()	Gets the releasingOrders list.
List<Long>	getSuspendingOrders()	Gets the suspendingOrders list.
org.springframework.transaction.PlatformTransactionManager	getTxManager()	Gets the transaction manger.
static void	main(String[] args)	Main method to start the application.
void	run(String... arg0)	Runs the application, initializing necessary configurations and components.
void	startDispatcher()	Starts the Kubernetes dispatcher thread.
void	stopDispatcher()	Stops the Kubernetes dispatcher thread.
void	updateAuth(Long orderId, String user, String pw)	Updates authentication details for an order).
KubeConfig	updateKubeConfig(String facilityName)	Attempts to connect to a processing facility.
void	updateKubeConfigs()	Walk through ProcessingFacility list of DB and try to connect each.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

jobNamePrefix

public static final String jobNamePrefix

See Also:

• Constant Field Values

jobContainerPrefix

public static final String jobContainerPrefix

See Also:

• Constant Field Values

hostName

public static String hostName

hostIP

public static String hostIP

port

public static String port

PLAN_THREAD_PREFIX

public static String PLAN_THREAD_PREFIX

RELEASE_THREAD_PREFIX

public static String RELEASE_THREAD_PREFIX

config

public static ProductionPlannerConfiguration config

The static production planner configuration

productionPlanner

public static ProductionPlanner productionPlanner

The production planner instance

plannerConfig

@Autowired
ProductionPlannerConfiguration plannerConfig

The instance production planner configuration

Constructor Details

ProductionPlanner

public ProductionPlanner()

Method Details

getFinishThreads

public Map<String,KubeJobFinish> getFinishThreads()

Gets the finishThreads map.

Returns:

The map of finishing threads.

getSuspendingOrders

public List<Long> getSuspendingOrders()

Gets the suspendingOrders list.

Returns:

The list of suspending orders.

getReleasingOrders

public List<Long> getReleasingOrders()

Gets the releasingOrders list.

Returns:

The list of releasing orders.

getPlanningOrders

public List<Long> getPlanningOrders()

Gets the planningOrders list.

Returns:

The list of planning orders.

getPlanThreads

public Map<String,OrderPlanThread> getPlanThreads()

Gets the planThreads map.

Returns:

The map of planning threads.

getReleaseThreads

public Map<String,OrderReleaseThread> getReleaseThreads()

Gets the releaseThreads map.

Returns:

The map of release threads.

getTxManager

public org.springframework.transaction.PlatformTransactionManager getTxManager()

Gets the transaction manger.

Returns:

The PlatformTransactionManager instance.

getEm

public jakarta.persistence.EntityManager getEm()

Gets the entity manager.

Returns:

The EntityManager instance.

getAuth

public Map<String,String> getAuth(Long orderId)

Gets the authentication details of an order (username and password).

Parameters:

orderId - The ID of the order.

Returns:

The authentication details.

updateAuth

public void updateAuth(Long orderId,
 String user,
 String pw)

Updates authentication details for an order).

Parameters:

orderId - The ID of the order.

user - The username.

pw - The password.

getKubeConfig

public KubeConfig getKubeConfig(String name)

Gets the KubeConfig instance by name.

Parameters:

name - The name of the KubeConfig instance (may be null).

Returns:

The KubeConfig instance.

getKubeConfigs

public Collection<KubeConfig> getKubeConfigs()

Gets all connected KubeConfig instances.

Returns:

Collection of KubeConfig instances.

main

public static void main(String[] args)
                 throws Exception

Main method to start the application.

Parameters:

args - Command line arguments.

Throws:

Exception - Exception if an error occurs.

updateKubeConfigs

@Transactional(isolation=REPEATABLE_READ,
               readOnly=true)
public void updateKubeConfigs()

Walk through ProcessingFacility list of DB and try to connect each. Disconnect and remove KubeConfigs not defined in this list.

updateKubeConfig

@Transactional(isolation=REPEATABLE_READ,
               readOnly=true)
public KubeConfig updateKubeConfig(String facilityName)

Attempts to connect to a processing facility. Adds a new Kubernetes configuration for the previously not connected facility, removes Kubernetes configuration for a facility to which a connection is not possible.

Parameters:

facilityName - the name of the processing facility to connect

Returns:

the KubeConfig object for this processing facility, or null, if the facility is not connected

checkNextForRestart

public void checkNextForRestart()

Checks for the next order to restart.

run

public void run(String... arg0)
         throws Exception

Runs the application, initializing necessary configurations and components.

Specified by:

run in interface org.springframework.boot.CommandLineRunner

Parameters:

arg0 - Command line arguments.

Throws:

Exception - If an error occurs during execution.

See Also:

• CommandLineRunner.run(java.lang.String[])

startDispatcher

public void startDispatcher()

Starts the Kubernetes dispatcher thread.

stopDispatcher

public void stopDispatcher()

Stops the Kubernetes dispatcher thread.