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
}
Source Files
Click to show internal directories.
Click to hide internal directories.