host

Documentation

Index

• func RefreshUntil(ctx context.Context, refresh func(context.Context), ...)
• type Info
  • func NewInfo(containerOrchestrator string, refreshInterval time.Duration, ...) (*Info, error)
  • func (m *Info) ExtractEbsIDsUsedByKubernetes() map[string]string
  • func (m *Info) GetAutoScalingGroupName() string
  • func (m *Info) GetClusterName() string
  • func (m *Info) GetEBSVolumeID(devName string) string
  • func (m *Info) GetInstanceID() string
  • func (m *Info) GetInstanceIP() string
  • func (m *Info) GetInstanceIPReadyC() chan bool
  • func (m *Info) GetInstanceType() string
  • func (m *Info) GetMemoryCapacity() int64
  • func (m *Info) GetNumCores() int64
  • func (m *Info) GetRegion() string
  • func (m *Info) Shutdown()

Functions

func RefreshUntil

func RefreshUntil(ctx context.Context, refresh func(context.Context), refreshInterval time.Duration,
	shouldRefresh func() bool, maxJitterTime time.Duration)

execute the refresh() function periodically with the given refresh interval until shouldRefresh() return false or the context is canceled

Types

type Info

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

Info contains information about a host

func NewInfo

func NewInfo(containerOrchestrator string, refreshInterval time.Duration, logger *zap.Logger, options ...machineInfoOption) (*Info, error)

NewInfo creates a new Info struct

func (*Info) ExtractEbsIDsUsedByKubernetes

func (m *Info) ExtractEbsIDsUsedByKubernetes() map[string]string

ExtractEbsIDsUsedByKubernetes extracts the ebs volume id used by kubernetes cluster from host mount file

func (*Info) GetAutoScalingGroupName

func (m *Info) GetAutoScalingGroupName() string

GetAutoScalingGroupName returns the auto scaling group associated with the host

func (*Info) GetClusterName

func (m *Info) GetClusterName() string

GetClusterName returns the cluster name associated with the host

func (*Info) GetEBSVolumeID

func (m *Info) GetEBSVolumeID(devName string) string

GetEBSVolumeID returns the ebs volume id corresponding to the given device name

func (*Info) GetInstanceID

func (m *Info) GetInstanceID() string

GetInstanceID returns the ec2 instance id for the host

func (*Info) GetInstanceIP

func (m *Info) GetInstanceIP() string

GetInstanceIP returns the IP address of the host

func (*Info) GetInstanceIPReadyC

func (m *Info) GetInstanceIPReadyC() chan bool

GetInstanceIPReadyC returns the channel to show the status of host IP

func (*Info) GetInstanceType

func (m *Info) GetInstanceType() string

GetInstanceType returns the ec2 instance type for the host

func (*Info) GetMemoryCapacity

func (m *Info) GetMemoryCapacity() int64

GetMemoryCapacity returns the total memory (in bytes) on the host

func (*Info) GetNumCores

func (m *Info) GetNumCores() int64

GetNumCores returns the number of cpu cores on the host

func (*Info) GetRegion

func (m *Info) GetRegion() string

GetRegion returns the region for the host

func (*Info) Shutdown

func (m *Info) Shutdown()

Shutdown stops the host Info