facade

Documentation

Index

• Variables
• func DeletePublishRetryKey(key string)
• type MockRetrySchedule
  • func (m MockRetrySchedule) Create(task *retry.Task) error
  • func (m MockRetrySchedule) Delete(key string)
• 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

Variables

var (
	OncePublishRetry sync.Once
	OncePubRelRetry  sync.Once
)

Functions

func DeletePublishRetryKey

func DeletePublishRetryKey(key string)

Types

type MockRetrySchedule

type MockRetrySchedule struct {
}

func (MockRetrySchedule) Create

func (m MockRetrySchedule) Create(task *retry.Task) error

func (MockRetrySchedule) Delete

func (m MockRetrySchedule) Delete(key string)

type RetrySchedule

type RetrySchedule interface {
	Create(task *retry.Task) error
	Delete(key string)
}

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