pubsub

package

v0.0.0-...-84dde57 Latest Latest Go to latest Published: Sep 8, 2023 License: MIT Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/primev/builder-boost

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type BuilderServer
type PubSubIO
- func New(ctx context.Context, cfg *config.Config, log log.Logger, ...) (*PubSubIO, error)
type SearcherServer
type Server

Constants ¶

View Source

const (
	BuilderTopicsCount       = 2
	SearcherTopicsCount      = 1
	BuilderComChannelsCount  = 4
	SearcherComChannelsCount = 2
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BuilderServer ¶

type BuilderServer struct {
	Server
	// contains filtered or unexported fields
}

func (*BuilderServer) Gossip ¶

func (bs *BuilderServer) Gossip(msg message.OutboundMessage) error

stream message for gossip peers

func (*BuilderServer) Publish ¶

func (bs *BuilderServer) Publish(msg message.OutboundMessage) error

publish message on topic

func (*BuilderServer) Stream ¶

func (bs *BuilderServer) Stream(peerID peer.ID, msg message.OutboundMessage) error

stream message for specific peer

type PubSubIO ¶

type PubSubIO struct {
	BuilderServer
	SearcherServer
}

func New ¶

func New(
	ctx context.Context,
	cfg *config.Config,
	log log.Logger,
	peerType commons.PeerType,
	host host.Host,
	registry *prometheus.Registry,
	connTrackCh chan commons.ConnectionEvent,
	token []byte,
	address common.Address,
	rollup rollup.Rollup,
	topics map[commons.Topic]*pubsub.Topic,
	imb message.InboundMsgBuilder,
	omb message.OutboundMsgBuilder,
	comChannels map[commons.ComChannels]chan messages.PeerMsg,
) (*PubSubIO, error)

type SearcherServer ¶

type SearcherServer struct {
	Server
	// contains filtered or unexported fields
}

func (*SearcherServer) Gossip ¶

func (ss *SearcherServer) Gossip(msg message.OutboundMessage) error

stream message for gossip peers

func (*SearcherServer) Publish ¶

func (ss *SearcherServer) Publish(msg message.OutboundMessage) error

publish message on topic

func (*SearcherServer) Stream ¶

func (ss *SearcherServer) Stream(peerID peer.ID, msg message.OutboundMessage) error

stream message for specific peer

type Server ¶

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

func (*Server) GetApprovedBuilderPeers ¶

func (server *Server) GetApprovedBuilderPeers() []peer.ID

get approved builders on pubsub server

func (*Server) GetApprovedGossipPeers ¶

func (server *Server) GetApprovedGossipPeers() []peer.ID

get approved gossip peers on pubsub server

func (*Server) GetApprovedPeers ¶

func (server *Server) GetApprovedPeers() []peer.ID

get approved peers on pubsub server

func (*Server) GetApprovedSearcherPeers ¶

func (server *Server) GetApprovedSearcherPeers() []peer.ID

get approved searchers on pubsub server

func (Server) ID ¶

func (server Server) ID() peer.ID

get self peer.ID

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL