eventstreams

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
  • func (f LoaderFunc) LoadWorkflowEvent(vid ulid.I, ev wfevents.WorkflowEvent) error
• type Watcher
• type WatcherFunc
  • func (f WatcherFunc) WatchWorkflowEvent(ctx context.Context, vid ulid.I, ev wfevents.WorkflowEvent) (done bool, err error)
• type WillBlocker
• type WillBlockerFunc
  • func (f WillBlockerFunc) WillBlock(ctx context.Context) (done bool, err error)

Functions

func LoadRegistryWorkflowEventsNoBlock

func LoadRegistryWorkflowEventsNoBlock(
	stream pb.EphemeralRegistry_RegistryWorkflowEventsClient,
	loader Loader,
) error

func LoadRegistryWorkflowIndexEventsNoBlock

func LoadRegistryWorkflowIndexEventsNoBlock(
	stream pb.EphemeralRegistry_RegistryWorkflowIndexEventsClient,
	loader Loader,
) error

func WatchRegistryWorkflowEvents

func WatchRegistryWorkflowEvents(
	ctx context.Context,
	tail ulid.I,
	stream pb.EphemeralRegistry_RegistryWorkflowEventsClient,
	watcher Watcher,
	blocker WillBlocker,
) (ulid.I, error)

func WatchRegistryWorkflowIndexEvents

func WatchRegistryWorkflowIndexEvents(
	ctx context.Context,
	tail ulid.I,
	stream pb.EphemeralRegistry_RegistryWorkflowIndexEventsClient,
	watcher Watcher,
	blocker WillBlocker,
) (ulid.I, 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 Watcher

type Watcher interface {
	WatchWorkflowEvent(
		ctx context.Context,
		vid ulid.I,
		ev wfevents.WorkflowEvent,
	) (done bool, err 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

type WillBlocker interface {
	WillBlock(ctx context.Context) (done bool, err error)
}

type WillBlockerFunc

type WillBlockerFunc func(ctx context.Context) (done bool, err error)

func (WillBlockerFunc) WillBlock

func (f WillBlockerFunc) WillBlock(
	ctx context.Context,
) (done bool, err error)