rpc

package

Go to main page

Versions in this module

v1

v1.2.1

May 2, 2026

v1.2.0

May 2, 2026

v1.1.1

Apr 30, 2026

v1.1.0

Apr 16, 2026

Changes in this version

+ var File_message_proto protoreflect.FileDescriptor

+ var File_multiserver_proto protoreflect.FileDescriptor

+ var File_osp_admin_proto protoreflect.FileDescriptor

+ var File_rpc_proto protoreflect.FileDescriptor

type AuthAck

+ func (x *AuthAck) ProtoReflect() protoreflect.Message

type AuthReq

+ func (x *AuthReq) ProtoReflect() protoreflect.Message

type BcastRoutingReply

+ func (x *BcastRoutingReply) ProtoReflect() protoreflect.Message

type BcastRoutingRequest

+ func (x *BcastRoutingRequest) ProtoReflect() protoreflect.Message

type BuildRoutingTableRequest

+ func (x *BuildRoutingTableRequest) ProtoReflect() protoreflect.Message

type CelerMsg

+ func (x *CelerMsg) ProtoReflect() protoreflect.Message

type ChannelInAuth

+ func (x *ChannelInAuth) ProtoReflect() protoreflect.Message

type ChannelOpRequest

+ func (x *ChannelOpRequest) ProtoReflect() protoreflect.Message

type ChannelOpResponse

+ func (x *ChannelOpResponse) ProtoReflect() protoreflect.Message

type ChannelRoutingInfo

+ func (x *ChannelRoutingInfo) ProtoReflect() protoreflect.Message

type ChannelSummary

+ func (x *ChannelSummary) ProtoReflect() protoreflect.Message

type ClearExpiredPaysRequest

+ func (x *ClearExpiredPaysRequest) ProtoReflect() protoreflect.Message

type CondPayReceipt

+ func (x *CondPayReceipt) ProtoReflect() protoreflect.Message

type CondPayRequest

+ func (x *CondPayRequest) ProtoReflect() protoreflect.Message

type CondPayResponse

+ func (x *CondPayResponse) ProtoReflect() protoreflect.Message

type ConfirmOnChainResolvedPaysRequest

+ func (x *ConfirmOnChainResolvedPaysRequest) ProtoReflect() protoreflect.Message

type CooperativeWithdrawRequest

+ func (x *CooperativeWithdrawRequest) ProtoReflect() protoreflect.Message

type CooperativeWithdrawResponse

+ func (x *CooperativeWithdrawResponse) ProtoReflect() protoreflect.Message

type CrossNetPay

+ func (x *CrossNetPay) ProtoReflect() protoreflect.Message

type DelegationDescription

+ func (x *DelegationDescription) ProtoReflect() protoreflect.Message

type DelegationProof

+ func (x *DelegationProof) ProtoReflect() protoreflect.Message

type DelegationRequest

+ func (x *DelegationRequest) ProtoReflect() protoreflect.Message

type DelegationResponse

+ func (x *DelegationResponse) ProtoReflect() protoreflect.Message

type DepositRequest

+ func (x *DepositRequest) ProtoReflect() protoreflect.Message

type DepositResponse

+ func (x *DepositResponse) ProtoReflect() protoreflect.Message

type DepositState

+ func (DepositState) Descriptor() protoreflect.EnumDescriptor

+ func (DepositState) Type() protoreflect.EnumType

+ func (x DepositState) Enum() *DepositState

+ func (x DepositState) Number() protoreflect.EnumNumber

type ErrCode

+ func (ErrCode) Descriptor() protoreflect.EnumDescriptor

+ func (ErrCode) Type() protoreflect.EnumType

+ func (x ErrCode) Enum() *ErrCode

+ func (x ErrCode) Number() protoreflect.EnumNumber

type Error

+ func (x *Error) ProtoReflect() protoreflect.Message

type FwdReply

+ func (x *FwdReply) ProtoReflect() protoreflect.Message

type FwdReq

+ func (x *FwdReq) ProtoReflect() protoreflect.Message

type GetPayHistoryRequest

+ func (x *GetPayHistoryRequest) ProtoReflect() protoreflect.Message

type GetPayHistoryResponse

+ func (x *GetPayHistoryResponse) ProtoReflect() protoreflect.Message

type JoinCelerStatus

+ func (JoinCelerStatus) Descriptor() protoreflect.EnumDescriptor

+ func (JoinCelerStatus) Type() protoreflect.EnumType

+ func (x JoinCelerStatus) Enum() *JoinCelerStatus

+ func (x JoinCelerStatus) Number() protoreflect.EnumNumber

type MID

+ func (x *MID) ProtoReflect() protoreflect.Message

type MigrateChannelRequest

+ func (x *MigrateChannelRequest) ProtoReflect() protoreflect.Message

type MigrateChannelResponse

+ func (x *MigrateChannelResponse) ProtoReflect() protoreflect.Message

type OneHistoricalPay

+ func (x *OneHistoricalPay) ProtoReflect() protoreflect.Message

type OpenChannelBy

+ func (OpenChannelBy) Descriptor() protoreflect.EnumDescriptor

+ func (OpenChannelBy) Type() protoreflect.EnumType

+ func (x OpenChannelBy) Enum() *OpenChannelBy

+ func (x OpenChannelBy) Number() protoreflect.EnumNumber

type OpenChannelRequest

+ func (x *OpenChannelRequest) ProtoReflect() protoreflect.Message

type OpenChannelResponse

