upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-06-09 08:56:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

Remove icingadb.Sync.fromRedis()

Browse source
This commit is contained in:
Eric Lippmann 2021-04-21 15:54:23 +02:00
parent 5550c47be3
commit 9c86198302
1 changed files with 0 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
pkg/icingadb/sync.go
View file

@ -166,19 +166,3 @@ func (s Sync) ApplyDelta(ctx context.Context, delta *Delta) error {
return g.Wait()
}
func (s Sync) fromRedis(ctx context.Context, factoryFunc contracts.EntityFactoryFunc, key string) (<-chan contracts.Entity, <-chan error) {
// Channel for Redis field-value pairs for the specified key and errors.
pairs, errs := s.redis.HYield(ctx, key, count)
// Group for the Redis sync. Redis sync will be cancelled if an error occurs.
// Note that we're calling HYield with the original context.
g, ctx := errgroup.WithContext(ctx)
// Let errors from HYield cancel our group.
com.ErrgroupReceive(g, errs)
desired, errs := icingaredis.CreateEntities(ctx, factoryFunc, pairs, runtime.NumCPU())
// Let errors from CreateEntities cancel our group.
com.ErrgroupReceive(g, errs)
return desired, com.WaitAsync(g)
}