db

Documentation

Index

• func CommitJobTransaction(dbContext *config.DbContextType) error
• func ConnectDB(conf *config.ConfigType) error
• func InitDatabase(conf config.ConfigType) error
• func PrepareJobTransaction(ctx context.Context, conf config.ConfigType, dbContext *config.DbContextType) error
• func QueryWorkflowRunAttempts(conf config.ConfigType, runId int64) map[int64]struct{}
• func QueryWorkflowRunsNotInDb(conf config.ConfigType, workflowRuns []gh.WorkflowRunAttemptKey) []gh.WorkflowRunAttemptKey
• func SaveJobInfo(dbContext *config.DbContextType, workflowJob *github.WorkflowJob) error
• func SaveStepInfo(dbContext *config.DbContextType, job *github.WorkflowJob, ...) error
• func SaveWorkflowRun(conf config.ConfigType, record *data.WorkflowRunRec) error
• func SaveWorkflowRunAttempt(conf config.ConfigType, workflowRun *github.WorkflowRun) error

Functions

func CommitJobTransaction

func CommitJobTransaction(dbContext *config.DbContextType) error

func ConnectDB

func ConnectDB(conf *config.ConfigType) error

func InitDatabase

func InitDatabase(conf config.ConfigType) error

func PrepareJobTransaction

func PrepareJobTransaction(ctx context.Context, conf config.ConfigType, dbContext *config.DbContextType) error

func QueryWorkflowRunAttempts

func QueryWorkflowRunAttempts(conf config.ConfigType, runId int64) map[int64]struct{}

func QueryWorkflowRunsNotInDb

func QueryWorkflowRunsNotInDb(conf config.ConfigType, workflowRuns []gh.WorkflowRunAttemptKey) []gh.WorkflowRunAttemptKey

func SaveJobInfo

func SaveJobInfo(dbContext *config.DbContextType, workflowJob *github.WorkflowJob) error

func SaveStepInfo

func SaveStepInfo(dbContext *config.DbContextType, job *github.WorkflowJob, step *github.TaskStep) error

func SaveWorkflowRun

func SaveWorkflowRun(conf config.ConfigType, record *data.WorkflowRunRec) error

func SaveWorkflowRunAttempt

func SaveWorkflowRunAttempt(conf config.ConfigType, workflowRun *github.WorkflowRun) error