Documentation
¶
Index ¶
- func FindJobDataFilename(c config.BobbitConfig, s payload.JobSearchMetadata) (p payload.JobDetailMetadata, err error)
- func GenerateJobDataFilename(c config.BobbitConfig, p payload.JobDetailMetadata, extFile DaemonFileTypeEnum) string
- func ParseExitCode(c config.BobbitConfig, job *payload.JobResponse) error
- func ParseJobDataFilename(filename string) (p payload.JobDetailMetadata, err error)
- func SplitFilenameFromExtfile(filename string) string
- type DaemonError
- type DaemonFileTypeEnum
- type DaemonPayloadError
- type DaemonStruct
- func (d *DaemonStruct) CleanupDaemon(sigChan <-chan os.Signal)
- func (d *DaemonStruct) HandleJob(jc *JobContext) error
- func (d *DaemonStruct) HandleVibeCheck(jc *JobContext) error
- func (d *DaemonStruct) ListJob(jc *JobContext) error
- func (d *DaemonStruct) NewJobContext(conn net.Conn) *JobContext
- func (d *DaemonStruct) StatusJob(jc *JobContext) error
- func (d *DaemonStruct) WaitJob(jc *JobContext) error
- type JobContext
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FindJobDataFilename ¶
func FindJobDataFilename(c config.BobbitConfig, s payload.JobSearchMetadata) (p payload.JobDetailMetadata, err error)
func GenerateJobDataFilename ¶
func GenerateJobDataFilename(c config.BobbitConfig, p payload.JobDetailMetadata, extFile DaemonFileTypeEnum) string
func ParseExitCode ¶
func ParseExitCode(c config.BobbitConfig, job *payload.JobResponse) error
func ParseJobDataFilename ¶
func ParseJobDataFilename(filename string) (p payload.JobDetailMetadata, err error)
Types ¶
type DaemonError ¶
func (*DaemonError) Error ¶
func (d *DaemonError) Error() string
type DaemonFileTypeEnum ¶
type DaemonFileTypeEnum string
const ( DAEMON_LOCKFILE DaemonFileTypeEnum = "lockfile" DAEMON_LOGFILE DaemonFileTypeEnum = "log" DAEMON_METADATA DaemonFileTypeEnum = "metadata" DAEMON_EXITCODE DaemonFileTypeEnum = "exitcode" )
type DaemonPayloadError ¶
func (*DaemonPayloadError) Error ¶
func (d *DaemonPayloadError) Error() string
func (*DaemonPayloadError) Warning ¶
func (d *DaemonPayloadError) Warning()
type DaemonStruct ¶
type DaemonStruct struct {
SocketListener net.Listener
config.BobbitConfig
}
func CreateDaemon ¶
func CreateDaemon(c config.BobbitConfig) (*DaemonStruct, error)
func (*DaemonStruct) CleanupDaemon ¶
func (d *DaemonStruct) CleanupDaemon(sigChan <-chan os.Signal)
func (*DaemonStruct) HandleJob ¶
func (d *DaemonStruct) HandleJob(jc *JobContext) error
func (*DaemonStruct) HandleVibeCheck ¶
func (d *DaemonStruct) HandleVibeCheck(jc *JobContext) error
func (*DaemonStruct) ListJob ¶
func (d *DaemonStruct) ListJob(jc *JobContext) error
func (*DaemonStruct) NewJobContext ¶
func (d *DaemonStruct) NewJobContext(conn net.Conn) *JobContext
func (*DaemonStruct) StatusJob ¶
func (d *DaemonStruct) StatusJob(jc *JobContext) error
func (*DaemonStruct) WaitJob ¶
func (d *DaemonStruct) WaitJob(jc *JobContext) error
type JobContext ¶
type JobContext struct {
Payload payload.JobPayload
// contains filtered or unexported fields
}
func (*JobContext) Close ¶
func (jc *JobContext) Close()
func (*JobContext) GetPayload ¶
func (jc *JobContext) GetPayload() error
func (*JobContext) SendPayload ¶
func (jc *JobContext) SendPayload(target any) error
Source Files
Click to show internal directories.
Click to hide internal directories.