fallback

package

v0.2.0-rc.1 Latest Latest Go to latest Published: Sep 25, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrEmptyWrite = errors.New("write size is empty (=0)")
)

This section is empty.

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

func NewFIFOLock() *FIFOLock

func (l *FIFOLock) Lock()

func (l *FIFOLock) LockUntil(closed <-chan struct{}, deadlineState func() (time.Time, <-chan struct{})) error

func (l *FIFOLock) Unlock()

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

func (f *FallbackConn) Close() error

func (f *FallbackConn) LocalAddr() net.Addr

func (f *FallbackConn) Read(b []byte) (n int, err error)

func (f *FallbackConn) RemoteAddr() net.Addr

func (f *FallbackConn) SetDeadline(t time.Time) error

func (f *FallbackConn) SetReadDeadline(t time.Time) error

func (f *FallbackConn) SetWriteDeadline(t time.Time) error

func (f *FallbackConn) Write(b []byte) (int, error)

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

func NewFallbackCount() (*FallbackCount, error)

func (f *FallbackCount) Attach(conn net.Conn, id uuid.UUID, addr string) (net.Conn, error)

func (f *FallbackCount) Close() error

func (f *FallbackCount) DeleteExecLimit(id uuid.UUID) error

func (f *FallbackCount) DeleteLimit(addr netutil.IPv6, id uuid.UUID) error

func (f *FallbackCount) Detach(addr string, id uuid.UUID, ipv6 netutil.IPv6) error

func (f *FallbackCount) SetExecLimit(id uuid.UUID, limit app.Bitrate) error

func (f *FallbackCount) SetLimit(addr string, id uuid.UUID, limit app.Bitrate) error

func (f *FallbackCount) Type() string