scms

Documentation

Index

• Constants
• type CmsAdm
  • func NewCmsAdm() *CmsAdm
  • func (c *CmsAdm) CreateTask(t *CmsTask, arg ...string) ([]byte, error)
  • func (c *CmsAdm) DeleteTask(arg ...string) ([]byte, error)
  • func (c *CmsAdm) Down() ([]byte, error)
  • func (c *CmsAdm) Query() ([]byte, error)
  • func (c *CmsAdm) Up() ([]byte, error)
• type CmsTask
  • func NewCmsTask(bandwidth int64, cdpFlag bool) *CmsTask
  • func (t *CmsTask) AddVolume(source CmsVolume, target CmsVolume) error
• type CmsVolume
• type ReplicationDriver
  • func (r *ReplicationDriver) CreateReplication(opt *pb.CreateReplicationOpts) (*model.ReplicationSpec, error)
  • func (r *ReplicationDriver) DeleteReplication(opt *pb.DeleteReplicationOpts) error
  • func (r *ReplicationDriver) DisableReplication(opt *pb.DisableReplicationOpts) error
  • func (r *ReplicationDriver) EnableReplication(opt *pb.EnableReplicationOpts) error
  • func (r *ReplicationDriver) FailoverReplication(opt *pb.FailoverReplicationOpts) error
  • func (r *ReplicationDriver) Setup() error
  • func (r *ReplicationDriver) Unset() error

Constants

const (
	CMS_CREATE = "--create"
	CMS_DELETE = "--remove"
	CMS_START  = "--up"
	CMS_STOP   = "--down"
	CMS_QUERY  = "--query"
)

const CMS_ADM = "/opt/cmsagent/cmsadm"

Types

type CmsAdm

type CmsAdm struct {
}

func NewCmsAdm

func NewCmsAdm() *CmsAdm

func (*CmsAdm) CreateTask

func (c *CmsAdm) CreateTask(t *CmsTask, arg ...string) ([]byte, error)

func (*CmsAdm) DeleteTask

func (c *CmsAdm) DeleteTask(arg ...string) ([]byte, error)

func (*CmsAdm) Down

func (c *CmsAdm) Down() ([]byte, error)

func (*CmsAdm) Query

func (c *CmsAdm) Query() ([]byte, error)

func (*CmsAdm) Up

func (c *CmsAdm) Up() ([]byte, error)

type CmsTask

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

func NewCmsTask

func NewCmsTask(bandwidth int64, cdpFlag bool) *CmsTask

func (*CmsTask) AddVolume

func (t *CmsTask) AddVolume(source CmsVolume, target CmsVolume) error

type CmsVolume

type CmsVolume struct {
	VolumeId   string
	VolumeName string
}

type ReplicationDriver

type ReplicationDriver struct{}

Replication driver

func (*ReplicationDriver) CreateReplication

func (r *ReplicationDriver) CreateReplication(opt *pb.CreateReplicationOpts) (*model.ReplicationSpec, error)

Create and start replication

func (*ReplicationDriver) DeleteReplication

func (r *ReplicationDriver) DeleteReplication(opt *pb.DeleteReplicationOpts) error

Delete replication

func (*ReplicationDriver) DisableReplication

func (r *ReplicationDriver) DisableReplication(opt *pb.DisableReplicationOpts) error

Stop replication

func (*ReplicationDriver) EnableReplication

func (r *ReplicationDriver) EnableReplication(opt *pb.EnableReplicationOpts) error

Start replication

func (*ReplicationDriver) FailoverReplication

func (r *ReplicationDriver) FailoverReplication(opt *pb.FailoverReplicationOpts) error

Failover Replication

func (*ReplicationDriver) Setup

func (r *ReplicationDriver) Setup() error

Setup

func (*ReplicationDriver) Unset

func (r *ReplicationDriver) Unset() error

Unset