agent/taskresource/volume/dockervolume.go
func (vol *VolumeResource) Create() error {
	seelog.Debugf("Creating volume with name %s using driver %s", vol.VolumeConfig.DockerVolumeName, vol.VolumeConfig.Driver)
	volumeResponse := vol.client.CreateVolume(
		vol.ctx,
		vol.VolumeConfig.DockerVolumeName,
		vol.VolumeConfig.Driver,
		vol.VolumeConfig.DriverOpts,
		vol.VolumeConfig.Labels,
		dockerclient.CreateVolumeTimeout)

	if volumeResponse.Error != nil {
		return volumeResponse.Error
	}

	// set readonly field after creation
	vol.setMountPoint(volumeResponse.DockerVolume.Name)
	return nil
}
func (vol *VolumeResource) Create() error {
	seelog.Debugf("Creating volume with name %s using driver %s", vol.VolumeConfig.DockerVolumeName, vol.VolumeConfig.Driver)
	volumeResponse := vol.client.CreateVolume(
		vol.ctx,
		vol.VolumeConfig.DockerVolumeName,
		vol.VolumeConfig.Driver,
		vol.VolumeConfig.DriverOpts,
		vol.VolumeConfig.Labels,
		dockerclient.CreateVolumeTimeout)

	if volumeResponse.Error != nil {
		return volumeResponse.Error
	}

	// set readonly field after creation
	vol.setMountPoint(volumeResponse.DockerVolume.Name)
	return nil
}
func ( vol * VolumeResource ) Create ( ) error { seelog . Debugf ( " " , vol . VolumeConfig . DockerVolumeName , vol . VolumeConfig . Driver ) volumeResponse := vol . client . CreateVolume ( vol . ctx , vol . VolumeConfig . DockerVolumeName , vol . VolumeConfig . Driver , vol . VolumeConfig . DriverOpts , vol . VolumeConfig . Labels , dockerclient . CreateVolumeTimeout ) if volumeResponse . Error != nil { return volumeResponse . Error } // set readonly field after creation vol . setMountPoint ( volumeResponse . DockerVolume . Name ) return nil }
// Create performs resource creation
Create performs resource creation