msghdl

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: May 2, 2026 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CondPayRequestMsgName   = "CondPayRequestMessage"
	PaySettleProofMsgName   = "PaySettleProofMessage"
	PaySettleRequestMsgName = "PaySettleRequestMessage"
	HopAckStateMsgName      = "HopAckStateMessage"
	RevealSecretMsgName     = "RevealSecretMessage"
	RevealSecretAckMsgName  = "RevealSecretAckMessage"
	CondPayReceiptMsgName   = "CondPayReceiptMessage"
	CondPayResultMsgName    = "CondPayResultMessage"
	WithdrawRequestMsgName  = "WithdrawRequestMessage"
	WithdrawResponseMsgName = "WithdrawResponseMessage"
	RoutingRequestMsgName   = "RoutingRequestMessage"
	UnkownMsgName           = "UnkownMessage"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CelerMsgHandler 

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

func NewCelerMsgHandler 

func NewCelerMsgHandler(
	nodeConfig common.GlobalNodeConfig,
	streamWriter common.StreamWriter,
	signer eth.Signer,
	monitorService intfs.MonitorService,
	serverForwarder handlers.ForwardToServerCallback,
	onReceivingToken event.OnReceivingTokenCallback,
	tokenCallbackLock *sync.RWMutex,
	onSendingToken event.OnSendingTokenCallback,
	sendingCallbackLock *sync.RWMutex,
	disputer *dispute.Processor,
	cooperativeWithdraw CooperativeWithdraw,
	routeForwarder *route.Forwarder,
	routeController *route.Controller,
	messager *messager.Messager,
	dal *storage.DAL,
	isOSP bool,
) *CelerMsgHandler

func (*CelerMsgHandler) GetMsgName 

func (h *CelerMsgHandler) GetMsgName() string

func (*CelerMsgHandler) HandleCondPayReceipt 

func (h *CelerMsgHandler) HandleCondPayReceipt(frame *common.MsgFrame) error

func (*CelerMsgHandler) HandleCondPayRequest 

func (h *CelerMsgHandler) HandleCondPayRequest(frame *common.MsgFrame) error

func (*CelerMsgHandler) HandleHopAckState 

func (h *CelerMsgHandler) HandleHopAckState(frame *common.MsgFrame) error

func (*CelerMsgHandler) HandleMysimplexFromAuthAck 

func (h *CelerMsgHandler) HandleMysimplexFromAuthAck(tx *storage.DALTx, cid ctype.CidType, ackState *rpc.SignedSimplexState) error

HandleMysimplexFromAuthAck calls internal funcs to update db and go over msg queue note when this is called by handleAuthAck, msgqueue doesn't have the peer in memory yet

func (*CelerMsgHandler) HandlePaySettleProof 

func (h *CelerMsgHandler) HandlePaySettleProof(frame *common.MsgFrame) error

func (*CelerMsgHandler) HandlePaySettleRequest 

func (h *CelerMsgHandler) HandlePaySettleRequest(frame *common.MsgFrame) error

func (*CelerMsgHandler) HandleRevealSecret 

func (h *CelerMsgHandler) HandleRevealSecret(frame *common.MsgFrame) error

func (*CelerMsgHandler) HandleRevealSecretAck 

func (h *CelerMsgHandler) HandleRevealSecretAck(frame *common.MsgFrame) error

func (*CelerMsgHandler) HandleRoutingRequest 

func (h *CelerMsgHandler) HandleRoutingRequest(frame *common.MsgFrame) error

func (*CelerMsgHandler) Run 

func (h *CelerMsgHandler) Run(frame *common.MsgFrame) error

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.