utils

Documentation

Index

• func CheckFileExists(fileName string) bool
• func FetchSideInputFileValue(filePath string) ([]byte, error)
• func UpdateSideInputFile(ctx context.Context, fileSymLink string, value []byte) error

Functions

func CheckFileExists

func CheckFileExists(fileName string) bool

CheckFileExists checks if a file with the given fileName exists in the file system.

func FetchSideInputFileValue

func FetchSideInputFileValue(filePath string) ([]byte, error)

FetchSideInputFileValue reads a given file and returns the value in bytes

func UpdateSideInputFile

func UpdateSideInputFile(ctx context.Context, fileSymLink string, value []byte) error

UpdateSideInputFile writes the given side input value to a new file and updates the side input store path to point to this new file.