channelmanager

Documentation

Index

• type ChannelManager
  • func NewChannelManager(client lnrpc.LightningClient) *ChannelManager
  • func (cm *ChannelManager) GetAllChannels() []*lnrpc.Channel
  • func (cm *ChannelManager) GetChannelById(chanId uint64) *lnrpc.Channel
  • func (cm *ChannelManager) GetFeeChangeChannel() <-chan FeeChangeEvent
  • func (cm *ChannelManager) GetPendingHTLCs() map[*lnrpc.Channel][]*lnrpc.HTLC
  • func (cm *ChannelManager) GetRefreshChannel() <-chan struct{}
  • func (cm *ChannelManager) RefreshNow() error
  • func (cm *ChannelManager) SetRefreshInterval(interval time.Duration)
  • func (cm *ChannelManager) Start() error
  • func (cm *ChannelManager) Stop()
• type FeeChangeEvent
• type PendingChannelManager
  • func NewPendingChannelManager(client lnrpc.LightningClient, pendingUpdates chan proto.Message) *PendingChannelManager
  • func (cm *PendingChannelManager) RefreshDelayed()
  • func (cm *PendingChannelManager) Start() error
  • func (cm *PendingChannelManager) Stop()

Types

type ChannelManager

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

func NewChannelManager

func NewChannelManager(client lnrpc.LightningClient) *ChannelManager

func (*ChannelManager) GetAllChannels

func (cm *ChannelManager) GetAllChannels() []*lnrpc.Channel

GetAllChannels returns a slice of all managed channels

func (*ChannelManager) GetChannelById

func (cm *ChannelManager) GetChannelById(chanId uint64) *lnrpc.Channel

GetChannelById retrieves a channel by its ID

func (*ChannelManager) GetFeeChangeChannel

func (cm *ChannelManager) GetFeeChangeChannel() <-chan FeeChangeEvent

GetFeeChangeChannel returns the channel for receiving fee change events

func (*ChannelManager) GetPendingHTLCs

func (cm *ChannelManager) GetPendingHTLCs() map[*lnrpc.Channel][]*lnrpc.HTLC

func (*ChannelManager) GetRefreshChannel

func (cm *ChannelManager) GetRefreshChannel() <-chan struct{}

GetRefreshChannel returns the channel that signals when a refresh has occurred

func (*ChannelManager) RefreshNow

func (cm *ChannelManager) RefreshNow() error

RefreshNow triggers an immediate refresh of channel states

func (*ChannelManager) SetRefreshInterval

func (cm *ChannelManager) SetRefreshInterval(interval time.Duration)

SetRefreshInterval sets the interval for periodic channel state refreshes

func (*ChannelManager) Start

func (cm *ChannelManager) Start() error

Start initializes the channel manager and begins periodic refreshes

func (*ChannelManager) Stop

func (cm *ChannelManager) Stop()

Stop stops the channel manager

type FeeChangeEvent

type FeeChangeEvent struct {
	Channel     *lnrpc.Channel
	ChannelEdge *lnrpc.ChannelEdge
	Timestamp   time.Time

	OldFeeRate int64
	NewFeeRate int64

	OldBaseFee int64
	NewBaseFee int64

	OldInboundFeeRate int32
	NewInboundFeeRate int32

	OldInboundBaseFee int32
	NewInboundBaseFee int32
}

FeeChangeEvent represents a change in a channel's fee policy

type PendingChannelManager

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

func NewPendingChannelManager

func NewPendingChannelManager(client lnrpc.LightningClient, pendingUpdates chan proto.Message) *PendingChannelManager

func (*PendingChannelManager) RefreshDelayed

func (cm *PendingChannelManager) RefreshDelayed()

RefreshDelayed refreshes the pending channels after a short delay to avoid data inconsistencies that may occur when called immediately after a channel event is received (e.g., missing closing txid and hex for closed channels).

func (*PendingChannelManager) Start

func (cm *PendingChannelManager) Start() error

func (*PendingChannelManager) Stop

func (cm *PendingChannelManager) Stop()