Mercurial > gemma

comparison pkg/imports/bn.go @ 2253:cfc523c70e90

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Uploaded imports: Small code clean-ups.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Wed, 13 Feb 2019 17:09:11 +0100
parents cce158db02b0
children 452bc714bfd9
comparison
equal deleted inserted replaced
2252:f8f2c4d88939 2253:cfc523c70e90
142 importID int64, 142 importID int64,
143 conn *sql.Conn, 143 conn *sql.Conn,
144 feedback Feedback, 144 feedback Feedback,
145 ) (interface{}, error) { 145 ) (interface{}, error) {
146 146
147 fetch := func(feedback Feedback) ([]*ifbn.BottleNeckType, error) { 147 fetch := func() ([]*ifbn.BottleNeckType, error) {
148 client := ifbn.NewIBottleneckService(bn.URL, bn.Insecure, nil) 148 client := ifbn.NewIBottleneckService(bn.URL, bn.Insecure, nil)
149 149
150 req := &ifbn.Export_bn_by_isrs{} 150 req := &ifbn.Export_bn_by_isrs{}
151 151
152 resp, err := client.Export_bn_by_isrs(req) 152 resp, err := client.Export_bn_by_isrs(req)
164 return storeBottlenecks(ctx, fetch, importID, conn, feedback) 164 return storeBottlenecks(ctx, fetch, importID, conn, feedback)
165 } 165 }
166 166
167 func storeBottlenecks( 167 func storeBottlenecks(
168 ctx context.Context, 168 ctx context.Context,
169 fetch func(Feedback) ([]*ifbn.BottleNeckType, error), 169 fetch func() ([]*ifbn.BottleNeckType, error),
170 importID int64, 170 importID int64,
171 conn *sql.Conn, 171 conn *sql.Conn,
172 feedback Feedback, 172 feedback Feedback,
173 ) (interface{}, error) { 173 ) (interface{}, error) {
174 start := time.Now() 174 start := time.Now()
175 175
176 bns, err := fetch(feedback) 176 bns, err := fetch()
177 if err != nil { 177 if err != nil {
178 return nil, err 178 return nil, err
179 } 179 }
180 180
181 feedback.Info("Found %d bottlenecks for import", len(bns)) 181 feedback.Info("Found %d bottlenecks for import", len(bns))