commons

Feb 3, 2023

Changes in this version

+ const WorkflowParameterLabelManuallyTriggered

+ const WorkflowParameterTypeManuallyTriggered

+ func ActivateWorkflowTrigger(reference string, workflowVersionId int, cancel context.CancelFunc)

+ func DeactivateWorkflowTrigger(workflowVersionId int)

Feb 3, 2023

Changes in this version

+ const CronService

+ const LIGHTNING_COMMUNICATION_TIMEOUT_SECONDS

+ const TimedOut

+ const WorkflowNodeChannelCloseEventTrigger

+ const WorkflowNodeChannelOpenEventTrigger

+ const WorkflowNodeChannelPolicyAutoRun

+ const WorkflowNodeCronTrigger

+ const WorkflowNodeManualTrigger

+ const WorkflowNodeRebalanceAutoRun

+ const WorkflowNodeRebalanceConfigurator

+ const WorkflowParameterChannelFilter

+ const WorkflowParameterLabelIncomingChannels

+ const WorkflowParameterLabelOutgoingChannels

+ func ActivateEventTrigger(reference string, workflowVersionId int, triggeringWorkflowVersionNodeId int, ...)

+ func ActivateTimeTrigger(reference string, workflowVersionId int, cancel context.CancelFunc)

+ func DeactivateEventTrigger(workflowVersionId int, triggeringWorkflowVersionNodeId int, ...)

+ func DeactivateTimeTrigger(workflowVersionId int)

+ func GetAllTorqNodeIdsByNetwork(chain Chain, network Network) []int

+ func GetBlockHeight() uint32

+ func GetChannelStateChannelIds(nodeId int, forceResponse bool) []int

+ func GetDeltaPerMille(base uint64, amt uint64) int

+ func IsWorkflowNodeTypeGrouped(workflowNodeType WorkflowNodeType) bool

+ func ScheduleTrigger(reference string, workflowVersionId int, triggeringNodeType WorkflowNodeType, ...)

+ func SetBlockHeight(blockHeight uint32)

type ManagedChannelState

+ ChannelIdsOut chan []int

type ManagedChannelStateCacheOperationType

+ const READ_ALL_CHANNELSTATE_CHANNELIDS

type ManagedNodeCacheOperationType

+ const READ_ALL_TORQ_NODEIDS_ALL_NETWORKS

type ManagedSettings

+ BlockHeight uint32

+ MixpanelOptOut bool

+ TorqUuid string

type ManagedSettingsCacheOperationType

+ const WRITE_BLOCKHEIGHT

type ManagedTrigger

+ TriggeringEvent any

+ TriggeringNodeType WorkflowNodeType

type ManagedTriggerCacheOperationType

+ const POP_SCHEDULED_TRIGGER

+ const READ_EVENT_TRIGGER_SETTINGS

+ const READ_TIME_TRIGGER_SETTINGS

+ const WRITE_EVENT_TRIGGER

+ const WRITE_SCHEDULED_TRIGGER

+ const WRITE_TIME_TRIGGER

type ManagedTriggerSettings

+ SchedulingTime *time.Time

+ TriggeringEventQueue []any

+ TriggeringNodeType WorkflowNodeType

+ func GetEventTriggerSettingsByWorkflowVersionId(workflowVersionId int, triggeringWorkflowVersionNodeId int, ...) ManagedTriggerSettings

+ func GetScheduledTrigger() ManagedTriggerSettings

+ func GetTimeTriggerSettingsByWorkflowVersionId(workflowVersionId int) ManagedTriggerSettings

+ type ManualTriggerEvent struct

+ WorkflowVersionNodeId int

type NodeConnectionDetailCustomSettings

+ const ImportForwards

+ const ImportHistoricForwards

+ const ImportHtlcEvents

+ const ImportInvoices

+ const ImportPayments

+ const ImportPeerEvents

+ const ImportTransactions

type ServiceType

+ func (st *ServiceType) String() string

type Services

+ func (rs *Services) HasCustomSetting(nodeId int, customSetting NodeConnectionDetailCustomSettings) bool

+ func (rs *Services) SetNodeConnectionDetailCustomSettings(nodeId int, customSetting NodeConnectionDetailCustomSettings)

type SignMessageRequest

+ SingleHash *bool

type SignMessageResponse

+ func SignMessageWithTimeout(unixTime time.Time, nodeId int, message string, singleHash *bool, ...) SignMessageResponse

type SignatureVerificationResponse

+ Valid bool

+ func SignatureVerificationRequestWithTimeout(unixTime time.Time, nodeId int, message string, signature string, ...) SignatureVerificationResponse

type Status

+ func (s *Status) String() string

type SubscriptionStream

+ func (ss *SubscriptionStream) String() string

Jan 23, 2023

Changes in this version

+ const WorkflowParameterLabelChannelEventTriggered

+ const WorkflowParameterLabelChannels

+ const WorkflowParameterLabelDestinationChannels

+ const WorkflowParameterLabelRebalanceSettings

+ const WorkflowParameterLabelRoutingPolicySettings

+ const WorkflowParameterLabelSourceChannels

+ const WorkflowParameterLabelStatus

+ const WorkflowParameterLabelTagSettings

+ const WorkflowParameterLabelTimeTriggered

+ const WorkflowParameterTypeChannelEventTriggered

+ const WorkflowParameterTypeChannelIds

+ const WorkflowParameterTypeRebalanceSettings

+ const WorkflowParameterTypeRoutingPolicySettings

+ const WorkflowParameterTypeStatus

+ const WorkflowParameterTypeTagSettings

+ const WorkflowParameterTypeTimeTriggered

+ type WorkflowParameterLabel string

Jan 20, 2023

Changes in this version

+ const VECTOR_PING_URL_SUFFIX

+ const VECTOR_SHORTCHANNELID_URL_SUFFIX

+ const VECTOR_TRANSACTIONDETAILS_URL_SUFFIX

+ const WorkflowNodeAddTag

+ const WorkflowNodeRemoveTag

+ func GetVectorUrl(vectorUrl string, suffix string) string

Jan 17, 2023

Changes in this version

