subpub

Jan 29, 2021

Changes in this version

+ type Message struct

+ Data []byte

+ Peer string

Jan 9, 2021

Changes in this version

+ type MessageContext struct

+ Message []byte

+ Stream network.Stream

+ func (mc *MessageContext) ConnectionType() string

+ func (mc *MessageContext) Send(m transports.Message) error

+ type SubPub struct

+ BootNodes []string

+ BroadcastWriter chan []byte

+ CollectionPeriod time.Duration

+ DiscoveryPeriod time.Duration

+ GroupKey [32]byte

+ Host host.Host

+ Key ecdsa.PrivateKey

+ MaxDHTpeers int

+ MultiAddr string

+ NoBootStrap bool

+ NodeID string

+ Peers []peerSub

+ PeersMu sync.RWMutex

+ Port int32

+ Private bool

+ PubKey string

+ Reader chan MessageContext

+ Topic string

+ func NewSubPub(key ecdsa.PrivateKey, groupKey []byte, port int32, private bool) *SubPub

+ func (ps *SubPub) Close() error

+ func (ps *SubPub) FindTopic(namespace string, callback func(*bufio.ReadWriter)) error

+ func (ps *SubPub) PeerStreamWrite(peerID string, msg []byte) error

+ func (ps *SubPub) SendMessage(w *bufio.Writer, msg []byte) error

+ func (ps *SubPub) Start(ctx context.Context)

+ func (ps *SubPub) String() string

+ func (ps *SubPub) Subscribe(ctx context.Context)

+ func (ps *SubPub) TransportConnectPeer(maddr string) error