build_ids

Documentation

Index

• Constants
• Variables
• func BuildIdScavangerWorkflow(ctx workflow.Context, input BuildIdScavangerInput) error
• type Activities
  • func NewActivities(logger log.Logger, taskManager persistence.TaskManager, ...) *Activities
  • func (a *Activities) ScavengeBuildIds(ctx context.Context, input BuildIdScavangerInput) error
• type BuildIdScavangerInput

Constants

const (
	BuildIdScavangerWorkflowName = "build-id-scavenger"
	BuildIdScavangerActivityName = "scavenge-build-ids"

	BuildIdScavengerWFID          = "temporal-sys-build-id-scavenger"
	BuildIdScavengerTaskQueueName = "temporal-sys-build-id-scavenger-taskqueue-0"
)

Variables

var (
	BuildIdScavengerWFStartOptions = client.StartWorkflowOptions{
		ID:                    BuildIdScavengerWFID,
		TaskQueue:             BuildIdScavengerTaskQueueName,
		WorkflowIDReusePolicy: enumspb.WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE,
		CronSchedule:          "0 */12 * * *",
	}
)

Functions

func BuildIdScavangerWorkflow

func BuildIdScavangerWorkflow(ctx workflow.Context, input BuildIdScavangerInput) error

BuildIdScavangerWorkflow scans all task queue user data entries in all namespaces and cleans up unused build ids. This workflow is a wrapper around the long running ScavengeBuildIds activity.

Types

type Activities

type Activities struct {
	// contains filtered or unexported fields
}

func NewActivities

func NewActivities(
	logger log.Logger,
	taskManager persistence.TaskManager,
	metadataManager persistence.MetadataManager,
	visibilityManager manager.VisibilityManager,
	namespaceRegistry namespace.Registry,
	matchingClient matchingservice.MatchingServiceClient,
	currentClusterName string,
	removableBuildIdDurationSinceDefault dynamicconfig.DurationPropertyFn,
) *Activities

func (*Activities) ScavengeBuildIds

func (a *Activities) ScavengeBuildIds(ctx context.Context, input BuildIdScavangerInput) error

ScavengeBuildIds scans all task queue user data entries in all namespaces and cleans up unused build ids.

type BuildIdScavangerInput

type BuildIdScavangerInput struct {
	VisibilityRPS         float64
	NamespaceListPageSize int
	TaskQueueListPageSize int
}