func newSampler(probability float32) sampler {
	if probability <= 0 || probability > 1 {
		panic("probability P ∈ (0, 1]")
	}
	return &probabilitySampling{probability: probability}
}
newSampler new probability sampler
package trace
import (
	"math/rand"
	"sync/atomic"
	"time"
)
const (
	slotLength = 2048
)
var ignoreds = []string{"/metrics", "/ping"}  
func init() {
	rand.Seed(time.Now().UnixNano())
}
func oneAtTimeHash(s string) (hash uint32) {
	b := []byte(s)
	for i := range b {
		hash += uint32(b[i])
		hash += hash << 10
		hash ^= hash >> 6
	}
	hash += hash << 3
	hash ^= hash >> 11
	hash += hash << 15
	return
}
type sampler interface {
	IsSampled(traceID uint64, operationName string) (bool, float32)
	Close() error
}
type probabilitySampling struct {
	probability float32
	slot        [slotLength]int64
}
func (p *probabilitySampling) IsSampled(traceID uint64, operationName string) (bool, float32) {
	for _, ignored := range ignoreds {
		if operationName == ignored {
			return false, 0
		}
	}
	now := time.Now().Unix()
	idx := oneAtTimeHash(operationName) % slotLength
	old := atomic.LoadInt64(&p.slot[idx])
	if old != now {
		atomic.SwapInt64(&p.slot[idx], now)
		return true, 1
	}
	return rand.Float32() < float32(p.probability), float32(p.probability)
}
func (p *probabilitySampling) Close() error { return nil }