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