repository

package
v0.3.8 Latest Latest
Warning

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

Go to latest
Published: Apr 13, 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 AccessRepository added in v0.3.0

type AccessRepository struct{}

func NewAccessRepository added in v0.3.0

func NewAccessRepository() *AccessRepository

func (*AccessRepository) GetById added in v0.3.0

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

type AcmeAccountRepository added in v0.2.8

type AcmeAccountRepository struct{}

func NewAcmeAccountRepository added in v0.2.8

func NewAcmeAccountRepository() *AcmeAccountRepository

func (*AcmeAccountRepository) GetByCAAndEmail added in v0.2.8

func (r *AcmeAccountRepository) GetByCAAndEmail(ca, email string) (*domain.AcmeAccount, error)

func (*AcmeAccountRepository) Save added in v0.2.8

type CertificateRepository added in v0.3.0

type CertificateRepository struct{}

func NewCertificateRepository added in v0.3.0

func NewCertificateRepository() *CertificateRepository

func (*CertificateRepository) DeleteWhere added in v0.3.5

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

func (*CertificateRepository) GetById added in v0.3.0

func (*CertificateRepository) GetByWorkflowNodeId added in v0.3.0

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

func (*CertificateRepository) ListExpireSoon added in v0.3.0

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

func (*CertificateRepository) Save added in v0.3.0

type SettingsRepository added in v0.3.0

type SettingsRepository struct{}

func NewSettingsRepository added in v0.3.0

func NewSettingsRepository() *SettingsRepository

func (*SettingsRepository) GetByName added in v0.3.0

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

type StatisticsRepository added in v0.3.0

type StatisticsRepository struct{}

func NewStatisticsRepository added in v0.3.0

func NewStatisticsRepository() *StatisticsRepository

func (*StatisticsRepository) Get added in v0.3.0

type WorkflowLogRepository added in v0.3.5

type WorkflowLogRepository struct{}

func NewWorkflowLogRepository added in v0.3.5

func NewWorkflowLogRepository() *WorkflowLogRepository

func (*WorkflowLogRepository) ListByWorkflowRunId added in v0.3.5

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

func (*WorkflowLogRepository) Save added in v0.3.5

type WorkflowOutputRepository added in v0.3.0

type WorkflowOutputRepository struct{}

func NewWorkflowOutputRepository added in v0.3.0

func NewWorkflowOutputRepository() *WorkflowOutputRepository

func (*WorkflowOutputRepository) GetByNodeId added in v0.3.0

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

func (*WorkflowOutputRepository) Save added in v0.3.0

func (*WorkflowOutputRepository) SaveWithCertificate added in v0.3.0

func (r *WorkflowOutputRepository) SaveWithCertificate(ctx context.Context, workflowOutput *domain.WorkflowOutput, certificate *domain.Certificate) (*domain.WorkflowOutput, error)

type WorkflowRepository added in v0.3.0

type WorkflowRepository struct{}

func NewWorkflowRepository added in v0.3.0

func NewWorkflowRepository() *WorkflowRepository

func (*WorkflowRepository) GetById added in v0.3.0

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

func (*WorkflowRepository) ListEnabledAuto added in v0.3.0

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

func (*WorkflowRepository) Save added in v0.3.0

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

type WorkflowRunRepository added in v0.3.0

type WorkflowRunRepository struct{}

func NewWorkflowRunRepository added in v0.3.0

func NewWorkflowRunRepository() *WorkflowRunRepository

func (*WorkflowRunRepository) DeleteWhere added in v0.3.5

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

func (*WorkflowRunRepository) GetById added in v0.3.0

func (*WorkflowRunRepository) Save added in v0.3.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL