Skip to content

Commit 5cf9beb

Browse files
committed
linting
1 parent 857e88c commit 5cf9beb

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

provisionerd/provisionerd.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -519,7 +519,7 @@ func (p *Server) FailJob(ctx context.Context, in *proto.FailedJob) error {
519519
}
520520

521521
func (p *Server) UploadModuleFiles(ctx context.Context, moduleFiles []byte) error {
522-
//Send the files separately if the message size is too large.
522+
// Send the files separately if the message size is too large.
523523
_, err := clientDoWithRetries(ctx, p.client, func(ctx context.Context, client proto.DRPCProvisionerDaemonClient) (*proto.Empty, error) {
524524
stream, err := client.UploadFile(ctx)
525525
if err != nil {

provisionerd/provisionerd_test.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1269,6 +1269,10 @@ func (p *provisionerTestServer) Apply(s *provisionersdk.Session, r *sdkproto.App
12691269
return p.apply(s, r, canceledOrComplete)
12701270
}
12711271

1272+
func (p *provisionerDaemonTestServer) UploadFile(stream proto.DRPCProvisionerDaemon_UploadFileStream) error {
1273+
return p.uploadFile(stream)
1274+
}
1275+
12721276
// Fulfills the protobuf interface for a ProvisionerDaemon with
12731277
// passable functions for dynamic functionality.
12741278
type provisionerDaemonTestServer struct {
@@ -1277,6 +1281,7 @@ type provisionerDaemonTestServer struct {
12771281
updateJob func(ctx context.Context, update *proto.UpdateJobRequest) (*proto.UpdateJobResponse, error)
12781282
failJob func(ctx context.Context, job *proto.FailedJob) (*proto.Empty, error)
12791283
completeJob func(ctx context.Context, job *proto.CompletedJob) (*proto.Empty, error)
1284+
uploadFile func(stream proto.DRPCProvisionerDaemon_UploadFileStream) error
12801285
}
12811286

12821287
func (*provisionerDaemonTestServer) AcquireJob(context.Context, *proto.Empty) (*proto.AcquiredJob, error) {

0 commit comments

Comments
 (0)