db

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 3, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init 

func Init(db *Database)

Init function can perform some initialization work of different databases.

func UpdateFileShareAclStatus added in v0.6.3 

func UpdateFileShareAclStatus(ctx *c.Context, client Client, fileID, status string) error

func UpdateFileShareSnapshotStatus added in v0.5.3 

func UpdateFileShareSnapshotStatus(ctx *c.Context, client Client, snapID, status string) error

func UpdateFileShareStatus added in v0.5.3 

func UpdateFileShareStatus(ctx *c.Context, client Client, fileID, status string) error

func UpdateReplicationStatus added in v0.5.1 

func UpdateReplicationStatus(ctx *c.Context, client Client, replicaID, status string) error

func UpdateVolumeAttachmentStatus added in v0.5.1 

func UpdateVolumeAttachmentStatus(ctx *c.Context, client Client, atcID, status string) error

func UpdateVolumeGroupStatus added in v0.5.1 

func UpdateVolumeGroupStatus(ctx *c.Context, client Client, vgID, status string) error

func UpdateVolumeSnapshotStatus added in v0.5.1 

func UpdateVolumeSnapshotStatus(ctx *c.Context, client Client, snapID, status string) error

func UpdateVolumeStatus added in v0.5.1 

func UpdateVolumeStatus(ctx *c.Context, client Client, volID, status string) error

Types

type Client 

