repo

package
v0.0.0-...-d40f389 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 19, 2024 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertToUpdateWorkflowParams 

func ConvertToUpdateWorkflowParams(
	input entity.UpdateWorkflow,
	workflowID, modifiedBy string,
) sqlcrepo.UpdateWorkflowParams

Types

type DynTabRepo 

type DynTabRepo struct {
	// contains filtered or unexported fields
}

func NewDynTabRepo 

func NewDynTabRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *DynTabRepo

func (*DynTabRepo) AddDynTabVars 

func (r *DynTabRepo) AddDynTabVars(newVars []entity.NewDynamicTableVariable) ([]entity.DynamicTableVariable, error)

func (*DynTabRepo) AddSchemaField 

func (r *DynTabRepo) AddSchemaField(suffix string, vars []entity.DynamicTableVariable) error

func (*DynTabRepo) CreateDynamicTables 

func (r *DynTabRepo) CreateDynamicTables(newModels []entity.NewDynamicTable) ([]entity.DynamicTable, error)

func (*DynTabRepo) CreateTable 

func (r *DynTabRepo) CreateTable(suffix string, dynTab entity.DynamicTable, vars []entity.DynamicTableVariable) error

func (*DynTabRepo) FetchDynamicTables 

func (r *DynTabRepo) FetchDynamicTables(ids []string) ([]entity.DynamicTable, error)

func (*DynTabRepo) FetchVarsByIDs 

func (r *DynTabRepo) FetchVarsByIDs(varsIDs []string) ([]entity.DynamicTableVariable, error)

func (*DynTabRepo) FetchVarsByTab 

func (r *DynTabRepo) FetchVarsByTab(dynTabID string) ([]entity.DynamicTableVariable, error)

func (*DynTabRepo) IDQuery 

func (r *DynTabRepo) IDQuery(idQuery string) ([]string, error)

func (*DynTabRepo) RemoveDynTabVars 

func (r *DynTabRepo) RemoveDynTabVars(varIDs []string) error

type RawWorkflow 

type RawWorkflow struct {
	ID          string              `json:"id"`
	Name        string              `json:"name"`
	Code        string              `json:"code"`
	BuildIn     bool                `json:"build_in"`
	FailOnError bool                `json:"fail_on_error"`
	ObjectType  entity.WorkflowType `json:"object_type"`
	Meta        entity.MetaData     `json:"meta"`
	Parent      *string
	Depth       int
}

type RunLogRepo 

type RunLogRepo struct {
	// contains filtered or unexported fields
}

func NewRunLogRepo 

func NewRunLogRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *RunLogRepo

func (*RunLogRepo) CreateRunLog 

func (r *RunLogRepo) CreateRunLog(newModel entity.NewRunLog) (*entity.RunLog, error)

func (*RunLogRepo) FetchRunLog 

func (r *RunLogRepo) FetchRunLog(id string) (*entity.RunLog, error)

func (*RunLogRepo) FetchRunLogsByRun 

func (r *RunLogRepo) FetchRunLogsByRun(runID string) ([]entity.RunLog, error)

type RunRepo 

type RunRepo struct {
	// contains filtered or unexported fields
}

func NewRunRepo 

func NewRunRepo(ctx context.Context, username, requestID string, dbPool *pgxpool.Pool) *RunRepo

func (*RunRepo) FetchRunByRequestID 

func (r *RunRepo) FetchRunByRequestID(requestID string) (*entity.Run, error)

func (*RunRepo) FetchRunByWorkflow 

func (r *RunRepo) FetchRunByWorkflow(workflowID string) ([]*entity.Run, error)

func (*RunRepo) FetchRuns 

func (r *RunRepo) FetchRuns(ids []string) ([]*entity.Run, error)

func (*RunRepo) IDQuery 

func (r *RunRepo) IDQuery(idQuery string) ([]string, error)

func (*RunRepo) SaveRun 

func (r *RunRepo) SaveRun(newModel entity.NewRun) (*entity.Run, error)

type TokenRepo 

type TokenRepo struct {
	Username string
	// contains filtered or unexported fields
}

func NewTokenRepo 

func NewTokenRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *TokenRepo

func (*TokenRepo) CreateToken 

func (r *TokenRepo) CreateToken(t entity.NewToken) (*entity.Token, error)

func (*TokenRepo) DeleteTokenByValue 

func (r *TokenRepo) DeleteTokenByValue(t string) error

func (*TokenRepo) ListTokens 

func (r *TokenRepo) ListTokens() ([]*entity.Token, error)

func (*TokenRepo) ListUserToken 

func (r *TokenRepo) ListUserToken(username string) ([]*entity.Token, error)

func (*TokenRepo) ReadToken 

func (r *TokenRepo) ReadToken(id string) (*entity.Token, error)

func (*TokenRepo) ReadTokenByValue 

func (r *TokenRepo) ReadTokenByValue(t string) (*entity.Token, error)

type UserRepo 

type UserRepo struct {
	Username string
	// contains filtered or unexported fields
}

func NewUserRepo 

func NewUserRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *UserRepo

func (*UserRepo) DeleteUser 

func (r *UserRepo) DeleteUser(id string) error

func (*UserRepo) FetchByIDs 

func (r *UserRepo) FetchByIDs(ids []string) ([]*entity.User, error)

func (*UserRepo) FetchUser 

func (r *UserRepo) FetchUser(id string) (*entity.User, error)

func (*UserRepo) FetchUserByName 

func (r *UserRepo) FetchUserByName(name string) (*entity.User, error)

func (*UserRepo) IDQuery 

func (r *UserRepo) IDQuery(idQuery string) ([]string, error)

func (*UserRepo) SaveUser 

func (r *UserRepo) SaveUser(t entity.NewUser) (*entity.User, error)

func (*UserRepo) UpdatePassword 

func (r *UserRepo) UpdatePassword(passwordHash string, userID string) (*entity.User, error)

type WorkflowRepo 

type WorkflowRepo struct {
	// contains filtered or unexported fields
}

func NewWorkflowRepo 

func NewWorkflowRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *WorkflowRepo

func (*WorkflowRepo) CreateWorkflows 

func (r *WorkflowRepo) CreateWorkflows(newModels []*entity.NewWorkflow) ([]entity.Workflow, error)

func (*WorkflowRepo) DeleteWorkflow 

func (r *WorkflowRepo) DeleteWorkflow(id string) error

func (*WorkflowRepo) FetchWorkflows 

func (r *WorkflowRepo) FetchWorkflows(ids []string, depth int) ([]entity.Workflow, error)

func (*WorkflowRepo) IDQuery 

func (r *WorkflowRepo) IDQuery(idQuery string) ([]string, error)

func (*WorkflowRepo) UpdateWorkflow 

func (r *WorkflowRepo) UpdateWorkflow(workflowID string, updateEntity entity.UpdateWorkflow) (*entity.Workflow, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.