deleteexecutions

Documentation

Index

• Constants
• type Activities
  • func NewActivities(visibilityManager manager.VisibilityManager, ...) *Activities
  • func (a *Activities) DeleteExecutionsActivity(ctx context.Context, params DeleteExecutionsActivityParams) (DeleteExecutionsActivityResult, error)
• type DeleteExecutionsActivityParams
• type DeleteExecutionsActivityResult
• type DeleteExecutionsConfig
  • func (cfg *DeleteExecutionsConfig) ApplyDefaults()
  • func (cfg DeleteExecutionsConfig) String() string
• type DeleteExecutionsParams
• type DeleteExecutionsResult
  • func DeleteExecutionsWorkflow(ctx workflow.Context, params DeleteExecutionsParams) (DeleteExecutionsResult, error)
• type GetNextPageTokenParams
• type LocalActivities
  • func NewLocalActivities(visibilityManager manager.VisibilityManager, metricsHandler metrics.Handler, ...) *LocalActivities
  • func (a *LocalActivities) GetNextPageTokenActivity(ctx context.Context, params GetNextPageTokenParams) ([]byte, error)

Constants

const (
	WorkflowName = "temporal-sys-delete-executions-workflow"
)

Types

type Activities

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

func NewActivities

func NewActivities(
	visibilityManager manager.VisibilityManager,
	historyClient historyservice.HistoryServiceClient,
	metricsHandler metrics.Handler,
	logger log.Logger,
) *Activities

func (*Activities) DeleteExecutionsActivity

func (a *Activities) DeleteExecutionsActivity(ctx context.Context, params DeleteExecutionsActivityParams) (DeleteExecutionsActivityResult, error)

type DeleteExecutionsActivityParams

type DeleteExecutionsActivityParams struct {
	Namespace     namespace.Name
	NamespaceID   namespace.ID
	RPS           int
	ListPageSize  int
	NextPageToken []byte
}

type DeleteExecutionsActivityResult

type DeleteExecutionsActivityResult struct {
	ErrorCount   int
	SuccessCount int
}

type DeleteExecutionsConfig

type DeleteExecutionsConfig struct {
	// RPS per every parallel delete executions activity.
	// Total RPS is equal to DeleteActivityRPS * ConcurrentDeleteExecutionsActivities.
	DeleteActivityRPS int
	// Page size to read executions from visibility.
	PageSize int
	// Number of pages before returning ContinueAsNew.
	PagesPerExecution int
	// Number of concurrent delete executions activities.
	// Must be not greater than PagesPerExecution and number of worker cores in the cluster.
	ConcurrentDeleteExecutionsActivities int
}

func (*DeleteExecutionsConfig) ApplyDefaults

func (cfg *DeleteExecutionsConfig) ApplyDefaults()

func (DeleteExecutionsConfig) String

func (cfg DeleteExecutionsConfig) String() string

type DeleteExecutionsParams

type DeleteExecutionsParams struct {
	Namespace   namespace.Name
	NamespaceID namespace.ID
	Config      DeleteExecutionsConfig

	// To carry over progress results with ContinueAsNew.
	PreviousSuccessCount int
	PreviousErrorCount   int
	ContinueAsNewCount   int
	NextPageToken        []byte
}

type DeleteExecutionsResult

type DeleteExecutionsResult struct {
	SuccessCount int
	ErrorCount   int
}

func DeleteExecutionsWorkflow

func DeleteExecutionsWorkflow(ctx workflow.Context, params DeleteExecutionsParams) (DeleteExecutionsResult, error)

type GetNextPageTokenParams

type GetNextPageTokenParams struct {
	Namespace     namespace.Name
	NamespaceID   namespace.ID
	PageSize      int
	NextPageToken []byte
}

type LocalActivities

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

func NewLocalActivities

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

func (*LocalActivities) GetNextPageTokenActivity

func (a *LocalActivities) GetNextPageTokenActivity(ctx context.Context, params GetNextPageTokenParams) ([]byte, error)