pubsub

Documentation

Overview

pubsub a publish subscribe client for IPFS PubSub

Index

• func NewEventMessage(content []byte) *iface.EventPubSubMessage
• func NewEventPayload(payload []byte, peerid peer.ID) *iface.EventPubSubPayload
• type Event
  • func NewEventPeerJoin(p peer.ID, topic string) Event
  • func NewEventPeerLeave(p peer.ID, topic string) Event
• type PayloadEmitter
  • func NewPayloadEmitter(bus event.Bus) (*PayloadEmitter, error)
  • func (e *PayloadEmitter) Emit(evt *iface.EventPubSubPayload) error

Functions

func NewEventMessage

func NewEventMessage(content []byte) *iface.EventPubSubMessage

Creates a new Message event

func NewEventPayload

func NewEventPayload(payload []byte, peerid peer.ID) *iface.EventPubSubPayload

NewEventPayload Creates a new Message event

Types

type Event

type Event interface{}

func NewEventPeerJoin

func NewEventPeerJoin(p peer.ID, topic string) Event

NewEventPeerJoin creates a new EventPubSubJoin event

func NewEventPeerLeave

func NewEventPeerLeave(p peer.ID, topic string) Event

NewEventPeerLeave creates a new EventPubSubLeave event

type PayloadEmitter

type PayloadEmitter struct {
	event.Emitter
}

func NewPayloadEmitter

func NewPayloadEmitter(bus event.Bus) (*PayloadEmitter, error)

func (*PayloadEmitter) Emit

func (e *PayloadEmitter) Emit(evt *iface.EventPubSubPayload) error