proxy

package

Go to main page

Versions in this module

v0

v0.11.1

Jun 30, 2024

Changes in this version

type RequestContextProvider

+ func (reqCtxProvider *RequestContextProvider) Close()

+ func (reqCtxProvider *RequestContextProvider) UpdateModulePool(mb ModulePool)

v0.11.0

Jun 20, 2024

Changes in this version

type ProxyPrinter

+ func (pp *ProxyPrinter) Debug(s string)

+ func (pp *ProxyPrinter) Info(s string)

type ProxyState

+ func (ps *ProxyState) ChangeLogs() []*spec.ChangeLog

v0.10.1

Jun 14, 2024

v0.10.0

Jun 13, 2024

v0.9.1

Jun 2, 2024

v0.9.0

Jun 2, 2024

Changes in this version

type RequestContextProvider

+ func (reqCtxProvider *RequestContextProvider) ModulePool() ModulePool

v0.8.1

May 31, 2024

v0.8.0

May 29, 2024

Changes in this version

+ func HashString[T any](salt uint32, objs ...T) (string, error)

+ func ValidateMethods(methods []string) error

+ type ModulePool interface

+ Borrow func() ModuleExtractor

+ Close func()

+ Return func(me ModuleExtractor)

+ func NewModulePool(minBuffers, maxBuffers int, reqCtxProvider *RequestContextProvider, ...) (ModulePool, error)

+ type ProxyMetrics struct

+ func NewProxyMetrics() *ProxyMetrics

+ func (pm *ProxyMetrics) MeasureCertResolutionDuration(start time.Time, host string, cache bool, err error)

+ func (pm *ProxyMetrics) MeasureModuleDuration(reqCtx *RequestContext, moduleFunc string, start time.Time, err error)

+ func (pm *ProxyMetrics) MeasureNamespaceResolutionDuration(start time.Time, host, namespace string, err error)

+ func (pm *ProxyMetrics) MeasureProxyRequest(reqCtx *RequestContext, start time.Time)

+ func (pm *ProxyMetrics) MeasureUpstreamDuration(reqCtx *RequestContext, start time.Time, upstreamHost string, err error)

+ func (pm *ProxyMetrics) Setup(config *config.DGateConfig)

type ProxyState

+ ProxyHandler ProxyHandlerFunc

+ func (ps *ProxyState) Ready() bool

+ func (ps *ProxyState) SetReady()

+ func (ps *ProxyState) SetupRaft(r *raft.Raft, rc *raft.Config)

+ func (ps *ProxyState) Start() (err error)

+ func (ps *ProxyState) Stop()

+ func (ps *ProxyState) Store() *proxystore.ProxyStore

+ func (ps *ProxyState) Version() string

type RequestContext

+ func (reqCtx *RequestContext) Context() context.Context

+ func (reqCtx *RequestContext) Pattern() string

+ func (reqCtx *RequestContext) Request() *http.Request

+ func (reqCtx *RequestContext) Route() *spec.DGateRoute

type RequestContextProvider

+ func (reqCtxProvider *RequestContextProvider) SetModulePool(mb ModulePool)

v0.7.1

Apr 22, 2024

v0.7.0

Apr 22, 2024

Changes in this version

+ func HashAny[T any](salt uint32, objs ...any) (uint32, error)

+ func NewRuntimeContext(proxyState *ProxyState, route *spec.DGateRoute, modules ...*spec.DGateModule) *runtimeContext

+ func RouteHash(routes ...*spec.DGateRoute) (hash uint32, err error)

+ func TimeoutDialer(connTimeout time.Duration) func(net, addr string) (c net.Conn, err error)

+ type LoggerOptions func(zerolog.Context) zerolog.Context

+ func WithComponentLogger(component string) LoggerOptions

+ func WithDefaultLevel(level zerolog.Level) LoggerOptions

+ type ModuleBuffer interface

+ Borrow func() (ModuleExtractor, bool)

+ Close func()

+ Load func(cb func())

+ Return func(me ModuleExtractor)

+ func NewModuleBuffer(minBuffers, maxBuffers int, reqCtxProvider *RequestContextProvider, ...) (ModuleBuffer, error)

+ type ModuleExtractor interface

+ ErrorHandlerFunc func() (extractors.ErrorHandlerFunc, bool)

+ FetchUpstreamUrlFunc func() (extractors.FetchUpstreamUrlFunc, bool)

+ ModHash func() uint32

+ ModuleContext func() *types.ModuleContext

+ RequestHandlerFunc func() (extractors.RequestHandlerFunc, bool)

+ RequestModifierFunc func() (extractors.RequestModifierFunc, bool)

+ ResponseModifierFunc func() (extractors.ResponseModifierFunc, bool)

