Documentation
¶
Index ¶
- func NewBaseFileRepository(workPath string, collectorDir string, filesystem volumeFs) *baseFileRepository
- type EventFileRepository
- type LogFileRepository
- type NodeInfoRepository
- type Reader
- type SecretsFileRepository
- type SingleLogFileRepository
- type SystemStateFileRepository
- type VolumesFileRepository
- type ZipFileArchiveRepository
- func (z *ZipFileArchiveRepository) Create(ctx context.Context, id domain.SupportArchiveID, ...) (string, error)
- func (z *ZipFileArchiveRepository) Delete(ctx context.Context, id domain.SupportArchiveID) error
- func (z *ZipFileArchiveRepository) Exists(_ context.Context, id domain.SupportArchiveID) (bool, error)
- func (z *ZipFileArchiveRepository) List(_ context.Context) ([]domain.SupportArchiveID, error)
- type Zipper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBaseFileRepository ¶
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 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
func (v *SystemStateFileRepository) Create(ctx context.Context, id domain.SupportArchiveID, dataStream <-chan *domain.UnstructuredResource) error
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 (z *ZipFileArchiveRepository) Create(ctx context.Context, id domain.SupportArchiveID, streams map[domain.CollectorType]*domain.Stream) (string, error)
func (*ZipFileArchiveRepository) Delete ¶
func (z *ZipFileArchiveRepository) Delete(ctx context.Context, id domain.SupportArchiveID) error
func (*ZipFileArchiveRepository) Exists ¶
func (z *ZipFileArchiveRepository) Exists(_ context.Context, id domain.SupportArchiveID) (bool, error)
func (*ZipFileArchiveRepository) List ¶
func (z *ZipFileArchiveRepository) List(_ context.Context) ([]domain.SupportArchiveID, error)
Click to show internal directories.
Click to hide internal directories.