gateway

package

Go to main page

Versions in this module

v1

v1.0.25

Apr 7, 2026

v1.0.24

Apr 7, 2026

v1.0.23

Apr 7, 2026

v1.0.22

Apr 4, 2026

v1.0.21

Apr 2, 2026

v1.0.20

Apr 2, 2026

v1.0.19

Apr 2, 2026

Changes in this version

+ type EndpointPolicyConfig struct

+ RequireDomain bool

+ RequireHTTPS bool

type ServiceConfig

+ BlockedSuppliers []string

v1.0.18

Mar 30, 2026

v1.0.17

Mar 29, 2026

v1.0.16

Mar 25, 2026

v1.0.15

Mar 12, 2026

Changes in this version

+ const DefaultEndpointsPerServiceEstimate

+ const DefaultMinHealthCheckWorkers

+ const DefaultRelayRequestTimeout

+ const HealthCheckWorkerMultiplier

+ type ArchivalRequirementChecker interface

+ RequiresArchival func() bool

+ type DomainCircuitBreaker struct

+ func NewDomainCircuitBreaker(redisClient *redis.Client, logger polylog.Logger) *DomainCircuitBreaker

+ func (cb *DomainCircuitBreaker) ClearService(ctx context.Context, serviceID string) int

+ func (cb *DomainCircuitBreaker) GetBrokenDomains(ctx context.Context, serviceID string) map[string]bool

+ func (cb *DomainCircuitBreaker) MarkBroken(ctx context.Context, serviceID, domain, reason string)

+ type ExternalBlockHeightFetcher struct

+ func NewExternalBlockHeightFetcher(logger polylog.Logger, configs []ExternalBlockSourceConfig) *ExternalBlockHeightFetcher

+ func (f *ExternalBlockHeightFetcher) Start(ctx context.Context) <-chan int64

+ type ExternalBlockSource struct

+ GracePeriod time.Duration

+ Interval time.Duration

+ Method string

+ Path string

+ Timeout time.Duration

+ Type string

+ URL string

+ type ExternalBlockSourceConfig struct

+ Interval time.Duration

+ Method string

+ Path string

+ Timeout time.Duration

+ Type string

+ URL string

type Gateway

+ DomainCircuitBreaker *DomainCircuitBreaker

type HealthCheckConfig

+ SyncCheck bool

type HealthCheckQoSContext

+ func (hc *HealthCheckQoSContext) SetProtocolError(err error)

type ParentConfigDefaults

+ ConnectTimeout *time.Duration

+ HedgeDelay *time.Duration

+ LocalHealthChecks []ServiceHealthCheckConfig

type Protocol

+ SetQoSServiceRegistry func(registry QoSServiceRegistry)

+ type QoSArchivalReporter interface

+ GetEndpointArchivalStatus func(endpointAddr protocol.EndpointAddr) (isArchival bool, expiresAt time.Time)

+ type QoSBlockConsensusReporter interface

+ GetBlockConsensusStats func() (medianBlock uint64, observationCount int)

+ type QoSServiceRegistry interface

+ GetQoSServiceForServiceID func(serviceID protocol.ServiceID) QoSService

type QueuedObservation

+ IsArchivalCheck bool

type RequestQoSContext

+ SetProtocolError func(err error)

type RetryConfig

+ ConnectTimeout *time.Duration

+ HedgeDelay *time.Duration

type ServiceConfig

+ ExternalBlockSources []ExternalBlockSource

+ TimeoutConfig *ServiceTimeoutConfig

type ServiceDefaults

+ ExternalBlockSources []ExternalBlockSource

+ TimeoutConfig ServiceTimeoutConfig

type ServiceRetryConfig

+ ConnectTimeout *time.Duration

+ HedgeDelay *time.Duration

+ type ServiceTimeoutConfig struct

+ RelayTimeout *time.Duration

type UnifiedServicesConfig

+ func (c *UnifiedServicesConfig) GetRelayTimeoutForService(serviceID protocol.ServiceID) time.Duration

+ func (c *UnifiedServicesConfig) SetServiceSyncAllowance(serviceID protocol.ServiceID, syncAllowance int)

v1.0.14

Jan 22, 2026

v1.0.13

Jan 22, 2026

v1.0.12

Jan 21, 2026

