worker

Documentation

Index

• type Manager
  • func NewManager(conn *grpc.ClientConn, id, baseURL, handlersDir string, numWorkers int) *Manager
  • func (m *Manager) ServeHTTP(w http.ResponseWriter, req *http.Request)
  • func (m *Manager) Stop()
  • func (m *Manager) Wait()

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

Manager controls a worker pool connected to a queue.

func NewManager

func NewManager(conn *grpc.ClientConn, id, baseURL, handlersDir string, numWorkers int) *Manager

NewManager starts a worker pool of size numWorkers connected to the given (presumably local) queue, running scripts off the handlersDir.

func (*Manager) ServeHTTP

func (m *Manager) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*Manager) Stop

func (m *Manager) Stop()

func (*Manager) Wait

func (m *Manager) Wait()