server

Documentation

Index

• func NewExportHandler(log *logrus.Logger) http.HandlerFunc
• func NewIndexHandler(log *logrus.Logger, s storage.AppNameGetter, dir http.FileSystem, ...) http.Handler
• func NewIngestHandler(log *logrus.Logger, p Parser, onSuccess func(pi *parser.PutInput)) http.Handler
• func NewLabelValuesHandler(log *logrus.Logger, s storage.LabelValuesGetter) http.HandlerFunc
• func NewLabelsHandler(log *logrus.Logger, s storage.LabelsGetter) http.HandlerFunc
• func WriteError(log *logrus.Logger, w http.ResponseWriter, code int, err error, msg string)
• func WriteErrorMessage(log *logrus.Logger, w http.ResponseWriter, code int, msg string)
• func WriteInternalServerError(log *logrus.Logger, w http.ResponseWriter, err error, msg string)
• func WriteInvalidMethodError(log *logrus.Logger, w http.ResponseWriter)
• func WriteInvalidParameterError(log *logrus.Logger, w http.ResponseWriter, err error)
• func WriteJSONEncodeError(log *logrus.Logger, w http.ResponseWriter, err error)
• func WriteResponseFile(_ *logrus.Logger, w http.ResponseWriter, filename string, content []byte)
• func WriteResponseJSON(log *logrus.Logger, w http.ResponseWriter, res interface{})
• type Config
• type Controller
  • func New(c Config) (*Controller, error)
  • func (ctrl *Controller) AppsCount() int
  • func (ctrl *Controller) Drain()
  • func (ctrl *Controller) Start() error
  • func (ctrl *Controller) Stats() map[string]int
  • func (ctrl *Controller) StatsInc(name string)
  • func (ctrl *Controller) Stop() error
