controller

package
v0.10.2 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func AsyncDecorator added in v0.6.3 

func AsyncDecorator(fn interface{}, args ...interface{})

AsyncDecorator is used to provide common method to print info to logs when got error. It will check the wrapped function parameter type and number, also the return value number.

Types

type Controller 

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

func NewController 

func NewController() *Controller

func (*Controller) CollectMetrics added in v0.5.3 

func (c *Controller) CollectMetrics(context context.Context, opt *pb.CollectMetricsOpts) (*pb.GenericResponse, error)

func (*Controller) CreateFileShare added in v0.5.3 

func (c *Controller) CreateFileShare(contx context.Context, opt *pb.CreateFileShareOpts) (*pb.GenericResponse, error)

CreateFileShare implements pb.ControllerServer.CreateFileShare

func (*Controller) CreateFileShareAcl added in v0.5.3 

func (c *Controller) CreateFileShareAcl(contx context.Context, opt *pb.CreateFileShareAclOpts) (*pb.GenericResponse, error)

CreateFileShare implements pb.ControllerServer.CreateFileShareAcl

func (*Controller) CreateFileShareSnapshot added in v0.5.3 

func (c *Controller) CreateFileShareSnapshot(contx context.Context, opt *pb.CreateFileShareSnapshotOpts) (*pb.GenericResponse, error)

CreateFileShareSnapshot implements pb.ControllerServer.CreateFileShareSnapshot

func (*Controller) CreateReplication added in v0.1.8 

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 added in v0.1.8 

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) DeleteFileShare added in v0.5.3 

func (c *Controller) DeleteFileShare(contx context.Context, opt *pb.DeleteFileShareOpts) (*pb.GenericResponse, error)

DeleteFileShare implements pb.ControllerServer.DeleteFileShare

func (*Controller) DeleteFileShareAcl added in v0.5.3 

func (c *Controller) DeleteFileShareAcl(contx context.Context, opt *pb.DeleteFileShareAclOpts) (*pb.GenericResponse, error)

DeleteFileShareAcl implements pb.ControllerServer.DeleteFileShareAcl

func (*Controller) DeleteFileShareSnapshot added in v0.5.3 

func (c *Controller) DeleteFileShareSnapshot(contx context.Context, opt *pb.DeleteFileShareSnapshotOpts) (*pb.GenericResponse, error)

DeleteFileshareSnapshot implements pb.ControllerServer.DeleteFileshareSnapshot

func (*Controller) DeleteReplication added in v0.1.8 

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 added in v0.1.8 

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 added in v0.1.8 

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

DisableReplication implements pb.ControllerServer.DisableReplication

func (*Controller) EnableReplication added in v0.1.8 

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

EnableReplication implements pb.ControllerServer.EnableReplication

func (*Controller) ExtendVolume added in v0.1.1 

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

ExtendVolume implements pb.ControllerServer.ExtendVolume

func (*Controller) FailoverReplication added in v0.1.8 

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

FailoverReplication implements pb.ControllerServer.FailoverReplication

func (*Controller) GetMetrics added in v0.5.2 

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

func (*Controller) GetUrls added in v0.5.3 

func (c *Controller) GetUrls(context.Context, *pb.NoParams) (*pb.GenericResponse, error)

func (*Controller) UpdateVolumeGroup added in v0.1.8 

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

UpdateVolumeGroup implements pb.ControllerServer.UpdateVolumeGroup

type GrpcServer added in v0.6.3 

type GrpcServer struct {
	*Controller
	Port string
}

func NewGrpcServer added in v0.6.3 

func NewGrpcServer(port string) *GrpcServer

func (*GrpcServer) CreateFileShare added in v0.6.3 

func (g *GrpcServer) CreateFileShare(contx context.Context, opt *pb.CreateFileShareOpts) (*pb.GenericResponse, error)

CreateFileShare implements pb.ControllerServer.CreateFileShare

func (*GrpcServer) CreateFileShareAcl added in v0.6.3 

func (g *GrpcServer) CreateFileShareAcl(contx context.Context, opt *pb.CreateFileShareAclOpts) (*pb.GenericResponse, error)

CreateFileShare implements pb.ControllerServer.CreateFileShareAcl

func (*GrpcServer) CreateFileShareSnapshot added in v0.6.3 

func (g *GrpcServer) CreateFileShareSnapshot(contx context.Context, opt *pb.CreateFileShareSnapshotOpts) (*pb.GenericResponse, error)

CreateFileShareSnapshot implements pb.ControllerServer.CreateFileShareSnapshot

func (*GrpcServer) CreateReplication added in v0.6.3 

func (g *GrpcServer) CreateReplication(contx context.Context, opt *pb.CreateReplicationOpts) (*pb.GenericResponse, error)

CreateReplication implements pb.ControllerServer.CreateReplication

func (*GrpcServer) CreateVolume added in v0.6.3 

func (g *GrpcServer) CreateVolume(contx context.Context, opt *pb.CreateVolumeOpts) (*pb.GenericResponse, error)

func (*GrpcServer) CreateVolumeAttachment added in v0.6.3 

func (g *GrpcServer) CreateVolumeAttachment(contx context.Context, opt *pb.CreateVolumeAttachmentOpts) (*pb.GenericResponse, error)