Changes in this version

+ const DefaultExternalReferenceCacheDuration

+ const DefaultExternalReferenceTimeout

+ type BlockHeightOperator string

+ const BlockHeightOperatorEqual

+ const BlockHeightOperatorGreaterThan

+ const BlockHeightOperatorGreaterThanOrEqual

+ const BlockHeightOperatorLessThan

+ const BlockHeightOperatorLessThanOrEqual

+ type BlockHeightReference struct

+ CacheDuration time.Duration

+ Endpoint string

+ Headers map[string]string

+ Method string

+ Timeout time.Duration

+ Tolerance int64

+ Type BlockHeightReferenceType

+ Value int64

+ func (bhr *BlockHeightReference) HydrateDefaults()

+ func (bhr *BlockHeightReference) Validate(checkName string) error

+ type BlockHeightReferenceType string

+ const BlockHeightReferenceTypeExternal

+ const BlockHeightReferenceTypePerceived

+ const BlockHeightReferenceTypeStatic

+ type BlockHeightValidation struct

+ Operator BlockHeightOperator

+ Reference BlockHeightReference

+ func (bhv *BlockHeightValidation) Validate(checkName string) error

+ type BlockHeightValidator struct

+ func NewBlockHeightValidator(logger polylog.Logger, externalCache *ExternalReferenceCache) *BlockHeightValidator

+ func (v *BlockHeightValidator) SetQoSInstances(instances map[protocol.ServiceID]QoSService)

+ func (v *BlockHeightValidator) ValidateBlockHeight(ctx context.Context, serviceID protocol.ServiceID, responseBody []byte, ...) error

+ type ErrorDetection struct

+ JSONRPCErrorCodes []JSONRPCErrorCode

+ ResponsePatterns []ErrorPattern

+ StatusCodes []ErrorStatusCode

+ func (ed *ErrorDetection) Validate(checkName string) error

+ type ErrorPattern struct

+ Pattern string

+ ReputationSignal string

+ type ErrorStatusCode struct

+ Code int

+ ReputationSignal string

+ type ExternalReferenceCache struct

+ func NewExternalReferenceCache(logger polylog.Logger) *ExternalReferenceCache

+ func (c *ExternalReferenceCache) ClearCache()

+ func (c *ExternalReferenceCache) GetBlockHeight(ctx context.Context, endpoint string, method string, headers map[string]string, ...) (int64, error)

type HealthCheckConfig

+ BlockHeightValidation *BlockHeightValidation

+ ErrorDetection *ErrorDetection

type HealthCheckExecutor

+ func (e *HealthCheckExecutor) SetQoSInstances(instances map[protocol.ServiceID]QoSService)

+ type JSONRPCErrorCode struct

+ Code int

+ ReputationSignal string

type QoSService

+ GetPerceivedBlockNumber func() uint64

v1.0.11

Jan 21, 2026

v1.0.10

Jan 13, 2026

Changes in this version

+ const DefaultExpectedStatusCode

+ const DefaultExternalConfigTimeout

+ const DefaultHealthCheckInterval

+ const DefaultHealthCheckTimeout

+ const DefaultLeaderKey

+ const DefaultLeaderLeaseDuration

+ const DefaultLeaderRenewInterval

+ const DefaultObservationPipelineQueueSize

+ const DefaultObservationPipelineSampleRate

+ const DefaultObservationPipelineWorkerCount

+ const DefaultObservationQueueSize

+ const DefaultObservationSampleRate

+ const DefaultObservationWorkerCount

+ const DefaultReputationSignal

+ const DefaultSyncAllowance

+ const JSONRPCInvalidRequest

+ const RPCTypeHeader

+ const RPCTypeStringCometBFT

+ const RPCTypeStringGRPC

+ const RPCTypeStringJSONRPC

+ const RPCTypeStringREST

+ const RPCTypeStringWebSocket

+ var ErrRPCTypeDetectionFailed = fmt.Errorf("RPC type detection failed")

+ var ErrServiceNotConfigured = fmt.Errorf("service not configured")

+ var ErrUnsupportedRPCType = fmt.Errorf("unsupported RPC type for service")

+ func GetAllValidRPCTypeStrings() []string

+ func GetHTTPBasedRPCTypeStrings() []string

