workqueue/callback.go at main · shengyanli1982/workqueue · GitHub

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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
package workqueue

import "time"

type queueCallbackImpl struct{}

// NewNopQueueCallbackImpl 返回空实现回调。
func NewNopQueueCallbackImpl() *queueCallbackImpl { return &queueCallbackImpl{} }

func (impl *queueCallbackImpl) OnPut(interface{}) {}

func (impl *queueCallbackImpl) OnGet(interface{}) {}

func (impl *queueCallbackImpl) OnDone(interface{}) {}

type delayingQueueCallbackImpl struct {
	queueCallbackImpl
}

// NewNopDelayingQueueCallbackImpl 返回空实现延迟回调。
func NewNopDelayingQueueCallbackImpl() *delayingQueueCallbackImpl {

	return &delayingQueueCallbackImpl{
		queueCallbackImpl: queueCallbackImpl{},
	}
}

func (impl *delayingQueueCallbackImpl) OnDelay(interface{}, int64) {}

func (impl *delayingQueueCallbackImpl) OnPullError(interface{}, error) {}

type priorityQueueCallbackImpl struct {
	queueCallbackImpl
}

// NewNopPriorityQueueCallbackImpl 返回空实现优先级回调。
func NewNopPriorityQueueCallbackImpl() *priorityQueueCallbackImpl {

	return &priorityQueueCallbackImpl{
		queueCallbackImpl: queueCallbackImpl{},
	}
}

func (impl *priorityQueueCallbackImpl) OnPriority(interface{}, int64) {}

type ratelimitingQueueCallbackImpl struct {
	delayingQueueCallbackImpl
}

// NewNopRateLimitingQueueCallbackImpl 返回空实现限流回调。
func NewNopRateLimitingQueueCallbackImpl() *ratelimitingQueueCallbackImpl {

	return &ratelimitingQueueCallbackImpl{
		delayingQueueCallbackImpl: delayingQueueCallbackImpl{
			queueCallbackImpl: queueCallbackImpl{},
		},
	}
}

func (impl *ratelimitingQueueCallbackImpl) OnLimited(interface{}) {}

type retryQueueCallbackImpl struct {
	delayingQueueCallbackImpl
}

// NewNopRetryQueueCallbackImpl 返回空实现重试回调。
func NewNopRetryQueueCallbackImpl() *retryQueueCallbackImpl {

	return &retryQueueCallbackImpl{
		delayingQueueCallbackImpl: delayingQueueCallbackImpl{
			queueCallbackImpl: queueCallbackImpl{},
		},
	}
}

func (impl *retryQueueCallbackImpl) OnRetry(interface{}, int, time.Duration, error) {}

func (impl *retryQueueCallbackImpl) OnRetryExhausted(interface{}, int, error) {}

func (impl *retryQueueCallbackImpl) OnForget(interface{}) {}

type deadLetterQueueCallbackImpl struct {
	queueCallbackImpl
}

// NewNopDeadLetterQueueCallbackImpl 返回空实现死信回调。
func NewNopDeadLetterQueueCallbackImpl() *deadLetterQueueCallbackImpl {

	return &deadLetterQueueCallbackImpl{
		queueCallbackImpl: queueCallbackImpl{},
	}
}

func (impl *deadLetterQueueCallbackImpl) OnDead(*DeadLetter) {}

func (impl *deadLetterQueueCallbackImpl) OnAckDead(*DeadLetter) {}

func (impl *deadLetterQueueCallbackImpl) OnRequeueDead(*DeadLetter, Queue) {}