Documentation
¶
Index ¶
- type Activities
- func (a *Activities) CheckNoopPlan(ctx context.Context, req *CheckNoopPlanRequest) (bool, error)
- func (a *Activities) CreateApprovalResponse(ctx context.Context, req CreateStepApprovalResponseRequest) (*app.WorkflowStepApprovalResponse, error)
- func (a *Activities) EvaluateSinglePolicy(ctx context.Context, req *EvaluateSinglePolicyRequest) (*EvaluateSinglePolicyResult, error)
- func (a *Activities) GetApprovalPlan(ctx context.Context, req GetApprovalPlanRequest) (*ApprovalPlan, error)
- func (a *Activities) PkgWorkflowsFlowCreateFlowSteps(ctx context.Context, reqs CreateFlowStepsRequest) ([]*app.WorkflowStep, error)
- func (a *Activities) PkgWorkflowsFlowGetFlow(ctx context.Context, req GetFlowRequest) (*app.Workflow, error)
- func (a *Activities) PkgWorkflowsFlowGetFlowSteps(ctx context.Context, req GetFlowStepsRequest) ([]app.WorkflowStep, error)
- func (a *Activities) PkgWorkflowsFlowGetFlowsStep(ctx context.Context, req GetFlowStepRequest) (*app.WorkflowStep, error)
- func (a *Activities) PkgWorkflowsFlowResetFlowFinishedAt(ctx context.Context, req ResetFlowFinishedAtRequest) error
- func (a *Activities) PkgWorkflowsFlowUpdateFlowFinishedAt(ctx context.Context, req UpdateFlowFinishedAtRequest) error
- func (a *Activities) PkgWorkflowsFlowUpdateFlowStartedAt(ctx context.Context, req UpdateFlowStartedAtRequest) error
- func (a *Activities) PkgWorkflowsFlowUpdateFlowStepFinishedAt(ctx context.Context, req UpdateFlowStepFinishedAtRequest) error
- func (a *Activities) PkgWorkflowsFlowUpdateFlowStepStartedAt(ctx context.Context, req UpdateFlowStepStartedAtRequest) error
- func (a *Activities) PkgWorkflowsFlowUpdateFlowStepTargetStatus(ctx context.Context, req UpdateFlowStepTargetStatusRequest) error
- func (a *Activities) PrepPolicyEvaluation(ctx context.Context, req *PrepPolicyEvaluationRequest) (*PrepPolicyEvaluationResult, error)
- type ApprovalPlan
- type CheckNoopPlanRequest
- type CreateFlowStep
- type CreateFlowStepsRequest
- type CreateStepApprovalResponseRequest
- type EvaluateSinglePolicyRequest
- type EvaluateSinglePolicyResult
- type GetApprovalPlanRequest
- type GetFlowRequest
- type GetFlowStepRequest
- type GetFlowStepsRequest
- type GetRunnerJobExecutionRequest
- type GetRunnerJobExecutionResultRequest
- type GetRunnerJobRequest
- type Params
- type PolicyToEvaluate
- type PolicyViolation
- type PrepPolicyEvaluationRequest
- type PrepPolicyEvaluationResult
- type ResetFlowFinishedAtRequest
- type UpdateFlowFinishedAtRequest
- type UpdateFlowStartedAtRequest
- type UpdateFlowStepFinishedAtRequest
- type UpdateFlowStepStartedAtRequest
- type UpdateFlowStepTargetStatusRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Activities ¶
type Activities struct {
// contains filtered or unexported fields
}
func New ¶
func New(params Params) *Activities
func (*Activities) CheckNoopPlan ¶
func (a *Activities) CheckNoopPlan(ctx context.Context, req *CheckNoopPlanRequest) (bool, error)
@temporal-gen activity @max-retries 1
func (*Activities) CreateApprovalResponse ¶
func (a *Activities) CreateApprovalResponse(ctx context.Context, req CreateStepApprovalResponseRequest) (*app.WorkflowStepApprovalResponse, error)
@temporal-gen activity @schedule-to-close-timeout 1m @start-to-close-timeout 10s
func (*Activities) EvaluateSinglePolicy ¶
func (a *Activities) EvaluateSinglePolicy(ctx context.Context, req *EvaluateSinglePolicyRequest) (*EvaluateSinglePolicyResult, error)
@temporal-gen activity @max-retries 1 @schedule-to-close-timeout 2m @start-to-close-timeout 1m30s
func (*Activities) GetApprovalPlan ¶
func (a *Activities) GetApprovalPlan(ctx context.Context, req GetApprovalPlanRequest) (*ApprovalPlan, error)
@temporal-gen activity @max-retries 1
func (*Activities) PkgWorkflowsFlowCreateFlowSteps ¶
func (a *Activities) PkgWorkflowsFlowCreateFlowSteps(ctx context.Context, reqs CreateFlowStepsRequest) ([]*app.WorkflowStep, error)
@temporal-gen activity
func (*Activities) PkgWorkflowsFlowGetFlow ¶
func (a *Activities) PkgWorkflowsFlowGetFlow(ctx context.Context, req GetFlowRequest) (*app.Workflow, error)
@temporal-gen activity @by-id ID
func (*Activities) PkgWorkflowsFlowGetFlowSteps ¶
func (a *Activities) PkgWorkflowsFlowGetFlowSteps(ctx context.Context, req GetFlowStepsRequest) ([]app.WorkflowStep, error)
@temporal-gen activity @by-id FlowID
func (*Activities) PkgWorkflowsFlowGetFlowsStep ¶
func (a *Activities) PkgWorkflowsFlowGetFlowsStep(ctx context.Context, req GetFlowStepRequest) (*app.WorkflowStep, error)
@temporal-gen activity @by-id FlowStepID
func (*Activities) PkgWorkflowsFlowResetFlowFinishedAt ¶
func (a *Activities) PkgWorkflowsFlowResetFlowFinishedAt(ctx context.Context, req ResetFlowFinishedAtRequest) error
@temporal-gen activity @by-id ID
func (*Activities) PkgWorkflowsFlowUpdateFlowFinishedAt ¶
func (a *Activities) PkgWorkflowsFlowUpdateFlowFinishedAt(ctx context.Context, req UpdateFlowFinishedAtRequest) error
@temporal-gen activity @by-id ID
func (*Activities) PkgWorkflowsFlowUpdateFlowStartedAt ¶
func (a *Activities) PkgWorkflowsFlowUpdateFlowStartedAt(ctx context.Context, req UpdateFlowStartedAtRequest) error
@temporal-gen activity @by-id ID
func (*Activities) PkgWorkflowsFlowUpdateFlowStepFinishedAt ¶
func (a *Activities) PkgWorkflowsFlowUpdateFlowStepFinishedAt(ctx context.Context, req UpdateFlowStepFinishedAtRequest) error
@temporal-gen activity @by-id ID
func (*Activities) PkgWorkflowsFlowUpdateFlowStepStartedAt ¶
func (a *Activities) PkgWorkflowsFlowUpdateFlowStepStartedAt(ctx context.Context, req UpdateFlowStepStartedAtRequest) error
@temporal-gen activity @by-id ID
func (*Activities) PkgWorkflowsFlowUpdateFlowStepTargetStatus ¶
func (a *Activities) PkgWorkflowsFlowUpdateFlowStepTargetStatus(ctx context.Context, req UpdateFlowStepTargetStatusRequest) error
@temporal-gen activity
func (*Activities) PrepPolicyEvaluation ¶
func (a *Activities) PrepPolicyEvaluation(ctx context.Context, req *PrepPolicyEvaluationRequest) (*PrepPolicyEvaluationResult, error)
@temporal-gen activity @max-retries 1 @schedule-to-close-timeout 5m @start-to-close-timeout 4m
type ApprovalPlan ¶
type ApprovalPlan struct {
RunnerJobType app.RunnerJobType `json:"runner_job_type" temporaljson:"runner_job_type,omitempty"`
PlanContents []byte `json:"plan_contents" temporaljson:"plan_contents,omitempty"`
}
func (*ApprovalPlan) IsNoopPlan ¶
func (p *ApprovalPlan) IsNoopPlan() (bool, error)
type CheckNoopPlanRequest ¶
type CheckNoopPlanRequest struct {
StepTargetID string `validate:"required"`
}
type CreateFlowStep ¶
type CreateFlowStep struct {
FlowID string `json:"flow_id" validate:"required"`
OwnerID string `json:"owner_id" validate:"required"`
OwnerType string `json:"owner_type" validate:"required"`
Status app.CompositeStatus `json:"status"`
Name string `json:"name"`
Signal app.Signal `json:"signal"`
Idx int `json:"idx"`
ExecutionType app.WorkflowStepExecutionType `json:"execution_type"`
Metadata pgtype.Hstore `json:"metadata"`
Retryable bool `json:"retryable"`
Skippable bool `json:"skippable"`
GroupIdx int `json:"group_idx"`
GroupRetryIdx int `json:"group_retry_idx"`
StepTargetType string `json:"step_target_type"`
StepTargetID string `json:"step_target_id"`
}
type CreateFlowStepsRequest ¶
type CreateFlowStepsRequest struct {
Steps []CreateFlowStep `json:"steps" validate:"required"`
}
type CreateStepApprovalResponseRequest ¶
type CreateStepApprovalResponseRequest struct {
StepApprovalID string `json:"step_approval_id" validate:"required"`
Type app.WorkflowStepResponseType `json:"type" validate:"required"`
Note string `json:"note" validate:"required"`
}
type EvaluateSinglePolicyResult ¶
type EvaluateSinglePolicyResult struct {
Violations []PolicyViolation `json:"violations" temporaljson:"violations,omitempty"`
}
type GetApprovalPlanRequest ¶
type GetApprovalPlanRequest struct {
StepTargetID string `validate:"required"`
}
type GetFlowRequest ¶
type GetFlowRequest struct {
ID string `validate:"required"`
}
type GetFlowStepRequest ¶
type GetFlowStepRequest struct {
FlowStepID string `json:"flow_step_id" validate:"required"`
}
type GetFlowStepsRequest ¶
type GetFlowStepsRequest struct {
FlowID string `json:"flow_id" validate:"required"`
}
type GetRunnerJobExecutionRequest ¶
type GetRunnerJobExecutionRequest struct {
RunnerJobID string `validate:"required"`
}
type GetRunnerJobExecutionResultRequest ¶
type GetRunnerJobExecutionResultRequest struct {
RunnerJobExecutionID string `validate:"required"`
}
type GetRunnerJobRequest ¶
type GetRunnerJobRequest struct {
RunnerJobOwnerID string `validate:"required"`
}
type PolicyToEvaluate ¶
type PolicyViolation ¶
type PrepPolicyEvaluationResult ¶
type PrepPolicyEvaluationResult struct {
Policies []PolicyToEvaluate `json:"policies" temporaljson:"policies,omitempty"`
HasPolicies bool `json:"has_policies" temporaljson:"has_policies,omitempty"`
}
type ResetFlowFinishedAtRequest ¶
type ResetFlowFinishedAtRequest struct {
ID string `validate:"required"`
}
type UpdateFlowFinishedAtRequest ¶
type UpdateFlowFinishedAtRequest struct {
ID string `validate:"required"`
}
type UpdateFlowStartedAtRequest ¶
type UpdateFlowStartedAtRequest struct {
ID string `validate:"required"`
}
type UpdateFlowStepFinishedAtRequest ¶
type UpdateFlowStepFinishedAtRequest struct {
ID string `validate:"required"`
}
type UpdateFlowStepStartedAtRequest ¶
type UpdateFlowStepStartedAtRequest struct {
ID string `validate:"required"`
}
type UpdateFlowStepTargetStatusRequest ¶
type UpdateFlowStepTargetStatusRequest struct {
StepID string `validate:"required"`
Status app.Status `validate:"required"`
StatusDescription string
}
NOTE(jm): once install-deploys and sandbox-runs objects are updated to the composite status type, we will not need to use this type of update flow
Source Files
¶
- activities.go
- approvals.go
- check_noop_plan.go
- create_flow_steps.go
- evaluate_single_policy.go
- get_flow.go
- get_flow_step.go
- get_flow_steps.go
- get_runner_job.go
- prep_policy_evaluation.go
- reset_flow_finished_at.go
- update_flow_finished_at.go
- update_flow_started_at.go
- update_flow_step_finished_at.go
- update_flow_step_started_at.go
- update_flow_step_target_status.go