/* Ċ Ġ* Ġ============ LICENSE _ START ================================================ ======= Ċ Ġ* Ġd cae gen 2 - collect ors - ves hv Ċ Ġ* Ġ================================================================= =============== Ċ Ġ* ĠCopyright Ġ( C ) Ġ 2 0 1 8 - 2 0 1 9 ĠN OK IA Ċ Ġ* Ġ================================================================= =============== Ċ Ġ* ĠLicensed Ġunder Ġthe ĠApache ĠLicense , ĠVersion Ġ 2 . 0 Ġ( the Ġ" License "); Ċ Ġ* Ġyou Ġmay Ġnot Ġuse Ġthis Ġfile Ġexcept Ġin Ġcompliance Ġwith Ġthe ĠLicense . Ċ Ġ* ĠYou Ġmay Ġobtain Ġa Ġcopy Ġof Ġthe ĠLicense Ġat Ċ Ġ* Ċ Ġ* ĠĠĠĠĠ Ġhttp :// www . apache . org / licenses / LICENSE - 2 . 0 Ċ Ġ* Ċ Ġ* ĠUnless Ġrequired Ġby Ġapplicable Ġlaw Ġor Ġagreed Ġto Ġin Ġwriting , Ġsoftware Ċ Ġ* Ġdistributed Ġunder Ġthe ĠLicense Ġis Ġdistributed Ġon Ġan Ġ" AS ĠIS " ĠBASIS , Ċ Ġ* ĠWITHOUT ĠWARRANTIES ĠOR ĠCONDITIONS ĠOF ĠANY ĠKIND , Ġeither Ġexpress Ġor Ġimplied . Ċ Ġ* ĠSee Ġthe ĠLicense Ġfor Ġthe Ġspecific Ġlanguage Ġgoverning Ġpermissions Ġand Ċ Ġ* Ġlimitations Ġunder Ġthe ĠLicense . Ċ Ġ* Ġ============ LICENSE _ END ================================================ ========= Ċ Ġ*/ Ċ package Ġorg . on ap . dca e . collect ors . ves hv . factory Ċ Ċ import Ġorg . on ap . dca e . collect ors . ves hv . boundary . Collector Ċ import Ġorg . on ap . dca e . collect ors . ves hv . boundary . Collector Factory Ċ import Ġorg . on ap . dca e . collect ors . ves hv . boundary . Metrics Ċ import Ġorg . on ap . dca e . collect ors . ves hv . boundary . Sink Factory Ċ import Ġorg . on ap . dca e . collect ors . ves hv . config . api . model . Collector Configuration Ċ import Ġorg . on ap . dca e . collect ors . ves hv . domain . Wire Frame Decoder Ċ import Ġorg . on ap . dca e . collect ors . ves hv . impl . Hv V es Collector Ċ import Ġorg . on ap . dca e . collect ors . ves hv . impl . Router Ċ import Ġorg . on ap . dca e . collect ors . ves hv . impl . V es Decoder Ċ import Ġorg . on ap . dca e . collect ors . ves hv . impl . wire . Wire Chunk Decoder Ċ import Ġorg . on ap . dca e . collect ors . ves hv . domain . logging . ClientContext Ċ Ċ /** Ċ Ġ* Ġ@ author ĠP io tr ĠJ as zc zy k Ġ< pio tr . jas zc zy k @ nok ia . com > Ċ Ġ* Ġ@ since ĠMay Ġ 2 0 1 8 Ċ Ġ*/ Ċ class ĠH v V es Collector Factory ( private Ġval Ġconfiguration : ĠCollector Configuration , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġsink Factory : ĠS ink Factory , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġmetrics : ĠMetrics ) Ġ: ĠCollector Factory Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġinvoke ( ctx : ĠClient Context ): ĠCollector Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcreate V es Hv Collector ( ctx ) ĊĊĠĠĠ Ġoverride Ġfun Ġclose () Ġ= Ġsink Factory . close () ĊĊĠĠĠ Ġprivate Ġfun Ġcreate V es Hv Collector ( ctx : ĠClient Context ): ĠCollector Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ ĠH v V es Collector ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġclient Context Ġ= Ġctx , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġwire Chunk Decoder Ġ= ĠWire Chunk Decoder ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠWire Frame Decoder ( configuration . max Payload Size Bytes ), Ġctx ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprotobuf Decoder Ġ= ĠV es Decoder (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġrouter Ġ= ĠRouter ( configuration . routing , Ġsink Factory , Ġctx , Ġmetrics ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmetrics Ġ= Ġmetrics ) Ċ } Ċ