controller

Documentation

Index

• Constants
• type Controller
  • func NewController(port string) *Controller
  • func (c *Controller) CreateReplication(contx context.Context, opt *pb.CreateReplicationOpts) (*pb.GenericResponse, error)
  • func (c *Controller) CreateVolume(contx context.Context, opt *pb.CreateVolumeOpts) (*pb.GenericResponse, error)
  • func (c *Controller) CreateVolumeAttachment(contx context.Context, opt *pb.CreateVolumeAttachmentOpts) (*pb.GenericResponse, error)
  • func (c *Controller) CreateVolumeGroup(contx context.Context, opt *pb.CreateVolumeGroupOpts) (*pb.GenericResponse, error)
  • func (c *Controller) CreateVolumeSnapshot(contx context.Context, opt *pb.CreateVolumeSnapshotOpts) (*pb.GenericResponse, error)
  • func (c *Controller) DeleteReplication(contx context.Context, opt *pb.DeleteReplicationOpts) (*pb.GenericResponse, error)
  • func (c *Controller) DeleteVolume(contx context.Context, opt *pb.DeleteVolumeOpts) (*pb.GenericResponse, error)
  • func (c *Controller) DeleteVolumeAttachment(contx context.Context, opt *pb.DeleteVolumeAttachmentOpts) (*pb.GenericResponse, error)
  • func (c *Controller) DeleteVolumeGroup(contx context.Context, opt *pb.DeleteVolumeGroupOpts) (*pb.GenericResponse, error)
  • func (c *Controller) DeleteVolumeSnapshot(contx context.Context, opt *pb.DeleteVolumeSnapshotOpts) (*pb.GenericResponse, error)
  • func (c *Controller) DisableReplication(contx context.Context, opt *pb.DisableReplicationOpts) (*pb.GenericResponse, error)
  • func (c *Controller) EnableReplication(contx context.Context, opt *pb.EnableReplicationOpts) (*pb.GenericResponse, error)
  • func (c *Controller) ExtendVolume(contx context.Context, opt *pb.ExtendVolumeOpts) (*pb.GenericResponse, error)
  • func (c *Controller) FailoverReplication(contx context.Context, opt *pb.FailoverReplicationOpts) (*pb.GenericResponse, error)
  • func (c *Controller) GetMetrics(context context.Context, opt *pb.GetMetricsOpts) (*pb.GenericResponse, error)
  • func (c *Controller) Run() error
  • func (c *Controller) UpdateVolumeGroup(contx context.Context, opt *pb.UpdateVolumeGroupOpts) (*pb.GenericResponse, error)

Constants

const (
	CREATE_LIFECIRCLE_FLAG = iota + 1
	GET_LIFECIRCLE_FLAG
	LIST_LIFECIRCLE_FLAG
	DELETE_LIFECIRCLE_FLAG
	EXTEND_LIFECIRCLE_FLAG
)

Types

type Controller

type Controller struct {
	Port string
	// contains filtered or unexported fields
}

func NewController

func NewController(port string) *Controller

func (*Controller) CreateReplication

func (c *Controller) CreateReplication(contx context.Context, opt *pb.CreateReplicationOpts) (*pb.GenericResponse, error)

CreateReplication implements pb.ControllerServer.CreateReplication

func (*Controller) CreateVolume

func (c *Controller) CreateVolume(contx context.Context, opt *pb.CreateVolumeOpts) (*pb.GenericResponse, error)

CreateVolume implements pb.ControllerServer.CreateVolume

func (*Controller) CreateVolumeAttachment

func (c *Controller) CreateVolumeAttachment(contx context.Context, opt *pb.CreateVolumeAttachmentOpts) (*pb.GenericResponse, error)

CreateVolumeAttachment implements pb.ControllerServer.CreateVolumeAttachment

func (*Controller) CreateVolumeGroup

func (c *Controller) CreateVolumeGroup(contx context.Context, opt *pb.CreateVolumeGroupOpts) (*pb.GenericResponse, error)

CreateVolumeGroup implements pb.ControllerServer.CreateVolumeGroup

func (*Controller) CreateVolumeSnapshot

func (c *Controller) CreateVolumeSnapshot(contx context.Context, opt *pb.CreateVolumeSnapshotOpts) (*pb.GenericResponse, error)

CreateVolumeSnapshot implements pb.ControllerServer.CreateVolumeSnapshot

func (*Controller) DeleteReplication

func (c *Controller) DeleteReplication(contx context.Context, opt *pb.DeleteReplicationOpts) (*pb.GenericResponse, error)

DeleteReplication implements pb.ControllerServer.DeleteReplication

func (*Controller) DeleteVolume

func (c *Controller) DeleteVolume(contx context.Context, opt *pb.DeleteVolumeOpts) (*pb.GenericResponse, error)

DeleteVolume implements pb.ControllerServer.DeleteVolume

func (*Controller) DeleteVolumeAttachment

func (c *Controller) DeleteVolumeAttachment(contx context.Context, opt *pb.DeleteVolumeAttachmentOpts) (*pb.GenericResponse, error)

DeleteVolumeAttachment implements pb.ControllerServer.DeleteVolumeAttachment

func (*Controller) DeleteVolumeGroup

func (c *Controller) DeleteVolumeGroup(contx context.Context, opt *pb.DeleteVolumeGroupOpts) (*pb.GenericResponse, error)

DeleteVolumeGroup implements pb.ControllerServer.DeleteVolumeGroup

func (*Controller) DeleteVolumeSnapshot

func (c *Controller) DeleteVolumeSnapshot(contx context.Context, opt *pb.DeleteVolumeSnapshotOpts) (*pb.GenericResponse, error)

DeleteVolumeSnapshot implements pb.ControllerServer.DeleteVolumeSnapshot

func (*Controller) DisableReplication

func (c *Controller) DisableReplication(contx context.Context, opt *pb.DisableReplicationOpts) (*pb.GenericResponse, error)

DisableReplication implements pb.ControllerServer.DisableReplication

func (*Controller) EnableReplication

func (c *Controller) EnableReplication(contx context.Context, opt *pb.EnableReplicationOpts) (*pb.GenericResponse, error)

EnableReplication implements pb.ControllerServer.EnableReplication

func (*Controller) ExtendVolume

func (c *Controller) ExtendVolume(contx context.Context, opt *pb.ExtendVolumeOpts) (*pb.GenericResponse, error)

ExtendVolume implements pb.ControllerServer.ExtendVolume

func (*Controller) FailoverReplication

func (c *Controller) FailoverReplication(contx context.Context, opt *pb.FailoverReplicationOpts) (*pb.GenericResponse, error)

FailoverReplication implements pb.ControllerServer.FailoverReplication

func (*Controller) GetMetrics

func (c *Controller) GetMetrics(context context.Context, opt *pb.GetMetricsOpts) (*pb.GenericResponse, error)

func (*Controller) Run

func (c *Controller) Run() error

Run method would start the listen mechanism of controller module.

func (*Controller) UpdateVolumeGroup

func (c *Controller) UpdateVolumeGroup(contx context.Context, opt *pb.UpdateVolumeGroupOpts) (*pb.GenericResponse, error)

UpdateVolumeGroup implements pb.ControllerServer.UpdateVolumeGroup