Versions in this module Expand all Collapse all v0 v0.15.10001 Jan 16, 2023 v0.15.101 Jan 16, 2023 Changes in this version + const DefaultMaxParts + const Subsystem + var ChanStatusAction_name = map[int32]string + var ChanStatusAction_value = map[string]int32 + var DefaultRouterMacFilename = "router.macaroon" + var ErrFwdNotExists = errors.New("forward does not exist") + var ErrInterceptorAlreadyExists = errors.New("interceptor already exists") + var ErrMissingPreimage = errors.New("missing preimage") + var FailureDetail_name = map[int32]string + var FailureDetail_value = map[string]int32 + var File_routerrpc_router_proto protoreflect.FileDescriptor + var HtlcEvent_EventType_name = map[int32]string + var HtlcEvent_EventType_value = map[string]int32 + var PaymentState_name = map[int32]string + var PaymentState_value = map[string]int32 + var ResolveHoldForwardAction_name = map[int32]string + var ResolveHoldForwardAction_value = map[string]int32 + var Router_ServiceDesc = grpc.ServiceDesc + func DisableLog() + func MarshalTimeNano(t time.Time) int64 + func RegisterRouterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterRouterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RouterClient) error + func RegisterRouterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterRouterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RouterServer) error + func RegisterRouterJSONCallbacks(...) + func RegisterRouterServer(s grpc.ServiceRegistrar, srv RouterServer) + func UnmarshalAMP(reqAMP *lnrpc.AMPRecord) (*record.AMP, error) + func UnmarshalFeatures(rpcFeatures []lnrpc.FeatureBit) (*lnwire.FeatureVector, error) + func UnmarshalMPP(reqMPP *lnrpc.MPPRecord) (*record.MPP, error) + func UnmarshallHopWithPubkey(rpcHop *lnrpc.Hop, pubkey route.Vertex) (*route.Hop, error) + func UseLogger(logger btclog.Logger) + func ValidateCLTVLimit(val, max uint32) (uint32, error) + func ValidatePayReqExpiry(payReq *zpay32.Invoice) error + type BuildRouteRequest struct + AmtMsat int64 + FinalCltvDelta int32 + HopPubkeys [][]byte + OutgoingChanId uint64 + PaymentAddr []byte + func (*BuildRouteRequest) Descriptor() ([]byte, []int) + func (*BuildRouteRequest) ProtoMessage() + func (x *BuildRouteRequest) GetAmtMsat() int64 + func (x *BuildRouteRequest) GetFinalCltvDelta() int32 + func (x *BuildRouteRequest) GetHopPubkeys() [][]byte + func (x *BuildRouteRequest) GetOutgoingChanId() uint64 + func (x *BuildRouteRequest) GetPaymentAddr() []byte + func (x *BuildRouteRequest) ProtoReflect() protoreflect.Message + func (x *BuildRouteRequest) Reset() + func (x *BuildRouteRequest) String() string + type BuildRouteResponse struct + Route *lnrpc.Route + func (*BuildRouteResponse) Descriptor() ([]byte, []int) + func (*BuildRouteResponse) ProtoMessage() + func (x *BuildRouteResponse) GetRoute() *lnrpc.Route + func (x *BuildRouteResponse) ProtoReflect() protoreflect.Message + func (x *BuildRouteResponse) Reset() + func (x *BuildRouteResponse) String() string + type ChanStatusAction int32 + const ChanStatusAction_AUTO + const ChanStatusAction_DISABLE + const ChanStatusAction_ENABLE + func (ChanStatusAction) Descriptor() protoreflect.EnumDescriptor + func (ChanStatusAction) EnumDescriptor() ([]byte, []int) + func (ChanStatusAction) Type() protoreflect.EnumType + func (x ChanStatusAction) Enum() *ChanStatusAction + func (x ChanStatusAction) Number() protoreflect.EnumNumber + func (x ChanStatusAction) String() string + type CircuitKey struct + ChanId uint64 + HtlcId uint64 + func (*CircuitKey) Descriptor() ([]byte, []int) + func (*CircuitKey) ProtoMessage() + func (x *CircuitKey) GetChanId() uint64 + func (x *CircuitKey) GetHtlcId() uint64 + func (x *CircuitKey) ProtoReflect() protoreflect.Message + func (x *CircuitKey) Reset() + func (x *CircuitKey) String() string + type Config struct + MacService *macaroons.Service + NetworkDir string + Router *routing.ChannelRouter + RouterBackend *RouterBackend + RouterMacPath string + func DefaultConfig() *Config + type FailureDetail int32 + const FailureDetail_ADDRESS_MISMATCH + const FailureDetail_CIRCULAR_ROUTE + const FailureDetail_FORWARDS_DISABLED + const FailureDetail_HTLC_ADD_FAILED + const FailureDetail_HTLC_EXCEEDS_MAX + const FailureDetail_INCOMPLETE_FORWARD + const FailureDetail_INSUFFICIENT_BALANCE + const FailureDetail_INVALID_KEYSEND + const FailureDetail_INVOICE_CANCELED + const FailureDetail_INVOICE_EXPIRY_TOO_SOON + const FailureDetail_INVOICE_NOT_OPEN + const FailureDetail_INVOICE_UNDERPAID + const FailureDetail_LINK_NOT_ELIGIBLE + const FailureDetail_MPP_INVOICE_TIMEOUT + const FailureDetail_MPP_IN_PROGRESS + const FailureDetail_NO_DETAIL + const FailureDetail_ONION_DECODE + const FailureDetail_ON_CHAIN_TIMEOUT + const FailureDetail_SET_OVERPAID + const FailureDetail_SET_TOTAL_MISMATCH + const FailureDetail_SET_TOTAL_TOO_LOW + const FailureDetail_UNKNOWN + const FailureDetail_UNKNOWN_INVOICE + func (FailureDetail) Descriptor() protoreflect.EnumDescriptor + func (FailureDetail) EnumDescriptor() ([]byte, []int) + func (FailureDetail) Type() protoreflect.EnumType + func (x FailureDetail) Enum() *FailureDetail + func (x FailureDetail) Number() protoreflect.EnumNumber + func (x FailureDetail) String() string + type FinalHtlcEvent struct + Offchain bool + Settled bool + func (*FinalHtlcEvent) Descriptor() ([]byte, []int) + func (*FinalHtlcEvent) ProtoMessage() + func (x *FinalHtlcEvent) GetOffchain() bool + func (x *FinalHtlcEvent) GetSettled() bool + func (x *FinalHtlcEvent) ProtoReflect() protoreflect.Message + func (x *FinalHtlcEvent) Reset() + func (x *FinalHtlcEvent) String() string + type ForwardEvent struct + Info *HtlcInfo + func (*ForwardEvent) Descriptor() ([]byte, []int) + func (*ForwardEvent) ProtoMessage() + func (x *ForwardEvent) GetInfo() *HtlcInfo + func (x *ForwardEvent) ProtoReflect() protoreflect.Message + func (x *ForwardEvent) Reset() + func (x *ForwardEvent) String() string + type ForwardFailEvent struct + func (*ForwardFailEvent) Descriptor() ([]byte, []int) + func (*ForwardFailEvent) ProtoMessage() + func (x *ForwardFailEvent) ProtoReflect() protoreflect.Message + func (x *ForwardFailEvent) Reset() + func (x *ForwardFailEvent) String() string + type ForwardHtlcInterceptRequest struct + AutoFailHeight int32 + CustomRecords map[uint64][]byte + IncomingAmountMsat uint64 + IncomingCircuitKey *CircuitKey + IncomingExpiry uint32 + OnionBlob []byte + OutgoingAmountMsat uint64 + OutgoingExpiry uint32 + OutgoingRequestedChanId uint64 + PaymentHash []byte + func (*ForwardHtlcInterceptRequest) Descriptor() ([]byte, []int) + func (*ForwardHtlcInterceptRequest) ProtoMessage() + func (x *ForwardHtlcInterceptRequest) GetAutoFailHeight() int32 + func (x *ForwardHtlcInterceptRequest) GetCustomRecords() map[uint64][]byte + func (x *ForwardHtlcInterceptRequest) GetIncomingAmountMsat() uint64 + func (x *ForwardHtlcInterceptRequest) GetIncomingCircuitKey() *CircuitKey + func (x *ForwardHtlcInterceptRequest) GetIncomingExpiry() uint32 + func (x *ForwardHtlcInterceptRequest) GetOnionBlob() []byte + func (x *ForwardHtlcInterceptRequest) GetOutgoingAmountMsat() uint64 + func (x *ForwardHtlcInterceptRequest) GetOutgoingExpiry() uint32 + func (x *ForwardHtlcInterceptRequest) GetOutgoingRequestedChanId() uint64 + func (x *ForwardHtlcInterceptRequest) GetPaymentHash() []byte + func (x *ForwardHtlcInterceptRequest) ProtoReflect() protoreflect.Message + func (x *ForwardHtlcInterceptRequest) Reset() + func (x *ForwardHtlcInterceptRequest) String() string + type ForwardHtlcInterceptResponse struct + Action ResolveHoldForwardAction + FailureCode lnrpc.Failure_FailureCode + FailureMessage []byte + IncomingCircuitKey *CircuitKey + Preimage []byte + func (*ForwardHtlcInterceptResponse) Descriptor() ([]byte, []int) + func (*ForwardHtlcInterceptResponse) ProtoMessage() + func (x *ForwardHtlcInterceptResponse) GetAction() ResolveHoldForwardAction + func (x *ForwardHtlcInterceptResponse) GetFailureCode() lnrpc.Failure_FailureCode + func (x *ForwardHtlcInterceptResponse) GetFailureMessage() []byte + func (x *ForwardHtlcInterceptResponse) GetIncomingCircuitKey() *CircuitKey + func (x *ForwardHtlcInterceptResponse) GetPreimage() []byte + func (x *ForwardHtlcInterceptResponse) ProtoReflect() protoreflect.Message + func (x *ForwardHtlcInterceptResponse) Reset() + func (x *ForwardHtlcInterceptResponse) String() string + type GetMissionControlConfigRequest struct + func (*GetMissionControlConfigRequest) Descriptor() ([]byte, []int) + func (*GetMissionControlConfigRequest) ProtoMessage() + func (x *GetMissionControlConfigRequest) ProtoReflect() protoreflect.Message + func (x *GetMissionControlConfigRequest) Reset() + func (x *GetMissionControlConfigRequest) String() string + type GetMissionControlConfigResponse struct + Config *MissionControlConfig + func (*GetMissionControlConfigResponse) Descriptor() ([]byte, []int) + func (*GetMissionControlConfigResponse) ProtoMessage() + func (x *GetMissionControlConfigResponse) GetConfig() *MissionControlConfig + func (x *GetMissionControlConfigResponse) ProtoReflect() protoreflect.Message + func (x *GetMissionControlConfigResponse) Reset() + func (x *GetMissionControlConfigResponse) String() string + type HtlcEvent struct + Event isHtlcEvent_Event + EventType HtlcEvent_EventType + IncomingChannelId uint64 + IncomingHtlcId uint64 + OutgoingChannelId uint64 + OutgoingHtlcId uint64 + TimestampNs uint64 + func (*HtlcEvent) Descriptor() ([]byte, []int) + func (*HtlcEvent) ProtoMessage() + func (m *HtlcEvent) GetEvent() isHtlcEvent_Event + func (x *HtlcEvent) GetEventType() HtlcEvent_EventType + func (x *HtlcEvent) GetFinalHtlcEvent() *FinalHtlcEvent + func (x *HtlcEvent) GetForwardEvent() *ForwardEvent + func (x *HtlcEvent) GetForwardFailEvent() *ForwardFailEvent + func (x *HtlcEvent) GetIncomingChannelId() uint64 + func (x *HtlcEvent) GetIncomingHtlcId() uint64 + func (x *HtlcEvent) GetLinkFailEvent() *LinkFailEvent + func (x *HtlcEvent) GetOutgoingChannelId() uint64 + func (x *HtlcEvent) GetOutgoingHtlcId() uint64 + func (x *HtlcEvent) GetSettleEvent() *SettleEvent + func (x *HtlcEvent) GetSubscribedEvent() *SubscribedEvent + func (x *HtlcEvent) GetTimestampNs() uint64 + func (x *HtlcEvent) ProtoReflect() protoreflect.Message + func (x *HtlcEvent) Reset() + func (x *HtlcEvent) String() string + type HtlcEvent_EventType int32 + const HtlcEvent_FORWARD + const HtlcEvent_RECEIVE + const HtlcEvent_SEND + const HtlcEvent_UNKNOWN + func (HtlcEvent_EventType) Descriptor() protoreflect.EnumDescriptor + func (HtlcEvent_EventType) EnumDescriptor() ([]byte, []int) + func (HtlcEvent_EventType) Type() protoreflect.EnumType + func (x HtlcEvent_EventType) Enum() *HtlcEvent_EventType + func (x HtlcEvent_EventType) Number() protoreflect.EnumNumber + func (x HtlcEvent_EventType) String() string + type HtlcEvent_FinalHtlcEvent struct + FinalHtlcEvent *FinalHtlcEvent + type HtlcEvent_ForwardEvent struct + ForwardEvent *ForwardEvent + type HtlcEvent_ForwardFailEvent struct + ForwardFailEvent *ForwardFailEvent + type HtlcEvent_LinkFailEvent struct + LinkFailEvent *LinkFailEvent + type HtlcEvent_SettleEvent struct + SettleEvent *SettleEvent + type HtlcEvent_SubscribedEvent struct + SubscribedEvent *SubscribedEvent + type HtlcInfo struct + IncomingAmtMsat uint64 + IncomingTimelock uint32 + OutgoingAmtMsat uint64 + OutgoingTimelock uint32 + func (*HtlcInfo) Descriptor() ([]byte, []int) + func (*HtlcInfo) ProtoMessage() + func (x *HtlcInfo) GetIncomingAmtMsat() uint64 + func (x *HtlcInfo) GetIncomingTimelock() uint32 + func (x *HtlcInfo) GetOutgoingAmtMsat() uint64 + func (x *HtlcInfo) GetOutgoingTimelock() uint32 + func (x *HtlcInfo) ProtoReflect() protoreflect.Message + func (x *HtlcInfo) Reset() + func (x *HtlcInfo) String() string + type LinkFailEvent struct + FailureDetail FailureDetail + FailureString string + Info *HtlcInfo + WireFailure lnrpc.Failure_FailureCode + func (*LinkFailEvent) Descriptor() ([]byte, []int) + func (*LinkFailEvent) ProtoMessage() + func (x *LinkFailEvent) GetFailureDetail() FailureDetail + func (x *LinkFailEvent) GetFailureString() string + func (x *LinkFailEvent) GetInfo() *HtlcInfo + func (x *LinkFailEvent) GetWireFailure() lnrpc.Failure_FailureCode + func (x *LinkFailEvent) ProtoReflect() protoreflect.Message + func (x *LinkFailEvent) Reset() + func (x *LinkFailEvent) String() string + type MissionControl interface + GetConfig func() *routing.MissionControlConfig + GetHistorySnapshot func() *routing.MissionControlSnapshot + GetPairHistorySnapshot func(fromNode, toNode route.Vertex) routing.TimedPairResult + GetProbability func(fromNode, toNode route.Vertex, amt lnwire.MilliSatoshi, ...) float64 + ImportHistory func(snapshot *routing.MissionControlSnapshot, force bool) error + ResetHistory func() error + SetConfig func(cfg *routing.MissionControlConfig) error + type MissionControlConfig struct + HalfLifeSeconds uint64 + HopProbability float32 + MaximumPaymentResults uint32 + MinimumFailureRelaxInterval uint64 + Weight float32 + func (*MissionControlConfig) Descriptor() ([]byte, []int) + func (*MissionControlConfig) ProtoMessage() + func (x *MissionControlConfig) GetHalfLifeSeconds() uint64 + func (x *MissionControlConfig) GetHopProbability() float32 + func (x *MissionControlConfig) GetMaximumPaymentResults() uint32 + func (x *MissionControlConfig) GetMinimumFailureRelaxInterval() uint64 + func (x *MissionControlConfig) GetWeight() float32 + func (x *MissionControlConfig) ProtoReflect() protoreflect.Message + func (x *MissionControlConfig) Reset() + func (x *MissionControlConfig) String() string + type PairData struct + FailAmtMsat int64 + FailAmtSat int64 + FailTime int64 + SuccessAmtMsat int64 + SuccessAmtSat int64 + SuccessTime int64 + func (*PairData) Descriptor() ([]byte, []int) + func (*PairData) ProtoMessage() + func (x *PairData) GetFailAmtMsat() int64 + func (x *PairData) GetFailAmtSat() int64 + func (x *PairData) GetFailTime() int64 + func (x *PairData) GetSuccessAmtMsat() int64 + func (x *PairData) GetSuccessAmtSat() int64 + func (x *PairData) GetSuccessTime() int64 + func (x *PairData) ProtoReflect() protoreflect.Message + func (x *PairData) Reset() + func (x *PairData) String() string + type PairHistory struct + History *PairData + NodeFrom []byte + NodeTo []byte + func (*PairHistory) Descriptor() ([]byte, []int) + func (*PairHistory) ProtoMessage() + func (x *PairHistory) GetHistory() *PairData + func (x *PairHistory) GetNodeFrom() []byte + func (x *PairHistory) GetNodeTo() []byte + func (x *PairHistory) ProtoReflect() protoreflect.Message + func (x *PairHistory) Reset() + func (x *PairHistory) String() string + type PaymentState int32 + const PaymentState_FAILED_ERROR + const PaymentState_FAILED_INCORRECT_PAYMENT_DETAILS + const PaymentState_FAILED_INSUFFICIENT_BALANCE + const PaymentState_FAILED_NO_ROUTE + const PaymentState_FAILED_TIMEOUT + const PaymentState_IN_FLIGHT + const PaymentState_SUCCEEDED + func (PaymentState) Descriptor() protoreflect.EnumDescriptor + func (PaymentState) EnumDescriptor() ([]byte, []int) + func (PaymentState) Type() protoreflect.EnumType + func (x PaymentState) Enum() *PaymentState + func (x PaymentState) Number() protoreflect.EnumNumber + func (x PaymentState) String() string + type PaymentStatus struct + Htlcs []*lnrpc.HTLCAttempt + Preimage []byte + State PaymentState + func (*PaymentStatus) Descriptor() ([]byte, []int) + func (*PaymentStatus) ProtoMessage() + func (x *PaymentStatus) GetHtlcs() []*lnrpc.HTLCAttempt + func (x *PaymentStatus) GetPreimage() []byte + func (x *PaymentStatus) GetState() PaymentState + func (x *PaymentStatus) ProtoReflect() protoreflect.Message + func (x *PaymentStatus) Reset() + func (x *PaymentStatus) String() string + type QueryMissionControlRequest struct + func (*QueryMissionControlRequest) Descriptor() ([]byte, []int) + func (*QueryMissionControlRequest) ProtoMessage() + func (x *QueryMissionControlRequest) ProtoReflect() protoreflect.Message + func (x *QueryMissionControlRequest) Reset() + func (x *QueryMissionControlRequest) String() string + type QueryMissionControlResponse struct + Pairs []*PairHistory + func (*QueryMissionControlResponse) Descriptor() ([]byte, []int) + func (*QueryMissionControlResponse) ProtoMessage() + func (x *QueryMissionControlResponse) GetPairs() []*PairHistory + func (x *QueryMissionControlResponse) ProtoReflect() protoreflect.Message + func (x *QueryMissionControlResponse) Reset() + func (x *QueryMissionControlResponse) String() string + type QueryProbabilityRequest struct + AmtMsat int64 + FromNode []byte + ToNode []byte + func (*QueryProbabilityRequest) Descriptor() ([]byte, []int) + func (*QueryProbabilityRequest) ProtoMessage() + func (x *QueryProbabilityRequest) GetAmtMsat() int64 + func (x *QueryProbabilityRequest) GetFromNode() []byte + func (x *QueryProbabilityRequest) GetToNode() []byte + func (x *QueryProbabilityRequest) ProtoReflect() protoreflect.Message + func (x *QueryProbabilityRequest) Reset() + func (x *QueryProbabilityRequest) String() string + type QueryProbabilityResponse struct + History *PairData + Probability float64 + func (*QueryProbabilityResponse) Descriptor() ([]byte, []int) + func (*QueryProbabilityResponse) ProtoMessage() + func (x *QueryProbabilityResponse) GetHistory() *PairData + func (x *QueryProbabilityResponse) GetProbability() float64 + func (x *QueryProbabilityResponse) ProtoReflect() protoreflect.Message + func (x *QueryProbabilityResponse) Reset() + func (x *QueryProbabilityResponse) String() string + type ResetMissionControlRequest struct + func (*ResetMissionControlRequest) Descriptor() ([]byte, []int) + func (*ResetMissionControlRequest) ProtoMessage() + func (x *ResetMissionControlRequest) ProtoReflect() protoreflect.Message + func (x *ResetMissionControlRequest) Reset() + func (x *ResetMissionControlRequest) String() string + type ResetMissionControlResponse struct + func (*ResetMissionControlResponse) Descriptor() ([]byte, []int) + func (*ResetMissionControlResponse) ProtoMessage() + func (x *ResetMissionControlResponse) ProtoReflect() protoreflect.Message + func (x *ResetMissionControlResponse) Reset() + func (x *ResetMissionControlResponse) String() string + type ResolveHoldForwardAction int32 + const ResolveHoldForwardAction_FAIL + const ResolveHoldForwardAction_RESUME + const ResolveHoldForwardAction_SETTLE + func (ResolveHoldForwardAction) Descriptor() protoreflect.EnumDescriptor + func (ResolveHoldForwardAction) EnumDescriptor() ([]byte, []int) + func (ResolveHoldForwardAction) Type() protoreflect.EnumType + func (x ResolveHoldForwardAction) Enum() *ResolveHoldForwardAction + func (x ResolveHoldForwardAction) Number() protoreflect.EnumNumber + func (x ResolveHoldForwardAction) String() string + type RouteFeeRequest struct + AmtSat int64 + Dest []byte + func (*RouteFeeRequest) Descriptor() ([]byte, []int) + func (*RouteFeeRequest) ProtoMessage() + func (x *RouteFeeRequest) GetAmtSat() int64 + func (x *RouteFeeRequest) GetDest() []byte + func (x *RouteFeeRequest) ProtoReflect() protoreflect.Message + func (x *RouteFeeRequest) Reset() + func (x *RouteFeeRequest) String() string + type RouteFeeResponse struct + RoutingFeeMsat int64 + TimeLockDelay int64 + func (*RouteFeeResponse) Descriptor() ([]byte, []int) + func (*RouteFeeResponse) ProtoMessage() + func (x *RouteFeeResponse) GetRoutingFeeMsat() int64 + func (x *RouteFeeResponse) GetTimeLockDelay() int64 + func (x *RouteFeeResponse) ProtoReflect() protoreflect.Message + func (x *RouteFeeResponse) Reset() + func (x *RouteFeeResponse) String() string + type RouterBackend struct + ActiveNetParams *chaincfg.Params + DefaultFinalCltvDelta uint16 + FetchAmountPairCapacity func(nodeFrom, nodeTo route.Vertex, amount lnwire.MilliSatoshi) (btcutil.Amount, error) + FetchChannelCapacity func(chanID uint64) (btcutil.Amount, error) + FetchChannelEndpoints func(chanID uint64) (route.Vertex, route.Vertex, error) + FindRoute func(source, target route.Vertex, amt lnwire.MilliSatoshi, timePref float64, ...) (*route.Route, float64, error) + InterceptableForwarder htlcswitch.InterceptableHtlcForwarder + MaxTotalTimelock uint32 + MissionControl MissionControl + SelfNode route.Vertex + SetChannelAuto func(wire.OutPoint) error + SetChannelDisabled func(wire.OutPoint) error + SetChannelEnabled func(wire.OutPoint) error + SubscribeHtlcEvents func() (*subscribe.Client, error) + Tower routing.ControlTower + func (r *RouterBackend) MarshalHTLCAttempt(htlc channeldb.HTLCAttempt) (*lnrpc.HTLCAttempt, error) + func (r *RouterBackend) MarshallPayment(payment *channeldb.MPPayment) (*lnrpc.Payment, error) + func (r *RouterBackend) MarshallRoute(route *route.Route) (*lnrpc.Route, error) + func (r *RouterBackend) QueryRoutes(ctx context.Context, in *lnrpc.QueryRoutesRequest) (*lnrpc.QueryRoutesResponse, error) + func (r *RouterBackend) UnmarshallHop(rpcHop *lnrpc.Hop, prevNodePubKey [33]byte) (*route.Hop, error) + func (r *RouterBackend) UnmarshallRoute(rpcroute *lnrpc.Route) (*route.Route, error) + type RouterClient interface + BuildRoute func(ctx context.Context, in *BuildRouteRequest, opts ...grpc.CallOption) (*BuildRouteResponse, error) + EstimateRouteFee func(ctx context.Context, in *RouteFeeRequest, opts ...grpc.CallOption) (*RouteFeeResponse, error) + GetMissionControlConfig func(ctx context.Context, in *GetMissionControlConfigRequest, ...) (*GetMissionControlConfigResponse, error) + HtlcInterceptor func(ctx context.Context, opts ...grpc.CallOption) (Router_HtlcInterceptorClient, error) + QueryMissionControl func(ctx context.Context, in *QueryMissionControlRequest, opts ...grpc.CallOption) (*QueryMissionControlResponse, error) + QueryProbability func(ctx context.Context, in *QueryProbabilityRequest, opts ...grpc.CallOption) (*QueryProbabilityResponse, error) + ResetMissionControl func(ctx context.Context, in *ResetMissionControlRequest, opts ...grpc.CallOption) (*ResetMissionControlResponse, error) + SendPayment func(ctx context.Context, in *SendPaymentRequest, opts ...grpc.CallOption) (Router_SendPaymentClient, error) + SendPaymentV2 func(ctx context.Context, in *SendPaymentRequest, opts ...grpc.CallOption) (Router_SendPaymentV2Client, error) + SendToRoute func(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*SendToRouteResponse, error) + SendToRouteV2 func(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*lnrpc.HTLCAttempt, error) + SetMissionControlConfig func(ctx context.Context, in *SetMissionControlConfigRequest, ...) (*SetMissionControlConfigResponse, error) + SubscribeHtlcEvents func(ctx context.Context, in *SubscribeHtlcEventsRequest, opts ...grpc.CallOption) (Router_SubscribeHtlcEventsClient, error) + TrackPayment func(ctx context.Context, in *TrackPaymentRequest, opts ...grpc.CallOption) (Router_TrackPaymentClient, error) + TrackPaymentV2 func(ctx context.Context, in *TrackPaymentRequest, opts ...grpc.CallOption) (Router_TrackPaymentV2Client, error) + TrackPayments func(ctx context.Context, in *TrackPaymentsRequest, opts ...grpc.CallOption) (Router_TrackPaymentsClient, error) + UpdateChanStatus func(ctx context.Context, in *UpdateChanStatusRequest, opts ...grpc.CallOption) (*UpdateChanStatusResponse, error) + XImportMissionControl func(ctx context.Context, in *XImportMissionControlRequest, opts ...grpc.CallOption) (*XImportMissionControlResponse, error) + func NewRouterClient(cc grpc.ClientConnInterface) RouterClient + type RouterServer interface + BuildRoute func(context.Context, *BuildRouteRequest) (*BuildRouteResponse, error) + EstimateRouteFee func(context.Context, *RouteFeeRequest) (*RouteFeeResponse, error) + GetMissionControlConfig func(context.Context, *GetMissionControlConfigRequest) (*GetMissionControlConfigResponse, error) + HtlcInterceptor func(Router_HtlcInterceptorServer) error + QueryMissionControl func(context.Context, *QueryMissionControlRequest) (*QueryMissionControlResponse, error) + QueryProbability func(context.Context, *QueryProbabilityRequest) (*QueryProbabilityResponse, error) + ResetMissionControl func(context.Context, *ResetMissionControlRequest) (*ResetMissionControlResponse, error) + SendPayment func(*SendPaymentRequest, Router_SendPaymentServer) error + SendPaymentV2 func(*SendPaymentRequest, Router_SendPaymentV2Server) error + SendToRoute func(context.Context, *SendToRouteRequest) (*SendToRouteResponse, error) + SendToRouteV2 func(context.Context, *SendToRouteRequest) (*lnrpc.HTLCAttempt, error) + SetMissionControlConfig func(context.Context, *SetMissionControlConfigRequest) (*SetMissionControlConfigResponse, error) + SubscribeHtlcEvents func(*SubscribeHtlcEventsRequest, Router_SubscribeHtlcEventsServer) error + TrackPayment func(*TrackPaymentRequest, Router_TrackPaymentServer) error + TrackPaymentV2 func(*TrackPaymentRequest, Router_TrackPaymentV2Server) error + TrackPayments func(*TrackPaymentsRequest, Router_TrackPaymentsServer) error + UpdateChanStatus func(context.Context, *UpdateChanStatusRequest) (*UpdateChanStatusResponse, error) + XImportMissionControl func(context.Context, *XImportMissionControlRequest) (*XImportMissionControlResponse, error) + type Router_HtlcInterceptorClient interface + Recv func() (*ForwardHtlcInterceptRequest, error) + Send func(*ForwardHtlcInterceptResponse) error + type Router_HtlcInterceptorServer interface + Recv func() (*ForwardHtlcInterceptResponse, error) + Send func(*ForwardHtlcInterceptRequest) error + type Router_SendPaymentClient interface + Recv func() (*PaymentStatus, error) + type Router_SendPaymentServer interface + Send func(*PaymentStatus) error + type Router_SendPaymentV2Client interface + Recv func() (*lnrpc.Payment, error) + type Router_SendPaymentV2Server interface + Send func(*lnrpc.Payment) error + type Router_SubscribeHtlcEventsClient interface + Recv func() (*HtlcEvent, error) + type Router_SubscribeHtlcEventsServer interface + Send func(*HtlcEvent) error + type Router_TrackPaymentClient interface + Recv func() (*PaymentStatus, error) + type Router_TrackPaymentServer interface + Send func(*PaymentStatus) error + type Router_TrackPaymentV2Client interface + Recv func() (*lnrpc.Payment, error) + type Router_TrackPaymentV2Server interface + Send func(*lnrpc.Payment) error + type Router_TrackPaymentsClient interface + Recv func() (*lnrpc.Payment, error) + type Router_TrackPaymentsServer interface + Send func(*lnrpc.Payment) error + type RoutingConfig struct + AprioriHopProbability float64 + AprioriWeight float64 + AttemptCost btcutil.Amount + AttemptCostPPM int64 + MaxMcHistory int + McFlushInterval time.Duration + MinRouteProbability float64 + PenaltyHalfLife time.Duration + func GetRoutingConfig(cfg *Config) *RoutingConfig + type SendPaymentRequest struct + AllowSelfPayment bool + Amp bool + Amt int64 + AmtMsat int64 + CltvLimit int32 + Dest []byte + DestCustomRecords map[uint64][]byte + DestFeatures []lnrpc.FeatureBit + FeeLimitMsat int64 + FeeLimitSat int64 + FinalCltvDelta int32 + LastHopPubkey []byte + MaxParts uint32 + MaxShardSizeMsat uint64 + NoInflightUpdates bool + OutgoingChanId uint64 + OutgoingChanIds []uint64 + PaymentAddr []byte + PaymentHash []byte + PaymentRequest string + RouteHints []*lnrpc.RouteHint + TimePref float64 + TimeoutSeconds int32 + func (*SendPaymentRequest) Descriptor() ([]byte, []int) + func (*SendPaymentRequest) ProtoMessage() + func (x *SendPaymentRequest) GetAllowSelfPayment() bool + func (x *SendPaymentRequest) GetAmp() bool + func (x *SendPaymentRequest) GetAmt() int64 + func (x *SendPaymentRequest) GetAmtMsat() int64 + func (x *SendPaymentRequest) GetCltvLimit() int32 + func (x *SendPaymentRequest) GetDest() []byte + func (x *SendPaymentRequest) GetDestCustomRecords() map[uint64][]byte + func (x *SendPaymentRequest) GetDestFeatures() []lnrpc.FeatureBit + func (x *SendPaymentRequest) GetFeeLimitMsat() int64 + func (x *SendPaymentRequest) GetFeeLimitSat() int64 + func (x *SendPaymentRequest) GetFinalCltvDelta() int32 + func (x *SendPaymentRequest) GetLastHopPubkey() []byte + func (x *SendPaymentRequest) GetMaxParts() uint32 + func (x *SendPaymentRequest) GetMaxShardSizeMsat() uint64 + func (x *SendPaymentRequest) GetNoInflightUpdates() bool + func (x *SendPaymentRequest) GetOutgoingChanId() uint64 + func (x *SendPaymentRequest) GetOutgoingChanIds() []uint64 + func (x *SendPaymentRequest) GetPaymentAddr() []byte + func (x *SendPaymentRequest) GetPaymentHash() []byte + func (x *SendPaymentRequest) GetPaymentRequest() string + func (x *SendPaymentRequest) GetRouteHints() []*lnrpc.RouteHint + func (x *SendPaymentRequest) GetTimePref() float64 + func (x *SendPaymentRequest) GetTimeoutSeconds() int32 + func (x *SendPaymentRequest) ProtoReflect() protoreflect.Message + func (x *SendPaymentRequest) Reset() + func (x *SendPaymentRequest) String() string + type SendToRouteRequest struct + PaymentHash []byte + Route *lnrpc.Route + SkipTempErr bool + func (*SendToRouteRequest) Descriptor() ([]byte, []int) + func (*SendToRouteRequest) ProtoMessage() + func (x *SendToRouteRequest) GetPaymentHash() []byte + func (x *SendToRouteRequest) GetRoute() *lnrpc.Route + func (x *SendToRouteRequest) GetSkipTempErr() bool + func (x *SendToRouteRequest) ProtoReflect() protoreflect.Message + func (x *SendToRouteRequest) Reset() + func (x *SendToRouteRequest) String() string + type SendToRouteResponse struct + Failure *lnrpc.Failure + Preimage []byte + func (*SendToRouteResponse) Descriptor() ([]byte, []int) + func (*SendToRouteResponse) ProtoMessage() + func (x *SendToRouteResponse) GetFailure() *lnrpc.Failure + func (x *SendToRouteResponse) GetPreimage() []byte + func (x *SendToRouteResponse) ProtoReflect() protoreflect.Message + func (x *SendToRouteResponse) Reset() + func (x *SendToRouteResponse) String() string + type Server struct + func New(cfg *Config) (*Server, lnrpc.MacaroonPerms, error) + func (s *Server) BuildRoute(ctx context.Context, req *BuildRouteRequest) (*BuildRouteResponse, error) + func (s *Server) EstimateRouteFee(ctx context.Context, req *RouteFeeRequest) (*RouteFeeResponse, error) + func (s *Server) GetMissionControlConfig(ctx context.Context, req *GetMissionControlConfigRequest) (*GetMissionControlConfigResponse, error) + func (s *Server) HtlcInterceptor(stream Router_HtlcInterceptorServer) error + func (s *Server) Name() string + func (s *Server) QueryMissionControl(ctx context.Context, req *QueryMissionControlRequest) (*QueryMissionControlResponse, error) + func (s *Server) QueryProbability(ctx context.Context, req *QueryProbabilityRequest) (*QueryProbabilityResponse, error) + func (s *Server) ResetMissionControl(ctx context.Context, req *ResetMissionControlRequest) (*ResetMissionControlResponse, error) + func (s *Server) SendPayment(request *SendPaymentRequest, stream Router_SendPaymentServer) error + func (s *Server) SendPaymentV2(req *SendPaymentRequest, stream Router_SendPaymentV2Server) error + func (s *Server) SendToRoute(ctx context.Context, req *SendToRouteRequest) (*SendToRouteResponse, error) + func (s *Server) SendToRouteV2(ctx context.Context, req *SendToRouteRequest) (*lnrpc.HTLCAttempt, error) + func (s *Server) SetMissionControlConfig(ctx context.Context, req *SetMissionControlConfigRequest) (*SetMissionControlConfigResponse, error) + func (s *Server) Start() error + func (s *Server) Stop() error + func (s *Server) SubscribeHtlcEvents(req *SubscribeHtlcEventsRequest, stream Router_SubscribeHtlcEventsServer) error + func (s *Server) TrackPayment(request *TrackPaymentRequest, stream Router_TrackPaymentServer) error + func (s *Server) TrackPaymentV2(request *TrackPaymentRequest, stream Router_TrackPaymentV2Server) error + func (s *Server) TrackPayments(request *TrackPaymentsRequest, stream Router_TrackPaymentsServer) error + func (s *Server) UpdateChanStatus(ctx context.Context, req *UpdateChanStatusRequest) (*UpdateChanStatusResponse, error) + func (s *Server) XImportMissionControl(ctx context.Context, req *XImportMissionControlRequest) (*XImportMissionControlResponse, error) + type ServerShell struct + func (r *ServerShell) CreateSubServer(configRegistry lnrpc.SubServerConfigDispatcher) (lnrpc.SubServer, lnrpc.MacaroonPerms, error) + func (r *ServerShell) RegisterWithRestServer(ctx context.Context, mux *runtime.ServeMux, dest string, ...) error + func (r *ServerShell) RegisterWithRootServer(grpcServer *grpc.Server) error + type SetMissionControlConfigRequest struct + Config *MissionControlConfig + func (*SetMissionControlConfigRequest) Descriptor() ([]byte, []int) + func (*SetMissionControlConfigRequest) ProtoMessage() + func (x *SetMissionControlConfigRequest) GetConfig() *MissionControlConfig + func (x *SetMissionControlConfigRequest) ProtoReflect() protoreflect.Message + func (x *SetMissionControlConfigRequest) Reset() + func (x *SetMissionControlConfigRequest) String() string + type SetMissionControlConfigResponse struct + func (*SetMissionControlConfigResponse) Descriptor() ([]byte, []int) + func (*SetMissionControlConfigResponse) ProtoMessage() + func (x *SetMissionControlConfigResponse) ProtoReflect() protoreflect.Message + func (x *SetMissionControlConfigResponse) Reset() + func (x *SetMissionControlConfigResponse) String() string + type SettleEvent struct + Preimage []byte + func (*SettleEvent) Descriptor() ([]byte, []int) + func (*SettleEvent) ProtoMessage() + func (x *SettleEvent) GetPreimage() []byte + func (x *SettleEvent) ProtoReflect() protoreflect.Message + func (x *SettleEvent) Reset() + func (x *SettleEvent) String() string + type SubscribeHtlcEventsRequest struct + func (*SubscribeHtlcEventsRequest) Descriptor() ([]byte, []int) + func (*SubscribeHtlcEventsRequest) ProtoMessage() + func (x *SubscribeHtlcEventsRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeHtlcEventsRequest) Reset() + func (x *SubscribeHtlcEventsRequest) String() string + type SubscribedEvent struct + func (*SubscribedEvent) Descriptor() ([]byte, []int) + func (*SubscribedEvent) ProtoMessage() + func (x *SubscribedEvent) ProtoReflect() protoreflect.Message + func (x *SubscribedEvent) Reset() + func (x *SubscribedEvent) String() string + type TrackPaymentRequest struct + NoInflightUpdates bool + PaymentHash []byte + func (*TrackPaymentRequest) Descriptor() ([]byte, []int) + func (*TrackPaymentRequest) ProtoMessage() + func (x *TrackPaymentRequest) GetNoInflightUpdates() bool + func (x *TrackPaymentRequest) GetPaymentHash() []byte + func (x *TrackPaymentRequest) ProtoReflect() protoreflect.Message + func (x *TrackPaymentRequest) Reset() + func (x *TrackPaymentRequest) String() string + type TrackPaymentsRequest struct + NoInflightUpdates bool + func (*TrackPaymentsRequest) Descriptor() ([]byte, []int) + func (*TrackPaymentsRequest) ProtoMessage() + func (x *TrackPaymentsRequest) GetNoInflightUpdates() bool + func (x *TrackPaymentsRequest) ProtoReflect() protoreflect.Message + func (x *TrackPaymentsRequest) Reset() + func (x *TrackPaymentsRequest) String() string + type UnimplementedRouterServer struct + func (UnimplementedRouterServer) BuildRoute(context.Context, *BuildRouteRequest) (*BuildRouteResponse, error) + func (UnimplementedRouterServer) EstimateRouteFee(context.Context, *RouteFeeRequest) (*RouteFeeResponse, error) + func (UnimplementedRouterServer) GetMissionControlConfig(context.Context, *GetMissionControlConfigRequest) (*GetMissionControlConfigResponse, error) + func (UnimplementedRouterServer) HtlcInterceptor(Router_HtlcInterceptorServer) error + func (UnimplementedRouterServer) QueryMissionControl(context.Context, *QueryMissionControlRequest) (*QueryMissionControlResponse, error) + func (UnimplementedRouterServer) QueryProbability(context.Context, *QueryProbabilityRequest) (*QueryProbabilityResponse, error) + func (UnimplementedRouterServer) ResetMissionControl(context.Context, *ResetMissionControlRequest) (*ResetMissionControlResponse, error) + func (UnimplementedRouterServer) SendPayment(*SendPaymentRequest, Router_SendPaymentServer) error + func (UnimplementedRouterServer) SendPaymentV2(*SendPaymentRequest, Router_SendPaymentV2Server) error + func (UnimplementedRouterServer) SendToRoute(context.Context, *SendToRouteRequest) (*SendToRouteResponse, error) + func (UnimplementedRouterServer) SendToRouteV2(context.Context, *SendToRouteRequest) (*lnrpc.HTLCAttempt, error) + func (UnimplementedRouterServer) SetMissionControlConfig(context.Context, *SetMissionControlConfigRequest) (*SetMissionControlConfigResponse, error) + func (UnimplementedRouterServer) SubscribeHtlcEvents(*SubscribeHtlcEventsRequest, Router_SubscribeHtlcEventsServer) error + func (UnimplementedRouterServer) TrackPayment(*TrackPaymentRequest, Router_TrackPaymentServer) error + func (UnimplementedRouterServer) TrackPaymentV2(*TrackPaymentRequest, Router_TrackPaymentV2Server) error + func (UnimplementedRouterServer) TrackPayments(*TrackPaymentsRequest, Router_TrackPaymentsServer) error + func (UnimplementedRouterServer) UpdateChanStatus(context.Context, *UpdateChanStatusRequest) (*UpdateChanStatusResponse, error) + func (UnimplementedRouterServer) XImportMissionControl(context.Context, *XImportMissionControlRequest) (*XImportMissionControlResponse, error) + type UnsafeRouterServer interface + type UpdateChanStatusRequest struct + Action ChanStatusAction + ChanPoint *lnrpc.ChannelPoint + func (*UpdateChanStatusRequest) Descriptor() ([]byte, []int) + func (*UpdateChanStatusRequest) ProtoMessage() + func (x *UpdateChanStatusRequest) GetAction() ChanStatusAction + func (x *UpdateChanStatusRequest) GetChanPoint() *lnrpc.ChannelPoint + func (x *UpdateChanStatusRequest) ProtoReflect() protoreflect.Message + func (x *UpdateChanStatusRequest) Reset() + func (x *UpdateChanStatusRequest) String() string + type UpdateChanStatusResponse struct + func (*UpdateChanStatusResponse) Descriptor() ([]byte, []int) + func (*UpdateChanStatusResponse) ProtoMessage() + func (x *UpdateChanStatusResponse) ProtoReflect() protoreflect.Message + func (x *UpdateChanStatusResponse) Reset() + func (x *UpdateChanStatusResponse) String() string + type XImportMissionControlRequest struct + Force bool + Pairs []*PairHistory + func (*XImportMissionControlRequest) Descriptor() ([]byte, []int) + func (*XImportMissionControlRequest) ProtoMessage() + func (x *XImportMissionControlRequest) GetForce() bool + func (x *XImportMissionControlRequest) GetPairs() []*PairHistory + func (x *XImportMissionControlRequest) ProtoReflect() protoreflect.Message + func (x *XImportMissionControlRequest) Reset() + func (x *XImportMissionControlRequest) String() string + type XImportMissionControlResponse struct + func (*XImportMissionControlResponse) Descriptor() ([]byte, []int) + func (*XImportMissionControlResponse) ProtoMessage() + func (x *XImportMissionControlResponse) ProtoReflect() protoreflect.Message + func (x *XImportMissionControlResponse) Reset() + func (x *XImportMissionControlResponse) String() string