forked from temporalio/temporal
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathqueue_v2.go
More file actions
43 lines (38 loc) · 1.26 KB
/
queue_v2.go
File metadata and controls
43 lines (38 loc) · 1.26 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package persistence
import (
"go.temporal.io/api/serviceerror"
)
const (
QueueTypeUnspecified QueueV2Type = 0
QueueTypeHistoryNormal QueueV2Type = 1
QueueTypeHistoryDLQ QueueV2Type = 2
// FirstQueueMessageID is the ID of the first message written to a queue partition.
FirstQueueMessageID = 0
)
var (
ErrInvalidReadQueueMessagesNextPageToken = &InvalidPersistenceRequestError{
Msg: "invalid next-page token for reading queue messages",
}
ErrInvalidListQueuesNextPageToken = &InvalidPersistenceRequestError{
Msg: "invalid next-page token for listing queues",
}
ErrNonPositiveReadQueueMessagesPageSize = &InvalidPersistenceRequestError{
Msg: "non-positive page size for reading queue messages",
}
ErrInvalidQueueRangeDeleteMaxMessageID = &InvalidPersistenceRequestError{
Msg: "max message id for queue range delete is invalid",
}
ErrNonPositiveListQueuesPageSize = &InvalidPersistenceRequestError{
Msg: "non-positive page size for listing queues",
}
ErrNegativeListQueuesOffset = &InvalidPersistenceRequestError{
Msg: "negative offset for listing queues",
}
)
func NewQueueNotFoundError(queueType QueueV2Type, queueName string) error {
return serviceerror.NewNotFoundf(
"queue not found: type = %v and name = %v",
queueType,
queueName,
)
}