rpc

Aug 21, 2021

Changes in this version

type PublishOption

+ func WithRepublishing(enable bool) PublishOption

Jul 22, 2021

Changes in this version

+ var ErrResponseNotReceived = errors.New("response not received")

+ type EventHandler func(from peer.ID, topic string, msg []byte)

+ type MessageHandler func(from peer.ID, topic string, msg []byte) ([]byte, error)

+ type PublishOption func(*PublishOptions) error

+ func WithIgnoreResponse(enable bool) PublishOption

+ func WithMultiResponse(enable bool) PublishOption

+ func WithPubOpts(opts ...pubsub.PubOpt) PublishOption

+ type PublishOptions struct

+ type Response struct

+ Data []byte

+ Err error

+ From peer.ID

+ ID string

+ type Topic struct

+ func NewTopic(ctx context.Context, ps *pubsub.PubSub, host peer.ID, topic string, ...) (*Topic, error)

+ func (t *Topic) Close() error

+ func (t *Topic) Publish(ctx context.Context, data []byte, opts ...PublishOption) (<-chan Response, error)

+ func (t *Topic) SetEventHandler(handler EventHandler)

+ func (t *Topic) SetMessageHandler(handler MessageHandler)