postgres

Documentation

Index

• func DownOneStep() error
• func StringToSQLString(str string) sql.NullString
• func Up() error
• type Client
  • func NewClient() Client
• type ClientMock
  • func (m ClientMock) Close() error
  • func (m ClientMock) GetDB() *sqlx.DB
  • func (m ClientMock) NamedExec(query string, data interface{}) (int64, error)
  • func (m ClientMock) Select(destination interface{}, query string, arguments ...interface{}) error
• type JobsExecutionAuditLog
  • func (j *JobsExecutionAuditLog) AddExecutionID(jobExecutionID string)
  • func (j *JobsExecutionAuditLog) AddJobArgs(jobArgs map[string]string)
• type JobsSchedule

Functions

func DownOneStep

func DownOneStep() error

func StringToSQLString

func StringToSQLString(str string) sql.NullString

func Up

func Up() error

Types

type Client

type Client interface {
	NamedExec(string, interface{}) (int64, error)
	Select(interface{}, string, ...interface{}) error
	Close() error
	GetDB() *sqlx.DB
}

func NewClient

func NewClient() Client

type ClientMock

type ClientMock struct {
	mock.Mock
}

func (ClientMock) Close

func (m ClientMock) Close() error

func (ClientMock) GetDB

func (m ClientMock) GetDB() *sqlx.DB

func (ClientMock) NamedExec

func (m ClientMock) NamedExec(query string, data interface{}) (int64, error)

func (ClientMock) Select

func (m ClientMock) Select(destination interface{}, query string, arguments ...interface{}) error

type JobsExecutionAuditLog

type JobsExecutionAuditLog struct {
	JobName             string         `db:"job_name"`
	UserEmail           string         `db:"user_email"`
	ImageName           string         `db:"image_name"`
	ExecutionID         sql.NullString `db:"job_name_submitted_for_execution"`
	JobArgs             string         `db:"job_args"`
	JobSubmissionStatus string         `db:"job_submission_status"`
	Errors              string         `db:"errors"`
	JobExecutionStatus  string         `db:"job_execution_status"`
	CreatedAt           time.Time      `db:"created_at"`
	UpdatedAt           time.Time      `db:"updated_at"`
}

func (*JobsExecutionAuditLog) AddExecutionID

func (j *JobsExecutionAuditLog) AddExecutionID(jobExecutionID string)

func (*JobsExecutionAuditLog) AddJobArgs

func (j *JobsExecutionAuditLog) AddJobArgs(jobArgs map[string]string)

type JobsSchedule

type JobsSchedule struct {
	ID                 string    `db:"id"`
	Name               string    `db:"name"`
	Args               string    `db:"args"`
	Tags               string    `db:"tags"`
	Time               string    `db:"time"`
	NotificationEmails string    `db:"notification_emails"`
	UserEmail          string    `db:"user_email"`
	Group              string    `db:"group_name"`
	Enabled            bool      `db:"enabled"`
	CreatedAt          time.Time `db:"created_at"`
	UpdatedAt          time.Time `db:"updated_at"`
}