fission

Documentation

Index

• Constants
• type FunctionEnv
  • func New(executorURL, serverURL, routerURL string) *FunctionEnv
  • func (fe *FunctionEnv) Invoke(spec *types.TaskInvocationSpec, opts ...fnenv.InvokeOption) (*types.TaskInvocationStatus, error)
  • func (fe *FunctionEnv) Prepare(fn types.FnRef, expectedAt time.Time) error
  • func (fe *FunctionEnv) Resolve(ref types.FnRef) (string, error)

Constants

const (
	Name = "fission"
)

Types

type FunctionEnv

type FunctionEnv struct {
	// contains filtered or unexported fields
}

FunctionEnv adapts the Fission platform to the function execution runtime. This allows the workflow engine to invoke Fission functions.

func New

func New(executorURL, serverURL, routerURL string) *FunctionEnv

func (*FunctionEnv) Invoke

func (fe *FunctionEnv) Invoke(spec *types.TaskInvocationSpec, opts ...fnenv.InvokeOption) (*types.TaskInvocationStatus, error)

Invoke executes the task in a blocking way.

spec contains the complete configuration needed for the execution. It returns the TaskInvocationStatus with a completed (FINISHED, FAILED, ABORTED) status. An error is returned only when error occurs outside of the runtime's control.

func (*FunctionEnv) Prepare

func (fe *FunctionEnv) Prepare(fn types.FnRef, expectedAt time.Time) error

Prepare signals the Fission runtime that a function request is expected at a specific time. For now this function will tap immediately regardless of the expected execution time.

func (*FunctionEnv) Resolve

func (fe *FunctionEnv) Resolve(ref types.FnRef) (string, error)