proxy

Mar 17, 2026

Changes in this version

+ var EmbeddingCostUSD = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ var EmbeddingItemsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var EmbeddingRequestDurationSeconds = prometheus.NewHistogram(prometheus.HistogramOpts{ ... })

+ var EmbeddingRequestsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var EmbeddingTokensTotal = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

type Client

+ EmbeddingAvailable func() bool

+ EmbeddingModel func() string

type DatasourcesResponse

+ EmbeddingAvailable bool

+ EmbeddingModel string

+ type EmbedCheckRequest struct

+ Hashes []string

+ Model string

+ type EmbedCheckResponse struct

+ Cached []EmbedResult

+ type EmbedItem struct

+ Hash string

+ Text string

+ type EmbedRequest struct

+ Items []EmbedItem

+ type EmbedResponse struct

+ Model string

+ Results []EmbedResult

+ type EmbedResult struct

+ Hash string

+ Vector []float32

+ type EmbeddingCacheConfig struct

+ Backend string

+ RedisURL string

+ type EmbeddingConfig struct

+ APIKey string

+ APIURL string

+ Cache EmbeddingCacheConfig

+ Model string

+ type EmbeddingService struct

+ func NewEmbeddingService(log logrus.FieldLogger, c cache.Cache, apiKey, model, apiURL string, ...) *EmbeddingService

+ func (s *EmbeddingService) CheckCached(ctx context.Context, hashes []string) ([]EmbedResult, error)

+ func (s *EmbeddingService) Close() error

+ func (s *EmbeddingService) Embed(ctx context.Context, items []EmbedItem) (*EmbedResponse, error)

+ func (s *EmbeddingService) Model() string

type ServerConfig

+ Embedding *EmbeddingConfig

type Service

+ EmbeddingAvailable func() bool

+ EmbeddingModel func() string

Mar 16, 2026

Changes in this version

+ type AuthMetadataResponse struct

+ ClientID string

+ Enabled bool

+ IssuerURL string

+ Mode string

+ type Authorizer struct

+ func NewAuthorizer(log logrus.FieldLogger, cfg ServerConfig) *Authorizer

+ func (a *Authorizer) FilterDatasources(ctx context.Context, resp DatasourcesResponse) DatasourcesResponse

+ func (a *Authorizer) Middleware() func(http.Handler) http.Handler

+ type BaseDatasourceConfig struct

+ AllowedOrgs []string

+ Description string

+ Name string

+ func (b BaseDatasourceConfig) DatasourceAllowedOrgs() []string

+ func (b BaseDatasourceConfig) DatasourceDescription() string

+ func (b BaseDatasourceConfig) DatasourceName() string

+ type DatasourceConfig interface

+ DatasourceAllowedOrgs func() []string

+ DatasourceDescription func() string

+ DatasourceName func() string

Mar 16, 2026

Changes in this version

type AuditEntry

+ Groups []string

+ Subject string

+ Username string

type AuthConfig

+ ClientID string

+ IssuerURL string

+ RefreshTokenTTL time.Duration

type AuthMode

+ const AuthModeOIDC

+ type AuthUser struct

+ Groups []string

+ Subject string

+ Username string

+ func GetAuthUser(ctx context.Context) *AuthUser

type Authenticator

+ func NewOIDCAuthenticator(log logrus.FieldLogger, cfg OIDCAuthenticatorConfig) (Authenticator, error)

type ClientConfig

+ RefreshTokenTTL time.Duration

type MetricsConfig

+ ListenAddr string

+ type OIDCAuthenticatorConfig struct

+ ClientID string

+ IssuerURL string

Mar 12, 2026

Changes in this version

type AuditEntry

+ DatasourceName string

+ DatasourceType string

+ GitHubID int64

+ GitHubLogin string

+ Orgs []string

+ ResponseBytes int

+ UserAgent string

Mar 11, 2026

Changes in this version

type AuthConfig

+ SuccessPage *simpleauth.SuccessPageConfig

Mar 11, 2026

Changes in this version

+ var ErrAuthenticationRequired = errors.New("proxy authentication required")

+ var ProxyActiveRequests = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var ProxyRateLimitRejectionsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var ProxyRequestDurationSeconds = prometheus.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... })

+ var ProxyRequestsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var ProxyResponseSizeBytes = prometheus.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... })

+ func GetUserID(ctx context.Context) string

+ type AuditConfig struct

+ Enabled bool

+ LogQueries bool

+ MaxQueryLength int

+ type AuditEntry struct

+ Datasource string

+ Duration string

+ Method string

+ Path string

+ Query string

+ StatusCode int

+ UserID string

+ type Auditor struct

+ func NewAuditor(log logrus.FieldLogger, cfg AuditorConfig) *Auditor

+ func (a *Auditor) Middleware() func(http.Handler) http.Handler

+ type AuditorConfig struct

+ LogQueries bool

+ MaxQueryLength int

+ type AuthConfig struct

