agentv1

package
v0.750.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 19, 2024 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_determined_agent_v1_agent_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Agent 

type Agent struct {

	// The unique id of the agent.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The time when the agent registered with the master.
	RegisteredTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=registered_time,json=registeredTime,proto3" json:"registered_time,omitempty"`
	// A map of slot id to each slot of this agent.
	Slots map[string]*Slot `` /* 151-byte string literal not displayed */
	// A map of container id to all containers assigned to this agent.
	Containers map[string]*containerv1.Container `` /* 161-byte string literal not displayed */
	// The addresses of the agent.
	Addresses []string `protobuf:"bytes,7,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// Flag notifying if containers can be scheduled on this agent.
	Enabled bool `protobuf:"varint,8,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Flag notifying if this agent is in the draining mode: current containers
	// will be allowed to finish but no new ones will be scheduled.
	Draining bool `protobuf:"varint,9,opt,name=draining,proto3" json:"draining,omitempty"`
	// The Determined version that this agent was built from.
	Version string `protobuf:"bytes,10,opt,name=version,proto3" json:"version,omitempty"`
	// The name of the resource pools the agent is in. Only slurm can contain
	// multiples.
	ResourcePools []string `protobuf:"bytes,6,rep,name=resource_pools,json=resourcePools,proto3" json:"resource_pools,omitempty"`
	// The slot stats for this agent.
	SlotStats *SlotStats `protobuf:"bytes,11,opt,name=slot_stats,json=slotStats,proto3" json:"slot_stats,omitempty"`
	// contains filtered or unexported fields
}

Agent is a pool of resources where containers are run.

func (*Agent) Descriptor deprecated 

func (*Agent) Descriptor() ([]byte, []int)

Deprecated: Use Agent.ProtoReflect.Descriptor instead.

func (*Agent) GetAddresses 

func (x *Agent) GetAddresses() []string

func (*Agent) GetContainers 

func (x *Agent) GetContainers() map[string]*containerv1.Container

func (*Agent) GetDraining 

func (x *Agent) GetDraining() bool

func (*Agent) GetEnabled 

func (x *Agent) GetEnabled() bool

func (*Agent) GetId 

func (x *Agent) GetId() string

func (*Agent) GetRegisteredTime 

func (x *Agent) GetRegisteredTime() *timestamp.Timestamp

func (*Agent) GetResourcePools 

func (x *Agent) GetResourcePools() []string

func (*Agent) GetSlotStats 

func (x *Agent) GetSlotStats() *SlotStats

func (*Agent) GetSlots 

func (x *Agent) GetSlots() map[string]*Slot

func (*Agent) GetVersion 

func (x *Agent) GetVersion() string

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) ProtoReflect 

func (x *Agent) ProtoReflect() protoreflect.Message

func (*Agent) Reset 

func (x *Agent) Reset()

func (*Agent) String 

func (x *Agent) String() string

type DeviceStats 

type DeviceStats struct {

	// The number of slots in each state if there's an associated container.
	States map[string]int32 `` /* 154-byte string literal not displayed */
	// the number of draining slots.
	Draining int32 `protobuf:"varint,2,opt,name=draining,proto3" json:"draining,omitempty"`
	// the number of disabled slots.
	Disabled int32 `protobuf:"varint,3,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// the total number of slots.
	Total int32 `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

DeviceStats contains statistics about a single device group.

func (*DeviceStats) Descriptor deprecated 

func (*DeviceStats) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStats.ProtoReflect.Descriptor instead.

func (*DeviceStats) GetDisabled 

func (x *DeviceStats) GetDisabled() int32

func (*DeviceStats) GetDraining 

func (x *DeviceStats) GetDraining() int32

func (*DeviceStats) GetStates 

func (x *DeviceStats) GetStates() map[string]int32

func (*DeviceStats) GetTotal 

func (x *DeviceStats) GetTotal() int32

func (*DeviceStats) ProtoMessage 

func (*DeviceStats) ProtoMessage()

func (*DeviceStats) ProtoReflect 

func (x *DeviceStats) ProtoReflect() protoreflect.Message

func (*DeviceStats) Reset 

func (x *DeviceStats) Reset()

func (*DeviceStats) String 

func (x *DeviceStats) String() string

type Slot 

type Slot struct {

	// The unqiue id of the slot for a given agent.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The individual resource this slot wraps.
	Device *devicev1.Device `protobuf:"bytes,2,opt,name=device,proto3" json:"device,omitempty"`
	// Flag notifying if containers can be scheduled on this slot.
	Enabled bool `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Container that is currently running on this agent. It is unset if there is
	// no container currently running on this slot.
	Container *containerv1.Container `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"`
	// Flag notifying if this slot is in the draining mode: current containers
	// will be allowed to finish but no new ones will be scheduled.
	Draining bool `protobuf:"varint,5,opt,name=draining,proto3" json:"draining,omitempty"`
	// contains filtered or unexported fields
}

Slot wraps a single device on the agent.

func (*Slot) Descriptor deprecated 

func (*Slot) Descriptor() ([]byte, []int)

Deprecated: Use Slot.ProtoReflect.Descriptor instead.

func (*Slot) GetContainer 

func (x *Slot) GetContainer() *containerv1.Container

func (*Slot) GetDevice 

func (x *Slot) GetDevice() *devicev1.Device

func (*Slot) GetDraining 

func (x *Slot) GetDraining() bool

func (*Slot) GetEnabled 

func (x *Slot) GetEnabled() bool

func (*Slot) GetId 

func (x *Slot) GetId() string

func (*Slot) ProtoMessage 

func (*Slot) ProtoMessage()

func (*Slot) ProtoReflect 

func (x *Slot) ProtoReflect() protoreflect.Message

func (*Slot) Reset 

func (x *Slot) Reset()

func (*Slot) String 

func (x *Slot) String() string

type SlotStats 

type SlotStats struct {

	// Map of device type to device stats.
	TypeStats map[string]*DeviceStats `` /* 176-byte string literal not displayed */
	// Map of device brands to device stats.
	BrandStats map[string]*DeviceStats `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

SlotStats contains statistics about a set of slots.

func (*SlotStats) Descriptor deprecated 

func (*SlotStats) Descriptor() ([]byte, []int)

Deprecated: Use SlotStats.ProtoReflect.Descriptor instead.

func (*SlotStats) GetBrandStats 

func (x *SlotStats) GetBrandStats() map[string]*DeviceStats

func (*SlotStats) GetTypeStats 

func (x *SlotStats) GetTypeStats() map[string]*DeviceStats

func (*SlotStats) ProtoMessage 

func (*SlotStats) ProtoMessage()

func (*SlotStats) ProtoReflect 

func (x *SlotStats) ProtoReflect() protoreflect.Message

func (*SlotStats) Reset 

func (x *SlotStats) Reset()

func (*SlotStats) String 

func (x *SlotStats) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.