util

Documentation

Index

• func CreateFileShareAclDBEntry(ctx *c.Context, in *model.FileShareAclSpec) (*model.FileShareAclSpec, error)
• func CreateFileShareDBEntry(ctx *c.Context, in *model.FileShareSpec) (*model.FileShareSpec, error)
• func CreateFileShareSnapshotDBEntry(ctx *c.Context, in *model.FileShareSnapshotSpec) (*model.FileShareSnapshotSpec, error)
• func CreateReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) (*model.ReplicationSpec, error)
• func CreateVolumeAttachmentDBEntry(ctx *c.Context, volAttachment *model.VolumeAttachmentSpec) (*model.VolumeAttachmentSpec, error)
• func CreateVolumeDBEntry(ctx *c.Context, in *model.VolumeSpec) (*model.VolumeSpec, error)
• func CreateVolumeGroupDBEntry(ctx *c.Context, in *model.VolumeGroupSpec) (*model.VolumeGroupSpec, error)
• func CreateVolumeSnapshotDBEntry(ctx *c.Context, in *model.VolumeSnapshotSpec) (*model.VolumeSnapshotSpec, error)
• func DeleteFileShareAclDBEntry(ctx *c.Context, in *model.FileShareAclSpec) error
• func DeleteFileShareDBEntry(ctx *c.Context, in *model.FileShareSpec) error
• func DeleteFileShareSnapshotDBEntry(ctx *c.Context, in *model.FileShareSnapshotSpec) error
• func DeleteReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) error
• func DeleteVolumeAttachmentDBEntry(ctx *c.Context, in *model.VolumeAttachmentSpec) error
• func DeleteVolumeDBEntry(ctx *c.Context, in *model.VolumeSpec) error
• func DeleteVolumeGroupDBEntry(ctx *c.Context, volumeGroupId string) error
• func DeleteVolumeSnapshotDBEntry(ctx *c.Context, in *model.VolumeSnapshotSpec) error
• func DisableReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) error
• func EnableReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) error
• func ExtendVolumeDBEntry(ctx *c.Context, volID string, in *model.ExtendVolumeSpec) (*model.VolumeSpec, error)
• func FailoverReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec, secondaryBackendId string) error
• func UpdateVolumeGroupDBEntry(ctx *c.Context, vgUpdate *model.VolumeGroupSpec) ([]string, []string, error)
• func ValidateAddVolumes(ctx *c.Context, volumes []*model.VolumeSpec, addVolumes []string, ...) ([]string, error)
• func ValidateRemoveVolumes(ctx *c.Context, volumes []*model.VolumeSpec, removeVolumes []string, ...) ([]string, error)

Functions

func CreateFileShareAclDBEntry

func CreateFileShareAclDBEntry(ctx *c.Context, in *model.FileShareAclSpec) (*model.FileShareAclSpec, error)

function to store filesahreAcl metadata into database

func CreateFileShareDBEntry

func CreateFileShareDBEntry(ctx *c.Context, in *model.FileShareSpec) (*model.FileShareSpec, error)

Function to store metadeta of fileshare into database

func CreateFileShareSnapshotDBEntry

func CreateFileShareSnapshotDBEntry(ctx *c.Context, in *model.FileShareSnapshotSpec) (*model.FileShareSnapshotSpec, error)

To create entry in database

func CreateReplicationDBEntry

func CreateReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) (*model.ReplicationSpec, error)

CreateReplicationDBEntry just modifies the state of the volume replication to be creating in the DB, the real deletion operation would be executed in another new thread.

func CreateVolumeAttachmentDBEntry

func CreateVolumeAttachmentDBEntry(ctx *c.Context, volAttachment *model.VolumeAttachmentSpec) (
	*model.VolumeAttachmentSpec, error)

CreateVolumeAttachmentDBEntry just modifies the state of the volume attachment to be creating in the DB, the real operation would be executed in another new thread.

func CreateVolumeDBEntry

func CreateVolumeDBEntry(ctx *c.Context, in *model.VolumeSpec) (*model.VolumeSpec, error)

func CreateVolumeGroupDBEntry

func CreateVolumeGroupDBEntry(ctx *c.Context, in *model.VolumeGroupSpec) (*model.VolumeGroupSpec, error)