+ const WorkflowParameterTag

+ const WorkflowTag

Jan 13, 2023

Changes in this version

+ const MAINTENANCE_QUEUE_TICKER_SECONDS

+ const MAINTENANCE_VECTOR_DELAY_MILLISECONDS

+ const MaintenanceService

+ const VECTOR_TRANSACTIONDETAILS_URL

+ func GetShortChannelIdFromVector(fundingTransactionHash string, fundingOutputIndex int, ...) string

+ func MaintenanceServiceStart(ctx context.Context, db *sqlx.DB, nodeId int, ...)

type ManagedChannel

+ ClosedOn *time.Time

+ ClosingBlockHeight *int64

+ ClosingNodeId *int

+ ClosingTransactionHash *string

+ FundedOn *time.Time

+ FundingBlockHeight *int64

type ManagedChannelSettings

+ ClosedOn *time.Time

+ ClosingBlockHeight *int64

+ ClosingNodeId *int

+ ClosingTransactionHash *string

+ FundedOn *time.Time

+ FundingBlockHeight *int64

type ShortChannelIdHttpRequest

+ PublicKey string

+ type TransactionDetailsHttpRequest struct

+ PublicKey string

+ Signature string

+ TransactionHash string

+ UnixTime int64

+ type TransactionDetailsHttpResponse struct

+ BlockHash string

+ BlockHeight int64

+ BlockTimestamp time.Time

+ Request TransactionDetailsHttpRequest

+ TransactionCount int

+ TransactionIndex int

+ func GetTransactionDetailsFromVector(transactionHash string, nodeSettings ManagedNodeSettings, ...) TransactionDetailsHttpResponse

Jan 10, 2023

Changes in this version

+ const VECTOR_PING_URL

+ const VECTOR_SHORTCHANNELID_URL

+ const VECTOR_URL

type ManagedTrigger

+ TriggeringWorkflowVersionNodeId int

type ManagedTriggerSettings

+ TriggeringWorkflowVersionNodeId int

+ type ShortChannelIdHttpRequest struct

+ OutputIndex int

+ Signature string

+ TransactionHash string

+ UnixTime int64

+ type ShortChannelIdHttpResponse struct

+ Request ShortChannelIdHttpRequest

+ ShortChannelId string

+ type ShortChannelIdRequest struct

+ OutputIndex int

+ ResponseChannel chan ShortChannelIdResponse

+ TransactionHash string

+ type ShortChannelIdResponse struct

+ Request ShortChannelIdRequest

+ ShortChannelId string

+ type SignMessageRequest struct

+ Message string

+ ResponseChannel chan SignMessageResponse

+ type SignMessageResponse struct

+ Request SignMessageRequest

+ Signature string

+ type SignatureVerificationRequest struct

+ Message string

+ ResponseChannel chan SignatureVerificationResponse

+ Signature string

+ type SignatureVerificationResponse struct

+ PublicKey string

+ Request SignatureVerificationRequest

Jan 10, 2023

Changes in this version

+ func SendServiceEvent(nodeId int, eventChannel chan interface{}, previousStatus Status, ...)

Jan 9, 2023

Changes in this version

+ const Archived

+ const AutomationService

+ const LightningCommunicationService

+ const REBALANCE_MAXIMUM_CONCURRENCY

+ const REBALANCE_MINIMUM_DELTA_SECONDS

+ const REBALANCE_QUEUE_TICKER_SECONDS

+ const REBALANCE_REBALANCE_DELAY_MILLISECONDS

+ const REBALANCE_RESULTS_TIMEOUT_SECONDS

+ const REBALANCE_ROUTES_TIMEOUT_SECONDS

+ const REBALANCE_ROUTE_FAILED_HOP_ALLOWED_DELTA_PER_MILLE

+ const REBALANCE_ROUTE_TIMEOUT_SECONDS

+ const REBALANCE_RUNNER_TIMEOUT_SECONDS

+ const REBALANCE_SUCCESS_TIMEOUT_SECONDS

+ const REBALANCE_TIMEOUT_SECONDS

+ const ROUTING_POLICY_UPDATE_LIMITER_SECONDS

+ const RebalanceRequestManual

+ const RebalanceRequestWorkflowNode

+ const RebalanceService

+ const WORKFLOW_TICKER_SECONDS

+ const WorkflowNodeChannelBalanceEventTrigger

+ const WorkflowNodeChannelFilter

+ const WorkflowNodeChannelPolicyConfigurator

+ const WorkflowNodeChannelPolicyRun

+ const WorkflowNodeFilterOnVariable

+ const WorkflowNodeRebalanceParameters

+ const WorkflowNodeRebalanceRun

+ const WorkflowNodeSetVariable

+ const WorkflowNodeStageTrigger

+ const WorkflowNodeTimeTrigger

+ const WorkflowParameterAny

+ const WorkflowParameterBalanceShifted

+ const WorkflowParameterChannelIds

+ const WorkflowParameterRebalanceSettings

+ const WorkflowParameterRoutingPolicySettings

+ const WorkflowParameterStatus

+ const WorkflowParameterTimeInSeconds

+ const WorkflowParameterTriggered

+ const WorkflowParameterVariableName

+ const WorkflowParameterVariableValueNumber

+ const WorkflowParameterVariableValueString

+ const WorkflowTrigger

+ const WorkflowTriggerEventService

+ const WorkflowTriggerTimingService

+ var ManagedRebalanceChannel = make(chan ManagedRebalance)

+ var ManagedTriggerChannel = make(chan ManagedTrigger)

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

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

+ func CopyParameters(parameters map[string]string) map[string]string

+ func GetWorkflowNodes() map[WorkflowNodeType]WorkflowNodeTypeParameters

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

+ func ManagedTriggerCache(ch chan ManagedTrigger, ctx context.Context)

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

+ func SendToManagedBoolChannel(ch chan bool, result bool)

+ func SendToManagedNodeSettingChannel(ch chan ManagedNodeSettings, nodeSetting ManagedNodeSettings)

+ func SendToManagedRebalanceChannel(ch chan ManagedRebalance, managedRebalance ManagedRebalance)

