rfqmsg

Nov 18, 2025

Changes in this version

+ const MaxOracleMetadataLength

+ const MaxSendPaymentQuotes

+ var UseNoOpHTLCs = false

+ func SomeRfqIDsRecord(ids []ID) tlv.OptionalRecordT[AvailableRfqIDsType, HtlcRfqIDs]

+ type AvailableRfqIDsType = tlv.TlvType65540

type BuyRequest

+ PriceOracleMetadata string

type Htlc

+ AvailableRfqIDs tlv.OptionalRecordT[AvailableRfqIDsType, HtlcRfqIDs]

+ NoopAdd bool

+ func (h *Htlc) SetNoopAdd(noopActive bool)

+ type HtlcRfqIDs struct

+ IDs []ID

+ func (r *HtlcRfqIDs) Record() tlv.Record

type JsonAssetChannelBalances

+ OpenChannelsByGroup map[string]*JsonAssetBalance

+ PendingChannelsByGroup map[string]*JsonAssetBalance

type JsonHtlc

+ AvailableRfqIDs []string

type SellRequest

+ PriceOracleMetadata string

Jun 17, 2025

Changes in this version

+ func HasAssetHTLCEntries(blob tlv.Blob) bool

type JsonAssetChannel

+ Capacity uint64

+ FundingAssets []JsonAssetUtxo

+ GroupKey string

+ IncomingHtlcBalance uint64

+ IncomingHtlcs []JsonAssetTranche

+ LocalAssets []JsonAssetTranche

+ LocalBalance uint64

+ OutgoingHtlcBalance uint64

+ OutgoingHtlcs []JsonAssetTranche

+ RemoteAssets []JsonAssetTranche

+ RemoteBalance uint64

+ func (c *JsonAssetChannel) HasAllAssetIDs(ids fn.Set[asset.ID]) bool

+ type JsonAssetTranche struct

+ Amount uint64

+ AssetID string

+ type SpecifierChecker func(ctx context.Context, specifier asset.Specifier, id asset.ID) (bool, error)

Feb 12, 2025

Changes in this version

+ func HasAssetHTLCCustomRecords(records lnwire.CustomRecords) bool

Dec 19, 2024

Changes in this version

+ const DefaultQuoteLifetime

+ var MilliSatPerBtc = rfqmath.FixedPointFromUint64[rfqmath.BigInt](100, 9)

+ func TlvFixedPointDecoder(r io.Reader, val any, buf *[8]byte, l uint64) error

+ func TlvFixedPointEncoder(w io.Writer, val any, buf *[8]byte) error

+ func TransferTypeDecoder(r io.Reader, val any, buf *[8]byte, l uint64) error

+ func TransferTypeEncoder(w io.Writer, val any, buf *[8]byte) error

+ type AssetRate struct

+ Expiry time.Time

+ Rate rfqmath.BigIntFixedPoint

+ func NewAssetRate(rate rfqmath.BigIntFixedPoint, expiry time.Time) AssetRate

+ func (a *AssetRate) String() string

type BuyAccept

+ AssetRate AssetRate

type BuyRequest

+ AssetMaxAmt uint64

+ AssetRateHint fn.Option[AssetRate]

+ AssetSpecifier asset.Specifier

+ func NewBuyRequestFromWire(wireMsg WireMessage, msgData requestWireMsgData) (*BuyRequest, error)

+ func (q *BuyRequest) MsgID() ID

+ func (q *BuyRequest) MsgPeer() route.Vertex

type Htlc

+ func (h *Htlc) AsJson() ([]byte, error)

+ func (h *Htlc) SumAssetBalance(assetSpecifier asset.Specifier) (rfqmath.BigInt, error)

+ func (h *Htlc) ToCustomRecords() (lnwire.CustomRecords, error)

type ID

+ func NewID() (ID, error)

type IncomingMsg

+ MsgID func() ID

+ MsgPeer func() route.Vertex

type JsonAssetUtxo

+ DecimalDisplay uint8

+ type JsonHtlc struct

+ Balances []*JsonHtlcBalance

+ RfqID string

+ type JsonHtlcBalance struct

+ Amount uint64

+ AssetID string

type Reject

+ func (q *Reject) MsgID() ID

+ func (q *Reject) MsgPeer() route.Vertex

type RejectErr

+ func (v *RejectErr) Record() tlv.Record

type SellAccept

+ AssetRate AssetRate

type SellRequest

+ AssetRateHint fn.Option[AssetRate]

+ AssetSpecifier asset.Specifier

+ PaymentMaxAmt lnwire.MilliSatoshi

+ func NewSellRequestFromWire(wireMsg WireMessage, msgData requestWireMsgData) (*SellRequest, error)

+ func (q *SellRequest) MsgID() ID

+ func (q *SellRequest) MsgPeer() route.Vertex

+ type SessionLookup func(id ID) (OutgoingMsg, bool)

