Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

archive

package

Go to main page

Versions in this module

v1

v1.3.1

Jun 22, 2024

v1.3.0

Apr 15, 2024

Changes in this version

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

v1.2.2

Sep 15, 2023

v1.2.1

Sep 7, 2023

v1.2.0

Sep 5, 2023

v1.1.0

Jul 20, 2023

v1.0.0

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

v1.0.0-rc.1

Jun 15, 2023