Home
last modified time | relevance | path

Searched refs:BigQueryWrite_AppendRowsClient (Results 1 – 25 of 128) sorted by relevance

123456

/dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/bigquery/storage/managedwriter/
H A Dmanaged_stream.go82 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
85 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
92 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
177 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
193 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
201 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
242 var arc *storagepb.BigQueryWrite_AppendRowsClient
294 var arc *storagepb.BigQueryWrite_AppendRowsClient
340 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/bigquery/storage/managedwriter/
H A Dmanaged_stream.go82 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
85 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
92 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
177 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
193 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
201 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
242 var arc *storagepb.BigQueryWrite_AppendRowsClient
294 var arc *storagepb.BigQueryWrite_AppendRowsClient
340 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/bigquery/storage/managedwriter/
H A Dmanaged_stream.go82 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
85 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
92 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
177 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
193 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
201 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
242 var arc *storagepb.BigQueryWrite_AppendRowsClient
294 var arc *storagepb.BigQueryWrite_AppendRowsClient
340 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/bigquery/storage/managedwriter/
H A Dmanaged_stream.go84 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
87 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
94 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
179 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
195 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
203 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
244 var arc *storagepb.BigQueryWrite_AppendRowsClient
303 var arc *storagepb.BigQueryWrite_AppendRowsClient
349 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/bigquery/storage/managedwriter/
H A Dmanaged_stream.go84 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
87 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
94 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
179 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
195 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
203 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
244 var arc *storagepb.BigQueryWrite_AppendRowsClient
303 var arc *storagepb.BigQueryWrite_AppendRowsClient
349 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/bigquery/storage/managedwriter/
H A Dmanaged_stream.go84 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
87 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
94 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
179 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
195 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
203 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
244 var arc *storagepb.BigQueryWrite_AppendRowsClient
303 var arc *storagepb.BigQueryWrite_AppendRowsClient
351 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/bigquery/storage/managedwriter/
H A Dmanaged_stream.go84 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
87 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
94 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
179 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
195 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
203 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
244 var arc *storagepb.BigQueryWrite_AppendRowsClient
303 var arc *storagepb.BigQueryWrite_AppendRowsClient
351 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/www/tusd/google-cloud-go-storage-v1.18.2/bigquery/storage/managedwriter/
H A Dmanaged_stream.go84 …open func(streamID string) (storagepb.BigQueryWrite_AppendRowsClient, error) // how we get a new…
87 arc *storagepb.BigQueryWrite_AppendRowsClient // current stream connection
94 …ientFunc func(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
179 …anagedStream) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient) (*storagepb.BigQueryWrite_A…
195 ms.arc = new(storagepb.BigQueryWrite_AppendRowsClient)
203 func (ms *ManagedStream) openWithRetry() (storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWr…
244 var arc *storagepb.BigQueryWrite_AppendRowsClient
303 var arc *storagepb.BigQueryWrite_AppendRowsClient
351 func recvProcessor(ctx context.Context, arc storagepb.BigQueryWrite_AppendRowsClient, fc *flowContr… argument
H A Dmanaged_stream_test.go58 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
110 open: func(s string) (storagepb.BigQueryWrite_AppendRowsClient, error) {
173 storagepb.BigQueryWrite_AppendRowsClient anonMember
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go145 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
217 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
354 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
356 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go145 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
217 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
354 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
356 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go145 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
217 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
354 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
356 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go145 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
217 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
354 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
356 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go145 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
217 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
354 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
356 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/bigquery/storage/apiv1/
H A Dbig_query_write_client.go143 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
230 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
373 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
375 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go145 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
217 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
354 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
356 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/sysutils/restic/google-cloud-go-storage-v1.16.0/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go144 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
216 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
353 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
355 var resp storagepb.BigQueryWrite_AppendRowsClient
/dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/bigquery/storage/apiv1beta2/
H A Dbig_query_write_client.go144 AppendRows(context.Context, ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)
216 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
353 …Rows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error…
355 var resp storagepb.BigQueryWrite_AppendRowsClient

123456