temporal

Documentation

Index

• func Close()
• func Init()
• func IsDirect(recipe *model.Recipe) bool
• func TriggerTemporalWorkflow(pipelineName string, recipe *model.Recipe, uid string, userName string) (map[string]string, error)

Functions

func Close

func Close()

func Init

func Init()

assign global client for Temporal server

func IsDirect

func IsDirect(recipe *model.Recipe) bool

Direct trigger: DS/DD kind are HTTP and no LO defined NOTE: Before migrate inference-backend into pipeline-backend, there is one more criteria is only 1 VDO

func TriggerTemporalWorkflow

func TriggerTemporalWorkflow(pipelineName string, recipe *model.Recipe, uid string, userName string) (map[string]string, error)