Documentation
¶
Index ¶
- type ControlPlane
- func (_m *ControlPlane) Action(request dao.AttachRequest, unused *int) error
- func (_m *ControlPlane) AddService(svc service.Service, serviceId *string) error
- func (_m *ControlPlane) AssignIPs(assignmentRequest addressassignment.AssignmentRequest, unused *int) error
- func (_m *ControlPlane) AsyncBackup(backupRequest dao.BackupRequest, filename *string) error
- func (_m *ControlPlane) AsyncRestore(restoreRequest dao.RestoreRequest, unused *int) error
- func (_m *ControlPlane) Backup(backupRequest dao.BackupRequest, filename *string) error
- func (_m *ControlPlane) BackupStatus(unused dao.EntityRequest, status *string) error
- func (_m *ControlPlane) CloneService(request dao.ServiceCloneRequest, serviceId *string) error
- func (_m *ControlPlane) DeleteSnapshot(snapshotID string, unused *int) error
- func (_m *ControlPlane) DeleteSnapshots(serviceID string, unused *int) error
- func (_m *ControlPlane) DeployService(svc dao.ServiceDeploymentRequest, serviceId *string) error
- func (_m *ControlPlane) FindChildService(request dao.FindChildRequest, svc *service.Service) error
- func (_m *ControlPlane) GetBackupEstimate(backupRequest dao.BackupRequest, estimate *dao.BackupEstimate) (err error)
- func (_m *ControlPlane) GetHostMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
- func (_m *ControlPlane) GetInstanceMemoryStats(req dao.MetricRequest, stats *[]metrics.MemoryUsageStats) error
- func (_m *ControlPlane) GetRunningServices(request dao.EntityRequest, runningServices *[]dao.RunningService) error
- func (_m *ControlPlane) GetRunningServicesForHost(hostId string, runningServices *[]dao.RunningService) error
- func (_m *ControlPlane) GetRunningServicesForService(serviceId string, runningServices *[]dao.RunningService) error
- func (_m *ControlPlane) GetService(serviceId string, svc *service.Service) error
- func (_m *ControlPlane) GetServiceLogs(serviceId string, logs *string) error
- func (_m *ControlPlane) GetServiceMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
- func (_m *ControlPlane) GetServiceStateLogs(request dao.ServiceStateRequest, logs *string) error
- func (_m *ControlPlane) GetServiceStatus(serviceID string, status *[]service.Instance) error
- func (_m *ControlPlane) GetSnapshotByServiceIDAndTag(request dao.SnapshotByTagRequest, snapshot *dao.SnapshotInfo) error
- func (_m *ControlPlane) GetTenantIDs(unused struct{}, tenantIDs *[]string) error
- func (_m *ControlPlane) ListBackups(dirpath string, files *[]dao.BackupFile) error
- func (_m *ControlPlane) ListSnapshots(serviceID string, snapshots *[]dao.SnapshotInfo) error
- func (_m *ControlPlane) MigrateServices(request dao.ServiceMigrationRequest, unused *int) error
- func (_m *ControlPlane) PauseService(request dao.ScheduleServiceRequest, affected *int) error
- func (_m *ControlPlane) ReadyDFS(serviceID string, unused *int) error
- func (_m *ControlPlane) RebalanceService(request dao.ScheduleServiceRequest, affected *int) error
- func (_m *ControlPlane) RemoveService(serviceId string, unused *int) error
- func (_m *ControlPlane) RemoveSnapshotTag(request dao.SnapshotByTagRequest, snapshotID *string) error
- func (_m *ControlPlane) RepairRegistry(unused dao.EntityRequest, unused_ *int) error
- func (_m *ControlPlane) ResetRegistry(unused dao.EntityRequest, unused_ *int) error
- func (_m *ControlPlane) RestartService(request dao.ScheduleServiceRequest, affected *int) error
- func (_m *ControlPlane) Restore(restoreRequest dao.RestoreRequest, unused *int) error
- func (_m *ControlPlane) Rollback(req dao.RollbackRequest, unused *int) error
- func (_m *ControlPlane) Snapshot(req dao.SnapshotRequest, snapshotID *string) error
- func (_m *ControlPlane) StartService(request dao.ScheduleServiceRequest, affected *int) error
- func (_m *ControlPlane) StopRunningInstance(request dao.HostServiceRequest, unused *int) error
- func (_m *ControlPlane) StopService(request dao.ScheduleServiceRequest, affected *int) error
- func (_m *ControlPlane) TagSnapshot(request dao.TagSnapshotRequest, unused *int) error
- func (_m *ControlPlane) UpdateService(svc service.Service, unused *int) error
- func (_m *ControlPlane) WaitService(request dao.WaitServiceRequest, unused *int) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControlPlane ¶
func (*ControlPlane) Action ¶
func (_m *ControlPlane) Action(request dao.AttachRequest, unused *int) error
func (*ControlPlane) AddService ¶
func (_m *ControlPlane) AddService(svc service.Service, serviceId *string) error
func (*ControlPlane) AssignIPs ¶
func (_m *ControlPlane) AssignIPs(assignmentRequest addressassignment.AssignmentRequest, unused *int) error
func (*ControlPlane) AsyncBackup ¶
func (_m *ControlPlane) AsyncBackup(backupRequest dao.BackupRequest, filename *string) error
func (*ControlPlane) AsyncRestore ¶
func (_m *ControlPlane) AsyncRestore(restoreRequest dao.RestoreRequest, unused *int) error
func (*ControlPlane) Backup ¶
func (_m *ControlPlane) Backup(backupRequest dao.BackupRequest, filename *string) error
func (*ControlPlane) BackupStatus ¶
func (_m *ControlPlane) BackupStatus(unused dao.EntityRequest, status *string) error
func (*ControlPlane) CloneService ¶
func (_m *ControlPlane) CloneService(request dao.ServiceCloneRequest, serviceId *string) error
func (*ControlPlane) DeleteSnapshot ¶
func (_m *ControlPlane) DeleteSnapshot(snapshotID string, unused *int) error
func (*ControlPlane) DeleteSnapshots ¶
func (_m *ControlPlane) DeleteSnapshots(serviceID string, unused *int) error
func (*ControlPlane) DeployService ¶
func (_m *ControlPlane) DeployService(svc dao.ServiceDeploymentRequest, serviceId *string) error
func (*ControlPlane) FindChildService ¶
func (_m *ControlPlane) FindChildService(request dao.FindChildRequest, svc *service.Service) error
func (*ControlPlane) GetBackupEstimate ¶
func (_m *ControlPlane) GetBackupEstimate(backupRequest dao.BackupRequest, estimate *dao.BackupEstimate) (err error)
func (*ControlPlane) GetHostMemoryStats ¶
func (_m *ControlPlane) GetHostMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
func (*ControlPlane) GetInstanceMemoryStats ¶
func (_m *ControlPlane) GetInstanceMemoryStats(req dao.MetricRequest, stats *[]metrics.MemoryUsageStats) error
func (*ControlPlane) GetRunningServices ¶
func (_m *ControlPlane) GetRunningServices(request dao.EntityRequest, runningServices *[]dao.RunningService) error
func (*ControlPlane) GetRunningServicesForHost ¶
func (_m *ControlPlane) GetRunningServicesForHost(hostId string, runningServices *[]dao.RunningService) error
func (*ControlPlane) GetRunningServicesForService ¶
func (_m *ControlPlane) GetRunningServicesForService(serviceId string, runningServices *[]dao.RunningService) error
func (*ControlPlane) GetService ¶
func (_m *ControlPlane) GetService(serviceId string, svc *service.Service) error
func (*ControlPlane) GetServiceLogs ¶
func (_m *ControlPlane) GetServiceLogs(serviceId string, logs *string) error
func (*ControlPlane) GetServiceMemoryStats ¶
func (_m *ControlPlane) GetServiceMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
func (*ControlPlane) GetServiceStateLogs ¶
func (_m *ControlPlane) GetServiceStateLogs(request dao.ServiceStateRequest, logs *string) error
func (*ControlPlane) GetServiceStatus ¶
func (_m *ControlPlane) GetServiceStatus(serviceID string, status *[]service.Instance) error
func (*ControlPlane) GetSnapshotByServiceIDAndTag ¶
func (_m *ControlPlane) GetSnapshotByServiceIDAndTag(request dao.SnapshotByTagRequest, snapshot *dao.SnapshotInfo) error
func (*ControlPlane) GetTenantIDs ¶
func (_m *ControlPlane) GetTenantIDs(unused struct{}, tenantIDs *[]string) error
func (*ControlPlane) ListBackups ¶
func (_m *ControlPlane) ListBackups(dirpath string, files *[]dao.BackupFile) error
func (*ControlPlane) ListSnapshots ¶
func (_m *ControlPlane) ListSnapshots(serviceID string, snapshots *[]dao.SnapshotInfo) error
func (*ControlPlane) MigrateServices ¶
func (_m *ControlPlane) MigrateServices(request dao.ServiceMigrationRequest, unused *int) error
func (*ControlPlane) PauseService ¶
func (_m *ControlPlane) PauseService(request dao.ScheduleServiceRequest, affected *int) error
func (*ControlPlane) ReadyDFS ¶
func (_m *ControlPlane) ReadyDFS(serviceID string, unused *int) error
func (*ControlPlane) RebalanceService ¶
func (_m *ControlPlane) RebalanceService(request dao.ScheduleServiceRequest, affected *int) error
func (*ControlPlane) RemoveService ¶
func (_m *ControlPlane) RemoveService(serviceId string, unused *int) error
func (*ControlPlane) RemoveSnapshotTag ¶
func (_m *ControlPlane) RemoveSnapshotTag(request dao.SnapshotByTagRequest, snapshotID *string) error
func (*ControlPlane) RepairRegistry ¶
func (_m *ControlPlane) RepairRegistry(unused dao.EntityRequest, unused_ *int) error
func (*ControlPlane) ResetRegistry ¶
func (_m *ControlPlane) ResetRegistry(unused dao.EntityRequest, unused_ *int) error
func (*ControlPlane) RestartService ¶
func (_m *ControlPlane) RestartService(request dao.ScheduleServiceRequest, affected *int) error
func (*ControlPlane) Restore ¶
func (_m *ControlPlane) Restore(restoreRequest dao.RestoreRequest, unused *int) error
func (*ControlPlane) Rollback ¶
func (_m *ControlPlane) Rollback(req dao.RollbackRequest, unused *int) error
func (*ControlPlane) Snapshot ¶
func (_m *ControlPlane) Snapshot(req dao.SnapshotRequest, snapshotID *string) error
func (*ControlPlane) StartService ¶
func (_m *ControlPlane) StartService(request dao.ScheduleServiceRequest, affected *int) error
func (*ControlPlane) StopRunningInstance ¶
func (_m *ControlPlane) StopRunningInstance(request dao.HostServiceRequest, unused *int) error
func (*ControlPlane) StopService ¶
func (_m *ControlPlane) StopService(request dao.ScheduleServiceRequest, affected *int) error
func (*ControlPlane) TagSnapshot ¶
func (_m *ControlPlane) TagSnapshot(request dao.TagSnapshotRequest, unused *int) error
func (*ControlPlane) UpdateService ¶
func (_m *ControlPlane) UpdateService(svc service.Service, unused *int) error
func (*ControlPlane) WaitService ¶
func (_m *ControlPlane) WaitService(request dao.WaitServiceRequest, unused *int) error
Click to show internal directories.
Click to hide internal directories.