+ func (x *OpenChannelResponse) ProtoReflect() protoreflect.Message

type OpenChannelStatus

+ func (OpenChannelStatus) Descriptor() protoreflect.EnumDescriptor

+ func (OpenChannelStatus) Type() protoreflect.EnumType

+ func (x OpenChannelStatus) Enum() *OpenChannelStatus

+ func (x OpenChannelStatus) Number() protoreflect.EnumNumber

type OspOpenChannelRequest

+ func (x *OspOpenChannelRequest) ProtoReflect() protoreflect.Message

type PayHop

+ func (x *PayHop) ProtoReflect() protoreflect.Message

type PayInAuthAck

+ func (x *PayInAuthAck) ProtoReflect() protoreflect.Message

type PayPath

+ func (x *PayPath) ProtoReflect() protoreflect.Message

type PaymentSettleProof

+ func (x *PaymentSettleProof) ProtoReflect() protoreflect.Message

type PaymentSettleReason

+ func (PaymentSettleReason) Descriptor() protoreflect.EnumDescriptor

+ func (PaymentSettleReason) Type() protoreflect.EnumType

+ func (x PaymentSettleReason) Enum() *PaymentSettleReason

+ func (x PaymentSettleReason) Number() protoreflect.EnumNumber

type PaymentSettleRequest

+ func (x *PaymentSettleRequest) ProtoReflect() protoreflect.Message

type PaymentSettleResponse

+ func (x *PaymentSettleResponse) ProtoReflect() protoreflect.Message

type PeerAddress

+ func (x *PeerAddress) ProtoReflect() protoreflect.Message

type PeerOsp

+ func (x *PeerOsp) ProtoReflect() protoreflect.Message

type PeerOspsResponse

+ func (x *PeerOspsResponse) ProtoReflect() protoreflect.Message

type PeerStatus

+ func (x *PeerStatus) ProtoReflect() protoreflect.Message

type PickReply

+ func (x *PickReply) ProtoReflect() protoreflect.Message

type PickReq

+ func (x *PickReq) ProtoReflect() protoreflect.Message

type PingReply

+ func (x *PingReply) ProtoReflect() protoreflect.Message

type PingReq

+ func (x *PingReq) ProtoReflect() protoreflect.Message

type QueryDelegationRequest

+ func (x *QueryDelegationRequest) ProtoReflect() protoreflect.Message

type QueryDelegationResponse

+ func (x *QueryDelegationResponse) ProtoReflect() protoreflect.Message

type QueryDepositRequest

+ func (x *QueryDepositRequest) ProtoReflect() protoreflect.Message

type QueryDepositResponse

+ func (x *QueryDepositResponse) ProtoReflect() protoreflect.Message

type RegisterStreamRequest

+ func (x *RegisterStreamRequest) ProtoReflect() protoreflect.Message

type RevealSecret

+ func (x *RevealSecret) ProtoReflect() protoreflect.Message

type RevealSecretAck

+ func (x *RevealSecretAck) ProtoReflect() protoreflect.Message

type RoutingRequest

+ func (x *RoutingRequest) ProtoReflect() protoreflect.Message

type RoutingUpdate

+ func (x *RoutingUpdate) ProtoReflect() protoreflect.Message

type SendTokenRequest

+ func (x *SendTokenRequest) ProtoReflect() protoreflect.Message

type SendTokenResponse

+ func (x *SendTokenResponse) ProtoReflect() protoreflect.Message

type SettledPayment

+ func (x *SettledPayment) ProtoReflect() protoreflect.Message

type SignedDuplexState

+ func (x *SignedDuplexState) ProtoReflect() protoreflect.Message

type SignedPayHop

+ func (x *SignedPayHop) ProtoReflect() protoreflect.Message

type SignedRoutingUpdate

+ func (x *SignedRoutingUpdate) ProtoReflect() protoreflect.Message

type SignedSimplexState

+ func (x *SignedSimplexState) ProtoReflect() protoreflect.Message

type TokenCidPair

+ func (x *TokenCidPair) ProtoReflect() protoreflect.Message

+ type UnsafeAdminServer interface

+ type UnsafeMultiServerServer interface

+ type UnsafeRpcServer interface

v1.0.0

Nov 2, 2025

Changes in this version

+ var DepositState_name = map[int32]string

+ var DepositState_value = map[string]int32

+ var ErrCode_name = map[int32]string

+ var ErrCode_value = map[string]int32

+ var JoinCelerStatus_name = map[int32]string

+ var JoinCelerStatus_value = map[string]int32

+ var OpenChannelBy_name = map[int32]string

+ var OpenChannelBy_value = map[string]int32

+ var OpenChannelStatus_name = map[int32]string

+ var OpenChannelStatus_value = map[string]int32

+ var PaymentSettleReason_name = map[int32]string

+ var PaymentSettleReason_value = map[string]int32

+ 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 interface

