schema

package

Go to main page

Versions in this module

v1

v1.4.4

Apr 24, 2025

Changes in this version

+ type ScopedJobStats map[string]map[MetricScope][]*ScopedStats

+ type ScopedStats struct

+ Data *MetricStatistics

+ Hostname string

+ Id *string

v1.4.3

Mar 14, 2025

Changes in this version

type JobData

+ func (jd *JobData) RoundMetricStats()

type Topology

+ func (topo *Topology) GetAcceleratorIDsAsInt() ([]int, error)

+ func (topo *Topology) GetSocketsFromCores(cores []int) (sockets []int, exclusive bool)

v1.4.2

Dec 19, 2024

v1.4.1

Dec 10, 2024

v1.4.0

Dec 5, 2024

Changes in this version

type BaseJob

+ Energy float64

+ EnergyFootprint map[string]float64

+ Footprint map[string]float64

+ RawEnergyFootprint []byte

+ RawFootprint []byte

+ type ClusterSupport struct

+ Cluster string

+ SubClusters []string

+ type CronFrequency struct

+ DurationWorker string

+ FootprintWorker string

+ type GlobalMetricListItem struct

+ Availability []ClusterSupport

+ Footprint string

+ Name string

+ Scope MetricScope

+ Unit Unit

type JWTAuthConfig

+ UpdateUserOnLogin bool

type MetricConfig

+ Energy string

+ Footprint string

+ LowerIsBetter bool

type OpenIDConfig

+ UpdateUserOnLogin bool

type ProgramConfig

+ CronFrequency *CronFrequency

+ EmissionConstant int

+ EnableResampling *ResampleConfig

+ type ResampleConfig struct

+ Resolutions []int

+ Trigger int

type StatsSeries

+ Median []Float

type SubCluster

+ EnergyFootprint []string

+ Footprint []string

+ MetricConfig []MetricConfig

type SubClusterConfig

+ Energy string

+ Footprint string

+ LowerIsBetter bool

type Tag

+ Scope string

type TimeRange

+ Range string

v1.3.1

Jun 22, 2024

v1.3.0

Apr 15, 2024

Changes in this version

type AuthSource

+ const AuthViaOIDC

+ type OpenIDConfig struct

+ Provider string

+ SyncUserOnLogin bool

type ProgramConfig

+ OpenIDConfig *OpenIDConfig

v1.2.2

Sep 15, 2023

v1.2.1

Sep 7, 2023

v1.2.0

Sep 5, 2023

Changes in this version

+ func GetRoleString(roleInt Role) string

+ func GetValidRoles(user *User) ([]string, error)

+ func GetValidRolesMap(user *User) (map[string]Role, error)

+ func IsValidRole(role string) bool

+ type AuthSource int

+ const AuthViaAll

+ const AuthViaLDAP

+ const AuthViaLocalPassword

+ const AuthViaToken

+ type AuthType int

+ const AuthSession

+ const AuthToken

type JWTAuthConfig

+ SyncUserOnLogin bool

+ TrustedIssuer string

+ ValidateUser bool

type LdapConfig

+ SyncUserOnLogin bool

+ UserAttr string

type ProgramConfig

+ ApiAllowedIPs []string

+ type Role int

+ const RoleAdmin

+ const RoleAnonymous

+ const RoleApi

+ const RoleError

+ const RoleManager

+ const RoleSupport

+ const RoleUser

+ type User struct

+ AuthSource AuthSource

+ AuthType AuthType

+ Email string

+ Name string

+ Password string

+ Projects []string

+ Roles []string

+ Username string

+ func (u *User) GetAuthLevel() Role

+ func (u *User) HasAllRoles(queryroles []Role) bool

+ func (u *User) HasAnyRole(queryroles []Role) bool

+ func (u *User) HasNotRoles(queryroles []Role) bool

+ func (u *User) HasProject(project string) bool

+ func (u *User) HasRole(role Role) bool

