mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Stephan BehnkeandGitHub
31d19ed37c
## What changed? <!-- Describe what has changed in this PR --> Instead of passing `namespaceID string`, dynamicconfig receives `ns namespace.ID` now. _NOTE: I'll do `namespace string` in a follow-up PR. I want to get this out of the door to establish the dependency of `common/dynamicconfig` on `common/namespace` as it already took several PRs to make that possible. And it's less risky._ ## Why? <!-- Tell your future self why have you made these changes --> Type safety. ## How did you test it? <!-- How have you verified this change? Tested locally? Added a unit test? Checked in staging env? --> Compiler, as there is no behavior change. ## Potential risks <!-- Assuming the worst case, what can be broken when deploying this change to production? --> ## Documentation <!-- Have you made sure this change doesn't falsify anything currently stated in `docs/`? If significant new behavior is added, have you described that in `docs/`? --> ## Is hotfix candidate? <!-- Is this PR a hotfix candidate or does it require a notification to be sent to the broader community? (Yes/No) -->
80 lines
3.0 KiB
Go
80 lines
3.0 KiB
Go
// The MIT License
|
|
//
|
|
// Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.
|
|
//
|
|
// Copyright (c) 2020 Uber Technologies, Inc.
|
|
//
|
|
// Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
// of this software and associated documentation files (the "Software"), to deal
|
|
// in the Software without restriction, including without limitation the rights
|
|
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
// copies of the Software, and to permit persons to whom the Software is
|
|
// furnished to do so, subject to the following conditions:
|
|
//
|
|
// The above copyright notice and this permission notice shall be included in
|
|
// all copies or substantial portions of the Software.
|
|
//
|
|
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|
// THE SOFTWARE.
|
|
|
|
package common
|
|
|
|
import (
|
|
"math"
|
|
"time"
|
|
)
|
|
|
|
const (
|
|
// FirstEventID is the id of the first event in the history
|
|
FirstEventID int64 = 1
|
|
// LastEventID is the id of the last possible event in the history
|
|
LastEventID int64 = math.MaxInt64
|
|
// EmptyEventID is the id of the empty event
|
|
EmptyEventID int64 = 0
|
|
// EmptyVersion is used as the default value for failover version when no value is provided
|
|
EmptyVersion int64 = 0
|
|
// EndEventID is the id of the end event, here we use the int64 max
|
|
EndEventID int64 = 1<<63 - 1
|
|
// BufferedEventID is the id of the buffered event
|
|
BufferedEventID int64 = -123
|
|
// EmptyEventTaskID is uninitialized id of the task id within event
|
|
EmptyEventTaskID int64 = 0
|
|
// TransientEventID is the id of the transient event
|
|
TransientEventID int64 = -124
|
|
// FirstBlobPageToken is the page token identifying the first blob for each history archival
|
|
FirstBlobPageToken = 1
|
|
// LastBlobNextPageToken is the next page token on the last blob for each history archival
|
|
LastBlobNextPageToken = -1
|
|
// EndMessageID is the id of the end message, here we use the int64 max
|
|
EndMessageID int64 = 1<<63 - 1
|
|
)
|
|
|
|
const (
|
|
// MinLongPollTimeout is the minimum context timeout for long poll API, below which
|
|
// the request won't be processed
|
|
MinLongPollTimeout = time.Second * 2
|
|
// CriticalLongPollTimeout is a threshold for the context timeout passed into long poll API,
|
|
// below which a warning will be logged
|
|
CriticalLongPollTimeout = time.Second * 20
|
|
)
|
|
|
|
const (
|
|
// Limit for schedule notes field
|
|
ScheduleNotesSizeLimit = 1000
|
|
)
|
|
|
|
const (
|
|
// DefaultQueueReaderID is the default readerID when loading history tasks
|
|
DefaultQueueReaderID int64 = 0
|
|
)
|
|
|
|
const (
|
|
// DefaultOperatorRPSRatio is the default percentage of rate limit that should be used for operator priority requests
|
|
DefaultOperatorRPSRatio float64 = 0.2
|
|
)
|