client

Documentation

Index

• Constants
• func GetControllerReplica(r *types.ControllerReplicaInfo) *enginerpc.ControllerReplica
• func GetControllerReplicaInfo(cr *enginerpc.ControllerReplica) *types.ControllerReplicaInfo
• func GetSyncFileInfo(info *enginerpc.SyncFileInfo) types.SyncFileInfo
• func GetSyncFileInfoList(list []*enginerpc.SyncFileInfo) []types.SyncFileInfo
• func GetVolumeInfo(v *enginerpc.Volume) *types.VolumeInfo
• type ControllerClient
  • func NewControllerClient(address, volumeName, instanceName string) (*ControllerClient, error)
  • 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, freezeFilesystem bool) (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
  • func (c ControllerServiceContext) Close() error

Constants

const (
	GRPCServiceTimeout = 3 * time.Minute
)

Functions

func GetControllerReplica

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

func GetControllerReplicaInfo

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

func GetSyncFileInfo

func GetSyncFileInfo(info *enginerpc.SyncFileInfo) types.SyncFileInfo

func GetSyncFileInfoList

func GetSyncFileInfoList(list []*enginerpc.SyncFileInfo) []types.SyncFileInfo

func GetVolumeInfo

func GetVolumeInfo(v *enginerpc.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

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 (c *ControllerClient) VolumeSnapshot(name string, labels map[string]string, freezeFilesystem bool) (string, error)

func (*ControllerClient) VolumeSnapshotMaxCountSet

func (c *ControllerClient) VolumeSnapshotMaxCountSet(count int) error

func (*ControllerClient) VolumeSnapshotMaxSizeSet

func (c *ControllerClient) VolumeSnapshotMaxSizeSet(size int64) error

func (*ControllerClient) VolumeStart

func (c *ControllerClient) VolumeStart(size, currentSize int64, replicas ...string) error

func (*ControllerClient) VolumeUnmapMarkSnapChainRemovedSet

func (c *ControllerClient) VolumeUnmapMarkSnapChainRemovedSet(enabled bool) error

type ControllerServiceContext

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

func (ControllerServiceContext) Close

func (c ControllerServiceContext) Close() error