pubsub

Documentation

Index

• Variables
• func Options() fx.Option
• type INet
  • func NewINet(p *PubSub) INet
• type IPubsuber
  • func NewIPubsuber(p *PubSub) IPubsuber
• type PubSub
  • func NewPubsub(ctx context.Context, listenAddress string, networkName types.NetworkName, ...) (*PubSub, error)
  • func ProvidePubsub(ctx context.Context, networkName types.NetworkName, ...) (*PubSub, error)
  • func (m *PubSub) AddrListen(ctx context.Context) (peer.AddrInfo, error)
  • func (m *PubSub) Connect(ctx context.Context, p peer.AddrInfo) error
  • func (m *PubSub) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)
  • func (m *PubSub) GetTopic(topic string) (*pubsub.Topic, error)
  • func (m *PubSub) Peers(ctx context.Context) ([]peer.AddrInfo, error)

Variables

var ErrPubsubDisabled = errors.New("pubsub is disabled")

Functions

func Options

func Options() fx.Option

Types

type INet

type INet interface {
	Connect(ctx context.Context, p peer.AddrInfo) error
	FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)
	Peers(ctx context.Context) ([]peer.AddrInfo, error)
	AddrListen(ctx context.Context) (peer.AddrInfo, error)
}

func NewINet

func NewINet(p *PubSub) INet

type IPubsuber

type IPubsuber interface {
	GetTopic(topic string) (*pubsub.Topic, error)
}

func NewIPubsuber

func NewIPubsuber(p *PubSub) IPubsuber

type PubSub

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

func NewPubsub

func NewPubsub(ctx context.Context,
	listenAddress string,
	networkName types.NetworkName,
	bootstrap []string,
	period time.Duration,
	threshold int,
) (*PubSub, error)

func ProvidePubsub

func ProvidePubsub(ctx context.Context, networkName types.NetworkName, net *config.Libp2pNetConfig) (*PubSub, error)

func (*PubSub) AddrListen

func (m *PubSub) AddrListen(ctx context.Context) (peer.AddrInfo, error)

func (*PubSub) Connect

func (m *PubSub) Connect(ctx context.Context, p peer.AddrInfo) error

func (*PubSub) FindPeer

func (m *PubSub) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)

FindPeer searches the libp2p router for a given peer id

func (*PubSub) GetTopic

func (m *PubSub) GetTopic(topic string) (*pubsub.Topic, error)

func (*PubSub) Peers

func (m *PubSub) Peers(ctx context.Context) ([]peer.AddrInfo, error)