service

type Dialer interface {
	Dial() (net.Conn, error)
}

type Execution struct {
	// Hash is the execution id of task.
	Hash string

	// Key is the name of task.
	Key string
	// contains filtered or unexported fields
}

type Option func(*Service)

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

type Taskable interface {
	// Key returns the task key.
	Key() string

	// Execute called when a task execution request arrived with the same key
	// returned by Name().
	Execute(execution *Execution) (interface{}, error)
}