worker

Documentation

Index

• type Worker
  • func NewWorker(superSpec *supervisor.Spec) *Worker
  • func (worker *Worker) Close()
  • func (worker *Worker) Create(w http.ResponseWriter, r *http.Request)
  • func (worker *Worker) Delete(w http.ResponseWriter, r *http.Request)
  • func (worker *Worker) Get(w http.ResponseWriter, r *http.Request)
  • func (worker *Worker) List(w http.ResponseWriter, r *http.Request)
  • func (worker *Worker) Lock()
  • func (worker *Worker) Start(w http.ResponseWriter, r *http.Request)
  • func (worker *Worker) Stop(w http.ResponseWriter, r *http.Request)
  • func (worker *Worker) Unlock()
  • func (worker *Worker) UnregisterAPIs()
  • func (worker *Worker) Update(w http.ResponseWriter, r *http.Request)

Types

type Worker

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

Worker stores the woker information

func NewWorker

func NewWorker(superSpec *supervisor.Spec) *Worker

NewWorker return a worker

func (*Worker) Close

func (worker *Worker) Close()

Close closes the Egress HTTPServer and Pipelines

func (*Worker) Create

func (worker *Worker) Create(w http.ResponseWriter, r *http.Request)

Create deals with HTTP POST method

func (*Worker) Delete

func (worker *Worker) Delete(w http.ResponseWriter, r *http.Request)

Delete deals with HTTP DELETE

func (*Worker) Get

func (worker *Worker) Get(w http.ResponseWriter, r *http.Request)

Get deals with HTTP GET method request

func (*Worker) List

func (worker *Worker) List(w http.ResponseWriter, r *http.Request)

List deals with HTTP GET method

func (*Worker) Lock

func (worker *Worker) Lock()

Lock locks the cluster store.

func (*Worker) Start

func (worker *Worker) Start(w http.ResponseWriter, r *http.Request)

Start is a start API which deals with HTTP PUT method

func (*Worker) Stop

func (worker *Worker) Stop(w http.ResponseWriter, r *http.Request)

Stop is a stop API which deals with HTTP PUT method

func (*Worker) Unlock

func (worker *Worker) Unlock()

Unlock unlocks the cluster store.

func (*Worker) UnregisterAPIs

func (worker *Worker) UnregisterAPIs()

UnregisterAPIs unregister APIs

func (*Worker) Update

func (worker *Worker) Update(w http.ResponseWriter, r *http.Request)

Update deals with HTTP PUT method