libp2p

Documentation

Index

• type PubSub
  • func NewPubSub[T any](params PubSubParams) (*PubSub[T], error)
  • func (p *PubSub[T]) Close(ctx context.Context) (err error)
  • func (p *PubSub[T]) Publish(ctx context.Context, message T) error
  • func (p *PubSub[T]) Subscribe(ctx context.Context, subscriber pubsub.Subscriber[T]) (err error)
• type PubSubParams

Types

type PubSub

type PubSub[T any] struct {
	// contains filtered or unexported fields
}

func NewPubSub

func NewPubSub[T any](params PubSubParams) (*PubSub[T], error)

func (*PubSub[T]) Close

func (p *PubSub[T]) Close(ctx context.Context) (err error)

func (*PubSub[T]) Publish

func (p *PubSub[T]) Publish(ctx context.Context, message T) error

func (*PubSub[T]) Subscribe

func (p *PubSub[T]) Subscribe(ctx context.Context, subscriber pubsub.Subscriber[T]) (err error)

type PubSubParams

type PubSubParams struct {
	Host        host.Host
	TopicName   string
	PubSub      *libp2p_pubsub.PubSub
	IgnoreLocal bool
}