reverseproxy

package module

Go to main page

Versions in this module

v1

v1.1.2

Sep 6, 2025

v1.1.1

Sep 6, 2025

Changes in this version

+ const EventTypeBackendAdded

+ const EventTypeBackendHealthy

+ const EventTypeBackendRemoved

+ const EventTypeBackendUnhealthy

+ const EventTypeCircuitBreakerClosed

+ const EventTypeCircuitBreakerHalfOpen

+ const EventTypeCircuitBreakerOpen

+ const EventTypeConfigLoaded

+ const EventTypeConfigValidated

+ const EventTypeError

+ const EventTypeLoadBalanceDecision

+ const EventTypeLoadBalanceRoundRobin

+ const EventTypeModuleStarted

+ const EventTypeModuleStopped

+ const EventTypeProxyCreated

+ const EventTypeProxyStarted

+ const EventTypeProxyStopped

+ const EventTypeRequestFailed

+ const EventTypeRequestProxied

+ const EventTypeRequestReceived

+ var ErrBackendAlreadyExists = errors.New("backend already exists")

+ var ErrBackendIDOrURLRequired = errors.New("backend id and service URL required")

+ var ErrBackendIDRequired = errors.New("backend id required")

+ var ErrEvaluatorFatal = errors.New("evaluator-fatal")

+ var ErrNoBackendsConfigured = errors.New("no backends configured")

+ var ErrNoDecision = errors.New("no-decision")

+ var ErrNoEvaluatorDecision = errors.New("no evaluator provided decision")

+ var ErrNoEvaluatorsAvailable = errors.New("no feature flag evaluators available")

+ var ErrNoSubjectForEventEmission = errors.New("no subject available for event emission")

+ var ErrUnexpectedConfigType = errors.New("unexpected config type")

type CircuitBreakerInfo

+ Failures int

+ type FeatureFlagAggregator struct

+ func NewFeatureFlagAggregator(app modular.Application, logger *slog.Logger) *FeatureFlagAggregator

+ func (a *FeatureFlagAggregator) EvaluateFlag(ctx context.Context, flagID string, tenantID modular.TenantID, ...) (bool, error)

+ func (a *FeatureFlagAggregator) EvaluateFlagWithDefault(ctx context.Context, flagID string, tenantID modular.TenantID, ...) bool

type HealthChecker

+ func (hc *HealthChecker) SetEventEmitter(emitter HealthEventEmitter)

+ func (hc *HealthChecker) UpdateHealthConfig(ctx context.Context, cfg *HealthCheckConfig)

+ type HealthEventEmitter func(eventType string, data map[string]interface{})

type ReverseProxyModule

+ func (m *ReverseProxyModule) AddBackend(backendID, serviceURL string) error

+ func (m *ReverseProxyModule) EmitEvent(ctx context.Context, event cloudevents.Event) error

+ func (m *ReverseProxyModule) GetRegisteredEventTypes() []string

+ func (m *ReverseProxyModule) RegisterObservers(subject modular.Subject) error

+ func (m *ReverseProxyModule) RemoveBackend(backendID string) error

+ type WeightedEvaluator interface

+ Weight func() int

v1.1.0

Aug 3, 2025

Changes in this version

+ var ErrApplicationNil = errors.New("app cannot be nil")

+ var ErrBackendNotFound = errors.New("backend not found")

+ var ErrBackendProxyNil = errors.New("backend proxy is nil")

+ var ErrBackendServiceNotFound = errors.New("backend service not found")

+ var ErrCannotRegisterRoutes = errors.New("cannot register routes: router is nil")

+ var ErrConfigurationNil = errors.New("configuration is nil")

+ var ErrDefaultBackendNotDefined = errors.New("default backend is not defined in backend_services")

+ var ErrDryRunModeNotEnabled = errors.New("dry-run mode is not enabled")

+ var ErrFeatureFlagNotFound = errors.New("feature flag not found")

+ var ErrLoggerNil = errors.New("logger cannot be nil")

+ var ErrNoHostname = errors.New("no hostname in URL")

+ var ErrServiceNotHandleFunc = errors.New("service does not implement HandleFunc interface")

+ var ErrTenantIDRequired = errors.New("tenant ID is required but TenantIDHeader is not set")

+ var ErrUnexpectedStatusCode = errors.New("unexpected status code")

+ type BackendHealthConfig struct

+ Enabled bool

