Documentation
¶
Index ¶
- Constants
- func GetControllerReplica(r *types.ControllerReplicaInfo) *ptypes.ControllerReplica
- func GetControllerReplicaInfo(cr *ptypes.ControllerReplica) *types.ControllerReplicaInfo
- func GetSyncFileInfo(info *ptypes.SyncFileInfo) types.SyncFileInfo
- func GetSyncFileInfoList(list []*ptypes.SyncFileInfo) []types.SyncFileInfo
- func GetVolumeInfo(v *ptypes.Volume) *types.VolumeInfo
- type ControllerClient
- func (c *ControllerClient) Check() error
- func (c *ControllerClient) JournalList(limit int) error
- func (c *ControllerClient) MetricsGet() (*types.Metrics, error)
- func (c *ControllerClient) ReplicaCreate(address string, snapshotRequired bool, mode types.Mode) (*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, instanceName string) ([]types.SyncFileInfo, error)
- func (c *ControllerClient) ReplicaUpdate(address string, mode types.Mode) (*types.ControllerReplicaInfo, error)
- func (c *ControllerClient) ReplicaVerifyRebuild(address, instanceName string) error
- func (c *ControllerClient) VersionDetailGet() (*meta.VersionOutput, error)
- func (c *ControllerClient) VolumeExpand(size int64) 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) VolumeSnapshotMaxCountSet(count int) error
- func (c *ControllerClient) VolumeSnapshotMaxSizeSet(size int64) error
- func (c *ControllerClient) VolumeStart(size, currentSize int64, replicas ...string) error
- func (c *ControllerClient) VolumeUnmapMarkSnapChainRemovedSet(enabled bool) error
- type ControllerServiceContext
Constants ¶
View Source
const (
GRPCServiceTimeout = 3 * time.Minute
)
Variables ¶
This section is empty.
Functions ¶
func GetControllerReplica ¶
func GetControllerReplica(r *types.ControllerReplicaInfo) *ptypes.ControllerReplica
func GetControllerReplicaInfo ¶
func GetControllerReplicaInfo(cr *ptypes.ControllerReplica) *types.ControllerReplicaInfo
func GetSyncFileInfo ¶
func GetSyncFileInfo(info *ptypes.SyncFileInfo) types.SyncFileInfo
func GetSyncFileInfoList ¶
func GetSyncFileInfoList(list []*ptypes.SyncFileInfo) []types.SyncFileInfo
func GetVolumeInfo ¶
func GetVolumeInfo(v *ptypes.Volume) *types.VolumeInfo
Types ¶
type ControllerClient ¶
type ControllerClient struct {
VolumeName string
ControllerServiceContext
// contains filtered or unexported fields
}
func NewControllerClient ¶
func NewControllerClient(address, volumeName, instanceName string) (*ControllerClient, error)
func (*ControllerClient) Check ¶
func (c *ControllerClient) Check() error
func (*ControllerClient) JournalList ¶
func (c *ControllerClient) JournalList(limit int) error
func (*ControllerClient) MetricsGet ¶ added in v1.4.0
func (c *ControllerClient) MetricsGet() (*types.Metrics, error)
func (*ControllerClient) ReplicaCreate ¶
func (c *ControllerClient) ReplicaCreate(address string, snapshotRequired bool, mode types.Mode) (*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, instanceName string) ([]types.SyncFileInfo, error)
func (*ControllerClient) ReplicaUpdate ¶
func (c *ControllerClient) ReplicaUpdate(address string, mode types.Mode) (*types.ControllerReplicaInfo, error)
func (*ControllerClient) ReplicaVerifyRebuild ¶
func (c *ControllerClient) ReplicaVerifyRebuild(address, instanceName string) error
func (*ControllerClient) VersionDetailGet ¶
func (c *ControllerClient) VersionDetailGet() (*meta.VersionOutput, error)
func (*ControllerClient) VolumeExpand ¶
func (c *ControllerClient) VolumeExpand(size int64) 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 (*ControllerClient) VolumeSnapshotMaxCountSet ¶ added in v1.6.0
func (c *ControllerClient) VolumeSnapshotMaxCountSet(count int) error
func (*ControllerClient) VolumeSnapshotMaxSizeSet ¶ added in v1.6.0
func (c *ControllerClient) VolumeSnapshotMaxSizeSet(size int64) error
func (*ControllerClient) VolumeStart ¶
func (c *ControllerClient) VolumeStart(size, currentSize int64, replicas ...string) error
func (*ControllerClient) VolumeUnmapMarkSnapChainRemovedSet ¶ added in v1.4.0
func (c *ControllerClient) VolumeUnmapMarkSnapChainRemovedSet(enabled bool) error
type ControllerServiceContext ¶ added in v1.1.3
type ControllerServiceContext struct {
// contains filtered or unexported fields
}
func (ControllerServiceContext) Close ¶ added in v1.1.3
func (c ControllerServiceContext) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.