Documentation
¶
Index ¶
- type AccessRepository
- type AcmeAccountRepository
- type CertificateRepository
- func (r *CertificateRepository) DeleteWhere(ctx context.Context, exprs ...dbx.Expression) (int, error)
- func (r *CertificateRepository) GetById(ctx context.Context, id string) (*domain.Certificate, error)
- func (r *CertificateRepository) GetByWorkflowNodeId(ctx context.Context, workflowNodeId string) (*domain.Certificate, error)
- func (r *CertificateRepository) GetByWorkflowRunIdAndNodeId(ctx context.Context, workflowRunId string, workflowNodeId string) (*domain.Certificate, error)
- func (r *CertificateRepository) ListExpireSoon(ctx context.Context) ([]*domain.Certificate, error)
- func (r *CertificateRepository) Save(ctx context.Context, certificate *domain.Certificate) (*domain.Certificate, error)
- type SettingsRepository
- type StatisticsRepository
- type WorkflowLogRepository
- type WorkflowOutputRepository
- func (r *WorkflowOutputRepository) GetByNodeId(ctx context.Context, workflowNodeId string) (*domain.WorkflowOutput, error)
- func (r *WorkflowOutputRepository) Save(ctx context.Context, workflowOutput *domain.WorkflowOutput) (*domain.WorkflowOutput, error)
- func (r *WorkflowOutputRepository) SaveWithCertificate(ctx context.Context, workflowOutput *domain.WorkflowOutput, ...) (*domain.WorkflowOutput, error)
- type WorkflowRepository
- type WorkflowRunRepository
- func (r *WorkflowRunRepository) DeleteWhere(ctx context.Context, exprs ...dbx.Expression) (int, error)
- func (r *WorkflowRunRepository) GetById(ctx context.Context, id string) (*domain.WorkflowRun, error)
- func (r *WorkflowRunRepository) Save(ctx context.Context, workflowRun *domain.WorkflowRun) (*domain.WorkflowRun, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AccessRepository ¶
type AccessRepository struct{}
func NewAccessRepository ¶
func NewAccessRepository() *AccessRepository
type AcmeAccountRepository ¶
type AcmeAccountRepository struct{}
func NewAcmeAccountRepository ¶
func NewAcmeAccountRepository() *AcmeAccountRepository
func (*AcmeAccountRepository) GetByCAAndEmail ¶
func (r *AcmeAccountRepository) GetByCAAndEmail(ca, email string) (*domain.AcmeAccount, error)
func (*AcmeAccountRepository) Save ¶
func (r *AcmeAccountRepository) Save(ctx context.Context, acmeAccount *domain.AcmeAccount) (*domain.AcmeAccount, 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) GetByWorkflowNodeId ¶
func (r *CertificateRepository) GetByWorkflowNodeId(ctx context.Context, workflowNodeId string) (*domain.Certificate, error)
func (*CertificateRepository) GetByWorkflowRunIdAndNodeId ¶
func (r *CertificateRepository) GetByWorkflowRunIdAndNodeId(ctx context.Context, workflowRunId string, workflowNodeId string) (*domain.Certificate, error)
func (*CertificateRepository) ListExpireSoon ¶
func (r *CertificateRepository) ListExpireSoon(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
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) GetByNodeId ¶
func (r *WorkflowOutputRepository) GetByNodeId(ctx context.Context, workflowNodeId string) (*domain.WorkflowOutput, error)
func (*WorkflowOutputRepository) Save ¶
func (r *WorkflowOutputRepository) Save(ctx context.Context, workflowOutput *domain.WorkflowOutput) (*domain.WorkflowOutput, error)
func (*WorkflowOutputRepository) SaveWithCertificate ¶
func (r *WorkflowOutputRepository) SaveWithCertificate(ctx context.Context, workflowOutput *domain.WorkflowOutput, certificate *domain.Certificate) (*domain.WorkflowOutput, error)
type WorkflowRepository ¶
type WorkflowRepository struct{}
func NewWorkflowRepository ¶
func NewWorkflowRepository() *WorkflowRepository
func (*WorkflowRepository) ListEnabledAuto ¶
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)
Source Files
Click to show internal directories.
Click to hide internal directories.