metadata

package

Go to main page

Versions in this module

v0

v0.14.2

Nov 14, 2023

v0.14.1

Oct 23, 2023

v0.14.0

Oct 13, 2023

v0.14.0-rc.0

Sep 29, 2023

v0.13.1

Oct 24, 2023

v0.13.0

Aug 11, 2023

Changes in this version

type Access

+ GetLatestVersions func(ctx context.Context) (map[string]bool, error)

+ type CorrectnessChecker struct

+ func NewCorrectnessChecker(cl client.Reader, access Access, opts dtcsi.CSIOptions) *CorrectnessChecker

+ func (checker *CorrectnessChecker) CorrectCSI(ctx context.Context) error

type FakeFailDB

+ func (f *FakeFailDB) GetLatestVersions(ctx context.Context) (map[string]bool, error)

type PathResolver

+ func (pr PathResolver) AgentSharedBinaryDirForAgent(versionOrDigest string) string

type SqliteAccess

+ func (access *SqliteAccess) GetLatestVersions(ctx context.Context) (map[string]bool, error)

v0.13.0-rc.1

Aug 8, 2023

v0.13.0-rc.0

Aug 2, 2023

v0.12.1

Jul 25, 2023

v0.12.0

Jun 22, 2023

v0.12.0-rc.2

Jun 14, 2023

v0.12.0-rc.1

Jun 6, 2023

v0.12.0-rc.0

Jun 6, 2023

v0.11.3

Jul 3, 2023

v0.11.2

May 17, 2023

v0.11.1

Apr 28, 2023

v0.11.0

Apr 17, 2023

v0.11.0-rc.0

Apr 11, 2023

v0.10.4

Mar 22, 2023

v0.10.3

Feb 27, 2023

v0.10.2

Jan 5, 2023

Changes in this version

type PathResolver

+ func (pr PathResolver) AgentTempUnzipRootDir() string

v0.10.1

Dec 15, 2022

v0.10.0

Nov 29, 2022

v0.9.2

Jan 9, 2023

v0.9.1

Oct 19, 2022

v0.9.0

Sep 28, 2022

Changes in this version

type Dynakube

+ MaxFailedMountAttempts int

type Volume

+ MountAttempts int

v0.8.2

Aug 30, 2022

v0.8.1

Aug 23, 2022

Changes in this version

type PathResolver

+ func (pr PathResolver) AgentTempUnzipDir() string

+ func (pr PathResolver) TenantDir(tenantUUID string) string

v0.8.0

Aug 8, 2022

Changes in this version

type Access

+ GetAllUsedVersions func() (map[string]bool, error)

+ GetUsedImageDigests func() (map[string]bool, error)

+ IsImageDigestUsed func(imageDigest string) (bool, error)

type Dynakube

+ ImageDigest string

type FakeFailDB

+ func (f *FakeFailDB) GetAllUsedVersions() (map[string]bool, error)

+ func (f *FakeFailDB) GetUsedImageDigests() (map[string]bool, error)

+ func (f *FakeFailDB) IsImageDigestUsed(imageDigest string) (bool, error)

type PathResolver

+ func (pr PathResolver) AgentConfigDir(tenantUUID string) string

+ func (pr PathResolver) AgentSharedBinaryDirBase() string

+ func (pr PathResolver) AgentSharedBinaryDirForImage(digest string) string

type SqliteAccess

+ func (access *SqliteAccess) GetAllUsedVersions() (map[string]bool, error)

+ func (access *SqliteAccess) GetUsedImageDigests() (map[string]bool, error)

+ func (access *SqliteAccess) IsImageDigestUsed(imageDigest string) (bool, error)

v0.7.3

Sep 6, 2022

v0.7.2

Jul 13, 2022

v0.7.1

Jul 5, 2022

v0.7.0

Jun 23, 2022

Changes in this version

type PathResolver

+ func (pr PathResolver) ImageCertPath(tenantUUID string) string

