reclaimresources

Documentation

Index

• Constants
• type Activities
  • func NewActivities(visibilityManager manager.VisibilityManager, ...) *Activities
  • func (a *Activities) DeleteNamespaceActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) error
  • func (a *Activities) EnsureNoExecutionsActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) error
• type ReclaimResourcesParams
• type ReclaimResourcesResult
  • func ReclaimResourcesWorkflow(ctx workflow.Context, params ReclaimResourcesParams) (ReclaimResourcesResult, error)

Constants

const (
	// WorkflowName is the workflow name.
	WorkflowName = "temporal-sys-reclaim-namespace-resources-workflow"
)

Types

type Activities

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

func NewActivities

func NewActivities(
	visibilityManager manager.VisibilityManager,
	metadataManager persistence.MetadataManager,
	metricsClient metrics.Client,
	logger log.Logger,
) *Activities

func (*Activities) DeleteNamespaceActivity

func (a *Activities) DeleteNamespaceActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) error

func (*Activities) EnsureNoExecutionsActivity

func (a *Activities) EnsureNoExecutionsActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) error

type ReclaimResourcesParams

type ReclaimResourcesParams struct {
	deleteexecutions.DeleteExecutionsParams
}

type ReclaimResourcesResult

type ReclaimResourcesResult struct {
	SuccessCount int
	ErrorCount   int
}

func ReclaimResourcesWorkflow

func ReclaimResourcesWorkflow(ctx workflow.Context, params ReclaimResourcesParams) (ReclaimResourcesResult, error)