functions

type Context map[string]interface{}

type DockerImageBuilder struct {
	ImageRegistry string
	RegistryAuth  string
	PushImages    bool
	PullImages    bool
	// contains filtered or unexported fields
}

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(ctx context.Context, f *Function) error

	// Delete deletes the function in the FaaS implementation.
	// f is a reference to function defition.
	Delete(ctx context.Context, f *Function) error

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

type FnRun struct {
	entitystore.BaseEntity
	FunctionName string                 `json:"functionName"`
	FunctionID   string                 `json:"functionID"`
	FaasID       string                 `json:"faasId"`
	Blocking     bool                   `json:"blocking"`
	Input        interface{}            `json:"input,omitempty"`
	Output       interface{}            `json:"output,omitempty"`
	Secrets      []string               `json:"secrets,omitempty"`
	Services     []string               `json:"services,omitempty"`
	HTTPContext  map[string]interface{} `json:"httpContext,omitempty"`
	Event        *events.CloudEvent     `json:"event,omitempty"`
	Logs         *v1.Logs               `json:"logs,omitempty"`
	Error        *v1.InvocationError    `json:"error,omitempty"`
	FinishedTime time.Time              `json:"finishedTime,omitempty"`

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

type Function struct {
	entitystore.BaseEntity
	FaasID           string   `json:"faasId"`
	SourceURL        string   `json:"sourceURL"`
	Handler          string   `json:"handler"`
	ImageName        string   `json:"image"`
	ImageURL         string   `json:"imageURL"`
	FunctionImageURL string   `json:"functionImageURL"`
	Schema           *Schema  `json:"schema,omitempty"`
	Secrets          []string `json:"secrets,omitempty"`
	Services         []string `json:"services,omitempty"`
	Timeout          int64    `json:"timeout,omitempty"`
}

type FunctionError interface {
	AsFunctionErrorObject() interface{}
}

type FunctionExecution struct {
	Context        Context
	OrganizationID string
	RunID          string

	FunctionID string
	FaasID     string

	Schemas  *Schemas
	Secrets  []string
	Services []string
	Cookie   string
}

type FunctionResources struct {
	Memory string `json:"memory"`
	CPU    string `json:"cpu"`
}

type ImageBuilder interface {
	// BuildImage builds a function image and pushes it to the docker registry.
	// Returns image full name.
	BuildImage(ctx context.Context, f *Function, code []byte) (string, error)

	// RemoveImage removes a function image from the docker host
	RemoveImage(ctx context.Context, f *Function) error
}

type InputError interface {
	AsInputErrorObject() interface{}
}

type Message struct {
	Context Context     `json:"context"`
	Payload interface{} `json:"payload"`
}

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(organizationID string, secrets []string, cookie string) Middleware
}

type ServiceInjector interface {
	GetMiddleware(organizationID string, services []string, cookie string) Middleware
}

type Source struct {
	entitystore.BaseEntity
	Code []byte `json:"code"`
}

type StackTracer interface {
	StackTrace() errors.StackTrace
}

type SystemError interface {
	AsSystemErrorObject() interface{}
}

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