router

Documentation

Index

• func ValidateGetMeterValuesParams(params api.GetMeterValuesParams) error
• type Config
• type GetMeterValuesResponse
  • func (rd *GetMeterValuesResponse) Render(w http.ResponseWriter, r *http.Request) error
• type IngestHandler
• type Router
  • func NewRouter(config Config) (*Router, error)
  • func (a *Router) CreateMeter(w http.ResponseWriter, r *http.Request, params api.CreateMeterParams)
  • func (a *Router) CreateNamespace(w http.ResponseWriter, r *http.Request)
  • func (a *Router) DeleteMeter(w http.ResponseWriter, r *http.Request, meterIdOrSlug string, ...)
  • func (a *Router) GetMeter(w http.ResponseWriter, r *http.Request, meterIdOrSlug string, ...)
  • func (a *Router) GetMeterValues(w http.ResponseWriter, r *http.Request, meterIdOrSlug string, ...)
  • func (a *Router) IngestEvents(w http.ResponseWriter, r *http.Request, params api.IngestEventsParams)
  • func (a *Router) ListMeters(w http.ResponseWriter, r *http.Request, params api.ListMetersParams)

Functions

func ValidateGetMeterValuesParams

func ValidateGetMeterValuesParams(params api.GetMeterValuesParams) error

Types

type Config

type Config struct {
	NamespaceManager   *namespace.Manager
	StreamingConnector streaming.Connector
	IngestHandler      IngestHandler
	Meters             []*models.Meter
}

type GetMeterValuesResponse

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

func (*GetMeterValuesResponse) Render

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

type IngestHandler

type IngestHandler interface {
	ServeHTTP(w http.ResponseWriter, r *http.Request, params api.IngestEventsParams)
}

type Router

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

func NewRouter

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

func (*Router) CreateMeter

func (a *Router) CreateMeter(w http.ResponseWriter, r *http.Request, params api.CreateMeterParams)

func (*Router) CreateNamespace

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

func (*Router) DeleteMeter

func (a *Router) DeleteMeter(w http.ResponseWriter, r *http.Request, meterIdOrSlug string, params api.DeleteMeterParams)

func (*Router) GetMeter

func (a *Router) GetMeter(w http.ResponseWriter, r *http.Request, meterIdOrSlug string, params api.GetMeterParams)

func (*Router) GetMeterValues

func (a *Router) GetMeterValues(w http.ResponseWriter, r *http.Request, meterIdOrSlug string, params api.GetMeterValuesParams)

func (*Router) IngestEvents

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

func (*Router) ListMeters

func (a *Router) ListMeters(w http.ResponseWriter, r *http.Request, params api.ListMetersParams)