Skip to content

Commit

Permalink
Merge pull request #8 from johnchildren/update-database-semantic-conv…
Browse files Browse the repository at this point in the history
…entions

Update database semantic conventions
  • Loading branch information
frigus02 authored Aug 7, 2020
2 parents c28457f + 072b866 commit a62c909
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 10 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -56,9 +56,9 @@ The following of the Span's attributes map to special fields in Application Insi
| `db.statement` | Dependency Data |
| `http.host` | Dependency Target |
| `net.peer.name` | Dependency Target |
| `db.instance` | Dependency Target |
| `db.name` | Dependency Target |
| `http.status_code` | Dependency Result code |
| `db.type` | Dependency Type |
| `db.system` | Dependency Type |
| `messaging.system` | Dependency Type |
| `"HTTP"` if any `http.` attribute exists | Dependency Type |
| `"DB"` if any `db.` attribute exists | Dependency Type |
Expand Down
16 changes: 8 additions & 8 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -50,9 +50,9 @@
//! | `db.statement` | Dependency Data |
//! | `http.host` | Dependency Target |
//! | `net.peer.name` | Dependency Target |
//! | `db.instance` | Dependency Target |
//! | `db.name` | Dependency Target |
//! | `http.status_code` | Dependency Result code |
//! | `db.type` | Dependency Type |
//! | `db.system` | Dependency Type |
//! | `messaging.system` | Dependency Type |
//! | `"HTTP"` if any `http.` attribute exists | Dependency Type |
//! | `"DB"` if any `db.` attribute exists | Dependency Type |
Expand Down Expand Up @@ -116,8 +116,8 @@ impl Exporter {
"db.statement",
"http.host",
"net.peer.name",
"db.instance",
"db.type",
"db.name",
"db.system",
"messaging.system",
]
.iter()
Expand Down Expand Up @@ -254,14 +254,14 @@ impl Exporter {
data.target = Some(String::from(*host));
} else if let Some(peer_name) = attrs.get("net.peer.name") {
data.target = Some(String::from(*peer_name));
} else if let Some(db_instance) = attrs.get("db.instance") {
data.target = Some(String::from(*db_instance));
} else if let Some(db_name) = attrs.get("db.name") {
data.target = Some(String::from(*db_name));
}
if span.span_kind == SpanKind::Internal {
data.type_ = Some("InProc".into());
data.success = Some(true);
} else if let Some(db_type) = attrs.get("db.type") {
data.type_ = Some(String::from(*db_type));
} else if let Some(db_system) = attrs.get("db.system") {
data.type_ = Some(String::from(*db_system));
} else if let Some(messaging_system) = attrs.get("messaging.system") {
data.type_ = Some(String::from(*messaging_system));
} else if attrs.keys().any(|x| x.starts_with("http.")) {
Expand Down

0 comments on commit a62c909

Please sign in to comment.