adjust

Documentation

Index

• type Adjust
  • func NewAdjust(ac *AdjustConfig) *Adjust
  • func (a *Adjust) Active(active uint32)
• type AdjustConfig
  • func (a *AdjustConfig) Init()

Types

type Adjust

type Adjust struct {
	CurrentTimeout time.Duration
	// contains filtered or unexported fields
}

func NewAdjust

func NewAdjust(ac *AdjustConfig) *Adjust

NewAdjust creates a new Adjust with constraints.

func (*Adjust) Active

func (a *Adjust) Active(active uint32)

type AdjustConfig

type AdjustConfig struct {
	// Increment is multiplied by the number of active evalutors to determine
	// the active timeout.
	// Defaults to 100 Microseconds.
	Increment time.Duration

	// Max is the maximum Increment multiplier that can be applied as the
	// current timeout.
	// If service/tfmodel/batcher/config.BatcherConfig.MaxEvaluatorConcurrency
	// is set and it is less than Max, then Max will be set to
	// service/tfmodel/batcher/config.BatcherConfig.MaxEvaluatorConcurrency
	Max uint32
}

func (*AdjustConfig) Init

func (a *AdjustConfig) Init()

Init sets defaults.