Skip to content
GitLab
Menu
Projects
Groups
Snippets
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in
Toggle navigation
Menu
Open sidebar
小 白蛋
Terraform
Commits
dee450cf
Unverified
Commit
dee450cf
authored
5 years ago
by
Radek Simko
Browse files
Options
Download
Email Patches
Plain Diff
vendor: Bump go-azure-helpers to 0.7.0
parent
273b6689
Changes
132
Hide whitespace changes
Inline
Side-by-side
Showing
20 changed files
backend/remote-state/azure/arm_client.go
+1
-2
backend/remote-state/azure/arm_client.go
go.mod
+6
-4
go.mod
go.sum
+22
-23
go.sum
vendor/contrib.go.opencensus.io/exporter/ocagent/.travis.yml
+0
-18
vendor/contrib.go.opencensus.io/exporter/ocagent/.travis.yml
vendor/contrib.go.opencensus.io/exporter/ocagent/CONTRIBUTING.md
+0
-24
...contrib.go.opencensus.io/exporter/ocagent/CONTRIBUTING.md
vendor/contrib.go.opencensus.io/exporter/ocagent/LICENSE
+0
-201
vendor/contrib.go.opencensus.io/exporter/ocagent/LICENSE
vendor/contrib.go.opencensus.io/exporter/ocagent/README.md
+0
-61
vendor/contrib.go.opencensus.io/exporter/ocagent/README.md
vendor/contrib.go.opencensus.io/exporter/ocagent/common.go
+0
-38
vendor/contrib.go.opencensus.io/exporter/ocagent/common.go
vendor/contrib.go.opencensus.io/exporter/ocagent/connection.go
+0
-97
...r/contrib.go.opencensus.io/exporter/ocagent/connection.go
vendor/contrib.go.opencensus.io/exporter/ocagent/go.mod
+0
-10
vendor/contrib.go.opencensus.io/exporter/ocagent/go.mod
vendor/contrib.go.opencensus.io/exporter/ocagent/go.sum
+0
-130
vendor/contrib.go.opencensus.io/exporter/ocagent/go.sum
vendor/contrib.go.opencensus.io/exporter/ocagent/nodeinfo.go
+0
-46
vendor/contrib.go.opencensus.io/exporter/ocagent/nodeinfo.go
vendor/contrib.go.opencensus.io/exporter/ocagent/ocagent.go
+0
-496
vendor/contrib.go.opencensus.io/exporter/ocagent/ocagent.go
vendor/contrib.go.opencensus.io/exporter/ocagent/options.go
+0
-128
vendor/contrib.go.opencensus.io/exporter/ocagent/options.go
vendor/contrib.go.opencensus.io/exporter/ocagent/transform_spans.go
+0
-248
...trib.go.opencensus.io/exporter/ocagent/transform_spans.go
vendor/contrib.go.opencensus.io/exporter/ocagent/transform_stats_to_metrics.go
+0
-274
...ncensus.io/exporter/ocagent/transform_stats_to_metrics.go
vendor/contrib.go.opencensus.io/exporter/ocagent/version.go
+0
-17
vendor/contrib.go.opencensus.io/exporter/ocagent/version.go
vendor/github.com/Azure/azure-sdk-for-go/services/resources/mgmt/2016-02-01/resources/deploymentoperations.go
+4
-4
...sources/mgmt/2016-02-01/resources/deploymentoperations.go
vendor/github.com/Azure/azure-sdk-for-go/services/resources/mgmt/2016-02-01/resources/deployments.go
+16
-16
...rvices/resources/mgmt/2016-02-01/resources/deployments.go
vendor/github.com/Azure/azure-sdk-for-go/services/resources/mgmt/2016-02-01/resources/groups.go
+16
-16
...go/services/resources/mgmt/2016-02-01/resources/groups.go
with
65 additions
and
1853 deletions
+65
-1853
backend/remote-state/azure/arm_client.go
+
1
-
2
View file @
dee450cf
...
...
@@ -13,7 +13,6 @@ import (
armStorage
"github.com/Azure/azure-sdk-for-go/profiles/2017-03-09/storage/mgmt/storage"
"github.com/Azure/azure-sdk-for-go/storage"
"github.com/Azure/go-autorest/autorest"
"github.com/Azure/go-autorest/autorest/adal"
"github.com/Azure/go-autorest/autorest/azure"
"github.com/hashicorp/go-azure-helpers/authentication"
"github.com/hashicorp/terraform/httpclient"
...
...
@@ -75,7 +74,7 @@ func buildArmClient(config BackendConfig) (*ArmClient, error) {
return
nil
,
fmt
.
Errorf
(
"Error building ARM Config: %+v"
,
err
)
}
oauthConfig
,
err
:=
a
dal
.
New
OAuthConfig
(
env
.
ActiveDirectoryEndpoint
,
armConfig
.
TenantID
)
oauthConfig
,
err
:=
a
rmConfig
.
Build
OAuthConfig
(
env
.
ActiveDirectoryEndpoint
)
if
err
!=
nil
{
return
nil
,
err
}
...
...
This diff is collapsed.
Click to expand it.
go.mod
+
6
-
4
View file @
dee450cf
...
...
@@ -2,9 +2,9 @@ module github.com/hashicorp/terraform
require (
cloud.google.com/go
v0.36.0
github.com/Azure/azure-sdk-for-go
v3
1.2
.0+incompatible
github.com/Azure/go-autorest/autorest
v0.
5
.0
github.com/Azure/go-autorest/autorest/adal
v0.
2
.0
github.com/Azure/azure-sdk-for-go
v3
2.5
.0+incompatible
github.com/Azure/go-autorest/autorest
v0.
9
.0
github.com/Azure/go-autorest/autorest/adal
v0.
6
.0
github.com/Unknwon/com
v0.0.0-20151008135407-28b053d5a292 // indirect
github.com/abdullin/seq
v0.0.0-20160510034733-d5467c17e7af // indirect
github.com/agext/levenshtein
v1.2.2
...
...
@@ -43,10 +43,11 @@ require (
github.com/gorilla/websocket
v1.4.0 // indirect
github.com/grpc-ecosystem/go-grpc-middleware
v1.0.0 // indirect
github.com/grpc-ecosystem/go-grpc-prometheus
v1.2.0 // indirect
github.com/grpc-ecosystem/grpc-gateway
v1.8.5 // indirect
github.com/hashicorp/aws-sdk-go-base
v0.3.0
github.com/hashicorp/consul
v0.0.0-20171026175957-610f3c86a089
github.com/hashicorp/errwrap
v1.0.0
github.com/hashicorp/go-azure-helpers
v0.
5
.0
github.com/hashicorp/go-azure-helpers
v0.
7
.0
github.com/hashicorp/go-checkpoint
v0.5.0
github.com/hashicorp/go-cleanhttp
v0.5.0
github.com/hashicorp/go-getter
v1.3.1-0.20190627223108-da0323b9545e
...
...
@@ -112,6 +113,7 @@ require (
github.com/xlab/treeprint
v0.0.0-20161029104018-1d6e34225557
github.com/zclconf/go-cty
v1.0.1-0.20190708163926-19588f92a98f
github.com/zclconf/go-cty-yaml
v1.0.1
go.opencensus.io
v0.20.2 // indirect
go.uber.org/atomic
v1.3.2 // indirect
go.uber.org/multierr
v1.1.0 // indirect
go.uber.org/zap
v1.9.1 // indirect
...
...
This diff is collapsed.
Click to expand it.
go.sum
+
22
-
23
View file @
dee450cf
...
...
@@ -4,36 +4,37 @@ cloud.google.com/go v0.31.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMT
cloud.google.com/go
v0.34.0/go.mod h1:
aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
cloud.google.com/go
v0.36.0 h1:
+aCSj7tOo2LODWVEuZDZeGCckdt6MlSF+X/rB3wUiS8=
cloud.google.com/go
v0.36.0/go.mod h1:
RUoy9p/M4ge0HzT8L+SDZ8jg+Q6fth0CiBuhFJpSV40=
contrib.go.opencensus.io/exporter/ocagent
v0.4.12 h1:
jGFvw3l57ViIVEPKKEUXPcLYIXJmQxLUh6ey1eJhwyc=
contrib.go.opencensus.io/exporter/ocagent
v0.4.12/go.mod h1:
450APlNTSR6FrvC3CTRqYosuDstRB9un7SOx2k/9ckA=
dmitri.shuralyov.com/app/changes
v0.0.0-20180602232624-0a106ad413e3/go.mod h1:
Yl+fi1br7+Rr3LqpNJf1/uxUdtRUV+Tnj0o93V2B9MU=
dmitri.shuralyov.com/html/belt
v0.0.0-20180602232347-f7d459c86be0/go.mod h1:
JLBrvjyP0v+ecvNYvCpyZgu5/xkfAUhi6wJj28eUfSU=
dmitri.shuralyov.com/service/change
v0.0.0-20181023043359-a85b471d5412/go.mod h1:
a1inKt/atXimZ4Mv927x+r7UpyzRUf4emIoiiSC2TN4=
dmitri.shuralyov.com/state
v0.0.0-20180228185332-28bcc343414c/go.mod h1:
0PRwlb0D6DFvNNtx+9ybjezNCa8XF0xaYcETyp6rHWU=
git.apache.org/thrift.git
v0.0.0-20180902110319-2566ecd5d999/go.mod h1:
fPE2ZNJGynbRyZ4dJvy6G277gSllfV2HJqblrnkyeyg=
github.com/Azure/azure-sdk-for-go
v31.0.0+incompatible/go.mod h1:
9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
github.com/Azure/azure-sdk-for-go
v31.2.0+incompatible h1:
kZFnTLmdQYNGfakatSivKHUfUnDZhqNdchHD4oIhp5k=
github.com/Azure/azure-sdk-for-go
v31.2.0+incompatible/go.mod h1:
9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
github.com/Azure/go-autorest/autorest
v0.3.0/go.mod h1:
AKyIcETwSUFxIcs/Wnq/C+kwCtlEYGUVd7FPNb2slmg=
github.com/Azure/go-autorest/autorest
v0.5.0 h1:
Mlm9qy2fpQ9MvfyI41G2Zf5B4CsgjjNbLOWszfK6KrY=
github.com/Azure/go-autorest/autorest
v0.5.0/go.mod h1:
9HLKlQjVBH6U3oDfsXOeVc56THsLPw1L03yban4xThw=
github.com/Azure/go-autorest/autorest/adal
v0.1.0/go.mod h1:
MeS4XhScH55IST095THyTxElntu7WqB7pNbZo8Q5G3E=
github.com/Azure/go-autorest/autorest/adal
v0.2.0 h1:
7IBDu1jgh+ADHXnEYExkV9RE/ztOOlxdACkkPRthGKw=
github.com/Azure/go-autorest/autorest/adal
v0.2.0/go.mod h1:
MeS4XhScH55IST095THyTxElntu7WqB7pNbZo8Q5G3E=
github.com/Azure/go-autorest/autorest/azure/cli
v0.1.0 h1:
YTtBrcb6mhA+PoSW8WxFDoIIyjp13XqJeX80ssQtri4=
github.com/Azure/go-autorest/autorest/azure/cli
v0.1.0/go.mod h1:
Dk8CUAt/b/PzkfeRsWzVG9Yj3ps8mS8ECztu43rdU8U=
github.com/Azure/azure-sdk-for-go
v32.5.0+incompatible h1:
Hn/DsObfmw0M7dMGS/c0MlVrJuGFzHzOpBWL89acR68=
github.com/Azure/azure-sdk-for-go
v32.5.0+incompatible/go.mod h1:
9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
github.com/Azure/go-autorest/autorest
v0.9.0 h1:
MRvx8gncNaXJqOoLmhNjUAKh33JJF8LyxPhomEtOsjs=
github.com/Azure/go-autorest/autorest
v0.9.0/go.mod h1:
xyHB1BMZT0cuDHU7I0+g046+BFDTQ8rEZB0s4Yfa6bI=
github.com/Azure/go-autorest/autorest/adal
v0.5.0/go.mod h1:
8Z9fGy2MpX0PvDjB1pEgQTmVqjGhiHBW7RJJEciWzS0=
github.com/Azure/go-autorest/autorest/adal
v0.6.0 h1:
UCTq22yE3RPgbU/8u4scfnnzuCW6pwQ9n+uBtV78ouo=
github.com/Azure/go-autorest/autorest/adal
v0.6.0/go.mod h1:
Z6vX6WXXuyieHAXwMj0S6HY6e6wcHn37qQMBQlvY3lc=
github.com/Azure/go-autorest/autorest/azure/cli
v0.2.0 h1:
pSwNMF0qotgehbQNllUWwJ4V3vnrLKOzHrwDLEZK904=
github.com/Azure/go-autorest/autorest/azure/cli
v0.2.0/go.mod h1:
WWTbGPvkAg3I4ms2j2s+Zr5xCGwGqTQh+6M2ZqOczkE=
github.com/Azure/go-autorest/autorest/date
v0.1.0 h1:
YGrhWfrgtFs84+h0o46rJrlmsZtyZRg470CqAXTZaGM=
github.com/Azure/go-autorest/autorest/date
v0.1.0/go.mod h1:
plvfp3oPSKwf2DNjlBjWF/7vwR+cUD/ELuzDCXwHUVA=
github.com/Azure/go-autorest/autorest/date
v0.2.0 h1:
yW+Zlqf26583pE43KhfnhFcdmSWlm5Ew6bxipnr/tbM=
github.com/Azure/go-autorest/autorest/date
v0.2.0/go.mod h1:
vcORJHLJEh643/Ioh9+vPmf1Ij9AEBM5FuBIXLmIy0g=
github.com/Azure/go-autorest/autorest/mocks
v0.1.0 h1:
Kx+AUU2Te+A3JIyYn6Dfs+cFgx5XorQKuIXrZGoq/SI=
github.com/Azure/go-autorest/autorest/mocks
v0.1.0/go.mod h1:
OTyCOPRA2IgIlWxVYxBee2F5Gr4kF2zd2J5cFRaIDN0=
github.com/Azure/go-autorest/autorest/to
v0.2.0 h1:
nQOZzFCudTh+TvquAtCRjM01VEYx85e9qbwt5ncW4L8=
github.com/Azure/go-autorest/autorest/to
v0.2.0/go.mod h1:
GunWKJp1AEqgMaGLV+iocmRAJWqST1wQYhyyjXJ3SJc=
github.com/Azure/go-autorest/autorest/validation
v0.1.0 h1:
ISSNzGUh+ZSzizJWOWzs8bwpXIePbGLW4z/AmUFGH5A=
github.com/Azure/go-autorest/autorest/validation
v0.1.0/go.mod h1:
Ha3z/SqBeaalWQvokg3NZAlQTalVMtOIAs1aGK7G6u8=
github.com/Azure/go-autorest/autorest/mocks
v0.2.0/go.mod h1:
OTyCOPRA2IgIlWxVYxBee2F5Gr4kF2zd2J5cFRaIDN0=
github.com/Azure/go-autorest/autorest/mocks
v0.3.0 h1:
qJumjCaCudz+OcqE9/XtEPfvtOjOmKaui4EOpFI6zZc=
github.com/Azure/go-autorest/autorest/mocks
v0.3.0/go.mod h1:
a8FDP3DYzQ4RYfVAxAN3SVSiiO77gL2j2ronKKP0syM=
github.com/Azure/go-autorest/autorest/to
v0.3.0 h1:
zebkZaadz7+wIQYgC7GXaz3Wb28yKYfVkkBKwc38VF8=
github.com/Azure/go-autorest/autorest/to
v0.3.0/go.mod h1:
MgwOyqaIuKdG4TL/2ywSsIWKAfJfgHDo8ObuUk3t5sA=
github.com/Azure/go-autorest/autorest/validation
v0.2.0 h1:
15vMO4y76dehZSq7pAaOLQxC6dZYsSrj2GQpflyM/L4=
github.com/Azure/go-autorest/autorest/validation
v0.2.0/go.mod h1:
3EEqHnBxQGHXRYq3HT1WyXAvT7LLY3tl70hw6tQIbjI=
github.com/Azure/go-autorest/logger
v0.1.0 h1:
ruG4BSDXONFRrZZJ2GUXDiUyVpayPmb1GnWeHDdaNKY=
github.com/Azure/go-autorest/logger
v0.1.0/go.mod h1:
oExouG+K6PryycPJfVSxi/koC6LSNgds39diKLz7Vrc=
github.com/Azure/go-autorest/tracing
v0.
1
.0 h1:
TR
BxC5Pj/fIuh4Qob0ZpkggbfT8RC0SubHbpV3p4/Vc
=
github.com/Azure/go-autorest/tracing
v0.
1
.0/go.mod h1:
ROEEAFwXycQw7Sn3DXNtEedEvdeRAgDr0izn4z5Ij88
=
github.com/Azure/go-autorest/tracing
v0.
5
.0 h1:
TR
n4WjSnkcSy5AEG3pnbtFSwNtwzjr4VYyQflFE619k
=
github.com/Azure/go-autorest/tracing
v0.
5
.0/go.mod h1:
r/s2XiOKccPW3HrqB+W0TQzfbtp2fGCgRFtBroKn4Dk
=
github.com/Azure/go-ntlmssp
v0.0.0-20180810175552-4a21cbd618b4 h1:
pSm8mp0T2OH2CPmPDPtwHPr3VAQaOwVF/JbllOPP4xA=
github.com/Azure/go-ntlmssp
v0.0.0-20180810175552-4a21cbd618b4/go.mod h1:
chxPXzSsl7ZWRAuOIE23GDNzjWuZquvFlgA8xmpunjU=
github.com/BurntSushi/toml
v0.3.1/go.mod h1:
xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
...
...
@@ -99,8 +100,6 @@ github.com/boltdb/bolt v1.3.1 h1:JQmyP4ZBrce+ZQu0dY660FMfatumYDLun9hBCUVIkF4=
github.com/boltdb/bolt
v1.3.1/go.mod h1:
clJnj/oiGkjum5o1McbSZDSLxVThjynRyGBgiAx27Ps=
github.com/bradfitz/go-smtpd
v0.0.0-20170404230938-deb6d6237625/go.mod h1:
HYsPBTaaSFSlLx/70C2HPIMNZpVV8+vt/A+FMnYP11g=
github.com/bsm/go-vlq
v0.0.0-20150828105119-ec6e8d4f5f4e/go.mod h1:
N+BjUcTjSxc2mtRGSCPsat1kze3CUtvJN3/jTXlp29k=
github.com/census-instrumentation/opencensus-proto
v0.2.0 h1:
LzQXZOgg4CQfE6bFvXGM30YZL1WW/M337pXml+GrcZ4=
github.com/census-instrumentation/opencensus-proto
v0.2.0/go.mod h1:
f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
github.com/cheggaaa/pb
v1.0.27/go.mod h1:
pQciLPpbU0oxA0h+VJYYLxO+XeDQb5pZijXscXHm81s=
github.com/chzyer/logex
v1.1.10 h1:
Swpa1K6QvQznwJRcfTfQJmTE72DqScAa40E+fbHEXEE=
github.com/chzyer/logex
v1.1.10/go.mod h1:
+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
...
...
@@ -211,8 +210,8 @@ github.com/hashicorp/consul v0.0.0-20171026175957-610f3c86a089/go.mod h1:mFrjN1m
github.com/hashicorp/errwrap
v0.0.0-20180715044906-d6c0cd880357/go.mod h1:
YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
github.com/hashicorp/errwrap
v1.0.0 h1:
hLrqtEDnRye3+sgx6z4qVLNuviH3MR5aQ0ykNJa/UYA=
github.com/hashicorp/errwrap
v1.0.0/go.mod h1:
YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
github.com/hashicorp/go-azure-helpers
v0.
5
.0 h1:
GW5YJKeeMfyIEZjiVf84Av2W6FizMwS1OYLtDwDwah0
=
github.com/hashicorp/go-azure-helpers
v0.
5
.0/go.mod h1:
1kVoV5ZV0b/Wc/Rck7dKgW0MhmUrZiRxt/OnG42Yeow
=
github.com/hashicorp/go-azure-helpers
v0.
7
.0 h1:
wxGpOyWYp15bjBMeL3pXKP5X3oFLZbThAMcJcU6x4FA
=
github.com/hashicorp/go-azure-helpers
v0.
7
.0/go.mod h1:
3xdjhbL7qs69rnwxA0UENOzkPJjtTFIRb5aRyrEpbCU
=
github.com/hashicorp/go-checkpoint
v0.5.0 h1:
MFYpPZCnQqQTE18jFwSII6eUQrD/oxMFp3mlgcqk5mU=
github.com/hashicorp/go-checkpoint
v0.5.0/go.mod h1:
7nfLNL10NsxqO4iWuW6tWW0HjZuDrwkBuEQsVcpCOgg=
github.com/hashicorp/go-cleanhttp
v0.5.0 h1:
wvCrVc9TjDls6+YGAF2hAifE1E5U1+b4tH6KdvN3Gig=
...
...
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/.travis.yml
deleted
100644 → 0
+
0
-
18
View file @
273b6689
language
:
go
go
:
-
1.11.x
go_import_path
:
contrib.go.opencensus.io/exporter/ocagent
before_script
:
-
GO_FILES=$(find . -iname '*.go' | grep -v /vendor/)
# All the .go files, excluding vendor/ if any
-
PKGS=$(go list ./... | grep -v /vendor/)
# All the import paths, excluding vendor/ if any
script
:
-
go build ./...
# Ensure dependency updates don't break build
-
if [ -n "$(gofmt -s -l $GO_FILES)" ]; then echo "gofmt the following files:"; gofmt -s -l $GO_FILES; exit 1; fi
-
go vet ./...
-
GO111MODULE=on go test -v -race $PKGS
# Run all the tests with the race detector enabled
-
GO111MODULE=off go test -v -race $PKGS
# Make sure tests still pass when not using Go modules.
-
'
if
[[
$TRAVIS_GO_VERSION
=
1.8*
]];
then
!
golint
./...
|
grep
-vE
"(_mock|_string|\.pb)\.go:";
fi'
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/CONTRIBUTING.md
deleted
100644 → 0
+
0
-
24
View file @
273b6689
# How to contribute
We'd love to accept your patches and contributions to this project. There are
just a few small guidelines you need to follow.
## Contributor License Agreement
Contributions to this project must be accompanied by a Contributor License
Agreement. You (or your employer) retain the copyright to your contribution,
this simply gives us permission to use and redistribute your contributions as
part of the project. Head over to
<https://cla.developers.google.com/>
to see
your current agreements on file or to sign a new one.
You generally only need to submit a CLA once, so if you've already submitted one
(even if it was for a different project), you probably don't need to do it
again.
## Code reviews
All submissions, including submissions by project members, require review. We
use GitHub pull requests for this purpose. Consult [GitHub Help] for more
information on using pull requests.
[
GitHub Help
]:
https://help.github.com/articles/about-pull-requests/
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/LICENSE
deleted
100644 → 0
+
0
-
201
View file @
273b6689
Apache License
Version 2.0, January 2004
http://www.apache.org/licenses/
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
1. Definitions.
"License" shall mean the terms and conditions for use, reproduction,
and distribution as defined by Sections 1 through 9 of this document.
"Licensor" shall mean the copyright owner or entity authorized by
the copyright owner that is granting the License.
"Legal Entity" shall mean the union of the acting entity and all
other entities that control, are controlled by, or are under common
control with that entity. For the purposes of this definition,
"control" means (i) the power, direct or indirect, to cause the
direction or management of such entity, whether by contract or
otherwise, or (ii) ownership of fifty percent (50%) or more of the
outstanding shares, or (iii) beneficial ownership of such entity.
"You" (or "Your") shall mean an individual or Legal Entity
exercising permissions granted by this License.
"Source" form shall mean the preferred form for making modifications,
including but not limited to software source code, documentation
source, and configuration files.
"Object" form shall mean any form resulting from mechanical
transformation or translation of a Source form, including but
not limited to compiled object code, generated documentation,
and conversions to other media types.
"Work" shall mean the work of authorship, whether in Source or
Object form, made available under the License, as indicated by a
copyright notice that is included in or attached to the work
(an example is provided in the Appendix below).
"Derivative Works" shall mean any work, whether in Source or Object
form, that is based on (or derived from) the Work and for which the
editorial revisions, annotations, elaborations, or other modifications
represent, as a whole, an original work of authorship. For the purposes
of this License, Derivative Works shall not include works that remain
separable from, or merely link (or bind by name) to the interfaces of,
the Work and Derivative Works thereof.
"Contribution" shall mean any work of authorship, including
the original version of the Work and any modifications or additions
to that Work or Derivative Works thereof, that is intentionally
submitted to Licensor for inclusion in the Work by the copyright owner
or by an individual or Legal Entity authorized to submit on behalf of
the copyright owner. For the purposes of this definition, "submitted"
means any form of electronic, verbal, or written communication sent
to the Licensor or its representatives, including but not limited to
communication on electronic mailing lists, source code control systems,
and issue tracking systems that are managed by, or on behalf of, the
Licensor for the purpose of discussing and improving the Work, but
excluding communication that is conspicuously marked or otherwise
designated in writing by the copyright owner as "Not a Contribution."
"Contributor" shall mean Licensor and any individual or Legal Entity
on behalf of whom a Contribution has been received by Licensor and
subsequently incorporated within the Work.
2. Grant of Copyright License. Subject to the terms and conditions of
this License, each Contributor hereby grants to You a perpetual,
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
copyright license to reproduce, prepare Derivative Works of,
publicly display, publicly perform, sublicense, and distribute the
Work and such Derivative Works in Source or Object form.
3. Grant of Patent License. Subject to the terms and conditions of
this License, each Contributor hereby grants to You a perpetual,
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
(except as stated in this section) patent license to make, have made,
use, offer to sell, sell, import, and otherwise transfer the Work,
where such license applies only to those patent claims licensable
by such Contributor that are necessarily infringed by their
Contribution(s) alone or by combination of their Contribution(s)
with the Work to which such Contribution(s) was submitted. If You
institute patent litigation against any entity (including a
cross-claim or counterclaim in a lawsuit) alleging that the Work
or a Contribution incorporated within the Work constitutes direct
or contributory patent infringement, then any patent licenses
granted to You under this License for that Work shall terminate
as of the date such litigation is filed.
4. Redistribution. You may reproduce and distribute copies of the
Work or Derivative Works thereof in any medium, with or without
modifications, and in Source or Object form, provided that You
meet the following conditions:
(a) You must give any other recipients of the Work or
Derivative Works a copy of this License; and
(b) You must cause any modified files to carry prominent notices
stating that You changed the files; and
(c) You must retain, in the Source form of any Derivative Works
that You distribute, all copyright, patent, trademark, and
attribution notices from the Source form of the Work,
excluding those notices that do not pertain to any part of
the Derivative Works; and
(d) If the Work includes a "NOTICE" text file as part of its
distribution, then any Derivative Works that You distribute must
include a readable copy of the attribution notices contained
within such NOTICE file, excluding those notices that do not
pertain to any part of the Derivative Works, in at least one
of the following places: within a NOTICE text file distributed
as part of the Derivative Works; within the Source form or
documentation, if provided along with the Derivative Works; or,
within a display generated by the Derivative Works, if and
wherever such third-party notices normally appear. The contents
of the NOTICE file are for informational purposes only and
do not modify the License. You may add Your own attribution
notices within Derivative Works that You distribute, alongside
or as an addendum to the NOTICE text from the Work, provided
that such additional attribution notices cannot be construed
as modifying the License.
You may add Your own copyright statement to Your modifications and
may provide additional or different license terms and conditions
for use, reproduction, or distribution of Your modifications, or
for any such Derivative Works as a whole, provided Your use,
reproduction, and distribution of the Work otherwise complies with
the conditions stated in this License.
5. Submission of Contributions. Unless You explicitly state otherwise,
any Contribution intentionally submitted for inclusion in the Work
by You to the Licensor shall be under the terms and conditions of
this License, without any additional terms or conditions.
Notwithstanding the above, nothing herein shall supersede or modify
the terms of any separate license agreement you may have executed
with Licensor regarding such Contributions.
6. Trademarks. This License does not grant permission to use the trade
names, trademarks, service marks, or product names of the Licensor,
except as required for reasonable and customary use in describing the
origin of the Work and reproducing the content of the NOTICE file.
7. Disclaimer of Warranty. Unless required by applicable law or
agreed to in writing, Licensor provides the Work (and each
Contributor provides its Contributions) on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
implied, including, without limitation, any warranties or conditions
of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
PARTICULAR PURPOSE. You are solely responsible for determining the
appropriateness of using or redistributing the Work and assume any
risks associated with Your exercise of permissions under this License.
8. Limitation of Liability. In no event and under no legal theory,
whether in tort (including negligence), contract, or otherwise,
unless required by applicable law (such as deliberate and grossly
negligent acts) or agreed to in writing, shall any Contributor be
liable to You for damages, including any direct, indirect, special,
incidental, or consequential damages of any character arising as a
result of this License or out of the use or inability to use the
Work (including but not limited to damages for loss of goodwill,
work stoppage, computer failure or malfunction, or any and all
other commercial damages or losses), even if such Contributor
has been advised of the possibility of such damages.
9. Accepting Warranty or Additional Liability. While redistributing
the Work or Derivative Works thereof, You may choose to offer,
and charge a fee for, acceptance of support, warranty, indemnity,
or other liability obligations and/or rights consistent with this
License. However, in accepting such obligations, You may act only
on Your own behalf and on Your sole responsibility, not on behalf
of any other Contributor, and only if You agree to indemnify,
defend, and hold each Contributor harmless for any liability
incurred by, or claims asserted against, such Contributor by reason
of your accepting any such warranty or additional liability.
END OF TERMS AND CONDITIONS
APPENDIX: How to apply the Apache License to your work.
To apply the Apache License to your work, attach the following
boilerplate notice, with the fields enclosed by brackets "[]"
replaced with your own identifying information. (Don't include
the brackets!) The text should be enclosed in the appropriate
comment syntax for the file format. We also recommend that a
file or class name and description of purpose be included on the
same "printed page" as the copyright notice for easier
identification within third-party archives.
Copyright [yyyy] [name of copyright owner]
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/README.md
deleted
100644 → 0
+
0
-
61
View file @
273b6689
# OpenCensus Agent Go Exporter
[
![Build Status
][
travis-image
]
]
[
travis-url] [![GoDoc
][
godoc-image
]
][godoc-url]
This repository contains the Go implementation of the OpenCensus Agent (OC-Agent) Exporter.
OC-Agent is a deamon process running in a VM that can retrieve spans/stats/metrics from
OpenCensus Library, export them to other backends and possibly push configurations back to
Library. See more details on
[
OC-Agent Readme
][
OCAgentReadme
]
.
Note: This is an experimental repository and is likely to get backwards-incompatible changes.
Ultimately we may want to move the OC-Agent Go Exporter to
[
OpenCensus Go core library
][
OpenCensusGo
]
.
## Installation
```
bash
$
go get
-u
contrib.go.opencensus.io/exporter/ocagent
```
## Usage
```
go
import
(
"context"
"fmt"
"log"
"time"
"contrib.go.opencensus.io/exporter/ocagent"
"go.opencensus.io/trace"
)
func
Example
()
{
exp
,
err
:=
ocagent
.
NewExporter
(
ocagent
.
WithInsecure
(),
ocagent
.
WithServiceName
(
"your-service-name"
))
if
err
!=
nil
{
log
.
Fatalf
(
"Failed to create the agent exporter: %v"
,
err
)
}
defer
exp
.
Stop
()
// Now register it as a trace exporter.
trace
.
RegisterExporter
(
exp
)
// Then use the OpenCensus tracing library, like we normally would.
ctx
,
span
:=
trace
.
StartSpan
(
context
.
Background
(),
"AgentExporter-Example"
)
defer
span
.
End
()
for
i
:=
0
;
i
<
10
;
i
++
{
_
,
iSpan
:=
trace
.
StartSpan
(
ctx
,
fmt
.
Sprintf
(
"Sample-%d"
,
i
))
<-
time
.
After
(
6
*
time
.
Millisecond
)
iSpan
.
End
()
}
}
```
[
OCAgentReadme
]:
https://github.com/census-instrumentation/opencensus-proto/tree/master/opencensus/proto/agent#opencensus-agent-proto
[
OpenCensusGo
]:
https://github.com/census-instrumentation/opencensus-go
[
godoc-image
]:
https://godoc.org/contrib.go.opencensus.io/exporter/ocagent?status.svg
[
godoc-url
]:
https://godoc.org/contrib.go.opencensus.io/exporter/ocagent
[
travis-image
]:
https://travis-ci.org/census-ecosystem/opencensus-go-exporter-ocagent.svg?branch=master
[
travis-url
]:
https://travis-ci.org/census-ecosystem/opencensus-go-exporter-ocagent
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/common.go
deleted
100644 → 0
+
0
-
38
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
import
(
"math/rand"
"time"
)
var
randSrc
=
rand
.
New
(
rand
.
NewSource
(
time
.
Now
()
.
UnixNano
()))
// retries function fn upto n times, if fn returns an error lest it returns nil early.
// It applies exponential backoff in units of (1<<n) + jitter microsends.
func
nTriesWithExponentialBackoff
(
nTries
int64
,
timeBaseUnit
time
.
Duration
,
fn
func
()
error
)
(
err
error
)
{
for
i
:=
int64
(
0
);
i
<
nTries
;
i
++
{
err
=
fn
()
if
err
==
nil
{
return
nil
}
// Backoff for a time period with a pseudo-random jitter
jitter
:=
time
.
Duration
(
randSrc
.
Float64
()
*
100
)
*
time
.
Microsecond
ts
:=
jitter
+
((
1
<<
uint64
(
i
))
*
timeBaseUnit
)
<-
time
.
After
(
ts
)
}
return
err
}
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/connection.go
deleted
100644 → 0
+
0
-
97
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
import
(
"math/rand"
"sync/atomic"
"time"
)
const
(
sDisconnected
int32
=
5
+
iota
sConnected
)
func
(
ae
*
Exporter
)
setStateDisconnected
()
{
atomic
.
StoreInt32
(
&
ae
.
connectionState
,
sDisconnected
)
select
{
case
ae
.
disconnectedCh
<-
true
:
default
:
}
}
func
(
ae
*
Exporter
)
setStateConnected
()
{
atomic
.
StoreInt32
(
&
ae
.
connectionState
,
sConnected
)
}
func
(
ae
*
Exporter
)
connected
()
bool
{
return
atomic
.
LoadInt32
(
&
ae
.
connectionState
)
==
sConnected
}
const
defaultConnReattemptPeriod
=
10
*
time
.
Second
func
(
ae
*
Exporter
)
indefiniteBackgroundConnection
()
error
{
defer
func
()
{
ae
.
backgroundConnectionDoneCh
<-
true
}()
connReattemptPeriod
:=
ae
.
reconnectionPeriod
if
connReattemptPeriod
<=
0
{
connReattemptPeriod
=
defaultConnReattemptPeriod
}
// No strong seeding required, nano time can
// already help with pseudo uniqueness.
rng
:=
rand
.
New
(
rand
.
NewSource
(
time
.
Now
()
.
UnixNano
()
+
rand
.
Int63n
(
1024
)))
// maxJitter: 1 + (70% of the connectionReattemptPeriod)
maxJitter
:=
int64
(
1
+
0.7
*
float64
(
connReattemptPeriod
))
for
{
// Otherwise these will be the normal scenarios to enable
// reconnections if we trip out.
// 1. If we've stopped, return entirely
// 2. Otherwise block until we are disconnected, and
// then retry connecting
select
{
case
<-
ae
.
stopCh
:
return
errStopped
case
<-
ae
.
disconnectedCh
:
// Normal scenario that we'll wait for
}
if
err
:=
ae
.
connect
();
err
==
nil
{
ae
.
setStateConnected
()
}
else
{
ae
.
setStateDisconnected
()
}
// Apply some jitter to avoid lockstep retrials of other
// agent-exporters. Lockstep retrials could result in an
// innocent DDOS, by clogging the machine's resources and network.
jitter
:=
time
.
Duration
(
rng
.
Int63n
(
maxJitter
))
<-
time
.
After
(
connReattemptPeriod
+
jitter
)
}
}
func
(
ae
*
Exporter
)
connect
()
error
{
cc
,
err
:=
ae
.
dialToAgent
()
if
err
!=
nil
{
return
err
}
return
ae
.
enableConnectionStreams
(
cc
)
}
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/go.mod
deleted
100644 → 0
+
0
-
10
View file @
273b6689
module contrib.go.opencensus.io/exporter/ocagent
require (
github.com/census-instrumentation/opencensus-proto v0.2.0 // this is to match the version used in census-instrumentation/opencensus-service
github.com/golang/protobuf v1.3.1
github.com/grpc-ecosystem/grpc-gateway v1.8.5 // indirect
go.opencensus.io v0.20.2
google.golang.org/api v0.3.1
google.golang.org/grpc v1.19.1
)
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/go.sum
deleted
100644 → 0
+
0
-
130
View file @
273b6689
cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
github.com/Shopify/sarama v1.19.0/go.mod h1:FVkBWblsNy7DGZRfXLU0O9RCGt5g3g3yEuWXgklEdEo=
github.com/Shopify/toxiproxy v2.1.4+incompatible/go.mod h1:OXgGpZ6Cli1/URJOF1DMxUHB2q5Ap20/P/eIdh4G0pI=
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/apache/thrift v0.12.0/go.mod h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ=
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
github.com/census-instrumentation/opencensus-proto v0.2.0 h1:LzQXZOgg4CQfE6bFvXGM30YZL1WW/M337pXml+GrcZ4=
github.com/census-instrumentation/opencensus-proto v0.2.0/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/eapache/go-resiliency v1.1.0/go.mod h1:kFI+JgMyC7bLPUVY133qvEBtVayf5mFgVsvEsIPBvNs=
github.com/eapache/go-xerial-snappy v0.0.0-20180814174437-776d5712da21/go.mod h1:+020luEh2TKB4/GOp8oxxtq0Daoen/Cii55CzbTV6DU=
github.com/eapache/queue v1.1.0/go.mod h1:6eCeP0CKFpHLu8blIFXhExK/dRa7WDZfr6jVFPTqq+I=
github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
github.com/go-kit/kit v0.8.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
github.com/gogo/protobuf v1.2.0/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b h1:VKtxabqXZkF25pY9ekfRL6a582T4P37/31XEstQ5p58=
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
github.com/golang/protobuf v1.2.0 h1:P3YflyNX/ehuJFLhxviNdFxQPkGK5cDcApsge1SqnvM=
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.3.1 h1:YF8+flBXS5eO826T4nzqPrxfhQThhXl0YzfuUPu4SBg=
github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/snappy v0.0.0-20180518054509-2e65f85255db/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
github.com/google/go-cmp v0.2.0 h1:+dTQ8DZQJz0Mb/HjFlkptS1FeQ4cWSnN941F8aEG4SQ=
github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
github.com/gorilla/context v1.1.1/go.mod h1:kBGZzfjB9CEq2AlWe17Uuf7NDRt0dE0s8S51q0aT7Yg=
github.com/gorilla/mux v1.6.2/go.mod h1:1lud6UwP+6orDFRuTfBEV8e9/aOM/c4fVVCaMa2zaAs=
github.com/grpc-ecosystem/grpc-gateway v1.8.5 h1:2+KSC78XiO6Qy0hIjfc1OD9H+hsaJdJlb8Kqsd41CTE=
github.com/grpc-ecosystem/grpc-gateway v1.8.5/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY=
github.com/hashicorp/golang-lru v0.5.0 h1:CL2msUPvZTLb5O648aiLNJw3hnBxN2+1Jq8rCOH9wdo=
github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w=
github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc=
github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
github.com/onsi/ginkgo v1.7.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
github.com/onsi/gomega v1.4.3/go.mod h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
github.com/openzipkin/zipkin-go v0.1.6/go.mod h1:QgAqvLzwWbR/WpD4A3cGpPtJrZXNIiJc5AZX7/PBEpw=
github.com/pierrec/lz4 v2.0.5+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
github.com/prometheus/client_golang v0.9.3-0.20190127221311-3c4408c8b829/go.mod h1:p2iRAGwDERtqlqzRXnrOVns+ignqQo//hLXqYxZYVNs=
github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
github.com/prometheus/client_model v0.0.0-20190115171406-56726106282f/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
github.com/prometheus/common v0.2.0/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-20190117184657-bf6a532e95b1/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
github.com/rcrowley/go-metrics v0.0.0-20181016184325-3113b8401b8a/go.mod h1:bCqnVzQkZxMG4s8nGwiZ5l3QUCyqpo9Y+/ZMZ9VjZe4=
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
go.opencensus.io v0.20.1/go.mod h1:6WKK9ahsWS3RSO+PY9ZHZUfv2irvY6gN279GOPZjmmk=
go.opencensus.io v0.20.2 h1:NAfh7zF0/3/HqtMvJNZ/RFrSlCE6ZTlHmKfhL/Dm1Jk=
go.opencensus.io v0.20.2/go.mod h1:6WKK9ahsWS3RSO+PY9ZHZUfv2irvY6gN279GOPZjmmk=
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
golang.org/x/lint v0.0.0-20190301231843-5614ed5bae6f/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181220203305-927f97764cc3/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190125091013-d26f9f9a57f3/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190311183353-d8887717615a h1:oWX7TPOiFAMXLq8o0ikBYfCJVlRHBcsciT5bXOrH628=
golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
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/sync v0.0.0-20180314180146-1d60e4601c6f h1:wMNYb4v58l5UBM7MYRLPG6ZhfOqbKu7X5eyFl8ZhKvA=
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=
golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6 h1:bjcUS9ztw9kFmmIxJInhon/0Is3p+EHBKNgquIzo1OI=
golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181107165924-66b7b1311ac8/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181122145206-62eef0e2fa9b/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a h1:1BGLXjeY4akVXGgbC9HugT3Jv3hCI0z56oJR5vAMgBU=
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/text v0.3.0 h1:g61tztE5qeGQ89tm6NTjjM9VPIm088od1l6aSorWRWg=
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
golang.org/x/tools v0.0.0-20180828015842-6cd1fcedba52/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
golang.org/x/tools v0.0.0-20190312170243-e65039ee4138/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
google.golang.org/api v0.3.1 h1:oJra/lMfmtm13/rgY/8i3MzjFWYXvQIAKjQ3HqofMk8=
google.golang.org/api v0.3.1/go.mod h1:6wY9I6uQWHQ8EM57III9mq/AjF+i8G65rmVagqKMtkk=
google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
google.golang.org/genproto v0.0.0-20190307195333-5fe7a883aa19 h1:Lj2SnHtxkRGJDqnGaSjo+CCdIieEnwVazbOXILwQemk=
google.golang.org/genproto v0.0.0-20190307195333-5fe7a883aa19/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
google.golang.org/grpc v1.17.0/go.mod h1:6QZJwpn2B+Zp71q/5VxRsJ6NXXVCE5NRUHRo+f3cWCs=
google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
google.golang.org/grpc v1.19.1 h1:TrBcJ1yqAl1G++wO39nD/qtgpsW9/1+QGrluyMGEYgM=
google.golang.org/grpc v1.19.1/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
gopkg.in/resty.v1 v1.12.0/go.mod h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo=
gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
gopkg.in/yaml.v2 v2.0.0-20170812160011-eb3733d160e7/go.mod h1:JAlM8MvJe8wmxCU4Bli9HhUf9+ttbYbLASfIpnQbh74=
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
honnef.co/go/tools v0.0.0-20180728063816-88497007e858/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/nodeinfo.go
deleted
100644 → 0
+
0
-
46
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
import
(
"os"
commonpb
"github.com/census-instrumentation/opencensus-proto/gen-go/agent/common/v1"
"go.opencensus.io"
)
// NodeWithStartTime creates a node using nodeName and derives:
// Hostname from the environment
// Pid from the current process
// StartTimestamp from the start time of this process
// Language and library information.
func
NodeWithStartTime
(
nodeName
string
)
*
commonpb
.
Node
{
return
&
commonpb
.
Node
{
Identifier
:
&
commonpb
.
ProcessIdentifier
{
HostName
:
os
.
Getenv
(
"HOSTNAME"
),
Pid
:
uint32
(
os
.
Getpid
()),
StartTimestamp
:
timeToTimestamp
(
startTime
),
},
LibraryInfo
:
&
commonpb
.
LibraryInfo
{
Language
:
commonpb
.
LibraryInfo_GO_LANG
,
ExporterVersion
:
Version
,
CoreLibraryVersion
:
opencensus
.
Version
(),
},
ServiceInfo
:
&
commonpb
.
ServiceInfo
{
Name
:
nodeName
,
},
Attributes
:
make
(
map
[
string
]
string
),
}
}
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/ocagent.go
deleted
100644 → 0
+
0
-
496
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
import
(
"context"
"errors"
"fmt"
"sync"
"time"
"google.golang.org/api/support/bundler"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials"
"google.golang.org/grpc/metadata"
"go.opencensus.io/plugin/ocgrpc"
"go.opencensus.io/resource"
"go.opencensus.io/stats/view"
"go.opencensus.io/trace"
commonpb
"github.com/census-instrumentation/opencensus-proto/gen-go/agent/common/v1"
agentmetricspb
"github.com/census-instrumentation/opencensus-proto/gen-go/agent/metrics/v1"
agenttracepb
"github.com/census-instrumentation/opencensus-proto/gen-go/agent/trace/v1"
metricspb
"github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"
resourcepb
"github.com/census-instrumentation/opencensus-proto/gen-go/resource/v1"
tracepb
"github.com/census-instrumentation/opencensus-proto/gen-go/trace/v1"
)
var
startupMu
sync
.
Mutex
var
startTime
time
.
Time
func
init
()
{
startupMu
.
Lock
()
startTime
=
time
.
Now
()
startupMu
.
Unlock
()
}
var
_
trace
.
Exporter
=
(
*
Exporter
)(
nil
)
var
_
view
.
Exporter
=
(
*
Exporter
)(
nil
)
type
Exporter
struct
{
connectionState
int32
// mu protects the non-atomic and non-channel variables
mu
sync
.
RWMutex
// senderMu protects the concurrent unsafe traceExporter client
senderMu
sync
.
RWMutex
started
bool
stopped
bool
agentAddress
string
serviceName
string
canDialInsecure
bool
traceExporter
agenttracepb
.
TraceService_ExportClient
metricsExporter
agentmetricspb
.
MetricsService_ExportClient
nodeInfo
*
commonpb
.
Node
grpcClientConn
*
grpc
.
ClientConn
reconnectionPeriod
time
.
Duration
resource
*
resourcepb
.
Resource
compressor
string
headers
map
[
string
]
string
startOnce
sync
.
Once
stopCh
chan
bool
disconnectedCh
chan
bool
backgroundConnectionDoneCh
chan
bool
traceBundler
*
bundler
.
Bundler
// viewDataBundler is the bundler to enable conversion
// from OpenCensus-Go view.Data to metricspb.Metric.
// Please do not confuse it with metricsBundler!
viewDataBundler
*
bundler
.
Bundler
clientTransportCredentials
credentials
.
TransportCredentials
}
func
NewExporter
(
opts
...
ExporterOption
)
(
*
Exporter
,
error
)
{
exp
,
err
:=
NewUnstartedExporter
(
opts
...
)
if
err
!=
nil
{
return
nil
,
err
}
if
err
:=
exp
.
Start
();
err
!=
nil
{
return
nil
,
err
}
return
exp
,
nil
}
const
spanDataBufferSize
=
300
func
NewUnstartedExporter
(
opts
...
ExporterOption
)
(
*
Exporter
,
error
)
{
e
:=
new
(
Exporter
)
for
_
,
opt
:=
range
opts
{
opt
.
withExporter
(
e
)
}
traceBundler
:=
bundler
.
NewBundler
((
*
trace
.
SpanData
)(
nil
),
func
(
bundle
interface
{})
{
e
.
uploadTraces
(
bundle
.
([]
*
trace
.
SpanData
))
})
traceBundler
.
DelayThreshold
=
2
*
time
.
Second
traceBundler
.
BundleCountThreshold
=
spanDataBufferSize
e
.
traceBundler
=
traceBundler
viewDataBundler
:=
bundler
.
NewBundler
((
*
view
.
Data
)(
nil
),
func
(
bundle
interface
{})
{
e
.
uploadViewData
(
bundle
.
([]
*
view
.
Data
))
})
viewDataBundler
.
DelayThreshold
=
2
*
time
.
Second
viewDataBundler
.
BundleCountThreshold
=
500
// TODO: (@odeke-em) make this configurable.
e
.
viewDataBundler
=
viewDataBundler
e
.
nodeInfo
=
NodeWithStartTime
(
e
.
serviceName
)
e
.
resource
=
resourceProtoFromEnv
()
return
e
,
nil
}
const
(
maxInitialConfigRetries
=
10
maxInitialTracesRetries
=
10
)
var
(
errAlreadyStarted
=
errors
.
New
(
"already started"
)
errNotStarted
=
errors
.
New
(
"not started"
)
errStopped
=
errors
.
New
(
"stopped"
)
errNoConnection
=
errors
.
New
(
"no active connection"
)
)
// Start dials to the agent, establishing a connection to it. It also
// initiates the Config and Trace services by sending over the initial
// messages that consist of the node identifier. Start invokes a background
// connector that will reattempt connections to the agent periodically
// if the connection dies.
func
(
ae
*
Exporter
)
Start
()
error
{
var
err
=
errAlreadyStarted
ae
.
startOnce
.
Do
(
func
()
{
ae
.
mu
.
Lock
()
defer
ae
.
mu
.
Unlock
()
ae
.
started
=
true
ae
.
disconnectedCh
=
make
(
chan
bool
,
1
)
ae
.
stopCh
=
make
(
chan
bool
)
ae
.
backgroundConnectionDoneCh
=
make
(
chan
bool
)
ae
.
setStateDisconnected
()
go
ae
.
indefiniteBackgroundConnection
()
err
=
nil
})
return
err
}
func
(
ae
*
Exporter
)
prepareAgentAddress
()
string
{
if
ae
.
agentAddress
!=
""
{
return
ae
.
agentAddress
}
return
fmt
.
Sprintf
(
"%s:%d"
,
DefaultAgentHost
,
DefaultAgentPort
)
}
func
(
ae
*
Exporter
)
enableConnectionStreams
(
cc
*
grpc
.
ClientConn
)
error
{
ae
.
mu
.
RLock
()
started
:=
ae
.
started
nodeInfo
:=
ae
.
nodeInfo
ae
.
mu
.
RUnlock
()
if
!
started
{
return
errNotStarted
}
ae
.
mu
.
Lock
()
// If the previous clientConn was non-nil, close it
if
ae
.
grpcClientConn
!=
nil
{
_
=
ae
.
grpcClientConn
.
Close
()
}
ae
.
grpcClientConn
=
cc
ae
.
mu
.
Unlock
()
if
err
:=
ae
.
createTraceServiceConnection
(
ae
.
grpcClientConn
,
nodeInfo
);
err
!=
nil
{
return
err
}
return
ae
.
createMetricsServiceConnection
(
ae
.
grpcClientConn
,
nodeInfo
)
}
func
(
ae
*
Exporter
)
createTraceServiceConnection
(
cc
*
grpc
.
ClientConn
,
node
*
commonpb
.
Node
)
error
{
// Initiate the trace service by sending over node identifier info.
traceSvcClient
:=
agenttracepb
.
NewTraceServiceClient
(
cc
)
ctx
:=
context
.
Background
()
if
len
(
ae
.
headers
)
>
0
{
ctx
=
metadata
.
NewOutgoingContext
(
ctx
,
metadata
.
New
(
ae
.
headers
))
}
traceExporter
,
err
:=
traceSvcClient
.
Export
(
ctx
)
if
err
!=
nil
{
return
fmt
.
Errorf
(
"Exporter.Start:: TraceServiceClient: %v"
,
err
)
}
firstTraceMessage
:=
&
agenttracepb
.
ExportTraceServiceRequest
{
Node
:
node
,
Resource
:
ae
.
resource
,
}
if
err
:=
traceExporter
.
Send
(
firstTraceMessage
);
err
!=
nil
{
return
fmt
.
Errorf
(
"Exporter.Start:: Failed to initiate the Config service: %v"
,
err
)
}
ae
.
mu
.
Lock
()
ae
.
traceExporter
=
traceExporter
ae
.
mu
.
Unlock
()
// Initiate the config service by sending over node identifier info.
configStream
,
err
:=
traceSvcClient
.
Config
(
context
.
Background
())
if
err
!=
nil
{
return
fmt
.
Errorf
(
"Exporter.Start:: ConfigStream: %v"
,
err
)
}
firstCfgMessage
:=
&
agenttracepb
.
CurrentLibraryConfig
{
Node
:
node
}
if
err
:=
configStream
.
Send
(
firstCfgMessage
);
err
!=
nil
{
return
fmt
.
Errorf
(
"Exporter.Start:: Failed to initiate the Config service: %v"
,
err
)
}
// In the background, handle trace configurations that are beamed down
// by the agent, but also reply to it with the applied configuration.
go
ae
.
handleConfigStreaming
(
configStream
)
return
nil
}
func
(
ae
*
Exporter
)
createMetricsServiceConnection
(
cc
*
grpc
.
ClientConn
,
node
*
commonpb
.
Node
)
error
{
metricsSvcClient
:=
agentmetricspb
.
NewMetricsServiceClient
(
cc
)
metricsExporter
,
err
:=
metricsSvcClient
.
Export
(
context
.
Background
())
if
err
!=
nil
{
return
fmt
.
Errorf
(
"MetricsExporter: failed to start the service client: %v"
,
err
)
}
// Initiate the metrics service by sending over the first message just containing the Node and Resource.
firstMetricsMessage
:=
&
agentmetricspb
.
ExportMetricsServiceRequest
{
Node
:
node
,
Resource
:
ae
.
resource
,
}
if
err
:=
metricsExporter
.
Send
(
firstMetricsMessage
);
err
!=
nil
{
return
fmt
.
Errorf
(
"MetricsExporter:: failed to send the first message: %v"
,
err
)
}
ae
.
mu
.
Lock
()
ae
.
metricsExporter
=
metricsExporter
ae
.
mu
.
Unlock
()
// With that we are good to go and can start sending metrics
return
nil
}
func
(
ae
*
Exporter
)
dialToAgent
()
(
*
grpc
.
ClientConn
,
error
)
{
addr
:=
ae
.
prepareAgentAddress
()
var
dialOpts
[]
grpc
.
DialOption
if
ae
.
clientTransportCredentials
!=
nil
{
dialOpts
=
append
(
dialOpts
,
grpc
.
WithTransportCredentials
(
ae
.
clientTransportCredentials
))
}
else
if
ae
.
canDialInsecure
{
dialOpts
=
append
(
dialOpts
,
grpc
.
WithInsecure
())
}
if
ae
.
compressor
!=
""
{
dialOpts
=
append
(
dialOpts
,
grpc
.
WithDefaultCallOptions
(
grpc
.
UseCompressor
(
ae
.
compressor
)))
}
dialOpts
=
append
(
dialOpts
,
grpc
.
WithStatsHandler
(
&
ocgrpc
.
ClientHandler
{}))
ctx
:=
context
.
Background
()
if
len
(
ae
.
headers
)
>
0
{
ctx
=
metadata
.
NewOutgoingContext
(
ctx
,
metadata
.
New
(
ae
.
headers
))
}
return
grpc
.
DialContext
(
ctx
,
addr
,
dialOpts
...
)
}
func
(
ae
*
Exporter
)
handleConfigStreaming
(
configStream
agenttracepb
.
TraceService_ConfigClient
)
error
{
// Note: We haven't yet implemented configuration sending so we
// should NOT be changing connection states within this function for now.
for
{
recv
,
err
:=
configStream
.
Recv
()
if
err
!=
nil
{
// TODO: Check if this is a transient error or exponential backoff-able.
return
err
}
cfg
:=
recv
.
Config
if
cfg
==
nil
{
continue
}
// Otherwise now apply the trace configuration sent down from the agent
if
psamp
:=
cfg
.
GetProbabilitySampler
();
psamp
!=
nil
{
trace
.
ApplyConfig
(
trace
.
Config
{
DefaultSampler
:
trace
.
ProbabilitySampler
(
psamp
.
SamplingProbability
)})
}
else
if
csamp
:=
cfg
.
GetConstantSampler
();
csamp
!=
nil
{
alwaysSample
:=
csamp
.
Decision
==
tracepb
.
ConstantSampler_ALWAYS_ON
if
alwaysSample
{
trace
.
ApplyConfig
(
trace
.
Config
{
DefaultSampler
:
trace
.
AlwaysSample
()})
}
else
{
trace
.
ApplyConfig
(
trace
.
Config
{
DefaultSampler
:
trace
.
NeverSample
()})
}
}
else
{
// TODO: Add the rate limiting sampler here
}
// Then finally send back to upstream the newly applied configuration
err
=
configStream
.
Send
(
&
agenttracepb
.
CurrentLibraryConfig
{
Config
:
&
tracepb
.
TraceConfig
{
Sampler
:
cfg
.
Sampler
}})
if
err
!=
nil
{
return
err
}
}
}
// Stop shuts down all the connections and resources
// related to the exporter.
func
(
ae
*
Exporter
)
Stop
()
error
{
ae
.
mu
.
RLock
()
cc
:=
ae
.
grpcClientConn
started
:=
ae
.
started
stopped
:=
ae
.
stopped
ae
.
mu
.
RUnlock
()
if
!
started
{
return
errNotStarted
}
if
stopped
{
// TODO: tell the user that we've already stopped, so perhaps a sentinel error?
return
nil
}
ae
.
Flush
()
// Now close the underlying gRPC connection.
var
err
error
if
cc
!=
nil
{
err
=
cc
.
Close
()
}
// At this point we can change the state variables: started and stopped
ae
.
mu
.
Lock
()
ae
.
started
=
false
ae
.
stopped
=
true
ae
.
mu
.
Unlock
()
close
(
ae
.
stopCh
)
// Ensure that the backgroundConnector returns
<-
ae
.
backgroundConnectionDoneCh
return
err
}
func
(
ae
*
Exporter
)
ExportSpan
(
sd
*
trace
.
SpanData
)
{
if
sd
==
nil
{
return
}
_
=
ae
.
traceBundler
.
Add
(
sd
,
1
)
}
func
(
ae
*
Exporter
)
ExportTraceServiceRequest
(
batch
*
agenttracepb
.
ExportTraceServiceRequest
)
error
{
if
batch
==
nil
||
len
(
batch
.
Spans
)
==
0
{
return
nil
}
select
{
case
<-
ae
.
stopCh
:
return
errStopped
default
:
if
!
ae
.
connected
()
{
return
errNoConnection
}
ae
.
senderMu
.
Lock
()
err
:=
ae
.
traceExporter
.
Send
(
batch
)
ae
.
senderMu
.
Unlock
()
if
err
!=
nil
{
ae
.
setStateDisconnected
()
return
err
}
return
nil
}
}
func
(
ae
*
Exporter
)
ExportView
(
vd
*
view
.
Data
)
{
if
vd
==
nil
{
return
}
_
=
ae
.
viewDataBundler
.
Add
(
vd
,
1
)
}
func
ocSpanDataToPbSpans
(
sdl
[]
*
trace
.
SpanData
)
[]
*
tracepb
.
Span
{
if
len
(
sdl
)
==
0
{
return
nil
}
protoSpans
:=
make
([]
*
tracepb
.
Span
,
0
,
len
(
sdl
))
for
_
,
sd
:=
range
sdl
{
if
sd
!=
nil
{
protoSpans
=
append
(
protoSpans
,
ocSpanToProtoSpan
(
sd
))
}
}
return
protoSpans
}
func
(
ae
*
Exporter
)
uploadTraces
(
sdl
[]
*
trace
.
SpanData
)
{
select
{
case
<-
ae
.
stopCh
:
return
default
:
if
!
ae
.
connected
()
{
return
}
protoSpans
:=
ocSpanDataToPbSpans
(
sdl
)
if
len
(
protoSpans
)
==
0
{
return
}
ae
.
senderMu
.
Lock
()
err
:=
ae
.
traceExporter
.
Send
(
&
agenttracepb
.
ExportTraceServiceRequest
{
Spans
:
protoSpans
,
})
ae
.
senderMu
.
Unlock
()
if
err
!=
nil
{
ae
.
setStateDisconnected
()
}
}
}
func
ocViewDataToPbMetrics
(
vdl
[]
*
view
.
Data
)
[]
*
metricspb
.
Metric
{
if
len
(
vdl
)
==
0
{
return
nil
}
metrics
:=
make
([]
*
metricspb
.
Metric
,
0
,
len
(
vdl
))
for
_
,
vd
:=
range
vdl
{
if
vd
!=
nil
{
vmetric
,
err
:=
viewDataToMetric
(
vd
)
// TODO: (@odeke-em) somehow report this error, if it is non-nil.
if
err
==
nil
&&
vmetric
!=
nil
{
metrics
=
append
(
metrics
,
vmetric
)
}
}
}
return
metrics
}
func
(
ae
*
Exporter
)
uploadViewData
(
vdl
[]
*
view
.
Data
)
{
select
{
case
<-
ae
.
stopCh
:
return
default
:
if
!
ae
.
connected
()
{
return
}
protoMetrics
:=
ocViewDataToPbMetrics
(
vdl
)
if
len
(
protoMetrics
)
==
0
{
return
}
err
:=
ae
.
metricsExporter
.
Send
(
&
agentmetricspb
.
ExportMetricsServiceRequest
{
Metrics
:
protoMetrics
,
// TODO:(@odeke-em)
// a) Figure out how to derive a Node from the environment
// b) Figure out how to derive a Resource from the environment
// or better letting users of the exporter configure it.
})
if
err
!=
nil
{
ae
.
setStateDisconnected
()
}
}
}
func
(
ae
*
Exporter
)
Flush
()
{
ae
.
traceBundler
.
Flush
()
ae
.
viewDataBundler
.
Flush
()
}
func
resourceProtoFromEnv
()
*
resourcepb
.
Resource
{
rs
,
_
:=
resource
.
FromEnv
(
context
.
Background
())
if
rs
==
nil
{
return
nil
}
rprs
:=
&
resourcepb
.
Resource
{
Type
:
rs
.
Type
,
}
if
rs
.
Labels
!=
nil
{
rprs
.
Labels
=
make
(
map
[
string
]
string
)
for
k
,
v
:=
range
rs
.
Labels
{
rprs
.
Labels
[
k
]
=
v
}
}
return
rprs
}
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/options.go
deleted
100644 → 0
+
0
-
128
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
import
(
"time"
"google.golang.org/grpc/credentials"
)
const
(
DefaultAgentPort
uint16
=
55678
DefaultAgentHost
string
=
"localhost"
)
type
ExporterOption
interface
{
withExporter
(
e
*
Exporter
)
}
type
insecureGrpcConnection
int
var
_
ExporterOption
=
(
*
insecureGrpcConnection
)(
nil
)
func
(
igc
*
insecureGrpcConnection
)
withExporter
(
e
*
Exporter
)
{
e
.
canDialInsecure
=
true
}
// WithInsecure disables client transport security for the exporter's gRPC connection
// just like grpc.WithInsecure() https://godoc.org/google.golang.org/grpc#WithInsecure
// does. Note, by default, client security is required unless WithInsecure is used.
func
WithInsecure
()
ExporterOption
{
return
new
(
insecureGrpcConnection
)
}
type
addressSetter
string
func
(
as
addressSetter
)
withExporter
(
e
*
Exporter
)
{
e
.
agentAddress
=
string
(
as
)
}
var
_
ExporterOption
=
(
*
addressSetter
)(
nil
)
// WithAddress allows one to set the address that the exporter will
// connect to the agent on. If unset, it will instead try to use
// connect to DefaultAgentHost:DefaultAgentPort
func
WithAddress
(
addr
string
)
ExporterOption
{
return
addressSetter
(
addr
)
}
type
serviceNameSetter
string
func
(
sns
serviceNameSetter
)
withExporter
(
e
*
Exporter
)
{
e
.
serviceName
=
string
(
sns
)
}
var
_
ExporterOption
=
(
*
serviceNameSetter
)(
nil
)
// WithServiceName allows one to set/override the service name
// that the exporter will report to the agent.
func
WithServiceName
(
serviceName
string
)
ExporterOption
{
return
serviceNameSetter
(
serviceName
)
}
type
reconnectionPeriod
time
.
Duration
func
(
rp
reconnectionPeriod
)
withExporter
(
e
*
Exporter
)
{
e
.
reconnectionPeriod
=
time
.
Duration
(
rp
)
}
func
WithReconnectionPeriod
(
rp
time
.
Duration
)
ExporterOption
{
return
reconnectionPeriod
(
rp
)
}
type
compressorSetter
string
func
(
c
compressorSetter
)
withExporter
(
e
*
Exporter
)
{
e
.
compressor
=
string
(
c
)
}
// UseCompressor will set the compressor for the gRPC client to use when sending requests.
// It is the responsibility of the caller to ensure that the compressor set has been registered
// with google.golang.org/grpc/encoding. This can be done by encoding.RegisterCompressor. Some
// compressors auto-register on import, such as gzip, which can be registered by calling
// `import _ "google.golang.org/grpc/encoding/gzip"`
func
UseCompressor
(
compressorName
string
)
ExporterOption
{
return
compressorSetter
(
compressorName
)
}
type
headerSetter
map
[
string
]
string
func
(
h
headerSetter
)
withExporter
(
e
*
Exporter
)
{
e
.
headers
=
map
[
string
]
string
(
h
)
}
// WithHeaders will send the provided headers when the gRPC stream connection
// is instantiated
func
WithHeaders
(
headers
map
[
string
]
string
)
ExporterOption
{
return
headerSetter
(
headers
)
}
type
clientCredentials
struct
{
credentials
.
TransportCredentials
}
var
_
ExporterOption
=
(
*
clientCredentials
)(
nil
)
// WithTLSCredentials allows the connection to use TLS credentials
// when talking to the server. It takes in grpc.TransportCredentials instead
// of say a Certificate file or a tls.Certificate, because the retrieving
// these credentials can be done in many ways e.g. plain file, in code tls.Config
// or by certificate rotation, so it is up to the caller to decide what to use.
func
WithTLSCredentials
(
creds
credentials
.
TransportCredentials
)
ExporterOption
{
return
&
clientCredentials
{
TransportCredentials
:
creds
}
}
func
(
cc
*
clientCredentials
)
withExporter
(
e
*
Exporter
)
{
e
.
clientTransportCredentials
=
cc
.
TransportCredentials
}
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/transform_spans.go
deleted
100644 → 0
+
0
-
248
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
import
(
"math"
"time"
"go.opencensus.io/trace"
"go.opencensus.io/trace/tracestate"
tracepb
"github.com/census-instrumentation/opencensus-proto/gen-go/trace/v1"
"github.com/golang/protobuf/ptypes/timestamp"
)
const
(
maxAnnotationEventsPerSpan
=
32
maxMessageEventsPerSpan
=
128
)
func
ocSpanToProtoSpan
(
sd
*
trace
.
SpanData
)
*
tracepb
.
Span
{
if
sd
==
nil
{
return
nil
}
var
namePtr
*
tracepb
.
TruncatableString
if
sd
.
Name
!=
""
{
namePtr
=
&
tracepb
.
TruncatableString
{
Value
:
sd
.
Name
}
}
return
&
tracepb
.
Span
{
TraceId
:
sd
.
TraceID
[
:
],
SpanId
:
sd
.
SpanID
[
:
],
ParentSpanId
:
sd
.
ParentSpanID
[
:
],
Status
:
ocStatusToProtoStatus
(
sd
.
Status
),
StartTime
:
timeToTimestamp
(
sd
.
StartTime
),
EndTime
:
timeToTimestamp
(
sd
.
EndTime
),
Links
:
ocLinksToProtoLinks
(
sd
.
Links
),
Kind
:
ocSpanKindToProtoSpanKind
(
sd
.
SpanKind
),
Name
:
namePtr
,
Attributes
:
ocAttributesToProtoAttributes
(
sd
.
Attributes
),
TimeEvents
:
ocTimeEventsToProtoTimeEvents
(
sd
.
Annotations
,
sd
.
MessageEvents
),
Tracestate
:
ocTracestateToProtoTracestate
(
sd
.
Tracestate
),
}
}
var
blankStatus
trace
.
Status
func
ocStatusToProtoStatus
(
status
trace
.
Status
)
*
tracepb
.
Status
{
if
status
==
blankStatus
{
return
nil
}
return
&
tracepb
.
Status
{
Code
:
status
.
Code
,
Message
:
status
.
Message
,
}
}
func
ocLinksToProtoLinks
(
links
[]
trace
.
Link
)
*
tracepb
.
Span_Links
{
if
len
(
links
)
==
0
{
return
nil
}
sl
:=
make
([]
*
tracepb
.
Span_Link
,
0
,
len
(
links
))
for
_
,
ocLink
:=
range
links
{
// This redefinition is necessary to prevent ocLink.*ID[:] copies
// being reused -- in short we need a new ocLink per iteration.
ocLink
:=
ocLink
sl
=
append
(
sl
,
&
tracepb
.
Span_Link
{
TraceId
:
ocLink
.
TraceID
[
:
],
SpanId
:
ocLink
.
SpanID
[
:
],
Type
:
ocLinkTypeToProtoLinkType
(
ocLink
.
Type
),
})
}
return
&
tracepb
.
Span_Links
{
Link
:
sl
,
}
}
func
ocLinkTypeToProtoLinkType
(
oct
trace
.
LinkType
)
tracepb
.
Span_Link_Type
{
switch
oct
{
case
trace
.
LinkTypeChild
:
return
tracepb
.
Span_Link_CHILD_LINKED_SPAN
case
trace
.
LinkTypeParent
:
return
tracepb
.
Span_Link_PARENT_LINKED_SPAN
default
:
return
tracepb
.
Span_Link_TYPE_UNSPECIFIED
}
}
func
ocAttributesToProtoAttributes
(
attrs
map
[
string
]
interface
{})
*
tracepb
.
Span_Attributes
{
if
len
(
attrs
)
==
0
{
return
nil
}
outMap
:=
make
(
map
[
string
]
*
tracepb
.
AttributeValue
)
for
k
,
v
:=
range
attrs
{
switch
v
:=
v
.
(
type
)
{
case
bool
:
outMap
[
k
]
=
&
tracepb
.
AttributeValue
{
Value
:
&
tracepb
.
AttributeValue_BoolValue
{
BoolValue
:
v
}}
case
int
:
outMap
[
k
]
=
&
tracepb
.
AttributeValue
{
Value
:
&
tracepb
.
AttributeValue_IntValue
{
IntValue
:
int64
(
v
)}}
case
int64
:
outMap
[
k
]
=
&
tracepb
.
AttributeValue
{
Value
:
&
tracepb
.
AttributeValue_IntValue
{
IntValue
:
v
}}
case
string
:
outMap
[
k
]
=
&
tracepb
.
AttributeValue
{
Value
:
&
tracepb
.
AttributeValue_StringValue
{
StringValue
:
&
tracepb
.
TruncatableString
{
Value
:
v
},
},
}
}
}
return
&
tracepb
.
Span_Attributes
{
AttributeMap
:
outMap
,
}
}
// This code is mostly copied from
// https://github.com/census-ecosystem/opencensus-go-exporter-stackdriver/blob/master/trace_proto.go#L46
func
ocTimeEventsToProtoTimeEvents
(
as
[]
trace
.
Annotation
,
es
[]
trace
.
MessageEvent
)
*
tracepb
.
Span_TimeEvents
{
if
len
(
as
)
==
0
&&
len
(
es
)
==
0
{
return
nil
}
timeEvents
:=
&
tracepb
.
Span_TimeEvents
{}
var
annotations
,
droppedAnnotationsCount
int
var
messageEvents
,
droppedMessageEventsCount
int
// Transform annotations
for
i
,
a
:=
range
as
{
if
annotations
>=
maxAnnotationEventsPerSpan
{
droppedAnnotationsCount
=
len
(
as
)
-
i
break
}
annotations
++
timeEvents
.
TimeEvent
=
append
(
timeEvents
.
TimeEvent
,
&
tracepb
.
Span_TimeEvent
{
Time
:
timeToTimestamp
(
a
.
Time
),
Value
:
transformAnnotationToTimeEvent
(
&
a
),
},
)
}
// Transform message events
for
i
,
e
:=
range
es
{
if
messageEvents
>=
maxMessageEventsPerSpan
{
droppedMessageEventsCount
=
len
(
es
)
-
i
break
}
messageEvents
++
timeEvents
.
TimeEvent
=
append
(
timeEvents
.
TimeEvent
,
&
tracepb
.
Span_TimeEvent
{
Time
:
timeToTimestamp
(
e
.
Time
),
Value
:
transformMessageEventToTimeEvent
(
&
e
),
},
)
}
// Process dropped counter
timeEvents
.
DroppedAnnotationsCount
=
clip32
(
droppedAnnotationsCount
)
timeEvents
.
DroppedMessageEventsCount
=
clip32
(
droppedMessageEventsCount
)
return
timeEvents
}
func
transformAnnotationToTimeEvent
(
a
*
trace
.
Annotation
)
*
tracepb
.
Span_TimeEvent_Annotation_
{
return
&
tracepb
.
Span_TimeEvent_Annotation_
{
Annotation
:
&
tracepb
.
Span_TimeEvent_Annotation
{
Description
:
&
tracepb
.
TruncatableString
{
Value
:
a
.
Message
},
Attributes
:
ocAttributesToProtoAttributes
(
a
.
Attributes
),
},
}
}
func
transformMessageEventToTimeEvent
(
e
*
trace
.
MessageEvent
)
*
tracepb
.
Span_TimeEvent_MessageEvent_
{
return
&
tracepb
.
Span_TimeEvent_MessageEvent_
{
MessageEvent
:
&
tracepb
.
Span_TimeEvent_MessageEvent
{
Type
:
tracepb
.
Span_TimeEvent_MessageEvent_Type
(
e
.
EventType
),
Id
:
uint64
(
e
.
MessageID
),
UncompressedSize
:
uint64
(
e
.
UncompressedByteSize
),
CompressedSize
:
uint64
(
e
.
CompressedByteSize
),
},
}
}
// clip32 clips an int to the range of an int32.
func
clip32
(
x
int
)
int32
{
if
x
<
math
.
MinInt32
{
return
math
.
MinInt32
}
if
x
>
math
.
MaxInt32
{
return
math
.
MaxInt32
}
return
int32
(
x
)
}
func
timeToTimestamp
(
t
time
.
Time
)
*
timestamp
.
Timestamp
{
nanoTime
:=
t
.
UnixNano
()
return
&
timestamp
.
Timestamp
{
Seconds
:
nanoTime
/
1e9
,
Nanos
:
int32
(
nanoTime
%
1e9
),
}
}
func
ocSpanKindToProtoSpanKind
(
kind
int
)
tracepb
.
Span_SpanKind
{
switch
kind
{
case
trace
.
SpanKindClient
:
return
tracepb
.
Span_CLIENT
case
trace
.
SpanKindServer
:
return
tracepb
.
Span_SERVER
default
:
return
tracepb
.
Span_SPAN_KIND_UNSPECIFIED
}
}
func
ocTracestateToProtoTracestate
(
ts
*
tracestate
.
Tracestate
)
*
tracepb
.
Span_Tracestate
{
if
ts
==
nil
{
return
nil
}
return
&
tracepb
.
Span_Tracestate
{
Entries
:
ocTracestateEntriesToProtoTracestateEntries
(
ts
.
Entries
()),
}
}
func
ocTracestateEntriesToProtoTracestateEntries
(
entries
[]
tracestate
.
Entry
)
[]
*
tracepb
.
Span_Tracestate_Entry
{
protoEntries
:=
make
([]
*
tracepb
.
Span_Tracestate_Entry
,
0
,
len
(
entries
))
for
_
,
entry
:=
range
entries
{
protoEntries
=
append
(
protoEntries
,
&
tracepb
.
Span_Tracestate_Entry
{
Key
:
entry
.
Key
,
Value
:
entry
.
Value
,
})
}
return
protoEntries
}
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/transform_stats_to_metrics.go
deleted
100644 → 0
+
0
-
274
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
import
(
"errors"
"time"
"go.opencensus.io/stats"
"go.opencensus.io/stats/view"
"go.opencensus.io/tag"
"github.com/golang/protobuf/ptypes/timestamp"
metricspb
"github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"
)
var
(
errNilMeasure
=
errors
.
New
(
"expecting a non-nil stats.Measure"
)
errNilView
=
errors
.
New
(
"expecting a non-nil view.View"
)
errNilViewData
=
errors
.
New
(
"expecting a non-nil view.Data"
)
)
func
viewDataToMetric
(
vd
*
view
.
Data
)
(
*
metricspb
.
Metric
,
error
)
{
if
vd
==
nil
{
return
nil
,
errNilViewData
}
descriptor
,
err
:=
viewToMetricDescriptor
(
vd
.
View
)
if
err
!=
nil
{
return
nil
,
err
}
timeseries
,
err
:=
viewDataToTimeseries
(
vd
)
if
err
!=
nil
{
return
nil
,
err
}
metric
:=
&
metricspb
.
Metric
{
MetricDescriptor
:
descriptor
,
Timeseries
:
timeseries
,
}
return
metric
,
nil
}
func
viewToMetricDescriptor
(
v
*
view
.
View
)
(
*
metricspb
.
MetricDescriptor
,
error
)
{
if
v
==
nil
{
return
nil
,
errNilView
}
if
v
.
Measure
==
nil
{
return
nil
,
errNilMeasure
}
desc
:=
&
metricspb
.
MetricDescriptor
{
Name
:
stringOrCall
(
v
.
Name
,
v
.
Measure
.
Name
),
Description
:
stringOrCall
(
v
.
Description
,
v
.
Measure
.
Description
),
Unit
:
v
.
Measure
.
Unit
(),
Type
:
aggregationToMetricDescriptorType
(
v
),
LabelKeys
:
tagKeysToLabelKeys
(
v
.
TagKeys
),
}
return
desc
,
nil
}
func
stringOrCall
(
first
string
,
call
func
()
string
)
string
{
if
first
!=
""
{
return
first
}
return
call
()
}
type
measureType
uint
const
(
measureUnknown
measureType
=
iota
measureInt64
measureFloat64
)
func
measureTypeFromMeasure
(
m
stats
.
Measure
)
measureType
{
switch
m
.
(
type
)
{
default
:
return
measureUnknown
case
*
stats
.
Float64Measure
:
return
measureFloat64
case
*
stats
.
Int64Measure
:
return
measureInt64
}
}
func
aggregationToMetricDescriptorType
(
v
*
view
.
View
)
metricspb
.
MetricDescriptor_Type
{
if
v
==
nil
||
v
.
Aggregation
==
nil
{
return
metricspb
.
MetricDescriptor_UNSPECIFIED
}
if
v
.
Measure
==
nil
{
return
metricspb
.
MetricDescriptor_UNSPECIFIED
}
switch
v
.
Aggregation
.
Type
{
case
view
.
AggTypeCount
:
// Cumulative on int64
return
metricspb
.
MetricDescriptor_CUMULATIVE_INT64
case
view
.
AggTypeDistribution
:
// Cumulative types
return
metricspb
.
MetricDescriptor_CUMULATIVE_DISTRIBUTION
case
view
.
AggTypeLastValue
:
// Gauge types
switch
measureTypeFromMeasure
(
v
.
Measure
)
{
case
measureFloat64
:
return
metricspb
.
MetricDescriptor_GAUGE_DOUBLE
case
measureInt64
:
return
metricspb
.
MetricDescriptor_GAUGE_INT64
}
case
view
.
AggTypeSum
:
// Cumulative types
switch
measureTypeFromMeasure
(
v
.
Measure
)
{
case
measureFloat64
:
return
metricspb
.
MetricDescriptor_CUMULATIVE_DOUBLE
case
measureInt64
:
return
metricspb
.
MetricDescriptor_CUMULATIVE_INT64
}
}
// For all other cases, return unspecified.
return
metricspb
.
MetricDescriptor_UNSPECIFIED
}
func
tagKeysToLabelKeys
(
tagKeys
[]
tag
.
Key
)
[]
*
metricspb
.
LabelKey
{
labelKeys
:=
make
([]
*
metricspb
.
LabelKey
,
0
,
len
(
tagKeys
))
for
_
,
tagKey
:=
range
tagKeys
{
labelKeys
=
append
(
labelKeys
,
&
metricspb
.
LabelKey
{
Key
:
tagKey
.
Name
(),
})
}
return
labelKeys
}
func
viewDataToTimeseries
(
vd
*
view
.
Data
)
([]
*
metricspb
.
TimeSeries
,
error
)
{
if
vd
==
nil
||
len
(
vd
.
Rows
)
==
0
{
return
nil
,
nil
}
// Given that view.Data only contains Start, End
// the timestamps for all the row data will be the exact same
// per aggregation. However, the values will differ.
// Each row has its own tags.
startTimestamp
:=
timeToProtoTimestamp
(
vd
.
Start
)
endTimestamp
:=
timeToProtoTimestamp
(
vd
.
End
)
mType
:=
measureTypeFromMeasure
(
vd
.
View
.
Measure
)
timeseries
:=
make
([]
*
metricspb
.
TimeSeries
,
0
,
len
(
vd
.
Rows
))
// It is imperative that the ordering of "LabelValues" matches those
// of the Label keys in the metric descriptor.
for
_
,
row
:=
range
vd
.
Rows
{
labelValues
:=
labelValuesFromTags
(
row
.
Tags
)
point
:=
rowToPoint
(
vd
.
View
,
row
,
endTimestamp
,
mType
)
timeseries
=
append
(
timeseries
,
&
metricspb
.
TimeSeries
{
StartTimestamp
:
startTimestamp
,
LabelValues
:
labelValues
,
Points
:
[]
*
metricspb
.
Point
{
point
},
})
}
if
len
(
timeseries
)
==
0
{
return
nil
,
nil
}
return
timeseries
,
nil
}
func
timeToProtoTimestamp
(
t
time
.
Time
)
*
timestamp
.
Timestamp
{
unixNano
:=
t
.
UnixNano
()
return
&
timestamp
.
Timestamp
{
Seconds
:
int64
(
unixNano
/
1e9
),
Nanos
:
int32
(
unixNano
%
1e9
),
}
}
func
rowToPoint
(
v
*
view
.
View
,
row
*
view
.
Row
,
endTimestamp
*
timestamp
.
Timestamp
,
mType
measureType
)
*
metricspb
.
Point
{
pt
:=
&
metricspb
.
Point
{
Timestamp
:
endTimestamp
,
}
switch
data
:=
row
.
Data
.
(
type
)
{
case
*
view
.
CountData
:
pt
.
Value
=
&
metricspb
.
Point_Int64Value
{
Int64Value
:
data
.
Value
}
case
*
view
.
DistributionData
:
pt
.
Value
=
&
metricspb
.
Point_DistributionValue
{
DistributionValue
:
&
metricspb
.
DistributionValue
{
Count
:
data
.
Count
,
Sum
:
float64
(
data
.
Count
)
*
data
.
Mean
,
// because Mean := Sum/Count
// TODO: Add Exemplar
Buckets
:
bucketsToProtoBuckets
(
data
.
CountPerBucket
),
BucketOptions
:
&
metricspb
.
DistributionValue_BucketOptions
{
Type
:
&
metricspb
.
DistributionValue_BucketOptions_Explicit_
{
Explicit
:
&
metricspb
.
DistributionValue_BucketOptions_Explicit
{
Bounds
:
v
.
Aggregation
.
Buckets
,
},
},
},
SumOfSquaredDeviation
:
data
.
SumOfSquaredDev
,
}}
case
*
view
.
LastValueData
:
setPointValue
(
pt
,
data
.
Value
,
mType
)
case
*
view
.
SumData
:
setPointValue
(
pt
,
data
.
Value
,
mType
)
}
return
pt
}
// Not returning anything from this function because metricspb.Point.is_Value is an unexported
// interface hence we just have to set its value by pointer.
func
setPointValue
(
pt
*
metricspb
.
Point
,
value
float64
,
mType
measureType
)
{
if
mType
==
measureInt64
{
pt
.
Value
=
&
metricspb
.
Point_Int64Value
{
Int64Value
:
int64
(
value
)}
}
else
{
pt
.
Value
=
&
metricspb
.
Point_DoubleValue
{
DoubleValue
:
value
}
}
}
func
bucketsToProtoBuckets
(
countPerBucket
[]
int64
)
[]
*
metricspb
.
DistributionValue_Bucket
{
distBuckets
:=
make
([]
*
metricspb
.
DistributionValue_Bucket
,
len
(
countPerBucket
))
for
i
:=
0
;
i
<
len
(
countPerBucket
);
i
++
{
count
:=
countPerBucket
[
i
]
distBuckets
[
i
]
=
&
metricspb
.
DistributionValue_Bucket
{
Count
:
count
,
}
}
return
distBuckets
}
func
labelValuesFromTags
(
tags
[]
tag
.
Tag
)
[]
*
metricspb
.
LabelValue
{
if
len
(
tags
)
==
0
{
return
nil
}
labelValues
:=
make
([]
*
metricspb
.
LabelValue
,
0
,
len
(
tags
))
for
_
,
tag_
:=
range
tags
{
labelValues
=
append
(
labelValues
,
&
metricspb
.
LabelValue
{
Value
:
tag_
.
Value
,
// It is imperative that we set the "HasValue" attribute,
// in order to distinguish missing a label from the empty string.
// https://godoc.org/github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1#LabelValue.HasValue
//
// OpenCensus-Go uses non-pointers for tags as seen by this function's arguments,
// so the best case that we can use to distinguish missing labels/tags from the
// empty string is by checking if the Tag.Key.Name() != "" to indicate that we have
// a value.
HasValue
:
tag_
.
Key
.
Name
()
!=
""
,
})
}
return
labelValues
}
This diff is collapsed.
Click to expand it.
vendor/contrib.go.opencensus.io/exporter/ocagent/version.go
deleted
100644 → 0
+
0
-
17
View file @
273b6689
// Copyright 2018, OpenCensus Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package
ocagent
const
Version
=
"0.0.1"
This diff is collapsed.
Click to expand it.
vendor/github.com/Azure/azure-sdk-for-go/services/resources/mgmt/2016-02-01/resources/deploymentoperations.go
+
4
-
4
View file @
dee450cf
...
...
@@ -111,8 +111,8 @@ func (client DeploymentOperationsClient) GetPreparer(ctx context.Context, resour
// GetSender sends the Get request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentOperationsClient
)
GetSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// GetResponder handles the response to the Get request. The method always
...
...
@@ -201,8 +201,8 @@ func (client DeploymentOperationsClient) ListPreparer(ctx context.Context, resou
// ListSender sends the List request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentOperationsClient
)
ListSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// ListResponder handles the response to the List request. The method always
...
...
This diff is collapsed.
Click to expand it.
vendor/github.com/Azure/azure-sdk-for-go/services/resources/mgmt/2016-02-01/resources/deployments.go
+
16
-
16
View file @
dee450cf
...
...
@@ -109,8 +109,8 @@ func (client DeploymentsClient) CancelPreparer(ctx context.Context, resourceGrou
// CancelSender sends the Cancel request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
CancelSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// CancelResponder handles the response to the Cancel request. The method always
...
...
@@ -193,8 +193,8 @@ func (client DeploymentsClient) CheckExistencePreparer(ctx context.Context, reso
// CheckExistenceSender sends the CheckExistence request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
CheckExistenceSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// CheckExistenceResponder handles the response to the CheckExistence request. The method always
...
...
@@ -281,9 +281,9 @@ func (client DeploymentsClient) CreateOrUpdatePreparer(ctx context.Context, reso
// CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
CreateOrUpdateSender
(
req
*
http
.
Request
)
(
future
DeploymentsCreateOrUpdateFuture
,
err
error
)
{
sd
:=
autorest
.
GetSendDecorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
var
resp
*
http
.
Response
resp
,
err
=
autorest
.
SendWithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
))
resp
,
err
=
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
if
err
!=
nil
{
return
}
...
...
@@ -366,9 +366,9 @@ func (client DeploymentsClient) DeletePreparer(ctx context.Context, resourceGrou
// DeleteSender sends the Delete request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
DeleteSender
(
req
*
http
.
Request
)
(
future
DeploymentsDeleteFuture
,
err
error
)
{
sd
:=
autorest
.
GetSendDecorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
var
resp
*
http
.
Response
resp
,
err
=
autorest
.
SendWithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
))
resp
,
err
=
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
if
err
!=
nil
{
return
}
...
...
@@ -456,8 +456,8 @@ func (client DeploymentsClient) ExportTemplatePreparer(ctx context.Context, reso
// ExportTemplateSender sends the ExportTemplate request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
ExportTemplateSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// ExportTemplateResponder handles the response to the ExportTemplate request. The method always
...
...
@@ -541,8 +541,8 @@ func (client DeploymentsClient) GetPreparer(ctx context.Context, resourceGroupNa
// GetSender sends the Get request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
GetSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// GetResponder handles the response to the Get request. The method always
...
...
@@ -633,8 +633,8 @@ func (client DeploymentsClient) ListPreparer(ctx context.Context, resourceGroupN
// ListSender sends the List request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
ListSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// ListResponder handles the response to the List request. The method always
...
...
@@ -765,8 +765,8 @@ func (client DeploymentsClient) ValidatePreparer(ctx context.Context, resourceGr
// ValidateSender sends the Validate request. The method will close the
// http.Response Body if it receives an error.
func
(
client
DeploymentsClient
)
ValidateSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// ValidateResponder handles the response to the Validate request. The method always
...
...
This diff is collapsed.
Click to expand it.
vendor/github.com/Azure/azure-sdk-for-go/services/resources/mgmt/2016-02-01/resources/groups.go
+
16
-
16
View file @
dee450cf
...
...
@@ -107,8 +107,8 @@ func (client GroupsClient) CheckExistencePreparer(ctx context.Context, resourceG
// CheckExistenceSender sends the CheckExistence request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
CheckExistenceSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// CheckExistenceResponder handles the response to the CheckExistence request. The method always
...
...
@@ -195,8 +195,8 @@ func (client GroupsClient) CreateOrUpdatePreparer(ctx context.Context, resourceG
// CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
CreateOrUpdateSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always
...
...
@@ -272,9 +272,9 @@ func (client GroupsClient) DeletePreparer(ctx context.Context, resourceGroupName
// DeleteSender sends the Delete request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
DeleteSender
(
req
*
http
.
Request
)
(
future
GroupsDeleteFuture
,
err
error
)
{
sd
:=
autorest
.
GetSendDecorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
var
resp
*
http
.
Response
resp
,
err
=
autorest
.
SendWithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
))
resp
,
err
=
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
if
err
!=
nil
{
return
}
...
...
@@ -363,8 +363,8 @@ func (client GroupsClient) ExportTemplatePreparer(ctx context.Context, resourceG
// ExportTemplateSender sends the ExportTemplate request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
ExportTemplateSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// ExportTemplateResponder handles the response to the ExportTemplate request. The method always
...
...
@@ -446,8 +446,8 @@ func (client GroupsClient) GetPreparer(ctx context.Context, resourceGroupName st
// GetSender sends the Get request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
GetSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// GetResponder handles the response to the Get request. The method always
...
...
@@ -528,8 +528,8 @@ func (client GroupsClient) ListPreparer(ctx context.Context, filter string, top
// ListSender sends the List request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
ListSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// ListResponder handles the response to the List request. The method always
...
...
@@ -661,8 +661,8 @@ func (client GroupsClient) ListResourcesPreparer(ctx context.Context, resourceGr
// ListResourcesSender sends the ListResources request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
ListResourcesSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// ListResourcesResponder handles the response to the ListResources request. The method always
...
...
@@ -787,8 +787,8 @@ func (client GroupsClient) PatchPreparer(ctx context.Context, resourceGroupName
// PatchSender sends the Patch request. The method will close the
// http.Response Body if it receives an error.
func
(
client
GroupsClient
)
PatchSender
(
req
*
http
.
Request
)
(
*
http
.
Response
,
error
)
{
return
autorest
.
Send
WithSender
(
client
,
req
,
azure
.
DoRetryWithRegistration
(
client
.
Client
)
)
sd
:=
autorest
.
Get
Send
Decorators
(
req
.
Context
(),
azure
.
DoRetryWithRegistration
(
client
.
Client
))
return
autorest
.
SendWithSender
(
client
,
req
,
sd
...
)
}
// PatchResponder handles the response to the Patch request. The method always
...
...
This diff is collapsed.
Click to expand it.
Prev
1
2
3
4
5
…
7
Next
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment