test

Documentation

Index

• func GetValueFromCnOrLogFatalWithTimeout[T any](cn <-chan T, timeout time.Duration, errorMsg string) T
• func RunInTransaction(t *testing.T, db *pgxpool.Pool, testFunc func(*testing.T, pgx.Tx))
• func SpinUpPostgresContainer(pathToMigration string) (testcontainers.Container, func(ctx context.Context), error)
• func SpinUpPostgresContainerAndGetPgxpool(pathToMigration string) (*pgxpool.Pool, testcontainers.Container, func(ctx context.Context))
• type MockXMRDaemonRpcClient
  • func (m *MockXMRDaemonRpcClient) GetBlockByHash(fillPowHash bool, hash string) (*daemon.JsonRpcGenericResponse[daemon.GetBlockResult], error)
  • func (m *MockXMRDaemonRpcClient) GetBlockByHeight(includeHex bool, height uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockResult], error)
  • func (m *MockXMRDaemonRpcClient) GetBlockCount() (*daemon.JsonRpcGenericResponse[daemon.GetBlockCountResult], error)
  • func (m *MockXMRDaemonRpcClient) GetBlockHeaderByHash(fillPowHash bool, hash string) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeaderResult], error)
  • func (m *MockXMRDaemonRpcClient) GetBlockHeaderByHeight(fillPowHash bool, height uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeaderResult], error)
  • func (m *MockXMRDaemonRpcClient) GetBlockHeadersRange(fillPowHash bool, startHeight uint64, endHeight uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeadersRangeResult], error)
  • func (m *MockXMRDaemonRpcClient) GetBlockTemplate(wallet string, reverseSize uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockTemplateResult], error)
  • func (m *MockXMRDaemonRpcClient) GetCurrentHeight() (*daemon.GetHeightResponse, error)
  • func (m *MockXMRDaemonRpcClient) GetFeeEstimate() (*daemon.JsonRpcGenericResponse[daemon.GetFeeEstimateResult], error)
  • func (m *MockXMRDaemonRpcClient) GetInfo() (*daemon.JsonRpcGenericResponse[daemon.GetInfoResult], error)
  • func (m *MockXMRDaemonRpcClient) GetLastBlockHeader(includeHex bool) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeaderResult], error)
  • func (m *MockXMRDaemonRpcClient) GetTransactionPool() (*daemon.GetTransactionPoolResponse, error)
  • func (m *MockXMRDaemonRpcClient) GetTransactions(txHashes []string, decodeAsJson bool, prune bool, split bool) (*daemon.GetTransactionsResponse, error)
  • func (m *MockXMRDaemonRpcClient) GetVersion() (*daemon.JsonRpcGenericResponse[daemon.GetVersionResult], error)
  • func (m *MockXMRDaemonRpcClient) OnGetBlockHash(height uint64) (*daemon.JsonRpcGenericResponse[daemon.OnGetBlockHashResult], error)
  • func (m *MockXMRDaemonRpcClient) SetRpcConnection(connection *daemon.RpcConnection)
  • func (m *MockXMRDaemonRpcClient) SubmitBlock(blobData []string) (*daemon.JsonRpcGenericResponse[daemon.SubmitBlockResult], error)

Functions

func GetValueFromCnOrLogFatalWithTimeout

func GetValueFromCnOrLogFatalWithTimeout[T any](cn <-chan T, timeout time.Duration, errorMsg string) T

func RunInTransaction

func RunInTransaction(t *testing.T, db *pgxpool.Pool, testFunc func(*testing.T, pgx.Tx))

func SpinUpPostgresContainer

func SpinUpPostgresContainer(pathToMigration string) (testcontainers.Container, func(ctx context.Context), error)

func SpinUpPostgresContainerAndGetPgxpool

func SpinUpPostgresContainerAndGetPgxpool(pathToMigration string) (*pgxpool.Pool, testcontainers.Container, func(ctx context.Context))

Types

