| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/indexgateway/indexgatewaypb/ |
| H A D | gateway.pb.go | 32 type QueryIndexResponse struct { struct
37 func (m *QueryIndexResponse) Reset() { *m = QueryIndexResponse{} } argument
38 func (*QueryIndexResponse) ProtoMessage() {} argument
60 func (m *QueryIndexResponse) XXX_Size() int { argument
76 func (m *QueryIndexResponse) GetRows() []*Row { argument
297 that1, ok := that.(*QueryIndexResponse)
299 that2, ok := that.(QueryIndexResponse)
516 Recv() (*QueryIndexResponse, error)
525 m := new(QueryIndexResponse)
560 Send(*QueryIndexResponse) error argument
[all …]
|
| H A D | gateway.proto | 8 rpc QueryIndex(QueryIndexRequest) returns (stream QueryIndexResponse);
11 message QueryIndexResponse { message
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/ |
| H A D | gateway_client.go | 152 *indexgatewaypb.QueryIndexResponse anonMember
158 QueryIndexResponse: r.QueryIndexResponse,
164 *indexgatewaypb.QueryIndexResponse anonMember
|
| H A D | gateway_client_test.go | 39 resp := indexgatewaypb.QueryIndexResponse{
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/grpc/ |
| H A D | index_client.go | 84 func (r *QueryIndexResponse) Iterator() chunk.ReadBatchIterator {
87 QueryIndexResponse: r,
93 *QueryIndexResponse anonMember
|
| H A D | grpc.proto | 14 rpc QueryIndex(QueryIndexRequest) returns (stream QueryIndexResponse);
86 message QueryIndexResponse { message
|
| H A D | grpc.pb.go | 488 type QueryIndexResponse struct { struct
492 func (m *QueryIndexResponse) Reset() { *m = QueryIndexResponse{} } argument
493 func (*QueryIndexResponse) ProtoMessage() {} argument
515 func (m *QueryIndexResponse) XXX_Size() int { argument
524 func (m *QueryIndexResponse) GetRows() []*Row { argument
1424 that1, ok := that.(*QueryIndexResponse)
1426 that2, ok := that.(QueryIndexResponse)
2058 Recv() (*QueryIndexResponse, error)
2067 m := new(QueryIndexResponse)
2276 Send(*QueryIndexResponse) error argument
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/indexgateway/ |
| H A D | gateway_test.go | 60 callback func(resp *indexgatewaypb.QueryIndexResponse)
63 func (m *mockQueryIndexServer) Send(resp *indexgatewaypb.QueryIndexResponse) error {
77 callback: func(resp *indexgatewaypb.QueryIndexResponse) {
|
| H A D | gateway.go | 67 err := server.Send(&indexgatewaypb.QueryIndexResponse{
84 err := server.Send(&indexgatewaypb.QueryIndexResponse{
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/grpc/ |
| H A D | index_client.go | 84 func (r *QueryIndexResponse) Iterator() chunk.ReadBatchIterator {
87 QueryIndexResponse: r,
93 *QueryIndexResponse anonMember
|
| H A D | grpc.proto | 14 rpc QueryIndex(QueryIndexRequest) returns (stream QueryIndexResponse);
86 message QueryIndexResponse { message
|
| H A D | grpc.pb.go | 488 type QueryIndexResponse struct { struct
492 func (m *QueryIndexResponse) Reset() { *m = QueryIndexResponse{} } argument
493 func (*QueryIndexResponse) ProtoMessage() {} argument
515 func (m *QueryIndexResponse) XXX_Size() int { argument
524 func (m *QueryIndexResponse) GetRows() []*Row { argument
1423 that1, ok := that.(*QueryIndexResponse)
1425 that2, ok := that.(QueryIndexResponse)
2057 Recv() (*QueryIndexResponse, error)
2066 m := new(QueryIndexResponse)
2275 Send(*QueryIndexResponse) error argument
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/grpc/ |
| H A D | index_client.go | 84 func (r *QueryIndexResponse) Iterator() chunk.ReadBatchIterator {
87 QueryIndexResponse: r,
93 *QueryIndexResponse anonMember
|
| H A D | grpc.proto | 14 rpc QueryIndex(QueryIndexRequest) returns (stream QueryIndexResponse);
86 message QueryIndexResponse { message
|
| H A D | grpc.pb.go | 488 type QueryIndexResponse struct { struct
492 func (m *QueryIndexResponse) Reset() { *m = QueryIndexResponse{} } argument
493 func (*QueryIndexResponse) ProtoMessage() {} argument
515 func (m *QueryIndexResponse) XXX_Size() int { argument
524 func (m *QueryIndexResponse) GetRows() []*Row { argument
1423 that1, ok := that.(*QueryIndexResponse)
1425 that2, ok := that.(QueryIndexResponse)
2057 Recv() (*QueryIndexResponse, error)
2066 m := new(QueryIndexResponse)
2275 Send(*QueryIndexResponse) error argument
[all …]
|