Skip to content

Commit

Permalink
fix: update incorrect DriverNetworkManager interface implementation i…
Browse files Browse the repository at this point in the history
…n plugins/drivers/client.go and drivers/mock/driver.go

And add assertions to catch drifts at compilation time.
  • Loading branch information
th0m committed Mar 15, 2022
1 parent dfd0bee commit 4c9f476
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 3 deletions.
6 changes: 4 additions & 2 deletions drivers/mock/driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -670,8 +670,10 @@ func (d *Driver) GetHandle(taskID string) *taskHandle {
return h
}

func (d *Driver) CreateNetwork(allocID string) (*drivers.NetworkIsolationSpec, error) {
return nil, nil
var _ drivers.DriverNetworkManager = (*Driver)(nil)

func (d *Driver) CreateNetwork(allocID string, request *drivers.NetworkCreateRequest) (*drivers.NetworkIsolationSpec, bool, error) {
return nil, true, nil
}

func (d *Driver) DestroyNetwork(allocID string, spec *drivers.NetworkIsolationSpec) error {
Expand Down
4 changes: 3 additions & 1 deletion plugins/drivers/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -468,7 +468,9 @@ func (d *driverPluginClient) ExecTaskStreamingRaw(ctx context.Context,
}
}

func (d *driverPluginClient) CreateNetwork(allocID string) (*NetworkIsolationSpec, bool, error) {
var _ DriverNetworkManager = (*driverPluginClient)(nil)

func (d *driverPluginClient) CreateNetwork(allocID string, _ *NetworkCreateRequest) (*NetworkIsolationSpec, bool, error) {
req := &proto.CreateNetworkRequest{
AllocId: allocID,
}
Expand Down

0 comments on commit 4c9f476

Please sign in to comment.