3 use Liuggio\StatsdClient\Entity\StatsdData;
4 use Liuggio\StatsdClient\Sender\SenderInterface;
10 public function testSampling( $data, $sampleRate, $seed, $expectWrite ) {
12 $sender->expects( $this->
any() )->method(
'open' )->will( $this->returnValue(
true ) );
14 $sender->expects( $this->once() )->method(
'write' )
15 ->with( $this->
anything(), $this->equalTo( $data ) );
17 $sender->expects( $this->never() )->method(
'write' );
21 $client->send( $data, $sampleRate );
25 $unsampled =
new StatsdData();
26 $unsampled->setKey(
'foo' );
27 $unsampled->setValue( 1 );
29 $sampled =
new StatsdData();
30 $sampled->setKey(
'foo' );
31 $sampled->setValue( 1 );
32 $sampled->setSampleRate(
'0.1' );
36 [ $unsampled, 1, 0 ,
true ],
37 [ $sampled, 1, 0 ,
false ],
38 [ $sampled, 1, 4 ,
true ],
39 [ $unsampled, 0.1, 0 ,
false ],
40 [ $sampled, 0.5, 0 ,
false ],
41 [ $sampled, 0.5, 4 ,
false ],
46 $matching =
new StatsdData();
47 $matching->setKey(
'foo.bar' );
48 $matching->setValue( 1 );
50 $nonMatching =
new StatsdData();
51 $nonMatching->setKey(
'oof.bar' );
52 $nonMatching->setValue( 1 );
55 $sender->expects( $this->
any() )->method(
'open' )->will( $this->returnValue(
true ) );
56 $sender->expects( $this->once() )->method(
'write' )->with( $this->
anything(),
57 $this->equalTo( $nonMatching ) );
60 $client->setSamplingRates( [
'foo.*' => 0.2 ] );
63 $client->send( $matching );
65 $client->send( $nonMatching );