| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
17 client streamClient
18 eventCh chan serf.Event
19 filters []EventFilter
20 logger *log.Logger
21 seq uint64
36 func (es *eventStream) HandleEvent(e serf.Event) {
54 func (es *eventStream) Stop() {
58 func (es *eventStream) stream() {
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
17 client streamClient
18 eventCh chan serf.Event
19 filters []EventFilter
20 logger *log.Logger
21 seq uint64
36 func (es *eventStream) HandleEvent(e serf.Event) {
54 func (es *eventStream) Stop() {
58 func (es *eventStream) stream() {
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
17 client streamClient
18 eventCh chan serf.Event
19 filters []EventFilter
20 logger *log.Logger
21 seq uint64
36 func (es *eventStream) HandleEvent(e serf.Event) {
54 func (es *eventStream) Stop() {
58 func (es *eventStream) stream() {
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/serf/serf-0.7.0/command/agent/ |
| H A D | ipc_event_stream.go | 15 type eventStream struct { struct
16 client streamClient
17 eventCh chan serf.Event
18 filters []EventFilter
19 logger *log.Logger
20 seq uint64
35 func (es *eventStream) HandleEvent(e serf.Event) {
53 func (es *eventStream) Stop() {
57 func (es *eventStream) stream() {
110 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
17 client streamClient
18 eventCh chan serf.Event
19 filters []EventFilter
20 logger *log.Logger
21 seq uint64
36 func (es *eventStream) HandleEvent(e serf.Event) {
54 func (es *eventStream) Stop() {
58 func (es *eventStream) stream() {
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
17 client streamClient
18 eventCh chan serf.Event
19 filters []EventFilter
20 logger *log.Logger
21 seq uint64
36 func (es *eventStream) HandleEvent(e serf.Event) {
54 func (es *eventStream) Stop() {
58 func (es *eventStream) stream() {
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/serf/command/agent/ |
| H A D | ipc_event_stream.go | 15 type eventStream struct { struct
16 client streamClient
17 eventCh chan serf.Event
18 filters []EventFilter
19 logger *log.Logger
20 seq uint64
35 func (es *eventStream) HandleEvent(e serf.Event) {
53 func (es *eventStream) Stop() {
57 func (es *eventStream) stream() {
110 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/sysutils/serf/serf-0.8.5/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
17 client streamClient
18 eventCh chan serf.Event
19 filters []EventFilter
20 logger *log.Logger
21 seq uint64
36 func (es *eventStream) HandleEvent(e serf.Event) {
54 func (es *eventStream) Stop() {
58 func (es *eventStream) stream() {
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error {
[all …]
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.bundles/bundles/org.eclipse.equinox.log.stream/osgi/src/org/osgi/util/pushstream/ |
| H A D | AbstractPushStreamImpl.java | 220 AbstractPushStreamImpl<T> eventStream = new IntermediatePushStreamImpl<>( in filter() local
243 AbstractPushStreamImpl<R> eventStream = new IntermediatePushStreamImpl<>( in map() local
265 AbstractPushStreamImpl<R> eventStream = new IntermediatePushStreamImpl<>( in asyncMap() local
315 AbstractPushStreamImpl<R> eventStream = new IntermediatePushStreamImpl<>( in flatMap() local
375 AbstractPushStreamImpl<T> eventStream = new IntermediatePushStreamImpl<>( in sorted() local
410 AbstractPushStreamImpl<T> eventStream = new IntermediatePushStreamImpl<>( in limit() local
441 AbstractPushStreamImpl<T> eventStream = new IntermediatePushStreamImpl<T>( in limit() local
465 AbstractPushStreamImpl<T> eventStream = new IntermediatePushStreamImpl<T>( in timeout() local
509 AbstractPushStreamImpl<T> eventStream = new IntermediatePushStreamImpl<>( in skip() local
533 AbstractPushStreamImpl<T> eventStream = new IntermediatePushStreamImpl<>( in fork() local
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/browser_ui/widget/android/java/src/org/chromium/components/browser_ui/widget/gesture/ |
| H A D | SwipeGestureListenerTest.java | 75 private void testSwipeByGivenDirection(int expectedDirection, List<MotionEvent> eventStream) { in testSwipeByGivenDirection()
|
| /dports/games/openclonk/openclonk-release-8.1-src/src/platform/ |
| H A D | C4FileMonitor.h | 84 FSEventStreamRef eventStream; variable
|
| /dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/code-generation/generator/src/main/java/com/amazonaws/util/awsclientgenerator/domainmodels/codegeneration/ |
| H A D | Operation.java | 25 private boolean eventStream; field in Operation
|
| H A D | Shape.java | 42 private boolean eventStream; field in Shape
|
| /dports/textproc/kibana6/kibana-6.8.16-darwin-x86_64/node_modules/graphql/subscription/ |
| H A D | subscribe.mjs | 141 return Promise.resolve(result).then(function (eventStream) { argument
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/browser_ui/android/bottomsheet/internal/java/src/org/chromium/components/browser_ui/bottomsheet/ |
| H A D | BottomSheetSwipeDetectorTest.java | 134 ArrayList<MotionEvent> eventStream = new ArrayList<>(); in performScroll() local
|
| /dports/databases/litestream/litestream-0.3.6/vendor/github.com/aws/aws-sdk-go/private/model/api/codegentest/service/restjsonservice/ |
| H A D | api.go | 667 eventStream *EmptyStreamEventStream member
1046 eventStream *GetEventStreamEventStream member
|
| /dports/databases/litestream/litestream-0.3.6/vendor/github.com/aws/aws-sdk-go/private/model/api/codegentest/service/restxmlservice/ |
| H A D | api.go | 667 eventStream *EmptyStreamEventStream member
1046 eventStream *GetEventStreamEventStream member
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Data/System/Data/SqlClient/ |
| H A D | SqlDataReaderSmi.cs | 958 …SmiEventStream eventStream, // the event stream that receives the events from … in SqlDataReaderSmi()
|
| /dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/github.com/aws/aws-sdk-go/aws-sdk-go-1.30.0/private/model/api/codegentest/service/restjsonservice/ |
| H A D | api.go | 685 eventStream *EmptyStreamEventStream member
1120 eventStream *GetEventStreamEventStream member
|
| /dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/github.com/aws/aws-sdk-go/aws-sdk-go-1.30.0/private/model/api/codegentest/service/restxmlservice/ |
| H A D | api.go | 685 eventStream *EmptyStreamEventStream member
1120 eventStream *GetEventStreamEventStream member
|
| /dports/dns/cli53/cli53-0.8.18/vendor/github.com/aws/aws-sdk-go/private/model/api/codegentest/service/restjsonservice/ |
| H A D | api.go | 685 eventStream *EmptyStreamEventStream member
1120 eventStream *GetEventStreamEventStream member
|
| /dports/dns/cli53/cli53-0.8.18/vendor/github.com/aws/aws-sdk-go/private/model/api/codegentest/service/restxmlservice/ |
| H A D | api.go | 685 eventStream *EmptyStreamEventStream member
1120 eventStream *GetEventStreamEventStream member
|
| /dports/databases/litestream/litestream-0.3.6/vendor/github.com/aws/aws-sdk-go/private/model/api/codegentest/service/rpcservice/ |
| H A D | api.go | 735 eventStream *EmptyStreamEventStream member
1141 eventStream *GetEventStreamEventStream member
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/aws/aws-sdk-go/private/model/api/codegentest/service/restxmlservice/ |
| H A D | api.go | 685 eventStream *EmptyStreamEventStream member
1120 eventStream *GetEventStreamEventStream member
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/aws/aws-sdk-go/private/model/api/codegentest/service/restjsonservice/ |
| H A D | api.go | 685 eventStream *EmptyStreamEventStream member
1120 eventStream *GetEventStreamEventStream member
|