client

package
v1.4.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 13, 2022 License: Apache-2.0 Imports: 23 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	GRPCServiceTimeout     = eclient.GRPCServiceCommonTimeout * 2
	GRPCServiceLongTimeout = eclient.GRPCServiceLongTimeout + GRPCServiceTimeout
)

Variables

View Source 
var (
	ErrParameterFmt = "missing required %v parameter"
)

Functions

This section is empty.

Types

type BackupRestoreStatus 

type BackupRestoreStatus struct {
	IsRestoring            bool
	LastRestored           string
	CurrentRestoringBackup string
	Progress               int
	Error                  string
	Filename               string
	State                  string
	BackupURL              string
}

type EngineBackupInfo 

type EngineBackupInfo struct {
	Name                   string
	URL                    string
	SnapshotName           string
	SnapshotCreated        string
	Created                string
	Size                   int64
	Labels                 map[string]string
	IsIncremental          bool
	VolumeName             string
	VolumeSize             int64
	VolumeCreated          string
	VolumeBackingImageName string
	Messages               map[string]string
}

type EngineBackupVolumeInfo 

type EngineBackupVolumeInfo struct {
	Name                 string
	Size                 int64
	Labels               map[string]string
	Created              string
	LastBackupName       string
	LastBackupAt         string
	DataStored           int64
	Messages             map[string]string
	Backups              map[string]*EngineBackupInfo
	BackingImageName     string
	BackingImageChecksum string
}

type ProcessManagerClient 

type ProcessManagerClient struct {
	ProcessManagerServiceContext
	// contains filtered or unexported fields
}

func NewProcessManagerClient 

func NewProcessManagerClient(serviceURL string, tlsConfig *tls.Config) (*ProcessManagerClient, error)

func NewProcessManagerClientWithTLS 

func NewProcessManagerClientWithTLS(serviceURL, caFile, certFile, keyFile, peerName string) (*ProcessManagerClient, error)

func (*ProcessManagerClient) ProcessCreate 

func (c *ProcessManagerClient) ProcessCreate(name, binary string, portCount int, args, portArgs []string) (*api.Process, error)

func (*ProcessManagerClient) ProcessDelete 

func (c *ProcessManagerClient) ProcessDelete(name string) (*api.Process, error)

func (*ProcessManagerClient) ProcessGet 

func (c *ProcessManagerClient) ProcessGet(name string) (*api.Process, error)

func (*ProcessManagerClient) ProcessList 

func (c *ProcessManagerClient) ProcessList() (map[string]*api.Process, error)

func (*ProcessManagerClient) ProcessLog 

func (c *ProcessManagerClient) ProcessLog(ctx context.Context, name string) (*api.LogStream, error)

func (*ProcessManagerClient) ProcessReplace 

func (c *ProcessManagerClient) ProcessReplace(name, binary string, portCount int, args, portArgs []string, terminateSignal string) (*api.Process, error)

func (*ProcessManagerClient) ProcessWatch 

func (c *ProcessManagerClient) ProcessWatch(ctx context.Context) (*api.ProcessStream, error)

func (*ProcessManagerClient) VersionGet 

func (c *ProcessManagerClient) VersionGet() (*meta.VersionOutput, error)

type ProcessManagerServiceContext 

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

func (ProcessManagerServiceContext) Close 

func (c ProcessManagerServiceContext) Close() error

type ProxyClient 

type ProxyClient struct {
	ServiceURL string
	ServiceContext

	Version int
}

func NewProxyClient 

func NewProxyClient(ctx context.Context, ctxCancel context.CancelFunc, address string, port int) (*ProxyClient, error)

func (*ProxyClient) BackupRestore 

func (c *ProxyClient) BackupRestore(serviceAddress, url, target, volumeName string, envs []string) (err error)

func (*ProxyClient) BackupRestoreStatus 

func (c *ProxyClient) BackupRestoreStatus(serviceAddress string) (status map[string]*BackupRestoreStatus, err error)

func (*ProxyClient) ClientVersionGet 

func (c *ProxyClient) ClientVersionGet() (version emeta.VersionOutput)

func (*ProxyClient) Close 

func (c *ProxyClient) Close() error

func (*ProxyClient) ReplicaAdd 

func (c *ProxyClient) ReplicaAdd(serviceAddress, replicaAddress string, restore bool, size, currentSize int64, fastSync bool) (err error)

func (*ProxyClient) ReplicaList 

func (c *ProxyClient) ReplicaList(serviceAddress string) (rInfoList []*etypes.ControllerReplicaInfo, err error)

func (*ProxyClient) ReplicaModeUpdate 

func (c *ProxyClient) ReplicaModeUpdate(serviceAddress, replicaAddress string, mode string) (err error)

func (*ProxyClient) ReplicaRebuildingStatus 

func (c *ProxyClient) ReplicaRebuildingStatus(serviceAddress string) (status map[string]*ReplicaRebuildStatus, err error)

