archive

Mar 6, 2026

Changes in this version

+ var GlobalUserMetricList []*schema.GlobalMetricListItem

+ func EncodeCluster(w io.Writer, c *schema.Cluster) error

+ func GetMetricConfigSubCluster(cluster, subcluster string) map[string]*schema.Metric

type ArchiveBackend

+ func InitBackend(rawConfig json.RawMessage) (ArchiveBackend, error)

+ StoreClusterCfg func(name string, config *schema.Cluster) error

type FsArchive

+ func (fsa *FsArchive) StoreClusterCfg(name string, config *schema.Cluster) error

type S3Archive

+ func (s3a *S3Archive) Clean(before int64, after int64)

+ func (s3a *S3Archive) CleanUp(jobs []*schema.Job)

+ func (s3a *S3Archive) Compress(jobs []*schema.Job)

+ func (s3a *S3Archive) CompressLast(starttime int64) int64

+ func (s3a *S3Archive) Exists(job *schema.Job) bool

+ func (s3a *S3Archive) GetClusters() []string

+ func (s3a *S3Archive) ImportJob(jobMeta *schema.Job, jobData *schema.JobData) error

+ func (s3a *S3Archive) Info()

+ func (s3a *S3Archive) Init(rawConfig json.RawMessage) (uint64, error)

+ func (s3a *S3Archive) Iter(loadMetricData bool) <-chan JobContainer

+ func (s3a *S3Archive) LoadClusterCfg(name string) (*schema.Cluster, error)

+ func (s3a *S3Archive) LoadJobData(job *schema.Job) (schema.JobData, error)

+ func (s3a *S3Archive) LoadJobMeta(job *schema.Job) (*schema.Job, error)

+ func (s3a *S3Archive) LoadJobStats(job *schema.Job) (schema.ScopedJobStats, error)

+ func (s3a *S3Archive) Move(jobs []*schema.Job, targetPath string)

+ func (s3a *S3Archive) StoreClusterCfg(name string, config *schema.Cluster) error

+ func (s3a *S3Archive) StoreJobMeta(job *schema.Job) error

type S3ArchiveConfig

+ AccessKey string

+ Bucket string

+ Endpoint string

+ Region string

+ SecretKey string

+ UsePathStyle bool

+ type SqliteArchive struct

+ func (sa *SqliteArchive) Clean(before int64, after int64)

+ func (sa *SqliteArchive) CleanUp(jobs []*schema.Job)

+ func (sa *SqliteArchive) Compress(jobs []*schema.Job)

+ func (sa *SqliteArchive) CompressLast(starttime int64) int64

+ func (sa *SqliteArchive) Exists(job *schema.Job) bool

+ func (sa *SqliteArchive) GetClusters() []string

+ func (sa *SqliteArchive) ImportJob(jobMeta *schema.Job, jobData *schema.JobData) error

+ func (sa *SqliteArchive) Info()

+ func (sa *SqliteArchive) Init(rawConfig json.RawMessage) (uint64, error)

+ func (sa *SqliteArchive) Iter(loadMetricData bool) <-chan JobContainer

+ func (sa *SqliteArchive) LoadClusterCfg(name string) (*schema.Cluster, error)

+ func (sa *SqliteArchive) LoadJobData(job *schema.Job) (schema.JobData, error)

+ func (sa *SqliteArchive) LoadJobMeta(job *schema.Job) (*schema.Job, error)

+ func (sa *SqliteArchive) LoadJobStats(job *schema.Job) (schema.ScopedJobStats, error)

+ func (sa *SqliteArchive) Move(jobs []*schema.Job, targetPath string)

+ func (sa *SqliteArchive) StoreClusterCfg(name string, config *schema.Cluster) error

+ func (sa *SqliteArchive) StoreJobMeta(job *schema.Job) error

+ type SqliteArchiveConfig struct

+ DBPath string

Apr 24, 2025

Changes in this version

+ func DecodeJobStats(r io.Reader, k string) (schema.ScopedJobStats, error)

+ func LoadScopedStatsFromArchive(job *schema.Job, metrics []string, scopes []schema.MetricScope) (schema.ScopedJobStats, error)

type ArchiveBackend

+ LoadJobStats func(job *schema.Job) (schema.ScopedJobStats, error)

type FsArchive

+ func (fsa *FsArchive) LoadJobStats(job *schema.Job) (schema.ScopedJobStats, error)

Mar 14, 2025

Changes in this version

+ var NodeLists map[string]map[string]NodeList

