Documentation
¶
Overview ¶
Package pollable contains mechanisms for setting up and managing a task that can poll SFN for work.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ResourceInfo ¶
ResourceInfo is the interface for any resource that knows its ARN and ActivityName.
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
Task is an action that supports polling.
func NewTask ¶
func NewTask(handlerFn interface{}, activityArn, workerName string, heartbeatInterval time.Duration, sfnAPI sfniface.SFNAPI) *Task
NewTask returns a reference to a new pollable task.
func NewTask2 ¶
func NewTask2(handlerFn interface{}, resourceInfo ResourceInfo, heartbeatInterval time.Duration, sfnAPI sfniface.SFNAPI) *Task
NewTask2 returns a reference to a new pollable task using ResourceInfo.
func (*Task) Done ¶
func (task *Task) Done() <-chan struct{}
Done returns a channel that blocks until the task is done polling.
func (*Task) Start ¶
func (task *Task) Start(ctx cancellablecontextiface.Context)
Start initializes polling for the task.
Directories
¶
Path | Synopsis |
---|---|
Package pollableiface contains an interface for a PollableTask
|
Package pollableiface contains an interface for a PollableTask |
Click to show internal directories.
Click to hide internal directories.