schema

package

Go to main page

Versions in this module

v1

v1.0.2

Dec 18, 2025

Changes in this version

type GlobalMetricListItem

+ Restrict bool

v1.0.1

Dec 18, 2025

Changes in this version

type MetricConfig

+ Restrict bool

type SubClusterConfig

+ Restrict bool

v1.0.0

Dec 15, 2025

v0

v0.11.0

Dec 4, 2025

v0.10.2

Dec 4, 2025

v0.10.1

Oct 16, 2025

Changes in this version

type Job

+ ArrayJobID int64

v0.10.0

Oct 15, 2025

Changes in this version

+ type NodeDB struct

+ Cluster string

+ Hostname string

+ ID int64

+ RawMetaData []byte

+ SubCluster string

+ type NodePayload struct

+ CpusAllocated int

+ GpusAllocated int

+ Hostname string

+ JobsRunning int

+ MemoryAllocated int

+ States []string

+ type NodeStateDB struct

+ CpusAllocated int

+ GpusAllocated int

+ HealthState MonitoringState

+ ID int64

+ JobsRunning int

+ MemoryAllocated int

+ NodeID int64

+ NodeState SchedulerState

+ TimeStamp int64

v0.9.1

Oct 1, 2025

v0.9.0

Oct 1, 2025

Changes in this version

type NodeState

+ CpusAllocated int

+ GpusAllocated int

+ HealthState MonitoringState

+ ID int64

+ JobsRunning int64

+ MemoryAllocated int

+ NodeID int64

+ NodeState SchedulerState

+ TimeStamp int64

+ type SchedulerState string

v0.8.0

Sep 9, 2025

Changes in this version

type Float

+ func ConvertToFloat(input float64) Float

+ func (f Float) Double() float64

+ type FloatArray []Float

v0.7.0

Aug 5, 2025

Changes in this version

type Job

+ Shared string

v0.6.0

Jul 25, 2025

Changes in this version

type Job

+ SubmitTime int64

type JobState

+ const JobStateBootFail

+ const JobStateDeadline

+ const JobStateNodeFail

+ const JobStatePending

+ const JobStateSuspended

type Node

+ JobsRunning int64

+ TimeStamp int64

v0.5.0

Jul 2, 2025

v0.4.0

Jul 2, 2025

v0.3.1

Jul 1, 2025

v0.3.0

Jun 30, 2025

Changes in this version

type CronFrequency

+ CommitJobWorker string

type Job

+ ArrayJobId int64

+ Cluster string

+ ConcurrentJobs JobLinkResultList

+ Duration int32

+ Energy float64

+ EnergyFootprint map[string]float64

+ Exclusive int32

+ Footprint map[string]float64

+ JobID int64

+ MetaData map[string]string

+ MonitoringStatus int32

+ NumAcc int32

+ NumHWThreads int32

+ NumNodes int32

+ Partition string

+ Project string

+ RawEnergyFootprint []byte

+ RawFootprint []byte

+ RawMetaData []byte

+ RawResources []byte

+ RequestedMemory int64

+ Resources []*Resource

+ SMT int32

+ State JobState

+ Statistics map[string]JobStatistics

+ SubCluster string

+ Tags []*Tag

+ User string

+ Walltime int64

+ func (j Job) GoString() string

type JobData

+ func (jd *JobData) RoundMetricStats()

+ type Metric struct

+ Alert float64

+ Caution float64

+ Name string

+ Normal float64

+ Peak float64

+ Unit Unit

+ type MonitoringState string

+ const MonitoringStateFailed

+ const MonitoringStateFull

+ const MonitoringStatePartial

+ type Node struct

+ Cluster string

+ CpusAllocated int

+ CpusTotal int

+ GpusAllocated int

+ GpusTotal int

+ HealthState MonitoringState

+ Hostname string

+ ID int64

+ MemoryAllocated int

+ MemoryTotal int

+ MetaData map[string]string

+ NodeState NodeState

+ RawMetaData []byte

+ SubCluster string

+ type NodeState string

+ const NodeStateAllocated

+ const NodeStateDown

+ const NodeStateIdle

+ const NodeStateMixed

+ const NodeStateReserved

+ const NodeStateUnknown

type ProgramConfig

+ EnableJobTaggers bool

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

+ type ScopedStats struct

+ Data *MetricStatistics

+ Hostname string

+ Id *string

type Topology

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

v0.2.0

Apr 24, 2025

v0.1.1

Mar 18, 2025

Changes in this version

+ const MonitoringStatusArchivingFailed

+ const MonitoringStatusArchivingSuccessful

+ const MonitoringStatusDisabled

+ const MonitoringStatusRunningOrArchiving

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

