filesystem

Documentation

Index

• Constants
• func CachedDataDirPath() string
• func ConfigDirPath() string
• func CopyFile(src, dst string) error
• func DefaultWorkspaceDir() string
• func EnsureCachedDataDir() error
• func EnsureConfigDir() error
• func EnsureDefaultWorkspace() error
• func EnsureExecutableDir(workspacePath, subPath string) error
• func EnsureLogsDir() error
• func EnsureWorkspaceConfig(workspaceName, workspacePath string) error
• func EnsureWorkspaceDir(workspacePath string) error
• func InitExecutables(template *executable.FlowFileTemplate, ws *workspace.Workspace, ...) error
• func InitUserConfig() error
• func InitWorkspaceConfig(name, path string) error
• func LatestCachedDataDir() string
• func LatestCachedDataFilePath(cacheKey string) string
• func LoadConfig() (*config.Config, error)
• func LoadFlowFile(cfgFile string) (*executable.FlowFile, error)
• func LoadFlowFileTemplate(templateFile string) (*executable.FlowFileTemplate, error)
• func LoadLatestCachedData(cacheKey string) ([]byte, error)
• func LoadWorkspaceConfig(workspaceName, workspacePath string) (*workspace.Workspace, error)
• func LoadWorkspaceFlowFiles(logger io.Logger, workspaceCfg *workspace.Workspace) (executable.FlowFileList, error)
• func LogsDir() string
• func UserConfigFilePath() string
• func WorkspaceConfigExists(workspacePath string) bool
• func WriteFlowFile(cfgFile string, cfg *executable.FlowFile) error
• func WriteFlowFileFromTemplate(cfgTemplate *executable.FlowFileTemplate, ws *workspace.Workspace, ...) error
• func WriteFlowFileTemplate(templatePath string, template *executable.FlowFileTemplate) error
• func WriteLatestCachedData(cacheKey string, data []byte) error
• func WriteUserConfig(config *config.Config) error
• func WriteWorkspaceConfig(workspacePath string, config *workspace.Workspace) error

Constants

const FlowCacheDirEnvVar = "FLOW_CACHE_DIR"

const FlowConfigDirEnvVar = "FLOW_CONFIG_DIR"

const FlowFileExt = ".flow"

const WorkspaceConfigFileName = "flow.yaml"

Functions

func CachedDataDirPath

func CachedDataDirPath() string

func ConfigDirPath

func ConfigDirPath() string

func CopyFile

func CopyFile(src, dst string) error

func DefaultWorkspaceDir

func DefaultWorkspaceDir() string

func EnsureCachedDataDir

func EnsureCachedDataDir() error

func EnsureConfigDir

func EnsureConfigDir() error

func EnsureDefaultWorkspace

func EnsureDefaultWorkspace() error

func EnsureExecutableDir

func EnsureExecutableDir(workspacePath, subPath string) error

func EnsureLogsDir

func EnsureLogsDir() error

func EnsureWorkspaceConfig

func EnsureWorkspaceConfig(workspaceName, workspacePath string) error

func EnsureWorkspaceDir

func EnsureWorkspaceDir(workspacePath string) error

func InitExecutables

func InitExecutables(
	template *executable.FlowFileTemplate,
	ws *workspace.Workspace,
	name, subPath string,
) error

func InitUserConfig

func InitUserConfig() error

func InitWorkspaceConfig

func InitWorkspaceConfig(name, path string) error

func LatestCachedDataDir

func LatestCachedDataDir() string

func LatestCachedDataFilePath

func LatestCachedDataFilePath(cacheKey string) string

func LoadConfig

func LoadConfig() (*config.Config, error)

func LoadFlowFile

func LoadFlowFile(cfgFile string) (*executable.FlowFile, error)

func LoadFlowFileTemplate

func LoadFlowFileTemplate(templateFile string) (*executable.FlowFileTemplate, error)

func LoadLatestCachedData

func LoadLatestCachedData(cacheKey string) ([]byte, error)

func LoadWorkspaceConfig

func LoadWorkspaceConfig(workspaceName, workspacePath string) (*workspace.Workspace, error)

func LoadWorkspaceFlowFiles

func LoadWorkspaceFlowFiles(
	logger io.Logger,
	workspaceCfg *workspace.Workspace,
) (executable.FlowFileList, error)

func LogsDir

func LogsDir() string

func UserConfigFilePath

func UserConfigFilePath() string

func WorkspaceConfigExists

func WorkspaceConfigExists(workspacePath string) bool

func WriteFlowFile

func WriteFlowFile(cfgFile string, cfg *executable.FlowFile) error

func WriteFlowFileFromTemplate

func WriteFlowFileFromTemplate(
	cfgTemplate *executable.FlowFileTemplate,
	ws *workspace.Workspace,
	name, subPath string,
) error

func WriteFlowFileTemplate

func WriteFlowFileTemplate(templatePath string, template *executable.FlowFileTemplate) error

func WriteLatestCachedData

func WriteLatestCachedData(cacheKey string, data []byte) error

func WriteUserConfig

func WriteUserConfig(config *config.Config) error

func WriteWorkspaceConfig

func WriteWorkspaceConfig(workspacePath string, config *workspace.Workspace) error