cobj

package
v1.2.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CelerGlobalNodeConfig 

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

func NewCelerGlobalNodeConfig 

func NewCelerGlobalNodeConfig(
	onchainAddr ctype.Addr,
	ethconn *ethclient.Client,
	profile *common.CProfile,
	walletABI string,
	ledgerABI string,
	virtResolverABI string,
	payResolverABI string,
	payRegistryABI string,
	routerRegistryABI string,
	chanDAL chanLedgerDAL) *CelerGlobalNodeConfig

func (*CelerGlobalNodeConfig) GetAllLedgerContracts 

func (config *CelerGlobalNodeConfig) GetAllLedgerContracts() map[ctype.Addr]chain.Contract

GetAllLedgerContracts returns a map with key being ledger addresses in profile and ledger contract bound to to the address.

func (*CelerGlobalNodeConfig) GetCheckInterval 

func (cfg *CelerGlobalNodeConfig) GetCheckInterval(eventName string) uint64

GetCheckInterval returns interval if set in profile or 0 monitor will treat 0 as check log every blockIntervalSec

func (*CelerGlobalNodeConfig) GetEthConn 

func (config *CelerGlobalNodeConfig) GetEthConn() *ethclient.Client

func (*CelerGlobalNodeConfig) GetEthPoolAddr 

func (config *CelerGlobalNodeConfig) GetEthPoolAddr() ctype.Addr

func (*CelerGlobalNodeConfig) GetLedgerContract 

func (config *CelerGlobalNodeConfig) GetLedgerContract() chain.Contract

func (*CelerGlobalNodeConfig) GetLedgerContractOf 

func (config *CelerGlobalNodeConfig) GetLedgerContractOf(cid ctype.CidType) chain.Contract

GetLedgerContractOf returns ledger contract object of which address is used by the cid.

func (*CelerGlobalNodeConfig) GetLedgerContractOn 

func (config *CelerGlobalNodeConfig) GetLedgerContractOn(addr ctype.Addr) chain.Contract

GetLedgerContractOn returns ledger contract on addr. The addr must exist in profile ledger address map. It will return nil otherwise.

func (*CelerGlobalNodeConfig) GetOnChainAddr 

func (config *CelerGlobalNodeConfig) GetOnChainAddr() ctype.Addr

func (*CelerGlobalNodeConfig) GetPayRegistryContract 

func (config *CelerGlobalNodeConfig) GetPayRegistryContract() chain.Contract

func (*CelerGlobalNodeConfig) GetPayResolverContract 

func (config *CelerGlobalNodeConfig) GetPayResolverContract() chain.Contract

func (*CelerGlobalNodeConfig) GetRPCAddr 

func (config *CelerGlobalNodeConfig) GetRPCAddr() string

func (*CelerGlobalNodeConfig) GetRouterRegistryContract 

func (config *CelerGlobalNodeConfig) GetRouterRegistryContract() chain.Contract

GetRouterRegistryContract gets the router registry contract info including ethclient, address and ABI

func (*CelerGlobalNodeConfig) GetSvrName 

func (config *CelerGlobalNodeConfig) GetSvrName() string

func (*CelerGlobalNodeConfig) GetVirtResolverContract 

func (config *CelerGlobalNodeConfig) GetVirtResolverContract() chain.Contract

func (*CelerGlobalNodeConfig) GetWalletContract 

func (config *CelerGlobalNodeConfig) GetWalletContract() chain.Contract

type CelerStreamWriter 

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

func NewCelerStreamWriter 

func NewCelerStreamWriter(connManager *rpc.ConnectionManager) *CelerStreamWriter

func (*CelerStreamWriter) WriteCelerMsg 

func (w *CelerStreamWriter) WriteCelerMsg(peerTo ctype.Addr, msg *rpc.CelerMsg) 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.