client

Documentation

Index

• func ConnectToMiners(listener net.Listener) []net.Conn
• func MulticastSendTransactionToMinersSimulatedDelay(clientTransaction Transaction, minerChannels []net.Conn)
• func SendRequest(minerChannels []net.Conn, delayInterval int)
• func SendStartup(clientID int) net.Conn
• func WaitForController(controllerChannel net.Conn)
• type Clients
  • func (n *Clients) NewClient(name string) client

Functions

func ConnectToMiners

func ConnectToMiners(listener net.Listener) []net.Conn

func MulticastSendTransactionToMinersSimulatedDelay

func MulticastSendTransactionToMinersSimulatedDelay(clientTransaction Transaction, minerChannels []net.Conn)

MulticastSendSimulatedDelay waits for a random bounded time to simulate message delay and then sends a transaction object to specified destinations via tcp.

func SendRequest

func SendRequest(minerChannels []net.Conn, delayInterval int)

SendRequest() periodically multicasts transactions to miners.

func SendStartup

func SendStartup(clientID int) net.Conn

SendStartup sends a start up message to the controller.

func WaitForController

func WaitForController(controllerChannel net.Conn)

WaitForController waits for a PROCEED message (string, not an object) from the controller that all processes have started up.

Types

type Clients

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

func (*Clients) NewClient

func (n *Clients) NewClient(name string) client

Creates a new client