+ type TlvFixedPoint struct

+ func NewTlvFixedPointFromBigInt(fp rfqmath.BigIntFixedPoint) TlvFixedPoint

+ func NewTlvFixedPointFromUint64(coefficient uint64, scale uint8) TlvFixedPoint

+ func (f *TlvFixedPoint) IntoBigIntFixedPoint() rfqmath.BigIntFixedPoint

+ func (f *TlvFixedPoint) Record() tlv.Record

+ type TransferType uint8

+ const PayInvoiceTransferType

+ const RecvPaymentTransferType

+ const UnspecifiedTransferType

+ func (t *TransferType) Record() tlv.Record

type WireMsgDataVersion

+ const V1

Jul 23, 2024

Changes in this version

+ const MaxMessageType

+ const MaxNumOutputs

+ const MsgTypeAccept

+ const MsgTypeReject

+ const MsgTypeRequest

+ const TapMessageTypeBaseOffset

+ const TypeRejectErrCode

+ const TypeRejectErrMsg

+ const TypeRejectID

+ const TypeRejectVersion

+ var ErrListInvalid = errors.New("encoded list is invalid")

+ var ErrNoSuitableBuyOffer = RejectErr

+ var ErrNoSuitableSellOffer = RejectErr

+ var ErrPriceOracleUnavailable = RejectErr

+ var ErrUnknownMessageType = errors.New("unknown message type")

+ var ErrUnknownReject = RejectErr

+ func AssetIdDecoder(r io.Reader, val any, buf *[8]byte, l uint64) error

+ func AssetIdEncoder(w io.Writer, val any, buf *[8]byte) error

+ func IdDecoder(r io.Reader, val any, buf *[8]byte, l uint64) error

+ func IdEncoder(w io.Writer, val any, buf *[8]byte) error

+ func SomeRfqIDRecord(id ID) tlv.OptionalRecordT[HtlcRfqIDType, ID]

+ func Sum(balances []*AssetBalance) uint64

+ func TypeRecordRejectErrCode(errCode *uint8) tlv.Record

+ func TypeRecordRejectErrMsg(errMsg *string) tlv.Record

+ func TypeRecordRejectID(id *ID) tlv.Record

+ func TypeRecordRejectVersion(version *WireMsgDataVersion) tlv.Record

+ func WireMsgDataVersionDecoder(r io.Reader, val any, buf *[8]byte, l uint64) error

+ func WireMsgDataVersionEncoder(w io.Writer, val any, buf *[8]byte) error

+ type AssetBalance struct

+ Amount tlv.RecordT[tlv.TlvType1, uint64]

+ AssetID tlv.RecordT[tlv.TlvType0, asset.ID]

+ func DecodeAssetBalance(blob tlv.Blob) (*AssetBalance, error)

+ func NewAssetBalance(assetID asset.ID, amount uint64) *AssetBalance

+ func (a *AssetBalance) Bytes() []byte

+ func (a *AssetBalance) Decode(r io.Reader) error

+ func (a *AssetBalance) Encode(w io.Writer) error

+ type AssetBalanceListRecord struct

+ Balances []*AssetBalance

+ func (l *AssetBalanceListRecord) Decode(r io.Reader) error

+ func (l *AssetBalanceListRecord) Encode(w io.Writer) error

+ func (l *AssetBalanceListRecord) Record() tlv.Record

+ func (l *AssetBalanceListRecord) Sum() uint64

+ type BuyAccept struct

+ AskPrice lnwire.MilliSatoshi

+ Expiry uint64

+ ID ID

+ Peer route.Vertex

+ Request BuyRequest

+ Version WireMsgDataVersion

+ func NewBuyAcceptFromRequest(request BuyRequest, askPrice lnwire.MilliSatoshi, expiry uint64) *BuyAccept

+ func (q *BuyAccept) MsgID() ID

+ func (q *BuyAccept) MsgPeer() route.Vertex

+ func (q *BuyAccept) ShortChannelId() SerialisedScid

+ func (q *BuyAccept) String() string

+ func (q *BuyAccept) ToWire() (WireMessage, error)

+ type BuyRequest struct

+ AssetAmount uint64

+ AssetGroupKey *btcec.PublicKey

+ AssetID *asset.ID

+ BidPrice lnwire.MilliSatoshi

+ ID ID

+ Peer route.Vertex

+ Version WireMsgDataVersion

+ func NewBuyRequest(peer route.Vertex, assetID *asset.ID, assetGroupKey *btcec.PublicKey, ...) (*BuyRequest, error)

+ func NewBuyRequestMsgFromWire(wireMsg WireMessage, msgData requestWireMsgData) (*BuyRequest, error)

+ func (q *BuyRequest) String() string

+ func (q *BuyRequest) ToWire() (WireMessage, error)

+ func (q *BuyRequest) Validate() error