+ func SendToManagedRebalanceResultChannel(ch chan RebalanceResult, rebalanceResult RebalanceResult)

+ func SendToManagedTriggerSettingsChannel(ch chan ManagedTriggerSettings, managedTriggerSettings ManagedTriggerSettings)

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

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

+ func SetTrigger(nodeId int, reference string, workflowVersionId int, ...)

+ func SetTriggerVerificationTime(nodeId int, workflowVersionId int, verificationTime time.Time)

+ type ChannelBalanceEvent struct

+ ChannelId int

+ PreviousEventData *ChannelBalanceEventData

+ type ChannelBalanceEventData struct

+ AggregatedLocalBalance int64

+ AggregatedLocalBalancePerMilleRatio int

+ Capacity int64

+ LocalBalance int64

+ LocalBalancePerMilleRatio int

+ RemoteBalance int64

+ type ChannelStatusUpdateRequest struct

+ ChannelId int

+ ChannelStatus Status

+ ResponseChannel chan ChannelStatusUpdateResponse

+ type ChannelStatusUpdateResponse struct

+ Request ChannelStatusUpdateRequest

type CloseChannelResponse

+ RequestId string

+ type CommunicationRequest struct

+ NodeId int

+ RequestId string

+ RequestTime *time.Time

+ type CommunicationResponse struct

+ Error string

+ Message string

+ Status Status

type ManagedNode

+ NodeSettingOut chan ManagedNodeSettings

+ NodeSettingsOut chan []ManagedNodeSettings

type ManagedNodeCacheOperationType

+ const READ_ALL_ACTIVE_TORQ_NODESETTINGS

+ const READ_NODE_SETTING

type ManagedNodeSettings

+ func GetActiveTorqNodeSettings() []ManagedNodeSettings

+ type ManagedRebalance struct

+ AmountMsat uint64

+ BoolOut chan bool

+ IncomingChannelId int

+ IncomingPublicKey string

+ Origin RebalanceRequestOrigin

+ OriginId int

+ OriginReference string

+ Out chan ManagedRebalance

+ OutgoingChannelId int

+ OutgoingPublicKey string

+ RebalanceResult RebalanceResult

+ RebalanceResultOut chan RebalanceResult

+ Rebalancer *Rebalancer

+ RebalancersOut chan []*Rebalancer

+ Status *Status

+ Type ManagedRebalanceCacheOperationType

+ type ManagedRebalanceCacheOperationType uint

+ const DELETE_REBALANCER

+ const READ_REBALANCER

+ const READ_REBALANCERS

+ const READ_REBALANCE_RESULT

+ const READ_REBALANCE_RESULT_BY_ORIGIN

+ const WRITE_REBALANCER

+ const WRITE_REBALANCE_RESULT

+ type ManagedTrigger struct

+ BootTime *time.Time

+ CancelFunction context.CancelFunc

+ NodeId int

+ PreviousState string

+ Reference string

+ Status Status

+ TriggerSettingsOut chan ManagedTriggerSettings

+ TriggeredWorkflowVersionNodeId int

+ Type ManagedTriggerCacheOperationType

+ VerificationTime *time.Time

+ WorkflowVersionId int

+ type ManagedTriggerCacheOperationType uint

+ const READ_TRIGGER_SETTINGS

+ const WRITE_TRIGGER

+ const WRITE_TRIGGER_VERIFICATIONTIME

+ type ManagedTriggerSettings struct

+ BootTime *time.Time

+ CancelFunction context.CancelFunc

+ NodeId int

+ PreviousState string

+ Reference string

+ Status Status

+ TriggeredWorkflowVersionNodeId int

+ VerificationTime *time.Time

+ WorkflowVersionId int

+ func GetTriggerSettingsByWorkflowVersionId(nodeId int, workflowVersionId int) ManagedTriggerSettings

type NewAddressResponse

+ RequestId string

type NewPaymentResponse

+ RequestId string

type OpenChannelResponse

+ RequestId string

+ type RebalanceRequest struct

+ AmountMsat uint64

+ ChannelIds []int

+ IncomingChannelId int

+ MaximumConcurrency int

+ MaximumCostMsat uint64

+ Origin RebalanceRequestOrigin

+ OriginId int

+ OriginReference string

+ OutgoingChannelId int

+ ResponseChannel chan RebalanceResponse

+ type RebalanceRequestOrigin int

+ type RebalanceResponse struct

+ Request RebalanceRequest

+ type RebalanceResult struct

+ CreatedOn time.Time

+ Error string

+ Hops string

+ IncomingChannelId int

+ OutgoingChannelId int

+ RebalanceId int

+ Route *lnrpc.Route

+ Status Status

+ TotalAmountMsat uint64

+ TotalFeeMsat uint64

+ TotalTimeLock uint32

+ UpdateOn time.Time

+ type RebalanceRunner struct

+ Cancel context.CancelFunc

+ Ctx context.Context

+ FailedHops map[string]uint64

+ FailedPairs []*lnrpc.NodePair

+ IncomingChannelId int

+ Invoices map[uint64]*lnrpc.AddInvoiceResponse

+ OutgoingChannelId int

+ RebalanceId int

+ Status Status

+ type Rebalancer struct

+ CreatedOn time.Time

+ GlobalCtx context.Context

+ NodeId int

+ RebalanceCancel context.CancelFunc

+ RebalanceCtx context.Context

+ RebalanceId int

+ Request RebalanceRequest

+ Runners map[int]*RebalanceRunner

+ Status Status

+ UpdateOn time.Time

+ type RoutingPolicyUpdateRequest struct

+ ChannelId int

+ FeeBaseMsat *uint64

+ FeeRateMilliMsat *uint64

+ MaxHtlcMsat *uint64

+ MinHtlcMsat *uint64

+ ResponseChannel chan RoutingPolicyUpdateResponse

+ TimeLockDelta *uint32

+ type RoutingPolicyUpdateResponse struct

+ FailedUpdates []FailedRequest

+ Request RoutingPolicyUpdateRequest

type ServiceType

+ func GetServiceTypes() []ServiceType

+ type WorkflowNodeType int

