AddWriteSubscriber (reference) in projects: dports

Searched refs:AddWriteSubscriber (Results 1 – 9 of 9) sorted by relevance

/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/coordinator/
H A D	points_writer_test.go	`343 c.AddWriteSubscriber(sub.Points()) 419 c.AddWriteSubscriber(sub.Points())`
H A D	points_writer.go	`146 func (w PointsWriter) AddWriteSubscriber(c chan<- WritePointsRequest) { func`
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/coordinator/
H A D	points_writer_test.go	`343 c.AddWriteSubscriber(sub.Points()) 419 c.AddWriteSubscriber(sub.Points())`
H A D	points_writer.go	`147 func (w PointsWriter) AddWriteSubscriber(c chan<- WritePointsRequest) { func`
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/coordinator/
H A D	points_writer_test.go	`343 c.AddWriteSubscriber(sub.Points()) 419 c.AddWriteSubscriber(sub.Points())`
H A D	points_writer.go	`146 func (w PointsWriter) AddWriteSubscriber(c chan<- WritePointsRequest) { func`
/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/cmd/influxd/run/
H A D	server.go	`450 s.PointsWriter.AddWriteSubscriber(s.Subscriber.Points())`
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/cmd/influxd/run/
H A D	server.go	`456 s.PointsWriter.AddWriteSubscriber(s.Subscriber.Points())`
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/cmd/influxd/run/
H A D	server.go	`462 s.PointsWriter.AddWriteSubscriber(s.Subscriber.Points())`