http

Documentation

Index

• func APIKeyMiddleware(apiKey string, next http.Handler) http.Handler
• func RegisterRoutes(mux *http.ServeMux, batcher *ingest.Batcher, exec *query.Executor, ...)
• type AdminHandler
  • func NewAdminHandler(manager *storage.SegmentManager, sparse *index.SparseIndex, log *slog.Logger) *AdminHandler
  • func (h *AdminHandler) Segments(w http.ResponseWriter, r *http.Request)
  • func (h *AdminHandler) Stats(w http.ResponseWriter, r *http.Request)
• type IngestHandler
  • func NewIngestHandler(batcher *ingest.Batcher, log *slog.Logger) *IngestHandler
  • func (h *IngestHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type OTLPHandler
  • func NewOTLPHandler(batcher *ingest.Batcher, log *slog.Logger) *OTLPHandler
  • func (h *OTLPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type QueryHandler
  • func NewQueryHandler(exec *query.Executor, log *slog.Logger) *QueryHandler
  • func (h *QueryHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Server
  • func NewServer(addr string, handler http.Handler, readTimeout, writeTimeout time.Duration, ...) *Server
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Start()
• type ServicesHandler
  • func NewServicesHandler(exec *query.Executor, log *slog.Logger) *ServicesHandler
  • func (h *ServicesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type TraceHandler
  • func NewTraceHandler(exec *query.Executor, log *slog.Logger) *TraceHandler
  • func (h *TraceHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type TracesHandler
  • func NewTracesHandler(exec *query.Executor, log *slog.Logger) *TracesHandler
  • func (h *TracesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func APIKeyMiddleware

func APIKeyMiddleware(apiKey string, next http.Handler) http.Handler

func RegisterRoutes

func RegisterRoutes(
	mux *http.ServeMux,
	batcher *ingest.Batcher,
	exec *query.Executor,
	logManager *storage.SegmentManager,
	logSparse *index.SparseIndex,
	apiKey string,
	log *slog.Logger,
)

Types

type AdminHandler

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

func NewAdminHandler

func NewAdminHandler(manager *storage.SegmentManager, sparse *index.SparseIndex, log *slog.Logger) *AdminHandler

func (*AdminHandler) Segments

func (h *AdminHandler) Segments(w http.ResponseWriter, r *http.Request)

func (*AdminHandler) Stats

func (h *AdminHandler) Stats(w http.ResponseWriter, r *http.Request)

type IngestHandler

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

func NewIngestHandler

func NewIngestHandler(batcher *ingest.Batcher, log *slog.Logger) *IngestHandler

func (*IngestHandler) ServeHTTP

func (h *IngestHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type OTLPHandler

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

func NewOTLPHandler

func NewOTLPHandler(batcher *ingest.Batcher, log *slog.Logger) *OTLPHandler

func (*OTLPHandler) ServeHTTP

func (h *OTLPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type QueryHandler

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

func NewQueryHandler

func NewQueryHandler(exec *query.Executor, log *slog.Logger) *QueryHandler

func (*QueryHandler) ServeHTTP

func (h *QueryHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Server

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

func NewServer

func NewServer(addr string, handler http.Handler, readTimeout, writeTimeout time.Duration, log *slog.Logger) *Server

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

func (*Server) Start

func (s *Server) Start()

type ServicesHandler

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

func NewServicesHandler

func NewServicesHandler(exec *query.Executor, log *slog.Logger) *ServicesHandler

func (*ServicesHandler) ServeHTTP

func (h *ServicesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type TraceHandler

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

func NewTraceHandler

func NewTraceHandler(exec *query.Executor, log *slog.Logger) *TraceHandler

func (*TraceHandler) ServeHTTP

func (h *TraceHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type TracesHandler

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

func NewTracesHandler

func NewTracesHandler(exec *query.Executor, log *slog.Logger) *TracesHandler

func (*TracesHandler) ServeHTTP

func (h *TracesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)