event

type ActionFailed ¶

type ActionFailed struct {
	ActionID   string
	WorkflowID string
	Reason     string
	Message    string
}

ActionFailed occurs when an action fails to complete.

func (ActionFailed) GetName() Name

func (e ActionFailed) String() string

type ActionStarted ¶

type ActionStarted struct {
	ActionID   string
	WorkflowID string
}

ActionStarted occurs when an action begins running.

func (ActionStarted) GetName() Name

func (e ActionStarted) String() string

type ActionSucceeded ¶

type ActionSucceeded struct {
	ActionID   string
	WorkflowID string
}

ActionSucceeded occurs when an action successfully completes.

func (ActionSucceeded) GetName() Name

func (e ActionSucceeded) String() string

type Event ¶

type Event interface {
	// GetName retrieves the event name.
	GetName() Name
	// contains filtered or unexported methods
}

Event is an event generated during execution of a Workflow. Each event in the event package implements this interface. Consumers may type switch the Event to the appropriate type for event handling.

E.g.

switch ev.(type) {
case event.ActionStarted:
	// Handle ActionStarted event.
default:
	// Unsupported event.
}

type IncompatibleError ¶

type IncompatibleError struct {
	Event Event
}

IncompatibleError indicates an event was received that.

func (e IncompatibleError) Error() string

type Name ¶

type Name string

Name is a unique name identifying an event.

const (
	ActionStartedName   Name = "ActionStarted"
	ActionSucceededName Name = "ActionSucceeded"
	ActionFailedName    Name = "ActionFailed"
)

const WorkflowRejectedName Name = "WorkflowRejected"

type Recorder ¶

type Recorder interface {
	RecordEvent(context.Context, Event) error
}

Recorder provides event recording methods.

type RecorderMock ¶

type RecorderMock struct {
	// RecordEventFunc mocks the RecordEvent method.
	RecordEventFunc func(contextMoqParam context.Context, event Event) error
	// contains filtered or unexported fields
}

RecorderMock is a mock implementation of Recorder.

func TestSomethingThatUsesRecorder(t *testing.T) {

	// make and configure a mocked Recorder
	mockedRecorder := &RecorderMock{
		RecordEventFunc: func(contextMoqParam context.Context, event Event) error {
			panic("mock out the RecordEvent method")
		},
	}

	// use mockedRecorder in code that requires Recorder
	// and then make assertions.

}

func NoopRecorder() *RecorderMock

func (mock *RecorderMock) RecordEvent(contextMoqParam context.Context, event Event) error

func (mock *RecorderMock) RecordEventCalls() []struct {
	ContextMoqParam context.Context
	Event           Event
}

len(mockedRecorder.RecordEventCalls())

type WorkflowRejected ¶

type WorkflowRejected struct {
	ID      string
	Message string
}

WorkflowRejected is generated when a workflow is being rejected by the agent.

func (WorkflowRejected) GetName() Name

func (e WorkflowRejected) String() string