dr

Documentation

Index

• type Controller
  • func NewController(controller volume.Controller) Controller
• type DrController
  • func (d *DrController) CreateReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) (*ReplicationSpec, error)
  • func (d *DrController) DeleteReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error
  • func (d *DrController) DisableReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error
  • func (d *DrController) EnableReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error
  • func (d *DrController) FailoverReplication(ctx *c.Context, replica *ReplicationSpec, failover *FailoverReplicationSpec, ...) error
  • func (d *DrController) LoadOperator(ctx *c.Context, primaryVol, secondaryVol *VolumeSpec) error
• type PairOperator
  • func NewPairOperator(ctx *c.Context, controller volume.Controller, vol *VolumeSpec, isPrimary bool) (*PairOperator, error)
  • func (p *PairOperator) Attach(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) (*ReplicationSpec, error)
  • func (p *PairOperator) Create(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) (*ReplicationSpec, error)
  • func (p *PairOperator) Delete(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
  • func (p *PairOperator) Detach(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
  • func (p *PairOperator) Disable(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
  • func (p *PairOperator) Enable(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
  • func (p *PairOperator) Failover(ctx *c.Context, replica *ReplicationSpec, failover *FailoverReplicationSpec, ...) error
• type ReplicationOperator

Types

type Controller

type Controller interface {
	CreateReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) (*ReplicationSpec, error)
	DeleteReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error
	EnableReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error
	DisableReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error
	FailoverReplication(ctx *c.Context, replica *ReplicationSpec, failover *FailoverReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error
}

func NewController

func NewController(controller volume.Controller) Controller

NewController method creates a controller structure and expose its pointer.

type DrController

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

func (*DrController) CreateReplication

func (d *DrController) CreateReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol,
	secondaryVol *VolumeSpec) (*ReplicationSpec, error)

func (*DrController) DeleteReplication

func (d *DrController) DeleteReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error

func (*DrController) DisableReplication

func (d *DrController) DisableReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error

func (*DrController) EnableReplication

func (d *DrController) EnableReplication(ctx *c.Context, replica *ReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error

func (*DrController) FailoverReplication

func (d *DrController) FailoverReplication(ctx *c.Context, replica *ReplicationSpec,
	failover *FailoverReplicationSpec, primaryVol, secondaryVol *VolumeSpec) error

func (*DrController) LoadOperator

func (d *DrController) LoadOperator(ctx *c.Context, primaryVol, secondaryVol *VolumeSpec) error

type PairOperator

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

func NewPairOperator

func NewPairOperator(ctx *c.Context, controller volume.Controller, vol *VolumeSpec, isPrimary bool) (*PairOperator, error)

func (*PairOperator) Attach

func (p *PairOperator) Attach(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) (*ReplicationSpec, error)

func (*PairOperator) Create

func (p *PairOperator) Create(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) (*ReplicationSpec, error)

func (*PairOperator) Delete

func (p *PairOperator) Delete(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error

func (*PairOperator) Detach

func (p *PairOperator) Detach(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error

func (*PairOperator) Disable

func (p *PairOperator) Disable(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error

func (*PairOperator) Enable

func (p *PairOperator) Enable(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error

func (*PairOperator) Failover

func (p *PairOperator) Failover(ctx *c.Context, replica *ReplicationSpec, failover *FailoverReplicationSpec, vol *VolumeSpec) error

type ReplicationOperator

type ReplicationOperator interface {
	Create(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) (*ReplicationSpec, error)
	Delete(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
	Enable(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
	Disable(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
	Failover(ctx *c.Context, replica *ReplicationSpec, failover *FailoverReplicationSpec, vol *VolumeSpec) error
	Attach(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) (*ReplicationSpec, error)
	Detach(ctx *c.Context, replica *ReplicationSpec, vol *VolumeSpec) error
}