play

Documentation

Index

• func Page(w http.ResponseWriter, req *http.Request, database services.Database)
• type Handler
  • func (h *Handler) Deploy(ctx context.Context, info messages.Deploy, req *http.Request, ...) error
  • func (h *Handler) Get(ctx context.Context, info messages.Get, req *http.Request, ...) error
  • func (h *Handler) Handle(ctx context.Context, req *http.Request, send func(message services.Message), ...) error
  • func (h *Handler) Initialise(ctx context.Context, info messages.Initialise, req *http.Request, ...) error
  • func (h *Handler) MarshalMessage(m services.Message) (payload []byte, messageType int, err error)
  • func (h *Handler) RequestTimeout() time.Duration
  • func (h *Handler) Share(ctx context.Context, info messages.Share, req *http.Request, ...) error
  • func (h *Handler) StoreError(ctx context.Context, err error, req *http.Request)
  • func (h *Handler) UnarshalMessage(b []byte) (services.Message, error)
  • func (h *Handler) Update(ctx context.Context, info messages.Update, req *http.Request, ...) error
  • func (h *Handler) WebsocketPingPeriod() time.Duration
  • func (h *Handler) WebsocketPongTimeout() time.Duration
  • func (h *Handler) WebsocketTimeout() time.Duration

Functions

func Page

func Page(w http.ResponseWriter, req *http.Request, database services.Database)

Types

type Handler

type Handler struct {
	Cache      *cache.Cache
	Fileserver services.Fileserver
	Database   services.Database
}

func (*Handler) Deploy

func (h *Handler) Deploy(ctx context.Context, info messages.Deploy, req *http.Request, send func(message services.Message), receive chan services.Message) error

func (*Handler) Get

func (h *Handler) Get(ctx context.Context, info messages.Get, req *http.Request, send func(message services.Message), receive chan services.Message) error

func (*Handler) Handle

func (h *Handler) Handle(ctx context.Context, req *http.Request, send func(message services.Message), receive chan services.Message, tj *tracker.Job) error

func (*Handler) Initialise

func (h *Handler) Initialise(ctx context.Context, info messages.Initialise, req *http.Request, send func(message services.Message), receive chan services.Message) error

func (*Handler) MarshalMessage

func (h *Handler) MarshalMessage(m services.Message) (payload []byte, messageType int, err error)

func (*Handler) RequestTimeout

func (h *Handler) RequestTimeout() time.Duration

func (*Handler) Share

func (h *Handler) Share(ctx context.Context, info messages.Share, req *http.Request, send func(message services.Message), receive chan services.Message) error

func (*Handler) StoreError

func (h *Handler) StoreError(ctx context.Context, err error, req *http.Request)

func (*Handler) UnarshalMessage

func (h *Handler) UnarshalMessage(b []byte) (services.Message, error)

func (*Handler) Update

func (h *Handler) Update(ctx context.Context, info messages.Update, req *http.Request, send func(message services.Message), receive chan services.Message) error

func (*Handler) WebsocketPingPeriod

func (h *Handler) WebsocketPingPeriod() time.Duration

func (*Handler) WebsocketPongTimeout

func (h *Handler) WebsocketPongTimeout() time.Duration

func (*Handler) WebsocketTimeout

func (h *Handler) WebsocketTimeout() time.Duration