func NewProber()

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
}