Versions in this module Expand all Collapse all v1 v1.0.1 Oct 17, 2020 Changes in this version + var DialTimeout = time.Second * 10 + var EventBusCapacity = 1 + var InitialPullInterval = time.Second + var MaxPullLimit = 10000 + var PullInterval = time.Second * 10 + var PullStartAfter = time.Second + var PullTimeout = time.Second * 10 + var PushTimeout = time.Second * 10 + func NewNetwork(ctx context.Context, h host.Host, bstore bs.Blockstore, ds format.DAGService, ...) (app.Net, error) + func NewRecord(r core.Record, id thread.ID, lid peer.ID) core.ThreadRecord + type Config struct + Debug bool + PubSub bool + type Handler func(context.Context, *pb.PushRecordRequest) + type PubSub struct + func NewPubSub(ctx context.Context, host peer.ID, ps *pubsub.PubSub, handler Handler) *PubSub + func (s *PubSub) Add(id thread.ID) error + func (s *PubSub) Publish(ctx context.Context, id thread.ID, req *pb.PushRecordRequest) error + func (s *PubSub) Remove(id thread.ID) error + type Record struct + func (r *Record) LogID() peer.ID + func (r *Record) ThreadID() thread.ID + func (r *Record) Value() core.Record
Go to main page