v0.6.0

May 5, 2022

Changes in this version

+ func LogAccessOverview(log logr.Logger, access Access)

type Access

+ GetAllDynakubes func() ([]*Dynakube, error)

+ GetAllOsAgentVolumes func() ([]*OsAgentVolume, error)

+ GetAllVolumes func() ([]*Volume, error)

+ GetTenantsToDynakubes func() (map[string]string, error)

+ type AccessOverview struct

+ Dynakubes []*Dynakube

+ OsAgentVolumes []*OsAgentVolume

+ Volumes []*Volume

+ func NewAccessOverview(access Access) (*AccessOverview, error)

type FakeFailDB

+ func (f *FakeFailDB) GetAllDynakubes() ([]*Dynakube, error)

+ func (f *FakeFailDB) GetAllOsAgentVolumes() ([]*OsAgentVolume, error)

+ func (f *FakeFailDB) GetAllVolumes() ([]*Volume, error)

+ func (f *FakeFailDB) GetTenantsToDynakubes() (map[string]string, error)

type SqliteAccess

+ func (a *SqliteAccess) GetAllDynakubes() ([]*Dynakube, error)

+ func (a *SqliteAccess) GetAllOsAgentVolumes() ([]*OsAgentVolume, error)

+ func (a *SqliteAccess) GetAllVolumes() ([]*Volume, error)

+ func (a *SqliteAccess) GetTenantsToDynakubes() (map[string]string, error)

v0.5.1

Apr 7, 2022

v0.5.0

Mar 14, 2022

Changes in this version

type Access

+ GetOsAgentVolumeViaTenantUUID func(volumeID string) (*OsAgentVolume, error)

+ GetOsAgentVolumeViaVolumeID func(volumeID string) (*OsAgentVolume, error)

+ InsertOsAgentVolume func(volume *OsAgentVolume) error

+ UpdateOsAgentVolume func(volume *OsAgentVolume) error

type FakeFailDB

+ func (f *FakeFailDB) GetOsAgentVolumeViaTenantUUID(volumeID string) (*OsAgentVolume, error)

+ func (f *FakeFailDB) GetOsAgentVolumeViaVolumeID(volumeID string) (*OsAgentVolume, error)

+ func (f *FakeFailDB) InsertOsAgentVolume(volume *OsAgentVolume) error

+ func (f *FakeFailDB) UpdateOsAgentVolume(volume *OsAgentVolume) error

+ type OsAgentVolume struct

+ LastModified *time.Time

+ Mounted bool

+ TenantUUID string

+ VolumeID string

+ func NewOsAgentVolume(volumeID, tenantUUID string, mounted bool, timeStamp *time.Time) *OsAgentVolume

type PathResolver

+ func (pr PathResolver) OsAgentDir(tenantUUID string) string

type SqliteAccess

+ func (a *SqliteAccess) GetOsAgentVolumeViaTenantUUID(tenantUUID string) (*OsAgentVolume, error)

+ func (a *SqliteAccess) GetOsAgentVolumeViaVolumeID(volumeID string) (*OsAgentVolume, error)

+ func (a *SqliteAccess) InsertOsAgentVolume(volume *OsAgentVolume) error

+ func (a *SqliteAccess) UpdateOsAgentVolume(volume *OsAgentVolume) error

v0.4.2

Feb 15, 2022

v0.4.1

Feb 1, 2022

v0.4.1-helm

Feb 1, 2022

v0.4.0

Jan 25, 2022

Changes in this version

+ func CorrectMetadata(cl client.Client, access Access) error

+ type Access interface

+ DeleteDynakube func(dynakubeName string) error

+ DeleteVolume func(volumeID string) error

+ GetDynakube func(dynakubeName string) (*Dynakube, error)

+ GetDynakubes func() (map[string]string, error)

+ GetPodNames func() (map[string]string, error)

