Documentation
¶
Index ¶
- type DiskRecorder
- func (d *DiskRecorder) LastArchive() (*insightsclient.Source, error)
- func (d *DiskRecorder) Prune(olderThan time.Time) error
- func (d *DiskRecorder) Save(records record.MemoryRecords) (record.MemoryRecords, error)
- func (d *DiskRecorder) SaveAtPath(records record.MemoryRecords, path string) (record.MemoryRecords, error)
- func (d *DiskRecorder) Summary(_ context.Context, since time.Time) (*insightsclient.Source, bool, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DiskRecorder ¶
type DiskRecorder struct {
// contains filtered or unexported fields
}
func (*DiskRecorder) LastArchive ¶
func (d *DiskRecorder) LastArchive() (*insightsclient.Source, error)
LastArchive tries to find the latest Insights archive. Returns an error when it can't read the base directory or when it can't open the last archive found.
func (*DiskRecorder) Prune ¶
func (d *DiskRecorder) Prune(olderThan time.Time) error
Prune the archives older than given time
func (*DiskRecorder) Save ¶
func (d *DiskRecorder) Save(records record.MemoryRecords) (record.MemoryRecords, error)
Save the records into the archive in the directory at d.basePath
func (*DiskRecorder) SaveAtPath ¶
func (d *DiskRecorder) SaveAtPath(records record.MemoryRecords, path string) (record.MemoryRecords, error)
SaveAtPath the records into the archive at `path`
Source Files
Click to show internal directories.
Click to hide internal directories.