crdt

type Broadcaster interface {
	Broadcast(ctx context.Context, data []byte) error
	Next(ctx context.Context) ([]byte, error)
}

type CRDTRouter interface {
	FindProvidersAsync(context.Context, cid.Cid, int) <-chan peer.AddrInfo
}

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

type CRDTStorer interface {
	ds.Datastore
	Prefix() string
}

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

type GossipPubSuber interface {
	PublishRaw(topicName string, data []byte) error
	SubscribeRaw(topicName string, h func([]byte) error) error
}