Files
upstream-mirror e241b33f26
Some checks failed
codecov / upload (push) Failing after 13m59s
CodeQL / Analyze (push) Failing after 1s
govulncheck / govulncheck (.) (push) Failing after 1s
govulncheck / govulncheck (./cmd/protoc-gen-go-grpc) (push) Failing after 1s
govulncheck / govulncheck (./gcp/observability) (push) Failing after 1s
govulncheck / govulncheck (./security/advancedtls) (push) Failing after 1s
govulncheck / govulncheck (./stats/opencensus) (push) Failing after 1s
Testing / vet-proto (push) Failing after 1s
Testing / tests (arm, latest) (push) Waiting to run
Testing / extras (latest) (push) Failing after 1s
Testing / static checks (latest-1) (push) Failing after 1s
Testing / tests (-race, latest) (push) Failing after 1s
Testing / tests (i386, latest) (push) Failing after 1s
Testing / tests (latest) (push) Failing after 1s
Testing / tests (latest-1) (push) Failing after 1s
Lock Threads / lock (push) Failing after 1s
Stale bot / stale (push) Failing after 1s
snapshot of https://github.com/grpc/grpc-go.git (master, 2026-09-15; blobs > 131072B omitted)
2026-09-15 20:40:15 +05:00

76 lines
2.0 KiB
Go

/*
*
* Copyright 2026 gRPC authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
package hostname_test
import (
"testing"
"google.golang.org/grpc/attributes"
"google.golang.org/grpc/experimental/balancer/hostname"
"google.golang.org/grpc/internal/grpctest"
"google.golang.org/grpc/resolver"
)
type s struct {
grpctest.Tester
}
func Test(t *testing.T) {
grpctest.RunSubTests(t, s{})
}
func (s) TestHostnameToAndFromEndpoint(t *testing.T) {
tests := []struct {
desc string
inputHostname string
inputAttributes *attributes.Attributes
wantHostname string
}{
{
desc: "empty_attributes",
inputHostname: "myservice.example.com",
wantHostname: "myservice.example.com",
},
{
desc: "non-empty_attributes",
inputHostname: "myservice.example.com",
inputAttributes: attributes.New("foo", "bar"),
wantHostname: "myservice.example.com",
},
{
desc: "hostname_not_present_in_empty_attributes",
},
{
desc: "hostname_not_present_in_non-empty_attributes",
inputAttributes: attributes.New("foo", "bar"),
},
}
for _, test := range tests {
t.Run(test.desc, func(t *testing.T) {
endpoint := resolver.Endpoint{Attributes: test.inputAttributes}
endpoint = hostname.Set(endpoint, test.inputHostname)
gotHostname := hostname.FromEndpoint(endpoint)
if gotHostname != test.wantHostname {
t.Errorf("hostname.FromEndpoint(%+v) = %q, want %q", endpoint, gotHostname, test.wantHostname)
}
})
}
}