dispatcher

package
v0.0.1-bate.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 13, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dispatcher

type Dispatcher struct {
	*clientdisp.Dispatcher
}

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL