| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/internal/ |
| H A D | streaming_subscription_batch_source_test.cc | 61 google::pubsub::v1::StreamingPullRequest const&) { in MakeWriteFailureStream()
66 google::pubsub::v1::StreamingPullRequest const&, in MakeWriteFailureStream()
126 google::pubsub::v1::StreamingPullRequest const& request) { in TEST()
165 google::pubsub::v1::StreamingPullRequest const& request) { in TEST()
340 google::pubsub::v1::StreamingPullRequest const&) { in TEST()
458 google::pubsub::v1::StreamingPullRequest const&) { in TEST()
497 using Request = google::pubsub::v1::StreamingPullRequest; in TEST()
619 using Request = google::pubsub::v1::StreamingPullRequest; in TEST()
717 using Request = google::pubsub::v1::StreamingPullRequest; in TEST()
775 using Request = google::pubsub::v1::StreamingPullRequest; in TEST()
[all …]
|
| H A D | subscriber_stub.h | 75 google::pubsub::v1::StreamingPullRequest,
81 google::pubsub::v1::StreamingPullRequest const& request) = 0;
|
| H A D | subscription_session_test.cc | 58 google::pubsub::v1::StreamingPullRequest const&) { in TEST()
66 [&](google::pubsub::v1::StreamingPullRequest const& request, in TEST()
76 [&](google::pubsub::v1::StreamingPullRequest const& request, in TEST()
475 google::pubsub::v1::StreamingPullRequest const&) { in TEST()
482 auto write_response = [cq](google::pubsub::v1::StreamingPullRequest const&, in TEST()
|
| H A D | subscriber_logging.h | 63 google::pubsub::v1::StreamingPullRequest const& request) override;
105 future<bool> Write(google::pubsub::v1::StreamingPullRequest const&,
|
| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/testing/ |
| H A D | fake_streaming_pull.cc | 28 google::pubsub::v1::StreamingPullRequest const&) { in FakeAsyncStreamingPull()
35 auto write_response = [cq](google::pubsub::v1::StreamingPullRequest const&, in FakeAsyncStreamingPull()
|
| H A D | mock_subscriber_stub.h | 68 google::pubsub::v1::StreamingPullRequest const&),
111 future<bool>(google::pubsub::v1::StreamingPullRequest const&,
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 49 pendingReq *pb.StreamingPullRequest
74 pendingReq: &pb.StreamingPullRequest{},
228 it.pendingReq = &pb.StreamingPullRequest{}
|
| H A D | service.go | 392 err = spc.Send(&pb.StreamingPullRequest{
471 func (p *streamingPuller) send(req *pb.StreamingPullRequest) error {
473 var rest *pb.StreamingPullRequest
496 func splitRequest(req *pb.StreamingPullRequest, maxSize int) (prefix, remainder *pb.StreamingPullRe… argument
500 remainder = &pb.StreamingPullRequest{}
|
| /dports/www/miniflux/v2-2.0.35/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 49 pendingReq *pb.StreamingPullRequest
74 pendingReq: &pb.StreamingPullRequest{},
228 it.pendingReq = &pb.StreamingPullRequest{}
|
| H A D | service.go | 392 err = spc.Send(&pb.StreamingPullRequest{
471 func (p *streamingPuller) send(req *pb.StreamingPullRequest) error {
473 var rest *pb.StreamingPullRequest
496 func splitRequest(req *pb.StreamingPullRequest, maxSize int) (prefix, remainder *pb.StreamingPullRe… argument
500 remainder = &pb.StreamingPullRequest{}
|
| /dports/sysutils/jest/jest-f76bc46/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 49 pendingReq *pb.StreamingPullRequest
74 pendingReq: &pb.StreamingPullRequest{},
228 it.pendingReq = &pb.StreamingPullRequest{}
|
| H A D | service.go | 392 err = spc.Send(&pb.StreamingPullRequest{
471 func (p *streamingPuller) send(req *pb.StreamingPullRequest) error {
473 var rest *pb.StreamingPullRequest
496 func splitRequest(req *pb.StreamingPullRequest, maxSize int) (prefix, remainder *pb.StreamingPullRe… argument
500 remainder = &pb.StreamingPullRequest{}
|
| /dports/databases/tile38/tile38-1.12.0/vendor/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 894 type StreamingPullRequest struct { struct
931 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
933 func (*StreamingPullRequest) ProtoMessage() {} argument
936 func (m *StreamingPullRequest) GetSubscription() string { argument
943 func (m *StreamingPullRequest) GetAckIds() []string { argument
950 func (m *StreamingPullRequest) GetModifyDeadlineSeconds() []int32 { argument
957 func (m *StreamingPullRequest) GetModifyDeadlineAckIds() []string { argument
964 func (m *StreamingPullRequest) GetStreamAckDeadlineSeconds() int32 { argument
1566 Send(*StreamingPullRequest) error argument
1895 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/golang/gddo/vendor/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 894 type StreamingPullRequest struct { struct
931 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
933 func (*StreamingPullRequest) ProtoMessage() {} argument
936 func (m *StreamingPullRequest) GetSubscription() string { argument
943 func (m *StreamingPullRequest) GetAckIds() []string { argument
950 func (m *StreamingPullRequest) GetModifyDeadlineSeconds() []int32 { argument
957 func (m *StreamingPullRequest) GetModifyDeadlineAckIds() []string { argument
964 func (m *StreamingPullRequest) GetStreamAckDeadlineSeconds() int32 { argument
1566 Send(*StreamingPullRequest) error argument
1895 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/www/miniflux/v2-2.0.35/vendor/github.com/golang/gddo/vendor/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 894 type StreamingPullRequest struct { struct
931 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
933 func (*StreamingPullRequest) ProtoMessage() {} argument
936 func (m *StreamingPullRequest) GetSubscription() string { argument
943 func (m *StreamingPullRequest) GetAckIds() []string { argument
950 func (m *StreamingPullRequest) GetModifyDeadlineSeconds() []int32 { argument
957 func (m *StreamingPullRequest) GetModifyDeadlineAckIds() []string { argument
964 func (m *StreamingPullRequest) GetStreamAckDeadlineSeconds() int32 { argument
1566 Send(*StreamingPullRequest) error argument
1895 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/sysutils/jest/jest-f76bc46/vendor/github.com/golang/gddo/vendor/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 894 type StreamingPullRequest struct { struct
931 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
933 func (*StreamingPullRequest) ProtoMessage() {} argument
936 func (m *StreamingPullRequest) GetSubscription() string { argument
943 func (m *StreamingPullRequest) GetAckIds() []string { argument
950 func (m *StreamingPullRequest) GetModifyDeadlineSeconds() []int32 { argument
957 func (m *StreamingPullRequest) GetModifyDeadlineAckIds() []string { argument
964 func (m *StreamingPullRequest) GetStreamAckDeadlineSeconds() int32 { argument
1566 Send(*StreamingPullRequest) error argument
1895 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/sysutils/docker-registry/distribution-2.7.1/vendor/cloud.google.com/go/pubsub/ |
| H A D | pullstream.go | 50 err = spc.Send(&pb.StreamingPullRequest{
144 func (s *pullStream) Send(req *pb.StreamingPullRequest) error {
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/cloud.google.com/go/pubsub/ |
| H A D | pullstream.go | 50 err = spc.Send(&pb.StreamingPullRequest{
151 func (s *pullStream) Send(req *pb.StreamingPullRequest) error {
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 1799 type StreamingPullRequest struct { struct
1839 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
1841 func (*StreamingPullRequest) ProtoMessage() {} argument
1842 func (*StreamingPullRequest) Descriptor() ([]byte, []int) { argument
1855 func (m *StreamingPullRequest) XXX_Size() int { argument
1858 func (m *StreamingPullRequest) XXX_DiscardUnknown() { argument
1864 func (m *StreamingPullRequest) GetSubscription() string { argument
1871 func (m *StreamingPullRequest) GetAckIds() []string { argument
3235 Send(*StreamingPullRequest) error argument
3596 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/devel/goprotobuf/protobuf-1.1.0/src/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 1566 type StreamingPullRequest struct { struct
1606 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
1608 func (*StreamingPullRequest) ProtoMessage() {} argument
1609 func (*StreamingPullRequest) Descriptor() ([]byte, []int) { argument
1621 func (m *StreamingPullRequest) XXX_Size() int { argument
1624 func (m *StreamingPullRequest) XXX_DiscardUnknown() { argument
1630 func (m *StreamingPullRequest) GetSubscription() string { argument
1637 func (m *StreamingPullRequest) GetAckIds() []string { argument
2888 Send(*StreamingPullRequest) error argument
3236 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 1566 type StreamingPullRequest struct { struct
1606 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
1608 func (*StreamingPullRequest) ProtoMessage() {} argument
1609 func (*StreamingPullRequest) Descriptor() ([]byte, []int) { argument
1621 func (m *StreamingPullRequest) XXX_Size() int { argument
1624 func (m *StreamingPullRequest) XXX_DiscardUnknown() { argument
1630 func (m *StreamingPullRequest) GetSubscription() string { argument
1637 func (m *StreamingPullRequest) GetAckIds() []string { argument
2890 Send(*StreamingPullRequest) error argument
3238 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/genproto/go-genproto-eb59cef1c072/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 1799 type StreamingPullRequest struct { struct
1839 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
1841 func (*StreamingPullRequest) ProtoMessage() {} argument
1842 func (*StreamingPullRequest) Descriptor() ([]byte, []int) { argument
1855 func (m *StreamingPullRequest) XXX_Size() int { argument
1858 func (m *StreamingPullRequest) XXX_DiscardUnknown() { argument
1864 func (m *StreamingPullRequest) GetSubscription() string { argument
1871 func (m *StreamingPullRequest) GetAckIds() []string { argument
3235 Send(*StreamingPullRequest) error argument
3596 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/google.golang.org/genproto/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 1792 type StreamingPullRequest struct { struct
1832 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
1834 func (*StreamingPullRequest) ProtoMessage() {} argument
1835 func (*StreamingPullRequest) Descriptor() ([]byte, []int) { argument
1848 func (m *StreamingPullRequest) XXX_Size() int { argument
1851 func (m *StreamingPullRequest) XXX_DiscardUnknown() { argument
1857 func (m *StreamingPullRequest) GetSubscription() string { argument
1864 func (m *StreamingPullRequest) GetAckIds() []string { argument
3231 Send(*StreamingPullRequest) error argument
3592 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/www/fabio/fabio-1.5.14/vendor/google.golang.org/genproto/go-genproto-082222b4a5c5/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 1640 type StreamingPullRequest struct { struct
1680 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
1682 func (*StreamingPullRequest) ProtoMessage() {} argument
1683 func (*StreamingPullRequest) Descriptor() ([]byte, []int) { argument
1695 func (m *StreamingPullRequest) XXX_Size() int { argument
1698 func (m *StreamingPullRequest) XXX_DiscardUnknown() { argument
1704 func (m *StreamingPullRequest) GetSubscription() string { argument
1711 func (m *StreamingPullRequest) GetAckIds() []string { argument
3016 Send(*StreamingPullRequest) error argument
3395 Recv() (*StreamingPullRequest, error)
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/google.golang.org/genproto/go-genproto-c66870c02cf8/googleapis/pubsub/v1/ |
| H A D | pubsub.pb.go | 1566 type StreamingPullRequest struct { struct
1606 func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } argument
1608 func (*StreamingPullRequest) ProtoMessage() {} argument
1609 func (*StreamingPullRequest) Descriptor() ([]byte, []int) { argument
1621 func (m *StreamingPullRequest) XXX_Size() int { argument
1624 func (m *StreamingPullRequest) XXX_DiscardUnknown() { argument
1630 func (m *StreamingPullRequest) GetSubscription() string { argument
1637 func (m *StreamingPullRequest) GetAckIds() []string { argument
2890 Send(*StreamingPullRequest) error argument
3238 Recv() (*StreamingPullRequest, error)
[all …]
|