reorder - Code Search

guava-tests/test/com/google/common/eventbus/ReentrantEventsTest.java

    EventProcessor processor = new EventProcessor();
    bus.register(processor);

    EventRecorder recorder = new EventRecorder();
    bus.register(recorder);

    bus.post(FIRST);

    assertEquals(
        "EventRecorder expected events in order",
        Lists.<Object>newArrayList(FIRST, SECOND),
        recorder.eventsReceived);
  }

  public class EventProcessor {
    @Subscribe

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Mon Dec 04 17:37:03 GMT 2017

- 2.5K bytes

- Viewed (0)

github.com/istio/istio

manifests/charts/istiod-remote/templates/reader-clusterrole.yaml

{{ $mcsAPIGroup := or .Values.pilot.env.MCS_API_GROUP "multicluster.x-k8s.io" }}
apiVersion: rbac.authorization.k8s.io/v1
kind: ClusterRole
metadata:
  name: istio-reader-clusterrole{{- if not (eq .Values.revision "")}}-{{ .Values.revision }}{{- end }}-{{ .Release.Namespace }}
  labels:
    app: istio-reader
    release: {{ .Release.Name }}
rules:
  - apiGroups:
      - "config.istio.io"
      - "security.istio.io"
      - "networking.istio.io"

Others

- Registered: Wed Mar 20 22:53:08 GMT 2024

- Last Modified: Mon Jul 17 21:19:52 GMT 2023

- 2.1K bytes

- Viewed (0)

github.com/istio/istio

manifests/charts/base/templates/reader-serviceaccount.yaml

# This service account aggregates reader permissions for the revisions in a given cluster
# Should be used for remote secret creation.
apiVersion: v1
kind: ServiceAccount
  {{- if .Values.global.imagePullSecrets }}
imagePullSecrets:
  {{- range .Values.global.imagePullSecrets }}
  - name: {{ . }}
    {{- end }}
    {{- end }}
metadata:
  name: istio-reader-service-account
  namespace: {{ .Values.global.istioNamespace }}
  labels:

Others

- Registered: Wed Apr 24 22:53:08 GMT 2024

- Last Modified: Mon May 31 07:10:20 GMT 2021

- 489 bytes

- Viewed (0)

github.com/istio/istio

manifests/charts/istio-control/istio-discovery/templates/reader-clusterrolebinding.yaml

apiVersion: rbac.authorization.k8s.io/v1
kind: ClusterRoleBinding
metadata:
  name: istio-reader-clusterrole{{- if not (eq .Values.revision "")}}-{{ .Values.revision }}{{- end }}-{{ .Release.Namespace }}
  labels:
    app: istio-reader
    release: {{ .Release.Name }}
roleRef:
  apiGroup: rbac.authorization.k8s.io
  kind: ClusterRole
  name: istio-reader-clusterrole{{- if not (eq .Values.revision "")}}-{{ .Values.revision }}{{- end }}-{{ .Release.Namespace }}

Others

- Registered: Wed Mar 20 22:53:08 GMT 2024

- Last Modified: Mon Jul 12 16:44:21 GMT 2021

- 589 bytes

- Viewed (0)

github.com/istio/istio

manifests/charts/istiod-remote/templates/reader-clusterrolebinding.yaml

apiVersion: rbac.authorization.k8s.io/v1
kind: ClusterRoleBinding
metadata:
  name: istio-reader-clusterrole{{- if not (eq .Values.revision "")}}-{{ .Values.revision }}{{- end }}-{{ .Release.Namespace }}
  labels:
    app: istio-reader
    release: {{ .Release.Name }}
roleRef:
  apiGroup: rbac.authorization.k8s.io
  kind: ClusterRole
  name: istio-reader-clusterrole{{- if not (eq .Values.revision "")}}-{{ .Values.revision }}{{- end }}-{{ .Release.Namespace }}

Others

- Registered: Wed Mar 20 22:53:08 GMT 2024

- Last Modified: Mon Jul 12 16:44:21 GMT 2021

- 589 bytes

- Viewed (0)

github.com/minio/minio

internal/hash/reader_test.go

	}
}

// Tests hash reader checksum verification.
func TestHashReaderVerification(t *testing.T) {
	testCases := []struct {
		desc              string
		src               io.Reader
		size              int64
		actualSize        int64
		md5hex, sha256hex string
		err               error
	}{
		0: {

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Mon Sep 18 17:00:54 GMT 2023

- 10.3K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/json/reader_test.go

Klaus Post <******@****.***> 1663610716 +0200

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Mon Sep 19 18:05:16 GMT 2022

- 2.5K bytes

- Viewed (0)

github.com/golang/go

src/bytes/reader_test.go

	}
}

var UnreadRuneErrorTests = []struct {
	name string
	f    func(*Reader)
}{
	{"Read", func(r *Reader) { r.Read([]byte{0}) }},
	{"ReadByte", func(r *Reader) { r.ReadByte() }},
	{"UnreadRune", func(r *Reader) { r.UnreadRune() }},
	{"Seek", func(r *Reader) { r.Seek(0, io.SeekCurrent) }},
	{"WriteTo", func(r *Reader) { r.WriteTo(&Buffer{}) }},
}

func TestUnreadRuneError(t *testing.T) {

Go

- Registered: Tue Apr 23 11:13:09 GMT 2024

- Last Modified: Mon Dec 13 18:45:54 GMT 2021

- 8K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/ContiguousSetTest.java

    assertThat(set.headSet(2)).containsExactly(1).inOrder();
    assertThat(set.headSet(3)).containsExactly(1, 2).inOrder();
    assertThat(set.headSet(4)).containsExactly(1, 2, 3).inOrder();
    assertThat(set.headSet(Integer.MAX_VALUE)).containsExactly(1, 2, 3).inOrder();
    assertThat(set.headSet(1, true)).containsExactly(1).inOrder();
    assertThat(set.headSet(2, true)).containsExactly(1, 2).inOrder();

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Mon Feb 19 20:34:55 GMT 2024

- 19.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/ContiguousSetTest.java

    assertThat(set.headSet(2)).containsExactly(1).inOrder();
    assertThat(set.headSet(3)).containsExactly(1, 2).inOrder();
    assertThat(set.headSet(4)).containsExactly(1, 2, 3).inOrder();
    assertThat(set.headSet(Integer.MAX_VALUE)).containsExactly(1, 2, 3).inOrder();
    assertThat(set.headSet(1, true)).containsExactly(1).inOrder();
    assertThat(set.headSet(2, true)).containsExactly(1, 2).inOrder();

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Feb 19 20:34:55 GMT 2024

- 19.1K bytes

- Viewed (0)

Search Options