+ Endpoint string

+ ExpectedStatusCodes []int

+ Interval time.Duration

+ Timeout time.Duration

+ type BackendServiceConfig struct

+ AlternativeBackend string

+ Endpoints map[string]EndpointConfig

+ FeatureFlagID string

+ HeaderRewriting HeaderRewritingConfig

+ PathRewriting PathRewritingConfig

+ URL string

type CircuitBreaker

+ func (cb *CircuitBreaker) GetFailureCount() int

+ type CircuitBreakerInfo struct

+ FailureCount int

+ LastAttempt time.Time

+ LastFailure time.Time

+ State string

+ SuccessCount int

+ type CircuitBreakerProvider func(backendID string) *HealthCircuitBreakerInfo

+ type ComparisonResult struct

+ BodyMatch bool

+ Differences []string

+ HeaderDiffs map[string]HeaderDiff

+ HeadersMatch bool

+ StatusCodeMatch bool

type CompositeRoute

+ AlternativeBackend string

+ FeatureFlagID string

+ type DebugEndpointsConfig struct

+ AuthToken string

+ BasePath string

+ Enabled bool

+ RequireAuth bool

+ type DebugHandler struct

+ func NewDebugHandler(config DebugEndpointsConfig, featureFlagEval FeatureFlagEvaluator, ...) *DebugHandler

+ func (d *DebugHandler) HandleBackends(w http.ResponseWriter, r *http.Request)

+ func (d *DebugHandler) HandleCircuitBreakers(w http.ResponseWriter, r *http.Request)

+ func (d *DebugHandler) HandleFlags(w http.ResponseWriter, r *http.Request)

+ func (d *DebugHandler) HandleHealthChecks(w http.ResponseWriter, r *http.Request)

+ func (d *DebugHandler) HandleInfo(w http.ResponseWriter, r *http.Request)

+ func (d *DebugHandler) RegisterRoutes(mux *http.ServeMux)

+ func (d *DebugHandler) SetCircuitBreakers(circuitBreakers map[string]*CircuitBreaker)

+ func (d *DebugHandler) SetHealthCheckers(healthCheckers map[string]*HealthChecker)

+ type DebugInfo struct

+ BackendServices map[string]string

+ CircuitBreakers map[string]CircuitBreakerInfo

+ Environment string

+ Flags map[string]interface{}

+ HealthChecks map[string]HealthInfo

+ Routes map[string]string

+ Tenant string

+ Timestamp time.Time

+ type DryRunConfig struct

+ CompareHeaders []string

+ DefaultResponseBackend string

+ Enabled bool

+ IgnoreHeaders []string

+ LogResponses bool

+ MaxResponseSize int64

+ type DryRunHandler struct

+ func NewDryRunHandler(config DryRunConfig, tenantIDHeader string, logger modular.Logger) *DryRunHandler

+ func (d *DryRunHandler) ProcessDryRun(ctx context.Context, req *http.Request, ...) (*DryRunResult, error)

+ type DryRunResult struct

+ Comparison ComparisonResult

+ Duration DurationInfo

+ Endpoint string

+ Method string

+ PrimaryBackend string

+ PrimaryResponse ResponseInfo

+ RequestID string

+ ReturnedResponse string

+ SecondaryBackend string

+ SecondaryResponse ResponseInfo

+ TenantID string

+ Timestamp time.Time

+ func (d *DryRunResult) GetReturnedResponse() ResponseInfo

+ type DurationInfo struct

+ Primary time.Duration

+ Secondary time.Duration

+ Total time.Duration

+ type EndpointConfig struct

+ AlternativeBackend string

+ FeatureFlagID string

+ HeaderRewriting HeaderRewritingConfig

+ PathRewriting PathRewritingConfig

+ Pattern string

+ type EndpointRewriteRule struct

+ Backend string

+ Pattern string

+ Replacement string

+ StripQueryParams bool

+ type FeatureFlagEvaluator interface

+ EvaluateFlag func(ctx context.Context, flagID string, tenantID modular.TenantID, ...) (bool, error)

+ EvaluateFlagWithDefault func(ctx context.Context, flagID string, tenantID modular.TenantID, ...) bool

+ type FeatureFlagsConfig struct

+ Enabled bool

+ Flags map[string]bool

+ type FileBasedFeatureFlagEvaluator struct

