coordinationv1 - Code Search

staging/src/k8s.io/api/coordination/v1beta1/zz_generated.prerelease-lifecycle.go

// It is controlled by "k8s:prerelease-lifecycle-gen:replacement=<group>,<version>,<kind>" tags in types.go.
func (in *Lease) APILifecycleReplacement() schema.GroupVersionKind {
	return schema.GroupVersionKind{Group: "coordination.k8s.io", Version: "v1", Kind: "Lease"}
}

// APILifecycleRemoved is an autogenerated function, returning the release in which the API is no longer served as int versions of major and minor for comparison.

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue Aug 24 19:47:49 UTC 2021

- 3.8K bytes

- Viewed (0)

github.com/istio/istio

manifests/charts/istio-operator/templates/clusterrole.yaml

  verbs:
  - '*'
- apiGroups:
  - rbac.authorization.k8s.io
  resources:
  - clusterrolebindings
  - clusterroles
  - roles
  - rolebindings
  verbs:
  - '*'
- apiGroups:
  - coordination.k8s.io
  resources:
  - leases
  verbs:
  - get
  - create
  - update
- apiGroups:
  - ""
  resources:
  - configmaps
  - endpoints
  - events
  - namespaces
  - pods

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Tue Apr 02 08:32:06 UTC 2024

- 1.9K bytes

- Viewed (0)

github.com/golang/go

src/cmd/cgo/internal/teststdio/testdata/chain.go

	"strconv"

	"cgostdio/stdio"
)

const N = 10
const R = 5

func link(left chan<- int, right <-chan int) {
	// Keep the links in dedicated operating system
	// threads, so that this program tests coordination
	// between pthreads and not just goroutines.
	runtime.LockOSThread()
	for {
		v := <-right
		stdio.Stdout.WriteString(strconv.Itoa(v) + "\n")
		left <- 1 + v
	}
}

func main() {

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri May 12 11:59:56 UTC 2023

- 914 bytes

- Viewed (0)

github.com/golang/go

src/cmd/cgo/internal/teststdio/testdata/fib.go

package main

import (
	"runtime"
	"strconv"

	"cgostdio/stdio"
)

func fibber(c, out chan int64, i int64) {
	// Keep the fibbers in dedicated operating system
	// threads, so that this program tests coordination
	// between pthreads and not just goroutines.
	runtime.LockOSThread()

	if i == 0 {
		c <- i
	}
	for {
		j := <-c
		stdio.Stdout.WriteString(strconv.FormatInt(j, 10) + "\n")
		out <- j
		<-out

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri May 12 11:59:56 UTC 2023

- 965 bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockState.java

     * fails.
     */
    void registerLocked(ResourceLock resourceLock);

    /**
     * Registers a resource lock that has been unlocked during the transform so that the coordination service can
     * notify threads waiting on a lock.
     */
    void registerUnlocked(ResourceLock resourceLock);

    /**
     * Release any locks that have been acquired during the transform.
     */

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Wed May 29 06:47:40 UTC 2024

- 1.3K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

cmd/kube-controller-manager/app/import_known_versions.go

	_ "k8s.io/kubernetes/pkg/apis/autoscaling/install"
	_ "k8s.io/kubernetes/pkg/apis/batch/install"
	_ "k8s.io/kubernetes/pkg/apis/certificates/install"
	_ "k8s.io/kubernetes/pkg/apis/coordination/install"
	_ "k8s.io/kubernetes/pkg/apis/core/install"
	_ "k8s.io/kubernetes/pkg/apis/events/install"
	_ "k8s.io/kubernetes/pkg/apis/extensions/install"
	_ "k8s.io/kubernetes/pkg/apis/policy/install"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Nov 10 19:23:50 UTC 2022

- 1.6K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/api/coordination/v1/register.go

import (
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/runtime/schema"
)

// GroupName is the group name use in this package
const GroupName = "coordination.k8s.io"

// SchemeGroupVersion is group version used to register these objects
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1"}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Dec 20 14:39:57 UTC 2018

- 1.7K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/AbstractTrackedResourceLockTest.groovy

        when:
        lock.unlock()

        then:
        1 * container.lockReleased(lock)
    }

    def "throws exception when methods are called without coordination service transform"() {
        given:
        _ * coordinationService.current >> null

        when:
        lock.tryLock()

        then:
        thrown(IllegalStateException)

        when:

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Sep 22 08:48:02 UTC 2023

- 1.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/controlplane/import_known_versions.go

	_ "k8s.io/kubernetes/pkg/apis/autoscaling/install"
	_ "k8s.io/kubernetes/pkg/apis/batch/install"
	_ "k8s.io/kubernetes/pkg/apis/certificates/install"
	_ "k8s.io/kubernetes/pkg/apis/coordination/install"
	_ "k8s.io/kubernetes/pkg/apis/core/install"
	_ "k8s.io/kubernetes/pkg/apis/discovery/install"
	_ "k8s.io/kubernetes/pkg/apis/events/install"
	_ "k8s.io/kubernetes/pkg/apis/extensions/install"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Fri Mar 08 04:18:56 UTC 2024

- 1.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/printers/internalversion/import_known_versions.go

	_ "k8s.io/kubernetes/pkg/apis/autoscaling/install"
	_ "k8s.io/kubernetes/pkg/apis/batch/install"
	_ "k8s.io/kubernetes/pkg/apis/certificates/install"
	_ "k8s.io/kubernetes/pkg/apis/coordination/install"
	_ "k8s.io/kubernetes/pkg/apis/core/install"
	_ "k8s.io/kubernetes/pkg/apis/discovery/install"
	_ "k8s.io/kubernetes/pkg/apis/events/install"
	_ "k8s.io/kubernetes/pkg/apis/extensions/install"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Nov 10 19:08:24 UTC 2022

- 1.5K bytes

- Viewed (0)

Search Options