reclaimresources

Documentation

Index

• Constants
• type Activities
  • func NewActivities(visibilityManager manager.VisibilityManager, metricsHandler metrics.Handler, ...) *Activities
  • func (a *Activities) EnsureNoExecutionsAdvVisibilityActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name, ...) error
• type LocalActivities
  • func NewLocalActivities(visibilityManager manager.VisibilityManager, ...) *LocalActivities
  • func (a *LocalActivities) CountExecutionsAdvVisibilityActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) (int64, error)
  • func (a *LocalActivities) DeleteNamespaceActivity(ctx context.Context, nsID namespace.ID, nsName namespace.Name) error
  • func (a *LocalActivities) IsAdvancedVisibilityActivity(_ context.Context, nsName namespace.Name) (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,
	metricsHandler metrics.Handler,
	logger log.Logger,
) *Activities

func (*Activities) EnsureNoExecutionsAdvVisibilityActivity

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

type LocalActivities

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

func NewLocalActivities

func NewLocalActivities(
	visibilityManager manager.VisibilityManager,
	metadataManager persistence.MetadataManager,
	metricsHandler metrics.Handler,
	logger log.Logger,
) *LocalActivities

func (*LocalActivities) CountExecutionsAdvVisibilityActivity

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

func (*LocalActivities) DeleteNamespaceActivity

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

func (*LocalActivities) IsAdvancedVisibilityActivity

func (a *LocalActivities) IsAdvancedVisibilityActivity(_ context.Context, nsName namespace.Name) (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)