fabric-sdk-go: github.com/hyperledger/fabric-sdk-go/pkg/fab/events/deliverclient/dispatcher Index | Files

package dispatcher

import "github.com/hyperledger/fabric-sdk-go/pkg/fab/events/deliverclient/dispatcher"


Package Files

dispatcher.go events.go

type Dispatcher Uses

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 Uses

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 Uses

func (ed *Dispatcher) Start() error

Start starts the dispatcher

type SeekEvent Uses

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

SeekEvent is a SeekInfo request to the deliver server

func NewSeekEvent Uses

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

NewSeekEvent returns a new SeekRequestEvent

Package dispatcher imports 12 packages (graph) and is imported by 1 packages. Updated 2019-08-24. Refresh now. Tools for package owners.