+ BuildRoutingTable func(ctx context.Context, in *BuildRoutingTableRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ ClearExpiredPaysWithPeerOsps func(ctx context.Context, in *ClearExpiredPaysRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ ConfirmOnChainResolvedPaysWithPeerOsps func(ctx context.Context, in *ConfirmOnChainResolvedPaysRequest, ...) (*empty.Empty, error)

+ CooperativeSettle func(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)

+ CooperativeWithdraw func(ctx context.Context, in *ChannelOpRequest, opts ...grpc.CallOption) (*ChannelOpResponse, error)

+ Deposit func(ctx context.Context, in *DepositRequest, opts ...grpc.CallOption) (*DepositResponse, error)

+ GetPeerOsps func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PeerOspsResponse, error)

+ OspOpenChannel func(ctx context.Context, in *OspOpenChannelRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ QueryDeposit func(ctx context.Context, in *QueryDepositRequest, opts ...grpc.CallOption) (*QueryDepositResponse, error)

+ RecvBcastRoutingInfo func(ctx context.Context, in *RoutingRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ RegisterStream func(ctx context.Context, in *RegisterStreamRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ SendToken func(ctx context.Context, in *SendTokenRequest, opts ...grpc.CallOption) (*SendTokenResponse, error)

+ func NewAdminClient(cc *grpc.ClientConn) AdminClient

+ type AdminServer interface

+ BuildRoutingTable func(context.Context, *BuildRoutingTableRequest) (*empty.Empty, error)

+ ClearExpiredPaysWithPeerOsps func(context.Context, *ClearExpiredPaysRequest) (*empty.Empty, error)

+ ConfirmOnChainResolvedPaysWithPeerOsps func(context.Context, *ConfirmOnChainResolvedPaysRequest) (*empty.Empty, error)

+ CooperativeSettle func(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)

+ CooperativeWithdraw func(context.Context, *ChannelOpRequest) (*ChannelOpResponse, error)

+ Deposit func(context.Context, *DepositRequest) (*DepositResponse, error)

+ GetPeerOsps func(context.Context, *empty.Empty) (*PeerOspsResponse, error)

+ OspOpenChannel func(context.Context, *OspOpenChannelRequest) (*empty.Empty, error)

+ QueryDeposit func(context.Context, *QueryDepositRequest) (*QueryDepositResponse, error)

+ RecvBcastRoutingInfo func(context.Context, *RoutingRequest) (*empty.Empty, error)

+ RegisterStream func(context.Context, *RegisterStreamRequest) (*empty.Empty, error)

+ SendToken func(context.Context, *SendTokenRequest) (*SendTokenResponse, error)

+ type AuthAck struct

+ MySig []byte

+ StartMid *MID

+ SyncChannels []*ChannelInAuth

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AuthAck) Descriptor() ([]byte, []int)

+ func (*AuthAck) ProtoMessage()

+ func (m *AuthAck) GetMySig() []byte

+ func (m *AuthAck) GetStartMid() *MID

+ func (m *AuthAck) GetSyncChannels() []*ChannelInAuth

+ 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 struct

+ ExpectPeer []byte

+ MutualAuth bool

+ MyAddr []byte

+ MySig []byte

+ OpenedChannels []*ChannelSummary

+ ProtocolVersion uint64

+ Timestamp uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AuthReq) Descriptor() ([]byte, []int)

+ func (*AuthReq) ProtoMessage()

+ 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 (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 struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Osps []string

+ Req *RoutingRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BcastRoutingRequest) Descriptor() ([]byte, []int)

+ func (*BcastRoutingRequest) ProtoMessage()

+ func (m *BcastRoutingRequest) GetOsps() []string

+ func (m *BcastRoutingRequest) GetReq() *RoutingRequest

+ 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 struct

+ TokenAddress []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BuildRoutingTableRequest) Descriptor() ([]byte, []int)

+ func (*BuildRoutingTableRequest) ProtoMessage()

+ func (m *BuildRoutingTableRequest) GetTokenAddress() []byte

+ 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 struct

+ Flag uint64

+ Message isCelerMsg_Message

+ Mid *MID

+ RetMid *MID

+ ToAddr []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CelerMsg) Descriptor() ([]byte, []int)

+ func (*CelerMsg) ProtoMessage()

+ func (*CelerMsg) XXX_OneofWrappers() []interface{}

+ 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 (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 (m *CelerMsg) XXX_Size() int

+ func (m *CelerMsg) XXX_Unmarshal(b []byte) error

+ type CelerMsg_AuthAck struct

+ AuthAck *AuthAck

+ type CelerMsg_AuthReq struct

+ AuthReq *AuthReq

+ type CelerMsg_CondPayReceipt struct

+ CondPayReceipt *CondPayReceipt

+ type CelerMsg_CondPayRequest struct

+ CondPayRequest *CondPayRequest

+ type CelerMsg_CondPayResponse struct

+ CondPayResponse *CondPayResponse

+ type CelerMsg_Error struct

+ Error *Error

+ type CelerMsg_PayResultVouchRequest struct

+ PayResultVouchRequest *entity.VouchedCondPayResult

+ type CelerMsg_PayResultVouchResponse struct

+ PayResultVouchResponse *entity.VouchedCondPayResult

+ type CelerMsg_PaymentSettleProof struct

+ PaymentSettleProof *PaymentSettleProof

+ type CelerMsg_PaymentSettleRequest struct

+ PaymentSettleRequest *PaymentSettleRequest

+ type CelerMsg_PaymentSettleResponse struct

+ PaymentSettleResponse *PaymentSettleResponse

+ type CelerMsg_RevealSecret struct

+ RevealSecret *RevealSecret

+ type CelerMsg_RevealSecretAck struct

+ RevealSecretAck *RevealSecretAck

+ type CelerMsg_RoutingRequest struct

+ RoutingRequest *RoutingRequest

+ type CelerMsg_WithdrawRequest struct

+ WithdrawRequest *CooperativeWithdrawRequest

+ type CelerMsg_WithdrawResponse struct

+ WithdrawResponse *CooperativeWithdrawResponse

+ type CelerStream interface

+ Recv func() (*CelerMsg, error)

+ Send func(*CelerMsg) error

+ type ChannelInAuth struct

+ AuthackPays []*PayInAuthAck

+ AuthackSimplex *SignedSimplexState

+ AuthreqPays []*PayInAuthAck

+ AuthreqSimplex *SignedSimplexState

+ ChannelState int64

+ Cid []byte

+ LedgerAddr []byte

+ OpenChannelResponse *OpenChannelResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChannelInAuth) Descriptor() ([]byte, []int)

