service

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

type Execution struct {
	// ID is the execution id of task.
	ID 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().
	// outputKey is the output key and data is the output data of task.
	Execute(execution *Execution) (outputKey string, outputData interface{})
}