mirrors/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-02-22 22:25:24 +01:00
Code Issues Projects Releases Wiki Activity

routerrpc: add mc probability query rpc

Browse source 
Probabilities are no longer returned for querymc calls. To still provide
some insight into the mission control internals, this commit adds a new
rpc that calculates a success probability estimate for a specific node
pair and amount.
This commit is contained in:
Joost Jager 2019-09-27 11:43:12 +02:00
parent 04e7c98461
commit fb57255b5c
No known key found for this signature in database
GPG key ID: A61B9D4C393C59C7
8 changed files with 430 additions and 119 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
cmd/lncli/cmd_query_probability.go Normal file
View file

@ -0,0 +1,70 @@
// +build routerrpc
package main
import (
"context"
"fmt"
"strconv"
"github.com/btcsuite/btcutil"
"github.com/lightningnetwork/lnd/lnrpc/routerrpc"
"github.com/lightningnetwork/lnd/lnwire"
"github.com/lightningnetwork/lnd/routing/route"
"github.com/urfave/cli"
)
var queryProbCommand = cli.Command{
Name: "queryprob",
Category: "Payments",
Usage: "Estimate a success probability.",
ArgsUsage: "from-node to-node amt",
Action: actionDecorator(queryProb),
}
func queryProb(ctx *cli.Context) error {
args := ctx.Args()
if len(args) != 3 {
return cli.ShowCommandHelp(ctx, "queryprob")
}
fromNode, err := route.NewVertexFromStr(args.Get(0))
if err != nil {
return fmt.Errorf("invalid from node key: %v", err)
}
toNode, err := route.NewVertexFromStr(args.Get(1))
if err != nil {
return fmt.Errorf("invalid to node key: %v", err)
}
amtSat, err := strconv.ParseUint(args.Get(2), 10, 64)
if err != nil {
return fmt.Errorf("invalid amt: %v", err)
}
amtMsat := lnwire.NewMSatFromSatoshis(
btcutil.Amount(amtSat),
)
conn := getClientConn(ctx, false)
defer conn.Close()
client := routerrpc.NewRouterClient(conn)
req := &routerrpc.QueryProbabilityRequest{
FromNode: fromNode[:],
ToNode: toNode[:],
AmtMsat: int64(amtMsat),
}
rpcCtx := context.Background()
response, err := client.QueryProbability(rpcCtx, req)
if err != nil {
return err
}
printJSON(response)
return nil
}

1
cmd/lncli/routerrpc_active.go
View file

