runtime

type AbstractRuntime struct {
	Logger         logger.Logger
	FunctionLogger logger.Logger
	Context        *nuclio.Context
	Statistics     Statistics
	// contains filtered or unexported fields
}

type Configuration struct {
	*processor.Configuration
	FunctionLogger           logger.Logger
	WorkerID                 int
	TriggerName              string
	TriggerKind              string
	WorkerTerminationTimeout time.Duration
	ControlMessageBroker     *controlcommunication.AbstractControlMessageBroker
	Mode                     functionconfig.TriggerWorkMode
}

type Creator interface {

	// Create creates a runtime instance
	Create(logger.Logger, *Configuration) (Runtime, error)
}

type Registry struct {
	registry.Registry
}

type ResponseWithErrors struct {
	nuclio.Response
	EventId         string
	SubmitError     error
	ProcessError    error
	NoResponseError error
}

type Runtime interface {

	// ProcessEvent receives the event and processes it at the specific runtime
	ProcessEvent(event nuclio.Event, functionLogger logger.Logger) (interface{}, error)

	// ProcessBatch receives the event batch and processes it at the specific runtime
	ProcessBatch(batch []nuclio.Event, functionLogger logger.Logger) ([]*ResponseWithErrors, error)

	// GetFunctionLogger returns the function logger
	GetFunctionLogger() logger.Logger

	// GetStatistics returns statistics gathered by the runtime
	GetStatistics() *Statistics

	// GetConfiguration returns the runtime configuration
	GetConfiguration() *Configuration

	// SetStatus sets the runtime's reported status
	SetStatus(newStatus status.Status)

	// GetStatus returns the runtime's reported status
	GetStatus() status.Status

	// Start starts the runtime, or does nothing if the runtime does not require starting (e.g. Go and shell runtimes)
	Start() error

	// Stop stops the runtime
	Stop() error

	// Restart restarts the runtime
	Restart() error

	// SupportsRestart return true if the runtime supports restart
	SupportsRestart() bool

	// Drain signals to the runtime process to drain its accumulated events and waits for it to finish
	Drain() error

	// Continue signals the runtime process to continue event processing
	Continue() error

	// Terminate signals to the runtime process that processor is about to stop working
	Terminate() error

	// GetControlMessageBroker returns the control message broker
	GetControlMessageBroker() controlcommunication.ControlMessageBroker
}

type Statistics struct {
	DurationMilliSecondsSum   uint64
	DurationMilliSecondsCount uint64
}