automation

Documentation

Index

• Variables
• func AddRebalanceAndChannels(db *sqlx.DB, rebalancer *Rebalancer) error
• func AddRebalanceLog(db *sqlx.DB, rebalanceResult RebalanceResult) error
• func CronTriggerMonitor(ctx context.Context, db *sqlx.DB)
• func EventTriggerMonitor(ctx context.Context, db *sqlx.DB, broadcaster broadcast.BroadcastServer)
• func ManagedRebalanceCache(ch chan ManagedRebalance, ctx context.Context)
• func RebalanceServiceStart(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int, ...)
• func RegisterAutomationRoutes(r *gin.RouterGroup, db *sqlx.DB, ...)
• func ScheduledTriggerMonitor(ctx context.Context, db *sqlx.DB, lightningRequestChannel chan interface{}, ...)
• func SendToManagedRebalanceChannel(ch chan ManagedRebalance, managedRebalance ManagedRebalance)
• func SendToManagedRebalanceResultChannel(ch chan RebalanceResult, rebalanceResult RebalanceResult)
• func SendToRebalancersChannel(ch chan []*Rebalancer, rebalancers []*Rebalancer)
• func SetRebalanceAndChannels(db *sqlx.DB, rebalancer Rebalancer) error
• func TimeTriggerMonitor(ctx context.Context, db *sqlx.DB)
• type CronTriggerParams
• type ManagedRebalance
• type ManagedRebalanceCacheOperationType
• type RebalanceResult
• type RebalanceRunner
• type Rebalancer

Variables

var ManagedRebalanceChannel = make(chan ManagedRebalance) //nolint:gochecknoglobals

Functions

func AddRebalanceAndChannels

func AddRebalanceAndChannels(db *sqlx.DB, rebalancer *Rebalancer) error

func AddRebalanceLog

func AddRebalanceLog(db *sqlx.DB, rebalanceResult RebalanceResult) error

func CronTriggerMonitor

func CronTriggerMonitor(ctx context.Context, db *sqlx.DB)

func EventTriggerMonitor

func EventTriggerMonitor(ctx context.Context, db *sqlx.DB,
	broadcaster broadcast.BroadcastServer)

func ManagedRebalanceCache

func ManagedRebalanceCache(ch chan ManagedRebalance, ctx context.Context)

func RebalanceServiceStart

func RebalanceServiceStart(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int,
	broadcaster broadcast.BroadcastServer)

func RegisterAutomationRoutes

func RegisterAutomationRoutes(r *gin.RouterGroup, db *sqlx.DB, rebalanceRequestChannel chan commons.RebalanceRequest)

func ScheduledTriggerMonitor

func ScheduledTriggerMonitor(ctx context.Context, db *sqlx.DB,
	lightningRequestChannel chan interface{},
	rebalanceRequestChannel chan commons.RebalanceRequest)

func SendToManagedRebalanceChannel

func SendToManagedRebalanceChannel(ch chan ManagedRebalance, managedRebalance ManagedRebalance)

func SendToManagedRebalanceResultChannel

func SendToManagedRebalanceResultChannel(ch chan RebalanceResult, rebalanceResult RebalanceResult)

func SendToRebalancersChannel

func SendToRebalancersChannel(ch chan []*Rebalancer, rebalancers []*Rebalancer)

func SetRebalanceAndChannels

func SetRebalanceAndChannels(db *sqlx.DB, rebalancer Rebalancer) error

func TimeTriggerMonitor

func TimeTriggerMonitor(ctx context.Context, db *sqlx.DB)

Types

type CronTriggerParams

type CronTriggerParams struct {
	CronValue string `json:"cronValue"`
}

type ManagedRebalance

type ManagedRebalance struct {
	Type               ManagedRebalanceCacheOperationType
	Origin             commons.RebalanceRequestOrigin
	OriginId           int
	OriginReference    string
	IncomingChannelId  int
	IncomingPublicKey  string
	OutgoingChannelId  int
	OutgoingPublicKey  string
	AmountMsat         uint64
	Status             *commons.Status
	Rebalancer         *Rebalancer
	RebalanceResult    RebalanceResult
	Out                chan ManagedRebalance
	BoolOut            chan bool
	RebalanceResultOut chan RebalanceResult
	RebalancersOut     chan []*Rebalancer
}

type ManagedRebalanceCacheOperationType

type ManagedRebalanceCacheOperationType uint

const (
	READ_REBALANCER ManagedRebalanceCacheOperationType = iota
	READ_REBALANCERS
	WRITE_REBALANCER
	DELETE_REBALANCER
	READ_REBALANCE_RESULT
	READ_REBALANCE_RESULT_BY_ORIGIN
	WRITE_REBALANCE_RESULT
)

type RebalanceResult

type RebalanceResult struct {
	RebalanceId       int            `json:"rebalanceId"`
	OutgoingChannelId int            `json:"outgoingChannelId"`
	IncomingChannelId int            `json:"incomingChannelId"`
	Status            commons.Status `json:"status"`
	Hops              string         `json:"hops"`
	TotalTimeLock     uint32         `json:"total_time_lock"`
	TotalFeeMsat      uint64         `json:"total_fee_msat"`
	TotalAmountMsat   uint64         `json:"total_amount_msat"`
	Error             string         `json:"error"`
	CreatedOn         time.Time      `json:"createdOn"`
	UpdateOn          time.Time      `json:"updateOn"`

	Route *lnrpc.Route `json:"-"`
}

type RebalanceRunner

type RebalanceRunner struct {
	RebalanceId       int
	OutgoingChannelId int
	IncomingChannelId int
	Invoices          map[uint64]*lnrpc.AddInvoiceResponse
	// FailedHops map[hopSourcePublicKey_hopDestinationPublicKey]amountMsat
	FailedHops  map[string]uint64
	FailedPairs []*lnrpc.NodePair
	Status      commons.Status
	Ctx         context.Context
	Cancel      context.CancelFunc
}

type Rebalancer

type Rebalancer struct {
	NodeId          int
	RebalanceId     int
	Status          commons.Status
	CreatedOn       time.Time
	UpdateOn        time.Time
	GlobalCtx       context.Context
	RebalanceCtx    context.Context
	RebalanceCancel context.CancelFunc
	Runners         map[int]*RebalanceRunner
	Request         commons.RebalanceRequest
}