rpc

type AdminClient interface {
	// ConfirmOnChainResolvedPaysWithPeerOsps instructs Osp to confirm on-chain resolved pays between itself and connected osps.
	ConfirmOnChainResolvedPaysWithPeerOsps(ctx context.Context, in *ConfirmOnChainResolvedPaysRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ClearExpiredPaysWithPeerOsps instructs Osp to clear expired pays between itself and connected osps.
	ClearExpiredPaysWithPeerOsps(ctx context.Context, in *ClearExpiredPaysRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// BuildRoutingTable instructs Osp to build routing table.
	BuildRoutingTable(ctx context.Context, in *BuildRoutingTableRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// RecvBcastRoutingInfo gives the OSP (listener & router) the incoming
	// broadcast routing information (OSP server forwarding to the listener).
	RecvBcastRoutingInfo(ctx context.Context, in *RoutingRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetPeerOsps returns info of all peer osps.
	GetPeerOsps(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeerOspsResponse, error)
	// OspOpenChannel instructs Osp to open a state channel with a peer described in request.
	OspOpenChannel(ctx context.Context, in *OspOpenChannelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// SendToken instructs the OSP to send token specified in SendTokenRequest.
	SendToken(ctx context.Context, in *SendTokenRequest, opts ...grpc.CallOption) (*SendTokenResponse, error)
	// Deposit instructs the OSP to deposit token specified in DepositRequest.
	Deposit(ctx context.Context, in *DepositRequest, opts ...grpc.CallOption) (*DepositResponse, error)
	// QueryDeposit asks OSP about the deposit status
	QueryDeposit(ctx context.Context, in *QueryDepositRequest, opts ...grpc.CallOption) (*QueryDepositResponse, error)
	// RegisterStream instructs the OSP to connect with other osp specified in RegisterStreamRequest.
	RegisterStream(ctx context.Context, in *RegisterStreamRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CooperativeWithdraw(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)
	CooperativeSettle(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)
}

type AdminServer interface {
	// ConfirmOnChainResolvedPaysWithPeerOsps instructs Osp to confirm on-chain resolved pays between itself and connected osps.
	ConfirmOnChainResolvedPaysWithPeerOsps(context.Context, *ConfirmOnChainResolvedPaysRequest) (*emptypb.Empty, error)
	// ClearExpiredPaysWithPeerOsps instructs Osp to clear expired pays between itself and connected osps.
	ClearExpiredPaysWithPeerOsps(context.Context, *ClearExpiredPaysRequest) (*emptypb.Empty, error)
	// BuildRoutingTable instructs Osp to build routing table.
	BuildRoutingTable(context.Context, *BuildRoutingTableRequest) (*emptypb.Empty, error)
	// RecvBcastRoutingInfo gives the OSP (listener & router) the incoming
	// broadcast routing information (OSP server forwarding to the listener).
	RecvBcastRoutingInfo(context.Context, *RoutingRequest) (*emptypb.Empty, error)
	// GetPeerOsps returns info of all peer osps.
	GetPeerOsps(context.Context, *emptypb.Empty) (*PeerOspsResponse, error)
	// OspOpenChannel instructs Osp to open a state channel with a peer described in request.
	OspOpenChannel(context.Context, *OspOpenChannelRequest) (*emptypb.Empty, error)
	// SendToken instructs the OSP to send token specified in SendTokenRequest.
	SendToken(context.Context, *SendTokenRequest) (*SendTokenResponse, error)
	// Deposit instructs the OSP to deposit token specified in DepositRequest.
	Deposit(context.Context, *DepositRequest) (*DepositResponse, error)
	// QueryDeposit asks OSP about the deposit status
	QueryDeposit(context.Context, *QueryDepositRequest) (*QueryDepositResponse, error)
	// RegisterStream instructs the OSP to connect with other osp specified in RegisterStreamRequest.
	RegisterStream(context.Context, *RegisterStreamRequest) (*emptypb.Empty, error)
	CooperativeWithdraw(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)
	CooperativeSettle(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)
	// contains filtered or unexported methods
}

type AuthAck struct {

	// expect requester to set mid to start_mid in next message
	// including the assigned tag
	StartMid *MID `protobuf:"bytes,1,opt,name=start_mid,json=startMid,proto3" json:"start_mid,omitempty"`
	// if req set mutual_auth, return acker's sig of authreq.timestamp
	// we assume requester has context to verify against expect_peer
	MySig []byte `protobuf:"bytes,2,opt,name=my_sig,json=mySig,proto3" json:"my_sig,omitempty"`
	// channels to be syned w/ auth requester
	SyncChannels []*ChannelInAuth `protobuf:"bytes,3,rep,name=sync_channels,json=syncChannels,proto3" json:"sync_channels,omitempty"`
	// contains filtered or unexported fields
}

type AuthReq struct {
	MyAddr []byte `protobuf:"bytes,1,opt,name=my_addr,json=myAddr,proto3" json:"my_addr,omitempty"`
	// protect against replay attack
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// sig of timestamp field
	MySig      []byte `protobuf:"bytes,3,opt,name=my_sig,json=mySig,proto3" json:"my_sig,omitempty"`
	ExpectPeer []byte `protobuf:"bytes,4,opt,name=expect_peer,json=expectPeer,proto3" json:"expect_peer,omitempty"`
	// whether to require peer proving it owns expect_peer
	MutualAuth bool `protobuf:"varint,5,opt,name=mutual_auth,json=mutualAuth,proto3" json:"mutual_auth,omitempty"`
	// r0.15 doesn't have this field so it's 0
	// r0.16 has 1 to support sync in auth
	ProtocolVersion uint64 `protobuf:"varint,6,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// client's view of channels. empty if never openchan or recover case
	OpenedChannels []*ChannelSummary `protobuf:"bytes,7,rep,name=opened_channels,json=openedChannels,proto3" json:"opened_channels,omitempty"`
	// contains filtered or unexported fields
}

type BcastRoutingReply struct {
	// contains filtered or unexported fields
}

type BcastRoutingRequest struct {

	// the routing request to broadcast
	Req *RoutingRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
	// peer OSPs to send the request to
	Osps []string `protobuf:"bytes,2,rep,name=osps,proto3" json:"osps,omitempty"`
	// contains filtered or unexported fields
}

type BuildRoutingTableRequest struct {
	TokenAddress []byte `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	// contains filtered or unexported fields
}

type CelerMsg struct {
	Mid *MID `protobuf:"bytes,1,opt,name=mid,proto3" json:"mid,omitempty"`
	// if ret_mid is set in received msg, use it as mid in next msg to send
	// this is to support multi-msg exchanges and let both ends be able to correlate
	// their own MID req/resp
	RetMid *MID `protobuf:"bytes,2,opt,name=ret_mid,json=retMid,proto3" json:"ret_mid,omitempty"`
	// bitmask flags for nature of this msg, eg. End2End, First msg in subflow, Last of subflow etc
	Flag uint64 `protobuf:"varint,3,opt,name=flag,proto3" json:"flag,omitempty"`
	// to_addr is only used for end-to-end msg to save relay node looking into payload
	// for hop-by-hop, expected peer addr is already checked in authreq/ack so no need in every msg
	ToAddr []byte `protobuf:"bytes,4,opt,name=to_addr,json=toAddr,proto3" json:"to_addr,omitempty"`
	// Types that are valid to be assigned to Message:
	//
	//	*CelerMsg_Error
	//	*CelerMsg_AuthReq
	//	*CelerMsg_AuthAck
	//	*CelerMsg_CondPayRequest
	//	*CelerMsg_CondPayResponse
	//	*CelerMsg_PaymentSettleProof
	//	*CelerMsg_PaymentSettleRequest
	//	*CelerMsg_PaymentSettleResponse
	//	*CelerMsg_WithdrawRequest
	//	*CelerMsg_WithdrawResponse
	//	*CelerMsg_RoutingRequest
	//	*CelerMsg_CondPayReceipt
	//	*CelerMsg_RevealSecret
	//	*CelerMsg_RevealSecretAck
	//	*CelerMsg_PayResultVouchRequest
	//	*CelerMsg_PayResultVouchResponse
	Message isCelerMsg_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type CelerMsg_AuthAck struct {
	// response to auth_req
	AuthAck *AuthAck `protobuf:"bytes,8,opt,name=auth_ack,json=authAck,proto3,oneof"`
}

type CelerMsg_AuthReq struct {
	// ====== hop-by-hop =====
	// first msg on a new stream to tell peer my addr and prove I do own it
	// optionally require peer to prove as well
	AuthReq *AuthReq `protobuf:"bytes,7,opt,name=auth_req,json=authReq,proto3,oneof"`
}

type CelerMsg_CondPayReceipt struct {
	// ====== end-to-end =====
	// sent by pay dest to notify pay src
	CondPayReceipt *CondPayReceipt `protobuf:"bytes,31,opt,name=cond_pay_receipt,json=condPayReceipt,proto3,oneof"`
}

type CelerMsg_CondPayRequest struct {
	// send a new condpay
	CondPayRequest *CondPayRequest `protobuf:"bytes,9,opt,name=cond_pay_request,json=condPayRequest,proto3,oneof"`
}

type CelerMsg_CondPayResponse struct {
	// condpay response
	CondPayResponse *CondPayResponse `protobuf:"bytes,10,opt,name=cond_pay_response,json=condPayResponse,proto3,oneof"`
}

type CelerMsg_Error struct {
	// error with enum code and string reason
	Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type CelerMsg_PayResultVouchRequest struct {
	// sent by pay dest to vouch pay result, only needed for payment with numeric conditions
	PayResultVouchRequest *entity.VouchedCondPayResult `protobuf:"bytes,34,opt,name=pay_result_vouch_request,json=payResultVouchRequest,proto3,oneof"`
}

type CelerMsg_PayResultVouchResponse struct {
	// sent by pay src with cosigned vouched pay result, only needed for payment with numeric conditions
	PayResultVouchResponse *entity.VouchedCondPayResult `protobuf:"bytes,35,opt,name=pay_result_vouch_response,json=payResultVouchResponse,proto3,oneof"`
}

type CelerMsg_PaymentSettleProof struct {
	// request peer to update simplex and send back PaymentSettleRequest
	PaymentSettleProof *PaymentSettleProof `protobuf:"bytes,11,opt,name=payment_settle_proof,json=paymentSettleProof,proto3,oneof"`
}

type CelerMsg_PaymentSettleRequest struct {
	// send a new simplex with some pays settled
	PaymentSettleRequest *PaymentSettleRequest `protobuf:"bytes,12,opt,name=payment_settle_request,json=paymentSettleRequest,proto3,oneof"`
}

type CelerMsg_PaymentSettleResponse struct {
	// pay settle response
	PaymentSettleResponse *PaymentSettleResponse `protobuf:"bytes,13,opt,name=payment_settle_response,json=paymentSettleResponse,proto3,oneof"`
}

type CelerMsg_RevealSecret struct {
	// sent by pay src to pay dest to reveal hash lock preimage
	RevealSecret *RevealSecret `protobuf:"bytes,32,opt,name=reveal_secret,json=revealSecret,proto3,oneof"`
}

type CelerMsg_RevealSecretAck struct {
	// sent by pay dest to pay src, indicate pay dest has received preimage
	RevealSecretAck *RevealSecretAck `protobuf:"bytes,33,opt,name=reveal_secret_ack,json=revealSecretAck,proto3,oneof"`
}

type CelerMsg_RoutingRequest struct {
	// send routing information (broadcast through OSP network)
	RoutingRequest *RoutingRequest `protobuf:"bytes,16,opt,name=routing_request,json=routingRequest,proto3,oneof"` // skip 17-30 for future msgs
}

type CelerMsg_WithdrawRequest struct {
	// request to move balance from offchain to onchain
	WithdrawRequest *CooperativeWithdrawRequest `protobuf:"bytes,14,opt,name=withdraw_request,json=withdrawRequest,proto3,oneof"`
}

type CelerMsg_WithdrawResponse struct {
	// withdraw response
	WithdrawResponse *CooperativeWithdrawResponse `protobuf:"bytes,15,opt,name=withdraw_response,json=withdrawResponse,proto3,oneof"`
}

type CelerStream interface {
	Send(*CelerMsg) error
	Recv() (*CelerMsg, error)
}

type ChannelInAuth struct {
	Cid []byte `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// Channel state defined in agentPay channel-fsm.go.
	ChannelState int64 `protobuf:"varint,2,opt,name=channel_state,json=channelState,proto3" json:"channel_state,omitempty"`
	// open channel response for case of TCB.
	OpenChannelResponse *OpenChannelResponse `protobuf:"bytes,3,opt,name=open_channel_response,json=openChannelResponse,proto3" json:"open_channel_response,omitempty"`
	// cosigned simplex belong to auth ack node
	AuthackSimplex *SignedSimplexState `protobuf:"bytes,4,opt,name=authack_simplex,json=authackSimplex,proto3" json:"authack_simplex,omitempty"`
	// pending pays in authack_simplex
	AuthackPays []*PayInAuthAck `protobuf:"bytes,5,rep,name=authack_pays,json=authackPays,proto3" json:"authack_pays,omitempty"`
	// cosigned simplex belong to auth requester
	AuthreqSimplex *SignedSimplexState `protobuf:"bytes,6,opt,name=authreq_simplex,json=authreqSimplex,proto3" json:"authreq_simplex,omitempty"`
	// pending pays in authreq_simplex
	AuthreqPays []*PayInAuthAck `protobuf:"bytes,7,rep,name=authreq_pays,json=authreqPays,proto3" json:"authreq_pays,omitempty"`
	// ledger address that the channel is operating on.
	LedgerAddr []byte `protobuf:"bytes,8,opt,name=ledger_addr,json=ledgerAddr,proto3" json:"ledger_addr,omitempty"`
	// contains filtered or unexported fields
}

type ChannelOpRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"` // hex string of channel id, accept both with and w/o 0x prefix
	Wei string `protobuf:"bytes,2,opt,name=wei,proto3" json:"wei,omitempty"` // decimal string of withdraw amount in wei, if not specified, will withdraw all free balance
	// contains filtered or unexported fields
}

type ChannelOpResponse struct {
	Status int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // 0 means success
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ChannelRoutingInfo struct {

	// channel identifier
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// channel liquidity amount
	Balance string `protobuf:"bytes,2,opt,name=balance,proto3" json:"balance,omitempty"`
	// contains filtered or unexported fields
}

type ChannelSummary struct {
	ChannelId  []byte `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	MySeqNum   uint64 `protobuf:"varint,2,opt,name=my_seq_num,json=mySeqNum,proto3" json:"my_seq_num,omitempty"`
	PeerSeqNum uint64 `protobuf:"varint,3,opt,name=peer_seq_num,json=peerSeqNum,proto3" json:"peer_seq_num,omitempty"`
	LedgerAddr []byte `protobuf:"bytes,4,opt,name=ledger_addr,json=ledgerAddr,proto3" json:"ledger_addr,omitempty"`
	// contains filtered or unexported fields
}

type ClearExpiredPaysRequest struct {
	TokenAddress []byte `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	// contains filtered or unexported fields
}

type CondPayReceipt struct {

	// refer to pay by its id is enough
	PayId []byte `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	// either pay_dest signs payid or pay delegator signs pay id
	PayDestSig      []byte           `protobuf:"bytes,2,opt,name=pay_dest_sig,json=payDestSig,proto3" json:"pay_dest_sig,omitempty"`
	PayDelegatorSig []byte           `protobuf:"bytes,3,opt,name=pay_delegator_sig,json=payDelegatorSig,proto3" json:"pay_delegator_sig,omitempty"`
	DelegationProof *DelegationProof `protobuf:"bytes,4,opt,name=delegation_proof,json=delegationProof,proto3" json:"delegation_proof,omitempty"`
	// used for cross net pay
	OriginalPayId []byte `protobuf:"bytes,5,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
	// contains filtered or unexported fields
}

type CondPayRequest struct {

	// use serialized entity.ConditionalPay to ensure byte-perfect consistency across all platforms
	// and simplify payment info verification especially during on-chain settlement
	CondPay              []byte              `protobuf:"bytes,1,opt,name=cond_pay,json=condPay,proto3" json:"cond_pay,omitempty"`
	StateOnlyPeerFromSig *SignedSimplexState `` /* 127-byte string literal not displayed */
	Note                 *anypb.Any          `protobuf:"bytes,3,opt,name=note,proto3" json:"note,omitempty"`
	// Sequence num of the previous simplex state that this new state is based on.
	// Useful for failure recover.
	BaseSeq uint64 `protobuf:"varint,4,opt,name=base_seq,json=baseSeq,proto3" json:"base_seq,omitempty"`
	// Optimization: payment between direct peers needs only one roundtrip.
	// A direct payment is one where the source and destination of the payment
	// are directly-connected peers (e.g. client sending a payment to its OSP)
	// and the payment is unconditional.
	DirectPay bool `protobuf:"varint,5,opt,name=direct_pay,json=directPay,proto3" json:"direct_pay,omitempty"`
	// used for cross network payment
	CrossNet *CrossNetPay `protobuf:"bytes,6,opt,name=cross_net,json=crossNet,proto3" json:"cross_net,omitempty"`
	// contains filtered or unexported fields
}

type CondPayResponse struct {
	StateCosigned *SignedSimplexState `protobuf:"bytes,1,opt,name=state_cosigned,json=stateCosigned,proto3" json:"state_cosigned,omitempty"`
	Error         *Error              `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ConfirmOnChainResolvedPaysRequest struct {
	TokenAddress []byte `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	// contains filtered or unexported fields
}

type ConnectionManager struct {
	// contains filtered or unexported fields
}

type CooperativeWithdrawRequest struct {
	WithdrawInfo *entity.CooperativeWithdrawInfo `protobuf:"bytes,1,opt,name=withdraw_info,json=withdrawInfo,proto3" json:"withdraw_info,omitempty"`
	RequesterSig []byte                          `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	// contains filtered or unexported fields
}

type CooperativeWithdrawResponse struct {
	WithdrawInfo *entity.CooperativeWithdrawInfo `protobuf:"bytes,1,opt,name=withdraw_info,json=withdrawInfo,proto3" json:"withdraw_info,omitempty"`
	RequesterSig []byte                          `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	ApproverSig  []byte                          `protobuf:"bytes,3,opt,name=approver_sig,json=approverSig,proto3" json:"approver_sig,omitempty"`
	// contains filtered or unexported fields
}

type CrossNetPay struct {

	// vars 1-3 are updated by pay src
	SrcNetId    uint64 `protobuf:"varint,1,opt,name=src_net_id,json=srcNetId,proto3" json:"src_net_id,omitempty"`
	DstNetId    uint64 `protobuf:"varint,2,opt,name=dst_net_id,json=dstNetId,proto3" json:"dst_net_id,omitempty"`
	OriginalPay []byte `protobuf:"bytes,3,opt,name=original_pay,json=originalPay,proto3" json:"original_pay,omitempty"`
	// vars 4-7 are updated by bridge OSPs
	Crossing    bool   `protobuf:"varint,4,opt,name=crossing,proto3" json:"crossing,omitempty"`
	BridgeAddr  []byte `protobuf:"bytes,5,opt,name=bridge_addr,json=bridgeAddr,proto3" json:"bridge_addr,omitempty"`
	BridgeNetId uint64 `protobuf:"varint,6,opt,name=bridge_net_id,json=bridgeNetId,proto3" json:"bridge_net_id,omitempty"`
	Timeout     uint64 `protobuf:"varint,7,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

type DelegationDescription struct {

	// address of delegator
	Delegator []byte `protobuf:"bytes,1,opt,name=delegator,proto3" json:"delegator,omitempty"`
	// address of delegatee
	Delegatee []byte `protobuf:"bytes,2,opt,name=delegatee,proto3" json:"delegatee,omitempty"`
	// Off-chain delegation expiry. Unix timestamp (seconds). Field name kept for wire-format back-compat.
	ExpiresAfterBlock int64 `protobuf:"varint,3,opt,name=expires_after_block,json=expiresAfterBlock,proto3" json:"expires_after_block,omitempty"`
	// token addresses to be delegated
	TokenToDelegate [][]byte `protobuf:"bytes,4,rep,name=token_to_delegate,json=tokenToDelegate,proto3" json:"token_to_delegate,omitempty"`
	// contains filtered or unexported fields
}

type DelegationProof struct {

	// Serialized DelegationDescription.
	DelegationDescriptionBytes []byte `` /* 141-byte string literal not displayed */
	// signature of delegation_description_bytes signed by signer.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// addresses of signer. Should be same to "delegator" in DelegationDescription.
	Signer []byte `protobuf:"bytes,3,opt,name=signer,proto3" json:"signer,omitempty"`
	// contains filtered or unexported fields
}

type DelegationRequest struct {
	Proof *DelegationProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

type DelegationResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type DepositRequest struct {

	// payment channel peer address
	PeerAddr string `protobuf:"bytes,1,opt,name=peer_addr,json=peerAddr,proto3" json:"peer_addr,omitempty"`
	// payment channel token address
	TokenAddr string `protobuf:"bytes,2,opt,name=token_addr,json=tokenAddr,proto3" json:"token_addr,omitempty"`
	// deposit to channel peer or self (default: false, to self)
	ToPeer bool `protobuf:"varint,3,opt,name=to_peer,json=toPeer,proto3" json:"to_peer,omitempty"`
	// deposit amount in wei
	AmtWei string `protobuf:"bytes,4,opt,name=amt_wei,json=amtWei,proto3" json:"amt_wei,omitempty"`
	// time (in seconds) allowed for OSP to wait and batch requests before submitting the on-chain transaction
	MaxWaitS uint64 `protobuf:"varint,5,opt,name=max_wait_s,json=maxWaitS,proto3" json:"max_wait_s,omitempty"`
	// contains filtered or unexported fields
}

type DepositResponse struct {
	Status    int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Error     string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	DepositId string `protobuf:"bytes,3,opt,name=deposit_id,json=depositId,proto3" json:"deposit_id,omitempty"`
	// contains filtered or unexported fields
}

type DepositState int32

type ErrCallbackFunc func(addr ctype.Addr, err error)

type ErrCode int32

type Error struct {
	Code   ErrCode `protobuf:"varint,1,opt,name=code,proto3,enum=rpc.ErrCode" json:"code,omitempty"`
	Reason string  `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// sequence number (if exists) of the errored message
	Seq uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	// contains filtered or unexported fields
}

type FwdReply struct {
	Accepted bool   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Err      string `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type FwdReq struct {
	Dest    string    `protobuf:"bytes,1,opt,name=dest,proto3" json:"dest,omitempty"`
	Message *CelerMsg `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type GetPayHistoryRequest struct {

	// request pay history of peer.
	Peer string `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	// request pay history before certain timestamp.
	BeforeTs int64 `protobuf:"varint,2,opt,name=before_ts,json=beforeTs,proto3" json:"before_ts,omitempty"`
	// max result in the response.
	ItemsPerPage int32 `protobuf:"varint,3,opt,name=items_per_page,json=itemsPerPage,proto3" json:"items_per_page,omitempty"`
	// signature to verify peer.
	TsSig []byte `protobuf:"bytes,4,opt,name=ts_sig,json=tsSig,proto3" json:"ts_sig,omitempty"`
	Ts    uint64 `protobuf:"varint,5,opt,name=ts,proto3" json:"ts,omitempty"`
	// if result has pays that have payIDs equal to before_ts, only return those that have higher pay ids than smallest_pay_id.
	SmallestPayId string `protobuf:"bytes,6,opt,name=smallest_pay_id,json=smallestPayId,proto3" json:"smallest_pay_id,omitempty"`
	// contains filtered or unexported fields
}

type GetPayHistoryResponse struct {
	Pays []*OneHistoricalPay `protobuf:"bytes,1,rep,name=pays,proto3" json:"pays,omitempty"`
	// contains filtered or unexported fields
}

type JoinCelerStatus int32

type MID struct {

	// tag is string to identify requester to avoid seq conflict
	// for a typical req/resp flow, both req and resp messages have the same tag
	// that identifies requester, and same seq so requester side can correlate
	// resp with req
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// sender must increment seq for new messages
	Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	// contains filtered or unexported fields
}

type MigrateChannelRequest struct {

	// Serialized entity.ChannelMigrationInfo
	ChannelMigrationInfo []byte `protobuf:"bytes,1,opt,name=channel_migration_info,json=channelMigrationInfo,proto3" json:"channel_migration_info,omitempty"`
	// Signature of channel_migration_info signed by request sender
	RequesterSig []byte `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	// contains filtered or unexported fields
}

type MigrateChannelResponse struct {

	// Signature of channel_migration_info signed by request approver
	ApproverSig []byte `protobuf:"bytes,1,opt,name=approver_sig,json=approverSig,proto3" json:"approver_sig,omitempty"`
	// contains filtered or unexported fields
}

type MsgQueueCallbackFunc func(peer ctype.Addr) error

type MultiServerClient interface {
	FwdMsg(ctx context.Context, in *FwdReq, opts ...grpc.CallOption) (*FwdReply, error)
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error)
	PickServer(ctx context.Context, in *PickReq, opts ...grpc.CallOption) (*PickReply, error)
	BcastRoutingInfo(ctx context.Context, in *BcastRoutingRequest, opts ...grpc.CallOption) (*BcastRoutingReply, error)
}

type MultiServerServer interface {
	FwdMsg(context.Context, *FwdReq) (*FwdReply, error)
	Ping(context.Context, *PingReq) (*PingReply, error)
	PickServer(context.Context, *PickReq) (*PickReply, error)
	BcastRoutingInfo(context.Context, *BcastRoutingRequest) (*BcastRoutingReply, error)
	// contains filtered or unexported methods
}

type OneHistoricalPay struct {

	// pay destination
	Dst string `protobuf:"bytes,1,opt,name=dst,proto3" json:"dst,omitempty"`
	// token address used by the pay.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// amount of the payment
	Amt string `protobuf:"bytes,3,opt,name=amt,proto3" json:"amt,omitempty"`
	// pay status
	State int64 `protobuf:"varint,4,opt,name=state,proto3" json:"state,omitempty"`
	// pay id
	PayId string `protobuf:"bytes,5,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	// pay creation timestamp
	CreateTs int64 `protobuf:"varint,6,opt,name=create_ts,json=createTs,proto3" json:"create_ts,omitempty"`
	// pay source
	Src string `protobuf:"bytes,7,opt,name=src,proto3" json:"src,omitempty"`
	// contains filtered or unexported fields
}

type OpenChannelBy int32

type OpenChannelRequest struct {

	// serialized entity.PaymentChannelInitializer
	ChannelInitializer []byte        `protobuf:"bytes,1,opt,name=channel_initializer,json=channelInitializer,proto3" json:"channel_initializer,omitempty"`
	RequesterSig       []byte        `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	OpenBy             OpenChannelBy `protobuf:"varint,3,opt,name=open_by,json=openBy,proto3,enum=rpc.OpenChannelBy" json:"open_by,omitempty"`
	// osp_to_osp set to true to indicate the channel is an OSP-OSP channel.
	OspToOsp bool `protobuf:"varint,4,opt,name=osp_to_osp,json=ospToOsp,proto3" json:"osp_to_osp,omitempty"`
	// contains filtered or unexported fields
}

type OpenChannelResponse struct {

	// serialized entity.PaymentChannelInitializer
	ChannelInitializer []byte            `protobuf:"bytes,1,opt,name=channel_initializer,json=channelInitializer,proto3" json:"channel_initializer,omitempty"`
	RequesterSig       []byte            `protobuf:"bytes,2,opt,name=requester_sig,json=requesterSig,proto3" json:"requester_sig,omitempty"`
	ApproverSig        []byte            `protobuf:"bytes,3,opt,name=approver_sig,json=approverSig,proto3" json:"approver_sig,omitempty"`
	Status             OpenChannelStatus `protobuf:"varint,4,opt,name=status,proto3,enum=rpc.OpenChannelStatus" json:"status,omitempty"`
	PaymentChannelId   []byte            `protobuf:"bytes,5,opt,name=payment_channel_id,json=paymentChannelId,proto3" json:"payment_channel_id,omitempty"`
	// contains filtered or unexported fields
}

type OpenChannelStatus int32

type OspOpenChannelRequest struct {

	// Peer to open channel with the osp.
	PeerEthAddress []byte `protobuf:"bytes,1,opt,name=peer_eth_address,json=peerEthAddress,proto3" json:"peer_eth_address,omitempty"`
	// ETH or ERC20
	TokenType entity.TokenType `protobuf:"varint,2,opt,name=token_type,json=tokenType,proto3,enum=entity.TokenType" json:"token_type,omitempty"`
	// where the token is defined.
	TokenAddress []byte `protobuf:"bytes,3,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
	// Deposit from myself in wei in decimal
	SelfDepositAmtWei string `protobuf:"bytes,4,opt,name=self_deposit_amt_wei,json=selfDepositAmtWei,proto3" json:"self_deposit_amt_wei,omitempty"`
	// Deposit asking to peer in wei in decimal
	PeerDepositAmtWei string `protobuf:"bytes,5,opt,name=peer_deposit_amt_wei,json=peerDepositAmtWei,proto3" json:"peer_deposit_amt_wei,omitempty"`
	// contains filtered or unexported fields
}

type PayHop struct {
	PayId       []byte `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
	PrevHopAddr []byte `protobuf:"bytes,2,opt,name=prev_hop_addr,json=prevHopAddr,proto3" json:"prev_hop_addr,omitempty"`
	NextHopAddr []byte `protobuf:"bytes,3,opt,name=next_hop_addr,json=nextHopAddr,proto3" json:"next_hop_addr,omitempty"`
	Err         *Error `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type PayInAuthAck struct {
	Pay  []byte     `protobuf:"bytes,1,opt,name=pay,proto3" json:"pay,omitempty"`   // pay bytes
	Note *anypb.Any `protobuf:"bytes,2,opt,name=note,proto3" json:"note,omitempty"` // pay note
	// pay state, from instate or outstate depending on which simplex
	State int64 `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type PayPath struct {
	Hops []*SignedPayHop `protobuf:"bytes,1,rep,name=hops,proto3" json:"hops,omitempty"`
	// contains filtered or unexported fields
}

type PaymentSettleProof struct {
	VouchedCondPayResults []*entity.VouchedCondPayResult `` /* 128-byte string literal not displayed */
	// valid reasons for settled_pays in PaymentSettleProof
	// EXPIRED, REJECTED, RESOLVED_ONCHAIN, DEST_UNREACHABLE
	SettledPays []*SettledPayment `protobuf:"bytes,2,rep,name=settled_pays,json=settledPays,proto3" json:"settled_pays,omitempty"`
	// contains filtered or unexported fields
}

type PaymentSettleReason int32

type PaymentSettleRequest struct {
	SettledPays          []*SettledPayment   `protobuf:"bytes,1,rep,name=settled_pays,json=settledPays,proto3" json:"settled_pays,omitempty"`
	StateOnlyPeerFromSig *SignedSimplexState `` /* 127-byte string literal not displayed */
	// Sequence num of the previous simplex state that this new state is based on.
	// Useful for failure recover.
	BaseSeq uint64 `protobuf:"varint,3,opt,name=base_seq,json=baseSeq,proto3" json:"base_seq,omitempty"`
	// contains filtered or unexported fields
}

type PaymentSettleResponse struct {
	StateCosigned *SignedSimplexState `protobuf:"bytes,1,opt,name=state_cosigned,json=stateCosigned,proto3" json:"state_cosigned,omitempty"`
	Error         *Error              `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}