- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 538 for Backend (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/audit/union_test.go
b.ProcessEvents(events...) for i, b := range backends { // so we can inspect the underlying events. backend := b.(*fakeBackend) if got := len(backend.events); got != n { t.Errorf("backend %d wanted %d events, got %d", i, n, got) continue } for j, event := range backend.events { wantID := types.UID(strconv.Itoa(j)) if event.AuditID != wantID {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 20 09:51:25 UTC 2022 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/audit/union.go
) // Union returns an audit Backend which logs events to a set of backends. The returned // Sink implementation blocks in turn for each call to ProcessEvents. func Union(backends ...Backend) Backend { if len(backends) == 1 { return backends[0] } return union{backends} } type union struct { backends []Backend } func (u union) ProcessEvents(events ...*auditinternal.Event) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 20 09:51:25 UTC 2022 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/truncate/truncate.go
MaxBatchSize int64 } type backend struct { // The delegate backend that actually exports events. delegateBackend audit.Backend // Configuration used for truncation. c Config // Encoder used to calculate audit event sizes. e runtime.Encoder } var _ audit.Backend = &backend{} // NewBackend returns a new truncating backend, using configuration passed in the parameters.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 29 00:03:53 UTC 2022 - 4.7K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/testdata/simple.yaml
- path: /path backend: service: name: service1 port: number: 4200 # Subpath without trailing / - path: /sub/path backend: service: name: service1 port: number: 4201 # With a trailing / - path: /sub/path/ backend: service:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 10 16:43:09 UTC 2023 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered_test.go
backend.Run(closedStopCh) backend.Shutdown() backend.ProcessEvents(newEvents(1)...) batch := backend.collectEvents(infiniteTimeCh, wait.NeverStop) require.Empty(t, batch, "processed events after the backed has been stopped") } func TestBufferedBackendProcessEventsBufferFull(t *testing.T) { t.Parallel() config := testBatchConfig() config.BufferSize = 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 14 17:20:35 UTC 2018 - 5.9K bytes - Viewed (0) -
samples/bookinfo/platform/kube/bookinfo-ingress.yaml
pathType: Exact backend: service: name: productpage port: number: 9080 - path: /static/ pathType: Prefix backend: service: name: productpage port: number: 9080 - path: /login pathType: Exact backend: service: name: productpage
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 28 04:24:35 UTC 2022 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/caching_authorizer_test.go
return authorizer.AuthorizerFunc(func(_ context.Context, attributes authorizer.Attributes) (authorizer.Decision, string, error) { if misses >= len(tc.backend) { t.Fatalf("got more than expected %d backend invocations", len(tc.backend)) } result := tc.backend[misses] misses++ return result.decision, result.reason, result.error }) }()) for i, invocation := range tc.calls {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 6.3K bytes - Viewed (0) -
cluster/addons/cluster-loadbalancing/glbc/default-svc.yaml
metadata: # This must match the --default-backend-service argument of the l7 lb # controller and is required because GCE mandates a default backend. name: default-http-backend namespace: kube-system labels: k8s-app: glbc kubernetes.io/cluster-service: "true" addonmanager.kubernetes.io/mode: Reconcile kubernetes.io/name: "GLBCDefaultBackend" spec: # The default backend must be of type NodePort. type: NodePort
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 25 00:53:12 UTC 2017 - 577 bytes - Viewed (0) -
pkg/apis/extensions/v1beta1/conversion_test.go
}{ "service-port-number": { external: v1beta1.IngressSpec{ Backend: &v1beta1.IngressBackend{ ServiceName: "test-backend", ServicePort: intstr.FromInt32(8080), }, }, internal: networking.IngressSpec{ DefaultBackend: &networking.IngressBackend{ Service: &networking.IngressServiceBackend{ Name: "test-backend", Port: networking.ServiceBackendPort{ Name: "",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:16:15 UTC 2023 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/fake/fake.go
"k8s.io/apiserver/pkg/audit" ) var _ audit.Backend = &Backend{} // Backend is a fake audit backend for testing purposes. type Backend struct { OnRequest func(events []*auditinternal.Event) } // Run does nothing. func (b *Backend) Run(stopCh <-chan struct{}) error { return nil } // Shutdown does nothing. func (b *Backend) Shutdown() { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 16 09:32:49 UTC 2018 - 1.2K bytes - Viewed (0)