+ func GetRoleString(roleInt Role) string

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

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

+ func IsValidRole(role string) bool

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

+ type Accelerator struct

+ ID string

+ Model string

+ Type string

+ type AuthSource int

+ const AuthViaAll

+ const AuthViaLDAP

+ const AuthViaLocalPassword

+ const AuthViaOIDC

+ const AuthViaToken

+ type AuthType int

+ const AuthSession

+ const AuthToken

+ type BaseJob struct

+ ArrayJobId int64

+ Cluster string

+ ConcurrentJobs JobLinkResultList

+ Duration int32

+ Energy float64

+ EnergyFootprint map[string]float64

+ Exclusive int32

+ Footprint map[string]float64

+ JobID int64

+ MetaData map[string]string

+ MonitoringStatus int32

+ NumAcc int32

+ NumHWThreads int32

+ NumNodes int32

+ Partition string

+ Project string

+ RawEnergyFootprint []byte

+ RawFootprint []byte

+ 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 ClusterSupport struct

+ Cluster string

+ SubClusters []string

+ type CronFrequency struct

+ DurationWorker string

+ FootprintWorker 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 GlobalMetricListItem struct

+ Availability []ClusterSupport

+ Footprint string

+ Name string

+ Scope MetricScope

+ Unit Unit

+ type IntRange struct

+ From int

+ To int

+ type JWTAuthConfig struct

+ CookieName string

+ MaxAge string

+ SyncUserOnLogin bool

+ TrustedIssuer string

+ UpdateUserOnLogin bool

+ ValidateUser bool

+ type Job struct

+ ID int64

+ 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

+ SyncUserOnLogin bool

+ Url string

+ UserAttr string

+ UserBase string

+ UserBind string

+ UserFilter string

+ type MetricConfig struct

+ Aggregation string

+ Alert float64

+ Caution float64

+ Energy string

+ Footprint string

+ LowerIsBetter bool

+ 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 OpenIDConfig struct

+ Provider string

+ SyncUserOnLogin bool

+ UpdateUserOnLogin bool

+ type ProgramConfig struct

+ Addr string

+ ApiAllowedIPs []string

+ Archive json.RawMessage

+ Clusters []*ClusterConfig

+ CronFrequency *CronFrequency

+ DB string

+ DBDriver string

+ DisableArchive bool

+ DisableAuthentication bool

+ EmbedStaticFiles bool

+ EmissionConstant int

+ EnableResampling *ResampleConfig

+ Group string

+ HttpsCertFile string

+ HttpsKeyFile string

+ JwtConfig *JWTAuthConfig

+ LdapConfig *LdapConfig

+ MachineStateDir string

+ OpenIDConfig *OpenIDConfig

+ RedirectHttpTo string

+ SessionMaxAge string

+ ShortRunningJobsDuration int

+ StaticFiles string

+ StopJobsExceedingWalltime int

+ UiDefaults map[string]interface{}

+ User string

+ Validate bool

+ type ResampleConfig struct

+ Resolutions []int

+ Trigger int

+ type Resource struct

+ Accelerators []string

+ Configuration string

+ HWThreads []int

+ Hostname string

+ type Retention struct

+ Age int

+ IncludeDB bool

+ Location string

+ Policy string

+ type Role int

+ const RoleAdmin

+ const RoleAnonymous

+ const RoleApi

+ const RoleError

+ const RoleManager

+ const RoleSupport

+ const RoleUser

+ type Series struct

+ Data []Float

+ Hostname string

+ Id *string

+ Statistics MetricStatistics

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

+ type StatsSeries struct

+ Max []Float

+ Mean []Float

+ Median []Float

+ Min []Float

+ Percentiles map[int][]Float

+ type SubCluster struct

+ CoresPerSocket int

+ EnergyFootprint []string

+ FlopRateScalar MetricValue

+ FlopRateSimd MetricValue

+ Footprint []string

+ MemoryBandwidth MetricValue

+ MetricConfig []MetricConfig

+ Name string

+ Nodes string

+ ProcessorType string

+ SocketsPerNode int

+ ThreadsPerCore int

+ Topology Topology

+ type SubClusterConfig struct

+ Alert float64

+ Caution float64

+ Energy string

+ Footprint string

+ LowerIsBetter bool

+ Name string

+ Normal float64

+ Peak float64

+ Remove bool

+ type Tag struct

+ ID int64

+ Name string

+ Scope string

+ Type string

+ type TimeRange struct

+ From *time.Time

+ Range string

+ 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() []string

+ func (topo *Topology) GetAcceleratorIDsAsInt() ([]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

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

v0.1.0-beta.1

Feb 26, 2025

Other modules containing this package

github.com/ClusterCockpit/cc-lib/v2

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