Repository: honeycombio/refinery
Pull request #233 (2021-03-24 12:10:15)

Bump github.com/grpc-ecosystem/grpc-gateway from 1.12.1 to 1.16.0
Bumps [github.com/grpc-ecosystem/grpc-gateway](https://github.com/grpc-ecosystem/grpc-gateway) from 1.12.1 to 1.16.0.
<details>
<summary>Release notes</summary>
<p><em>Sourced from <a href="https://github.com/grpc-ecosystem/grpc-gateway/releases">github.com/grpc-ecosystem/grpc-gateway's releases</a>.</em></p>
<blockquote>
<h2>v1.16.0</h2>
<h2>The grpc-gateway v1 is in maintenance mode, you are encouraged to migrate to v2. Check out <a href="https://grpc-ecosystem.github.io/grpc-gateway/docs/development/grpc-gateway_v2_migration_guide/">our v2 migration guide</a>.</h2>
<h2><a href="https://github.com/grpc-ecosystem/grpc-gateway/tree/v1.16.0">v1.16.0</a> (2020-10-28)</h2>
<p><a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v1.15.2...v1.16.0">Full Changelog</a></p>
<p><strong>Merged pull requests:</strong></p>
<ul>
<li>feat: protoc-gen-swagger: Implement Response Header(s) object, Implem… <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1730">#1730</a> (<a href="https://github.com/elijah-roberts">elijah-roberts</a>)</li>
</ul>
<h2>v1.15.2</h2>
<h2>The grpc-gateway v1 is in maintenance mode, you are encouraged to migrate to v2.</h2>
<h2>See <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1223">grpc-ecosystem/grpc-gateway#1223</a> for more information and check out <a href="https://grpc-ecosystem.github.io/grpc-gateway/docs/development/grpc-gateway_v2_migration_guide/">our v2 migration guide</a>.</h2>
<h2><a href="https://github.com/grpc-ecosystem/grpc-gateway/tree/v1.15.2">v1.15.2</a> (2020-10-10)</h2>
<p><a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v1.15.1...v1.15.2">Full Changelog</a></p>
<h2>v1.15.1</h2>
<h2>This will be the last release of v1 on the master branch</h2>
<h2>The grpc-gateway v1 is in maintenance mode, you are encouraged to migrate to v2.</h2>
<h2>See <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1223">grpc-ecosystem/grpc-gateway#1223</a> for more information and check out <a href="https://grpc-ecosystem.github.io/grpc-gateway/docs/development/grpc-gateway_v2_migration_guide/">our v2 migration guide</a>.</h2>
<h2><a href="https://github.com/grpc-ecosystem/grpc-gateway/tree/v1.15.1">v1.15.1</a> (2020-10-10)</h2>
<p><a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v1.15.0...v1.15.1">Full Changelog</a></p>
<h2>v1.15.0</h2>
<h2>The grpc-gateway v1 is in maintenance mode, you are encouraged to migrate to v2.</h2>
<h2>See <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1223">grpc-ecosystem/grpc-gateway#1223</a> for more information and check out <a href="https://grpc-ecosystem.github.io/grpc-gateway/docs/development/grpc-gateway_v2_migration_guide/">our v2 migration guide</a>.</h2>
<h2><a href="https://github.com/grpc-ecosystem/grpc-gateway/tree/v1.15.0">v1.15.0</a> (2020-09-18)</h2>
<p><a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v1.14.8...v1.15.0">Full Changelog</a></p>
<p><strong>New Features:</strong></p>
<ul>
<li>Generate unbound methods <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1652">#1652</a> (<a href="https://github.com/plaflamme">plaflamme</a>)</li>
</ul>
<p><strong>Closed issues:</strong></p>
<ul>
<li>Empty json array is passed as nil <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1673">#1673</a></li>
<li>Lightweight support for custom protobuf annotations on RPCs <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1666">#1666</a></li>
<li>undefined: runtime.ServerTransportStream <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1664">#1664</a></li>
<li>Merge swagger definitions generated by swaggo/swag init and protoc --swagger_out command <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1651">#1651</a></li>
<li>Add base_path as constant in generated gateway files <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1650">#1650</a></li>
<li>Support service definitions without any annotations. <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1649">#1649</a></li>
<li>proto directory names preclude using protos in python code <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1647">#1647</a></li>
</ul>
<!-- raw HTML omitted -->
</blockquote>
<p>... (truncated)</p>
</details>
<details>
<summary>Changelog</summary>
<p><em>Sourced from <a href="https://github.com/grpc-ecosystem/grpc-gateway/blob/master/CHANGELOG.md">github.com/grpc-ecosystem/grpc-gateway's changelog</a>.</em></p>
<blockquote>
<h2><a href="https://github.com/grpc-ecosystem/grpc-gateway/tree/v1.16.0">v1.16.0</a> (2020-10-28)</h2>
<p><a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v1.15.1...v1.16.0">Full Changelog</a></p>
<p><strong>Merged pull requests:</strong></p>
<ul>
<li>Update dependency io_bazel_rules_go to v0.24.5 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1775">#1775</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update google.golang.org/genproto commit hash to d4b8fe4 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1774">#1774</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update google.golang.org/genproto commit hash to 0ff5f38 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1772">#1772</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update google.golang.org/genproto commit hash to 0d71844 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1771">#1771</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
</ul>
<h2><a href="https://github.com/grpc-ecosystem/grpc-gateway/tree/v2.0.1">v2.0.1</a> (2020-10-21)</h2>
<p><a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v2.0.0...v2.0.1">Full Changelog</a></p>
<p><strong>Closed issues:</strong></p>
<ul>
<li>why was swagger removed <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1765">#1765</a></li>
<li>Option -module does not work anymore for protoc-gen-grpc-gateway v2 <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1753">#1753</a></li>
<li>grpc-gateway_out Cannot set flag <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1751">#1751</a></li>
</ul>
<p><strong>Merged pull requests:</strong></p>
<ul>
<li>Generate changelog for v2.0.1 <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1770">#1770</a> (<a href="https://github.com/johanbrandhorst">johanbrandhorst</a>)</li>
<li>Update module google.golang.org/grpc to v1.33.1 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1768">#1768</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update google.golang.org/genproto commit hash to 1ed22bb (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1764">#1764</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update dependency io_bazel_rules_go to v0.24.4 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1762">#1762</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update google.golang.org/genproto commit hash to 32ed001 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1761">#1761</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update module golang/protobuf to v1.4.3 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1760">#1760</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update golang Docker tag to v1.15.3 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1759">#1759</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>fix import alias issue with protoc-gen-grpc-gateway <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1757">#1757</a> (<a href="https://github.com/danielhochman">danielhochman</a>)</li>
<li>Refactor registry and generator to use protogen <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1756">#1756</a> (<a href="https://github.com/adambabik">adambabik</a>)</li>
<li>Adapt usage instructions to use protoc-gen-go-grpc <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1755">#1755</a> (<a href="https://github.com/olivierlemasle">olivierlemasle</a>)</li>
<li>Fix -module option for protoc-gen-grpc-gateway <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1754">#1754</a> (<a href="https://github.com/olivierlemasle">olivierlemasle</a>)</li>
<li>fix empty parameter fatal in protoc-gen-grpc-gateway  <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1752">#1752</a> (<a href="https://github.com/danielhochman">danielhochman</a>)</li>
<li>Update google.golang.org/genproto commit hash to 03b6142 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1750">#1750</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
<li>Update Readme  + remove duplicated paragraph <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1749">#1749</a> (<a href="https://github.com/olivierlemasle">olivierlemasle</a>)</li>
<li>Update gorelease base for master <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1747">#1747</a> (<a href="https://github.com/johanbrandhorst">johanbrandhorst</a>)</li>
<li>Update google.golang.org/genproto commit hash to 7f9ee70 (master) <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/pull/1745">#1745</a> (<a href="https://github.com/apps/renovate">renovate[bot]</a>)</li>
</ul>
<h2><a href="https://github.com/grpc-ecosystem/grpc-gateway/tree/v2.0.0">v2.0.0</a> (2020-10-14)</h2>
<p><a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v1.15.1...v2.0.0">Full Changelog</a></p>
<p><strong>Closed issues:</strong></p>
<ul>
<li>protoc-gen-swagger: support a header parameter <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1737">#1737</a></li>
<li>Cannot unmarshal list <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1736">#1736</a></li>
<li><a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1723">grpc-ecosystem/grpc-gateway#1723</a> <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1724">#1724</a></li>
<li>too many arguments in call to runtime.NewPattern and  undefined: runtime.AssumeColonVerbOpt <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1723">#1723</a></li>
<li>v2 release planning <a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1223">#1223</a></li>
</ul>
<p><strong>Merged pull requests:</strong></p>
<!-- raw HTML omitted -->
</blockquote>
<p>... (truncated)</p>
</details>
<details>
<summary>Commits</summary>
<ul>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/094a6fe78b3ca888297d090185cdf30f0e42e157"><code>094a6fe</code></a> Generate changelog for v1.16.0 (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1776">#1776</a>)</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/e0a026aeb20c3eb0f32cbfdc537c9966634895b9"><code>e0a026a</code></a> protoc-gen-swagger: Implement Response Header(s) object (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1730">#1730</a>)</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/cfb0a30bdd7fbce1be871b773119d6fdc2b0eeb5"><code>cfb0a30</code></a> Update module google.golang.org/grpc to v1.33.1</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/0dc6280eac3663b3128312838429873e89cee66f"><code>0dc6280</code></a> Update golang Docker tag to v1.15.3</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/f6391fc3d0e68ad865156b9b9ccacec44421484f"><code>f6391fc</code></a> Update gorelease base for v1 (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1748">#1748</a>)</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/384bafa91ebfa32c14d75f5c75a084546b7bcefa"><code>384bafa</code></a> Update v1 renovate config (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1738">#1738</a>)</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/90c395095094cad43c533f891c71de21d7744341"><code>90c3950</code></a> Update dependency bazel_gazelle to v0.22.2</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/9f0459a63fd4c62c6b9a9d8cea0dc49f26a790f0"><code>9f0459a</code></a> Add Slack badge, remove fuzzit badge (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1712">#1712</a>) (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1713">#1713</a>)</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/df2d5924ac4806c9dc753dc9a79c3d2c5734906e"><code>df2d592</code></a> Add --omit_package_doc flag (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1702">#1702</a>)</li>
<li><a href="https://github.com/grpc-ecosystem/grpc-gateway/commit/2a56465887849317a3d7db2c1b983b110a11aff9"><code>2a56465</code></a> Add patch to CircleCI build image (<a href="https://github-redirect.dependabot.com/grpc-ecosystem/grpc-gateway/issues/1699">#1699</a>)</li>
<li>Additional commits viewable in <a href="https://github.com/grpc-ecosystem/grpc-gateway/compare/v1.12.1...v1.16.0">compare view</a></li>
</ul>
</details>
<br />


[![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=github.com/grpc-ecosystem/grpc-gateway&package-manager=go_modules&previous-version=1.12.1&new-version=1.16.0)](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores)

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`.

[//]: # (dependabot-automerge-start)
[//]: # (dependabot-automerge-end)

---

<details>
<summary>Dependabot commands and options</summary>
<br />

You can trigger Dependabot actions by commenting on this PR:
- `@dependabot rebase` will rebase this PR
- `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it
- `@dependabot merge` will merge this PR after your CI passes on it
- `@dependabot squash and merge` will squash and merge this PR after your CI passes on it
- `@dependabot cancel merge` will cancel a previously requested merge and block automerging
- `@dependabot reopen` will reopen this PR if it is closed
- `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
- `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)


</details>


Patch:
diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS
index 8dcecb4..bc06334 100644
--- a/.github/CODEOWNERS
+++ b/.github/CODEOWNERS
@@ -1,1 +1,1 @@
-* @honeycombio/integrations-team
+* @honeycombio/telemetry-team
diff --git a/.github/dependabot.yml b/.github/dependabot.yml
index caf9e4d..2a0f635 100644
--- a/.github/dependabot.yml
+++ b/.github/dependabot.yml
@@ -10,6 +10,6 @@ updates:
     schedule:
       interval: "weekly"
     labels:
-      - "type: maintenance"
+      - "type: dependencies"
     reviewers:
-      - "honeycombio/integrations-team"
+      - "honeycombio/telemetry-team"
diff --git a/.github/workflows/add-to-project.yml b/.github/workflows/add-to-project.yml
new file mode 100644
index 0000000..ac02faa
--- /dev/null
+++ b/.github/workflows/add-to-project.yml
@@ -0,0 +1,14 @@
+name: Apply project management flow
+on:
+  issues:
+    types: [opened]
+  pull_request_target:
+    types: [opened]
+jobs:
+  project-management:
+    runs-on: ubuntu-latest
+    name: Apply project management flow
+    steps:
+      - uses: honeycombio/oss-management-actions/projects@v1
+        with:
+          ghprojects-token: ${{ secrets.GHPROJECTS_TOKEN }}
diff --git a/.github/workflows/apply-labels.yml b/.github/workflows/apply-labels.yml
index b6aeae2..7d90af5 100644
--- a/.github/workflows/apply-labels.yml
+++ b/.github/workflows/apply-labels.yml
@@ -1,16 +1,10 @@
 name: Apply project labels
-
-on:
-  - issues
-  - label
-  - pull_request_target
-  - pull_request
-
+on: [issues, pull_request, label]
 jobs:
   apply-labels:
     runs-on: ubuntu-latest
     name: Apply common project labels
     steps:
-      - uses: honeycombio/integrations-labels@v1
+      - uses: honeycombio/oss-management-actions/labels@v1
         with:
           github-token: ${{ secrets.GITHUB_TOKEN }}
diff --git a/CHANGELOG.md b/CHANGELOG.md
index a9e889d..305965c 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,48 @@
 # Refinery Changelog
 
+## 1.3.0
+
+### Added
+
+- Add support to "does-not-contain" operator on RulesBasedSampler [#267](https://github.com/honeycombio/refinery/pull/267) | [@tr-fteixeira](https://github.com/tr-fteixeira)
+
+### Fixes
+
+- Ensure span links and events generate events and get resource attrs [#264](https://github.com/honeycombio/refinery/pull/264) | [@MikeGoldsmith](https://github.com/MikeGoldsmith)
+
+## 1.2.1
+
+### Fixes
+
+- OTLP span events are now supported, they were being dropped on the floor previously (#261) | [@dstrelau](https://github.com/dstrelau)
+
+## 1.2.0
+
+### Added
+
+- Add `UseTLSInsecure` config option to skip TLS verification with Redis (#254) | [@beanieboi](https://github.com/beanieboi)
+- Add `AddHostMetadataToTrace` config option to add Refinery hostname information to spans (#250) | [@jharley](https://github.com/jharley)
+- Additional config validation: verify that sample rate trace field key is specified, if needed (#248) | [@paulosman](https://github.com/paulosman)
+
+### Changed
+
+- Remove redundant peer/api suffix from response error metrics (#247) | [@vreynolds](https://github.com/vreynolds)
+    - `api_response_errors_api`, `api_response_errors_peer`, `peer_response_errors_api`, `peer_response_errors_peer`
+    - replaced by `api_response_errors`, `peer_response_errors`
+- Fix rules sampler to emit correct metric (#236) | [@isnotajoke](https://github.com/isnotajoke)
+    - Previously `dynsampler_num_dropped` was emitted, now `rulessampler_num_dropped` will be emitted
+
+### Maintenance
+
+- Update README content (#239) | [@jjziv](https://github.com/jjziv)
+- Move from garyburd Redigo to supported redigo (#249) | [@verajohne](https://github.com/verajohne)
+- Bump google.golang.org/grpc from 1.32.0 to 1.37.1 (#253)
+- Bump github.com/prometheus/client_golang from 0.9.3 to 0.9.4 (#240)
+- Bump github.com/pkg/errors from 0.8.1 to 0.9.1 (#232)
+- Bump github.com/stretchr/testify from 1.5.1 to 1.7.0 (#231)
+- Bump github.com/jessevdk/go-flags from 1.4.0 to 1.5.0 (#230)
+- Bump github.com/hashicorp/golang-lru from 0.5.1 to 0.5.4 (#229)
+
 ## 1.1.1
 
 ### Fixes
diff --git a/go.mod b/go.mod
index dfaf6f5..5bd4205 100644
--- a/go.mod
+++ b/go.mod
@@ -15,7 +15,7 @@ require (
 	github.com/golang/protobuf v1.4.3
 	github.com/gomodule/redigo v1.8.4
 	github.com/gorilla/mux v1.6.3-0.20190108142930-08e7f807d38d
-	github.com/grpc-ecosystem/grpc-gateway v1.12.1
+	github.com/grpc-ecosystem/grpc-gateway v1.16.0
 	github.com/hashicorp/golang-lru v0.5.4
 	github.com/honeycombio/dynsampler-go v0.2.1
 	github.com/honeycombio/libhoney-go v1.12.4
@@ -26,7 +26,7 @@ require (
 	github.com/mitchellh/mapstructure v1.3.3 // indirect
 	github.com/pelletier/go-toml v1.8.0 // indirect
 	github.com/pkg/errors v0.9.1
-	github.com/prometheus/client_golang v0.9.3
+	github.com/prometheus/client_golang v0.9.4
 	github.com/rcrowley/go-metrics v0.0.0-20200313005456-10cdbea86bc0
 	github.com/sirupsen/logrus v1.2.0
 	github.com/spf13/afero v1.3.2 // indirect
diff --git a/go.sum b/go.sum
index 0850042..1732b0e 100644
--- a/go.sum
+++ b/go.sum
@@ -20,7 +20,7 @@ github.com/DataDog/zstd v1.4.5/go.mod h1:1jcaCB/ufaK+sKp1NBhlGmpz41jOoPQ35bpF36t
 github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
 github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
 github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
-github.com/antihax/optional v0.0.0-20180407024304-ca021399b1a6/go.mod h1:V8iCPQYkqmusNa815XgQio277wI47sdRh1dUOLdyC6Q=
+github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY=
 github.com/armon/circbuf v0.0.0-20150827004946-bbbad097214e/go.mod h1:3U/XgcO3hCbHZ8TKRvWD2dDTCfh9M9ya+I9JpbB7O8o=
 github.com/armon/go-metrics v0.0.0-20180917152333-f0300d1749da/go.mod h1:Q73ZrmVTwzkszR9V5SSuryQ31EELlFMUz1kKyl939pY=
 github.com/armon/go-radix v0.0.0-20180808171621-7fddfc383310/go.mod h1:ufUuZ+zHj4x4TnLV4JWEpy2hxWSpsRywHrMgIH9cCH8=
@@ -32,6 +32,7 @@ github.com/bketelsen/crypt v0.0.3-0.20200106085610-5cbc8cc4026c/go.mod h1:MKsuJm
 github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
 github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
+github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
 github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
 github.com/coreos/bbolt v1.3.2/go.mod h1:iRUV2dpdMOn7Bo10OQBFzIJO9kkE559Wcmn+qkEiiKk=
 github.com/coreos/etcd v3.3.13+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE=
@@ -45,6 +46,7 @@ github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZm
 github.com/dgryski/go-sip13 v0.0.0-20181026042036-e10d5fee7954/go.mod h1:vAd38F8PWV+bWy6jNmig1y/TA+kYO4g3RSRF0IAv0no=
 github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
 github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
+github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98=
 github.com/envoyproxy/go-control-plane v0.9.9-0.20210217033140-668b12f5399d/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk=
 github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
 github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a h1:yDWHCSQ40h88yih2JAcL6Ls/kVkSE8GFACTGVnMPruw=
@@ -93,6 +95,7 @@ github.com/golang/mock v1.3.1/go.mod h1:sBzyDLLjw3U8JLTeZvSv8jJB+tU5PVekmnlKIyFU
 github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
 github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
 github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.3.3/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw=
 github.com/golang/protobuf v1.3.4/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw=
 github.com/golang/protobuf v1.3.5/go.mod h1:6O5/vntMXwX2lRkT1hjjk0nAC1IDOTvTlVgjlRvqsdk=
 github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
@@ -129,8 +132,8 @@ github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/ad
 github.com/grpc-ecosystem/go-grpc-middleware v1.0.0/go.mod h1:FiyG127CGDf3tlThmgyCl78X/SZQqEOJBCDaAfeWzPs=
 github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0/go.mod h1:8NvIoxWQoOIhqOTXgfV/d3M/q6VIi02HzZEHgUlZvzk=
 github.com/grpc-ecosystem/grpc-gateway v1.9.0/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY=
-github.com/grpc-ecosystem/grpc-gateway v1.12.1 h1:zCy2xE9ablevUOrUZc3Dl72Dt+ya2FNAvC2yLYMHzi4=
-github.com/grpc-ecosystem/grpc-gateway v1.12.1/go.mod h1:8XEsbTttt/W+VvjtQhLACqCisSPWTxCZ7sBRjU6iH9c=
+github.com/grpc-ecosystem/grpc-gateway v1.16.0 h1:gmcG1KaJ57LophUzW0Hy8NmPhnMZb4M0+kPpLofRdBo=
+github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw=
 github.com/hashicorp/consul/api v1.1.0/go.mod h1:VmuI/Lkw1nC05EYQWNKwWGbkg+FbDBtguAZLlVdkD9Q=
 github.com/hashicorp/consul/sdk v0.1.1/go.mod h1:VKf9jXwCTEY1QZP2MOLRhb5i/I/ssyNV1vwHyQBF0x8=
 github.com/hashicorp/errwrap v1.0.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
@@ -218,18 +221,21 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/posener/complete v1.1.1/go.mod h1:em0nMJCgc9GFtwrmVmEMR/ZL6WyhyjMBndrE9hABlRI=
 github.com/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
-github.com/prometheus/client_golang v0.9.3 h1:9iH4JKXLzFbOAdtqv/a+j8aewx2Y8lAjAydhbaScPF8=
 github.com/prometheus/client_golang v0.9.3/go.mod h1:/TN21ttK/J9q6uSwhBd54HahCDft0ttaMvbicHlPoso=
+github.com/prometheus/client_golang v0.9.4 h1:Y8E/JaaPbmFSW2V81Ab/d8yZFYQQGbni1b1jPcG9Y6A=
+github.com/prometheus/client_golang v0.9.4/go.mod h1:oCXIBxdI62A4cR6aTRJCgetEjecSIYzOEaeAn4iYEpM=
 github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
 github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4 h1:gQz4mCbXsO+nc9n1hCxHcGA3Zx3Eo+UHZoInFGUIXNM=
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
 github.com/prometheus/common v0.0.0-20181113130724-41aa239b4cce/go.mod h1:daVV7qP5qjZbuso7PdcryaAu0sAZbrN9i7WWcTMWvro=
-github.com/prometheus/common v0.4.0 h1:7etb9YClo3a6HjLzfl6rIQaU+FDfi0VSX39io3aQ+DM=
 github.com/prometheus/common v0.4.0/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
+github.com/prometheus/common v0.4.1 h1:K0MGApIoQvMw27RTdJkPbr3JZ7DNbtxQNyi5STVM6Kw=
+github.com/prometheus/common v0.4.1/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
 github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
-github.com/prometheus/procfs v0.0.0-20190507164030-5867b95ac084 h1:sofwID9zm4tzrgykg80hfFph1mryUeLRsUfoocVVmRY=
 github.com/prometheus/procfs v0.0.0-20190507164030-5867b95ac084/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
+github.com/prometheus/procfs v0.0.2 h1:6LJUbpNm42llc4HRCuvApCSWB/WfhuNo9K98Q9sNGfs=
+github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
 github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
 github.com/rcrowley/go-metrics v0.0.0-20200313005456-10cdbea86bc0 h1:MkV+77GLUNo5oJ0jf870itWm3D0Sjh7+Za9gazKc5LQ=
 github.com/rcrowley/go-metrics v0.0.0-20200313005456-10cdbea86bc0/go.mod h1:bCqnVzQkZxMG4s8nGwiZ5l3QUCyqpo9Y+/ZMZ9VjZe4=
@@ -287,8 +293,9 @@ golang.org/x/crypto v0.0.0-20181029021203-45a5f77698d3/go.mod h1:6SG95UA2DQfeDnf
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/crypto v0.0.0-20190605123033-f99c8df09eb5/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
-golang.org/x/crypto v0.0.0-20190820162420-60c769a6c586 h1:7KByu05hhLed2MO29w7p1XfZvZ13m8mub3shuVftRs0=
 golang.org/x/crypto v0.0.0-20190820162420-60c769a6c586/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9 h1:psW17arqaxU48Z5kZ0CQnkZWQJsqcURM6tKiBApRjXI=
+golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
 golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
 golang.org/x/exp v0.0.0-20190306152737-a1d7652674e8/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
 golang.org/x/exp v0.0.0-20190510132918-efd6b22b2522/go.mod h1:ZjyILWgesfNpC6sMxTJOJm9Kp84zZh5NQWvqDGG3Qr8=
@@ -321,13 +328,14 @@ golang.org/x/net v0.0.0-20190501004415-9ce7a6920f09/go.mod h1:t9HGtf8HONx5eT2rtn
 golang.org/x/net v0.0.0-20190503192946-f4e77d36d62c/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190603091049-60506f45cf65/go.mod h1:HSz+uSET+XFnRR8LxR5pz3Of3rY3CfYBVs4xY44aLks=
 golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20191002035440-2ec189313ef0/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20200301022130-244492dfa37a/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20200324143707-d3edc9973b7e h1:3G+cUijn7XD+S4eJFddp53Pv7+slrESplyjG25HgL+k=
 golang.org/x/net v0.0.0-20200324143707-d3edc9973b7e/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200822124328-c89045814202 h1:VvcQYSHwXgi7W+TpUR6A9g6Up98WAHf3f/ulnJ62IyA=
+golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
+golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -377,8 +385,9 @@ golang.org/x/tools v0.0.0-20190911174233-4f2ddba30aff/go.mod h1:b+2E5dAYhXwXZwtn
 golang.org/x/tools v0.0.0-20191012152004-8de300cfc20a/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.0.0-20191112195655-aa38f8e97acc/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 google.golang.org/api v0.4.0/go.mod h1:8k5glujaEP+g9n7WNsDg8QP6cUVNI86fCNMcbazEtwE=
 google.golang.org/api v0.7.0/go.mod h1:WtwebWUNSVBH/HAw79HIFXZNqEvBhG+Ra+ax0hx3E3M=
 google.golang.org/api v0.8.0/go.mod h1:o4eAsZoiT+ibD93RtjEohWalFOjRDx6CVaqeizhEnKg=
@@ -398,17 +407,17 @@ google.golang.org/genproto v0.0.0-20190502173448-54afdca5d873/go.mod h1:VzzqZJRn
 google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
 google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
 google.golang.org/genproto v0.0.0-20190911173649-1774047e7e51/go.mod h1:IbNlFCBrqXvoKpeg0TB2l7cyZUmoaFKYIwrEpbDKLA8=
-google.golang.org/genproto v0.0.0-20190927181202-20e1ac93f88c/go.mod h1:IbNlFCBrqXvoKpeg0TB2l7cyZUmoaFKYIwrEpbDKLA8=
 google.golang.org/genproto v0.0.0-20191108220845-16a3f7862a1a/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
+google.golang.org/genproto v0.0.0-20200513103714-09dca8ec2884/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
 google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 h1:+kGHl1aib/qcwaRi1CbqBZ1rk19r85MNUf8HaBghugY=
 google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo=
 google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
 google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38=
 google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=
 google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg=
-google.golang.org/grpc v1.24.0/go.mod h1:XDChyiUovWa60DnaeDeZmSW86xtLtjtZbwvSiRnRtcA=
 google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY=
 google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
+google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0=
 google.golang.org/grpc v1.37.1 h1:ARnQJNWxGyYJpdf/JXscNlQr/uv607ZPU9Z7ogHi+iI=
 google.golang.org/grpc v1.37.1/go.mod h1:NREThFqKR1f3iQ6oBuvc5LadQuXVGo9rkm5ZGrQdJfM=
 google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
diff --git a/route/errors.go b/route/errors.go
index 5e347ec..ff697d9 100644
--- a/route/errors.go
+++ b/route/errors.go
@@ -33,6 +33,7 @@ var (
 	ErrUpstreamUnavailable = handlerError{nil, "upstream target unavailable", http.StatusServiceUnavailable, true, true}
 	ErrReqToEvent          = handlerError{nil, "failed to parse event", http.StatusBadRequest, false, true}
 	ErrBatchToEvent        = handlerError{nil, "failed to parse event within batch", http.StatusBadRequest, false, true}
+	ErrInvalidContentType  = handlerError{nil, "invalid content-type - only 'application/protobuf' is supported", http.StatusNotImplemented, false, true}
 )
 
 func (r *Router) handlerReturnWithError(w http.ResponseWriter, he handlerError, err error) {
diff --git a/route/middleware.go b/route/middleware.go
index 8264bc7..7836433 100644
--- a/route/middleware.go
+++ b/route/middleware.go
@@ -45,7 +45,7 @@ func (r *Router) apiKeyChecker(next http.Handler) http.Handler {
 				return
 			}
 		}
-		err = errors.New(fmt.Sprintf("api key %s not found in list of authed keys", apiKey))
+		err = fmt.Errorf("api key %s not found in list of authed keys", apiKey)
 		r.handlerReturnWithError(w, ErrAuthNeeded, err)
 	})
 }
diff --git a/route/otlp_trace.go b/route/otlp_trace.go
new file mode 100644
index 0000000..dca390e
--- /dev/null
+++ b/route/otlp_trace.go
@@ -0,0 +1,404 @@
+package route
+
+import (
+	"bytes"
+	"compress/gzip"
+	"context"
+	"encoding/binary"
+	"encoding/hex"
+	"errors"
+	"fmt"
+	"io"
+	"io/ioutil"
+	"net/http"
+	"time"
+
+	"github.com/golang/protobuf/proto"
+	"github.com/honeycombio/refinery/types"
+	"github.com/klauspost/compress/zstd"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/metadata"
+	"google.golang.org/grpc/status"
+
+	collectortrace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/collector/trace/v1"
+	common "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/common/v1"
+	trace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/trace/v1"
+)
+
+func (router *Router) postOTLP(w http.ResponseWriter, req *http.Request) {
+	defer req.Body.Close()
+	contentType := req.Header.Get("content-type")
+	if contentType != "application/protobuf" && contentType != "application/x-protobuf" {
+		router.handlerReturnWithError(w, ErrInvalidContentType, errors.New("invalid content-type"))
+		return
+	}
+
+	apiKey, datasetName, err := getAPIKeyDatasetAndTokenFromHttpHeaders(req)
+	if err != nil {
+		router.handlerReturnWithError(w, ErrAuthNeeded, err)
+		return
+	}
+
+	request, cleanup, err := parseOTLPBody(req, router.zstdDecoders)
+	defer cleanup()
+	if err != nil {
+		router.handlerReturnWithError(w, ErrPostBody, err)
+	}
+
+	if err := processTraceRequest(req.Context(), router, request, apiKey, datasetName); err != nil {
+		router.handlerReturnWithError(w, ErrUpstreamFailed, err)
+	}
+}
+
+func (router *Router) Export(ctx context.Context, req *collectortrace.ExportTraceServiceRequest) (*collectortrace.ExportTraceServiceResponse, error) {
+	apiKey, datasetName, err := getAPIKeyDatasetAndTokenFromMetadata(ctx)
+	if err != nil {
+		return nil, status.Error(codes.Unauthenticated, err.Error())
+	}
+
+	if err := processTraceRequest(ctx, router, req, apiKey, datasetName); err != nil {
+		return nil, status.Error(codes.Internal, err.Error())
+	}
+
+	return &collectortrace.ExportTraceServiceResponse{}, nil
+}
+
+func processTraceRequest(
+	ctx context.Context,
+	router *Router,
+	request *collectortrace.ExportTraceServiceRequest,
+	apiKey string,
+	datasetName string) error {
+
+	var requestID types.RequestIDContextKey
+	debugLog := router.iopLogger.Debug().WithField("request_id", requestID)
+
+	apiHost, err := router.Config.GetHoneycombAPI()
+	if err != nil {
+		router.Logger.Error().Logf("Unable to retrieve APIHost from config while processing OTLP batch")
+		return err
+	}
+
+	for _, resourceSpan := range request.ResourceSpans {
+		resourceAttrs := make(map[string]interface{})
+
+		if resourceSpan.Resource != nil {
+			addAttributesToMap(resourceAttrs, resourceSpan.Resource.Attributes)
+		}
+
+		for _, librarySpan := range resourceSpan.InstrumentationLibrarySpans {
+			library := librarySpan.InstrumentationLibrary
+			if library != nil {
+				if len(library.Name) > 0 {
+					resourceAttrs["library.name"] = library.Name
+				}
+				if len(library.Version) > 0 {
+					resourceAttrs["library.version"] = library.Version
+				}
+			}
+
+			for _, span := range librarySpan.GetSpans() {
+				traceID := bytesToTraceID(span.TraceId)
+				spanID := hex.EncodeToString(span.SpanId)
+				timestamp := time.Unix(0, int64(span.StartTimeUnixNano)).UTC()
+
+				eventAttrs := map[string]interface{}{
+					"trace.trace_id": traceID,
+					"trace.span_id":  spanID,
+					"type":           getSpanKind(span.Kind),
+					"name":           span.Name,
+					"duration_ms":    float64(span.EndTimeUnixNano-span.StartTimeUnixNano) / float64(time.Millisecond),
+					"status_code":    int32(getSpanStatusCode(span.Status)),
+				}
+				if span.ParentSpanId != nil {
+					eventAttrs["trace.parent_id"] = hex.EncodeToString(span.ParentSpanId)
+				}
+				if getSpanStatusCode(span.Status) == trace.Status_STATUS_CODE_ERROR {
+					eventAttrs["error"] = true
+				}
+				if span.Status != nil && len(span.Status.Message) > 0 {
+					eventAttrs["status_message"] = span.Status.Message
+				}
+				if span.Attributes != nil {
+					addAttributesToMap(eventAttrs, span.Attributes)
+				}
+
+				sampleRate, err := getSampleRateFromAttributes(eventAttrs)
+				if err != nil {
+					debugLog.WithField("error", err.Error()).WithField("sampleRate", eventAttrs["sampleRate"]).Logf("error parsing sampleRate")
+				}
+
+				// copy resource attributes to event attributes
+				for k, v := range resourceAttrs {
+					eventAttrs[k] = v
+				}
+
+				events := make([]*types.Event, 0, 1+len(span.Events)+len(span.Links))
+				events = append(events, &types.Event{
+					Context:    ctx,
+					APIHost:    apiHost,
+					APIKey:     apiKey,
+					Dataset:    datasetName,
+					SampleRate: uint(sampleRate),
+					Timestamp:  timestamp,
+					Data:       eventAttrs,
+				})
+
+				for _, sevent := range span.Events {
+					timestamp := time.Unix(0, int64(sevent.TimeUnixNano)).UTC()
+					attrs := map[string]interface{}{
+						"trace.trace_id":       traceID,
+						"trace.parent_id":      spanID,
+						"name":                 sevent.Name,
+						"parent_name":          span.Name,
+						"meta.annotation_type": "span_event",
+					}
+
+					if sevent.Attributes != nil {
+						addAttributesToMap(attrs, sevent.Attributes)
+					}
+					for k, v := range resourceAttrs {
+						attrs[k] = v
+					}
+					sampleRate, err := getSampleRateFromAttributes(attrs)
+					if err != nil {
+						debugLog.
+							WithField("error", err.Error()).
+							WithField("sampleRate", attrs["sampleRate"]).
+							Logf("error parsing sampleRate")
+					}
+					events = append(events, &types.Event{
+						Context:    ctx,
+						APIHost:    apiHost,
+						APIKey:     apiKey,
+						Dataset:    datasetName,
+						SampleRate: uint(sampleRate),
+						Timestamp:  timestamp,
+						Data:       attrs,
+					})
+				}
+
+				for _, slink := range span.Links {
+					attrs := map[string]interface{}{
+						"trace.trace_id":       traceID,
+						"trace.parent_id":      spanID,
+						"trace.link.trace_id":  bytesToTraceID(slink.TraceId),
+						"trace.link.span_id":   hex.EncodeToString(slink.SpanId),
+						"parent_name":          span.Name,
+						"meta.annotation_type": "link",
+					}
+
+					if slink.Attributes != nil {
+						addAttributesToMap(attrs, slink.Attributes)
+					}
+					for k, v := range resourceAttrs {
+						attrs[k] = v
+					}
+					sampleRate, err := getSampleRateFromAttributes(attrs)
+					if err != nil {
+						debugLog.
+							WithField("error", err.Error()).
+							WithField("sampleRate", attrs["sampleRate"]).
+							Logf("error parsing sampleRate")
+					}
+					events = append(events, &types.Event{
+						Context:    ctx,
+						APIHost:    apiHost,
+						APIKey:     apiKey,
+						Dataset:    datasetName,
+						SampleRate: uint(sampleRate),
+						Timestamp:  time.Time{}, //links don't have timestamps, so use empty time
+						Data:       attrs,
+					})
+				}
+
+				for _, evt := range events {
+					err = router.processEvent(evt, requestID)
+					if err != nil {
+						router.Logger.Error().Logf("Error processing event: " + err.Error())
+					}
+				}
+
+			}
+		}
+	}
+
+	return nil
+}
+
+func addAttributesToMap(attrs map[string]interface{}, attributes []*common.KeyValue) {
+	for _, attr := range attributes {
+		if attr.Key == "" {
+			continue
+		}
+		switch attr.Value.Value.(type) {
+		case *common.AnyValue_StringValue:
+			attrs[attr.Key] = attr.Value.GetStringValue()
+		case *common.AnyValue_BoolValue:
+			attrs[attr.Key] = attr.Value.GetBoolValue()
+		case *common.AnyValue_DoubleValue:
+			attrs[attr.Key] = attr.Value.GetDoubleValue()
+		case *common.AnyValue_IntValue:
+			attrs[attr.Key] = attr.Value.GetIntValue()
+		}
+	}
+}
+
+func getSpanKind(kind trace.Span_SpanKind) string {
+	switch kind {
+	case trace.Span_SPAN_KIND_CLIENT:
+		return "client"
+	case trace.Span_SPAN_KIND_SERVER:
+		return "server"
+	case trace.Span_SPAN_KIND_PRODUCER:
+		return "producer"
+	case trace.Span_SPAN_KIND_CONSUMER:
+		return "consumer"
+	case trace.Span_SPAN_KIND_INTERNAL:
+		return "internal"
+	case trace.Span_SPAN_KIND_UNSPECIFIED:
+		fallthrough
+	default:
+		return "unspecified"
+	}
+}
+
+// bytesToTraceID returns an ID suitable for use for spans and traces. Before
+// encoding the bytes as a hex string, we want to handle cases where we are
+// given 128-bit IDs with zero padding, e.g. 0000000000000000f798a1e7f33c8af6.
+// To do this, we borrow a strategy from Jaeger [1] wherein we split the byte
+// sequence into two parts. The leftmost part could contain all zeros. We use
+// that to determine whether to return a 64-bit hex encoded string or a 128-bit
+// one.
+//
+// [1]: https://github.com/jaegertracing/jaeger/blob/cd19b64413eca0f06b61d92fe29bebce1321d0b0/model/ids.go#L81
+func bytesToTraceID(traceID []byte) string {
+	// binary.BigEndian.Uint64() does a bounds check on traceID which will
+	// cause a panic if traceID is fewer than 8 bytes. In this case, we don't
+	// need to check for zero padding on the high part anyway, so just return a
+	// hex string.
+	if len(traceID) < traceIDShortLength {
+		return fmt.Sprintf("%x", traceID)
+	}
+	var low uint64
+	if len(traceID) == traceIDLongLength {
+		low = binary.BigEndian.Uint64(traceID[traceIDShortLength:])
+		if high := binary.BigEndian.Uint64(traceID[:traceIDShortLength]); high != 0 {
+			return fmt.Sprintf("%016x%016x", high, low)
+		}
+	} else {
+		low = binary.BigEndian.Uint64(traceID)
+	}
+
+	return fmt.Sprintf("%016x", low)
+}
+
+// getSpanStatusCode checks the value of both the deprecated code and code fields
+// on the span status and using the rules specified in the backward compatibility
+// notes in the protobuf definitions. See:
+//
+// https://github.com/open-telemetry/opentelemetry-proto/blob/59c488bfb8fb6d0458ad6425758b70259ff4a2bd/opentelemetry/proto/trace/v1/trace.proto#L230
+func getSpanStatusCode(status *trace.Status) trace.Status_StatusCode {
+	if status == nil {
+		return trace.Status_STATUS_CODE_UNSET
+	}
+	if status.Code == trace.Status_STATUS_CODE_UNSET {
+		if status.DeprecatedCode == trace.Status_DEPRECATED_STATUS_CODE_OK {
+			return trace.Status_STATUS_CODE_UNSET
+		}
+		return trace.Status_STATUS_CODE_ERROR
+	}
+	return status.Code
+}
+
+func getAPIKeyDatasetAndTokenFromMetadata(ctx context.Context) (
+	apiKey string,
+	datasetName string,
+	err error) {
+	if md, ok := metadata.FromIncomingContext(ctx); ok {
+		apiKey = getValueFromMetadata(md, "x-honeycomb-team")
+		datasetName = getValueFromMetadata(md, "x-honeycomb-dataset")
+	}
+
+	if err := validateHeaders(apiKey, datasetName); err != nil {
+		return "", "", err
+	}
+	return apiKey, datasetName, nil
+}
+
+func getValueFromMetadata(md metadata.MD, key string) string {
+	if vals := md.Get(key); len(vals) > 0 {
+		return vals[0]
+	}
+	return ""
+}
+
+func getAPIKeyDatasetAndTokenFromHttpHeaders(r *http.Request) (
+	apiKey string,
+	datasetName string,
+	err error) {
+	apiKey = r.Header.Get("x-honeycomb-team")
+	datasetName = r.Header.Get("x-honeycomb-dataset")
+
+	if err := validateHeaders(apiKey, datasetName); err != nil {
+		return "", "", err
+	}
+	return apiKey, datasetName, nil
+}
+
+func validateHeaders(apiKey string, datasetName string) error {
+	if apiKey == "" {
+		return errors.New("missing x-honeycomb-team header")
+	}
+	if datasetName == "" {
+		return errors.New("missing x-honeycomb-team header")
+	}
+	return nil
+}
+
+func parseOTLPBody(r *http.Request, zstdDecoders chan *zstd.Decoder) (request *collectortrace.ExportTraceServiceRequest, cleanup func(), err error) {
+	cleanup = func() { /* empty cleanup */ }
+	bodyBytes, err := ioutil.ReadAll(r.Body)
+	if err != nil {
+		return nil, cleanup, err
+	}
+	bodyReader := bytes.NewReader(bodyBytes)
+
+	var reader io.Reader
+	switch r.Header.Get("Content-Encoding") {
+	case "gzip":
+		var err error
+		reader, err = gzip.NewReader(bodyReader)
+		if err != nil {
+			return nil, cleanup, err
+		}
+	case "zstd":
+		zReader := <-zstdDecoders
+		cleanup = func() {
+			zReader.Reset(nil)
+			zstdDecoders <- zReader
+		}
+
+		err = zReader.Reset(bodyReader)
+		if err != nil {
+			return nil, cleanup, err
+		}
+
+		reader = zReader
+	default:
+		reader = bodyReader
+	}
+
+	bytes, err := ioutil.ReadAll(reader)
+	if err != nil {
+		return nil, cleanup, err
+	}
+
+	otlpRequet := &collectortrace.ExportTraceServiceRequest{}
+	err = proto.Unmarshal(bytes, otlpRequet)
+	if err != nil {
+		return nil, cleanup, err
+	}
+
+	return otlpRequet, cleanup, nil
+}
diff --git a/route/route.go b/route/route.go
index 05630cc..6597318 100644
--- a/route/route.go
+++ b/route/route.go
@@ -4,8 +4,6 @@ import (
 	"bytes"
 	"compress/gzip"
 	"context"
-	"encoding/binary"
-	"encoding/hex"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -15,7 +13,6 @@ import (
 	"net"
 	"net/http"
 	"strconv"
-	"strings"
 	"sync"
 	"time"
 
@@ -39,8 +36,6 @@ import (
 	"github.com/honeycombio/refinery/types"
 
 	collectortrace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/collector/trace/v1"
-	common "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/common/v1"
-	trace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/trace/v1"
 )
 
 const (
@@ -161,6 +156,13 @@ func (r *Router) LnS(incomingOrPeer string) {
 	authedMuxxer.HandleFunc("/events/{datasetName}", r.event).Name("event")
 	authedMuxxer.HandleFunc("/batch/{datasetName}", r.batch).Name("batch")
 
+	// require an auth header for OTLP requests
+	otlpMuxxer := muxxer.PathPrefix("/v1/").Methods("POST").Subrouter()
+	otlpMuxxer.Use(r.apiKeyChecker)
+
+	// handle OTLP trace requests
+	otlpMuxxer.HandleFunc("/traces", r.postOTLP).Name("otlp")
+
 	// pass everything else through unmolested
 	muxxer.PathPrefix("/").HandlerFunc(r.proxy).Name("proxy")
 
@@ -386,118 +388,6 @@ func (r *Router) batch(w http.ResponseWriter, req *http.Request) {
 	w.Write(response)
 }
 
-func (r *Router) Export(ctx context.Context, req *collectortrace.ExportTraceServiceRequest) (*collectortrace.ExportTraceServiceResponse, error) {
-
-	md, ok := metadata.FromIncomingContext(ctx)
-	if !ok {
-		r.Logger.Error().Logf("Unable to retreive metadata from OTLP request.")
-		return &collectortrace.ExportTraceServiceResponse{}, nil
-	}
-
-	// requestID is used to track a requst as it moves between refinery nodes (peers)
-	// the OTLP handler only receives incoming (not peer) requests for now so will be empty here
-	var requestID types.RequestIDContextKey
-	debugLog := r.iopLogger.Debug().WithField("request_id", requestID)
-
-	apiKey, dataset := getAPIKeyAndDatasetFromMetadata(md)
-	if apiKey == "" {
-		r.Logger.Error().Logf("Received OTLP request without Honeycomb APIKey header")
-		return &collectortrace.ExportTraceServiceResponse{}, nil
-	}
-	if dataset == "" {
-		r.Logger.Error().Logf("Received OTLP request without Honeycomb dataset header")
-		return &collectortrace.ExportTraceServiceResponse{}, nil
-	}
-
-	apiHost, err := r.Config.GetHoneycombAPI()
-	if err != nil {
-		r.Logger.Error().Logf("Unable to retrieve APIHost from config while processing OTLP batch")
-		return &collectortrace.ExportTraceServiceResponse{}, nil
-	}
-
-	var grpcRequestEncoding string
-	if val := md.Get("grpc-accept-encoding"); val != nil {
-		grpcRequestEncoding = strings.Join(val, ",")
-	}
-
-	for _, resourceSpan := range req.ResourceSpans {
-		resourceAttrs := make(map[string]interface{})
-
-		if resourceSpan.Resource != nil {
-			addAttributesToMap(resourceAttrs, resourceSpan.Resource.Attributes)
-		}
-
-		for _, librarySpan := range resourceSpan.InstrumentationLibrarySpans {
-			library := librarySpan.InstrumentationLibrary
-			if library != nil {
-				if len(library.Name) > 0 {
-					resourceAttrs["library.name"] = library.Name
-				}
-				if len(library.Version) > 0 {
-					resourceAttrs["library.version"] = library.Version
-				}
-			}
-
-			for _, span := range librarySpan.GetSpans() {
-				traceID := bytesToTraceID(span.TraceId)
-				spanID := hex.EncodeToString(span.SpanId)
-				timestamp := time.Unix(0, int64(span.StartTimeUnixNano)).UTC()
-
-				eventAttrs := map[string]interface{}{
-					"trace.trace_id": traceID,
-					"trace.span_id":  spanID,
-					"type":           getSpanKind(span.Kind),
-					"name":           span.Name,
-					"duration_ms":    float64(span.EndTimeUnixNano-span.StartTimeUnixNano) / float64(time.Millisecond),
-					"status_code":    int32(r.getSpanStatusCode(span.Status)),
-				}
-				if span.ParentSpanId != nil {
-					eventAttrs["trace.parent_id"] = hex.EncodeToString(span.ParentSpanId)
-				}
-				if r.getSpanStatusCode(span.Status) == trace.Status_STATUS_CODE_ERROR {
-					eventAttrs["error"] = true
-				}
-				if span.Status != nil && len(span.Status.Message) > 0 {
-					eventAttrs["status_message"] = span.Status.Message
-				}
-				if span.Attributes != nil {
-					addAttributesToMap(eventAttrs, span.Attributes)
-				}
-				if grpcRequestEncoding != "" {
-					eventAttrs["grpc_request_encoding"] = grpcRequestEncoding
-				}
-
-				sampleRate, err := getSampleRateFromAttributes(eventAttrs)
-				if err != nil {
-					debugLog.WithField("error", err.Error()).WithField("sampleRate", eventAttrs["sampleRate"]).Logf("error parsing sampleRate")
-				}
-
-				// copy resource attributes to event attributes
-				for k, v := range resourceAttrs {
-					eventAttrs[k] = v
-				}
-
-				event := &types.Event{
-					Context:    ctx,
-					APIHost:    apiHost,
-					APIKey:     apiKey,
-					Dataset:    dataset,
-					SampleRate: uint(sampleRate),
-					Timestamp:  timestamp,
-					Data:       eventAttrs,
-				}
-
-				err = r.processEvent(event, requestID)
-				if err != nil {
-					r.Logger.Error().Logf("Error processing event: " + err.Error())
-				}
-			}
-		}
-	}
-
-	return &collectortrace.ExportTraceServiceResponse{}, nil
-}
-
 func (r *Router) processEvent(ev *types.Event, reqID interface{}) error {
 	debugLog := r.iopLogger.Debug().
 		WithField("request_id", reqID).
@@ -734,91 +624,6 @@ func getFirstValueFromMetadata(key string, md metadata.MD) string {
 	return ""
 }
 
-func addAttributesToMap(attrs map[string]interface{}, attributes []*common.KeyValue) {
-	for _, attr := range attributes {
-		if attr.Key == "" {
-			continue
-		}
-		switch attr.Value.Value.(type) {
-		case *common.AnyValue_StringValue:
-			attrs[attr.Key] = attr.Value.GetStringValue()
-		case *common.AnyValue_BoolValue:
-			attrs[attr.Key] = attr.Value.GetBoolValue()
-		case *common.AnyValue_DoubleValue:
-			attrs[attr.Key] = attr.Value.GetDoubleValue()
-		case *common.AnyValue_IntValue:
-			attrs[attr.Key] = attr.Value.GetIntValue()
-		}
-	}
-}
-
-func getSpanKind(kind trace.Span_SpanKind) string {
-	switch kind {
-	case trace.Span_SPAN_KIND_CLIENT:
-		return "client"
-	case trace.Span_SPAN_KIND_SERVER:
-		return "server"
-	case trace.Span_SPAN_KIND_PRODUCER:
-		return "producer"
-	case trace.Span_SPAN_KIND_CONSUMER:
-		return "consumer"
-	case trace.Span_SPAN_KIND_INTERNAL:
-		return "internal"
-	case trace.Span_SPAN_KIND_UNSPECIFIED:
-		fallthrough
-	default:
-		return "unspecified"
-	}
-}
-
-// bytesToTraceID returns an ID suitable for use for spans and traces. Before
-// encoding the bytes as a hex string, we want to handle cases where we are
-// given 128-bit IDs with zero padding, e.g. 0000000000000000f798a1e7f33c8af6.
-// To do this, we borrow a strategy from Jaeger [1] wherein we split the byte
-// sequence into two parts. The leftmost part could contain all zeros. We use
-// that to determine whether to return a 64-bit hex encoded string or a 128-bit
-// one.
-//
-// [1]: https://github.com/jaegertracing/jaeger/blob/cd19b64413eca0f06b61d92fe29bebce1321d0b0/model/ids.go#L81
-func bytesToTraceID(traceID []byte) string {
-	// binary.BigEndian.Uint64() does a bounds check on traceID which will
-	// cause a panic if traceID is fewer than 8 bytes. In this case, we don't
-	// need to check for zero padding on the high part anyway, so just return a
-	// hex string.
-	if len(traceID) < traceIDShortLength {
-		return fmt.Sprintf("%x", traceID)
-	}
-	var low uint64
-	if len(traceID) == traceIDLongLength {
-		low = binary.BigEndian.Uint64(traceID[traceIDShortLength:])
-		if high := binary.BigEndian.Uint64(traceID[:traceIDShortLength]); high != 0 {
-			return fmt.Sprintf("%016x%016x", high, low)
-		}
-	} else {
-		low = binary.BigEndian.Uint64(traceID)
-	}
-
-	return fmt.Sprintf("%016x", low)
-}
-
-// getSpanStatusCode checks the value of both the deprecated code and code fields
-// on the span status and using the rules specified in the backward compatibility
-// notes in the protobuf definitions. See:
-//
-// https://github.com/open-telemetry/opentelemetry-proto/blob/59c488bfb8fb6d0458ad6425758b70259ff4a2bd/opentelemetry/proto/trace/v1/trace.proto#L230
-func (r *Router) getSpanStatusCode(status *trace.Status) trace.Status_StatusCode {
-	if status == nil {
-		return trace.Status_STATUS_CODE_UNSET
-	}
-	if status.Code == trace.Status_STATUS_CODE_UNSET {
-		if status.DeprecatedCode == trace.Status_DEPRECATED_STATUS_CODE_OK {
-			return trace.Status_STATUS_CODE_UNSET
-		}
-		return trace.Status_STATUS_CODE_ERROR
-	}
-	return status.Code
-}
-
 func getSampleRateFromAttributes(attrs map[string]interface{}) (int, error) {
 	var sampleRateKey string
 	if attrs["sampleRate"] != nil {
@@ -851,7 +656,7 @@ func getSampleRateFromAttributes(attrs map[string]interface{}) (int, error) {
 			sampleRate = int(v)
 		}
 	default:
-		err = fmt.Errorf("Unrecognised sampleRate datatype - %T", sampleRate)
+		err = fmt.Errorf("unrecognised sampleRate datatype - %T", sampleRate)
 		sampleRate = defaultSampleRate
 	}
 	// remove sampleRate from event fields
diff --git a/sample/rules.go b/sample/rules.go
index da9d997..4f035c3 100644
--- a/sample/rules.go
+++ b/sample/rules.go
@@ -104,6 +104,14 @@ func (s *RulesBasedSampler) GetSampleRate(trace *types.Trace) (rate uint, keep b
 								match = strings.Contains(a, b)
 							}
 						}
+					case "does-not-contain":
+						switch a := value.(type) {
+						case string:
+							switch b := condition.Value.(type) {
+							case string:
+								match = !strings.Contains(a, b)
+							}
+						}
 					}
 				case false:
 					switch condition.Operator {
diff --git a/transmit/transmit.go b/transmit/transmit.go
index fc6d7d1..fa46711 100644
--- a/transmit/transmit.go
+++ b/transmit/transmit.go
@@ -23,10 +23,9 @@ type Transmission interface {
 }
 
 const (
-	counterEnqueueErrors      = "enqueue_errors"
-	counterResponse20x        = "response_20x"
-	counterResponseErrorsAPI  = "response_errors_api"
-	counterResponseErrorsPeer = "response_errors_peer"
+	counterEnqueueErrors  = "enqueue_errors"
+	counterResponse20x    = "response_20x"
+	counterResponseErrors = "response_errors"
 )
 
 type DefaultTransmission struct {
@@ -72,8 +71,7 @@ func (d *DefaultTransmission) Start() error {
 
 	d.Metrics.Register(d.Name+counterEnqueueErrors, "counter")
 	d.Metrics.Register(d.Name+counterResponse20x, "counter")
-	d.Metrics.Register(d.Name+counterResponseErrorsAPI, "counter")
-	d.Metrics.Register(d.Name+counterResponseErrorsPeer, "counter")
+	d.Metrics.Register(d.Name+counterResponseErrors, "counter")
 
 	processCtx, canceler := context.WithCancel(context.Background())
 	d.responseCanceler = canceler
@@ -147,7 +145,6 @@ func (d *DefaultTransmission) processResponses(
 	ctx context.Context,
 	responses chan transmission.Response,
 ) {
-	honeycombAPI, _ := d.Config.GetHoneycombAPI()
 	for {
 		select {
 		case r := <-responses:
@@ -170,14 +167,7 @@ func (d *DefaultTransmission) processResponses(
 					log = log.WithField("error", r.Err.Error())
 				}
 				log.Logf("error when sending event")
-				if honeycombAPI == apiHost {
-					// if the API host matches the configured honeycomb API,
-					// count it as an API error
-					d.Metrics.Increment(d.Name + counterResponseErrorsAPI)
-				} else {
-					// otherwise, it's probably a peer error
-					d.Metrics.Increment(d.Name + counterResponseErrorsPeer)
-				}
+				d.Metrics.Increment(d.Name + counterResponseErrors)
 			} else {
 				d.Metrics.Increment(d.Name + counterResponse20x)
 			}


Test patch:
diff --git a/route/otlp_trace_test.go b/route/otlp_trace_test.go
new file mode 100644
index 0000000..2354b29
--- /dev/null
+++ b/route/otlp_trace_test.go
@@ -0,0 +1,348 @@
+package route
+
+import (
+	"bytes"
+	"compress/gzip"
+	"context"
+	"encoding/hex"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"testing"
+	"time"
+
+	"github.com/golang/protobuf/proto"
+	"github.com/honeycombio/refinery/config"
+	collectortrace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/collector/trace/v1"
+	common "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/common/v1"
+	trace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/trace/v1"
+	"github.com/honeycombio/refinery/logger"
+	"github.com/honeycombio/refinery/metrics"
+	"github.com/honeycombio/refinery/transmit"
+	"github.com/klauspost/compress/zstd"
+	"github.com/stretchr/testify/assert"
+	"google.golang.org/grpc/metadata"
+)
+
+func TestOTLPHandler(t *testing.T) {
+	md := metadata.New(map[string]string{"x-honeycomb-team": "meow", "x-honeycomb-dataset": "ds"})
+	ctx := metadata.NewIncomingContext(context.Background(), md)
+
+	mockMetrics := metrics.MockMetrics{}
+	mockMetrics.Start()
+	mockTransmission := &transmit.MockTransmission{}
+	mockTransmission.Start()
+	decoders, err := makeDecoders(1)
+	if err != nil {
+		t.Error(err)
+	}
+	router := &Router{
+		Config:               &config.MockConfig{},
+		Metrics:              &mockMetrics,
+		UpstreamTransmission: mockTransmission,
+		iopLogger: iopLogger{
+			Logger:         &logger.MockLogger{},
+			incomingOrPeer: "incoming",
+		},
+		Logger:       &logger.MockLogger{},
+		zstdDecoders: decoders,
+	}
+
+	conf := &config.MockConfig{
+		GetSendDelayVal:    0,
+		GetTraceTimeoutVal: 60 * time.Second,
+		GetSamplerTypeVal:  &config.DeterministicSamplerConfig{SampleRate: 1},
+		SendTickerVal:      2 * time.Millisecond,
+		GetInMemoryCollectorCacheCapacityVal: config.InMemoryCollectorCacheCapacity{
+			CacheCapacity: 100,
+			MaxAlloc:      100,
+		},
+	}
+
+	t.Run("span with status", func(t *testing.T) {
+		req := &collectortrace.ExportTraceServiceRequest{
+			ResourceSpans: []*trace.ResourceSpans{{
+				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
+					Spans: helperOTLPRequestSpansWithStatus(),
+				}},
+			}},
+		}
+		_, err := router.Export(ctx, req)
+		if err != nil {
+			t.Errorf(`Unexpected error: %s`, err)
+		}
+		assert.Equal(t, 2, len(mockTransmission.Events))
+		mockTransmission.Flush()
+	})
+
+	t.Run("span without status", func(t *testing.T) {
+		req := &collectortrace.ExportTraceServiceRequest{
+			ResourceSpans: []*trace.ResourceSpans{{
+				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
+					Spans: helperOTLPRequestSpansWithoutStatus(),
+				}},
+			}},
+		}
+		_, err := router.Export(ctx, req)
+		if err != nil {
+			t.Errorf(`Unexpected error: %s`, err)
+		}
+		assert.Equal(t, 2, len(mockTransmission.Events))
+		mockTransmission.Flush()
+	})
+
+	// TODO: (MG) figuure out how we can test JSON created from OTLP requests
+	// Below is example, but requires significant usage of collector, sampler, conf, etc
+	t.Run("creates events for span events", func(t *testing.T) {
+		t.Skip("need additional work to support inspecting outbound JSON")
+
+		traceID := []byte{0, 0, 0, 0, 1}
+		spanID := []byte{1, 0, 0, 0, 0}
+		req := &collectortrace.ExportTraceServiceRequest{
+			ResourceSpans: []*trace.ResourceSpans{{
+				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
+					Spans: []*trace.Span{{
+						TraceId: traceID,
+						SpanId:  spanID,
+						Name:    "span_with_event",
+						Events: []*trace.Span_Event{{
+							TimeUnixNano: 12345,
+							Name:         "span_link",
+							Attributes: []*common.KeyValue{{
+								Key: "event_attr_key", Value: &common.AnyValue{Value: &common.AnyValue_StringValue{StringValue: "event_attr_val"}},
+							}},
+						}},
+					}},
+				}},
+			}},
+		}
+		_, err := router.Export(ctx, req)
+		if err != nil {
+			t.Errorf(`Unexpected error: %s`, err)
+		}
+
+		time.Sleep(conf.SendTickerVal * 2)
+
+		mockTransmission.Mux.Lock()
+		assert.Equal(t, 2, len(mockTransmission.Events))
+
+		spanEvent := mockTransmission.Events[0]
+		// assert.Equal(t, time.Unix(0, int64(12345)).UTC(), spanEvent.Timestamp)
+		assert.Equal(t, bytesToTraceID(traceID), spanEvent.Data["trace.trace_id"])
+		assert.Equal(t, hex.EncodeToString(spanID), spanEvent.Data["trace.span_id"])
+		assert.Equal(t, "span_link", spanEvent.Data["span.name"])
+		assert.Equal(t, "span_with_event", spanEvent.Data["parent.name"])
+		assert.Equal(t, "span_event", spanEvent.Data["meta.annotation_type"])
+		assert.Equal(t, "event_attr_key", spanEvent.Data["event_attr_val"])
+		mockTransmission.Mux.Unlock()
+		mockTransmission.Flush()
+	})
+
+	t.Run("creates events for span links", func(t *testing.T) {
+		t.Skip("need additional work to support inspecting outbound JSON")
+
+		traceID := []byte{0, 0, 0, 0, 1}
+		spanID := []byte{1, 0, 0, 0, 0}
+		linkTraceID := []byte{0, 0, 0, 0, 2}
+		linkSpanID := []byte{2, 0, 0, 0, 0}
+
+		req := &collectortrace.ExportTraceServiceRequest{
+			ResourceSpans: []*trace.ResourceSpans{{
+				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
+					Spans: []*trace.Span{{
+						Name:    "span_with_link",
+						TraceId: traceID,
+						SpanId:  spanID,
+						Links: []*trace.Span_Link{{
+							TraceId:    traceID,
+							SpanId:     spanID,
+							TraceState: "link_trace_state",
+							Attributes: []*common.KeyValue{{
+								Key: "link_attr_key", Value: &common.AnyValue{Value: &common.AnyValue_StringValue{StringValue: "link_attr_val"}},
+							}},
+						}},
+					}},
+				}},
+			}},
+		}
+		_, err := router.Export(ctx, req)
+		if err != nil {
+			t.Errorf(`Unexpected error: %s`, err)
+		}
+
+		time.Sleep(conf.SendTickerVal * 2)
+		assert.Equal(t, 2, len(mockTransmission.Events))
+
+		spanLink := mockTransmission.Events[1]
+		assert.Equal(t, bytesToTraceID(traceID), spanLink.Data["trace.trace_id"])
+		assert.Equal(t, hex.EncodeToString(spanID), spanLink.Data["trace.span_id"])
+		assert.Equal(t, bytesToTraceID(linkTraceID), spanLink.Data["trace.link.trace_id"])
+		assert.Equal(t, hex.EncodeToString(linkSpanID), spanLink.Data["trace.link.span_id"])
+		assert.Equal(t, "link", spanLink.Data["meta.annotation_type"])
+		assert.Equal(t, "link_attr_val", spanLink.Data["link_attr_key"])
+		mockTransmission.Flush()
+	})
+
+	t.Run("can receive OTLP over HTTP/protobuf", func(t *testing.T) {
+		req := &collectortrace.ExportTraceServiceRequest{
+			ResourceSpans: []*trace.ResourceSpans{{
+				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
+					Spans: helperOTLPRequestSpansWithStatus(),
+				}},
+			}},
+		}
+		body, err := proto.Marshal(req)
+		if err != nil {
+			t.Error(err)
+		}
+
+		request, _ := http.NewRequest("POST", "/v1/traces", strings.NewReader(string(body)))
+		request.Header = http.Header{}
+		request.Header.Set("content-type", "application/protobuf")
+		request.Header.Set("x-honeycomb-team", "apikey")
+		request.Header.Set("x-honeycomb-dataset", "dataset")
+
+		w := httptest.NewRecorder()
+		router.postOTLP(w, request)
+		assert.Equal(t, w.Code, http.StatusOK)
+
+		assert.Equal(t, 2, len(mockTransmission.Events))
+		mockTransmission.Flush()
+	})
+
+	t.Run("can receive OTLP over HTTP/protobuf with gzip encoding", func(t *testing.T) {
+		req := &collectortrace.ExportTraceServiceRequest{
+			ResourceSpans: []*trace.ResourceSpans{{
+				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
+					Spans: helperOTLPRequestSpansWithStatus(),
+				}},
+			}},
+		}
+		body, err := proto.Marshal(req)
+		if err != nil {
+			t.Error(err)
+		}
+
+		buf := new(bytes.Buffer)
+		writer := gzip.NewWriter(buf)
+		writer.Write(body)
+		writer.Close()
+		if err != nil {
+			t.Error(err)
+		}
+
+		request, _ := http.NewRequest("POST", "/v1/traces", strings.NewReader(buf.String()))
+		request.Header = http.Header{}
+		request.Header.Set("content-type", "application/protobuf")
+		request.Header.Set("content-encoding", "gzip")
+		request.Header.Set("x-honeycomb-team", "apikey")
+		request.Header.Set("x-honeycomb-dataset", "dataset")
+
+		w := httptest.NewRecorder()
+		router.postOTLP(w, request)
+		assert.Equal(t, w.Code, http.StatusOK)
+
+		assert.Equal(t, 2, len(mockTransmission.Events))
+		mockTransmission.Flush()
+	})
+
+	t.Run("can receive OTLP over HTTP/protobuf with zstd encoding", func(t *testing.T) {
+		req := &collectortrace.ExportTraceServiceRequest{
+			ResourceSpans: []*trace.ResourceSpans{{
+				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
+					Spans: helperOTLPRequestSpansWithStatus(),
+				}},
+			}},
+		}
+		body, err := proto.Marshal(req)
+		if err != nil {
+			t.Error(err)
+		}
+
+		buf := new(bytes.Buffer)
+		writer, err := zstd.NewWriter(buf)
+		if err != nil {
+			t.Error(err)
+		}
+		writer.Write(body)
+		writer.Close()
+		if err != nil {
+			t.Error(err)
+		}
+
+		request, _ := http.NewRequest("POST", "/v1/traces", strings.NewReader(buf.String()))
+		request.Header = http.Header{}
+		request.Header.Set("content-type", "application/protobuf")
+		request.Header.Set("content-encoding", "zstd")
+		request.Header.Set("x-honeycomb-team", "apikey")
+		request.Header.Set("x-honeycomb-dataset", "dataset")
+
+		w := httptest.NewRecorder()
+		router.postOTLP(w, request)
+		assert.Equal(t, w.Code, http.StatusOK)
+
+		assert.Equal(t, 2, len(mockTransmission.Events))
+		mockTransmission.Flush()
+	})
+
+	t.Run("rejects OTLP over HTTP/JSON ", func(t *testing.T) {
+		request, _ := http.NewRequest("POST", "/v1/traces", strings.NewReader("{}"))
+		request.Header = http.Header{}
+		request.Header.Set("content-type", "application/json")
+		request.Header.Set("x-honeycomb-team", "apikey")
+		request.Header.Set("x-honeycomb-dataset", "dataset")
+
+		w := httptest.NewRecorder()
+		router.postOTLP(w, request)
+		assert.Equal(t, w.Code, http.StatusNotImplemented)
+		assert.Equal(t, `{"source":"refinery","error":"invalid content-type - only 'application/protobuf' is supported"}`, string(w.Body.String()))
+
+		assert.Equal(t, 0, len(mockTransmission.Events))
+		mockTransmission.Flush()
+	})
+}
+
+func helperOTLPRequestSpansWithoutStatus() []*trace.Span {
+	now := time.Now()
+	return []*trace.Span{
+		{
+			StartTimeUnixNano: uint64(now.UnixNano()),
+			Events: []*trace.Span_Event{
+				{
+					TimeUnixNano: uint64(now.UnixNano()),
+					Attributes: []*common.KeyValue{
+						{
+							Key: "attribute_key",
+							Value: &common.AnyValue{
+								Value: &common.AnyValue_StringValue{StringValue: "attribute_value"},
+							},
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
+func helperOTLPRequestSpansWithStatus() []*trace.Span {
+	now := time.Now()
+	return []*trace.Span{
+		{
+			StartTimeUnixNano: uint64(now.UnixNano()),
+			Events: []*trace.Span_Event{
+				{
+					TimeUnixNano: uint64(now.UnixNano()),
+					Attributes: []*common.KeyValue{
+						{
+							Key: "attribute_key",
+							Value: &common.AnyValue{
+								Value: &common.AnyValue_StringValue{StringValue: "attribute_value"},
+							},
+						},
+					},
+				},
+			},
+			Status: &trace.Status{Code: trace.Status_STATUS_CODE_OK},
+		},
+	}
+}
diff --git a/route/route_test.go b/route/route_test.go
index 8cb5beb..2080396 100644
--- a/route/route_test.go
+++ b/route/route_test.go
@@ -1,11 +1,8 @@
-// +build all race
-
 package route
 
 import (
 	"bytes"
 	"compress/gzip"
-	"context"
 	"fmt"
 	"io"
 	"io/ioutil"
@@ -19,9 +16,6 @@ import (
 	"github.com/facebookgo/inject"
 	"github.com/honeycombio/refinery/collect"
 	"github.com/honeycombio/refinery/config"
-	collectortrace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/collector/trace/v1"
-	common "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/common/v1"
-	trace "github.com/honeycombio/refinery/internal/opentelemetry-proto-gen/trace/v1"
 	"github.com/honeycombio/refinery/logger"
 	"github.com/honeycombio/refinery/metrics"
 	"github.com/honeycombio/refinery/transmit"
@@ -399,51 +393,6 @@ func TestDebugTrace(t *testing.T) {
 	}
 }
 
-func TestOTLPHandler(t *testing.T) {
-	md := metadata.New(map[string]string{"x-honeycomb-team": "meow", "x-honeycomb-dataset": "ds"})
-	ctx := metadata.NewIncomingContext(context.Background(), md)
-
-	mockMetrics := metrics.MockMetrics{}
-	mockMetrics.Start()
-	router := &Router{
-		Config:               &config.MockConfig{},
-		Metrics:              &mockMetrics,
-		UpstreamTransmission: &transmit.MockTransmission{},
-		iopLogger: iopLogger{
-			Logger:         &logger.MockLogger{},
-			incomingOrPeer: "incoming",
-		},
-	}
-
-	t.Run("span with status", func(t *testing.T) {
-		req := &collectortrace.ExportTraceServiceRequest{
-			ResourceSpans: []*trace.ResourceSpans{{
-				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
-					Spans: helperOTLPRequestSpansWithStatus(),
-				}},
-			}},
-		}
-		_, err := router.Export(ctx, req)
-		if err != nil {
-			t.Errorf(`Unexpected error: %s`, err)
-		}
-	})
-
-	t.Run("span without status", func(t *testing.T) {
-		req := &collectortrace.ExportTraceServiceRequest{
-			ResourceSpans: []*trace.ResourceSpans{{
-				InstrumentationLibrarySpans: []*trace.InstrumentationLibrarySpans{{
-					Spans: helperOTLPRequestSpansWithoutStatus(),
-				}},
-			}},
-		}
-		_, err := router.Export(ctx, req)
-		if err != nil {
-			t.Errorf(`Unexpected error: %s`, err)
-		}
-	})
-}
-
 func TestDependencyInjection(t *testing.T) {
 	var g inject.Graph
 	err := g.Provide(
@@ -466,51 +415,6 @@ func TestDependencyInjection(t *testing.T) {
 	}
 }
 
-func helperOTLPRequestSpansWithoutStatus() []*trace.Span {
-	now := time.Now()
-	return []*trace.Span{
-		{
-			StartTimeUnixNano: uint64(now.UnixNano()),
-			Events: []*trace.Span_Event{
-				{
-					TimeUnixNano: uint64(now.UnixNano()),
-					Attributes: []*common.KeyValue{
-						{
-							Key: "attribute_key",
-							Value: &common.AnyValue{
-								Value: &common.AnyValue_StringValue{StringValue: "attribute_value"},
-							},
-						},
-					},
-				},
-			},
-		},
-	}
-}
-
-func helperOTLPRequestSpansWithStatus() []*trace.Span {
-	now := time.Now()
-	return []*trace.Span{
-		{
-			StartTimeUnixNano: uint64(now.UnixNano()),
-			Events: []*trace.Span_Event{
-				{
-					TimeUnixNano: uint64(now.UnixNano()),
-					Attributes: []*common.KeyValue{
-						{
-							Key: "attribute_key",
-							Value: &common.AnyValue{
-								Value: &common.AnyValue_StringValue{StringValue: "attribute_value"},
-							},
-						},
-					},
-				},
-			},
-			Status: &trace.Status{Code: trace.Status_STATUS_CODE_OK},
-		},
-	}
-}
-
 type TestSharder struct{}
 
 func (s *TestSharder) MyShard() sharder.Shard { return nil }
diff --git a/sample/rules_test.go b/sample/rules_test.go
index 7add1ae..2965c70 100644
--- a/sample/rules_test.go
+++ b/sample/rules_test.go
@@ -439,6 +439,34 @@ func TestRules(t *testing.T) {
 			ExpectedKeep: true,
 			ExpectedRate: 4,
 		},
+		{
+			Rules: &config.RulesBasedSamplerConfig{
+				Rule: []*config.RulesBasedSamplerRule{
+					{
+						Name:       "does not contain test",
+						SampleRate: 4,
+						Condition: []*config.RulesBasedSamplerCondition{
+							{
+								Field:    "first",
+								Operator: "does-not-contain",
+								Value:    "noteyco",
+							},
+						},
+					},
+				},
+			},
+			Spans: []*types.Span{
+				{
+					Event: types.Event{
+						Data: map[string]interface{}{
+							"first": "honeycomb",
+						},
+					},
+				},
+			},
+			ExpectedKeep: true,
+			ExpectedRate: 4,
+		},
 		{
 			Rules: &config.RulesBasedSamplerConfig{
 				Rule: []*config.RulesBasedSamplerRule{