+ func (*ChannelInAuth) ProtoMessage()

+ 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 (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 struct

+ Cid string

+ Wei string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChannelOpRequest) Descriptor() ([]byte, []int)

+ func (*ChannelOpRequest) ProtoMessage()

+ func (m *ChannelOpRequest) GetCid() string

+ func (m *ChannelOpRequest) GetWei() string

+ 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 struct

+ Error string

+ Status int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChannelOpResponse) Descriptor() ([]byte, []int)

+ func (*ChannelOpResponse) ProtoMessage()

+ func (m *ChannelOpResponse) GetError() string

+ func (m *ChannelOpResponse) GetStatus() int32

+ 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 struct

+ Balance string

+ Cid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChannelRoutingInfo) Descriptor() ([]byte, []int)

+ func (*ChannelRoutingInfo) ProtoMessage()

+ func (m *ChannelRoutingInfo) GetBalance() string

+ func (m *ChannelRoutingInfo) GetCid() string

+ 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 struct

+ ChannelId []byte

+ LedgerAddr []byte

+ MySeqNum uint64

+ PeerSeqNum uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChannelSummary) Descriptor() ([]byte, []int)

+ func (*ChannelSummary) ProtoMessage()

+ func (m *ChannelSummary) GetChannelId() []byte

+ func (m *ChannelSummary) GetLedgerAddr() []byte

+ func (m *ChannelSummary) GetMySeqNum() uint64

+ func (m *ChannelSummary) GetPeerSeqNum() uint64

+ 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 struct

+ TokenAddress []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClearExpiredPaysRequest) Descriptor() ([]byte, []int)

+ func (*ClearExpiredPaysRequest) ProtoMessage()

+ func (m *ClearExpiredPaysRequest) GetTokenAddress() []byte

+ 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 struct

+ DelegationProof *DelegationProof

+ OriginalPayId []byte

+ PayDelegatorSig []byte

+ PayDestSig []byte

+ PayId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CondPayReceipt) Descriptor() ([]byte, []int)

+ func (*CondPayReceipt) ProtoMessage()

+ 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 (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 struct

+ BaseSeq uint64

+ CondPay []byte

+ CrossNet *CrossNetPay

+ DirectPay bool

+ Note *any.Any

+ StateOnlyPeerFromSig *SignedSimplexState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CondPayRequest) Descriptor() ([]byte, []int)

+ func (*CondPayRequest) ProtoMessage()

+ 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 (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 struct

+ Error *Error

+ StateCosigned *SignedSimplexState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CondPayResponse) Descriptor() ([]byte, []int)

+ func (*CondPayResponse) ProtoMessage()

+ func (m *CondPayResponse) GetError() *Error

+ func (m *CondPayResponse) GetStateCosigned() *SignedSimplexState

+ 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 struct

+ TokenAddress []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConfirmOnChainResolvedPaysRequest) Descriptor() ([]byte, []int)

+ func (*ConfirmOnChainResolvedPaysRequest) ProtoMessage()

+ func (m *ConfirmOnChainResolvedPaysRequest) GetTokenAddress() []byte

+ 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 struct

+ func NewConnectionManager(regClient RegisterClientCallbackFunc) *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 struct

+ RequesterSig []byte

+ WithdrawInfo *entity.CooperativeWithdrawInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CooperativeWithdrawRequest) Descriptor() ([]byte, []int)

+ func (*CooperativeWithdrawRequest) ProtoMessage()

+ func (m *CooperativeWithdrawRequest) GetRequesterSig() []byte

+ func (m *CooperativeWithdrawRequest) GetWithdrawInfo() *entity.CooperativeWithdrawInfo

+ 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 struct

+ ApproverSig []byte

+ RequesterSig []byte

+ WithdrawInfo *entity.CooperativeWithdrawInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CooperativeWithdrawResponse) Descriptor() ([]byte, []int)

+ func (*CooperativeWithdrawResponse) ProtoMessage()

+ func (m *CooperativeWithdrawResponse) GetApproverSig() []byte

+ func (m *CooperativeWithdrawResponse) GetRequesterSig() []byte

+ func (m *CooperativeWithdrawResponse) GetWithdrawInfo() *entity.CooperativeWithdrawInfo

+ 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 struct

+ BridgeAddr []byte

+ BridgeNetId uint64

+ Crossing bool

+ DstNetId uint64

+ OriginalPay []byte

+ SrcNetId uint64

+ Timeout uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CrossNetPay) Descriptor() ([]byte, []int)

+ func (*CrossNetPay) ProtoMessage()

