mirror of https://github.com/linkerd/linkerd2.git
build(deps): bump linkerd/dev from v43 to v44 (#13428)
* docker.io/library/golang from 1.22 to 1.23 * gotestsum from 0.4.2 to 1.12.0 * protoc-gen-go from 1.28.1 to 1.35.2 * protoc-gen-go-grpc from 1.2 to 1.5.1 * docker.io/library/rust from 1.76.0 to 1.83.0 * cargo-deny from 0.14.11 to 0.16.3 * cargo-nextest from 0.9.67 to 0.9.85 * cargo-tarpaulin from 0.27.3 to 0.31.3 * just from 1.24.0 to 1.37.0 * yq from 4.33.3 to 4.44.5 * markdownlint-cli2 from 0.10.0 to 0.15.0 * shellcheck from 0.9.0 to 0.10.0 * actionlint from 1.6.26 to 1.7.4 * protoc from 3.20.3 to 29.0 * step from 0.25.2 to 0.28.2 * kubectl from 1.29.2 to 1.31.3 * k3d from 5.6.0 to 5.7.5 * k3s image shas * helm from 3.14.1 to 3.16.3 * helm-docs from 1.12.0 to 1.14.2
This commit is contained in:
Oliver Gould
GitHub
parent
683ce40e07
commit
17b2692d58
|
|
@ -1,6 +1,6 @@
|
|||
{
|
||||
"name": "linkerd2",
|
||||
"image": "ghcr.io/linkerd/dev:v43",
|
||||
"image": "ghcr.io/linkerd/dev:v44",
|
||||
// "dockerFile": "./Dockerfile",
|
||||
// "context": "..",
|
||||
"features": {
|
||||
|
|
|
|||
|
|
@ -14,13 +14,13 @@ jobs:
|
|||
runs-on: ubuntu-22.04
|
||||
timeout-minutes: 10
|
||||
steps:
|
||||
- uses: linkerd/dev/actions/setup-tools@v43
|
||||
- uses: linkerd/dev/actions/setup-tools@v44
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: just-dev lint-actions
|
||||
|
||||
devcontainer-versions:
|
||||
runs-on: ubuntu-22.04
|
||||
steps:
|
||||
- uses: linkerd/dev/actions/setup-tools@v43
|
||||
- uses: linkerd/dev/actions/setup-tools@v44
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: just-dev check-action-images
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ jobs:
|
|||
timeout-minutes: 30
|
||||
runs-on: ubuntu-22.04
|
||||
container:
|
||||
image: golang:1.22
|
||||
image: golang:1.23
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: go install gotest.tools/gotestsum@v0.4.2
|
||||
|
|
@ -51,7 +51,7 @@ jobs:
|
|||
runs-on: ubuntu-22.04
|
||||
timeout-minutes: 15
|
||||
container:
|
||||
image: docker://rust:1.76.0
|
||||
image: docker://rust:1.83.0
|
||||
options: --security-opt seccomp=unconfined
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
|
|
|
|||
|
|
@ -38,7 +38,7 @@ jobs:
|
|||
steps:
|
||||
- uses: actions/setup-go@41dfa10bad2bb2ae585af6ee5bb4d7d973ad74ed
|
||||
with:
|
||||
go-version: "1.22"
|
||||
go-version: "1.23"
|
||||
- name: Checkout
|
||||
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
|
||||
|
|
|
|||
|
|
@ -15,7 +15,7 @@ permissions:
|
|||
jobs:
|
||||
rust-version:
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-rust
|
||||
container: ghcr.io/linkerd/dev:v44-rust
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- shell: bash
|
||||
|
|
@ -39,6 +39,6 @@ jobs:
|
|||
devcontainer-image:
|
||||
runs-on: ubuntu-22.04
|
||||
steps:
|
||||
- uses: linkerd/dev/actions/setup-tools@v43
|
||||
- uses: linkerd/dev/actions/setup-tools@v44
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: just-dev pull-dev-image
|
||||
|
|
|
|||
|
|
@ -29,7 +29,7 @@ jobs:
|
|||
if: needs.meta.outputs.changed == 'true'
|
||||
timeout-minutes: 10
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-go
|
||||
container: ghcr.io/linkerd/dev:v44-go
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: git config --global --add safe.directory "$PWD" # actions/runner#2033
|
||||
|
|
@ -40,7 +40,7 @@ jobs:
|
|||
if: needs.meta.outputs.changed == 'true'
|
||||
timeout-minutes: 10
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-go
|
||||
container: ghcr.io/linkerd/dev:v44-go
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: git config --global --add safe.directory "$PWD" # actions/runner#2033
|
||||
|
|
@ -51,7 +51,7 @@ jobs:
|
|||
if: needs.meta.outputs.changed == 'true'
|
||||
timeout-minutes: 10
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-go
|
||||
container: ghcr.io/linkerd/dev:v44-go
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: git config --global --add safe.directory "$PWD" # actions/runner#2033
|
||||
|
|
|
|||
|
|
@ -16,7 +16,7 @@ jobs:
|
|||
runs-on: ubuntu-22.04
|
||||
timeout-minutes: 5
|
||||
steps:
|
||||
- uses: linkerd/dev/actions/setup-tools@v43
|
||||
- uses: linkerd/dev/actions/setup-tools@v44
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: helm-docs
|
||||
- run: git diff --exit-code -- **/charts/**/README.md
|
||||
|
|
|
|||
|
|
@ -10,10 +10,10 @@ env:
|
|||
CARGO_NET_RETRY: 10
|
||||
DOCKER_REGISTRY: ghcr.io/linkerd
|
||||
GH_ANNOTATION: true
|
||||
K3D_VERSION: v5.4.4
|
||||
K3D_VERSION: v5.7.5
|
||||
RUST_BACKTRACE: short
|
||||
RUSTUP_MAX_RETRIES: 10
|
||||
YQ_VERSION: v4.25.1
|
||||
YQ_VERSION: v4.44.5
|
||||
LINKERD2_PROXY_REPO: ${{ vars.LINKERD2_PROXY_REPO || 'linkerd/linkerd2-proxy' }}
|
||||
LINKERD2_PROXY_RELEASE_PREFIX: ${{ vars.LINKERD2_PROXY_RELEASE_PREFIX || 'release/' }}
|
||||
|
||||
|
|
@ -138,7 +138,7 @@ jobs:
|
|||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- uses: actions/setup-go@41dfa10bad2bb2ae585af6ee5bb4d7d973ad74ed
|
||||
with:
|
||||
go-version: "1.22"
|
||||
go-version: "1.23"
|
||||
- uses: actions/download-artifact@fa0a91b85d4f404e444e00e005971372dc801d16
|
||||
with:
|
||||
pattern: image-archives-*
|
||||
|
|
@ -265,7 +265,7 @@ jobs:
|
|||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- uses: actions/setup-go@41dfa10bad2bb2ae585af6ee5bb4d7d973ad74ed
|
||||
with:
|
||||
go-version: "1.22"
|
||||
go-version: "1.23"
|
||||
- uses: actions/download-artifact@fa0a91b85d4f404e444e00e005971372dc801d16
|
||||
with:
|
||||
pattern: image-archives-*
|
||||
|
|
@ -290,7 +290,7 @@ jobs:
|
|||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- uses: actions/setup-go@41dfa10bad2bb2ae585af6ee5bb4d7d973ad74ed
|
||||
with:
|
||||
go-version: "1.22"
|
||||
go-version: "1.23"
|
||||
- uses: actions/download-artifact@fa0a91b85d4f404e444e00e005971372dc801d16
|
||||
with:
|
||||
pattern: image-archives-*
|
||||
|
|
@ -324,7 +324,7 @@ jobs:
|
|||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- uses: actions/setup-go@41dfa10bad2bb2ae585af6ee5bb4d7d973ad74ed
|
||||
with:
|
||||
go-version: "1.22"
|
||||
go-version: "1.23"
|
||||
- uses: actions/download-artifact@fa0a91b85d4f404e444e00e005971372dc801d16
|
||||
with:
|
||||
pattern: image-archives-*
|
||||
|
|
|
|||
|
|
@ -15,7 +15,7 @@ jobs:
|
|||
proto-diff:
|
||||
timeout-minutes: 10
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-go
|
||||
container: ghcr.io/linkerd/dev:v44-go
|
||||
steps:
|
||||
- run: apt update && apt install -y unzip
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
|
|
|
|||
|
|
@ -11,7 +11,7 @@ permissions:
|
|||
env:
|
||||
GH_ANNOTATION: true
|
||||
DOCKER_REGISTRY: ghcr.io/linkerd
|
||||
K3D_VERSION: v5.4.4
|
||||
K3D_VERSION: v5.7.5
|
||||
LINKERD2_PROXY_REPO: ${{ vars.LINKERD2_PROXY_REPO }}
|
||||
|
||||
jobs:
|
||||
|
|
@ -98,7 +98,7 @@ jobs:
|
|||
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- uses: actions/setup-go@41dfa10bad2bb2ae585af6ee5bb4d7d973ad74ed
|
||||
with:
|
||||
go-version: "1.22"
|
||||
go-version: "1.23"
|
||||
- name: Download image archives
|
||||
uses: actions/download-artifact@fa0a91b85d4f404e444e00e005971372dc801d16
|
||||
with:
|
||||
|
|
@ -130,7 +130,7 @@ jobs:
|
|||
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- uses: actions/setup-go@41dfa10bad2bb2ae585af6ee5bb4d7d973ad74ed
|
||||
with:
|
||||
go-version: "1.22"
|
||||
go-version: "1.23"
|
||||
- name: Set environment variables from scripts
|
||||
run: |
|
||||
TAG='${{ needs.tag.outputs.tag }}'
|
||||
|
|
|
|||
|
|
@ -43,7 +43,7 @@ jobs:
|
|||
fmt:
|
||||
timeout-minutes: 5
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-rust
|
||||
container: ghcr.io/linkerd/dev:v44-rust
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: git config --global --add safe.directory "$PWD" # actions/runner#2033
|
||||
|
|
@ -52,7 +52,7 @@ jobs:
|
|||
clippy:
|
||||
timeout-minutes: 20
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-rust
|
||||
container: ghcr.io/linkerd/dev:v44-rust
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: git config --global --add safe.directory "$PWD" # actions/runner#2033
|
||||
|
|
@ -63,7 +63,7 @@ jobs:
|
|||
check:
|
||||
timeout-minutes: 20
|
||||
runs-on: ubuntu-22.04
|
||||
container: ghcr.io/linkerd/dev:v43-rust
|
||||
container: ghcr.io/linkerd/dev:v44-rust
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: git config --global --add safe.directory "$PWD" # actions/runner#2033
|
||||
|
|
@ -74,7 +74,7 @@ jobs:
|
|||
name: test
|
||||
runs-on: ubuntu-22.04
|
||||
timeout-minutes: 15
|
||||
container: ghcr.io/linkerd/dev:v43-rust
|
||||
container: ghcr.io/linkerd/dev:v44-rust
|
||||
steps:
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: git config --global --add safe.directory "$PWD" # actions/runner#2033
|
||||
|
|
|
|||
|
|
@ -16,6 +16,6 @@ jobs:
|
|||
timeout-minutes: 10
|
||||
runs-on: ubuntu-22.04
|
||||
steps:
|
||||
- uses: linkerd/dev/actions/setup-tools@v43
|
||||
- uses: linkerd/dev/actions/setup-tools@v44
|
||||
- uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
|
||||
- run: just sh-lint
|
||||
|
|
|
|||
|
|
@ -7,15 +7,15 @@
|
|||
|
||||
run:
|
||||
deadline: 5m
|
||||
skip-dirs:
|
||||
exclude-dirs:
|
||||
- controller/gen
|
||||
|
||||
linters:
|
||||
enable:
|
||||
- bodyclose
|
||||
#TODO - copyloopvar
|
||||
- errcheck
|
||||
- errorlint
|
||||
- exportloopref
|
||||
- gocritic
|
||||
- gosec
|
||||
- gosimple
|
||||
|
|
@ -41,9 +41,7 @@ linters:
|
|||
# - maligned
|
||||
# - prealloc
|
||||
|
||||
disable:
|
||||
# https://github.com/golangci/golangci-lint/issues/2649
|
||||
- structcheck
|
||||
disable: []
|
||||
|
||||
linters-settings:
|
||||
revive:
|
||||
|
|
@ -52,6 +50,14 @@ linters-settings:
|
|||
disabled: true
|
||||
stylecheck:
|
||||
checks: ["ST1019"]
|
||||
errcheck:
|
||||
exclude-functions:
|
||||
- fmt.Fprint
|
||||
- fmt.Fprintf
|
||||
- fmt.Fprintln
|
||||
gosec:
|
||||
excludes:
|
||||
- G115 # Potential integer overflow when converting between integer types
|
||||
|
||||
issues:
|
||||
exclude-use-default: false
|
||||
|
|
|
|||
|
|
@ -2,7 +2,7 @@ ARG RUNTIME_IMAGE=gcr.io/distroless/cc-debian12
|
|||
ARG BUILDPLATFORM=linux/amd64
|
||||
|
||||
# Precompile key slow-to-build dependencies
|
||||
FROM --platform=$BUILDPLATFORM golang:1.22-alpine AS go-deps
|
||||
FROM --platform=$BUILDPLATFORM golang:1.23-alpine AS go-deps
|
||||
WORKDIR /linkerd-build
|
||||
COPY go.mod go.sum ./
|
||||
COPY bin/install-deps bin/
|
||||
|
|
|
|||
2
bin/k3d
2
bin/k3d
|
|
@ -2,7 +2,7 @@
|
|||
|
||||
set -eu
|
||||
|
||||
K3D_VERSION=v5.4.3
|
||||
K3D_VERSION=v5.7.5
|
||||
|
||||
bindir=$( cd "${0%/*}" && pwd )
|
||||
|
||||
|
|
|
|||
|
|
@ -48,6 +48,9 @@ Note that the provided certificates must be ECDSA certificates.
|
|||
|
||||
## Adding Linkerd's Helm repository
|
||||
|
||||
Included here for completeness-sake, but should have already been added when
|
||||
`linkerd-base` was installed.
|
||||
|
||||
```bash
|
||||
# To add the repo for Linkerd edge releases:
|
||||
helm repo add linkerd https://helm.linkerd.io/edge
|
||||
|
|
@ -66,6 +69,9 @@ helm install linkerd-control-plane -n linkerd \
|
|||
linkerd/linkerd-control-plane
|
||||
```
|
||||
|
||||
Note that you require to install this chart in the same namespace you installed
|
||||
the `linkerd-base` chart.
|
||||
|
||||
## Setting High-Availability
|
||||
|
||||
Besides the default `values.yaml` file, the chart provides a `values-ha.yaml`
|
||||
|
|
@ -313,4 +319,4 @@ Kubernetes: `>=1.22.0-0`
|
|||
| webhookFailurePolicy | string | `"Ignore"` | Failure policy for the proxy injector |
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -70,4 +70,4 @@ Kubernetes: `>=1.22.0-0`
|
|||
| enableTlsRoutes | bool | `true` | |
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -68,4 +68,4 @@ Kubernetes: `>=1.22.0-0`
|
|||
| useWaitFlag | bool | `false` | Configures the CNI plugin to use the -w flag for the iptables command |
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -6,4 +6,4 @@ depended by the 'linkerd' and 'patch' charts.
|
|||
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
ARG BUILDPLATFORM=linux/amd64
|
||||
|
||||
# Precompile key slow-to-build dependencies
|
||||
FROM --platform=$BUILDPLATFORM golang:1.22-alpine AS go-deps
|
||||
FROM --platform=$BUILDPLATFORM golang:1.23-alpine AS go-deps
|
||||
WORKDIR /linkerd-build
|
||||
COPY go.mod go.sum ./
|
||||
COPY bin/install-deps bin/
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
ARG BUILDPLATFORM=linux/amd64
|
||||
|
||||
# Precompile key slow-to-build dependencies
|
||||
FROM --platform=$BUILDPLATFORM golang:1.22-alpine AS go-deps
|
||||
FROM --platform=$BUILDPLATFORM golang:1.23-alpine AS go-deps
|
||||
WORKDIR /linkerd-build
|
||||
COPY go.mod go.sum ./
|
||||
COPY bin/install-deps bin/
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.28.1
|
||||
// protoc-gen-go v1.35.2
|
||||
// protoc v3.20.0
|
||||
// source: common/net.proto
|
||||
|
||||
|
|
@ -34,11 +34,9 @@ type IPAddress struct {
|
|||
|
||||
func (x *IPAddress) Reset() {
|
||||
*x = IPAddress{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_common_net_proto_msgTypes[0]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *IPAddress) String() string {
|
||||
|
|
@ -49,7 +47,7 @@ func (*IPAddress) ProtoMessage() {}
|
|||
|
||||
func (x *IPAddress) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_common_net_proto_msgTypes[0]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -112,11 +110,9 @@ type IPv6 struct {
|
|||
|
||||
func (x *IPv6) Reset() {
|
||||
*x = IPv6{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_common_net_proto_msgTypes[1]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *IPv6) String() string {
|
||||
|
|
@ -127,7 +123,7 @@ func (*IPv6) ProtoMessage() {}
|
|||
|
||||
func (x *IPv6) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_common_net_proto_msgTypes[1]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -167,11 +163,9 @@ type TcpAddress struct {
|
|||
|
||||
func (x *TcpAddress) Reset() {
|
||||
*x = TcpAddress{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_common_net_proto_msgTypes[2]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TcpAddress) String() string {
|
||||
|
|
@ -182,7 +176,7 @@ func (*TcpAddress) ProtoMessage() {}
|
|||
|
||||
func (x *TcpAddress) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_common_net_proto_msgTypes[2]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -250,7 +244,7 @@ func file_common_net_proto_rawDescGZIP() []byte {
|
|||
}
|
||||
|
||||
var file_common_net_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
|
||||
var file_common_net_proto_goTypes = []interface{}{
|
||||
var file_common_net_proto_goTypes = []any{
|
||||
(*IPAddress)(nil), // 0: linkerd2.common.net.IPAddress
|
||||
(*IPv6)(nil), // 1: linkerd2.common.net.IPv6
|
||||
(*TcpAddress)(nil), // 2: linkerd2.common.net.TcpAddress
|
||||
|
|
@ -270,45 +264,7 @@ func file_common_net_proto_init() {
|
|||
if File_common_net_proto != nil {
|
||||
return
|
||||
}
|
||||
if !protoimpl.UnsafeEnabled {
|
||||
file_common_net_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*IPAddress); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_common_net_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*IPv6); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_common_net_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TcpAddress); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
}
|
||||
file_common_net_proto_msgTypes[0].OneofWrappers = []interface{}{
|
||||
file_common_net_proto_msgTypes[0].OneofWrappers = []any{
|
||||
(*IPAddress_Ipv4)(nil),
|
||||
(*IPAddress_Ipv6)(nil),
|
||||
}
|
||||
|
|
|
|||
23
deny.toml
23
deny.toml
|
|
@ -1,3 +1,4 @@
|
|||
[graph]
|
||||
targets = [
|
||||
{ triple = "x86_64-unknown-linux-gnu" },
|
||||
{ triple = "aarch64-unknown-linux-gnu" },
|
||||
|
|
@ -7,14 +8,13 @@ targets = [
|
|||
[advisories]
|
||||
db-path = "~/.cargo/advisory-db"
|
||||
db-urls = ["https://github.com/rustsec/advisory-db"]
|
||||
vulnerability = "deny"
|
||||
unmaintained = "warn"
|
||||
yanked = "deny"
|
||||
notice = "warn"
|
||||
ignore = []
|
||||
ignore = [
|
||||
# Pending kube update
|
||||
"RUSTSEC-2024-0384",
|
||||
"RUSTSEC-2024-0388",
|
||||
]
|
||||
|
||||
[licenses]
|
||||
unlicensed = "deny"
|
||||
allow = [
|
||||
"Apache-2.0",
|
||||
"BSD-2-Clause",
|
||||
|
|
@ -23,10 +23,6 @@ allow = [
|
|||
"MIT",
|
||||
"Unicode-DFS-2016",
|
||||
]
|
||||
deny = []
|
||||
copyleft = "deny"
|
||||
allow-osi-fsf-free = "neither"
|
||||
default = "deny"
|
||||
confidence-threshold = 0.8
|
||||
exceptions = [
|
||||
{ allow = [
|
||||
|
|
@ -51,21 +47,16 @@ multiple-versions = "deny"
|
|||
# Wildcard dependencies are used for all workspace-local crates.
|
||||
wildcards = "allow"
|
||||
highlight = "all"
|
||||
deny = []
|
||||
skip = [
|
||||
# `rustls-pemfile` and `k8s-openapi` depend on versions of `base64` that
|
||||
# have diverged significantly.
|
||||
{ name = "base64" },
|
||||
# syn v2 has been released and some libraries are slower to adopt it
|
||||
{ name = "syn", version = "1.0" },
|
||||
# `tower-http` (a transitive dep via `kubert`) depends on v2.x of `bitflags`,
|
||||
# while pretty much the entire rest of the world is still on v1.x
|
||||
{ name = "bitflags", version = "1.0" },
|
||||
# https://github.com/hawkw/matchers/pull/4
|
||||
{ name = "regex-automata", version = "0.1" },
|
||||
{ name = "regex-syntax", version = "0.6" },
|
||||
# Pending hyper upgrade to 1.0
|
||||
{ name = "socket2" },
|
||||
]
|
||||
skip-tree = [
|
||||
# `serde_json` and `h2` depend on diverged versions of `indexmap` (2.0.x and
|
||||
|
|
@ -77,7 +68,7 @@ skip-tree = [
|
|||
unknown-registry = "deny"
|
||||
unknown-git = "deny"
|
||||
allow-registry = ["https://github.com/rust-lang/crates.io-index"]
|
||||
allow-git = ["https://github.com/linkerd/linkerd2-proxy-api"]
|
||||
allow-git = []
|
||||
|
||||
[sources.allow-org]
|
||||
github = []
|
||||
|
|
|
|||
2
go.mod
2
go.mod
|
|
@ -1,6 +1,6 @@
|
|||
module github.com/linkerd/linkerd2
|
||||
|
||||
go 1.22.0
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
contrib.go.opencensus.io/exporter/ocagent v0.7.0
|
||||
|
|
|
|||
|
|
@ -148,4 +148,4 @@ Kubernetes: `>=1.22.0-0`
|
|||
| webhook.tolerations | string | `nil` | Tolerations section, See the [K8S documentation](https://kubernetes.io/docs/concepts/scheduling-eviction/taint-and-toleration/) for more information |
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
ARG BUILDPLATFORM=linux/amd64
|
||||
|
||||
# Precompile key slow-to-build dependencies
|
||||
FROM --platform=$BUILDPLATFORM golang:1.22-alpine AS go-deps
|
||||
FROM --platform=$BUILDPLATFORM golang:1.23-alpine AS go-deps
|
||||
WORKDIR /linkerd-build
|
||||
COPY go.mod go.sum ./
|
||||
COPY bin/install-deps bin/
|
||||
|
|
|
|||
|
|
@ -50,4 +50,4 @@ Kubernetes: `>=1.22.0-0`
|
|||
| tolerations | object | `{}` | Tolerations for the Service mirror pod |
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -120,4 +120,4 @@ Kubernetes: `>=1.22.0-0`
|
|||
| revisionHistoryLimit | int | `10` | Specifies the number of old ReplicaSets to retain to allow rollback. |
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
FROM --platform=$BUILDPLATFORM ghcr.io/linkerd/dev:v43-rust-musl AS controller
|
||||
FROM --platform=$BUILDPLATFORM ghcr.io/linkerd/dev:v44-rust-musl AS controller
|
||||
ARG BUILD_TYPE="release"
|
||||
WORKDIR /build
|
||||
RUN mkdir -p target/bin
|
||||
|
|
|
|||
|
|
@ -9,7 +9,7 @@ publish = false
|
|||
ahash = "0.8"
|
||||
anyhow = "1"
|
||||
async-trait = "0.1"
|
||||
chrono = { version = "0.4.38", default_features = false }
|
||||
chrono = { version = "0.4.38", default-features = false }
|
||||
futures = { version = "0.3", default-features = false, features = ["std"] }
|
||||
http = "0.2"
|
||||
ipnet = "2"
|
||||
|
|
|
|||
|
|
@ -72,9 +72,6 @@ fn convert_outbound_route(
|
|||
parent_info: &ParentInfo,
|
||||
original_dst: Option<SocketAddr>,
|
||||
) -> outbound::GrpcRoute {
|
||||
// This encoder sets deprecated timeouts for older proxies.
|
||||
#![allow(deprecated)]
|
||||
|
||||
let metadata = Some(meta::Metadata {
|
||||
kind: Some(meta::metadata::Kind::Resource(meta::Resource {
|
||||
group: gknn.group.to_string(),
|
||||
|
|
@ -122,6 +119,7 @@ fn convert_outbound_route(
|
|||
if retry.is_none() {
|
||||
retry = service_retry.clone();
|
||||
}
|
||||
#[allow(deprecated)]
|
||||
outbound::grpc_route::Rule {
|
||||
matches: matches.into_iter().map(convert_match).collect(),
|
||||
backends: Some(outbound::grpc_route::Distribution { kind: Some(dist) }),
|
||||
|
|
|
|||
|
|
@ -99,8 +99,6 @@ fn convert_outbound_route(
|
|||
parent_info: &ParentInfo,
|
||||
original_dst: Option<SocketAddr>,
|
||||
) -> outbound::HttpRoute {
|
||||
// This encoder sets deprecated timeouts for older proxies.
|
||||
#![allow(deprecated)]
|
||||
let metadata = Some(meta::Metadata {
|
||||
kind: Some(meta::metadata::Kind::Resource(meta::Resource {
|
||||
group: gknn.group.to_string(),
|
||||
|
|
@ -148,6 +146,8 @@ fn convert_outbound_route(
|
|||
if retry.is_none() {
|
||||
retry = service_retry.clone();
|
||||
}
|
||||
// This encoder sets deprecated timeouts for older proxies.
|
||||
#[allow(deprecated)]
|
||||
outbound::http_route::Rule {
|
||||
matches: matches.into_iter().map(convert_match).collect(),
|
||||
backends: Some(outbound::http_route::Distribution { kind: Some(dist) }),
|
||||
|
|
|
|||
|
|
@ -140,7 +140,7 @@ impl<'de> Deserialize<'de> for K8sDuration {
|
|||
D: Deserializer<'de>,
|
||||
{
|
||||
struct Visitor;
|
||||
impl<'de> de::Visitor<'de> for Visitor {
|
||||
impl de::Visitor<'_> for Visitor {
|
||||
type Value = K8sDuration;
|
||||
|
||||
fn expecting(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ publish = false
|
|||
[dependencies]
|
||||
ahash = "0.8"
|
||||
anyhow = "1"
|
||||
chrono = { version = "0.4.38", default_features = false }
|
||||
chrono = { version = "0.4.38", default-features = false }
|
||||
futures = { version = "0.3", default-features = false }
|
||||
http = "0.2"
|
||||
kube = { workspace = true, default-features = false, features = [
|
||||
|
|
|
|||
|
|
@ -267,14 +267,14 @@ mod tests {
|
|||
let mut expected_5432 = BTreeSet::new();
|
||||
expected_5432.insert("/liveness-container-1".to_string());
|
||||
expected_5432.insert("/ready-container-1".to_string());
|
||||
assert!(probes.get(&port_5432).is_some());
|
||||
assert!(probes.contains_key(&port_5432));
|
||||
assert_eq!(*probes.get(&port_5432).unwrap(), expected_5432);
|
||||
|
||||
let port_6543 = u16::try_from(6543).and_then(NonZeroU16::try_from).unwrap();
|
||||
let mut expected_6543 = BTreeSet::new();
|
||||
expected_6543.insert("/liveness-container-2".to_string());
|
||||
expected_6543.insert("/ready-container-2".to_string());
|
||||
assert!(probes.get(&port_6543).is_some());
|
||||
assert!(probes.contains_key(&port_6543));
|
||||
assert_eq!(*probes.get(&port_6543).unwrap(), expected_6543);
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -134,7 +134,7 @@ mod test {
|
|||
#[test]
|
||||
fn test_picks_smallest_cidr() {
|
||||
let ip_addr = "192.168.0.4".parse().unwrap();
|
||||
let networks = vec![
|
||||
let networks = [
|
||||
EgressNetwork {
|
||||
networks: vec![Network {
|
||||
cidr: "192.168.0.1/16".parse().unwrap(),
|
||||
|
|
@ -165,7 +165,7 @@ mod test {
|
|||
#[test]
|
||||
fn test_picks_local_ns() {
|
||||
let ip_addr = "192.168.0.4".parse().unwrap();
|
||||
let networks = vec![
|
||||
let networks = [
|
||||
EgressNetwork {
|
||||
networks: vec![Network {
|
||||
cidr: "192.168.0.1/16".parse().unwrap(),
|
||||
|
|
@ -196,7 +196,7 @@ mod test {
|
|||
#[test]
|
||||
fn does_not_pick_network_in_unralated_ns() {
|
||||
let ip_addr = "192.168.0.4".parse().unwrap();
|
||||
let networks = vec![EgressNetwork {
|
||||
let networks = [EgressNetwork {
|
||||
networks: vec![Network {
|
||||
cidr: "192.168.0.1/16".parse().unwrap(),
|
||||
except: None,
|
||||
|
|
@ -215,7 +215,7 @@ mod test {
|
|||
#[test]
|
||||
fn test_picks_older_resource() {
|
||||
let ip_addr = "192.168.0.4".parse().unwrap();
|
||||
let networks = vec![
|
||||
let networks = [
|
||||
EgressNetwork {
|
||||
networks: vec![Network {
|
||||
cidr: "192.168.0.1/16".parse().unwrap(),
|
||||
|
|
@ -246,7 +246,7 @@ mod test {
|
|||
#[test]
|
||||
fn test_picks_alphabetical_order() {
|
||||
let ip_addr = "192.168.0.4".parse().unwrap();
|
||||
let networks = vec![
|
||||
let networks = [
|
||||
EgressNetwork {
|
||||
networks: vec![Network {
|
||||
cidr: "192.168.0.1/16".parse().unwrap(),
|
||||
|
|
@ -277,7 +277,7 @@ mod test {
|
|||
#[test]
|
||||
fn test_respects_exception() {
|
||||
let ip_addr = "192.168.0.4".parse().unwrap();
|
||||
let networks = vec![
|
||||
let networks = [
|
||||
EgressNetwork {
|
||||
networks: vec![Network {
|
||||
cidr: "192.168.0.1/16".parse().unwrap(),
|
||||
|
|
|
|||
|
|
@ -750,12 +750,7 @@ impl Index {
|
|||
id: &NamespaceGroupKindName,
|
||||
ratelimit: &HttpLocalRateLimitPolicyRef,
|
||||
) -> Option<k8s_core_api::Patch<serde_json::Value>> {
|
||||
let status = self.target_ref_status(id, &ratelimit.target_ref);
|
||||
|
||||
let Some(status) = status else {
|
||||
return None;
|
||||
};
|
||||
|
||||
let status = self.target_ref_status(id, &ratelimit.target_ref)?;
|
||||
if eq_time_insensitive_conditions(&status.conditions, &ratelimit.status_conditions) {
|
||||
return None;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,2 +1,2 @@
|
|||
[toolchain]
|
||||
channel = "1.76.0"
|
||||
channel = "1.83.0"
|
||||
|
|
|
|||
|
|
@ -15,7 +15,7 @@ spec:
|
|||
spec:
|
||||
containers:
|
||||
- image: ghcr.io/alpeb/family-server:v1
|
||||
image: golang:1.22-alpine
|
||||
image: golang:1.23-alpine
|
||||
name: ipfamilies-server
|
||||
ports:
|
||||
- containerPort: 8080
|
||||
|
|
|
|||
|
|
@ -218,4 +218,4 @@ Kubernetes: `>=1.22.0-0`
|
|||
| tolerations | string | `nil` | Default tolerations section, See the [K8S documentation](https://kubernetes.io/docs/concepts/scheduling-eviction/taint-and-toleration/) for more information |
|
||||
|
||||
----------------------------------------------
|
||||
Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0)
|
||||
Autogenerated from chart metadata using [helm-docs v1.14.2](https://github.com/norwoodj/helm-docs/releases/v1.14.2)
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
ARG BUILDPLATFORM=linux/amd64
|
||||
|
||||
# Precompile key slow-to-build dependencies
|
||||
FROM --platform=$BUILDPLATFORM golang:1.22-alpine AS go-deps
|
||||
FROM --platform=$BUILDPLATFORM golang:1.23-alpine AS go-deps
|
||||
WORKDIR /linkerd-build
|
||||
COPY go.mod go.sum ./
|
||||
COPY bin/install-deps bin/
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load Diff
|
|
@ -1,6 +1,6 @@
|
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-grpc v1.2.0
|
||||
// - protoc-gen-go-grpc v1.5.1
|
||||
// - protoc v3.20.0
|
||||
// source: viz.proto
|
||||
|
||||
|
|
@ -15,8 +15,19 @@ 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
|
||||
// Requires gRPC-Go v1.64.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion9
|
||||
|
||||
const (
|
||||
Api_StatSummary_FullMethodName = "/linkerd2.viz.Api/StatSummary"
|
||||
Api_Edges_FullMethodName = "/linkerd2.viz.Api/Edges"
|
||||
Api_Gateways_FullMethodName = "/linkerd2.viz.Api/Gateways"
|
||||
Api_TopRoutes_FullMethodName = "/linkerd2.viz.Api/TopRoutes"
|
||||
Api_ListPods_FullMethodName = "/linkerd2.viz.Api/ListPods"
|
||||
Api_ListServices_FullMethodName = "/linkerd2.viz.Api/ListServices"
|
||||
Api_SelfCheck_FullMethodName = "/linkerd2.viz.Api/SelfCheck"
|
||||
Api_Authz_FullMethodName = "/linkerd2.viz.Api/Authz"
|
||||
)
|
||||
|
||||
// ApiClient is the client API for Api service.
|
||||
//
|
||||
|
|
@ -41,8 +52,9 @@ func NewApiClient(cc grpc.ClientConnInterface) ApiClient {
|
|||
}
|
||||
|
||||
func (c *apiClient) StatSummary(ctx context.Context, in *StatSummaryRequest, opts ...grpc.CallOption) (*StatSummaryResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(StatSummaryResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/StatSummary", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_StatSummary_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -50,8 +62,9 @@ func (c *apiClient) StatSummary(ctx context.Context, in *StatSummaryRequest, opt
|
|||
}
|
||||
|
||||
func (c *apiClient) Edges(ctx context.Context, in *EdgesRequest, opts ...grpc.CallOption) (*EdgesResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(EdgesResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/Edges", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_Edges_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -59,8 +72,9 @@ func (c *apiClient) Edges(ctx context.Context, in *EdgesRequest, opts ...grpc.Ca
|
|||
}
|
||||
|
||||
func (c *apiClient) Gateways(ctx context.Context, in *GatewaysRequest, opts ...grpc.CallOption) (*GatewaysResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GatewaysResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/Gateways", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_Gateways_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -68,8 +82,9 @@ func (c *apiClient) Gateways(ctx context.Context, in *GatewaysRequest, opts ...g
|
|||
}
|
||||
|
||||
func (c *apiClient) TopRoutes(ctx context.Context, in *TopRoutesRequest, opts ...grpc.CallOption) (*TopRoutesResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(TopRoutesResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/TopRoutes", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_TopRoutes_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -77,8 +92,9 @@ func (c *apiClient) TopRoutes(ctx context.Context, in *TopRoutesRequest, opts ..
|
|||
}
|
||||
|
||||
func (c *apiClient) ListPods(ctx context.Context, in *ListPodsRequest, opts ...grpc.CallOption) (*ListPodsResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(ListPodsResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/ListPods", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_ListPods_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -86,8 +102,9 @@ func (c *apiClient) ListPods(ctx context.Context, in *ListPodsRequest, opts ...g
|
|||
}
|
||||
|
||||
func (c *apiClient) ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(ListServicesResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/ListServices", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_ListServices_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -95,8 +112,9 @@ func (c *apiClient) ListServices(ctx context.Context, in *ListServicesRequest, o
|
|||
}
|
||||
|
||||
func (c *apiClient) SelfCheck(ctx context.Context, in *SelfCheckRequest, opts ...grpc.CallOption) (*SelfCheckResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(SelfCheckResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/SelfCheck", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_SelfCheck_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -104,8 +122,9 @@ func (c *apiClient) SelfCheck(ctx context.Context, in *SelfCheckRequest, opts ..
|
|||
}
|
||||
|
||||
func (c *apiClient) Authz(ctx context.Context, in *AuthzRequest, opts ...grpc.CallOption) (*AuthzResponse, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(AuthzResponse)
|
||||
err := c.cc.Invoke(ctx, "/linkerd2.viz.Api/Authz", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Api_Authz_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -114,7 +133,7 @@ func (c *apiClient) Authz(ctx context.Context, in *AuthzRequest, opts ...grpc.Ca
|
|||
|
||||
// ApiServer is the server API for Api service.
|
||||
// All implementations must embed UnimplementedApiServer
|
||||
// for forward compatibility
|
||||
// for forward compatibility.
|
||||
type ApiServer interface {
|
||||
StatSummary(context.Context, *StatSummaryRequest) (*StatSummaryResponse, error)
|
||||
Edges(context.Context, *EdgesRequest) (*EdgesResponse, error)
|
||||
|
|
@ -127,9 +146,12 @@ type ApiServer interface {
|
|||
mustEmbedUnimplementedApiServer()
|
||||
}
|
||||
|
||||
// UnimplementedApiServer must be embedded to have forward compatible implementations.
|
||||
type UnimplementedApiServer struct {
|
||||
}
|
||||
// UnimplementedApiServer must be embedded to have
|
||||
// forward compatible implementations.
|
||||
//
|
||||
// NOTE: this should be embedded by value instead of pointer to avoid a nil
|
||||
// pointer dereference when methods are called.
|
||||
type UnimplementedApiServer struct{}
|
||||
|
||||
func (UnimplementedApiServer) StatSummary(context.Context, *StatSummaryRequest) (*StatSummaryResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method StatSummary not implemented")
|
||||
|
|
@ -156,6 +178,7 @@ func (UnimplementedApiServer) Authz(context.Context, *AuthzRequest) (*AuthzRespo
|
|||
return nil, status.Errorf(codes.Unimplemented, "method Authz not implemented")
|
||||
}
|
||||
func (UnimplementedApiServer) mustEmbedUnimplementedApiServer() {}
|
||||
func (UnimplementedApiServer) testEmbeddedByValue() {}
|
||||
|
||||
// UnsafeApiServer may be embedded to opt out of forward compatibility for this service.
|
||||
// Use of this interface is not recommended, as added methods to ApiServer will
|
||||
|
|
@ -165,6 +188,13 @@ type UnsafeApiServer interface {
|
|||
}
|
||||
|
||||
func RegisterApiServer(s grpc.ServiceRegistrar, srv ApiServer) {
|
||||
// If the following call pancis, it indicates UnimplementedApiServer was
|
||||
// embedded by pointer and is nil. This will cause panics if an
|
||||
// unimplemented method is ever invoked, so we test this at initialization
|
||||
// time to prevent it from happening at runtime later due to I/O.
|
||||
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
|
||||
t.testEmbeddedByValue()
|
||||
}
|
||||
s.RegisterService(&Api_ServiceDesc, srv)
|
||||
}
|
||||
|
||||
|
|
@ -178,7 +208,7 @@ func _Api_StatSummary_Handler(srv interface{}, ctx context.Context, dec func(int
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/StatSummary",
|
||||
FullMethod: Api_StatSummary_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).StatSummary(ctx, req.(*StatSummaryRequest))
|
||||
|
|
@ -196,7 +226,7 @@ func _Api_Edges_Handler(srv interface{}, ctx context.Context, dec func(interface
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/Edges",
|
||||
FullMethod: Api_Edges_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).Edges(ctx, req.(*EdgesRequest))
|
||||
|
|
@ -214,7 +244,7 @@ func _Api_Gateways_Handler(srv interface{}, ctx context.Context, dec func(interf
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/Gateways",
|
||||
FullMethod: Api_Gateways_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).Gateways(ctx, req.(*GatewaysRequest))
|
||||
|
|
@ -232,7 +262,7 @@ func _Api_TopRoutes_Handler(srv interface{}, ctx context.Context, dec func(inter
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/TopRoutes",
|
||||
FullMethod: Api_TopRoutes_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).TopRoutes(ctx, req.(*TopRoutesRequest))
|
||||
|
|
@ -250,7 +280,7 @@ func _Api_ListPods_Handler(srv interface{}, ctx context.Context, dec func(interf
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/ListPods",
|
||||
FullMethod: Api_ListPods_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).ListPods(ctx, req.(*ListPodsRequest))
|
||||
|
|
@ -268,7 +298,7 @@ func _Api_ListServices_Handler(srv interface{}, ctx context.Context, dec func(in
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/ListServices",
|
||||
FullMethod: Api_ListServices_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).ListServices(ctx, req.(*ListServicesRequest))
|
||||
|
|
@ -286,7 +316,7 @@ func _Api_SelfCheck_Handler(srv interface{}, ctx context.Context, dec func(inter
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/SelfCheck",
|
||||
FullMethod: Api_SelfCheck_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).SelfCheck(ctx, req.(*SelfCheckRequest))
|
||||
|
|
@ -304,7 +334,7 @@ func _Api_Authz_Handler(srv interface{}, ctx context.Context, dec func(interface
|
|||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/linkerd2.viz.Api/Authz",
|
||||
FullMethod: Api_Authz_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ApiServer).Authz(ctx, req.(*AuthzRequest))
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
ARG BUILDPLATFORM=linux/amd64
|
||||
|
||||
# Precompile key slow-to-build dependencies
|
||||
FROM --platform=$BUILDPLATFORM golang:1.22-alpine AS go-deps
|
||||
FROM --platform=$BUILDPLATFORM golang:1.23-alpine AS go-deps
|
||||
WORKDIR /linkerd-build
|
||||
COPY go.mod go.sum ./
|
||||
COPY bin/install-deps bin/
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.28.1
|
||||
// protoc-gen-go v1.35.2
|
||||
// protoc v3.20.0
|
||||
// source: viz_tap.proto
|
||||
|
||||
|
|
@ -72,7 +72,7 @@ func (TapEvent_ProxyDirection) EnumDescriptor() ([]byte, []int) {
|
|||
return file_viz_tap_proto_rawDescGZIP(), []int{2, 0}
|
||||
}
|
||||
|
||||
// Deprecated: Do not use.
|
||||
// Deprecated: Marked as deprecated in viz_tap.proto.
|
||||
type TapRequest struct {
|
||||
state protoimpl.MessageState
|
||||
sizeCache protoimpl.SizeCache
|
||||
|
|
@ -97,11 +97,9 @@ type TapRequest struct {
|
|||
|
||||
func (x *TapRequest) Reset() {
|
||||
*x = TapRequest{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[0]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapRequest) String() string {
|
||||
|
|
@ -112,7 +110,7 @@ func (*TapRequest) ProtoMessage() {}
|
|||
|
||||
func (x *TapRequest) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[0]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -248,11 +246,9 @@ type TapByResourceRequest struct {
|
|||
|
||||
func (x *TapByResourceRequest) Reset() {
|
||||
*x = TapByResourceRequest{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[1]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapByResourceRequest) String() string {
|
||||
|
|
@ -263,7 +259,7 @@ func (*TapByResourceRequest) ProtoMessage() {}
|
|||
|
||||
func (x *TapByResourceRequest) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[1]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -326,11 +322,9 @@ type TapEvent struct {
|
|||
|
||||
func (x *TapEvent) Reset() {
|
||||
*x = TapEvent{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[2]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent) String() string {
|
||||
|
|
@ -341,7 +335,7 @@ func (*TapEvent) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[2]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -439,11 +433,9 @@ type TapByResourceRequest_Match struct {
|
|||
|
||||
func (x *TapByResourceRequest_Match) Reset() {
|
||||
*x = TapByResourceRequest_Match{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[3]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapByResourceRequest_Match) String() string {
|
||||
|
|
@ -454,7 +446,7 @@ func (*TapByResourceRequest_Match) ProtoMessage() {}
|
|||
|
||||
func (x *TapByResourceRequest_Match) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[3]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -563,11 +555,9 @@ type TapByResourceRequest_Extract struct {
|
|||
|
||||
func (x *TapByResourceRequest_Extract) Reset() {
|
||||
*x = TapByResourceRequest_Extract{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[4]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapByResourceRequest_Extract) String() string {
|
||||
|
|
@ -578,7 +568,7 @@ func (*TapByResourceRequest_Extract) ProtoMessage() {}
|
|||
|
||||
func (x *TapByResourceRequest_Extract) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[4]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -627,11 +617,9 @@ type TapByResourceRequest_Match_Seq struct {
|
|||
|
||||
func (x *TapByResourceRequest_Match_Seq) Reset() {
|
||||
*x = TapByResourceRequest_Match_Seq{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[5]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapByResourceRequest_Match_Seq) String() string {
|
||||
|
|
@ -642,7 +630,7 @@ func (*TapByResourceRequest_Match_Seq) ProtoMessage() {}
|
|||
|
||||
func (x *TapByResourceRequest_Match_Seq) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[5]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -680,11 +668,9 @@ type TapByResourceRequest_Match_Http struct {
|
|||
|
||||
func (x *TapByResourceRequest_Match_Http) Reset() {
|
||||
*x = TapByResourceRequest_Match_Http{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[6]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapByResourceRequest_Match_Http) String() string {
|
||||
|
|
@ -695,7 +681,7 @@ func (*TapByResourceRequest_Match_Http) ProtoMessage() {}
|
|||
|
||||
func (x *TapByResourceRequest_Match_Http) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[6]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -786,11 +772,9 @@ type TapByResourceRequest_Extract_Http struct {
|
|||
|
||||
func (x *TapByResourceRequest_Extract_Http) Reset() {
|
||||
*x = TapByResourceRequest_Extract_Http{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[7]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapByResourceRequest_Extract_Http) String() string {
|
||||
|
|
@ -801,7 +785,7 @@ func (*TapByResourceRequest_Extract_Http) ProtoMessage() {}
|
|||
|
||||
func (x *TapByResourceRequest_Extract_Http) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[7]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -848,11 +832,9 @@ type TapByResourceRequest_Extract_Http_Headers struct {
|
|||
|
||||
func (x *TapByResourceRequest_Extract_Http_Headers) Reset() {
|
||||
*x = TapByResourceRequest_Extract_Http_Headers{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[8]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapByResourceRequest_Extract_Http_Headers) String() string {
|
||||
|
|
@ -863,7 +845,7 @@ func (*TapByResourceRequest_Extract_Http_Headers) ProtoMessage() {}
|
|||
|
||||
func (x *TapByResourceRequest_Extract_Http_Headers) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[8]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -888,11 +870,9 @@ type TapEvent_EndpointMeta struct {
|
|||
|
||||
func (x *TapEvent_EndpointMeta) Reset() {
|
||||
*x = TapEvent_EndpointMeta{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[9]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent_EndpointMeta) String() string {
|
||||
|
|
@ -903,7 +883,7 @@ func (*TapEvent_EndpointMeta) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent_EndpointMeta) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[9]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -935,11 +915,9 @@ type TapEvent_RouteMeta struct {
|
|||
|
||||
func (x *TapEvent_RouteMeta) Reset() {
|
||||
*x = TapEvent_RouteMeta{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[10]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent_RouteMeta) String() string {
|
||||
|
|
@ -950,7 +928,7 @@ func (*TapEvent_RouteMeta) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent_RouteMeta) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[10]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -987,11 +965,9 @@ type TapEvent_Http struct {
|
|||
|
||||
func (x *TapEvent_Http) Reset() {
|
||||
*x = TapEvent_Http{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[11]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent_Http) String() string {
|
||||
|
|
@ -1002,7 +978,7 @@ func (*TapEvent_Http) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent_Http) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[11]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -1080,11 +1056,9 @@ type TapEvent_Http_StreamId struct {
|
|||
|
||||
func (x *TapEvent_Http_StreamId) Reset() {
|
||||
*x = TapEvent_Http_StreamId{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[14]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent_Http_StreamId) String() string {
|
||||
|
|
@ -1095,7 +1069,7 @@ func (*TapEvent_Http_StreamId) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent_Http_StreamId) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[14]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -1139,11 +1113,9 @@ type TapEvent_Http_RequestInit struct {
|
|||
|
||||
func (x *TapEvent_Http_RequestInit) Reset() {
|
||||
*x = TapEvent_Http_RequestInit{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[15]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent_Http_RequestInit) String() string {
|
||||
|
|
@ -1154,7 +1126,7 @@ func (*TapEvent_Http_RequestInit) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent_Http_RequestInit) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[15]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -1224,11 +1196,9 @@ type TapEvent_Http_ResponseInit struct {
|
|||
|
||||
func (x *TapEvent_Http_ResponseInit) Reset() {
|
||||
*x = TapEvent_Http_ResponseInit{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[16]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent_Http_ResponseInit) String() string {
|
||||
|
|
@ -1239,7 +1209,7 @@ func (*TapEvent_Http_ResponseInit) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent_Http_ResponseInit) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[16]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -1297,11 +1267,9 @@ type TapEvent_Http_ResponseEnd struct {
|
|||
|
||||
func (x *TapEvent_Http_ResponseEnd) Reset() {
|
||||
*x = TapEvent_Http_ResponseEnd{}
|
||||
if protoimpl.UnsafeEnabled {
|
||||
mi := &file_viz_tap_proto_msgTypes[17]
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
ms.StoreMessageInfo(mi)
|
||||
}
|
||||
}
|
||||
|
||||
func (x *TapEvent_Http_ResponseEnd) String() string {
|
||||
|
|
@ -1312,7 +1280,7 @@ func (*TapEvent_Http_ResponseEnd) ProtoMessage() {}
|
|||
|
||||
func (x *TapEvent_Http_ResponseEnd) ProtoReflect() protoreflect.Message {
|
||||
mi := &file_viz_tap_proto_msgTypes[17]
|
||||
if protoimpl.UnsafeEnabled && x != nil {
|
||||
if x != nil {
|
||||
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
||||
if ms.LoadMessageInfo() == nil {
|
||||
ms.StoreMessageInfo(mi)
|
||||
|
|
@ -1613,7 +1581,7 @@ func file_viz_tap_proto_rawDescGZIP() []byte {
|
|||
|
||||
var file_viz_tap_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
|
||||
var file_viz_tap_proto_msgTypes = make([]protoimpl.MessageInfo, 18)
|
||||
var file_viz_tap_proto_goTypes = []interface{}{
|
||||
var file_viz_tap_proto_goTypes = []any{
|
||||
(TapEvent_ProxyDirection)(0), // 0: linkerd2.tap.TapEvent.ProxyDirection
|
||||
(*TapRequest)(nil), // 1: linkerd2.tap.TapRequest
|
||||
(*TapByResourceRequest)(nil), // 2: linkerd2.tap.TapByResourceRequest
|
||||
|
|
@ -1693,227 +1661,33 @@ func file_viz_tap_proto_init() {
|
|||
if File_viz_tap_proto != nil {
|
||||
return
|
||||
}
|
||||
if !protoimpl.UnsafeEnabled {
|
||||
file_viz_tap_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapRequest); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapByResourceRequest); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapByResourceRequest_Match); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapByResourceRequest_Extract); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapByResourceRequest_Match_Seq); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapByResourceRequest_Match_Http); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapByResourceRequest_Extract_Http); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapByResourceRequest_Extract_Http_Headers); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent_EndpointMeta); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent_RouteMeta); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent_Http); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent_Http_StreamId); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent_Http_RequestInit); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent_Http_ResponseInit); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
|
||||
switch v := v.(*TapEvent_Http_ResponseEnd); i {
|
||||
case 0:
|
||||
return &v.state
|
||||
case 1:
|
||||
return &v.sizeCache
|
||||
case 2:
|
||||
return &v.unknownFields
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[0].OneofWrappers = []interface{}{
|
||||
file_viz_tap_proto_msgTypes[0].OneofWrappers = []any{
|
||||
(*TapRequest_Pod)(nil),
|
||||
(*TapRequest_Deployment)(nil),
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[2].OneofWrappers = []interface{}{
|
||||
file_viz_tap_proto_msgTypes[2].OneofWrappers = []any{
|
||||
(*TapEvent_Http_)(nil),
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[3].OneofWrappers = []interface{}{
|
||||
file_viz_tap_proto_msgTypes[3].OneofWrappers = []any{
|
||||
(*TapByResourceRequest_Match_All)(nil),
|
||||
(*TapByResourceRequest_Match_Any)(nil),
|
||||
(*TapByResourceRequest_Match_Not)(nil),
|
||||
(*TapByResourceRequest_Match_Destinations)(nil),
|
||||
(*TapByResourceRequest_Match_Http_)(nil),
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[4].OneofWrappers = []interface{}{
|
||||
file_viz_tap_proto_msgTypes[4].OneofWrappers = []any{
|
||||
(*TapByResourceRequest_Extract_Http_)(nil),
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[6].OneofWrappers = []interface{}{
|
||||
file_viz_tap_proto_msgTypes[6].OneofWrappers = []any{
|
||||
(*TapByResourceRequest_Match_Http_Scheme)(nil),
|
||||
(*TapByResourceRequest_Match_Http_Method)(nil),
|
||||
(*TapByResourceRequest_Match_Http_Authority)(nil),
|
||||
(*TapByResourceRequest_Match_Http_Path)(nil),
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[7].OneofWrappers = []interface{}{
|
||||
file_viz_tap_proto_msgTypes[7].OneofWrappers = []any{
|
||||
(*TapByResourceRequest_Extract_Http_Headers_)(nil),
|
||||
}
|
||||
file_viz_tap_proto_msgTypes[11].OneofWrappers = []interface{}{
|
||||
file_viz_tap_proto_msgTypes[11].OneofWrappers = []any{
|
||||
(*TapEvent_Http_RequestInit_)(nil),
|
||||
(*TapEvent_Http_ResponseInit_)(nil),
|
||||
(*TapEvent_Http_ResponseEnd_)(nil),
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-grpc v1.2.0
|
||||
// - protoc-gen-go-grpc v1.5.1
|
||||
// - protoc v3.20.0
|
||||
// source: viz_tap.proto
|
||||
|
||||
|
|
@ -15,17 +15,22 @@ 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
|
||||
// Requires gRPC-Go v1.64.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion9
|
||||
|
||||
const (
|
||||
Tap_Tap_FullMethodName = "/linkerd2.tap.Tap/Tap"
|
||||
Tap_TapByResource_FullMethodName = "/linkerd2.tap.Tap/TapByResource"
|
||||
)
|
||||
|
||||
// TapClient is the client API for Tap service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
||||
type TapClient interface {
|
||||
// Deprecated: Do not use.
|
||||
Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (Tap_TapClient, error)
|
||||
Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TapEvent], error)
|
||||
// Deprecated: Do not use.
|
||||
TapByResource(ctx context.Context, in *TapByResourceRequest, opts ...grpc.CallOption) (Tap_TapByResourceClient, error)
|
||||
TapByResource(ctx context.Context, in *TapByResourceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TapEvent], error)
|
||||
}
|
||||
|
||||
type tapClient struct {
|
||||
|
|
@ -37,12 +42,13 @@ func NewTapClient(cc grpc.ClientConnInterface) TapClient {
|
|||
}
|
||||
|
||||
// Deprecated: Do not use.
|
||||
func (c *tapClient) Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (Tap_TapClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Tap_ServiceDesc.Streams[0], "/linkerd2.tap.Tap/Tap", opts...)
|
||||
func (c *tapClient) Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TapEvent], error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &Tap_ServiceDesc.Streams[0], Tap_Tap_FullMethodName, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
x := &tapTapClient{stream}
|
||||
x := &grpc.GenericClientStream[TapRequest, TapEvent]{ClientStream: stream}
|
||||
if err := x.ClientStream.SendMsg(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -52,30 +58,17 @@ func (c *tapClient) Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOp
|
|||
return x, nil
|
||||
}
|
||||
|
||||
type Tap_TapClient interface {
|
||||
Recv() (*TapEvent, error)
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
type tapTapClient struct {
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
func (x *tapTapClient) Recv() (*TapEvent, error) {
|
||||
m := new(TapEvent)
|
||||
if err := x.ClientStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return m, nil
|
||||
}
|
||||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
||||
type Tap_TapClient = grpc.ServerStreamingClient[TapEvent]
|
||||
|
||||
// Deprecated: Do not use.
|
||||
func (c *tapClient) TapByResource(ctx context.Context, in *TapByResourceRequest, opts ...grpc.CallOption) (Tap_TapByResourceClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Tap_ServiceDesc.Streams[1], "/linkerd2.tap.Tap/TapByResource", opts...)
|
||||
func (c *tapClient) TapByResource(ctx context.Context, in *TapByResourceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TapEvent], error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &Tap_ServiceDesc.Streams[1], Tap_TapByResource_FullMethodName, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
x := &tapTapByResourceClient{stream}
|
||||
x := &grpc.GenericClientStream[TapByResourceRequest, TapEvent]{ClientStream: stream}
|
||||
if err := x.ClientStream.SendMsg(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -85,45 +78,35 @@ func (c *tapClient) TapByResource(ctx context.Context, in *TapByResourceRequest,
|
|||
return x, nil
|
||||
}
|
||||
|
||||
type Tap_TapByResourceClient interface {
|
||||
Recv() (*TapEvent, error)
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
type tapTapByResourceClient struct {
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
func (x *tapTapByResourceClient) Recv() (*TapEvent, error) {
|
||||
m := new(TapEvent)
|
||||
if err := x.ClientStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return m, nil
|
||||
}
|
||||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
||||
type Tap_TapByResourceClient = grpc.ServerStreamingClient[TapEvent]
|
||||
|
||||
// TapServer is the server API for Tap service.
|
||||
// All implementations must embed UnimplementedTapServer
|
||||
// for forward compatibility
|
||||
// for forward compatibility.
|
||||
type TapServer interface {
|
||||
// Deprecated: Do not use.
|
||||
Tap(*TapRequest, Tap_TapServer) error
|
||||
Tap(*TapRequest, grpc.ServerStreamingServer[TapEvent]) error
|
||||
// Deprecated: Do not use.
|
||||
TapByResource(*TapByResourceRequest, Tap_TapByResourceServer) error
|
||||
TapByResource(*TapByResourceRequest, grpc.ServerStreamingServer[TapEvent]) error
|
||||
mustEmbedUnimplementedTapServer()
|
||||
}
|
||||
|
||||
// UnimplementedTapServer must be embedded to have forward compatible implementations.
|
||||
type UnimplementedTapServer struct {
|
||||
}
|
||||
// UnimplementedTapServer must be embedded to have
|
||||
// forward compatible implementations.
|
||||
//
|
||||
// NOTE: this should be embedded by value instead of pointer to avoid a nil
|
||||
// pointer dereference when methods are called.
|
||||
type UnimplementedTapServer struct{}
|
||||
|
||||
func (UnimplementedTapServer) Tap(*TapRequest, Tap_TapServer) error {
|
||||
func (UnimplementedTapServer) Tap(*TapRequest, grpc.ServerStreamingServer[TapEvent]) error {
|
||||
return status.Errorf(codes.Unimplemented, "method Tap not implemented")
|
||||
}
|
||||
func (UnimplementedTapServer) TapByResource(*TapByResourceRequest, Tap_TapByResourceServer) error {
|
||||
func (UnimplementedTapServer) TapByResource(*TapByResourceRequest, grpc.ServerStreamingServer[TapEvent]) error {
|
||||
return status.Errorf(codes.Unimplemented, "method TapByResource not implemented")
|
||||
}
|
||||
func (UnimplementedTapServer) mustEmbedUnimplementedTapServer() {}
|
||||
func (UnimplementedTapServer) testEmbeddedByValue() {}
|
||||
|
||||
// UnsafeTapServer may be embedded to opt out of forward compatibility for this service.
|
||||
// Use of this interface is not recommended, as added methods to TapServer will
|
||||
|
|
@ -133,6 +116,13 @@ type UnsafeTapServer interface {
|
|||
}
|
||||
|
||||
func RegisterTapServer(s grpc.ServiceRegistrar, srv TapServer) {
|
||||
// If the following call pancis, it indicates UnimplementedTapServer was
|
||||
// embedded by pointer and is nil. This will cause panics if an
|
||||
// unimplemented method is ever invoked, so we test this at initialization
|
||||
// time to prevent it from happening at runtime later due to I/O.
|
||||
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
|
||||
t.testEmbeddedByValue()
|
||||
}
|
||||
s.RegisterService(&Tap_ServiceDesc, srv)
|
||||
}
|
||||
|
||||
|
|
@ -141,42 +131,22 @@ func _Tap_Tap_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|||
if err := stream.RecvMsg(m); err != nil {
|
||||
return err
|
||||
}
|
||||
return srv.(TapServer).Tap(m, &tapTapServer{stream})
|
||||
return srv.(TapServer).Tap(m, &grpc.GenericServerStream[TapRequest, TapEvent]{ServerStream: stream})
|
||||
}
|
||||
|
||||
type Tap_TapServer interface {
|
||||
Send(*TapEvent) error
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
type tapTapServer struct {
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
func (x *tapTapServer) Send(m *TapEvent) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
||||
type Tap_TapServer = grpc.ServerStreamingServer[TapEvent]
|
||||
|
||||
func _Tap_TapByResource_Handler(srv interface{}, stream grpc.ServerStream) error {
|
||||
m := new(TapByResourceRequest)
|
||||
if err := stream.RecvMsg(m); err != nil {
|
||||
return err
|
||||
}
|
||||
return srv.(TapServer).TapByResource(m, &tapTapByResourceServer{stream})
|
||||
return srv.(TapServer).TapByResource(m, &grpc.GenericServerStream[TapByResourceRequest, TapEvent]{ServerStream: stream})
|
||||
}
|
||||
|
||||
type Tap_TapByResourceServer interface {
|
||||
Send(*TapEvent) error
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
type tapTapByResourceServer struct {
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
func (x *tapTapByResourceServer) Send(m *TapEvent) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
||||
type Tap_TapByResourceServer = grpc.ServerStreamingServer[TapEvent]
|
||||
|
||||
// Tap_ServiceDesc is the grpc.ServiceDesc for Tap service.
|
||||
// It's only intended for direct use with grpc.RegisterService,
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
ARG BUILDPLATFORM=linux/amd64
|
||||
|
||||
# Precompile key slow-to-build dependencies
|
||||
FROM --platform=$BUILDPLATFORM golang:1.22-alpine AS go-deps
|
||||
FROM --platform=$BUILDPLATFORM golang:1.23-alpine AS go-deps
|
||||
WORKDIR /linkerd-build
|
||||
COPY go.mod go.sum ./
|
||||
COPY bin/install-deps bin/
|
||||
|
|
|
|||
Loading…
Reference in New Issue