fileprefetcher

package
v1.0.7 Latest Latest
Warning

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

Go to latest
Published: Sep 19, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// prefix for labels and annotations used in file prefetcher feature
	// i.e. file-prefetcher.fluid.io/
	LabelAnnotationFilePrefetcherPrefix = "file-prefetcher." + common.LabelAnnotationPrefix

	// annotation to inject file prefetcher sidecar container
	// i.e. file-prefetcher.fluid.io/inject
	AnnotationFilePrefetcherInject = LabelAnnotationFilePrefetcherPrefix + "inject"

	// annotation to mark file prefetcher sidecar container has been injected
	// i.e. file-prefetcher.fluid.io/inject-done
	AnnotationFilePrefetcherInjectDone = LabelAnnotationFilePrefetcherPrefix + "inject-done"

	// annotation to set file prefetcher sidecar container's image
	// i.e. file-prefetcher.fluid.io/image
	AnnotationFilePrefetcherImage = LabelAnnotationFilePrefetcherPrefix + "image"

	// annotation to set file list to prefetch
	// i.e. file-prefetcher.fluid.io/file-list
	AnnotationFilePrefetcherFileList = LabelAnnotationFilePrefetcherPrefix + "file-list"

	// annotation to set if prefetch files asynchronously. When setting it to true,
	// app container will start up after file prefetcher finishes.
	// i.e. file-prefetcher.fluid.io/async-prefetch
	AnnotationFilePrefetcherAsync = LabelAnnotationFilePrefetcherPrefix + "async-prefetch"

	// annotation to set extra envs for file prefetcher
	// i.e. file-prefetcher.fluid.io/extra-envs
	AnnotationFilePrefetcherExtraEnvs = LabelAnnotationFilePrefetcherPrefix + "extra-envs"

	// annotation to set timeout for file prefetcher
	// i.e. file-prefetcher.fluid.io/prefetch-timeout-seconds
	AnnotationFilePrefetcherTimeoutSeconds = LabelAnnotationFilePrefetcherPrefix + "prefetch-timeout-seconds"
)
View Source
const Name string = "FilePrefetcher"

Variables

This section is empty.

Functions

func NewPlugin

func NewPlugin(c client.Client, args string) (api.MutatingHandler, error)

Types

type FilePrefetcher

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

func (*FilePrefetcher) GetName

func (p *FilePrefetcher) GetName() string

func (*FilePrefetcher) Mutate

func (p *FilePrefetcher) Mutate(pod *corev1.Pod, runtimeInfos map[string]base.RuntimeInfoInterface) (shouldStop bool, err error)

Jump to

Keyboard shortcuts

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