retry

Documentation

Index

• type Retry
  • func New() *Retry
  • func (r *Retry) Add(ctx context.Context, name string, job *api.Job) error
  • func (r *Retry) Close()
  • func (r *Retry) Delete(ctx context.Context, name string) error
  • func (r *Retry) DeletePrefixes(ctx context.Context, prefixes ...string) error
  • func (r *Retry) DeliverablePrefixes(ctx context.Context, prefixes ...string) (context.CancelFunc, error)
  • func (r *Retry) Get(ctx context.Context, name string) (*api.Job, error)
  • func (r *Retry) List(ctx context.Context, prefix string) (*api.ListResponse, error)
  • func (r *Retry) NotReady()
  • func (r *Retry) Ready(engine engine.Interface)

Types

type Retry

type Retry struct {
	// contains filtered or unexported fields
}

Retry is a engine wrapper for executing the cron API, which will retry calls when the API is "closing". This ensures that caller API calls will be held and eventually executed during leadership reshuffles.

func New

func New() *Retry

func (*Retry) Add

func (r *Retry) Add(ctx context.Context, name string, job *api.Job) error

func (*Retry) Close

func (r *Retry) Close()

func (*Retry) Delete

func (r *Retry) Delete(ctx context.Context, name string) error

func (*Retry) DeletePrefixes

func (r *Retry) DeletePrefixes(ctx context.Context, prefixes ...string) error

func (*Retry) DeliverablePrefixes

func (r *Retry) DeliverablePrefixes(ctx context.Context, prefixes ...string) (context.CancelFunc, error)

func (*Retry) Get

func (r *Retry) Get(ctx context.Context, name string) (*api.Job, error)

func (*Retry) List

func (r *Retry) List(ctx context.Context, prefix string) (*api.ListResponse, error)

func (*Retry) NotReady

func (r *Retry) NotReady()

NotReady blocks the Retry API calls, preventing them from being executed on the underlying engine.

func (*Retry) Ready

func (r *Retry) Ready(engine engine.Interface)

Ready unblocks the Retry API calls, allowing them to be executed on the underlying engine.