functions

Documentation

Index

• Constants
• func AssembleWorkflowServiceName(wf, svn string, hash uint64) string
• func GenerateServiceName(info *igrpc.BaseInfo) (string, string, string)
• func GenerateWorkflowServiceName(info *igrpc.BaseInfo) (string, string)
• func SanitizeLabel(s string) string
• func StartServer(echan chan error)
• func StopServer()
• type HeartbeatTuple

Constants

const (
	// Direktiv Headers
	ServiceHeaderName          = "direktiv.io/name"
	ServiceHeaderNamespaceID   = "direktiv.io/namespace-id"
	ServiceHeaderNamespaceName = "direktiv.io/namespace-name"
	ServiceHeaderWorkflowID    = "direktiv.io/workflow-id"
	ServiceHeaderPath          = "direktiv.io/path"
	ServiceHeaderRevision      = "direktiv.io/revision"
	ServiceHeaderSize          = "direktiv.io/size"
	ServiceHeaderScale         = "direktiv.io/scale"
	ServiceTemplateGeneration  = "direktiv.io/templateGeneration"
	ServiceHeaderScope         = "direktiv.io/scope"

	// Serving Headers
	ServiceKnativeHeaderName            = "serving.knative.dev/service"
	ServiceKnativeHeaderConfiguration   = "serving.knative.dev/configuration"
	ServiceKnativeHeaderGeneration      = "serving.knative.dev/configurationGeneration"
	ServiceKnativeHeaderRevision        = "serving.knative.dev/revision"
	ServiceKnativeHeaderRolloutDuration = "serving.knative.dev/rolloutDuration"

	// Extra Annotations
	ServiceKongIngressHeaderTimeoutName = "direktiv-functions-timeout"
	ServiceKongIngressHeaderTimeout     = "konghq.com/override"
)

Headers for knative services

const (
	PrefixWorkflow  = "workflow"
	PrefixNamespace = "namespace"
	PrefixGlobal    = "global"
	PrefixService   = "service" // unused, only if a one item list is requested
)

Available prefixes for different scopes

const (
	PodEnvActionID   = "DIREKTIV_ACTIONID"
	PodEnvInstanceID = "DIREKTIV_INSTANCEID"
	PodEnvStep       = "DIREKTIV_STEP"
)

Pod env vars

const FunctionsChannel = "fnsync"

Functions

func AssembleWorkflowServiceName

func AssembleWorkflowServiceName(wf, svn string, hash uint64) string

AssembleWorkflowServiceName generates a knative name based on workflow details

func GenerateServiceName

func GenerateServiceName(info *igrpc.BaseInfo) (string, string, string)

GenerateServiceName generates a knative name based on workflow details

func GenerateWorkflowServiceName

func GenerateWorkflowServiceName(info *igrpc.BaseInfo) (string, string)

GenerateWorkflowServiceName generates a knative name based on workflow details

func SanitizeLabel

func SanitizeLabel(s string) string

func StartServer

func StartServer(echan chan error)

StartServer starts functions grpc server

func StopServer

func StopServer()

StopServer is stopping server gracefully

Types

type HeartbeatTuple

type HeartbeatTuple struct {
	NamespaceName      string
	NamespaceID        string
	WorkflowPath       string
	WorkflowID         string
	Revision           string
	FunctionDefinition *model.ReusableFunctionDefinition
}