mirror of https://github.com/knative/client.git
upgrade to latest dependencies (#1266)
bumping knative.dev/hack 9b73a25...b6ab329: > b6ab329 Add a comment to explain why we have a long wait_until_pods_running function (# 60) > 58edbdc [schema cli] correct arrays (# 58) > 97362eb go test flag should go first (# 54) > 57abacd Don't redirect STDERR to /dev/null when querying pods (# 55) bumping knative.dev/pkg 4048853...952fdd9: > 952fdd9 Update common github actions (# 2077) > 6317ec6 Update DEVELOPMENT.md (# 2069) > a5005d3 Bump k8s min version to v1.18.0 (# 2076) > 808d622 Escape path before returning it in a response (# 2075) > 71e938e Fix int conversion in statefulset ordinals (# 2074) > 3b7934e Update webhook/README.md to reflect current packages (# 2062) > 9d92ea1 Update reconciler_controller.go (# 2066) > 78ca070 upgrade to latest dependencies (# 2070) > b558677 Use TB interface, rather than T pointer when doing test stuff (# 2064) > 9bf9eeb rename downstream-test-go to actions-downstream-test (# 2065) > dfeeb18 Update common github actions (# 2059) > de0a8c9 upgrade to latest dependencies (# 2060) > 6a33a1a Upgrade a few assorted dependencies (# 2058) bumping github.com/google/go-cmp ec71d6d...8fa37b4: > 8fa37b4 Fix reporter verbosity bug (# 253) > dc6435e De-virtualize interfaces for specialized diffing (# 254) > e9947a2 Run tests on Go 1.16 (# 252) > 3a98a11 cmp/cmpopts: use errors.Is with ≥go1.13 in compareErrors (# 251) bumping knative.dev/eventing 3b42737...8f35d42: > 8f35d42 last control plane test for channel (# 5182) > 2d4951e redo smoketests, move one broker test (# 5187) > 5aacf4f Channel Data Plane Conformance Template (# 5183) > 6c632d1 add post 022 job to remove pingsource finalizer (# 5008) > ae36e5b upgrade to latest dependencies (# 5156) > ab0b9b0 Update common github actions (# 5186) > dca8b0a 4962 test coverage kncloudevents (# 5171) > 18e33bf increase webhook timeout values to be larger than probe timeouts. (# 5175) > f526e3d adding channel subscription smoke tests (# 5177) > 6d403f8 fix lease not always being released (# 5162) > 9ababf2 update downstream test to also run on main branch PRs (# 5145) > 9362696 Channel Conformance tests for Spec and Status shapes. (# 5152) > 3ebce0d relax malformed ce response code to 4xx (# 5154) > 8ff609f add tests for various missing required fields (# 5144) > 979f99e Changing cluster role's name check to check only suffix for source spec conformance testing (# 5105) > 724f4ed adding role and role selector test for channels (# 5141) > 116a571 Fix comment on podspecable-binding clusterrole (# 5142) > c820f42 Channel Conformance Tests, CRD (# 5138) > d3e856a upgrade to latest dependencies (# 5140) > b5b547f adding todo stubs for channel conformance tests (# 5127) > 5947002 add test for rejecting malformed CE (# 5135) > f9de675 broker.status.address.url is not required (# 5134) > 04ab20f rename downstream-test-go to actions-downstream-test (# 5133) > 9e8f2df add conformance test for checking GET method gets rejected (# 5132) > 88b3c90 More unit tests for pingsource (# 5106) > c039526 Add create KinD cluster script (# 5126) > aecb58c Format markdown (# 5116) > 1ba9ebd add test for wrong version of CE (# 5124) > e2e9edf Use correlation between send / response events (# 5108) > 33cc21a Adjust resources.requests of eventing-webhook (# 5112) > 2dcdb47 Add Eventing 1.0 to the roadmap (# 5043) > 4e1a66b Update community support instructions with ux issue template info (# 5109) > c42772d KafkaChannel hack to upgrade (# 5085) > a95567e statuscode 200-299 (# 5102) > 85c4286 add data plane for ce versions (# 5101) > 025f1c1 Broker/Trigger Conformance Tests, invalid trigger.spec.filters (# 5089) > 266b743 use timing and common config from reconciler-test (# 5094) > c1124d5 Format markdown (# 5093) > de960c7 Update common github actions (# 5090) > 8983fc8 Change spec redirects to template used by docs (# 5092) > 48fb081 broker changes come from the env. (# 5088) > 23d1519 Format markdown (# 5083) > df48abb Schema tool for Eventing v1 (# 5087) > 3b812fc Switch slinkydeveloper and devguyio rotations (# 5084) > 07939c5 fix trigger conf tests (# 5082) > 646b9e2 add unit tests to reconciler/apiserversource (# 5067) > b09cc03 add ./ to file (# 5078) > ef536d4 Start adding spec based conformance tests for Broker/Trigger. (# 5072) > 60043be Add KO_FLAGS usage to chaosduck build (# 5075) > b2ea385 Add redirect link (# 5077) > c8b0b6b Remove specs for eventing and point to new location in specs repo (# 5057) > 1184217 Update support info with machine-readable rotation (# 5068) > 248cd1b Add query for doc issues that eventing eng. attention (# 5074) > 2b95fce upgrade to latest dependencies (# 5060) > 4cbc070 Timezone not added to schedule in runner.go # 5058 (# 5059) bumping knative.dev/networking 430a689...999a770: > 999a770 Update common github actions (# 382) > a1fa52a upgrade to latest dependencies (# 381) > 45fe1f5 upgrade to latest dependencies (# 380) > 354e242 Add pod-addressability config to config-network (# 377) > 6a77ca6 upgrade to latest dependencies (# 376) > 44a3b91 upgrade to latest dependencies (# 375) > 8fc278d rename downstream-test-go to actions-downstream-test (# 374) > ed835c9 Update common github actions (# 372) > ada810f upgrade to latest dependencies (# 373) > 33105c6 upgrade to latest dependencies (# 371) bumping knative.dev/serving 1583394...fc58a32: > fc58a32 Update net-certmanager nightly (# 11095) > feb2da0 Add leeway for deployment rollouts in autoscale upgrade tests (# 11093) > fe09f38 Update net-contour nightly (# 11071) > bb43fdb Update net-istio nightly (# 11086) > 8671de8 Update net-certmanager nightly (# 11085) > a0a847b Update common github actions (# 11082) > 6174a0e upgrade to latest dependencies (# 11083) > 1fef748 Add passthrough LB functionality to the stats scraper (# 11076) > c6ddb40 upgrade to latest dependencies (# 11081) > d6ea20a drop gloo from third party & e2e scripts (# 11080) > 5813b79 Drop misleading comment in autoscaler main (# 11073) > 0711285 upgrade to latest dependencies (# 11077) > 3190050 Update net-istio nightly (# 11072) > 350184b Drop explicit namespaces and system imports (# 11054) > 9f1b7eb Update net-istio nightly (# 11055) > c799d89 upgrade to latest dependencies (# 11067) > 7931069 Use kubectl replace instead of patch to restore config-gc (# 11062) > 2bbfc27 Thread network config into the autoscaler (# 11056) > 8ab7b39 Remove hardcoded config names throughout (# 11057) > 3244771 Drop tracing config testdata in activator (# 11053) > 69610eb upgrade to latest dependencies (# 11061) > 6126291 Update net-certmanager nightly (# 11029) > 25a49c8 Bump request timeout in TestProbeQueueNotReady to fix flake (# 11050) > 6a45e7d Update net-istio nightly (# 11030) > 9b024b4 Update net-contour nightly (# 11028) > a597700 Add a proxy-builder to make use of passthrough loadbalancing (# 11035) > 34d7b4b upgrade to latest dependencies (# 11040) > 5dbe774 upgrade to latest dependencies (# 11036) > 2081525 Fix HTTP2 feature-gate threading in queue-proxy (# 11022) > 2490284 use-new-helpts (# 11018) > d55482e Bypass tracing handler if tracing is disabled (# 11016) > 37dedfa Skip flaky HTTP2 probe test (# 11027) > d5d489c Reduce allocations to store config on context in Activator (# 11013) > 1a0d326 Prevent MaxScaleLimit being exceeded on update (# 11010) > 4682e3e Use service-host-name helper in Activator creation (# 11021) > fb5af24 upgrade to latest dependencies (# 11020) > c9296e1 Add HA test for DomainMapping controller (# 10816) > b5d1348 Add a benchmark for the entire handler chain of the activator (# 11014) > ccf35f1 Update net-istio nightly (# 11002) > 069c635 add to mon reviewers (# 10972) > 0e8410a Format markdown (# 11001) > 3e2b15e Collapse revision context into specialized context to avoid allocations (# 11009) > 4e5fde5 Only allocate named logger if necessary in activator (# 11008) > 9ee92b1 Default PeriodSeconds of the readiness probe to 1 if unset (# 10992) > 27757ec Fix concurrency reporter log to use the correct key (# 11007) > 60a7f99 Add lint for aliasing autoscaling import correctly (# 10885) > 05f16c6 Update net-kourier nightly (# 10989) > decdaf4 Update net-contour nightly (# 10988) > b7ef994 Add ux issue template to community contact instructions (# 10993) > 08e4e0e Update net-kourier nightly (# 10977) > 9cdf9b0 Update net-certmanager nightly (# 10976) > a78e43e Update net-istio nightly (# 10974) > aeae909 Update common github actions (# 10969) > 8179fc6 set httpoption in kingress spec from cm (# 10412) > 77383a4 upgrade to latest dependencies (# 10971) > df03bdb Format markdown (# 10970) > df6c235 Update support info with machine-readable rotation (# 10955) > 3a6856b Add triage instructions for support rotation (# 10965) > 5af85b7 Format markdown (# 10968) > 90de379 Point spec files and runtime contract file to the specs repo (# 10967) > e66e402 Update net-istio nightly (# 10964) > a10bc74 upgrade to latest dependencies (# 10956) > 057c203 Update query for doc issues for serving that need attention (# 10958) > 7398ca3 Update net-istio nightly (# 10952) > 7b0bab7 Update net-contour nightly (# 10953) > e9ef3a1 Update net-kourier nightly (# 10954) > 73a6ba5 Update net-certmanager nightly (# 10945) > 503c978 Update net-contour nightly (# 10931) > fec9960 Update net-kourier nightly (# 10947) > b4fd523 Update net-istio nightly (# 10946) Signed-off-by: Knative Automation <automation@knative.team>
This commit is contained in:
knative-automation
GitHub
parent
a93b9b4e94
commit
8bcefe59d5
12
go.mod
12
go.mod
|
|
@ -3,7 +3,7 @@ module knative.dev/client
|
|||
go 1.15
|
||||
|
||||
require (
|
||||
github.com/google/go-cmp v0.5.4
|
||||
github.com/google/go-cmp v0.5.5
|
||||
github.com/gregjones/httpcache v0.0.0-20190212212710-3befbb6ad0cc // indirect
|
||||
github.com/mitchellh/go-homedir v1.1.0
|
||||
github.com/mitchellh/mapstructure v1.3.1 // indirect
|
||||
|
|
@ -21,11 +21,11 @@ require (
|
|||
k8s.io/cli-runtime v0.19.7
|
||||
k8s.io/client-go v0.19.7
|
||||
k8s.io/code-generator v0.19.7
|
||||
knative.dev/eventing v0.21.1-0.20210312002228-3b427377abe0
|
||||
knative.dev/hack v0.0.0-20210309141825-9b73a256fd9a
|
||||
knative.dev/networking v0.0.0-20210311190926-430a689490e6
|
||||
knative.dev/pkg v0.0.0-20210311174826-40488532be3f
|
||||
knative.dev/serving v0.21.1-0.20210311225828-1583394c61cb
|
||||
knative.dev/eventing v0.21.1-0.20210331231822-8f35d42544e0
|
||||
knative.dev/hack v0.0.0-20210325223819-b6ab329907d3
|
||||
knative.dev/networking v0.0.0-20210331064822-999a7708876c
|
||||
knative.dev/pkg v0.0.0-20210331065221-952fdd90dbb0
|
||||
knative.dev/serving v0.21.1-0.20210401115722-fc58a32f0ef6
|
||||
sigs.k8s.io/yaml v1.2.0
|
||||
)
|
||||
|
||||
|
|
|
|||
42
go.sum
42
go.sum
|
|
@ -350,6 +350,8 @@ github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
|
|||
github.com/google/go-cmp v0.5.3/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
|
||||
github.com/google/go-cmp v0.5.4 h1:L8R9j+yAqZuZjsqh/z+F1NCffTKKLShY6zXTItVIZ8M=
|
||||
github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
|
||||
github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
|
||||
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
|
||||
github.com/google/go-containerregistry v0.4.1-0.20210128200529-19c2b639fab1 h1:o2ykCuuhHeUwtzNg89pH2hi+821aqjLWkaREVR3ziTQ=
|
||||
github.com/google/go-containerregistry v0.4.1-0.20210128200529-19c2b639fab1/go.mod h1:GU9FUA/X9rd2cV3ZoUNaWihp27tki6/38EsVzL2Dyzc=
|
||||
github.com/google/go-containerregistry/pkg/authn/k8schain v0.0.0-20210129212729-5c4818de4025/go.mod h1:n9wRxRfKkHy6ZFyj0jJQHw11P+mGLnED4sqegwrXxDk=
|
||||
|
|
@ -641,6 +643,8 @@ github.com/prometheus/common v0.7.0/go.mod h1:DjGbpBbp5NYNiECxcL/VnbXCCaQpKd3tt2
|
|||
github.com/prometheus/common v0.10.0/go.mod h1:Tlit/dnDKsSWFlCLTWaA1cyBgKHSMdTB80sz/V91rCo=
|
||||
github.com/prometheus/common v0.15.0 h1:4fgOnadei3EZvgRwxJ7RMpG1k1pOZth5Pc13tyspaKM=
|
||||
github.com/prometheus/common v0.15.0/go.mod h1:U+gB1OBLb1lF3O42bTCL+FK18tX9Oar16Clt/msog/s=
|
||||
github.com/prometheus/common v0.19.0 h1:Itb4+NjG9wRdkAWgVucbM/adyIXxEhbw0866e0uZE6A=
|
||||
github.com/prometheus/common v0.19.0/go.mod h1:U+gB1OBLb1lF3O42bTCL+FK18tX9Oar16Clt/msog/s=
|
||||
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/prometheus/procfs v0.0.0-20190507164030-5867b95ac084/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
|
||||
|
|
@ -775,8 +779,8 @@ go.opencensus.io v0.22.4 h1:LYy1Hy3MJdrCdMwwzxA/dRok4ejH+RwNGbuoD9fCjto=
|
|||
go.opencensus.io v0.22.4/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
|
||||
go.opencensus.io v0.22.5 h1:dntmOdLpSpHlVqbW5Eay97DelsZHe+55D+xC6i0dDS0=
|
||||
go.opencensus.io v0.22.5/go.mod h1:5pWMHQbX5EPX2/62yrJeAkowc+lfs/XD7Uxpq3pI6kk=
|
||||
go.opencensus.io v0.22.6 h1:BdkrbWrzDlV9dnbzoP7sfN+dHheJ4J9JOaYxcUDL+ok=
|
||||
go.opencensus.io v0.22.6/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
|
||||
go.opencensus.io v0.23.0 h1:gqCw0LfLxScz8irSi8exQc7fyQ0fKQU/qnC/X8+V/1M=
|
||||
go.opencensus.io v0.23.0/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
|
||||
go.opentelemetry.io/otel v0.16.0/go.mod h1:e4GKElweB8W2gWUqbghw0B8t5MCTccc9212eNHnOHwA=
|
||||
go.uber.org/atomic v1.3.2/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
|
||||
go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
|
||||
|
|
@ -1194,8 +1198,8 @@ google.golang.org/grpc v1.31.0/go.mod h1:N36X2cJ7JwdamYAgDz+s+rVMFjt3numwzf/HckM
|
|||
google.golang.org/grpc v1.31.1 h1:SfXqXS5hkufcdZ/mHtYCh53P2b+92WQq/DZcKLgsFRs=
|
||||
google.golang.org/grpc v1.31.1/go.mod h1:N36X2cJ7JwdamYAgDz+s+rVMFjt3numwzf/HckM8pak=
|
||||
google.golang.org/grpc v1.33.2/go.mod h1:JMHMWHQWaTccqQQlmk3MJZS+GWXOdAesneDmEnv2fbc=
|
||||
google.golang.org/grpc v1.35.0 h1:TwIQcH3es+MojMVojxxfQ3l3OF2KzlRxML2xZq0kRo8=
|
||||
google.golang.org/grpc v1.35.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU=
|
||||
google.golang.org/grpc v1.36.0 h1:o1bcQ6imQMIOpdrO3SWf2z5RV72WbDwdXuK0MDlc8As=
|
||||
google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU=
|
||||
google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
|
||||
google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
|
||||
google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
|
||||
|
|
@ -1305,20 +1309,22 @@ k8s.io/utils v0.0.0-20200729134348-d5654de09c73 h1:uJmqzgNWG7XyClnU/mLPBWwfKKF1K
|
|||
k8s.io/utils v0.0.0-20200729134348-d5654de09c73/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
|
||||
k8s.io/utils v0.0.0-20210111153108-fddb29f9d009 h1:0T5IaWHO3sJTEmCP6mUlBvMukxPKUQWqiI/YuiBNMiQ=
|
||||
k8s.io/utils v0.0.0-20210111153108-fddb29f9d009/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
|
||||
knative.dev/caching v0.0.0-20210311181225-4b366c7a9f99/go.mod h1:OlAEAfCSUjHVetZp/hpMw3lzAGHfTEQyu2a5dgf/7Qo=
|
||||
knative.dev/eventing v0.21.1-0.20210312002228-3b427377abe0 h1:nd6yNE6L10abHfrrsVarMiirHke7tvqfP9uczfRCOIE=
|
||||
knative.dev/eventing v0.21.1-0.20210312002228-3b427377abe0/go.mod h1:k/F174UcHeY70F00RAExTv2/wg8yUR20EPYX3hlD3+8=
|
||||
knative.dev/hack v0.0.0-20210309141825-9b73a256fd9a h1:0UGKyvFzY1Czu0lP9+0IrJhwtKe2oNLI2GYa7MIQ5c0=
|
||||
knative.dev/hack v0.0.0-20210309141825-9b73a256fd9a/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
|
||||
knative.dev/networking v0.0.0-20210311182125-f51c10d6fcf0/go.mod h1:dBcp0JBxATXsbCKK43cA6LxTricz4Ur3dPHataW5J64=
|
||||
knative.dev/networking v0.0.0-20210311190926-430a689490e6 h1:yuf+sPvbvjvQ2KBJrEORN/YPxuf3EIFD31z/jL4WfwU=
|
||||
knative.dev/networking v0.0.0-20210311190926-430a689490e6/go.mod h1:dBcp0JBxATXsbCKK43cA6LxTricz4Ur3dPHataW5J64=
|
||||
knative.dev/pkg v0.0.0-20210310173525-bbe0bb3eb1e0/go.mod h1:pn/vClSL/iCW40TlFR91EhtmMmsyPQR2V2LavDAOOMs=
|
||||
knative.dev/pkg v0.0.0-20210311174826-40488532be3f h1:WBgC84Ldkyvt+25osB1pfrNXH9LKoXvr3BptANZWvIE=
|
||||
knative.dev/pkg v0.0.0-20210311174826-40488532be3f/go.mod h1:pn/vClSL/iCW40TlFR91EhtmMmsyPQR2V2LavDAOOMs=
|
||||
knative.dev/reconciler-test v0.0.0-20210311161026-af80deacbe19/go.mod h1:BqljHB9eQj66yPyxOj62syip0ZZtiG0lw76XrtRe36M=
|
||||
knative.dev/serving v0.21.1-0.20210311225828-1583394c61cb h1:HX5EVjJJqIUoDAWmfulMnGvPFeKJkAC6GAuj9/y97Ig=
|
||||
knative.dev/serving v0.21.1-0.20210311225828-1583394c61cb/go.mod h1:5cO/KA08FzPBPuCa5CU2lEGZOP8V/zUgvoluuPcL1lQ=
|
||||
knative.dev/caching v0.0.0-20210331063521-5691bb38d441/go.mod h1:CfW7OVs7gzUXJj0OrIe8YlWEC4Qe0Avnq+5b81/Gw1s=
|
||||
knative.dev/eventing v0.21.1-0.20210331231822-8f35d42544e0 h1:hTZYXQgaWV3b2BVD7xjr6EMbwGETsnKs/VpgOfVkrZU=
|
||||
knative.dev/eventing v0.21.1-0.20210331231822-8f35d42544e0/go.mod h1:LOG7bh0eZQkbYANcnORwke6Yy6aUu62o8GeByaOFfRQ=
|
||||
knative.dev/hack v0.0.0-20210325223819-b6ab329907d3 h1:km0Rrh0T9/wA2pivQm1hqSPVwgNgGCHC2WNn3GakZmE=
|
||||
knative.dev/hack v0.0.0-20210325223819-b6ab329907d3/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
|
||||
knative.dev/hack/schema v0.0.0-20210325223819-b6ab329907d3/go.mod h1:ffjwmdcrH5vN3mPhO8RrF2KfNnbHeCE2C60A+2cv3U0=
|
||||
knative.dev/networking v0.0.0-20210331064822-999a7708876c h1:7ggsYXtltPHjbgxi76hg5g2eOtmg8KaBIP40XJsfMyA=
|
||||
knative.dev/networking v0.0.0-20210331064822-999a7708876c/go.mod h1:0V6M1AaWPL/MtQLuEx0NxiwDdtb8Y4b4f7P3C8sp0zo=
|
||||
knative.dev/pkg v0.0.0-20210329065222-9d92ea16c0d3/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
|
||||
knative.dev/pkg v0.0.0-20210330162221-808d62257db6/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
|
||||
knative.dev/pkg v0.0.0-20210331062321-6317ec6066f4/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
|
||||
knative.dev/pkg v0.0.0-20210331065221-952fdd90dbb0 h1:z05hcB4br0qz7JdwIoUSTXLTF+7ThuJ+R6NFfXd1Y4Q=
|
||||
knative.dev/pkg v0.0.0-20210331065221-952fdd90dbb0/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
|
||||
knative.dev/reconciler-test v0.0.0-20210329214021-2a67496462a4/go.mod h1:qLfJMHc0i9ENTSet/SUp/FcQm4QVfNTX8ZC//aVQN0M=
|
||||
knative.dev/serving v0.21.1-0.20210401115722-fc58a32f0ef6 h1:eXinNd46GLQHm5wAYX6Sqonj3E2dFZ+C48xumv1DjTg=
|
||||
knative.dev/serving v0.21.1-0.20210401115722-fc58a32f0ef6/go.mod h1:20yuZH4F7cvoovC2Pi1uQBoIbOjllapVSKDkWAXkItA=
|
||||
modernc.org/cc v1.0.0/go.mod h1:1Sk4//wdnYJiUIxnW8ddKpaOJCF37yAdqYnkxUpaYxw=
|
||||
modernc.org/golex v1.0.0/go.mod h1:b/QX9oBD/LhixY6NDh+IdGv17hgB+51fET1i2kPSmvk=
|
||||
modernc.org/mathutil v1.0.0/go.mod h1:wU0vUrJsVWBZ4P6e7xtFJEhFSNsfRLJ8H458uRjg03k=
|
||||
|
|
|
|||
|
|
@ -1,27 +0,0 @@
|
|||
Copyright (c) 2019 The Go Authors. All rights reserved.
|
||||
|
||||
Redistribution and use in source and binary forms, with or without
|
||||
modification, are permitted provided that the following conditions are
|
||||
met:
|
||||
|
||||
* Redistributions of source code must retain the above copyright
|
||||
notice, this list of conditions and the following disclaimer.
|
||||
* Redistributions in binary form must reproduce the above
|
||||
copyright notice, this list of conditions and the following disclaimer
|
||||
in the documentation and/or other materials provided with the
|
||||
distribution.
|
||||
* Neither the name of Google Inc. nor the names of its
|
||||
contributors may be used to endorse or promote products derived from
|
||||
this software without specific prior written permission.
|
||||
|
||||
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
||||
"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
||||
LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
||||
A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
||||
OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||
SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||
LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
||||
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
||||
THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
|
|
@ -11,7 +11,6 @@ import (
|
|||
"time"
|
||||
|
||||
"github.com/google/go-cmp/cmp"
|
||||
"golang.org/x/xerrors"
|
||||
)
|
||||
|
||||
func equateAlways(_, _ interface{}) bool { return true }
|
||||
|
|
@ -147,10 +146,3 @@ func areConcreteErrors(x, y interface{}) bool {
|
|||
_, ok2 := y.(error)
|
||||
return ok1 && ok2
|
||||
}
|
||||
|
||||
func compareErrors(x, y interface{}) bool {
|
||||
xe := x.(error)
|
||||
ye := y.(error)
|
||||
// TODO(≥go1.13): Use standard definition of errors.Is.
|
||||
return xerrors.Is(xe, ye) || xerrors.Is(ye, xe)
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,15 @@
|
|||
// Copyright 2021, The Go Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style
|
||||
// license that can be found in the LICENSE file.
|
||||
|
||||
// +build go1.13
|
||||
|
||||
package cmpopts
|
||||
|
||||
import "errors"
|
||||
|
||||
func compareErrors(x, y interface{}) bool {
|
||||
xe := x.(error)
|
||||
ye := y.(error)
|
||||
return errors.Is(xe, ye) || errors.Is(ye, xe)
|
||||
}
|
||||
|
|
@ -0,0 +1,18 @@
|
|||
// Copyright 2021, The Go Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style
|
||||
// license that can be found in the LICENSE file.
|
||||
|
||||
// +build !go1.13
|
||||
|
||||
// TODO(≥go1.13): For support on <go1.13, we use the xerrors package.
|
||||
// Drop this file when we no longer support older Go versions.
|
||||
|
||||
package cmpopts
|
||||
|
||||
import "golang.org/x/xerrors"
|
||||
|
||||
func compareErrors(x, y interface{}) bool {
|
||||
xe := x.(error)
|
||||
ye := y.(error)
|
||||
return xerrors.Is(xe, ye) || xerrors.Is(ye, xe)
|
||||
}
|
||||
|
|
@ -79,7 +79,7 @@ func (opts formatOptions) verbosity() uint {
|
|||
}
|
||||
}
|
||||
|
||||
const maxVerbosityPreset = 3
|
||||
const maxVerbosityPreset = 6
|
||||
|
||||
// verbosityPreset modifies the verbosity settings given an index
|
||||
// between 0 and maxVerbosityPreset, inclusive.
|
||||
|
|
@ -100,7 +100,7 @@ func verbosityPreset(opts formatOptions, i int) formatOptions {
|
|||
func (opts formatOptions) FormatDiff(v *valueNode, ptrs *pointerReferences) (out textNode) {
|
||||
if opts.DiffMode == diffIdentical {
|
||||
opts = opts.WithVerbosity(1)
|
||||
} else {
|
||||
} else if opts.verbosity() < 3 {
|
||||
opts = opts.WithVerbosity(3)
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -26,8 +26,6 @@ func (opts formatOptions) CanFormatDiffSlice(v *valueNode) bool {
|
|||
return false // No differences detected
|
||||
case !v.ValueX.IsValid() || !v.ValueY.IsValid():
|
||||
return false // Both values must be valid
|
||||
case v.Type.Kind() == reflect.Slice && (v.ValueX.Len() == 0 || v.ValueY.Len() == 0):
|
||||
return false // Both slice values have to be non-empty
|
||||
case v.NumIgnored > 0:
|
||||
return false // Some ignore option was used
|
||||
case v.NumTransformed > 0:
|
||||
|
|
@ -45,7 +43,16 @@ func (opts formatOptions) CanFormatDiffSlice(v *valueNode) bool {
|
|||
return false
|
||||
}
|
||||
|
||||
switch t := v.Type; t.Kind() {
|
||||
// Check whether this is an interface with the same concrete types.
|
||||
t := v.Type
|
||||
vx, vy := v.ValueX, v.ValueY
|
||||
if t.Kind() == reflect.Interface && !vx.IsNil() && !vy.IsNil() && vx.Elem().Type() == vy.Elem().Type() {
|
||||
vx, vy = vx.Elem(), vy.Elem()
|
||||
t = vx.Type()
|
||||
}
|
||||
|
||||
// Check whether we provide specialized diffing for this type.
|
||||
switch t.Kind() {
|
||||
case reflect.String:
|
||||
case reflect.Array, reflect.Slice:
|
||||
// Only slices of primitive types have specialized handling.
|
||||
|
|
@ -57,6 +64,11 @@ func (opts formatOptions) CanFormatDiffSlice(v *valueNode) bool {
|
|||
return false
|
||||
}
|
||||
|
||||
// Both slice values have to be non-empty.
|
||||
if t.Kind() == reflect.Slice && (vx.Len() == 0 || vy.Len() == 0) {
|
||||
return false
|
||||
}
|
||||
|
||||
// If a sufficient number of elements already differ,
|
||||
// use specialized formatting even if length requirement is not met.
|
||||
if v.NumDiff > v.NumSame {
|
||||
|
|
@ -68,7 +80,7 @@ func (opts formatOptions) CanFormatDiffSlice(v *valueNode) bool {
|
|||
|
||||
// Use specialized string diffing for longer slices or strings.
|
||||
const minLength = 64
|
||||
return v.ValueX.Len() >= minLength && v.ValueY.Len() >= minLength
|
||||
return vx.Len() >= minLength && vy.Len() >= minLength
|
||||
}
|
||||
|
||||
// FormatDiffSlice prints a diff for the slices (or strings) represented by v.
|
||||
|
|
@ -77,6 +89,11 @@ func (opts formatOptions) CanFormatDiffSlice(v *valueNode) bool {
|
|||
func (opts formatOptions) FormatDiffSlice(v *valueNode) textNode {
|
||||
assert(opts.DiffMode == diffUnknown)
|
||||
t, vx, vy := v.Type, v.ValueX, v.ValueY
|
||||
if t.Kind() == reflect.Interface {
|
||||
vx, vy = vx.Elem(), vy.Elem()
|
||||
t = vx.Type()
|
||||
opts = opts.WithTypeMode(emitType)
|
||||
}
|
||||
|
||||
// Auto-detect the type of the data.
|
||||
var isLinedText, isText, isBinary bool
|
||||
|
|
|
|||
|
|
@ -14,6 +14,7 @@
|
|||
package model
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"math"
|
||||
"regexp"
|
||||
|
|
@ -254,6 +255,37 @@ func (d Duration) String() string {
|
|||
return r
|
||||
}
|
||||
|
||||
// MarshalJSON implements the json.Marshaler interface.
|
||||
func (d Duration) MarshalJSON() ([]byte, error) {
|
||||
return json.Marshal(d.String())
|
||||
}
|
||||
|
||||
// UnmarshalJSON implements the json.Unmarshaler interface.
|
||||
func (d *Duration) UnmarshalJSON(bytes []byte) error {
|
||||
var s string
|
||||
if err := json.Unmarshal(bytes, &s); err != nil {
|
||||
return err
|
||||
}
|
||||
dur, err := ParseDuration(s)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
*d = dur
|
||||
return nil
|
||||
}
|
||||
|
||||
// MarshalText implements the encoding.TextMarshaler interface.
|
||||
func (d *Duration) MarshalText() ([]byte, error) {
|
||||
return []byte(d.String()), nil
|
||||
}
|
||||
|
||||
// UnmarshalText implements the encoding.TextUnmarshaler interface.
|
||||
func (d *Duration) UnmarshalText(text []byte) error {
|
||||
var err error
|
||||
*d, err = ParseDuration(string(text))
|
||||
return err
|
||||
}
|
||||
|
||||
// MarshalYAML implements the yaml.Marshaler interface.
|
||||
func (d Duration) MarshalYAML() (interface{}, error) {
|
||||
return d.String(), nil
|
||||
|
|
|
|||
1
vendor/google.golang.org/grpc/balancer/grpclb/grpc_lb_v1/load_balancer_grpc.pb.go
generated
vendored
1
vendor/google.golang.org/grpc/balancer/grpclb/grpc_lb_v1/load_balancer_grpc.pb.go
generated
vendored
|
|
@ -11,6 +11,7 @@ import (
|
|||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7
|
||||
|
||||
// LoadBalancerClient is the client API for LoadBalancer service.
|
||||
|
|
|
|||
|
|
@ -11,6 +11,7 @@ import (
|
|||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7
|
||||
|
||||
// HandshakerServiceClient is the client API for HandshakerService service.
|
||||
|
|
|
|||
|
|
@ -21,6 +21,8 @@
|
|||
package proto
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"github.com/golang/protobuf/proto"
|
||||
"google.golang.org/grpc/encoding"
|
||||
)
|
||||
|
|
@ -36,11 +38,19 @@ func init() {
|
|||
type codec struct{}
|
||||
|
||||
func (codec) Marshal(v interface{}) ([]byte, error) {
|
||||
return proto.Marshal(v.(proto.Message))
|
||||
vv, ok := v.(proto.Message)
|
||||
if !ok {
|
||||
return nil, fmt.Errorf("failed to marshal, message is %T, want proto.Message", v)
|
||||
}
|
||||
return proto.Marshal(vv)
|
||||
}
|
||||
|
||||
func (codec) Unmarshal(data []byte, v interface{}) error {
|
||||
return proto.Unmarshal(data, v.(proto.Message))
|
||||
vv, ok := v.(proto.Message)
|
||||
if !ok {
|
||||
return fmt.Errorf("failed to unmarshal, message is %T, want proto.Message", v)
|
||||
}
|
||||
return proto.Unmarshal(data, vv)
|
||||
}
|
||||
|
||||
func (codec) Name() string {
|
||||
|
|
|
|||
|
|
@ -40,6 +40,9 @@ echo "go install cmd/protoc-gen-go-grpc"
|
|||
echo "git clone https://github.com/grpc/grpc-proto"
|
||||
git clone --quiet https://github.com/grpc/grpc-proto ${WORKDIR}/grpc-proto
|
||||
|
||||
echo "git clone https://github.com/protocolbuffers/protobuf"
|
||||
git clone --quiet https://github.com/protocolbuffers/protobuf ${WORKDIR}/protobuf
|
||||
|
||||
# Pull in code.proto as a proto dependency
|
||||
mkdir -p ${WORKDIR}/googleapis/google/rpc
|
||||
echo "curl https://raw.githubusercontent.com/googleapis/googleapis/master/google/rpc/code.proto"
|
||||
|
|
@ -87,6 +90,7 @@ for src in ${SOURCES[@]}; do
|
|||
-I"." \
|
||||
-I${WORKDIR}/grpc-proto \
|
||||
-I${WORKDIR}/googleapis \
|
||||
-I${WORKDIR}/protobuf/src \
|
||||
-I${WORKDIR}/istio \
|
||||
${src}
|
||||
done
|
||||
|
|
@ -97,6 +101,7 @@ for src in ${LEGACY_SOURCES[@]}; do
|
|||
-I"." \
|
||||
-I${WORKDIR}/grpc-proto \
|
||||
-I${WORKDIR}/googleapis \
|
||||
-I${WORKDIR}/protobuf/src \
|
||||
-I${WORKDIR}/istio \
|
||||
${src}
|
||||
done
|
||||
|
|
|
|||
|
|
@ -888,8 +888,7 @@ type channelzData struct {
|
|||
// buffer files to ensure compatibility with the gRPC version used. The latest
|
||||
// support package version is 7.
|
||||
//
|
||||
// Older versions are kept for compatibility. They may be removed if
|
||||
// compatibility cannot be maintained.
|
||||
// Older versions are kept for compatibility.
|
||||
//
|
||||
// These constants should not be referenced from any other code.
|
||||
const (
|
||||
|
|
|
|||
|
|
@ -73,9 +73,11 @@ func FromProto(s *spb.Status) *Status {
|
|||
return status.FromProto(s)
|
||||
}
|
||||
|
||||
// FromError returns a Status representing err if it was produced from this
|
||||
// package or has a method `GRPCStatus() *Status`. Otherwise, ok is false and a
|
||||
// Status is returned with codes.Unknown and the original error message.
|
||||
// FromError returns a Status representing err if it was produced by this
|
||||
// package or has a method `GRPCStatus() *Status`.
|
||||
// If err is nil, a Status is returned with codes.OK and no message.
|
||||
// Otherwise, ok is false and a Status is returned with codes.Unknown and
|
||||
// the original error message.
|
||||
func FromError(err error) (s *Status, ok bool) {
|
||||
if err == nil {
|
||||
return nil, true
|
||||
|
|
|
|||
|
|
@ -19,4 +19,4 @@
|
|||
package grpc
|
||||
|
||||
// Version is the current grpc version.
|
||||
const Version = "1.35.0"
|
||||
const Version = "1.36.0"
|
||||
|
|
|
|||
|
|
@ -117,6 +117,7 @@ type TriggerStatus struct {
|
|||
duckv1.Status `json:",inline"`
|
||||
|
||||
// SubscriberURI is the resolved URI of the receiver for this Trigger.
|
||||
// +optional
|
||||
SubscriberURI *apis.URL `json:"subscriberUri,omitempty"`
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -120,6 +120,7 @@ type TriggerStatus struct {
|
|||
duckv1.Status `json:",inline"`
|
||||
|
||||
// SubscriberURI is the resolved URI of the receiver for this Trigger.
|
||||
// +optional
|
||||
SubscriberURI *apis.URL `json:"subscriberUri,omitempty"`
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -25,5 +25,9 @@ func (s *Subscription) SetDefaults(ctx context.Context) {
|
|||
}
|
||||
|
||||
func (ss *SubscriptionSpec) SetDefaults(ctx context.Context) {
|
||||
// TODO anything?
|
||||
// HACK if a channel ref is a kafka channel ref, we need to hack it around to use only v1beta1
|
||||
// TODO(slinkydeveloper) REMOVE AFTER 0.22 release
|
||||
if ss.Channel.Kind == "KafkaChannel" && ss.Channel.APIVersion == "messaging.knative.dev/v1alpha1" {
|
||||
ss.Channel.APIVersion = "messaging.knative.dev/v1beta1"
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -80,8 +80,16 @@ func (s *Subscription) CheckImmutableFields(ctx context.Context, original *Subsc
|
|||
return nil
|
||||
}
|
||||
|
||||
// TODO(slinkydeveloper)
|
||||
// HACK around the immutability check to make sure the update script can upgrade the api version
|
||||
// REMOVE AFTER 0.22 release
|
||||
ignoredFields := []string{"Subscriber", "Reply"}
|
||||
if original.Spec.Channel.Kind == "KafkaChannel" && original.Spec.Channel.APIVersion == "messaging.knative.dev/v1alpha1" && s.Spec.Channel.APIVersion == "messaging.knative.dev/v1beta1" {
|
||||
ignoredFields = append(ignoredFields, "Channel.APIVersion")
|
||||
}
|
||||
|
||||
// Only Subscriber and Reply are mutable.
|
||||
ignoreArguments := cmpopts.IgnoreFields(SubscriptionSpec{}, "Subscriber", "Reply")
|
||||
ignoreArguments := cmpopts.IgnoreFields(SubscriptionSpec{}, ignoredFields...)
|
||||
if diff, err := kmp.ShortDiff(original.Spec, s.Spec, ignoreArguments); err != nil {
|
||||
return &apis.FieldError{
|
||||
Message: "Failed to diff Subscription",
|
||||
|
|
|
|||
|
|
@ -25,5 +25,9 @@ func (s *Subscription) SetDefaults(ctx context.Context) {
|
|||
}
|
||||
|
||||
func (ss *SubscriptionSpec) SetDefaults(ctx context.Context) {
|
||||
// TODO anything?
|
||||
// HACK if a channel ref is a kafka channel ref, we need to hack it around to use only v1beta1
|
||||
// TODO(slinkydeveloper) REMOVE AFTER 0.22 release
|
||||
if ss.Channel.Kind == "KafkaChannel" && ss.Channel.APIVersion == "messaging.knative.dev/v1alpha1" {
|
||||
ss.Channel.APIVersion = "messaging.knative.dev/v1beta1"
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -75,8 +75,16 @@ func (s *Subscription) CheckImmutableFields(ctx context.Context, original *Subsc
|
|||
return nil
|
||||
}
|
||||
|
||||
// TODO(slinkydeveloper)
|
||||
// HACK around the immutability check to make sure the update script can upgrade the api version
|
||||
// REMOVE AFTER 0.22 release
|
||||
ignoredFields := []string{"Subscriber", "Reply"}
|
||||
if original.Spec.Channel.Kind == "KafkaChannel" && original.Spec.Channel.APIVersion == "messaging.knative.dev/v1alpha1" && s.Spec.Channel.APIVersion == "messaging.knative.dev/v1beta1" {
|
||||
ignoredFields = append(ignoredFields, "Channel.APIVersion")
|
||||
}
|
||||
|
||||
// Only Subscriber and Reply are mutable.
|
||||
ignoreArguments := cmpopts.IgnoreFields(SubscriptionSpec{}, "Subscriber", "Reply")
|
||||
ignoreArguments := cmpopts.IgnoreFields(SubscriptionSpec{}, ignoredFields...)
|
||||
if diff, err := kmp.ShortDiff(original.Spec, s.Spec, ignoreArguments); err != nil {
|
||||
return &apis.FieldError{
|
||||
Message: "Failed to diff Subscription",
|
||||
|
|
|
|||
|
|
@ -37,12 +37,15 @@ function teardown_test_resources() {
|
|||
# Parameters: $1..$n - any go test flags, then directories containing the tests to run.
|
||||
function go_test_e2e() {
|
||||
local go_test_args=()
|
||||
[[ ! " $*" == *" -tags="* ]] && go_test_args+=("-tags=e2e")
|
||||
[[ ! " $*" == *" -count="* ]] && go_test_args+=("-count=1")
|
||||
[[ ! " $*" == *" -race"* ]] && go_test_args+=("-race")
|
||||
|
||||
# Remove empty args as `go test` will consider it as running tests for the current directory, which is not expected.
|
||||
for arg in "$@"; do
|
||||
[[ -n "$arg" ]] && go_test_args+=("$arg")
|
||||
done
|
||||
[[ ! " $*" == *" -tags="* ]] && go_test_args+=("-tags=e2e")
|
||||
report_go_test -race -count=1 "${go_test_args[@]}"
|
||||
report_go_test "${go_test_args[@]}"
|
||||
}
|
||||
|
||||
# Setup the test cluster for running the tests.
|
||||
|
|
@ -69,8 +72,8 @@ function setup_test_cluster() {
|
|||
# Acquire cluster admin role for the current user.
|
||||
acquire_cluster_admin_role "${k8s_cluster}"
|
||||
|
||||
# Setup KO_DOCKER_REPO if it is a GKE cluster. Incorporate an element of
|
||||
# randomness to ensure that each run properly publishes images. Don't
|
||||
# Setup KO_DOCKER_REPO if it is a GKE cluster. Incorporate an element of
|
||||
# randomness to ensure that each run properly publishes images. Don't
|
||||
# owerwrite KO_DOCKER_REPO if already set.
|
||||
[ -z "${KO_DOCKER_REPO}" ] && \
|
||||
[[ "${k8s_cluster}" =~ ^gke_.* ]] && \
|
||||
|
|
|
|||
|
|
@ -156,6 +156,9 @@ function wait_until_object_does_not_exist() {
|
|||
}
|
||||
|
||||
# Waits until all pods are running in the given namespace.
|
||||
# This function handles some edge cases that `kubectl wait` does not support,
|
||||
# and it provides nice debug info on the state of the pod if it failed,
|
||||
# that’s why we have this long bash function instead of using `kubectl wait`.
|
||||
# Parameters: $1 - namespace.
|
||||
function wait_until_pods_running() {
|
||||
echo -n "Waiting until all pods in namespace $1 are up"
|
||||
|
|
@ -163,7 +166,7 @@ function wait_until_pods_running() {
|
|||
for i in {1..150}; do # timeout after 5 minutes
|
||||
# List all pods. Ignore Terminating pods as those have either been replaced through
|
||||
# a deployment or terminated on purpose (through chaosduck for example).
|
||||
local pods="$(kubectl get pods --no-headers -n $1 2>/dev/null | grep -v Terminating)"
|
||||
local pods="$(kubectl get pods --no-headers -n $1 | grep -v Terminating)"
|
||||
# All pods must be running (ignore ImagePull error to allow the pod to retry)
|
||||
local not_running_pods=$(echo "${pods}" | grep -v Running | grep -v Completed | grep -v ErrImagePull | grep -v ImagePullBackOff)
|
||||
if [[ -n "${pods}" ]] && [[ -z "${not_running_pods}" ]]; then
|
||||
|
|
|
|||
|
|
@ -209,7 +209,7 @@ function run_unit_tests() {
|
|||
|
||||
# Default unit test runner that runs all go tests in the repo.
|
||||
function default_unit_test_runner() {
|
||||
report_go_test -race ./...
|
||||
report_go_test -race -count 1 ./...
|
||||
}
|
||||
|
||||
# Run integration tests. If there's no `integration_tests` function, run the
|
||||
|
|
|
|||
|
|
@ -180,6 +180,9 @@ const (
|
|||
// load balancers to not load balance the respective request but to
|
||||
// send it to the request's target directly.
|
||||
PassthroughLoadbalancingHeaderName = "K-Passthrough-Lb"
|
||||
|
||||
// EnableMeshPodAddressabilityKey is the config for enabling pod addressability in mesh.
|
||||
EnableMeshPodAddressabilityKey = "enable-mesh-pod-addressability"
|
||||
)
|
||||
|
||||
// DomainTemplateValues are the available properties people can choose from
|
||||
|
|
@ -251,6 +254,14 @@ type Config struct {
|
|||
// cluster administrator is responsible for pre-creating ClusterDomainClaims
|
||||
// and delegating them to namespaces via their spec.Namespace field.
|
||||
AutocreateClusterDomainClaims bool
|
||||
|
||||
// EnableMeshPodAddressability specifies whether networking plugins will add
|
||||
// additional information to deployed applications to make their pods directl
|
||||
// accessible via their IPs even if mesh is enabled and thus direct-addressability
|
||||
// is usually not possible.
|
||||
// Consumers like Knative Serving can use this setting to adjust their behavior
|
||||
// accordingly, i.e. to drop fallback solutions for non-pod-addressable systems.
|
||||
EnableMeshPodAddressability bool
|
||||
}
|
||||
|
||||
// HTTPProtocol indicates a type of HTTP endpoint behavior
|
||||
|
|
@ -298,6 +309,7 @@ func NewConfigFromMap(data map[string]string) (*Config, error) {
|
|||
cm.AsString(TagTemplateKey, &nc.TagTemplate),
|
||||
cm.AsInt(RolloutDurationKey, &nc.RolloutDurationSecs),
|
||||
cm.AsBool(AutocreateClusterDomainClaimsKey, &nc.AutocreateClusterDomainClaims),
|
||||
cm.AsBool(EnableMeshPodAddressabilityKey, &nc.EnableMeshPodAddressability),
|
||||
); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
|
|||
|
|
@ -204,7 +204,7 @@ const (
|
|||
// NewImpl returns a {{.controllerImpl|raw}} that handles queuing and feeding work from
|
||||
// the queue through an implementation of {{.controllerReconciler|raw}}, delegating to
|
||||
// the provided Interface and optional Finalizer methods. OptionsFn is used to return
|
||||
// {{.controllerOptions|raw}} to be used but the internal reconciler.
|
||||
// {{.controllerOptions|raw}} to be used by the internal reconciler.
|
||||
func NewImpl(ctx {{.contextContext|raw}}, r Interface{{if .hasClass}}, classValue string{{end}}, optionsFns ...{{.controllerOptionsFn|raw}}) *{{.controllerImpl|raw}} {
|
||||
logger := {{.loggingFromContext|raw}}(ctx)
|
||||
|
||||
|
|
|
|||
|
|
@ -134,8 +134,8 @@ type statefulSetID struct {
|
|||
|
||||
func (ssID *statefulSetID) Decode(v string) error {
|
||||
if i := strings.LastIndex(v, "-"); i != -1 {
|
||||
ui, err := strconv.ParseUint(v[i+1:], 10, 64)
|
||||
ssID.ordinal = int(ui)
|
||||
ui, err := strconv.Atoi(v[i+1:])
|
||||
ssID.ordinal = ui
|
||||
ssID.ssName = v[:i]
|
||||
return err
|
||||
}
|
||||
|
|
|
|||
|
|
@ -52,7 +52,7 @@ func getIntGE0(m map[string]string, k string) (int32, *apis.FieldError) {
|
|||
// ValidateAnnotations verifies the autoscaling annotations.
|
||||
func ValidateAnnotations(ctx context.Context, config *autoscalerconfig.Config, anns map[string]string) *apis.FieldError {
|
||||
return validateClass(anns).
|
||||
Also(validateMinMaxScale(ctx, config, anns)).
|
||||
Also(validateMinMaxScale(config, anns)).
|
||||
Also(validateFloats(anns)).
|
||||
Also(validateWindow(anns)).
|
||||
Also(validateLastPodRetention(anns)).
|
||||
|
|
@ -173,7 +173,7 @@ func validateWindow(annotations map[string]string) *apis.FieldError {
|
|||
return nil
|
||||
}
|
||||
|
||||
func validateMinMaxScale(ctx context.Context, config *autoscalerconfig.Config, annotations map[string]string) *apis.FieldError {
|
||||
func validateMinMaxScale(config *autoscalerconfig.Config, annotations map[string]string) *apis.FieldError {
|
||||
min, errs := getIntGE0(annotations, MinScaleAnnotationKey)
|
||||
max, err := getIntGE0(annotations, MaxScaleAnnotationKey)
|
||||
errs = errs.Also(err)
|
||||
|
|
@ -184,21 +184,30 @@ func validateMinMaxScale(ctx context.Context, config *autoscalerconfig.Config, a
|
|||
Paths: []string{MaxScaleAnnotationKey, MinScaleAnnotationKey},
|
||||
})
|
||||
}
|
||||
_, exists := annotations[MaxScaleAnnotationKey]
|
||||
// If max scale annotation is not set but default MaxScale is set, then max scale will not be unlimited.
|
||||
if !apis.IsInCreate(ctx) || config.MaxScaleLimit == 0 || (!exists && config.MaxScale > 0) {
|
||||
return errs
|
||||
|
||||
if _, hasMaxScaleAnnotation := annotations[MaxScaleAnnotationKey]; hasMaxScaleAnnotation {
|
||||
errs = errs.Also(validateMaxScaleWithinLimit(max, config.MaxScaleLimit))
|
||||
}
|
||||
if max > config.MaxScaleLimit {
|
||||
errs = errs.Also(apis.ErrOutOfBoundsValue(
|
||||
max, 1, config.MaxScaleLimit, MaxScaleAnnotationKey))
|
||||
|
||||
return errs
|
||||
}
|
||||
|
||||
func validateMaxScaleWithinLimit(maxScale, maxScaleLimit int32) (errs *apis.FieldError) {
|
||||
if maxScaleLimit == 0 {
|
||||
return nil
|
||||
}
|
||||
if max == 0 {
|
||||
|
||||
if maxScale > maxScaleLimit {
|
||||
errs = errs.Also(apis.ErrOutOfBoundsValue(maxScale, 1, maxScaleLimit, MaxScaleAnnotationKey))
|
||||
}
|
||||
|
||||
if maxScale == 0 {
|
||||
errs = errs.Also(&apis.FieldError{
|
||||
Message: fmt.Sprint("maxScale=0 (unlimited), must be less than ", config.MaxScaleLimit),
|
||||
Message: fmt.Sprint("maxScale=0 (unlimited), must be less than ", maxScaleLimit),
|
||||
Paths: []string{MaxScaleAnnotationKey},
|
||||
})
|
||||
}
|
||||
|
||||
return errs
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -24,7 +24,7 @@ import (
|
|||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
|
||||
"knative.dev/pkg/apis"
|
||||
av1alpha1 "knative.dev/serving/pkg/apis/autoscaling/v1alpha1"
|
||||
autoscalingv1alpha1 "knative.dev/serving/pkg/apis/autoscaling/v1alpha1"
|
||||
"knative.dev/serving/pkg/apis/config"
|
||||
"knative.dev/serving/pkg/apis/serving"
|
||||
)
|
||||
|
|
@ -168,9 +168,9 @@ func (rs *RevisionStatus) PropagateDeploymentStatus(original *appsv1.DeploymentS
|
|||
}
|
||||
|
||||
// PropagateAutoscalerStatus propagates autoscaler's status to the revision's status.
|
||||
func (rs *RevisionStatus) PropagateAutoscalerStatus(ps *av1alpha1.PodAutoscalerStatus) {
|
||||
func (rs *RevisionStatus) PropagateAutoscalerStatus(ps *autoscalingv1alpha1.PodAutoscalerStatus) {
|
||||
// Reflect the PA status in our own.
|
||||
cond := ps.GetCondition(av1alpha1.PodAutoscalerConditionReady)
|
||||
cond := ps.GetCondition(autoscalingv1alpha1.PodAutoscalerConditionReady)
|
||||
if cond == nil {
|
||||
rs.MarkActiveUnknown("Deploying", "")
|
||||
return
|
||||
|
|
|
|||
|
|
@ -132,7 +132,7 @@ github.com/golang/protobuf/ptypes/timestamp
|
|||
github.com/golang/protobuf/ptypes/wrappers
|
||||
# github.com/google/btree v1.0.0
|
||||
github.com/google/btree
|
||||
# github.com/google/go-cmp v0.5.4
|
||||
# github.com/google/go-cmp v0.5.5
|
||||
## explicit
|
||||
github.com/google/go-cmp/cmp
|
||||
github.com/google/go-cmp/cmp/cmpopts
|
||||
|
|
@ -223,7 +223,7 @@ github.com/prometheus/client_golang/prometheus/internal
|
|||
github.com/prometheus/client_golang/prometheus/promhttp
|
||||
# github.com/prometheus/client_model v0.2.0
|
||||
github.com/prometheus/client_model/go
|
||||
# github.com/prometheus/common v0.15.0
|
||||
# github.com/prometheus/common v0.19.0
|
||||
github.com/prometheus/common/expfmt
|
||||
github.com/prometheus/common/internal/bitbucket.org/ww/goautoneg
|
||||
github.com/prometheus/common/log
|
||||
|
|
@ -270,7 +270,7 @@ github.com/spf13/pflag
|
|||
github.com/spf13/viper
|
||||
# github.com/subosito/gotenv v1.2.0
|
||||
github.com/subosito/gotenv
|
||||
# go.opencensus.io v0.22.6
|
||||
# go.opencensus.io v0.23.0
|
||||
go.opencensus.io
|
||||
go.opencensus.io/internal
|
||||
go.opencensus.io/internal/tagencoding
|
||||
|
|
@ -404,7 +404,7 @@ google.golang.org/genproto/googleapis/monitoring/v3
|
|||
google.golang.org/genproto/googleapis/rpc/status
|
||||
google.golang.org/genproto/googleapis/type/calendarperiod
|
||||
google.golang.org/genproto/protobuf/field_mask
|
||||
# google.golang.org/grpc v1.35.0
|
||||
# google.golang.org/grpc v1.36.0
|
||||
google.golang.org/grpc
|
||||
google.golang.org/grpc/attributes
|
||||
google.golang.org/grpc/backoff
|
||||
|
|
@ -771,7 +771,7 @@ k8s.io/kube-openapi/pkg/util/sets
|
|||
k8s.io/utils/buffer
|
||||
k8s.io/utils/integer
|
||||
k8s.io/utils/trace
|
||||
# knative.dev/eventing v0.21.1-0.20210312002228-3b427377abe0
|
||||
# knative.dev/eventing v0.21.1-0.20210331231822-8f35d42544e0
|
||||
## explicit
|
||||
knative.dev/eventing/pkg/apis/config
|
||||
knative.dev/eventing/pkg/apis/duck
|
||||
|
|
@ -800,15 +800,15 @@ knative.dev/eventing/pkg/client/clientset/versioned/typed/eventing/v1beta1/fake
|
|||
knative.dev/eventing/pkg/client/clientset/versioned/typed/messaging/v1beta1
|
||||
knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha2
|
||||
knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha2/fake
|
||||
# knative.dev/hack v0.0.0-20210309141825-9b73a256fd9a
|
||||
# knative.dev/hack v0.0.0-20210325223819-b6ab329907d3
|
||||
## explicit
|
||||
knative.dev/hack
|
||||
# knative.dev/networking v0.0.0-20210311190926-430a689490e6
|
||||
# knative.dev/networking v0.0.0-20210331064822-999a7708876c
|
||||
## explicit
|
||||
knative.dev/networking/pkg
|
||||
knative.dev/networking/pkg/apis/networking
|
||||
knative.dev/networking/pkg/apis/networking/v1alpha1
|
||||
# knative.dev/pkg v0.0.0-20210311174826-40488532be3f
|
||||
# knative.dev/pkg v0.0.0-20210331065221-952fdd90dbb0
|
||||
## explicit
|
||||
knative.dev/pkg/apis
|
||||
knative.dev/pkg/apis/duck
|
||||
|
|
@ -852,7 +852,7 @@ knative.dev/pkg/tracing/config
|
|||
knative.dev/pkg/tracing/propagation
|
||||
knative.dev/pkg/tracing/propagation/tracecontextb3
|
||||
knative.dev/pkg/tracker
|
||||
# knative.dev/serving v0.21.1-0.20210311225828-1583394c61cb
|
||||
# knative.dev/serving v0.21.1-0.20210401115722-fc58a32f0ef6
|
||||
## explicit
|
||||
knative.dev/serving/pkg/apis/autoscaling
|
||||
knative.dev/serving/pkg/apis/autoscaling/v1alpha1
|
||||
|
|
|
|||
Loading…
Reference in New Issue