update tag

Author: kikitux

create_function_toddog.sql

@@ -64,7 +64,7 @@ declare
 begin
   name := 'sample.gauge';
   metric := 15;
-  tag := 'plsql';
+  tag := 'source:plsql';
   result := f_gaugetoddog(name,metric,tag);
   dbms_output.put_line(result);
 EXCEPTION
@@ -86,7 +86,7 @@ declare
 begin
   name := 'sample.count';
   metric := 15;
-  tag := 'plsql';
+  tag := 'source:plsql';
   result := f_counttoddog(name,metric,tag);
   dbms_output.put_line(result);
 EXCEPTION

samples/rowcount.sql

@@ -2,6 +2,7 @@ set serveroutput on
 
 declare
   name varchar2(50);
+  tag varchar2(50);
   result varchar2(10);
   cursor c_table is
     select TABLE_NAME, NUM_ROWS from all_tables where OWNER = 'HR';
@@ -11,7 +12,8 @@ declare
 begin
   name := 'sample.rowcount';
   for t in c_table loop
-    result := f_gaugetoddog(name,t.num_rows,t.table_name);
+    tag := concat('schema:hr,table_name:',t.table_name);
+    result := f_gaugetoddog(name,t.num_rows,tag);
     IF result != 'done' THEN
       RAISE errorinloop;
    END IF;

samples/rowcount_job.sql

@@ -3,6 +3,7 @@ set serveroutput on
 CREATE OR REPLACE PROCEDURE proc_rowcount_toddog AS
   name varchar2(50);
   result varchar2(10);
+  tag varchar2(50);
   cursor c_table is
     select TABLE_NAME, NUM_ROWS from all_tables where OWNER = 'HR';
   errorinloop EXCEPTION;
@@ -11,7 +12,8 @@ CREATE OR REPLACE PROCEDURE proc_rowcount_toddog AS
 begin
   name := 'sample.rowcount';
   for t in c_table loop
-    result := f_gaugetoddog(name,t.num_rows,t.table_name);
+    tag := concat('schema:hr,table_name:',t.table_name);
+    result := f_gaugetoddog(name,t.num_rows,tag);
     IF result != 'done' THEN
       RAISE errorinloop;
    END IF;

src/toddog.c

@@ -50,12 +50,12 @@ char *metrictoddog(
 
     if (tag_i == OCI_IND_NULL)
     {
-      asprintf(&themetric,"%s:%d|%s|#tag:notag",metricname, metric, thekind);
+      asprintf(&themetric,"%s:%d|%s|",metricname, metric, thekind);
     }
 
     if  (tag_i == OCI_IND_NOTNULL)
     {
-      asprintf(&themetric,"%s:%d|%s|#tag:%s",metricname, metric, thekind,tag);
+      asprintf(&themetric,"%s:%d|%s|#%s",metricname, metric, thekind,tag);
     }
 
     udp(8125, themetric);