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

Drop utils.SyncMap*()

Browse source
This commit is contained in:
Alexander A. Klimov 2021-04-08 18:12:51 +02:00
parent fac47fb330
commit bf1a77a67c
1 changed files with 0 additions and 47 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
pkg/utils/utils.go
View file

@ -7,7 +7,6 @@ import (
"fmt"
"github.com/go-sql-driver/mysql"
"github.com/google/uuid"
"github.com/icinga/icingadb/pkg/contracts"
"go.uber.org/zap"
"io/ioutil"
"math"
@ -111,52 +110,6 @@ func BatchSliceOfInterfaces(ctx context.Context, keys []interface{}, count int)
return batches
}
func SyncMapKeys(m *sync.Map) []string {
keys := make([]string, 0)
if m != nil {
m.Range(func(key, value interface{}) bool {
keys = append(keys, key.(string))
return true
})
}
return keys
}
func SyncMapIDs(m *sync.Map) []interface{} {
ids := make([]interface{}, 0)
if m != nil {
m.Range(func(key, value interface{}) bool {
ids = append(ids, value.(contracts.IDer).ID())
return true
})
}
return ids
}
func SyncMapEntities(m *sync.Map) <-chan contracts.Entity {
entities := make(chan contracts.Entity, 0)
go func() {
defer close(entities)
if m != nil {
m.Range(func(key, value interface{}) bool {
entities <- value.(contracts.Entity)
return true
})
}
}()
return entities
}
func IsContextCanceled(err error) bool {
return errors.Is(err, context.Canceled)
}