+ AccessTokenTTL time.Duration

+ AllowedOrgs []string

+ GitHub *simpleauth.GitHubConfig

+ Mode AuthMode

+ Tokens simpleauth.TokensConfig

+ type AuthMode string

+ const AuthModeNone

+ const AuthModeOAuth

+ type Authenticator interface

+ Middleware func() func(http.Handler) http.Handler

+ Start func(ctx context.Context) error

+ Stop func() error

+ func NewNoneAuthenticator(log logrus.FieldLogger) Authenticator

+ func NewSimpleServiceAuthenticator(svc simpleauth.SimpleService) Authenticator

+ type ClickHouseClusterConfig struct

+ Database string

+ Description string

+ Host string

+ Name string

+ Password string

+ Port int

+ Secure bool

+ SkipVerify bool

+ Timeout int

+ Username string

+ type Client interface

+ ClickHouseDatasourceInfo func() []types.DatasourceInfo

+ ClickHouseDatasources func() []string

+ Discover func(ctx context.Context) error

+ EnsureAuthenticated func(ctx context.Context) error

+ EthNodeAvailable func() bool

+ LokiDatasourceInfo func() []types.DatasourceInfo

+ LokiDatasources func() []string

+ PrometheusDatasourceInfo func() []types.DatasourceInfo

+ PrometheusDatasources func() []string

+ RegisterToken func(executionID string) string

+ RevokeToken func(executionID string)

+ S3Bucket func() string

+ S3PublicURLPrefix func() string

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ URL func() string

+ func NewClient(log logrus.FieldLogger, cfg ClientConfig) Client

+ type ClientConfig struct

+ ClientID string

+ DiscoveryInterval time.Duration

+ HTTPTimeout time.Duration

+ IssuerURL string

+ Resource string

+ URL string

+ func (c *ClientConfig) ApplyDefaults()

+ type DatasourcesResponse struct

+ ClickHouse []string

+ ClickHouseInfo []types.DatasourceInfo

+ EthNodeAvailable bool

+ Loki []string

+ LokiInfo []types.DatasourceInfo

+ Prometheus []string

+ PrometheusInfo []types.DatasourceInfo

+ S3Bucket string

+ S3PublicURLPrefix string

+ type EthNodeInstanceConfig struct

+ Password string

+ Username string

+ type HTTPServerConfig struct

+ IdleTimeout time.Duration

+ ListenAddr string

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type LokiInstanceConfig struct

+ Description string

+ Name string

+ Password string

+ URL string

+ Username string

+ type MetricsConfig struct

+ Enabled bool

+ Port int

+ type PrometheusInstanceConfig struct

+ Description string

+ Name string

+ Password string

+ URL string

+ Username string

+ type RateLimitConfig struct

+ BurstSize int

+ Enabled bool

+ RequestsPerMinute int

+ type RateLimiter struct

+ func NewRateLimiter(log logrus.FieldLogger, cfg RateLimiterConfig) *RateLimiter

+ func (rl *RateLimiter) Allow(userID string) bool

+ func (rl *RateLimiter) Middleware() func(http.Handler) http.Handler

+ func (rl *RateLimiter) Stop()

+ type RateLimiterConfig struct

+ BurstSize int

+ RequestsPerMinute int

+ type S3Config struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ PublicURLPrefix string

+ Region string

+ SecretKey string

+ type Server interface

+ ClickHouseDatasources func() []string

+ LokiDatasources func() []string

+ PrometheusDatasources func() []string

+ S3Bucket func() string

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ URL func() string

+ func NewServer(log logrus.FieldLogger, cfg ServerConfig) (Server, error)

+ type ServerConfig struct

+ Audit AuditConfig

+ Auth AuthConfig

+ ClickHouse []ClickHouseClusterConfig

+ EthNode *EthNodeInstanceConfig

+ Loki []LokiInstanceConfig

+ Metrics MetricsConfig

+ Prometheus []PrometheusInstanceConfig

+ RateLimiting RateLimitConfig

+ S3 *S3Config

+ Server HTTPServerConfig

+ func LoadServerConfig(path string) (*ServerConfig, error)

+ func (c *ServerConfig) ApplyDefaults()

+ func (c *ServerConfig) ToHandlerConfigs() ([]handlers.ClickHouseConfig, []handlers.PrometheusConfig, ...)

+ func (c *ServerConfig) Validate() error

+ type Service interface

+ ClickHouseDatasourceInfo func() []types.DatasourceInfo

+ ClickHouseDatasources func() []string

+ EthNodeAvailable func() bool

+ LokiDatasourceInfo func() []types.DatasourceInfo

+ LokiDatasources func() []string

+ PrometheusDatasourceInfo func() []types.DatasourceInfo

+ PrometheusDatasources func() []string

+ RegisterToken func(executionID string) string

+ RevokeToken func(executionID string)

+ S3Bucket func() string

+ S3PublicURLPrefix func() string

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ URL func() string