CreateVolumeGroupDBEntry just modifies the state of the volume group to be creating in the DB, the real deletion operation would be executed in another new thread.

func CreateVolumeSnapshotDBEntry

func CreateVolumeSnapshotDBEntry(ctx *c.Context, in *model.VolumeSnapshotSpec) (*model.VolumeSnapshotSpec, error)

CreateVolumeSnapshotDBEntry just modifies the state of the volume snapshot to be creating in the DB, the real operation would be executed in another new thread.

func DeleteFileShareAclDBEntry

func DeleteFileShareAclDBEntry(ctx *c.Context, in *model.FileShareAclSpec) error

func DeleteFileShareDBEntry

func DeleteFileShareDBEntry(ctx *c.Context, in *model.FileShareSpec) error

DeleteFileShareDBEntry just modifies the state of the fileshare to be deleting in the DB, the real deletion operation would be executed in another new thread.

func DeleteFileShareSnapshotDBEntry

func DeleteFileShareSnapshotDBEntry(ctx *c.Context, in *model.FileShareSnapshotSpec) error

func DeleteReplicationDBEntry

func DeleteReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) error

DeleteReplicationDBEntry just modifies the state of the volume replication to be deleting in the DB, the real deletion operation would be executed in another new thread.

func DeleteVolumeAttachmentDBEntry

func DeleteVolumeAttachmentDBEntry(ctx *c.Context, in *model.VolumeAttachmentSpec) error

DeleteVolumeAttachmentDBEntry just modifies the state of the volume attachment to be deleting in the DB, the real deletion operation would be executed in another new thread.

func DeleteVolumeDBEntry

func DeleteVolumeDBEntry(ctx *c.Context, in *model.VolumeSpec) error

DeleteVolumeDBEntry just modifies the state of the volume to be deleting in the DB, the real deletion operation would be executed in another new thread.

func DeleteVolumeGroupDBEntry

func DeleteVolumeGroupDBEntry(ctx *c.Context, volumeGroupId string) error

DeleteVolumeGroupDBEntry just modifies the state of the volume group to be deleting in the DB, the real deletion operation would be executed in another new thread.

func DeleteVolumeSnapshotDBEntry

func DeleteVolumeSnapshotDBEntry(ctx *c.Context, in *model.VolumeSnapshotSpec) error

DeleteVolumeSnapshotDBEntry just modifies the state of the volume snapshot to be deleting in the DB, the real deletion operation would be executed in another new thread.

func DisableReplicationDBEntry

func DisableReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) error

DisableReplicationDBEntry just modifies the state of the volume replication to be disabling in the DB, the real deletion operation would be executed in another new thread.

func EnableReplicationDBEntry

func EnableReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec) error

EnableReplicationDBEntry just modifies the state of the volume replication to be enabling in the DB, the real deletion operation would be executed in another new thread.

func ExtendVolumeDBEntry

func ExtendVolumeDBEntry(ctx *c.Context, volID string, in *model.ExtendVolumeSpec) (*model.VolumeSpec, error)

ExtendVolumeDBEntry just modifies the state of the volume to be extending in the DB, the real operation would be executed in another new thread, and the new size would be updated in controller module.

func FailoverReplicationDBEntry

func FailoverReplicationDBEntry(ctx *c.Context, in *model.ReplicationSpec, secondaryBackendId string) error

FailoverReplicationDBEntry just modifies the state of the volume replication to be failing_over or failing_back in the DB, the real deletion operation would be executed in another new thread.

func UpdateVolumeGroupDBEntry

func UpdateVolumeGroupDBEntry(ctx *c.Context, vgUpdate *model.VolumeGroupSpec) ([]string, []string, error)

UpdateVolumeGroupDBEntry just modifies the state of the volume group to be updating in the DB, the real deletion operation would be executed in another new thread.

func ValidateAddVolumes

func ValidateAddVolumes(ctx *c.Context, volumes []*model.VolumeSpec, addVolumes []string, vg *model.VolumeGroupSpec) ([]string, error)

func ValidateRemoveVolumes

func ValidateRemoveVolumes(ctx *c.Context, volumes []*model.VolumeSpec, removeVolumes []string, vg *model.VolumeGroupSpec) ([]string, error)