type Client interface {
	CreateFileShareAcl(ctx *c.Context, fshare *model.FileShareAclSpec) (*model.FileShareAclSpec, error)

	UpdateFileShareAcl(ctx *c.Context, acl *model.FileShareAclSpec) (*model.FileShareAclSpec, error)

	ListFileSharesAcl(ctx *c.Context) ([]*model.FileShareAclSpec, error)

	CreateFileShare(ctx *c.Context, fshare *model.FileShareSpec) (*model.FileShareSpec, error)

	ListFileShares(ctx *c.Context) ([]*model.FileShareSpec, error)

	ListFileSharesByProfileId(ctx *c.Context, prfId string) ([]string, error)

	ListFileSharesWithFilter(ctx *c.Context, m map[string][]string) ([]*model.FileShareSpec, error)

	ListFileSharesAclWithFilter(ctx *c.Context, m map[string][]string) ([]*model.FileShareAclSpec, error)

	ListFileShareAclsByShareId(ctx *c.Context, fileshareId string) ([]*model.FileShareAclSpec, error)

	GetFileShare(ctx *c.Context, fshareID string) (*model.FileShareSpec, error)

	GetFileShareAcl(ctx *c.Context, aclID string) (*model.FileShareAclSpec, error)

	UpdateFileShare(ctx *c.Context, fshare *model.FileShareSpec) (*model.FileShareSpec, error)

	DeleteFileShare(ctx *c.Context, fshareID string) error

	DeleteFileShareAcl(ctx *c.Context, aclID string) error

	CreateFileShareSnapshot(ctx *c.Context, vs *model.FileShareSnapshotSpec) (*model.FileShareSnapshotSpec, error)

	GetFileShareSnapshot(ctx *c.Context, snapshotID string) (*model.FileShareSnapshotSpec, error)

	ListFileShareSnapshots(ctx *c.Context) ([]*model.FileShareSnapshotSpec, error)

	ListSnapshotsByShareId(ctx *c.Context, fileshareId string) ([]*model.FileShareSnapshotSpec, error)

	ListFileShareSnapshotsWithFilter(ctx *c.Context, m map[string][]string) ([]*model.FileShareSnapshotSpec, error)

	UpdateFileShareSnapshot(ctx *c.Context, snapshotID string, vs *model.FileShareSnapshotSpec) (*model.FileShareSnapshotSpec, error)

	DeleteFileShareSnapshot(ctx *c.Context, snapshotID string) error

	CreateDock(ctx *c.Context, dck *model.DockSpec) (*model.DockSpec, error)

	GetDock(ctx *c.Context, dckID string) (*model.DockSpec, error)

	ListDocks(ctx *c.Context) ([]*model.DockSpec, error)

	ListDocksWithFilter(ctx *c.Context, m map[string][]string) ([]*model.DockSpec, error)

	UpdateDock(ctx *c.Context, dckID, name, desp string) (*model.DockSpec, error)

	DeleteDock(ctx *c.Context, dckID string) error

	GetDockByPoolId(ctx *c.Context, poolId string) (*model.DockSpec, error)

	CreatePool(ctx *c.Context, pol *model.StoragePoolSpec) (*model.StoragePoolSpec, error)

	GetPool(ctx *c.Context, polID string) (*model.StoragePoolSpec, error)

	ListAvailabilityZones(ctx *c.Context) ([]string, error)

	ListPools(ctx *c.Context) ([]*model.StoragePoolSpec, error)

	ListPoolsWithFilter(ctx *c.Context, m map[string][]string) ([]*model.StoragePoolSpec, error)

	UpdatePool(ctx *c.Context, polID, name, desp string, usedCapacity int64, used bool) (*model.StoragePoolSpec, error)

	DeletePool(ctx *c.Context, polID string) error

	CreateProfile(ctx *c.Context, prf *model.ProfileSpec) (*model.ProfileSpec, error)

	GetProfile(ctx *c.Context, prfID string) (*model.ProfileSpec, error)

	GetDefaultProfile(ctx *c.Context) (*model.ProfileSpec, error)

	GetDefaultProfileFileShare(ctx *c.Context) (*model.ProfileSpec, error)

	ListProfiles(ctx *c.Context) ([]*model.ProfileSpec, error)

	ListProfilesWithFilter(ctx *c.Context, m map[string][]string) ([]*model.ProfileSpec, error)

	UpdateProfile(ctx *c.Context, prfID string, input *model.ProfileSpec) (*model.ProfileSpec, error)

	DeleteProfile(ctx *c.Context, prfID string) error

	AddCustomProperty(ctx *c.Context, prfID string, custom model.CustomPropertiesSpec) (*model.CustomPropertiesSpec, error)

	ListCustomProperties(ctx *c.Context, prfID string) (*model.CustomPropertiesSpec, error)

	RemoveCustomProperty(ctx *c.Context, prfID, customKey string) error

	CreateVolume(ctx *c.Context, vol *model.VolumeSpec) (*model.VolumeSpec, error)

	GetVolume(ctx *c.Context, volID string) (*model.VolumeSpec, error)

	ListVolumes(ctx *c.Context) ([]*model.VolumeSpec, error)

	ListVolumesByProfileId(ctx *c.Context, prfID string) ([]string, error)

	ListVolumesWithFilter(ctx *c.Context, m map[string][]string) ([]*model.VolumeSpec, error)

	UpdateVolume(ctx *c.Context, vol *model.VolumeSpec) (*model.VolumeSpec, error)

	DeleteVolume(ctx *c.Context, volID string) error

	ExtendVolume(ctx *c.Context, vol *model.VolumeSpec) (*model.VolumeSpec, error)

	CreateVolumeAttachment(ctx *c.Context, attachment *model.VolumeAttachmentSpec) (*model.VolumeAttachmentSpec, error)

	GetVolumeAttachment(ctx *c.Context, attachmentId string) (*model.VolumeAttachmentSpec, error)

	ListVolumeAttachments(ctx *c.Context, volumeId string) ([]*model.VolumeAttachmentSpec, error)

	ListVolumeAttachmentsWithFilter(ctx *c.Context, m map[string][]string) ([]*model.VolumeAttachmentSpec, error)

	UpdateVolumeAttachment(ctx *c.Context, attachmentId string, attachment *model.VolumeAttachmentSpec) (*model.VolumeAttachmentSpec, error)

	DeleteVolumeAttachment(ctx *c.Context, attachmentId string) error

	CreateVolumeSnapshot(ctx *c.Context, vs *model.VolumeSnapshotSpec) (*model.VolumeSnapshotSpec, error)

	GetVolumeSnapshot(ctx *c.Context, snapshotID string) (*model.VolumeSnapshotSpec, error)

	ListVolumeSnapshots(ctx *c.Context) ([]*model.VolumeSnapshotSpec, error)

	ListVolumeSnapshotsWithFilter(ctx *c.Context, m map[string][]string) ([]*model.VolumeSnapshotSpec, error)

	UpdateVolumeSnapshot(ctx *c.Context, snapshotID string, vs *model.VolumeSnapshotSpec) (*model.VolumeSnapshotSpec, error)

	DeleteVolumeSnapshot(ctx *c.Context, snapshotID string) error

	CreateReplication(ctx *c.Context, replication *model.ReplicationSpec) (*model.ReplicationSpec, error)

	GetReplication(ctx *c.Context, replicationId string) (*model.ReplicationSpec, error)

	GetReplicationByVolumeId(ctx *c.Context, volumeId string) (*model.ReplicationSpec, error)

	ListReplication(ctx *c.Context) ([]*model.ReplicationSpec, error)

	ListReplicationWithFilter(ctx *c.Context, m map[string][]string) ([]*model.ReplicationSpec, error)

	DeleteReplication(ctx *c.Context, replicationId string) error

	UpdateReplication(ctx *c.Context, replicationId string, input *model.ReplicationSpec) (*model.ReplicationSpec, error)

	CreateVolumeGroup(ctx *c.Context, vg *model.VolumeGroupSpec) (*model.VolumeGroupSpec, error)

	GetVolumeGroup(ctx *c.Context, vgId string) (*model.VolumeGroupSpec, error)

	UpdateVolumeGroup(ctx *c.Context, vg *model.VolumeGroupSpec) (*model.VolumeGroupSpec, error)

	UpdateStatus(ctx *c.Context, object interface{}, status string) error

	ListVolumesByGroupId(ctx *c.Context, vgId string) ([]*model.VolumeSpec, error)

	ListAttachmentsByVolumeId(ctx *c.Context, volId string) ([]*model.VolumeAttachmentSpec, error)

	ListSnapshotsByVolumeId(ctx *c.Context, volId string) ([]*model.VolumeSnapshotSpec, error)

	DeleteVolumeGroup(ctx *c.Context, vgId string) error

	ListVolumeGroups(ctx *c.Context) ([]*model.VolumeGroupSpec, error)

	VolumesToUpdate(ctx *c.Context, volumeList []*model.VolumeSpec) ([]*model.VolumeSpec, error)

	ListVolumeGroupsWithFilter(ctx *c.Context, m map[string][]string) ([]*model.VolumeGroupSpec, error)

	ListHosts(ctx *c.Context, m map[string][]string) ([]*model.HostSpec, error)

	ListHostsByName(ctx *c.Context, hostName string) ([]*model.HostSpec, error)

	CreateHost(ctx *c.Context, host *model.HostSpec) (*model.HostSpec, error)

	UpdateHost(ctx *c.Context, host *model.HostSpec) (*model.HostSpec, error)

	GetHost(ctx *c.Context, hostId string) (*model.HostSpec, error)

	DeleteHost(ctx *c.Context, hostId string) error
}

Client is an interface for exposing some operations of managing database client. 

var C Client

C is a global variable that controls database module.

Source Files

View all Source files

Directories

Path Synopsis
drivers
etcd
mysql

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.