Documentation
¶
Index ¶
Constants ¶
View Source
const ( // migration state for channel MigrationStateInitialized int = 0 MigrationStateSubmitted int = 1 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MigrateChannelProcessor ¶
type MigrateChannelProcessor struct {
// contains filtered or unexported fields
}
MigrateChannelProcessor defines the structure of channel's CelerLedger migration processor
func NewMigrateChannelProcessor ¶
func NewMigrateChannelProcessor( nodeConfig common.GlobalNodeConfig, signer eth.Signer, dal *storage.DAL, connectionMgr *rpc.ConnectionManager, monitorService intfs.MonitorService, isOsp bool) *MigrateChannelProcessor
NewMigrateChannelProcessor returns a migrate-ledger processor
func (*MigrateChannelProcessor) CheckPeerChannelMigration ¶
func (p *MigrateChannelProcessor) CheckPeerChannelMigration(peer ctype.Addr)
CheckPeerChannelMigration gets all channels of peer and migrates each channel (TODO): consider that everytime client gets online, need to check migration process(?performance?)
func (*MigrateChannelProcessor) ProcessMigrateChannelRequest ¶
func (p *MigrateChannelProcessor) ProcessMigrateChannelRequest(req *rpc.MigrateChannelRequest) (*rpc.MigrateChannelResponse, error)
ProcessMigrateChannelRequest processes migrate channel request
Source Files
Click to show internal directories.
Click to hide internal directories.