rpc

package

Go to main page

Versions in this module

v0

v0.4.3

Dec 14, 2023

v0.4.2

Aug 28, 2023

Changes in this version

type NetService

+ func (s *NetService) Pairs(_ *http.Request, req *rpctypes.PairsRequest, resp *rpctypes.PairsResponse) error

v0.4.1

Jun 29, 2023

v0.4.0

Jun 20, 2023

v0.3.0

Jun 9, 2023

Changes in this version

type PastSwap

+ RelayerFee *apd.Decimal

type PersonalService

+ func (s *PersonalService) SweepETH(_ *http.Request, req *SweepETHRequest, resp *SweepETHResponse) error

type ProtocolBackend

+ SweepETH func(to ethcommon.Address) (*ethtypes.Receipt, error)

type Server

+ func (s *Server) Port() uint16

+ type SweepETHRequest struct

+ To ethcommon.Address

+ type SweepETHResponse struct

+ TxHash ethcommon.Hash

type TransferETHRequest

+ GasLimit *uint64

type TransferETHResponse

+ GasLimit *uint64

v0.2.2

May 9, 2023

Changes in this version

+ func NewPrometheusRegistry() (*prometheus.Registry, error)

type Config

+ Env common.Environment

+ type Metrics struct

+ func SetupMetrics(ctx context.Context, reg *prometheus.Registry, net Net, pb ProtocolBackend, ...) *Metrics

v0.2.1

May 4, 2023

Changes in this version

+ type ManualTransactionRequest struct

+ OfferID types.Hash

+ type ManualTransactionResponse struct

+ TxHash types.Hash

type OngoingSwap

+ Timeout2 *time.Time

type PersonalService

+ func (s *PersonalService) SweepXMR(_ *http.Request, req *SweepXMRRequest, resp *SweepXMRResponse) error

+ func (s *PersonalService) TransferETH(_ *http.Request, req *TransferETHRequest, resp *TransferETHResponse) error

+ func (s *PersonalService) TransferXMR(_ *http.Request, req *TransferXMRRequest, resp *TransferXMRResponse) error

type ProtocolBackend

+ Ctx func() context.Context

+ SweepXMR func(to *mcrypto.Address) ([]string, error)

+ TransferETH func(to ethcommon.Address, amount *coins.WeiAmount) (types.Hash, error)

+ TransferXMR func(to *mcrypto.Address, amount *coins.PiconeroAmount) (string, error)

type SwapService

+ func (s *SwapService) Claim(_ *http.Request, req *ManualTransactionRequest, ...) error

+ func (s *SwapService) Refund(_ *http.Request, req *ManualTransactionRequest, ...) error

+ type SweepXMRRequest struct

+ To *mcrypto.Address

+ type SweepXMRResponse struct

+ TxIDs []string

+ type TransferETHRequest struct

+ Amount *apd.Decimal

+ To ethcommon.Address

+ type TransferETHResponse struct

+ TxHash ethcommon.Hash

+ type TransferXMRRequest struct

+ Amount *apd.Decimal

+ To *mcrypto.Address

+ type TransferXMRResponse struct

+ TxID string

v0.2.0

Apr 27, 2023

v0.1.1

Apr 21, 2023

Changes in this version

+ const DaemonNamespace

+ const DatabaseNamespace

+ const NetNamespace

+ const PersonalName

+ const SwapNamespace

+ func AllNamespaces() map[string]struct

+ type CancelRequest struct

+ OfferID types.Hash

+ type CancelResponse struct

+ Status types.Status

+ type ClearOffersRequest struct

+ OfferIDs []types.Hash

+ type Codec struct

+ func NewCodec() *Codec

+ func (c *Codec) NewRequest(req *http.Request) rpc.CodecRequest

+ type CodecRequest struct

+ func (cr *CodecRequest) Method() (string, error)

+ type Config struct

+ Address string

+ Ctx context.Context

+ IsBootnodeOnly bool

+ Namespaces map[string]struct{}

+ Net Net

+ ProtocolBackend ProtocolBackend

+ RecoveryDB RecoveryDB

+ XMRMaker XMRMaker

+ XMRTaker XMRTaker

+ type DaemonService struct

+ func NewDaemonService(stopServer func(), pb ProtocolBackend) *DaemonService

