Documentation
¶
Index ¶
- type Metrics
- type SandboxProxy
- func (p *SandboxProxy) Close(ctx context.Context) error
- func (p *SandboxProxy) GetAddr() string
- func (p *SandboxProxy) OnInsert(_ context.Context, _ *sandbox.Sandbox)
- func (p *SandboxProxy) OnNetworkRelease(_ context.Context, sbx *sandbox.Sandbox)
- func (p *SandboxProxy) RemoveFromPool(connectionKey string) error
- func (p *SandboxProxy) Start(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
Metrics holds ingress proxy metrics.
func NewMetrics ¶
func NewMetrics(meterProvider metric.MeterProvider) *Metrics
NewMetrics creates a new Metrics instance.
func (*Metrics) RecordConnectionBlocked ¶
RecordConnectionBlocked records a connection that was blocked by the connection limit.
func (*Metrics) RecordConnectionDuration ¶
RecordConnectionDuration records the duration of a proxied connection.
type SandboxProxy ¶
type SandboxProxy struct {
// contains filtered or unexported fields
}
func NewSandboxProxy ¶
func NewSandboxProxy(meterProvider metric.MeterProvider, port uint16, sandboxes *sandbox.Map, featureFlags *featureflags.Client) (*SandboxProxy, error)
func (*SandboxProxy) GetAddr ¶
func (p *SandboxProxy) GetAddr() string
func (*SandboxProxy) OnInsert ¶
func (p *SandboxProxy) OnInsert(_ context.Context, _ *sandbox.Sandbox)
OnInsert is called when a sandbox is inserted into the map.
func (*SandboxProxy) OnNetworkRelease ¶
func (p *SandboxProxy) OnNetworkRelease(_ context.Context, sbx *sandbox.Sandbox)
OnNetworkRelease is called when a sandbox's network slot is released. Keyed by LifecycleID so the removal is scoped to this sandbox lifecycle.
func (*SandboxProxy) RemoveFromPool ¶
func (p *SandboxProxy) RemoveFromPool(connectionKey string) error
Source Files
Click to show internal directories.
Click to hide internal directories.