shepherd_unittest

Documentation

Index

• type Platform
  • func (s *Platform) GetClusterIP(ctx context.Context, clusterInst *edgeproto.ClusterInst) (string, error)
  • func (s *Platform) GetClusterPlatformClient(ctx context.Context, clusterInst *edgeproto.ClusterInst, clientType string) (ssh.Client, error)
  • func (s *Platform) GetMetricsCollectInterval() time.Duration
  • func (s *Platform) GetPlatformStats(ctx context.Context) (shepherd_common.CloudletMetrics, error)
  • func (s *Platform) GetVmAppRootLbClient(ctx context.Context, appInst *edgeproto.AppInst) (ssh.Client, error)
  • func (s *Platform) GetVmStats(ctx context.Context, key *edgeproto.AppInstKey) (shepherd_common.AppMetrics, error)
  • func (s *Platform) Init(ctx context.Context, pc *platform.PlatformConfig, caches *platform.Caches) error
  • func (s *Platform) IsPlatformLocal(ctx context.Context) bool
  • func (s *Platform) SetUsageAccessArgs(ctx context.Context, addr string, client ssh.Client) error
  • func (s *Platform) SetVMPool(ctx context.Context, vmPool *edgeproto.VMPool)
  • func (s *Platform) VmAppChangedCallback(ctx context.Context, appInst *edgeproto.AppInst, ...)
• type UTClient
  • func (s *UTClient) Output(command string) (string, error)
  • func (s *UTClient) OutputWithTimeout(command string, timeout time.Duration) (string, error)

Types

type Platform

type Platform struct {
	// Contains the response string for a given type of a request
	DockerAppMetrics     string
	DockerClusterMetrics string
	DockerContainerPid   string
	CatContainerNetData  string
	DockerPsSizeData     string
	// Cloudlet-level test data
	CloudletMetrics    string
	VmAppInstMetrics   string
	FailPlatformClient bool
	Ncpus              string
}

func (*Platform) GetClusterIP

func (s *Platform) GetClusterIP(ctx context.Context, clusterInst *edgeproto.ClusterInst) (string, error)

func (*Platform) GetClusterPlatformClient

func (s *Platform) GetClusterPlatformClient(ctx context.Context, clusterInst *edgeproto.ClusterInst, clientType string) (ssh.Client, error)

func (*Platform) GetMetricsCollectInterval

func (s *Platform) GetMetricsCollectInterval() time.Duration

func (*Platform) GetPlatformStats

func (s *Platform) GetPlatformStats(ctx context.Context) (shepherd_common.CloudletMetrics, error)

Query local system for the resource usage

func (*Platform) GetVmAppRootLbClient

func (s *Platform) GetVmAppRootLbClient(ctx context.Context, appInst *edgeproto.AppInst) (ssh.Client, error)

func (*Platform) GetVmStats

func (s *Platform) GetVmStats(ctx context.Context, key *edgeproto.AppInstKey) (shepherd_common.AppMetrics, error)

func (*Platform) Init

func (s *Platform) Init(ctx context.Context, pc *platform.PlatformConfig, caches *platform.Caches) error

func (*Platform) IsPlatformLocal

func (s *Platform) IsPlatformLocal(ctx context.Context) bool

func (*Platform) SetUsageAccessArgs

func (s *Platform) SetUsageAccessArgs(ctx context.Context, addr string, client ssh.Client) error

func (*Platform) SetVMPool

func (s *Platform) SetVMPool(ctx context.Context, vmPool *edgeproto.VMPool)

func (*Platform) VmAppChangedCallback

func (s *Platform) VmAppChangedCallback(ctx context.Context, appInst *edgeproto.AppInst, newState edgeproto.TrackedState)

type UTClient

type UTClient struct {
	pc.LocalClient
	// contains filtered or unexported fields
}

UTClient hijacks a set of commands and returns predetermined output For all other commands it just calls pc.LocalClient equivalents

func (*UTClient) Output

func (s *UTClient) Output(command string) (string, error)

func (*UTClient) OutputWithTimeout

func (s *UTClient) OutputWithTimeout(command string, timeout time.Duration) (string, error)