server

Documentation

Overview

Package server serves up the endpoints cache via http

Package server serves the HTTP endpoints

Index

• func Run(shutdownChannel chan bool, waitGroup *sync.WaitGroup, port int64, ...)
• type HealthStatus
  • func NewHealthStatus(errorChannel chan bool) *HealthStatus
  • func (h *HealthStatus) Health(w http.ResponseWriter, r *http.Request)
• type Provider
  • func NewProvider(controller *streamer.Controller) *Provider
  • func (p Provider) Create(w http.ResponseWriter, r *http.Request)

Functions

func Run

func Run(shutdownChannel chan bool, waitGroup *sync.WaitGroup, port int64, controller *streamer.Controller, errorChannel chan bool)

Run runs our http server using specified port

Types

type HealthStatus

type HealthStatus struct {
	Errors   chan bool
	HasError bool
}

func NewHealthStatus

func NewHealthStatus(errorChannel chan bool) *HealthStatus

func (*HealthStatus) Health

func (h *HealthStatus) Health(w http.ResponseWriter, r *http.Request)

Health serves our health route

type Provider

type Provider struct {
	Controller *streamer.Controller
}

func NewProvider

func NewProvider(controller *streamer.Controller) *Provider

func (Provider) Create

func (p Provider) Create(w http.ResponseWriter, r *http.Request)