+ func NewFileBasedFeatureFlagEvaluator(app modular.Application, logger *slog.Logger) (*FileBasedFeatureFlagEvaluator, error)

+ func (f *FileBasedFeatureFlagEvaluator) EvaluateFlag(ctx context.Context, flagID string, tenantID modular.TenantID, ...) (bool, error)

+ func (f *FileBasedFeatureFlagEvaluator) EvaluateFlagWithDefault(ctx context.Context, flagID string, tenantID modular.TenantID, ...) bool

+ type HeaderDiff struct

+ Primary string

+ Secondary string

+ type HeaderRewritingConfig struct

+ CustomHostname string

+ HostnameHandling HostnameHandlingMode

+ RemoveHeaders []string

+ SetHeaders map[string]string

+ type HealthCheckConfig struct

+ BackendHealthCheckConfig map[string]BackendHealthConfig

+ Enabled bool

+ ExpectedStatusCodes []int

+ HealthEndpoints map[string]string

+ Interval time.Duration

+ RecentRequestThreshold time.Duration

+ Timeout time.Duration

+ type HealthChecker struct

+ func NewHealthChecker(config *HealthCheckConfig, backends map[string]string, httpClient *http.Client, ...) *HealthChecker

+ func (hc *HealthChecker) GetBackendHealthStatus(backendID string) (*HealthStatus, bool)

+ func (hc *HealthChecker) GetHealthStatus() map[string]*HealthStatus

+ func (hc *HealthChecker) GetOverallHealthStatus(includeDetails bool) *OverallHealthStatus

+ func (hc *HealthChecker) IsRunning() bool

+ func (hc *HealthChecker) RecordBackendRequest(backendID string)

+ func (hc *HealthChecker) SetCircuitBreakerProvider(provider CircuitBreakerProvider)

+ func (hc *HealthChecker) Start(ctx context.Context) error

+ func (hc *HealthChecker) Stop(ctx context.Context)

+ func (hc *HealthChecker) UpdateBackends(ctx context.Context, backends map[string]string)

+ type HealthCircuitBreakerInfo struct

+ FailureCount int

+ IsOpen bool

+ State string

+ type HealthInfo struct

+ LastCheck time.Time

+ ResponseTime string

+ Status string

+ StatusCode int

+ type HealthStatus struct

+ BackendID string

+ ChecksSkipped int64

+ CircuitBreakerOpen bool

+ CircuitBreakerState string

+ CircuitFailureCount int

+ DNSResolved bool

+ HealthCheckPassing bool

+ Healthy bool

+ LastCheck time.Time

+ LastError string

+ LastRequest time.Time

+ LastSuccess time.Time

+ ResolvedIPs []string

+ ResponseTime time.Duration

+ SuccessfulChecks int64

+ TotalChecks int64

+ URL string

+ type HostnameHandlingMode string

+ const HostnamePreserveOriginal

+ const HostnameUseBackend

+ const HostnameUseCustom

+ type OverallHealthStatus struct

+ BackendDetails map[string]*HealthStatus

+ CircuitOpenCount int

+ Healthy bool

+ HealthyBackends int

+ LastCheck time.Time

+ TotalBackends int

+ UnhealthyBackends int

+ type PathRewritingConfig struct

+ BasePathRewrite string

+ EndpointRewrites map[string]EndpointRewriteRule

+ StripBasePath string

+ type ResponseInfo struct

+ Body string

+ BodySize int64

+ Error string

+ Headers map[string]string

+ ResponseTime time.Duration

+ StatusCode int

type ReverseProxyConfig

+ BackendConfigs map[string]BackendServiceConfig

+ DebugEndpoints DebugEndpointsConfig

+ DryRun DryRunConfig

+ FeatureFlags FeatureFlagsConfig

+ HealthCheck HealthCheckConfig

+ RouteConfigs map[string]RouteConfig

type ReverseProxyModule

+ func (m *ReverseProxyModule) GetBackendHealthStatus(backendID string) (*HealthStatus, bool)

+ func (m *ReverseProxyModule) GetHealthStatus() map[string]*HealthStatus

+ func (m *ReverseProxyModule) GetOverallHealthStatus(includeDetails bool) *OverallHealthStatus

+ func (m *ReverseProxyModule) IsHealthCheckEnabled() bool

+ type RouteConfig struct

+ AlternativeBackend string

+ DryRun bool

+ DryRunBackend string

+ FeatureFlagID string

