(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption)
| 6231 | } |
| 6232 | |
| 6233 | func (c *workerClient) Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error) { |
| 6234 | out := new(ExportResponse) |
| 6235 | err := c.cc.Invoke(ctx, "/pb.Worker/Export", in, out, opts...) |
| 6236 | if err != nil { |
| 6237 | return nil, err |
| 6238 | } |
| 6239 | return out, nil |
| 6240 | } |
| 6241 | |
| 6242 | func (c *workerClient) ReceivePredicate(ctx context.Context, opts ...grpc.CallOption) (Worker_ReceivePredicateClient, error) { |
| 6243 | stream, err := c.cc.NewStream(ctx, &_Worker_serviceDesc.Streams[1], "/pb.Worker/ReceivePredicate", opts...) |
nothing calls this directly
no outgoing calls
no test coverage detected