Home
last modified time | relevance | path

Searched refs:feed (Results 1 - 25 of 49) sorted by relevance

12

/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/projector/
H A Dfeed.go40 opaque uint16 // opaque that created this feed.
76 // NewFeed creates a new topic feed.
81 // feedChanSize: channel size for feed's control path and back path
94 feed := &Feed{
120 feed.logPrefix = fmt.Sprintf("FEED[<=>%v(%v)]", topic, feed.cluster)
122 go feed.genServer()
123 logging.Infof("%v ##%x feed started ...\n", feed.logPrefix, opaque)
124 return feed, ni
[all...]
H A Dprojector.go194 feed, ok := p.topics[topic]
195 return feed, ok
198 if feed, ok := getfeed(); ok {
199 if err := feed.Ping(); err != nil {
202 return feed, nil
213 for _, feed := range p.topics {
214 feeds = append(feeds, feed)
221 func (p *Projector) AddFeed(topic string, feed *Feed) (err error) {
228 p.topics[topic] = feed
229 opaque := feed
[all...]
H A Dkvdata.go4 // feed <---------------------* NewKVData()
33 feed *Feed
65 feed *Feed, bucket string,
74 feed: feed,
76 topic: feed.topic,
82 // control calls on this feed.
88 kvdata.logPrefix = fmt.Sprintf(fmsg, bucket, feed.cluster, feed.topic)
100 kvdata.workers = kvdata.spawnWorkers(feed, bucke
[all...]
/5.5.2/godeps/src/github.com/couchbase/go-couchbase/
H A Dtap.go29 // StartTapFeed creates and starts a new Tap feed
36 feed := &TapFeed{
43 go feed.run()
45 feed.C = feed.output
46 return feed, nil
49 // Goroutine that runs the feed
50 func (feed *TapFeed) run() {
54 // Connect to the TAP feed of each server node:
56 killSwitch, err := feed
[all...]
H A Dupr.go27 name string // name of this UPR feed
28 sequence uint32 // sequence number for this feed
39 uprFeed *memcached.UprFeed // UPR feed handle
110 // StartUprFeed creates and starts a new Upr feed
114 feed := &UprFeed{
126 err := feed.connectToNodes()
130 feed.connected = true
131 go feed.run()
133 feed.C = feed
[all...]
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/dcp/
H A Dtap.go28 // StartTapFeed creates and starts a new Tap feed
35 feed := &TapFeed{
42 go feed.run()
44 feed.C = feed.output
45 return feed, nil
48 // Goroutine that runs the feed
49 func (feed *TapFeed) run() {
53 // Connect to the TAP feed of each server node:
55 killSwitch, err := feed
[all...]
H A Dupr.go36 // Make a valid DCP feed name. These always begin with secidx:
113 name DcpFeedName // name of this DCP feed
114 sequence uint32 // sequence number for this feed
124 // StartDcpFeed creates and starts a new Dcp feed.
135 // StartDcpFeedOver creates and starts a new Dcp feed.
154 feed := &DcpFeed{
165 feed.numConnections = config["numConnections"].(int)
166 feed.activeVbOnly = config["activeVbOnly"].(bool)
168 feed.C = feed
[all...]
/5.5.2/godeps/src/github.com/couchbase/gomemcached/client/
H A Dupr_feed.go167 func (negotiator *vbStreamNegotiator) handleStreamRequest(feed *UprFeed,
172 if feed == nil || response == nil || pktPtr == nil {
200 feed.activateStream(vbno, opaque, stream)
201 feed.negotiator.deleteStreamFromMap(vbno, opaque)
224 // UprFeed represents an UPR feed. A feed contains a connection to a single
227 // lock for feed.vbstreams
229 // lock for feed.closed
243 closed bool // flag indicating whether the feed has been closed
244 // flag indicating whether client of upr feed wil
[all...]
H A Dtap_feed.go130 // TapArguments are parameters for requesting a TAP feed.
228 // StartTapFeed starts a TAP feed on a client connection.
247 feed := &TapFeed{
251 go mc.runFeed(ch, feed)
252 return feed, nil
260 func (mc *Client) runFeed(ch chan TapEvent, feed *TapFeed) {
277 feed.Error = err
287 feed.Error = fmt.Errorf("tap connection failed: %s", pkt.Body)
299 case <-feed.closer:
308 feed
[all...]
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/dcp/transport/client/
H A Ddcp_feed.go38 // DcpFeed represents an DCP feed. A feed contains a connection to a single
63 feed := &DcpFeed{
75 feed.conn = mc
77 go feed.genServer(opaque, feed.reqch, feed.finch, rcvch, config)
78 go feed.doReceive(rcvch, feed.finch, mc)
79 logging.Infof("%v ##%x feed starte
[all...]
H A Dtap_feed.go130 // TapArguments are parameters for requesting a TAP feed.
228 // StartTapFeed starts a TAP feed on a client connection.
247 feed := &TapFeed{
251 go mc.runFeed(ch, feed)
252 return feed, nil
260 func (mc *Client) runFeed(ch chan TapEvent, feed *TapFeed) {
277 feed.Error = err
287 feed.Error = fmt.Errorf("tap connection failed: %s", pkt.Body)
299 case <-feed.closer:
308 feed
[all...]
/5.5.2/godeps/src/github.com/couchbase/go-couchbase/examples/upr_restart/
H A Drestart.go25 // start upr feed
26 feed, err := bucket.StartUprFeed("index" /*name*/, 0)
32 err := feed.UprRequestStream(
40 vbseqNo := receiveMutations(feed, 20000)
63 feed, err = bucket.StartUprFeed("index" /*name*/, 0)
71 err := feed.UprRequestStream(
86 case f = <-feed.C:
106 feed.Close()
119 func receiveMutations(feed *couchbase.UprFeed, breakAfter int) [][2]uint64 {
127 case e = <-feed
[all...]
/5.5.2/goproj/src/github.com/couchbase/cbft/
H A Dpindex_bleve_rollback_test.go56 func setVBucketFailoverLog(feed *cbgt.PrimaryFeed, partition string) {
60 feed.OpaqueSet(partition, buf)
103 var feed *cbgt.PrimaryFeed var
136 Desc: "create dest feed with 1 partition for rollback",
156 t.Errorf("expected to be 1 feed, got feeds: %+v", feeds)
164 feed, ok = f.(*cbgt.PrimaryFeed)
166 t.Errorf("expected the 1 feed to be a PrimaryFeed")
179 err = feed.SnapshotStart(partition, snapStart, snapEnd)
183 setVBucketFailoverLog(feed, partition)
199 err = feed
[all...]
/5.5.2/goproj/src/github.com/couchbase/cbgt/
H A Dfeed_tap.go40 // StartDCPFeed starts a TAP related feed and is registered at
48 feed, err := NewTAPFeed(feedName, indexName, server, poolName,
50 mgr.tagsMap != nil && !mgr.tagsMap["feed"])
56 err = feed.Start()
61 err = mgr.registerFeed(feed)
63 feed.Close()
89 // feed.
157 progress, err := t.feed()
169 func (t *TAPFeed) feed() (int, error) {
202 feed, er
[all...]
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/dcp/examples/upr_restart/
H A Drestart.go60 // start dcp feed
67 feed, err := bucket.StartDcpFeed(name, 0, 0xABCD, dcpConfig)
73 err := feed.DcpRequestStream(
81 vbseqNo := receiveMutations(feed, 20000)
104 feed, err = bucket.StartDcpFeed(name, 0, 0xABCD, dcpConfig)
112 err := feed.DcpRequestStream(
127 case f := <-feed.C:
145 feed.Close()
158 func receiveMutations(feed *couchbase.DcpFeed, breakAfter int) [][2]uint64 {
165 case e := <-feed
[all...]
/5.5.2/couchbase-cli/requests/packages/chardet/
H A Deucjpprober.py52 def feed(self, aBuf): member in EUCJPProber
71 self._mContextAnalyzer.feed(self._mLastChar, charLen)
72 self._mDistributionAnalyzer.feed(self._mLastChar, charLen)
74 self._mContextAnalyzer.feed(aBuf[i - 1:i + 1], charLen)
75 self._mDistributionAnalyzer.feed(aBuf[i - 1:i + 1],
H A Dsjisprober.py52 def feed(self, aBuf): member in SJISProber
70 self._mContextAnalyzer.feed(self._mLastChar[2 - charLen:],
72 self._mDistributionAnalyzer.feed(self._mLastChar, charLen)
74 self._mContextAnalyzer.feed(aBuf[i + 1 - charLen:i + 3
76 self._mDistributionAnalyzer.feed(aBuf[i - 1:i + 1],
H A Dmbcharsetprober.py53 def feed(self, aBuf): member in MultiByteCharSetProber
71 self._mDistributionAnalyzer.feed(self._mLastChar, charLen)
73 self._mDistributionAnalyzer.feed(aBuf[i - 1:i + 1],
H A Duniversaldetector.py64 def feed(self, aBuf): member in UniversalDetector
119 if self._mEscCharSetProber.feed(aBuf) == constants.eFoundIt:
128 if prober.feed(aBuf) == constants.eFoundIt:
H A Dcharsetgroupprober.py58 def feed(self, aBuf): member in CharSetGroupProber
64 st = prober.feed(aBuf)
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/dcp/examples/upr_feed/
H A Dfeed.go103 // start dcp feed
110 feed, err := bucket.StartDcpFeed(name, 0, 0xABCD, dcpConfig)
119 err := feed.DcpRequestStream(
128 events(feed, 2000)
138 if err := feed.DcpCloseStream(uint16(vbno), opaque); err != nil {
145 events(feed, 100000)
147 feed.Close()
150 func events(feed *couchbase.DcpFeed, timeoutMs int) {
163 case e := <-feed.C:
/5.5.2/godeps/src/github.com/couchbase/go-couchbase/examples/upr_feed/
H A Dfeed.go89 // start upr feed
91 feed, err := bucket.StartUprFeed(name, 0)
99 err := feed.UprRequestStream(
114 case e, ok := <-feed.C:
141 err := feed.UprCloseStream(
148 feed.Close()
/5.5.2/godeps/src/github.com/couchbase/gomemcached/client/example/
H A Dtap_example.go45 feed, err := client.StartTapFeed(args)
47 log.Fatalf("Error starting tap feed: %v", err)
49 for op := range feed.C {
59 log.Printf("Tap feed closed; err = %v.", feed.Error)
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/dcp/transport/client/example/
H A Dtap_example.go45 feed, err := client.StartTapFeed(args)
47 log.Fatalf("Error starting tap feed: %v", err)
49 for op := range feed.C {
59 log.Printf("Tap feed closed; err = %v.", feed.Error)
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/common/
H A Ddcp_seqno.go182 // make sure a feed is available for all kv-nodes
299 for _, feed := range kvfeeds {
301 go func(index int, feed *kvConn) {
303 kv_seqnos_node[index] = feed.seqsbuf
304 feed.mc.SetReadDeadline(time.Now().Add(20 * time.Second))
305 errors[index] = couchbase.GetSeqs(feed.mc, kv_seqnos_node[index], feed.tmpbuf)
306 feed.mc.SetReadDeadline(time.Time{})
307 }(i, feed)
317 logging.Errorf("feed
[all...]

Completed in 36 milliseconds

12