standalone

Documentation

Index

• type MinimalNetAdapter
  • func NewMinimalNetAdapter(cfg *config.Config) (*MinimalNetAdapter, error)
  • func (mna *MinimalNetAdapter) Connect(address string) (*Routes, error)
• type Routes
  • func (r *Routes) Disconnect()
  • func (r *Routes) WaitForDisconnect(timeout time.Duration) error
  • func (r *Routes) WaitForMessageOfType(command appmessage.MessageCommand, timeout time.Duration) (appmessage.Message, error)

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