tasks

package

v0.9.0 Latest Latest Go to latest Published: Jun 15, 2021 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	Ping = iota + 1
	AskPeers
	MineMicro
	PersistComplete
)

This section is empty.

func SendAsyncTask(output chan AsyncTask, task AsyncTask)

SendAsyncTask sends task into channel with overflow check.

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

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 {
	TaskType int
	Data     interface{}
}

type MineMicroTask struct {
	MineMicroTaskData MineMicroTaskData
	// contains filtered or unexported fields
}

func NewMineMicroTask(timeout time.Duration, block *proto.Block, limits proto.MiningLimits, keyPair proto.KeyPair, vrf []byte) MineMicroTask

func (a MineMicroTask) Run(ctx context.Context, output chan AsyncTask) error

func (MineMicroTask) Type() int

type MineMicroTaskData struct {
	Block   *proto.Block
	Limits  proto.MiningLimits
	KeyPair proto.KeyPair
	Vrf     []byte
}

type PingTask struct {
}

func (PingTask) Run(ctx context.Context, output chan AsyncTask) error

func (PingTask) Type() int

type Task interface {
	Run(ctx context.Context, output chan AsyncTask) error
	Type() int
}

func NewFuncTask(f func(ctx context.Context, output chan AsyncTask) error, taskType int) Task

func NewPingTask() Task

func Tasks(tasks ...Task) []Task

type TaskType int