heartbeatconn

package
v0.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 10, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsPublicFrameType

func IsPublicFrameType(ft uint32) bool

The 4 MSBs of ft are reserved for frameconn, we reserve the next 4 MSB for us.

Types

type Conn

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

func Wrap

func Wrap(nc timeoutconn.Wire, sendInterval, timeout time.Duration) *Conn

func (*Conn) ReadFrame

func (c *Conn) ReadFrame() (frameconn.Frame, error)

func (*Conn) Shutdown

func (c *Conn) Shutdown() error

func (*Conn) WriteFrame

func (c *Conn) WriteFrame(payload []byte, frameType uint32) error

type HeartbeatTimeout

type HeartbeatTimeout struct{}

func (HeartbeatTimeout) Error

func (e HeartbeatTimeout) Error() string

func (HeartbeatTimeout) Temporary

func (e HeartbeatTimeout) Temporary() bool

This function is deprecated in net.Error and since this function is not involved in .Accept() code path, nothing really needs this method to be here.

func (HeartbeatTimeout) Timeout

func (e HeartbeatTimeout) Timeout() bool

Directories

Path Synopsis
This integration test exercises the behavior of heartbeatconn where the server is slow at handling the data received over the connection.
This integration test exercises the behavior of heartbeatconn where the server is slow at handling the data received over the connection.

Jump to

Keyboard shortcuts

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