activities

package
v0.19.921 Latest Latest
Warning

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

Go to latest
Published: May 7, 2026 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

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) CheckContainerImagePoliciesExist added in v0.19.767

@temporal-gen-v2 activity @max-retries 1 @schedule-to-close-timeout 1m @start-to-close-timeout 30s

func (*Activities) CheckExists

func (a *Activities) CheckExists(ctx context.Context, req CheckExistsRequest) (bool, error)

@temporal-gen-v2 activity @schedule-to-close-timeout 1m @start-to-close-timeout 10s @by-field ID

func (*Activities) CloseLogStream

func (a *Activities) CloseLogStream(ctx context.Context, req CloseLogStreamRequest) error

@temporal-gen-v2 activity @by-field LogStreamID

func (*Activities) CreateBuildJob

func (a *Activities) CreateBuildJob(ctx context.Context, req *CreateBuildJobRequest) (*app.RunnerJob, error)

@temporal-gen-v2 activity

func (*Activities) CreateComponentBuildRecord added in v0.19.894

func (a *Activities) CreateComponentBuildRecord(ctx context.Context, req CreateComponentBuildRecordRequest) (*app.ComponentBuild, error)

CreateComponentBuildRecord creates a component build record without dispatching to the event loop. Used by queue signals that handle build execution themselves.

@temporal-gen-v2 activity

func (*Activities) CreateFetchImageMetadataJob

func (a *Activities) CreateFetchImageMetadataJob(ctx context.Context, req *CreateFetchImageMetadataJobRequest) (*app.RunnerJob, error)

@temporal-gen-v2 activity

func (*Activities) CreateJobLogToken

func (a *Activities) CreateJobLogToken(ctx context.Context, req CreateTokenRequest) (*CreateTokenResponse, error)

@temporal-gen-v2 activity @by-field RunnerID

func (*Activities) CreateLogStream

func (a *Activities) CreateLogStream(ctx context.Context, req CreateLogStreamRequest) (*app.LogStream, error)

@temporal-gen-v2 activity @by-field BuildID

func (*Activities) Delete

func (a *Activities) Delete(ctx context.Context, req DeleteRequest) error

@temporal-gen-v2 activity @by-field ComponentID

func (*Activities) FetchImageMetadata

@temporal-gen-v2 activity @max-retries 2 @schedule-to-close-timeout 5m @start-to-close-timeout 4m

func (*Activities) GetBuildGitSource

func (a *Activities) GetBuildGitSource(ctx context.Context, req GetBuildGitSource) (*plantypes.GitSource, error)

@temporal-gen-v2 activity @by-field BuildID

func (*Activities) GetCloudProvider added in v0.19.870

func (a *Activities) GetCloudProvider(ctx context.Context, req *GetCloudProviderRequest) (string, error)

@temporal-gen-v2 activity @max-retries 1

func (*Activities) GetComponent

func (a *Activities) GetComponent(ctx context.Context, req GetComponentRequest) (*app.Component, error)

@temporal-gen-v2 activity @by-field ComponentID

func (*Activities) GetComponentApp

func (a *Activities) GetComponentApp(ctx context.Context, req *GetComponentAppRequest) (*app.App, error)

@temporal-gen-v2 activity @by-field ComponentID

func (*Activities) GetComponentAppConfig

func (a *Activities) GetComponentAppConfig(ctx context.Context, req *GetComponentAppConfigRequest) (*app.AppConfig, error)

@temporal-gen-v2 activity @by-field ComponentID

func (*Activities) GetComponentBuild

func (a *Activities) GetComponentBuild(ctx context.Context, req GetComponentBuildRequest) (*app.ComponentBuild, error)

@temporal-gen-v2 activity @by-field ID

func (*Activities) GetComponentBuildForPolicyEval added in v0.19.783

func (a *Activities) GetComponentBuildForPolicyEval(ctx context.Context, req GetComponentBuildForPolicyEvalRequest) (*app.ComponentBuild, error)

@temporal-gen-v2 activity @by-field ID

