core

type MessageHandler ¶

type MessageHandler func(data *pubsub.Message)

type MessageTransport ¶

type MessageTransport struct {
	Data []byte
}

type PubSubWrapper ¶

type PubSubWrapper struct {
	// A channel of signed transactions to send new pending transactions to peers
	Data      chan MessageTransport
	TopicName string
	Context   context.Context
	PubSub    *pubsub.PubSub
	Topic     *pubsub.Topic
	Sub       *pubsub.Subscription
	Self      peer.ID
}

PubSubWrapper represents a subscription to a single PubSub topic. Messages can be published to the topic with PubSubWrapper.Publish, and received messages are pushed to the Messages channel. TODO this name is bad... but works for now..

func (cr *PubSubWrapper) ListPeers(ps *pubsub.PubSub) []peer.ID

func (cr *PubSubWrapper) Publish(ctx context.Context, msgChan chan MessageTransport) error

func (cr *PubSubWrapper) ReadLoop(ctx context.Context, onMessage MessageHandler)

type PublishHandler ¶

type PublishHandler func(msg []byte)