service

Documentation

Index

• Variables
• type HttpService
  • func NewHttpService(ic *backend.InfluxCluster, nodecfg *backend.NodeConfig) (hs *HttpService)
  • func (hs *HttpService) HandlerPing(w http.ResponseWriter, req *http.Request)
  • func (hs *HttpService) HandlerQuery(w http.ResponseWriter, req *http.Request)
  • func (hs *HttpService) HandlerWrite(w http.ResponseWriter, req *http.Request)
  • func (hs *HttpService) Register(mux *http.ServeMux)
  • func (hs *HttpService) WriteError(w http.ResponseWriter, req *http.Request, status int, err error)

Variables

var (
	ErrAuthentication    = errors.New("authentication failed")
	ErrMethodNotAllowed  = errors.New("method not allowed")
	ErrDatabaseNotFound  = errors.New("database not found")
	ErrDatabaseForbidden = errors.New("database forbidden")
	ErrGzipUnableDecode  = errors.New("unable to decode gzip body")
)

Types

type HttpService

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

func NewHttpService

func NewHttpService(ic *backend.InfluxCluster, nodecfg *backend.NodeConfig) (hs *HttpService)

func (*HttpService) HandlerPing

func (hs *HttpService) HandlerPing(w http.ResponseWriter, req *http.Request)

func (*HttpService) HandlerQuery

func (hs *HttpService) HandlerQuery(w http.ResponseWriter, req *http.Request)

func (*HttpService) HandlerWrite

func (hs *HttpService) HandlerWrite(w http.ResponseWriter, req *http.Request)

func (*HttpService) Register

func (hs *HttpService) Register(mux *http.ServeMux)

func (*HttpService) WriteError

func (hs *HttpService) WriteError(w http.ResponseWriter, req *http.Request, status int, err error)