+ func (u *User) HasValidRole(role string) (hasRole bool, isValid bool)

v1.1.0

Jul 20, 2023

v1.0.0

Jul 3, 2023

Changes in this version

+ const MonitoringStatusArchivingFailed

+ const MonitoringStatusArchivingSuccessful

+ const MonitoringStatusDisabled

+ const MonitoringStatusRunningOrArchiving

+ func ConvertFloatToFloat64(s []Float) []float64

+ func Validate(k Kind, r io.Reader) (err error)

+ type Accelerator struct

+ ID string

+ Model string

+ Type string

+ type BaseJob struct

+ ArrayJobId int64

+ Cluster string

+ ConcurrentJobs JobLinkResultList

+ Duration int32

+ Exclusive int32

+ JobID int64

+ MetaData map[string]string

+ MonitoringStatus int32

+ NumAcc int32

+ NumHWThreads int32

+ NumNodes int32

+ Partition string

+ Project string

+ RawMetaData []byte

+ RawResources []byte

+ Resources []*Resource

+ SMT int32

+ State JobState

+ SubCluster string

+ Tags []*Tag

+ User string

+ Walltime int64

+ var JobDefaults BaseJob = BaseJob{ ... }

+ type Cluster struct

+ MetricConfig []*MetricConfig

+ Name string

+ SubClusters []*SubCluster

+ type ClusterConfig struct

+ FilterRanges *FilterRanges

+ MetricDataRepository json.RawMessage

+ Name string

+ type FilterRanges struct

+ Duration *IntRange

+ NumNodes *IntRange

+ StartTime *TimeRange

+ type Float float64

+ var NaN Float = Float(math.NaN())

+ func GetFloat64ToFloat(s []float64) []Float

+ func (f *Float) UnmarshalGQL(v interface{}) error

+ func (f *Float) UnmarshalJSON(input []byte) error

+ func (f Float) IsNaN() bool

+ func (f Float) MarshalGQL(w io.Writer)

+ func (f Float) MarshalJSON() ([]byte, error)

+ type IntRange struct

+ From int

+ To int

+ type JWTAuthConfig struct

+ CookieName string

+ ForceJWTValidationViaDatabase bool

+ MaxAge int64

+ TrustedExternalIssuer string

+ type Job struct

+ FileBwAvg float64

+ FileDataVolTotal float64

+ FlopsAnyAvg float64

+ ID int64

+ LoadAvg float64

+ MemBwAvg float64

+ MemUsedMax float64

+ NetBwAvg float64

+ NetDataVolTotal float64

+ StartTime time.Time

+ StartTimeUnix int64

+ type JobData map[string]map[MetricScope]*JobMetric

+ func (jd *JobData) AddNodeScope(metric string) bool

+ func (jd *JobData) Size() int

+ type JobLink struct

+ ID int64

+ JobID int64

+ type JobLinkResultList struct

+ Count int

+ Items []*JobLink

+ type JobMeta struct

+ ID *int64

+ StartTime int64

+ Statistics map[string]JobStatistics

+ type JobMetric struct

+ Series []Series

+ StatisticsSeries *StatsSeries

+ Timestep int

+ Unit Unit

+ func (jm *JobMetric) AddPercentiles(ps []int) bool

+ func (jm *JobMetric) AddStatisticsSeries()

+ type JobState string

+ const JobStateCancelled

+ const JobStateCompleted

+ const JobStateFailed

+ const JobStateOutOfMemory

+ const JobStatePreempted

+ const JobStateRunning

+ const JobStateStopped

+ const JobStateTimeout

+ func (e *JobState) UnmarshalGQL(v interface{}) error

+ func (e JobState) MarshalGQL(w io.Writer)

+ func (e JobState) Valid() bool

+ type JobStatistics struct

+ Avg float64

+ Max float64

+ Min float64

+ Unit Unit

+ type Kind int

+ const ClusterCfg

+ const Config

+ const Data

+ const Meta