CreateVolumeAttachment implements pb.ControllerServer.CreateVolumeAttachment

func (*GrpcServer) CreateVolumeGroup added in v0.6.3 

func (g *GrpcServer) CreateVolumeGroup(contx context.Context, opt *pb.CreateVolumeGroupOpts) (*pb.GenericResponse, error)

CreateVolumeGroup implements pb.ControllerServer.CreateVolumeGroup

func (*GrpcServer) CreateVolumeSnapshot added in v0.6.3 

func (g *GrpcServer) CreateVolumeSnapshot(contx context.Context, opt *pb.CreateVolumeSnapshotOpts) (*pb.GenericResponse, error)

CreateVolumeSnapshot implements pb.ControllerServer.CreateVolumeSnapshot

func (*GrpcServer) DeleteFileShare added in v0.6.3 

func (g *GrpcServer) DeleteFileShare(contx context.Context, opt *pb.DeleteFileShareOpts) (*pb.GenericResponse, error)

DeleteFileShare implements pb.ControllerServer.DeleteFileShare

func (*GrpcServer) DeleteFileShareAcl added in v0.6.3 

func (g *GrpcServer) DeleteFileShareAcl(contx context.Context, opt *pb.DeleteFileShareAclOpts) (*pb.GenericResponse, error)

DeleteFileShareAcl implements pb.ControllerServer.DeleteFileShareAcl

func (*GrpcServer) DeleteFileShareSnapshot added in v0.6.3 

func (g *GrpcServer) DeleteFileShareSnapshot(contx context.Context, opt *pb.DeleteFileShareSnapshotOpts) (*pb.GenericResponse, error)

DeleteFileshareSnapshot implements pb.ControllerServer.DeleteFileshareSnapshot

func (*GrpcServer) DeleteReplication added in v0.6.3 

func (g *GrpcServer) DeleteReplication(contx context.Context, opt *pb.DeleteReplicationOpts) (*pb.GenericResponse, error)

DeleteReplication implements pb.ControllerServer.DeleteReplication

func (*GrpcServer) DeleteVolume added in v0.6.3 

func (g *GrpcServer) DeleteVolume(contx context.Context, opt *pb.DeleteVolumeOpts) (*pb.GenericResponse, error)

DeleteVolume implements pb.ControllerServer.DeleteVolume

func (*GrpcServer) DeleteVolumeAttachment added in v0.6.3 

func (g *GrpcServer) DeleteVolumeAttachment(contx context.Context, opt *pb.DeleteVolumeAttachmentOpts) (*pb.GenericResponse, error)

DeleteVolumeAttachment implements pb.ControllerServer.DeleteVolumeAttachment

func (*GrpcServer) DeleteVolumeGroup added in v0.6.3 

func (g *GrpcServer) DeleteVolumeGroup(contx context.Context, opt *pb.DeleteVolumeGroupOpts) (*pb.GenericResponse, error)

DeleteVolumeGroup implements pb.ControllerServer.DeleteVolumeGroup

func (*GrpcServer) DeleteVolumeSnapshot added in v0.6.3 

func (g *GrpcServer) DeleteVolumeSnapshot(contx context.Context, opt *pb.DeleteVolumeSnapshotOpts) (*pb.GenericResponse, error)

DeleteVolumeSnapshot implements pb.ControllerServer.DeleteVolumeSnapshot

func (*GrpcServer) DisableReplication added in v0.6.3 

func (g *GrpcServer) DisableReplication(contx context.Context, opt *pb.DisableReplicationOpts) (*pb.GenericResponse, error)

DisableReplication implements pb.ControllerServer.DisableReplication

func (*GrpcServer) EnableReplication added in v0.6.3 

func (g *GrpcServer) EnableReplication(contx context.Context, opt *pb.EnableReplicationOpts) (*pb.GenericResponse, error)

EnableReplication implements pb.ControllerServer.EnableReplication

func (*GrpcServer) ExtendVolume added in v0.6.3 

func (g *GrpcServer) ExtendVolume(contx context.Context, opt *pb.ExtendVolumeOpts) (*pb.GenericResponse, error)

ExtendVolume implements pb.ControllerServer.ExtendVolume

func (*GrpcServer) FailoverReplication added in v0.6.3 

func (g *GrpcServer) FailoverReplication(contx context.Context, opt *pb.FailoverReplicationOpts) (*pb.GenericResponse, error)

FailoverReplication implements pb.ControllerServer.FailoverReplication

func (*GrpcServer) Run added in v0.6.3 

func (g *GrpcServer) Run() error

Run method would start the listen mechanism of controller module.

func (*GrpcServer) UpdateVolumeGroup added in v0.6.3 

func (g *GrpcServer) UpdateVolumeGroup(contx context.Context, opt *pb.UpdateVolumeGroupOpts) (*pb.GenericResponse, error)

UpdateVolumeGroup implements pb.ControllerServer.UpdateVolumeGroup

Source Files

View all Source files

Directories

Path Synopsis
This module implements a entry into the OpenSDS file share controller service.
 This module implements a entry into the OpenSDS file share controller service.
adapters
executor

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.