Delete the archival workflow code

common/dynamicconfig/constants.go

@@ -321,10 +321,6 @@ const (
 	SearchAttributesTotalSizeLimit = "frontend.searchAttributesTotalSizeLimit"
 	// VisibilityArchivalQueryMaxPageSize is the maximum page size for a visibility archival query
 	VisibilityArchivalQueryMaxPageSize = "frontend.visibilityArchivalQueryMaxPageSize"
-	// VisibilityArchivalQueryMaxRangeInDays is the maximum number of days for a visibility archival query
-	VisibilityArchivalQueryMaxRangeInDays = "frontend.visibilityArchivalQueryMaxRangeInDays"
-	// VisibilityArchivalQueryMaxQPS is the timeout for a visibility archival query
-	VisibilityArchivalQueryMaxQPS = "frontend.visibilityArchivalQueryMaxQPS"
 	// EnableServerVersionCheck is a flag that controls whether or not periodic version checking is enabled
 	EnableServerVersionCheck = "frontend.enableServerVersionCheck"
 	// EnableTokenNamespaceEnforcement enables enforcement that namespace in completion token matches namespace of the request
@@ -599,10 +595,6 @@ const (
 	TimerProcessorPollBackoffInterval = "history.timerProcessorPollBackoffInterval"
 	// TimerProcessorMaxTimeShift is the max shift timer processor can have
 	TimerProcessorMaxTimeShift = "history.timerProcessorMaxTimeShift"
-	// TimerProcessorHistoryArchivalSizeLimit is the max history size for inline archival
-	TimerProcessorHistoryArchivalSizeLimit = "history.timerProcessorHistoryArchivalSizeLimit"
-	// TimerProcessorArchivalTimeLimit is the upper time limit for inline history archival
-	TimerProcessorArchivalTimeLimit = "history.timerProcessorArchivalTimeLimit"
 	// RetentionTimerJitterDuration is a time duration jitter to distribute timer from T0 to T0 + jitter duration
 	RetentionTimerJitterDuration = "history.retentionTimerJitterDuration"
 
@@ -637,8 +629,6 @@ const (
 	TransferProcessorCompleteTransferInterval = "history.transferProcessorCompleteTransferInterval"
 	// TransferProcessorPollBackoffInterval is the poll backoff interval if task redispatcher's size exceeds limit for transferQueueProcessor
 	TransferProcessorPollBackoffInterval = "history.transferProcessorPollBackoffInterval"
-	// TransferProcessorVisibilityArchivalTimeLimit is the upper time limit for archiving visibility records
-	TransferProcessorVisibilityArchivalTimeLimit = "history.transferProcessorVisibilityArchivalTimeLimit"
 	// TransferProcessorEnsureCloseBeforeDelete means we ensure the execution is closed before we delete it
 	TransferProcessorEnsureCloseBeforeDelete = "history.transferProcessorEnsureCloseBeforeDelete"
 
@@ -666,8 +656,6 @@ const (
 	VisibilityProcessorCompleteTaskInterval = "history.visibilityProcessorCompleteTaskInterval"
 	// VisibilityProcessorPollBackoffInterval is the poll backoff interval if task redispatcher's size exceeds limit for visibilityQueueProcessor
 	VisibilityProcessorPollBackoffInterval = "history.visibilityProcessorPollBackoffInterval"
-	// VisibilityProcessorVisibilityArchivalTimeLimit is the upper time limit for archiving visibility records
-	VisibilityProcessorVisibilityArchivalTimeLimit = "history.visibilityProcessorVisibilityArchivalTimeLimit"
 	// VisibilityProcessorEnsureCloseBeforeDelete means we ensure the visibility of an execution is closed before we delete its visibility records
 	VisibilityProcessorEnsureCloseBeforeDelete = "history.visibilityProcessorEnsureCloseBeforeDelete"
 	// VisibilityProcessorEnableCloseWorkflowCleanup to clean up the mutable state after visibility
@@ -738,12 +726,6 @@ const (
 	EmitShardLagLog = "history.emitShardLagLog"
 	// DefaultEventEncoding is the encoding type for history events
 	DefaultEventEncoding = "history.defaultEventEncoding"
-	// NumArchiveSystemWorkflows is key for number of archive system workflows running in total
-	NumArchiveSystemWorkflows = "history.numArchiveSystemWorkflows"
-	// ArchiveRequestRPS is the rate limit on the number of archive request per second
-	ArchiveRequestRPS = "history.archiveRequestRPS"
-	// ArchiveSignalTimeout is the signal timeout used when starting an archive system workflow
-	ArchiveSignalTimeout = "history.archiveSignalTimeout"
 	// DefaultActivityRetryPolicy represents the out-of-box retry policy for activities where
 	// the user has not specified an explicit RetryPolicy
 	DefaultActivityRetryPolicy = "history.defaultActivityRetryPolicy"
@@ -854,20 +836,6 @@ const (
 	// WorkerESProcessorAckTimeout is the timeout that store will wait to get ack signal from ES processor.
 	// Should be at least WorkerESProcessorFlushInterval+<time to process request>.
 	WorkerESProcessorAckTimeout = "worker.ESProcessorAckTimeout"
-	// WorkerArchiverMaxConcurrentActivityExecutionSize indicates worker archiver max concurrent activity execution size
-	WorkerArchiverMaxConcurrentActivityExecutionSize = "worker.ArchiverMaxConcurrentActivityExecutionSize"
-	// WorkerArchiverMaxConcurrentWorkflowTaskExecutionSize indicates worker archiver max concurrent workflow execution size
-	WorkerArchiverMaxConcurrentWorkflowTaskExecutionSize = "worker.ArchiverMaxConcurrentWorkflowTaskExecutionSize"
-	// WorkerArchiverMaxConcurrentActivityTaskPollers indicates worker archiver max concurrent activity pollers
-	WorkerArchiverMaxConcurrentActivityTaskPollers = "worker.ArchiverMaxConcurrentActivityTaskPollers"
-	// WorkerArchiverMaxConcurrentWorkflowTaskPollers indicates worker archiver max concurrent workflow pollers
-	WorkerArchiverMaxConcurrentWorkflowTaskPollers = "worker.ArchiverMaxConcurrentWorkflowTaskPollers"
-	// WorkerArchiverConcurrency controls the number of coroutines handling archival work per archival workflow
-	WorkerArchiverConcurrency = "worker.ArchiverConcurrency"
-	// WorkerArchivalsPerIteration controls the number of archivals handled in each iteration of archival workflow
-	WorkerArchivalsPerIteration = "worker.ArchivalsPerIteration"
-	// WorkerTimeLimitPerArchivalIteration controls the time limit of each iteration of archival workflow
-	WorkerTimeLimitPerArchivalIteration = "worker.TimeLimitPerArchivalIteration"
 	// WorkerThrottledLogRPS is the rate limit on number of log messages emitted per second for throttled logger
 	WorkerThrottledLogRPS = "worker.throttledLogRPS"
 	// WorkerScannerMaxConcurrentActivityExecutionSize indicates worker scanner max concurrent activity execution size

common/log/tag/tags.go

@@ -765,11 +765,6 @@ func ArchivalCallerServiceName(callerServiceName string) ZapTag {
 	return NewStringTag("archival-caller-service-name", callerServiceName)
 }
 
-// ArchivalArchiveAttemptedInline returns tag for whether archival is attempted inline before signal is sent.
-func ArchivalArchiveAttemptedInline(archiveInline bool) ZapTag {
-	return NewBoolTag("archival-archive-attempted-inline", archiveInline)
-}
-
 // ArchivalRequestNamespaceID returns tag for RequestNamespaceID
 func ArchivalRequestNamespaceID(requestNamespaceID string) ZapTag {
 	return NewStringTag("archival-request-namespace-id", requestNamespaceID)
@@ -830,44 +825,6 @@ func ArchivalArchiveFailReason(archiveFailReason string) ZapTag {
 	return NewStringTag("archival-archive-fail-reason", archiveFailReason)
 }
 
-// ArchivalDeleteHistoryFailReason returns tag for ArchivalDeleteHistoryFailReason
-func ArchivalDeleteHistoryFailReason(deleteHistoryFailReason string) ZapTag {
-	return NewStringTag("archival-delete-history-fail-reason", deleteHistoryFailReason)
-}
-
-// ArchivalVisibilityQuery returns tag for the query for getting archived visibility record
-func ArchivalVisibilityQuery(query string) ZapTag {
-	return NewStringTag("archival-visibility-query", query)
-}
-
-// The following logger tags are only used by internal archiver implemention.
-// TODO: move them to internal repo once temporal plugin model is in place.
-
-// ArchivalBlobKey returns tag for BlobKey
-func ArchivalBlobKey(blobKey string) ZapTag {
-	return NewStringTag("archival-blob-key", blobKey)
-}
-
-// ArchivalDeterministicConstructionCheckFailReason returns tag for ArchivalDeterministicConstructionCheckFailReason
-func ArchivalDeterministicConstructionCheckFailReason(deterministicConstructionCheckFailReason string) ZapTag {
-	return NewStringTag("archival-deterministic-construction-check-fail-reason", deterministicConstructionCheckFailReason)
-}
-
-// ArchivalNonDeterministicBlobKey returns tag for randomly generated NonDeterministicBlobKey
-func ArchivalNonDeterministicBlobKey(nondeterministicBlobKey string) ZapTag {
-	return NewStringTag("archival-non-deterministic-blob-key", nondeterministicBlobKey)
-}
-
-// ArchivalBlobIntegrityCheckFailReason returns tag for ArchivalBlobIntegrityCheckFailReason
-func ArchivalBlobIntegrityCheckFailReason(blobIntegrityCheckFailReason string) ZapTag {
-	return NewStringTag("archival-blob-integrity-check-fail-reason", blobIntegrityCheckFailReason)
-}
-
-// ArchivalBlobstoreContextTimeout returns tag for ArchivalBlobstoreContextTimeout
-func ArchivalBlobstoreContextTimeout(blobstoreContextTimeout time.Duration) ZapTag {
-	return NewDurationTag("archival-blobstore-context-timeout", blobstoreContextTimeout)
-}
-
 // TransportType returns tag for transportType
 func TransportType(transportType string) ZapTag {
 	return NewStringTag("transport-type", transportType)