+ type WorkflowNodeTypeParameters struct

+ OptionalInputs []WorkflowParameterWithLabel

+ OptionalOutputs []WorkflowParameterWithLabel

+ RequiredInputs []WorkflowParameterWithLabel

+ RequiredOutputs []WorkflowParameterWithLabel

+ WorkflowNodeType WorkflowNodeType

+ type WorkflowParameter string

+ type WorkflowParameterType int

+ type WorkflowParameterWithLabel struct

+ Label string

+ type WorkflowTriggerType int

Dec 13, 2022

Changes in this version

+ const AMBOSS

+ const MEMPOOL

+ const ONEML

+ type Attempt struct

+ AttemptId uint64

+ AttemptTimeNs time.Time

+ Failure FailureDetails

+ Preimage string

+ ResolveTimeNs time.Time

+ Route Route

+ Status string

+ type BatchOpenChannel struct

+ LocalFundingAmount int64

+ MinHtlcMsat *uint64

+ NodePubkey string

+ Private *bool

+ PushSat *int64

+ type BatchOpenRequest struct

+ Channels []BatchOpenChannel

+ NodeId int

+ SatPerVbyte *int64

+ TargetConf *int32

+ type BatchOpenResponse struct

+ PendingChannels []PendingChannel

type ChannelGraphEventData

+ MinHtlcMsat uint64

+ type ChannelPoint struct

+ OutputIndex uint32

+ TxId []byte

+ type CloseChannelRequest struct

+ ChannelId int

+ DeliveryAddress *string

+ Force *bool

+ NodeId int

+ SatPerVbyte *uint64

+ TargetConf *int32

+ type CloseChannelResponse struct

+ CloseChannelStatus CloseChannelStatus

+ ClosePendingChannelPoint ChannelPoint

+ ReqId string

+ Request CloseChannelRequest

+ Status ChannelStatus

+ type CloseChannelStatus struct

+ ClosingTxId []byte

+ Success bool

+ type FailedRequest struct

+ Error string

+ Reason string

+ type FailureDetails struct

+ FailureSourceIndex uint32

+ Height uint32

+ Reason string

+ type Hops struct

+ AmtToForwardMsat int64

+ ChanId string

+ Expiry uint32

+ MppRecord MppRecord

+ PubKey string

type ManagedChannelState

+ MinHtlcMsat uint64

type ManagedChannelStateSettings

+ LocalMinHtlcMsat uint64

+ RemoteMinHtlcMsat uint64

+ type MppRecord struct

+ PaymentAddr string

+ TotalAmtMsat int64

+ type NewAddressRequest struct

+ Account string

+ NodeId int

+ Type int32

+ type NewAddressResponse struct

+ Address string

+ ReqId string

+ Request NewAddressRequest

+ type NewPaymentRequest struct

+ AllowSelfPayment *bool

+ AmtMSat *int64

+ Dest *string

+ FeeLimitMsat *int64

+ Invoice *string

+ NodeId int

+ TimeOutSecs int32

+ type NewPaymentResponse struct

+ AmountMsat int64

+ Attempt Attempt

+ CreationDate time.Time

+ FailureReason string

+ FeeLimitMsat int64

+ FeePaidMsat int64

+ Hash string

+ PaymentRequest string

+ Preimage string

+ ReqId string

+ Request NewPaymentRequest

+ Status string

+ type OpenChannelRequest struct

+ CloseAddress *string

+ Host *string

+ LocalFundingAmount int64

+ MinConfs *int32

+ MinHtlcMsat *uint64

+ NodeId int

+ NodePubKey string

+ Private *bool

+ PushSat *int64

+ RemoteCsvDelay *uint32

+ SatPerVbyte *uint64

+ SpendUnconfirmed *bool

+ TargetConf *int32

+ type OpenChannelResponse struct

+ ChannelPoint string

+ PendingChannelPoint string

+ ReqId string

+ Request OpenChannelRequest

+ Status ChannelStatus

+ type PayOnChainRequest struct

+ Address string

+ AmountSat int64

+ Label *string

+ MinConfs *int32

+ NodeId int

+ SatPerVbyte *uint64

+ SendAll *bool

+ SpendUnconfirmed *bool

+ TargetConf *int32

+ type PayOnChainResponse struct

+ Request PayOnChainRequest

+ TxId string

+ type PendingChannel struct

+ PendingChannelPoint string

+ type Route struct

+ Hops []Hops

+ TotalAmtMsat int64

+ TotalTimeLock uint32

+ type UpdateChannelRequest struct

+ ChannelId *int

+ FeeBaseMsat *uint64

+ FeeRateMilliMsat *uint64

+ MaxHtlcMsat *uint64

+ MinHtlcMsat *uint64

+ NodeId int

+ TimeLockDelta *uint32

+ type UpdateChannelResponse struct

+ FailedUpdates []FailedRequest

+ Request UpdateChannelRequest

+ Status Status

Dec 10, 2022

Changes in this version

+ const BOOTSTRAPPING_TIME_MINUTES

+ const CHANNELBALANCE_BOOTSTRAP_TICKER_SECONDS

+ const CHANNELBALANCE_TICKER_SECONDS

+ const ChannelBalanceCacheStream

+ const STREAM_LND_MAX_FORWARDS

+ const STREAM_LND_MAX_INVOICES

+ const TOLERATED_SUBSCRIPTION_DOWNTIME_SECONDS

+ const WORKFLOW_LOG_COUNT

+ var ManagedChannelStateChannel = make(chan ManagedChannelState)

+ func ConvertLNDShortChannelID(LNDShortChannelID uint64) string

+ func ConvertShortChannelIDToLND(ShortChannelID string) (uint64, error)

+ func CreateChannelPoint(fundingTransactionHash string, fundingOutputIndex int) string

+ func GetChannelIdByChannelPoint(channelPoint string) int

+ func GetChannelIdByLndShortChannelId(lndShortChannelId uint64) int

+ func GetChannelIdsByNodeId(peerNodeId int) []int

+ func ManagedChannelStateCache(ch chan ManagedChannelState, broadcaster broadcast.BroadcastServer, ...)

