Dispatcher is responsible for handling all events, including connection and registration events originating from the client, and events originating from the channel event service. All events are processed in a single Go routine in order to avoid any race conditions and to ensure that events are processed in the order that they are received. This also avoids the need for synchronization.
type Dispatcher struct {
*clientdisp.Dispatcher
}
func New(context fabcontext.Client, chConfig fab.ChannelCfg, discoveryService fab.DiscoveryService, connectionProvider api.ConnectionProvider, opts ...options.Opt) *Dispatcher
New returns a new deliver dispatcher
func (ed *Dispatcher) Start() error
Start starts the dispatcher
SeekEvent is a SeekInfo request to the deliver server
type SeekEvent struct {
SeekInfo *ab.SeekInfo
ErrCh chan<- error
}
func NewSeekEvent(seekInfo *ab.SeekInfo, errch chan<- error) *SeekEvent
NewSeekEvent returns a new SeekRequestEvent