filesystem

Documentation

Index

• type FileSystemInputLifetimer
  • func NewFileSystemLifetimerForInputData(fileSystemSpec *lifetimesapi.InputFileSystemSpec, pod *corev1.Pod, ...) (*FileSystemInputLifetimer, error)
  • func (fsil *FileSystemInputLifetimer) Delete(deletePolicy lifetimesapi.DeletePolicy) error
  • func (fsil *FileSystemInputLifetimer) FirstUpdate(ctx context.Context, offsetTime time.Time) (bool, error)
  • func (fsil *FileSystemInputLifetimer) Start(ctx context.Context) (time.Time, error)
  • func (fsil *FileSystemInputLifetimer) Stop() error
  • func (fsil *FileSystemInputLifetimer) Update(ctx context.Context) (bool, error)
• type FileSystemOutputLifetimer
  • func NewFileSystemLifetimerForOutputData(fileSystemSpec *lifetimesapi.OutputFileSystemSpec, pod *corev1.Pod, ...) (*FileSystemOutputLifetimer, error)
  • func (fsol *FileSystemOutputLifetimer) Delete(deletePolicy lifetimesapi.DeletePolicy) error
  • func (fsol *FileSystemOutputLifetimer) Start(ctx context.Context) error
  • func (fsol *FileSystemOutputLifetimer) Stop() error

Types

type FileSystemInputLifetimer

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

func NewFileSystemLifetimerForInputData

func NewFileSystemLifetimerForInputData(
	fileSystemSpec *lifetimesapi.InputFileSystemSpec, pod *corev1.Pod,
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.MessageQueueSpec,
	lifetimeStatus *lifetimesapi.ConsumerStatus, disableUsageControl bool,
	volumeControllerEndpoint string, podNamespace string, podName string,
	dataContainerName string) (*FileSystemInputLifetimer, error)

func (*FileSystemInputLifetimer) Delete

func (fsil *FileSystemInputLifetimer) Delete(
	deletePolicy lifetimesapi.DeletePolicy) error

func (*FileSystemInputLifetimer) FirstUpdate

func (fsil *FileSystemInputLifetimer) FirstUpdate(
	ctx context.Context, offsetTime time.Time) (bool, error)

func (*FileSystemInputLifetimer) Start

func (fsil *FileSystemInputLifetimer) Start(
	ctx context.Context) (time.Time, error)

func (*FileSystemInputLifetimer) Stop

func (fsil *FileSystemInputLifetimer) Stop() error

func (*FileSystemInputLifetimer) Update

func (fsil *FileSystemInputLifetimer) Update(
	ctx context.Context) (bool, error)

type FileSystemOutputLifetimer

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

func NewFileSystemLifetimerForOutputData

func NewFileSystemLifetimerForOutputData(
	fileSystemSpec *lifetimesapi.OutputFileSystemSpec, pod *corev1.Pod,
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.PublishMessageQueueSpec,
	messageQueuePublisherOptions *publish.MessageQueuePublisherOptions,
	disableUsageControl bool, volumeControllerEndpoint string,
	podNamespace string, podName string, dataContainerName string) (
	*FileSystemOutputLifetimer, error)

func (*FileSystemOutputLifetimer) Delete

func (fsol *FileSystemOutputLifetimer) Delete(
	deletePolicy lifetimesapi.DeletePolicy) error

func (*FileSystemOutputLifetimer) Start

func (fsol *FileSystemOutputLifetimer) Start(ctx context.Context) error

func (*FileSystemOutputLifetimer) Stop

func (fsol *FileSystemOutputLifetimer) Stop() error