standalone

package
v1.0.1-0...-25a685e Latest Latest
Warning

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

Go to latest
Published: Jan 11, 2024 License: ISC Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MinimalNetAdapter

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

MinimalNetAdapter allows tests and other tools to use a simple network adapter without implementing all the required supporting structures.

func NewMinimalNetAdapter

func NewMinimalNetAdapter(cfg *config.Config) (*MinimalNetAdapter, error)

NewMinimalNetAdapter creates a new instance of a MinimalNetAdapter

func (*MinimalNetAdapter) Connect

func (mna *MinimalNetAdapter) Connect(address string) (*Routes, error)

Connect opens a connection to the given address, handles handshake, and returns the routes for this connection To simplify usage the return type contains only two routes: OutgoingRoute - for all outgoing messages IncomingRoute - for all incoming messages (excluding handshake messages)

type Routes

type Routes struct {
	IncomingRoute, OutgoingRoute *router.Route
	// contains filtered or unexported fields
}

Routes holds the incoming and outgoing routes of a connection created by MinimalNetAdapter

func (*Routes) Disconnect

func (r *Routes) Disconnect()

Disconnect closes the connection behind the routes, thus closing all routes

func (*Routes) WaitForDisconnect

func (r *Routes) WaitForDisconnect(timeout time.Duration) error

WaitForDisconnect waits for a disconnect up to `timeout`, skipping all messages received while waiting

func (*Routes) WaitForMessageOfType

func (r *Routes) WaitForMessageOfType(command appmessage.MessageCommand, timeout time.Duration) (appmessage.Message, error)

WaitForMessageOfType waits for a message of requested type up to `timeout`, skipping all messages of any other type received while waiting

Jump to

Keyboard shortcuts

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