bifrost

package module

Go to main page

Versions in this module

v0

v0.4.1

Jun 19, 2026

Changes in this version

+ type ProxyStreamOptions struct

+ Observer StreamObserver

type Server

+ func (s *Server) ProxyStreamWithOptions(ctx context.Context, endpointKey string, ingressConn net.Conn, ...) error

v0.4.0

Jun 15, 2026

Changes in this version

+ type PassiveLatencyObservation = latency.Observation

+ type PassiveLatencyObserver = latency.Observer

+ type PassiveLatencySnapshotter = latency.Snapshotter

+ type PassiveLatencyState = latency.State

+ const PassiveLatencyOK

+ const PassiveLatencyStale

+ const PassiveLatencyUnknown

+ type PassiveLatencyStore = latency.Store

+ func NewPassiveLatencyStore(staleAfter time.Duration) *PassiveLatencyStore

type Server

+ func (s *Server) PassiveLatencyObservation(endpointKey string, now time.Time) PassiveLatencyObservation

+ func (s *Server) PassiveLatencySnapshot(now time.Time) []PassiveLatencyObservation

type ServerOptions

+ PassiveLatencyObserver PassiveLatencyObserver

v0.3.1

May 16, 2026

Changes in this version

+ type Listener = listener.Spec

v0.3.0

May 15, 2026

Changes in this version

+ const DirectionEndpointToIngress

+ const DirectionIngressToEndpoint

type ClientOptions

+ Observer Observer

+ type Direction = metrics.Direction

+ type NoopObserver = metrics.Noop

+ type NoopStreamObserver = metrics.NoopStream

+ type Observer = metrics.Observer

+ func NewMultiObserver(observers ...Observer) Observer

type ServerOptions

+ Observer Observer

+ type StreamObserver = metrics.StreamObserver

v0.2.1

May 14, 2026

Changes in this version

type ServerOptions

+ Listener net.Listener

v0.2.0

May 14, 2026

Changes in this version

+ const ALPN

type ServerConfig

+ TLSConfig *tls.Config

v0.1.0

May 11, 2026

Changes in this version

+ const PolicyAllowParallel

+ const PolicyRejectIfExists

+ const PolicyReplaceExisting

+ const TokenHeader

+ func Copy(ctx context.Context, a net.Conn, b net.Conn, opts CopyOptions)

+ func ListenerSpec(network string, address string) listener.Spec

+ func RunClient(ctx context.Context, cfg ClientConfig, opts ClientOptions) error

+ func RunServer(ctx context.Context, cfg ServerConfig, opts ServerOptions) error

+ type AcceptDecision = acceptor.Decision

+ type AcceptProvider = acceptor.Provider

+ func NewStaticAcceptProvider(clients []StaticClient) (AcceptProvider, error)

+ type AcceptRequest = acceptor.Request

+ type ClientConfig struct

+ AdminListen string

+ Headers map[string]string

+ ServerURL string

+ TLSCAFile string

+ TLSInsecureSkipVerify bool

+ TLSServerName string

+ TargetAddress string

+ type ClientOptions struct

+ AdminReady func(net.Addr)

+ Logger *slog.Logger

+ StreamHandler func(context.Context, net.Conn)

+ type ConnectionPolicy = acceptor.ConnectionPolicy

+ type CopyOptions struct

+ BufferSize int

+ IdleTimeout time.Duration

+ OnBytes func(direction string, n int64)

+ type Guardrails struct

+ MaxBandwidthBPSPerSession int64

+ MaxHeaderBytes int

+ MaxHeaders int

+ MaxSessions int

+ MaxStreamIdleTimeout time.Duration

+ MaxStreamsPerSession int

+ MinStreamIdleTimeout time.Duration

+ type PlanLimits = limits.PlanLimits

+ type Runtime struct

+ HandshakeTimeout time.Duration

+ StreamCopyBufferBytes int

+ TunnelKeepAliveInterval time.Duration

+ TunnelKeepAliveTimeout time.Duration

+ type Server struct

+ func NewServer(cfg ServerConfig, opts ServerOptions) (*Server, error)

+ func (s *Server) OpenStream(ctx context.Context, endpointKey string) (net.Conn, error)

+ func (s *Server) ProxyStream(ctx context.Context, endpointKey string, ingressConn net.Conn) error

+ func (s *Server) Run(ctx context.Context) error

+ type ServerConfig struct

+ AdminListen string

+ Clients []StaticClient

+ Guardrails Guardrails

+ Listen string

+ Runtime Runtime

+ TLSCertFile string

+ TLSKeyFile string

+ type ServerOptions struct

+ AcceptProvider AcceptProvider

+ AdminReady func(net.Addr)

+ Logger *slog.Logger

+ Ready func(net.Addr)

+ type StaticClient = acceptor.StaticClient

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