client

Documentation

Index

• type VolumeGroup
  • func NewVolumeGroupClient(cc *grpc.ClientConn, timeout time.Duration) VolumeGroup
• type VolumeReplication
  • func NewVolumeGroupReplicationClient(cc *grpc.ClientConn, timeout time.Duration) VolumeReplication
  • func NewVolumeReplicationClient(cc *grpc.ClientConn, timeout time.Duration) VolumeReplication

Types

type VolumeGroup

type VolumeGroup interface {
	// CreateVolumeGroup RPC call to create a volume group.
	CreateVolumeGroup(volumeGroupName string, volumeIDs []string, secretName, secretNamespace string, parameters map[string]string) (*proto.CreateVolumeGroupResponse, error)
	// ModifyVolumeGroupMembership RPC call to modify the volume group.
	ModifyVolumeGroupMembership(volumeGroupID string, volumeIDs []string, secretName, secretNamespace string) (*proto.ModifyVolumeGroupMembershipResponse, error)
	// DeleteVolumeGroup RPC call to delete the volume group.
	DeleteVolumeGroup(volumeGroupID string, secretName, secretNamespace string) (*proto.DeleteVolumeGroupResponse, error)
	// ControllerGetVolumeGroup RPC call to fetch the volume group.
	ControllerGetVolumeGroup(volumeGroupID string, secretName, secretNamespace string) (*proto.ControllerGetVolumeGroupResponse, error)
}

VolumeGroup holds the methods required for volume grouping.

func NewVolumeGroupClient

func NewVolumeGroupClient(cc *grpc.ClientConn, timeout time.Duration) VolumeGroup

NewReplicationClient returns VolumeGroup interface which has the RPC calls for grouping.

type VolumeReplication

type VolumeReplication interface {
	// EnableVolumeReplication RPC call to enable the volume replication.
	EnableVolumeReplication(id, replicationID string, secretName, secretNamespace string, parameters map[string]string) (*proto.EnableVolumeReplicationResponse, error)
	// DisableVolumeReplication RPC call to disable the volume replication.
	DisableVolumeReplication(id, replicationID string, secretName, secretNamespace string, parameters map[string]string) (*proto.DisableVolumeReplicationResponse, error)
	// PromoteVolume RPC call to promote the volume.
	PromoteVolume(id, replicationID string, force bool, secretName, secretNamespace string, parameters map[string]string) (*proto.
		PromoteVolumeResponse, error)
	// DemoteVolume RPC call to demote the volume.
	DemoteVolume(id, replicationID string, secretName, secretNamespace string, parameters map[string]string) (*proto.
		DemoteVolumeResponse, error)
	// ResyncVolume RPC call to resync the volume.
	ResyncVolume(id, replicationID string, force bool, secretName, secretNamespace string, parameters map[string]string) (*proto.
		ResyncVolumeResponse, error)
	// GetVolumeReplicationInfo RPC call to get volume replication info.
	GetVolumeReplicationInfo(id, replicationID, secretName, secretNamespace string) (*proto.GetVolumeReplicationInfoResponse, error)
}

VolumeReplication holds the methods required for replication.

func NewVolumeGroupReplicationClient

func NewVolumeGroupReplicationClient(cc *grpc.ClientConn, timeout time.Duration) VolumeReplication

NewVolumeGroupReplicationClient returns VolumeReplication interface which has the RPC calls for volume group replication.

func NewVolumeReplicationClient

func NewVolumeReplicationClient(cc *grpc.ClientConn, timeout time.Duration) VolumeReplication

NewReplicationClient returns VolumeReplication interface which has the RPC calls for replication.