• type Flags
• type IndexHandler
  • func (ih *IndexHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type IndexHandlerConfig
• type MergeHandler
  • func NewMergeHandler(l *logrus.Logger, s storage.Merger, dir http.FileSystem, stats StatsReceiver, ...) *MergeHandler
  • func (mh *MergeHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Notifier
• type Parser
• type Payload
• type RenderDiffHandler
  • func NewRenderDiffHandler(l *logrus.Logger, s storage.Getter, dir http.FileSystem, stats StatsReceiver, ...) *RenderDiffHandler
  • func (rh *RenderDiffHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type RenderDiffParams
• type RenderDiffResponse
• type RenderHandler
  • func NewRenderHandler(l *logrus.Logger, s storage.Getter, dir http.FileSystem, stats StatsReceiver, ...) *RenderHandler
  • func (rh *RenderHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type RenderResponse
• type RenderTreeParams
• type StatsReceiver
• type TargetsResponse

Functions

func NewExportHandler

func NewExportHandler(log *logrus.Logger) http.HandlerFunc

func NewIndexHandler

func NewIndexHandler(log *logrus.Logger, s storage.AppNameGetter, dir http.FileSystem, stats StatsReceiver, notifier Notifier, cfg *IndexHandlerConfig) http.Handler

func NewIngestHandler

func NewIngestHandler(log *logrus.Logger, p Parser, onSuccess func(pi *parser.PutInput)) http.Handler

func NewLabelValuesHandler

func NewLabelValuesHandler(log *logrus.Logger, s storage.LabelValuesGetter) http.HandlerFunc

func NewLabelsHandler

func NewLabelsHandler(log *logrus.Logger, s storage.LabelsGetter) http.HandlerFunc

func WriteError

func WriteError(log *logrus.Logger, w http.ResponseWriter, code int, err error, msg string)

func WriteErrorMessage

func WriteErrorMessage(log *logrus.Logger, w http.ResponseWriter, code int, msg string)

func WriteInternalServerError

func WriteInternalServerError(log *logrus.Logger, w http.ResponseWriter, err error, msg string)

func WriteInvalidMethodError

func WriteInvalidMethodError(log *logrus.Logger, w http.ResponseWriter)

func WriteInvalidParameterError

func WriteInvalidParameterError(log *logrus.Logger, w http.ResponseWriter, err error)

func WriteJSONEncodeError

func WriteJSONEncodeError(log *logrus.Logger, w http.ResponseWriter, err error)

func WriteResponseFile

func WriteResponseFile(_ *logrus.Logger, w http.ResponseWriter, filename string, content []byte)

func WriteResponseJSON

func WriteResponseJSON(log *logrus.Logger, w http.ResponseWriter, res interface{})

Types

type Config

type Config struct {
	Configuration *config.Server
	*logrus.Logger
	*storage.Storage
	*gorm.DB
	Notifier

	// The registerer is used for exposing server metrics.
	MetricsRegisterer prometheus.Registerer

	// Exported metrics registry and exported.
	ExportedMetricsRegistry *prometheus.Registry
	storage.MetricsExporter

	Adhoc adhocserver.Server

	ScrapeManager *scrape.Manager
}

type Controller

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

func New

func New(c Config) (*Controller, error)

func (*Controller) AppsCount

func (ctrl *Controller) AppsCount() int

func (*Controller) Drain

func (ctrl *Controller) Drain()

func (*Controller) Start

func (ctrl *Controller) Start() error

func (*Controller) Stats

func (ctrl *Controller) Stats() map[string]int

func (*Controller) StatsInc

func (ctrl *Controller) StatsInc(name string)

func (*Controller) Stop

func (ctrl *Controller) Stop() error

type Flags

type Flags struct {
	EnableAdhocUI bool `json:"enableAdhocUI"`
}

type IndexHandler

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

func (*IndexHandler) ServeHTTP

func (ih *IndexHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type IndexHandlerConfig

type IndexHandlerConfig struct {
	Flags          Flags
	IsAuthRequired bool
	BaseURL        string
}

type MergeHandler

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

func NewMergeHandler

func NewMergeHandler(l *logrus.Logger, s storage.Merger, dir http.FileSystem, stats StatsReceiver, maxNodesDefault int) *MergeHandler

func (*MergeHandler) ServeHTTP

func (mh *MergeHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Notifier

type Notifier interface {
	// NotificationText returns message that will be displayed to user
	// on index page load. The message should point user to a critical problem.
	// TODO(kolesnikovae): we should poll for notifications (or subscribe).
	NotificationText() string
}

type Parser

type Parser interface {
	Put(context.Context, *parser.PutInput) (error, error)
}

type Payload

type Payload struct {
	Name    string
	Profile string
	Type    string
}

type RenderDiffHandler

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

func NewRenderDiffHandler

func NewRenderDiffHandler(l *logrus.Logger, s storage.Getter, dir http.FileSystem, stats StatsReceiver, maxNodesDefault int) *RenderDiffHandler

func (*RenderDiffHandler) ServeHTTP

func (rh *RenderDiffHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type RenderDiffParams

type RenderDiffParams struct {
	LeftQuery string `json:"leftQuery"`
	LeftFrom  string `json:"leftFrom"`
	LeftUntil string `json:"leftUntil"`

	RightQuery string `json:"rightQuery"`
	RightFrom  string `json:"rightFrom"`
	RightUntil string `json:"rightUntil"`

	Format   string `json:"format"`
	MaxNodes *int   `json:"maxNodes,omitempty"`
}

RenderDiffParams refers to the params accepted by the renderDiffHandler

type RenderDiffResponse

type RenderDiffResponse struct {
	*flamebearer.FlamebearerProfile
}

RenderDiffResponse refers to the response of the renderDiffHandler

type RenderHandler

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

func NewRenderHandler

func NewRenderHandler(l *logrus.Logger, s storage.Getter, dir http.FileSystem, stats StatsReceiver, maxNodesDefault int) *RenderHandler

func (*RenderHandler) ServeHTTP

func (rh *RenderHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type RenderResponse

type RenderResponse struct {
	flamebearer.FlamebearerProfile
	Metadata renderMetadataResponse `json:"metadata"`
}

type RenderTreeParams

type RenderTreeParams struct {
	From  string `json:"from"`
	Until string `json:"until"`
}

type StatsReceiver

type StatsReceiver interface {
	StatsInc(name string)
}

type TargetsResponse

type TargetsResponse struct {
	Job                string              `json:"job"`
	TargetURL          string              `json:"url"`
	DiscoveredLabels   labels.Labels       `json:"discoveredLabels"`
	Labels             labels.Labels       `json:"labels"`
	Health             scrape.TargetHealth `json:"health"`
	LastScrape         time.Time           `json:"lastScrape"`
	LastError          string              `json:"lastError"`
	LastScrapeDuration string              `json:"lastScrapeDuration"`
}