+ GetUsedVersions func(tenantUUID string) (map[string]bool, error)

+ GetVolume func(volumeID string) (*Volume, error)

+ InsertDynakube func(dynakube *Dynakube) error

+ InsertVolume func(volume *Volume) error

+ Setup func(path string) error

+ UpdateDynakube func(dynakube *Dynakube) error

+ func NewAccess(path string) (Access, error)

+ type Dynakube struct

+ LatestVersion string

+ Name string

+ TenantUUID string

+ func NewDynakube(dynakubeName, tenantUUID, latestVersion string) *Dynakube

+ type FakeFailDB struct

+ func (f *FakeFailDB) DeleteDynakube(dynakubeName string) error

+ func (f *FakeFailDB) DeleteVolume(volumeID string) error

+ func (f *FakeFailDB) GetDynakube(dynakubeName string) (*Dynakube, error)

+ func (f *FakeFailDB) GetDynakubes() (map[string]string, error)

+ func (f *FakeFailDB) GetPodNames() (map[string]string, error)

+ func (f *FakeFailDB) GetUsedVersions(tenantUUID string) (map[string]bool, error)

+ func (f *FakeFailDB) GetVolume(volumeID string) (*Volume, error)

+ func (f *FakeFailDB) InsertDynakube(tenant *Dynakube) error

+ func (f *FakeFailDB) InsertVolume(volume *Volume) error

+ func (f *FakeFailDB) Setup(dbPath string) error

+ func (f *FakeFailDB) UpdateDynakube(tenant *Dynakube) error

+ type PathResolver struct

+ RootDir string

+ func (pr PathResolver) AgentBinaryDir(tenantUUID string) string

+ func (pr PathResolver) AgentBinaryDirForVersion(tenantUUID string, version string) string

+ func (pr PathResolver) AgentProcessModuleConfigForVersion(tenantUUID string, version string) string

+ func (pr PathResolver) AgentRunDir(tenantUUID string) string

+ func (pr PathResolver) AgentRunDirForVolume(tenantUUID string, volumeId string) string

+ func (pr PathResolver) AgentRuxitProcResponseCache(tenantUUID string) string

+ func (pr PathResolver) EnvDir(tenantUUID string) string

+ func (pr PathResolver) InnerAgentBinaryDirForSymlinkForVersion(tenantUUID string, version string) string

+ func (pr PathResolver) OverlayMappedDir(tenantUUID string, volumeId string) string

+ func (pr PathResolver) OverlayVarDir(tenantUUID string, volumeId string) string

+ func (pr PathResolver) OverlayWorkDir(tenantUUID string, volumeId string) string

+ func (pr PathResolver) SourceAgentProcessModuleConfigForVersion(tenantUUID string, version string) string

+ type SqliteAccess struct

+ func FakeMemoryDB() *SqliteAccess

+ func (a *SqliteAccess) DeleteDynakube(dynakubeName string) error

+ func (a *SqliteAccess) DeleteVolume(volumeID string) error

+ func (a *SqliteAccess) GetDynakube(dynakubeName string) (*Dynakube, error)

+ func (a *SqliteAccess) GetDynakubes() (map[string]string, error)

+ func (a *SqliteAccess) GetPodNames() (map[string]string, error)

+ func (a *SqliteAccess) GetUsedVersions(tenantUUID string) (map[string]bool, error)

+ func (a *SqliteAccess) GetVolume(volumeID string) (*Volume, error)

+ func (a *SqliteAccess) InsertDynakube(dynakube *Dynakube) error

+ func (a *SqliteAccess) InsertVolume(volume *Volume) error

+ func (a *SqliteAccess) Setup(path string) error

+ func (a *SqliteAccess) UpdateDynakube(dynakube *Dynakube) error

+ type Volume struct

+ PodName string

+ TenantUUID string

+ Version string

+ VolumeID string

+ func NewVolume(id, podUID, version, tenantUUID string) *Volume

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