agentpoller

Documentation

Overview

* This file is part of the KubeVirt project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * * Copyright 2018 Red Hat, Inc. *

Index

• func MergeAgentStatusesWithDomainData(domInterfaces []api.Interface, interfaceStatuses []api.InterfaceStatus) []api.InterfaceStatus
• type AgentCommand
• type AgentInfo
• type AgentPoller
  • func CreatePoller(connecton cli.Connection, vmiUID types.UID, domainName string, ...) *AgentPoller
  • func (p *AgentPoller) Start()
  • func (p *AgentPoller) Stop()
• type AgentUpdatedEvent
• type AsyncAgentStore
  • func NewAsyncAgentStore() AsyncAgentStore
  • func (s *AsyncAgentStore) GetFS(limit int) []api.Filesystem
  • func (s *AsyncAgentStore) GetGA() string
  • func (s *AsyncAgentStore) GetSysInfo() api.DomainSysInfo
  • func (s *AsyncAgentStore) GetUsers(limit int) []api.User
  • func (s *AsyncAgentStore) Store(key AgentCommand, value interface{})
• type Filesystem
• type GuestOsInfo
• type Hostname
• type IP
• type Interface
• type PollerWorker
  • func (p *PollerWorker) Poll(con cli.Connection, agentStore *AsyncAgentStore, domainName string, ...)
• type Timezone
• type User

Functions

func MergeAgentStatusesWithDomainData

func MergeAgentStatusesWithDomainData(domInterfaces []api.Interface, interfaceStatuses []api.InterfaceStatus) []api.InterfaceStatus

MergeAgentStatusesWithDomainData merge QEMU interfaces with agent interfaces

Types

type AgentCommand

type AgentCommand string

AgentCommand is a command executable on guest agent

const (
	GET_OSINFO     AgentCommand = "guest-get-osinfo"
	GET_HOSTNAME   AgentCommand = "guest-get-host-name"
	GET_INTERFACES AgentCommand = "guest-network-get-interfaces"
	GET_TIMEZONE   AgentCommand = "guest-get-timezone"
	GET_USERS      AgentCommand = "guest-get-users"
	GET_FILESYSTEM AgentCommand = "guest-get-fsinfo"
	GET_AGENT      AgentCommand = "guest-info"
)

Aliases for commands executed on guest agent TODO: when updated to libvirt 5.6.0 this can change to libvirt types Aliases are also used as keys to the store, it does not matter how the keys are named, only whther it relates to the right data

type AgentInfo

type AgentInfo struct {
	Version string `json:"version"`
}

AgentInfo from the guest VM serves the purpose of checking the GA presence and version compatibility

type AgentPoller

type AgentPoller struct {
	Connection cli.Connection
	VmiUID     types.UID
	// contains filtered or unexported fields
}

func CreatePoller

func CreatePoller(
	connecton cli.Connection,
	vmiUID types.UID,
	domainName string,
	store *AsyncAgentStore,
	qemuAgentSysInterval time.Duration,
	qemuAgentFileInterval time.Duration,
	qemuAgentUserInterval time.Duration,
	qemuAgentVersionInterval time.Duration,
) *AgentPoller

CreatePoller creates the new structure that holds guest agent pollers

func (*AgentPoller) Start

func (p *AgentPoller) Start()

Start the poller workers

func (*AgentPoller) Stop

func (p *AgentPoller) Stop()

Stop all poller workers

type AgentUpdatedEvent

type AgentUpdatedEvent struct {
	Type       AgentCommand
	DomainInfo api.DomainGuestInfo
}

AgentUpdatedEvent fire up when data is changes in the store

type AsyncAgentStore

type AsyncAgentStore struct {
	AgentUpdated chan AgentUpdatedEvent
	// contains filtered or unexported fields
}

AsyncAgentStore stores the agent data converted to api domain objects it offers methods to get the data and fire up an event when there is a change of the data

func NewAsyncAgentStore

func NewAsyncAgentStore() AsyncAgentStore

NewAsyncAgentStore creates new agent store

func (*AsyncAgentStore) GetFS

func (s *AsyncAgentStore) GetFS(limit int) []api.Filesystem

GetFS returns the filesystem list limited to the limit set set limit to -1 to return the whole list

func (*AsyncAgentStore) GetGA

func (s *AsyncAgentStore) GetGA() string

GetGA returns guest agent record with its version if present

func (*AsyncAgentStore) GetSysInfo

func (s *AsyncAgentStore) GetSysInfo() api.DomainSysInfo

GetSysInfo returns the sysInfo information packed together. Sysinfo comprises of:

• Guest Hostname
• Guest OS version and architecture
• Guest Timezone

func (*AsyncAgentStore) GetUsers

func (s *AsyncAgentStore) GetUsers(limit int) []api.User

GetUsers return the use list limited to the limit set set limit to -1 to return all users

func (*AsyncAgentStore) Store

func (s *AsyncAgentStore) Store(key AgentCommand, value interface{})

Store saves the value with a key to the storage, when there is a change in data it fires up updated event

type Filesystem

type Filesystem struct {
	Name       string `json:"name"`
	Mountpoint string `json:"mountpoint"`
	Type       string `json:"type"`
	UsedBytes  int    `json:"used-bytes,omitempty"`
	TotalBytes int    `json:"total-bytes,omitempty"`
}

Filesystem of the host

type GuestOsInfo

type GuestOsInfo struct {
	Name          string `json:"name"`
	KernelRelease string `json:"kernel-release"`
	Version       string `json:"version"`
	PrettyName    string `json:"pretty-name"`
	VersionId     string `json:"version-id"`
	KernelVersion string `json:"kernel-version"`
	Machine       string `json:"machine"`
	Id            string `json:"id"`
}

GuestOsInfo is the response from 'guest-get-osinfo'

type Hostname

type Hostname struct {
	Hostname string `json:"host-name"`
}

Hostname of the guest vm

type IP

type IP struct {
	IP     string `json:"ip-address"`
	Type   string `json:"ip-address-type"`
	Prefix int    `json:"prefix"`
}

IP for json unmarshalling

type Interface

type Interface struct {
	MAC  string `json:"hardware-address"`
	IPs  []IP   `json:"ip-addresses"`
	Name string `json:"name"`
}

Interface for json unmarshalling

type PollerWorker

type PollerWorker struct {
	// AgentCommands is a list of commands executed on the guestAgent
	AgentCommands []AgentCommand
	// CallTick is how often to call this set of commands
	CallTick time.Duration
}

PollerWorker collects the data from the guest agent only unique items are stored as configuration

func (*PollerWorker) Poll

func (p *PollerWorker) Poll(con cli.Connection, agentStore *AsyncAgentStore, domainName string, closeChan chan struct{})

Poll is the call to the guestagent with libvirt 5.6.0 direct call to agent can be replaced with call to libvirt Domain.GetGuestInfo

type Timezone

type Timezone struct {
	Zone   string `json:"zone,omitempty"`
	Offset int    `json:"offset"`
}

Timezone of the host

type User

type User struct {
	Name      string  `json:"user"`
	Domain    string  `json:"domain"`
	LoginTime float64 `json:"login-time"`
}

User on the guest host