/dports/devel/gitlab-runner/google-cloud-go-storage-v1.12.0/pubsub/ |
H A D | message.go | 25 type Message struct { struct 30 ID string member 33 Data []byte 40 ackID string 46 PublishTime time.Time 49 receiveTime time.Time 57 DeliveryAttempt *int 60 size int 62 calledDone bool 69 OrderingKey string [all …]
|
/dports/sysutils/helmfile/google-cloud-go-storage-v1.10.0/pubsub/ |
H A D | message.go | 25 type Message struct { struct 30 ID string member 33 Data []byte 40 ackID string 46 PublishTime time.Time 49 receiveTime time.Time 57 DeliveryAttempt *int 60 size int 62 calledDone bool 69 OrderingKey string [all …]
|
/dports/net/grpcui/grpcui-1.1.0/vendor/cloud.google.com/go/pubsub/ |
H A D | message.go | 25 type Message struct { struct 30 ID string member 33 Data []byte 40 ackID string 46 PublishTime time.Time 49 receiveTime time.Time 61 DeliveryAttempt *int 64 size int 66 calledDone bool 73 OrderingKey string [all …]
|
/dports/net/grpcurl/grpcurl-1.8.5/vendor/cloud.google.com/go/pubsub/ |
H A D | message.go | 25 type Message struct { struct 30 ID string member 33 Data []byte 40 ackID string 46 PublishTime time.Time 49 receiveTime time.Time 61 DeliveryAttempt *int 64 size int 66 calledDone bool 73 OrderingKey string [all …]
|
/dports/sysutils/terraform/google-cloud-go-storage-v1.10.0/pubsub/ |
H A D | message.go | 25 type Message struct { struct 30 ID string member 33 Data []byte 40 ackID string 46 PublishTime time.Time 49 receiveTime time.Time 57 DeliveryAttempt *int 60 size int 62 calledDone bool 69 OrderingKey string [all …]
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/ |
H A D | util.go | 34 func isConnectedToQuorumSince(transport rafthttp.Transporter, since time.Time, self types.ID, membe… 40 func isConnectedSince(transport rafthttp.Transporter, since time.Time, remote types.ID) bool { 47 func isConnectedFullySince(transport rafthttp.Transporter, since time.Time, self types.ID, members … 53 func numConnectedSince(transport rafthttp.Transporter, since time.Time, self types.ID, members []*m… 65 func longestConnected(tp rafthttp.Transporter, membs []types.ID) (types.ID, bool) { 106 …eRequest(lg *zap.Logger, now time.Time, reqStringer fmt.Stringer, respMsg proto.Message, err error… 114 …dRequest(lg *zap.Logger, now time.Time, reqStringer fmt.Stringer, respMsg proto.Message, err error… 185 func isNil(msg proto.Message) bool {
|
/dports/net/nsq/nsq-1.2.1/nsqd/ |
H A D | message.go | 17 type Message struct { struct 18 ID MessageID member 19 Body []byte 20 Timestamp int64 21 Attempts uint16 24 deliveryTS time.Time 25 clientID int64 26 pri int64 27 index int 28 deferred time.Duration [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/llvm/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/tinygo/tinygo-0.14.1/llvm-project/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 62 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 70 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 94 void sendMessage(json::Value Message) { in sendMessage() 105 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 113 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/wasi-libcxx/llvm-project-13.0.1.src/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm11/llvm-11.0.1.src/tools/clang/tools/extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm12/llvm-project-12.0.1.src/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm10/llvm-10.0.1.src/tools/clang/tools/extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 62 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 70 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 94 void sendMessage(json::Value Message) { in sendMessage() 105 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 113 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm-devel/llvm-project-f05c95f10fc1d8171071735af8ad3a9e87633120/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/wasi-compiler-rt13/llvm-project-13.0.1.src/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/wasi-compiler-rt12/llvm-project-12.0.1.src/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm90/llvm-9.0.1.src/tools/clang/tools/extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 62 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 70 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 94 void sendMessage(json::Value Message) { in sendMessage() 105 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 113 Optional<json::Value> ID; in handleMessage() local
|
/dports/lang/rust/rustc-1.58.1-src/src/llvm-project/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm13/llvm-project-13.0.1.src/clang-tools-extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 23 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/devel/llvm80/llvm-8.0.1.src/tools/clang/tools/extra/clangd/xpc/ |
H A D | XPCTransport.cpp | 24 std::string Message; in encodeError() local 63 void call(StringRef Method, json::Value Params, json::Value ID) override { in call() 71 void reply(json::Value ID, Expected<json::Value> Result) override { in reply() 95 void sendMessage(json::Value Message) { in sendMessage() 106 bool XPCTransport::handleMessage(json::Value Message, MessageHandler &Handler) { in handleMessage() 114 Optional<json::Value> ID; in handleMessage() local
|
/dports/net/storj/storj-1.45.3/private/post/ |
H A D | message.go | 20 type Message struct { struct 21 From Address 22 To []Address 23 Subject string 24 ID string member 25 Date time.Time 26 ReceiptTo []string 28 PlainText string 29 Parts []Part 44 func (msg *Message) Bytes() (data []byte, err error) {
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/etcdserver/ |
H A D | util.go | 32 func isConnectedToQuorumSince(transport rafthttp.Transporter, since time.Time, self types.ID, membe… 38 func isConnectedSince(transport rafthttp.Transporter, since time.Time, remote types.ID) bool { 45 func isConnectedFullySince(transport rafthttp.Transporter, since time.Time, self types.ID, members … 51 func numConnectedSince(transport rafthttp.Transporter, since time.Time, self types.ID, members []*m… 63 func longestConnected(tp rafthttp.Transporter, membs []types.ID) (types.ID, bool) { 104 func warnOfExpensiveRequest(now time.Time, reqStringer fmt.Stringer, respMsg proto.Message, err err… 153 func isNil(msg proto.Message) bool {
|
/dports/devel/etcd32/etcd-3.2.32/etcdserver/ |
H A D | util.go | 32 func isConnectedToQuorumSince(transport rafthttp.Transporter, since time.Time, self types.ID, membe… 38 func isConnectedSince(transport rafthttp.Transporter, since time.Time, remote types.ID) bool { 45 func isConnectedFullySince(transport rafthttp.Transporter, since time.Time, self types.ID, members … 51 func numConnectedSince(transport rafthttp.Transporter, since time.Time, self types.ID, members []*m… 63 func longestConnected(tp rafthttp.Transporter, membs []types.ID) (types.ID, bool) { 104 func warnOfExpensiveRequest(now time.Time, reqStringer fmt.Stringer, respMsg proto.Message, err err… 153 func isNil(msg proto.Message) bool {
|
/dports/devel/etcd31/etcd-3.1.20/etcdserver/ |
H A D | util.go | 32 func isConnectedToQuorumSince(transport rafthttp.Transporter, since time.Time, self types.ID, membe… 38 func isConnectedSince(transport rafthttp.Transporter, since time.Time, remote types.ID) bool { 45 func isConnectedFullySince(transport rafthttp.Transporter, since time.Time, self types.ID, members … 51 func numConnectedSince(transport rafthttp.Transporter, since time.Time, self types.ID, members []*m… 63 func longestConnected(tp rafthttp.Transporter, membs []types.ID) (types.ID, bool) { 104 func warnOfExpensiveRequest(now time.Time, reqStringer fmt.Stringer, respMsg proto.Message, err err… 153 func isNil(msg proto.Message) bool {
|