repository

package
v0.4.7 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2025 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ACMEAccountRepository added in v0.4.0 

type ACMEAccountRepository struct{}

func NewACMEAccountRepository added in v0.4.0 

func NewACMEAccountRepository() *ACMEAccountRepository

func (*ACMEAccountRepository) GetByAcctUrl added in v0.4.3 

func (r *ACMEAccountRepository) GetByAcctUrl(ctx context.Context, acctUrl string) (*domain.ACMEAccount, error)

func (*ACMEAccountRepository) GetByCAAndEmail added in v0.4.0 

func (r *ACMEAccountRepository) GetByCAAndEmail(ctx context.Context, ca, caDirUrl, email string) (*domain.ACMEAccount, error)

func (*ACMEAccountRepository) Save added in v0.4.0 

func (r *ACMEAccountRepository) Save(ctx context.Context, acmeAccount *domain.ACMEAccount) (*domain.ACMEAccount, error)

type AccessRepository 

type AccessRepository struct{}

func NewAccessRepository 

func NewAccessRepository() *AccessRepository

func (*AccessRepository) GetById 

func (r *AccessRepository) GetById(ctx context.Context, id string) (*domain.Access, error)

type CertificateRepository 

type CertificateRepository struct{}

func NewCertificateRepository 

func NewCertificateRepository() *CertificateRepository

func (*CertificateRepository) DeleteWhere 

func (r *CertificateRepository) DeleteWhere(ctx context.Context, exprs ...dbx.Expression) (int, error)

func (*CertificateRepository) GetById 

func (r *CertificateRepository) GetById(ctx context.Context, id string) (*domain.Certificate, error)

func (*CertificateRepository) GetByWorkflowIdAndNodeId added in v0.4.0 

func (r *CertificateRepository) GetByWorkflowIdAndNodeId(ctx context.Context, workflowId string, workflowNodeId string) (*domain.Certificate, error)

func (*CertificateRepository) GetByWorkflowRunIdAndNodeId 

func (r *CertificateRepository) GetByWorkflowRunIdAndNodeId(ctx context.Context, workflowRunId string, workflowNodeId string) (*domain.Certificate, error)

func (*CertificateRepository) ListExpiringSoon added in v0.4.0 

func (r *CertificateRepository) ListExpiringSoon(ctx context.Context) ([]*domain.Certificate, error)

func (*CertificateRepository) Save 

func (r *CertificateRepository) Save(ctx context.Context, certificate *domain.Certificate) (*domain.Certificate, error)

type SettingsRepository 

type SettingsRepository struct{}

func NewSettingsRepository 

func NewSettingsRepository() *SettingsRepository

func (*SettingsRepository) GetByName 

func (r *SettingsRepository) GetByName(ctx context.Context, name string) (*domain.Settings, error)

type StatisticsRepository 

type StatisticsRepository struct{}

func NewStatisticsRepository 

func NewStatisticsRepository() *StatisticsRepository

func (*StatisticsRepository) Get 

func (r *StatisticsRepository) Get(ctx context.Context) (*domain.Statistics, error)

type WorkflowLogRepository 

type WorkflowLogRepository struct{}

func NewWorkflowLogRepository 

func NewWorkflowLogRepository() *WorkflowLogRepository

func (*WorkflowLogRepository) ListByWorkflowRunId 

func (r *WorkflowLogRepository) ListByWorkflowRunId(ctx context.Context, workflowRunId string) ([]*domain.WorkflowLog, error)

func (*WorkflowLogRepository) Save 

func (r *WorkflowLogRepository) Save(ctx context.Context, workflowLog *domain.WorkflowLog) (*domain.WorkflowLog, error)

type WorkflowOutputRepository 

type WorkflowOutputRepository struct{}

func NewWorkflowOutputRepository 

func NewWorkflowOutputRepository() *WorkflowOutputRepository

func (*WorkflowOutputRepository) GetByWorkflowIdAndNodeId added in v0.4.6 

func (r *WorkflowOutputRepository) GetByWorkflowIdAndNodeId(ctx context.Context, workflowId string, workflowNodeId string) (*domain.WorkflowOutput, error)

func (*WorkflowOutputRepository) GetByWorkflowRunIdAndNodeId added in v0.4.6 

func (r *WorkflowOutputRepository) GetByWorkflowRunIdAndNodeId(ctx context.Context, workflowRunId string, workflowNodeId string) (*domain.WorkflowOutput, error)

func (*WorkflowOutputRepository) Save 

func (r *WorkflowOutputRepository) Save(ctx context.Context, workflowOutput *domain.WorkflowOutput) (*domain.WorkflowOutput, error)

type WorkflowRepository 

type WorkflowRepository struct{}

func NewWorkflowRepository 

func NewWorkflowRepository() *WorkflowRepository

func (*WorkflowRepository) GetById 

func (r *WorkflowRepository) GetById(ctx context.Context, id string) (*domain.Workflow, error)

func (*WorkflowRepository) ListEnabledScheduled added in v0.4.0 

func (r *WorkflowRepository) ListEnabledScheduled(ctx context.Context) ([]*domain.Workflow, error)

func (*WorkflowRepository) Save 

func (r *WorkflowRepository) Save(ctx context.Context, workflow *domain.Workflow) (*domain.Workflow, error)

type WorkflowRunRepository 

type WorkflowRunRepository struct{}

func NewWorkflowRunRepository 

func NewWorkflowRunRepository() *WorkflowRunRepository

func (*WorkflowRunRepository) DeleteWhere 

func (r *WorkflowRunRepository) DeleteWhere(ctx context.Context, exprs ...dbx.Expression) (int, error)

func (*WorkflowRunRepository) GetById 

func (r *WorkflowRunRepository) GetById(ctx context.Context, id string) (*domain.WorkflowRun, error)

func (*WorkflowRunRepository) Save 

func (r *WorkflowRunRepository) Save(ctx context.Context, workflowRun *domain.WorkflowRun) (*domain.WorkflowRun, error)

func (*WorkflowRunRepository) SaveWithCascading added in v0.4.0 

func (r *WorkflowRunRepository) SaveWithCascading(ctx context.Context, workflowRun *domain.WorkflowRun) (*domain.WorkflowRun, 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.