+ func IsBuiltInLatencyProfile(name string) bool

+ func IsHTTPBasedRPCType(rpcTypeStr string) bool

+ func NewRPCTypeValidationErrorResponse(serviceID protocol.ServiceID, detectedType string, allowedRPCTypes []string, ...) *rpcTypeValidationErrorResponse

+ func NewServiceNotConfiguredErrorResponse(serviceID protocol.ServiceID, availableServices []protocol.ServiceID, ...) *rpcTypeValidationErrorResponse

+ func ValidateServiceType(t ServiceType) error

+ type ActiveHealthChecksConfig struct

+ Coordination LeaderElectionConfig

+ Enabled bool

+ External *ExternalConfigSource

+ Local []ServiceHealthCheckConfig

+ MaxWorkers int

+ SyncAllowance int

+ func (hc *ActiveHealthChecksConfig) HydrateDefaults(hasRedis bool)

+ func (hc *ActiveHealthChecksConfig) Validate() error

+ func (hc *ActiveHealthChecksConfig) ValidateUniqueness() error

+ type ConcurrencyConfig struct

+ MaxBatchPayloads int

+ MaxConcurrentRelays int

+ MaxParallelEndpoints int

+ func (cc *ConcurrencyConfig) Validate(logger polylog.Logger) error

+ type DefaultObservationHandler struct

+ func NewDefaultObservationHandler(logger polylog.Logger) *DefaultObservationHandler

+ func (h *DefaultObservationHandler) HandleExtractedData(obs *QueuedObservation, data *qostypes.ExtractedData) error

+ func (h *DefaultObservationHandler) SetQoSInstances(instances map[protocol.ServiceID]QoSService)

+ type EndpointInfo struct

+ Addr protocol.EndpointAddr

+ HTTPURL string

+ SessionID string

+ WebSocketURL string

+ type ExternalConfigSource struct

+ RefreshInterval time.Duration

+ Timeout time.Duration

+ URL string

+ func (ecs *ExternalConfigSource) HydrateDefaults()

+ func (ecs *ExternalConfigSource) Validate() error

type Gateway

+ ObservationQueue *ObservationQueue

+ RPCTypeValidator *RPCTypeValidator

+ type HealthCheckConfig struct

+ Archival bool

+ Body string

+ Enabled *bool

+ ExpectedResponseContains string

+ ExpectedStatusCode int

+ Headers map[string]string

+ Method string

+ Name string

+ Path string

+ ReputationSignal string

+ Timeout time.Duration

+ Type HealthCheckType

+ func (hcc *HealthCheckConfig) HydrateDefaults()

+ func (hcc *HealthCheckConfig) Validate() error

+ type HealthCheckExecutor struct

+ func NewHealthCheckExecutor(cfg HealthCheckExecutorConfig) *HealthCheckExecutor

+ func (e *HealthCheckExecutor) ExecuteCheckViaProtocol(ctx context.Context, serviceID protocol.ServiceID, ...) (time.Duration, error)

+ func (e *HealthCheckExecutor) ExecuteWebSocketCheckViaProtocol(ctx context.Context, serviceID protocol.ServiceID, ...) (time.Duration, error)

+ func (e *HealthCheckExecutor) GetConfigForService(serviceID protocol.ServiceID) *ServiceHealthCheckConfig

+ func (e *HealthCheckExecutor) GetServiceConfigs() []ServiceHealthCheckConfig

+ func (e *HealthCheckExecutor) InitExternalConfig(ctx context.Context)

+ func (e *HealthCheckExecutor) IsEnabled() bool

+ func (e *HealthCheckExecutor) RunAllChecksViaProtocol(ctx context.Context, ...) error

+ func (e *HealthCheckExecutor) RunChecksForEndpointViaProtocol(ctx context.Context, serviceID protocol.ServiceID, ...) map[string]error

+ func (e *HealthCheckExecutor) ShouldRunChecks() bool

+ func (e *HealthCheckExecutor) Stop()

+ type HealthCheckExecutorConfig struct

+ Config *ActiveHealthChecksConfig

+ LeaderElector *LeaderElector

+ Logger polylog.Logger

+ MaxWorkers int

+ MetricsReporter RequestResponseReporter

+ ObservationQueue *ObservationQueue

