floxyctl

Documentation

Index

• func AbortWorkflow(ctx context.Context, pool *pgxpool.Pool, objectID, requestedBy, reason string) error
• func CancelWorkflow(ctx context.Context, pool *pgxpool.Pool, objectID, requestedBy, reason string) error
• func ConnectDB(ctx context.Context, config DBConfig) (*pgxpool.Pool, error)
• func CreateEngineFromDB(ctx context.Context, pool *pgxpool.Pool) (*floxy.Engine, error)
• func NewRootCommand(version, commit string) *cobra.Command
• func ReadPassword() (string, error)
• func RunWorkflow(ctx context.Context, yamlFile, inputFile string, config Config) error
• func StartWorkflow(ctx context.Context, pool *pgxpool.Pool, workflowID, inputFile string) error
• type Config
• type DBConfig

Functions

func AbortWorkflow

func AbortWorkflow(ctx context.Context, pool *pgxpool.Pool, objectID, requestedBy, reason string) error

func CancelWorkflow

func CancelWorkflow(ctx context.Context, pool *pgxpool.Pool, objectID, requestedBy, reason string) error

func ConnectDB

func ConnectDB(ctx context.Context, config DBConfig) (*pgxpool.Pool, error)

func CreateEngineFromDB

func CreateEngineFromDB(ctx context.Context, pool *pgxpool.Pool) (*floxy.Engine, error)

func NewRootCommand

func NewRootCommand(version, commit string) *cobra.Command

func ReadPassword

func ReadPassword() (string, error)

func RunWorkflow

func RunWorkflow(ctx context.Context, yamlFile, inputFile string, config Config) error

func StartWorkflow

func StartWorkflow(ctx context.Context, pool *pgxpool.Pool, workflowID, inputFile string) error

Types

type Config

type Config struct {
	PoolWorkers         int
	WorkerInterval      time.Duration
	CompletionTimeout   time.Duration
	StatusCheckInterval time.Duration
	Debug               bool
}

type DBConfig

type DBConfig struct {
	Host     string
	Port     string
	User     string
	Password string
	Database string
}