pubsub

Documentation

Index

• Constants
• type Handler
• type PubSubMessage
• type PubSubMessageType
• type PubSubRouter
  • func NewPubSubRouter(h host.Host, ps *pubsub.PubSub, oracleTopic string, isBootstrap bool) *PubSubRouter
  • func (psr *PubSubRouter) BroadcastToServiceTopic(msg *PubSubMessage) error
  • func (psr *PubSubRouter) Hook(messageType PubSubMessageType, handler Handler)
  • func (psr *PubSubRouter) Run()
  • func (psr *PubSubRouter) Shutdown()

Constants

const (
	UnknownMessageType = iota
	PrePrepareMessageType
	PrepareMessageType
	CommitMessageType
	NewTxMessageType
	NewBlockMessageType
)

Types

type Handler

type Handler func(message *PubSubMessage)

type PubSubMessage

type PubSubMessage struct {
	Type    PubSubMessageType
	From    peer.ID `cbor:"-"`
	Payload []byte
}

type PubSubMessageType

type PubSubMessageType int

type PubSubRouter

type PubSubRouter struct {
	Pubsub *pubsub.PubSub
	// contains filtered or unexported fields
}

func NewPubSubRouter

func NewPubSubRouter(h host.Host, ps *pubsub.PubSub, oracleTopic string, isBootstrap bool) *PubSubRouter

func (*PubSubRouter) BroadcastToServiceTopic

func (psr *PubSubRouter) BroadcastToServiceTopic(msg *PubSubMessage) error

func (*PubSubRouter) Hook

func (psr *PubSubRouter) Hook(messageType PubSubMessageType, handler Handler)

func (*PubSubRouter) Run

func (psr *PubSubRouter) Run()

func (*PubSubRouter) Shutdown

func (psr *PubSubRouter) Shutdown()