Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func New ¶
func New(j *jobmanager.JobManager, t *table.Table, instanceID uint32, l net.Listener, shutdownTimeout, idleTimeout, readTimeout, writeTimeout time.Duration) *Server
func (*Server) NotifyDone ¶
func (s *Server) NotifyDone() chan struct{}
type Status ¶
type Status struct { InstanceID uint32 `json:"instance_id"` InstanceRunningJobs int `json:"instance_running_jobs"` RunningJobs int64 `json:"running_jobs"` TotalJobs int64 `json:"total_jobs"` PendingJobs int64 `json:"pending_jobs"` TotalInstances int64 `json:"total_instances"` Lag int64 `json:"lag"` }
Click to show internal directories.
Click to hide internal directories.