io.github.retz.db

Class Database

java.lang.Object

io.github.retz.db.Database

public class Database
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
boolean	addApplication(Application a)
void	addJob(java.sql.Connection conn, Job j)
boolean	addUser(User u)
boolean	allTableExists()
java.util.List<User>	allUsers()
void	clear()
int	countJobs()
int	countQueued()
int	countRunning()
User	createUser(java.lang.String info)
void	deleteAllJob(int maxId)
void	deleteAllProperties()
void	deleteApplication(java.sql.Connection conn, java.lang.String appid)
void	deleteOldJobs(int leeway)
void	enableUser(java.lang.String keyId, boolean enabled)
java.util.List<Job>	findFit(java.util.List<java.lang.String> orderBy, int cpu, int memMB)
java.util.List<Job>	finishedJobs(java.lang.String start, java.lang.String end)
java.util.List<Application>	getAllApplications()
java.util.List<Application>	getAllApplications(java.lang.String id)
java.util.Optional<AppJobPair>	getAppJob(int id)
java.util.Optional<Application>	getApplication(java.sql.Connection conn, java.lang.String appid)
java.util.Optional<Application>	getApplication(java.lang.String appid)
java.util.List<Application>	getApplications(java.sql.Connection conn, java.lang.String id)
java.util.Optional<java.lang.String>	getFrameworkId()
static Database	getInstance()
java.util.Optional<Job>	getJob(int id)
java.util.Optional<Job>	getJobFromTaskId(java.lang.String taskId)
int	getLatestJobId()
java.util.List<Job>	getRunning()
java.util.Optional<User>	getUser(java.sql.Connection conn, java.lang.String keyId)
java.util.Optional<User>	getUser(java.lang.String keyId)
void	init(ServerConfiguration config)
java.util.List<Job>	listJobs(java.lang.String id, Job.JobState state, java.util.Optional<java.lang.String> tag, int limit)
java.util.List<Job>	queued(int limit)
void	retryJobs(java.util.List<java.lang.Integer> ids)
void	safeAddJob(Job j)
void	safeDeleteApplication(java.lang.String appid)
boolean	setFrameworkId(java.lang.String value)
void	setJobStarting(int id, java.util.Optional<java.lang.String> maybeUrl, java.lang.String taskId)
void	stop()
void	updateJob(int id, java.util.function.Function<Job,java.util.Optional<Job>> fun)
void	updateJobs(java.util.List<Job> list)
void	validate()

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static Database getInstance()

validate

public void validate()
              throws java.lang.Exception

Throws:

java.lang.Exception

init

public void init(ServerConfiguration config)
          throws java.io.IOException,
                 java.sql.SQLException

Throws:

java.io.IOException

java.sql.SQLException

stop

public void stop()

clear

public void clear()

allTableExists

public boolean allTableExists()

allUsers

public java.util.List<User> allUsers()
                              throws java.io.IOException

Throws:

java.io.IOException

createUser

public User createUser(java.lang.String info)
                throws java.sql.SQLException,
                       com.fasterxml.jackson.core.JsonProcessingException

Throws:

java.sql.SQLException

com.fasterxml.jackson.core.JsonProcessingException

addUser

public boolean addUser(User u)
                throws java.sql.SQLException,
                       com.fasterxml.jackson.core.JsonProcessingException

Throws:

java.sql.SQLException

com.fasterxml.jackson.core.JsonProcessingException

getUser

public java.util.Optional<User> getUser(java.lang.String keyId)
                                 throws java.io.IOException

Throws:

java.io.IOException

getUser

public java.util.Optional<User> getUser(java.sql.Connection conn,
                                        java.lang.String keyId)
                                 throws java.sql.SQLException,
                                        java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

enableUser

public void enableUser(java.lang.String keyId,
                       boolean enabled)
                throws java.sql.SQLException,
                       java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

getAllApplications

