hub

Documentation

Index

• type Message
  • func NewMessage(s string) *Message
  • func (m *Message) Apply(opts ...MessageOption) error
  • func (m *Message) Copy() *Message
  • func (m *Message) WithMessage(s string) *Message
• type MessageHub
  • func NewHub(otp string, maxsize, keyLength, interval int) *MessageHub
  • func (m *MessageHub) ListPeers() ([]peer.ID, error)
  • func (m *MessageHub) PublishMessage(mess *Message) error
  • func (m *MessageHub) Start(ctx context.Context, host host.Host) error
• type MessageOption

Types

type Message

type Message struct {
	Message  string
	SenderID string

	Annotations map[string]string
}

Message gets converted to/from JSON and sent in the body of pubsub messages.

func NewMessage

func NewMessage(s string) *Message

func (*Message) Apply

func (m *Message) Apply(opts ...MessageOption) error

Apply applies the given options to the config, returning the first error encountered (if any).

func (*Message) Copy

func (m *Message) Copy() *Message

func (*Message) WithMessage

func (m *Message) WithMessage(s string) *Message

type MessageHub

type MessageHub struct {
	sync.Mutex

	Messages chan *Message
	// contains filtered or unexported fields
}

func NewHub

func NewHub(otp string, maxsize, keyLength, interval int) *MessageHub

func (*MessageHub) ListPeers

func (m *MessageHub) ListPeers() ([]peer.ID, error)

func (*MessageHub) PublishMessage

func (m *MessageHub) PublishMessage(mess *Message) error

func (*MessageHub) Start

func (m *MessageHub) Start(ctx context.Context, host host.Host) error

type MessageOption

type MessageOption func(cfg *Message) error