wasm

Documentation

Index

• Constants
• type EmissionError
  • func NewEmissionError(err error) *EmissionError
  • func (e *EmissionError) Error() string
• type Runner
  • func NewRunner() *Runner
  • func (r *Runner) Config() []byte
  • func (r *Runner) Run(factory *sdk.WorkflowSpecFactory)
• type Runtime
  • func (r *Runtime) Emitter() sdk.MessageEmitter
  • func (r *Runtime) Fetch(req sdk.FetchRequest) (sdk.FetchResponse, error)
  • func (r *Runtime) Logger() logger.Logger
• type RuntimeConfig

Constants

const (
	CodeInvalidResponse = 110
	CodeInvalidRequest  = 111
	CodeRunnerErr       = 112
	CodeHostErr         = 113
	CodeSuccess         = 0
)

Types

type EmissionError

type EmissionError struct {
	Wrapped error
}

EmissionError wraps all errors that occur during the emission process for the runtime to handle.

func NewEmissionError

func NewEmissionError(err error) *EmissionError

func (*EmissionError) Error

func (e *EmissionError) Error() string

type Runner

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

func NewRunner

func NewRunner() *Runner

func (*Runner) Config

func (r *Runner) Config() []byte

func (*Runner) Run

func (r *Runner) Run(factory *sdk.WorkflowSpecFactory)

type Runtime

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

func (*Runtime) Emitter

func (r *Runtime) Emitter() sdk.MessageEmitter

func (*Runtime) Fetch

func (r *Runtime) Fetch(req sdk.FetchRequest) (sdk.FetchResponse, error)

func (*Runtime) Logger

func (r *Runtime) Logger() logger.Logger

type RuntimeConfig

type RuntimeConfig struct {
	MaxFetchResponseSizeBytes int64
	RequestID                 *string
	Metadata                  *capabilities.RequestMetadata
}