workflow

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// MetricTemporalConnAttempted - Metric Temporal Conn Attempted
	MetricTemporalConnAttempted = "temporal_connection_attempted"
	// MetricTemporalConnSucc - Metric Temporal Conn Succ
	MetricTemporalConnSucc = "temporal_connection_succeeded"
	// MetricTemporalConnStatus - Metric Temporal Conn Status
	MetricTemporalConnStatus = "temporal_connection_status"
)
View Source 
const (
	// RetryInterval- Retry Interval
	RetryInterval = 2
	// RetryCount - Retry Count
	RetryCount = 10
	// MaxTemporalActivityRetryCount - Max Temporal Activity Retry Count
	MaxTemporalActivityRetryCount = 7
)

Retry parameters for Temporal workflows

Variables

View Source 
var ManagerAccess *Manager.ManagerAccess

ManagerAccess - access to all managers

Functions

func Orchestrator 

func Orchestrator()

Orchestrator - Workflow Orchestrator

Types

type API 

type API struct{}

API - all API interface

func NewWorkflowManager 

func NewWorkflowManager(superForge *elektratypes.Elektra, superAPI *Manager.ManagerAPI, superConf *Manager.ManagerConf) *API

NewWorkflowManager - returns a new instance of helm manager

func (*API) AddWorkflow 

func (w *API) AddWorkflow(wf interface{})

AddWorkflow - Register all the resource workflow functions here

func (*API) DoActivity 

func (w *API) DoActivity(ctx context.Context, ResourceVer uint64, ResourceID string,
	ResourceReq interface{}, wflowMd workflowtypes.WorkflowMetadata) (interface{}, error)

DoActivity - Execute the Activity

func (*API) DoWorkflow 

func (w *API) DoWorkflow(ctx workflow.Context, TransactionID *wflows.TransactionID,
	ResourceRequest interface{}, wflowMd wflowtypes.WorkflowMetadata,
	retryOptions *wflows.WorkflowOptions) (actErr error, pubErr error)

DoWorkflow - Execute the Workflow

func (*API) GetState 

func (wflow *API) GetState() []string

GetState - handle http request

func (*API) Init 

func (wflow *API) Init()

Init - initialize the workflow orchestrator

func (*API) Invoke 

func (w *API) Invoke() error

Invoke all the resource workflow functions here

func (*API) Start 

func (wflow *API) Start()

Start the workflow orchestrator

func (*API) WatchCertFile 

func (wflow *API) WatchCertFile()

WatchCertFile - Watch Cert File

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.