260
}
261
263
hostInfo := c.hostInfoProvider.HostInfo()
264
return nil, fmt.Errorf("ControllerImpl for host '%v' shutting down", hostInfo.Identity())
265
}
266
267
>
shard, err := c.contextFactory.CreateContext(shardID, c.shardRemoveAndStop)
controller_impl.go
268
>
if err != nil {
269
return nil, err
270
}
272
>
metrics.ShardContextCreatedCounter.With(c.taggedMetricsHandler).Record(1)
273
>
c.contextTaggedLogger.Info("", numShardsTag(len(c.historyShards)))
274
>
275
>
return shard, nil
276
}
277