| /dports/audio/din/din-52/src/ |
| H A D | recorder.h | 48 struct recorder { struct
70 recorder (); argument
84 ~recorder (); argument
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.etcd.io/etcd/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/devel/etcd34/etcd-3.4.18/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/devel/etcd33/etcd-3.3.23/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/clientv3/balancer/connectivity/ |
| H A D | connectivity.go | 39 type recorder struct { struct
40 lg *zap.Logger
42 mu sync.RWMutex
44 cur connectivity.State
46 numReady uint64 // Number of addrConns in ready state.
47 numConnecting uint64 // Number of addrConns in connecting state.
48 numTransientFailure uint64 // Number of addrConns in transientFailure.
51 func (rc *recorder) GetCurrentState() (state connectivity.State) {
67 func (rc *recorder) RecordTransition(oldState, newState connectivity.State) {
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chromecast/base/java/test/org/chromium/chromecast/base/ |
| H A D | ControllerTest.java | 38 ReactiveRecorder recorder = ReactiveRecorder.record(controller); in testNoStateTransitionAfterRegisteringWithInactiveController() local
45 ReactiveRecorder recorder = ReactiveRecorder.record(controller); in testStateIsopenedWhenControllerIsSet() local
54 ReactiveRecorder recorder = ReactiveRecorder.record(controller); in testBasicStateFromController() local
64 ReactiveRecorder recorder = ReactiveRecorder.record(controller); in testSetStateTwicePerformsImplicitReset() local
77 ReactiveRecorder recorder = ReactiveRecorder.record(controller); in testResetWhileStateIsNotopenedIsNoOp() local
101 ReactiveRecorder recorder = ReactiveRecorder.record(controller); in testNewStateIsActivatedImmediatelyIfObservingAlreadyActiveObservable() local
110 ReactiveRecorder recorder = ReactiveRecorder.record(controller); in testNewStateIsNotActivatedIfObservingObservableThatHasBeenDeactivated() local
128 ReactiveRecorder recorder = ReactiveRecorder.record(a); in testClosedSubscriptionDoesNotGetNotifiedOfFutureActivations() local
139 ReactiveRecorder recorder = ReactiveRecorder.record(a); in testClosedSubscriptionIsImplicitlyDeactivated() local
148 ReactiveRecorder recorder = ReactiveRecorder.record(a); in testCloseSubscriptionAfterDeactivatingSourceStateDoesNotCallExitHAndlerAgain() local
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/open-policy-agent/opa/runtime/ |
| H A D | logging.go | 105 type recorder struct { struct
106 inner http.ResponseWriter
107 req *http.Request
108 id uint64
110 buf *bytes.Buffer
111 bytesWritten int
112 statusCode int
128 func (r *recorder) Header() http.Header {
132 func (r *recorder) Write(bs []byte) (int, error) {
140 func (r *recorder) WriteHeader(s int) {
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apiserver/pkg/endpoints/filters/ |
| H A D | warning.go | 49 type recorder struct { struct
51 lock sync.Mutex
54 recorded map[string]bool
57 ordered []recordedWarning
60 written int
63 truncating bool
66 writer http.ResponseWriter
69 func (r *recorder) AddWarning(agent, text string) {
|
| /dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiserver/pkg/endpoints/filters/ |
| H A D | warning.go | 49 type recorder struct { struct
51 lock sync.Mutex
54 recorded map[string]bool
57 ordered []recordedWarning
60 written int
63 truncating bool
66 writer http.ResponseWriter
69 func (r *recorder) AddWarning(agent, text string) {
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/gscloud/gscloud-0.11.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/grpcox/grpcox-1.0.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/github.com/envoyproxy/protoc-gen-validate/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/go-bapu/carlostrub-bapu-23ca6b019fbc/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/rclone/rclone-1.57.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/devel/gh/cli-2.4.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/deskutils/ultralist/ultralist-1.7.0/vendor/golang.org/x/text/text-0.3.2/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/drive/drive-0.4.0/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|
| /dports/net/evans/evans-0.9.1/vendor/golang.org/x/text/unicode/cldr/ |
| H A D | collate_test.go | 15 type recorder struct { struct
16 calls []string
19 func (r *recorder) Reset(anchor string, before int) error {
27 func (r *recorder) Insert(level int, str, context, extend string) error {
39 func (r *recorder) Index(id string) {
43 func (r *recorder) Error(err error) {
|