Documentation
¶
Index ¶
- func GetTestWorkflowID(deploymentName, buildID, taskQueue string) string
- func GetTestWorkflowStatus(ctx context.Context, client temporalClient.Client, workerDeploymentName string, ...) ([]temporaliov1alpha1.WorkflowExecution, error)
- func HasUnversionedPoller(ctx context.Context, client temporalClient.Client, ...) (bool, error)
- type TemporalWorkerState
- type VersionInfo
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, buildID string, workerDeploy *temporaliov1alpha1.TemporalWorkerDeployment, temporalState *TemporalWorkerState, ) ([]temporaliov1alpha1.WorkflowExecution, error)
GetTestWorkflowStatus queries Temporal to get the status of test workflows for a version
func HasUnversionedPoller ¶ added in v1.0.0
func HasUnversionedPoller(ctx context.Context, client temporalClient.Client, taskQueueInfo temporalClient.WorkerDeploymentTaskQueueInfo, ) (bool, error)
Types ¶
type TemporalWorkerState ¶
type TemporalWorkerState struct {
CurrentBuildID string
VersionConflictToken []byte
RampingBuildID string
RampPercentage float32
// RampingSince is the time when the current ramping version was set.
RampingSince *metav1.Time
RampLastModifiedAt *metav1.Time
// Versions indexed by build ID
Versions map[string]*VersionInfo
LastModifierIdentity string
ManagerIdentity 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, k8sDeployments map[string]*appsv1.Deployment, targetBuildID string, strategy temporaliov1alpha1.DefaultVersionUpdateStrategy, controllerIdentity string, ) (*TemporalWorkerState, error)
GetWorkerDeploymentState queries Temporal to get the state of a worker deployment
type VersionInfo ¶
type VersionInfo struct {
DeploymentName string
BuildID string
Status temporaliov1alpha1.VersionStatus
DrainedSince *time.Time
TaskQueues []temporaliov1alpha1.TaskQueue
TestWorkflows []temporaliov1alpha1.WorkflowExecution
// True if all task queues in this version have at least one unversioned poller.
// False could just mean unknown / not checked / not checked successfully.
// Only checked for Target Version when Current Version is nil and strategy is Progressive.
// Used to decide whether to fast track the rollout; rollout will be AllAtOnce if:
// - Current Version is nil
// - Strategy is Progressive, and
// - Presence of unversioned pollers in all task queues of target version cannot be confirmed.
AllTaskQueuesHaveUnversionedPoller bool
}
VersionInfo contains information about a specific version
Click to show internal directories.
Click to hide internal directories.