reclaimresources

Documentation

Index

• Constants
• type Activities
  • func NewActivities(visibilityManager manager.VisibilityManager, ...) *Activities
  • func (a *Activities) CountExecutionsAdvVisibilityActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) (int64, error)
  • func (a *Activities) DeleteNamespaceActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) error
  • func (a *Activities) EnsureNoExecutionsAdvVisibilityActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name, ...) error
  • func (a *Activities) EnsureNoExecutionsStdVisibilityActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) error
  • func (a *Activities) IsAdvancedVisibilityActivity(_ context.Context) (bool, error)
• type ReclaimResourcesParams
• type ReclaimResourcesResult
  • func ReclaimResourcesWorkflow(ctx workflow.Context, params ReclaimResourcesParams) (ReclaimResourcesResult, error)

Constants

const (
	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) CountExecutionsAdvVisibilityActivity

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

func (*Activities) DeleteNamespaceActivity

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

func (*Activities) EnsureNoExecutionsAdvVisibilityActivity

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

func (*Activities) EnsureNoExecutionsStdVisibilityActivity

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

func (*Activities) IsAdvancedVisibilityActivity

func (a *Activities) IsAdvancedVisibilityActivity(_ context.Context) (bool, error)

type ReclaimResourcesParams

type ReclaimResourcesParams struct {
	deleteexecutions.DeleteExecutionsParams

	// NamespaceDeleteDelay indicates the duration for how long ReclaimResourcesWorkflow
	// will sleep between workflow execution and namespace deletion.
	// Default is 0, means, workflow won't sleep.
	NamespaceDeleteDelay time.Duration
}

type ReclaimResourcesResult

type ReclaimResourcesResult struct {
	DeleteSuccessCount int
	DeleteErrorCount   int
	NamespaceDeleted   bool
}

func ReclaimResourcesWorkflow

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