masterv1

package
v0.0.0-...-3511abf Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResourceAllocationAggregationPeriod_name = map[int32]string{
		0: "RESOURCE_ALLOCATION_AGGREGATION_PERIOD_UNSPECIFIED",
		1: "RESOURCE_ALLOCATION_AGGREGATION_PERIOD_DAILY",
		2: "RESOURCE_ALLOCATION_AGGREGATION_PERIOD_MONTHLY",
	}
	ResourceAllocationAggregationPeriod_value = map[string]int32{
		"RESOURCE_ALLOCATION_AGGREGATION_PERIOD_UNSPECIFIED": 0,
		"RESOURCE_ALLOCATION_AGGREGATION_PERIOD_DAILY":       1,
		"RESOURCE_ALLOCATION_AGGREGATION_PERIOD_MONTHLY":     2,
	}
)

Enum value maps for ResourceAllocationAggregationPeriod.

View Source 
var (
	ResourceAllocationAggregationType_name = map[int32]string{
		0: "RESOURCE_ALLOCATION_AGGREGATION_TYPE_UNSPECIFIED",
		1: "RESOURCE_ALLOCATION_AGGREGATION_TYPE_TOTAL",
		2: "RESOURCE_ALLOCATION_AGGREGATION_TYPE_USER",
		3: "RESOURCE_ALLOCATION_AGGREGATION_TYPE_LABEL",
	}
	ResourceAllocationAggregationType_value = map[string]int32{
		"RESOURCE_ALLOCATION_AGGREGATION_TYPE_UNSPECIFIED": 0,
		"RESOURCE_ALLOCATION_AGGREGATION_TYPE_TOTAL":       1,
		"RESOURCE_ALLOCATION_AGGREGATION_TYPE_USER":        2,
		"RESOURCE_ALLOCATION_AGGREGATION_TYPE_LABEL":       3,
	}
)

Enum value maps for ResourceAllocationAggregationType.

View Source 
var File_determined_master_v1_master_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Config 

