// SetReservoirQuotaTTL sets the ReservoirQuotaTTL field's value.
358209
func (s *SamplingTargetDocument) SetReservoirQuotaTTL(v time.Time) *SamplingTargetDocument {
	s.ReservoirQuotaTTL = &v
	return s
}
250097
func (s *TrafficPolicyInstance) SetTTL(v int64) *TrafficPolicyInstance {
	s.TTL = &v
	return s
}
1071911
func (tsv *TabletServer) SetTxPoolWaiterCap(val int64) {
	tsv.te.txPool.waiterCap.Set(val)
}
306772
func (s *TagDescription) SetResourceArn(v string) *TagDescription {
	s.ResourceArn = &v
	return s
}
1196770
func (s *SamplingRuleUpdate) SetResourceARN(v string) *SamplingRuleUpdate {
	s.ResourceARN = &v
	return s
}
1159847
func (d *Decoder) updateReservoir3() error {
	err1 := d.reservoir.setSize(d.mainDataBegin)

	// Even if setSize failed due to not enough main data being available, we
	// only report the error after loading the main data from the current frame,
	// as it may be required for decoding the next frame.

	if d.bitrateIndex != 0 {
		// Frame size
		mainDataLength := 144 * bitrateBps[d.layer][d.bitrateIndex]
		mainDataLength /= samplingFreqHz[d.samplingFreq]
		mainDataLength += d.paddingBit
		// Header
		mainDataLength -= 4
		// crc_check
		if d.protectionBit == 0 {
			mainDataLength -= 2
		}
		// Side information
		if d.mode == ModeMono {
			mainDataLength -= 17
		} else {
			mainDataLength -= 32
		}

		if err := d.reservoir.load(mainDataLength); err != nil {
			return err
		}
	} else {
		if err := d.reservoir.loadUntilSyncword(); err != nil {
			return err
		}
	}

	return err1
}
79291
func (s *CreateVirtualRouterOutput) SetVirtualRouter(v *VirtualRouterData) *CreateVirtualRouterOutput {
	s.VirtualRouter = v
	return s
}
1172501
func (pool *serverPool) setRetryDial(entry *poolEntry) {
	delay := longRetryDelay
	if entry.shortRetry > 0 {
		entry.shortRetry--
		delay = shortRetryDelay
	}
	delay += time.Duration(rand.Int63n(int64(delay) + 1))
	entry.delayedRetry = true
	go func() {
		select {
		case <-pool.quit:
		case <-time.After(delay):
			select {
			case <-pool.quit:
			case pool.enableRetry <- entry:
			}
		}
	}()
}
1035564
func (s *AddTagsInput) SetResourceArn(v string) *AddTagsInput {
	s.ResourceArn = &v
	return s
}
566023
func (s *SimulatePrincipalPolicyInput) SetResourceOwner(v string) *SimulatePrincipalPolicyInput {
	s.ResourceOwner = &v
	return s
}
563386
func (s *Volume) SetDockerVolumeConfiguration(v *DockerVolumeConfiguration) *Volume {
	s.DockerVolumeConfiguration = v
	return s
}
474488
func (l *rateLimiterImpl) SetMaxQuota(q float64) error {
	if q < 0 {
		return errors.Newf("Max quota must be non-negative: %f", q)
	}

	l.mutex.Lock()
	defer l.mutex.Unlock()

	l.maxQuota = q
	if l.quota > q {
		l.quota = q
	}

	if l.maxQuota == 0 {
		l.cond.Broadcast()
	}

	return nil
}
659864
func (r *Request) SetSRV(srv *SRVRecord) *Request {
	r.SRV = srv
	return r
}
352806
func (s *TrainingJob) SetResourceConfig(v *ResourceConfig) *TrainingJob {
	s.ResourceConfig = v
	return s
}
1247112
func (s *KinesisStreamsInput) SetResourceARN(v string) *KinesisStreamsInput {
	s.ResourceARN = &v
	return s
}
491515
func (s *DeleteTagsInput) SetResourceArn(v string) *DeleteTagsInput {
	s.ResourceArn = &v
	return s
}
1077003
func (s *H264Settings) SetTemporalAdaptiveQuantization(v string) *H264Settings {
	s.TemporalAdaptiveQuantization = &v
	return s
}