public java.util.List<Application> getAllApplications()
                                               throws java.io.IOException

Throws:

java.io.IOException

getAllApplications

public java.util.List<Application> getAllApplications(java.lang.String id)
                                               throws java.io.IOException

Throws:

java.io.IOException

getApplications

public java.util.List<Application> getApplications(java.sql.Connection conn,
                                                   java.lang.String id)
                                            throws java.sql.SQLException,
                                                   java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

addApplication

public boolean addApplication(Application a)
                       throws java.io.IOException

Throws:

java.io.IOException

getApplication

public java.util.Optional<Application> getApplication(java.lang.String appid)
                                               throws java.io.IOException

Throws:

java.io.IOException

getApplication

public java.util.Optional<Application> getApplication(java.sql.Connection conn,
                                                      java.lang.String appid)
                                               throws java.sql.SQLException,
                                                      java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

safeDeleteApplication

public void safeDeleteApplication(java.lang.String appid)

deleteApplication

public void deleteApplication(java.sql.Connection conn,
                              java.lang.String appid)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

listJobs

public java.util.List<Job> listJobs(java.lang.String id,
                                    Job.JobState state,
                                    java.util.Optional<java.lang.String> tag,
                                    int limit)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

finishedJobs

public java.util.List<Job> finishedJobs(java.lang.String start,
                                        java.lang.String end)

findFit

public java.util.List<Job> findFit(java.util.List<java.lang.String> orderBy,
                                   int cpu,
                                   int memMB)
                            throws java.io.IOException

Throws:

java.io.IOException

queued

public java.util.List<Job> queued(int limit)
                           throws java.io.IOException,
                                  java.sql.SQLException

Throws:

java.io.IOException

java.sql.SQLException

addJob

public void addJob(java.sql.Connection conn,
                   Job j)
            throws java.sql.SQLException,
                   com.fasterxml.jackson.core.JsonProcessingException

Throws:

java.sql.SQLException

com.fasterxml.jackson.core.JsonProcessingException

safeAddJob

public void safeAddJob(Job j)

getAppJob

public java.util.Optional<AppJobPair> getAppJob(int id)
                                         throws java.io.IOException

Throws:

java.io.IOException

getJob

public java.util.Optional<Job> getJob(int id)
                               throws com.fasterxml.jackson.core.JsonProcessingException,
                                      java.io.IOException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

java.io.IOException

getJobFromTaskId

public java.util.Optional<Job> getJobFromTaskId(java.lang.String taskId)
                                         throws com.fasterxml.jackson.core.JsonProcessingException,
                                                java.io.IOException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

java.io.IOException

deleteAllJob

public void deleteAllJob(int maxId)

deleteOldJobs

public void deleteOldJobs(int leeway)

setJobStarting

public void setJobStarting(int id,
                           java.util.Optional<java.lang.String> maybeUrl,
                           java.lang.String taskId)
                    throws java.io.IOException,
                           java.sql.SQLException,
                           JobNotFoundException

Throws:

java.io.IOException

java.sql.SQLException

JobNotFoundException

updateJob

public void updateJob(int id,
                      java.util.function.Function<Job,java.util.Optional<Job>> fun)
               throws java.io.IOException,
                      java.sql.SQLException,
                      JobNotFoundException

Throws:

java.io.IOException

java.sql.SQLException

JobNotFoundException

countJobs

public int countJobs()

countRunning

public int countRunning()

countQueued

public int countQueued()

getLatestJobId

public int getLatestJobId()

getRunning

public java.util.List<Job> getRunning()

setFrameworkId

public boolean setFrameworkId(java.lang.String value)

getFrameworkId

public java.util.Optional<java.lang.String> getFrameworkId()

deleteAllProperties

public void deleteAllProperties()

updateJobs

public void updateJobs(java.util.List<Job> list)

retryJobs

public void retryJobs(java.util.List<java.lang.Integer> ids)