+ Protocol Protocol

+ ReputationSvc reputation.ReputationService

+ UnifiedServicesConfig *UnifiedServicesConfig

+ type HealthCheckQoSContext struct

+ func NewHealthCheckQoSContext(cfg HealthCheckQoSContextConfig) *HealthCheckQoSContext

+ func (hc *HealthCheckQoSContext) GetEndpointSelector() protocol.EndpointSelector

+ func (hc *HealthCheckQoSContext) GetError() string

+ func (hc *HealthCheckQoSContext) GetHTTPResponse() pathhttp.HTTPResponse

+ func (hc *HealthCheckQoSContext) GetObservations() qosobservations.Observations

+ func (hc *HealthCheckQoSContext) GetServicePayloads() []protocol.Payload

+ func (hc *HealthCheckQoSContext) IsSuccess() bool

+ func (hc *HealthCheckQoSContext) UpdateWithResponse(endpointAddr protocol.EndpointAddr, endpointSerializedResponse []byte, ...)

+ type HealthCheckQoSContextConfig struct

+ CheckConfig HealthCheckConfig

+ Logger polylog.Logger

+ ServiceID protocol.ServiceID

+ ServicePayload protocol.Payload

+ type HealthCheckType string

+ const HealthCheckTypeCometBFT

+ const HealthCheckTypeGRPC

+ const HealthCheckTypeJSONRPC

+ const HealthCheckTypeREST

+ const HealthCheckTypeWebSocket

+ type HealthChecksConfig = ActiveHealthChecksConfig

+ type LatencyProfileConfig struct

+ FastBonus float64

+ FastThreshold time.Duration

+ NormalThreshold time.Duration

+ PenaltyThreshold time.Duration

+ SevereThreshold time.Duration

+ SlowPenalty float64

+ SlowThreshold time.Duration

+ VerySlowPenalty float64

+ type LeaderElectionConfig struct

+ Key string

+ LeaseDuration time.Duration

+ RenewInterval time.Duration

+ Type string

+ func (lec *LeaderElectionConfig) HydrateDefaults()

+ type LeaderElector struct

+ func NewLeaderElector(cfg LeaderElectorConfig) *LeaderElector

+ func (l *LeaderElector) GetLeaderInstanceID(ctx context.Context) string

+ func (l *LeaderElector) IsLeader() bool

+ func (l *LeaderElector) Start(ctx context.Context) error

+ func (l *LeaderElector) Stop() error

+ type LeaderElectorConfig struct

+ Client *redis.Client

+ Config LeaderElectionConfig

+ Logger polylog.Logger

+ type ObservationHandler interface

+ HandleExtractedData func(obs *QueuedObservation, data *qostypes.ExtractedData) error

+ type ObservationPipelineConfig struct

+ Enabled bool

+ QueueSize int

+ SampleRate float64

+ WorkerCount int

+ func (pc *ObservationPipelineConfig) HydrateDefaults()

+ func (pc *ObservationPipelineConfig) Validate() error

+ type ObservationQueue struct

+ func NewObservationQueue(config ObservationQueueConfig, logger polylog.Logger) *ObservationQueue

+ func (q *ObservationQueue) GetMetrics() (queued, processed, dropped, skipped int64)

+ func (q *ObservationQueue) GetSampleRate() float64

+ func (q *ObservationQueue) IsEnabled() bool

+ func (q *ObservationQueue) ProcessSync(obs *QueuedObservation)

+ func (q *ObservationQueue) SetHandler(handler ObservationHandler)

+ func (q *ObservationQueue) SetPerServiceRate(serviceID protocol.ServiceID, rate float64)

+ func (q *ObservationQueue) SetRegistry(registry *qostypes.ExtractorRegistry)

+ func (q *ObservationQueue) Stop()

+ func (q *ObservationQueue) Submit(obs *QueuedObservation) bool

+ func (q *ObservationQueue) TryQueue(obs *QueuedObservation) bool

+ type ObservationQueueConfig struct

+ Enabled bool

+ QueueSize int

+ SampleRate float64

+ WorkerCount int

+ func (c *ObservationQueueConfig) HydrateDefaults()

+ type ObservationSource string

+ const SourceHealthCheck

+ const SourceUserRequest

+ type ParentConfigDefaults struct

