dispatchers

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2026 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CelerMsgDispatcher 

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

func NewCelerMsgDispatcher 

func NewCelerMsgDispatcher(
	nodeConfig common.GlobalNodeConfig,
	streamWriter common.StreamWriter,
	signer eth.Signer,
	monitorService intfs.MonitorService,
	dal *storage.DAL,
	cooperativeWithdraw CooperativeWithdraw,
	serverForwarder handlers.ForwardToServerCallback,
	disputer *dispute.Processor,
	routeForwarder *route.Forwarder,
	routeController *route.Controller,
	messager *messager.Messager,
	isOSP bool,
) *CelerMsgDispatcher

func (*CelerMsgDispatcher) NewMsgHandler 

func (d *CelerMsgDispatcher) NewMsgHandler() *msghdl.CelerMsgHandler

func (*CelerMsgDispatcher) NewStream 

func (d *CelerMsgDispatcher) NewStream(peerAddr ctype.Addr) chan *rpc.CelerMsg

func (*CelerMsgDispatcher) OnReceivingToken 

func (d *CelerMsgDispatcher) OnReceivingToken(callback event.OnReceivingTokenCallback)

func (*CelerMsgDispatcher) OnSendingToken 

func (d *CelerMsgDispatcher) OnSendingToken(callback event.OnSendingTokenCallback)

func (*CelerMsgDispatcher) Start 

func (d *CelerMsgDispatcher) Start(input chan *rpc.CelerMsg, peerAddr ctype.Addr)

func (*CelerMsgDispatcher) Stop 

func (d *CelerMsgDispatcher) Stop()

type CooperativeWithdraw 

type CooperativeWithdraw interface {
	ProcessRequest(*common.MsgFrame) error
	ProcessResponse(*common.MsgFrame) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.