functions

type Context map[string]interface{}

type Exec struct {
	// Code is the function code, either as readable text or base64 encoded (for .zip and .jar archives)
	Code string
	// Main is the function's entry point (aka main function), by default "main"
	Main string
	// Image is the function's docker image
	Image string
	// Language is the function's runtime language
	Language string
}

type FaaSDriver interface {
	// Create creates (or updates, if is already exists) the function in the FaaS implementation.
	// name is the name of the function.
	// exec defines the function implementation.
	Create(f *Function, exec *Exec) error

	// Delete deletes the function in the FaaS implementation.
	// name is the name of the function.
	Delete(f *Function) error

	// GetRunnable returns a callable representation of a function.
	// name is the name of the function.
	GetRunnable(e *FunctionExecution) Runnable
}

type FnRun struct {
	entitystore.BaseEntity
	FunctionName string      `json:"functionName"`
	FunctionID   string      `json:"functionID"`
	Blocking     bool        `json:"blocking"`
	Input        interface{} `json:"input,omitempty"`
	Output       interface{} `json:"output,omitempty"`
	Secrets      []string    `json:"secrets,omitempty"`
	Logs         []string    `json:"logs,omitempty"`
	FinishedTime time.Time   `json:"finishedTime,omitempty"`

	WaitChan chan struct{} `json:"-"`
}

type Function struct {
	entitystore.BaseEntity
	Code      string   `json:"code"`
	Main      string   `json:"main"`
	ImageName string   `json:"image"`
	Schema    *Schema  `json:"schema,omitempty"`
	Secrets   []string `json:"secrets,omitempty"`
}

type FunctionError interface {
	AsFunctionErrorObject() interface{}
}

type FunctionExecution struct {
	Context Context

	Name string
	ID   string

	Schemas *Schemas
	Secrets []string
	Cookie  string
}

type Middleware func(f Runnable) Runnable

type Runnable func(ctx Context, in interface{}) (interface{}, error)

type Runner interface {
	Run(fn *FunctionExecution, in interface{}) (interface{}, error)
}

type Schema struct {
	In  *spec.Schema `json:"in,omitempty"`
	Out *spec.Schema `json:"out,omitempty"`
}

type Schemas struct {
	// SchemaIn is the function input validation schema data structure. Can be nil.
	SchemaIn interface{}
	// SchemaOut is the function output validation schema data structure. Can be nil.
	SchemaOut interface{}
}

type SecretInjector interface {
	GetMiddleware(secrets []string, cookie string) Middleware
}

type UserError interface {
	AsUserErrorObject() interface{}
}

type Validator interface {
	GetMiddleware(schemas *Schemas) Middleware
}