core

Jan 28, 2026

Changes in this version

+ const WAIT_FOR_SYNC_RETRY_DELAY

+ func NewLogger(chainEvents <-chan spec.BlockchainEvent) governor.Service

+ func NewSplitter(chainEvents <-chan spec.BlockchainEvent, chanSizes []int) (governor.Service, []chan spec.BlockchainEvent)

+ type Logger struct

+ func (l *Logger) Run()

+ type Splitter struct

+ func (s *Splitter) Run()

Oct 22, 2025

Changes in this version

type CoreRPCClient

+ func (c *CoreRPCClient) SendRawTransaction(ctx context.Context, txHex string) (err error)

Oct 6, 2025

Changes in this version

+ const AlreadyInUTXOSet

+ const InWarmup

+ const InvalidAddressOrKey

+ const InvalidParameter

+ const VerifyError

+ const VerifyRejected

type CoreRPCClient

+ func (c *CoreRPCClient) EstimateFee(ctx context.Context, confirmTarget int) (feePerKB koinu.Koinu, err error)

+ func (c *CoreRPCClient) GetBlockchainInfo(ctx context.Context) (info spec.BlockchainInfo, err error)

+ func (c *CoreRPCClient) GetRawMempool(ctx context.Context) (mem spec.RawMempool, err error)

+ func (c *CoreRPCClient) GetRawMempoolTxList(ctx context.Context) (txlist []string, err error)

+ func (c *CoreRPCClient) GetRawTransaction(ctx context.Context, txID string) (tx doge.BlockTx, err error)

Jul 31, 2025

Changes in this version

+ const BlockHeightOutOfRange

+ const BlockNotFound

+ func SleepWithContext(ctx context.Context, duration time.Duration) (cancelled bool)

type CoreRPCClient

+ func (c *CoreRPCClient) RetryMode(attempts int, delay time.Duration) spec.Blockchain

+ func (c *CoreRPCClient) WaitForSync() spec.Blockchain

Jul 18, 2025

Changes in this version

+ const ERROR_DELAY

+ const RETRY_DELAY

+ func NewCoreRPCClient(rpcHost string, rpcPort int, rpcUser string, rpcPass string) spec.Blockchain

+ func NewTipChaser(coreAddrZMQ string) (service governor.Service, newTip chan string)

+ type CoreRPCClient struct

+ func (c *CoreRPCClient) GetBestBlockHash() (blockHash string, err error)

+ func (c *CoreRPCClient) GetBlock(blockHash string) (hex string, err error)

+ func (c *CoreRPCClient) GetBlockCount() (blockCount int64, err error)

+ func (c *CoreRPCClient) GetBlockHash(blockHeight int64) (hash string, err error)

+ func (c *CoreRPCClient) GetBlockHeader(blockHash string) (txn spec.BlockHeader, err error)

+ func (c *CoreRPCClient) Request(method string, params []any, result any) error