v1.0.11

Jun 28, 2025

v1.0.10

Jun 27, 2025

v1.0.9

Jun 27, 2025

v1.0.8

Jun 11, 2025

v1.0.7

Jun 6, 2025

v1.0.6

Jun 5, 2025

Changes in this version

+ var ErrCircuitOpen = errors.New("circuit breaker is open")

+ var ErrMaxRetriesReached = errors.New("maximum number of retries reached")

+ var ErrNoAvailableBackend = errors.New("no available backend")

+ var ErrRequestTimeout = errors.New("request timed out")

+ func RetryWithPolicy(ctx context.Context, policy RetryPolicy, fn RetryFunc, ...) (interface{}, int, error)

+ type BackendConfig struct

+ CircuitBreaker *CircuitBreakerConfig

+ IdleConnTimeout time.Duration

+ MaxConnsPerHost int

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ Retry *RetryConfig

+ TLSSkipVerify bool

+ Timeout time.Duration

+ URL string

type CircuitBreaker

+ func NewCircuitBreakerWithConfig(backendName string, config CircuitBreakerConfig, ...) *CircuitBreaker

+ func (cb *CircuitBreaker) Execute(req *http.Request, fn func(*http.Request) (*http.Response, error)) (*http.Response, error)

+ func (cb *CircuitBreaker) WithFailureThreshold(threshold int) *CircuitBreaker

+ func (cb *CircuitBreaker) WithMetricsCollector(collector *MetricsCollector) *CircuitBreaker

+ func (cb *CircuitBreaker) WithRequestTimeout(timeout time.Duration) *CircuitBreaker

+ func (cb *CircuitBreaker) WithResetTimeout(timeout time.Duration) *CircuitBreaker

type CircuitBreakerConfig

+ HalfOpenAllowedRequests int

+ OpenTimeout time.Duration

+ SuccessRateThreshold float64

+ SuccessThreshold int

+ WindowSize int

type CircuitState

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ func (s CircuitState) String() string

+ type Config struct

+ Backends map[string]BackendConfig

+ CircuitBreaker CircuitBreakerConfig

+ ExactMapping map[string]string

+ MetricsEnabled bool

+ MetricsPath string

+ PrefixMapping map[string]string

+ Retry RetryConfig

+ type MetricsCollector struct

+ func NewMetricsCollector() *MetricsCollector

+ func (m *MetricsCollector) GetMetrics() map[string]interface{}

+ func (m *MetricsCollector) MetricsHandler() http.HandlerFunc

+ func (m *MetricsCollector) RecordRequest(backend string, start time.Time, statusCode int, err error, ...)

+ func (m *MetricsCollector) SetCircuitBreakerStateString(backend string, state string)

+ func (m *MetricsCollector) SetCircuitBreakerStatus(backend string, isOpen bool)

+ type RetryConfig struct

+ BaseDelay time.Duration

+ Enabled bool

+ Jitter float64

+ MaxDelay time.Duration

+ MaxRetries int

+ RetryableStatusCodes []int

+ Timeout time.Duration

+ type RetryFunc func(ctx context.Context) (interface{}, int, error)

+ type RetryPolicy struct

+ BaseDelay time.Duration

+ Jitter float64

+ MaxDelay time.Duration

+ MaxRetries int

+ RetryableStatusCodes map[int]bool

+ Timeout time.Duration

+ func DefaultRetryPolicy() RetryPolicy

+ func (p RetryPolicy) CalculateBackoff(attempt int) time.Duration

+ func (p RetryPolicy) ShouldRetry(statusCode int) bool

+ func (p RetryPolicy) WithBaseDelay(baseDelay time.Duration) RetryPolicy

+ func (p RetryPolicy) WithJitter(jitter float64) RetryPolicy

+ func (p RetryPolicy) WithMaxDelay(maxDelay time.Duration) RetryPolicy

+ func (p RetryPolicy) WithMaxRetries(maxRetries int) RetryPolicy

+ func (p RetryPolicy) WithRetryableStatusCodes(codes ...int) RetryPolicy

+ func (p RetryPolicy) WithTimeout(timeout time.Duration) RetryPolicy

type ReverseProxyConfig

+ MetricsEnabled bool

+ MetricsEndpoint string

+ MetricsPath string

+ RequestTimeout time.Duration

v1.0.5

May 26, 2025

v1.0.4

