Archives
/
loop
mirror of https://github.com/lightninglabs/loop
2
0
Fork 0
Code Issues Releases Wiki Activity

looprpc: request and response params for new getInfo rpc

Browse Source
pull/586/head
Slyghtning 12 months ago
parent cb8975d605
commit 7f6f265db3
5 changed files with 642 additions and 106 deletions
Show Stats Download Patch File Download Diff File

539
looprpc/client.pb.go
Unescape Escape View File

@ -2074,6 +2074,252 @@ func (x *LsatToken) GetStorageName() string {
return "" return ""
} }
type LoopStats struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
//
//Number of currently pending swaps.
PendingCount uint64 `protobuf:"varint,1,opt,name=pending_count,json=pendingCount,proto3" json:"pending_count,omitempty"`
//
//Number of succeeded swaps.
SuccessCount uint64 `protobuf:"varint,2,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"`
//
//Number failed swaps.
FailCount uint64 `protobuf:"varint,3,opt,name=fail_count,json=failCount,proto3" json:"fail_count,omitempty"`
//
//The sum of all pending swap amounts.
SumPendingAmt int64 `protobuf:"varint,4,opt,name=sum_pending_amt,json=sumPendingAmt,proto3" json:"sum_pending_amt,omitempty"`
//
//The sum of all succeeded swap amounts.
SumSucceededAmt int64 `protobuf:"varint,5,opt,name=sum_succeeded_amt,json=sumSucceededAmt,proto3" json:"sum_succeeded_amt,omitempty"`
}
func (x *LoopStats) Reset() {
*x = LoopStats{}
if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[19]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *LoopStats) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*LoopStats) ProtoMessage() {}
func (x *LoopStats) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[19]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use LoopStats.ProtoReflect.Descriptor instead.
func (*LoopStats) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{19}
}
func (x *LoopStats) GetPendingCount() uint64 {
if x != nil {
return x.PendingCount
}
return 0
}
func (x *LoopStats) GetSuccessCount() uint64 {
if x != nil {
return x.SuccessCount
}
return 0
}
func (x *LoopStats) GetFailCount() uint64 {
if x != nil {
return x.FailCount
}
return 0
}
func (x *LoopStats) GetSumPendingAmt() int64 {
if x != nil {
return x.SumPendingAmt
}
return 0
}
func (x *LoopStats) GetSumSucceededAmt() int64 {
if x != nil {
return x.SumSucceededAmt
}
return 0
}
type GetInfoRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
}
func (x *GetInfoRequest) Reset() {
*x = GetInfoRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[20]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetInfoRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetInfoRequest) ProtoMessage() {}
func (x *GetInfoRequest) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[20]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetInfoRequest.ProtoReflect.Descriptor instead.
func (*GetInfoRequest) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{20}
}
type GetInfoResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
//
//The current daemon version.
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
//
//The network the daemon is running on.
Network string `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
//
//Host and port of the loopd grpc server.
RpcListen string `protobuf:"bytes,3,opt,name=rpc_listen,json=rpcListen,proto3" json:"rpc_listen,omitempty"`
//
//Host and port of the loopd rest server.
RestListen string `protobuf:"bytes,4,opt,name=rest_listen,json=restListen,proto3" json:"rest_listen,omitempty"`
//
//Loop's macaroon path that clients use to talk to the daemon.
MacaroonPath string `protobuf:"bytes,5,opt,name=macaroon_path,json=macaroonPath,proto3" json:"macaroon_path,omitempty"`
//
//Loop's tls cert path
TlsCertPath string `protobuf:"bytes,6,opt,name=tls_cert_path,json=tlsCertPath,proto3" json:"tls_cert_path,omitempty"`
//
//Statistics about loop outs.
LoopOutStats *LoopStats `protobuf:"bytes,7,opt,name=loop_out_stats,json=loopOutStats,proto3" json:"loop_out_stats,omitempty"`
//
//Statistics about loop ins.
LoopInStats *LoopStats `protobuf:"bytes,8,opt,name=loop_in_stats,json=loopInStats,proto3" json:"loop_in_stats,omitempty"`
}
func (x *GetInfoResponse) Reset() {
*x = GetInfoResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[21]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetInfoResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetInfoResponse) ProtoMessage() {}
func (x *GetInfoResponse) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[21]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetInfoResponse.ProtoReflect.Descriptor instead.
func (*GetInfoResponse) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{21}
}
func (x *GetInfoResponse) GetVersion() string {
if x != nil {
return x.Version
}
return ""
}
func (x *GetInfoResponse) GetNetwork() string {
if x != nil {
return x.Network
}
return ""
}
func (x *GetInfoResponse) GetRpcListen() string {
if x != nil {
return x.RpcListen
}
return ""
}
func (x *GetInfoResponse) GetRestListen() string {
if x != nil {
return x.RestListen
}
return ""
}
func (x *GetInfoResponse) GetMacaroonPath() string {
if x != nil {
return x.MacaroonPath
}
return ""
}
func (x *GetInfoResponse) GetTlsCertPath() string {
if x != nil {
return x.TlsCertPath
}
return ""
}
func (x *GetInfoResponse) GetLoopOutStats() *LoopStats {
if x != nil {
return x.LoopOutStats
}
return nil
}
func (x *GetInfoResponse) GetLoopInStats() *LoopStats {
if x != nil {
return x.LoopInStats
}
return nil
}
type GetLiquidityParamsRequest struct { type GetLiquidityParamsRequest struct {
state protoimpl.MessageState state protoimpl.MessageState
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
@ -2083,7 +2329,7 @@ type GetLiquidityParamsRequest struct {
func (x *GetLiquidityParamsRequest) Reset() { func (x *GetLiquidityParamsRequest) Reset() {
*x = GetLiquidityParamsRequest{} *x = GetLiquidityParamsRequest{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[19] mi := &file_client_proto_msgTypes[22]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2096,7 +2342,7 @@ func (x *GetLiquidityParamsRequest) String() string {
func (*GetLiquidityParamsRequest) ProtoMessage() {} func (*GetLiquidityParamsRequest) ProtoMessage() {}
func (x *GetLiquidityParamsRequest) ProtoReflect() protoreflect.Message { func (x *GetLiquidityParamsRequest) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[19] mi := &file_client_proto_msgTypes[22]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2109,7 +2355,7 @@ func (x *GetLiquidityParamsRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use GetLiquidityParamsRequest.ProtoReflect.Descriptor instead. // Deprecated: Use GetLiquidityParamsRequest.ProtoReflect.Descriptor instead.
func (*GetLiquidityParamsRequest) Descriptor() ([]byte, []int) { func (*GetLiquidityParamsRequest) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{19} return file_client_proto_rawDescGZIP(), []int{22}
} }
type LiquidityParameters struct { type LiquidityParameters struct {
@ -2225,7 +2471,7 @@ type LiquidityParameters struct {
func (x *LiquidityParameters) Reset() { func (x *LiquidityParameters) Reset() {
*x = LiquidityParameters{} *x = LiquidityParameters{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[20] mi := &file_client_proto_msgTypes[23]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2238,7 +2484,7 @@ func (x *LiquidityParameters) String() string {
func (*LiquidityParameters) ProtoMessage() {} func (*LiquidityParameters) ProtoMessage() {}
func (x *LiquidityParameters) ProtoReflect() protoreflect.Message { func (x *LiquidityParameters) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[20] mi := &file_client_proto_msgTypes[23]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2251,7 +2497,7 @@ func (x *LiquidityParameters) ProtoReflect() protoreflect.Message {
// Deprecated: Use LiquidityParameters.ProtoReflect.Descriptor instead. // Deprecated: Use LiquidityParameters.ProtoReflect.Descriptor instead.
func (*LiquidityParameters) Descriptor() ([]byte, []int) { func (*LiquidityParameters) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{20} return file_client_proto_rawDescGZIP(), []int{23}
} }
func (x *LiquidityParameters) GetRules() []*LiquidityRule { func (x *LiquidityParameters) GetRules() []*LiquidityRule {
@ -2443,7 +2689,7 @@ type LiquidityRule struct {
func (x *LiquidityRule) Reset() { func (x *LiquidityRule) Reset() {
*x = LiquidityRule{} *x = LiquidityRule{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[21] mi := &file_client_proto_msgTypes[24]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2456,7 +2702,7 @@ func (x *LiquidityRule) String() string {
func (*LiquidityRule) ProtoMessage() {} func (*LiquidityRule) ProtoMessage() {}
func (x *LiquidityRule) ProtoReflect() protoreflect.Message { func (x *LiquidityRule) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[21] mi := &file_client_proto_msgTypes[24]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2469,7 +2715,7 @@ func (x *LiquidityRule) ProtoReflect() protoreflect.Message {
// Deprecated: Use LiquidityRule.ProtoReflect.Descriptor instead. // Deprecated: Use LiquidityRule.ProtoReflect.Descriptor instead.
func (*LiquidityRule) Descriptor() ([]byte, []int) { func (*LiquidityRule) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{21} return file_client_proto_rawDescGZIP(), []int{24}
} }
func (x *LiquidityRule) GetChannelId() uint64 { func (x *LiquidityRule) GetChannelId() uint64 {
@ -2530,7 +2776,7 @@ type SetLiquidityParamsRequest struct {
func (x *SetLiquidityParamsRequest) Reset() { func (x *SetLiquidityParamsRequest) Reset() {
*x = SetLiquidityParamsRequest{} *x = SetLiquidityParamsRequest{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[22] mi := &file_client_proto_msgTypes[25]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2543,7 +2789,7 @@ func (x *SetLiquidityParamsRequest) String() string {
func (*SetLiquidityParamsRequest) ProtoMessage() {} func (*SetLiquidityParamsRequest) ProtoMessage() {}
func (x *SetLiquidityParamsRequest) ProtoReflect() protoreflect.Message { func (x *SetLiquidityParamsRequest) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[22] mi := &file_client_proto_msgTypes[25]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2556,7 +2802,7 @@ func (x *SetLiquidityParamsRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use SetLiquidityParamsRequest.ProtoReflect.Descriptor instead. // Deprecated: Use SetLiquidityParamsRequest.ProtoReflect.Descriptor instead.
func (*SetLiquidityParamsRequest) Descriptor() ([]byte, []int) { func (*SetLiquidityParamsRequest) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{22} return file_client_proto_rawDescGZIP(), []int{25}
} }
func (x *SetLiquidityParamsRequest) GetParameters() *LiquidityParameters { func (x *SetLiquidityParamsRequest) GetParameters() *LiquidityParameters {
@ -2575,7 +2821,7 @@ type SetLiquidityParamsResponse struct {
func (x *SetLiquidityParamsResponse) Reset() { func (x *SetLiquidityParamsResponse) Reset() {
*x = SetLiquidityParamsResponse{} *x = SetLiquidityParamsResponse{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[23] mi := &file_client_proto_msgTypes[26]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2588,7 +2834,7 @@ func (x *SetLiquidityParamsResponse) String() string {
func (*SetLiquidityParamsResponse) ProtoMessage() {} func (*SetLiquidityParamsResponse) ProtoMessage() {}
func (x *SetLiquidityParamsResponse) ProtoReflect() protoreflect.Message { func (x *SetLiquidityParamsResponse) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[23] mi := &file_client_proto_msgTypes[26]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2601,7 +2847,7 @@ func (x *SetLiquidityParamsResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use SetLiquidityParamsResponse.ProtoReflect.Descriptor instead. // Deprecated: Use SetLiquidityParamsResponse.ProtoReflect.Descriptor instead.
func (*SetLiquidityParamsResponse) Descriptor() ([]byte, []int) { func (*SetLiquidityParamsResponse) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{23} return file_client_proto_rawDescGZIP(), []int{26}
} }
type SuggestSwapsRequest struct { type SuggestSwapsRequest struct {
@ -2613,7 +2859,7 @@ type SuggestSwapsRequest struct {
func (x *SuggestSwapsRequest) Reset() { func (x *SuggestSwapsRequest) Reset() {
*x = SuggestSwapsRequest{} *x = SuggestSwapsRequest{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[24] mi := &file_client_proto_msgTypes[27]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2626,7 +2872,7 @@ func (x *SuggestSwapsRequest) String() string {
func (*SuggestSwapsRequest) ProtoMessage() {} func (*SuggestSwapsRequest) ProtoMessage() {}
func (x *SuggestSwapsRequest) ProtoReflect() protoreflect.Message { func (x *SuggestSwapsRequest) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[24] mi := &file_client_proto_msgTypes[27]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2639,7 +2885,7 @@ func (x *SuggestSwapsRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use SuggestSwapsRequest.ProtoReflect.Descriptor instead. // Deprecated: Use SuggestSwapsRequest.ProtoReflect.Descriptor instead.
func (*SuggestSwapsRequest) Descriptor() ([]byte, []int) { func (*SuggestSwapsRequest) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{24} return file_client_proto_rawDescGZIP(), []int{27}
} }
type Disqualified struct { type Disqualified struct {
@ -2661,7 +2907,7 @@ type Disqualified struct {
func (x *Disqualified) Reset() { func (x *Disqualified) Reset() {
*x = Disqualified{} *x = Disqualified{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[25] mi := &file_client_proto_msgTypes[28]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2674,7 +2920,7 @@ func (x *Disqualified) String() string {
func (*Disqualified) ProtoMessage() {} func (*Disqualified) ProtoMessage() {}
func (x *Disqualified) ProtoReflect() protoreflect.Message { func (x *Disqualified) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[25] mi := &file_client_proto_msgTypes[28]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2687,7 +2933,7 @@ func (x *Disqualified) ProtoReflect() protoreflect.Message {
// Deprecated: Use Disqualified.ProtoReflect.Descriptor instead. // Deprecated: Use Disqualified.ProtoReflect.Descriptor instead.
func (*Disqualified) Descriptor() ([]byte, []int) { func (*Disqualified) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{25} return file_client_proto_rawDescGZIP(), []int{28}
} }
func (x *Disqualified) GetChannelId() uint64 { func (x *Disqualified) GetChannelId() uint64 {
@ -2731,7 +2977,7 @@ type SuggestSwapsResponse struct {
func (x *SuggestSwapsResponse) Reset() { func (x *SuggestSwapsResponse) Reset() {
*x = SuggestSwapsResponse{} *x = SuggestSwapsResponse{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_client_proto_msgTypes[26] mi := &file_client_proto_msgTypes[29]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
@ -2744,7 +2990,7 @@ func (x *SuggestSwapsResponse) String() string {
func (*SuggestSwapsResponse) ProtoMessage() {} func (*SuggestSwapsResponse) ProtoMessage() {}
func (x *SuggestSwapsResponse) ProtoReflect() protoreflect.Message { func (x *SuggestSwapsResponse) ProtoReflect() protoreflect.Message {
mi := &file_client_proto_msgTypes[26] mi := &file_client_proto_msgTypes[29]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
@ -2757,7 +3003,7 @@ func (x *SuggestSwapsResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use SuggestSwapsResponse.ProtoReflect.Descriptor instead. // Deprecated: Use SuggestSwapsResponse.ProtoReflect.Descriptor instead.
func (*SuggestSwapsResponse) Descriptor() ([]byte, []int) { func (*SuggestSwapsResponse) Descriptor() ([]byte, []int) {
return file_client_proto_rawDescGZIP(), []int{26} return file_client_proto_rawDescGZIP(), []int{29}
} }
func (x *SuggestSwapsResponse) GetLoopOut() []*LoopOutRequest { func (x *SuggestSwapsResponse) GetLoopOut() []*LoopOutRequest {
@ -3007,6 +3253,40 @@ var file_client_proto_rawDesc = []byte{
0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x64, 0x12, 0x21, 0x0a, 0x0c, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x64, 0x12, 0x21, 0x0a, 0x0c,
0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x08, 0x20, 0x01, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x08, 0x20, 0x01,
0x28, 0x09, 0x52, 0x0b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x28, 0x09, 0x52, 0x0b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22,
0xc8, 0x01, 0x0a, 0x09, 0x4c, 0x6f, 0x6f, 0x70, 0x53, 0x74, 0x61, 0x74, 0x73, 0x12, 0x23, 0x0a,
0x0d, 0x70, 0x65, 0x6e, 0x64, 0x69, 0x6e, 0x67, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x01,
0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x70, 0x65, 0x6e, 0x64, 0x69, 0x6e, 0x67, 0x43, 0x6f, 0x75,
0x6e, 0x74, 0x12, 0x23, 0x0a, 0x0d, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x5f, 0x63, 0x6f,
0x75, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x73, 0x75, 0x63, 0x63, 0x65,
0x73, 0x73, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x66, 0x61, 0x69, 0x6c, 0x5f,
0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x09, 0x66, 0x61, 0x69,
0x6c, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x26, 0x0a, 0x0f, 0x73, 0x75, 0x6d, 0x5f, 0x70, 0x65,
0x6e, 0x64, 0x69, 0x6e, 0x67, 0x5f, 0x61, 0x6d, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52,
0x0d, 0x73, 0x75, 0x6d, 0x50, 0x65, 0x6e, 0x64, 0x69, 0x6e, 0x67, 0x41, 0x6d, 0x74, 0x12, 0x2a,
0x0a, 0x11, 0x73, 0x75, 0x6d, 0x5f, 0x73, 0x75, 0x63, 0x63, 0x65, 0x65, 0x64, 0x65, 0x64, 0x5f,
0x61, 0x6d, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x73, 0x75, 0x6d, 0x53, 0x75,
0x63, 0x63, 0x65, 0x65, 0x64, 0x65, 0x64, 0x41, 0x6d, 0x74, 0x22, 0x10, 0x0a, 0x0e, 0x47, 0x65,
0x74, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0xc0, 0x02, 0x0a,
0x0f, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28,
0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x18, 0x0a, 0x07, 0x6e, 0x65,
0x74, 0x77, 0x6f, 0x72, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6e, 0x65, 0x74,
0x77, 0x6f, 0x72, 0x6b, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x70, 0x63, 0x5f, 0x6c, 0x69, 0x73, 0x74,
0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x70, 0x63, 0x4c, 0x69, 0x73,
0x74, 0x65, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x73, 0x74, 0x5f, 0x6c, 0x69, 0x73, 0x74,
0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x72, 0x65, 0x73, 0x74, 0x4c, 0x69,
0x73, 0x74, 0x65, 0x6e, 0x12, 0x23, 0x0a, 0x0d, 0x6d, 0x61, 0x63, 0x61, 0x72, 0x6f, 0x6f, 0x6e,
0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6d, 0x61, 0x63,
0x61, 0x72, 0x6f, 0x6f, 0x6e, 0x50, 0x61, 0x74, 0x68, 0x12, 0x22, 0x0a, 0x0d, 0x74, 0x6c, 0x73,
0x5f, 0x63, 0x65, 0x72, 0x74, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09,
0x52, 0x0b, 0x74, 0x6c, 0x73, 0x43, 0x65, 0x72, 0x74, 0x50, 0x61, 0x74, 0x68, 0x12, 0x38, 0x0a,
0x0e, 0x6c, 0x6f, 0x6f, 0x70, 0x5f, 0x6f, 0x75, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x73, 0x18,
0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e,
0x4c, 0x6f, 0x6f, 0x70, 0x53, 0x74, 0x61, 0x74, 0x73, 0x52, 0x0c, 0x6c, 0x6f, 0x6f, 0x70, 0x4f,
0x75, 0x74, 0x53, 0x74, 0x61, 0x74, 0x73, 0x12, 0x36, 0x0a, 0x0d, 0x6c, 0x6f, 0x6f, 0x70, 0x5f,
0x69, 0x6e, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12,
0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x6f, 0x6f, 0x70, 0x53, 0x74, 0x61,
0x74, 0x73, 0x52, 0x0b, 0x6c, 0x6f, 0x6f, 0x70, 0x49, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x73, 0x22,
0x1b, 0x0a, 0x19, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x1b, 0x0a, 0x19, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50,
0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0xb8, 0x08, 0x0a, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0xb8, 0x08, 0x0a,
0x13, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x13, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65,
@ -3175,7 +3455,7 @@ var file_client_proto_rawDesc = []byte{
0x5f, 0x49, 0x4e, 0x53, 0x55, 0x46, 0x46, 0x49, 0x43, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x0c, 0x12, 0x5f, 0x49, 0x4e, 0x53, 0x55, 0x46, 0x46, 0x49, 0x43, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x0c, 0x12,
0x20, 0x0a, 0x1c, 0x41, 0x55, 0x54, 0x4f, 0x5f, 0x52, 0x45, 0x41, 0x53, 0x4f, 0x4e, 0x5f, 0x46, 0x20, 0x0a, 0x1c, 0x41, 0x55, 0x54, 0x4f, 0x5f, 0x52, 0x45, 0x41, 0x53, 0x4f, 0x4e, 0x5f, 0x46,
0x45, 0x45, 0x5f, 0x49, 0x4e, 0x53, 0x55, 0x46, 0x46, 0x49, 0x43, 0x49, 0x45, 0x4e, 0x54, 0x10, 0x45, 0x45, 0x5f, 0x49, 0x4e, 0x53, 0x55, 0x46, 0x46, 0x49, 0x43, 0x49, 0x45, 0x4e, 0x54, 0x10,
0x0d, 0x32, 0xc2, 0x07, 0x0a, 0x0a, 0x53, 0x77, 0x61, 0x70, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x0d, 0x32, 0x80, 0x08, 0x0a, 0x0a, 0x53, 0x77, 0x61, 0x70, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
0x12, 0x39, 0x0a, 0x07, 0x4c, 0x6f, 0x6f, 0x70, 0x4f, 0x75, 0x74, 0x12, 0x17, 0x2e, 0x6c, 0x6f, 0x12, 0x39, 0x0a, 0x07, 0x4c, 0x6f, 0x6f, 0x70, 0x4f, 0x75, 0x74, 0x12, 0x17, 0x2e, 0x6c, 0x6f,
0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x6f, 0x6f, 0x70, 0x4f, 0x75, 0x74, 0x52, 0x65, 0x71, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x6f, 0x6f, 0x70, 0x4f, 0x75, 0x74, 0x52, 0x65, 0x71,
0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x53,
@ -3219,26 +3499,30 @@ var file_client_proto_rawDesc = []byte{
0x73, 0x12, 0x16, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x54, 0x6f, 0x6b, 0x65, 0x73, 0x12, 0x16, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x54, 0x6f, 0x6b, 0x65,
0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x6c, 0x6f, 0x6f, 0x70,
0x72, 0x70, 0x63, 0x2e, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x72, 0x70, 0x63, 0x2e, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x73, 0x65, 0x12, 0x56, 0x0a, 0x12, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x73, 0x65, 0x12, 0x3c, 0x0a, 0x07, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x17, 0x2e,
0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12, 0x22, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x52,
0x70, 0x63, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63,
0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x6c, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x12, 0x56, 0x0a, 0x12, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79,
0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x12, 0x5d, 0x0a, 0x12, 0x53, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12, 0x22, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63,
0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72,
0x12, 0x22, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x74, 0x4c, 0x69, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x6c, 0x6f, 0x6f,
0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61,
0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x12, 0x5d, 0x0a, 0x12, 0x53, 0x65, 0x74, 0x4c,
0x65, 0x74, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x12, 0x22,
0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x53, 0x75, 0x67, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x74, 0x4c, 0x69, 0x71, 0x75,
0x67, 0x65, 0x73, 0x74, 0x53, 0x77, 0x61, 0x70, 0x73, 0x12, 0x1c, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
0x72, 0x70, 0x63, 0x2e, 0x53, 0x75, 0x67, 0x67, 0x65, 0x73, 0x74, 0x53, 0x77, 0x61, 0x70, 0x73, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x74,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x4c, 0x69, 0x71, 0x75, 0x69, 0x64, 0x69, 0x74, 0x79, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x52,
0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x53, 0x75, 0x67, 0x67, 0x65,
0x73, 0x74, 0x53, 0x77, 0x61, 0x70, 0x73, 0x12, 0x1c, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70,
0x63, 0x2e, 0x53, 0x75, 0x67, 0x67, 0x65, 0x73, 0x74, 0x53, 0x77, 0x61, 0x70, 0x73, 0x52, 0x65, 0x63, 0x2e, 0x53, 0x75, 0x67, 0x67, 0x65, 0x73, 0x74, 0x53, 0x77, 0x61, 0x70, 0x73, 0x52, 0x65,
0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x27, 0x5a, 0x25, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x2e,
0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x6e, 0x69, 0x6e, 0x67, 0x6c, 0x61, 0x53, 0x75, 0x67, 0x67, 0x65, 0x73, 0x74, 0x53, 0x77, 0x61, 0x70, 0x73, 0x52, 0x65, 0x73, 0x70,
0x62, 0x73, 0x2f, 0x6c, 0x6f, 0x6f, 0x70, 0x2f, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x62, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x27, 0x5a, 0x25, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63,
0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 0x6f, 0x6d, 0x2f, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x6e, 0x69, 0x6e, 0x67, 0x6c, 0x61, 0x62, 0x73,
0x2f, 0x6c, 0x6f, 0x6f, 0x70, 0x2f, 0x6c, 0x6f, 0x6f, 0x70, 0x72, 0x70, 0x63, 0x62, 0x06, 0x70,
0x72, 0x6f, 0x74, 0x6f, 0x33,
} }
var ( var (
@ -3254,7 +3538,7 @@ func file_client_proto_rawDescGZIP() []byte {
} }
var file_client_proto_enumTypes = make([]protoimpl.EnumInfo, 5) var file_client_proto_enumTypes = make([]protoimpl.EnumInfo, 5)
var file_client_proto_msgTypes = make([]protoimpl.MessageInfo, 27) var file_client_proto_msgTypes = make([]protoimpl.MessageInfo, 30)
var file_client_proto_goTypes = []interface{}{ var file_client_proto_goTypes = []interface{}{
(SwapType)(0), // 0: looprpc.SwapType (SwapType)(0), // 0: looprpc.SwapType
(SwapState)(0), // 1: looprpc.SwapState (SwapState)(0), // 1: looprpc.SwapState
@ -3280,66 +3564,73 @@ var file_client_proto_goTypes = []interface{}{
(*TokensRequest)(nil), // 21: looprpc.TokensRequest (*TokensRequest)(nil), // 21: looprpc.TokensRequest
(*TokensResponse)(nil), // 22: looprpc.TokensResponse (*TokensResponse)(nil), // 22: looprpc.TokensResponse
(*LsatToken)(nil), // 23: looprpc.LsatToken (*LsatToken)(nil), // 23: looprpc.LsatToken
(*GetLiquidityParamsRequest)(nil), // 24: looprpc.GetLiquidityParamsRequest (*LoopStats)(nil), // 24: looprpc.LoopStats
(*LiquidityParameters)(nil), // 25: looprpc.LiquidityParameters (*GetInfoRequest)(nil), // 25: looprpc.GetInfoRequest
(*LiquidityRule)(nil), // 26: looprpc.LiquidityRule (*GetInfoResponse)(nil), // 26: looprpc.GetInfoResponse
(*SetLiquidityParamsRequest)(nil), // 27: looprpc.SetLiquidityParamsRequest (*GetLiquidityParamsRequest)(nil), // 27: looprpc.GetLiquidityParamsRequest
(*SetLiquidityParamsResponse)(nil), // 28: looprpc.SetLiquidityParamsResponse (*LiquidityParameters)(nil), // 28: looprpc.LiquidityParameters
(*SuggestSwapsRequest)(nil), // 29: looprpc.SuggestSwapsRequest (*LiquidityRule)(nil), // 29: looprpc.LiquidityRule
(*Disqualified)(nil), // 30: looprpc.Disqualified (*SetLiquidityParamsRequest)(nil), // 30: looprpc.SetLiquidityParamsRequest
(*SuggestSwapsResponse)(nil), // 31: looprpc.SuggestSwapsResponse (*SetLiquidityParamsResponse)(nil), // 31: looprpc.SetLiquidityParamsResponse
(*swapserverrpc.RouteHint)(nil), // 32: looprpc.RouteHint (*SuggestSwapsRequest)(nil), // 32: looprpc.SuggestSwapsRequest
(*Disqualified)(nil), // 33: looprpc.Disqualified
(*SuggestSwapsResponse)(nil), // 34: looprpc.SuggestSwapsResponse
(*swapserverrpc.RouteHint)(nil), // 35: looprpc.RouteHint
} }
var file_client_proto_depIdxs = []int32{ var file_client_proto_depIdxs = []int32{
32, // 0: looprpc.LoopInRequest.route_hints:type_name -> looprpc.RouteHint 35, // 0: looprpc.LoopInRequest.route_hints:type_name -> looprpc.RouteHint
0, // 1: looprpc.SwapStatus.type:type_name -> looprpc.SwapType 0, // 1: looprpc.SwapStatus.type:type_name -> looprpc.SwapType
1, // 2: looprpc.SwapStatus.state:type_name -> looprpc.SwapState 1, // 2: looprpc.SwapStatus.state:type_name -> looprpc.SwapState
2, // 3: looprpc.SwapStatus.failure_reason:type_name -> looprpc.FailureReason 2, // 3: looprpc.SwapStatus.failure_reason:type_name -> looprpc.FailureReason
9, // 4: looprpc.ListSwapsResponse.swaps:type_name -> looprpc.SwapStatus 9, // 4: looprpc.ListSwapsResponse.swaps:type_name -> looprpc.SwapStatus
32, // 5: looprpc.QuoteRequest.loop_in_route_hints:type_name -> looprpc.RouteHint 35, // 5: looprpc.QuoteRequest.loop_in_route_hints:type_name -> looprpc.RouteHint
32, // 6: looprpc.ProbeRequest.route_hints:type_name -> looprpc.RouteHint 35, // 6: looprpc.ProbeRequest.route_hints:type_name -> looprpc.RouteHint
23, // 7: looprpc.TokensResponse.tokens:type_name -> looprpc.LsatToken 23, // 7: looprpc.TokensResponse.tokens:type_name -> looprpc.LsatToken
26, // 8: looprpc.LiquidityParameters.rules:type_name -> looprpc.LiquidityRule 24, // 8: looprpc.GetInfoResponse.loop_out_stats:type_name -> looprpc.LoopStats
0, // 9: looprpc.LiquidityRule.swap_type:type_name -> looprpc.SwapType 24, // 9: looprpc.GetInfoResponse.loop_in_stats:type_name -> looprpc.LoopStats
3, // 10: looprpc.LiquidityRule.type:type_name -> looprpc.LiquidityRuleType 29, // 10: looprpc.LiquidityParameters.rules:type_name -> looprpc.LiquidityRule
25, // 11: looprpc.SetLiquidityParamsRequest.parameters:type_name -> looprpc.LiquidityParameters 0, // 11: looprpc.LiquidityRule.swap_type:type_name -> looprpc.SwapType
4, // 12: looprpc.Disqualified.reason:type_name -> looprpc.AutoReason 3, // 12: looprpc.LiquidityRule.type:type_name -> looprpc.LiquidityRuleType
5, // 13: looprpc.SuggestSwapsResponse.loop_out:type_name -> looprpc.LoopOutRequest 28, // 13: looprpc.SetLiquidityParamsRequest.parameters:type_name -> looprpc.LiquidityParameters
6, // 14: looprpc.SuggestSwapsResponse.loop_in:type_name -> looprpc.LoopInRequest 4, // 14: looprpc.Disqualified.reason:type_name -> looprpc.AutoReason
30, // 15: looprpc.SuggestSwapsResponse.disqualified:type_name -> looprpc.Disqualified 5, // 15: looprpc.SuggestSwapsResponse.loop_out:type_name -> looprpc.LoopOutRequest
5, // 16: looprpc.SwapClient.LoopOut:input_type -> looprpc.LoopOutRequest 6, // 16: looprpc.SuggestSwapsResponse.loop_in:type_name -> looprpc.LoopInRequest
6, // 17: looprpc.SwapClient.LoopIn:input_type -> looprpc.LoopInRequest 33, // 17: looprpc.SuggestSwapsResponse.disqualified:type_name -> looprpc.Disqualified
8, // 18: looprpc.SwapClient.Monitor:input_type -> looprpc.MonitorRequest 5, // 18: looprpc.SwapClient.LoopOut:input_type -> looprpc.LoopOutRequest
10, // 19: looprpc.SwapClient.ListSwaps:input_type -> looprpc.ListSwapsRequest 6, // 19: looprpc.SwapClient.LoopIn:input_type -> looprpc.LoopInRequest
12, // 20: looprpc.SwapClient.SwapInfo:input_type -> looprpc.SwapInfoRequest 8, // 20: looprpc.SwapClient.Monitor:input_type -> looprpc.MonitorRequest
13, // 21: looprpc.SwapClient.LoopOutTerms:input_type -> looprpc.TermsRequest 10, // 21: looprpc.SwapClient.ListSwaps:input_type -> looprpc.ListSwapsRequest
16, // 22: looprpc.SwapClient.LoopOutQuote:input_type -> looprpc.QuoteRequest 12, // 22: looprpc.SwapClient.SwapInfo:input_type -> looprpc.SwapInfoRequest
13, // 23: looprpc.SwapClient.GetLoopInTerms:input_type -> looprpc.TermsRequest 13, // 23: looprpc.SwapClient.LoopOutTerms:input_type -> looprpc.TermsRequest
16, // 24: looprpc.SwapClient.GetLoopInQuote:input_type -> looprpc.QuoteRequest 16, // 24: looprpc.SwapClient.LoopOutQuote:input_type -> looprpc.QuoteRequest
19, // 25: looprpc.SwapClient.Probe:input_type -> looprpc.ProbeRequest 13, // 25: looprpc.SwapClient.GetLoopInTerms:input_type -> looprpc.TermsRequest
21, // 26: looprpc.SwapClient.GetLsatTokens:input_type -> looprpc.TokensRequest 16, // 26: looprpc.SwapClient.GetLoopInQuote:input_type -> looprpc.QuoteRequest
24, // 27: looprpc.SwapClient.GetLiquidityParams:input_type -> looprpc.GetLiquidityParamsRequest 19, // 27: looprpc.SwapClient.Probe:input_type -> looprpc.ProbeRequest
27, // 28: looprpc.SwapClient.SetLiquidityParams:input_type -> looprpc.SetLiquidityParamsRequest 21, // 28: looprpc.SwapClient.GetLsatTokens:input_type -> looprpc.TokensRequest
29, // 29: looprpc.SwapClient.SuggestSwaps:input_type -> looprpc.SuggestSwapsRequest 25, // 29: looprpc.SwapClient.GetInfo:input_type -> looprpc.GetInfoRequest
7, // 30: looprpc.SwapClient.LoopOut:output_type -> looprpc.SwapResponse 27, // 30: looprpc.SwapClient.GetLiquidityParams:input_type -> looprpc.GetLiquidityParamsRequest
7, // 31: looprpc.SwapClient.LoopIn:output_type -> looprpc.SwapResponse 30, // 31: looprpc.SwapClient.SetLiquidityParams:input_type -> looprpc.SetLiquidityParamsRequest
9, // 32: looprpc.SwapClient.Monitor:output_type -> looprpc.SwapStatus 32, // 32: looprpc.SwapClient.SuggestSwaps:input_type -> looprpc.SuggestSwapsRequest
11, // 33: looprpc.SwapClient.ListSwaps:output_type -> looprpc.ListSwapsResponse 7, // 33: looprpc.SwapClient.LoopOut:output_type -> looprpc.SwapResponse
9, // 34: looprpc.SwapClient.SwapInfo:output_type -> looprpc.SwapStatus 7, // 34: looprpc.SwapClient.LoopIn:output_type -> looprpc.SwapResponse
15, // 35: looprpc.SwapClient.LoopOutTerms:output_type -> looprpc.OutTermsResponse 9, // 35: looprpc.SwapClient.Monitor:output_type -> looprpc.SwapStatus
18, // 36: looprpc.SwapClient.LoopOutQuote:output_type -> looprpc.OutQuoteResponse 11, // 36: looprpc.SwapClient.ListSwaps:output_type -> looprpc.ListSwapsResponse
14, // 37: looprpc.SwapClient.GetLoopInTerms:output_type -> looprpc.InTermsResponse 9, // 37: looprpc.SwapClient.SwapInfo:output_type -> looprpc.SwapStatus
17, // 38: looprpc.SwapClient.GetLoopInQuote:output_type -> looprpc.InQuoteResponse 15, // 38: looprpc.SwapClient.LoopOutTerms:output_type -> looprpc.OutTermsResponse
20, // 39: looprpc.SwapClient.Probe:output_type -> looprpc.ProbeResponse 18, // 39: looprpc.SwapClient.LoopOutQuote:output_type -> looprpc.OutQuoteResponse
22, // 40: looprpc.SwapClient.GetLsatTokens:output_type -> looprpc.TokensResponse 14, // 40: looprpc.SwapClient.GetLoopInTerms:output_type -> looprpc.InTermsResponse
25, // 41: looprpc.SwapClient.GetLiquidityParams:output_type -> looprpc.LiquidityParameters 17, // 41: looprpc.SwapClient.GetLoopInQuote:output_type -> looprpc.InQuoteResponse
28, // 42: looprpc.SwapClient.SetLiquidityParams:output_type -> looprpc.SetLiquidityParamsResponse 20, // 42: looprpc.SwapClient.Probe:output_type -> looprpc.ProbeResponse
31, // 43: looprpc.SwapClient.SuggestSwaps:output_type -> looprpc.SuggestSwapsResponse 22, // 43: looprpc.SwapClient.GetLsatTokens:output_type -> looprpc.TokensResponse
30, // [30:44] is the sub-list for method output_type 26, // 44: looprpc.SwapClient.GetInfo:output_type -> looprpc.GetInfoResponse
16, // [16:30] is the sub-list for method input_type 28, // 45: looprpc.SwapClient.GetLiquidityParams:output_type -> looprpc.LiquidityParameters
16, // [16:16] is the sub-list for extension type_name 31, // 46: looprpc.SwapClient.SetLiquidityParams:output_type -> looprpc.SetLiquidityParamsResponse
16, // [16:16] is the sub-list for extension extendee 34, // 47: looprpc.SwapClient.SuggestSwaps:output_type -> looprpc.SuggestSwapsResponse
0, // [0:16] is the sub-list for field type_name 33, // [33:48] is the sub-list for method output_type
18, // [18:33] is the sub-list for method input_type
18, // [18:18] is the sub-list for extension type_name
18, // [18:18] is the sub-list for extension extendee
0, // [0:18] is the sub-list for field type_name
} }
func init() { file_client_proto_init() } func init() { file_client_proto_init() }
@ -3577,7 +3868,7 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetLiquidityParamsRequest); i { switch v := v.(*LoopStats); i {
case 0: case 0:
return &v.state return &v.state
case 1: case 1:
@ -3589,7 +3880,7 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LiquidityParameters); i { switch v := v.(*GetInfoRequest); i {
case 0: case 0:
return &v.state return &v.state
case 1: case 1:
@ -3601,7 +3892,7 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LiquidityRule); i { switch v := v.(*GetInfoResponse); i {
case 0: case 0:
return &v.state return &v.state
case 1: case 1:
@ -3613,7 +3904,7 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SetLiquidityParamsRequest); i { switch v := v.(*GetLiquidityParamsRequest); i {
case 0: case 0:
return &v.state return &v.state
case 1: case 1:
@ -3625,7 +3916,7 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SetLiquidityParamsResponse); i { switch v := v.(*LiquidityParameters); i {
case 0: case 0:
return &v.state return &v.state
case 1: case 1:
@ -3637,7 +3928,7 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SuggestSwapsRequest); i { switch v := v.(*LiquidityRule); i {
case 0: case 0:
return &v.state return &v.state
case 1: case 1:
@ -3649,7 +3940,7 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Disqualified); i { switch v := v.(*SetLiquidityParamsRequest); i {
case 0: case 0:
return &v.state return &v.state
case 1: case 1:
@ -3661,6 +3952,42 @@ func file_client_proto_init() {
} }
} }
file_client_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} { file_client_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SetLiquidityParamsResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_client_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SuggestSwapsRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_client_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Disqualified); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_client_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SuggestSwapsResponse); i { switch v := v.(*SuggestSwapsResponse); i {
case 0: case 0:
return &v.state return &v.state
@ -3679,7 +4006,7 @@ func file_client_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(), GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_client_proto_rawDesc, RawDescriptor: file_client_proto_rawDesc,
NumEnums: 5, NumEnums: 5,
NumMessages: 27, NumMessages: 30,
NumExtensions: 0, NumExtensions: 0,
NumServices: 1, NumServices: 1,
}, },

77
looprpc/client.proto
Unescape Escape View File

@ -75,6 +75,11 @@ service SwapClient {
*/ */
rpc GetLsatTokens (TokensRequest) returns (TokensResponse); rpc GetLsatTokens (TokensRequest) returns (TokensResponse);
/* loop: `getinfo`
GetInfo gets basic information about the loop daemon.
*/
rpc GetInfo (GetInfoRequest) returns (GetInfoResponse);
/* loop: `getparams` /* loop: `getparams`
GetLiquidityParams gets the parameters that the daemon's liquidity manager GetLiquidityParams gets the parameters that the daemon's liquidity manager
is currently configured with. This may be nil if nothing is configured. is currently configured with. This may be nil if nothing is configured.
@ -740,6 +745,78 @@ message LsatToken {
string storage_name = 8; string storage_name = 8;
} }
message LoopStats {
/*
Number of currently pending swaps.
*/
uint64 pending_count = 1;
/*
Number of succeeded swaps.
*/
uint64 success_count = 2;
/*
Number failed swaps.
*/
uint64 fail_count = 3;
/*
The sum of all pending swap amounts.
*/
int64 sum_pending_amt = 4;
/*
The sum of all succeeded swap amounts.
*/
int64 sum_succeeded_amt = 5;
}
message GetInfoRequest {
}
message GetInfoResponse {
/*
The current daemon version.
*/
string version = 1;
/*
The network the daemon is running on.
*/
string network = 2;
/*
Host and port of the loopd grpc server.
*/
string rpc_listen = 3;
/*
Host and port of the loopd rest server.
*/
string rest_listen = 4;
/*
Loop's macaroon path that clients use to talk to the daemon.
*/
string macaroon_path = 5;
/*
Loop's tls cert path
*/
string tls_cert_path = 6;
/*
Statistics about loop outs.
*/
LoopStats loop_out_stats = 7;
/*
Statistics about loop ins.
*/
LoopStats loop_in_stats = 8;
}
message GetLiquidityParamsRequest { message GetLiquidityParamsRequest {
} }

67
looprpc/client.swagger.json
Unescape Escape View File

@ -523,6 +523,43 @@
"default": "FAILURE_REASON_NONE", "default": "FAILURE_REASON_NONE",
"description": " - FAILURE_REASON_NONE: FAILURE_REASON_NONE is set when the swap did not fail, it is either in\nprogress or succeeded.\n - FAILURE_REASON_OFFCHAIN: FAILURE_REASON_OFFCHAIN indicates that a loop out failed because it wasn't\npossible to find a route for one or both off chain payments that met the fee\nand timelock limits required.\n - FAILURE_REASON_TIMEOUT: FAILURE_REASON_TIMEOUT indicates that the swap failed because on chain htlc\ndid not confirm before its expiry, or it confirmed too late for us to reveal\nour preimage and claim.\n - FAILURE_REASON_SWEEP_TIMEOUT: FAILURE_REASON_SWEEP_TIMEOUT indicates that a loop out permanently failed\nbecause the on chain htlc wasn't swept before the server revoked the\nhtlc.\n - FAILURE_REASON_INSUFFICIENT_VALUE: FAILURE_REASON_INSUFFICIENT_VALUE indicates that a loop out has failed\nbecause the on chain htlc had a lower value than requested.\n - FAILURE_REASON_TEMPORARY: FAILURE_REASON_TEMPORARY indicates that a swap cannot continue due to an\ninternal error. Manual intervention such as a restart is required.\n - FAILURE_REASON_INCORRECT_AMOUNT: FAILURE_REASON_INCORRECT_AMOUNT indicates that a loop in permanently failed\nbecause the amount extended by an external loop in htlc is insufficient." "description": " - FAILURE_REASON_NONE: FAILURE_REASON_NONE is set when the swap did not fail, it is either in\nprogress or succeeded.\n - FAILURE_REASON_OFFCHAIN: FAILURE_REASON_OFFCHAIN indicates that a loop out failed because it wasn't\npossible to find a route for one or both off chain payments that met the fee\nand timelock limits required.\n - FAILURE_REASON_TIMEOUT: FAILURE_REASON_TIMEOUT indicates that the swap failed because on chain htlc\ndid not confirm before its expiry, or it confirmed too late for us to reveal\nour preimage and claim.\n - FAILURE_REASON_SWEEP_TIMEOUT: FAILURE_REASON_SWEEP_TIMEOUT indicates that a loop out permanently failed\nbecause the on chain htlc wasn't swept before the server revoked the\nhtlc.\n - FAILURE_REASON_INSUFFICIENT_VALUE: FAILURE_REASON_INSUFFICIENT_VALUE indicates that a loop out has failed\nbecause the on chain htlc had a lower value than requested.\n - FAILURE_REASON_TEMPORARY: FAILURE_REASON_TEMPORARY indicates that a swap cannot continue due to an\ninternal error. Manual intervention such as a restart is required.\n - FAILURE_REASON_INCORRECT_AMOUNT: FAILURE_REASON_INCORRECT_AMOUNT indicates that a loop in permanently failed\nbecause the amount extended by an external loop in htlc is insufficient."
}, },
"looprpcGetInfoResponse": {
"type": "object",
"properties": {
"version": {
"type": "string",
"description": "The current daemon version."
},
"network": {
"type": "string",
"description": "The network the daemon is running on."
},
"rpc_listen": {
"type": "string",
"description": "Host and port of the loopd grpc server."
},
"rest_listen": {
"type": "string",
"description": "Host and port of the loopd rest server."
},
"macaroon_path": {
"type": "string",
"description": "Loop's macaroon path that clients use to talk to the daemon."
},
"tls_cert_path": {
"type": "string",
"title": "Loop's tls cert path"
},
"loop_out_stats": {
"$ref": "#/definitions/looprpcLoopStats",
"description": "Statistics about loop outs."
},
"loop_in_stats": {
"$ref": "#/definitions/looprpcLoopStats",
"description": "Statistics about loop ins."
}
}
},
"looprpcHopHint": { "looprpcHopHint": {
"type": "object", "type": "object",
"properties": { "properties": {
@ -887,6 +924,36 @@
} }
} }
}, },
"looprpcLoopStats": {
"type": "object",
"properties": {
"pending_count": {
"type": "string",
"format": "uint64",
"description": "Number of currently pending swaps."
},
"success_count": {
"type": "string",
"format": "uint64",
"description": "Number of succeeded swaps."
},
"fail_count": {
"type": "string",
"format": "uint64",
"description": "Number failed swaps."
},
"sum_pending_amt": {
"type": "string",
"format": "int64",
"description": "The sum of all pending swap amounts."
},
"sum_succeeded_amt": {
"type": "string",
"format": "int64",
"description": "The sum of all succeeded swap amounts."
}
}
},
"looprpcLsatToken": { "looprpcLsatToken": {
"type": "object", "type": "object",
"properties": { "properties": {

40
looprpc/client_grpc.pb.go
Unescape Escape View File

@ -60,6 +60,9 @@ type SwapClientClient interface {
// loop: `listauth` // loop: `listauth`
//GetLsatTokens returns all LSAT tokens the daemon ever paid for. //GetLsatTokens returns all LSAT tokens the daemon ever paid for.
GetLsatTokens(ctx context.Context, in *TokensRequest, opts ...grpc.CallOption) (*TokensResponse, error) GetLsatTokens(ctx context.Context, in *TokensRequest, opts ...grpc.CallOption) (*TokensResponse, error)
// loop: `getinfo`
//GetInfo gets basic information about the loop daemon.
GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error)
// loop: `getparams` // loop: `getparams`
//GetLiquidityParams gets the parameters that the daemon's liquidity manager //GetLiquidityParams gets the parameters that the daemon's liquidity manager
//is currently configured with. This may be nil if nothing is configured. //is currently configured with. This may be nil if nothing is configured.
@ -209,6 +212,15 @@ func (c *swapClientClient) GetLsatTokens(ctx context.Context, in *TokensRequest,
return out, nil return out, nil
} }
func (c *swapClientClient) GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error) {
out := new(GetInfoResponse)
err := c.cc.Invoke(ctx, "/looprpc.SwapClient/GetInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *swapClientClient) GetLiquidityParams(ctx context.Context, in *GetLiquidityParamsRequest, opts ...grpc.CallOption) (*LiquidityParameters, error) { func (c *swapClientClient) GetLiquidityParams(ctx context.Context, in *GetLiquidityParamsRequest, opts ...grpc.CallOption) (*LiquidityParameters, error) {
out := new(LiquidityParameters) out := new(LiquidityParameters)
err := c.cc.Invoke(ctx, "/looprpc.SwapClient/GetLiquidityParams", in, out, opts...) err := c.cc.Invoke(ctx, "/looprpc.SwapClient/GetLiquidityParams", in, out, opts...)
@ -282,6 +294,9 @@ type SwapClientServer interface {
// loop: `listauth` // loop: `listauth`
//GetLsatTokens returns all LSAT tokens the daemon ever paid for. //GetLsatTokens returns all LSAT tokens the daemon ever paid for.
GetLsatTokens(context.Context, *TokensRequest) (*TokensResponse, error) GetLsatTokens(context.Context, *TokensRequest) (*TokensResponse, error)
// loop: `getinfo`
//GetInfo gets basic information about the loop daemon.
GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)
// loop: `getparams` // loop: `getparams`
//GetLiquidityParams gets the parameters that the daemon's liquidity manager //GetLiquidityParams gets the parameters that the daemon's liquidity manager
//is currently configured with. This may be nil if nothing is configured. //is currently configured with. This may be nil if nothing is configured.
@ -339,6 +354,9 @@ func (UnimplementedSwapClientServer) Probe(context.Context, *ProbeRequest) (*Pro
func (UnimplementedSwapClientServer) GetLsatTokens(context.Context, *TokensRequest) (*TokensResponse, error) { func (UnimplementedSwapClientServer) GetLsatTokens(context.Context, *TokensRequest) (*TokensResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetLsatTokens not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetLsatTokens not implemented")
} }
func (UnimplementedSwapClientServer) GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetInfo not implemented")
}
func (UnimplementedSwapClientServer) GetLiquidityParams(context.Context, *GetLiquidityParamsRequest) (*LiquidityParameters, error) { func (UnimplementedSwapClientServer) GetLiquidityParams(context.Context, *GetLiquidityParamsRequest) (*LiquidityParameters, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetLiquidityParams not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetLiquidityParams not implemented")
} }
@ -562,6 +580,24 @@ func _SwapClient_GetLsatTokens_Handler(srv interface{}, ctx context.Context, dec
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _SwapClient_GetInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetInfoRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(SwapClientServer).GetInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/looprpc.SwapClient/GetInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(SwapClientServer).GetInfo(ctx, req.(*GetInfoRequest))
}
return interceptor(ctx, in, info, handler)
}
func _SwapClient_GetLiquidityParams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _SwapClient_GetLiquidityParams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetLiquidityParamsRequest) in := new(GetLiquidityParamsRequest)
if err := dec(in); err != nil { if err := dec(in); err != nil {
@ -663,6 +699,10 @@ var SwapClient_ServiceDesc = grpc.ServiceDesc{
MethodName: "GetLsatTokens", MethodName: "GetLsatTokens",
Handler: _SwapClient_GetLsatTokens_Handler, Handler: _SwapClient_GetLsatTokens_Handler,
}, },
{
MethodName: "GetInfo",
Handler: _SwapClient_GetInfo_Handler,
},
{ {
MethodName: "GetLiquidityParams", MethodName: "GetLiquidityParams",
Handler: _SwapClient_GetLiquidityParams_Handler, Handler: _SwapClient_GetLiquidityParams_Handler,

25
looprpc/swapclient.pb.json.go
Unescape Escape View File

@ -313,6 +313,31 @@ func RegisterSwapClientJSONCallbacks(registry map[string]func(ctx context.Contex
callback(string(respBytes), nil) callback(string(respBytes), nil)
} }
registry["looprpc.SwapClient.GetInfo"] = func(ctx context.Context,
conn *grpc.ClientConn, reqJSON string, callback func(string, error)) {
req := &GetInfoRequest{}
err := marshaler.Unmarshal([]byte(reqJSON), req)
if err != nil {
callback("", err)
return
}
client := NewSwapClientClient(conn)
resp, err := client.GetInfo(ctx, req)
if err != nil {
callback("", err)
return
}
respBytes, err := marshaler.Marshal(resp)
if err != nil {
callback("", err)
return
}
callback(string(respBytes), nil)
}
registry["looprpc.SwapClient.GetLiquidityParams"] = func(ctx context.Context, registry["looprpc.SwapClient.GetLiquidityParams"] = func(ctx context.Context,
conn *grpc.ClientConn, reqJSON string, callback func(string, error)) { conn *grpc.ClientConn, reqJSON string, callback func(string, error)) {

Write Preview
Loading…
Cancel
Save