+ func ParseChannelPoint(channelPoint string) (string, int)

+ func SendToManagedChannelBalanceStateSettingsChannel(ch chan *ManagedChannelBalanceStateSettings, ...)

+ func SendToManagedChannelBalanceStatesSettingsChannel(ch chan []ManagedChannelBalanceStateSettings, ...)

+ func SendToManagedChannelIdsChannel(ch chan []int, channelIds []int)

+ func SendToManagedChannelStateSettingsChannel(ch chan *ManagedChannelStateSettings, ...)

+ func SendToManagedChannelStatesSettingsChannel(ch chan []ManagedChannelStateSettings, ...)

+ func SetChannelStateBalanceHtlcEvent(htlcEvent HtlcEvent)

+ func SetChannelStateBalanceUpdate(nodeId int, channelId int, increaseBalance bool, amount int64)

+ func SetChannelStateBalanceUpdateMsat(nodeId int, channelId int, increaseBalance bool, amount uint64)

+ func SetChannelStateChannelStatus(nodeId int, channelId int, status Status)

+ func SetChannelStateNodeStatus(nodeId int, status Status)

+ func SetChannelStateRoutingPolicy(nodeId int, channelId int, local bool, disabled bool, timeLockDelta uint32, ...)

+ func SetChannelStates(nodeId int, channelStateSettings []ManagedChannelStateSettings)

+ type ChannelBalanceStateHtlcInclude uint

+ const PENDING_HTLCS_IGNORED

+ const PENDING_HTLCS_LOCAL_AND_REMOTE_BALANCE_ADJUSTED_DOWNWARDS

+ const PENDING_HTLCS_LOCAL_AND_REMOTE_BALANCE_ADJUSTED_UPWARDS

+ const PENDING_HTLCS_LOCAL_BALANCE_ADJUSTED_DOWNWARDS

+ const PENDING_HTLCS_LOCAL_BALANCE_ADJUSTED_UPWARDS

+ const PENDING_HTLCS_REMOTE_BALANCE_ADJUSTED_DOWNWARDS

+ const PENDING_HTLCS_REMOTE_BALANCE_ADJUSTED_UPWARDS

+ type ChannelStateInclude uint

+ const ALL_CHANNELS

+ const ALL_LOCAL_ACTIVE_CHANNELS

+ const ALL_LOCAL_AND_REMOTE_ACTIVE_CHANNELS

+ type Htlc struct

+ Amount int64

+ ExpirationHeight uint32

+ ForwardingChannel uint64

+ ForwardingHtlcIndex uint64

+ HashLock []byte

+ HtlcIndex uint64

+ Incoming bool

type InvoiceEvent

+ AmountPaidMsat uint64

+ ChannelId int

+ DestinationNodeId *int

type ManagedChannel

+ ChannelIdsOut chan []int

+ LndShortChannelId uint64

+ NodeId int

+ type ManagedChannelBalanceStateSettings struct

+ ChannelId int

+ HtlcInclude ChannelBalanceStateHtlcInclude

+ LocalBalance int64

+ LocalBalancePerMilleRatio int

+ NodeId int

+ RemoteBalance int64

+ RemoteBalancePerMilleRatio int

+ RemoteNodeId int

+ func GetChannelBalanceState(nodeId, channelId int, htlcInclude ChannelBalanceStateHtlcInclude) *ManagedChannelBalanceStateSettings

+ func GetChannelBalanceStates(nodeId int, channelStateInclude ChannelStateInclude, ...) []ManagedChannelBalanceStateSettings

type ManagedChannelCacheOperationType

+ const READ_CHANNELIDS_BY_NODE_ID

type ManagedChannelSettings

+ LndShortChannelId uint64

+ type ManagedChannelState struct

+ Amount int64

+ Balance int64

+ BalanceStateOut chan *ManagedChannelBalanceStateSettings

+ BalanceStatesOut chan []ManagedChannelBalanceStateSettings

+ ChannelId int

+ ChannelStateSettings []ManagedChannelStateSettings

+ Disabled bool

+ FeeBaseMsat uint64

+ FeeRateMilliMsat uint64

+ ForceResponse bool

+ HtlcEvent HtlcEvent

+ HtlcInclude ChannelBalanceStateHtlcInclude

+ Local bool

+ MaxHtlcMsat uint64

+ MinHtlc int64

+ NodeId int

+ RemoteNodeId int

+ StateInclude ChannelStateInclude

+ StateOut chan *ManagedChannelStateSettings

+ StatesOut chan []ManagedChannelStateSettings

+ Status Status

+ TimeLockDelta uint32

+ Type ManagedChannelStateCacheOperationType

+ type ManagedChannelStateCacheOperationType uint

+ const READ_ALL_CHANNELBALANCESTATES

+ const READ_ALL_CHANNELSTATES

+ const READ_CHANNELBALANCESTATE

+ const READ_CHANNELSTATE

+ const WRITE_CHANNELSTATE_CHANNELSTATUS

+ const WRITE_CHANNELSTATE_NODESTATUS

+ const WRITE_CHANNELSTATE_ROUTINGPOLICY

+ const WRITE_CHANNELSTATE_UPDATEBALANCE

+ const WRITE_CHANNELSTATE_UPDATEHTLCEVENT

+ const WRITE_INITIAL_CHANNELSTATES

+ type ManagedChannelStateSettings struct

+ ChanStatusFlags string

+ ChannelId int

+ CommitFee int64

+ CommitWeight int64

+ CommitmentType lnrpc.CommitmentType

+ FeePerKw int64

+ Lifetime int64

+ LocalBalance int64

+ LocalDisabled bool

+ LocalFeeBaseMsat uint64

+ LocalFeeRateMilliMsat uint64

+ LocalMaxHtlcMsat uint64

+ LocalMinHtlc int64

+ LocalTimeLockDelta uint32

+ NodeId int

+ NumUpdates uint64

+ PendingHtlcs []Htlc

+ PendingIncomingHtlcAmount int64

+ PendingIncomingHtlcCount int

+ PendingOutgoingHtlcAmount int64

+ PendingOutgoingHtlcCount int

+ RemoteBalance int64

