Documentation ¶
Index ¶
- func CreateDBSession(kubectlConfig kubernetes.Interface, namespace string, ...) (sqlbuilder.Database, string, error)
- func CreateMySQLDBSession(kubectlConfig kubernetes.Interface, namespace string, cfg *config.MySQLConfig, ...) (sqlbuilder.Database, string, error)
- func CreatePostGresDBSession(kubectlConfig kubernetes.Interface, namespace string, ...) (sqlbuilder.Database, string, error)
- type Migrate
- type OffloadNodeStatusRepo
- type UUIDVersion
- type WorkflowArchive
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateDBSession ¶
func CreateDBSession(kubectlConfig kubernetes.Interface, namespace string, persistConfig *config.PersistConfig) (sqlbuilder.Database, string, error)
CreateDBSession creates the dB session
func CreateMySQLDBSession ¶
func CreateMySQLDBSession(kubectlConfig kubernetes.Interface, namespace string, cfg *config.MySQLConfig, persistPool *config.ConnectionPool) (sqlbuilder.Database, string, error)
CreateMySQLDBSession creates Mysql DB session
func CreatePostGresDBSession ¶
func CreatePostGresDBSession(kubectlConfig kubernetes.Interface, namespace string, cfg *config.PostgreSQLConfig, persistPool *config.ConnectionPool) (sqlbuilder.Database, string, error)
CreatePostGresDBSession creates postgresDB session
Types ¶
type Migrate ¶
func NewMigrate ¶
func NewMigrate(session sqlbuilder.Database, clusterName string, tableName string) Migrate
type OffloadNodeStatusRepo ¶
type OffloadNodeStatusRepo interface { Save(uid, namespace string, nodes wfv1.Nodes) (string, error) Get(uid, version string) (wfv1.Nodes, error) List(namespace string) (map[UUIDVersion]wfv1.Nodes, error) ListOldOffloads(namespace string) ([]UUIDVersion, error) Delete(uid, version string) error IsEnabled() bool }
var ExplosiveOffloadNodeStatusRepo OffloadNodeStatusRepo = &explosiveOffloadNodeStatusRepo{}
func NewOffloadNodeStatusRepo ¶
func NewOffloadNodeStatusRepo(session sqlbuilder.Database, clusterName, tableName string) (OffloadNodeStatusRepo, error)
type UUIDVersion ¶
type WorkflowArchive ¶
type WorkflowArchive interface { ArchiveWorkflow(wf *wfv1.Workflow) error ListWorkflows(namespace string, limit, offset int) (wfv1.Workflows, error) GetWorkflow(uid string) (*wfv1.Workflow, error) DeleteWorkflow(uid string) error }
var NullWorkflowArchive WorkflowArchive = &nullWorkflowArchive{}
func NewWorkflowArchive ¶
func NewWorkflowArchive(session sqlbuilder.Database, clusterName string) WorkflowArchive
Source Files ¶
Click to show internal directories.
Click to hide internal directories.