Home
last modified time | relevance | path

Searched refs:nsq (Results 1 – 25 of 477) sorted by relevance

12345678910>>...20

/dports/net/nsq/nsq-1.2.1/
H A DREADME.md2 <img align="left" width="175" src="https://nsq.io/static/img/nsq_blue.png">
4 <li><strong>Source</strong>: https://github.com/nsqio/nsq
5 <li><strong>Issues</strong>: https://github.com/nsqio/nsq/issues
6 <li><strong>Mailing List</strong>: <a href="https://groups.google.com/d/forum/nsq-users">nsq-users@…
7 <li><strong>IRC</strong>: #nsq on freenode
8 <li><strong>Docs</strong>: https://nsq.io
13 …nsq/workflows/tests/badge.svg)](https://github.com/nsqio/nsq/actions) [![GitHub release](https://i…
86 [protocol]: https://nsq.io/clients/tcp_protocol_spec.html
87 [installing]: https://nsq.io/deployment/installing.html
88 [docker_deployment]: https://nsq.io/deployment/docker.html
[all …]
H A DDockerfile5 RUN mkdir -p /go/src/github.com/nsqio/nsq
6 COPY . /go/src/github.com/nsqio/nsq
7 WORKDIR /go/src/github.com/nsqio/nsq
10 RUN CGO_ENABLED=0 make PREFIX=/opt/nsq BLDFLAGS='-ldflags="-s -w"' install
28 COPY --from=build /opt/nsq/bin/ /usr/local/bin/
29 RUN ln -s /usr/local/bin/*nsq* / \
30 && ln -s /usr/local/bin/*nsq* /bin/
/dports/net/nsq/nsq-1.2.1/bench/bench_channels/
H A Dbench_channels.go46 conn.Write(nsq.MagicV2)
50 cmd, _ := nsq.Identify(ci)
57 nsq.Ready(rdyCount).WriteTo(rw)
59 nsq.ReadResponse(rw)
60 nsq.ReadResponse(rw)
62 resp, err := nsq.ReadResponse(rw)
70 if frameType == nsq.FrameTypeError {
73 nsq.Nop().WriteTo(rw)
77 msg, err := nsq.DecodeMessage(data)
81 nsq.Finish(msg.ID).WriteTo(rw)
[all …]
/dports/math/faiss/faiss-1.7.1/faiss/impl/
H A Dpq4_fast_scan.cpp51 size_t nsq, in pq4_pack_codes() argument
55 FAISS_THROW_IF_NOT(nsq % 2 == 0); in pq4_pack_codes()
57 memset(blocks, 0, nb * nsq / 2); in pq4_pack_codes()
63 for (int sq = 0; sq < nsq; sq += 2) { in pq4_pack_codes()
128 size_t nsq, in pq4_get_packed_element() argument
170 FAISS_THROW_IF_NOT(nsq % 2 == 0); in pq4_pack_LUT_qbs()
171 size_t dim12 = 16 * nsq; in pq4_pack_LUT_qbs()
188 int nsq, in pack_LUT_1_q_map() argument
208 int nsq, in pq4_pack_LUT_qbs_q_map() argument
212 FAISS_THROW_IF_NOT(nsq % 2 == 0); in pq4_pack_LUT_qbs_q_map()
[all …]
H A Dpq4_fast_scan_search_qbs.cpp32 int nsq, in kernel_accumulate_block() argument
87 int nsq, in accumulate_q_4step() argument
101 LUT += Q1 * nsq * 16; in accumulate_q_4step()
118 codes += 32 * nsq / 2; in accumulate_q_4step()
125 int nsq, in kernel_accumulate_block_loop() argument
132 nsq, codes + j0 * nsq / 2, LUT, res); in kernel_accumulate_block_loop()
141 int nsq, in accumulate() argument
145 assert(nsq % 2 == 0); in accumulate()
172 int nsq, in pq4_accumulate_loop_qbs() argument
176 assert(nsq % 2 == 0); in pq4_accumulate_loop_qbs()
[all …]
H A Dpq4_fast_scan.h70 size_t nsq,
81 void pq4_pack_LUT(int nq, int nsq, const uint8_t* src, uint8_t* dest);
97 int nsq,
131 int pq4_pack_LUT_qbs(int fqbs, int nsq, const uint8_t* src, uint8_t* dest);
137 int nsq,
155 int nsq,
/dports/net/py-pynsq/pynsq-0.9.0b1/
H A D.travis.yml7 env: TORNADO_VERSION=4.1 NSQ_DOWNLOAD=nsq-1.0.0-compat.linux-amd64.go1.8
9 env: TORNADO_VERSION=4.4.3 NSQ_DOWNLOAD=nsq-1.0.0-compat.linux-amd64.go1.8
11 env: TORNADO_VERSION=4.5.3 NSQ_DOWNLOAD=nsq-1.1.0.linux-amd64.go1.10.3
13 env: TORNADO_VERSION=5.1.1 NSQ_DOWNLOAD=nsq-1.1.0.linux-amd64.go1.10.3
16 env: TORNADO_VERSION=4.5.3 NSQ_DOWNLOAD=nsq-1.0.0-compat.linux-amd64.go1.8
18 env: TORNADO_VERSION=5.1.1 NSQ_DOWNLOAD=nsq-1.1.0.linux-amd64.go1.10.3
21 env: TORNADO_VERSION=4.5.3 NSQ_DOWNLOAD=nsq-1.0.0-compat.linux-amd64.go1.8
23 env: TORNADO_VERSION=5.1.1 NSQ_DOWNLOAD=nsq-1.1.0.linux-amd64.go1.10.3
26 env: TORNADO_VERSION=4.5.3 NSQ_DOWNLOAD=nsq-1.0.0-compat.linux-amd64.go1.8
28 env: TORNADO_VERSION=5.1.1 NSQ_DOWNLOAD=nsq-1.1.0.linux-amd64.go1.10.3
[all …]
H A DREADME.md5 The official Python client library for [NSQ][nsq].
20 wget http://bitly-downloads.s3.amazonaws.com/nsq/nsq-0.3.5.linux-amd64.go1.4.2.tar.gz
21 tar zxvf nsq-0.3.5.linux-amd64.go1.4.2.tar.gz
22 sudo cp nsq-0.3.5.linux-amd64.go1.4.2/bin/{nsqd,nsqlookupd} /usr/local/bin
28 [nsq]: https://github.com/nsqio/nsq
/dports/net/nsq/nsq-1.2.1/vendor/github.com/nsqio/go-nsq/
H A DREADME.md1 ## go-nsq
3 …nsq.svg?branch=master)][travis] [![GoDoc](https://godoc.org/github.com/nsqio/go-nsq?status.svg)](h…
5 The official Go package for [NSQ][nsq].
16 [nsq]: https://github.com/nsqio/nsq
17 [nsq_gopkgdoc]: http://godoc.org/github.com/nsqio/go-nsq argument
18 [apps]: https://github.com/nsqio/nsq/tree/master/apps
19 [travis]: http://travis-ci.org/nsqio/go-nsq
H A DUPGRADING.md19 Previously, the high-level types we exposed were named `nsq.Reader` and `nsq.Writer`. These
24 We renamed these types to `nsq.Consumer` and `nsq.Producer`, which more effectively communicate
31 Now, configuration is performed *before* creating an `nsq.Consumer` or `nsq.Producer` by creating
32 an `nsq.Config` struct. The only valid way to do this is via `nsq.NewConfig` (i.e. using a struct
46 #### Improving the nsq.Handler interface
56 called `nsq.AsyncHandler`.
65 The new `go-nsq` message handler interface exposes only `nsq.Handler`, and its `HandleMessage`
78 r, err := nsq.NewConsumer("test_topic", "test_channel", nsq.NewConfig())
83 r.AddHandler(nsq.HandlerFunc(func(m *nsq.Message) error {
110 func (h *myHandler) HandleMessage(m *nsq.Message) error {
[all …]
H A D.travis.yml7 - NSQ_DOWNLOAD=nsq-1.0.0-compat.linux-amd64.go1.8 GOARCH=amd64
8 - NSQ_DOWNLOAD=nsq-1.1.0.linux-amd64.go1.10.3 GOARCH=amd64
9 - NSQ_DOWNLOAD=nsq-1.2.0.linux-amd64.go1.12.9 GOARCH=amd64
10 # test most recent nsq version on GOARCH=386
11 - NSQ_DOWNLOAD=nsq-1.2.0.linux-amd64.go1.12.9 GOARCH=386
/dports/math/faiss/faiss-1.7.1/faiss/
H A DIndexLattice.cpp19 nsq(nsq), in IndexLattice()
20 dsq(d / nsq), in IndexLattice()
23 FAISS_THROW_IF_NOT(d % nsq == 0); in IndexLattice()
39 trained.resize(nsq * 2); in train()
41 float* maxs = trained.data() + nsq; in train()
42 for (int sq = 0; sq < nsq; sq++) { in train()
57 for (int sq = 0; sq < nsq; sq++) { in train()
72 const float* maxs = mins + nsq; in sa_encode()
79 for (int j = 0; j < nsq; j++) { in sa_encode()
95 const float* maxs = mins + nsq; in sa_decode()
[all …]
/dports/net/nsq/nsq-1.2.1/nsqd/
H A Dprotocol_v2_test.go62 conn.Write(nsq.MagicV2)
75 cmd, _ := nsq.Identify(ci)
93 auth, _ := nsq.Auth(authSecret)
396 _, err = nsq.Finish(nsq.MessageID(msg.ID)).WriteTo(conn)
644 _, err = nsq.Touch(nsq.MessageID(msg.ID)).WriteTo(conn)
649 _, err = nsq.Finish(nsq.MessageID(msg.ID)).WriteTo(conn)
1378 _, err = nsq.Finish(nsq.MessageID(msgOut.ID)).WriteTo(conn)
1403 fin := nsq.Finish(nsq.MessageID{})
1447 _, err = nsq.Requeue(nsq.MessageID(msg.ID), -1).WriteTo(conn)
1461 _, err = nsq.Requeue(nsq.MessageID(msg.ID), opts.MaxReqTimeout*2).WriteTo(conn)
[all …]
H A Dlookup.go24 cmd, err := nsq.Identify(ci)
52 var commands []*nsq.Command
57 commands = append(commands, nsq.Register(topic.name, ""))
60 commands = append(commands, nsq.Register(channel.topicName, channel.name))
113 cmd := nsq.Ping()
120 var cmd *nsq.Command
129 cmd = nsq.UnRegister(channel.topicName, channel.name)
131 cmd = nsq.Register(channel.topicName, channel.name)
138 cmd = nsq.UnRegister(topic.name, "")
140 cmd = nsq.Register(topic.name, "")
/dports/net/nsq/nsq-1.2.1/bench/bench_reader/
H A Dbench_reader.go76 conn.Write(nsq.MagicV2)
82 cmd, _ := nsq.Identify(ci)
84 nsq.Subscribe(topic, channel).WriteTo(rw)
87 nsq.Ready(*rdy).WriteTo(rw)
89 nsq.ReadResponse(rw)
90 nsq.ReadResponse(rw)
97 resp, err := nsq.ReadResponse(rw)
108 if frameType == nsq.FrameTypeError {
110 } else if frameType == nsq.FrameTypeResponse {
113 msg, err := nsq.DecodeMessage(data)
[all …]
/dports/net/kamailio/kamailio-5.4.5/src/modules/nsq/
H A DREADME95 it can be found at nsq.io.
164 Usage: nsq related.
177 Usage: nsq related.
191 Usage: nsq related.
204 Usage: nsq related.
217 Usage: nsq related.
231 Usage: nsq related.
245 Usage: nsq related.
259 Usage: nsq related.
272 Usage: nsq related.
[all …]
/dports/biology/fasta3/fasta-36.3.8/src/
H A Ddropgsw2.c142 int nsq; in init_work() local
155 nsq = ppst->nsqx; ip = 1; in init_work()
159 nsq = ppst->nsqx; ip = 0; in init_work()
311 for(i = 1; i < nsq ; i++) { in init_work()
326 for(e = 1; e<=nsq; e++) { in init_work()
346 for(e = 1; e<=nsq; e++) { in init_work()
371 for(i = 1; i < nsq ; i++) { in init_work()
390 for(e = 1; e<=nsq; e++) { in init_work()
410 for(e = 1; e<=nsq; e++) { in init_work()
433 f_str->alphabet_size = nsq+1; in init_work()
[all …]
H A Dprint_pssm.c85 ppst->nsq = naa; in main()
98 alloc_pam(pst.nsq+1,pst.nsq+1, &pst); in main()
376 for (j = 1 ; j <=nsq ; j++) { in fill_pam()
392 int i, j, k, nsq, pam_xx, pam_xm; in initpam2() local
395 nsq = ppst->nsq; in initpam2()
403 for (i = 1; i <= nsq; i++) { in initpam2()
422 for (i=1; i<=nsq; i++) { in initpam2()
453 for (j = 1; j <= nsq ; j++) { in get_lambda()
472 for (j = 1; j <= nsq ; j++) { in get_lambda()
498 alloc_pam2p(int len, int nsq) { in alloc_pam2p() argument
[all …]
H A Dtatstats.c85 if (ppst->nsq > MAXUC) { in calc_priors()
87 ppst->nsq, MAXUC); in calc_priors()
89 n_counts = ppst->nsq; in calc_priors()
155 for(i = 1 ; i < ppst->nsq ; i++) { in calc_priors()
167 max_score(int *scores, int nsq) { in max_score() argument
172 for ( i = 1 ; i < nsq ; i++ ) { in max_score()
180 min_score(int *scores, int nsq) { in min_score() argument
185 for (i = 1 ; i < nsq ; i++ ) { in min_score()
196 int **pam2, int nsq, in calc_tatusov() argument
405 int nsq, in generate_tatprobs() argument
[all …]
/dports/net/nsq/nsq-1.2.1/apps/nsq_to_nsq/
H A Dnsq_to_nsq.go64 producers map[string]*nsq.Producer
67 respChan chan *nsq.ProducerTransaction
83 var msg *nsq.Message
91 msg = t.Args[0].(*nsq.Message)
96 msg = t.Args[0].(*nsq.Message)
270 cCfg := nsq.NewConfig()
271 pCfg := nsq.NewConfig()
328 producers := make(map[string]*nsq.Producer)
330 producer, err := nsq.NewProducer(addr, pCfg)
353 var consumerList []*nsq.Consumer
[all …]
/dports/science/quantum-espresso/q-e-qe-6.7.0/LR_Modules/
H A Dstar_q.f9043 integer :: nsq (48), isym, ism1, iq, i local
71 nsq (i) = 0
91 nsq (iq) = nsq (iq) + 1
96 nsq (nq) = 1
113 if (nsq(iq)*nq /= nsym) call errore ('star_q', 'wrong degeneracy', iq)
161 integer :: nsq (48), isym, ism1, iq, i, t_rev(48) local
191 nsq (i) = 0
210 nsq (iq) = nsq (iq) + 1
215 nsq (nq) = 1
232 if (nsq(iq)*nq /= nsym) call errore ('star_q', 'wrong degeneracy', iq)
/dports/science/nwchem-data/nwchem-7.0.2-release/src/atomscf/
H A Dguess_mem.F13 integer ntr, nsq
24 nsq = nb * nb
43 icopn = ic + nsq
44 ismin = icopn + nsq
47 icc = itransf + nsq
48 memscr = icc + nsq - 1
/dports/science/nwchem/nwchem-7b21660b82ebd85ef659f6fba7e1e73433b0bd0a/src/atomscf/
H A Dguess_mem.F13 integer ntr, nsq
24 nsq = nb * nb
43 icopn = ic + nsq
44 ismin = icopn + nsq
47 icc = itransf + nsq
48 memscr = icc + nsq - 1
/dports/net/nsq/nsq-1.2.1/nsqlookupd/
H A Dnsqlookupd_test.go58 conn.Write(nsq.MagicV1)
69 cmd, _ := nsq.Identify(ci)
72 _, err = nsq.ReadResponse(conn)
92 v, err := nsq.ReadResponse(conn)
167 v, err := nsq.ReadResponse(conn)
178 v, err = nsq.ReadResponse(conn)
214 _, err := nsq.ReadResponse(conn)
218 _, err = nsq.ReadResponse(conn)
261 _, err := nsq.ReadResponse(conn)
277 _, err = nsq.ReadResponse(conn)
[all …]
/dports/net/nsq/nsq-1.2.1/bench/bench_writer/
H A Dbench_writer.go79 conn.Write(nsq.MagicV2)
84 ci["user_agent"] = fmt.Sprintf("bench_writer/%s", nsq.VERSION)
85 cmd, _ := nsq.Identify(ci)
90 nsq.ReadResponse(rw)
94 cmd, _ := nsq.MultiPublish(topic, batch)
103 resp, err := nsq.ReadResponse(rw)
107 frameType, data, err := nsq.UnpackResponse(resp)
111 if frameType == nsq.FrameTypeError {

12345678910>>...20