util

Documentation

Index

• func ApplyImagePullSecret(secret string, podspec apiv1.PodSpec) *apiv1.PodSpec
• func ConvertConfigSecrets(ctx context.Context, fn *fv1.Function, kc kubernetes.Interface) ([]apiv1.EnvFromSource, error)
• func CreateDumpFile(logger *zap.Logger) (*os.File, error)
• func GetObjectReaperInterval(logger *zap.Logger, executorType fv1.ExecutorType, defaultReaperInterval uint) uint
• func GetSpecFromConfigMap(filePath string) (*apiv1.PodSpec, error)
• func MergeContainer(dst *apiv1.Container, src *apiv1.Container) (*apiv1.Container, error)
• func MergePodSpec(srcPodSpec *apiv1.PodSpec, targetPodSpec *apiv1.PodSpec) (*apiv1.PodSpec, error)
• func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration)

Functions

func ApplyImagePullSecret

func ApplyImagePullSecret(secret string, podspec apiv1.PodSpec) *apiv1.PodSpec

ApplyImagePullSecret applies image pull secret to the give pod spec. It's intentional not to check the existence of secret here. First, Kubernetes will set Pod status to "ImagePullBackOff" once kubelet failed to pull image so that users will know what's happening. Second, Fission no longer need to handle "secret not found" error when creating the environment deployment since kubelet will retry to pull image until successes.

func ConvertConfigSecrets

func ConvertConfigSecrets(ctx context.Context, fn *fv1.Function, kc kubernetes.Interface) ([]apiv1.EnvFromSource, error)

ConvertConfigSecrets returns envFromSource which can be passed directly into the pod spec

func CreateDumpFile

func CreateDumpFile(logger *zap.Logger) (*os.File, error)

CreateDumpFile => create dump file inside temp directory

func GetObjectReaperInterval

func GetObjectReaperInterval(logger *zap.Logger, executorType fv1.ExecutorType, defaultReaperInterval uint) uint

func GetSpecFromConfigMap

func GetSpecFromConfigMap(filePath string) (*apiv1.PodSpec, error)

func MergeContainer

func MergeContainer(dst *apiv1.Container, src *apiv1.Container) (*apiv1.Container, error)

MergeContainer returns merged container specs. Slices are merged, and return an error if the elements in the slice have name conflicts. Maps are merged, the value of map of dst container are overridden if the key is the same. The rest of fields of dst container are overridden directly.

func MergePodSpec

func MergePodSpec(srcPodSpec *apiv1.PodSpec, targetPodSpec *apiv1.PodSpec) (*apiv1.PodSpec, error)

MergePodSpec updates srcPodSpec with targetPodSpec fields if not empty

func WaitTimeout

func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration)

WaitTimeout starts a wait group with timeout