dispatcher

package
v0.0.0-...-7c2dc49 Latest Latest
Warning

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

Go to latest
Published: Oct 25, 2022 License: Apache-2.0 Imports: 9 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 interface {
	// Start starts the Dispatcher's routine.
	Start() error

	// Stop stops the dispatcher.
	Stop()

	// AddToQueue adds a message to the queue for process.
	AddToQueue(link string, auth *bind.TransactOpts, id string, destID *big.Int, esAddr common.Address, srcID *big.Int, srcAddr common.Address, rawData []byte, signature []byte)
}

Dispatcher is the interface to a componenet to dispatch requests from threads.

func NewDispatcherImplV1

func NewDispatcherImplV1() Dispatcher

NewDispatcherImplV1 creates a new dispatcher.

type DispatcherImplV1

type DispatcherImplV1 struct {
	// contains filtered or unexported fields
}

DispatcherImplV1 implements dispatcher interface.

func (*DispatcherImplV1) AddToQueue

func (d *DispatcherImplV1) AddToQueue(link string, auth *bind.TransactOpts, id string, destID *big.Int, esAddr common.Address, srcID *big.Int, srcAddr common.Address, rawData []byte, signature []byte)

AddToQueue adds a message to the queue for process.

func (*DispatcherImplV1) Start

func (d *DispatcherImplV1) Start() error

Start starts the Dispatcher's routine.

func (*DispatcherImplV1) Stop

func (d *DispatcherImplV1) Stop()

Stop stops the dispatcher.

type Item

type Item struct {
	// contains filtered or unexported fields
}

Item represents an item in the queue.

Jump to

Keyboard shortcuts

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