+ type Htlc struct

+ Amounts tlv.RecordT[HtlcAmountRecordType, AssetBalanceListRecord]

+ RfqID tlv.OptionalRecordT[HtlcRfqIDType, ID]

+ func DecodeHtlc(blob tlv.Blob) (*Htlc, error)

+ func HtlcFromCustomRecords(records lnwire.CustomRecords) (*Htlc, error)

+ func NewHtlc(amounts []*AssetBalance, rfqID fn.Option[ID]) *Htlc

+ func (h *Htlc) Balances() []*AssetBalance

+ func (h *Htlc) Bytes() []byte

+ func (h *Htlc) Decode(r io.Reader) error

+ func (h *Htlc) Encode(w io.Writer) error

+ func (h *Htlc) Records() []tlv.Record

+ type HtlcAmountRecordType = tlv.TlvType65536

+ type HtlcRfqIDType = tlv.TlvType65538

+ type ID [32]byte

+ func (id *ID) Record() tlv.Record

+ func (id ID) Scid() SerialisedScid

+ func (id ID) String() string

+ type IncomingMsg interface

+ String func() string

+ func NewIncomingAcceptFromWire(wireMsg WireMessage) (IncomingMsg, error)

+ func NewIncomingMsgFromWire(wireMsg WireMessage) (IncomingMsg, error)

+ func NewIncomingRequestFromWire(wireMsg WireMessage) (IncomingMsg, error)

+ type JsonAssetBalance struct

+ AssetID string

+ LocalBalance uint64

+ Name string

+ RemoteBalance uint64

+ type JsonAssetChanInfo struct

+ AssetInfo JsonAssetUtxo

+ Capacity uint64

+ LocalBalance uint64

+ RemoteBalance uint64

+ type JsonAssetChannel struct

+ Assets []JsonAssetChanInfo

+ type JsonAssetChannelBalances struct

+ OpenChannels map[string]*JsonAssetBalance

+ PendingChannels map[string]*JsonAssetBalance

+ type JsonAssetGenesis struct

+ AssetID string

+ GenesisPoint string

+ MetaHash string

+ Name string

+ type JsonAssetUtxo struct

+ Amount uint64

+ AssetGenesis JsonAssetGenesis

+ ScriptKey string

+ Version int64

+ type JsonCloseOutput struct

+ AssetInternalKey string

+ BtcInternalKey string

+ ScriptKeys map[string]string

+ type OutgoingMsg interface

+ String func() string

+ ToWire func() (WireMessage, error)

+ type QuoteResponse interface

+ MsgID func() ID

+ MsgPeer func() route.Vertex

+ String func() string

+ type Reject struct

+ Peer route.Vertex

+ func NewQuoteRejectFromWireMsg(wireMsg WireMessage) (*Reject, error)

+ func NewReject(peer route.Vertex, requestId ID, rejectErr RejectErr) *Reject

+ func (q *Reject) Bytes() ([]byte, error)

+ func (q *Reject) Decode(r io.Reader) error

+ func (q *Reject) Encode(writer io.Writer) error

+ func (q *Reject) String() string

+ func (q *Reject) ToWire() (WireMessage, error)

+ type RejectErr struct

+ Code uint8

+ Msg string

+ type SellAccept struct

+ BidPrice lnwire.MilliSatoshi

+ Expiry uint64

+ ID ID

+ Peer route.Vertex

+ Request SellRequest

+ Version WireMsgDataVersion

+ func NewSellAcceptFromRequest(request SellRequest, bidPrice lnwire.MilliSatoshi, expiry uint64) *SellAccept

+ func (q *SellAccept) MsgID() ID

+ func (q *SellAccept) MsgPeer() route.Vertex

+ func (q *SellAccept) ShortChannelId() SerialisedScid

+ func (q *SellAccept) String() string

+ func (q *SellAccept) ToWire() (WireMessage, error)

+ type SellRequest struct

+ AskPrice lnwire.MilliSatoshi

+ AssetAmount uint64

+ AssetGroupKey *btcec.PublicKey

+ AssetID *asset.ID

+ ID ID

+ Peer route.Vertex

+ Version WireMsgDataVersion

+ func NewSellRequest(peer route.Vertex, assetID *asset.ID, assetGroupKey *btcec.PublicKey, ...) (*SellRequest, error)

+ func NewSellRequestMsgFromWire(wireMsg WireMessage, msgData requestWireMsgData) (*SellRequest, error)

+ func (q *SellRequest) String() string

+ func (q *SellRequest) ToWire() (WireMessage, error)

+ func (q *SellRequest) Validate() error

+ type SerialisedScid uint64

+ type WireMessage struct

+ Data []byte

+ MsgType lnwire.MessageType

+ Peer route.Vertex

+ type WireMsgDataVersion uint8

+ const V0

+ func (v *WireMsgDataVersion) Record() tlv.Record