$sampled->setValue( 1 );
$sampled->setSampleRate( '0.1' );
- return array(
+ return [
// $data, $sampleRate, $seed, $expectWrite
- array( $unsampled, 1, 0 /*0.44*/, $unsampled ),
- array( $sampled, 1, 0 /*0.44*/, null ),
- array( $sampled, 1, 4 /*0.03*/, $sampled ),
- array( $unsampled, 0.1, 4 /*0.03*/, $sampled ),
- array( $sampled, 0.5, 0 /*0.44*/, null ),
- array( $sampled, 0.5, 4 /*0.03*/, $sampled ),
- );
+ [ $unsampled, 1, 0 /*0.44*/, true ],
+ [ $sampled, 1, 0 /*0.44*/, false ],
+ [ $sampled, 1, 4 /*0.03*/, true ],
+ [ $unsampled, 0.1, 0 /*0.44*/, false ],
+ [ $sampled, 0.5, 0 /*0.44*/, false ],
+ [ $sampled, 0.5, 4 /*0.03*/, false ],
+ ];
+ }
+
+ public function testSetSamplingRates() {
+ $matching = new StatsdData();
+ $matching->setKey( 'foo.bar' );
+ $matching->setValue( 1 );
+
+ $nonMatching = new StatsdData();
+ $nonMatching->setKey( 'oof.bar' );
+ $nonMatching->setValue( 1 );
+
+ $sender = $this->getMock( 'Liuggio\StatsdClient\Sender\SenderInterface' );
+ $sender->expects( $this->any() )->method( 'open' )->will( $this->returnValue( true ) );
+ $sender->expects( $this->once() )->method( 'write' )->with( $this->anything(),
+ $this->equalTo( $nonMatching ) );
+
+ $client = new SamplingStatsdClient( $sender );
+ $client->setSamplingRates( [ 'foo.*' => 0.2 ] );
+
+ mt_srand( 0 ); // next random is 0.44
+ $client->send( $matching );
+ mt_srand( 0 );
+ $client->send( $nonMatching );
}
}