Versions in this module Expand all Collapse all v1 v1.14.2 Feb 25, 2025 Changes in this version + type AbstractRuntime struct + func NewAbstractRuntime(logger logger.Logger, configuration *runtime.Configuration, ...) (*AbstractRuntime, error) + func (r *AbstractRuntime) GetSocketType() connection.SocketType + func (r *AbstractRuntime) ProcessBatch(batch []nuclio.Event, functionLogger logger.Logger) ([]*runtime.ResponseWithErrors, error) + func (r *AbstractRuntime) ProcessEvent(event nuclio.Event, functionLogger logger.Logger) (interface{}, error) + func (r *AbstractRuntime) Restart() error + func (r *AbstractRuntime) Signal(signal syscall.Signal) error + func (r *AbstractRuntime) Start() error + func (r *AbstractRuntime) Stop() error + func (r *AbstractRuntime) SupportsControlCommunication() bool + func (r *AbstractRuntime) SupportsRestart() bool + func (r *AbstractRuntime) WaitForProcessTermination(timeout time.Duration) + func (r *AbstractRuntime) WaitForStart() bool + type Runtime interface + GetEventEncoder func(writer io.Writer) encoder.EventEncoder + GetSocketType func() connection.SocketType + RunWrapper func([]string, string) (*os.Process, error) + SupportsControlCommunication func() bool + WaitForStart func() bool
Go to main page