+ func LoadStatsFromArchive(job *schema.Job, metrics []string) (map[string]schema.MetricStatistics, error)

Dec 5, 2024

Changes in this version

+ var GlobalMetricList []*schema.GlobalMetricListItem

+ func MetricIndex(mc []schema.MetricConfig, name string) (int, error)

Apr 15, 2024

Changes in this version

+ func UpdateMetadata(job *schema.Job, metadata map[string]string) error

Jul 3, 2023

Changes in this version

+ const Version

+ var Clusters []*schema.Cluster

+ func AssignSubCluster(job *schema.BaseJob) error

+ func DecodeCluster(r io.Reader) (*schema.Cluster, error)

+ func DecodeJobData(r io.Reader, k string) (schema.JobData, error)

+ func DecodeJobMeta(r io.Reader) (*schema.JobMeta, error)

+ func EncodeJobData(w io.Writer, d *schema.JobData) error

+ func EncodeJobMeta(w io.Writer, d *schema.JobMeta) error

+ func GetCluster(cluster string) *schema.Cluster

+ func GetMetricConfig(cluster, metric string) *schema.MetricConfig

+ func GetStatistics(job *schema.Job) (map[string]schema.JobStatistics, error)

+ func GetSubCluster(cluster, subcluster string) (*schema.SubCluster, error)

+ func GetSubClusterByNode(cluster, hostname string) (string, error)

+ func Init(rawConfig json.RawMessage, disableArchive bool) error

+ func LoadAveragesFromArchive(job *schema.Job, metrics []string, data [][]schema.Float) error

+ func UpdateTags(job *schema.Job, tags []*schema.Tag) error

+ type ArchiveBackend interface

+ Clean func(before int64, after int64)

+ CleanUp func(jobs []*schema.Job)

+ Compress func(jobs []*schema.Job)

+ CompressLast func(starttime int64) int64

+ Exists func(job *schema.Job) bool

+ GetClusters func() []string

+ ImportJob func(jobMeta *schema.JobMeta, jobData *schema.JobData) error

+ Info func()

+ Init func(rawConfig json.RawMessage) (uint64, error)

+ Iter func(loadMetricData bool) <-chan JobContainer

+ LoadClusterCfg func(name string) (*schema.Cluster, error)

+ LoadJobData func(job *schema.Job) (schema.JobData, error)

+ LoadJobMeta func(job *schema.Job) (*schema.JobMeta, error)

+ Move func(jobs []*schema.Job, path string)

+ StoreJobMeta func(jobMeta *schema.JobMeta) error

+ func GetHandle() ArchiveBackend

+ type FsArchive struct

+ func (fsa *FsArchive) Clean(before int64, after int64)

+ func (fsa *FsArchive) CleanUp(jobs []*schema.Job)

+ func (fsa *FsArchive) Compress(jobs []*schema.Job)

+ func (fsa *FsArchive) CompressLast(starttime int64) int64

+ func (fsa *FsArchive) Exists(job *schema.Job) bool

+ func (fsa *FsArchive) GetClusters() []string

+ func (fsa *FsArchive) ImportJob(jobMeta *schema.JobMeta, jobData *schema.JobData) error

+ func (fsa *FsArchive) Info()

+ func (fsa *FsArchive) Init(rawConfig json.RawMessage) (uint64, error)

+ func (fsa *FsArchive) Iter(loadMetricData bool) <-chan JobContainer

+ func (fsa *FsArchive) LoadClusterCfg(name string) (*schema.Cluster, error)

+ func (fsa *FsArchive) LoadJobData(job *schema.Job) (schema.JobData, error)

+ func (fsa *FsArchive) LoadJobMeta(job *schema.Job) (*schema.JobMeta, error)

+ func (fsa *FsArchive) Move(jobs []*schema.Job, path string)

+ func (fsa *FsArchive) StoreJobMeta(jobMeta *schema.JobMeta) error

+ type FsArchiveConfig struct

+ Path string

+ type JobContainer struct

+ Data *schema.JobData

+ Meta *schema.JobMeta

+ type NLExprIntRange struct

+ type NLExprIntRanges []NLExprIntRange

+ type NLExprString string

+ type NodeList [][]interface

+ func (nl *NodeList) Contains(name string) bool

+ func (nl *NodeList) NodeCount() int

+ func (nl *NodeList) PrintList() []string

+ func ParseNodeList(raw string) (NodeList, error)

+ type S3Archive struct

+ type S3ArchiveConfig struct

+ Path string