Fulfills the protobuf interface for a ProvisionerDaemon with passable functions for dynamic functionality.
| 1315 | // Fulfills the protobuf interface for a ProvisionerDaemon with |
| 1316 | // passable functions for dynamic functionality. |
| 1317 | type provisionerDaemonTestServer struct { |
| 1318 | acquireJobWithCancel func(stream proto.DRPCProvisionerDaemon_AcquireJobWithCancelStream) error |
| 1319 | commitQuota func(ctx context.Context, com *proto.CommitQuotaRequest) (*proto.CommitQuotaResponse, error) |
| 1320 | updateJob func(ctx context.Context, update *proto.UpdateJobRequest) (*proto.UpdateJobResponse, error) |
| 1321 | failJob func(ctx context.Context, job *proto.FailedJob) (*proto.Empty, error) |
| 1322 | completeJob func(ctx context.Context, job *proto.CompletedJob) (*proto.Empty, error) |
| 1323 | uploadFile func(stream proto.DRPCProvisionerDaemon_UploadFileStream) error |
| 1324 | downloadFile func(request *proto.FileRequest, stream proto.DRPCProvisionerDaemon_DownloadFileStream) error |
| 1325 | } |
| 1326 | |
| 1327 | func (p *provisionerDaemonTestServer) DownloadFile(request *proto.FileRequest, stream proto.DRPCProvisionerDaemon_DownloadFileStream) error { |
| 1328 | return p.downloadFile(request, stream) |
nothing calls this directly
no outgoing calls
no test coverage detected