Versions in this module Expand all Collapse all v0 v0.0.2 Jan 22, 2021 v0.0.1 Jan 22, 2021 Changes in this version + var Deliver = func(client pb.DeliverClient) (deliverStream, func(), error) + var DeliverFiltered = func(client pb.DeliverClient) (deliverStream, func(), error) + type DeliverConnection struct + func New(ctx fabcontext.Client, chConfig fab.ChannelCfg, streamProvider StreamProvider, ...) (*DeliverConnection, error) + func (c *DeliverConnection) Receive(eventch chan<- interface{}) + func (c *DeliverConnection) Send(seekInfo *ab.SeekInfo) error + type Event struct + Event interface{} + SourceURL string + func NewEvent(event interface{}, sourceURL string) *Event + type StreamProvider func(pb.DeliverClient) (stream deliverStream, cancel func(), err error)
Go to main page