Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetTestWorkflowID ¶
GetTestWorkflowID generates a workflowID for test workflows
func GetTestWorkflowStatus ¶
func GetTestWorkflowStatus( ctx context.Context, client temporalClient.Client, workerDeploymentName string, versionID string, workerDeploy *temporaliov1alpha1.TemporalWorkerDeployment, temporalState *TemporalWorkerState, ) ([]temporaliov1alpha1.WorkflowExecution, error)
GetTestWorkflowStatus queries Temporal to get the status of test workflows for a version
Types ¶
type TemporalWorkerState ¶
type TemporalWorkerState struct {
CurrentVersionID string
VersionConflictToken []byte
RampingVersionID string
RampPercentage float32
// RampingSince is the time when the current ramping version was set.
RampingSince *metav1.Time
RampLastModifiedAt *metav1.Time
Versions map[string]*VersionInfo
LastModifierIdentity string
}
TemporalWorkerState represents the state of a worker deployment in Temporal
func GetWorkerDeploymentState ¶
func GetWorkerDeploymentState( ctx context.Context, client temporalClient.Client, workerDeploymentName string, namespace string, ) (*TemporalWorkerState, error)
GetWorkerDeploymentState queries Temporal to get the state of a worker deployment
type VersionInfo ¶
type VersionInfo struct {
VersionID string
Status temporaliov1alpha1.VersionStatus
DrainedSince *time.Time
TaskQueues []temporaliov1alpha1.TaskQueue
TestWorkflows []temporaliov1alpha1.WorkflowExecution
}
VersionInfo contains information about a specific version
Source Files
Click to show internal directories.
Click to hide internal directories.