repository

Documentation

Index

• type AccessRepository
  • func NewAccessRepository() *AccessRepository
  • func (a *AccessRepository) GetById(ctx context.Context, id string) (*domain.Access, error)
• type AcmeAccountRepository
  • func NewAcmeAccountRepository() *AcmeAccountRepository
  • func (r *AcmeAccountRepository) GetByCAAndEmail(ca, email string) (*domain.AcmeAccount, error)
  • func (r *AcmeAccountRepository) Save(ca, email, key string, resource *registration.Resource) error
• type CertificateRepository
  • func NewCertificateRepository() *CertificateRepository
  • func (c *CertificateRepository) GetExpireSoon(ctx context.Context) ([]domain.Certificate, error)
• type SettingRepository
  • func NewSettingRepository() *SettingRepository
  • func (s *SettingRepository) GetByName(ctx context.Context, name string) (*domain.Setting, error)
• type StatisticsRepository
  • func NewStatisticsRepository() *StatisticsRepository
  • func (r *StatisticsRepository) Get(ctx context.Context) (*domain.Statistics, error)
• type WorkflowOutputRepository
  • func NewWorkflowOutputRepository() *WorkflowOutputRepository
  • func (w *WorkflowOutputRepository) Get(ctx context.Context, nodeId string) (*domain.WorkflowOutput, error)
  • func (w *WorkflowOutputRepository) GetCertificate(ctx context.Context, nodeId string) (*domain.Certificate, error)
  • func (w *WorkflowOutputRepository) Save(ctx context.Context, output *domain.WorkflowOutput, ...) error
• type WorkflowRepository
  • func NewWorkflowRepository() *WorkflowRepository
  • func (w *WorkflowRepository) Get(ctx context.Context, id string) (*domain.Workflow, error)
  • func (w *WorkflowRepository) ListEnabledAuto(ctx context.Context) ([]domain.Workflow, error)
  • func (w *WorkflowRepository) SaveRunLog(ctx context.Context, log *domain.WorkflowRunLog) error

Types

type AccessRepository

type AccessRepository struct{}

func NewAccessRepository

func NewAccessRepository() *AccessRepository

func (*AccessRepository) GetById

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

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(ca, email, key string, resource *registration.Resource) error

type CertificateRepository

type CertificateRepository struct{}

func NewCertificateRepository

func NewCertificateRepository() *CertificateRepository

func (*CertificateRepository) GetExpireSoon

func (c *CertificateRepository) GetExpireSoon(ctx context.Context) ([]domain.Certificate, error)

type SettingRepository

type SettingRepository struct{}

func NewSettingRepository

func NewSettingRepository() *SettingRepository

func (*SettingRepository) GetByName

func (s *SettingRepository) GetByName(ctx context.Context, name string) (*domain.Setting, 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 WorkflowOutputRepository

type WorkflowOutputRepository struct{}

func NewWorkflowOutputRepository

func NewWorkflowOutputRepository() *WorkflowOutputRepository

func (*WorkflowOutputRepository) Get

func (w *WorkflowOutputRepository) Get(ctx context.Context, nodeId string) (*domain.WorkflowOutput, error)

func (*WorkflowOutputRepository) GetCertificate

func (w *WorkflowOutputRepository) GetCertificate(ctx context.Context, nodeId string) (*domain.Certificate, error)

func (*WorkflowOutputRepository) Save

func (w *WorkflowOutputRepository) Save(ctx context.Context, output *domain.WorkflowOutput, certificate *domain.Certificate, cb func(id string) error) error

保存节点输出

type WorkflowRepository

type WorkflowRepository struct{}

func NewWorkflowRepository

func NewWorkflowRepository() *WorkflowRepository

func (*WorkflowRepository) Get

func (w *WorkflowRepository) Get(ctx context.Context, id string) (*domain.Workflow, error)

func (*WorkflowRepository) ListEnabledAuto

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

func (*WorkflowRepository) SaveRunLog

func (w *WorkflowRepository) SaveRunLog(ctx context.Context, log *domain.WorkflowRunLog) error