proxy

type LoggerOptions func(zerolog.Context) zerolog.Context

type ModuleBuffer interface {
	Load(cb func())
	Borrow() (ModuleExtractor, bool)
	Return(me ModuleExtractor)
	Close()
}

type ModuleExtractor interface {
	// Start starts the event loop for the module extractor; ret is true if the event loop was started, false otherwise
	Start()
	// Stop stops the event loop for the module extractor
	Stop(wait bool)

	// RuntimeContext returns the runtime context for the module extractor
	RuntimeContext() modules.RuntimeContext

	// SetModuleContext sets the module context for the module extractor
	SetModuleContext(*types.ModuleContext)
	// ModuleContext returns the module context for the module extractor
	ModuleContext() *types.ModuleContext

	// ModHash returns the hash of the module
	ModHash() uint32

	FetchUpstreamUrlFunc() (extractors.FetchUpstreamUrlFunc, bool)
	RequestModifierFunc() (extractors.RequestModifierFunc, bool)
	ResponseModifierFunc() (extractors.ResponseModifierFunc, bool)
	ErrorHandlerFunc() (extractors.ErrorHandlerFunc, bool)
	RequestHandlerFunc() (extractors.RequestHandlerFunc, bool)
}

type ModuleExtractorFunc func(*RequestContextProvider) ModuleExtractor

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

type ProxyPrinter struct {
	// contains filtered or unexported fields
}

type ProxyReplication struct {
	// contains filtered or unexported fields
}

type ProxySnapshot struct {
	ResourceManager *resources.ResourceManager `json:"resource_manager"`
}

type ProxyState struct {
	ReverseProxyBuilder   reverse_proxy.Builder
	ProxyTransportBuilder proxy_transport.Builder
	ProxyHandlerFunc      ProxyHandlerFunc
	// contains filtered or unexported fields
}

type ProxyStats struct {
	RouteRequestCount   map[string]int64
	LastNRequestsDurs   []float64
	LastNModExtractDurs []float64
	// contains filtered or unexported fields
}

type ProxyStatus byte

type RequestContext struct {
	// contains filtered or unexported fields
}

type RequestContextProvider struct {
	// contains filtered or unexported fields
}

type RequestStats struct {
	Service            *spec.DGateService
	Route              *spec.DGateRoute
	UpstreamRequestDur time.Duration
	MiscDurs           map[string]time.Duration
}

type S string