p2psender

Documentation

Index

• type Option
  • func WithTopic(topic *pubsub.Topic) Option
• type Sender
  • func New(p2pHost host.Host, topicName string, options ...Option) (*Sender, error)
  • func (s *Sender) Close() error
  • func (s *Sender) Send(ctx context.Context, msg message.Message) error
  • func (s *Sender) TopicName() string

Types

type Option

type Option func(*config) error

Option is a function that sets a value in a config.

func WithTopic

func WithTopic(topic *pubsub.Topic) Option

WithTopic provides an existing pubsub topic.

type Sender

type Sender struct {
	// contains filtered or unexported fields
}

func New

func New(p2pHost host.Host, topicName string, options ...Option) (*Sender, error)

New creates a new Sender that sends announce messages over pubsub.

func (*Sender) Close

func (s *Sender) Close() error

Close stops the pubsub topic if the sender owns to topic.

func (*Sender) Send

func (s *Sender) Send(ctx context.Context, msg message.Message) error

Send sends the Message to the pubsub topic.

func (*Sender) TopicName

func (s *Sender) TopicName() string

TopicName returns the name of the topic that messages are sent to.