func (*Activities) GetComponentBuildWithConfig

func (a *Activities) GetComponentBuildWithConfig(ctx context.Context, req GetComponentBuildWithConfigRequest) (*app.ComponentBuild, error)

@temporal-gen-v2 activity @by-field ID

func (*Activities) GetComponentDependents

func (a *Activities) GetComponentDependents(ctx context.Context, req GetComponentDependentsRequest) ([]string, error)

@temporal-gen-v2 activity

func (*Activities) GetComponentInstalls

func (a *Activities) GetComponentInstalls(ctx context.Context, req GetComponentInstallsRequest) ([]string, error)

@temporal-gen-v2 activity

func (*Activities) GetComponentOCIRegistryRepository

func (a *Activities) GetComponentOCIRegistryRepository(ctx context.Context, req *GetComponentOCIRegistryRepository) (*configs.OCIRegistryRepository, error)

@temporal-gen-v2 activity @by-field ComponentID

func (*Activities) GetComponentsWithType

func (a *Activities) GetComponentsWithType(ctx context.Context, req GetComponentsWithType) ([]app.Component, error)

@temporal-gen-v2 activity @start-to-close-timeout 300s @max-retries 1

func (*Activities) GetGARAccessToken added in v0.19.870

func (a *Activities) GetGARAccessToken(ctx context.Context, req *GetGARAccessTokenRequest) (*GARAccessToken, error)

@temporal-gen-v2 activity @max-retries 1

func (*Activities) GetHelmComponentConfig

func (a *Activities) GetHelmComponentConfig(ctx context.Context, req GetHelmComponentConfigRequest) (*app.HelmComponentConfig, error)

@temporal-gen-v2 activity @by-field ComponentConfigConnectionID

func (*Activities) GetImageMetadataFromJobResult

@temporal-gen-v2 activity @max-retries 2 @schedule-to-close-timeout 1m @start-to-close-timeout 30s

func (*Activities) GetJob

func (a *Activities) GetJob(ctx context.Context, req *GetJobRequest) (*app.RunnerJob, error)

@temporal-gen-v2 activity @by-field ID

func (*Activities) GetOrg

func (a *Activities) GetOrg(ctx context.Context, req GetOrgRequest) (*app.Org, error)

@temporal-gen-v2 activity @by-field ID

func (*Activities) GetPoliciesConfigByAppConfigID added in v0.19.783

func (a *Activities) GetPoliciesConfigByAppConfigID(ctx context.Context, req *GetPoliciesConfigByAppConfigIDRequest) (*app.AppPoliciesConfig, error)

@temporal-gen-v2 activity @max-retries 1

func (*Activities) GetRunnerJobExecutionByJobID added in v0.19.783

func (a *Activities) GetRunnerJobExecutionByJobID(ctx context.Context, req *GetRunnerJobExecutionByJobIDRequest) (*app.RunnerJobExecution, error)

@temporal-gen-v2 activity @max-retries 1

func (*Activities) GetRunnerJobExecutionResult added in v0.19.783

func (a *Activities) GetRunnerJobExecutionResult(ctx context.Context, req *GetRunnerJobExecutionResultRequest) (*app.RunnerJobExecutionResult, error)

@temporal-gen-v2 activity @max-retries 1

func (*Activities) GetUnknownComponentCount

func (a *Activities) GetUnknownComponentCount(ctx context.Context, req GetcomponentRecordsCount) (int64, error)

@temporal-gen-v2 activity

func (*Activities) GetUnknownComponentIDs

func (a *Activities) GetUnknownComponentIDs(ctx context.Context, req GetUnknownComponents) ([]string, error)

@temporal-gen-v2 activity

func (*Activities) OrgHasFeature added in v0.19.903

func (a *Activities) OrgHasFeature(ctx context.Context, req OrgHasFeatureRequest) (bool, error)

OrgHasFeature returns true if the given org has the given feature flag enabled. Mirror of the orgs-namespace activity of the same name; needed because workflows running in the components namespace cannot dispatch activities to the orgs worker.

