configproposalmanager

Documentation

Index

• type BackoffInfo
• type BackoffManager
  • func BackoffManagerNew(minBO, maxInitBO, maxBO int32, signalChan chan RetryInfo, factor float64, ...) *BackoffManager
  • func (bm *BackoffManager) CheckAndHandleBackoff(inst int32, attemptedBal lwcproto.ConfigBal, preempter lwcproto.ConfigBal, ...) (bool, int32)
  • func (bm *BackoffManager) ClearBackoff(inst int32)
  • func (bm *BackoffManager) ShouldBackoff(inst int32, preempter lwcproto.ConfigBal, preempterPhase stdpaxosproto.Phase) bool
  • func (bm *BackoffManager) StillRelevant(backoff RetryInfo) bool
• type IntRange
  • func (ir *IntRange) NextRandom(r *rand.Rand) int
• type RetryInfo

Types

type BackoffInfo

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

type BackoffManager

type BackoffManager struct {
	BackoffInfo
	// contains filtered or unexported fields
}

func BackoffManagerNew

func BackoffManagerNew(minBO, maxInitBO, maxBO int32, signalChan chan RetryInfo, factor float64, softFac bool, constBackoff bool) *BackoffManager

func (*BackoffManager) CheckAndHandleBackoff

func (bm *BackoffManager) CheckAndHandleBackoff(inst int32, attemptedBal lwcproto.ConfigBal, preempter lwcproto.ConfigBal, prempterPhase stdpaxosproto.Phase) (bool, int32)

func (*BackoffManager) ClearBackoff

func (bm *BackoffManager) ClearBackoff(inst int32)

func (*BackoffManager) ShouldBackoff

func (bm *BackoffManager) ShouldBackoff(inst int32, preempter lwcproto.ConfigBal, preempterPhase stdpaxosproto.Phase) bool

func (*BackoffManager) StillRelevant

func (bm *BackoffManager) StillRelevant(backoff RetryInfo) bool

type IntRange

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

range specification, note that min <= max

func (*IntRange) NextRandom

func (ir *IntRange) NextRandom(r *rand.Rand) int

get next random value within the interval including min and max

type RetryInfo

type RetryInfo struct {
	Inst           int32
	AttemptedBal   lwcproto.ConfigBal
	PreempterBal   lwcproto.ConfigBal
	PreempterAt    stdpaxosproto.Phase
	Prev           int32
	TimesPreempted int32
}