pubsubconn

type Chain interface {
	HandleTrx(trx *chestnutpb.Trx) error
	HandleBlock(block *chestnutpb.Block) error
}

type P2pPubSubConn struct {
	Cid          string
	Topic        *pubsub.Topic
	Subscription *pubsub.Subscription

	Ctx context.Context
	// contains filtered or unexported fields
}

type PubSubConn interface {
	JoinChannel(cId string, chain Chain) error
	Publish(data []byte) error
}