@temporal-gen-v2 activity

func (*Activities) PrepExternalImagePolicy

@temporal-gen-v2 activity @max-retries 1 @schedule-to-close-timeout 5m @start-to-close-timeout 4m

func (*Activities) QueueComponentBuild

func (a *Activities) QueueComponentBuild(ctx context.Context, req QueueComponentBuildRequest) (*app.ComponentBuild, error)

@temporal-gen-v2 activity

func (*Activities) SaveFetchImageMetadataPlan

func (a *Activities) SaveFetchImageMetadataPlan(ctx context.Context, req *SaveFetchImageMetadataPlanRequest) error

@temporal-gen-v2 activity @max-retries 2 @schedule-to-close-timeout 1m @start-to-close-timeout 30s

func (*Activities) SaveRunnerJobPlan

func (a *Activities) SaveRunnerJobPlan(ctx context.Context, req *SaveRunnerJobPlanRequest) error

@temporal-gen-v2 activity

func (*Activities) UpdateBuildStatus

func (a *Activities) UpdateBuildStatus(ctx context.Context, req UpdateBuildStatus) error

@temporal-gen-v2 activity

func (*Activities) UpdateComponentType

func (a *Activities) UpdateComponentType(ctx context.Context, req UpdateComponentTypeRequest) error

@temporal-gen-v2 activity

func (*Activities) UpdateJobStatus

func (a *Activities) UpdateJobStatus(ctx context.Context, req *UpdateJobStatusRequest) error

@temporal-gen-v2 activity

func (*Activities) UpdateStatus

func (a *Activities) UpdateStatus(ctx context.Context, req UpdateStatusRequest) error

@temporal-gen-v2 activity

type CheckContainerImagePoliciesExistRequest added in v0.19.767

type CheckContainerImagePoliciesExistRequest struct {
	BuildID string `validate:"required"`
}

type CheckContainerImagePoliciesExistResult added in v0.19.767

type CheckContainerImagePoliciesExistResult struct {
	HasPolicies   bool   `json:"has_policies" temporaljson:"has_policies,omitempty"`
	ComponentName string `json:"component_name" temporaljson:"component_name,omitempty"`
	AppConfigID   string `json:"app_config_id" temporaljson:"app_config_id,omitempty"`
}

type CheckExistsRequest

type CheckExistsRequest struct {
	ID string `validate:"required"`
}

type CloseLogStreamRequest

type CloseLogStreamRequest struct {
	LogStreamID string `validate:"required"`
}

type CreateBuildJobRequest

type CreateBuildJobRequest struct {
	BuildID     string                     `validate:"required"`
	RunnerID    string                     `validate:"required"`
	Op          app.RunnerJobOperationType `validate:"required"`
	Type        app.RunnerJobType          `validate:"required"`
	LogStreamID string                     `validate:"required"`
	Metadata    map[string]string          `validate:"required"`
}

type CreateComponentBuildRecordRequest added in v0.19.894

type CreateComponentBuildRecordRequest struct {
	ComponentID string `validate:"required"`
	OrgID       string `validate:"required"`
	CreatedByID string `validate:"required"`

	// GitRef overrides useLatest when set. Used to pin a build to the branch's specific commit.
	GitRef *string
	// VCSConnectionCommitID is a pre-resolved commit to attach to the build record.
	VCSConnectionCommitID *string
}

type CreateFetchImageMetadataJobRequest

type CreateFetchImageMetadataJobRequest struct {
	BuildID     string            `validate:"required"`
	RunnerID    string            `validate:"required"`
	LogStreamID string            `validate:"required"`
	Metadata    map[string]string `validate:"required"`
}

type CreateLogStreamRequest

type CreateLogStreamRequest struct {
	BuildID string `validate:"required"`
}

type CreateTokenRequest

type CreateTokenRequest struct {
	RunnerID string `validate:"required"`
}

type CreateTokenResponse

type CreateTokenResponse struct {
	Token string `json:"token"`
}

