client

Documentation

Index

• Constants
• func GetControllerReplica(r *types.ControllerReplicaInfo) *contollerpb.ControllerReplica
• func GetControllerReplicaInfo(cr *contollerpb.ControllerReplica) *types.ControllerReplicaInfo
• func GetVolumeInfo(v *contollerpb.Volume) *types.VolumeInfo
• type ControllerClient
  • func NewControllerClient(address string) *ControllerClient
  • func (c *ControllerClient) BackupReplicaMappingCreate(backupID string, replicaAddress string) error
  • func (c *ControllerClient) BackupReplicaMappingDelete(backupID string) error
  • func (c *ControllerClient) BackupReplicaMappingGet() (map[string]string, error)
  • func (c *ControllerClient) Check() error
  • func (c *ControllerClient) JournalList(limit int) error
  • func (c *ControllerClient) ReplicaCreate(address string) (*types.ControllerReplicaInfo, error)
  • func (c *ControllerClient) ReplicaDelete(address string) error
  • func (c *ControllerClient) ReplicaGet(address string) (*types.ControllerReplicaInfo, error)
  • func (c *ControllerClient) ReplicaList() ([]*types.ControllerReplicaInfo, error)
  • func (c *ControllerClient) ReplicaPrepareRebuild(address string) (*types.PrepareRebuildOutput, error)
  • func (c *ControllerClient) ReplicaUpdate(replica *types.ControllerReplicaInfo) (*types.ControllerReplicaInfo, error)
  • func (c *ControllerClient) ReplicaVerifyRebuild(address string) error
  • func (c *ControllerClient) VersionDetailGet() (*meta.VersionOutput, error)
  • func (c *ControllerClient) VolumeFrontendShutdown() error
  • func (c *ControllerClient) VolumeFrontendStart(frontend string) error
  • func (c *ControllerClient) VolumeGet() (*types.VolumeInfo, error)
  • func (c *ControllerClient) VolumeRevert(snapshot string) error
  • func (c *ControllerClient) VolumeSnapshot(name string, labels map[string]string) (string, error)
  • func (c *ControllerClient) VolumeStart(replicas ...string) error

Constants

const (
	GRPCServiceTimeout = 1 * time.Minute
)

Functions

func GetControllerReplica

func GetControllerReplica(r *types.ControllerReplicaInfo) *contollerpb.ControllerReplica

func GetControllerReplicaInfo

func GetControllerReplicaInfo(cr *contollerpb.ControllerReplica) *types.ControllerReplicaInfo

func GetVolumeInfo

func GetVolumeInfo(v *contollerpb.Volume) *types.VolumeInfo

Types

type ControllerClient

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

func NewControllerClient

func NewControllerClient(address string) *ControllerClient

func (*ControllerClient) BackupReplicaMappingCreate

func (c *ControllerClient) BackupReplicaMappingCreate(backupID string, replicaAddress string) error

func (*ControllerClient) BackupReplicaMappingDelete

func (c *ControllerClient) BackupReplicaMappingDelete(backupID string) error

func (*ControllerClient) BackupReplicaMappingGet

func (c *ControllerClient) BackupReplicaMappingGet() (map[string]string, error)

func (*ControllerClient) Check

func (c *ControllerClient) Check() error

func (*ControllerClient) JournalList

func (c *ControllerClient) JournalList(limit int) error

func (*ControllerClient) ReplicaCreate

func (c *ControllerClient) ReplicaCreate(address string) (*types.ControllerReplicaInfo, error)

func (*ControllerClient) ReplicaDelete

func (c *ControllerClient) ReplicaDelete(address string) error

func (*ControllerClient) ReplicaGet

func (c *ControllerClient) ReplicaGet(address string) (*types.ControllerReplicaInfo, error)

func (*ControllerClient) ReplicaList

func (c *ControllerClient) ReplicaList() ([]*types.ControllerReplicaInfo, error)

func (*ControllerClient) ReplicaPrepareRebuild

func (c *ControllerClient) ReplicaPrepareRebuild(address string) (*types.PrepareRebuildOutput, error)

func (*ControllerClient) ReplicaUpdate

func (c *ControllerClient) ReplicaUpdate(replica *types.ControllerReplicaInfo) (*types.ControllerReplicaInfo, error)

func (*ControllerClient) ReplicaVerifyRebuild

func (c *ControllerClient) ReplicaVerifyRebuild(address string) error

func (*ControllerClient) VersionDetailGet

func (c *ControllerClient) VersionDetailGet() (*meta.VersionOutput, error)

func (*ControllerClient) VolumeFrontendShutdown

func (c *ControllerClient) VolumeFrontendShutdown() error

func (*ControllerClient) VolumeFrontendStart

func (c *ControllerClient) VolumeFrontendStart(frontend string) error

func (*ControllerClient) VolumeGet

func (c *ControllerClient) VolumeGet() (*types.VolumeInfo, error)

func (*ControllerClient) VolumeRevert

func (c *ControllerClient) VolumeRevert(snapshot string) error

func (*ControllerClient) VolumeSnapshot

func (c *ControllerClient) VolumeSnapshot(name string, labels map[string]string) (string, error)

func (*ControllerClient) VolumeStart

func (c *ControllerClient) VolumeStart(replicas ...string) error