- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for statusUpdate (0.2 sec)
-
src/time/example_test.go
fmt.Println("timed out") } } func ExampleSleep() { time.Sleep(100 * time.Millisecond) } func statusUpdate() string { return "" } func ExampleTick() { c := time.Tick(5 * time.Second) for next := range c { fmt.Printf("%v %s\n", next, statusUpdate()) } } func ExampleMonth() { _, month, day := time.Now().Date() if month == time.November && day == 10 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 13 01:05:00 UTC 2024 - 22.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/fake_node_status_updater.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 statusupdater import ( "fmt" "k8s.io/klog/v2" "k8s.io/apimachinery/pkg/types" ) func NewFakeNodeStatusUpdater(returnError bool) NodeStatusUpdater { return &fakeNodeStatusUpdater{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/cache" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/metrics" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/statusupdater" controllervolumetesting "k8s.io/kubernetes/pkg/controller/volume/attachdetach/testing" volumetesting "k8s.io/kubernetes/pkg/volume/testing" "k8s.io/kubernetes/pkg/volume/util/operationexecutor"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
See the License for the specific language governing permissions and limitations under the License. */ // Package statusupdater implements interfaces that enable updating the status // of API objects. package statusupdater import ( "fmt" "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/types" clientset "k8s.io/client-go/kubernetes"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
// and delete Pods and to create PersistentVolumeClaims. statusUpdater is the StatefulSetStatusUpdaterInterface used // to update the status of StatefulSets. You should use an instance returned from NewRealStatefulPodControl() for any // scenario other than testing. func NewDefaultStatefulSetControl( podControl *StatefulPodControl, statusUpdater StatefulSetStatusUpdaterInterface,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
"k8s.io/klog/v2" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/cache" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/metrics" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/statusupdater" kevents "k8s.io/kubernetes/pkg/kubelet/events" "k8s.io/kubernetes/pkg/util/goroutinemap/exponentialbackoff" nodeutil "k8s.io/kubernetes/pkg/util/node" "k8s.io/kubernetes/pkg/util/taints"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater_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 statusupdater import ( "context" "errors" "fmt" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/types"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 8.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
"k8s.io/kubernetes/pkg/controller/volume/attachdetach/populator" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/reconciler" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/statusupdater" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/util" "k8s.io/kubernetes/pkg/controller/volume/common" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/csi"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal_test.go
reportedPodReadiness []v1.ConditionStatus reportedPodStartTime []metav1.Time reportedPodPhase []v1.PodPhase reportedPodDeletionTimestamp []bool scaleUpdated bool statusUpdated bool eventCreated bool verifyEvents bool useMetricsAPI bool metricsTarget []autoscalingv2.MetricSpec expectedDesiredReplicas int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 199.3K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
metrics.JobPodsFinished.Reset() manager.podControl = &fakePodControl var statusUpdates []batch.JobStatus manager.updateStatusHandler = func(ctx context.Context, job *batch.Job) (*batch.Job, error) { statusUpdates = append(statusUpdates, *job.Status.DeepCopy()) return job, tc.statusUpdateErr } job := tc.job.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)