Documentation
¶
Overview ¶
Package sfnpoller provides a 'generic' mechanism for to poll a StepFunction state machine for tasks.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type API ¶
type API struct {
// contains filtered or unexported fields
}
API is the sfnpoller's API.
func (*API) BeginPolling ¶
BeginPolling initiates polling on registered tasks. This method blocks until all all pollers have reported that they have started.
func (*API) Done ¶
func (a *API) Done() <-chan struct{}
Done returns a channel that blocks until all pollers have reported that they are done polling.
func (*API) RegisterTask ¶
func (a *API) RegisterTask(task pollableiface.PollableTask) *API
RegisterTask adds the specified task to the poller's internal list of tasks to execute.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package cancellablecontext is a wrapper around context.WithCancel that exposes context.CancelFunc as a receiver.
|
Package cancellablecontext is a wrapper around context.WithCancel that exposes context.CancelFunc as a receiver. |
|
cancellablecontextiface
Package cancellablecontextiface represents a context that supports cancellation.
|
Package cancellablecontextiface represents a context that supports cancellation. |
|
internal
|
|
|
Package pollable contains mechanisms for setting up and managing a task that can poll SFN for work.
|
Package pollable contains mechanisms for setting up and managing a task that can poll SFN for work. |
|
pollableiface
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.