Skip to content

Commit

Permalink
- remote redundant use of seconds time unit
Browse files Browse the repository at this point in the history
- change method to private
  • Loading branch information
etrpx committed May 29, 2024
1 parent 5511b7a commit 38b5505
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions seed/redis/component.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ import (
"strconv"
"sync"
"sync/atomic"
"time"
)

// ComponentType represents the type of the redis seed component.
Expand Down Expand Up @@ -78,7 +77,7 @@ func (r *SeedComponent) seed(ctx context.Context) error {
return err
}

if err = r.HashSetEntries(ctx, err, client); err != nil {
if err = r.hashSetEntries(ctx, err, client); err != nil {
return err
}
r.logInsertions()
Expand All @@ -88,7 +87,7 @@ func (r *SeedComponent) seed(ctx context.Context) error {

func (r *SeedComponent) setEntries(ctx context.Context, err error, client *redis.Client) error {
for _, entry := range r.config.Entries {
err = client.Set(ctx, entry.Key, entry.Value, entry.TTL*time.Second).Err()
err = client.Set(ctx, entry.Key, entry.Value, entry.TTL).Err()

if err != nil {
return err
Expand All @@ -97,15 +96,15 @@ func (r *SeedComponent) setEntries(ctx context.Context, err error, client *redis
return nil
}

func (r *SeedComponent) HashSetEntries(ctx context.Context, err error, client *redis.Client) error {
func (r *SeedComponent) hashSetEntries(ctx context.Context, err error, client *redis.Client) error {
for _, hEntry := range r.config.HEntries {
err = client.HSet(ctx, hEntry.Key, hEntry.Values).Err()

if err != nil {
return err
}
if hEntry.TTL > 0 {
err = client.Expire(ctx, hEntry.Key, hEntry.TTL*time.Second).Err()
err = client.Expire(ctx, hEntry.Key, hEntry.TTL).Err()
if err != nil {
return err
}
Expand Down

0 comments on commit 38b5505

Please sign in to comment.