listener

Documentation

Index

• Constants
• type DaemonRpcClientExecutor
  • func NewDaemonRpcClientExecutor(client daemon.IDaemonRpcClient, log *zerolog.Logger) *DaemonRpcClientExecutor
  • func (d *DaemonRpcClientExecutor) LastSyncedBlockHeight() uint64
  • func (d *DaemonRpcClientExecutor) NewBlockChan() <-chan daemon.GetBlockResult
  • func (d *DaemonRpcClientExecutor) NewTxPoolChan() <-chan daemon.MoneroTx
  • func (d *DaemonRpcClientExecutor) Start(startBlock uint64)
  • func (d *DaemonRpcClientExecutor) Stop()

Constants

const (
	MIN_SYNC_TIMEOUT time.Duration = 10 * time.Second
)

Types

type DaemonRpcClientExecutor

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

func NewDaemonRpcClientExecutor

func NewDaemonRpcClientExecutor(client daemon.IDaemonRpcClient, log *zerolog.Logger) *DaemonRpcClientExecutor

func (*DaemonRpcClientExecutor) LastSyncedBlockHeight

func (d *DaemonRpcClientExecutor) LastSyncedBlockHeight() uint64

func (*DaemonRpcClientExecutor) NewBlockChan

func (d *DaemonRpcClientExecutor) NewBlockChan() <-chan daemon.GetBlockResult

func (*DaemonRpcClientExecutor) NewTxPoolChan

func (d *DaemonRpcClientExecutor) NewTxPoolChan() <-chan daemon.MoneroTx

func (*DaemonRpcClientExecutor) Start

func (d *DaemonRpcClientExecutor) Start(startBlock uint64)

func (*DaemonRpcClientExecutor) Stop

func (d *DaemonRpcClientExecutor) Stop()