+ RemoteDisabled bool

+ RemoteFeeBaseMsat uint64

+ RemoteFeeRateMilliMsat uint64

+ RemoteMaxHtlcMsat uint64

+ RemoteMinHtlc int64

+ RemoteNodeId int

+ RemoteTimeLockDelta uint32

+ TotalSatoshisReceived int64

+ TotalSatoshisSent int64

+ UnsettledBalance int64

+ func GetChannelState(nodeId, channelId int) *ManagedChannelStateSettings

+ func GetChannelStates(nodeId int, forceResponse bool) []ManagedChannelStateSettings

type ManagedNode

+ Name *string

type ManagedNodeSettings

+ Name *string

+ type PaymentEvent struct

+ AmountPaid int64

+ FeeMsat uint64

+ IncomingChannelId *int

+ OutgoingChannelId *int

+ PaymentFailureReason lnrpc.PaymentFailureReason

+ PaymentStatus lnrpc.Payment_PaymentStatus

+ RebalanceAmountMsat *uint64

type PeerEvent

+ EventNodeId int

type Services

+ func (rs *Services) Initialising(nodeId int, eventChannel chan interface{})

Nov 30, 2022

Changes in this version

+ const AMBOSS_SLEEP_SECONDS

+ const AVOID_CHANNEL_AND_POLICY_IMPORT_RERUN_TIME_SECONDS

+ const AmbossService

+ const ChannelEventStream

+ const ForwardStream

+ const GENERIC_BOOTSTRAPPING_TIME_SECONDS

+ const GraphEventStream

+ const HtlcEventStream

+ const INVOICE_BOOTSTRAPPING_TIME_SECONDS

+ const ImportChannelAndRoutingPolicies

+ const ImportNodeInformation

+ const InFlightPaymentStream

+ const Initializing

+ const InvoiceStream

+ const LndService

+ const NodeConnectionDetailCustomSettingsMax

+ const PaymentStream

+ const PeerEventStream

+ const SERVICES_ERROR_SLEEP_SECONDS

+ const STREAM_BOOTED_CHECK_SECONDS

+ const STREAM_ERROR_SLEEP_SECONDS

+ const STREAM_FORWARDS_TICKER_SECONDS

+ const STREAM_INFLIGHT_PAYMENTS_TICKER_SECONDS

+ const STREAM_LND_INVOICES_DELTA_TIME_MILLISECONDS

+ const STREAM_LND_INVOICES_INTERVAL_SLEEP

+ const STREAM_LND_INVOICES_SLEEP_MILLISECONDS

+ const STREAM_PAYMENTS_TICKER_SECONDS

+ const TorqDummyNodeId

+ const TorqService

+ const TransactionStream

+ const VECTOR_SLEEP_SECONDS

+ const VectorService

+ var RunningServices map[ServiceType]*Services

+ var SubscriptionStreams = []SubscriptionStream

+ func GetActiveChannelIdByFundingTransaction(fundingTransactionHash string, fundingOutputIndex int) int

+ func GetActiveChannelIdByShortChannelId(shortChannelId string) int

+ func GetActiveNodeIdByPublicKey(publicKey string, chain Chain, network Network) int

+ func GetAllActiveTorqNodeIds(chain *Chain, network *Network) []int

+ func GetChannelIdByFundingTransaction(fundingTransactionHash string, fundingOutputIndex int) int

+ func GetChannelIdByShortChannelId(shortChannelId string) int

+ func GetNodeIdByPublicKey(publicKey string, chain Chain, network Network) int

+ func RWMutexReadLocked(rw *sync.RWMutex) bool

+ func RWMutexWriteLocked(rw *sync.RWMutex) bool

+ func SendToManagedChannelSettingChannel(ch chan ManagedChannelSettings, channelSettings ManagedChannelSettings)

+ type BlockEvent struct

+ Hash []byte

+ Height uint32

+ type ChannelEvent struct

+ ChannelId int

+ Type lnrpc.ChannelEventUpdate_UpdateType

+ type ChannelGraphEvent struct

+ PreviousEventData ChannelGraphEventData

+ PreviousEventTime time.Time

+ type ChannelGraphEventData struct

+ Disabled bool

+ FeeBaseMsat int64

+ FeeRateMilliMsat int64

+ MaxHtlcMsat uint64

+ MinHtlc int64

+ TimeLockDelta uint32

type ChannelStatus

+ func GetChannelStatusByChannelId(channelId int) ChannelStatus

+ type EventData struct

+ EventTime time.Time

+ NodeId int

+ type ForwardEvent struct

+ AmountInMsat uint64

+ AmountOutMsat uint64

+ FeeMsat uint64

+ IncomingChannelId *int

+ OutgoingChannelId *int

+ Timestamp time.Time

+ type GraphEventData struct

+ AnnouncingNodeId *int

+ ChannelId *int

+ ConnectingNodeId *int

+ EventNodeId *int

+ type HtlcEvent struct

+ BoltFailureCode *string

+ BoltFailureString *string

+ Data string

+ EventOrigin *string

+ EventType *string

+ IncomingAmtMsat *uint64

+ IncomingChannelId *int

+ IncomingHtlcId *uint64

+ IncomingTimelock *uint32

+ LndFailureDetail *string

+ OutgoingAmtMsat *uint64

+ OutgoingChannelId *int

+ OutgoingHtlcId *uint64

+ OutgoingTimelock *uint32

+ Timestamp time.Time

+ TimestampNs *uint64

+ type ImportRequest struct

+ ImportType ImportType

+ Out chan error

+ type ImportType int

+ type InvoiceEvent struct

+ AddIndex uint64

+ AmountPaid int64

+ SettledDate time.Time

+ State lnrpc.Invoice_InvoiceState

+ ValueMSat int64

type ManagedChannel

+ AcceptingNodeId *int

+ Capacity int64

+ ChannelSettingOut chan ManagedChannelSettings

+ ChannelSettingsOut chan []ManagedChannelSettings

+ FirstNodeId int

+ InitiatingNodeId *int

+ Private bool

+ SecondNodeId int

type ManagedChannelCacheOperationType

