file

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 6, 2026 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBaseFileRepository

func NewBaseFileRepository(workPath string, collectorDir string, filesystem volumeFs) *baseFileRepository

Types

type EventFileRepository added in v1.0.0

type EventFileRepository struct {
	*SingleLogFileRepository
}

type LogFileRepository

type LogFileRepository struct {
	*SingleLogFileRepository
}

func NewEventFileRepository added in v1.0.0

func NewEventFileRepository(workPath string, fs volumeFs) *LogFileRepository

func NewLogFileRepository

func NewLogFileRepository(workPath string, fs volumeFs) *LogFileRepository

type NodeInfoRepository added in v1.0.0

type NodeInfoRepository struct {
	// contains filtered or unexported fields
}

func NewNodeInfoFileRepository added in v1.0.0

func NewNodeInfoFileRepository(workPath string, fs volumeFs) *NodeInfoRepository

func (*NodeInfoRepository) Create added in v1.0.0

func (v *NodeInfoRepository) Create(ctx context.Context, id domain.SupportArchiveID, dataStream <-chan *domain.LabeledSample) error

type Reader

type Reader interface {
	io.Reader
}

type SecretsFileRepository added in v1.0.0

type SecretsFileRepository struct {
	// contains filtered or unexported fields
}

func NewSecretsFileRepository added in v1.0.0

func NewSecretsFileRepository(workPath string, fs secretFs) *SecretsFileRepository

func (*SecretsFileRepository) Create added in v1.0.0

func (v *SecretsFileRepository) Create(ctx context.Context, id domain.SupportArchiveID, dataStream <-chan *domain.SecretYaml) error

type SingleLogFileRepository added in v1.0.0

type SingleLogFileRepository struct {
	// contains filtered or unexported fields
}

func NewSingleLogFileRepository added in v1.0.0

func NewSingleLogFileRepository(workPath, dirname string, fs volumeFs) *SingleLogFileRepository

func (*SingleLogFileRepository) Create added in v1.0.0

func (l *SingleLogFileRepository) Create(ctx context.Context, id domain.SupportArchiveID, dataStream <-chan *domain.LogLine) error

type SystemStateFileRepository added in v1.0.0

type SystemStateFileRepository struct {
	// contains filtered or unexported fields
}

func NewSystemStateFileRepository added in v1.0.0

func NewSystemStateFileRepository(workPath string, fs volumeFs) *SystemStateFileRepository

func (*SystemStateFileRepository) Create added in v1.0.0

type VolumesFileRepository

type VolumesFileRepository struct {
	// contains filtered or unexported fields
}

func NewVolumesFileRepository

func NewVolumesFileRepository(workPath string, fs volumeFs) *VolumesFileRepository

func (*VolumesFileRepository) Create

func (v *VolumesFileRepository) Create(ctx context.Context, id domain.SupportArchiveID, dataStream <-chan *domain.VolumeInfo) error

type ZipFileArchiveRepository

type ZipFileArchiveRepository struct {
	// contains filtered or unexported fields
}

func NewZipFileArchiveRepository

func NewZipFileArchiveRepository(archivesPath string, zipCreator zipCreator, config *config.OperatorConfig) *ZipFileArchiveRepository

func (*ZipFileArchiveRepository) Create

func (*ZipFileArchiveRepository) Delete

func (*ZipFileArchiveRepository) Exists

func (*ZipFileArchiveRepository) List

type Zipper

type Zipper interface {
	Close() error
	Create(name string) (io.Writer, error)
}

func NewZipWriter

func NewZipWriter(w io.Writer) Zipper

Jump to

Keyboard shortcuts

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