api

Documentation

Overview

Package api provides API endpoints and controllers.

Index

• Variables
• type API
  • func NewAPI(appCtx app.Context) *API
  • func (api *API) Router() *echo.Echo
  • func (api *API) Run() error
  • func (api *API) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (api *API) Stop() error
  • func (api *API) Use(middleware ...echo.MiddlewareFunc)
  • func (api *API) WriteResult(c echo.Context, v interface{}, err error) (int, interface{})

Variables

var ErrCDCDisabled = etre.Error{
	Type:       "cdc-disabled",
	HTTPStatus: http.StatusNotImplemented,
	Message:    "CDC disabled",
}

var ErrDb = etre.Error{
	Type:       "db-error",
	HTTPStatus: http.StatusInternalServerError,
	Message:    "unknown database error",
}

var ErrDuplicateEntity = etre.Error{
	Type:       "duplicate-entity",
	HTTPStatus: http.StatusConflict,
	Message:    "cannot insert or update entity because identifying labels conflict with another entity",
}

var ErrInternal = etre.Error{
	Type:       "internal-error",
	HTTPStatus: http.StatusInternalServerError,
	Message:    "internal server error",
}

var ErrInvalidParam = etre.Error{
	Type:       "invalid-param",
	HTTPStatus: http.StatusBadRequest,
	Message:    "missing parameter",
}

var ErrInvalidQuery = etre.Error{
	Type:       "invalid-query",
	HTTPStatus: http.StatusBadRequest,
	Message:    "invalid query",
}

var ErrMissingParam = etre.Error{
	Type:       "missing-param",
	HTTPStatus: http.StatusBadRequest,
	Message:    "missing parameter",
}

var ErrNotFound = etre.Error{
	Type:       "entity-not-found",
	HTTPStatus: http.StatusNotFound,
	Message:    "entity not found",
}

Types

type API

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

API provides controllers for endpoints it registers with a router.

func NewAPI

func NewAPI(appCtx app.Context) *API

NewAPI makes a new API.

func (*API) Router

func (api *API) Router() *echo.Echo

func (*API) Run

func (api *API) Run() error

func (*API) ServeHTTP

func (api *API) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP allows the API to statisfy the http.HandlerFunc interface.

func (*API) Stop

func (api *API) Stop() error

func (*API) Use

func (api *API) Use(middleware ...echo.MiddlewareFunc)

Use adds middleware to the echo web server in the API. See https://echo.labstack.com/middleware for more details.

func (*API) WriteResult

func (api *API) WriteResult(c echo.Context, v interface{}, err error) (int, interface{})

Return an etre.WriteResult for all writes, successful of not. v are the writes, if any, from entity.Store calls, which is why it can be different types. v and err are _not_ mutually exclusive; writes can be partially successful.