lightpush

Nov 14, 2023

Changes in this version

+ const LightPushENRField

type Option

+ func WithDefaultPubsubTopic() Option

Oct 7, 2023

Changes in this version

type Option

+ func WithPubSubTopic(pubsubTopic string) Option

Sep 17, 2023

Changes in this version

+ var ErrInvalidID = errors.New("invalid request id")

+ type Metrics interface

+ RecordError func(err metricsErrCategory)

+ RecordMessage func()

+ type Option func(*lightPushParameters)

+ func WithAutomaticRequestID() Option

+ func WithRequestID(requestID []byte) Option

May 12, 2023

Changes in this version

type WakuLightPush

+ func (wakuLP *WakuLightPush) SetHost(h host.Host)

Dec 21, 2022

Changes in this version

+ const LightPushID_v20beta1

+ var ErrInvalidId = errors.New("invalid request id")

+ var ErrNoPeersAvailable = errors.New("no suitable remote peers")

+ type LightPushOption func(*LightPushParameters)

+ func DefaultOptions(host host.Host) []LightPushOption

+ func WithAutomaticPeerSelection(fromThesePeers ...peer.ID) LightPushOption

+ func WithAutomaticRequestId() LightPushOption

+ func WithFastestPeerSelection(ctx context.Context, fromThesePeers ...peer.ID) LightPushOption

+ func WithPeer(p peer.ID) LightPushOption

+ func WithRequestId(requestId []byte) LightPushOption

+ type LightPushParameters struct

+ type WakuLightPush struct

+ func NewWakuLightPush(ctx context.Context, h host.Host, relay *relay.WakuRelay, log *zap.Logger) *WakuLightPush

+ func (wakuLP *WakuLightPush) IsStarted() bool

+ func (wakuLP *WakuLightPush) Publish(ctx context.Context, message *pb.WakuMessage, opts ...LightPushOption) ([]byte, error)

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

+ func (wakuLP *WakuLightPush) Start() error

+ func (wakuLP *WakuLightPush) Stop()