pubsub

Documentation

Index

• func BaseTestPubSub(t *testing.T, hGen pv.HostGenerator)
• type IPubSub
  • func NewPubSub(hGen pv.HostGenerator, bootstraps ...peer.AddrInfo) (IPubSub, error)
• type IRoom

Functions

func BaseTestPubSub

func BaseTestPubSub(t *testing.T, hGen pv.HostGenerator)

go test -test.v=true .

Types

type IPubSub

type IPubSub interface {
	Close()
	AddrInfo() peer.AddrInfo
	Topics() []string
	JoinTopic(string) (IRoom, error)
}

func NewPubSub

func NewPubSub(hGen pv.HostGenerator, bootstraps ...peer.AddrInfo) (IPubSub, error)

type IRoom

type IRoom interface {
	Close()
	ListPeers() []peer.ID
	Publish([]byte) error
	Get() (*recievedMessage, error)
	GetAll() ([]*recievedMessage, error)
}