runtime

Documentation

Index

• Variables
• type AbstractRuntime
  • func NewAbstractRuntime(logger nuclio.Logger, configuration *Configuration) (*AbstractRuntime, error)
  • func (ar *AbstractRuntime) GetFunctionLogger() nuclio.Logger
  • func (ar *AbstractRuntime) GetStatistics() *Statistics
• type Configuration
  • func NewConfiguration(configuration *viper.Viper) (*Configuration, error)
• type Creator
• type DataBinding
• type Registry
  • func (r *Registry) NewRuntime(logger nuclio.Logger, kind string, configuration *viper.Viper) (Runtime, error)
• type Runtime
• type Statistics
  • func (s *Statistics) DiffFrom(prev *Statistics) Statistics

Variables

var RegistrySingleton = Registry{
	Registry: *registry.NewRegistry("runtime"),
}

global singleton

Types

type AbstractRuntime

type AbstractRuntime struct {
	Logger         nuclio.Logger
	FunctionLogger nuclio.Logger
	Context        *nuclio.Context
	Statistics     Statistics
}

func NewAbstractRuntime

func NewAbstractRuntime(logger nuclio.Logger,
	configuration *Configuration) (*AbstractRuntime, error)

func (*AbstractRuntime) GetFunctionLogger

func (ar *AbstractRuntime) GetFunctionLogger() nuclio.Logger

func (*AbstractRuntime) GetStatistics

func (ar *AbstractRuntime) GetStatistics() *Statistics

type Configuration

type Configuration struct {
	Name           string
	Version        string
	Description    string
	DataBindings   map[string]*DataBinding
	FunctionLogger nuclio.Logger
}

func NewConfiguration

func NewConfiguration(configuration *viper.Viper) (*Configuration, error)

type Creator

type Creator interface {
	Create(logger nuclio.Logger, configuration *viper.Viper) (Runtime, error)
}

type DataBinding

type DataBinding struct {
	Name    string            `json:"name"`
	Class   string            `json:"class"`
	URL     string            `json:"url"`
	Path    string            `json:"path,omitempty"`
	Query   string            `json:"query,omitempty"`
	Secret  string            `json:"secret,omitempty"`
	Options map[string]string `json:"options,omitempty"`
}

Copied from functioncr to prevent dependencies on functioncr

type Registry

type Registry struct {
	registry.Registry
}

func (*Registry) NewRuntime

func (r *Registry) NewRuntime(logger nuclio.Logger,
	kind string,
	configuration *viper.Viper) (Runtime, error)

type Runtime

type Runtime interface {
	ProcessEvent(event nuclio.Event, functionLogger nuclio.Logger) (interface{}, error)

	GetFunctionLogger() nuclio.Logger

	GetStatistics() *Statistics
}

type Statistics

type Statistics struct {
	DurationMilliSecondsSum   uint64
	DurationMilliSecondsCount uint64
}

func (*Statistics) DiffFrom

func (s *Statistics) DiffFrom(prev *Statistics) Statistics