Versions in this module Expand all Collapse all v1 v1.14.2 Feb 25, 2025 Changes in this version + var ErrNoResponseFromBatchResponse = errors.New("processor hasn't received corresponding response for the event") + var RegistrySingleton = Registry + type AbstractRuntime struct + Context *nuclio.Context + FunctionLogger logger.Logger + Logger logger.Logger + Statistics Statistics + func NewAbstractRuntime(logger logger.Logger, configuration *Configuration) (*AbstractRuntime, error) + func (ar *AbstractRuntime) Continue() error + func (ar *AbstractRuntime) Drain() error + func (ar *AbstractRuntime) GetConfiguration() *Configuration + func (ar *AbstractRuntime) GetControlMessageBroker() controlcommunication.ControlMessageBroker + func (ar *AbstractRuntime) GetEnvFromConfiguration() []string + func (ar *AbstractRuntime) GetFunctionLogger() logger.Logger + func (ar *AbstractRuntime) GetStatistics() *Statistics + func (ar *AbstractRuntime) GetStatus() status.Status + func (ar *AbstractRuntime) Restart() error + func (ar *AbstractRuntime) SetStatus(newStatus status.Status) + func (ar *AbstractRuntime) Start() error + func (ar *AbstractRuntime) Stop() error + func (ar *AbstractRuntime) SupportsControlCommunication() bool + func (ar *AbstractRuntime) SupportsRestart() bool + func (ar *AbstractRuntime) Terminate() error + type Configuration struct + ControlMessageBroker *controlcommunication.AbstractControlMessageBroker + FunctionLogger logger.Logger + Mode functionconfig.TriggerWorkMode + TriggerKind string + TriggerName string + WorkerID int + WorkerTerminationTimeout time.Duration + type Creator interface + Create func(logger.Logger, *Configuration) (Runtime, error) + type Registry struct + func (r *Registry) NewRuntime(logger logger.Logger, kind string, runtimeConfiguration *Configuration) (Runtime, error) + type ResponseWithErrors struct + EventId string + NoResponseError error + ProcessError error + SubmitError error + type Runtime interface + Continue func() error + Drain func() error + GetConfiguration func() *Configuration + GetControlMessageBroker func() controlcommunication.ControlMessageBroker + GetFunctionLogger func() logger.Logger + GetStatistics func() *Statistics + GetStatus func() status.Status + ProcessBatch func(batch []nuclio.Event, functionLogger logger.Logger) ([]*ResponseWithErrors, error) + ProcessEvent func(event nuclio.Event, functionLogger logger.Logger) (interface{}, error) + Restart func() error + SetStatus func(newStatus status.Status) + Start func() error + Stop func() error + SupportsRestart func() bool + Terminate func() error + type Statistics struct + DurationMilliSecondsCount uint64 + DurationMilliSecondsSum uint64 + func (s *Statistics) DiffFrom(prev *Statistics) Statistics
Go to main page