{"level":"error","ts":1615978405.9387739,"logger":"gloo.v1.event_loop.setup.v1.event_loop.syncer.kubernetes_eds","caller":"kubernetes/eds.go:212","msg":"upstream gloo-system.mft-consumer-flagger-podinfo-primary-9898: port 9898 not found for service podinfo-primary","version":"1.6.15","stacktrace":"github.com/solo-io/gloo/projects/gloo/pkg/plugins/kubernetes.filterEndpoints\n\t/workspace/gloo/projects/gloo/pkg/plugins/kubernetes/eds.go:212\ngithub.com/solo-io/gloo/projects/gloo/pkg/plugins/kubernetes.(*edsWatcher).List\n\t/workspace/gloo/projects/gloo/pkg/plugins/kubernetes/eds.go:121\ngithub.com/solo-io/gloo/projects/gloo/pkg/plugins/kubernetes.(*edsWatcher).watch.func1\n\t/workspace/gloo/projects/gloo/pkg/plugins/kubernetes/eds.go:130\ngithub.com/solo-io/gloo/projects/gloo/pkg/plugins/kubernetes.(*edsWatcher).watch.func2\n\t/workspace/gloo/projects/gloo/pkg/plugins/kubernetes/eds.go:157"}
{"level":"error","ts":1615978405.9388125,"logger":"gloo.v1.event_loop.setup.v1.event_loop.syncer.kubernetes_eds","cal
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
func main() { | |
var ( | |
leaseLockName string | |
leaseLockNamespace string | |
podName = os.Getenv("POD_NAME") | |
) | |
flag.StringVar(&leaseLockName, "lease-name", "", "Name of lease lock") | |
flag.StringVar(&leaseLockNamespace, "lease-namespace", "default", "Name of lease lock namespace") | |
flag.Parse() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// controller/sidecar_controller_test.go | |
func TestHandleDeploymentReconciler(t *testing.T) { | |
client := utils.NewClient() | |
// setup expectations | |
client.On("Update", | |
mock.IsType(context.Background()), | |
mock.IsType(&appsv1.Deployment{}), | |
mock.Anything, |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// testutil/testutil.go | |
package testutil | |
import ( | |
"context" | |
"github.com/stretchr/testify/mock" | |
"sigs.k8s.io/controller-runtime/pkg/client" | |
) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
type SidecarReconciler struct { | |
client.Client | |
Scheme *runtime.Scheme | |
} | |
func (r *SidecarReconciler) Reconcile( | |
ctx context.Context, req ctrl.Request) (ctrl.Result, error) { | |
// STEP 1: get the deployment object | |
deployment := &appsv1.Deployment{} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// controller/sidecar_controller.go | |
func (r *SidecarReconciler) Reconcile( | |
ctx context.Context, req ctrl.Request) (ctrl.Result, error) { | |
// STEP 1: get the deployment object | |
deployment := &appsv1.Deployment{} | |
err := r.Get(ctx, req.NamespacedName, deployment) | |
if err != nil { | |
return ctrl.Result{}, err |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/bin/sh | |
cp -r /go /shared | |
./tekton_dashboard_backend \ | |
--port=9097 | |
--logout-url= | |
--pipelines-namespace=tekton-pipelines | |
--triggers-namespace=tekton-pipelines | |
--read-only=false |
Total PRs - 33
Total issues - 7
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from absl import logging | |
import collections | |
from tensorflow_privacy.privacy.analysis import privacy_ledger | |
from tensorflow_privacy.privacy.dp_query import gaussian_query | |
def make_optimizer_class(cls): | |
"""Constructs a DP optimizer class from an existing one.""" | |
parent_code = tf.compat.v1.train.Optimizer.compute_gradients.__code__ | |
child_code = cls.compute_gradients.__code__ |
- kubernetes-sigs/blob-csi-driver#236 (added commits to this PR)
- kubernetes/kubernetes#94559
- kubernetes-sigs/azurefile-csi-driver#406