+ 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 (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 struct

+ Delegatee []byte

+ Delegator []byte

+ ExpiresAfterBlock int64

+ TokenToDelegate [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DelegationDescription) Descriptor() ([]byte, []int)

+ func (*DelegationDescription) ProtoMessage()

+ func (m *DelegationDescription) GetDelegatee() []byte

+ func (m *DelegationDescription) GetDelegator() []byte

+ func (m *DelegationDescription) GetExpiresAfterBlock() int64

+ func (m *DelegationDescription) GetTokenToDelegate() [][]byte

+ 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 struct

+ DelegationDescriptionBytes []byte

+ Signature []byte

+ Signer []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DelegationProof) Descriptor() ([]byte, []int)

+ func (*DelegationProof) ProtoMessage()

+ func (m *DelegationProof) GetDelegationDescriptionBytes() []byte

+ func (m *DelegationProof) GetSignature() []byte

+ func (m *DelegationProof) GetSigner() []byte

+ 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 struct

+ Proof *DelegationProof

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DelegationRequest) Descriptor() ([]byte, []int)

+ func (*DelegationRequest) ProtoMessage()

+ func (m *DelegationRequest) GetProof() *DelegationProof

+ 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 struct

+ Error string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DelegationResponse) Descriptor() ([]byte, []int)

+ func (*DelegationResponse) ProtoMessage()

+ func (m *DelegationResponse) GetError() string

+ 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 struct

+ AmtWei string

+ MaxWaitS uint64

+ PeerAddr string

+ ToPeer bool

+ TokenAddr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DepositRequest) Descriptor() ([]byte, []int)

+ func (*DepositRequest) ProtoMessage()

+ 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 (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 struct

+ DepositId string

+ Error string

+ Status int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DepositResponse) Descriptor() ([]byte, []int)

+ func (*DepositResponse) ProtoMessage()

+ func (m *DepositResponse) GetDepositId() string

+ func (m *DepositResponse) GetError() string

+ func (m *DepositResponse) GetStatus() int32

+ 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 int32

+ const DepositState_Deposit_FAILED

+ const DepositState_Deposit_NOT_FOUND

+ const DepositState_Deposit_QUEUED

+ const DepositState_Deposit_SUBMITTED

+ const DepositState_Deposit_SUCCEEDED

+ func (DepositState) EnumDescriptor() ([]byte, []int)

+ func (x DepositState) String() string

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

+ type ErrCode int32

+ const ErrCode_INCORRECT_CLOCK

+ const ErrCode_INVALID_SEQ_NUM

+ const ErrCode_INVALID_SIG

+ const ErrCode_MISC_ERROR

+ const ErrCode_NOT_ENOUGH_BALANCE

+ const ErrCode_NO_ROUTE_TO_DST

+ const ErrCode_OK

+ const ErrCode_PAY_ROUTE_LOOP

+ const ErrCode_PEER_NOT_ONLINE

+ const ErrCode_UNAUTHORIZED

+ const ErrCode_WRONG_PEER

+ func (ErrCode) EnumDescriptor() ([]byte, []int)

+ func (x ErrCode) String() string

+ type Error struct

+ Code ErrCode

+ Reason string

+ Seq uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (m *Error) GetCode() ErrCode

+ func (m *Error) GetReason() string

+ func (m *Error) GetSeq() uint64

+ 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 struct

+ Accepted bool

+ Err string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FwdReply) Descriptor() ([]byte, []int)

+ func (*FwdReply) ProtoMessage()

+ func (m *FwdReply) GetAccepted() bool

+ func (m *FwdReply) GetErr() string

+ 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 struct

+ Dest string

+ Message *CelerMsg

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FwdReq) Descriptor() ([]byte, []int)

+ func (*FwdReq) ProtoMessage()

+ func (m *FwdReq) GetDest() string

+ func (m *FwdReq) GetMessage() *CelerMsg

+ 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 struct

+ BeforeTs int64

+ ItemsPerPage int32

+ Peer string

+ SmallestPayId string

+ Ts uint64

+ TsSig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetPayHistoryRequest) Descriptor() ([]byte, []int)

+ func (*GetPayHistoryRequest) ProtoMessage()

+ 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 (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 struct

+ Pays []*OneHistoricalPay

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetPayHistoryResponse) Descriptor() ([]byte, []int)

+ func (*GetPayHistoryResponse) ProtoMessage()

+ func (m *GetPayHistoryResponse) GetPays() []*OneHistoricalPay

+ 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 int32

+ const JoinCelerStatus_LOCAL

+ const JoinCelerStatus_NOT_JOIN

+ const JoinCelerStatus_REMOTE

+ func (JoinCelerStatus) EnumDescriptor() ([]byte, []int)

+ func (x JoinCelerStatus) String() string

+ type MID struct

+ Seq uint64

+ Tag string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MID) Descriptor() ([]byte, []int)

+ func (*MID) ProtoMessage()

+ func (m *MID) GetSeq() uint64

+ func (m *MID) GetTag() string

+ 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 struct

+ ChannelMigrationInfo []byte

+ RequesterSig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MigrateChannelRequest) Descriptor() ([]byte, []int)

+ func (*MigrateChannelRequest) ProtoMessage()

+ func (m *MigrateChannelRequest) GetChannelMigrationInfo() []byte

+ func (m *MigrateChannelRequest) GetRequesterSig() []byte

+ 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 struct

+ ApproverSig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MigrateChannelResponse) Descriptor() ([]byte, []int)

+ func (*MigrateChannelResponse) ProtoMessage()

+ func (m *MigrateChannelResponse) GetApproverSig() []byte

+ 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 func(peer ctype.Addr) error

+ type MultiServerClient interface

+ BcastRoutingInfo func(ctx context.Context, in *BcastRoutingRequest, opts ...grpc.CallOption) (*BcastRoutingReply, error)