+ type LdapConfig struct

+ SearchDN string

+ SyncDelOldUsers bool

+ SyncInterval string

+ Url string

+ UserBase string

+ UserBind string

+ UserFilter string

+ type MetricConfig struct

+ Aggregation string

+ Alert float64

+ Caution float64

+ Name string

+ Normal float64

+ Peak float64

+ Scope MetricScope

+ SubClusters []*SubClusterConfig

+ Timestep int

+ Unit Unit

+ type MetricScope string

+ const MetricScopeAccelerator

+ const MetricScopeCore

+ const MetricScopeHWThread

+ const MetricScopeInvalid

+ const MetricScopeMemoryDomain

+ const MetricScopeNode

+ const MetricScopeSocket

+ func (e *MetricScope) LT(other MetricScope) bool

+ func (e *MetricScope) LTE(other MetricScope) bool

+ func (e *MetricScope) Max(other MetricScope) MetricScope

+ func (e *MetricScope) UnmarshalGQL(v interface{}) error

+ func (e MetricScope) MarshalGQL(w io.Writer)

+ func (e MetricScope) Valid() bool

+ type MetricStatistics struct

+ Avg float64

+ Max float64

+ Min float64

+ type MetricValue struct

+ Unit Unit

+ Value float64

+ type ProgramConfig struct

+ Addr string

+ Archive json.RawMessage

+ Clusters []*ClusterConfig

+ DB string

+ DBDriver string

+ DisableArchive bool

+ DisableAuthentication bool

+ EmbedStaticFiles bool

+ Group string

+ HttpsCertFile string

+ HttpsKeyFile string

+ JwtConfig *JWTAuthConfig

+ LdapConfig *LdapConfig

+ MachineStateDir string

+ RedirectHttpTo string

+ SessionMaxAge string

+ ShortRunningJobsDuration int

+ StaticFiles string

+ StopJobsExceedingWalltime int

+ UiDefaults map[string]interface{}

+ User string

+ Validate bool

+ type Resource struct

+ Accelerators []string

+ Configuration string

+ HWThreads []int

+ Hostname string

+ type Retention struct

+ Age int

+ IncludeDB bool

+ Location string

+ Policy string

+ type Series struct

+ Data []Float

+ Hostname string

+ Id *string

+ Statistics MetricStatistics

+ func (s *Series) MarshalJSON() ([]byte, error)

+ type StatsSeries struct

+ Max []Float

+ Mean []Float

+ Min []Float

+ Percentiles map[int][]Float

+ type SubCluster struct

+ CoresPerSocket int

+ FlopRateScalar MetricValue

+ FlopRateSimd MetricValue

+ MemoryBandwidth MetricValue

+ Name string

+ Nodes string

+ ProcessorType string

+ SocketsPerNode int

+ ThreadsPerCore int

+ Topology Topology

+ type SubClusterConfig struct

+ Alert float64

+ Caution float64

+ Name string

+ Normal float64

+ Peak float64

+ Remove bool

+ type Tag struct

+ ID int64

+ Name string

+ Type string

+ type TimeRange struct

+ From *time.Time

+ To *time.Time

+ type Topology struct

+ Accelerators []*Accelerator

+ Core [][]int

+ Die [][]*int

+ MemoryDomain [][]int

+ Node []int

+ Socket [][]int

+ func (topo *Topology) GetAcceleratorID(id int) (string, error)

+ func (topo *Topology) GetAcceleratorIDs() ([]int, error)

+ func (topo *Topology) GetCoresFromHWThreads(hwthreads []int) (cores []int, exclusive bool)

+ func (topo *Topology) GetMemoryDomainsFromHWThreads(hwthreads []int) (memDoms []int, exclusive bool)

+ func (topo *Topology) GetSocketsFromHWThreads(hwthreads []int) (sockets []int, exclusive bool)

+ type Unit struct

+ Base string

+ Prefix string

v1.0.0-rc.1

Jun 15, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL