io

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Jan 6, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultTimeout = time.Millisecond * 10 // time.Second * 240
)

Variables

This section is empty.

Functions

func MD5Hash

func MD5Hash(in []byte) []byte

func SessionTwoParties added in v0.4.0

func SessionTwoParties(t *testing.T, network ...networkNode)

Types

type Comm

type Comm struct {
	Channels map[uint]Conn
	MyPID    int
}

type Conn

type Conn interface {
	io.Writer
	io.Reader
	Flush() error
}

func NewBufConn

func NewBufConn(session view.Session) (Conn, error)

NewBufConn creates a new connection conn backed by the comm scc with a buffered writer to improve efficiency

func NewConn

func NewConn(index int, session view.Session) (Conn, error)

NewConn creates a new connection conn backed by the comm scc

type MsgConn

type MsgConn interface {
	io.Writer
	streamio.MsgReader
	Flush() error
}

func NewMsgConn

func NewMsgConn(index int, session view.Session) (MsgConn, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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