+ const READ_ALL_CHANNEL_SETTINGS

type ManagedChannelSettings

+ AcceptingNodeId *int

+ Capacity int64

+ FirstNodeId int

+ InitiatingNodeId *int

+ Private bool

+ SecondNodeId int

+ func GetChannelSettingByChannelId(channelId int) ManagedChannelSettings

+ func GetChannelSettingsByNodeId(nodeId int) []ManagedChannelSettings

type ManagedNodeCacheOperationType

+ const READ_ALL_ACTIVE_TORQ_NODEIDS

+ type NodeConnectionDetailCustomSettings byte

+ const ImportFailedPayments

+ type NodeGraphEvent struct

+ PreviousEventData NodeGraphEventData

+ PreviousEventTime time.Time

+ type NodeGraphEventData struct

+ Addresses string

+ Alias string

+ Color string

+ Features string

+ type PeerEvent struct

+ EventPublicKey string

+ Type lnrpc.PeerEvent_EventType

+ type ServiceEvent struct

+ PreviousStatus Status

+ Status Status

+ SubscriptionStream *SubscriptionStream

+ Type ServiceType

+ type Services struct

+ ServiceType ServiceType

+ func (rs *Services) AddSubscription(nodeId int, cancelFunc func(), serviceEventChannel chan ServiceEvent)

+ func (rs *Services) Booted(nodeId int, bootLock *sync.Mutex, serviceEventChannel chan ServiceEvent)

+ func (rs *Services) Cancel(nodeId int, enforcedServiceStatus *Status, noDelay bool, ...) Status

+ func (rs *Services) GetActiveNodeIds() []int

+ func (rs *Services) GetBootLock(nodeId int) *sync.Mutex

+ func (rs *Services) GetBootTime(nodeId int) *time.Time

+ func (rs *Services) GetChannelBalanceCacheStreamStatus(nodeId int) Status

+ func (rs *Services) GetEnforcedServiceStatusCheck(nodeId int) *Status

+ func (rs *Services) GetIncludeIncomplete(nodeId int) bool

+ func (rs *Services) GetNodeIds() []int

+ func (rs *Services) GetStatus(nodeId int) Status

+ func (rs *Services) GetStreamBootTime(nodeId int, stream SubscriptionStream) *time.Time

+ func (rs *Services) GetStreamInitializationPingTime(nodeId int, stream SubscriptionStream) *time.Time

+ func (rs *Services) GetStreamStatus(nodeId int, stream SubscriptionStream) Status

+ func (rs *Services) IsNoDelay(nodeId int) bool

+ func (rs *Services) RemoveSubscription(nodeId int, serviceEventChannel chan ServiceEvent)

+ func (rs *Services) SetIncludeIncomplete(nodeId int, includeIncomplete bool)

+ func (rs *Services) SetStreamStatus(nodeId int, stream SubscriptionStream, status Status, ...)

+ type SubscriptionStream int

+ func (ss *SubscriptionStream) IsChannelBalanceCache() bool

+ type TransactionEvent struct

+ Amount *int64

+ BlockHash *string

+ BlockHeight *int32

+ DestinationAddresses *[]string

+ Label *string

+ NumberOfConfirmations *int32

+ RawTransactionHex *string

+ Timestamp time.Time

+ TotalFees *int64

+ TransactionHash *string

Nov 24, 2022

Changes in this version

+ var ManagedChannelGroupChannel = make(chan ManagedChannelGroup)

+ func ManagedChannelGroupCache(ch chan ManagedChannelGroup, ctx context.Context)

+ func SendToManagedChannelGroupSettingsChannel(ch chan *ManagedChannelGroupSettings, ...)

+ func SetChannelGroupsByChannelId(channelId int, channelGroups []ChannelGroup)

+ type ChannelGroup struct

+ CategoryId *int

+ CategoryName *string

+ CategoryStyle *string

+ TagId *int

+ TagName *string

+ TagStyle *string

+ type ChannelGroupInclude uint

+ const ALL_REGULAR_AND_TAG_CATEGORIES

+ const CATEGORIES_ONLY

+ const DISTINCT_REGULAR_AND_TAG_CATEGORIES

+ const TAGS_ONLY

+ type ManagedChannelGroup struct

+ ChannelGroups []ChannelGroup

+ ChannelId int

+ Include ChannelGroupInclude

+ Out chan *ManagedChannelGroupSettings

+ Type ManagedChannelGroupCacheOperationType

+ type ManagedChannelGroupCacheOperationType uint

+ const READ_CHANNELGROUPS

+ const WRITE_CHANNELGROUPS

+ type ManagedChannelGroupSettings struct

+ ChannelGroups []ChannelGroup

+ ChannelId int

+ func GetChannelGroupsByChannelId(channelId int, include ChannelGroupInclude) *ManagedChannelGroupSettings

type ManagedSettingsCacheOperationType

+ const READ_SETTINGS

+ const WRITE_SETTINGS

Nov 20, 2022

Changes in this version

+ const AmbossSubscription

+ const Boot

+ const Kill

+ const LndSubscription

+ const PingSystemMax

+ const VectorSubscription

+ func MutexLocked(m *sync.Mutex) bool

+ type PingSystem byte

+ const Amboss

+ const Vector

+ type ServiceChannelMessage = struct

+ EnforcedServiceStatus *Status

+ NoDelay bool

+ NodeId int

+ Out chan Status

+ ServiceCommand ServiceCommand

+ ServiceType ServiceType

+ type ServiceCommand int

+ type ServiceType int

Nov 8, 2022

Changes in this version

+ const AbandonedClosed

+ const Active

+ const Bitcoin

+ const BreachClosed

+ const CLN

+ const Closing

+ const CooperativeClosed

+ const Deleted

+ const FundingCancelledClosed

+ const Inactive

+ const LND

+ const Litecoin

+ const LocalForceClosed

+ const MainNet

+ const Open

+ const Opening

+ const Pending

+ const RegTest

+ const RemoteForceClosed

+ const SigNet

+ const SimNet

+ const TestNet

+ var ManagedChannelChannel = make(chan ManagedChannel)

