relay

Nov 14, 2023

Changes in this version

+ const WakuRelayENRField

+ var DefaultRelaySubscriptionBufferSize int = 1024

type Broadcaster

+ UnRegister func(pubsubTopic string)

+ type BroadcasterOption func(*BroadcasterParameters)

+ func DefaultBroadcasterOptions() []BroadcasterOption

+ func DontConsume() BroadcasterOption

+ func WithBufferSize(size int) BroadcasterOption

+ func WithConsumerOption(dontConsume bool) BroadcasterOption

+ type BroadcasterParameters struct

+ type PublishOption func(*publishParameters)

+ func WithDefaultPubsubTopic() PublishOption

+ func WithPubSubTopic(pubsubTopic string) PublishOption

+ type RelaySubscribeOption func(*RelaySubscribeParameters) error

+ func WithCacheSize(size uint) RelaySubscribeOption

+ func WithoutConsumer() RelaySubscribeOption

+ type RelaySubscribeParameters struct

type Subscription

+ ID int

+ func NewSubscription(contentFilter protocol.ContentFilter) *Subscription

+ func (s *Subscription) Submit(ctx context.Context, msg *protocol.Envelope)

+ type SubscriptionType int

+ const AllContentTopics

+ const SpecificContentTopics

+ type Subscriptions struct

type WakuRelay

+ func (w *WakuRelay) CreateEventEmitters() error

+ func (w *WakuRelay) GetSubscription(contentTopic string) (*Subscription, error)

+ func (w *WakuRelay) GetSubscriptionWithPubsubTopic(pubsubTopic string, contentTopic string) (*Subscription, error)

Oct 7, 2023

Changes in this version

+ const PEER_JOINED

+ const PEER_LEFT

+ type EvtPeerTopic struct

+ PeerID peer.ID

+ PubsubTopic string

+ State PeerTopicState

type EvtRelaySubscribed

+ TopicInst *pubsub.Topic

+ type PeerTopicState int

Sep 17, 2023

Changes in this version

+ type EvtRelaySubscribed struct

+ Topic string

+ type EvtRelayUnsubscribed struct

+ Topic string

+ type Metrics interface

+ RecordMessage func(envelope *waku_proto.Envelope)

type WakuRelay

+ func (w *WakuRelay) Events() event.Bus

+ func (w *WakuRelay) RegisterDefaultValidator(fn validatorFn)

+ func (w *WakuRelay) RegisterTopicValidator(topic string, fn validatorFn)

+ func (w *WakuRelay) RemoveTopicValidator(topic string)

Jun 26, 2023

Changes in this version

type WakuRelay

+ func (w *WakuRelay) Params() pubsub.GossipSubParams

May 12, 2023

Changes in this version

+ const MessageWindowDuration

+ func MsgHash(pubSubTopic string, msg *pb.WakuMessage) []byte

+ func NewBroadcaster(bufLen int) *broadcaster

+ func PrivKeyToTopic(privKey *ecdsa.PrivateKey) string

+ func SignMessage(privKey *ecdsa.PrivateKey, msg *pb.WakuMessage) error

+ type Broadcaster interface

+ Register func(topic string, chLen ...int) Subscription

+ RegisterForAll func(chLen ...int) Subscription

+ Start func(ctx context.Context) error

+ Stop func()

+ Submit func(*protocol.Envelope)

type Subscription

+ Ch <-chan *protocol.Envelope

+ func ArraySubscription(msgs []*protocol.Envelope) Subscription

+ func NoopSubscription() Subscription

type WakuRelay

+ func (w *WakuRelay) AddSignedTopicValidator(topic string, address common.Address) error

+ func (w *WakuRelay) IsSubscribed(topic string) bool

+ func (w *WakuRelay) SetHost(h host.Host)

Jan 23, 2023

Changes in this version

type WakuRelay

+ func (w *WakuRelay) Start(ctx context.Context) error

Dec 21, 2022

Changes in this version

+ const WakuRelayID_v200

+ var DefaultWakuTopic string = waku_proto.DefaultPubsubTopic().String()

+ type Subscription struct

+ C chan *protocol.Envelope

+ func (subs *Subscription) IsClosed() bool

+ func (subs *Subscription) Unsubscribe()

+ type WakuRelay struct

+ func NewWakuRelay(ctx context.Context, h host.Host, bcaster v2.Broadcaster, ...) (*WakuRelay, error)

+ func (w *WakuRelay) EnoughPeersToPublish() bool

+ func (w *WakuRelay) EnoughPeersToPublishToTopic(topic string) bool

+ func (w *WakuRelay) PubSub() *pubsub.PubSub

+ func (w *WakuRelay) Publish(ctx context.Context, message *pb.WakuMessage) ([]byte, error)

+ func (w *WakuRelay) PublishToTopic(ctx context.Context, message *pb.WakuMessage, topic string) ([]byte, error)

+ func (w *WakuRelay) SetPubSub(pubSub *pubsub.PubSub)

+ func (w *WakuRelay) Stop()

+ func (w *WakuRelay) Subscribe(ctx context.Context) (*Subscription, error)

+ func (w *WakuRelay) SubscribeToTopic(ctx context.Context, topic string) (*Subscription, error)

+ func (w *WakuRelay) Topics() []string

+ func (w *WakuRelay) Unsubscribe(ctx context.Context, topic string) error