+ FwdMsg func(ctx context.Context, in *FwdReq, opts ...grpc.CallOption) (*FwdReply, error)

+ PickServer func(ctx context.Context, in *PickReq, opts ...grpc.CallOption) (*PickReply, error)

+ Ping func(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error)

+ func NewMultiServerClient(cc *grpc.ClientConn) MultiServerClient

+ type MultiServerServer interface

+ BcastRoutingInfo func(context.Context, *BcastRoutingRequest) (*BcastRoutingReply, error)

+ FwdMsg func(context.Context, *FwdReq) (*FwdReply, error)

+ PickServer func(context.Context, *PickReq) (*PickReply, error)

+ Ping func(context.Context, *PingReq) (*PingReply, error)

+ type OneHistoricalPay struct

+ Amt string

+ CreateTs int64

+ Dst string

+ PayId string

+ Src string

+ State int64

+ Token string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OneHistoricalPay) Descriptor() ([]byte, []int)

+ func (*OneHistoricalPay) ProtoMessage()

+ 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 (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 int32

+ const OpenChannelBy_OPEN_CHANNEL_APPROVER

+ const OpenChannelBy_OPEN_CHANNEL_PROPOSER

+ const OpenChannelBy_UNDEFINED_OPEN_BY

+ func (OpenChannelBy) EnumDescriptor() ([]byte, []int)

+ func (x OpenChannelBy) String() string

+ type OpenChannelRequest struct

+ ChannelInitializer []byte

+ OpenBy OpenChannelBy

+ OspToOsp bool

+ RequesterSig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OpenChannelRequest) Descriptor() ([]byte, []int)

+ func (*OpenChannelRequest) ProtoMessage()

+ func (m *OpenChannelRequest) GetChannelInitializer() []byte

+ func (m *OpenChannelRequest) GetOpenBy() OpenChannelBy

+ func (m *OpenChannelRequest) GetOspToOsp() bool

+ func (m *OpenChannelRequest) GetRequesterSig() []byte

+ 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 struct

+ ApproverSig []byte

+ ChannelInitializer []byte

+ PaymentChannelId []byte

+ RequesterSig []byte

+ Status OpenChannelStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OpenChannelResponse) Descriptor() ([]byte, []int)

+ func (*OpenChannelResponse) ProtoMessage()

+ 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 (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 int32

+ const OpenChannelStatus_OPEN_CHANNEL_APPROVED

+ const OpenChannelStatus_OPEN_CHANNEL_TCB_OPENED

+ const OpenChannelStatus_OPEN_CHANNEL_TX_SUBMITTED

+ const OpenChannelStatus_UNDEFINED_OPEN_CHANNEL_STATUS

+ func (OpenChannelStatus) EnumDescriptor() ([]byte, []int)

+ func (x OpenChannelStatus) String() string

+ type OspOpenChannelRequest struct

+ PeerDepositAmtWei string

+ PeerEthAddress []byte

+ SelfDepositAmtWei string

+ TokenAddress []byte

+ TokenType entity.TokenType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OspOpenChannelRequest) Descriptor() ([]byte, []int)

+ func (*OspOpenChannelRequest) ProtoMessage()

+ 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 (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 struct

+ Err *Error

+ NextHopAddr []byte

+ PayId []byte

+ PrevHopAddr []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PayHop) Descriptor() ([]byte, []int)

+ func (*PayHop) ProtoMessage()

+ func (m *PayHop) GetErr() *Error

+ func (m *PayHop) GetNextHopAddr() []byte

+ func (m *PayHop) GetPayId() []byte

+ func (m *PayHop) GetPrevHopAddr() []byte

+ 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 struct

+ Note *any.Any

+ Pay []byte

+ State int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PayInAuthAck) Descriptor() ([]byte, []int)

+ func (*PayInAuthAck) ProtoMessage()

+ func (m *PayInAuthAck) GetNote() *any.Any

+ func (m *PayInAuthAck) GetPay() []byte

+ func (m *PayInAuthAck) GetState() int64

+ 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 struct

+ Hops []*SignedPayHop

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PayPath) Descriptor() ([]byte, []int)

+ func (*PayPath) ProtoMessage()

+ func (m *PayPath) GetHops() []*SignedPayHop

+ 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 struct

+ SettledPays []*SettledPayment

+ VouchedCondPayResults []*entity.VouchedCondPayResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PaymentSettleProof) Descriptor() ([]byte, []int)

+ func (*PaymentSettleProof) ProtoMessage()

+ func (m *PaymentSettleProof) GetSettledPays() []*SettledPayment

+ func (m *PaymentSettleProof) GetVouchedCondPayResults() []*entity.VouchedCondPayResult

+ 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 int32

+ const PaymentSettleReason_NONE

+ const PaymentSettleReason_PAY_DEST_UNREACHABLE

+ const PaymentSettleReason_PAY_EXPIRED

+ const PaymentSettleReason_PAY_PAID_MAX

+ const PaymentSettleReason_PAY_REJECTED

+ const PaymentSettleReason_PAY_RESOLVED_ONCHAIN

+ const PaymentSettleReason_PAY_VOUCHED

+ func (PaymentSettleReason) EnumDescriptor() ([]byte, []int)

+ func (x PaymentSettleReason) String() string

+ type PaymentSettleRequest struct

+ BaseSeq uint64

+ SettledPays []*SettledPayment