type Config struct {

	// The log config to be patched into Master Config.
	Log *LogConfig `protobuf:"bytes,2,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

The config to be patched into Master Config.

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetLog 

func (x *Config) GetLog() *LogConfig

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type LogConfig 

type LogConfig struct {

	// The log level for Master Config.
	Level string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
	// The color setting for log in Master Config.
	Color bool `protobuf:"varint,2,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

The log config for Master Config

func (*LogConfig) Descriptor deprecated 

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

Deprecated: Use LogConfig.ProtoReflect.Descriptor instead.

func (*LogConfig) GetColor 

func (x *LogConfig) GetColor() bool

func (*LogConfig) GetLevel 

func (x *LogConfig) GetLevel() string

func (*LogConfig) ProtoMessage 

func (*LogConfig) ProtoMessage()

func (*LogConfig) ProtoReflect 

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

func (*LogConfig) Reset 

func (x *LogConfig) Reset()

func (*LogConfig) String 

func (x *LogConfig) String() string

type ResourceAllocationAggregatedEntry 

type ResourceAllocationAggregatedEntry struct {

	// The date of this entry.
	PeriodStart string `protobuf:"bytes,1,opt,name=period_start,json=periodStart,proto3" json:"period_start,omitempty"`
	// The period over which aggregation occurred.
	Period ResourceAllocationAggregationPeriod `` /* 128-byte string literal not displayed */
	// The total number of seconds included in this allocation entry.
	Seconds float32 `protobuf:"fixed32,3,opt,name=seconds,proto3" json:"seconds,omitempty"`
	// The seconds in the cluster used by experiments belonging to each user.
	ByUsername map[string]float32 `` /* 181-byte string literal not displayed */
	// The seconds in the cluster used by experiments labeled with each label.
	ByExperimentLabel map[string]float32 `` /* 204-byte string literal not displayed */
	// The seconds in the cluster used by experiments assigned to each resource
	// pool.
	ByResourcePool map[string]float32 `` /* 195-byte string literal not displayed */
	// This field has been deprecated and will be empty.
	ByAgentLabel map[string]float32 `` /* 189-byte string literal not displayed */
	// contains filtered or unexported fields
}

One instance of slots in the cluster being allocated to a task during a period (aggregated).

func (*ResourceAllocationAggregatedEntry) Descriptor deprecated 

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

Deprecated: Use ResourceAllocationAggregatedEntry.ProtoReflect.Descriptor instead.

func (*ResourceAllocationAggregatedEntry) GetByAgentLabel 

func (x *ResourceAllocationAggregatedEntry) GetByAgentLabel() map[string]float32

func (*ResourceAllocationAggregatedEntry) GetByExperimentLabel 

func (x *ResourceAllocationAggregatedEntry) GetByExperimentLabel() map[string]float32

func (*ResourceAllocationAggregatedEntry) GetByResourcePool 

func (x *ResourceAllocationAggregatedEntry) GetByResourcePool() map[string]float32

func (*ResourceAllocationAggregatedEntry) GetByUsername 

func (x *ResourceAllocationAggregatedEntry) GetByUsername() map[string]float32

func (*ResourceAllocationAggregatedEntry) GetPeriod 

func (x *ResourceAllocationAggregatedEntry) GetPeriod() ResourceAllocationAggregationPeriod

func (*ResourceAllocationAggregatedEntry) GetPeriodStart 

func (x *ResourceAllocationAggregatedEntry) GetPeriodStart() string

func (*ResourceAllocationAggregatedEntry) GetSeconds 

func (x *ResourceAllocationAggregatedEntry) GetSeconds() float32

func (*ResourceAllocationAggregatedEntry) ProtoMessage 

func (*ResourceAllocationAggregatedEntry) ProtoMessage()

func (*ResourceAllocationAggregatedEntry) ProtoReflect 

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

func (*ResourceAllocationAggregatedEntry) Reset 

func (x *ResourceAllocationAggregatedEntry) Reset()

func (*ResourceAllocationAggregatedEntry) String 

func (x *ResourceAllocationAggregatedEntry) String() string

type ResourceAllocationAggregationPeriod 

type ResourceAllocationAggregationPeriod int32

The period over which to perform aggregation. 

const (
	// Unspecified. This value will never actually be returned by the API, it is
	// just an artifact of using protobuf.
	ResourceAllocationAggregationPeriod_RESOURCE_ALLOCATION_AGGREGATION_PERIOD_UNSPECIFIED ResourceAllocationAggregationPeriod = 0
	// Aggregation by day.
	ResourceAllocationAggregationPeriod_RESOURCE_ALLOCATION_AGGREGATION_PERIOD_DAILY ResourceAllocationAggregationPeriod = 1
	// Aggregation by month.
	ResourceAllocationAggregationPeriod_RESOURCE_ALLOCATION_AGGREGATION_PERIOD_MONTHLY ResourceAllocationAggregationPeriod = 2
)

func (ResourceAllocationAggregationPeriod) Descriptor 

func (ResourceAllocationAggregationPeriod) Descriptor() protoreflect.EnumDescriptor

func (ResourceAllocationAggregationPeriod) Enum 

func (x ResourceAllocationAggregationPeriod) Enum() *ResourceAllocationAggregationPeriod

func (ResourceAllocationAggregationPeriod) EnumDescriptor deprecated 

func (ResourceAllocationAggregationPeriod) EnumDescriptor() ([]byte, []int)

Deprecated: Use ResourceAllocationAggregationPeriod.Descriptor instead.

func (ResourceAllocationAggregationPeriod) Number 

func (x ResourceAllocationAggregationPeriod) Number() protoreflect.EnumNumber

func (ResourceAllocationAggregationPeriod) String 

func (x ResourceAllocationAggregationPeriod) String() string

func (ResourceAllocationAggregationPeriod) Type 

func (ResourceAllocationAggregationPeriod) Type() protoreflect.EnumType

type ResourceAllocationAggregationType 

type ResourceAllocationAggregationType int32

A type of aggregation performed on allocation values. 

const (
	// Unspecified. This value will never actually be returned by the API, it is
	// just an artifact of using protobuf.
	ResourceAllocationAggregationType_RESOURCE_ALLOCATION_AGGREGATION_TYPE_UNSPECIFIED ResourceAllocationAggregationType = 0
	// Aggregation by days only.
	ResourceAllocationAggregationType_RESOURCE_ALLOCATION_AGGREGATION_TYPE_TOTAL ResourceAllocationAggregationType = 1
	// Aggregation by owner within each day.
	ResourceAllocationAggregationType_RESOURCE_ALLOCATION_AGGREGATION_TYPE_USER ResourceAllocationAggregationType = 2
	// Aggregation by experiment labels within each day.
	ResourceAllocationAggregationType_RESOURCE_ALLOCATION_AGGREGATION_TYPE_LABEL ResourceAllocationAggregationType = 3
)

func (ResourceAllocationAggregationType) Descriptor 

func (ResourceAllocationAggregationType) Descriptor() protoreflect.EnumDescriptor

func (ResourceAllocationAggregationType) Enum 

func (x ResourceAllocationAggregationType) Enum() *ResourceAllocationAggregationType

func (ResourceAllocationAggregationType) EnumDescriptor deprecated 

func (ResourceAllocationAggregationType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ResourceAllocationAggregationType.Descriptor instead.

func (ResourceAllocationAggregationType) Number 

func (x ResourceAllocationAggregationType) Number() protoreflect.EnumNumber

func (ResourceAllocationAggregationType) String 

func (x ResourceAllocationAggregationType) String() string

func (ResourceAllocationAggregationType) Type 

func (ResourceAllocationAggregationType) Type() protoreflect.EnumType

type ResourceAllocationRawEntry 

type ResourceAllocationRawEntry struct {

	// The kind of workload being run during this allocation (training,
	// checkpoint, or validation).
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// The time at which the allocation began.
	StartTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The time at which the allocation ended.
	EndTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The ID of the experiment the allocation is a part of.
	ExperimentId int32 `protobuf:"varint,4,opt,name=experiment_id,json=experimentId,proto3" json:"experiment_id,omitempty"`
	// The username of the user who ran the experiment.
	Username string `protobuf:"bytes,5,opt,name=username,proto3" json:"username,omitempty"`
	// The username of the user who ran the experiment.
	UserId int32 `protobuf:"varint,9,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// The labels assigned to the experiment.
	Labels []string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"`
	// The number of seconds for which the allocation was active during the
	// requested period.
	Seconds float32 `protobuf:"fixed32,7,opt,name=seconds,proto3" json:"seconds,omitempty"`
	// The number of slots used by the allocation.
	Slots int32 `protobuf:"varint,8,opt,name=slots,proto3" json:"slots,omitempty"`
	// contains filtered or unexported fields
}

One instance of slots in the cluster being allocated to a task.

func (*ResourceAllocationRawEntry) Descriptor deprecated 

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

Deprecated: Use ResourceAllocationRawEntry.ProtoReflect.Descriptor instead.

func (*ResourceAllocationRawEntry) GetEndTime 

func (x *ResourceAllocationRawEntry) GetEndTime() *timestamp.Timestamp

func (*ResourceAllocationRawEntry) GetExperimentId 

func (x *ResourceAllocationRawEntry) GetExperimentId() int32

func (*ResourceAllocationRawEntry) GetKind 

func (x *ResourceAllocationRawEntry) GetKind() string

func (*ResourceAllocationRawEntry) GetLabels 

func (x *ResourceAllocationRawEntry) GetLabels() []string

func (*ResourceAllocationRawEntry) GetSeconds 

func (x *ResourceAllocationRawEntry) GetSeconds() float32

func (*ResourceAllocationRawEntry) GetSlots 

func (x *ResourceAllocationRawEntry) GetSlots() int32

func (*ResourceAllocationRawEntry) GetStartTime 

func (x *ResourceAllocationRawEntry) GetStartTime() *timestamp.Timestamp

func (*ResourceAllocationRawEntry) GetUserId 

func (x *ResourceAllocationRawEntry) GetUserId() int32

func (*ResourceAllocationRawEntry) GetUsername 

func (x *ResourceAllocationRawEntry) GetUsername() string

func (*ResourceAllocationRawEntry) ProtoMessage 

func (*ResourceAllocationRawEntry) ProtoMessage()

func (*ResourceAllocationRawEntry) ProtoReflect 

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

func (*ResourceAllocationRawEntry) Reset 

func (x *ResourceAllocationRawEntry) Reset()

func (*ResourceAllocationRawEntry) String 

func (x *ResourceAllocationRawEntry) 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.