router

Documentation

Index

• func NewMeterListResponse(meters []*models.Meter) []render.Renderer
• func ValidateGetValuesByMeterIdParams(meter *models.Meter, params api.GetValuesByMeterIdParams) error
• type Config
• type GetValuesByMeterIdResponse
  • func (rd *GetValuesByMeterIdResponse) Render(w http.ResponseWriter, r *http.Request) error
• type Router
  • func NewRouter(config Config) (*Router, error)
  • func (a *Router) GetMeters(w http.ResponseWriter, r *http.Request)
  • func (a *Router) GetMetersById(w http.ResponseWriter, r *http.Request, meterID string)
  • func (a *Router) GetValuesByMeterId(w http.ResponseWriter, r *http.Request, meterId string, ...)
  • func (a *Router) IngestEvents(w http.ResponseWriter, r *http.Request)

Functions

func NewMeterListResponse

func NewMeterListResponse(meters []*models.Meter) []render.Renderer

func ValidateGetValuesByMeterIdParams

func ValidateGetValuesByMeterIdParams(meter *models.Meter, params api.GetValuesByMeterIdParams) error

Types

type Config

type Config struct {
	StreamingConnector streaming.Connector
	IngestHandler      http.Handler
	Meters             []*models.Meter
}

type GetValuesByMeterIdResponse

type GetValuesByMeterIdResponse struct {
	WindowSize *models.WindowSize   `json:"windowSize"`
	Data       []*models.MeterValue `json:"data"`
}

func (*GetValuesByMeterIdResponse) Render

func (rd *GetValuesByMeterIdResponse) Render(w http.ResponseWriter, r *http.Request) error

type Router

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

func NewRouter

func NewRouter(config Config) (*Router, error)

func (*Router) GetMeters

func (a *Router) GetMeters(w http.ResponseWriter, r *http.Request)

func (*Router) GetMetersById

func (a *Router) GetMetersById(w http.ResponseWriter, r *http.Request, meterID string)

func (*Router) GetValuesByMeterId

func (a *Router) GetValuesByMeterId(w http.ResponseWriter, r *http.Request, meterId string, params api.GetValuesByMeterIdParams)

func (*Router) IngestEvents

func (a *Router) IngestEvents(w http.ResponseWriter, r *http.Request)