+ StateOnlyPeerFromSig *SignedSimplexState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PaymentSettleRequest) Descriptor() ([]byte, []int)

+ func (*PaymentSettleRequest) ProtoMessage()

+ func (m *PaymentSettleRequest) GetBaseSeq() uint64

+ func (m *PaymentSettleRequest) GetSettledPays() []*SettledPayment

+ func (m *PaymentSettleRequest) GetStateOnlyPeerFromSig() *SignedSimplexState

+ 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 struct

+ Error *Error

+ StateCosigned *SignedSimplexState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PaymentSettleResponse) Descriptor() ([]byte, []int)

+ func (*PaymentSettleResponse) ProtoMessage()

+ func (m *PaymentSettleResponse) GetError() *Error

+ func (m *PaymentSettleResponse) GetStateCosigned() *SignedSimplexState

+ 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 struct

+ Address string

+ TokenAddr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PeerAddress) Descriptor() ([]byte, []int)

+ func (*PeerAddress) ProtoMessage()

+ func (m *PeerAddress) GetAddress() string

+ func (m *PeerAddress) GetTokenAddr() string

+ 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 struct

+ OspAddress string

+ TokenCidPairs []*TokenCidPair

+ UpdateTs uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PeerOsp) Descriptor() ([]byte, []int)

+ func (*PeerOsp) ProtoMessage()

+ func (m *PeerOsp) GetOspAddress() string

+ func (m *PeerOsp) GetTokenCidPairs() []*TokenCidPair

+ func (m *PeerOsp) GetUpdateTs() uint64

+ 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 struct

+ PeerOsps []*PeerOsp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PeerOspsResponse) Descriptor() ([]byte, []int)

+ func (*PeerOspsResponse) ProtoMessage()

+ func (m *PeerOspsResponse) GetPeerOsps() []*PeerOsp

+ 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 struct

+ FreeBalance string

+ JoinStatus JoinCelerStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PeerStatus) Descriptor() ([]byte, []int)

+ func (*PeerStatus) ProtoMessage()

+ func (m *PeerStatus) GetFreeBalance() string

+ func (m *PeerStatus) GetJoinStatus() JoinCelerStatus

+ 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 struct

+ Server string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PickReply) Descriptor() ([]byte, []int)

+ func (*PickReply) ProtoMessage()

+ func (m *PickReply) GetServer() string

+ 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 struct

+ Client string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PickReq) Descriptor() ([]byte, []int)

+ func (*PickReq) ProtoMessage()

+ func (m *PickReq) GetClient() string

+ 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 struct

+ Numclients uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PingReply) Descriptor() ([]byte, []int)

+ func (*PingReply) ProtoMessage()

+ func (m *PingReply) GetNumclients() uint32

+ 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 struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Delegatee []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryDelegationRequest) Descriptor() ([]byte, []int)

+ func (*QueryDelegationRequest) ProtoMessage()

+ func (m *QueryDelegationRequest) GetDelegatee() []byte

+ 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 struct

+ Proof *DelegationProof

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryDelegationResponse) Descriptor() ([]byte, []int)

+ func (*QueryDelegationResponse) ProtoMessage()

+ func (m *QueryDelegationResponse) GetProof() *DelegationProof

+ 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 struct

+ DepositId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryDepositRequest) Descriptor() ([]byte, []int)

+ func (*QueryDepositRequest) ProtoMessage()

+ func (m *QueryDepositRequest) GetDepositId() string

+ 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 struct

+ DepositState DepositState

+ Error string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryDepositResponse) Descriptor() ([]byte, []int)

+ func (*QueryDepositResponse) ProtoMessage()

+ func (m *QueryDepositResponse) GetDepositState() DepositState

+ func (m *QueryDepositResponse) GetError() string

+ 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 func(clientAddr ctype.Addr)

+ type RegisterStreamRequest struct

+ PeerEthAddress []byte

+ PeerRpcAddress string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterStreamRequest) Descriptor() ([]byte, []int)

+ func (*RegisterStreamRequest) ProtoMessage()

+ func (m *RegisterStreamRequest) GetPeerEthAddress() []byte

+ func (m *RegisterStreamRequest) GetPeerRpcAddress() string

+ 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 struct

+ OriginalPayId []byte

+ PayId []byte

+ Secret []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RevealSecret) Descriptor() ([]byte, []int)

+ func (*RevealSecret) ProtoMessage()

+ func (m *RevealSecret) GetOriginalPayId() []byte

+ func (m *RevealSecret) GetPayId() []byte

+ func (m *RevealSecret) GetSecret() []byte

+ 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 struct

+ OriginalPayId []byte

+ PayDestSecretSig []byte

+ PayId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RevealSecretAck) Descriptor() ([]byte, []int)

+ func (*RevealSecretAck) ProtoMessage()

+ func (m *RevealSecretAck) GetOriginalPayId() []byte

+ func (m *RevealSecretAck) GetPayDestSecretSig() []byte

+ func (m *RevealSecretAck) GetPayId() []byte

+ 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 struct

+ Sender string

+ Updates []*SignedRoutingUpdate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RoutingRequest) Descriptor() ([]byte, []int)

+ func (*RoutingRequest) ProtoMessage()

+ func (m *RoutingRequest) GetSender() string

+ func (m *RoutingRequest) GetUpdates() []*SignedRoutingUpdate

+ 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 struct

+ Channels []*ChannelRoutingInfo

+ Origin string

+ ProtoVersion uint64

