Documentation ¶
Index ¶
- Variables
- func DeletePublishRetryKey(key string)
- type MockRetrySchedule
- type RetrySchedule
- func GetPubRelRetry() RetrySchedule
- func GetPublishRetry() RetrySchedule
- func GetWillDelay() RetrySchedule
- func SinglePubRelRetry(ctx context.Context, option ...retry.Option) RetrySchedule
- func SinglePublishRetry(option ...retry.Option) RetrySchedule
- func SingleWillDelay(option ...retry.Option) RetrySchedule
Constants ¶
This section is empty.
Variables ¶
View Source
var ( OncePublishRetry sync.Once OncePubRelRetry sync.Once )
Functions ¶
func DeletePublishRetryKey ¶
func DeletePublishRetryKey(key string)
Types ¶
type MockRetrySchedule ¶
type MockRetrySchedule struct { }
func (MockRetrySchedule) Delete ¶
func (m MockRetrySchedule) Delete(key string)
type RetrySchedule ¶
func GetPubRelRetry ¶
func GetPubRelRetry() RetrySchedule
func GetPublishRetry ¶
func GetPublishRetry() RetrySchedule
func GetWillDelay ¶
func GetWillDelay() RetrySchedule
func SinglePubRelRetry ¶
func SinglePubRelRetry(ctx context.Context, option ...retry.Option) RetrySchedule
func SinglePublishRetry ¶
func SinglePublishRetry(option ...retry.Option) RetrySchedule
func SingleWillDelay ¶
func SingleWillDelay(option ...retry.Option) RetrySchedule
Click to show internal directories.
Click to hide internal directories.