store

package

v0.0.0-...-0f8ae5d Latest Latest Go to latest Published: Dec 31, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

package store provides typed, centralized access to the event-sourced workflow and invocation models

This section is empty.

This section is empty.

func ParseNotificationToInvocation(update *fes.Notification) (*types.WorkflowInvocation, error)

func ParseNotificationToWorkflow(update *fes.Notification) (*types.Workflow, error)

type InvocationSubscription struct {
	*pubsub.Subscription
	// contains filtered or unexported fields
}

func (sub *InvocationSubscription) Close() error

func (sub *InvocationSubscription) ToNotification(msg pubsub.Msg) (*fes.Notification, error)

type Invocations struct {
	fes.CacheReader
}

func NewInvocationStore(invocations fes.CacheReader) *Invocations

func (s *Invocations) GetInvocation(invocationID string) (*types.WorkflowInvocation, error)

GetInvocation returns an event-sourced invocation. If an error occurred the error is returned, if no invocation was found both return values are nil.

func (s *Invocations) GetOldestQueued() []*types.WorkflowInvocation

func (s *Invocations) GetQueuedInvocationUpdates() *InvocationSubscription

func (s *Invocations) GetRunningInvocationUpdates() *InvocationSubscription

type WorkflowSubscription struct {
	*pubsub.Subscription
	// contains filtered or unexported fields
}

func (sub *WorkflowSubscription) Close() error

func (sub *WorkflowSubscription) ToNotification(msg pubsub.Msg) (*fes.Notification, error)

type Workflows struct {
	fes.CacheReader // Currently needed for pubsub publisher interface, should be exposed here
}

func NewWorkflowsStore(workflows fes.CacheReader) *Workflows

func (s *Workflows) GetWorkflow(workflowID string) (*types.Workflow, error)

GetWorkflow returns an event-sourced workflow. If an error occurred the error is returned, if no workflow was found both return values are nil.

func (s *Workflows) GetWorkflowUpdates() *WorkflowSubscription

GetWorkflowNotifications returns a subscription to the updates of the workflow cache. Returns nil if the cache does not support pubsub.

Future: Currently this assumes the presence of a pubsub.Publisher interface in the cache. In the future we can fallback to pull-based mechanisms