registry2 - Code Search

platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonRegistryUpdater.java

        try {
            daemonRegistry.remove(connectorAddress);
        } catch (DaemonRegistry.EmptyRegistryException e) {
            LOGGER.warn("Cannot remove daemon from the registry because the registry is empty.");
        }
        LOGGER.debug("Address removed from registry.");
    }

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

- Last Modified: Fri Sep 22 09:29:13 UTC 2023

- 4K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/storage/rest/storage_storage.go

	"k8s.io/apiserver/pkg/registry/generic"
	"k8s.io/apiserver/pkg/registry/rest"
	genericapiserver "k8s.io/apiserver/pkg/server"
	serverstorage "k8s.io/apiserver/pkg/server/storage"
	"k8s.io/kubernetes/pkg/api/legacyscheme"
	storageapi "k8s.io/kubernetes/pkg/apis/storage"
	csidriverstore "k8s.io/kubernetes/pkg/registry/storage/csidriver/storage"
	csinodestore "k8s.io/kubernetes/pkg/registry/storage/csinode/storage"

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

- Last Modified: Thu Nov 02 12:51:06 UTC 2023

- 5.8K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/process/internal/worker/request/RequestSerializerRegistry.java

        SerializerRegistry registry = new DefaultSerializerRegistry(false);
        registry.register(Request.class, new RequestSerializer(argumentSerializers.getSerializer(classLoader), false));
        return registry;
    }

    public static SerializerRegistry createDiscardRequestArg() {
        SerializerRegistry registry = new DefaultSerializerRegistry(false);

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

- Last Modified: Sun Mar 15 22:51:06 UTC 2020

- 1.5K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/inspect/RuleExtractorUtils.java

        ModelAction action = context.contextualize(ruleAction);
        ModelRegistry registry = context.getRegistry();
        switch (ruleApplicationScope) {
            case SELF:
                registry.configure(role, action);
                break;
            case DESCENDANTS:
                registry.configureMatching(new NonReferenceDescendantsSpec(context.getScope()), role, action);
                break;

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

- Last Modified: Thu Sep 28 09:51:04 UTC 2023

- 2.2K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/kuberuntime/instrumented_services_test.go

)

func TestRecordOperation(t *testing.T) {
	// Use local registry
	var registry = compbasemetrics.NewKubeRegistry()
	var gather compbasemetrics.Gatherer = registry

	registry.MustRegister(metrics.RuntimeOperations)
	registry.MustRegister(metrics.RuntimeOperationsDuration)
	registry.MustRegister(metrics.RuntimeOperationsErrors)

	registry.Reset()

	l, err := net.Listen("tcp", "127.0.0.1:0")
	assert.NoError(t, err)

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

- Last Modified: Sat Nov 05 13:02:13 UTC 2022

- 3.1K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/serviceregistry/provider/providers.go

package provider

// ID defines underlying platform supporting service registry
type ID string

const (
	// Mock is a service registry that contains 2 hard-coded test services
	Mock ID = "Mock"
	// Kubernetes is a service registry backed by k8s API server
	Kubernetes ID = "Kubernetes"
	// External is a service registry for externally provided ServiceEntries
	External ID = "External"
)

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

- Last Modified: Fri May 20 16:41:15 UTC 2022

- 1K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/WorkerLoggingSerializer.java

        registry.register(StyledTextOutputEvent.class, new StyledTextOutputEventSerializer(logLevelSerializer, new ListSerializer<StyledTextOutputEvent.Span>(new SpanSerializer(factory.getSerializerFor(StyledTextOutput.Style.class)))));
        registry.register(LogLevelChangeEvent.class, new LogLevelChangeEventSerializer(logLevelSerializer));

        return registry;
    }

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

- Last Modified: Thu May 23 05:58:56 UTC 2024

- 2.4K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonRegistryUnavailableExpirationStrategyTest.groovy

import org.gradle.launcher.daemon.context.DaemonContext
import org.gradle.launcher.daemon.context.DefaultDaemonContext
import org.gradle.launcher.daemon.registry.DaemonDir
import org.gradle.launcher.daemon.registry.DaemonInfo
import org.gradle.launcher.daemon.registry.DaemonRegistry
import org.gradle.launcher.daemon.registry.EmbeddedDaemonRegistry
import org.gradle.launcher.daemon.server.expiry.DaemonExpirationResult

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

- Last Modified: Fri May 24 00:09:57 UTC 2024

- 3.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/core/limitrange/storage/storage.go

limitations under the License.
*/

package storage

import (
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apiserver/pkg/registry/generic"
	genericregistry "k8s.io/apiserver/pkg/registry/generic/registry"
	"k8s.io/apiserver/pkg/registry/rest"
	api "k8s.io/kubernetes/pkg/apis/core"
	"k8s.io/kubernetes/pkg/registry/core/limitrange"
)

// REST implements a RESTStorage for limit ranges.
type REST struct {
	*genericregistry.Store
}

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

- Last Modified: Fri Nov 18 09:21:13 UTC 2022

- 2.1K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/registry/apps/rest/storage_apps.go

	"k8s.io/apiserver/pkg/registry/generic"
	"k8s.io/apiserver/pkg/registry/rest"
	genericapiserver "k8s.io/apiserver/pkg/server"
	serverstorage "k8s.io/apiserver/pkg/server/storage"
	"k8s.io/kubernetes/pkg/api/legacyscheme"
	"k8s.io/kubernetes/pkg/apis/apps"
	controllerrevisionsstore "k8s.io/kubernetes/pkg/registry/apps/controllerrevision/storage"
	daemonsetstore "k8s.io/kubernetes/pkg/registry/apps/daemonset/storage"

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

- Last Modified: Wed Feb 23 18:36:33 UTC 2022

- 4.5K bytes

- Viewed (0)

Search Options