This section is empty.


This section is empty.


This section is empty.


type Dispatcher

type Dispatcher struct {

    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.

    func New

    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 (*Dispatcher) Start

      func (ed *Dispatcher) Start() error

        Start starts the dispatcher

        type SeekEvent

        type SeekEvent struct {
        	SeekInfo *ab.SeekInfo
        	ErrCh    chan<- error

          SeekEvent is a SeekInfo request to the deliver server

          func NewSeekEvent

          func NewSeekEvent(seekInfo *ab.SeekInfo, errch chan<- error) *SeekEvent

            NewSeekEvent returns a new SeekRequestEvent