mock

type Func ¶

type Func func(spec *types.TaskInvocationSpec) (*typedvalues.TypedValue, error)

Func is the type for mocked functions used in the mock.Runtime

type Resolver ¶

type Resolver struct {
	FnNameIDs map[string]string
}

Resolver is a mocked implementation of a RuntimeResolver.

Use FnNameIDs to setup a mapping to mock resolving function references to IDs.

func NewResolver() *Resolver

func (mf *Resolver) Resolve(ref types.FnRef) (string, error)

type Runtime ¶

type Runtime struct {
	Functions       map[string]Func
	AsyncResults    map[string]*types.TaskInvocation
	ManualExecution bool
}

Runtime mocks the implementation of the various runtime.

Mock functions can be added to Functions, and should have the mocked function id as the key. For AsyncRuntime the results are stored and retrieved from the AsyncResults. The result is added automatically/instantly using the function, but can be avoided by enabling ManualExecution.

Note it does not mock the resolver, which is mocked by the mock.Resolver

func NewRuntime() *Runtime

func (mk *Runtime) Cancel(fnInvocationID string) error

func (mk *Runtime) Invoke(spec *types.TaskInvocationSpec, opts ...fnenv.InvokeOption) (*types.TaskInvocationStatus, error)

func (mk *Runtime) InvokeAsync(spec *types.TaskInvocationSpec, opts ...fnenv.InvokeOption) (string, error)

func (mk *Runtime) MockComplete(fnInvocationID string) error

func (mk *Runtime) Notify(taskID string, fn types.FnRef, expectedAt time.Time) error

func (mk *Runtime) Status(fnInvocationID string) (*types.TaskInvocationStatus, error)