sqldb

Documentation

Index

• Constants
• func CreateDBSession(kubectlConfig kubernetes.Interface, namespace string, ...) (sqlbuilder.Database, string, error)
• func CreateMySQLDBSession(kubectlConfig kubernetes.Interface, namespace string, ...) (sqlbuilder.Database, string, error)
• func CreatePostGresDBSession(kubectlConfig kubernetes.Interface, namespace string, ...) (sqlbuilder.Database, string, error)
• func DBInvalidSession(err error, message ...string) error
• func DBOperationError(err error, message ...string) error
• func DBUpdateNoRowFoundError(err error, message ...string) error
• func DBUpdateNoRowFoundErrorf(err error, format string, args ...interface{}) error
• type DBRepository
• type WorkflowDB
• type WorkflowDBContext
  • func (wdc *WorkflowDBContext) Close() error
  • func (wdc *WorkflowDBContext) Get(uid string) (*wfv1.Workflow, error)
  • func (wdc *WorkflowDBContext) Init(sess sqlbuilder.Database)
  • func (wdc *WorkflowDBContext) IsNodeStatusOffload() bool
  • func (wdc *WorkflowDBContext) List() ([]wfv1.Workflow, error)
  • func (wdc *WorkflowDBContext) Query(condition interface{}) ([]wfv1.Workflow, error)
  • func (wdc *WorkflowDBContext) Save(wf *wfv1.Workflow) error

Constants

const (
	CodeInvalidDBSession    = "ERR_INVALID_DB_SESSION"
	CodeDBUpdateRowNotFound = "ERR_DB_UPDATE_ROW_NOT_FOUND"
	CodeDBOperationError    = "ERR_DB_OPERATION_ERROR"
)

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, mysqlConfig *config.MySQLConfig, persistPool *config.ConnectionPool) (sqlbuilder.Database, string, error)

CreatePostGresDBSession creates Mysql DB session

func CreatePostGresDBSession

func CreatePostGresDBSession(kubectlConfig kubernetes.Interface, namespace string, postgresConfig *config.PostgreSQLConfig, persistPool *config.ConnectionPool) (sqlbuilder.Database, string, error)

CreatePostGresDBSession creates postgresDB session

func DBInvalidSession

func DBInvalidSession(err error, message ...string) error

func DBOperationError

func DBOperationError(err error, message ...string) error

func DBUpdateNoRowFoundError

func DBUpdateNoRowFoundError(err error, message ...string) error

func DBUpdateNoRowFoundErrorf

func DBUpdateNoRowFoundErrorf(err error, format string, args ...interface{}) error

InternalWrapErrorf annotates the error with the ERR_INTERNAL code and a stack trace, optional message

Types

type DBRepository

type DBRepository interface {
	Save(wf *wfv1.Workflow) error
	Get(uid string) (*wfv1.Workflow, error)
	List() ([]wfv1.Workflow, error)
	Query(condition interface{}) ([]wfv1.Workflow, error)
	Close() error
	IsNodeStatusOffload() bool
}

type WorkflowDB

type WorkflowDB struct {
	Id         string         `db:"id"`
	Name       string         `db:"name"`
	Phase      wfv1.NodePhase `db:"phase"`
	Namespace  string         `db:"namespace"`
	Workflow   string         `db:"workflow"`
	StartedAt  time.Time      `db:"startedat"`
	FinishedAt time.Time      `db:"finishedat"`
}

type WorkflowDBContext

type WorkflowDBContext struct {
	TableName         string
	NodeStatusOffload bool
	Session           sqlbuilder.Database
}

func (*WorkflowDBContext) Close

func (wdc *WorkflowDBContext) Close() error

func (*WorkflowDBContext) Get

func (wdc *WorkflowDBContext) Get(uid string) (*wfv1.Workflow, error)

func (*WorkflowDBContext) Init

func (wdc *WorkflowDBContext) Init(sess sqlbuilder.Database)

func (*WorkflowDBContext) IsNodeStatusOffload

func (wdc *WorkflowDBContext) IsNodeStatusOffload() bool

func (*WorkflowDBContext) List

func (wdc *WorkflowDBContext) List() ([]wfv1.Workflow, error)

func (*WorkflowDBContext) Query

func (wdc *WorkflowDBContext) Query(condition interface{}) ([]wfv1.Workflow, error)

func (*WorkflowDBContext) Save

func (wdc *WorkflowDBContext) Save(wf *wfv1.Workflow) error

Save will upset the workflow