proxy

package

v0.0.0-...-cda31bf Latest Latest Go to latest Published: Jul 22, 2026 License: Apache-2.0 Imports: 18 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/e2b-dev/infra

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GetTargetFromRequest() func(r *http.Request) (sandboxId string, port uint64, err error)
func SandboxSharedHostDomain(host string) (string, bool)
type ConnectionLimitConfig
type InvalidSandboxPortError
- func (e InvalidSandboxPortError) Error() string
- func (e InvalidSandboxPortError) Unwrap() error
type InvalidTrafficAccessTokenError
- func NewErrInvalidTrafficAccessToken(sandboxId string, header string) *InvalidTrafficAccessTokenError
- func (e InvalidTrafficAccessTokenError) Error() string
type MaxConnectionAttempts
type MissingHeaderError
- func (e MissingHeaderError) Error() string
type MissingTrafficAccessTokenError
- func NewErrMissingTrafficAccessToken(sandboxId, header string) *MissingTrafficAccessTokenError
- func (e MissingTrafficAccessTokenError) Error() string
type Proxy
- func New(port uint16, maxConnectionAttempts MaxConnectionAttempts, ...) *Proxy
- func (p *Proxy) CurrentPoolConnections() int64
- func (p *Proxy) CurrentPoolSize() int
- func (p *Proxy) CurrentServerConnections() int64
- func (p *Proxy) ListenAndServe(ctx context.Context) error
- func (p *Proxy) RemoveFromPool(connectionKey string) error
- func (p *Proxy) Serve(l net.Listener) error
- func (p *Proxy) TotalPoolConnections() uint64
type SandboxNotFoundError
- func NewErrSandboxNotFound(sandboxId string) *SandboxNotFoundError
- func (e SandboxNotFoundError) Error() string
type SandboxResourceExhaustedError
- func NewErrSandboxResourceExhausted(sandboxId string, message string) *SandboxResourceExhaustedError
- func (e SandboxResourceExhaustedError) Error() string
type SandboxResumePermissionDeniedError
- func NewErrSandboxResumePermissionDenied(sandboxId string) *SandboxResumePermissionDeniedError
- func (e SandboxResumePermissionDeniedError) Error() string
type SandboxStillTransitioningError
- func NewErrSandboxStillTransitioning(sandboxId string) *SandboxStillTransitioningError
- func (e SandboxStillTransitioningError) Error() string

Constants ¶

View Source

const (
	ClientProxyRetries  = 1
	SandboxProxyRetries = 5
)

Variables ¶

View Source

var (
	ErrInvalidHost      = errors.New("invalid url host")
	ErrInvalidSandboxID = errors.New("invalid sandbox ID")
)

Functions ¶

func GetTargetFromRequest ¶

func GetTargetFromRequest() func(r *http.Request) (sandboxId string, port uint64, err error)

func SandboxSharedHostDomain ¶

func SandboxSharedHostDomain(host string) (string, bool)

Types ¶

type ConnectionLimitConfig ¶

type ConnectionLimitConfig struct {
	Limiter              *connlimit.ConnectionLimiter
	GetMaxLimit          func(ctx context.Context) int
	OnConnectionAcquired func(ctx context.Context, count int64)
	OnConnectionReleased func(ctx context.Context, durationMs int64)
	OnConnectionBlocked  func(ctx context.Context)
}

ConnectionLimitConfig bundles connection limiting and associated metric callbacks. When nil is passed, connection limiting is disabled.

type InvalidSandboxPortError ¶

type InvalidSandboxPortError struct {
	Port string
	// contains filtered or unexported fields
}

func (InvalidSandboxPortError) Error ¶

func (e InvalidSandboxPortError) Error() string

func (InvalidSandboxPortError) Unwrap ¶

func (e InvalidSandboxPortError) Unwrap() error

type InvalidTrafficAccessTokenError ¶

type InvalidTrafficAccessTokenError struct {
	SandboxId string
	Header    string
}

func NewErrInvalidTrafficAccessToken ¶

func NewErrInvalidTrafficAccessToken(sandboxId string, header string) *InvalidTrafficAccessTokenError

func (InvalidTrafficAccessTokenError) Error ¶

func (e InvalidTrafficAccessTokenError) Error() string

type MaxConnectionAttempts ¶

type MaxConnectionAttempts int

type MissingHeaderError ¶

type MissingHeaderError struct {
	Header string
}

func (MissingHeaderError) Error ¶

func (e MissingHeaderError) Error() string

type MissingTrafficAccessTokenError ¶

type MissingTrafficAccessTokenError struct {
	SandboxId string
	Header    string
}

func NewErrMissingTrafficAccessToken ¶

func NewErrMissingTrafficAccessToken(sandboxId, header string) *MissingTrafficAccessTokenError

func (MissingTrafficAccessTokenError) Error ¶

func (e MissingTrafficAccessTokenError) Error() string

type Proxy ¶

type Proxy struct {
	http.Server
	// contains filtered or unexported fields
}

func New ¶

func New(
	port uint16,
	maxConnectionAttempts MaxConnectionAttempts,
	idleTimeout time.Duration,
	getDestination func(r *http.Request) (*pool.Destination, error),
	connLimitConfig *ConnectionLimitConfig,
	disableKeepAlives bool,
) *Proxy

func (*Proxy) CurrentPoolConnections ¶

func (p *Proxy) CurrentPoolConnections() int64

func (*Proxy) CurrentPoolSize ¶

func (p *Proxy) CurrentPoolSize() int

func (*Proxy) CurrentServerConnections ¶

func (p *Proxy) CurrentServerConnections() int64

CurrentServerConnections returns the current number of connections that are alive across whole pool.

func (*Proxy) ListenAndServe ¶

func (p *Proxy) ListenAndServe(ctx context.Context) error

func (*Proxy) RemoveFromPool ¶

func (p *Proxy) RemoveFromPool(connectionKey string) error

func (*Proxy) Serve ¶

func (p *Proxy) Serve(l net.Listener) error

func (*Proxy) TotalPoolConnections ¶

func (p *Proxy) TotalPoolConnections() uint64

TotalPoolConnections returns the total number of connections that have been established across whole pool.

type SandboxNotFoundError ¶

type SandboxNotFoundError struct {
	SandboxId string
}

func NewErrSandboxNotFound ¶

func NewErrSandboxNotFound(sandboxId string) *SandboxNotFoundError

func (SandboxNotFoundError) Error ¶

func (e SandboxNotFoundError) Error() string

type SandboxResourceExhaustedError ¶

type SandboxResourceExhaustedError struct {
	SandboxId string
	Message   string
}

func NewErrSandboxResourceExhausted ¶

func NewErrSandboxResourceExhausted(sandboxId string, message string) *SandboxResourceExhaustedError

func (SandboxResourceExhaustedError) Error ¶

func (e SandboxResourceExhaustedError) Error() string

type SandboxResumePermissionDeniedError ¶

type SandboxResumePermissionDeniedError struct {
	SandboxId string
}

func NewErrSandboxResumePermissionDenied ¶

func NewErrSandboxResumePermissionDenied(sandboxId string) *SandboxResumePermissionDeniedError

func (SandboxResumePermissionDeniedError) Error ¶

func (e SandboxResumePermissionDeniedError) Error() string

type SandboxStillTransitioningError ¶

type SandboxStillTransitioningError struct {
	SandboxId string
}

func NewErrSandboxStillTransitioning ¶

func NewErrSandboxStillTransitioning(sandboxId string) *SandboxStillTransitioningError

func (SandboxStillTransitioningError) Error ¶

func (e SandboxStillTransitioningError) Error() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
pool
template
tracking

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