+ Ts uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RoutingUpdate) Descriptor() ([]byte, []int)

+ func (*RoutingUpdate) ProtoMessage()

+ func (m *RoutingUpdate) GetChannels() []*ChannelRoutingInfo

+ func (m *RoutingUpdate) GetOrigin() string

+ func (m *RoutingUpdate) GetProtoVersion() uint64

+ func (m *RoutingUpdate) GetTs() uint64

+ 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 interface

+ CelerGetPeerStatus func(ctx context.Context, in *PeerAddress, opts ...grpc.CallOption) (*PeerStatus, error)

+ CelerMigrateChannel func(ctx context.Context, in *MigrateChannelRequest, opts ...grpc.CallOption) (*MigrateChannelResponse, error)

+ CelerOpenChannel func(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error)

+ CelerOpenTcbChannel func(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error)

+ CelerStream func(ctx context.Context, opts ...grpc.CallOption) (Rpc_CelerStreamClient, error)

+ GetPayHistory func(ctx context.Context, in *GetPayHistoryRequest, opts ...grpc.CallOption) (*GetPayHistoryResponse, error)

+ QueryDelegation func(ctx context.Context, in *QueryDelegationRequest, opts ...grpc.CallOption) (*QueryDelegationResponse, error)

+ RequestDelegation func(ctx context.Context, in *DelegationRequest, opts ...grpc.CallOption) (*DelegationResponse, error)

+ func NewRpcClient(cc *grpc.ClientConn) RpcClient

+ type RpcServer interface

+ CelerGetPeerStatus func(context.Context, *PeerAddress) (*PeerStatus, error)

+ CelerMigrateChannel func(context.Context, *MigrateChannelRequest) (*MigrateChannelResponse, error)

+ CelerOpenChannel func(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)

+ CelerOpenTcbChannel func(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)

+ CelerStream func(Rpc_CelerStreamServer) error

+ GetPayHistory func(context.Context, *GetPayHistoryRequest) (*GetPayHistoryResponse, error)

+ QueryDelegation func(context.Context, *QueryDelegationRequest) (*QueryDelegationResponse, error)

+ RequestDelegation func(context.Context, *DelegationRequest) (*DelegationResponse, error)

+ type Rpc_CelerOneServer interface

+ Recv func() (*CelerMsg, error)

+ Send func(*CelerMsg) error

+ type Rpc_CelerStreamClient interface

+ Recv func() (*CelerMsg, error)

+ Send func(*CelerMsg) error

+ type Rpc_CelerStreamServer interface

+ Recv func() (*CelerMsg, error)

+ Send func(*CelerMsg) error

+ type SafeSendCelerStream struct

+ func (s *SafeSendCelerStream) SafeSend(msg *CelerMsg) error

+ type SendTokenRequest struct

+ AmtWei string

+ DstAddr string

+ DstNetId uint64

+ Note *any.Any

+ TokenAddr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SendTokenRequest) Descriptor() ([]byte, []int)

+ func (*SendTokenRequest) ProtoMessage()

+ 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 (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 struct

+ Error string

+ PayId string

+ Status int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SendTokenResponse) Descriptor() ([]byte, []int)

+ func (*SendTokenResponse) ProtoMessage()

+ func (m *SendTokenResponse) GetError() string

+ func (m *SendTokenResponse) GetPayId() string

+ func (m *SendTokenResponse) GetStatus() int32

+ 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 struct

+ Amount []byte

+ OriginalPayId []byte

+ Path *PayPath

+ Reason PaymentSettleReason

+ SettledPayId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SettledPayment) Descriptor() ([]byte, []int)

+ func (*SettledPayment) ProtoMessage()

+ 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 (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 struct

+ SimplexStates []*SignedSimplexState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SignedDuplexState) Descriptor() ([]byte, []int)

+ func (*SignedDuplexState) ProtoMessage()

+ func (m *SignedDuplexState) GetSimplexStates() []*SignedSimplexState

+ 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 struct

+ PayHopBytes []byte

+ Sig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SignedPayHop) Descriptor() ([]byte, []int)

+ func (*SignedPayHop) ProtoMessage()

+ func (m *SignedPayHop) GetPayHopBytes() []byte

+ func (m *SignedPayHop) GetSig() []byte

+ 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 struct

+ Sig []byte

+ Ttl uint64

+ Update []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SignedRoutingUpdate) Descriptor() ([]byte, []int)

+ func (*SignedRoutingUpdate) ProtoMessage()

+ func (m *SignedRoutingUpdate) GetSig() []byte

+ func (m *SignedRoutingUpdate) GetTtl() uint64

+ func (m *SignedRoutingUpdate) GetUpdate() []byte

+ 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 struct

+ SigOfPeerFrom []byte

+ SigOfPeerTo []byte

+ SimplexState []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SignedSimplexState) Descriptor() ([]byte, []int)

+ func (*SignedSimplexState) ProtoMessage()

+ func (m *SignedSimplexState) GetSigOfPeerFrom() []byte

+ func (m *SignedSimplexState) GetSigOfPeerTo() []byte

+ func (m *SignedSimplexState) GetSimplexState() []byte

+ 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 struct

+ Cid string

+ TokenAddress string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TokenCidPair) Descriptor() ([]byte, []int)

+ func (*TokenCidPair) ProtoMessage()

+ func (m *TokenCidPair) GetCid() string

+ func (m *TokenCidPair) GetTokenAddress() string

+ 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 struct

+ 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 struct

+ 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 struct

+ 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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL