repo

package
v0.0.0-...-63fb21e Latest Latest
Warning

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

 Go to latest Published: Dec 3, 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 DynDataRepo 

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

func NewDynDataRepo 

func NewDynDataRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *DynDataRepo

func (*DynDataRepo) Query 

func (r *DynDataRepo) Query(idQuery string) error

type DynFieldRepo 

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

func NewDynFieldRepo 

func NewDynFieldRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *DynFieldRepo

func (*DynFieldRepo) AddFields 

func (r *DynFieldRepo) AddFields(newModels []entity.NewDynamicField) ([]entity.DynamicField, error)

func (*DynFieldRepo) FetchDynamicFields 

func (r *DynFieldRepo) FetchDynamicFields(dynFieldIDs []string) ([]entity.DynamicField, error)

func (*DynFieldRepo) FetchVarsByDynFieldName 

func (r *DynFieldRepo) FetchVarsByDynFieldName(dynFieldName string) ([]entity.DynamicField, error)

func (*DynFieldRepo) FetchVarsByTabID 

func (r *DynFieldRepo) FetchVarsByTabID(dynTabID string) ([]entity.DynamicField, error)

func (*DynFieldRepo) IDQuery 

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

func (*DynFieldRepo) RemoveDynField 

func (r *DynFieldRepo) RemoveDynField(varIDs []string) error

type DynSchemaRepo 

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

func NewDynSchemaRepo 

func NewDynSchemaRepo(ctx context.Context, username string, dbPool *pgxpool.Pool) *DynSchemaRepo

func (*DynSchemaRepo) AddFieldsToSchema 

func (r *DynSchemaRepo) AddFieldsToSchema(suffix string, vars []entity.DynamicField) error

func (*DynSchemaRepo) CreateTable 

func (r *DynSchemaRepo) CreateTable(suffix string, dynSchema entity.DynamicTable, vars []entity.DynamicField) error

func (*DynSchemaRepo) IDQuery 

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

func (*DynSchemaRepo) Query 

func (r *DynSchemaRepo) Query(idQuery string) error

func (*DynSchemaRepo) RemoveFieldsFromSchema 

func (r *DynSchemaRepo) RemoveFieldsFromSchema(suffix, dynTabName string, vars []entity.DynamicField) error

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) CreateDynamicTables 

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

func (*DynTabRepo) FetchDynamicTables 

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

func (*DynTabRepo) IDQuery 

func (r *DynTabRepo) IDQuery(idQuery string) ([]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) FetchToBackup 

func (r *WorkflowRepo) FetchToBackup() ([]entity.Workflow, 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)

func (*WorkflowRepo) Upserts 

func (r *WorkflowRepo) Upserts(workflows []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.