refactor: update sw agent

Author: BFergerson

build.gradle.kts

@@ -4,7 +4,7 @@ plugins {
 }
 
 python {
-    pip("apache-skywalking:0.8.0")
+    pip("apache-skywalking:1.0.0")
     pip("vertx-eventbus-client:1.0.0")    
 }
 

sourceplusplus/SourcePlusPlus.py

@@ -103,12 +103,12 @@ def __init__(self, args: dict = None):
 
     def attach(self):
         config.init(
-            collector_address=self.probe_config["skywalking"]["collector"]["backend_service"],
-            service_name=self.probe_config["skywalking"]["agent"]["service_name"],
-            authentication=self.probe_config["skywalking"]["agent"].get("authentication"),
-            log_reporter_active=True,
-            force_tls=self.probe_config["spp"]["ssl_enabled"],
-            log_reporter_formatted=self.probe_config["skywalking"]["plugin"]["toolkit"]["log"]["transmit_formatted"]
+            agent_collector_backend_services=self.probe_config["skywalking"]["collector"]["backend_service"],
+            agent_name=self.probe_config["skywalking"]["agent"]["service_name"],
+            agent_authentication=self.probe_config["skywalking"]["agent"].get("authentication"),
+            agent_log_reporter_active=True,
+            agent_force_tls=self.probe_config["spp"]["ssl_enabled"],
+            agent_log_reporter_formatted=self.probe_config["skywalking"]["plugin"]["toolkit"]["log"]["transmit_formatted"]
         )
         agent.start()
 
@@ -141,8 +141,8 @@ def __send_connected(self, eb: EventBus):
             "language": "python",
             "probe_version": __version__,
             "python_version": sys.version,
-            "service": config.service_name,
-            "service_instance": config.service_instance
+            "service": config.agent_name,
+            "service_instance": config.agent_instance_name
         }
 
         # add hardcoded probe meta data (if present)

sourceplusplus/control/ContextReceiver.py

@@ -62,8 +62,8 @@ def apply_log(live_log_id, globals, locals):
     sw_context = get_context()
     log_data = LogData(
         timestamp=round(time.time() * 1000),
-        service=config.service_name,
-        serviceInstance=config.service_instance,
+        service=config.agent_name,
+        serviceInstance=config.agent_instance_name,
         body=LogDataBody(
             type='text',
             text=TextLog(text=live_log.log_format)
@@ -75,7 +75,7 @@ def apply_log(live_log_id, globals, locals):
         ),
         tags=log_tags,
     )
-    agent.archive_log(log_data)
+    agent.agent.archive_log(log_data)
 
     if live_log.is_finished():
         try: