session

Jul 17, 2026

Changes in this version

+ type ConcurrentBlockReceiveSink interface

+ ConcurrentWriteAtSafe func() bool

+ type DirectBlockReceiveSink interface

+ CommitDirectWrite func(bytes int, highestEnd int64) error

+ DirectWriteBuffer func() []byte

type ListenConfig

+ DirectTCPPort int

type OfferConfig

+ DirectTCPPort int

type ReceiveConfig

+ DirectTCPPort int

type SendConfig

+ DirectTCPPort int

Jul 3, 2026

Changes in this version

+ const DefaultParallelStripes

+ type BlockReceiveRequest struct

+ ChunkSize int

+ Header []byte

+ PayloadSize int64

+ type BlockReceiveSink interface

+ Close func() error

+ type BlockReceiver func(context.Context, BlockReceiveRequest) (BlockReceiveSink, error)

+ type BlockSource struct

+ ChunkSize int

+ Header []byte

+ HeaderFunc func() []byte

+ OpenStream func() (io.ReadCloser, error)

+ Payload io.ReaderAt

+ PayloadSize int64

type ListenConfig

+ BlockReceiver BlockReceiver

type OfferConfig

+ BlockSource *BlockSource

type ReceiveConfig

+ BlockReceiver BlockReceiver

type SendConfig

+ BlockSource *BlockSource

Jun 27, 2026

Changes in this version

+ func DerptunAppDial(ctx context.Context, cfg DerptunAppDialConfig) (*derptun.Mux, func(), error)

+ func DerptunAppDialStream(ctx context.Context, cfg DerptunAppDialConfig) (net.Conn, func(), error)

+ func DerptunAppServe(ctx context.Context, cfg DerptunAppServeConfig) error

+ type DerptunAppDialConfig struct

+ ClientToken string

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ UsePublicDERP bool

+ type DerptunAppServeConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ OnMux func(context.Context, *derptun.Mux) error

+ ServerToken string

+ UsePublicDERP bool

May 16, 2026

Changes in this version

type OfferConfig

+ Progress func(bytesReceived int64, transferElapsedMS int64)

type SendConfig

+ Progress func(bytesReceived int64, transferElapsedMS int64)

type State

+ const StateDirectFallbackRelay

+ const StateTryingDirect

May 11, 2026

Changes in this version

type ListenConfig

+ Trace *transfertrace.Recorder

type OfferConfig

+ Trace *transfertrace.Recorder

type ReceiveConfig

+ Trace *transfertrace.Recorder

type SendConfig

+ Trace *transfertrace.Recorder

Apr 18, 2026

Changes in this version

type DerptunConnectConfig

+ ClientToken string

type DerptunOpenConfig

+ ClientToken string

type DerptunServeConfig

+ ServerToken string

Apr 18, 2026

Changes in this version

+ func DerptunConnect(ctx context.Context, cfg DerptunConnectConfig) error

+ func DerptunOpen(ctx context.Context, cfg DerptunOpenConfig) error

+ func DerptunServe(ctx context.Context, cfg DerptunServeConfig) error

+ type DerptunConnectConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ StdioIn io.Reader

+ StdioOut io.Writer

+ Token string

+ UsePublicDERP bool

+ type DerptunOpenConfig struct

+ BindAddrSink chan<- string

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ ListenAddr string

+ Token string

+ UsePublicDERP bool

+ type DerptunServeConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ TargetAddr string

+ Token string

+ UsePublicDERP bool

Apr 16, 2026

Changes in this version

+ const AutoParallelGrowthStep

+ const AutoParallelHoldSamples

+ const AutoParallelMinGainMbps

+ const AutoParallelMinGainPercent

+ const AutoParallelSamplePeriod

+ const AutoParallelTargetFloor

+ const DefaultParallelInitial

+ const MaxParallelStripes

+ var ErrPeerAborted = errors.New("peer aborted transfer")

+ var ErrPeerDisconnected = errors.New("peer disconnected")

+ var ErrSessionClaimed = errors.New("session already claimed")

+ var ErrUnknownSession = errors.New("unknown session")

+ func DialAttach(ctx context.Context, cfg AttachDialConfig) (net.Conn, error)

+ func Listen(ctx context.Context, cfg ListenConfig) (string, error)

+ func Offer(ctx context.Context, cfg OfferConfig) (string, error)

+ func Open(ctx context.Context, cfg OpenConfig) error

+ func Receive(ctx context.Context, cfg ReceiveConfig) error

+ func Send(ctx context.Context, cfg SendConfig) error

+ func Share(ctx context.Context, cfg ShareConfig) (string, error)

+ type AttachDialConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ ParallelPolicy ParallelPolicy

+ Token string

+ UsePublicDERP bool

+ type AttachListenConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ UsePublicDERP bool

+ type AttachListener struct

+ Token string

+ func ListenAttach(ctx context.Context, cfg AttachListenConfig) (*AttachListener, error)

+ func (l *AttachListener) Accept(ctx context.Context) (net.Conn, error)

+ func (l *AttachListener) Close() error

+ type ListenConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ StdioOut io.Writer

+ TokenSink chan<- string

+ UsePublicDERP bool

+ type OfferConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ ParallelPolicy ParallelPolicy

+ StdioExpectedBytes int64

+ StdioIn io.Reader

+ TokenSink chan<- string

+ UsePublicDERP bool

+ type OpenConfig struct

+ BindAddr string

+ BindAddrSink chan<- string

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ ParallelPolicy ParallelPolicy

+ Token string

+ UsePublicDERP bool

+ type ParallelMode string

+ const ParallelModeAuto

+ const ParallelModeFixed

+ type ParallelPolicy struct

+ Cap int

+ Initial int

+ Mode ParallelMode

+ func AutoParallelPolicy() ParallelPolicy

+ func DefaultParallelPolicy() ParallelPolicy

+ func FixedParallelPolicy(n int) ParallelPolicy

+ func ParseParallelPolicy(raw string) (ParallelPolicy, error)

+ type ReceiveConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ StdioOut io.Writer

+ Token string

+ UsePublicDERP bool

+ type SendConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ ParallelPolicy ParallelPolicy

+ StdioExpectedBytes int64

+ StdioIn io.Reader

+ Token string

+ UsePublicDERP bool

+ type ShareConfig struct

+ Emitter *telemetry.Emitter

+ ForceRelay bool

+ TargetAddr string

+ TokenSink chan<- string

+ UsePublicDERP bool

+ type State string

+ const StateClaimed

+ const StateComplete

+ const StateDirect

+ const StateProbing

+ const StateRelay

+ const StateWaiting