| /dports/net/nsq/nsq-1.2.1/vendor/github.com/nsqio/go-nsq/ |
| H A D | producer.go | 25 type Producer struct { struct
26 id int64
27 addr string
28 conn producerConn
29 config Config
31 logger logger
32 logLvl LogLevel
33 logGuard sync.RWMutex
35 responseChan chan []byte
37 closeChan chan int
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka/ |
| H A D | kafka.go | 164 type Producer struct { struct
165 *kafka.Producer
170 // WrapProducer wraps a kafka.Producer so requests are traced.
171 func WrapProducer(p *kafka.Producer, opts ...Option) *Producer {
181 func (p *Producer) traceProduceChannel(out chan *kafka.Message) chan *kafka.Message {
198 func (p *Producer) startSpan(msg *kafka.Message) ddtrace.Span {
217 func (p *Producer) Close() {
223 func (p *Producer) Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error {
254 func (p *Producer) ProduceChannel() chan *kafka.Message {
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka/ |
| H A D | kafka.go | 164 type Producer struct { struct
165 *kafka.Producer
170 // WrapProducer wraps a kafka.Producer so requests are traced.
171 func WrapProducer(p *kafka.Producer, opts ...Option) *Producer {
181 func (p *Producer) traceProduceChannel(out chan *kafka.Message) chan *kafka.Message {
198 func (p *Producer) startSpan(msg *kafka.Message) ddtrace.Span {
217 func (p *Producer) Close() {
223 func (p *Producer) Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error {
254 func (p *Producer) ProduceChannel() chan *kafka.Message {
|
| /dports/games/retroarch/RetroArch-1.9.7/gfx/include/dxsdk/ |
| H A D | dxgidebug.h | 118 DXGI_DEBUG_ID Producer; member
649 #define IDXGIInfoQueue_ClearStoredMessages(This,Producer) \ argument
658 #define IDXGIInfoQueue_GetNumStoredMessages(This,Producer) \ argument
664 #define IDXGIInfoQueue_GetMessageCountLimit(This,Producer) \ argument
679 #define IDXGIInfoQueue_ClearStorageFilter(This,Producer) \ argument
682 #define IDXGIInfoQueue_PushEmptyStorageFilter(This,Producer) \ argument
694 #define IDXGIInfoQueue_PopStorageFilter(This,Producer) \ argument
706 #define IDXGIInfoQueue_ClearRetrievalFilter(This,Producer) \ argument
721 #define IDXGIInfoQueue_PopRetrievalFilter(This,Producer) \ argument
748 #define IDXGIInfoQueue_GetBreakOnID(This,Producer,ID) \ argument
[all …]
|
| /dports/emulators/mess/mame-mame0226/3rdparty/bgfx/3rdparty/dxsdk/include/ |
| H A D | dxgidebug.h | 123 DXGI_DEBUG_ID Producer; member
661 #define IDXGIInfoQueue_ClearStoredMessages(This,Producer) \ argument
670 #define IDXGIInfoQueue_GetNumStoredMessages(This,Producer) \ argument
676 #define IDXGIInfoQueue_GetMessageCountLimit(This,Producer) \ argument
691 #define IDXGIInfoQueue_ClearStorageFilter(This,Producer) \ argument
694 #define IDXGIInfoQueue_PushEmptyStorageFilter(This,Producer) \ argument
706 #define IDXGIInfoQueue_PopStorageFilter(This,Producer) \ argument
718 #define IDXGIInfoQueue_ClearRetrievalFilter(This,Producer) \ argument
733 #define IDXGIInfoQueue_PopRetrievalFilter(This,Producer) \ argument
760 #define IDXGIInfoQueue_GetBreakOnID(This,Producer,ID) \ argument
[all …]
|
| /dports/emulators/mame/mame-mame0226/3rdparty/bgfx/3rdparty/dxsdk/include/ |
| H A D | dxgidebug.h | 123 DXGI_DEBUG_ID Producer; member
661 #define IDXGIInfoQueue_ClearStoredMessages(This,Producer) \ argument
670 #define IDXGIInfoQueue_GetNumStoredMessages(This,Producer) \ argument
676 #define IDXGIInfoQueue_GetMessageCountLimit(This,Producer) \ argument
691 #define IDXGIInfoQueue_ClearStorageFilter(This,Producer) \ argument
694 #define IDXGIInfoQueue_PushEmptyStorageFilter(This,Producer) \ argument
706 #define IDXGIInfoQueue_PopStorageFilter(This,Producer) \ argument
718 #define IDXGIInfoQueue_ClearRetrievalFilter(This,Producer) \ argument
733 #define IDXGIInfoQueue_PopRetrievalFilter(This,Producer) \ argument
760 #define IDXGIInfoQueue_GetBreakOnID(This,Producer,ID) \ argument
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/langtools/tools/javac/lambda/ |
| H A D | InnerInstanceCreationTest.java | 51 class Producer { class in InnerInstanceCreationTest
52 Producer() { in Producer() method in InnerInstanceCreationTest.Producer
55 Producer(int x) { in Producer() method in InnerInstanceCreationTest.Producer
58 Producer(String s) { in Producer() method in InnerInstanceCreationTest.Producer
61 Producer(Supplier<Object> supplier) { in Producer() method in InnerInstanceCreationTest.Producer
|
| /dports/www/firefox/firefox-99.0/third_party/rust/ringbuf/src/ |
| H A D | producer.rs | 13 pub struct Producer<T> { struct
17 impl<T: Sized> Producer<T> { implementation
211 impl<T: Sized + Copy> Producer<T> { impl
222 impl Producer<u8> { impl
274 impl Write for Producer<u8> { implementation
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/ringbuf/src/ |
| H A D | producer.rs | 13 pub struct Producer<T> { struct
17 impl<T: Sized> Producer<T> { implementation
211 impl<T: Sized + Copy> Producer<T> { implementation
222 impl Producer<u8> { implementation
274 impl Write for Producer<u8> { implementation
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/ringbuf/src/ |
| H A D | producer.rs | 13 pub struct Producer<T> { struct
17 impl<T: Sized> Producer<T> { implementation
211 impl<T: Sized + Copy> Producer<T> { implementation
222 impl Producer<u8> { impl
274 impl Write for Producer<u8> { implementation
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/ringbuf/src/ |
| H A D | producer.rs | 11 pub struct Producer<T> { struct
15 impl<T: Sized> Producer<T> { implementation
197 impl<T: Sized + Copy> Producer<T> { impl
207 impl Producer<u8> { implementation
258 impl Write for Producer<u8> { implementation
|
| /dports/multimedia/mlt6/mlt-6.26.1/src/mlt++/ |
| H A D | MltProducer.cpp | 27 Producer::Producer( ) : in Producer() function in Producer
33 Producer::Producer( Profile& profile, const char *id, const char *service ) : in Producer() function in Producer
38 Producer::Producer( mlt_profile profile, const char *id, const char *service ) : in Producer() function in Producer
48 Producer::Producer( Service &producer ) : in Producer() function in Producer
61 Producer::Producer( mlt_producer producer ) : in Producer() function in Producer
68 Producer::Producer( Producer &producer ) : in Producer() function in Producer
76 Producer::Producer( const Producer &producer ) : in Producer() function in Producer
81 Producer::Producer( Producer *producer ) : in Producer() function in Producer
|
| /dports/multimedia/mlt7/mlt-7.0.1/src/mlt++/ |
| H A D | MltProducer.cpp | 27 Producer::Producer( ) : in Producer() function in Producer
33 Producer::Producer( Profile& profile, const char *id, const char *service ) : in Producer() function in Producer
38 Producer::Producer( mlt_profile profile, const char *id, const char *service ) : in Producer() function in Producer
48 Producer::Producer( Service &producer ) : in Producer() function in Producer
62 Producer::Producer( mlt_producer producer ) : in Producer() function in Producer
69 Producer::Producer( Producer &producer ) : in Producer() function in Producer
77 Producer::Producer( const Producer &producer ) : in Producer() function in Producer
82 Producer::Producer( Producer *producer ) : in Producer() function in Producer
|
| /dports/multimedia/mlt6-qt5/mlt-6.26.1/src/mlt++/ |
| H A D | MltProducer.cpp | 27 Producer::Producer( ) : in Producer() function in Producer
33 Producer::Producer( Profile& profile, const char *id, const char *service ) : in Producer() function in Producer
38 Producer::Producer( mlt_profile profile, const char *id, const char *service ) : in Producer() function in Producer
48 Producer::Producer( Service &producer ) : in Producer() function in Producer
61 Producer::Producer( mlt_producer producer ) : in Producer() function in Producer
68 Producer::Producer( Producer &producer ) : in Producer() function in Producer
76 Producer::Producer( const Producer &producer ) : in Producer() function in Producer
81 Producer::Producer( Producer *producer ) : in Producer() function in Producer
|
| /dports/multimedia/py-mlt6/mlt-6.26.1/src/mlt++/ |
| H A D | MltProducer.cpp | 27 Producer::Producer( ) : in Producer() function in Producer
33 Producer::Producer( Profile& profile, const char *id, const char *service ) : in Producer() function in Producer
38 Producer::Producer( mlt_profile profile, const char *id, const char *service ) : in Producer() function in Producer
48 Producer::Producer( Service &producer ) : in Producer() function in Producer
61 Producer::Producer( mlt_producer producer ) : in Producer() function in Producer
68 Producer::Producer( Producer &producer ) : in Producer() function in Producer
76 Producer::Producer( const Producer &producer ) : in Producer() function in Producer
81 Producer::Producer( Producer *producer ) : in Producer() function in Producer
|
| /dports/multimedia/mlt7-qt5/mlt-7.0.1/src/mlt++/ |
| H A D | MltProducer.cpp | 27 Producer::Producer( ) : in Producer() function in Producer
33 Producer::Producer( Profile& profile, const char *id, const char *service ) : in Producer() function in Producer
38 Producer::Producer( mlt_profile profile, const char *id, const char *service ) : in Producer() function in Producer
48 Producer::Producer( Service &producer ) : in Producer() function in Producer
62 Producer::Producer( mlt_producer producer ) : in Producer() function in Producer
69 Producer::Producer( Producer &producer ) : in Producer() function in Producer
77 Producer::Producer( const Producer &producer ) : in Producer() function in Producer
82 Producer::Producer( Producer *producer ) : in Producer() function in Producer
|
| /dports/devel/capnproto/capnproto-0.9.0/c++/src/kj/ |
| H A D | async-queue-test.c++ | 41 struct Producer { struct
42 QueueTest& test;
43 Promise<void> promise = kj::READY_NOW;
45 Producer(QueueTest& test): test(test) {} in Producer() function
47 void push(size_t i) { in push()
|
| /dports/net/nsq/nsq-1.2.1/internal/clusterinfo/ |
| H A D | types.go | 25 type Producer struct { struct
28 Hostname string `json:"hostname"`
30 TCPPort int `json:"tcp_port"`
31 HTTPPort int `json:"http_port"`
32 Version string `json:"version"`
33 VersionObj semver.Version `json:"-"`
34 Topics ProducerTopics `json:"topics"`
39 func (p *Producer) UnmarshalJSON(b []byte) error {
72 func (p *Producer) Address() string {
79 func (p *Producer) HTTPAddress() string {
[all …]
|