+ HealthCheckInterval time.Duration

+ HealthChecksEnabled bool

+ MaxRetries int

+ MaxRetryLatency time.Duration

+ ObservationPipelineEnabled bool

+ ProbationEnabled bool

+ ProbationRecoveryMultiplier float64

+ ProbationThreshold float64

+ ProbationTrafficPercent float64

+ RetryEnabled bool

+ RetryOn5xx bool

+ RetryOnConnection bool

+ RetryOnTimeout bool

+ SampleRate float64

+ SyncAllowance int

+ Tier1Threshold float64

+ Tier2Threshold float64

+ TieredSelectionEnabled bool

+ type PassthroughConfig = ObservationPipelineConfig

type Protocol

+ GetConcurrencyConfig func() ConcurrencyConfig

+ GetEndpointsForHealthCheck func() func(protocol.ServiceID) ([]EndpointInfo, error)

+ GetReputationService func() reputation.ReputationService

+ GetUnifiedServicesConfig func() *UnifiedServicesConfig

+ IsSessionActive func(ctx context.Context, serviceID protocol.ServiceID, sessionID string) bool

+ IsSupplierBlacklisted func(serviceID protocol.ServiceID, supplierAddr string) bool

+ UnblacklistSupplier func(serviceID protocol.ServiceID, supplierAddr string) bool

type QoSService

+ UpdateFromExtractedData func(endpointAddr protocol.EndpointAddr, data *qostypes.ExtractedData) error

+ type QueuedObservation struct

+ EndpointAddr protocol.EndpointAddr

+ Latency time.Duration

+ RequestBody []byte

+ RequestHTTPMethod string

+ RequestHeaders map[string]string

+ RequestID string

+ RequestPath string

+ ResponseBody []byte

+ ResponseHeaders map[string]string

+ ResponseStatusCode int

+ ServiceID protocol.ServiceID

+ Source ObservationSource

+ Timestamp time.Time

+ type RPCTypeDetector struct

+ func NewRPCTypeDetector() *RPCTypeDetector

+ func (d *RPCTypeDetector) DetectRPCType(httpReq *http.Request, serviceID string, serviceRPCTypes []string) (sharedtypes.RPCType, error)

+ type RPCTypeMapper struct

+ func NewRPCTypeMapper() *RPCTypeMapper

+ func (m *RPCTypeMapper) FormatRPCType(rpcType sharedtypes.RPCType) string

+ func (m *RPCTypeMapper) ParseRPCType(configStr string) (sharedtypes.RPCType, error)

+ func (m *RPCTypeMapper) ValidateRPCTypeString(str string) error

+ type RPCTypeValidator struct

+ func NewRPCTypeValidator(unifiedConfig *UnifiedServicesConfig, rpcTypeMapper *RPCTypeMapper) *RPCTypeValidator

+ func (v *RPCTypeValidator) ValidateRPCType(serviceID protocol.ServiceID, rpcType sharedtypes.RPCType) error

+ func (v *RPCTypeValidator) ValidateServiceConfigured(serviceID protocol.ServiceID) error

+ type RetryConfig struct

+ Enabled bool

+ MaxRetries int

+ MaxRetryLatency *time.Duration

+ RetryOn5xx bool

+ RetryOnConnection bool

+ RetryOnTimeout bool

+ func (rc *RetryConfig) Validate(logger polylog.Logger) error

+ type ServiceConcurrencyConfig struct

+ MaxBatchPayloads *int

+ MaxParallelEndpoints *int

+ type ServiceConfig struct

+ ConcurrencyConfig *ServiceConcurrencyConfig

+ Fallback *ServiceFallbackConfig

+ HealthChecks *ServiceHealthCheckOverride

+ ID protocol.ServiceID

+ Latency *ServiceLatencyConfig

+ LatencyProfile string

+ ObservationPipeline *ServiceObservationConfig

+ Probation *ServiceProbationConfig

+ RPCTypeFallbacks map[string]string

+ RPCTypes []string

+ ReputationConfig *ServiceReputationConfig

+ RetryConfig *ServiceRetryConfig

+ TieredSelection *ServiceTieredSelectionConfig

+ Type ServiceType

+ type ServiceDefaults struct

+ ActiveHealthChecks ServiceHealthCheckOverride

