httpsource

Documentation

Overview

Package httpsource implements event.Source by accepting incoming HTTP requests that contain a machine.Event serialized as JSON.

Index

• type HTTPSource
  • func New() (*HTTPSource, error)
  • func (h *HTTPSource) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (h *HTTPSource) Start(ctx context.Context) (<-chan machine.Event, error)

Types

type HTTPSource

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

HTTPSource implements event.Source and http.Handler.

func New

func New() (*HTTPSource, error)

New returns an instance of HTTPSource.

func (*HTTPSource) ServeHTTP

func (h *HTTPSource) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP implements http.Handler.

Must be hooked up to the frontend to handle incoming HTTP sent Events. See rpc.go for the URL to use.

func (*HTTPSource) Start

func (h *HTTPSource) Start(ctx context.Context) (<-chan machine.Event, error)

Start implements Source.