@ -8,6 +8,7 @@ import "github.com/urfave/cli"
func routerCommands() []cli.Command {
return []cli.Command{
queryMissionControlCommand,
queryProbCommand,
resetMissionControlCommand,
buildRouteCommand,
}

391
lnrpc/routerrpc/router.pb.go
View file

@ -1161,6 +1161,113 @@ func (m *PairData) GetLastAttemptSuccessful() bool {
return false
}
type QueryProbabilityRequest struct {
/// The source node pubkey of the pair.
FromNode []byte `protobuf:"bytes,1,opt,name=from_node,proto3" json:"from_node,omitempty"`
/// The destination node pubkey of the pair.
ToNode []byte `protobuf:"bytes,2,opt,name=to_node,proto3" json:"to_node,omitempty"`
/// The amount for which to calculate a probability.
AmtMsat int64 `protobuf:"varint,3,opt,name=amt_msat,proto3" json:"amt_msat,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *QueryProbabilityRequest) Reset() { *m = QueryProbabilityRequest{} }
func (m *QueryProbabilityRequest) String() string { return proto.CompactTextString(m) }
func (*QueryProbabilityRequest) ProtoMessage() {}
func (*QueryProbabilityRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_7a0613f69d37b0a5, []int{15}
}
func (m *QueryProbabilityRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_QueryProbabilityRequest.Unmarshal(m, b)
}
func (m *QueryProbabilityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_QueryProbabilityRequest.Marshal(b, m, deterministic)
}
func (m *QueryProbabilityRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryProbabilityRequest.Merge(m, src)
}
func (m *QueryProbabilityRequest) XXX_Size() int {
return xxx_messageInfo_QueryProbabilityRequest.Size(m)
}
func (m *QueryProbabilityRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryProbabilityRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryProbabilityRequest proto.InternalMessageInfo
func (m *QueryProbabilityRequest) GetFromNode() []byte {
if m != nil {
return m.FromNode
}
return nil
}
func (m *QueryProbabilityRequest) GetToNode() []byte {
if m != nil {
return m.ToNode
}
return nil
}
func (m *QueryProbabilityRequest) GetAmtMsat() int64 {
if m != nil {
return m.AmtMsat
}
return 0
}
type QueryProbabilityResponse struct {
/// The success probability for the requested pair.
Probability float64 `protobuf:"fixed64,1,opt,name=probability,proto3" json:"probability,omitempty"`
/// The historical data for the requested pair.
History *PairData `protobuf:"bytes,2,opt,name=history,proto3" json:"history,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *QueryProbabilityResponse) Reset() { *m = QueryProbabilityResponse{} }
func (m *QueryProbabilityResponse) String() string { return proto.CompactTextString(m) }
func (*QueryProbabilityResponse) ProtoMessage() {}
func (*QueryProbabilityResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_7a0613f69d37b0a5, []int{16}
}
func (m *QueryProbabilityResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_QueryProbabilityResponse.Unmarshal(m, b)
}
func (m *QueryProbabilityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_QueryProbabilityResponse.Marshal(b, m, deterministic)
}
func (m *QueryProbabilityResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryProbabilityResponse.Merge(m, src)
}
func (m *QueryProbabilityResponse) XXX_Size() int {
return xxx_messageInfo_QueryProbabilityResponse.Size(m)
}
func (m *QueryProbabilityResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryProbabilityResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryProbabilityResponse proto.InternalMessageInfo
func (m *QueryProbabilityResponse) GetProbability() float64 {
if m != nil {
return m.Probability
}
return 0
}
func (m *QueryProbabilityResponse) GetHistory() *PairData {
if m != nil {
return m.History
}
return nil
}
type BuildRouteRequest struct {
//*
//The amount to send expressed in msat. If set to zero, the minimum routable
@ -1187,7 +1294,7 @@ func (m *BuildRouteRequest) Reset() { *m = BuildRouteRequest{} }
func (m *BuildRouteRequest) String() string { return proto.CompactTextString(m) }
func (*BuildRouteRequest) ProtoMessage() {}
func (*BuildRouteRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_7a0613f69d37b0a5, []int{15}
return fileDescriptor_7a0613f69d37b0a5, []int{17}
}
func (m *BuildRouteRequest) XXX_Unmarshal(b []byte) error {
@ -1249,7 +1356,7 @@ func (m *BuildRouteResponse) Reset() { *m = BuildRouteResponse{} }
func (m *BuildRouteResponse) String() string { return proto.CompactTextString(m) }
func (*BuildRouteResponse) ProtoMessage() {}
func (*BuildRouteResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_7a0613f69d37b0a5, []int{16}
return fileDescriptor_7a0613f69d37b0a5, []int{18}
}
func (m *BuildRouteResponse) XXX_Unmarshal(b []byte) error {
@ -1296,6 +1403,8 @@ func init() {
proto.RegisterType((*QueryMissionControlResponse)(nil), "routerrpc.QueryMissionControlResponse")
proto.RegisterType((*PairHistory)(nil), "routerrpc.PairHistory")
proto.RegisterType((*PairData)(nil), "routerrpc.PairData")
proto.RegisterType((*QueryProbabilityRequest)(nil), "routerrpc.QueryProbabilityRequest")
proto.RegisterType((*QueryProbabilityResponse)(nil), "routerrpc.QueryProbabilityResponse")
proto.RegisterType((*BuildRouteRequest)(nil), "routerrpc.BuildRouteRequest")
proto.RegisterType((*BuildRouteResponse)(nil), "routerrpc.BuildRouteResponse")
}
@ -1303,123 +1412,128 @@ func init() {
func init() { proto.RegisterFile("routerrpc/router.proto", fileDescriptor_7a0613f69d37b0a5) }
var fileDescriptor_7a0613f69d37b0a5 = []byte{
// 1843 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x57, 0x41, 0x73, 0x22, 0xc7,
0x15, 0xf6, 0x08, 0x10, 0xf0, 0x00, 0x69, 0xd4, 0x92, 0xb5, 0x2c, 0x5a, 0x79, 0x65, 0xec, 0xd8,
0xaa, 0xad, 0xb5, 0xb4, 0x21, 0x65, 0xd7, 0x96, 0x0f, 0x49, 0xb1, 0xd0, 0x58, 0xa3, 0x85, 0x19,
0x6d, 0x03, 0x6b, 0x6f, 0x72, 0xe8, 0xea, 0x85, 0x96, 0x98, 0xd2, 0x30, 0x83, 0x67, 0x1a, 0x65,
0x95, 0x43, 0xaa, 0x72, 0x4f, 0xae, 0xf9, 0x0b, 0xb9, 0xe4, 0x96, 0x3f, 0x92, 0x5f, 0x91, 0xfc,
0x82, 0xdc, 0x53, 0xdd, 0x3d, 0x03, 0x83, 0x84, 0x36, 0x39, 0x89, 0xfe, 0xde, 0xf7, 0x5e, 0xf7,
0xbc, 0xf7, 0xfa, 0xeb, 0x27, 0xd8, 0x0f, 0x83, 0xb9, 0xe0, 0x61, 0x38, 0x1b, 0x9d, 0xea, 0x5f,
0x27, 0xb3, 0x30, 0x10, 0x01, 0x2a, 0x2e, 0xf0, 0x5a, 0x31, 0x9c, 0x8d, 0x34, 0x5a, 0xff, 0x53,
0x16, 0x50, 0x9f, 0xfb, 0xe3, 0x0b, 0x76, 0x3b, 0xe5, 0xbe, 0x20, 0xfc, 0xe7, 0x39, 0x8f, 0x04,
0x42, 0x90, 0x1d, 0xf3, 0x48, 0x54, 0x8d, 0x23, 0xe3, 0xb8, 0x4c, 0xd4, 0x6f, 0x64, 0x42, 0x86,
0x4d, 0x45, 0x75, 0xe3, 0xc8, 0x38, 0xce, 0x10, 0xf9, 0x13, 0x7d, 0x0e, 0xe5, 0x99, 0xf6, 0xa3,
0x13, 0x16, 0x4d, 0xaa, 0x19, 0xc5, 0x2e, 0xc5, 0xd8, 0x19, 0x8b, 0x26, 0xe8, 0x18, 0xcc, 0x4b,
0xd7, 0x67, 0x1e, 0x1d, 0x79, 0xe2, 0x86, 0x8e, 0xb9, 0x27, 0x58, 0x35, 0x7b, 0x64, 0x1c, 0xe7,
0xc8, 0x96, 0xc2, 0x5b, 0x9e, 0xb8, 0x69, 0x4b, 0x14, 0x7d, 0x0d, 0xdb, 0x49, 0xb0, 0x50, 0x9f,
0xa2, 0x9a, 0x3b, 0x32, 0x8e, 0x8b, 0x64, 0x6b, 0xb6, 0x7a, 0xb6, 0xaf, 0x61, 0x5b, 0xb8, 0x53,
0x1e, 0xcc, 0x05, 0x8d, 0xf8, 0x28, 0xf0, 0xc7, 0x51, 0x75, 0x53, 0x47, 0x8c, 0xe1, 0xbe, 0x46,
0x51, 0x1d, 0x2a, 0x97, 0x9c, 0x53, 0xcf, 0x9d, 0xba, 0x82, 0x46, 0x4c, 0x54, 0xf3, 0xea, 0xe8,
0xa5, 0x4b, 0xce, 0xbb, 0x12, 0xeb, 0x33, 0x81, 0x9e, 0x83, 0x19, 0xcc, 0xc5, 0x55, 0xe0, 0xfa,
0x57, 0x74, 0x34, 0x61, 0x3e, 0x75, 0xc7, 0xd5, 0xc2, 0x91, 0x71, 0x9c, 0x7d, 0xb5, 0xf1, 0xc2,
0x20, 0x5b, 0x89, 0xad, 0x35, 0x61, 0xbe, 0x35, 0x46, 0x87, 0x00, 0xea, 0x3b, 0x54, 0xc8, 0x6a,
0x51, 0xed, 0x5a, 0x94, 0x88, 0x8a, 0x87, 0x1a, 0x50, 0x52, 0x49, 0xa6, 0x13, 0xd7, 0x17, 0x51,
0x15, 0x8e, 0x32, 0xc7, 0xa5, 0x86, 0x79, 0xe2, 0xf9, 0x32, 0xdf, 0x44, 0x5a, 0xce, 0x5c, 0x5f,
0x90, 0x34, 0x09, 0x61, 0x28, 0xc8, 0xec, 0x52, 0xe1, 0xdd, 0x54, 0x4b, 0xca, 0xe1, 0xd9, 0xc9,
0xa2, 0x52, 0x27, 0xf7, 0x4b, 0x73, 0xd2, 0xe6, 0x91, 0x18, 0x78, 0x37, 0xd8, 0x17, 0xe1, 0x2d,
0xc9, 0x8f, 0xf5, 0xaa, 0xf6, 0x3d, 0x94, 0xd3, 0x06, 0x59, 0xac, 0x6b, 0x7e, 0xab, 0xea, 0x97,
0x25, 0xf2, 0x27, 0xda, 0x83, 0xdc, 0x0d, 0xf3, 0xe6, 0x5c, 0x15, 0xb0, 0x4c, 0xf4, 0xe2, 0xfb,
0x8d, 0x97, 0x46, 0xfd, 0x25, 0xec, 0x0e, 0x42, 0x36, 0xba, 0xbe, 0xd3, 0x03, 0x77, 0xab, 0x6b,
0xdc, 0xab, 0x6e, 0xfd, 0x8f, 0x50, 0x89, 0x9d, 0xfa, 0x82, 0x89, 0x79, 0x84, 0xbe, 0x81, 0x5c,
0x24, 0x98, 0xe0, 0x8a, 0xbc, 0xd5, 0x78, 0x94, 0xfa, 0x94, 0x14, 0x91, 0x13, 0xcd, 0x42, 0x35,
0x28, 0xcc, 0x42, 0xee, 0x4e, 0xd9, 0x55, 0x72, 0xac, 0xc5, 0x1a, 0xd5, 0x21, 0xa7, 0x9c, 0x55,
0x57, 0x95, 0x1a, 0xe5, 0x74, 0x1a, 0x89, 0x36, 0xd5, 0x7f, 0x0d, 0xdb, 0x6a, 0xdd, 0xe1, 0xfc,
0x63, 0x9d, 0xfb, 0x08, 0xf2, 0x6c, 0xaa, 0x5b, 0x40, 0x77, 0xef, 0x26, 0x9b, 0xca, 0xea, 0xd7,
0xc7, 0x60, 0x2e, 0xfd, 0xa3, 0x59, 0xe0, 0x47, 0x5c, 0x76, 0xac, 0x0c, 0x2e, 0x1b, 0x42, 0x76,
0xcf, 0x54, 0x7a, 0x19, 0xca, 0x6b, 0x2b, 0xc6, 0x3b, 0x9c, 0xf7, 0x22, 0x26, 0xd0, 0x57, 0xba,
0x11, 0xa9, 0x17, 0x8c, 0xae, 0x65, 0x6b, 0xb3, 0xdb, 0x38, 0x7c, 0x45, 0xc2, 0xdd, 0x60, 0x74,
0xdd, 0x96, 0x60, 0xfd, 0x77, 0xfa, 0x8a, 0x0d, 0x02, 0x7d, 0xf6, 0xff, 0x3b, 0xbd, 0xcb, 0x14,
0x6c, 0x3c, 0x9c, 0x02, 0x0a, 0xbb, 0x2b, 0xc1, 0xe3, 0xaf, 0x48, 0x67, 0xd6, 0xb8, 0x93, 0xd9,
0xe7, 0x90, 0xbf, 0x64, 0xae, 0x37, 0x0f, 0x93, 0xc0, 0x28, 0x55, 0xa6, 0x8e, 0xb6, 0x90, 0x84,
0x52, 0xff, 0x4f, 0x1e, 0xf2, 0x31, 0x88, 0x1a, 0x90, 0x1d, 0x05, 0xe3, 0xa4, 0xba, 0x9f, 0xdd,
0x77, 0x4b, 0xfe, 0xb6, 0x82, 0x31, 0x27, 0x8a, 0x8b, 0x7e, 0x03, 0x5b, 0xf2, 0x62, 0xf9, 0xdc,
0xa3, 0xf3, 0xd9, 0x98, 0x2d, 0x0a, 0x5a, 0x4d, 0x79, 0xb7, 0x34, 0x61, 0xa8, 0xec, 0xa4, 0x32,
0x4a, 0x2f, 0xd1, 0x01, 0x14, 0x27, 0xc2, 0x1b, 0xe9, 0x4a, 0x64, 0x55, 0x43, 0x17, 0x24, 0xa0,
0x6a, 0x50, 0x87, 0x4a, 0xe0, 0xbb, 0x81, 0x4f, 0xa3, 0x09, 0xa3, 0x8d, 0x6f, 0xbf, 0x53, 0x9a,
0x51, 0x26, 0x25, 0x05, 0xf6, 0x27, 0xac, 0xf1, 0xed, 0x77, 0xe8, 0x29, 0x94, 0xd4, 0xad, 0xe5,
0x1f, 0x66, 0x6e, 0x78, 0xab, 0xc4, 0xa2, 0x42, 0xd4, 0x45, 0xc6, 0x0a, 0x91, 0x57, 0xe3, 0xd2,
0x63, 0x57, 0x91, 0x12, 0x88, 0x0a, 0xd1, 0x0b, 0xf4, 0x02, 0xf6, 0xe2, 0x1c, 0xd0, 0x28, 0x98,
0x87, 0x23, 0x4e, 0x5d, 0x7f, 0xcc, 0x3f, 0x28, 0x79, 0xa8, 0x10, 0x14, 0xdb, 0xfa, 0xca, 0x64,
0x49, 0x0b, 0xda, 0x87, 0xcd, 0x09, 0x77, 0xaf, 0x26, 0x5a, 0x1a, 0x2a, 0x24, 0x5e, 0xd5, 0xff,
0x9e, 0x83, 0x52, 0x2a, 0x31, 0xa8, 0x0c, 0x05, 0x82, 0xfb, 0x98, 0xbc, 0xc5, 0x6d, 0xf3, 0x13,
0x74, 0x0c, 0x5f, 0x5a, 0x76, 0xcb, 0x21, 0x04, 0xb7, 0x06, 0xd4, 0x21, 0x74, 0x68, 0xbf, 0xb6,
0x9d, 0x1f, 0x6d, 0x7a, 0xd1, 0x7c, 0xd7, 0xc3, 0xf6, 0x80, 0xb6, 0xf1, 0xa0, 0x69, 0x75, 0xfb,
0xa6, 0x81, 0x9e, 0x40, 0x75, 0xc9, 0x4c, 0xcc, 0xcd, 0x9e, 0x33, 0xb4, 0x07, 0xe6, 0x06, 0x7a,
0x0a, 0x07, 0x1d, 0xcb, 0x6e, 0x76, 0xe9, 0x92, 0xd3, 0xea, 0x0e, 0xde, 0x52, 0xfc, 0xd3, 0x85,
0x45, 0xde, 0x99, 0x99, 0x75, 0x84, 0xb3, 0x41, 0xb7, 0x95, 0x44, 0xc8, 0xa2, 0xc7, 0xf0, 0xa9,
0x26, 0x68, 0x17, 0x3a, 0x70, 0x1c, 0xda, 0x77, 0x1c, 0xdb, 0xcc, 0xa1, 0x1d, 0xa8, 0x58, 0xf6,
0xdb, 0x66, 0xd7, 0x6a, 0x53, 0x82, 0x9b, 0xdd, 0x9e, 0xb9, 0x89, 0x76, 0x61, 0xfb, 0x2e, 0x2f,
0x2f, 0x43, 0x24, 0x3c, 0xc7, 0xb6, 0x1c, 0x9b, 0xbe, 0xc5, 0xa4, 0x6f, 0x39, 0xb6, 0x59, 0x40,
0xfb, 0x80, 0x56, 0x4d, 0x67, 0xbd, 0x66, 0xcb, 0x2c, 0xa2, 0x4f, 0x61, 0x67, 0x15, 0x7f, 0x8d,
0xdf, 0x99, 0x80, 0xaa, 0xb0, 0xa7, 0x0f, 0x46, 0x5f, 0xe1, 0xae, 0xf3, 0x23, 0xed, 0x59, 0xb6,
0xd5, 0x1b, 0xf6, 0xcc, 0x12, 0xda, 0x03, 0xb3, 0x83, 0x31, 0xb5, 0xec, 0xfe, 0xb0, 0xd3, 0xb1,
0x5a, 0x16, 0xb6, 0x07, 0x66, 0x59, 0xef, 0xbc, 0xee, 0xc3, 0x2b, 0xd2, 0xa1, 0x75, 0xd6, 0xb4,
0x6d, 0xdc, 0xa5, 0x6d, 0xab, 0xdf, 0x7c, 0xd5, 0xc5, 0x6d, 0x73, 0x0b, 0x1d, 0xc2, 0xe3, 0x01,
0xee, 0x5d, 0x38, 0xa4, 0x49, 0xde, 0xd1, 0xc4, 0xde, 0x69, 0x5a, 0xdd, 0x21, 0xc1, 0xe6, 0x36,
0xfa, 0x1c, 0x0e, 0x09, 0x7e, 0x33, 0xb4, 0x08, 0x6e, 0x53, 0xdb, 0x69, 0x63, 0xda, 0xc1, 0xcd,
0xc1, 0x90, 0x60, 0xda, 0xb3, 0xfa, 0x7d, 0xcb, 0xfe, 0xc1, 0x34, 0xd1, 0x97, 0x70, 0xb4, 0xa0,
0x2c, 0x02, 0xdc, 0x61, 0xed, 0xc8, 0xef, 0x4b, 0x4a, 0x6a, 0xe3, 0x9f, 0x06, 0xf4, 0x02, 0x63,
0x62, 0x22, 0x54, 0x83, 0xfd, 0xe5, 0xf6, 0x7a, 0x83, 0x78, 0xef, 0x5d, 0x69, 0xbb, 0xc0, 0xa4,
0xd7, 0xb4, 0x65, 0x81, 0x57, 0x6c, 0x7b, 0xf2, 0xd8, 0x4b, 0xdb, 0xdd, 0x63, 0x7f, 0x8a, 0x10,
0x6c, 0xa5, 0xaa, 0xd2, 0x69, 0x12, 0x73, 0x1f, 0xed, 0xc1, 0x76, 0x72, 0x82, 0x84, 0xf8, 0xaf,
0x3c, 0x7a, 0x04, 0x68, 0x68, 0x13, 0xdc, 0x6c, 0xcb, 0x84, 0x2c, 0x0c, 0xff, 0xce, 0x9f, 0x67,
0x0b, 0x1b, 0x66, 0xa6, 0xfe, 0x8f, 0x0c, 0x54, 0x56, 0xee, 0x25, 0x7a, 0x02, 0xc5, 0xc8, 0xbd,
0xf2, 0x99, 0x90, 0xca, 0xa1, 0x45, 0x65, 0x09, 0xa8, 0xb7, 0x71, 0xc2, 0x5c, 0x5f, 0xab, 0x99,
0x56, 0xf3, 0xa2, 0x42, 0x94, 0x96, 0x1d, 0x40, 0x3e, 0x79, 0x5f, 0x33, 0x8b, 0xf7, 0x75, 0x73,
0xa4, 0xdf, 0xd5, 0x27, 0x50, 0x94, 0x92, 0x19, 0x09, 0x36, 0x9d, 0xa9, 0x2b, 0x5e, 0x21, 0x4b,
0x00, 0x7d, 0x01, 0x95, 0x29, 0x8f, 0x22, 0x76, 0xc5, 0xa9, 0xbe, 0xa6, 0xa0, 0x18, 0xe5, 0x18,
0xec, 0xa8, 0xdb, 0xfa, 0x05, 0x24, 0xb2, 0x11, 0x93, 0x72, 0x9a, 0x14, 0x83, 0x9a, 0x74, 0x57,
0xb1, 0x05, 0x8b, 0xd5, 0x20, 0xad, 0xd8, 0x82, 0xa1, 0x67, 0xb0, 0xa3, 0x25, 0xc7, 0xf5, 0xdd,
0xe9, 0x7c, 0xaa, 0xa5, 0x27, 0xaf, 0xa4, 0x67, 0x5b, 0x49, 0x8f, 0xc6, 0x95, 0x02, 0x3d, 0x86,
0xc2, 0x7b, 0x16, 0x71, 0xf9, 0x58, 0xc4, 0xd2, 0x90, 0x97, 0xeb, 0x0e, 0xe7, 0xd2, 0x24, 0x9f,
0x90, 0x50, 0x8a, 0x9e, 0x56, 0x84, 0xfc, 0x25, 0xe7, 0x44, 0xe6, 0x72, 0xb1, 0x03, 0xfb, 0xb0,
0xdc, 0xa1, 0x94, 0xda, 0x41, 0xe3, 0x6a, 0x87, 0x67, 0xb0, 0xc3, 0x3f, 0x88, 0x90, 0xd1, 0x60,
0xc6, 0x7e, 0x9e, 0x73, 0x3a, 0x66, 0x82, 0x55, 0xcb, 0x2a, 0xc1, 0xdb, 0xca, 0xe0, 0x28, 0xbc,
0xcd, 0x04, 0xab, 0x3f, 0x81, 0x1a, 0xe1, 0x11, 0x17, 0x3d, 0x37, 0x8a, 0xdc, 0xc0, 0x6f, 0x05,
0xbe, 0x08, 0x03, 0x2f, 0x7e, 0x73, 0xea, 0x87, 0x70, 0xb0, 0xd6, 0xaa, 0x1f, 0x0d, 0xe9, 0xfc,
0x66, 0xce, 0xc3, 0xdb, 0xf5, 0xce, 0x6f, 0xe0, 0x60, 0xad, 0x35, 0x7e, 0x71, 0x9e, 0x43, 0x6e,
0xc6, 0xdc, 0x30, 0xaa, 0x6e, 0xa8, 0x29, 0x66, 0x7f, 0xe5, 0xe9, 0x77, 0xc3, 0x33, 0x37, 0x12,
0x41, 0x78, 0x4b, 0x34, 0xe9, 0x3c, 0x5b, 0x30, 0xcc, 0x8d, 0xfa, 0x9f, 0x0d, 0x28, 0xa5, 0x8c,
0xb2, 0x0f, 0xfc, 0x60, 0xcc, 0xe9, 0x65, 0x18, 0x4c, 0x93, 0x0e, 0x5b, 0x00, 0xa8, 0x0a, 0x79,
0xb5, 0x10, 0x41, 0xdc, 0x5e, 0xc9, 0x12, 0x7d, 0x03, 0xf9, 0x89, 0x0e, 0xa1, 0xaa, 0x54, 0x6a,
0xec, 0xde, 0xd9, 0x5d, 0xe6, 0x86, 0x24, 0x9c, 0xf3, 0x6c, 0x21, 0x63, 0x66, 0xcf, 0xb3, 0x85,
0xac, 0x99, 0x3b, 0xcf, 0x16, 0x72, 0xe6, 0xe6, 0x79, 0xb6, 0xb0, 0x69, 0xe6, 0xeb, 0x7f, 0x35,
0xa0, 0x90, 0xb0, 0x57, 0x7b, 0x52, 0x0f, 0x00, 0xa9, 0x9e, 0x6c, 0xc0, 0xde, 0xd4, 0xf5, 0xe9,
0x8c, 0xfb, 0xcc, 0x73, 0xff, 0xc0, 0xe9, 0xea, 0x7c, 0xb1, 0xd6, 0x86, 0x5e, 0xc2, 0x23, 0x8f,
0x45, 0x82, 0x32, 0x21, 0xf8, 0x74, 0x26, 0x68, 0x34, 0x1f, 0x8d, 0x78, 0x14, 0x5d, 0xce, 0x3d,
0x75, 0x25, 0x0a, 0xe4, 0x21, 0x73, 0xfd, 0x6f, 0x06, 0xec, 0xbc, 0x9a, 0xbb, 0xde, 0x78, 0x65,
0x82, 0x78, 0x0c, 0x05, 0x19, 0x3a, 0x35, 0xa1, 0xc8, 0x31, 0x47, 0xb5, 0xcc, 0xba, 0xb1, 0x7b,
0x63, 0xed, 0xd8, 0xbd, 0x6e, 0x00, 0xce, 0x3c, 0x38, 0x00, 0x3f, 0x85, 0xd2, 0x24, 0x98, 0xd1,
0xd9, 0xfc, 0xfd, 0x35, 0xbf, 0x8d, 0xaa, 0xd9, 0xa3, 0xcc, 0x71, 0x99, 0xc0, 0x24, 0x98, 0x5d,
0x68, 0xa4, 0xfe, 0x12, 0x50, 0xfa, 0xa0, 0x71, 0x6f, 0x2c, 0x06, 0x19, 0xe3, 0xc1, 0x41, 0xe6,
0xd9, 0x5f, 0x0c, 0x28, 0xa7, 0x67, 0x44, 0x54, 0x81, 0xa2, 0x65, 0xd3, 0x4e, 0xd7, 0xfa, 0xe1,
0x6c, 0x60, 0x7e, 0x22, 0x97, 0xfd, 0x61, 0xab, 0x85, 0x71, 0x1b, 0xb7, 0x4d, 0x43, 0xea, 0x9c,
0x94, 0x2c, 0xdc, 0xa6, 0x03, 0xab, 0x87, 0x9d, 0xa1, 0x7c, 0x01, 0x77, 0x61, 0x3b, 0xc6, 0x6c,
0x87, 0x12, 0x67, 0x38, 0xc0, 0x66, 0x06, 0x99, 0x50, 0x8e, 0x41, 0x4c, 0x88, 0x43, 0xcc, 0xac,
0x94, 0xed, 0x18, 0xb9, 0xff, 0x9a, 0x26, 0x8f, 0x6d, 0xae, 0xf1, 0xcf, 0x2c, 0x6c, 0xaa, 0x03,
0x86, 0xe8, 0x0c, 0x4a, 0xa9, 0x41, 0x1c, 0x1d, 0x7e, 0x74, 0x40, 0xaf, 0x55, 0xd7, 0x0f, 0xbd,
0xf3, 0xe8, 0x85, 0x81, 0xce, 0xa1, 0x9c, 0x1e, 0xb5, 0x51, 0x7a, 0x84, 0x5a, 0x33, 0x83, 0x7f,
0x34, 0xd6, 0x6b, 0x30, 0x71, 0x24, 0xdc, 0xa9, 0x1c, 0x99, 0xe2, 0x21, 0x16, 0xd5, 0x52, 0xfc,
0x3b, 0x93, 0x71, 0xed, 0x60, 0xad, 0x2d, 0xae, 0x50, 0x57, 0x7f, 0x62, 0x3c, 0x46, 0xde, 0xfb,
0xc4, 0xd5, 0xd9, 0xb5, 0xf6, 0xd9, 0x43, 0xe6, 0x38, 0xda, 0x18, 0x76, 0xd7, 0xe8, 0x0c, 0xfa,
0x45, 0xfa, 0x04, 0x0f, 0xaa, 0x54, 0xed, 0xab, 0xff, 0x45, 0x5b, 0xee, 0xb2, 0x46, 0x90, 0x56,
0x76, 0x79, 0x58, 0xce, 0x56, 0x76, 0xf9, 0x98, 0xae, 0x59, 0x00, 0xcb, 0x8e, 0x46, 0x4f, 0x52,
0x5e, 0xf7, 0x6e, 0x64, 0xed, 0xf0, 0x01, 0xab, 0x0e, 0xf5, 0xea, 0x97, 0xbf, 0x3d, 0xbd, 0x72,
0xc5, 0x64, 0xfe, 0xfe, 0x64, 0x14, 0x4c, 0x4f, 0x3d, 0x39, 0x1b, 0xfa, 0xae, 0x7f, 0xe5, 0x73,
0xf1, 0xfb, 0x20, 0xbc, 0x3e, 0xf5, 0xfc, 0xf1, 0xa9, 0xba, 0x18, 0xa7, 0x8b, 0x28, 0xef, 0x37,
0xd5, 0xbf, 0xe9, 0xbf, 0xfa, 0x6f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x1e, 0x33, 0xcc, 0xf1, 0xd6,
0x0f, 0x00, 0x00,
// 1931 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x58, 0x4f, 0x73, 0x22, 0xc7,
0x15, 0xf7, 0x08, 0x10, 0xf0, 0x00, 0x69, 0xd4, 0x92, 0xb5, 0xb3, 0x48, 0xf2, 0xca, 0xb3, 0x8e,
0xad, 0xda, 0x5a, 0x4b, 0x1b, 0x52, 0x76, 0x6d, 0xf9, 0x90, 0x14, 0x0b, 0x83, 0x35, 0x5a, 0x18,
0xb4, 0x0d, 0xac, 0xbd, 0xf1, 0xa1, 0xab, 0x05, 0x2d, 0x31, 0xa5, 0x61, 0x06, 0xcf, 0x34, 0x9b,
0x55, 0x0e, 0xa9, 0xca, 0x3d, 0xb9, 0xe6, 0x2b, 0xe4, 0x92, 0x9c, 0xf2, 0x9d, 0x92, 0x4f, 0x90,
0x7b, 0xaa, 0xbb, 0x67, 0x60, 0x40, 0x68, 0x9d, 0x93, 0xe8, 0xdf, 0x7b, 0xfd, 0xfa, 0xf5, 0xfb,
0xf3, 0xeb, 0x37, 0x82, 0xfd, 0x30, 0x98, 0x71, 0x16, 0x86, 0xd3, 0xe1, 0x99, 0xfa, 0x75, 0x3a,
0x0d, 0x03, 0x1e, 0xa0, 0xe2, 0x1c, 0xaf, 0x16, 0xc3, 0xe9, 0x50, 0xa1, 0xe6, 0x9f, 0xb3, 0x80,
0x7a, 0xcc, 0x1f, 0x5d, 0xd2, 0xbb, 0x09, 0xf3, 0x39, 0x66, 0x3f, 0xcf, 0x58, 0xc4, 0x11, 0x82,
0xec, 0x88, 0x45, 0xdc, 0xd0, 0x8e, 0xb5, 0x93, 0x32, 0x96, 0xbf, 0x91, 0x0e, 0x19, 0x3a, 0xe1,
0xc6, 0xc6, 0xb1, 0x76, 0x92, 0xc1, 0xe2, 0x27, 0xfa, 0x1c, 0xca, 0x53, 0xb5, 0x8f, 0x8c, 0x69,
0x34, 0x36, 0x32, 0x52, 0xbb, 0x14, 0x63, 0xe7, 0x34, 0x1a, 0xa3, 0x13, 0xd0, 0xaf, 0x5d, 0x9f,
0x7a, 0x64, 0xe8, 0xf1, 0xf7, 0x64, 0xc4, 0x3c, 0x4e, 0x8d, 0xec, 0xb1, 0x76, 0x92, 0xc3, 0x5b,
0x12, 0x6f, 0x78, 0xfc, 0x7d, 0x53, 0xa0, 0xe8, 0x2b, 0xd8, 0x4e, 0x8c, 0x85, 0xca, 0x0b, 0x23,
0x77, 0xac, 0x9d, 0x14, 0xf1, 0xd6, 0x74, 0xd9, 0xb7, 0xaf, 0x60, 0x9b, 0xbb, 0x13, 0x16, 0xcc,
0x38, 0x89, 0xd8, 0x30, 0xf0, 0x47, 0x91, 0xb1, 0xa9, 0x2c, 0xc6, 0x70, 0x4f, 0xa1, 0xc8, 0x84,
0xca, 0x35, 0x63, 0xc4, 0x73, 0x27, 0x2e, 0x27, 0x11, 0xe5, 0x46, 0x5e, 0xba, 0x5e, 0xba, 0x66,
0xac, 0x2d, 0xb0, 0x1e, 0xe5, 0xe8, 0x39, 0xe8, 0xc1, 0x8c, 0xdf, 0x04, 0xae, 0x7f, 0x43, 0x86,
0x63, 0xea, 0x13, 0x77, 0x64, 0x14, 0x8e, 0xb5, 0x93, 0xec, 0xab, 0x8d, 0x17, 0x1a, 0xde, 0x4a,
0x64, 0x8d, 0x31, 0xf5, 0xed, 0x11, 0x3a, 0x02, 0x90, 0xf7, 0x90, 0x26, 0x8d, 0xa2, 0x3c, 0xb5,
0x28, 0x10, 0x69, 0x0f, 0xd5, 0xa0, 0x24, 0x83, 0x4c, 0xc6, 0xae, 0xcf, 0x23, 0x03, 0x8e, 0x33,
0x27, 0xa5, 0x9a, 0x7e, 0xea, 0xf9, 0x22, 0xde, 0x58, 0x48, 0xce, 0x5d, 0x9f, 0xe3, 0xb4, 0x12,
0xb2, 0xa0, 0x20, 0xa2, 0x4b, 0xb8, 0xf7, 0xde, 0x28, 0xc9, 0x0d, 0xcf, 0x4e, 0xe7, 0x99, 0x3a,
0xbd, 0x9f, 0x9a, 0xd3, 0x26, 0x8b, 0x78, 0xdf, 0x7b, 0x6f, 0xf9, 0x3c, 0xbc, 0xc3, 0xf9, 0x91,
0x5a, 0x55, 0xbf, 0x83, 0x72, 0x5a, 0x20, 0x92, 0x75, 0xcb, 0xee, 0x64, 0xfe, 0xb2, 0x58, 0xfc,
0x44, 0x7b, 0x90, 0x7b, 0x4f, 0xbd, 0x19, 0x93, 0x09, 0x2c, 0x63, 0xb5, 0xf8, 0x6e, 0xe3, 0xa5,
0x66, 0xbe, 0x84, 0xdd, 0x7e, 0x48, 0x87, 0xb7, 0x2b, 0x35, 0xb0, 0x9a, 0x5d, 0xed, 0x5e, 0x76,
0xcd, 0x3f, 0x41, 0x25, 0xde, 0xd4, 0xe3, 0x94, 0xcf, 0x22, 0xf4, 0x35, 0xe4, 0x22, 0x4e, 0x39,
0x93, 0xca, 0x5b, 0xb5, 0x47, 0xa9, 0xab, 0xa4, 0x14, 0x19, 0x56, 0x5a, 0xa8, 0x0a, 0x85, 0x69,
0xc8, 0xdc, 0x09, 0xbd, 0x49, 0xdc, 0x9a, 0xaf, 0x91, 0x09, 0x39, 0xb9, 0x59, 0x56, 0x55, 0xa9,
0x56, 0x4e, 0x87, 0x11, 0x2b, 0x91, 0xf9, 0x5b, 0xd8, 0x96, 0xeb, 0x16, 0x63, 0x1f, 0xab, 0xdc,
0x47, 0x90, 0xa7, 0x13, 0x55, 0x02, 0xaa, 0x7a, 0x37, 0xe9, 0x44, 0x64, 0xdf, 0x1c, 0x81, 0xbe,
0xd8, 0x1f, 0x4d, 0x03, 0x3f, 0x62, 0xa2, 0x62, 0x85, 0x71, 0x51, 0x10, 0xa2, 0x7a, 0x26, 0x62,
0x97, 0x26, 0x77, 0x6d, 0xc5, 0x78, 0x8b, 0xb1, 0x4e, 0x44, 0x39, 0xfa, 0x52, 0x15, 0x22, 0xf1,
0x82, 0xe1, 0xad, 0x28, 0x6d, 0x7a, 0x17, 0x9b, 0xaf, 0x08, 0xb8, 0x1d, 0x0c, 0x6f, 0x9b, 0x02,
0x34, 0x7f, 0x52, 0x2d, 0xd6, 0x0f, 0x94, 0xef, 0xff, 0x77, 0x78, 0x17, 0x21, 0xd8, 0x78, 0x38,
0x04, 0x04, 0x76, 0x97, 0x8c, 0xc7, 0xb7, 0x48, 0x47, 0x56, 0x5b, 0x89, 0xec, 0x73, 0xc8, 0x5f,
0x53, 0xd7, 0x9b, 0x85, 0x89, 0x61, 0x94, 0x4a, 0x53, 0x4b, 0x49, 0x70, 0xa2, 0x62, 0xfe, 0x37,
0x0f, 0xf9, 0x18, 0x44, 0x35, 0xc8, 0x0e, 0x83, 0x51, 0x92, 0xdd, 0xcf, 0xee, 0x6f, 0x4b, 0xfe,
0x36, 0x82, 0x11, 0xc3, 0x52, 0x17, 0xfd, 0x0e, 0xb6, 0x44, 0x63, 0xf9, 0xcc, 0x23, 0xb3, 0xe9,
0x88, 0xce, 0x13, 0x6a, 0xa4, 0x76, 0x37, 0x94, 0xc2, 0x40, 0xca, 0x71, 0x65, 0x98, 0x5e, 0xa2,
0x03, 0x28, 0x8e, 0xb9, 0x37, 0x54, 0x99, 0xc8, 0xca, 0x82, 0x2e, 0x08, 0x40, 0xe6, 0xc0, 0x84,
0x4a, 0xe0, 0xbb, 0x81, 0x4f, 0xa2, 0x31, 0x25, 0xb5, 0x6f, 0xbe, 0x95, 0x9c, 0x51, 0xc6, 0x25,
0x09, 0xf6, 0xc6, 0xb4, 0xf6, 0xcd, 0xb7, 0xe8, 0x09, 0x94, 0x64, 0xd7, 0xb2, 0x0f, 0x53, 0x37,
0xbc, 0x93, 0x64, 0x51, 0xc1, 0xb2, 0x91, 0x2d, 0x89, 0x88, 0xd6, 0xb8, 0xf6, 0xe8, 0x4d, 0x24,
0x09, 0xa2, 0x82, 0xd5, 0x02, 0xbd, 0x80, 0xbd, 0x38, 0x06, 0x24, 0x0a, 0x66, 0xe1, 0x90, 0x11,
0xd7, 0x1f, 0xb1, 0x0f, 0x92, 0x1e, 0x2a, 0x18, 0xc5, 0xb2, 0x9e, 0x14, 0xd9, 0x42, 0x82, 0xf6,
0x61, 0x73, 0xcc, 0xdc, 0x9b, 0xb1, 0xa2, 0x86, 0x0a, 0x8e, 0x57, 0xe6, 0x3f, 0x72, 0x50, 0x4a,
0x05, 0x06, 0x95, 0xa1, 0x80, 0xad, 0x9e, 0x85, 0xdf, 0x5a, 0x4d, 0xfd, 0x13, 0x74, 0x02, 0x5f,
0xd8, 0x4e, 0xa3, 0x8b, 0xb1, 0xd5, 0xe8, 0x93, 0x2e, 0x26, 0x03, 0xe7, 0xb5, 0xd3, 0xfd, 0xc1,
0x21, 0x97, 0xf5, 0x77, 0x1d, 0xcb, 0xe9, 0x93, 0xa6, 0xd5, 0xaf, 0xdb, 0xed, 0x9e, 0xae, 0xa1,
0x43, 0x30, 0x16, 0x9a, 0x89, 0xb8, 0xde, 0xe9, 0x0e, 0x9c, 0xbe, 0xbe, 0x81, 0x9e, 0xc0, 0x41,
0xcb, 0x76, 0xea, 0x6d, 0xb2, 0xd0, 0x69, 0xb4, 0xfb, 0x6f, 0x89, 0xf5, 0xe3, 0xa5, 0x8d, 0xdf,
0xe9, 0x99, 0x75, 0x0a, 0xe7, 0xfd, 0x76, 0x23, 0xb1, 0x90, 0x45, 0x8f, 0xe1, 0x53, 0xa5, 0xa0,
0xb6, 0x90, 0x7e, 0xb7, 0x4b, 0x7a, 0xdd, 0xae, 0xa3, 0xe7, 0xd0, 0x0e, 0x54, 0x6c, 0xe7, 0x6d,
0xbd, 0x6d, 0x37, 0x09, 0xb6, 0xea, 0xed, 0x8e, 0xbe, 0x89, 0x76, 0x61, 0x7b, 0x55, 0x2f, 0x2f,
0x4c, 0x24, 0x7a, 0x5d, 0xc7, 0xee, 0x3a, 0xe4, 0xad, 0x85, 0x7b, 0x76, 0xd7, 0xd1, 0x0b, 0x68,
0x1f, 0xd0, 0xb2, 0xe8, 0xbc, 0x53, 0x6f, 0xe8, 0x45, 0xf4, 0x29, 0xec, 0x2c, 0xe3, 0xaf, 0xad,
0x77, 0x3a, 0x20, 0x03, 0xf6, 0x94, 0x63, 0xe4, 0x95, 0xd5, 0xee, 0xfe, 0x40, 0x3a, 0xb6, 0x63,
0x77, 0x06, 0x1d, 0xbd, 0x84, 0xf6, 0x40, 0x6f, 0x59, 0x16, 0xb1, 0x9d, 0xde, 0xa0, 0xd5, 0xb2,
0x1b, 0xb6, 0xe5, 0xf4, 0xf5, 0xb2, 0x3a, 0x79, 0xdd, 0xc5, 0x2b, 0x62, 0x43, 0xe3, 0xbc, 0xee,
0x38, 0x56, 0x9b, 0x34, 0xed, 0x5e, 0xfd, 0x55, 0xdb, 0x6a, 0xea, 0x5b, 0xe8, 0x08, 0x1e, 0xf7,
0xad, 0xce, 0x65, 0x17, 0xd7, 0xf1, 0x3b, 0x92, 0xc8, 0x5b, 0x75, 0xbb, 0x3d, 0xc0, 0x96, 0xbe,
0x8d, 0x3e, 0x87, 0x23, 0x6c, 0xbd, 0x19, 0xd8, 0xd8, 0x6a, 0x12, 0xa7, 0xdb, 0xb4, 0x48, 0xcb,
0xaa, 0xf7, 0x07, 0xd8, 0x22, 0x1d, 0xbb, 0xd7, 0xb3, 0x9d, 0xef, 0x75, 0x1d, 0x7d, 0x01, 0xc7,
0x73, 0x95, 0xb9, 0x81, 0x15, 0xad, 0x1d, 0x71, 0xbf, 0x24, 0xa5, 0x8e, 0xf5, 0x63, 0x9f, 0x5c,
0x5a, 0x16, 0xd6, 0x11, 0xaa, 0xc2, 0xfe, 0xe2, 0x78, 0x75, 0x40, 0x7c, 0xf6, 0xae, 0x90, 0x5d,
0x5a, 0xb8, 0x53, 0x77, 0x44, 0x82, 0x97, 0x64, 0x7b, 0xc2, 0xed, 0x85, 0x6c, 0xd5, 0xed, 0x4f,
0x11, 0x82, 0xad, 0x54, 0x56, 0x5a, 0x75, 0xac, 0xef, 0xa3, 0x3d, 0xd8, 0x4e, 0x3c, 0x48, 0x14,
0xff, 0x9d, 0x47, 0x8f, 0x00, 0x0d, 0x1c, 0x6c, 0xd5, 0x9b, 0x22, 0x20, 0x73, 0xc1, 0x7f, 0xf2,
0x17, 0xd9, 0xc2, 0x86, 0x9e, 0x31, 0xff, 0x95, 0x81, 0xca, 0x52, 0x5f, 0xa2, 0x43, 0x28, 0x46,
0xee, 0x8d, 0x4f, 0xb9, 0x60, 0x0e, 0x45, 0x2a, 0x0b, 0x40, 0xbe, 0x8d, 0x63, 0xea, 0xfa, 0x8a,
0xcd, 0x14, 0x9b, 0x17, 0x25, 0x22, 0xb9, 0xec, 0x00, 0xf2, 0xc9, 0xfb, 0x9a, 0x99, 0xbf, 0xaf,
0x9b, 0x43, 0xf5, 0xae, 0x1e, 0x42, 0x51, 0x50, 0x66, 0xc4, 0xe9, 0x64, 0x2a, 0x5b, 0xbc, 0x82,
0x17, 0x00, 0x7a, 0x0a, 0x95, 0x09, 0x8b, 0x22, 0x7a, 0xc3, 0x88, 0x6a, 0x53, 0x90, 0x1a, 0xe5,
0x18, 0x6c, 0xc9, 0x6e, 0x7d, 0x0a, 0x09, 0x6d, 0xc4, 0x4a, 0x39, 0xa5, 0x14, 0x83, 0x4a, 0x69,
0x95, 0xb1, 0x39, 0x8d, 0xd9, 0x20, 0xcd, 0xd8, 0x9c, 0xa2, 0x67, 0xb0, 0xa3, 0x28, 0xc7, 0xf5,
0xdd, 0xc9, 0x6c, 0xa2, 0xa8, 0x27, 0x2f, 0xa9, 0x67, 0x5b, 0x52, 0x8f, 0xc2, 0x25, 0x03, 0x3d,
0x86, 0xc2, 0x15, 0x8d, 0x98, 0x78, 0x2c, 0x62, 0x6a, 0xc8, 0x8b, 0x75, 0x8b, 0x31, 0x21, 0x12,
0x4f, 0x48, 0x28, 0x48, 0x4f, 0x31, 0x42, 0xfe, 0x9a, 0x31, 0x2c, 0x62, 0x39, 0x3f, 0x81, 0x7e,
0x58, 0x9c, 0x50, 0x4a, 0x9d, 0xa0, 0x70, 0x79, 0xc2, 0x33, 0xd8, 0x61, 0x1f, 0x78, 0x48, 0x49,
0x30, 0xa5, 0x3f, 0xcf, 0x18, 0x19, 0x51, 0x4e, 0x8d, 0xb2, 0x0c, 0xf0, 0xb6, 0x14, 0x74, 0x25,
0xde, 0xa4, 0x9c, 0x9a, 0x87, 0x50, 0xc5, 0x2c, 0x62, 0xbc, 0xe3, 0x46, 0x91, 0x1b, 0xf8, 0x8d,
0xc0, 0xe7, 0x61, 0xe0, 0xc5, 0x6f, 0x8e, 0x79, 0x04, 0x07, 0x6b, 0xa5, 0xea, 0xd1, 0x10, 0x9b,
0xdf, 0xcc, 0x58, 0x78, 0xb7, 0x7e, 0xf3, 0x1b, 0x38, 0x58, 0x2b, 0x8d, 0x5f, 0x9c, 0xe7, 0x90,
0x9b, 0x52, 0x37, 0x8c, 0x8c, 0x0d, 0x39, 0xc5, 0xec, 0x2f, 0x3d, 0xfd, 0x6e, 0x78, 0xee, 0x46,
0x3c, 0x08, 0xef, 0xb0, 0x52, 0xba, 0xc8, 0x16, 0x34, 0x7d, 0xc3, 0xfc, 0x8b, 0x06, 0xa5, 0x94,
0x50, 0xd4, 0x81, 0x1f, 0x8c, 0x18, 0xb9, 0x0e, 0x83, 0x49, 0x52, 0x61, 0x73, 0x00, 0x19, 0x90,
0x97, 0x0b, 0x1e, 0xc4, 0xe5, 0x95, 0x2c, 0xd1, 0xd7, 0x90, 0x1f, 0x2b, 0x13, 0x32, 0x4b, 0xa5,
0xda, 0xee, 0xca, 0xe9, 0x22, 0x36, 0x38, 0xd1, 0xb9, 0xc8, 0x16, 0x32, 0x7a, 0xf6, 0x22, 0x5b,
0xc8, 0xea, 0xb9, 0x8b, 0x6c, 0x21, 0xa7, 0x6f, 0x5e, 0x64, 0x0b, 0x9b, 0x7a, 0xde, 0xfc, 0x9b,
0x06, 0x85, 0x44, 0x7b, 0xb9, 0x26, 0xd5, 0x00, 0x90, 0xaa, 0xc9, 0x1a, 0xec, 0x4d, 0x5c, 0x9f,
0x4c, 0x99, 0x4f, 0x3d, 0xf7, 0x8f, 0x8c, 0x2c, 0xcf, 0x17, 0x6b, 0x65, 0xe8, 0x25, 0x3c, 0xf2,
0x68, 0xc4, 0x09, 0xe5, 0x9c, 0x4d, 0xa6, 0x9c, 0x44, 0xb3, 0xe1, 0x90, 0x45, 0xd1, 0xf5, 0xcc,
0x93, 0x2d, 0x51, 0xc0, 0x0f, 0x89, 0xcd, 0x09, 0x3c, 0x92, 0xa1, 0xbf, 0x0c, 0x83, 0x2b, 0x7a,
0xe5, 0x7a, 0x2e, 0xbf, 0x4b, 0xc6, 0x88, 0x43, 0x28, 0x8a, 0xe0, 0x10, 0x3f, 0x79, 0x97, 0xcb,
0x78, 0x01, 0x88, 0x90, 0xf1, 0x40, 0xc9, 0xe2, 0x90, 0xc5, 0x4b, 0x31, 0x20, 0x08, 0xbf, 0x64,
0xdd, 0x65, 0xa4, 0xd3, 0xf3, 0xb5, 0x79, 0x0b, 0xc6, 0xfd, 0xe3, 0xe2, 0x34, 0x1f, 0x43, 0x69,
0xba, 0x80, 0xe5, 0x89, 0x1a, 0x4e, 0x43, 0xe9, 0x64, 0x6c, 0xfc, 0x72, 0x32, 0xcc, 0xbf, 0x6b,
0xb0, 0xf3, 0x6a, 0xe6, 0x7a, 0xa3, 0xa5, 0xe9, 0xe8, 0x71, 0xca, 0x3d, 0x15, 0x7c, 0x31, 0xc2,
0xc9, 0x76, 0x58, 0xf7, 0x49, 0xb1, 0xb1, 0xf6, 0x93, 0x62, 0xdd, 0x70, 0x9f, 0x79, 0x70, 0xb8,
0x7f, 0x02, 0xa5, 0x71, 0x30, 0x25, 0xd3, 0xd9, 0xd5, 0x2d, 0xbb, 0x8b, 0x8c, 0xec, 0x71, 0xe6,
0xa4, 0x8c, 0x61, 0x1c, 0x4c, 0x2f, 0x15, 0x62, 0xbe, 0x04, 0x94, 0x76, 0x34, 0x0e, 0xc8, 0x7c,
0x48, 0xd3, 0x1e, 0x1c, 0xd2, 0x9e, 0xfd, 0x55, 0x83, 0x72, 0x7a, 0xfe, 0x45, 0x15, 0x28, 0xda,
0x0e, 0x69, 0xb5, 0xed, 0xef, 0xcf, 0xfb, 0xfa, 0x27, 0x62, 0xd9, 0x1b, 0x34, 0x1a, 0x96, 0xd5,
0xb4, 0x9a, 0xba, 0x26, 0x38, 0x5c, 0xd0, 0xb1, 0xd5, 0x24, 0x7d, 0xbb, 0x63, 0x75, 0x07, 0xe2,
0x75, 0xdf, 0x85, 0xed, 0x18, 0x73, 0xba, 0x04, 0x77, 0x07, 0x7d, 0x4b, 0xcf, 0x20, 0x1d, 0xca,
0x31, 0x68, 0x61, 0xdc, 0xc5, 0x7a, 0x56, 0x3c, 0x49, 0x31, 0x72, 0x7f, 0x52, 0x48, 0x06, 0x89,
0x5c, 0xed, 0x9f, 0x39, 0xd8, 0x94, 0x0e, 0x86, 0xe8, 0x1c, 0x4a, 0xa9, 0x8f, 0x0c, 0x74, 0xf4,
0xd1, 0x8f, 0x8f, 0xaa, 0xb1, 0x7e, 0xa0, 0x9f, 0x45, 0x2f, 0x34, 0x74, 0x01, 0xe5, 0xf4, 0x67,
0x04, 0x4a, 0x8f, 0x87, 0x6b, 0xbe, 0x2f, 0x3e, 0x6a, 0xeb, 0x35, 0xe8, 0x56, 0xc4, 0xdd, 0x89,
0x18, 0x07, 0xe3, 0x01, 0x1d, 0x55, 0x53, 0xfa, 0x2b, 0x53, 0x7f, 0xf5, 0x60, 0xad, 0x2c, 0xce,
0x50, 0x5b, 0x5d, 0x31, 0x1e, 0x91, 0xef, 0x5d, 0x71, 0x79, 0x2e, 0xaf, 0x7e, 0xf6, 0x90, 0x38,
0xb6, 0x36, 0x82, 0xdd, 0x35, 0x1c, 0x8a, 0x7e, 0x95, 0xf6, 0xe0, 0x41, 0x06, 0xae, 0x7e, 0xf9,
0x4b, 0x6a, 0x8b, 0x53, 0xd6, 0x90, 0xed, 0xd2, 0x29, 0x0f, 0x53, 0xf5, 0xd2, 0x29, 0x1f, 0xe3,
0xec, 0x9f, 0x40, 0x5f, 0x6d, 0x74, 0x64, 0xae, 0xee, 0xbd, 0x4f, 0x3a, 0xd5, 0xa7, 0x1f, 0xd5,
0x89, 0x8d, 0xdb, 0x00, 0x8b, 0x76, 0x41, 0x87, 0xa9, 0x2d, 0xf7, 0xda, 0xbd, 0x7a, 0xf4, 0x80,
0x54, 0x99, 0x7a, 0xf5, 0xeb, 0xdf, 0x9f, 0xdd, 0xb8, 0x7c, 0x3c, 0xbb, 0x3a, 0x1d, 0x06, 0x93,
0x33, 0x4f, 0x0c, 0xd5, 0xbe, 0xeb, 0xdf, 0xf8, 0x8c, 0xff, 0x21, 0x08, 0x6f, 0xcf, 0x3c, 0x7f,
0x74, 0x26, 0xbb, 0xee, 0x6c, 0x6e, 0xe5, 0x6a, 0x53, 0xfe, 0x7f, 0xe3, 0x37, 0xff, 0x0b, 0x00,
0x00, 0xff, 0xff, 0x1d, 0x08, 0x9a, 0xb8, 0x0f, 0x11, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
@ -1461,6 +1575,10 @@ type RouterClient interface {
//It is a development feature.
QueryMissionControl(ctx context.Context, in *QueryMissionControlRequest, opts ...grpc.CallOption) (*QueryMissionControlResponse, error)
//*
//QueryProbability returns the current success probability estimate for a
//given node pair and amount.
QueryProbability(ctx context.Context, in *QueryProbabilityRequest, opts ...grpc.CallOption) (*QueryProbabilityResponse, error)
//*
//BuildRoute builds a fully specified route based on a list of hop public
//keys. It retrieves the relevant channel policies from the graph in order to
//calculate the correct fees and time locks.
@ -1575,6 +1693,15 @@ func (c *routerClient) QueryMissionControl(ctx context.Context, in *QueryMission
return out, nil
}
func (c *routerClient) QueryProbability(ctx context.Context, in *QueryProbabilityRequest, opts ...grpc.CallOption) (*QueryProbabilityResponse, error) {
out := new(QueryProbabilityResponse)
err := c.cc.Invoke(ctx, "/routerrpc.Router/QueryProbability", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *routerClient) BuildRoute(ctx context.Context, in *BuildRouteRequest, opts ...grpc.CallOption) (*BuildRouteResponse, error) {
out := new(BuildRouteResponse)
err := c.cc.Invoke(ctx, "/routerrpc.Router/BuildRoute", in, out, opts...)
@ -1613,6 +1740,10 @@ type RouterServer interface {
//It is a development feature.
QueryMissionControl(context.Context, *QueryMissionControlRequest) (*QueryMissionControlResponse, error)
//*
//QueryProbability returns the current success probability estimate for a
//given node pair and amount.
QueryProbability(context.Context, *QueryProbabilityRequest) (*QueryProbabilityResponse, error)
//*
//BuildRoute builds a fully specified route based on a list of hop public
//keys. It retrieves the relevant channel policies from the graph in order to
//calculate the correct fees and time locks.
@ -1737,6 +1868,24 @@ func _Router_QueryMissionControl_Handler(srv interface{}, ctx context.Context, d
return interceptor(ctx, in, info, handler)
}
func _Router_QueryProbability_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryProbabilityRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RouterServer).QueryProbability(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/routerrpc.Router/QueryProbability",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RouterServer).QueryProbability(ctx, req.(*QueryProbabilityRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Router_BuildRoute_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(BuildRouteRequest)
if err := dec(in); err != nil {
@ -1775,6 +1924,10 @@ var _Router_serviceDesc = grpc.ServiceDesc{
MethodName: "QueryMissionControl",
Handler: _Router_QueryMissionControl_Handler,
},
{
MethodName: "QueryProbability",
Handler: _Router_QueryProbability_Handler,
},
{
MethodName: "BuildRoute",
Handler: _Router_BuildRoute_Handler,

25
lnrpc/routerrpc/router.proto
View file

@ -367,6 +367,25 @@ message PairData {
bool last_attempt_successful = 3 [json_name = "last_attempt_successful"];
}
message QueryProbabilityRequest{
/// The source node pubkey of the pair.
bytes from_node = 1 [json_name = "from_node"];
/// The destination node pubkey of the pair.
bytes to_node = 2 [json_name = "to_node"];
/// The amount for which to calculate a probability.
int64 amt_msat = 3 [json_name = "amt_msat"];
}
message QueryProbabilityResponse{
/// The success probability for the requested pair.
double probability = 1 [json_name = "probability"];
/// The historical data for the requested pair.
PairData history = 2 [json_name = "history"];
}
message BuildRouteRequest {
/**
The amount to send expressed in msat. If set to zero, the minimum routable
@ -440,6 +459,12 @@ service Router {
*/
rpc QueryMissionControl(QueryMissionControlRequest) returns (QueryMissionControlResponse);
/**
QueryProbability returns the current success probability estimate for a
given node pair and amount.
*/
rpc QueryProbability(QueryProbabilityRequest) returns (QueryProbabilityResponse);
/**
BuildRoute builds a fully specified route based on a list of hop public
keys. It retrieves the relevant channel policies from the graph in order to

5
lnrpc/routerrpc/router_backend.go
View file

@ -76,6 +76,11 @@ type MissionControl interface {
// GetHistorySnapshot takes a snapshot from the current mission control
// state and actual probability estimates.
GetHistorySnapshot() *routing.MissionControlSnapshot
// GetPairHistorySnapshot returns the stored history for a given node
// pair.
GetPairHistorySnapshot(fromNode,
toNode route.Vertex) routing.TimedPairResult
}
// QueryRoutes attempts to query the daemons' Channel Router for a possible

6
lnrpc/routerrpc/router_backend_test.go
View file

@ -174,3 +174,9 @@ func (m *mockMissionControl) ResetHistory() error {
func (m *mockMissionControl) GetHistorySnapshot() *routing.MissionControlSnapshot {
return nil
}
func (m *mockMissionControl) GetPairHistorySnapshot(fromNode,
toNode route.Vertex) routing.TimedPairResult {
return routing.TimedPairResult{}
}

31
lnrpc/routerrpc/router_server.go
View file

@ -68,6 +68,10 @@ var (
Entity: "offchain",
Action: "read",
}},
"/routerrpc.Router/QueryProbability": {{
Entity: "offchain",
Action: "read",
}},
"/routerrpc.Router/ResetMissionControl": {{
Entity: "offchain",
Action: "write",
@ -503,6 +507,33 @@ func toRPCPairData(data *routing.TimedPairResult) *PairData {
return &rpcData
}
// QueryProbability returns the current success probability estimate for a
// given node pair and amount.
func (s *Server) QueryProbability(ctx context.Context,
req *QueryProbabilityRequest) (*QueryProbabilityResponse, error) {
fromNode, err := route.NewVertexFromBytes(req.FromNode)
if err != nil {
return nil, err
}
toNode, err := route.NewVertexFromBytes(req.ToNode)
if err != nil {
return nil, err
}
amt := lnwire.MilliSatoshi(req.AmtMsat)
mc := s.cfg.RouterBackend.MissionControl
prob := mc.GetProbability(fromNode, toNode, amt)
history := mc.GetPairHistorySnapshot(fromNode, toNode)
return &QueryProbabilityResponse{
Probability: prob,
History: toRPCPairData(&history),
}, nil
}
// TrackPayment returns a stream of payment state updates. The stream is
// closed when the payment completes.
func (s *Server) TrackPayment(request *TrackPaymentRequest,

20
routing/missioncontrol.go
View file

@ -355,6 +355,26 @@ func (m *MissionControl) GetHistorySnapshot() *MissionControlSnapshot {
return &snapshot
}
// GetPairHistorySnapshot returns the stored history for a given node pair.
func (m *MissionControl) GetPairHistorySnapshot(
fromNode, toNode route.Vertex) TimedPairResult {
m.Lock()
defer m.Unlock()
results, ok := m.lastPairResult[fromNode]
if !ok {
return TimedPairResult{}
}
result, ok := results[toNode]
if !ok {
return TimedPairResult{}
}
return result
}
// ReportPaymentFail reports a failed payment to mission control as input for
// future probability estimates. The failureSourceIdx argument indicates the
// failure source. If it is nil, the failure source is unknown. This function