blob: d819588c030d4e51cce7e2a76327641105ef109f (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
/* =========================================================================================
* Copyright © 2013-2014 the kamon project <http://kamon.io/>
*
* 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.
* =========================================================================================
*/
package kamon
import _root_.akka.actor
import _root_.akka.actor._
import com.typesafe.config.{ ConfigFactory, Config }
import kamon.metric._
import kamon.trace.{ TracerModuleImpl, TracerModule }
object Kamon {
trait Extension extends actor.Extension
private case class KamonCoreComponents(metrics: MetricsModule, tracer: TracerModule)
@volatile private var _system: ActorSystem = _
@volatile private var _coreComponents: Option[KamonCoreComponents] = None
def start(config: Config): Unit = synchronized {
def resolveInternalConfig: Config = {
val internalConfig = config.getConfig("kamon.internal-config")
config
.withoutPath("akka")
.withoutPath("spray")
.withFallback(internalConfig)
}
if (_coreComponents.isEmpty) {
val metrics = MetricsModuleImpl(config)
val tracer = TracerModuleImpl(metrics, config)
_coreComponents = Some(KamonCoreComponents(metrics, tracer))
_system = ActorSystem("kamon", resolveInternalConfig)
metrics.start(_system)
tracer.start(_system)
_system.registerExtension(ModuleLoader)
} else sys.error("Kamon has already been started.")
}
def start(): Unit =
start(ConfigFactory.load)
def shutdown(): Unit = {
_coreComponents = None
_system.shutdown()
_system = null
}
def metrics: MetricsModule =
ifStarted(_.metrics)
def tracer: TracerModule =
ifStarted(_.tracer)
def apply[T <: Kamon.Extension](key: ExtensionId[T]): T =
ifStarted { _ ⇒
if (_system ne null)
key(_system)
else
sys.error("Cannot retrieve extensions while Kamon is being initialized.")
}
def extension[T <: Kamon.Extension](key: ExtensionId[T]): T =
apply(key)
private def ifStarted[T](thunk: KamonCoreComponents ⇒ T): T =
_coreComponents.map(thunk(_)) getOrElse (sys.error("Kamon has not been started yet."))
}
|
