lambda

Documentation

Index

• Constants
• func CreateFnInstance(cfg model.FunctionConfig) (string, error)
• func GetSourceFilePath(tenant string) string
• func HealthCheck(url string) error
• func HealthCheckRetry(url string, retries int) error
• func StartNodeInstance(cfg model.FunctionConfig) (url string, err error)
• func ValidateFunctionConfig(cfg *model.FunctionTopic) error
• type FunctionInstance
• type WorkerSignal

Constants

const (
	// PulsarTrigger is pulsar input topic trigger
	PulsarTrigger = "pulsar-topic"

	// HTTPTrigger is http trigger
	HTTPTrigger = "http"

	// CronTrigger is time based cron trigger
	CronTrigger = "cron"
)

Functions

func CreateFnInstance

func CreateFnInstance(cfg model.FunctionConfig) (string, error)

CreateFnInstance creates function instance

func GetSourceFilePath

func GetSourceFilePath(tenant string) string

GetSourceFilePath gets the directory to source file

func HealthCheck

func HealthCheck(url string) error

HealthCheck checks the any language pack is running

func HealthCheckRetry

func HealthCheckRetry(url string, retries int) error

HealthCheckRetry is health check with retry

func StartNodeInstance

func StartNodeInstance(cfg model.FunctionConfig) (url string, err error)

StartNodeInstance starts node/javascript instance

func ValidateFunctionConfig

func ValidateFunctionConfig(cfg *model.FunctionTopic) error

ValidateFunctionConfig validates function config

Types

type FunctionInstance

type FunctionInstance struct {
	ID  string
	URI url.URL

	Pid       int
	CreatedAt time.Time
	UpdatedAt time.Time
	// contains filtered or unexported fields
}

FunctionInstance is the function worker instance running

type WorkerSignal

type WorkerSignal struct{}

WorkerSignal is a signal object to pass for channel