edu.iu.dsc.tws.rsched.schedulers.k8s.logger

Class WorkerLogger

java.lang.Object

java.lang.Thread

edu.iu.dsc.tws.rsched.schedulers.k8s.logger.WorkerLogger

All Implemented Interfaces:

java.lang.Runnable

public class WorkerLogger
extends java.lang.Thread

save log of a worker or a job master to a log file

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
WorkerLogger(java.lang.String namespace, java.lang.String podName, java.lang.String containerName, java.lang.String id, java.lang.String logsDir, CoreV1Api coreV1Api, JobLogger jobLogger)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.lang.String	getID()
int	hashCode()
void	run()
void	stopLogging()
java.io.InputStream	streamContainerLog()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

WorkerLogger

public WorkerLogger(java.lang.String namespace,
                    java.lang.String podName,
                    java.lang.String containerName,
                    java.lang.String id,
                    java.lang.String logsDir,
                    CoreV1Api coreV1Api,
                    JobLogger jobLogger)

Method Detail

getID

public java.lang.String getID()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

streamContainerLog

public java.io.InputStream streamContainerLog()
                                       throws ApiException,
                                              java.io.IOException

Throws:

ApiException

java.io.IOException

stopLogging

public void stopLogging()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object