- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 165 for Authenticators (0.42 sec)
-
staging/src/k8s.io/apiserver/pkg/authentication/request/x509/x509_test.go
if !testCase.Insecure { req.TLS = &tls.ConnectionState{PeerCertificates: testCase.Certs} } authCall := false auth := authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) { authCall = true return &authenticator.Response{User: &user.DefaultInfo{Name: "innerauth"}}, true, nil }) a := NewVerifier(testCase.Opts, auth, testCase.AllowedCNs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 23:23:03 UTC 2024 - 36.9K bytes - Viewed (0) -
security/pkg/server/ca/authenticate/xfcc_authenticator.go
"istio.io/istio/pkg/security" ) const ( XfccAuthenticatorType = "XfccAuthenticator" ) // XfccAuthenticator extracts identities from Xfcc header. type XfccAuthenticator struct{} var _ security.Authenticator = &XfccAuthenticator{} func (xff XfccAuthenticator) AuthenticatorType() string { return XfccAuthenticatorType } // Authenticate extracts identities from Xfcc Header.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 17:05:56 UTC 2024 - 3K bytes - Viewed (0) -
tests/fuzz/security_fuzzer.go
kcb := util.NewKeyCertBundleFromPem(nil, nil, certChainBytes, rootCertBytes) mockCa := &mockca.FakeCA{ SignedCert: signedCert, KeyCertBundle: kcb, } server, err := ca.New(mockCa, 1, []security.Authenticator{auth}, nil) if err != nil { return 0 } csrString, err := f.GetString() if err != nil { return 0 } request := &pb.IstioCertificateRequest{Csr: csrString} ctx := context.Background()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/token.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/validation/field" "k8s.io/apiserver/pkg/audit" "k8s.io/apiserver/pkg/authentication/authenticator" "k8s.io/apiserver/pkg/authentication/serviceaccount" genericapirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/registry/rest" utilfeature "k8s.io/apiserver/pkg/util/feature"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 10:24:31 UTC 2024 - 10K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
* This avoids sending potentially sensitive data like HTTP cookies to the proxy unencrypted. * * In order to support preemptive authentication we pass a fake "Auth Failed" response to the * authenticator. This gives the authenticator the option to customize the CONNECT request. It can * decline to do so by returning null, in which case OkHttp will use it as-is. */ @Throws(IOException::class)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 12K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/NtlmAuthenticator.groovy
static final String NTLM_AUTH_METHOD = 'NTLM' // There is absolutely no doubt that no one should ever on a map like that // and that a proper implementation of an NTLM authenticator shouldn't do this // but those are test fixtures and I couldn't find a better way to do this // without deeper understanding of the Jetty APIs. Feel free to provide an // alternate solution
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/authenticator/audagnostic_test.go
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 authenticator import ( "context" "errors" "fmt" "reflect" "testing" "github.com/google/go-cmp/cmp" "k8s.io/apiserver/pkg/authentication/user" ) func TestAuthenticate(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:16 UTC 2023 - 4.9K bytes - Viewed (0) -
cmd/jwt_test.go
claims.SetExpiry(UTCNow().Add(defaultJWTExpiry)) claims.SetAccessKey(accessKey) token := jwtgo.NewWithClaims(jwtgo.SigningMethodHS512, claims) return token.SignedString([]byte(secretKey)) } // Tests web request authenticator. func TestWebRequestAuthenticate(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 19 16:45:14 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/security/mock.go
} func (f *FakeAuthenticator) Set(token string, identity string) *FakeAuthenticator { f.mu.Lock() defer f.mu.Unlock() f.AllowedToken = token f.AllowedCert = identity return f } var _ Authenticator = &FakeAuthenticator{} func checkToken(ctx context.Context, expected string) error { if expected == "" { return fmt.Errorf("jwt authentication not allowed") } targetJWT, err := ExtractBearerToken(ctx)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.5K bytes - Viewed (0) -
security/pkg/server/ca/authenticate/kubeauth/kube_jwt.go
kubeClient kubernetes.Interface // Primary cluster ID clusterID cluster.ID // remote cluster kubeClient getter remoteKubeClientGetter RemoteKubeClientGetter } var _ security.Authenticator = &KubeJWTAuthenticator{} // NewKubeJWTAuthenticator creates a new kubeJWTAuthenticator. func NewKubeJWTAuthenticator( meshHolder mesh.Holder, client kubernetes.Interface, clusterID cluster.ID,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0)