Documentation
¶
Overview ¶
Package rpc is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdminClient) error
- func RegisterAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAdminServer(s *grpc.Server, srv AdminServer)
- func RegisterMultiServerServer(s *grpc.Server, srv MultiServerServer)
- func RegisterRpcServer(s *grpc.Server, srv RpcServer)
- type AdminClient
- type AdminServer
- type AuthAck
- func (*AuthAck) Descriptor() ([]byte, []int)
- func (m *AuthAck) GetMySig() []byte
- func (m *AuthAck) GetStartMid() *MID
- func (m *AuthAck) GetSyncChannels() []*ChannelInAuth
- func (*AuthAck) ProtoMessage()
- func (m *AuthAck) Reset()
- func (m *AuthAck) String() string
- func (m *AuthAck) XXX_DiscardUnknown()
- func (m *AuthAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuthAck) XXX_Merge(src proto.Message)
- func (m *AuthAck) XXX_Size() int
- func (m *AuthAck) XXX_Unmarshal(b []byte) error
- type AuthReq
- func (*AuthReq) Descriptor() ([]byte, []int)
- func (m *AuthReq) GetExpectPeer() []byte
- func (m *AuthReq) GetMutualAuth() bool
- func (m *AuthReq) GetMyAddr() []byte
- func (m *AuthReq) GetMySig() []byte
- func (m *AuthReq) GetOpenedChannels() []*ChannelSummary
- func (m *AuthReq) GetProtocolVersion() uint64
- func (m *AuthReq) GetTimestamp() uint64
- func (*AuthReq) ProtoMessage()
- func (m *AuthReq) Reset()
- func (m *AuthReq) String() string
- func (m *AuthReq) XXX_DiscardUnknown()
- func (m *AuthReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuthReq) XXX_Merge(src proto.Message)
- func (m *AuthReq) XXX_Size() int
- func (m *AuthReq) XXX_Unmarshal(b []byte) error
- type BcastRoutingReply
- func (*BcastRoutingReply) Descriptor() ([]byte, []int)
- func (*BcastRoutingReply) ProtoMessage()
- func (m *BcastRoutingReply) Reset()
- func (m *BcastRoutingReply) String() string
- func (m *BcastRoutingReply) XXX_DiscardUnknown()
- func (m *BcastRoutingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BcastRoutingReply) XXX_Merge(src proto.Message)
- func (m *BcastRoutingReply) XXX_Size() int
- func (m *BcastRoutingReply) XXX_Unmarshal(b []byte) error
- type BcastRoutingRequest
- func (*BcastRoutingRequest) Descriptor() ([]byte, []int)
- func (m *BcastRoutingRequest) GetOsps() []string
- func (m *BcastRoutingRequest) GetReq() *RoutingRequest
- func (*BcastRoutingRequest) ProtoMessage()
- func (m *BcastRoutingRequest) Reset()
- func (m *BcastRoutingRequest) String() string
- func (m *BcastRoutingRequest) XXX_DiscardUnknown()
- func (m *BcastRoutingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BcastRoutingRequest) XXX_Merge(src proto.Message)
- func (m *BcastRoutingRequest) XXX_Size() int
- func (m *BcastRoutingRequest) XXX_Unmarshal(b []byte) error
- type BuildRoutingTableRequest
- func (*BuildRoutingTableRequest) Descriptor() ([]byte, []int)
- func (m *BuildRoutingTableRequest) GetTokenAddress() []byte
- func (*BuildRoutingTableRequest) ProtoMessage()
- func (m *BuildRoutingTableRequest) Reset()
- func (m *BuildRoutingTableRequest) String() string
- func (m *BuildRoutingTableRequest) XXX_DiscardUnknown()
- func (m *BuildRoutingTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BuildRoutingTableRequest) XXX_Merge(src proto.Message)
- func (m *BuildRoutingTableRequest) XXX_Size() int
- func (m *BuildRoutingTableRequest) XXX_Unmarshal(b []byte) error
- type CelerMsg
- func (*CelerMsg) Descriptor() ([]byte, []int)
- func (m *CelerMsg) GetAuthAck() *AuthAck
- func (m *CelerMsg) GetAuthReq() *AuthReq
- func (m *CelerMsg) GetCondPayReceipt() *CondPayReceipt
- func (m *CelerMsg) GetCondPayRequest() *CondPayRequest
- func (m *CelerMsg) GetCondPayResponse() *CondPayResponse
- func (m *CelerMsg) GetError() *Error
- func (m *CelerMsg) GetFlag() uint64
- func (m *CelerMsg) GetMessage() isCelerMsg_Message
- func (m *CelerMsg) GetMid() *MID
- func (m *CelerMsg) GetPayResultVouchRequest() *entity.VouchedCondPayResult
- func (m *CelerMsg) GetPayResultVouchResponse() *entity.VouchedCondPayResult
- func (m *CelerMsg) GetPaymentSettleProof() *PaymentSettleProof
- func (m *CelerMsg) GetPaymentSettleRequest() *PaymentSettleRequest
- func (m *CelerMsg) GetPaymentSettleResponse() *PaymentSettleResponse
- func (m *CelerMsg) GetRetMid() *MID
- func (m *CelerMsg) GetRevealSecret() *RevealSecret
- func (m *CelerMsg) GetRevealSecretAck() *RevealSecretAck
- func (m *CelerMsg) GetRoutingRequest() *RoutingRequest
- func (m *CelerMsg) GetToAddr() []byte
- func (m *CelerMsg) GetWithdrawRequest() *CooperativeWithdrawRequest
- func (m *CelerMsg) GetWithdrawResponse() *CooperativeWithdrawResponse
- func (*CelerMsg) ProtoMessage()
- func (m *CelerMsg) Reset()
- func (m *CelerMsg) String() string
- func (m *CelerMsg) XXX_DiscardUnknown()
- func (m *CelerMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CelerMsg) XXX_Merge(src proto.Message)
- func (*CelerMsg) XXX_OneofWrappers() []interface{}
- func (m *CelerMsg) XXX_Size() int
- func (m *CelerMsg) XXX_Unmarshal(b []byte) error
- type CelerMsg_AuthAck
- type CelerMsg_AuthReq
- type CelerMsg_CondPayReceipt
- type CelerMsg_CondPayRequest
- type CelerMsg_CondPayResponse
- type CelerMsg_Error
- type CelerMsg_PayResultVouchRequest
- type CelerMsg_PayResultVouchResponse
- type CelerMsg_PaymentSettleProof
- type CelerMsg_PaymentSettleRequest
- type CelerMsg_PaymentSettleResponse
- type CelerMsg_RevealSecret
- type CelerMsg_RevealSecretAck
- type CelerMsg_RoutingRequest
- type CelerMsg_WithdrawRequest
- type CelerMsg_WithdrawResponse
- type CelerStream
- type ChannelInAuth
- func (*ChannelInAuth) Descriptor() ([]byte, []int)
- func (m *ChannelInAuth) GetAuthackPays() []*PayInAuthAck
- func (m *ChannelInAuth) GetAuthackSimplex() *SignedSimplexState
- func (m *ChannelInAuth) GetAuthreqPays() []*PayInAuthAck
- func (m *ChannelInAuth) GetAuthreqSimplex() *SignedSimplexState
- func (m *ChannelInAuth) GetChannelState() int64
- func (m *ChannelInAuth) GetCid() []byte
- func (m *ChannelInAuth) GetLedgerAddr() []byte
- func (m *ChannelInAuth) GetOpenChannelResponse() *OpenChannelResponse
- func (*ChannelInAuth) ProtoMessage()
- func (m *ChannelInAuth) Reset()
- func (m *ChannelInAuth) String() string
- func (m *ChannelInAuth) XXX_DiscardUnknown()
- func (m *ChannelInAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelInAuth) XXX_Merge(src proto.Message)
- func (m *ChannelInAuth) XXX_Size() int
- func (m *ChannelInAuth) XXX_Unmarshal(b []byte) error
- type ChannelOpRequest
- func (*ChannelOpRequest) Descriptor() ([]byte, []int)
- func (m *ChannelOpRequest) GetCid() string
- func (m *ChannelOpRequest) GetWei() string
- func (*ChannelOpRequest) ProtoMessage()
- func (m *ChannelOpRequest) Reset()
- func (m *ChannelOpRequest) String() string
- func (m *ChannelOpRequest) XXX_DiscardUnknown()
- func (m *ChannelOpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelOpRequest) XXX_Merge(src proto.Message)
- func (m *ChannelOpRequest) XXX_Size() int
- func (m *ChannelOpRequest) XXX_Unmarshal(b []byte) error
- type ChannelOpResponse
- func (*ChannelOpResponse) Descriptor() ([]byte, []int)
- func (m *ChannelOpResponse) GetError() string
- func (m *ChannelOpResponse) GetStatus() int32
- func (*ChannelOpResponse) ProtoMessage()
- func (m *ChannelOpResponse) Reset()
- func (m *ChannelOpResponse) String() string
- func (m *ChannelOpResponse) XXX_DiscardUnknown()
- func (m *ChannelOpResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelOpResponse) XXX_Merge(src proto.Message)
- func (m *ChannelOpResponse) XXX_Size() int
- func (m *ChannelOpResponse) XXX_Unmarshal(b []byte) error
- type ChannelRoutingInfo
- func (*ChannelRoutingInfo) Descriptor() ([]byte, []int)
- func (m *ChannelRoutingInfo) GetBalance() string
- func (m *ChannelRoutingInfo) GetCid() string
- func (*ChannelRoutingInfo) ProtoMessage()
- func (m *ChannelRoutingInfo) Reset()
- func (m *ChannelRoutingInfo) String() string
- func (m *ChannelRoutingInfo) XXX_DiscardUnknown()
- func (m *ChannelRoutingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelRoutingInfo) XXX_Merge(src proto.Message)
- func (m *ChannelRoutingInfo) XXX_Size() int
- func (m *ChannelRoutingInfo) XXX_Unmarshal(b []byte) error
- type ChannelSummary
- func (*ChannelSummary) Descriptor() ([]byte, []int)
- func (m *ChannelSummary) GetChannelId() []byte
- func (m *ChannelSummary) GetLedgerAddr() []byte
- func (m *ChannelSummary) GetMySeqNum() uint64
- func (m *ChannelSummary) GetPeerSeqNum() uint64
- func (*ChannelSummary) ProtoMessage()
- func (m *ChannelSummary) Reset()
- func (m *ChannelSummary) String() string
- func (m *ChannelSummary) XXX_DiscardUnknown()
- func (m *ChannelSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelSummary) XXX_Merge(src proto.Message)
- func (m *ChannelSummary) XXX_Size() int
- func (m *ChannelSummary) XXX_Unmarshal(b []byte) error
- type ClearExpiredPaysRequest
- func (*ClearExpiredPaysRequest) Descriptor() ([]byte, []int)
- func (m *ClearExpiredPaysRequest) GetTokenAddress() []byte
- func (*ClearExpiredPaysRequest) ProtoMessage()
- func (m *ClearExpiredPaysRequest) Reset()
- func (m *ClearExpiredPaysRequest) String() string
- func (m *ClearExpiredPaysRequest) XXX_DiscardUnknown()
- func (m *ClearExpiredPaysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClearExpiredPaysRequest) XXX_Merge(src proto.Message)
- func (m *ClearExpiredPaysRequest) XXX_Size() int
- func (m *ClearExpiredPaysRequest) XXX_Unmarshal(b []byte) error
- type CondPayReceipt
- func (*CondPayReceipt) Descriptor() ([]byte, []int)
- func (m *CondPayReceipt) GetDelegationProof() *DelegationProof
- func (m *CondPayReceipt) GetOriginalPayId() []byte
- func (m *CondPayReceipt) GetPayDelegatorSig() []byte
- func (m *CondPayReceipt) GetPayDestSig() []byte
- func (m *CondPayReceipt) GetPayId() []byte
- func (*CondPayReceipt) ProtoMessage()
- func (m *CondPayReceipt) Reset()
- func (m *CondPayReceipt) String() string
- func (m *CondPayReceipt) XXX_DiscardUnknown()
- func (m *CondPayReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CondPayReceipt) XXX_Merge(src proto.Message)
- func (m *CondPayReceipt) XXX_Size() int
- func (m *CondPayReceipt) XXX_Unmarshal(b []byte) error
- type CondPayRequest
- func (*CondPayRequest) Descriptor() ([]byte, []int)
- func (m *CondPayRequest) GetBaseSeq() uint64
- func (m *CondPayRequest) GetCondPay() []byte
- func (m *CondPayRequest) GetCrossNet() *CrossNetPay
- func (m *CondPayRequest) GetDirectPay() bool
- func (m *CondPayRequest) GetNote() *any.Any
- func (m *CondPayRequest) GetStateOnlyPeerFromSig() *SignedSimplexState
- func (*CondPayRequest) ProtoMessage()
- func (m *CondPayRequest) Reset()
- func (m *CondPayRequest) String() string
- func (m *CondPayRequest) XXX_DiscardUnknown()
- func (m *CondPayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CondPayRequest) XXX_Merge(src proto.Message)
- func (m *CondPayRequest) XXX_Size() int
- func (m *CondPayRequest) XXX_Unmarshal(b []byte) error
- type CondPayResponse
- func (*CondPayResponse) Descriptor() ([]byte, []int)
- func (m *CondPayResponse) GetError() *Error
- func (m *CondPayResponse) GetStateCosigned() *SignedSimplexState
- func (*CondPayResponse) ProtoMessage()
- func (m *CondPayResponse) Reset()
- func (m *CondPayResponse) String() string
- func (m *CondPayResponse) XXX_DiscardUnknown()
- func (m *CondPayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CondPayResponse) XXX_Merge(src proto.Message)
- func (m *CondPayResponse) XXX_Size() int
- func (m *CondPayResponse) XXX_Unmarshal(b []byte) error
- type ConfirmOnChainResolvedPaysRequest
- func (*ConfirmOnChainResolvedPaysRequest) Descriptor() ([]byte, []int)
- func (m *ConfirmOnChainResolvedPaysRequest) GetTokenAddress() []byte
- func (*ConfirmOnChainResolvedPaysRequest) ProtoMessage()
- func (m *ConfirmOnChainResolvedPaysRequest) Reset()
- func (m *ConfirmOnChainResolvedPaysRequest) String() string
- func (m *ConfirmOnChainResolvedPaysRequest) XXX_DiscardUnknown()
- func (m *ConfirmOnChainResolvedPaysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfirmOnChainResolvedPaysRequest) XXX_Merge(src proto.Message)
- func (m *ConfirmOnChainResolvedPaysRequest) XXX_Size() int
- func (m *ConfirmOnChainResolvedPaysRequest) XXX_Unmarshal(b []byte) error
- type ConnectionManager
- func (m *ConnectionManager) AddCelerStream(peerAddr ctype.Addr, stream CelerStream, msgProcessor chan *CelerMsg) context.Context
- func (m *ConnectionManager) AddConnection(peerAddr ctype.Addr, cc *grpc.ClientConn)
- func (m *ConnectionManager) AddErrorCallback(peerAddr ctype.Addr, cb ErrCallbackFunc)
- func (m *ConnectionManager) CleanupStreams(peerAddr ctype.Addr)
- func (m *ConnectionManager) CloseConnection(peerAddr ctype.Addr)
- func (m *ConnectionManager) CloseNoRetry(onchainAddr ctype.Addr)
- func (m *ConnectionManager) GetCelerStream(peerAddr ctype.Addr) *SafeSendCelerStream
- func (m *ConnectionManager) GetClient(peerAddr ctype.Addr) (RpcClient, error)
- func (m *ConnectionManager) GetClientByAddr(peerAddr ctype.Addr) (RpcClient, error)
- func (m *ConnectionManager) GetNumCelerStreams() int
- func (m *ConnectionManager) SetMsgQueueCallback(enable, disable MsgQueueCallbackFunc)
- type CooperativeWithdrawRequest
- func (*CooperativeWithdrawRequest) Descriptor() ([]byte, []int)
- func (m *CooperativeWithdrawRequest) GetRequesterSig() []byte
- func (m *CooperativeWithdrawRequest) GetWithdrawInfo() *entity.CooperativeWithdrawInfo
- func (*CooperativeWithdrawRequest) ProtoMessage()
- func (m *CooperativeWithdrawRequest) Reset()
- func (m *CooperativeWithdrawRequest) String() string
- func (m *CooperativeWithdrawRequest) XXX_DiscardUnknown()
- func (m *CooperativeWithdrawRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CooperativeWithdrawRequest) XXX_Merge(src proto.Message)
- func (m *CooperativeWithdrawRequest) XXX_Size() int
- func (m *CooperativeWithdrawRequest) XXX_Unmarshal(b []byte) error
- type CooperativeWithdrawResponse
- func (*CooperativeWithdrawResponse) Descriptor() ([]byte, []int)
- func (m *CooperativeWithdrawResponse) GetApproverSig() []byte
- func (m *CooperativeWithdrawResponse) GetRequesterSig() []byte
- func (m *CooperativeWithdrawResponse) GetWithdrawInfo() *entity.CooperativeWithdrawInfo
- func (*CooperativeWithdrawResponse) ProtoMessage()
- func (m *CooperativeWithdrawResponse) Reset()
- func (m *CooperativeWithdrawResponse) String() string
- func (m *CooperativeWithdrawResponse) XXX_DiscardUnknown()
- func (m *CooperativeWithdrawResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CooperativeWithdrawResponse) XXX_Merge(src proto.Message)
- func (m *CooperativeWithdrawResponse) XXX_Size() int
- func (m *CooperativeWithdrawResponse) XXX_Unmarshal(b []byte) error
- type CrossNetPay
- func (*CrossNetPay) Descriptor() ([]byte, []int)
- func (m *CrossNetPay) GetBridgeAddr() []byte
- func (m *CrossNetPay) GetBridgeNetId() uint64
- func (m *CrossNetPay) GetCrossing() bool
- func (m *CrossNetPay) GetDstNetId() uint64
- func (m *CrossNetPay) GetOriginalPay() []byte
- func (m *CrossNetPay) GetSrcNetId() uint64
- func (m *CrossNetPay) GetTimeout() uint64
- func (*CrossNetPay) ProtoMessage()
- func (m *CrossNetPay) Reset()
- func (m *CrossNetPay) String() string
- func (m *CrossNetPay) XXX_DiscardUnknown()
- func (m *CrossNetPay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrossNetPay) XXX_Merge(src proto.Message)
- func (m *CrossNetPay) XXX_Size() int
- func (m *CrossNetPay) XXX_Unmarshal(b []byte) error
- type DelegationDescription
- func (*DelegationDescription) Descriptor() ([]byte, []int)
- func (m *DelegationDescription) GetDelegatee() []byte
- func (m *DelegationDescription) GetDelegator() []byte
- func (m *DelegationDescription) GetExpiresAfterBlock() int64
- func (m *DelegationDescription) GetTokenToDelegate() [][]byte
- func (*DelegationDescription) ProtoMessage()
- func (m *DelegationDescription) Reset()
- func (m *DelegationDescription) String() string
- func (m *DelegationDescription) XXX_DiscardUnknown()
- func (m *DelegationDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelegationDescription) XXX_Merge(src proto.Message)
- func (m *DelegationDescription) XXX_Size() int
- func (m *DelegationDescription) XXX_Unmarshal(b []byte) error
- type DelegationProof
- func (*DelegationProof) Descriptor() ([]byte, []int)
- func (m *DelegationProof) GetDelegationDescriptionBytes() []byte
- func (m *DelegationProof) GetSignature() []byte
- func (m *DelegationProof) GetSigner() []byte
- func (*DelegationProof) ProtoMessage()
- func (m *DelegationProof) Reset()
- func (m *DelegationProof) String() string
- func (m *DelegationProof) XXX_DiscardUnknown()
- func (m *DelegationProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelegationProof) XXX_Merge(src proto.Message)
- func (m *DelegationProof) XXX_Size() int
- func (m *DelegationProof) XXX_Unmarshal(b []byte) error
- type DelegationRequest
- func (*DelegationRequest) Descriptor() ([]byte, []int)
- func (m *DelegationRequest) GetProof() *DelegationProof
- func (*DelegationRequest) ProtoMessage()
- func (m *DelegationRequest) Reset()
- func (m *DelegationRequest) String() string
- func (m *DelegationRequest) XXX_DiscardUnknown()
- func (m *DelegationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelegationRequest) XXX_Merge(src proto.Message)
- func (m *DelegationRequest) XXX_Size() int
- func (m *DelegationRequest) XXX_Unmarshal(b []byte) error
- type DelegationResponse
- func (*DelegationResponse) Descriptor() ([]byte, []int)
- func (m *DelegationResponse) GetError() string
- func (*DelegationResponse) ProtoMessage()
- func (m *DelegationResponse) Reset()
- func (m *DelegationResponse) String() string
- func (m *DelegationResponse) XXX_DiscardUnknown()
- func (m *DelegationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelegationResponse) XXX_Merge(src proto.Message)
- func (m *DelegationResponse) XXX_Size() int
- func (m *DelegationResponse) XXX_Unmarshal(b []byte) error
- type DepositRequest
- func (*DepositRequest) Descriptor() ([]byte, []int)
- func (m *DepositRequest) GetAmtWei() string
- func (m *DepositRequest) GetMaxWaitS() uint64
- func (m *DepositRequest) GetPeerAddr() string
- func (m *DepositRequest) GetToPeer() bool
- func (m *DepositRequest) GetTokenAddr() string
- func (*DepositRequest) ProtoMessage()
- func (m *DepositRequest) Reset()
- func (m *DepositRequest) String() string
- func (m *DepositRequest) XXX_DiscardUnknown()
- func (m *DepositRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DepositRequest) XXX_Merge(src proto.Message)
- func (m *DepositRequest) XXX_Size() int
- func (m *DepositRequest) XXX_Unmarshal(b []byte) error
- type DepositResponse
- func (*DepositResponse) Descriptor() ([]byte, []int)
- func (m *DepositResponse) GetDepositId() string
- func (m *DepositResponse) GetError() string
- func (m *DepositResponse) GetStatus() int32
- func (*DepositResponse) ProtoMessage()
- func (m *DepositResponse) Reset()
- func (m *DepositResponse) String() string
- func (m *DepositResponse) XXX_DiscardUnknown()
- func (m *DepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DepositResponse) XXX_Merge(src proto.Message)
- func (m *DepositResponse) XXX_Size() int
- func (m *DepositResponse) XXX_Unmarshal(b []byte) error
- type DepositState
- type ErrCallbackFunc
- type ErrCode
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetCode() ErrCode
- func (m *Error) GetReason() string
- func (m *Error) GetSeq() uint64
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) String() string
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type FwdReply
- func (*FwdReply) Descriptor() ([]byte, []int)
- func (m *FwdReply) GetAccepted() bool
- func (m *FwdReply) GetErr() string
- func (*FwdReply) ProtoMessage()
- func (m *FwdReply) Reset()
- func (m *FwdReply) String() string
- func (m *FwdReply) XXX_DiscardUnknown()
- func (m *FwdReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FwdReply) XXX_Merge(src proto.Message)
- func (m *FwdReply) XXX_Size() int
- func (m *FwdReply) XXX_Unmarshal(b []byte) error
- type FwdReq
- func (*FwdReq) Descriptor() ([]byte, []int)
- func (m *FwdReq) GetDest() string
- func (m *FwdReq) GetMessage() *CelerMsg
- func (*FwdReq) ProtoMessage()
- func (m *FwdReq) Reset()
- func (m *FwdReq) String() string
- func (m *FwdReq) XXX_DiscardUnknown()
- func (m *FwdReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FwdReq) XXX_Merge(src proto.Message)
- func (m *FwdReq) XXX_Size() int
- func (m *FwdReq) XXX_Unmarshal(b []byte) error
- type GetPayHistoryRequest
- func (*GetPayHistoryRequest) Descriptor() ([]byte, []int)
- func (m *GetPayHistoryRequest) GetBeforeTs() int64
- func (m *GetPayHistoryRequest) GetItemsPerPage() int32
- func (m *GetPayHistoryRequest) GetPeer() string
- func (m *GetPayHistoryRequest) GetSmallestPayId() string
- func (m *GetPayHistoryRequest) GetTs() uint64
- func (m *GetPayHistoryRequest) GetTsSig() []byte
- func (*GetPayHistoryRequest) ProtoMessage()
- func (m *GetPayHistoryRequest) Reset()
- func (m *GetPayHistoryRequest) String() string
- func (m *GetPayHistoryRequest) XXX_DiscardUnknown()
- func (m *GetPayHistoryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPayHistoryRequest) XXX_Merge(src proto.Message)
- func (m *GetPayHistoryRequest) XXX_Size() int
- func (m *GetPayHistoryRequest) XXX_Unmarshal(b []byte) error
- type GetPayHistoryResponse
- func (*GetPayHistoryResponse) Descriptor() ([]byte, []int)
- func (m *GetPayHistoryResponse) GetPays() []*OneHistoricalPay
- func (*GetPayHistoryResponse) ProtoMessage()
- func (m *GetPayHistoryResponse) Reset()
- func (m *GetPayHistoryResponse) String() string
- func (m *GetPayHistoryResponse) XXX_DiscardUnknown()
- func (m *GetPayHistoryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPayHistoryResponse) XXX_Merge(src proto.Message)
- func (m *GetPayHistoryResponse) XXX_Size() int
- func (m *GetPayHistoryResponse) XXX_Unmarshal(b []byte) error
- type JoinCelerStatus
- type MID
- func (*MID) Descriptor() ([]byte, []int)
- func (m *MID) GetSeq() uint64
- func (m *MID) GetTag() string
- func (*MID) ProtoMessage()
- func (m *MID) Reset()
- func (m *MID) String() string
- func (m *MID) XXX_DiscardUnknown()
- func (m *MID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MID) XXX_Merge(src proto.Message)
- func (m *MID) XXX_Size() int
- func (m *MID) XXX_Unmarshal(b []byte) error
- type MigrateChannelRequest
- func (*MigrateChannelRequest) Descriptor() ([]byte, []int)
- func (m *MigrateChannelRequest) GetChannelMigrationInfo() []byte
- func (m *MigrateChannelRequest) GetRequesterSig() []byte
- func (*MigrateChannelRequest) ProtoMessage()
- func (m *MigrateChannelRequest) Reset()
- func (m *MigrateChannelRequest) String() string
- func (m *MigrateChannelRequest) XXX_DiscardUnknown()
- func (m *MigrateChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrateChannelRequest) XXX_Merge(src proto.Message)
- func (m *MigrateChannelRequest) XXX_Size() int
- func (m *MigrateChannelRequest) XXX_Unmarshal(b []byte) error
- type MigrateChannelResponse
- func (*MigrateChannelResponse) Descriptor() ([]byte, []int)
- func (m *MigrateChannelResponse) GetApproverSig() []byte
- func (*MigrateChannelResponse) ProtoMessage()
- func (m *MigrateChannelResponse) Reset()
- func (m *MigrateChannelResponse) String() string
- func (m *MigrateChannelResponse) XXX_DiscardUnknown()
- func (m *MigrateChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrateChannelResponse) XXX_Merge(src proto.Message)
- func (m *MigrateChannelResponse) XXX_Size() int
- func (m *MigrateChannelResponse) XXX_Unmarshal(b []byte) error
- type MsgQueueCallbackFunc
- type MultiServerClient
- type MultiServerServer
- type OneHistoricalPay
- func (*OneHistoricalPay) Descriptor() ([]byte, []int)
- func (m *OneHistoricalPay) GetAmt() string
- func (m *OneHistoricalPay) GetCreateTs() int64
- func (m *OneHistoricalPay) GetDst() string
- func (m *OneHistoricalPay) GetPayId() string
- func (m *OneHistoricalPay) GetSrc() string
- func (m *OneHistoricalPay) GetState() int64
- func (m *OneHistoricalPay) GetToken() string
- func (*OneHistoricalPay) ProtoMessage()
- func (m *OneHistoricalPay) Reset()
- func (m *OneHistoricalPay) String() string
- func (m *OneHistoricalPay) XXX_DiscardUnknown()
- func (m *OneHistoricalPay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OneHistoricalPay) XXX_Merge(src proto.Message)
- func (m *OneHistoricalPay) XXX_Size() int
- func (m *OneHistoricalPay) XXX_Unmarshal(b []byte) error
- type OpenChannelBy
- type OpenChannelRequest
- func (*OpenChannelRequest) Descriptor() ([]byte, []int)
- func (m *OpenChannelRequest) GetChannelInitializer() []byte
- func (m *OpenChannelRequest) GetOpenBy() OpenChannelBy
- func (m *OpenChannelRequest) GetOspToOsp() bool
- func (m *OpenChannelRequest) GetRequesterSig() []byte
- func (*OpenChannelRequest) ProtoMessage()
- func (m *OpenChannelRequest) Reset()
- func (m *OpenChannelRequest) String() string
- func (m *OpenChannelRequest) XXX_DiscardUnknown()
- func (m *OpenChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenChannelRequest) XXX_Merge(src proto.Message)
- func (m *OpenChannelRequest) XXX_Size() int
- func (m *OpenChannelRequest) XXX_Unmarshal(b []byte) error
- type OpenChannelResponse
- func (*OpenChannelResponse) Descriptor() ([]byte, []int)
- func (m *OpenChannelResponse) GetApproverSig() []byte
- func (m *OpenChannelResponse) GetChannelInitializer() []byte
- func (m *OpenChannelResponse) GetPaymentChannelId() []byte
- func (m *OpenChannelResponse) GetRequesterSig() []byte
- func (m *OpenChannelResponse) GetStatus() OpenChannelStatus
- func (*OpenChannelResponse) ProtoMessage()
- func (m *OpenChannelResponse) Reset()
- func (m *OpenChannelResponse) String() string
- func (m *OpenChannelResponse) XXX_DiscardUnknown()
- func (m *OpenChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenChannelResponse) XXX_Merge(src proto.Message)
- func (m *OpenChannelResponse) XXX_Size() int
- func (m *OpenChannelResponse) XXX_Unmarshal(b []byte) error
- type OpenChannelStatus
- type OspOpenChannelRequest
- func (*OspOpenChannelRequest) Descriptor() ([]byte, []int)
- func (m *OspOpenChannelRequest) GetPeerDepositAmtWei() string
- func (m *OspOpenChannelRequest) GetPeerEthAddress() []byte
- func (m *OspOpenChannelRequest) GetSelfDepositAmtWei() string
- func (m *OspOpenChannelRequest) GetTokenAddress() []byte
- func (m *OspOpenChannelRequest) GetTokenType() entity.TokenType
- func (*OspOpenChannelRequest) ProtoMessage()
- func (m *OspOpenChannelRequest) Reset()
- func (m *OspOpenChannelRequest) String() string
- func (m *OspOpenChannelRequest) XXX_DiscardUnknown()
- func (m *OspOpenChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OspOpenChannelRequest) XXX_Merge(src proto.Message)
- func (m *OspOpenChannelRequest) XXX_Size() int
- func (m *OspOpenChannelRequest) XXX_Unmarshal(b []byte) error
- type PayHop
- func (*PayHop) Descriptor() ([]byte, []int)
- func (m *PayHop) GetErr() *Error
- func (m *PayHop) GetNextHopAddr() []byte
- func (m *PayHop) GetPayId() []byte
- func (m *PayHop) GetPrevHopAddr() []byte
- func (*PayHop) ProtoMessage()
- func (m *PayHop) Reset()
- func (m *PayHop) String() string
- func (m *PayHop) XXX_DiscardUnknown()
- func (m *PayHop) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PayHop) XXX_Merge(src proto.Message)
- func (m *PayHop) XXX_Size() int
- func (m *PayHop) XXX_Unmarshal(b []byte) error
- type PayInAuthAck
- func (*PayInAuthAck) Descriptor() ([]byte, []int)
- func (m *PayInAuthAck) GetNote() *any.Any
- func (m *PayInAuthAck) GetPay() []byte
- func (m *PayInAuthAck) GetState() int64
- func (*PayInAuthAck) ProtoMessage()
- func (m *PayInAuthAck) Reset()
- func (m *PayInAuthAck) String() string
- func (m *PayInAuthAck) XXX_DiscardUnknown()
- func (m *PayInAuthAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PayInAuthAck) XXX_Merge(src proto.Message)
- func (m *PayInAuthAck) XXX_Size() int
- func (m *PayInAuthAck) XXX_Unmarshal(b []byte) error
- type PayPath
- func (*PayPath) Descriptor() ([]byte, []int)
- func (m *PayPath) GetHops() []*SignedPayHop
- func (*PayPath) ProtoMessage()
- func (m *PayPath) Reset()
- func (m *PayPath) String() string
- func (m *PayPath) XXX_DiscardUnknown()
- func (m *PayPath) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PayPath) XXX_Merge(src proto.Message)
- func (m *PayPath) XXX_Size() int
- func (m *PayPath) XXX_Unmarshal(b []byte) error
- type PaymentSettleProof
- func (*PaymentSettleProof) Descriptor() ([]byte, []int)
- func (m *PaymentSettleProof) GetSettledPays() []*SettledPayment
- func (m *PaymentSettleProof) GetVouchedCondPayResults() []*entity.VouchedCondPayResult
- func (*PaymentSettleProof) ProtoMessage()
- func (m *PaymentSettleProof) Reset()
- func (m *PaymentSettleProof) String() string
- func (m *PaymentSettleProof) XXX_DiscardUnknown()
- func (m *PaymentSettleProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PaymentSettleProof) XXX_Merge(src proto.Message)
- func (m *PaymentSettleProof) XXX_Size() int
- func (m *PaymentSettleProof) XXX_Unmarshal(b []byte) error
- type PaymentSettleReason
- type PaymentSettleRequest
- func (*PaymentSettleRequest) Descriptor() ([]byte, []int)
- func (m *PaymentSettleRequest) GetBaseSeq() uint64
- func (m *PaymentSettleRequest) GetSettledPays() []*SettledPayment
- func (m *PaymentSettleRequest) GetStateOnlyPeerFromSig() *SignedSimplexState
- func (*PaymentSettleRequest) ProtoMessage()
- func (m *PaymentSettleRequest) Reset()
- func (m *PaymentSettleRequest) String() string
- func (m *PaymentSettleRequest) XXX_DiscardUnknown()
- func (m *PaymentSettleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PaymentSettleRequest) XXX_Merge(src proto.Message)
- func (m *PaymentSettleRequest) XXX_Size() int
- func (m *PaymentSettleRequest) XXX_Unmarshal(b []byte) error
- type PaymentSettleResponse
- func (*PaymentSettleResponse) Descriptor() ([]byte, []int)
- func (m *PaymentSettleResponse) GetError() *Error
- func (m *PaymentSettleResponse) GetStateCosigned() *SignedSimplexState
- func (*PaymentSettleResponse) ProtoMessage()
- func (m *PaymentSettleResponse) Reset()
- func (m *PaymentSettleResponse) String() string
- func (m *PaymentSettleResponse) XXX_DiscardUnknown()
- func (m *PaymentSettleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PaymentSettleResponse) XXX_Merge(src proto.Message)
- func (m *PaymentSettleResponse) XXX_Size() int
- func (m *PaymentSettleResponse) XXX_Unmarshal(b []byte) error
- type PeerAddress
- func (*PeerAddress) Descriptor() ([]byte, []int)
- func (m *PeerAddress) GetAddress() string
- func (m *PeerAddress) GetTokenAddr() string
- func (*PeerAddress) ProtoMessage()
- func (m *PeerAddress) Reset()
- func (m *PeerAddress) String() string
- func (m *PeerAddress) XXX_DiscardUnknown()
- func (m *PeerAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerAddress) XXX_Merge(src proto.Message)
- func (m *PeerAddress) XXX_Size() int
- func (m *PeerAddress) XXX_Unmarshal(b []byte) error
- type PeerOsp
- func (*PeerOsp) Descriptor() ([]byte, []int)
- func (m *PeerOsp) GetOspAddress() string
- func (m *PeerOsp) GetTokenCidPairs() []*TokenCidPair
- func (m *PeerOsp) GetUpdateTs() uint64
- func (*PeerOsp) ProtoMessage()
- func (m *PeerOsp) Reset()
- func (m *PeerOsp) String() string
- func (m *PeerOsp) XXX_DiscardUnknown()
- func (m *PeerOsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerOsp) XXX_Merge(src proto.Message)
- func (m *PeerOsp) XXX_Size() int
- func (m *PeerOsp) XXX_Unmarshal(b []byte) error
- type PeerOspsResponse
- func (*PeerOspsResponse) Descriptor() ([]byte, []int)
- func (m *PeerOspsResponse) GetPeerOsps() []*PeerOsp
- func (*PeerOspsResponse) ProtoMessage()
- func (m *PeerOspsResponse) Reset()
- func (m *PeerOspsResponse) String() string
- func (m *PeerOspsResponse) XXX_DiscardUnknown()
- func (m *PeerOspsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerOspsResponse) XXX_Merge(src proto.Message)
- func (m *PeerOspsResponse) XXX_Size() int
- func (m *PeerOspsResponse) XXX_Unmarshal(b []byte) error
- type PeerStatus
- func (*PeerStatus) Descriptor() ([]byte, []int)
- func (m *PeerStatus) GetFreeBalance() string
- func (m *PeerStatus) GetJoinStatus() JoinCelerStatus
- func (*PeerStatus) ProtoMessage()
- func (m *PeerStatus) Reset()
- func (m *PeerStatus) String() string
- func (m *PeerStatus) XXX_DiscardUnknown()
- func (m *PeerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerStatus) XXX_Merge(src proto.Message)
- func (m *PeerStatus) XXX_Size() int
- func (m *PeerStatus) XXX_Unmarshal(b []byte) error
- type PickReply
- func (*PickReply) Descriptor() ([]byte, []int)
- func (m *PickReply) GetServer() string
- func (*PickReply) ProtoMessage()
- func (m *PickReply) Reset()
- func (m *PickReply) String() string
- func (m *PickReply) XXX_DiscardUnknown()
- func (m *PickReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PickReply) XXX_Merge(src proto.Message)
- func (m *PickReply) XXX_Size() int
- func (m *PickReply) XXX_Unmarshal(b []byte) error
- type PickReq
- func (*PickReq) Descriptor() ([]byte, []int)
- func (m *PickReq) GetClient() string
- func (*PickReq) ProtoMessage()
- func (m *PickReq) Reset()
- func (m *PickReq) String() string
- func (m *PickReq) XXX_DiscardUnknown()
- func (m *PickReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PickReq) XXX_Merge(src proto.Message)
- func (m *PickReq) XXX_Size() int
- func (m *PickReq) XXX_Unmarshal(b []byte) error
- type PingReply
- func (*PingReply) Descriptor() ([]byte, []int)
- func (m *PingReply) GetNumclients() uint32
- func (*PingReply) ProtoMessage()
- func (m *PingReply) Reset()
- func (m *PingReply) String() string
- func (m *PingReply) XXX_DiscardUnknown()
- func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PingReply) XXX_Merge(src proto.Message)
- func (m *PingReply) XXX_Size() int
- func (m *PingReply) XXX_Unmarshal(b []byte) error
- type PingReq
- func (*PingReq) Descriptor() ([]byte, []int)
- func (*PingReq) ProtoMessage()
- func (m *PingReq) Reset()
- func (m *PingReq) String() string
- func (m *PingReq) XXX_DiscardUnknown()
- func (m *PingReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PingReq) XXX_Merge(src proto.Message)
- func (m *PingReq) XXX_Size() int
- func (m *PingReq) XXX_Unmarshal(b []byte) error
- type QueryDelegationRequest
- func (*QueryDelegationRequest) Descriptor() ([]byte, []int)
- func (m *QueryDelegationRequest) GetDelegatee() []byte
- func (*QueryDelegationRequest) ProtoMessage()
- func (m *QueryDelegationRequest) Reset()
- func (m *QueryDelegationRequest) String() string
- func (m *QueryDelegationRequest) XXX_DiscardUnknown()
- func (m *QueryDelegationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDelegationRequest) XXX_Merge(src proto.Message)
- func (m *QueryDelegationRequest) XXX_Size() int
- func (m *QueryDelegationRequest) XXX_Unmarshal(b []byte) error
- type QueryDelegationResponse
- func (*QueryDelegationResponse) Descriptor() ([]byte, []int)
- func (m *QueryDelegationResponse) GetProof() *DelegationProof
- func (*QueryDelegationResponse) ProtoMessage()
- func (m *QueryDelegationResponse) Reset()
- func (m *QueryDelegationResponse) String() string
- func (m *QueryDelegationResponse) XXX_DiscardUnknown()
- func (m *QueryDelegationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDelegationResponse) XXX_Merge(src proto.Message)
- func (m *QueryDelegationResponse) XXX_Size() int
- func (m *QueryDelegationResponse) XXX_Unmarshal(b []byte) error
- type QueryDepositRequest
- func (*QueryDepositRequest) Descriptor() ([]byte, []int)
- func (m *QueryDepositRequest) GetDepositId() string
- func (*QueryDepositRequest) ProtoMessage()
- func (m *QueryDepositRequest) Reset()
- func (m *QueryDepositRequest) String() string
- func (m *QueryDepositRequest) XXX_DiscardUnknown()
- func (m *QueryDepositRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDepositRequest) XXX_Merge(src proto.Message)
- func (m *QueryDepositRequest) XXX_Size() int
- func (m *QueryDepositRequest) XXX_Unmarshal(b []byte) error
- type QueryDepositResponse
- func (*QueryDepositResponse) Descriptor() ([]byte, []int)
- func (m *QueryDepositResponse) GetDepositState() DepositState
- func (m *QueryDepositResponse) GetError() string
- func (*QueryDepositResponse) ProtoMessage()
- func (m *QueryDepositResponse) Reset()
- func (m *QueryDepositResponse) String() string
- func (m *QueryDepositResponse) XXX_DiscardUnknown()
- func (m *QueryDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryDepositResponse) XXX_Merge(src proto.Message)
- func (m *QueryDepositResponse) XXX_Size() int
- func (m *QueryDepositResponse) XXX_Unmarshal(b []byte) error
- type RegisterClientCallbackFunc
- type RegisterStreamRequest
- func (*RegisterStreamRequest) Descriptor() ([]byte, []int)
- func (m *RegisterStreamRequest) GetPeerEthAddress() []byte
- func (m *RegisterStreamRequest) GetPeerRpcAddress() string
- func (*RegisterStreamRequest) ProtoMessage()
- func (m *RegisterStreamRequest) Reset()
- func (m *RegisterStreamRequest) String() string
- func (m *RegisterStreamRequest) XXX_DiscardUnknown()
- func (m *RegisterStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterStreamRequest) XXX_Merge(src proto.Message)
- func (m *RegisterStreamRequest) XXX_Size() int
- func (m *RegisterStreamRequest) XXX_Unmarshal(b []byte) error
- type RevealSecret
- func (*RevealSecret) Descriptor() ([]byte, []int)
- func (m *RevealSecret) GetOriginalPayId() []byte
- func (m *RevealSecret) GetPayId() []byte
- func (m *RevealSecret) GetSecret() []byte
- func (*RevealSecret) ProtoMessage()
- func (m *RevealSecret) Reset()
- func (m *RevealSecret) String() string
- func (m *RevealSecret) XXX_DiscardUnknown()
- func (m *RevealSecret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RevealSecret) XXX_Merge(src proto.Message)
- func (m *RevealSecret) XXX_Size() int
- func (m *RevealSecret) XXX_Unmarshal(b []byte) error
- type RevealSecretAck
- func (*RevealSecretAck) Descriptor() ([]byte, []int)
- func (m *RevealSecretAck) GetOriginalPayId() []byte
- func (m *RevealSecretAck) GetPayDestSecretSig() []byte
- func (m *RevealSecretAck) GetPayId() []byte
- func (*RevealSecretAck) ProtoMessage()
- func (m *RevealSecretAck) Reset()
- func (m *RevealSecretAck) String() string
- func (m *RevealSecretAck) XXX_DiscardUnknown()
- func (m *RevealSecretAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RevealSecretAck) XXX_Merge(src proto.Message)
- func (m *RevealSecretAck) XXX_Size() int
- func (m *RevealSecretAck) XXX_Unmarshal(b []byte) error
- type RoutingRequest
- func (*RoutingRequest) Descriptor() ([]byte, []int)
- func (m *RoutingRequest) GetSender() string
- func (m *RoutingRequest) GetUpdates() []*SignedRoutingUpdate
- func (*RoutingRequest) ProtoMessage()
- func (m *RoutingRequest) Reset()
- func (m *RoutingRequest) String() string
- func (m *RoutingRequest) XXX_DiscardUnknown()
- func (m *RoutingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoutingRequest) XXX_Merge(src proto.Message)
- func (m *RoutingRequest) XXX_Size() int
- func (m *RoutingRequest) XXX_Unmarshal(b []byte) error
- type RoutingUpdate
- func (*RoutingUpdate) Descriptor() ([]byte, []int)
- func (m *RoutingUpdate) GetChannels() []*ChannelRoutingInfo
- func (m *RoutingUpdate) GetOrigin() string
- func (m *RoutingUpdate) GetProtoVersion() uint64
- func (m *RoutingUpdate) GetTs() uint64
- func (*RoutingUpdate) ProtoMessage()
- func (m *RoutingUpdate) Reset()
- func (m *RoutingUpdate) String() string
- func (m *RoutingUpdate) XXX_DiscardUnknown()
- func (m *RoutingUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoutingUpdate) XXX_Merge(src proto.Message)
- func (m *RoutingUpdate) XXX_Size() int
- func (m *RoutingUpdate) XXX_Unmarshal(b []byte) error
- type RpcClient
- type RpcServer
- type Rpc_CelerOneServer
- type Rpc_CelerStreamClient
- type Rpc_CelerStreamServer
- type SafeSendCelerStream
- type SendTokenRequest
- func (*SendTokenRequest) Descriptor() ([]byte, []int)
- func (m *SendTokenRequest) GetAmtWei() string
- func (m *SendTokenRequest) GetDstAddr() string
- func (m *SendTokenRequest) GetDstNetId() uint64
- func (m *SendTokenRequest) GetNote() *any.Any
- func (m *SendTokenRequest) GetTokenAddr() string
- func (*SendTokenRequest) ProtoMessage()
- func (m *SendTokenRequest) Reset()
- func (m *SendTokenRequest) String() string
- func (m *SendTokenRequest) XXX_DiscardUnknown()
- func (m *SendTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendTokenRequest) XXX_Merge(src proto.Message)
- func (m *SendTokenRequest) XXX_Size() int
- func (m *SendTokenRequest) XXX_Unmarshal(b []byte) error
- type SendTokenResponse
- func (*SendTokenResponse) Descriptor() ([]byte, []int)
- func (m *SendTokenResponse) GetError() string
- func (m *SendTokenResponse) GetPayId() string
- func (m *SendTokenResponse) GetStatus() int32
- func (*SendTokenResponse) ProtoMessage()
- func (m *SendTokenResponse) Reset()
- func (m *SendTokenResponse) String() string
- func (m *SendTokenResponse) XXX_DiscardUnknown()
- func (m *SendTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendTokenResponse) XXX_Merge(src proto.Message)
- func (m *SendTokenResponse) XXX_Size() int
- func (m *SendTokenResponse) XXX_Unmarshal(b []byte) error
- type SettledPayment
- func (*SettledPayment) Descriptor() ([]byte, []int)
- func (m *SettledPayment) GetAmount() []byte
- func (m *SettledPayment) GetOriginalPayId() []byte
- func (m *SettledPayment) GetPath() *PayPath
- func (m *SettledPayment) GetReason() PaymentSettleReason
- func (m *SettledPayment) GetSettledPayId() []byte
- func (*SettledPayment) ProtoMessage()
- func (m *SettledPayment) Reset()
- func (m *SettledPayment) String() string
- func (m *SettledPayment) XXX_DiscardUnknown()
- func (m *SettledPayment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SettledPayment) XXX_Merge(src proto.Message)
- func (m *SettledPayment) XXX_Size() int
- func (m *SettledPayment) XXX_Unmarshal(b []byte) error
- type SignedDuplexState
- func (*SignedDuplexState) Descriptor() ([]byte, []int)
- func (m *SignedDuplexState) GetSimplexStates() []*SignedSimplexState
- func (*SignedDuplexState) ProtoMessage()
- func (m *SignedDuplexState) Reset()
- func (m *SignedDuplexState) String() string
- func (m *SignedDuplexState) XXX_DiscardUnknown()
- func (m *SignedDuplexState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignedDuplexState) XXX_Merge(src proto.Message)
- func (m *SignedDuplexState) XXX_Size() int
- func (m *SignedDuplexState) XXX_Unmarshal(b []byte) error
- type SignedPayHop
- func (*SignedPayHop) Descriptor() ([]byte, []int)
- func (m *SignedPayHop) GetPayHopBytes() []byte
- func (m *SignedPayHop) GetSig() []byte
- func (*SignedPayHop) ProtoMessage()
- func (m *SignedPayHop) Reset()
- func (m *SignedPayHop) String() string
- func (m *SignedPayHop) XXX_DiscardUnknown()
- func (m *SignedPayHop) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignedPayHop) XXX_Merge(src proto.Message)
- func (m *SignedPayHop) XXX_Size() int
- func (m *SignedPayHop) XXX_Unmarshal(b []byte) error
- type SignedRoutingUpdate
- func (*SignedRoutingUpdate) Descriptor() ([]byte, []int)
- func (m *SignedRoutingUpdate) GetSig() []byte
- func (m *SignedRoutingUpdate) GetTtl() uint64
- func (m *SignedRoutingUpdate) GetUpdate() []byte
- func (*SignedRoutingUpdate) ProtoMessage()
- func (m *SignedRoutingUpdate) Reset()
- func (m *SignedRoutingUpdate) String() string
- func (m *SignedRoutingUpdate) XXX_DiscardUnknown()
- func (m *SignedRoutingUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignedRoutingUpdate) XXX_Merge(src proto.Message)
- func (m *SignedRoutingUpdate) XXX_Size() int
- func (m *SignedRoutingUpdate) XXX_Unmarshal(b []byte) error
- type SignedSimplexState
- func (*SignedSimplexState) Descriptor() ([]byte, []int)
- func (m *SignedSimplexState) GetSigOfPeerFrom() []byte
- func (m *SignedSimplexState) GetSigOfPeerTo() []byte
- func (m *SignedSimplexState) GetSimplexState() []byte
- func (*SignedSimplexState) ProtoMessage()
- func (m *SignedSimplexState) Reset()
- func (m *SignedSimplexState) String() string
- func (m *SignedSimplexState) XXX_DiscardUnknown()
- func (m *SignedSimplexState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignedSimplexState) XXX_Merge(src proto.Message)
- func (m *SignedSimplexState) XXX_Size() int
- func (m *SignedSimplexState) XXX_Unmarshal(b []byte) error
- type TokenCidPair
- func (*TokenCidPair) Descriptor() ([]byte, []int)
- func (m *TokenCidPair) GetCid() string
- func (m *TokenCidPair) GetTokenAddress() string
- func (*TokenCidPair) ProtoMessage()
- func (m *TokenCidPair) Reset()
- func (m *TokenCidPair) String() string
- func (m *TokenCidPair) XXX_DiscardUnknown()
- func (m *TokenCidPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TokenCidPair) XXX_Merge(src proto.Message)
- func (m *TokenCidPair) XXX_Size() int
- func (m *TokenCidPair) XXX_Unmarshal(b []byte) error
- type UnimplementedAdminServer
- func (*UnimplementedAdminServer) BuildRoutingTable(ctx context.Context, req *BuildRoutingTableRequest) (*empty.Empty, error)
- func (*UnimplementedAdminServer) ClearExpiredPaysWithPeerOsps(ctx context.Context, req *ClearExpiredPaysRequest) (*empty.Empty, error)
- func (*UnimplementedAdminServer) ConfirmOnChainResolvedPaysWithPeerOsps(ctx context.Context, req *ConfirmOnChainResolvedPaysRequest) (*empty.Empty, error)
- func (*UnimplementedAdminServer) CooperativeSettle(ctx context.Context, req *ChannelOpRequest) (*ChannelOpResponse, error)
- func (*UnimplementedAdminServer) CooperativeWithdraw(ctx context.Context, req *ChannelOpRequest) (*ChannelOpResponse, error)
- func (*UnimplementedAdminServer) Deposit(ctx context.Context, req *DepositRequest) (*DepositResponse, error)
- func (*UnimplementedAdminServer) GetPeerOsps(ctx context.Context, req *empty.Empty) (*PeerOspsResponse, error)
- func (*UnimplementedAdminServer) OspOpenChannel(ctx context.Context, req *OspOpenChannelRequest) (*empty.Empty, error)
- func (*UnimplementedAdminServer) QueryDeposit(ctx context.Context, req *QueryDepositRequest) (*QueryDepositResponse, error)
- func (*UnimplementedAdminServer) RecvBcastRoutingInfo(ctx context.Context, req *RoutingRequest) (*empty.Empty, error)
- func (*UnimplementedAdminServer) RegisterStream(ctx context.Context, req *RegisterStreamRequest) (*empty.Empty, error)
- func (*UnimplementedAdminServer) SendToken(ctx context.Context, req *SendTokenRequest) (*SendTokenResponse, error)
- type UnimplementedMultiServerServer
- func (*UnimplementedMultiServerServer) BcastRoutingInfo(ctx context.Context, req *BcastRoutingRequest) (*BcastRoutingReply, error)
- func (*UnimplementedMultiServerServer) FwdMsg(ctx context.Context, req *FwdReq) (*FwdReply, error)
- func (*UnimplementedMultiServerServer) PickServer(ctx context.Context, req *PickReq) (*PickReply, error)
- func (*UnimplementedMultiServerServer) Ping(ctx context.Context, req *PingReq) (*PingReply, error)
- type UnimplementedRpcServer
- func (*UnimplementedRpcServer) CelerGetPeerStatus(ctx context.Context, req *PeerAddress) (*PeerStatus, error)
- func (*UnimplementedRpcServer) CelerMigrateChannel(ctx context.Context, req *MigrateChannelRequest) (*MigrateChannelResponse, error)
- func (*UnimplementedRpcServer) CelerOpenChannel(ctx context.Context, req *OpenChannelRequest) (*OpenChannelResponse, error)
- func (*UnimplementedRpcServer) CelerOpenTcbChannel(ctx context.Context, req *OpenChannelRequest) (*OpenChannelResponse, error)
- func (*UnimplementedRpcServer) CelerStream(srv Rpc_CelerStreamServer) error
- func (*UnimplementedRpcServer) GetPayHistory(ctx context.Context, req *GetPayHistoryRequest) (*GetPayHistoryResponse, error)
- func (*UnimplementedRpcServer) QueryDelegation(ctx context.Context, req *QueryDelegationRequest) (*QueryDelegationResponse, error)
- func (*UnimplementedRpcServer) RequestDelegation(ctx context.Context, req *DelegationRequest) (*DelegationResponse, error)
Constants ¶
This section is empty.
Variables ¶
var DepositState_name = map[int32]string{
0: "Deposit_NOT_FOUND",
1: "Deposit_QUEUED",
2: "Deposit_SUBMITTED",
3: "Deposit_SUCCEEDED",
4: "Deposit_FAILED",
}
var DepositState_value = map[string]int32{
"Deposit_NOT_FOUND": 0,
"Deposit_QUEUED": 1,
"Deposit_SUBMITTED": 2,
"Deposit_SUCCEEDED": 3,
"Deposit_FAILED": 4,
}
var ErrCode_name = map[int32]string{
0: "OK",
1: "UNAUTHORIZED",
2: "INVALID_SIG",
3: "INCORRECT_CLOCK",
4: "WRONG_PEER",
5: "INVALID_SEQ_NUM",
6: "PAY_ROUTE_LOOP",
7: "NO_ROUTE_TO_DST",
8: "NOT_ENOUGH_BALANCE",
9: "PEER_NOT_ONLINE",
10: "MISC_ERROR",
}
var ErrCode_value = map[string]int32{
"OK": 0,
"UNAUTHORIZED": 1,
"INVALID_SIG": 2,
"INCORRECT_CLOCK": 3,
"WRONG_PEER": 4,
"INVALID_SEQ_NUM": 5,
"PAY_ROUTE_LOOP": 6,
"NO_ROUTE_TO_DST": 7,
"NOT_ENOUGH_BALANCE": 8,
"PEER_NOT_ONLINE": 9,
"MISC_ERROR": 10,
}
var JoinCelerStatus_name = map[int32]string{
0: "NOT_JOIN",
1: "LOCAL",
2: "REMOTE",
}
var JoinCelerStatus_value = map[string]int32{
"NOT_JOIN": 0,
"LOCAL": 1,
"REMOTE": 2,
}
var OpenChannelBy_name = map[int32]string{
0: "UNDEFINED_OPEN_BY",
1: "OPEN_CHANNEL_PROPOSER",
2: "OPEN_CHANNEL_APPROVER",
}
var OpenChannelBy_value = map[string]int32{
"UNDEFINED_OPEN_BY": 0,
"OPEN_CHANNEL_PROPOSER": 1,
"OPEN_CHANNEL_APPROVER": 2,
}
var OpenChannelStatus_name = map[int32]string{
0: "UNDEFINED_OPEN_CHANNEL_STATUS",
1: "OPEN_CHANNEL_APPROVED",
2: "OPEN_CHANNEL_TX_SUBMITTED",
3: "OPEN_CHANNEL_TCB_OPENED",
}
var OpenChannelStatus_value = map[string]int32{
"UNDEFINED_OPEN_CHANNEL_STATUS": 0,
"OPEN_CHANNEL_APPROVED": 1,
"OPEN_CHANNEL_TX_SUBMITTED": 2,
"OPEN_CHANNEL_TCB_OPENED": 3,
}
var PaymentSettleReason_name = map[int32]string{
0: "NONE",
1: "PAY_EXPIRED",
2: "PAY_REJECTED",
3: "PAY_RESOLVED_ONCHAIN",
4: "PAY_PAID_MAX",
5: "PAY_DEST_UNREACHABLE",
6: "PAY_VOUCHED",
}
var PaymentSettleReason_value = map[string]int32{
"NONE": 0,
"PAY_EXPIRED": 1,
"PAY_REJECTED": 2,
"PAY_RESOLVED_ONCHAIN": 3,
"PAY_PAID_MAX": 4,
"PAY_DEST_UNREACHABLE": 5,
"PAY_VOUCHED": 6,
}
Functions ¶
func RegisterAdminHandler ¶
RegisterAdminHandler registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAdminHandlerClient ¶
func RegisterAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdminClient) error
RegisterAdminHandlerClient registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AdminClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AdminClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AdminClient" to call the correct interceptors.
func RegisterAdminHandlerFromEndpoint ¶
func RegisterAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAdminHandlerFromEndpoint is same as RegisterAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAdminServer ¶
func RegisterAdminServer(s *grpc.Server, srv AdminServer)
func RegisterMultiServerServer ¶
func RegisterMultiServerServer(s *grpc.Server, srv MultiServerServer)
func RegisterRpcServer ¶
Types ¶
type AdminClient ¶
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) (*empty.Empty, error)
// ClearExpiredPaysWithPeerOsps instructs Osp to clear expired pays between itself and connected osps.
ClearExpiredPaysWithPeerOsps(ctx context.Context, in *ClearExpiredPaysRequest, opts ...grpc.CallOption) (*empty.Empty, error)
// BuildRoutingTable instructs Osp to build routing table.
BuildRoutingTable(ctx context.Context, in *BuildRoutingTableRequest, opts ...grpc.CallOption) (*empty.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) (*empty.Empty, error)
// GetPeerOsps returns info of all peer osps.
GetPeerOsps(ctx context.Context, in *empty.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) (*empty.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) (*empty.Empty, error)
CooperativeWithdraw(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)
CooperativeSettle(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)
}
AdminClient is the client API for Admin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAdminClient ¶
func NewAdminClient(cc *grpc.ClientConn) AdminClient
type AdminServer ¶
type AdminServer interface {
// ConfirmOnChainResolvedPaysWithPeerOsps instructs Osp to confirm on-chain resolved pays between itself and connected osps.
ConfirmOnChainResolvedPaysWithPeerOsps(context.Context, *ConfirmOnChainResolvedPaysRequest) (*empty.Empty, error)
// ClearExpiredPaysWithPeerOsps instructs Osp to clear expired pays between itself and connected osps.
ClearExpiredPaysWithPeerOsps(context.Context, *ClearExpiredPaysRequest) (*empty.Empty, error)
// BuildRoutingTable instructs Osp to build routing table.
BuildRoutingTable(context.Context, *BuildRoutingTableRequest) (*empty.Empty, error)
// RecvBcastRoutingInfo gives the OSP (listener & router) the incoming
// broadcast routing information (OSP server forwarding to the listener).
RecvBcastRoutingInfo(context.Context, *RoutingRequest) (*empty.Empty, error)
// GetPeerOsps returns info of all peer osps.
GetPeerOsps(context.Context, *empty.Empty) (*PeerOspsResponse, error)
// OspOpenChannel instructs Osp to open a state channel with a peer described in request.
OspOpenChannel(context.Context, *OspOpenChannelRequest) (*empty.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) (*empty.Empty, error)
CooperativeWithdraw(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)
CooperativeSettle(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)
}
AdminServer is the server API for Admin service.
type AuthAck ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AuthAck) Descriptor ¶
func (*AuthAck) GetStartMid ¶
func (*AuthAck) GetSyncChannels ¶
func (m *AuthAck) GetSyncChannels() []*ChannelInAuth
func (*AuthAck) ProtoMessage ¶
func (*AuthAck) ProtoMessage()
func (*AuthAck) XXX_DiscardUnknown ¶
func (m *AuthAck) XXX_DiscardUnknown()
func (*AuthAck) XXX_Marshal ¶
func (*AuthAck) XXX_Unmarshal ¶
type AuthReq ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
prove to peer I own this addr
func (*AuthReq) Descriptor ¶
func (*AuthReq) GetExpectPeer ¶
func (*AuthReq) GetMutualAuth ¶
func (*AuthReq) GetOpenedChannels ¶
func (m *AuthReq) GetOpenedChannels() []*ChannelSummary
func (*AuthReq) GetProtocolVersion ¶
func (*AuthReq) GetTimestamp ¶
func (*AuthReq) ProtoMessage ¶
func (*AuthReq) ProtoMessage()
func (*AuthReq) XXX_DiscardUnknown ¶
func (m *AuthReq) XXX_DiscardUnknown()
func (*AuthReq) XXX_Marshal ¶
func (*AuthReq) XXX_Unmarshal ¶
type BcastRoutingReply ¶
type BcastRoutingReply struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 1
func (*BcastRoutingReply) Descriptor ¶
func (*BcastRoutingReply) Descriptor() ([]byte, []int)
func (*BcastRoutingReply) ProtoMessage ¶
func (*BcastRoutingReply) ProtoMessage()
func (*BcastRoutingReply) Reset ¶
func (m *BcastRoutingReply) Reset()
func (*BcastRoutingReply) String ¶
func (m *BcastRoutingReply) String() string
func (*BcastRoutingReply) XXX_DiscardUnknown ¶
func (m *BcastRoutingReply) XXX_DiscardUnknown()
func (*BcastRoutingReply) XXX_Marshal ¶
func (m *BcastRoutingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BcastRoutingReply) XXX_Merge ¶
func (m *BcastRoutingReply) XXX_Merge(src proto.Message)
func (*BcastRoutingReply) XXX_Size ¶
func (m *BcastRoutingReply) XXX_Size() int
func (*BcastRoutingReply) XXX_Unmarshal ¶
func (m *BcastRoutingReply) XXX_Unmarshal(b []byte) error
type BcastRoutingRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 3
func (*BcastRoutingRequest) Descriptor ¶
func (*BcastRoutingRequest) Descriptor() ([]byte, []int)
func (*BcastRoutingRequest) GetOsps ¶
func (m *BcastRoutingRequest) GetOsps() []string
func (*BcastRoutingRequest) GetReq ¶
func (m *BcastRoutingRequest) GetReq() *RoutingRequest
func (*BcastRoutingRequest) ProtoMessage ¶
func (*BcastRoutingRequest) ProtoMessage()
func (*BcastRoutingRequest) Reset ¶
func (m *BcastRoutingRequest) Reset()
func (*BcastRoutingRequest) String ¶
func (m *BcastRoutingRequest) String() string
func (*BcastRoutingRequest) XXX_DiscardUnknown ¶
func (m *BcastRoutingRequest) XXX_DiscardUnknown()
func (*BcastRoutingRequest) XXX_Marshal ¶
func (m *BcastRoutingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BcastRoutingRequest) XXX_Merge ¶
func (m *BcastRoutingRequest) XXX_Merge(src proto.Message)
func (*BcastRoutingRequest) XXX_Size ¶
func (m *BcastRoutingRequest) XXX_Size() int
func (*BcastRoutingRequest) XXX_Unmarshal ¶
func (m *BcastRoutingRequest) XXX_Unmarshal(b []byte) error
type BuildRoutingTableRequest ¶
type BuildRoutingTableRequest struct {
TokenAddress []byte `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Admin request to build routing table. Next tag: 2
func (*BuildRoutingTableRequest) Descriptor ¶
func (*BuildRoutingTableRequest) Descriptor() ([]byte, []int)
func (*BuildRoutingTableRequest) GetTokenAddress ¶
func (m *BuildRoutingTableRequest) GetTokenAddress() []byte
func (*BuildRoutingTableRequest) ProtoMessage ¶
func (*BuildRoutingTableRequest) ProtoMessage()
func (*BuildRoutingTableRequest) Reset ¶
func (m *BuildRoutingTableRequest) Reset()
func (*BuildRoutingTableRequest) String ¶
func (m *BuildRoutingTableRequest) String() string
func (*BuildRoutingTableRequest) XXX_DiscardUnknown ¶
func (m *BuildRoutingTableRequest) XXX_DiscardUnknown()
func (*BuildRoutingTableRequest) XXX_Marshal ¶
func (m *BuildRoutingTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BuildRoutingTableRequest) XXX_Merge ¶
func (m *BuildRoutingTableRequest) XXX_Merge(src proto.Message)
func (*BuildRoutingTableRequest) XXX_Size ¶
func (m *BuildRoutingTableRequest) XXX_Size() int
func (*BuildRoutingTableRequest) XXX_Unmarshal ¶
func (m *BuildRoutingTableRequest) XXX_Unmarshal(b []byte) error
type CelerMsg ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Envelope msg for unified bidi-streaming
func (*CelerMsg) Descriptor ¶
func (*CelerMsg) GetAuthAck ¶
func (*CelerMsg) GetAuthReq ¶
func (*CelerMsg) GetCondPayReceipt ¶
func (m *CelerMsg) GetCondPayReceipt() *CondPayReceipt
func (*CelerMsg) GetCondPayRequest ¶
func (m *CelerMsg) GetCondPayRequest() *CondPayRequest
func (*CelerMsg) GetCondPayResponse ¶
func (m *CelerMsg) GetCondPayResponse() *CondPayResponse
func (*CelerMsg) GetMessage ¶
func (m *CelerMsg) GetMessage() isCelerMsg_Message
func (*CelerMsg) GetPayResultVouchRequest ¶
func (m *CelerMsg) GetPayResultVouchRequest() *entity.VouchedCondPayResult
func (*CelerMsg) GetPayResultVouchResponse ¶
func (m *CelerMsg) GetPayResultVouchResponse() *entity.VouchedCondPayResult
func (*CelerMsg) GetPaymentSettleProof ¶
func (m *CelerMsg) GetPaymentSettleProof() *PaymentSettleProof
func (*CelerMsg) GetPaymentSettleRequest ¶
func (m *CelerMsg) GetPaymentSettleRequest() *PaymentSettleRequest
func (*CelerMsg) GetPaymentSettleResponse ¶
func (m *CelerMsg) GetPaymentSettleResponse() *PaymentSettleResponse
func (*CelerMsg) GetRevealSecret ¶
func (m *CelerMsg) GetRevealSecret() *RevealSecret
func (*CelerMsg) GetRevealSecretAck ¶
func (m *CelerMsg) GetRevealSecretAck() *RevealSecretAck
func (*CelerMsg) GetRoutingRequest ¶
func (m *CelerMsg) GetRoutingRequest() *RoutingRequest
func (*CelerMsg) GetWithdrawRequest ¶
func (m *CelerMsg) GetWithdrawRequest() *CooperativeWithdrawRequest
func (*CelerMsg) GetWithdrawResponse ¶
func (m *CelerMsg) GetWithdrawResponse() *CooperativeWithdrawResponse
func (*CelerMsg) ProtoMessage ¶
func (*CelerMsg) ProtoMessage()
func (*CelerMsg) XXX_DiscardUnknown ¶
func (m *CelerMsg) XXX_DiscardUnknown()
func (*CelerMsg) XXX_Marshal ¶
func (*CelerMsg) XXX_OneofWrappers ¶
func (*CelerMsg) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*CelerMsg) XXX_Unmarshal ¶
type CelerMsg_AuthAck ¶
type CelerMsg_AuthAck struct {
AuthAck *AuthAck `protobuf:"bytes,8,opt,name=auth_ack,json=authAck,proto3,oneof"`
}
type CelerMsg_AuthReq ¶
type CelerMsg_AuthReq struct {
AuthReq *AuthReq `protobuf:"bytes,7,opt,name=auth_req,json=authReq,proto3,oneof"`
}
type CelerMsg_CondPayReceipt ¶
type CelerMsg_CondPayReceipt struct {
CondPayReceipt *CondPayReceipt `protobuf:"bytes,31,opt,name=cond_pay_receipt,json=condPayReceipt,proto3,oneof"`
}
type CelerMsg_CondPayRequest ¶
type CelerMsg_CondPayRequest struct {
CondPayRequest *CondPayRequest `protobuf:"bytes,9,opt,name=cond_pay_request,json=condPayRequest,proto3,oneof"`
}
type CelerMsg_CondPayResponse ¶
type CelerMsg_CondPayResponse struct {
CondPayResponse *CondPayResponse `protobuf:"bytes,10,opt,name=cond_pay_response,json=condPayResponse,proto3,oneof"`
}
type CelerMsg_Error ¶
type CelerMsg_Error struct {
Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}
type CelerMsg_PayResultVouchRequest ¶
type CelerMsg_PayResultVouchRequest struct {
PayResultVouchRequest *entity.VouchedCondPayResult `protobuf:"bytes,34,opt,name=pay_result_vouch_request,json=payResultVouchRequest,proto3,oneof"`
}
type CelerMsg_PayResultVouchResponse ¶
type CelerMsg_PayResultVouchResponse struct {
PayResultVouchResponse *entity.VouchedCondPayResult `protobuf:"bytes,35,opt,name=pay_result_vouch_response,json=payResultVouchResponse,proto3,oneof"`
}
type CelerMsg_PaymentSettleProof ¶
type CelerMsg_PaymentSettleProof struct {
PaymentSettleProof *PaymentSettleProof `protobuf:"bytes,11,opt,name=payment_settle_proof,json=paymentSettleProof,proto3,oneof"`
}
type CelerMsg_PaymentSettleRequest ¶
type CelerMsg_PaymentSettleRequest struct {
PaymentSettleRequest *PaymentSettleRequest `protobuf:"bytes,12,opt,name=payment_settle_request,json=paymentSettleRequest,proto3,oneof"`
}
type CelerMsg_PaymentSettleResponse ¶
type CelerMsg_PaymentSettleResponse struct {
PaymentSettleResponse *PaymentSettleResponse `protobuf:"bytes,13,opt,name=payment_settle_response,json=paymentSettleResponse,proto3,oneof"`
}
type CelerMsg_RevealSecret ¶
type CelerMsg_RevealSecret struct {
RevealSecret *RevealSecret `protobuf:"bytes,32,opt,name=reveal_secret,json=revealSecret,proto3,oneof"`
}
type CelerMsg_RevealSecretAck ¶
type CelerMsg_RevealSecretAck struct {
RevealSecretAck *RevealSecretAck `protobuf:"bytes,33,opt,name=reveal_secret_ack,json=revealSecretAck,proto3,oneof"`
}
type CelerMsg_RoutingRequest ¶
type CelerMsg_RoutingRequest struct {
RoutingRequest *RoutingRequest `protobuf:"bytes,16,opt,name=routing_request,json=routingRequest,proto3,oneof"`
}
type CelerMsg_WithdrawRequest ¶
type CelerMsg_WithdrawRequest struct {
WithdrawRequest *CooperativeWithdrawRequest `protobuf:"bytes,14,opt,name=withdraw_request,json=withdrawRequest,proto3,oneof"`
}
type CelerMsg_WithdrawResponse ¶
type CelerMsg_WithdrawResponse struct {
WithdrawResponse *CooperativeWithdrawResponse `protobuf:"bytes,15,opt,name=withdraw_response,json=withdrawResponse,proto3,oneof"`
}
type ChannelInAuth ¶
type ChannelInAuth struct {
Cid []byte `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
// Channel state defined in agent-pay 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
In AuthAck if need to sync channels Next tag: 9
func (*ChannelInAuth) Descriptor ¶
func (*ChannelInAuth) Descriptor() ([]byte, []int)
func (*ChannelInAuth) GetAuthackPays ¶
func (m *ChannelInAuth) GetAuthackPays() []*PayInAuthAck
func (*ChannelInAuth) GetAuthackSimplex ¶
func (m *ChannelInAuth) GetAuthackSimplex() *SignedSimplexState
func (*ChannelInAuth) GetAuthreqPays ¶
func (m *ChannelInAuth) GetAuthreqPays() []*PayInAuthAck
func (*ChannelInAuth) GetAuthreqSimplex ¶
func (m *ChannelInAuth) GetAuthreqSimplex() *SignedSimplexState
func (*ChannelInAuth) GetChannelState ¶
func (m *ChannelInAuth) GetChannelState() int64
func (*ChannelInAuth) GetCid ¶
func (m *ChannelInAuth) GetCid() []byte
func (*ChannelInAuth) GetLedgerAddr ¶
func (m *ChannelInAuth) GetLedgerAddr() []byte
func (*ChannelInAuth) GetOpenChannelResponse ¶
func (m *ChannelInAuth) GetOpenChannelResponse() *OpenChannelResponse
func (*ChannelInAuth) ProtoMessage ¶
func (*ChannelInAuth) ProtoMessage()
func (*ChannelInAuth) Reset ¶
func (m *ChannelInAuth) Reset()
func (*ChannelInAuth) String ¶
func (m *ChannelInAuth) String() string
func (*ChannelInAuth) XXX_DiscardUnknown ¶
func (m *ChannelInAuth) XXX_DiscardUnknown()
func (*ChannelInAuth) XXX_Marshal ¶
func (m *ChannelInAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelInAuth) XXX_Merge ¶
func (m *ChannelInAuth) XXX_Merge(src proto.Message)
func (*ChannelInAuth) XXX_Size ¶
func (m *ChannelInAuth) XXX_Size() int
func (*ChannelInAuth) XXX_Unmarshal ¶
func (m *ChannelInAuth) XXX_Unmarshal(b []byte) error
type ChannelOpRequest ¶
type ChannelOpRequest struct {
Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
Wei string `protobuf:"bytes,2,opt,name=wei,proto3" json:"wei,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
cooperative withdraw/settle channel request
func (*ChannelOpRequest) Descriptor ¶
func (*ChannelOpRequest) Descriptor() ([]byte, []int)
func (*ChannelOpRequest) GetCid ¶
func (m *ChannelOpRequest) GetCid() string
func (*ChannelOpRequest) GetWei ¶
func (m *ChannelOpRequest) GetWei() string
func (*ChannelOpRequest) ProtoMessage ¶
func (*ChannelOpRequest) ProtoMessage()
func (*ChannelOpRequest) Reset ¶
func (m *ChannelOpRequest) Reset()
func (*ChannelOpRequest) String ¶
func (m *ChannelOpRequest) String() string
func (*ChannelOpRequest) XXX_DiscardUnknown ¶
func (m *ChannelOpRequest) XXX_DiscardUnknown()
func (*ChannelOpRequest) XXX_Marshal ¶
func (m *ChannelOpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelOpRequest) XXX_Merge ¶
func (m *ChannelOpRequest) XXX_Merge(src proto.Message)
func (*ChannelOpRequest) XXX_Size ¶
func (m *ChannelOpRequest) XXX_Size() int
func (*ChannelOpRequest) XXX_Unmarshal ¶
func (m *ChannelOpRequest) XXX_Unmarshal(b []byte) error
type ChannelOpResponse ¶
type ChannelOpResponse 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ChannelOpResponse) Descriptor ¶
func (*ChannelOpResponse) Descriptor() ([]byte, []int)
func (*ChannelOpResponse) GetError ¶
func (m *ChannelOpResponse) GetError() string
func (*ChannelOpResponse) GetStatus ¶
func (m *ChannelOpResponse) GetStatus() int32
func (*ChannelOpResponse) ProtoMessage ¶
func (*ChannelOpResponse) ProtoMessage()
func (*ChannelOpResponse) Reset ¶
func (m *ChannelOpResponse) Reset()
func (*ChannelOpResponse) String ¶
func (m *ChannelOpResponse) String() string
func (*ChannelOpResponse) XXX_DiscardUnknown ¶
func (m *ChannelOpResponse) XXX_DiscardUnknown()
func (*ChannelOpResponse) XXX_Marshal ¶
func (m *ChannelOpResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelOpResponse) XXX_Merge ¶
func (m *ChannelOpResponse) XXX_Merge(src proto.Message)
func (*ChannelOpResponse) XXX_Size ¶
func (m *ChannelOpResponse) XXX_Size() int
func (*ChannelOpResponse) XXX_Unmarshal ¶
func (m *ChannelOpResponse) XXX_Unmarshal(b []byte) error
type ChannelRoutingInfo ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 3
func (*ChannelRoutingInfo) Descriptor ¶
func (*ChannelRoutingInfo) Descriptor() ([]byte, []int)
func (*ChannelRoutingInfo) GetBalance ¶
func (m *ChannelRoutingInfo) GetBalance() string
func (*ChannelRoutingInfo) GetCid ¶
func (m *ChannelRoutingInfo) GetCid() string
func (*ChannelRoutingInfo) ProtoMessage ¶
func (*ChannelRoutingInfo) ProtoMessage()
func (*ChannelRoutingInfo) Reset ¶
func (m *ChannelRoutingInfo) Reset()
func (*ChannelRoutingInfo) String ¶
func (m *ChannelRoutingInfo) String() string
func (*ChannelRoutingInfo) XXX_DiscardUnknown ¶
func (m *ChannelRoutingInfo) XXX_DiscardUnknown()
func (*ChannelRoutingInfo) XXX_Marshal ¶
func (m *ChannelRoutingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelRoutingInfo) XXX_Merge ¶
func (m *ChannelRoutingInfo) XXX_Merge(src proto.Message)
func (*ChannelRoutingInfo) XXX_Size ¶
func (m *ChannelRoutingInfo) XXX_Size() int
func (*ChannelRoutingInfo) XXX_Unmarshal ¶
func (m *ChannelRoutingInfo) XXX_Unmarshal(b []byte) error
type ChannelSummary ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
For Auth handshake and auto recovery note with only seq num we lost the ability to sync if client side has higher value. but it's ok because after authreq/ack, osp msg queue will re-send un-acked msgs Next tag: 5
func (*ChannelSummary) Descriptor ¶
func (*ChannelSummary) Descriptor() ([]byte, []int)
func (*ChannelSummary) GetChannelId ¶
func (m *ChannelSummary) GetChannelId() []byte
func (*ChannelSummary) GetLedgerAddr ¶
func (m *ChannelSummary) GetLedgerAddr() []byte
func (*ChannelSummary) GetMySeqNum ¶
func (m *ChannelSummary) GetMySeqNum() uint64
func (*ChannelSummary) GetPeerSeqNum ¶
func (m *ChannelSummary) GetPeerSeqNum() uint64
func (*ChannelSummary) ProtoMessage ¶
func (*ChannelSummary) ProtoMessage()
func (*ChannelSummary) Reset ¶
func (m *ChannelSummary) Reset()
func (*ChannelSummary) String ¶
func (m *ChannelSummary) String() string
func (*ChannelSummary) XXX_DiscardUnknown ¶
func (m *ChannelSummary) XXX_DiscardUnknown()
func (*ChannelSummary) XXX_Marshal ¶
func (m *ChannelSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelSummary) XXX_Merge ¶
func (m *ChannelSummary) XXX_Merge(src proto.Message)
func (*ChannelSummary) XXX_Size ¶
func (m *ChannelSummary) XXX_Size() int
func (*ChannelSummary) XXX_Unmarshal ¶
func (m *ChannelSummary) XXX_Unmarshal(b []byte) error
type ClearExpiredPaysRequest ¶
type ClearExpiredPaysRequest struct {
TokenAddress []byte `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Admin request to clear expired pays. Next tag: 2
func (*ClearExpiredPaysRequest) Descriptor ¶
func (*ClearExpiredPaysRequest) Descriptor() ([]byte, []int)
func (*ClearExpiredPaysRequest) GetTokenAddress ¶
func (m *ClearExpiredPaysRequest) GetTokenAddress() []byte
func (*ClearExpiredPaysRequest) ProtoMessage ¶
func (*ClearExpiredPaysRequest) ProtoMessage()
func (*ClearExpiredPaysRequest) Reset ¶
func (m *ClearExpiredPaysRequest) Reset()
func (*ClearExpiredPaysRequest) String ¶
func (m *ClearExpiredPaysRequest) String() string
func (*ClearExpiredPaysRequest) XXX_DiscardUnknown ¶
func (m *ClearExpiredPaysRequest) XXX_DiscardUnknown()
func (*ClearExpiredPaysRequest) XXX_Marshal ¶
func (m *ClearExpiredPaysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClearExpiredPaysRequest) XXX_Merge ¶
func (m *ClearExpiredPaysRequest) XXX_Merge(src proto.Message)
func (*ClearExpiredPaysRequest) XXX_Size ¶
func (m *ClearExpiredPaysRequest) XXX_Size() int
func (*ClearExpiredPaysRequest) XXX_Unmarshal ¶
func (m *ClearExpiredPaysRequest) XXX_Unmarshal(b []byte) error
type CondPayReceipt ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 5
func (*CondPayReceipt) Descriptor ¶
func (*CondPayReceipt) Descriptor() ([]byte, []int)
func (*CondPayReceipt) GetDelegationProof ¶
func (m *CondPayReceipt) GetDelegationProof() *DelegationProof
func (*CondPayReceipt) GetOriginalPayId ¶
func (m *CondPayReceipt) GetOriginalPayId() []byte
func (*CondPayReceipt) GetPayDelegatorSig ¶
func (m *CondPayReceipt) GetPayDelegatorSig() []byte
func (*CondPayReceipt) GetPayDestSig ¶
func (m *CondPayReceipt) GetPayDestSig() []byte
func (*CondPayReceipt) GetPayId ¶
func (m *CondPayReceipt) GetPayId() []byte
func (*CondPayReceipt) ProtoMessage ¶
func (*CondPayReceipt) ProtoMessage()
func (*CondPayReceipt) Reset ¶
func (m *CondPayReceipt) Reset()
func (*CondPayReceipt) String ¶
func (m *CondPayReceipt) String() string
func (*CondPayReceipt) XXX_DiscardUnknown ¶
func (m *CondPayReceipt) XXX_DiscardUnknown()
func (*CondPayReceipt) XXX_Marshal ¶
func (m *CondPayReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CondPayReceipt) XXX_Merge ¶
func (m *CondPayReceipt) XXX_Merge(src proto.Message)
func (*CondPayReceipt) XXX_Size ¶
func (m *CondPayReceipt) XXX_Size() int
func (*CondPayReceipt) XXX_Unmarshal ¶
func (m *CondPayReceipt) XXX_Unmarshal(b []byte) error
type CondPayRequest ¶
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 *any.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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
CondPayRequest is the first request setting up a pay path.
func (*CondPayRequest) Descriptor ¶
func (*CondPayRequest) Descriptor() ([]byte, []int)
func (*CondPayRequest) GetBaseSeq ¶
func (m *CondPayRequest) GetBaseSeq() uint64
func (*CondPayRequest) GetCondPay ¶
func (m *CondPayRequest) GetCondPay() []byte
func (*CondPayRequest) GetCrossNet ¶
func (m *CondPayRequest) GetCrossNet() *CrossNetPay
func (*CondPayRequest) GetDirectPay ¶
func (m *CondPayRequest) GetDirectPay() bool
func (*CondPayRequest) GetNote ¶
func (m *CondPayRequest) GetNote() *any.Any
func (*CondPayRequest) GetStateOnlyPeerFromSig ¶
func (m *CondPayRequest) GetStateOnlyPeerFromSig() *SignedSimplexState
func (*CondPayRequest) ProtoMessage ¶
func (*CondPayRequest) ProtoMessage()
func (*CondPayRequest) Reset ¶
func (m *CondPayRequest) Reset()
func (*CondPayRequest) String ¶
func (m *CondPayRequest) String() string
func (*CondPayRequest) XXX_DiscardUnknown ¶
func (m *CondPayRequest) XXX_DiscardUnknown()
func (*CondPayRequest) XXX_Marshal ¶
func (m *CondPayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CondPayRequest) XXX_Merge ¶
func (m *CondPayRequest) XXX_Merge(src proto.Message)
func (*CondPayRequest) XXX_Size ¶
func (m *CondPayRequest) XXX_Size() int
func (*CondPayRequest) XXX_Unmarshal ¶
func (m *CondPayRequest) XXX_Unmarshal(b []byte) error
type CondPayResponse ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
CondPayResponse is returning the signature of the other side in the channel.
func (*CondPayResponse) Descriptor ¶
func (*CondPayResponse) Descriptor() ([]byte, []int)
func (*CondPayResponse) GetError ¶
func (m *CondPayResponse) GetError() *Error
func (*CondPayResponse) GetStateCosigned ¶
func (m *CondPayResponse) GetStateCosigned() *SignedSimplexState
func (*CondPayResponse) ProtoMessage ¶
func (*CondPayResponse) ProtoMessage()
func (*CondPayResponse) Reset ¶
func (m *CondPayResponse) Reset()
func (*CondPayResponse) String ¶
func (m *CondPayResponse) String() string
func (*CondPayResponse) XXX_DiscardUnknown ¶
func (m *CondPayResponse) XXX_DiscardUnknown()
func (*CondPayResponse) XXX_Marshal ¶
func (m *CondPayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CondPayResponse) XXX_Merge ¶
func (m *CondPayResponse) XXX_Merge(src proto.Message)
func (*CondPayResponse) XXX_Size ¶
func (m *CondPayResponse) XXX_Size() int
func (*CondPayResponse) XXX_Unmarshal ¶
func (m *CondPayResponse) XXX_Unmarshal(b []byte) error
type ConfirmOnChainResolvedPaysRequest ¶
type ConfirmOnChainResolvedPaysRequest struct {
TokenAddress []byte `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Admin request to confirm on-chain resolved pays. Next tag: 2
func (*ConfirmOnChainResolvedPaysRequest) Descriptor ¶
func (*ConfirmOnChainResolvedPaysRequest) Descriptor() ([]byte, []int)
func (*ConfirmOnChainResolvedPaysRequest) GetTokenAddress ¶
func (m *ConfirmOnChainResolvedPaysRequest) GetTokenAddress() []byte
func (*ConfirmOnChainResolvedPaysRequest) ProtoMessage ¶
func (*ConfirmOnChainResolvedPaysRequest) ProtoMessage()
func (*ConfirmOnChainResolvedPaysRequest) Reset ¶
func (m *ConfirmOnChainResolvedPaysRequest) Reset()
func (*ConfirmOnChainResolvedPaysRequest) String ¶
func (m *ConfirmOnChainResolvedPaysRequest) String() string
func (*ConfirmOnChainResolvedPaysRequest) XXX_DiscardUnknown ¶
func (m *ConfirmOnChainResolvedPaysRequest) XXX_DiscardUnknown()
func (*ConfirmOnChainResolvedPaysRequest) XXX_Marshal ¶
func (m *ConfirmOnChainResolvedPaysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfirmOnChainResolvedPaysRequest) XXX_Merge ¶
func (m *ConfirmOnChainResolvedPaysRequest) XXX_Merge(src proto.Message)
func (*ConfirmOnChainResolvedPaysRequest) XXX_Size ¶
func (m *ConfirmOnChainResolvedPaysRequest) XXX_Size() int
func (*ConfirmOnChainResolvedPaysRequest) XXX_Unmarshal ¶
func (m *ConfirmOnChainResolvedPaysRequest) XXX_Unmarshal(b []byte) error
type ConnectionManager ¶
type ConnectionManager struct {
// contains filtered or unexported fields
}
func NewConnectionManager ¶
func NewConnectionManager(regClient RegisterClientCallbackFunc) *ConnectionManager
func (*ConnectionManager) AddCelerStream ¶
func (m *ConnectionManager) AddCelerStream(peerAddr ctype.Addr, stream CelerStream, msgProcessor chan *CelerMsg) context.Context
func (*ConnectionManager) AddConnection ¶
func (m *ConnectionManager) AddConnection(peerAddr ctype.Addr, cc *grpc.ClientConn)
func (*ConnectionManager) AddErrorCallback ¶
func (m *ConnectionManager) AddErrorCallback(peerAddr ctype.Addr, cb ErrCallbackFunc)
func (*ConnectionManager) CleanupStreams ¶
func (m *ConnectionManager) CleanupStreams(peerAddr ctype.Addr)
CleanupStreams terminate and cleanup the existing (old) hop & flow stream goroutines to allow for new streams & goroutines to be registered for the same address. It helps call from external to aquire lock.
func (*ConnectionManager) CloseConnection ¶
func (m *ConnectionManager) CloseConnection(peerAddr ctype.Addr)
func (*ConnectionManager) CloseNoRetry ¶
func (m *ConnectionManager) CloseNoRetry(onchainAddr ctype.Addr)
CloseNoRetry remove errCallbacks so no more retry, then close the underlying grpc conn expect to be only called in cNode.Close
func (*ConnectionManager) GetCelerStream ¶
func (m *ConnectionManager) GetCelerStream(peerAddr ctype.Addr) *SafeSendCelerStream
func (*ConnectionManager) GetClient ¶
func (m *ConnectionManager) GetClient(peerAddr ctype.Addr) (RpcClient, error)
func (*ConnectionManager) GetClientByAddr ¶
func (m *ConnectionManager) GetClientByAddr(peerAddr ctype.Addr) (RpcClient, error)
func (*ConnectionManager) GetNumCelerStreams ¶
func (m *ConnectionManager) GetNumCelerStreams() int
func (*ConnectionManager) SetMsgQueueCallback ¶
func (m *ConnectionManager) SetMsgQueueCallback(enable, disable MsgQueueCallbackFunc)
type CooperativeWithdrawRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 3
func (*CooperativeWithdrawRequest) Descriptor ¶
func (*CooperativeWithdrawRequest) Descriptor() ([]byte, []int)
func (*CooperativeWithdrawRequest) GetRequesterSig ¶
func (m *CooperativeWithdrawRequest) GetRequesterSig() []byte
func (*CooperativeWithdrawRequest) GetWithdrawInfo ¶
func (m *CooperativeWithdrawRequest) GetWithdrawInfo() *entity.CooperativeWithdrawInfo
func (*CooperativeWithdrawRequest) ProtoMessage ¶
func (*CooperativeWithdrawRequest) ProtoMessage()
func (*CooperativeWithdrawRequest) Reset ¶
func (m *CooperativeWithdrawRequest) Reset()
func (*CooperativeWithdrawRequest) String ¶
func (m *CooperativeWithdrawRequest) String() string
func (*CooperativeWithdrawRequest) XXX_DiscardUnknown ¶
func (m *CooperativeWithdrawRequest) XXX_DiscardUnknown()
func (*CooperativeWithdrawRequest) XXX_Marshal ¶
func (m *CooperativeWithdrawRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CooperativeWithdrawRequest) XXX_Merge ¶
func (m *CooperativeWithdrawRequest) XXX_Merge(src proto.Message)
func (*CooperativeWithdrawRequest) XXX_Size ¶
func (m *CooperativeWithdrawRequest) XXX_Size() int
func (*CooperativeWithdrawRequest) XXX_Unmarshal ¶
func (m *CooperativeWithdrawRequest) XXX_Unmarshal(b []byte) error
type CooperativeWithdrawResponse ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 4
func (*CooperativeWithdrawResponse) Descriptor ¶
func (*CooperativeWithdrawResponse) Descriptor() ([]byte, []int)
func (*CooperativeWithdrawResponse) GetApproverSig ¶
func (m *CooperativeWithdrawResponse) GetApproverSig() []byte
func (*CooperativeWithdrawResponse) GetRequesterSig ¶
func (m *CooperativeWithdrawResponse) GetRequesterSig() []byte
func (*CooperativeWithdrawResponse) GetWithdrawInfo ¶
func (m *CooperativeWithdrawResponse) GetWithdrawInfo() *entity.CooperativeWithdrawInfo
func (*CooperativeWithdrawResponse) ProtoMessage ¶
func (*CooperativeWithdrawResponse) ProtoMessage()
func (*CooperativeWithdrawResponse) Reset ¶
func (m *CooperativeWithdrawResponse) Reset()
func (*CooperativeWithdrawResponse) String ¶
func (m *CooperativeWithdrawResponse) String() string
func (*CooperativeWithdrawResponse) XXX_DiscardUnknown ¶
func (m *CooperativeWithdrawResponse) XXX_DiscardUnknown()
func (*CooperativeWithdrawResponse) XXX_Marshal ¶
func (m *CooperativeWithdrawResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CooperativeWithdrawResponse) XXX_Merge ¶
func (m *CooperativeWithdrawResponse) XXX_Merge(src proto.Message)
func (*CooperativeWithdrawResponse) XXX_Size ¶
func (m *CooperativeWithdrawResponse) XXX_Size() int
func (*CooperativeWithdrawResponse) XXX_Unmarshal ¶
func (m *CooperativeWithdrawResponse) XXX_Unmarshal(b []byte) error
type CrossNetPay ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CrossNetPay) Descriptor ¶
func (*CrossNetPay) Descriptor() ([]byte, []int)
func (*CrossNetPay) GetBridgeAddr ¶
func (m *CrossNetPay) GetBridgeAddr() []byte
func (*CrossNetPay) GetBridgeNetId ¶
func (m *CrossNetPay) GetBridgeNetId() uint64
func (*CrossNetPay) GetCrossing ¶
func (m *CrossNetPay) GetCrossing() bool
func (*CrossNetPay) GetDstNetId ¶
func (m *CrossNetPay) GetDstNetId() uint64
func (*CrossNetPay) GetOriginalPay ¶
func (m *CrossNetPay) GetOriginalPay() []byte
func (*CrossNetPay) GetSrcNetId ¶
func (m *CrossNetPay) GetSrcNetId() uint64
func (*CrossNetPay) GetTimeout ¶
func (m *CrossNetPay) GetTimeout() uint64
func (*CrossNetPay) ProtoMessage ¶
func (*CrossNetPay) ProtoMessage()
func (*CrossNetPay) Reset ¶
func (m *CrossNetPay) Reset()
func (*CrossNetPay) String ¶
func (m *CrossNetPay) String() string
func (*CrossNetPay) XXX_DiscardUnknown ¶
func (m *CrossNetPay) XXX_DiscardUnknown()
func (*CrossNetPay) XXX_Marshal ¶
func (m *CrossNetPay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrossNetPay) XXX_Merge ¶
func (m *CrossNetPay) XXX_Merge(src proto.Message)
func (*CrossNetPay) XXX_Size ¶
func (m *CrossNetPay) XXX_Size() int
func (*CrossNetPay) XXX_Unmarshal ¶
func (m *CrossNetPay) XXX_Unmarshal(b []byte) error
type DelegationDescription ¶
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"`
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 5
func (*DelegationDescription) Descriptor ¶
func (*DelegationDescription) Descriptor() ([]byte, []int)
func (*DelegationDescription) GetDelegatee ¶
func (m *DelegationDescription) GetDelegatee() []byte
func (*DelegationDescription) GetDelegator ¶
func (m *DelegationDescription) GetDelegator() []byte
func (*DelegationDescription) GetExpiresAfterBlock ¶
func (m *DelegationDescription) GetExpiresAfterBlock() int64
func (*DelegationDescription) GetTokenToDelegate ¶
func (m *DelegationDescription) GetTokenToDelegate() [][]byte
func (*DelegationDescription) ProtoMessage ¶
func (*DelegationDescription) ProtoMessage()
func (*DelegationDescription) Reset ¶
func (m *DelegationDescription) Reset()
func (*DelegationDescription) String ¶
func (m *DelegationDescription) String() string
func (*DelegationDescription) XXX_DiscardUnknown ¶
func (m *DelegationDescription) XXX_DiscardUnknown()
func (*DelegationDescription) XXX_Marshal ¶
func (m *DelegationDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelegationDescription) XXX_Merge ¶
func (m *DelegationDescription) XXX_Merge(src proto.Message)
func (*DelegationDescription) XXX_Size ¶
func (m *DelegationDescription) XXX_Size() int
func (*DelegationDescription) XXX_Unmarshal ¶
func (m *DelegationDescription) XXX_Unmarshal(b []byte) error
type DelegationProof ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 4
func (*DelegationProof) Descriptor ¶
func (*DelegationProof) Descriptor() ([]byte, []int)
func (*DelegationProof) GetDelegationDescriptionBytes ¶
func (m *DelegationProof) GetDelegationDescriptionBytes() []byte
func (*DelegationProof) GetSignature ¶
func (m *DelegationProof) GetSignature() []byte
func (*DelegationProof) GetSigner ¶
func (m *DelegationProof) GetSigner() []byte
func (*DelegationProof) ProtoMessage ¶
func (*DelegationProof) ProtoMessage()
func (*DelegationProof) Reset ¶
func (m *DelegationProof) Reset()
func (*DelegationProof) String ¶
func (m *DelegationProof) String() string
func (*DelegationProof) XXX_DiscardUnknown ¶
func (m *DelegationProof) XXX_DiscardUnknown()
func (*DelegationProof) XXX_Marshal ¶
func (m *DelegationProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelegationProof) XXX_Merge ¶
func (m *DelegationProof) XXX_Merge(src proto.Message)
func (*DelegationProof) XXX_Size ¶
func (m *DelegationProof) XXX_Size() int
func (*DelegationProof) XXX_Unmarshal ¶
func (m *DelegationProof) XXX_Unmarshal(b []byte) error
type DelegationRequest ¶
type DelegationRequest struct {
Proof *DelegationProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*DelegationRequest) Descriptor ¶
func (*DelegationRequest) Descriptor() ([]byte, []int)
func (*DelegationRequest) GetProof ¶
func (m *DelegationRequest) GetProof() *DelegationProof
func (*DelegationRequest) ProtoMessage ¶
func (*DelegationRequest) ProtoMessage()
func (*DelegationRequest) Reset ¶
func (m *DelegationRequest) Reset()
func (*DelegationRequest) String ¶
func (m *DelegationRequest) String() string
func (*DelegationRequest) XXX_DiscardUnknown ¶
func (m *DelegationRequest) XXX_DiscardUnknown()
func (*DelegationRequest) XXX_Marshal ¶
func (m *DelegationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelegationRequest) XXX_Merge ¶
func (m *DelegationRequest) XXX_Merge(src proto.Message)
func (*DelegationRequest) XXX_Size ¶
func (m *DelegationRequest) XXX_Size() int
func (*DelegationRequest) XXX_Unmarshal ¶
func (m *DelegationRequest) XXX_Unmarshal(b []byte) error
type DelegationResponse ¶
type DelegationResponse struct {
Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*DelegationResponse) Descriptor ¶
func (*DelegationResponse) Descriptor() ([]byte, []int)
func (*DelegationResponse) GetError ¶
func (m *DelegationResponse) GetError() string
func (*DelegationResponse) ProtoMessage ¶
func (*DelegationResponse) ProtoMessage()
func (*DelegationResponse) Reset ¶
func (m *DelegationResponse) Reset()
func (*DelegationResponse) String ¶
func (m *DelegationResponse) String() string
func (*DelegationResponse) XXX_DiscardUnknown ¶
func (m *DelegationResponse) XXX_DiscardUnknown()
func (*DelegationResponse) XXX_Marshal ¶
func (m *DelegationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelegationResponse) XXX_Merge ¶
func (m *DelegationResponse) XXX_Merge(src proto.Message)
func (*DelegationResponse) XXX_Size ¶
func (m *DelegationResponse) XXX_Size() int
func (*DelegationResponse) XXX_Unmarshal ¶
func (m *DelegationResponse) XXX_Unmarshal(b []byte) error
type DepositRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 6
func (*DepositRequest) Descriptor ¶
func (*DepositRequest) Descriptor() ([]byte, []int)
func (*DepositRequest) GetAmtWei ¶
func (m *DepositRequest) GetAmtWei() string
func (*DepositRequest) GetMaxWaitS ¶
func (m *DepositRequest) GetMaxWaitS() uint64
func (*DepositRequest) GetPeerAddr ¶
func (m *DepositRequest) GetPeerAddr() string
func (*DepositRequest) GetToPeer ¶
func (m *DepositRequest) GetToPeer() bool
func (*DepositRequest) GetTokenAddr ¶
func (m *DepositRequest) GetTokenAddr() string
func (*DepositRequest) ProtoMessage ¶
func (*DepositRequest) ProtoMessage()
func (*DepositRequest) Reset ¶
func (m *DepositRequest) Reset()
func (*DepositRequest) String ¶
func (m *DepositRequest) String() string
func (*DepositRequest) XXX_DiscardUnknown ¶
func (m *DepositRequest) XXX_DiscardUnknown()
func (*DepositRequest) XXX_Marshal ¶
func (m *DepositRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DepositRequest) XXX_Merge ¶
func (m *DepositRequest) XXX_Merge(src proto.Message)
func (*DepositRequest) XXX_Size ¶
func (m *DepositRequest) XXX_Size() int
func (*DepositRequest) XXX_Unmarshal ¶
func (m *DepositRequest) XXX_Unmarshal(b []byte) error
type DepositResponse ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 4
func (*DepositResponse) Descriptor ¶
func (*DepositResponse) Descriptor() ([]byte, []int)
func (*DepositResponse) GetDepositId ¶
func (m *DepositResponse) GetDepositId() string
func (*DepositResponse) GetError ¶
func (m *DepositResponse) GetError() string
func (*DepositResponse) GetStatus ¶
func (m *DepositResponse) GetStatus() int32
func (*DepositResponse) ProtoMessage ¶
func (*DepositResponse) ProtoMessage()
func (*DepositResponse) Reset ¶
func (m *DepositResponse) Reset()
func (*DepositResponse) String ¶
func (m *DepositResponse) String() string
func (*DepositResponse) XXX_DiscardUnknown ¶
func (m *DepositResponse) XXX_DiscardUnknown()
func (*DepositResponse) XXX_Marshal ¶
func (m *DepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DepositResponse) XXX_Merge ¶
func (m *DepositResponse) XXX_Merge(src proto.Message)
func (*DepositResponse) XXX_Size ¶
func (m *DepositResponse) XXX_Size() int
func (*DepositResponse) XXX_Unmarshal ¶
func (m *DepositResponse) XXX_Unmarshal(b []byte) error
type DepositState ¶
type DepositState int32
const ( DepositState_Deposit_NOT_FOUND DepositState = 0 DepositState_Deposit_QUEUED DepositState = 1 DepositState_Deposit_SUBMITTED DepositState = 2 DepositState_Deposit_SUCCEEDED DepositState = 3 DepositState_Deposit_FAILED DepositState = 4 )
func (DepositState) EnumDescriptor ¶
func (DepositState) EnumDescriptor() ([]byte, []int)
func (DepositState) String ¶
func (x DepositState) String() string
type ErrCallbackFunc ¶
type ErrCode ¶
type ErrCode int32
Next Tag: 11
const ( // reserve 0 so not setting this is not a valid error code ErrCode_OK ErrCode = 0 // not yet authreq/authack ErrCode_UNAUTHORIZED ErrCode = 1 // sig in authreq can't recover claimed my_addr ErrCode_INVALID_SIG ErrCode = 2 // timestamp in req out of allowed range ErrCode_INCORRECT_CLOCK ErrCode = 3 // I'm not your expected peer ErrCode_WRONG_PEER ErrCode = 4 // invalid simplex state sequence number ErrCode_INVALID_SEQ_NUM ErrCode = 5 // forwared the pay before and receiving again, probably a loop. ErrCode_PAY_ROUTE_LOOP ErrCode = 6 // can't find a route to dst. ErrCode_NO_ROUTE_TO_DST ErrCode = 7 // not enough balance ErrCode_NOT_ENOUGH_BALANCE ErrCode = 8 // peer not online ErrCode_PEER_NOT_ONLINE ErrCode = 9 // no specified error code ErrCode_MISC_ERROR ErrCode = 10 )
func (ErrCode) EnumDescriptor ¶
type Error ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Error) Descriptor ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶
func (*Error) XXX_Unmarshal ¶
type FwdReply ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 3
func (*FwdReply) Descriptor ¶
func (*FwdReply) GetAccepted ¶
func (*FwdReply) ProtoMessage ¶
func (*FwdReply) ProtoMessage()
func (*FwdReply) XXX_DiscardUnknown ¶
func (m *FwdReply) XXX_DiscardUnknown()
func (*FwdReply) XXX_Marshal ¶
func (*FwdReply) XXX_Unmarshal ¶
type FwdReq ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 6
func (*FwdReq) Descriptor ¶
func (*FwdReq) GetMessage ¶
func (*FwdReq) ProtoMessage ¶
func (*FwdReq) ProtoMessage()
func (*FwdReq) XXX_DiscardUnknown ¶
func (m *FwdReq) XXX_DiscardUnknown()
func (*FwdReq) XXX_Marshal ¶
func (*FwdReq) XXX_Unmarshal ¶
type GetPayHistoryRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 7
func (*GetPayHistoryRequest) Descriptor ¶
func (*GetPayHistoryRequest) Descriptor() ([]byte, []int)
func (*GetPayHistoryRequest) GetBeforeTs ¶
func (m *GetPayHistoryRequest) GetBeforeTs() int64
func (*GetPayHistoryRequest) GetItemsPerPage ¶
func (m *GetPayHistoryRequest) GetItemsPerPage() int32
func (*GetPayHistoryRequest) GetPeer ¶
func (m *GetPayHistoryRequest) GetPeer() string
func (*GetPayHistoryRequest) GetSmallestPayId ¶
func (m *GetPayHistoryRequest) GetSmallestPayId() string
func (*GetPayHistoryRequest) GetTs ¶
func (m *GetPayHistoryRequest) GetTs() uint64
func (*GetPayHistoryRequest) GetTsSig ¶
func (m *GetPayHistoryRequest) GetTsSig() []byte
func (*GetPayHistoryRequest) ProtoMessage ¶
func (*GetPayHistoryRequest) ProtoMessage()
func (*GetPayHistoryRequest) Reset ¶
func (m *GetPayHistoryRequest) Reset()
func (*GetPayHistoryRequest) String ¶
func (m *GetPayHistoryRequest) String() string
func (*GetPayHistoryRequest) XXX_DiscardUnknown ¶
func (m *GetPayHistoryRequest) XXX_DiscardUnknown()
func (*GetPayHistoryRequest) XXX_Marshal ¶
func (m *GetPayHistoryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPayHistoryRequest) XXX_Merge ¶
func (m *GetPayHistoryRequest) XXX_Merge(src proto.Message)
func (*GetPayHistoryRequest) XXX_Size ¶
func (m *GetPayHistoryRequest) XXX_Size() int
func (*GetPayHistoryRequest) XXX_Unmarshal ¶
func (m *GetPayHistoryRequest) XXX_Unmarshal(b []byte) error
type GetPayHistoryResponse ¶
type GetPayHistoryResponse struct {
Pays []*OneHistoricalPay `protobuf:"bytes,1,rep,name=pays,proto3" json:"pays,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*GetPayHistoryResponse) Descriptor ¶
func (*GetPayHistoryResponse) Descriptor() ([]byte, []int)
func (*GetPayHistoryResponse) GetPays ¶
func (m *GetPayHistoryResponse) GetPays() []*OneHistoricalPay
func (*GetPayHistoryResponse) ProtoMessage ¶
func (*GetPayHistoryResponse) ProtoMessage()
func (*GetPayHistoryResponse) Reset ¶
func (m *GetPayHistoryResponse) Reset()
func (*GetPayHistoryResponse) String ¶
func (m *GetPayHistoryResponse) String() string
func (*GetPayHistoryResponse) XXX_DiscardUnknown ¶
func (m *GetPayHistoryResponse) XXX_DiscardUnknown()
func (*GetPayHistoryResponse) XXX_Marshal ¶
func (m *GetPayHistoryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPayHistoryResponse) XXX_Merge ¶
func (m *GetPayHistoryResponse) XXX_Merge(src proto.Message)
func (*GetPayHistoryResponse) XXX_Size ¶
func (m *GetPayHistoryResponse) XXX_Size() int
func (*GetPayHistoryResponse) XXX_Unmarshal ¶
func (m *GetPayHistoryResponse) XXX_Unmarshal(b []byte) error
type JoinCelerStatus ¶
type JoinCelerStatus int32
JoinCelerStatus describes the status of a endpoint in Celer network Next Tag: 3
const ( // Endpoint has not joined in Celer Network yet, // does not have any celer channel with any Osp in Celer Network JoinCelerStatus_NOT_JOIN JoinCelerStatus = 0 // Endpoint has a celer channel with the Osp responding this msg JoinCelerStatus_LOCAL JoinCelerStatus = 1 // Endpoint does not have a celer channel with the Osp responding this msg, // but has a celer channel with another remote Osp JoinCelerStatus_REMOTE JoinCelerStatus = 2 )
func (JoinCelerStatus) EnumDescriptor ¶
func (JoinCelerStatus) EnumDescriptor() ([]byte, []int)
func (JoinCelerStatus) String ¶
func (x JoinCelerStatus) String() string
type MID ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
MID is the message identifier, used as map key for unary over stream NOTE: all field types must be golang comparable so map[MID] can work Auth requester should set its mid to start_mid in AuthAck
func (*MID) Descriptor ¶
func (*MID) ProtoMessage ¶
func (*MID) ProtoMessage()
func (*MID) XXX_DiscardUnknown ¶
func (m *MID) XXX_DiscardUnknown()
func (*MID) XXX_Unmarshal ¶
type MigrateChannelRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 3
func (*MigrateChannelRequest) Descriptor ¶
func (*MigrateChannelRequest) Descriptor() ([]byte, []int)
func (*MigrateChannelRequest) GetChannelMigrationInfo ¶
func (m *MigrateChannelRequest) GetChannelMigrationInfo() []byte
func (*MigrateChannelRequest) GetRequesterSig ¶
func (m *MigrateChannelRequest) GetRequesterSig() []byte
func (*MigrateChannelRequest) ProtoMessage ¶
func (*MigrateChannelRequest) ProtoMessage()
func (*MigrateChannelRequest) Reset ¶
func (m *MigrateChannelRequest) Reset()
func (*MigrateChannelRequest) String ¶
func (m *MigrateChannelRequest) String() string
func (*MigrateChannelRequest) XXX_DiscardUnknown ¶
func (m *MigrateChannelRequest) XXX_DiscardUnknown()
func (*MigrateChannelRequest) XXX_Marshal ¶
func (m *MigrateChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrateChannelRequest) XXX_Merge ¶
func (m *MigrateChannelRequest) XXX_Merge(src proto.Message)
func (*MigrateChannelRequest) XXX_Size ¶
func (m *MigrateChannelRequest) XXX_Size() int
func (*MigrateChannelRequest) XXX_Unmarshal ¶
func (m *MigrateChannelRequest) XXX_Unmarshal(b []byte) error
type MigrateChannelResponse ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*MigrateChannelResponse) Descriptor ¶
func (*MigrateChannelResponse) Descriptor() ([]byte, []int)
func (*MigrateChannelResponse) GetApproverSig ¶
func (m *MigrateChannelResponse) GetApproverSig() []byte
func (*MigrateChannelResponse) ProtoMessage ¶
func (*MigrateChannelResponse) ProtoMessage()
func (*MigrateChannelResponse) Reset ¶
func (m *MigrateChannelResponse) Reset()
func (*MigrateChannelResponse) String ¶
func (m *MigrateChannelResponse) String() string
func (*MigrateChannelResponse) XXX_DiscardUnknown ¶
func (m *MigrateChannelResponse) XXX_DiscardUnknown()
func (*MigrateChannelResponse) XXX_Marshal ¶
func (m *MigrateChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrateChannelResponse) XXX_Merge ¶
func (m *MigrateChannelResponse) XXX_Merge(src proto.Message)
func (*MigrateChannelResponse) XXX_Size ¶
func (m *MigrateChannelResponse) XXX_Size() int
func (*MigrateChannelResponse) XXX_Unmarshal ¶
func (m *MigrateChannelResponse) XXX_Unmarshal(b []byte) error
type MsgQueueCallbackFunc ¶
type MultiServerClient ¶
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)
}
MultiServerClient is the client API for MultiServer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMultiServerClient ¶
func NewMultiServerClient(cc *grpc.ClientConn) MultiServerClient
type MultiServerServer ¶
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)
}
MultiServerServer is the server API for MultiServer service.
type OneHistoricalPay ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 8
func (*OneHistoricalPay) Descriptor ¶
func (*OneHistoricalPay) Descriptor() ([]byte, []int)
func (*OneHistoricalPay) GetAmt ¶
func (m *OneHistoricalPay) GetAmt() string
func (*OneHistoricalPay) GetCreateTs ¶
func (m *OneHistoricalPay) GetCreateTs() int64
func (*OneHistoricalPay) GetDst ¶
func (m *OneHistoricalPay) GetDst() string
func (*OneHistoricalPay) GetPayId ¶
func (m *OneHistoricalPay) GetPayId() string
func (*OneHistoricalPay) GetSrc ¶
func (m *OneHistoricalPay) GetSrc() string
func (*OneHistoricalPay) GetState ¶
func (m *OneHistoricalPay) GetState() int64
func (*OneHistoricalPay) GetToken ¶
func (m *OneHistoricalPay) GetToken() string
func (*OneHistoricalPay) ProtoMessage ¶
func (*OneHistoricalPay) ProtoMessage()
func (*OneHistoricalPay) Reset ¶
func (m *OneHistoricalPay) Reset()
func (*OneHistoricalPay) String ¶
func (m *OneHistoricalPay) String() string
func (*OneHistoricalPay) XXX_DiscardUnknown ¶
func (m *OneHistoricalPay) XXX_DiscardUnknown()
func (*OneHistoricalPay) XXX_Marshal ¶
func (m *OneHistoricalPay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OneHistoricalPay) XXX_Merge ¶
func (m *OneHistoricalPay) XXX_Merge(src proto.Message)
func (*OneHistoricalPay) XXX_Size ¶
func (m *OneHistoricalPay) XXX_Size() int
func (*OneHistoricalPay) XXX_Unmarshal ¶
func (m *OneHistoricalPay) XXX_Unmarshal(b []byte) error
type OpenChannelBy ¶
type OpenChannelBy int32
Next Tag: 3
const ( OpenChannelBy_UNDEFINED_OPEN_BY OpenChannelBy = 0 OpenChannelBy_OPEN_CHANNEL_PROPOSER OpenChannelBy = 1 OpenChannelBy_OPEN_CHANNEL_APPROVER OpenChannelBy = 2 )
func (OpenChannelBy) EnumDescriptor ¶
func (OpenChannelBy) EnumDescriptor() ([]byte, []int)
func (OpenChannelBy) String ¶
func (x OpenChannelBy) String() string
type OpenChannelRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
OpenChannelRequest when one wants to open a channel with peer. Next Tag: 5
func (*OpenChannelRequest) Descriptor ¶
func (*OpenChannelRequest) Descriptor() ([]byte, []int)
func (*OpenChannelRequest) GetChannelInitializer ¶
func (m *OpenChannelRequest) GetChannelInitializer() []byte
func (*OpenChannelRequest) GetOpenBy ¶
func (m *OpenChannelRequest) GetOpenBy() OpenChannelBy
func (*OpenChannelRequest) GetOspToOsp ¶
func (m *OpenChannelRequest) GetOspToOsp() bool
func (*OpenChannelRequest) GetRequesterSig ¶
func (m *OpenChannelRequest) GetRequesterSig() []byte
func (*OpenChannelRequest) ProtoMessage ¶
func (*OpenChannelRequest) ProtoMessage()
func (*OpenChannelRequest) Reset ¶
func (m *OpenChannelRequest) Reset()
func (*OpenChannelRequest) String ¶
func (m *OpenChannelRequest) String() string
func (*OpenChannelRequest) XXX_DiscardUnknown ¶
func (m *OpenChannelRequest) XXX_DiscardUnknown()
func (*OpenChannelRequest) XXX_Marshal ¶
func (m *OpenChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenChannelRequest) XXX_Merge ¶
func (m *OpenChannelRequest) XXX_Merge(src proto.Message)
func (*OpenChannelRequest) XXX_Size ¶
func (m *OpenChannelRequest) XXX_Size() int
func (*OpenChannelRequest) XXX_Unmarshal ¶
func (m *OpenChannelRequest) XXX_Unmarshal(b []byte) error
type OpenChannelResponse ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 6
func (*OpenChannelResponse) Descriptor ¶
func (*OpenChannelResponse) Descriptor() ([]byte, []int)
func (*OpenChannelResponse) GetApproverSig ¶
func (m *OpenChannelResponse) GetApproverSig() []byte
func (*OpenChannelResponse) GetChannelInitializer ¶
func (m *OpenChannelResponse) GetChannelInitializer() []byte
func (*OpenChannelResponse) GetPaymentChannelId ¶
func (m *OpenChannelResponse) GetPaymentChannelId() []byte
func (*OpenChannelResponse) GetRequesterSig ¶
func (m *OpenChannelResponse) GetRequesterSig() []byte
func (*OpenChannelResponse) GetStatus ¶
func (m *OpenChannelResponse) GetStatus() OpenChannelStatus
func (*OpenChannelResponse) ProtoMessage ¶
func (*OpenChannelResponse) ProtoMessage()
func (*OpenChannelResponse) Reset ¶
func (m *OpenChannelResponse) Reset()
func (*OpenChannelResponse) String ¶
func (m *OpenChannelResponse) String() string
func (*OpenChannelResponse) XXX_DiscardUnknown ¶
func (m *OpenChannelResponse) XXX_DiscardUnknown()
func (*OpenChannelResponse) XXX_Marshal ¶
func (m *OpenChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenChannelResponse) XXX_Merge ¶
func (m *OpenChannelResponse) XXX_Merge(src proto.Message)
func (*OpenChannelResponse) XXX_Size ¶
func (m *OpenChannelResponse) XXX_Size() int
func (*OpenChannelResponse) XXX_Unmarshal ¶
func (m *OpenChannelResponse) XXX_Unmarshal(b []byte) error
type OpenChannelStatus ¶
type OpenChannelStatus int32
Next Tag: 4
const ( OpenChannelStatus_UNDEFINED_OPEN_CHANNEL_STATUS OpenChannelStatus = 0 // OpenChannel is approved by approver. // But no on-chain transaction has been made. OpenChannelStatus_OPEN_CHANNEL_APPROVED OpenChannelStatus = 1 // OpenChannel transaction is submitted on-chain by approver. OpenChannelStatus_OPEN_CHANNEL_TX_SUBMITTED OpenChannelStatus = 2 OpenChannelStatus_OPEN_CHANNEL_TCB_OPENED OpenChannelStatus = 3 )
func (OpenChannelStatus) EnumDescriptor ¶
func (OpenChannelStatus) EnumDescriptor() ([]byte, []int)
func (OpenChannelStatus) String ¶
func (x OpenChannelStatus) String() string
type OspOpenChannelRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Admin request to ask the receiving osp to open a channel with peer. Next tag: 6
func (*OspOpenChannelRequest) Descriptor ¶
func (*OspOpenChannelRequest) Descriptor() ([]byte, []int)
func (*OspOpenChannelRequest) GetPeerDepositAmtWei ¶
func (m *OspOpenChannelRequest) GetPeerDepositAmtWei() string
func (*OspOpenChannelRequest) GetPeerEthAddress ¶
func (m *OspOpenChannelRequest) GetPeerEthAddress() []byte
func (*OspOpenChannelRequest) GetSelfDepositAmtWei ¶
func (m *OspOpenChannelRequest) GetSelfDepositAmtWei() string
func (*OspOpenChannelRequest) GetTokenAddress ¶
func (m *OspOpenChannelRequest) GetTokenAddress() []byte
func (*OspOpenChannelRequest) GetTokenType ¶
func (m *OspOpenChannelRequest) GetTokenType() entity.TokenType
func (*OspOpenChannelRequest) ProtoMessage ¶
func (*OspOpenChannelRequest) ProtoMessage()
func (*OspOpenChannelRequest) Reset ¶
func (m *OspOpenChannelRequest) Reset()
func (*OspOpenChannelRequest) String ¶
func (m *OspOpenChannelRequest) String() string
func (*OspOpenChannelRequest) XXX_DiscardUnknown ¶
func (m *OspOpenChannelRequest) XXX_DiscardUnknown()
func (*OspOpenChannelRequest) XXX_Marshal ¶
func (m *OspOpenChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OspOpenChannelRequest) XXX_Merge ¶
func (m *OspOpenChannelRequest) XXX_Merge(src proto.Message)
func (*OspOpenChannelRequest) XXX_Size ¶
func (m *OspOpenChannelRequest) XXX_Size() int
func (*OspOpenChannelRequest) XXX_Unmarshal ¶
func (m *OspOpenChannelRequest) XXX_Unmarshal(b []byte) error
type PayHop ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 5
func (*PayHop) Descriptor ¶
func (*PayHop) GetNextHopAddr ¶
func (*PayHop) GetPrevHopAddr ¶
func (*PayHop) ProtoMessage ¶
func (*PayHop) ProtoMessage()
func (*PayHop) XXX_DiscardUnknown ¶
func (m *PayHop) XXX_DiscardUnknown()
func (*PayHop) XXX_Marshal ¶
func (*PayHop) XXX_Unmarshal ¶
type PayInAuthAck ¶
type PayInAuthAck struct {
Pay []byte `protobuf:"bytes,1,opt,name=pay,proto3" json:"pay,omitempty"`
Note *any.Any `protobuf:"bytes,2,opt,name=note,proto3" json:"note,omitempty"`
// pay state, from instate or outstate depending on which simplex
State int64 `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PayInAuthAck) Descriptor ¶
func (*PayInAuthAck) Descriptor() ([]byte, []int)
func (*PayInAuthAck) GetNote ¶
func (m *PayInAuthAck) GetNote() *any.Any
func (*PayInAuthAck) GetPay ¶
func (m *PayInAuthAck) GetPay() []byte
func (*PayInAuthAck) GetState ¶
func (m *PayInAuthAck) GetState() int64
func (*PayInAuthAck) ProtoMessage ¶
func (*PayInAuthAck) ProtoMessage()
func (*PayInAuthAck) Reset ¶
func (m *PayInAuthAck) Reset()
func (*PayInAuthAck) String ¶
func (m *PayInAuthAck) String() string
func (*PayInAuthAck) XXX_DiscardUnknown ¶
func (m *PayInAuthAck) XXX_DiscardUnknown()
func (*PayInAuthAck) XXX_Marshal ¶
func (m *PayInAuthAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PayInAuthAck) XXX_Merge ¶
func (m *PayInAuthAck) XXX_Merge(src proto.Message)
func (*PayInAuthAck) XXX_Size ¶
func (m *PayInAuthAck) XXX_Size() int
func (*PayInAuthAck) XXX_Unmarshal ¶
func (m *PayInAuthAck) XXX_Unmarshal(b []byte) error
type PayPath ¶
type PayPath struct {
Hops []*SignedPayHop `protobuf:"bytes,1,rep,name=hops,proto3" json:"hops,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 2
func (*PayPath) Descriptor ¶
func (*PayPath) GetHops ¶
func (m *PayPath) GetHops() []*SignedPayHop
func (*PayPath) ProtoMessage ¶
func (*PayPath) ProtoMessage()
func (*PayPath) XXX_DiscardUnknown ¶
func (m *PayPath) XXX_DiscardUnknown()
func (*PayPath) XXX_Marshal ¶
func (*PayPath) XXX_Unmarshal ¶
type PaymentSettleProof ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
PaymentSettleProof provides all condition results to settle a pay. Expect after receives this msg, peer will send PaymentSettleRequest Next Tag: 3
func (*PaymentSettleProof) Descriptor ¶
func (*PaymentSettleProof) Descriptor() ([]byte, []int)
func (*PaymentSettleProof) GetSettledPays ¶
func (m *PaymentSettleProof) GetSettledPays() []*SettledPayment
func (*PaymentSettleProof) GetVouchedCondPayResults ¶
func (m *PaymentSettleProof) GetVouchedCondPayResults() []*entity.VouchedCondPayResult
func (*PaymentSettleProof) ProtoMessage ¶
func (*PaymentSettleProof) ProtoMessage()
func (*PaymentSettleProof) Reset ¶
func (m *PaymentSettleProof) Reset()
func (*PaymentSettleProof) String ¶
func (m *PaymentSettleProof) String() string
func (*PaymentSettleProof) XXX_DiscardUnknown ¶
func (m *PaymentSettleProof) XXX_DiscardUnknown()
func (*PaymentSettleProof) XXX_Marshal ¶
func (m *PaymentSettleProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PaymentSettleProof) XXX_Merge ¶
func (m *PaymentSettleProof) XXX_Merge(src proto.Message)
func (*PaymentSettleProof) XXX_Size ¶
func (m *PaymentSettleProof) XXX_Size() int
func (*PaymentSettleProof) XXX_Unmarshal ¶
func (m *PaymentSettleProof) XXX_Unmarshal(b []byte) error
type PaymentSettleReason ¶
type PaymentSettleReason int32
Next Tag: 7
const ( PaymentSettleReason_NONE PaymentSettleReason = 0 PaymentSettleReason_PAY_EXPIRED PaymentSettleReason = 1 PaymentSettleReason_PAY_REJECTED PaymentSettleReason = 2 PaymentSettleReason_PAY_RESOLVED_ONCHAIN PaymentSettleReason = 3 PaymentSettleReason_PAY_PAID_MAX PaymentSettleReason = 4 PaymentSettleReason_PAY_DEST_UNREACHABLE PaymentSettleReason = 5 PaymentSettleReason_PAY_VOUCHED PaymentSettleReason = 6 )
func (PaymentSettleReason) EnumDescriptor ¶
func (PaymentSettleReason) EnumDescriptor() ([]byte, []int)
func (PaymentSettleReason) String ¶
func (x PaymentSettleReason) String() string
type PaymentSettleRequest ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
When peer_from of a simplex channel wants to settle a pay the updated simplex will be sent along with its signature.
func (*PaymentSettleRequest) Descriptor ¶
func (*PaymentSettleRequest) Descriptor() ([]byte, []int)
func (*PaymentSettleRequest) GetBaseSeq ¶
func (m *PaymentSettleRequest) GetBaseSeq() uint64
func (*PaymentSettleRequest) GetSettledPays ¶
func (m *PaymentSettleRequest) GetSettledPays() []*SettledPayment
func (*PaymentSettleRequest) GetStateOnlyPeerFromSig ¶
func (m *PaymentSettleRequest) GetStateOnlyPeerFromSig() *SignedSimplexState
func (*PaymentSettleRequest) ProtoMessage ¶
func (*PaymentSettleRequest) ProtoMessage()
func (*PaymentSettleRequest) Reset ¶
func (m *PaymentSettleRequest) Reset()
func (*PaymentSettleRequest) String ¶
func (m *PaymentSettleRequest) String() string
func (*PaymentSettleRequest) XXX_DiscardUnknown ¶
func (m *PaymentSettleRequest) XXX_DiscardUnknown()
func (*PaymentSettleRequest) XXX_Marshal ¶
func (m *PaymentSettleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PaymentSettleRequest) XXX_Merge ¶
func (m *PaymentSettleRequest) XXX_Merge(src proto.Message)
func (*PaymentSettleRequest) XXX_Size ¶
func (m *PaymentSettleRequest) XXX_Size() int
func (*PaymentSettleRequest) XXX_Unmarshal ¶
func (m *PaymentSettleRequest) XXX_Unmarshal(b []byte) error
type PaymentSettleResponse ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
peer_to of a simplex channel confirms the settlement by providing its sig Next Tag: 4
func (*PaymentSettleResponse) Descriptor ¶
func (*PaymentSettleResponse) Descriptor() ([]byte, []int)
func (*PaymentSettleResponse) GetError ¶
func (m *PaymentSettleResponse) GetError() *Error
func (*PaymentSettleResponse) GetStateCosigned ¶
func (m *PaymentSettleResponse) GetStateCosigned() *SignedSimplexState
func (*PaymentSettleResponse) ProtoMessage ¶
func (*PaymentSettleResponse) ProtoMessage()
func (*PaymentSettleResponse) Reset ¶
func (m *PaymentSettleResponse) Reset()
func (*PaymentSettleResponse) String ¶
func (m *PaymentSettleResponse) String() string
func (*PaymentSettleResponse) XXX_DiscardUnknown ¶
func (m *PaymentSettleResponse) XXX_DiscardUnknown()
func (*PaymentSettleResponse) XXX_Marshal ¶
func (m *PaymentSettleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PaymentSettleResponse) XXX_Merge ¶
func (m *PaymentSettleResponse) XXX_Merge(src proto.Message)
func (*PaymentSettleResponse) XXX_Size ¶
func (m *PaymentSettleResponse) XXX_Size() int
func (*PaymentSettleResponse) XXX_Unmarshal ¶
func (m *PaymentSettleResponse) XXX_Unmarshal(b []byte) error
type PeerAddress ¶
type PeerAddress struct {
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
TokenAddr string `protobuf:"bytes,2,opt,name=token_addr,json=tokenAddr,proto3" json:"token_addr,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PeerAddress) Descriptor ¶
func (*PeerAddress) Descriptor() ([]byte, []int)
func (*PeerAddress) GetAddress ¶
func (m *PeerAddress) GetAddress() string
func (*PeerAddress) GetTokenAddr ¶
func (m *PeerAddress) GetTokenAddr() string
func (*PeerAddress) ProtoMessage ¶
func (*PeerAddress) ProtoMessage()
func (*PeerAddress) Reset ¶
func (m *PeerAddress) Reset()
func (*PeerAddress) String ¶
func (m *PeerAddress) String() string
func (*PeerAddress) XXX_DiscardUnknown ¶
func (m *PeerAddress) XXX_DiscardUnknown()
func (*PeerAddress) XXX_Marshal ¶
func (m *PeerAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeerAddress) XXX_Merge ¶
func (m *PeerAddress) XXX_Merge(src proto.Message)
func (*PeerAddress) XXX_Size ¶
func (m *PeerAddress) XXX_Size() int
func (*PeerAddress) XXX_Unmarshal ¶
func (m *PeerAddress) XXX_Unmarshal(b []byte) error
type PeerOsp ¶
type PeerOsp struct {
// eth addr of peer osp
OspAddress string `protobuf:"bytes,1,opt,name=osp_address,json=ospAddress,proto3" json:"osp_address,omitempty"`
// channels with the peer osp
TokenCidPairs []*TokenCidPair `protobuf:"bytes,2,rep,name=token_cid_pairs,json=tokenCidPairs,proto3" json:"token_cid_pairs,omitempty"`
// last update timestamp
UpdateTs uint64 `protobuf:"varint,3,opt,name=update_ts,json=updateTs,proto3" json:"update_ts,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PeerOsp) Descriptor ¶
func (*PeerOsp) GetOspAddress ¶
func (*PeerOsp) GetTokenCidPairs ¶
func (m *PeerOsp) GetTokenCidPairs() []*TokenCidPair
func (*PeerOsp) GetUpdateTs ¶
func (*PeerOsp) ProtoMessage ¶
func (*PeerOsp) ProtoMessage()
func (*PeerOsp) XXX_DiscardUnknown ¶
func (m *PeerOsp) XXX_DiscardUnknown()
func (*PeerOsp) XXX_Marshal ¶
func (*PeerOsp) XXX_Unmarshal ¶
type PeerOspsResponse ¶
type PeerOspsResponse struct {
// info of peer osps.
PeerOsps []*PeerOsp `protobuf:"bytes,1,rep,name=peer_osps,json=peerOsps,proto3" json:"peer_osps,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Admin request to list all peer osps. Next tag: 2
func (*PeerOspsResponse) Descriptor ¶
func (*PeerOspsResponse) Descriptor() ([]byte, []int)
func (*PeerOspsResponse) GetPeerOsps ¶
func (m *PeerOspsResponse) GetPeerOsps() []*PeerOsp
func (*PeerOspsResponse) ProtoMessage ¶
func (*PeerOspsResponse) ProtoMessage()
func (*PeerOspsResponse) Reset ¶
func (m *PeerOspsResponse) Reset()
func (*PeerOspsResponse) String ¶
func (m *PeerOspsResponse) String() string
func (*PeerOspsResponse) XXX_DiscardUnknown ¶
func (m *PeerOspsResponse) XXX_DiscardUnknown()
func (*PeerOspsResponse) XXX_Marshal ¶
func (m *PeerOspsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeerOspsResponse) XXX_Merge ¶
func (m *PeerOspsResponse) XXX_Merge(src proto.Message)
func (*PeerOspsResponse) XXX_Size ¶
func (m *PeerOspsResponse) XXX_Size() int
func (*PeerOspsResponse) XXX_Unmarshal ¶
func (m *PeerOspsResponse) XXX_Unmarshal(b []byte) error
type PeerStatus ¶
type PeerStatus struct {
FreeBalance string `protobuf:"bytes,1,opt,name=free_balance,json=freeBalance,proto3" json:"free_balance,omitempty"`
JoinStatus JoinCelerStatus `protobuf:"varint,2,opt,name=join_status,json=joinStatus,proto3,enum=rpc.JoinCelerStatus" json:"join_status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 3
func (*PeerStatus) Descriptor ¶
func (*PeerStatus) Descriptor() ([]byte, []int)
func (*PeerStatus) GetFreeBalance ¶
func (m *PeerStatus) GetFreeBalance() string
func (*PeerStatus) GetJoinStatus ¶
func (m *PeerStatus) GetJoinStatus() JoinCelerStatus
func (*PeerStatus) ProtoMessage ¶
func (*PeerStatus) ProtoMessage()
func (*PeerStatus) Reset ¶
func (m *PeerStatus) Reset()
func (*PeerStatus) String ¶
func (m *PeerStatus) String() string
func (*PeerStatus) XXX_DiscardUnknown ¶
func (m *PeerStatus) XXX_DiscardUnknown()
func (*PeerStatus) XXX_Marshal ¶
func (m *PeerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeerStatus) XXX_Merge ¶
func (m *PeerStatus) XXX_Merge(src proto.Message)
func (*PeerStatus) XXX_Size ¶
func (m *PeerStatus) XXX_Size() int
func (*PeerStatus) XXX_Unmarshal ¶
func (m *PeerStatus) XXX_Unmarshal(b []byte) error
type PickReply ¶
type PickReply struct {
Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*PickReply) Descriptor ¶
func (*PickReply) ProtoMessage ¶
func (*PickReply) ProtoMessage()
func (*PickReply) XXX_DiscardUnknown ¶
func (m *PickReply) XXX_DiscardUnknown()
func (*PickReply) XXX_Marshal ¶
func (*PickReply) XXX_Unmarshal ¶
type PickReq ¶
type PickReq struct {
Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*PickReq) Descriptor ¶
func (*PickReq) ProtoMessage ¶
func (*PickReq) ProtoMessage()
func (*PickReq) XXX_DiscardUnknown ¶
func (m *PickReq) XXX_DiscardUnknown()
func (*PickReq) XXX_Marshal ¶
func (*PickReq) XXX_Unmarshal ¶
type PingReply ¶
type PingReply struct {
Numclients uint32 `protobuf:"varint,1,opt,name=numclients,proto3" json:"numclients,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*PingReply) Descriptor ¶
func (*PingReply) GetNumclients ¶
func (*PingReply) ProtoMessage ¶
func (*PingReply) ProtoMessage()
func (*PingReply) XXX_DiscardUnknown ¶
func (m *PingReply) XXX_DiscardUnknown()
func (*PingReply) XXX_Marshal ¶
func (*PingReply) XXX_Unmarshal ¶
type PingReq ¶
type PingReq struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 1
func (*PingReq) Descriptor ¶
func (*PingReq) ProtoMessage ¶
func (*PingReq) ProtoMessage()
func (*PingReq) XXX_DiscardUnknown ¶
func (m *PingReq) XXX_DiscardUnknown()
func (*PingReq) XXX_Marshal ¶
func (*PingReq) XXX_Unmarshal ¶
type QueryDelegationRequest ¶
type QueryDelegationRequest struct {
// delegatee to query delegation.
Delegatee []byte `protobuf:"bytes,1,opt,name=delegatee,proto3" json:"delegatee,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*QueryDelegationRequest) Descriptor ¶
func (*QueryDelegationRequest) Descriptor() ([]byte, []int)
func (*QueryDelegationRequest) GetDelegatee ¶
func (m *QueryDelegationRequest) GetDelegatee() []byte
func (*QueryDelegationRequest) ProtoMessage ¶
func (*QueryDelegationRequest) ProtoMessage()
func (*QueryDelegationRequest) Reset ¶
func (m *QueryDelegationRequest) Reset()
func (*QueryDelegationRequest) String ¶
func (m *QueryDelegationRequest) String() string
func (*QueryDelegationRequest) XXX_DiscardUnknown ¶
func (m *QueryDelegationRequest) XXX_DiscardUnknown()
func (*QueryDelegationRequest) XXX_Marshal ¶
func (m *QueryDelegationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDelegationRequest) XXX_Merge ¶
func (m *QueryDelegationRequest) XXX_Merge(src proto.Message)
func (*QueryDelegationRequest) XXX_Size ¶
func (m *QueryDelegationRequest) XXX_Size() int
func (*QueryDelegationRequest) XXX_Unmarshal ¶
func (m *QueryDelegationRequest) XXX_Unmarshal(b []byte) error
type QueryDelegationResponse ¶
type QueryDelegationResponse struct {
// DelegationProof stored by celer node.
Proof *DelegationProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 2
func (*QueryDelegationResponse) Descriptor ¶
func (*QueryDelegationResponse) Descriptor() ([]byte, []int)
func (*QueryDelegationResponse) GetProof ¶
func (m *QueryDelegationResponse) GetProof() *DelegationProof
func (*QueryDelegationResponse) ProtoMessage ¶
func (*QueryDelegationResponse) ProtoMessage()
func (*QueryDelegationResponse) Reset ¶
func (m *QueryDelegationResponse) Reset()
func (*QueryDelegationResponse) String ¶
func (m *QueryDelegationResponse) String() string
func (*QueryDelegationResponse) XXX_DiscardUnknown ¶
func (m *QueryDelegationResponse) XXX_DiscardUnknown()
func (*QueryDelegationResponse) XXX_Marshal ¶
func (m *QueryDelegationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDelegationResponse) XXX_Merge ¶
func (m *QueryDelegationResponse) XXX_Merge(src proto.Message)
func (*QueryDelegationResponse) XXX_Size ¶
func (m *QueryDelegationResponse) XXX_Size() int
func (*QueryDelegationResponse) XXX_Unmarshal ¶
func (m *QueryDelegationResponse) XXX_Unmarshal(b []byte) error
type QueryDepositRequest ¶
type QueryDepositRequest struct {
DepositId string `protobuf:"bytes,1,opt,name=deposit_id,json=depositId,proto3" json:"deposit_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 2
func (*QueryDepositRequest) Descriptor ¶
func (*QueryDepositRequest) Descriptor() ([]byte, []int)
func (*QueryDepositRequest) GetDepositId ¶
func (m *QueryDepositRequest) GetDepositId() string
func (*QueryDepositRequest) ProtoMessage ¶
func (*QueryDepositRequest) ProtoMessage()
func (*QueryDepositRequest) Reset ¶
func (m *QueryDepositRequest) Reset()
func (*QueryDepositRequest) String ¶
func (m *QueryDepositRequest) String() string
func (*QueryDepositRequest) XXX_DiscardUnknown ¶
func (m *QueryDepositRequest) XXX_DiscardUnknown()
func (*QueryDepositRequest) XXX_Marshal ¶
func (m *QueryDepositRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDepositRequest) XXX_Merge ¶
func (m *QueryDepositRequest) XXX_Merge(src proto.Message)
func (*QueryDepositRequest) XXX_Size ¶
func (m *QueryDepositRequest) XXX_Size() int
func (*QueryDepositRequest) XXX_Unmarshal ¶
func (m *QueryDepositRequest) XXX_Unmarshal(b []byte) error
type QueryDepositResponse ¶
type QueryDepositResponse struct {
DepositState DepositState `protobuf:"varint,1,opt,name=deposit_state,json=depositState,proto3,enum=rpc.DepositState" json:"deposit_state,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 3
func (*QueryDepositResponse) Descriptor ¶
func (*QueryDepositResponse) Descriptor() ([]byte, []int)
func (*QueryDepositResponse) GetDepositState ¶
func (m *QueryDepositResponse) GetDepositState() DepositState
func (*QueryDepositResponse) GetError ¶
func (m *QueryDepositResponse) GetError() string
func (*QueryDepositResponse) ProtoMessage ¶
func (*QueryDepositResponse) ProtoMessage()
func (*QueryDepositResponse) Reset ¶
func (m *QueryDepositResponse) Reset()
func (*QueryDepositResponse) String ¶
func (m *QueryDepositResponse) String() string
func (*QueryDepositResponse) XXX_DiscardUnknown ¶
func (m *QueryDepositResponse) XXX_DiscardUnknown()
func (*QueryDepositResponse) XXX_Marshal ¶
func (m *QueryDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryDepositResponse) XXX_Merge ¶
func (m *QueryDepositResponse) XXX_Merge(src proto.Message)
func (*QueryDepositResponse) XXX_Size ¶
func (m *QueryDepositResponse) XXX_Size() int
func (*QueryDepositResponse) XXX_Unmarshal ¶
func (m *QueryDepositResponse) XXX_Unmarshal(b []byte) error
type RegisterStreamRequest ¶
type RegisterStreamRequest struct {
PeerRpcAddress string `protobuf:"bytes,1,opt,name=peer_rpc_address,json=peerRpcAddress,proto3" json:"peer_rpc_address,omitempty"`
PeerEthAddress []byte `protobuf:"bytes,2,opt,name=peer_eth_address,json=peerEthAddress,proto3" json:"peer_eth_address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 3
func (*RegisterStreamRequest) Descriptor ¶
func (*RegisterStreamRequest) Descriptor() ([]byte, []int)
func (*RegisterStreamRequest) GetPeerEthAddress ¶
func (m *RegisterStreamRequest) GetPeerEthAddress() []byte
func (*RegisterStreamRequest) GetPeerRpcAddress ¶
func (m *RegisterStreamRequest) GetPeerRpcAddress() string
func (*RegisterStreamRequest) ProtoMessage ¶
func (*RegisterStreamRequest) ProtoMessage()
func (*RegisterStreamRequest) Reset ¶
func (m *RegisterStreamRequest) Reset()
func (*RegisterStreamRequest) String ¶
func (m *RegisterStreamRequest) String() string
func (*RegisterStreamRequest) XXX_DiscardUnknown ¶
func (m *RegisterStreamRequest) XXX_DiscardUnknown()
func (*RegisterStreamRequest) XXX_Marshal ¶
func (m *RegisterStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterStreamRequest) XXX_Merge ¶
func (m *RegisterStreamRequest) XXX_Merge(src proto.Message)
func (*RegisterStreamRequest) XXX_Size ¶
func (m *RegisterStreamRequest) XXX_Size() int
func (*RegisterStreamRequest) XXX_Unmarshal ¶
func (m *RegisterStreamRequest) XXX_Unmarshal(b []byte) error
type RevealSecret ¶
type RevealSecret struct {
PayId []byte `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
// preimage of the hash
Secret []byte `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
// used for cross net pay
OriginalPayId []byte `protobuf:"bytes,3,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RevealSecret) Descriptor ¶
func (*RevealSecret) Descriptor() ([]byte, []int)
func (*RevealSecret) GetOriginalPayId ¶
func (m *RevealSecret) GetOriginalPayId() []byte
func (*RevealSecret) GetPayId ¶
func (m *RevealSecret) GetPayId() []byte
func (*RevealSecret) GetSecret ¶
func (m *RevealSecret) GetSecret() []byte
func (*RevealSecret) ProtoMessage ¶
func (*RevealSecret) ProtoMessage()
func (*RevealSecret) Reset ¶
func (m *RevealSecret) Reset()
func (*RevealSecret) String ¶
func (m *RevealSecret) String() string
func (*RevealSecret) XXX_DiscardUnknown ¶
func (m *RevealSecret) XXX_DiscardUnknown()
func (*RevealSecret) XXX_Marshal ¶
func (m *RevealSecret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RevealSecret) XXX_Merge ¶
func (m *RevealSecret) XXX_Merge(src proto.Message)
func (*RevealSecret) XXX_Size ¶
func (m *RevealSecret) XXX_Size() int
func (*RevealSecret) XXX_Unmarshal ¶
func (m *RevealSecret) XXX_Unmarshal(b []byte) error
type RevealSecretAck ¶
type RevealSecretAck struct {
// include pay_id for avoid preimage->pay reverse lookup
PayId []byte `protobuf:"bytes,1,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
// pay dest sign secret to avoid spoof
PayDestSecretSig []byte `protobuf:"bytes,2,opt,name=pay_dest_secret_sig,json=payDestSecretSig,proto3" json:"pay_dest_secret_sig,omitempty"`
// used for cross net pay
OriginalPayId []byte `protobuf:"bytes,3,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RevealSecretAck) Descriptor ¶
func (*RevealSecretAck) Descriptor() ([]byte, []int)
func (*RevealSecretAck) GetOriginalPayId ¶
func (m *RevealSecretAck) GetOriginalPayId() []byte
func (*RevealSecretAck) GetPayDestSecretSig ¶
func (m *RevealSecretAck) GetPayDestSecretSig() []byte
func (*RevealSecretAck) GetPayId ¶
func (m *RevealSecretAck) GetPayId() []byte
func (*RevealSecretAck) ProtoMessage ¶
func (*RevealSecretAck) ProtoMessage()
func (*RevealSecretAck) Reset ¶
func (m *RevealSecretAck) Reset()
func (*RevealSecretAck) String ¶
func (m *RevealSecretAck) String() string
func (*RevealSecretAck) XXX_DiscardUnknown ¶
func (m *RevealSecretAck) XXX_DiscardUnknown()
func (*RevealSecretAck) XXX_Marshal ¶
func (m *RevealSecretAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RevealSecretAck) XXX_Merge ¶
func (m *RevealSecretAck) XXX_Merge(src proto.Message)
func (*RevealSecretAck) XXX_Size ¶
func (m *RevealSecretAck) XXX_Size() int
func (*RevealSecretAck) XXX_Unmarshal ¶
func (m *RevealSecretAck) XXX_Unmarshal(b []byte) error
type RoutingRequest ¶
type RoutingRequest struct {
// list of routing updates
Updates []*SignedRoutingUpdate `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
// OSP that sent (propagated) this information.
Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 3
func (*RoutingRequest) Descriptor ¶
func (*RoutingRequest) Descriptor() ([]byte, []int)
func (*RoutingRequest) GetSender ¶
func (m *RoutingRequest) GetSender() string
func (*RoutingRequest) GetUpdates ¶
func (m *RoutingRequest) GetUpdates() []*SignedRoutingUpdate
func (*RoutingRequest) ProtoMessage ¶
func (*RoutingRequest) ProtoMessage()
func (*RoutingRequest) Reset ¶
func (m *RoutingRequest) Reset()
func (*RoutingRequest) String ¶
func (m *RoutingRequest) String() string
func (*RoutingRequest) XXX_DiscardUnknown ¶
func (m *RoutingRequest) XXX_DiscardUnknown()
func (*RoutingRequest) XXX_Marshal ¶
func (m *RoutingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoutingRequest) XXX_Merge ¶
func (m *RoutingRequest) XXX_Merge(src proto.Message)
func (*RoutingRequest) XXX_Size ¶
func (m *RoutingRequest) XXX_Size() int
func (*RoutingRequest) XXX_Unmarshal ¶
func (m *RoutingRequest) XXX_Unmarshal(b []byte) error
type RoutingUpdate ¶
type RoutingUpdate struct {
// origin source OSP for this information.
Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
// timestamp of this information at the origin.
Ts uint64 `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
// channel information
Channels []*ChannelRoutingInfo `protobuf:"bytes,3,rep,name=channels,proto3" json:"channels,omitempty"`
// routing protocol version number
ProtoVersion uint64 `protobuf:"varint,4,opt,name=proto_version,json=protoVersion,proto3" json:"proto_version,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 5
func (*RoutingUpdate) Descriptor ¶
func (*RoutingUpdate) Descriptor() ([]byte, []int)
func (*RoutingUpdate) GetChannels ¶
func (m *RoutingUpdate) GetChannels() []*ChannelRoutingInfo
func (*RoutingUpdate) GetOrigin ¶
func (m *RoutingUpdate) GetOrigin() string
func (*RoutingUpdate) GetProtoVersion ¶
func (m *RoutingUpdate) GetProtoVersion() uint64
func (*RoutingUpdate) GetTs ¶
func (m *RoutingUpdate) GetTs() uint64
func (*RoutingUpdate) ProtoMessage ¶
func (*RoutingUpdate) ProtoMessage()
func (*RoutingUpdate) Reset ¶
func (m *RoutingUpdate) Reset()
func (*RoutingUpdate) String ¶
func (m *RoutingUpdate) String() string
func (*RoutingUpdate) XXX_DiscardUnknown ¶
func (m *RoutingUpdate) XXX_DiscardUnknown()
func (*RoutingUpdate) XXX_Marshal ¶
func (m *RoutingUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoutingUpdate) XXX_Merge ¶
func (m *RoutingUpdate) XXX_Merge(src proto.Message)
func (*RoutingUpdate) XXX_Size ¶
func (m *RoutingUpdate) XXX_Size() int
func (*RoutingUpdate) XXX_Unmarshal ¶
func (m *RoutingUpdate) XXX_Unmarshal(b []byte) error
type RpcClient ¶
type RpcClient interface {
GetPayHistory(ctx context.Context, in *GetPayHistoryRequest, opts ...grpc.CallOption) (*GetPayHistoryResponse, error)
QueryDelegation(ctx context.Context, in *QueryDelegationRequest, opts ...grpc.CallOption) (*QueryDelegationResponse, error)
RequestDelegation(ctx context.Context, in *DelegationRequest, opts ...grpc.CallOption) (*DelegationResponse, error)
CelerOpenChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error)
CelerOpenTcbChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error)
CelerGetPeerStatus(ctx context.Context, in *PeerAddress, opts ...grpc.CallOption) (*PeerStatus, error)
// unified offchain bidi streaming rpc and msg definition
CelerStream(ctx context.Context, opts ...grpc.CallOption) (Rpc_CelerStreamClient, error)
CelerMigrateChannel(ctx context.Context, in *MigrateChannelRequest, opts ...grpc.CallOption) (*MigrateChannelResponse, error)
}
RpcClient is the client API for Rpc service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRpcClient ¶
func NewRpcClient(cc *grpc.ClientConn) RpcClient
type RpcServer ¶
type RpcServer interface {
GetPayHistory(context.Context, *GetPayHistoryRequest) (*GetPayHistoryResponse, error)
QueryDelegation(context.Context, *QueryDelegationRequest) (*QueryDelegationResponse, error)
RequestDelegation(context.Context, *DelegationRequest) (*DelegationResponse, error)
CelerOpenChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)
CelerOpenTcbChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)
CelerGetPeerStatus(context.Context, *PeerAddress) (*PeerStatus, error)
// unified offchain bidi streaming rpc and msg definition
CelerStream(Rpc_CelerStreamServer) error
CelerMigrateChannel(context.Context, *MigrateChannelRequest) (*MigrateChannelResponse, error)
}
RpcServer is the server API for Rpc service.
type Rpc_CelerOneServer ¶
type Rpc_CelerStreamClient ¶
type Rpc_CelerStreamServer ¶
type SafeSendCelerStream ¶
type SafeSendCelerStream struct {
// contains filtered or unexported fields
}
func (*SafeSendCelerStream) SafeSend ¶
func (s *SafeSendCelerStream) SafeSend(msg *CelerMsg) error
type SendTokenRequest ¶
type SendTokenRequest struct {
DstAddr string `protobuf:"bytes,1,opt,name=dst_addr,json=dstAddr,proto3" json:"dst_addr,omitempty"`
AmtWei string `protobuf:"bytes,2,opt,name=amt_wei,json=amtWei,proto3" json:"amt_wei,omitempty"`
TokenAddr string `protobuf:"bytes,3,opt,name=token_addr,json=tokenAddr,proto3" json:"token_addr,omitempty"`
Note *any.Any `protobuf:"bytes,4,opt,name=note,proto3" json:"note,omitempty"`
DstNetId uint64 `protobuf:"varint,5,opt,name=dst_net_id,json=dstNetId,proto3" json:"dst_net_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 5
func (*SendTokenRequest) Descriptor ¶
func (*SendTokenRequest) Descriptor() ([]byte, []int)
func (*SendTokenRequest) GetAmtWei ¶
func (m *SendTokenRequest) GetAmtWei() string
func (*SendTokenRequest) GetDstAddr ¶
func (m *SendTokenRequest) GetDstAddr() string
func (*SendTokenRequest) GetDstNetId ¶
func (m *SendTokenRequest) GetDstNetId() uint64
func (*SendTokenRequest) GetNote ¶
func (m *SendTokenRequest) GetNote() *any.Any
func (*SendTokenRequest) GetTokenAddr ¶
func (m *SendTokenRequest) GetTokenAddr() string
func (*SendTokenRequest) ProtoMessage ¶
func (*SendTokenRequest) ProtoMessage()
func (*SendTokenRequest) Reset ¶
func (m *SendTokenRequest) Reset()
func (*SendTokenRequest) String ¶
func (m *SendTokenRequest) String() string
func (*SendTokenRequest) XXX_DiscardUnknown ¶
func (m *SendTokenRequest) XXX_DiscardUnknown()
func (*SendTokenRequest) XXX_Marshal ¶
func (m *SendTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendTokenRequest) XXX_Merge ¶
func (m *SendTokenRequest) XXX_Merge(src proto.Message)
func (*SendTokenRequest) XXX_Size ¶
func (m *SendTokenRequest) XXX_Size() int
func (*SendTokenRequest) XXX_Unmarshal ¶
func (m *SendTokenRequest) XXX_Unmarshal(b []byte) error
type SendTokenResponse ¶
type SendTokenResponse 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"`
PayId string `protobuf:"bytes,3,opt,name=pay_id,json=payId,proto3" json:"pay_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 4
func (*SendTokenResponse) Descriptor ¶
func (*SendTokenResponse) Descriptor() ([]byte, []int)
func (*SendTokenResponse) GetError ¶
func (m *SendTokenResponse) GetError() string
func (*SendTokenResponse) GetPayId ¶
func (m *SendTokenResponse) GetPayId() string
func (*SendTokenResponse) GetStatus ¶
func (m *SendTokenResponse) GetStatus() int32
func (*SendTokenResponse) ProtoMessage ¶
func (*SendTokenResponse) ProtoMessage()
func (*SendTokenResponse) Reset ¶
func (m *SendTokenResponse) Reset()
func (*SendTokenResponse) String ¶
func (m *SendTokenResponse) String() string
func (*SendTokenResponse) XXX_DiscardUnknown ¶
func (m *SendTokenResponse) XXX_DiscardUnknown()
func (*SendTokenResponse) XXX_Marshal ¶
func (m *SendTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendTokenResponse) XXX_Merge ¶
func (m *SendTokenResponse) XXX_Merge(src proto.Message)
func (*SendTokenResponse) XXX_Size ¶
func (m *SendTokenResponse) XXX_Size() int
func (*SendTokenResponse) XXX_Unmarshal ¶
func (m *SendTokenResponse) XXX_Unmarshal(b []byte) error
type SettledPayment ¶
type SettledPayment struct {
SettledPayId []byte `protobuf:"bytes,1,opt,name=settled_pay_id,json=settledPayId,proto3" json:"settled_pay_id,omitempty"`
Reason PaymentSettleReason `protobuf:"varint,2,opt,name=reason,proto3,enum=rpc.PaymentSettleReason" json:"reason,omitempty"`
Amount []byte `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
// used in pay settle proof to track path for failed payments
Path *PayPath `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
// used for cross net pay
OriginalPayId []byte `protobuf:"bytes,5,opt,name=original_pay_id,json=originalPayId,proto3" json:"original_pay_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 5
func (*SettledPayment) Descriptor ¶
func (*SettledPayment) Descriptor() ([]byte, []int)
func (*SettledPayment) GetAmount ¶
func (m *SettledPayment) GetAmount() []byte
func (*SettledPayment) GetOriginalPayId ¶
func (m *SettledPayment) GetOriginalPayId() []byte
func (*SettledPayment) GetPath ¶
func (m *SettledPayment) GetPath() *PayPath
func (*SettledPayment) GetReason ¶
func (m *SettledPayment) GetReason() PaymentSettleReason
func (*SettledPayment) GetSettledPayId ¶
func (m *SettledPayment) GetSettledPayId() []byte
func (*SettledPayment) ProtoMessage ¶
func (*SettledPayment) ProtoMessage()
func (*SettledPayment) Reset ¶
func (m *SettledPayment) Reset()
func (*SettledPayment) String ¶
func (m *SettledPayment) String() string
func (*SettledPayment) XXX_DiscardUnknown ¶
func (m *SettledPayment) XXX_DiscardUnknown()
func (*SettledPayment) XXX_Marshal ¶
func (m *SettledPayment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SettledPayment) XXX_Merge ¶
func (m *SettledPayment) XXX_Merge(src proto.Message)
func (*SettledPayment) XXX_Size ¶
func (m *SettledPayment) XXX_Size() int
func (*SettledPayment) XXX_Unmarshal ¶
func (m *SettledPayment) XXX_Unmarshal(b []byte) error
type SignedDuplexState ¶
type SignedDuplexState struct {
// only expect two messages for duplex
SimplexStates []*SignedSimplexState `protobuf:"bytes,1,rep,name=simplex_states,json=simplexStates,proto3" json:"simplex_states,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 2
func (*SignedDuplexState) Descriptor ¶
func (*SignedDuplexState) Descriptor() ([]byte, []int)
func (*SignedDuplexState) GetSimplexStates ¶
func (m *SignedDuplexState) GetSimplexStates() []*SignedSimplexState
func (*SignedDuplexState) ProtoMessage ¶
func (*SignedDuplexState) ProtoMessage()
func (*SignedDuplexState) Reset ¶
func (m *SignedDuplexState) Reset()
func (*SignedDuplexState) String ¶
func (m *SignedDuplexState) String() string
func (*SignedDuplexState) XXX_DiscardUnknown ¶
func (m *SignedDuplexState) XXX_DiscardUnknown()
func (*SignedDuplexState) XXX_Marshal ¶
func (m *SignedDuplexState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SignedDuplexState) XXX_Merge ¶
func (m *SignedDuplexState) XXX_Merge(src proto.Message)
func (*SignedDuplexState) XXX_Size ¶
func (m *SignedDuplexState) XXX_Size() int
func (*SignedDuplexState) XXX_Unmarshal ¶
func (m *SignedDuplexState) XXX_Unmarshal(b []byte) error
type SignedPayHop ¶
type SignedPayHop struct {
PayHopBytes []byte `protobuf:"bytes,1,opt,name=pay_hop_bytes,json=payHopBytes,proto3" json:"pay_hop_bytes,omitempty"`
Sig []byte `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 3
func (*SignedPayHop) Descriptor ¶
func (*SignedPayHop) Descriptor() ([]byte, []int)
func (*SignedPayHop) GetPayHopBytes ¶
func (m *SignedPayHop) GetPayHopBytes() []byte
func (*SignedPayHop) GetSig ¶
func (m *SignedPayHop) GetSig() []byte
func (*SignedPayHop) ProtoMessage ¶
func (*SignedPayHop) ProtoMessage()
func (*SignedPayHop) Reset ¶
func (m *SignedPayHop) Reset()
func (*SignedPayHop) String ¶
func (m *SignedPayHop) String() string
func (*SignedPayHop) XXX_DiscardUnknown ¶
func (m *SignedPayHop) XXX_DiscardUnknown()
func (*SignedPayHop) XXX_Marshal ¶
func (m *SignedPayHop) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SignedPayHop) XXX_Merge ¶
func (m *SignedPayHop) XXX_Merge(src proto.Message)
func (*SignedPayHop) XXX_Size ¶
func (m *SignedPayHop) XXX_Size() int
func (*SignedPayHop) XXX_Unmarshal ¶
func (m *SignedPayHop) XXX_Unmarshal(b []byte) error
type SignedRoutingUpdate ¶
type SignedRoutingUpdate struct {
// serialized RoutingUpdate
Update []byte `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
// sig of serialized RoutingUpdate by origin
Sig []byte `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"`
// time to live: decreasing hop count to stop the broadcast.
Ttl uint64 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next tag: 4
func (*SignedRoutingUpdate) Descriptor ¶
func (*SignedRoutingUpdate) Descriptor() ([]byte, []int)
func (*SignedRoutingUpdate) GetSig ¶
func (m *SignedRoutingUpdate) GetSig() []byte
func (*SignedRoutingUpdate) GetTtl ¶
func (m *SignedRoutingUpdate) GetTtl() uint64
func (*SignedRoutingUpdate) GetUpdate ¶
func (m *SignedRoutingUpdate) GetUpdate() []byte
func (*SignedRoutingUpdate) ProtoMessage ¶
func (*SignedRoutingUpdate) ProtoMessage()
func (*SignedRoutingUpdate) Reset ¶
func (m *SignedRoutingUpdate) Reset()
func (*SignedRoutingUpdate) String ¶
func (m *SignedRoutingUpdate) String() string
func (*SignedRoutingUpdate) XXX_DiscardUnknown ¶
func (m *SignedRoutingUpdate) XXX_DiscardUnknown()
func (*SignedRoutingUpdate) XXX_Marshal ¶
func (m *SignedRoutingUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SignedRoutingUpdate) XXX_Merge ¶
func (m *SignedRoutingUpdate) XXX_Merge(src proto.Message)
func (*SignedRoutingUpdate) XXX_Size ¶
func (m *SignedRoutingUpdate) XXX_Size() int
func (*SignedRoutingUpdate) XXX_Unmarshal ¶
func (m *SignedRoutingUpdate) XXX_Unmarshal(b []byte) error
type SignedSimplexState ¶
type SignedSimplexState struct {
// serialized simplexPaymentChannel message
SimplexState []byte `protobuf:"bytes,1,opt,name=simplex_state,json=simplexState,proto3" json:"simplex_state,omitempty"`
SigOfPeerFrom []byte `protobuf:"bytes,2,opt,name=sig_of_peer_from,json=sigOfPeerFrom,proto3" json:"sig_of_peer_from,omitempty"`
SigOfPeerTo []byte `protobuf:"bytes,3,opt,name=sig_of_peer_to,json=sigOfPeerTo,proto3" json:"sig_of_peer_to,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Next Tag: 4
func (*SignedSimplexState) Descriptor ¶
func (*SignedSimplexState) Descriptor() ([]byte, []int)
func (*SignedSimplexState) GetSigOfPeerFrom ¶
func (m *SignedSimplexState) GetSigOfPeerFrom() []byte
func (*SignedSimplexState) GetSigOfPeerTo ¶
func (m *SignedSimplexState) GetSigOfPeerTo() []byte
func (*SignedSimplexState) GetSimplexState ¶
func (m *SignedSimplexState) GetSimplexState() []byte
func (*SignedSimplexState) ProtoMessage ¶
func (*SignedSimplexState) ProtoMessage()
func (*SignedSimplexState) Reset ¶
func (m *SignedSimplexState) Reset()
func (*SignedSimplexState) String ¶
func (m *SignedSimplexState) String() string
func (*SignedSimplexState) XXX_DiscardUnknown ¶
func (m *SignedSimplexState) XXX_DiscardUnknown()
func (*SignedSimplexState) XXX_Marshal ¶
func (m *SignedSimplexState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SignedSimplexState) XXX_Merge ¶
func (m *SignedSimplexState) XXX_Merge(src proto.Message)
func (*SignedSimplexState) XXX_Size ¶
func (m *SignedSimplexState) XXX_Size() int
func (*SignedSimplexState) XXX_Unmarshal ¶
func (m *SignedSimplexState) XXX_Unmarshal(b []byte) error
type TokenCidPair ¶
type TokenCidPair struct {
TokenAddress string `protobuf:"bytes,1,opt,name=token_address,json=tokenAddress,proto3" json:"token_address,omitempty"`
Cid string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*TokenCidPair) Descriptor ¶
func (*TokenCidPair) Descriptor() ([]byte, []int)
func (*TokenCidPair) GetCid ¶
func (m *TokenCidPair) GetCid() string
func (*TokenCidPair) GetTokenAddress ¶
func (m *TokenCidPair) GetTokenAddress() string
func (*TokenCidPair) ProtoMessage ¶
func (*TokenCidPair) ProtoMessage()
func (*TokenCidPair) Reset ¶
func (m *TokenCidPair) Reset()
func (*TokenCidPair) String ¶
func (m *TokenCidPair) String() string
func (*TokenCidPair) XXX_DiscardUnknown ¶
func (m *TokenCidPair) XXX_DiscardUnknown()
func (*TokenCidPair) XXX_Marshal ¶
func (m *TokenCidPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TokenCidPair) XXX_Merge ¶
func (m *TokenCidPair) XXX_Merge(src proto.Message)
func (*TokenCidPair) XXX_Size ¶
func (m *TokenCidPair) XXX_Size() int
func (*TokenCidPair) XXX_Unmarshal ¶
func (m *TokenCidPair) XXX_Unmarshal(b []byte) error
type UnimplementedAdminServer ¶
type UnimplementedAdminServer struct {
}
UnimplementedAdminServer can be embedded to have forward compatible implementations.
func (*UnimplementedAdminServer) BuildRoutingTable ¶
func (*UnimplementedAdminServer) BuildRoutingTable(ctx context.Context, req *BuildRoutingTableRequest) (*empty.Empty, error)
func (*UnimplementedAdminServer) ClearExpiredPaysWithPeerOsps ¶
func (*UnimplementedAdminServer) ClearExpiredPaysWithPeerOsps(ctx context.Context, req *ClearExpiredPaysRequest) (*empty.Empty, error)
func (*UnimplementedAdminServer) ConfirmOnChainResolvedPaysWithPeerOsps ¶
func (*UnimplementedAdminServer) ConfirmOnChainResolvedPaysWithPeerOsps(ctx context.Context, req *ConfirmOnChainResolvedPaysRequest) (*empty.Empty, error)
func (*UnimplementedAdminServer) CooperativeSettle ¶
func (*UnimplementedAdminServer) CooperativeSettle(ctx context.Context, req *ChannelOpRequest) (*ChannelOpResponse, error)
func (*UnimplementedAdminServer) CooperativeWithdraw ¶
func (*UnimplementedAdminServer) CooperativeWithdraw(ctx context.Context, req *ChannelOpRequest) (*ChannelOpResponse, error)
func (*UnimplementedAdminServer) Deposit ¶
func (*UnimplementedAdminServer) Deposit(ctx context.Context, req *DepositRequest) (*DepositResponse, error)
func (*UnimplementedAdminServer) GetPeerOsps ¶
func (*UnimplementedAdminServer) GetPeerOsps(ctx context.Context, req *empty.Empty) (*PeerOspsResponse, error)
func (*UnimplementedAdminServer) OspOpenChannel ¶
func (*UnimplementedAdminServer) OspOpenChannel(ctx context.Context, req *OspOpenChannelRequest) (*empty.Empty, error)
func (*UnimplementedAdminServer) QueryDeposit ¶
func (*UnimplementedAdminServer) QueryDeposit(ctx context.Context, req *QueryDepositRequest) (*QueryDepositResponse, error)
func (*UnimplementedAdminServer) RecvBcastRoutingInfo ¶
func (*UnimplementedAdminServer) RecvBcastRoutingInfo(ctx context.Context, req *RoutingRequest) (*empty.Empty, error)
func (*UnimplementedAdminServer) RegisterStream ¶
func (*UnimplementedAdminServer) RegisterStream(ctx context.Context, req *RegisterStreamRequest) (*empty.Empty, error)
func (*UnimplementedAdminServer) SendToken ¶
func (*UnimplementedAdminServer) SendToken(ctx context.Context, req *SendTokenRequest) (*SendTokenResponse, error)
type UnimplementedMultiServerServer ¶
type UnimplementedMultiServerServer struct {
}
UnimplementedMultiServerServer can be embedded to have forward compatible implementations.
func (*UnimplementedMultiServerServer) BcastRoutingInfo ¶
func (*UnimplementedMultiServerServer) BcastRoutingInfo(ctx context.Context, req *BcastRoutingRequest) (*BcastRoutingReply, error)
func (*UnimplementedMultiServerServer) PickServer ¶
type UnimplementedRpcServer ¶
type UnimplementedRpcServer struct {
}
UnimplementedRpcServer can be embedded to have forward compatible implementations.
func (*UnimplementedRpcServer) CelerGetPeerStatus ¶
func (*UnimplementedRpcServer) CelerGetPeerStatus(ctx context.Context, req *PeerAddress) (*PeerStatus, error)
func (*UnimplementedRpcServer) CelerMigrateChannel ¶
func (*UnimplementedRpcServer) CelerMigrateChannel(ctx context.Context, req *MigrateChannelRequest) (*MigrateChannelResponse, error)
func (*UnimplementedRpcServer) CelerOpenChannel ¶
func (*UnimplementedRpcServer) CelerOpenChannel(ctx context.Context, req *OpenChannelRequest) (*OpenChannelResponse, error)
func (*UnimplementedRpcServer) CelerOpenTcbChannel ¶
func (*UnimplementedRpcServer) CelerOpenTcbChannel(ctx context.Context, req *OpenChannelRequest) (*OpenChannelResponse, error)
func (*UnimplementedRpcServer) CelerStream ¶
func (*UnimplementedRpcServer) CelerStream(srv Rpc_CelerStreamServer) error
func (*UnimplementedRpcServer) GetPayHistory ¶
func (*UnimplementedRpcServer) GetPayHistory(ctx context.Context, req *GetPayHistoryRequest) (*GetPayHistoryResponse, error)
func (*UnimplementedRpcServer) QueryDelegation ¶
func (*UnimplementedRpcServer) QueryDelegation(ctx context.Context, req *QueryDelegationRequest) (*QueryDelegationResponse, error)
func (*UnimplementedRpcServer) RequestDelegation ¶
func (*UnimplementedRpcServer) RequestDelegation(ctx context.Context, req *DelegationRequest) (*DelegationResponse, error)