job

Documentation

Index

• type Job
  • func NewJob() *Job
  • func (j *Job) GetListenerJob(listenerUUID string) (*ListenerJob, error)
  • func (j *Job) NewListenerJob(listenerUUID string) *ListenerJob
  • func (j *Job) RemoveListenerJob(listenerUUID string) error
  • func (j *Job) WaitListenerStart(database *db.Database, lis *listener.Listener, lisJob *ListenerJob) error
  • func (j *Job) WaitListenerStop(database *db.Database, lis *listener.Listener) error
• type ListenerJob

Types

type Job

type Job struct {
	ChServerStarted chan bool
	ChQuit          chan os.Signal
	ListenerJobs    []*ListenerJob
}

func NewJob

func NewJob() *Job

func (*Job) GetListenerJob

func (j *Job) GetListenerJob(listenerUUID string) (*ListenerJob, error)

func (*Job) NewListenerJob

func (j *Job) NewListenerJob(listenerUUID string) *ListenerJob

func (*Job) RemoveListenerJob

func (j *Job) RemoveListenerJob(listenerUUID string) error

func (*Job) WaitListenerStart

func (j *Job) WaitListenerStart(database *db.Database, lis *listener.Listener, lisJob *ListenerJob) error

func (*Job) WaitListenerStop

func (j *Job) WaitListenerStop(database *db.Database, lis *listener.Listener) error

type ListenerJob

type ListenerJob struct {
	ListenerUUID string
	ChReady      chan string
	ChError      chan string
	ChQuit       chan string
	ChReqQuit    chan string
}