retry

Documentation

Overview

Package retry provides a way to determine when a task should be retried.

Index

• func IsNeeded(result *steps.ExecuteResponse_TaskResult) bool
• type Counter
  • func NewCounter(params *test_platform.Request_Params, ...) Counter
  • func (c *Counter) CanRetry(ctx context.Context, iid types.InvocationID) bool
  • func (c *Counter) NotifyRetry(iid types.InvocationID)

Functions

func IsNeeded

func IsNeeded(result *steps.ExecuteResponse_TaskResult) bool

IsNeeded determines if a task result indicates that the invocation needs to be retried.

Panics on unknown verdicts.

Types

type Counter

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

Counter tracks retries across tests and exposes a method to decide if a particular test can be retried any further.

func NewCounter

func NewCounter(params *test_platform.Request_Params, iids map[types.InvocationID]*steps.EnumerationResponse_AutotestInvocation) Counter

NewCounter initializes a new Counter.

func (*Counter) CanRetry

func (c *Counter) CanRetry(ctx context.Context, iid types.InvocationID) bool

CanRetry determines if a retry is allowed for a test based on the count of retries so far.

CanRetry panics for an unknown types.InvocationID.

func (*Counter) NotifyRetry

func (c *Counter) NotifyRetry(iid types.InvocationID)

NotifyRetry notifies retryCounter of a retry attempt for a test.

NotifyRetry panics for an unknown types.InvocationID.