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 InitConfig() 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(flowfileName, templatePath string) (*executable.Template, error)
• func LoadFlowFileTemplates(templatePaths map[string]string) (executable.TemplateList, 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 WriteConfig(config *config.Config) error
• func WriteFlowFile(cfgFile string, cfg *executable.FlowFile) error
• func WriteLatestCachedData(cacheKey string, data []byte) error
• func WriteWorkspaceConfig(workspacePath string, config *workspace.Workspace) error

Constants

const FlowCacheDirEnvVar = "FLOW_CACHE_DIR"

const FlowConfigDirEnvVar = "FLOW_CONFIG_DIR"

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 InitConfig

func InitConfig() 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(flowfileName, templatePath string) (*executable.Template, error)

func LoadFlowFileTemplates

func LoadFlowFileTemplates(templatePaths map[string]string) (executable.TemplateList, 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 WriteConfig

func WriteConfig(config *config.Config) error

func WriteFlowFile

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

func WriteLatestCachedData

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

func WriteWorkspaceConfig

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