+ func (s *DaemonService) Shutdown(_ *http.Request, _ *any, _ *any) error

+ func (s *DaemonService) Version(_ *http.Request, _ *any, resp *VersionResponse) error

+ type DatabaseService struct

+ func NewDatabaseService(rdb RecoveryDB) *DatabaseService

+ func (s *DatabaseService) GetContractSwapInfo(_ *http.Request, req *GetContractSwapInfoRequest, ...) error

+ func (s *DatabaseService) GetSwapSecret(_ *http.Request, req *GetSwapSecretRequest, resp *GetSwapSecretResponse) error

+ type GetContractSwapInfoRequest struct

+ OfferID types.Hash

+ type GetContractSwapInfoResponse struct

+ StartNumber *big.Int

+ Swap *contracts.SwapCreatorSwap

+ SwapCreatorAddr ethcommon.Address

+ SwapID types.Hash

+ type GetOffersResponse struct

+ Offers []*types.Offer

+ PeerID peer.ID

+ type GetOngoingRequest struct

+ OfferID *types.Hash

+ type GetOngoingResponse struct

+ Swaps []*OngoingSwap

+ type GetPastRequest struct

+ OfferID *types.Hash

+ type GetPastResponse struct

+ Swaps []*PastSwap

+ type GetStatusRequest struct

+ ID types.Hash

+ type GetStatusResponse struct

+ Description string

+ StartTime time.Time

+ Status types.Status

+ type GetSwapSecretRequest struct

+ OfferID types.Hash

+ type GetSwapSecretResponse struct

+ Secret *mcrypto.PrivateSpendKey

+ type GetSwapTimeoutResponse struct

+ Timeout uint64

+ type Net interface

+ Addresses func() []ma.Multiaddr

+ CloseProtocolStream func(types.Hash)

+ ConnectedPeers func() []string

+ Discover func(provides string, searchTime time.Duration) ([]peer.ID, error)

+ Initiate func(who peer.AddrInfo, sendKeysMessage common.Message, s common.SwapStateNet) error

+ PeerID func() peer.ID

+ Query func(who peer.ID) (*message.QueryResponse, error)

+ type NetService struct

+ func NewNetService(net Net, xmrtaker XMRTaker, xmrmaker XMRMaker, sm SwapManager, isBootnode bool) *NetService

+ func (s *NetService) Addresses(_ *http.Request, _ *interface{}, resp *rpctypes.AddressesResponse) error

+ func (s *NetService) Discover(_ *http.Request, req *rpctypes.DiscoverRequest, ...) error

+ func (s *NetService) MakeOffer(_ *http.Request, req *rpctypes.MakeOfferRequest, ...) error

+ func (s *NetService) Peers(_ *http.Request, _ *interface{}, resp *rpctypes.PeersResponse) error

+ func (s *NetService) QueryAll(_ *http.Request, req *rpctypes.QueryAllRequest, ...) error

+ func (s *NetService) QueryPeer(_ *http.Request, req *rpctypes.QueryPeerRequest, ...) error

+ func (s *NetService) TakeOffer(_ *http.Request, req *rpctypes.TakeOfferRequest, _ *interface{}) error

+ func (s *NetService) TakeOfferSync(_ *http.Request, req *rpctypes.TakeOfferRequest, resp *TakeOfferSyncResponse) error

+ type OngoingSwap struct

+ EstimatedTimeToCompletion time.Duration

+ EthAsset types.EthAsset

+ ExchangeRate *coins.ExchangeRate

+ ExpectedAmount *apd.Decimal

+ ID types.Hash

+ LastStatusUpdateTime time.Time

+ Provided coins.ProvidesCoin

+ ProvidedAmount *apd.Decimal

+ StartTime time.Time

+ Status types.Status

+ Timeout0 *time.Time

+ Timeout1 *time.Time

+ type PastSwap struct

+ EndTime *time.Time

+ EthAsset types.EthAsset

+ ExchangeRate *coins.ExchangeRate

+ ExpectedAmount *apd.Decimal

+ ID types.Hash

+ Provided coins.ProvidesCoin

+ ProvidedAmount *apd.Decimal

+ StartTime time.Time

+ Status types.Status

+ type PersonalService struct