+ ConcurrencyConfig ServiceConcurrencyConfig

+ Latency ServiceLatencyConfig

+ LatencyProfile string

+ ObservationPipeline ServiceObservationConfig

+ Probation ServiceProbationConfig

+ RPCTypes []string

+ ReputationConfig ServiceReputationConfig

+ RetryConfig ServiceRetryConfig

+ TieredSelection ServiceTieredSelectionConfig

+ Type ServiceType

+ type ServiceFallbackConfig struct

+ Enabled bool

+ Endpoints []map[string]string

+ SendAllTraffic bool

+ type ServiceHealthCheckConfig struct

+ CheckInterval time.Duration

+ Checks []HealthCheckConfig

+ Enabled *bool

+ ServiceID protocol.ServiceID

+ SyncAllowance *int

+ func (shc *ServiceHealthCheckConfig) HydrateDefaults()

+ func (shc *ServiceHealthCheckConfig) Validate() error

+ type ServiceHealthCheckOverride struct

+ Enabled *bool

+ External *ExternalConfigSource

+ Interval time.Duration

+ Local []HealthCheckConfig

+ SyncAllowance *int

+ type ServiceLatencyConfig struct

+ Enabled *bool

+ PenaltyWeight float64

+ TargetMs int

+ type ServiceObservationConfig struct

+ Enabled *bool

+ SampleRate *float64

+ type ServiceProbationConfig struct

+ Enabled *bool

+ RecoveryMultiplier *float64

+ Threshold *float64

+ TrafficPercent *float64

+ type ServiceReputationConfig struct

+ Enabled *bool

+ InitialScore *float64

+ KeyGranularity string

+ MinThreshold *float64

+ RecoveryTimeout *time.Duration

+ type ServiceRetryConfig struct

+ Enabled *bool

+ MaxRetries *int

+ MaxRetryLatency *time.Duration

+ RetryOn5xx *bool

+ RetryOnConnection *bool

+ RetryOnTimeout *bool

+ type ServiceTieredSelectionConfig struct

+ Enabled *bool

+ Tier1Threshold *float64

+ Tier2Threshold *float64

+ type ServiceType string

+ const ServiceTypeCosmos

+ const ServiceTypeEVM

+ const ServiceTypeGeneric

+ const ServiceTypePassthrough

+ const ServiceTypeSolana

+ type UnifiedServicesConfig struct

+ Defaults ServiceDefaults

+ LatencyProfiles map[string]LatencyProfileConfig

+ Services []ServiceConfig

+ func (c *UnifiedServicesConfig) GetConfiguredServiceIDs() []protocol.ServiceID

+ func (c *UnifiedServicesConfig) GetLatencyProfile(name string) *LatencyProfileConfig

+ func (c *UnifiedServicesConfig) GetMergedServiceConfig(serviceID protocol.ServiceID) *ServiceConfig

+ func (c *UnifiedServicesConfig) GetServiceConfig(serviceID protocol.ServiceID) *ServiceConfig

+ func (c *UnifiedServicesConfig) GetServiceRPCTypes(serviceID protocol.ServiceID) []string

+ func (c *UnifiedServicesConfig) GetServiceType(serviceID protocol.ServiceID) ServiceType

+ func (c *UnifiedServicesConfig) GetSyncAllowanceForService(serviceID protocol.ServiceID) uint64

+ func (c *UnifiedServicesConfig) HasService(serviceID protocol.ServiceID) bool

+ func (c *UnifiedServicesConfig) HasServices() bool

+ func (c *UnifiedServicesConfig) HydrateDefaults()

+ func (c *UnifiedServicesConfig) SetDefaultsFromParent(parent ParentConfigDefaults)

+ func (c *UnifiedServicesConfig) Validate() error

v1.0.9

Dec 4, 2025

v1.0.8

Dec 4, 2025

v1.0.7

Dec 4, 2025

v1.0.6

Dec 4, 2025

v1.0.5

Dec 2, 2025

v1.0.4

Nov 29, 2025

Changes in this version

+ const DefaultWebsocketMessageBufferSize

type Gateway

+ WebsocketMessageBufferSize int

v1.0.3

Nov 28, 2025

v1.0.2

Nov 27, 2025

v1.0.1

Nov 27, 2025

