handlers

Documentation

Index

• Variables
• func BasicAuthWrap(handler http.Handler, username, password string) http.Handler
• func CORSWrapper(handler http.Handler) http.HandlerFunc
• func CookieAuthWrap(handler http.Handler, cookieName string) http.HandlerFunc
• func LogWrap(handler http.Handler, logger lager.Logger) http.HandlerFunc
• func New(bbs Bbs.ReceptorBBS, hub event.Hub, logger lager.Logger, ...) http.Handler
• type ActualLRPHandler
  • func NewActualLRPHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *ActualLRPHandler
  • func (h *ActualLRPHandler) GetAll(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPHandler) GetAllByProcessGuid(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPHandler) GetByProcessGuidAndIndex(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPHandler) KillByProcessGuidAndIndex(w http.ResponseWriter, req *http.Request)
• type CellHandler
  • func NewCellHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *CellHandler
  • func (h *CellHandler) GetAll(w http.ResponseWriter, req *http.Request)
• type DesiredLRPHandler
  • func NewDesiredLRPHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *DesiredLRPHandler
  • func (h *DesiredLRPHandler) Create(w http.ResponseWriter, r *http.Request)
  • func (h *DesiredLRPHandler) Delete(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) Get(w http.ResponseWriter, r *http.Request)
  • func (h *DesiredLRPHandler) GetAll(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) Update(w http.ResponseWriter, r *http.Request)
• type DomainHandler
  • func NewDomainHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *DomainHandler
  • func (h *DomainHandler) GetAll(w http.ResponseWriter, req *http.Request)
  • func (h *DomainHandler) Upsert(w http.ResponseWriter, req *http.Request)
• type EventStreamHandler
  • func NewEventStreamHandler(hub event.Hub, logger lager.Logger) *EventStreamHandler
  • func (h *EventStreamHandler) EventStream(w http.ResponseWriter, req *http.Request)
• type TaskHandler
  • func NewTaskHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *TaskHandler
  • func (h *TaskHandler) Cancel(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) Create(w http.ResponseWriter, r *http.Request)
  • func (h *TaskHandler) Delete(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) GetAll(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) GetByGuid(w http.ResponseWriter, req *http.Request)

Variables

var (
	ErrDomainMissing = errors.New("domain missing from request")
	ErrMaxAgeMissing = errors.New("max-age directive missing from request")
)

Functions

func BasicAuthWrap

func BasicAuthWrap(handler http.Handler, username, password string) http.Handler

func CORSWrapper

func CORSWrapper(handler http.Handler) http.HandlerFunc

see https://developer.mozilla.org/en-US/docs/Web/HTTP/Access_control_CORS

func CookieAuthWrap

func CookieAuthWrap(handler http.Handler, cookieName string) http.HandlerFunc

func LogWrap

func LogWrap(handler http.Handler, logger lager.Logger) http.HandlerFunc

func New

func New(bbs Bbs.ReceptorBBS, hub event.Hub, logger lager.Logger, username, password string, corsEnabled bool) http.Handler

Types

type ActualLRPHandler

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

func NewActualLRPHandler

func NewActualLRPHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *ActualLRPHandler

func (*ActualLRPHandler) GetAll

func (h *ActualLRPHandler) GetAll(w http.ResponseWriter, req *http.Request)

func (*ActualLRPHandler) GetAllByProcessGuid

func (h *ActualLRPHandler) GetAllByProcessGuid(w http.ResponseWriter, req *http.Request)

func (*ActualLRPHandler) GetByProcessGuidAndIndex

func (h *ActualLRPHandler) GetByProcessGuidAndIndex(w http.ResponseWriter, req *http.Request)

func (*ActualLRPHandler) KillByProcessGuidAndIndex

func (h *ActualLRPHandler) KillByProcessGuidAndIndex(w http.ResponseWriter, req *http.Request)

type CellHandler

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

func NewCellHandler

func NewCellHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *CellHandler

func (*CellHandler) GetAll

func (h *CellHandler) GetAll(w http.ResponseWriter, req *http.Request)

type DesiredLRPHandler

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

func NewDesiredLRPHandler

func NewDesiredLRPHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *DesiredLRPHandler

func (*DesiredLRPHandler) Create

func (h *DesiredLRPHandler) Create(w http.ResponseWriter, r *http.Request)

func (*DesiredLRPHandler) Delete

func (h *DesiredLRPHandler) Delete(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) Get

func (h *DesiredLRPHandler) Get(w http.ResponseWriter, r *http.Request)

func (*DesiredLRPHandler) GetAll

func (h *DesiredLRPHandler) GetAll(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) Update

func (h *DesiredLRPHandler) Update(w http.ResponseWriter, r *http.Request)

type DomainHandler

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

func NewDomainHandler

func NewDomainHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *DomainHandler

func (*DomainHandler) GetAll

func (h *DomainHandler) GetAll(w http.ResponseWriter, req *http.Request)

func (*DomainHandler) Upsert

func (h *DomainHandler) Upsert(w http.ResponseWriter, req *http.Request)

type EventStreamHandler

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

func NewEventStreamHandler

func NewEventStreamHandler(hub event.Hub, logger lager.Logger) *EventStreamHandler

func (*EventStreamHandler) EventStream

func (h *EventStreamHandler) EventStream(w http.ResponseWriter, req *http.Request)

type TaskHandler

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

func NewTaskHandler

func NewTaskHandler(bbs Bbs.ReceptorBBS, logger lager.Logger) *TaskHandler

func (*TaskHandler) Cancel

func (h *TaskHandler) Cancel(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) Create

func (h *TaskHandler) Create(w http.ResponseWriter, r *http.Request)

func (*TaskHandler) Delete

func (h *TaskHandler) Delete(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) GetAll

func (h *TaskHandler) GetAll(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) GetByGuid

func (h *TaskHandler) GetByGuid(w http.ResponseWriter, req *http.Request)