package
0.0.0-20200625043019-ec8dcbf1eed9
Repository: https://github.com/kafkaesque-io/pubsub-function.git
Documentation: pkg.go.dev

# Functions

CreateFnInstance creates function instance.
GetSourceFilePath gets the directory to source file.
HealthCheck checks the any language pack is running.
HealthCheckRetry is health check with retry.
StartNodeInstance starts node/javascript instance.
ValidateFunctionConfig validates function config.

# Constants

CronTrigger is time based cron trigger.
HTTPTrigger is http trigger.
PulsarTrigger is pulsar input topic trigger.

# Structs

FunctionInstance is the function worker instance running.
WorkerSignal is a signal object to pass for channel.