May 2, 2025

v1.0.3

May 1, 2025

Changes in this version

+ type HandleFuncService interface

+ HandleFunc func(pattern string, handler func(http.ResponseWriter, *http.Request))

v1.0.2

May 1, 2025

v1.0.1

Apr 26, 2025

Changes in this version

+ func ProvideConfig() interface

+ func TenantIDFromRequest(tenantIDHeader string, req *http.Request) (string, bool)

+ type Backend struct

+ Client *http.Client

+ ID string

+ URL string

+ type BackendEndpointRequest struct

+ Backend string

+ Headers map[string]string

+ Method string

+ Path string

+ QueryParams map[string]string

+ type CachedResponse struct

+ Body []byte

+ ExpirationTime time.Time

+ Headers http.Header

+ LastAccessed time.Time

+ StatusCode int

+ type CircuitBreaker struct

+ func NewCircuitBreaker(failureThreshold int, resetTimeout time.Duration) *CircuitBreaker

+ func (cb *CircuitBreaker) GetState() CircuitState

+ func (cb *CircuitBreaker) IsOpen() bool

+ func (cb *CircuitBreaker) RecordFailure()

+ func (cb *CircuitBreaker) RecordSuccess()

+ func (cb *CircuitBreaker) Reset()

+ type CircuitBreakerConfig struct

+ Enabled bool

+ FailureThreshold int

+ ResetTimeoutSeconds int

+ type CircuitState int

+ const CircuitClosed

+ const CircuitHalfOpen

+ const CircuitOpen

+ type CompositeHandler struct

+ func NewCompositeHandler(backends []*Backend, parallel bool, responseTimeout time.Duration) *CompositeHandler

+ func (h *CompositeHandler) ConfigureCircuitBreakers(globalConfig CircuitBreakerConfig, ...)

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

+ func (h *CompositeHandler) SetResponseCache(cache *responseCache)

+ type CompositeResponse struct

+ Body []byte

+ Headers http.Header

+ StatusCode int

+ type CompositeRoute struct

+ Backends []string

+ Pattern string

+ Strategy string

+ type EndpointMapping struct

+ Endpoints []BackendEndpointRequest

+ ResponseTransformer func(ctx context.Context, req *http.Request, responses map[string]*http.Response) (*CompositeResponse, error)

+ type PathMatcher struct

+ func NewPathMatcher() *PathMatcher

+ func (pm *PathMatcher) AddRoutePattern(backendID, pattern string)

+ func (pm *PathMatcher) MatchBackend(path string) string

+ type ReverseProxyConfig struct

+ BackendCircuitBreakers map[string]CircuitBreakerConfig

+ BackendServices map[string]string

+ CacheEnabled bool

+ CacheTTL int

+ CircuitBreakerConfig CircuitBreakerConfig

+ CompositeRoutes map[string]CompositeRoute

+ DefaultBackend string

+ RequireTenantID bool

+ Routes map[string]string

+ TenantIDHeader string

+ func (c *ReverseProxyConfig) Validate() error

+ type ReverseProxyModule struct

+ func NewModule() (*ReverseProxyModule, error)

+ func (m *ReverseProxyModule) AddBackendRoute(backendID, pattern string)

+ func (m *ReverseProxyModule) AddCompositeRoute(pattern string, backends []string, strategy string)

+ func (m *ReverseProxyModule) Constructor() modular.ModuleConstructor

+ func (m *ReverseProxyModule) GetConfig() *ReverseProxyConfig

+ func (m *ReverseProxyModule) Init(app modular.Application) error

+ func (m *ReverseProxyModule) Name() string

+ func (m *ReverseProxyModule) OnTenantRegistered(tenantID modular.TenantID)

+ func (m *ReverseProxyModule) OnTenantRemoved(tenantID modular.TenantID)

+ func (m *ReverseProxyModule) ProvidesServices() []modular.ServiceProvider

+ func (m *ReverseProxyModule) RegisterConfig(app modular.Application) error

+ func (m *ReverseProxyModule) RegisterCustomEndpoint(pattern string, mapping EndpointMapping)

+ func (m *ReverseProxyModule) RequiresServices() []modular.ServiceDependency

+ func (m *ReverseProxyModule) SetHttpClient(client *http.Client)

+ func (m *ReverseProxyModule) Start(context.Context) error

+ func (m *ReverseProxyModule) Stop(context.Context) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL