Documentation ¶
Index ¶
- func LoadRegistryWorkflowEventsNoBlock(stream pb.EphemeralRegistry_RegistryWorkflowEventsClient, loader Loader) error
- func LoadRegistryWorkflowIndexEventsNoBlock(stream pb.EphemeralRegistry_RegistryWorkflowIndexEventsClient, loader Loader) error
- func WatchRegistryWorkflowEvents(ctx context.Context, tail ulid.I, ...) (ulid.I, error)
- func WatchRegistryWorkflowIndexEvents(ctx context.Context, tail ulid.I, ...) (ulid.I, error)
- type Loader
- type LoaderFunc
- type Watcher
- type WatcherFunc
- type WillBlocker
- type WillBlockerFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LoadRegistryWorkflowEventsNoBlock ¶
func LoadRegistryWorkflowEventsNoBlock( stream pb.EphemeralRegistry_RegistryWorkflowEventsClient, loader Loader, ) error
func LoadRegistryWorkflowIndexEventsNoBlock ¶
func LoadRegistryWorkflowIndexEventsNoBlock( stream pb.EphemeralRegistry_RegistryWorkflowIndexEventsClient, loader Loader, ) error
Types ¶
type Loader ¶
type Loader interface {
LoadWorkflowEvent(vid ulid.I, ev wfevents.WorkflowEvent) error
}
type LoaderFunc ¶
type LoaderFunc func(vid ulid.I, ev wfevents.WorkflowEvent) error
func (LoaderFunc) LoadWorkflowEvent ¶
func (f LoaderFunc) LoadWorkflowEvent( vid ulid.I, ev wfevents.WorkflowEvent, ) error
type WatcherFunc ¶
type WatcherFunc func( ctx context.Context, vid ulid.I, ev wfevents.WorkflowEvent, ) (done bool, err error)
func (WatcherFunc) WatchWorkflowEvent ¶
func (f WatcherFunc) WatchWorkflowEvent( ctx context.Context, vid ulid.I, ev wfevents.WorkflowEvent, ) (done bool, err error)
type WillBlocker ¶
Click to show internal directories.
Click to hide internal directories.