Documentation
¶
Index ¶
- Variables
- type ShepherdPlatform
- func (s *ShepherdPlatform) GetClusterIP(ctx context.Context, clusterInst *edgeproto.ClusterInst) (string, error)
- func (s *ShepherdPlatform) GetClusterPlatformClient(ctx context.Context, clusterInst *edgeproto.ClusterInst, clientType string) (ssh.Client, error)
- func (s *ShepherdPlatform) GetMetricsCollectInterval() time.Duration
- func (s *ShepherdPlatform) GetPlatformStats(ctx context.Context) (shepherd_common.CloudletMetrics, error)
- func (s *ShepherdPlatform) GetVmAppRootLbClient(ctx context.Context, appInst *edgeproto.AppInst) (ssh.Client, error)
- func (s *ShepherdPlatform) GetVmStats(ctx context.Context, key *edgeproto.AppInstKey) (shepherd_common.AppMetrics, error)
- func (s *ShepherdPlatform) Init(ctx context.Context, pc *platform.PlatformConfig, ...) error
- func (s *ShepherdPlatform) IsPlatformLocal(ctx context.Context) bool
- func (s *ShepherdPlatform) SetUsageAccessArgs(ctx context.Context, addr string, client ssh.Client) error
- func (s *ShepherdPlatform) SetVMPool(ctx context.Context, vmPool *edgeproto.VMPool)
- func (s *ShepherdPlatform) VmAppChangedCallback(ctx context.Context, appInst *edgeproto.AppInst, ...)
Constants ¶
This section is empty.
Variables ¶
View Source
var ChangeSinceLastVmAppStats bool
ChangeSinceLastCloudletStats means a VM appinst changed since last VM App stats collection
Functions ¶
This section is empty.
Types ¶
type ShepherdPlatform ¶
type ShepherdPlatform struct {
VMPlatform *vmlayer.VMPlatform
// contains filtered or unexported fields
}
func (*ShepherdPlatform) GetClusterIP ¶
func (s *ShepherdPlatform) GetClusterIP(ctx context.Context, clusterInst *edgeproto.ClusterInst) (string, error)
func (*ShepherdPlatform) GetClusterPlatformClient ¶
func (s *ShepherdPlatform) GetClusterPlatformClient(ctx context.Context, clusterInst *edgeproto.ClusterInst, clientType string) (ssh.Client, error)
func (*ShepherdPlatform) GetMetricsCollectInterval ¶
func (s *ShepherdPlatform) GetMetricsCollectInterval() time.Duration
func (*ShepherdPlatform) GetPlatformStats ¶
func (s *ShepherdPlatform) GetPlatformStats(ctx context.Context) (shepherd_common.CloudletMetrics, error)
func (*ShepherdPlatform) GetVmAppRootLbClient ¶
func (*ShepherdPlatform) GetVmStats ¶
func (s *ShepherdPlatform) GetVmStats(ctx context.Context, key *edgeproto.AppInstKey) (shepherd_common.AppMetrics, error)
func (*ShepherdPlatform) Init ¶
func (s *ShepherdPlatform) Init(ctx context.Context, pc *platform.PlatformConfig, platformCaches *platform.Caches) error
func (*ShepherdPlatform) IsPlatformLocal ¶
func (s *ShepherdPlatform) IsPlatformLocal(ctx context.Context) bool
func (*ShepherdPlatform) SetUsageAccessArgs ¶
func (*ShepherdPlatform) SetVMPool ¶
func (s *ShepherdPlatform) SetVMPool(ctx context.Context, vmPool *edgeproto.VMPool)
func (*ShepherdPlatform) VmAppChangedCallback ¶
func (s *ShepherdPlatform) VmAppChangedCallback(ctx context.Context, appInst *edgeproto.AppInst, newState edgeproto.TrackedState)
Click to show internal directories.
Click to hide internal directories.