type DeleteRequest

type DeleteRequest struct {
	ComponentID string `validate:"required"`
}

type ExternalImagePolicyToEvaluate

type ExternalImagePolicyToEvaluate struct {
	PolicyID      string `json:"policy_id" temporaljson:"policy_id,omitempty"`
	Contents      string `json:"contents" temporaljson:"contents,omitempty"`
	InputJSON     []byte `json:"input_json" temporaljson:"input_json,omitempty"`
	InputIdentity string `json:"input_identity" temporaljson:"input_identity,omitempty"`
}

type ExternalImagePolicyViolation

type ExternalImagePolicyViolation struct {
	PolicyID string `json:"policy_id" temporaljson:"policy_id,omitempty"`
	Message  string `json:"message" temporaljson:"message,omitempty"`
	Severity string `json:"severity" temporaljson:"severity,omitempty"`
}

type FetchImageMetadataRequest

type FetchImageMetadataRequest struct {
	BuildID string `validate:"required"`
}

type FetchImageMetadataResult

type FetchImageMetadataResult struct {
	Metadata *metadata.ImageMetadata `json:"metadata" temporaljson:"metadata,omitempty"`
}

type GARAccessToken added in v0.19.870

type GARAccessToken struct {
	Username string
	Password string
}

type GetBuildGitSource

type GetBuildGitSource struct {
	BuildID string `validate:"required"`
}

type GetCloudProviderRequest added in v0.19.870

type GetCloudProviderRequest struct{}

type GetComponentAppConfigRequest

type GetComponentAppConfigRequest struct {
	ComponentID string `validate:"required"`
}

type GetComponentAppRequest

type GetComponentAppRequest struct {
	ComponentID string `validate:"required"`
}

type GetComponentBuildForPolicyEvalRequest added in v0.19.783

type GetComponentBuildForPolicyEvalRequest struct {
	ID string `validate:"required"`
}

type GetComponentBuildRequest

type GetComponentBuildRequest struct {
	ID string `validate:"required"`
}

type GetComponentBuildWithConfigRequest

type GetComponentBuildWithConfigRequest struct {
	ID string `validate:"required"`
}

type GetComponentDependentsRequest

type GetComponentDependentsRequest struct {
	ComponentID string `validate:"required"`
	AppConfigID string `validate:"required"`
}

type GetComponentInstallsRequest

type GetComponentInstallsRequest struct {
	ComponentID string `validate:"required"`
	AppID       string `validate:"required"`
}

type GetComponentOCIRegistryRepository

type GetComponentOCIRegistryRepository struct {
	ComponentID string `validate:"required"`
}

type GetComponentRequest

type GetComponentRequest struct {
	ComponentID string `validate:"required"`
}

type GetComponentsWithType

type GetComponentsWithType struct {
	IDs []string `validate:"required"`
}

type GetGARAccessTokenRequest added in v0.19.870

type GetGARAccessTokenRequest struct {
	ServiceAccountEmail      string
	WorkloadIdentityProvider string
}

type GetHelmComponentConfigRequest

type GetHelmComponentConfigRequest struct {
	ComponentConfigConnectionID string `validate:"required"`
}

type GetImageMetadataFromJobResultRequest

type GetImageMetadataFromJobResultRequest struct {
	JobID string `validate:"required"`
}

type GetImageMetadataFromJobResultResponse

type GetImageMetadataFromJobResultResponse struct {
	Metadata *metadata.ImageMetadata `json:"metadata" temporaljson:"metadata,omitempty"`
}

type GetJobRequest

type GetJobRequest struct {
	ID string `validate:"required"`
}

type GetOrgRequest

type GetOrgRequest struct {
	ID string `validate:"required"`
}

type GetPoliciesConfigByAppConfigIDRequest added in v0.19.783

type GetPoliciesConfigByAppConfigIDRequest struct {
	AppConfigID string `validate:"required"`
}

type GetRunnerJobExecutionByJobIDRequest added in v0.19.783

