Documentation
¶
Index ¶
- type Activities
- func (a *Activities) PkgStatusGetInstallStackVersionStatus(ctx context.Context, req GetStatusRequest) (*app.CompositeStatus, error)
- func (a *Activities) PkgStatusGetInstallWorkflowStatus(ctx context.Context, req GetStatusRequest) (*app.CompositeStatus, error)
- func (a *Activities) PkgStatusGetInstallWorkflowStepStatus(ctx context.Context, req GetStatusRequest) (*app.CompositeStatus, error)
- func (a *Activities) PkgStatusUpdateFlowStatus(ctx context.Context, req UpdateStatusRequest) error
- func (a *Activities) PkgStatusUpdateFlowStepStatus(ctx context.Context, req UpdateStatusRequest) error
- func (a *Activities) PkgStatusUpdateInstallStackVersionStatus(ctx context.Context, req UpdateStatusRequest) error
- func (a *Activities) PkgStatusUpdateInstallWorkflowStatus(ctx context.Context, req UpdateStatusRequest) error
- func (a *Activities) PkgStatusUpdateInstallWorkflowStepStatus(ctx context.Context, req UpdateStatusRequest) error
- func (a *Activities) UpdateBuildStatusV2(ctx context.Context, req UpdateBuildStatusV2) error
- func (a *Activities) UpdateDeployStatusV2(ctx context.Context, req UpdateDeployStatusV2Request) error
- func (a *Activities) UpdateInstallWorkflowRunStatusV2(ctx context.Context, req UpdateInstallWorkflowRunStatusV2Request) error
- func (a *Activities) UpdateRunStatusV2(ctx context.Context, req UpdateRunStatusV2Request) error
- type GetStatusRequest
- type Params
- type UpdateBuildStatusV2
- type UpdateDeployStatusV2Request
- type UpdateInstallWorkflowRunStatusV2Request
- type UpdateRunStatusV2Request
- type UpdateStatusRequest
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) PkgStatusGetInstallStackVersionStatus ¶
func (a *Activities) PkgStatusGetInstallStackVersionStatus(ctx context.Context, req GetStatusRequest) (*app.CompositeStatus, error)
@temporal-gen activity @by-id ID
func (*Activities) PkgStatusGetInstallWorkflowStatus ¶
func (a *Activities) PkgStatusGetInstallWorkflowStatus(ctx context.Context, req GetStatusRequest) (*app.CompositeStatus, error)
@temporal-gen activity @by-id ID
func (*Activities) PkgStatusGetInstallWorkflowStepStatus ¶
func (a *Activities) PkgStatusGetInstallWorkflowStepStatus(ctx context.Context, req GetStatusRequest) (*app.CompositeStatus, error)
@temporal-gen activity @by-id ID
func (*Activities) PkgStatusUpdateFlowStatus ¶
func (a *Activities) PkgStatusUpdateFlowStatus(ctx context.Context, req UpdateStatusRequest) error
@temporal-gen activity
func (*Activities) PkgStatusUpdateFlowStepStatus ¶
func (a *Activities) PkgStatusUpdateFlowStepStatus(ctx context.Context, req UpdateStatusRequest) error
@temporal-gen activity
func (*Activities) PkgStatusUpdateInstallStackVersionStatus ¶
func (a *Activities) PkgStatusUpdateInstallStackVersionStatus(ctx context.Context, req UpdateStatusRequest) error
@temporal-gen activity
func (*Activities) PkgStatusUpdateInstallWorkflowStatus ¶
func (a *Activities) PkgStatusUpdateInstallWorkflowStatus(ctx context.Context, req UpdateStatusRequest) error
TODO(sdboyer) remove after workflow refactor @temporal-gen activity
func (*Activities) PkgStatusUpdateInstallWorkflowStepStatus ¶
func (a *Activities) PkgStatusUpdateInstallWorkflowStepStatus(ctx context.Context, req UpdateStatusRequest) error
TODO(sdboyer) remove after workflow refactor @temporal-gen activity
func (*Activities) UpdateBuildStatusV2 ¶
func (a *Activities) UpdateBuildStatusV2(ctx context.Context, req UpdateBuildStatusV2) error
@temporal-gen activity
func (*Activities) UpdateDeployStatusV2 ¶
func (a *Activities) UpdateDeployStatusV2(ctx context.Context, req UpdateDeployStatusV2Request) error
@temporal-gen activity
func (*Activities) UpdateInstallWorkflowRunStatusV2 ¶
func (a *Activities) UpdateInstallWorkflowRunStatusV2(ctx context.Context, req UpdateInstallWorkflowRunStatusV2Request) error
@temporal-gen activity @by-id RunID
func (*Activities) UpdateRunStatusV2 ¶
func (a *Activities) UpdateRunStatusV2(ctx context.Context, req UpdateRunStatusV2Request) error
@temporal-gen activity
type GetStatusRequest ¶
type GetStatusRequest struct {
ID string `json:"id" validate:"required"`
}
NOTE(jm): this could probably be implemented with some type of parsing the ID to figure out what model is represented by it, but if we do that and something _does not_ work, then it's going to be damn near impossible to debug, so we keep the verbose approach here, until something more elegant comes along.
type UpdateBuildStatusV2 ¶
type UpdateBuildStatusV2 struct {
BuildID string `validate:"required"`
Status app.ComponentBuildStatus `validate:"required"`
StatusDescription string `validate:"required"`
}
type UpdateInstallWorkflowRunStatusV2Request ¶
type UpdateInstallWorkflowRunStatusV2Request struct {
RunID string `validate:"required"`
Status app.InstallActionWorkflowRunStatus `validate:"required"`
StatusDescription string `validate:"required"`
}
type UpdateRunStatusV2Request ¶
type UpdateRunStatusV2Request struct {
RunID string `validate:"required"`
Status app.SandboxRunStatus `validate:"required"`
StatusDescription string `validate:"required"`
SkipStatusSync bool
}
type UpdateStatusRequest ¶
type UpdateStatusRequest struct {
ID string `validate:"required"`
Status app.CompositeStatus `json:"status" validate:"required"`
}
NOTE
This package is the beginning of consolidating all status logic into a single package.
Right now, it's a bit verbose with getters for statuses when updating, however long term we can either generate this or make the status selectable in isolation by selecting the field using reflection or something else.
However, for now, this interface provides a few things: 1. ability to manage history of a status 2. ability to start doing things such as sending a signal to a channel if needed. This enables the ability to start blocking for a "status" change or a specific status.
Source Files