+ func NewPersonalService(ctx context.Context, xmrmaker XMRMaker, pb ProtocolBackend) *PersonalService

+ func (s *PersonalService) Balances(_ *http.Request, req *rpctypes.BalancesRequest, ...) error

+ func (s *PersonalService) GetSwapTimeout(_ *http.Request, _ *interface{}, resp *GetSwapTimeoutResponse) error

+ func (s *PersonalService) SetGasPrice(_ *http.Request, req *SetGasPriceRequest, _ *interface{}) error

+ func (s *PersonalService) SetSwapTimeout(_ *http.Request, req *SetSwapTimeoutRequest, _ *interface{}) error

+ func (s *PersonalService) TokenInfo(_ *http.Request, req *rpctypes.TokenInfoRequest, ...) error

+ type Protocol interface

+ GetOngoingSwapState func(types.Hash) common.SwapState

+ Provides func() coins.ProvidesCoin

+ type ProtocolBackend interface

+ ClearXMRDepositAddress func(types.Hash)

+ ETHClient func() extethclient.EthClient

+ Env func() common.Environment

+ SetSwapTimeout func(timeout time.Duration)

+ SetXMRDepositAddress func(*mcrypto.Address, types.Hash)

+ SwapCreatorAddr func() ethcommon.Address

+ SwapManager func() swap.Manager

+ SwapTimeout func() time.Duration

+ type RecoveryDB interface

+ GetContractSwapInfo func(id types.Hash) (*db.EthereumSwapInfo, error)

+ GetCounterpartySwapPrivateKey func(id types.Hash) (*mcrypto.PrivateSpendKey, error)

+ GetSwapPrivateKey func(id types.Hash) (*mcrypto.PrivateSpendKey, error)

+ type Server struct

+ func NewServer(cfg *Config) (*Server, error)

+ func (s *Server) HttpURL() string

+ func (s *Server) Start() error

+ func (s *Server) Stop() error

+ func (s *Server) WsURL() string

+ type SetGasPriceRequest struct

+ GasPrice uint64

+ type SetSwapTimeoutRequest struct

+ Timeout uint64

+ type SuggestedExchangeRateResponse struct

+ ETHPrice *apd.Decimal

+ ETHUpdatedAt time.Time

+ ExchangeRate *coins.ExchangeRate

+ XMRPrice *apd.Decimal

+ XMRUpdatedAt time.Time

+ type SwapManager = swap.Manager

+ type SwapService struct

+ func NewSwapService(ctx context.Context, sm SwapManager, xmrtaker XMRTaker, xmrmaker XMRMaker, ...) *SwapService

+ func (s *SwapService) Cancel(_ *http.Request, req *CancelRequest, resp *CancelResponse) error

+ func (s *SwapService) ClearOffers(_ *http.Request, req *ClearOffersRequest, _ *interface{}) error

+ func (s *SwapService) GetOffers(_ *http.Request, _ *interface{}, resp *GetOffersResponse) error

+ func (s *SwapService) GetOngoing(_ *http.Request, req *GetOngoingRequest, resp *GetOngoingResponse) error

+ func (s *SwapService) GetPast(_ *http.Request, req *GetPastRequest, resp *GetPastResponse) error

+ func (s *SwapService) GetStatus(_ *http.Request, req *GetStatusRequest, resp *GetStatusResponse) error

+ func (s *SwapService) SuggestedExchangeRate(_ *http.Request, _ *interface{}, resp *SuggestedExchangeRateResponse) error

+ type TakeOfferSyncResponse struct

+ Status types.Status

+ type VersionResponse struct

+ Env common.Environment

+ P2PVersion string

+ SwapCreatorAddr ethcommon.Address

+ SwapdVersion string

+ type XMRMaker interface

+ ClearOffers func([]types.Hash) error

+ GetMoneroBalance func() (*mcrypto.Address, *wallet.GetBalanceResponse, error)

+ GetOffers func() []*types.Offer

+ MakeOffer func(offer *types.Offer, useRelayer bool) (*types.OfferExtra, error)

+ type XMRTaker interface

+ ExternalSender func(offerID types.Hash) (*txsender.ExternalSender, error)

+ InitiateProtocol func(peerID peer.ID, providesAmount *apd.Decimal, offer *types.Offer) (common.SwapState, error)

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