volume

type BackupOptions struct {
	CompressFormat  string
	IncludeMetadata bool
	Timeout         time.Duration
	Logger          *logrus.Logger
}

type CreateOptions struct {
	Driver     string
	DriverOpts map[string]string
	Labels     map[string]string
	Timeout    time.Duration
	Logger     *logrus.Logger
}

type EventOptions struct {
	Filters    filters.Args
	BufferSize int
	Since      time.Time
	Until      time.Time
	Logger     *logrus.Logger
}

type GetOptions struct {
	Timeout time.Duration
	Logger  *logrus.Logger
}

type ListOptions struct {
	Filters filters.Args
	Timeout time.Duration
	Logger  *logrus.Logger
}

type PruneOptions struct {
	Filters filters.Args
	Timeout time.Duration
	Logger  *logrus.Logger
}

type RemoveOptions struct {
	Force   bool
	Timeout time.Duration
	Logger  *logrus.Logger
}

type RestoreOptions struct {
	OverwriteIfExists bool
	ExtractFormat     string
	RestoreMetadata   bool
	Timeout           time.Duration
	Logger            *logrus.Logger
}

type Service interface {
	// Create creates a new volume
	Create(ctx context.Context, name string, options CreateOptions) (*models.Volume, error)

	// Get gets a volume by name
	Get(ctx context.Context, name string, options GetOptions) (*models.Volume, error)

	// List lists volumes
	List(ctx context.Context, options ListOptions) ([]*models.Volume, error)

	// Remove removes a volume
	Remove(ctx context.Context, name string, options RemoveOptions) error

	// Prune removes unused volumes
	Prune(ctx context.Context, options PruneOptions) (*volume.PruneReport, error) // Use volume.PruneReport

	// Backup creates a backup of a volume
	Backup(ctx context.Context, name string, options BackupOptions) (io.ReadCloser, error)

	// Restore restores a volume from a backup
	Restore(ctx context.Context, name string, reader io.Reader, options RestoreOptions) error

	// InspectRaw gets the raw information about a volume
	InspectRaw(ctx context.Context, name string) (volume.Volume, error) // Use volume.Volume

	// GetEvents subscribes to volume events
	GetEvents(ctx context.Context, options EventOptions) (<-chan events.Message, <-chan error) // Use events.Message for now

	// Update updates a volume's metadata
	Update(ctx context.Context, name string, metadata map[string]string, options UpdateOptions) error
}

type UpdateOptions struct {
	Timeout time.Duration
	Logger  *logrus.Logger
}

type VolumeClient interface {
	// VolumeCreate creates a volume
	VolumeCreate(ctx context.Context, options volume.CreateOptions) (volume.Volume, error)

	// VolumeInspect inspects a volume
	VolumeInspect(ctx context.Context, volumeID string) (volume.Volume, error)

	// VolumeList lists volumes
	VolumeList(ctx context.Context, filter filters.Args) (volume.ListResponse, error)

	// VolumeRemove removes a volume
	VolumeRemove(ctx context.Context, volumeID string, force bool) error

	// VolumePrune prunes volumes
	VolumePrune(ctx context.Context, pruneFilters filters.Args) (volume.PruneReport, error) // Use volume.PruneReport

	// Events streams events from the Docker daemon
	Events(ctx context.Context, options events.ListOptions) (<-chan events.Message, <-chan error) // Use events.ListOptions
}

type VolumeManager struct {
	// contains filtered or unexported fields
}