agentv1

Documentation

Index

• Variables
• type Agent
  • func (*Agent) Descriptor() ([]byte, []int)
  • func (x *Agent) GetAddresses() []string
  • func (x *Agent) GetContainers() map[string]*containerv1.Container
  • func (x *Agent) GetDraining() bool
  • func (x *Agent) GetEnabled() bool
  • func (x *Agent) GetId() string
  • func (x *Agent) GetLabel() string
  • func (x *Agent) GetRegisteredTime() *timestamp.Timestamp
  • func (x *Agent) GetResourcePools() []string
  • func (x *Agent) GetSlots() map[string]*Slot
  • func (x *Agent) GetVersion() string
  • func (*Agent) ProtoMessage()
  • func (x *Agent) ProtoReflect() protoreflect.Message
  • func (x *Agent) Reset()
  • func (x *Agent) String() string
• type Slot
  • func (*Slot) Descriptor() ([]byte, []int)
  • func (x *Slot) GetContainer() *containerv1.Container
  • func (x *Slot) GetDevice() *devicev1.Device
  • func (x *Slot) GetDraining() bool
  • func (x *Slot) GetEnabled() bool
  • func (x *Slot) GetId() string
  • func (*Slot) ProtoMessage()
  • func (x *Slot) ProtoReflect() protoreflect.Message
  • func (x *Slot) Reset()
  • func (x *Slot) String() string

Variables

var File_determined_agent_v1_agent_proto protoreflect.FileDescriptor

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 */
	// This field has been deprecated and will be empty.
	Label string `protobuf:"bytes,5,opt,name=label,proto3" json:"label,omitempty"`
	// 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"`
	// contains filtered or unexported fields
}

Agent is a pool of resources where containers are run.

func (*Agent) Descriptor

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) GetLabel

func (x *Agent) GetLabel() string

func (*Agent) GetRegisteredTime

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

func (*Agent) GetResourcePools

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

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 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

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