+ RuntimeContext func() modules.RuntimeContext

+ SetModuleContext func(*types.ModuleContext)

+ Start func()

+ Stop func(wait bool)

+ func NewEmptyModuleExtractor() ModuleExtractor

+ func NewModuleExtractor(runtimeContext modules.RuntimeContext, ...) ModuleExtractor

+ type ModuleExtractorFunc func(*RequestContextProvider) ModuleExtractor

+ type ProxyHandlerFunc func(ps *ProxyState, reqCtx *RequestContext)

+ type ProxyPrinter struct

+ func NewProxyPrinter(logger zerolog.Logger) *ProxyPrinter

+ func (pp *ProxyPrinter) Error(s string)

+ func (pp *ProxyPrinter) Log(s string)

+ func (pp *ProxyPrinter) Warn(s string)

+ type ProxyReplication struct

+ func NewProxyReplication(raft *raft.Raft, raftConfig *raft.Config) *ProxyReplication

+ type ProxySnapshot struct

+ ResourceManager *resources.ResourceManager

+ func (ps *ProxySnapshot) PersistState(w io.Writer) error

+ type ProxyState struct

+ ProxyHandlerFunc ProxyHandlerFunc

+ ProxyTransportBuilder proxy_transport.Builder

+ ReverseProxyBuilder reverse_proxy.Builder

+ func NewProxyState(conf *config.DGateConfig) *ProxyState

+ func StartProxyGateway(conf *config.DGateConfig) (*ProxyState, error)

+ func (ps *ProxyState) ApplyChangeLog(log *spec.ChangeLog) error

+ func (ps *ProxyState) ChangeHash() uint32

+ func (ps *ProxyState) DocumentManager() resources.DocumentManager

+ func (ps *ProxyState) DynamicTLSConfig(certFile, keyFile string) *tls.Config

+ func (ps *ProxyState) EnableRaft(r *raft.Raft, rc *raft.Config)

+ func (ps *ProxyState) FindNamespaceByRequest(r *http.Request) *spec.DGateNamespace

+ func (ps *ProxyState) GetDocumentByID(namespace, collection, docId string) (*spec.Document, error)

+ func (ps *ProxyState) GetDocuments(collection, namespace string, limit, offset int) ([]*spec.Document, error)

+ func (ps *ProxyState) HandleRoute(requestCtxProvider *RequestContextProvider, pattern string) http.HandlerFunc

+ func (ps *ProxyState) Logger(opts ...LoggerOptions) *zerolog.Logger

+ func (ps *ProxyState) ProcessChangeLog(log *spec.ChangeLog, register bool) error

+ func (ps *ProxyState) Raft() *raft.Raft

+ func (ps *ProxyState) ReloadState() error

+ func (ps *ProxyState) ResourceManager() *resources.ResourceManager

+ func (ps *ProxyState) RestoreState(r io.Reader) error

+ func (ps *ProxyState) Scheduler() scheduler.Scheduler

+ func (ps *ProxyState) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (ps *ProxyState) SharedCache() cache.TCache

+ func (ps *ProxyState) Snapshot() *ProxySnapshot

+ func (ps *ProxyState) Stats() *ProxyStats

+ func (ps *ProxyState) WaitForChanges()

+ type ProxyStats struct

+ LastNModExtractDurs []float64

+ LastNRequestsDurs []float64

+ RouteRequestCount map[string]int64

+ func NewProxyStats(windowSize int) *ProxyStats

+ func (ps *ProxyStats) AddRequestStats(rs *RequestStats)

+ func (ps *ProxyStats) Snapshot() map[string]any

+ type ProxyStatus byte

+ const ProxyStatusClosed

+ const ProxyStatusModifying

+ const ProxyStatusRunning

+ const ProxyStatusStarting

+ const ProxyStatusStopping

+ type RequestContext struct

+ type RequestContextProvider struct

+ func NewRequestContextProvider(route *spec.DGateRoute) *RequestContextProvider

+ func (reqCtxProvider *RequestContextProvider) CreateRequestContext(ctx context.Context, rw http.ResponseWriter, req *http.Request, pattern string) *RequestContext

+ func (reqCtxProvider *RequestContextProvider) SetModuleBuffer(mb ModuleBuffer)

+ type RequestStats struct

+ MiscDurs map[string]time.Duration

+ Route *spec.DGateRoute

+ Service *spec.DGateService

+ UpstreamRequestDur time.Duration

+ func NewRequestStats(route *spec.DGateRoute) *RequestStats

+ func (rs *RequestStats) AddMiscDuration(name string, dur time.Duration)

+ func (rs *RequestStats) AddUpstreamRequestDuration(dur time.Duration)

+ func (rs *RequestStats) String() string

+ type S string

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