type MockXMRDaemonRpcClient

type MockXMRDaemonRpcClient struct {
	mock.Mock
}

func (*MockXMRDaemonRpcClient) GetBlockByHash

func (m *MockXMRDaemonRpcClient) GetBlockByHash(fillPowHash bool, hash string) (*daemon.JsonRpcGenericResponse[daemon.GetBlockResult], error)

func (*MockXMRDaemonRpcClient) GetBlockByHeight

func (m *MockXMRDaemonRpcClient) GetBlockByHeight(includeHex bool, height uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockResult], error)

func (*MockXMRDaemonRpcClient) GetBlockCount

func (m *MockXMRDaemonRpcClient) GetBlockCount() (*daemon.JsonRpcGenericResponse[daemon.GetBlockCountResult], error)

func (*MockXMRDaemonRpcClient) GetBlockHeaderByHash

func (m *MockXMRDaemonRpcClient) GetBlockHeaderByHash(fillPowHash bool, hash string) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeaderResult], error)

func (*MockXMRDaemonRpcClient) GetBlockHeaderByHeight

func (m *MockXMRDaemonRpcClient) GetBlockHeaderByHeight(fillPowHash bool, height uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeaderResult], error)

func (*MockXMRDaemonRpcClient) GetBlockHeadersRange

func (m *MockXMRDaemonRpcClient) GetBlockHeadersRange(fillPowHash bool, startHeight uint64, endHeight uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeadersRangeResult], error)

func (*MockXMRDaemonRpcClient) GetBlockTemplate

func (m *MockXMRDaemonRpcClient) GetBlockTemplate(wallet string, reverseSize uint64) (*daemon.JsonRpcGenericResponse[daemon.GetBlockTemplateResult], error)

func (*MockXMRDaemonRpcClient) GetCurrentHeight

func (m *MockXMRDaemonRpcClient) GetCurrentHeight() (*daemon.GetHeightResponse, error)

func (*MockXMRDaemonRpcClient) GetFeeEstimate

func (m *MockXMRDaemonRpcClient) GetFeeEstimate() (*daemon.JsonRpcGenericResponse[daemon.GetFeeEstimateResult], error)

func (*MockXMRDaemonRpcClient) GetInfo

func (m *MockXMRDaemonRpcClient) GetInfo() (*daemon.JsonRpcGenericResponse[daemon.GetInfoResult], error)

func (*MockXMRDaemonRpcClient) GetLastBlockHeader

func (m *MockXMRDaemonRpcClient) GetLastBlockHeader(includeHex bool) (*daemon.JsonRpcGenericResponse[daemon.GetBlockHeaderResult], error)

func (*MockXMRDaemonRpcClient) GetTransactionPool

func (m *MockXMRDaemonRpcClient) GetTransactionPool() (*daemon.GetTransactionPoolResponse, error)

func (*MockXMRDaemonRpcClient) GetTransactions

func (m *MockXMRDaemonRpcClient) GetTransactions(txHashes []string, decodeAsJson bool, prune bool, split bool) (*daemon.GetTransactionsResponse, error)

func (*MockXMRDaemonRpcClient) GetVersion

func (m *MockXMRDaemonRpcClient) GetVersion() (*daemon.JsonRpcGenericResponse[daemon.GetVersionResult], error)

func (*MockXMRDaemonRpcClient) OnGetBlockHash

func (m *MockXMRDaemonRpcClient) OnGetBlockHash(height uint64) (*daemon.JsonRpcGenericResponse[daemon.OnGetBlockHashResult], error)

func (*MockXMRDaemonRpcClient) SetRpcConnection

func (m *MockXMRDaemonRpcClient) SetRpcConnection(connection *daemon.RpcConnection)

func (*MockXMRDaemonRpcClient) SubmitBlock

func (m *MockXMRDaemonRpcClient) SubmitBlock(blobData []string) (*daemon.JsonRpcGenericResponse[daemon.SubmitBlockResult], error)