Documentation
¶
Index ¶
- type ControlClient
- func (s *ControlClient) Action(req dao.AttachRequest, unused *int) error
- func (s *ControlClient) AddService(service service.Service, serviceId *string) (err error)
- func (s *ControlClient) AssignIPs(assignmentRequest addressassignment.AssignmentRequest, _ *int) (err error)
- func (s *ControlClient) AsyncBackup(backupRequest dao.BackupRequest, filename *string) (err error)
- func (s *ControlClient) AsyncRestore(restoreRequest dao.RestoreRequest, unused *int) (err error)
- func (s *ControlClient) AsyncSnapshot(serviceId string, label *string) error
- func (s *ControlClient) Backup(backupRequest dao.BackupRequest, filename *string) (err error)
- func (s *ControlClient) BackupStatus(req dao.EntityRequest, status *string) (err error)
- func (s *ControlClient) CloneService(request dao.ServiceCloneRequest, copiedServiceId *string) (err error)
- func (s *ControlClient) Close() (err error)
- func (s *ControlClient) DeleteSnapshot(snapshotID string, unused *int) (err error)
- func (s *ControlClient) DeleteSnapshots(serviceID string, unused *int) (err error)
- func (s *ControlClient) DeployService(service dao.ServiceDeploymentRequest, serviceId *string) (err error)
- func (s *ControlClient) FindChildService(request dao.FindChildRequest, service *service.Service) (err error)
- func (s *ControlClient) GetBackupEstimate(backupRequest dao.BackupRequest, estimate *dao.BackupEstimate) (err error)
- func (s *ControlClient) GetHostMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
- func (s *ControlClient) GetInstanceMemoryStats(req dao.MetricRequest, stats *[]metrics.MemoryUsageStats) error
- func (s *ControlClient) GetRunningServices(request dao.EntityRequest, runningServices *[]dao.RunningService) (err error)
- func (s *ControlClient) GetRunningServicesForHost(hostId string, runningServices *[]dao.RunningService) (err error)
- func (s *ControlClient) GetRunningServicesForService(serviceId string, runningServices *[]dao.RunningService) (err error)
- func (s *ControlClient) GetService(serviceId string, service *service.Service) (err error)
- func (s *ControlClient) GetServiceEndpoints(serviceId string, ...) (err error)
- func (s *ControlClient) GetServiceList(serviceID string, services *[]service.Service) (err error)
- func (s *ControlClient) GetServiceLogs(serviceId string, logs *string) error
- func (s *ControlClient) GetServiceMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
- func (s *ControlClient) GetServiceStateLogs(request dao.ServiceStateRequest, logs *string) error
- func (s *ControlClient) GetServiceStatus(serviceID string, statusmap *[]service.Instance) (err error)
- func (s *ControlClient) GetSnapshotByServiceIDAndTag(request dao.SnapshotByTagRequest, snapshot *dao.SnapshotInfo) error
- func (s *ControlClient) GetTenantIDs(unused struct{}, tenantIDs *[]string) error
- func (s *ControlClient) ListBackups(dirpath string, files *[]dao.BackupFile) (err error)
- func (s *ControlClient) ListSnapshots(serviceID string, snapshots *[]dao.SnapshotInfo) (err error)
- func (s *ControlClient) MigrateServices(request dao.ServiceMigrationRequest, unused *int) (err error)
- func (s *ControlClient) PauseService(request dao.ScheduleServiceRequest, affected *int) (err error)
- func (s *ControlClient) ReadyDFS(serviceID string, unused *int) (err error)
- func (s *ControlClient) RebalanceService(request dao.ScheduleServiceRequest, affected *int) (err error)
- func (s *ControlClient) RemoveService(serviceId string, unused *int) (err error)
- func (s *ControlClient) RemoveSnapshotTag(request dao.SnapshotByTagRequest, snapshotID *string) error
- func (s *ControlClient) RepairRegistry(req dao.EntityRequest, unused *int) (err error)
- func (s *ControlClient) ResetRegistry(req dao.EntityRequest, unused *int) (err error)
- func (s *ControlClient) RestartService(request dao.ScheduleServiceRequest, affected *int) (err error)
- func (s *ControlClient) Restore(restoreRequest dao.RestoreRequest, unused *int) (err error)
- func (s *ControlClient) Rollback(req dao.RollbackRequest, unused *int) (err error)
- func (s *ControlClient) Snapshot(req dao.SnapshotRequest, snapshotID *string) (err error)
- func (s *ControlClient) StartService(request dao.ScheduleServiceRequest, affected *int) (err error)
- func (s *ControlClient) StopRunningInstance(request dao.HostServiceRequest, unused *int) (err error)
- func (s *ControlClient) StopService(request dao.ScheduleServiceRequest, affected *int) (err error)
- func (s *ControlClient) TagSnapshot(request dao.TagSnapshotRequest, unused *int) error
- func (s *ControlClient) UpdateService(service service.Service, unused *int) (err error)
- func (s *ControlClient) WaitService(request dao.WaitServiceRequest, _ *int) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControlClient ¶
type ControlClient struct {
// contains filtered or unexported fields
}
A serviced client.
func NewControlClient ¶
func NewControlClient(addr string) (s *ControlClient, err error)
Create a new ControlClient.
func (*ControlClient) Action ¶
func (s *ControlClient) Action(req dao.AttachRequest, unused *int) error
func (*ControlClient) AddService ¶
func (s *ControlClient) AddService(service service.Service, serviceId *string) (err error)
func (*ControlClient) AssignIPs ¶
func (s *ControlClient) AssignIPs(assignmentRequest addressassignment.AssignmentRequest, _ *int) (err error)
func (*ControlClient) AsyncBackup ¶
func (s *ControlClient) AsyncBackup(backupRequest dao.BackupRequest, filename *string) (err error)
func (*ControlClient) AsyncRestore ¶
func (s *ControlClient) AsyncRestore(restoreRequest dao.RestoreRequest, unused *int) (err error)
func (*ControlClient) AsyncSnapshot ¶
func (s *ControlClient) AsyncSnapshot(serviceId string, label *string) error
func (*ControlClient) Backup ¶
func (s *ControlClient) Backup(backupRequest dao.BackupRequest, filename *string) (err error)
func (*ControlClient) BackupStatus ¶
func (s *ControlClient) BackupStatus(req dao.EntityRequest, status *string) (err error)
func (*ControlClient) CloneService ¶
func (s *ControlClient) CloneService(request dao.ServiceCloneRequest, copiedServiceId *string) (err error)
func (*ControlClient) Close ¶
func (s *ControlClient) Close() (err error)
Return the matching hosts.
func (*ControlClient) DeleteSnapshot ¶
func (s *ControlClient) DeleteSnapshot(snapshotID string, unused *int) (err error)
func (*ControlClient) DeleteSnapshots ¶
func (s *ControlClient) DeleteSnapshots(serviceID string, unused *int) (err error)
func (*ControlClient) DeployService ¶
func (s *ControlClient) DeployService(service dao.ServiceDeploymentRequest, serviceId *string) (err error)
func (*ControlClient) FindChildService ¶
func (s *ControlClient) FindChildService(request dao.FindChildRequest, service *service.Service) (err error)
func (*ControlClient) GetBackupEstimate ¶
func (s *ControlClient) GetBackupEstimate(backupRequest dao.BackupRequest, estimate *dao.BackupEstimate) (err error)
func (*ControlClient) GetHostMemoryStats ¶
func (s *ControlClient) GetHostMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
func (*ControlClient) GetInstanceMemoryStats ¶
func (s *ControlClient) GetInstanceMemoryStats(req dao.MetricRequest, stats *[]metrics.MemoryUsageStats) error
func (*ControlClient) GetRunningServices ¶
func (s *ControlClient) GetRunningServices(request dao.EntityRequest, runningServices *[]dao.RunningService) (err error)
func (*ControlClient) GetRunningServicesForHost ¶
func (s *ControlClient) GetRunningServicesForHost(hostId string, runningServices *[]dao.RunningService) (err error)
func (*ControlClient) GetRunningServicesForService ¶
func (s *ControlClient) GetRunningServicesForService(serviceId string, runningServices *[]dao.RunningService) (err error)
func (*ControlClient) GetService ¶
func (s *ControlClient) GetService(serviceId string, service *service.Service) (err error)
func (*ControlClient) GetServiceEndpoints ¶
func (s *ControlClient) GetServiceEndpoints(serviceId string, response *map[string][]applicationendpoint.ApplicationEndpoint) (err error)
func (*ControlClient) GetServiceList ¶
func (s *ControlClient) GetServiceList(serviceID string, services *[]service.Service) (err error)
func (*ControlClient) GetServiceLogs ¶
func (s *ControlClient) GetServiceLogs(serviceId string, logs *string) error
func (*ControlClient) GetServiceMemoryStats ¶
func (s *ControlClient) GetServiceMemoryStats(req dao.MetricRequest, stats *metrics.MemoryUsageStats) error
func (*ControlClient) GetServiceStateLogs ¶
func (s *ControlClient) GetServiceStateLogs(request dao.ServiceStateRequest, logs *string) error
func (*ControlClient) GetServiceStatus ¶
func (s *ControlClient) GetServiceStatus(serviceID string, statusmap *[]service.Instance) (err error)
func (*ControlClient) GetSnapshotByServiceIDAndTag ¶
func (s *ControlClient) GetSnapshotByServiceIDAndTag(request dao.SnapshotByTagRequest, snapshot *dao.SnapshotInfo) error
func (*ControlClient) GetTenantIDs ¶
func (s *ControlClient) GetTenantIDs(unused struct{}, tenantIDs *[]string) error
func (*ControlClient) ListBackups ¶
func (s *ControlClient) ListBackups(dirpath string, files *[]dao.BackupFile) (err error)
func (*ControlClient) ListSnapshots ¶
func (s *ControlClient) ListSnapshots(serviceID string, snapshots *[]dao.SnapshotInfo) (err error)
func (*ControlClient) MigrateServices ¶
func (s *ControlClient) MigrateServices(request dao.ServiceMigrationRequest, unused *int) (err error)
func (*ControlClient) PauseService ¶
func (s *ControlClient) PauseService(request dao.ScheduleServiceRequest, affected *int) (err error)
func (*ControlClient) ReadyDFS ¶
func (s *ControlClient) ReadyDFS(serviceID string, unused *int) (err error)
func (*ControlClient) RebalanceService ¶
func (s *ControlClient) RebalanceService(request dao.ScheduleServiceRequest, affected *int) (err error)
func (*ControlClient) RemoveService ¶
func (s *ControlClient) RemoveService(serviceId string, unused *int) (err error)
func (*ControlClient) RemoveSnapshotTag ¶
func (s *ControlClient) RemoveSnapshotTag(request dao.SnapshotByTagRequest, snapshotID *string) error
func (*ControlClient) RepairRegistry ¶
func (s *ControlClient) RepairRegistry(req dao.EntityRequest, unused *int) (err error)
func (*ControlClient) ResetRegistry ¶
func (s *ControlClient) ResetRegistry(req dao.EntityRequest, unused *int) (err error)
func (*ControlClient) RestartService ¶
func (s *ControlClient) RestartService(request dao.ScheduleServiceRequest, affected *int) (err error)
func (*ControlClient) Restore ¶
func (s *ControlClient) Restore(restoreRequest dao.RestoreRequest, unused *int) (err error)
func (*ControlClient) Rollback ¶
func (s *ControlClient) Rollback(req dao.RollbackRequest, unused *int) (err error)
func (*ControlClient) Snapshot ¶
func (s *ControlClient) Snapshot(req dao.SnapshotRequest, snapshotID *string) (err error)
func (*ControlClient) StartService ¶
func (s *ControlClient) StartService(request dao.ScheduleServiceRequest, affected *int) (err error)
func (*ControlClient) StopRunningInstance ¶
func (s *ControlClient) StopRunningInstance(request dao.HostServiceRequest, unused *int) (err error)
func (*ControlClient) StopService ¶
func (s *ControlClient) StopService(request dao.ScheduleServiceRequest, affected *int) (err error)
func (*ControlClient) TagSnapshot ¶
func (s *ControlClient) TagSnapshot(request dao.TagSnapshotRequest, unused *int) error
func (*ControlClient) UpdateService ¶
func (s *ControlClient) UpdateService(service service.Service, unused *int) (err error)
func (*ControlClient) WaitService ¶
func (s *ControlClient) WaitService(request dao.WaitServiceRequest, _ *int) (err error)
Source Files
Click to show internal directories.
Click to hide internal directories.