Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( HighestBidTopic = bulletinBoardTypes.MQTTTopic("topic/HighestBid") ProposerRequestTopic = bulletinBoardTypes.MQTTTopic("topic/ProposerSlotHeaderRequest") ProposerPayloadRequestTopic = bulletinBoardTypes.MQTTTopic("topic/ProposerPayloadRequest") BountyBidTopic = bulletinBoardTypes.MQTTTopic("topic/BountyBidWon") )
Functions ¶
func ClientBrokerUrl ¶
Types ¶
type RelayMQTT ¶
type RelayMQTT struct { Broker string Port uint64 ClientOptions *pahoMQTT.ClientOptions Client pahoMQTT.Client BeaconInterface *beaconclient.MultiBeaconClient Log *logrus.Entry Channel RelayMQTTChannels }
func NewMQTTClient ¶
func NewMQTTClient(clientParameters bulletinBoardTypes.RelayMQTTOpts, beaconClient *beaconclient.MultiBeaconClient) (*RelayMQTT, error)
func (*RelayMQTT) BountyBidWon ¶
func (relayClient *RelayMQTT) BountyBidWon()
func (*RelayMQTT) BulletinBoards ¶
func (relayClient *RelayMQTT) BulletinBoards()
func (*RelayMQTT) HighestBidPublish ¶
func (relayClient *RelayMQTT) HighestBidPublish()
func (*RelayMQTT) SlotHeaderRequested ¶
func (relayClient *RelayMQTT) SlotHeaderRequested()
func (*RelayMQTT) SlotPayloadRequested ¶
func (relayClient *RelayMQTT) SlotPayloadRequested()
type RelayMQTTChannels ¶
type RelayMQTTChannels struct { HighestBidChannel chan bulletinBoardTypes.RelayHighestBid ProposerHeaderChannel chan bulletinBoardTypes.ProposerHeaderRequest SlotPayloadChannel chan bulletinBoardTypes.SlotPayloadRequest BountyBidChannel chan bulletinBoardTypes.BountyBidWon }
Click to show internal directories.
Click to hide internal directories.