apirequest - Code Search

staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width_test.go

			requestURI: "http://server/apis/",
			requestInfo: &apirequest.RequestInfo{
				Verb: "get",
			},
			maxSeats:             10,
			initialSeatsExpected: 1,
		},
		{
			name:       "request verb is list, conversion to ListOptions returns error",
			requestURI: "http://server/apis/foo.bar/v1/events?limit=invalid",
			requestInfo: &apirequest.RequestInfo{
				Verb:     "list",
				APIGroup: "foo.bar",

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

- Last Modified: Wed Apr 24 18:25:29 UTC 2024

- 17K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go

	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
	"k8s.io/apimachinery/pkg/util/sets"
	"k8s.io/apiserver/pkg/authentication/user"
	apifilters "k8s.io/apiserver/pkg/endpoints/filters"
	apirequest "k8s.io/apiserver/pkg/endpoints/request"
	"k8s.io/apiserver/pkg/features"
	"k8s.io/apiserver/pkg/reconcilers"
	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
	"k8s.io/apiserver/pkg/storageversion"

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

- Last Modified: Wed Apr 24 18:25:29 UTC 2024

- 10.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

cmd/kube-scheduler/app/server.go

	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
	"k8s.io/apiserver/pkg/authentication/authenticator"
	"k8s.io/apiserver/pkg/authorization/authorizer"
	genericapifilters "k8s.io/apiserver/pkg/endpoints/filters"
	apirequest "k8s.io/apiserver/pkg/endpoints/request"
	"k8s.io/apiserver/pkg/server"
	genericfilters "k8s.io/apiserver/pkg/server/filters"
	"k8s.io/apiserver/pkg/server/healthz"
	"k8s.io/apiserver/pkg/server/mux"

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

- Last Modified: Mon May 27 19:11:24 UTC 2024

- 14.3K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiserver/pkg/server/config.go

	"k8s.io/apiserver/pkg/endpoints/filterlatency"
	genericapifilters "k8s.io/apiserver/pkg/endpoints/filters"
	apiopenapi "k8s.io/apiserver/pkg/endpoints/openapi"
	apirequest "k8s.io/apiserver/pkg/endpoints/request"
	genericfeatures "k8s.io/apiserver/pkg/features"
	genericregistry "k8s.io/apiserver/pkg/registry/generic"
	"k8s.io/apiserver/pkg/server/dynamiccertificates"

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

- Last Modified: Tue May 28 08:48:22 UTC 2024

- 47.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go

	utilnet "k8s.io/apimachinery/pkg/util/net"
	"k8s.io/apimachinery/pkg/util/wait"
	auditinternal "k8s.io/apiserver/pkg/apis/audit"
	"k8s.io/apiserver/pkg/audit"
	"k8s.io/apiserver/pkg/authorization/authorizer"
	apirequest "k8s.io/apiserver/pkg/endpoints/request"
	"k8s.io/apiserver/pkg/server/dynamiccertificates"
	"k8s.io/klog/v2"
	"k8s.io/klog/v2/ktesting"

	"github.com/google/go-cmp/cmp"
	"golang.org/x/net/http2"
)

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

- Last Modified: Mon Apr 29 18:59:21 UTC 2024

- 38.3K bytes

- Viewed (0)

github.com/apache/maven

maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java

            }
        };

        CliRequest cliRequest = new CliRequest(new String[] {}, null);

        customizedMavenCli.cli(cliRequest);
        customizedMavenCli.logging(cliRequest);
        customizedMavenCli.container(cliRequest);
        customizedMavenCli.toolchains(cliRequest);

        InOrder orderedEventSpyDispatcherMock = inOrder(eventSpyDispatcherMock);

Registered: Wed Jun 12 09:55:16 UTC 2024

- Last Modified: Wed Feb 28 23:31:59 UTC 2024

- 28.3K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/kuberuntime/kuberuntime_container_linux.go

	// set linux container resources
	var cpuRequest *resource.Quantity
	if _, cpuRequestExists := container.Resources.Requests[v1.ResourceCPU]; cpuRequestExists {
		cpuRequest = container.Resources.Requests.Cpu()
	}
	lcr := m.calculateLinuxResources(cpuRequest, container.Resources.Limits.Cpu(), container.Resources.Limits.Memory())

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

- Last Modified: Wed May 29 22:40:29 UTC 2024

- 17.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/RoleQueryHelper.java

        }
        return roleSet;
    }

    protected boolean processAccessToken(final HttpServletRequest request, final Set<String> roleSet, final boolean isApiRequest) {
        if (isApiRequest) {
            return ComponentUtil.getComponent(AccessTokenService.class).getPermissions(request).map(p -> {
                p.forEach(roleSet::add);
                return true;

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 11.5K bytes

- Viewed (0)

github.com/istio/istio

pkg/istio-agent/xds_proxy.go

		Cert:          cert,
		ServerAddress: agent.proxyConfig.DiscoveryAddress,
		SAN:           p.istiodSAN,
	}, nil
}

// tapRequest() sends "req" to Istiod, and returns a matching response, or `nil` on timeout.
// Requests are serialized -- only one may be in-flight at a time.
func (p *XdsProxy) tapRequest(req *discovery.DiscoveryRequest, timeout time.Duration) (*discovery.DiscoveryResponse, error) {
	p.connectedMutex.Lock()

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

- Last Modified: Thu May 16 22:12:28 UTC 2024

- 27.9K bytes

- Viewed (0)

github.com/minio/minio

internal/grid/muxclient.go

func (m *muxClient) roundtrip(h HandlerID, req []byte) ([]byte, error) {
	if m.init {
		return nil, errors.New("mux client already used")
	}
	m.init = true
	m.singleResp = true
	msg := message{
		Op:         OpRequest,
		MuxID:      m.MuxID,
		Handler:    h,
		Flags:      m.BaseFlags | FlagEOF,
		Payload:    req,
		DeadlineMS: uint32(m.deadline.Milliseconds()),
	}
	if m.subroute != nil {
		msg.Flags |= FlagSubroute
	}

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri Jun 07 15:51:52 UTC 2024

- 15.9K bytes

- Viewed (0)

Search Options