+ var ManagedNodeChannel = make(chan ManagedNode)

+ var ManagedSettingsChannel = make(chan ManagedSettings)

+ func GetActiveChannelIdFromFundingTransaction(fundingTransactionHash string, fundingOutputIndex int) int

+ func GetActiveChannelIdFromShortChannelId(shortChannelId string) int

+ func GetActiveNodeIdFromPublicKey(publicKey string, chain Chain, network Network) int

+ func GetActiveTorqNodeIdFromPublicKey(publicKey string, chain Chain, network Network) int

+ func GetAllChannelPublicKeys(chain Chain, network Network) []string

+ func GetAllTorqNodeIds(chain Chain, network Network) []int

+ func GetAllTorqPublicKeys(chain Chain, network Network) []string

+ func GetChannelIdFromFundingTransaction(fundingTransactionHash string, fundingOutputIndex int) int

+ func GetChannelIdFromShortChannelId(shortChannelId string) int

+ func GetChannelNodeIds(chain Chain, network Network) []int

+ func GetChannelPublicKeys(chain Chain, network Network) []string

+ func GetNodeIdFromPublicKey(publicKey string, chain Chain, network Network) int

+ func InactivateChannelNode(publicKey string, chain Chain, network Network)

+ func ManagedChannelCache(ch chan ManagedChannel, ctx context.Context)

+ func ManagedNodeCache(ch chan ManagedNode, ctx context.Context)

+ func ManagedSettingsCache(ch chan ManagedSettings, ctx context.Context)

+ func SendToManagedChannelChannel(ch chan ManagedChannel, managedChannel ManagedChannel)

+ func SendToManagedChannelSettingsChannel(ch chan ManagedChannelSettings, channelSettings ManagedChannelSettings)

+ func SendToManagedNodeChannel(ch chan ManagedNode, managedNode ManagedNode)

+ func SendToManagedNodeIdsChannel(ch chan []int, channelIds []int)

+ func SendToManagedNodeSettingsChannel(ch chan ManagedNodeSettings, nodeSettings ManagedNodeSettings)

+ func SendToManagedPublicKeysChannel(ch chan []string, publicKeys []string)

+ func SendToManagedSettingsChannel(ch chan ManagedSettings, managedSettings ManagedSettings)

+ func SetChannel(channelId int, shortChannelId *string, status ChannelStatus, ...)

+ func SetChannelNode(nodeId int, publicKey string, chain Chain, network Network, ...)

+ func SetChannelStatus(channelId int, status ChannelStatus)

+ func SetInactiveChannelNode(nodeId int, publicKey string, chain Chain, network Network)

+ func SetSettings(defaultDateRange, defaultLanguage, weekStartsOn, preferredTimeZone string)

+ func SetTorqNode(nodeId int, status Status, publicKey string, chain Chain, network Network)

+ type Chain int

+ func GetChain(chain string) Chain

+ type ChannelStatus int

+ func GetChannelStatusFromChannelId(channelId int) ChannelStatus

+ type Implementation int

+ type ManagedChannel struct

+ ChannelId int

+ ChannelIdSettingsOut chan ManagedChannelSettings

+ FundingOutputIndex int

+ FundingTransactionHash string

+ Out chan ManagedChannel

+ ShortChannelId string

+ Status ChannelStatus

+ Type ManagedChannelCacheOperationType

+ type ManagedChannelCacheOperationType uint

+ const READ_ACTIVE_CHANNELID_BY_FUNDING_TRANSACTION

+ const READ_ACTIVE_CHANNELID_BY_SHORTCHANNELID

+ const READ_CHANNELID_BY_FUNDING_TRANSACTION

+ const READ_CHANNELID_BY_SHORTCHANNELID

+ const READ_CHANNEL_SETTINGS

+ const READ_STATUSID_BY_CHANNELID

+ const WRITE_CHANNEL

+ const WRITE_CHANNELSTATUSID

+ type ManagedChannelSettings struct

+ ChannelId int

+ FundingOutputIndex int

+ FundingTransactionHash string

+ ShortChannelId string

+ Status ChannelStatus

+ func GetChannelSettingsFromChannelId(channelId int) ManagedChannelSettings

+ type ManagedNode struct

+ Chain *Chain

+ Network *Network

+ NodeId int

+ NodeIdSettingsOut chan ManagedNodeSettings

+ NodeIdsOut chan []int

+ Out chan ManagedNode

+ PublicKey string

+ PublicKeysOut chan []string

+ Type ManagedNodeCacheOperationType

+ type ManagedNodeCacheOperationType uint

+ const INACTIVATE_CHANNEL_NODE

+ const READ_ACTIVE_CHANNEL_NODE

+ const READ_ACTIVE_TORQ_NODE

+ const READ_ACTIVE_TORQ_NODEIDS

+ const READ_ACTIVE_TORQ_PUBLICKEYS

+ const READ_ALL_CHANNEL_NODEIDS

+ const READ_ALL_CHANNEL_PUBLICKEYS

+ const READ_ALL_TORQ_NODE

+ const READ_ALL_TORQ_NODEIDS

+ const READ_ALL_TORQ_PUBLICKEYS

+ const READ_CHANNEL_NODE

+ const READ_NODE_SETTINGS

+ const WRITE_ACTIVE_CHANNEL_NODE

+ const WRITE_ACTIVE_TORQ_NODE

+ const WRITE_INACTIVE_CHANNEL_NODE

+ const WRITE_INACTIVE_TORQ_NODE

+ type ManagedNodeSettings struct

+ Chain Chain

+ Network Network

+ NodeId int

+ PublicKey string

+ Status Status

+ func GetNodeSettingsByNodeId(nodeId int) ManagedNodeSettings

+ type ManagedSettings struct

+ DefaultDateRange string

+ DefaultLanguage string

+ Out chan ManagedSettings

+ PreferredTimeZone string

+ Type ManagedSettingsCacheOperationType

+ WeekStartsOn string

+ func GetSettings() ManagedSettings

+ type ManagedSettingsCacheOperationType uint

+ const READ

+ const WRITE

+ type Network int

+ func GetNetwork(network string) Network

+ type Status int