Lines Matching refs:rpu
201 func (rpu *RetentionPolicyUpdate) SetName(v string) { rpu.Name = &v }
204 func (rpu *RetentionPolicyUpdate) SetDuration(v time.Duration) { rpu.Duration = &v }
207 func (rpu *RetentionPolicyUpdate) SetReplicaN(v int) { rpu.ReplicaN = &v }
210 func (rpu *RetentionPolicyUpdate) SetShardGroupDuration(v time.Duration) { rpu.ShardGroupDuration =…
213 func (data *Data) UpdateRetentionPolicy(database, name string, rpu *RetentionPolicyUpdate, makeDefa…
227 if rpu.Name != nil && *rpu.Name != name && di.RetentionPolicy(*rpu.Name) != nil {
232 if rpu.Duration != nil && *rpu.Duration < MinRetentionPolicyDuration && *rpu.Duration != 0 {
237 if (rpu.Duration != nil && *rpu.Duration > 0 &&
238 ((rpu.ShardGroupDuration != nil && *rpu.Duration < *rpu.ShardGroupDuration) ||
239 (rpu.ShardGroupDuration == nil && *rpu.Duration < rpi.ShardGroupDuration))) ||
240 (rpu.Duration == nil && rpi.Duration > 0 &&
241 rpu.ShardGroupDuration != nil && rpi.Duration < *rpu.ShardGroupDuration) {
246 if rpu.Name != nil {
247 rpi.Name = *rpu.Name
249 if rpu.Duration != nil {
250 rpi.Duration = *rpu.Duration
252 if rpu.ReplicaN != nil {
253 rpi.ReplicaN = *rpu.ReplicaN
255 if rpu.ShardGroupDuration != nil {
256 rpi.ShardGroupDuration = normalisedShardDuration(*rpu.ShardGroupDuration, rpi.Duration)