Changes in this version

+ const APIVersionPrefix

+ const HttpHeaderAuthorization

+ const HttpHeaderPortalAppID

+ const RelayRequestTimeout

+ var ErrGatewayNoServiceIDProvided = errors.New("no service ID provided")

+ type EndpointHydrator struct

+ ActiveQoSServices map[protocol.ServiceID]QoSService

+ DataReporter RequestResponseReporter

+ Logger polylog.Logger

+ MaxEndpointCheckWorkers int

+ MetricsReporter RequestResponseReporter

+ RunInterval time.Duration

+ func (eph *EndpointHydrator) IsAlive() bool

+ func (eph *EndpointHydrator) Name() string

+ func (eph *EndpointHydrator) Start() error

+ type Gateway struct

+ DataReporter RequestResponseReporter

+ Logger polylog.Logger

+ MetricsReporter RequestResponseReporter

+ func (g Gateway) HandleServiceRequest(ctx context.Context, httpReq *http.Request, responseWriter http.ResponseWriter)

+ type HTTPRequestParser interface

+ GetHTTPErrorResponse func(context.Context, error) pathhttp.HTTPResponse

+ GetQoSService func(context.Context, *http.Request) (protocol.ServiceID, QoSService, error)

+ type Protocol interface

+ ApplyHTTPObservations func(*protocolobservations.Observations) error

+ ApplyWebSocketObservations func(*protocolobservations.Observations) error

+ AvailableHTTPEndpoints func(context.Context, protocol.ServiceID, *http.Request) (protocol.EndpointAddrList, protocolobservations.Observations, error)

+ AvailableWebsocketEndpoints func(context.Context, protocol.ServiceID, *http.Request) (protocol.EndpointAddrList, protocolobservations.Observations, error)

+ BuildHTTPRequestContextForEndpoint func(context.Context, protocol.ServiceID, protocol.EndpointAddr, *http.Request) (ProtocolRequestContext, protocolobservations.Observations, error)

+ BuildWebsocketRequestContextForEndpoint func(context.Context, protocol.ServiceID, protocol.EndpointAddr, ...) (ProtocolRequestContextWebsocket, <-chan *protocolobservations.Observations, ...)

+ CheckWebsocketConnection func(context.Context, protocol.ServiceID, protocol.EndpointAddr) *protocolobservations.Observations

+ ConfiguredServiceIDs func() map[protocol.ServiceID]struct{}

+ GetTotalServiceEndpointsCount func(protocol.ServiceID, *http.Request) (int, error)

+ HydrateDisqualifiedEndpointsResponse func(protocol.ServiceID, *devtools.DisqualifiedEndpointResponse)

+ SupportedGatewayModes func() []protocol.GatewayMode

+ type ProtocolRequestContext interface

+ GetObservations func() protocolobservations.Observations

+ HandleServiceRequest func([]protocol.Payload) ([]protocol.Response, error)

+ type ProtocolRequestContextWebsocket interface

+ ProcessProtocolClientWebsocketMessage func([]byte) ([]byte, error)

+ ProcessProtocolEndpointWebsocketMessage func([]byte) ([]byte, protocolobservations.Observations, error)

+ type QoSContextBuilder interface

+ ParseHTTPRequest func(context.Context, *http.Request) (RequestQoSContext, bool)

+ ParseWebsocketRequest func(context.Context) (RequestQoSContext, bool)

+ type QoSEndpointCheckGenerator interface

+ CheckWebsocketConnection func() bool

+ GetRequiredQualityChecks func(protocol.EndpointAddr) []RequestQoSContext

+ type QoSService interface

+ ApplyObservations func(*qos.Observations) error

+ HydrateDisqualifiedEndpointsResponse func(protocol.ServiceID, *devtools.DisqualifiedEndpointResponse)

+ type RequestQoSContext interface

+ GetEndpointSelector func() protocol.EndpointSelector

+ GetHTTPResponse func() pathhttp.HTTPResponse

+ GetObservations func() qos.Observations

+ GetServicePayloads func() []protocol.Payload

+ UpdateWithResponse func(endpointAddr protocol.EndpointAddr, endpointSerializedResponse []byte)

+ type RequestResponseReporter interface

+ Publish func(*observation.RequestResponseObservations)

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