CanalServerWithEmbedded:class
+ setMetricsPort- loadCanalMetrics
MetaCollector:class
+ collect:List<MetricFamilySamples>
CanalMetricsService:interface
+ initialize+ terminate+ register+ unRegister+ isRunning+ setServerPort
PrometheusService:class
ParserCollector:class
EntryCollector:class
CanalInstanceExports:class
+ initialize+ terminate+ register+ unRegister
StoreCollector:class
SinkCollector:class
InstanceRegistry:interface
+ register+ unRegister