Versions in this module Expand all Collapse all v0 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