type GetRunnerJobExecutionByJobIDRequest struct {
	JobID string `validate:"required"`
}

type GetRunnerJobExecutionResultRequest added in v0.19.783

type GetRunnerJobExecutionResultRequest struct {
	RunnerJobExecutionID string `validate:"required"`
}

type GetUnknownComponents

type GetUnknownComponents struct {
}

type GetcomponentRecordsCount

type GetcomponentRecordsCount struct {
}

type OrgHasFeatureRequest added in v0.19.903

type OrgHasFeatureRequest struct {
	OrgID   string `validate:"required"`
	Feature string `validate:"required"`
}

type Params

type Params struct {
	fx.In

	DB            *gorm.DB `name:"psql"`
	Helpers       *helpers.Helpers
	EvClient      eventloop.Client
	AppsHelpers   *appshelpers.Helpers
	RunnerHelpers *runnerhelpers.Helpers
	VCSHelpers    *vcshelpers.Helpers
	AcctClient    *account.Client
	AuthzClient   *authz.Client
	Cfg           *internal.Config
	Features      *features.Features
}

type PrepExternalImagePolicyRequest

type PrepExternalImagePolicyRequest struct {
	BuildID       string                  `validate:"required"`
	ImageMetadata *metadata.ImageMetadata `validate:"required"`
}

type PrepExternalImagePolicyResult

type PrepExternalImagePolicyResult struct {
	Policies    []ExternalImagePolicyToEvaluate `json:"policies" temporaljson:"policies,omitempty"`
	HasPolicies bool                            `json:"has_policies" temporaljson:"has_policies,omitempty"`
	AppID       string                          `json:"app_id" temporaljson:"app_id,omitempty"`
	ComponentID string                          `json:"component_id" temporaljson:"component_id,omitempty"`
	PolicyIDs   []string                        `json:"policy_ids" temporaljson:"policy_ids,omitempty"`
	InputCount  int                             `json:"input_count" temporaljson:"input_count,omitempty"`
	// Human-readable names for display in reports
	OrgName       string `json:"org_name" temporaljson:"org_name,omitempty"`
	AppName       string `json:"app_name" temporaljson:"app_name,omitempty"`
	ComponentName string `json:"component_name" temporaljson:"component_name,omitempty"`
}

type QueueComponentBuildRequest

type QueueComponentBuildRequest struct {
	ComponentID string `validate:"required"`
	OrgID       string `validate:"required"`
	CreatedByID string `validate:"required"`

	// GitRef overrides useLatest when set. Used to pin a build to the branch's specific commit.
	GitRef *string
	// VCSConnectionCommitID is a pre-resolved commit to attach to the build record.
	VCSConnectionCommitID *string
}

type SaveFetchImageMetadataPlanRequest

type SaveFetchImageMetadataPlanRequest struct {
	JobID   string `validate:"required"`
	BuildID string `validate:"required"`
}

type SaveRunnerJobPlanRequest

type SaveRunnerJobPlanRequest struct {
	JobID         string                  `validate:"required"`
	CompositePlan plantypes.CompositePlan `validate:"required"`

	// Deprecated: but kept for backward compatibility
	PlanJSON string `validate:"required"`
}

type UpdateBuildStatus

type UpdateBuildStatus struct {
	BuildID           string                   `validate:"required"`
	Status            app.ComponentBuildStatus `validate:"required"`
	StatusDescription string                   `validate:"required"`
}

type UpdateComponentTypeRequest

type UpdateComponentTypeRequest struct {
	ComponentID string            `validate:"required"`
	Type        app.ComponentType `validate:"required"`
}

type UpdateJobStatusRequest

type UpdateJobStatusRequest struct {
	JobID             string              `validate:"required"`
	Status            app.RunnerJobStatus `validate:"required"`
	StatusDescription string              `validate:"required"`
}

type UpdateStatusRequest

type UpdateStatusRequest struct {
	ComponentID       string              `validate:"required"`
	Status            app.ComponentStatus `validate:"required"`
	StatusDescription string              `validate:"required"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL