in spanner_prober/prober/proberlib.go [300:317]
func NewProber(ctx context.Context, opt ProberOptions, clientOpts ...option.ClientOption) (*Prober, error) {
ctx, err := tag.New(ctx, tag.Insert(opNameTag, opt.Prober.name()))
if err != nil {
return nil, err
}
// Override Cloud Spanner endpoint if specified.
if opt.Endpoint != "" {
clientOpts = append(clientOpts, option.WithEndpoint(opt.Endpoint))
}
p, err := newSpannerProber(ctx, opt, clientOpts...)
if err != nil {
return nil, err
}
go p.backgroundStatsAggregator(ctx)
return p, nil
}