client

type BrokerConnection struct {
	// Handling the connection to the local broker
	// the IP:Port of the local broker we talk to
	BrokerAddrStr string
	BrokerAddress *net.TCPAddr

	// the IP:Port of the coordinator that we fall back to
	CoordinatorAddress *net.TCPAddr

	// signals on this channel when it is done
	Stop chan bool
	// contains filtered or unexported fields
}

type Client struct {
	BrokerConnection
	// unique client identifier
	ID common.UUID
	// contains filtered or unexported fields
}

type Config struct {
	// ip:port of the initial, local broker
	BrokerAddress string
	// ip:port of the coordinator
	CoordinatorAddress string
}

type Publisher struct {
	BrokerConnection
	ID common.UUID
	// contains filtered or unexported fields
}

type PublisherStats struct {
	MessagesAttempted  uint32
	MessagesSuccessful uint32
}

type SimulatedBroker struct {
	// the IP:Port of the coordinator that we talk to
	CoordinatorAddress *net.TCPAddr

	// signals on this channel when it is done
	Stop chan bool
	// contains filtered or unexported fields
}