Home
last modified time | relevance | path

Searched refs:IntoWriteRequest (Results 1 – 19 of 19) sorted by relevance

/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/coordinator/
H A Dstatement_executor_test.go136 pw func(t *testing.T, req *coordinator.IntoWriteRequest) error
143 pw: func(t *testing.T, req *coordinator.IntoWriteRequest) error {
159 pw: func(t *testing.T, req *coordinator.IntoWriteRequest) error {
183 …e.StatementExecutor.PointsWriter = writePointsIntoFunc(func(req *coordinator.IntoWriteRequest) err…
612 type writePointsIntoFunc func(req *coordinator.IntoWriteRequest) error
614 func (fn writePointsIntoFunc) WritePointsInto(req *coordinator.IntoWriteRequest) error { argument
H A Dpoints_writer_test.go432 WritePointsIntoFn func(*coordinator.IntoWriteRequest) error
435 func (f *fakePointsWriter) WritePointsInto(req *coordinator.IntoWriteRequest) error {
453 WritePointsIntoFn: func(req *coordinator.IntoWriteRequest) error {
477 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
500 r := coordinator.IntoWriteRequest(req)
527 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
H A Dstatement_executor.go30 WritePointsInto(*IntoWriteRequest) error argument
51 WritePointsInto(*IntoWriteRequest) error
1132 func (w *BufferedPointsWriter) WritePointsInto(req *IntoWriteRequest) error {
1171 if err := w.w.WritePointsInto(&IntoWriteRequest{
1213 if err := w.WritePointsInto(&IntoWriteRequest{
1351 type IntoWriteRequest struct { struct
H A Dpoints_writer.go281 func (w *PointsWriter) WritePointsInto(p *IntoWriteRequest) error {
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/coordinator/
H A Dstatement_executor_test.go136 pw func(t *testing.T, req *coordinator.IntoWriteRequest) error
143 pw: func(t *testing.T, req *coordinator.IntoWriteRequest) error {
159 pw: func(t *testing.T, req *coordinator.IntoWriteRequest) error {
183 …e.StatementExecutor.PointsWriter = writePointsIntoFunc(func(req *coordinator.IntoWriteRequest) err…
612 type writePointsIntoFunc func(req *coordinator.IntoWriteRequest) error
614 func (fn writePointsIntoFunc) WritePointsInto(req *coordinator.IntoWriteRequest) error { argument
H A Dpoints_writer_test.go432 WritePointsIntoFn func(*coordinator.IntoWriteRequest) error
435 func (f *fakePointsWriter) WritePointsInto(req *coordinator.IntoWriteRequest) error {
453 WritePointsIntoFn: func(req *coordinator.IntoWriteRequest) error {
477 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
500 r := coordinator.IntoWriteRequest(req)
527 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
H A Dstatement_executor.go30 WritePointsInto(*IntoWriteRequest) error argument
51 WritePointsInto(*IntoWriteRequest) error
1132 func (w *BufferedPointsWriter) WritePointsInto(req *IntoWriteRequest) error {
1171 if err := w.w.WritePointsInto(&IntoWriteRequest{
1213 if err := w.WritePointsInto(&IntoWriteRequest{
1351 type IntoWriteRequest struct { struct
H A Dpoints_writer.go282 func (w *PointsWriter) WritePointsInto(p *IntoWriteRequest) error {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/coordinator/
H A Dstatement_executor_test.go136 pw func(t *testing.T, req *coordinator.IntoWriteRequest) error
143 pw: func(t *testing.T, req *coordinator.IntoWriteRequest) error {
159 pw: func(t *testing.T, req *coordinator.IntoWriteRequest) error {
183 …e.StatementExecutor.PointsWriter = writePointsIntoFunc(func(req *coordinator.IntoWriteRequest) err…
600 type writePointsIntoFunc func(req *coordinator.IntoWriteRequest) error
602 func (fn writePointsIntoFunc) WritePointsInto(req *coordinator.IntoWriteRequest) error { argument
H A Dpoints_writer_test.go432 WritePointsIntoFn func(*coordinator.IntoWriteRequest) error
435 func (f *fakePointsWriter) WritePointsInto(req *coordinator.IntoWriteRequest) error {
453 WritePointsIntoFn: func(req *coordinator.IntoWriteRequest) error {
477 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
500 r := coordinator.IntoWriteRequest(req)
527 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
H A Dstatement_executor.go30 WritePointsInto(*IntoWriteRequest) error argument
51 WritePointsInto(*IntoWriteRequest) error
1138 func (w *BufferedPointsWriter) WritePointsInto(req *IntoWriteRequest) error {
1177 if err := w.w.WritePointsInto(&IntoWriteRequest{
1219 if err := w.WritePointsInto(&IntoWriteRequest{
1360 type IntoWriteRequest struct { struct
H A Dpoints_writer.go269 func (w *PointsWriter) WritePointsInto(p *IntoWriteRequest) error {
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/coordinator/
H A Dpoints_writer_test.go432 WritePointsIntoFn func(*coordinator.IntoWriteRequest) error
435 func (f *fakePointsWriter) WritePointsInto(req *coordinator.IntoWriteRequest) error {
453 WritePointsIntoFn: func(req *coordinator.IntoWriteRequest) error {
477 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
500 r := coordinator.IntoWriteRequest(req)
527 if err := w.WritePointsInto(&coordinator.IntoWriteRequest{
H A Dstatement_executor.go30 WritePointsInto(*IntoWriteRequest) error argument
1129 func (w *BufferedPointsWriter) WritePointsInto(req *IntoWriteRequest) error {
1168 if err := w.w.WritePointsInto(&IntoWriteRequest{
1210 if err := w.WritePointsInto(&IntoWriteRequest{
1344 type IntoWriteRequest struct { struct
H A Dpoints_writer.go281 func (w *PointsWriter) WritePointsInto(p *IntoWriteRequest) error {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/flux/stdlib/influxdata/influxdb/
H A Ddependencies.go16 WritePointsInto(request *coordinator.IntoWriteRequest) error argument
H A Dto.go383 return t.buf.WritePointsInto(&coordinator.IntoWriteRequest{
H A Dto_test.go788 func (m *mockPointsWriter) WritePointsInto(request *coordinator.IntoWriteRequest) error {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/mock/
H A Dflux.go48 func (w *Writer) WritePointsInto(request *coordinator.IntoWriteRequest) error {