Versions in this module Expand all Collapse all v0 v0.11.0 Mar 24, 2026 Changes in this version + const AskPeers + const MineMicro + const PersistComplete + const Ping + const SnapshotTimeout + func SendAsyncTask(output chan AsyncTask, task AsyncTask) + type AskPeersTask struct + func NewAskPeersTask(d time.Duration) AskPeersTask + func (a AskPeersTask) Run(ctx context.Context, output chan AsyncTask) error + func (a AskPeersTask) Type() int + type AsyncTask struct + Data TaskData + TaskType int + type MineMicroTask struct + MineMicroTaskData MineMicroTaskData + func NewMineMicroTask(timeout time.Duration, block *proto.Block, limits proto.MiningLimits, ...) MineMicroTask + func (MineMicroTask) Type() int + func (a MineMicroTask) Run(ctx context.Context, output chan AsyncTask) error + type MineMicroTaskData struct + Block *proto.Block + KeyPair proto.KeyPair + Limits proto.MiningLimits + Vrf []byte + type PingTask struct + func (PingTask) Run(ctx context.Context, output chan AsyncTask) error + func (PingTask) Type() int + type SnapshotTimeoutTask struct + SnapshotTimeoutTaskData SnapshotTimeoutTaskData + func NewBlockSnapshotTimeoutTask(timeout time.Duration, blockID proto.BlockID, outdated <-chan struct{}) SnapshotTimeoutTask + func NewMicroBlockSnapshotTimeoutTask(timeout time.Duration, blockID proto.BlockID, outdated <-chan struct{}) SnapshotTimeoutTask + func (SnapshotTimeoutTask) Type() int + func (a SnapshotTimeoutTask) Run(ctx context.Context, output chan AsyncTask) error + type SnapshotTimeoutTaskData struct + BlockID proto.BlockID + SnapshotTaskType SnapshotTimeoutTaskType + type SnapshotTimeoutTaskType int + const BlockSnapshot + const MicroBlockSnapshot + type Task interface + Run func(ctx context.Context, output chan AsyncTask) error + Type func() int + func NewFuncTask(f func(ctx context.Context, output chan AsyncTask) error, taskType int) Task + func NewPingTask() Task + func Tasks(tasks ...Task) []Task + type TaskData interface + type TaskType int
Go to main page