Versions in this module Expand all Collapse all v0 v0.2.0 Aug 28, 2026 Changes in this version + var ErrInvalidAuth = errors.New("admin auth: invalid bearer token") + var ErrMissingAuth = errors.New("admin auth: missing or malformed Authorization header") + type Authenticator interface + Authenticate func(r *http.Request) error + type JWTVerifier interface + Verify func(ctx context.Context, token string) error type Option + func WithAuth(a Authenticator) Option + func WithAuthToken(tokens ...string) Option + func WithJWTVerifier(v JWTVerifier) Option v0.1.0 May 12, 2026 Changes in this version + func UIHandler() http.Handler + type Option func(*Server) + func WithAllowedOrigins(origins ...string) Option + type PipelineInfo struct + CacheType string + MonoidKind string + Name string + SourceType string + StoreType string + WindowGranSec int64 + WindowRetSec int64 + Windowed bool + type QueryFn func(op string, params map[string]string) (data []byte, present bool, err error) + type Server struct + func NewServer(recorder *metrics.InMemory, opts ...Option) *Server + func (s *Server) FullHandler() http.Handler + func (s *Server) GetPipelineMetrics(_ context.Context, req *connect.Request[adminv1.GetPipelineMetricsRequest]) (*connect.Response[adminv1.GetPipelineMetricsResponse], error) + func (s *Server) GetRange(_ context.Context, req *connect.Request[adminv1.GetRangeRequest]) (*connect.Response[adminv1.GetRangeResponse], error) + func (s *Server) GetState(_ context.Context, req *connect.Request[adminv1.GetStateRequest]) (*connect.Response[adminv1.GetStateResponse], error) + func (s *Server) GetWindow(_ context.Context, req *connect.Request[adminv1.GetWindowRequest]) (*connect.Response[adminv1.GetWindowResponse], error) + func (s *Server) Handler() http.Handler + func (s *Server) Health(_ context.Context, _ *connect.Request[adminv1.HealthRequest]) (*connect.Response[adminv1.HealthResponse], error) + func (s *Server) ListPipelines(_ context.Context, _ *connect.Request[adminv1.ListPipelinesRequest]) (*connect.Response[adminv1.ListPipelinesResponse], error) + func (s *Server) Register(info PipelineInfo, query QueryFn)
Go to main page