func (*ProxyClient) ReplicaRemove 

func (c *ProxyClient) ReplicaRemove(serviceAddress, replicaAddress string) (err error)

func (*ProxyClient) ReplicaVerifyRebuild 

func (c *ProxyClient) ReplicaVerifyRebuild(serviceAddress, replicaAddress string) (err error)

func (*ProxyClient) ServerVersionGet 

func (c *ProxyClient) ServerVersionGet(serviceAddress string) (version *emeta.VersionOutput, err error)

func (*ProxyClient) SnapshotBackup 

func (c *ProxyClient) SnapshotBackup(serviceAddress,
	backupName, snapshotName, backupTarget,
	backingImageName, backingImageChecksum string,
	labels map[string]string, envs []string) (backupID, replicaAddress string, err error)

func (*ProxyClient) SnapshotBackupStatus 

func (c *ProxyClient) SnapshotBackupStatus(serviceAddress, backupName, replicaAddress string) (status *SnapshotBackupStatus, err error)

func (*ProxyClient) SnapshotClone 

func (c *ProxyClient) SnapshotClone(serviceAddress, name, fromController string) (err error)

func (*ProxyClient) SnapshotCloneStatus 

func (c *ProxyClient) SnapshotCloneStatus(serviceAddress string) (status map[string]*SnapshotCloneStatus, err error)

func (*ProxyClient) SnapshotHash 

func (c *ProxyClient) SnapshotHash(serviceAddress string, snapshotName string, rehash bool) (err error)

func (*ProxyClient) SnapshotHashStatus 

func (c *ProxyClient) SnapshotHashStatus(serviceAddress, snapshotName string) (status map[string]*SnapshotHashStatus, err error)

func (*ProxyClient) SnapshotList 

func (c *ProxyClient) SnapshotList(serviceAddress string) (snapshotDiskInfo map[string]*etypes.DiskInfo, err error)

func (*ProxyClient) SnapshotPurge 

func (c *ProxyClient) SnapshotPurge(serviceAddress string, skipIfInProgress bool) (err error)

func (*ProxyClient) SnapshotPurgeStatus 

func (c *ProxyClient) SnapshotPurgeStatus(serviceAddress string) (status map[string]*SnapshotPurgeStatus, err error)

func (*ProxyClient) SnapshotRemove 

func (c *ProxyClient) SnapshotRemove(serviceAddress string, names []string) (err error)

func (*ProxyClient) SnapshotRevert 

func (c *ProxyClient) SnapshotRevert(serviceAddress string, name string) (err error)

func (*ProxyClient) VolumeExpand 

func (c *ProxyClient) VolumeExpand(serviceAddress string, size int64) (err error)

func (*ProxyClient) VolumeFrontendShutdown 

func (c *ProxyClient) VolumeFrontendShutdown(serviceAddress string) (err error)

func (*ProxyClient) VolumeFrontendStart 

func (c *ProxyClient) VolumeFrontendStart(serviceAddress, frontendName string) (err error)

func (*ProxyClient) VolumeGet 

func (c *ProxyClient) VolumeGet(serviceAddress string) (info *etypes.VolumeInfo, err error)

func (*ProxyClient) VolumeSnapshot 

func (c *ProxyClient) VolumeSnapshot(serviceAddress, volumeSnapshotName string, labels map[string]string) (snapshotName string, err error)

func (*ProxyClient) VolumeUnmapMarkSnapChainRemovedSet 

func (c *ProxyClient) VolumeUnmapMarkSnapChainRemovedSet(serviceAddress string, enabled bool) (err error)

type ReplicaError 

type ReplicaError struct {
	Address string
	Message string
}

func (ReplicaError) Error 

func (e ReplicaError) Error() string

type ReplicaRebuildStatus 

type ReplicaRebuildStatus struct {
	Error              string
	IsRebuilding       bool
	Progress           int
	State              string
	FromReplicaAddress string
}

type ServiceContext 

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

func (ServiceContext) GetConnectionState 

func (s ServiceContext) GetConnectionState() connectivity.State

type SnapshotBackupStatus 

type SnapshotBackupStatus struct {
	Progress       int
	BackupURL      string
	Error          string
	SnapshotName   string
	State          string
	ReplicaAddress string
}

type SnapshotCloneStatus 

type SnapshotCloneStatus struct {
	IsCloning          bool
	Error              string
	Progress           int
	State              string
	FromReplicaAddress string
	SnapshotName       string
}

type SnapshotHashStatus 

type SnapshotHashStatus struct {
	State             string
	Checksum          string
	Error             string
	SilentlyCorrupted bool
}

type SnapshotPurgeStatus 

type SnapshotPurgeStatus struct {
	Error     string
	IsPurging bool
	Progress  int
	State     string
}

type TaskError 

type TaskError struct {
	ReplicaErrors []ReplicaError
}

func (TaskError) Error 

func (e TaskError) Error() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.