retry

Documentation

Index

• type AsyncFifoRetry
  • func NewAsyncFifoRetry(coder coder.Coder, store storage.KvStorage, metrics metrics.Metrics, ...) AsyncFifoRetry
• type Config

Types

type AsyncFifoRetry

type AsyncFifoRetry interface {
	// Run start retrying
	Run(ctx context.Context)

	// Append add Events
	Append(event *common.WatchEvent)

	// Size return the length of queue
	Size() int

	// MinRevision should return the revision of head
	// If queue is empty, return 0
	MinRevision() uint64
}

AsyncFifoRetry is the interface to retry uncertain operation

func NewAsyncFifoRetry

func NewAsyncFifoRetry(coder coder.Coder,
	store storage.KvStorage,
	metrics metrics.Metrics,
	tso tso.TSO,
	getter getter,
	dispatcher dispatcher,
	config Config) AsyncFifoRetry

NewAsyncFifoRetry build a fifo queue to automatically retry uncertain operations

type Config

type Config struct {
	// UnaryTimeout is the max time to send unary request
	UnaryTimeout time.Duration

	// CheckInterval is the interval of checking
	CheckInterval time.Duration

	// RetryInterval is the interval of retrying
	RetryInterval time.Duration

	// Tombstone is the tombstone
	Tombstone []byte
}

Config is the config of retry queue