const draManagerStateFileName …
const defaultReconcilePeriod …
type ActivePodsFunc …
type ManagerImpl …
func NewManagerImpl(kubeClient clientset.Interface, stateFileDirectory string, nodeName types.NodeName) (*ManagerImpl, error) { … }
func (m *ManagerImpl) Start(ctx context.Context, activePods ActivePodsFunc, sourcesReady config.SourcesReady) error { … }
func (m *ManagerImpl) reconcileLoop(ctx context.Context) { … }
func (m *ManagerImpl) PrepareResources(ctx context.Context, pod *v1.Pod) error { … }
func lookupClaimRequest(claims []*drapb.Claim, claimUID string) *drapb.Claim { … }
func (m *ManagerImpl) GetResources(pod *v1.Pod, container *v1.Container) (*ContainerInfo, error) { … }
func (m *ManagerImpl) UnprepareResources(ctx context.Context, pod *v1.Pod) error { … }
func (m *ManagerImpl) unprepareResources(ctx context.Context, podUID types.UID, namespace string, claimNames []string) error { … }
func (m *ManagerImpl) PodMightNeedToUnprepareResources(uid types.UID) bool { … }
func (m *ManagerImpl) GetContainerClaimInfos(pod *v1.Pod, container *v1.Container) ([]*ClaimInfo, error) { … }