Documentation
¶
Index ¶
- func NewAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.APIRepository
- func NewAPITokenRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.APITokenRepository
- func NewDispatcherRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.DispatcherEngineRepository
- func NewEngineRepository(pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.EngineRepository
- func NewEngineTokenRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.EngineTokenRepository
- func NewEntitlementRepository(pool *pgxpool.Pool, s *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) repository.EntitlementsRepository
- func NewEventAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.EventAPIRepository
- func NewEventEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.EventEngineRepository
- func NewGetGroupKeyRunRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.GetGroupKeyRunEngineRepository
- func NewGithubRepository(client *db.PrismaClient, v validator.Validator) repository.GithubRepository
- func NewHealthAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool) repository.HealthRepository
- func NewHealthEngineRepository(pool *pgxpool.Pool) repository.HealthRepository
- func NewJobRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.JobRunAPIRepository
- func NewJobRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.JobRunEngineRepository
- func NewLogAPIRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.LogsAPIRepository
- func NewLogEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.LogsEngineRepository
- func NewRateLimitEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.RateLimitEngineRepository
- func NewSNSRepository(client *db.PrismaClient, v validator.Validator) repository.SNSRepository
- func NewSlackRepository(client *db.PrismaClient, v validator.Validator) repository.SlackRepository
- func NewStepRepository(client *db.PrismaClient, v validator.Validator) repository.StepRepository
- func NewStepRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.StepRunAPIRepository
- func NewStepRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRunEngineRepository
- func NewStreamEventsEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StreamEventsEngineRepository
- func NewTenantAPIRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.TenantAPIRepository
- func NewTenantAlertingAPIRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.TenantAlertingAPIRepository
- func NewTenantAlertingEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.TenantAlertingEngineRepository
- func NewTenantEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.TenantEngineRepository
- func NewTenantInviteRepository(client *db.PrismaClient, v validator.Validator) repository.TenantInviteRepository
- func NewTenantLimitRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.TenantLimitRepository
- func NewTickerRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.TickerEngineRepository
- func NewUserRepository(client *db.PrismaClient, v validator.Validator) repository.UserRepository
- func NewUserSessionRepository(client *db.PrismaClient, v validator.Validator) repository.UserSessionRepository
- func NewWorkerAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.WorkerAPIRepository
- func NewWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.WorkerEngineRepository
- func NewWorkflowEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.WorkflowEngineRepository
- func NewWorkflowRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.WorkflowAPIRepository
- func NewWorkflowRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.WorkflowRunEngineRepository
- func NewWorkflowRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.WorkflowRunAPIRepository
- type PrismaRepositoryOpt
- type PrismaRepositoryOpts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAPIRepository ¶ added in v0.17.0
func NewAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.APIRepository
func NewAPITokenRepository ¶ added in v0.7.0
func NewAPITokenRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.APITokenRepository
func NewDispatcherRepository ¶
func NewDispatcherRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.DispatcherEngineRepository
func NewEngineRepository ¶ added in v0.17.0
func NewEngineRepository(pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.EngineRepository
func NewEngineTokenRepository ¶ added in v0.17.0
func NewEngineTokenRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.EngineTokenRepository
func NewEntitlementRepository ¶ added in v0.31.0
func NewEntitlementRepository(pool *pgxpool.Pool, s *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) repository.EntitlementsRepository
func NewEventAPIRepository ¶ added in v0.17.0
func NewEventAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.EventAPIRepository
func NewEventEngineRepository ¶ added in v0.17.0
func NewEventEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.EventEngineRepository
func NewGetGroupKeyRunRepository ¶ added in v0.8.0
func NewGetGroupKeyRunRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.GetGroupKeyRunEngineRepository
func NewGithubRepository ¶ added in v0.11.0
func NewGithubRepository(client *db.PrismaClient, v validator.Validator) repository.GithubRepository
func NewHealthAPIRepository ¶ added in v0.17.0
func NewHealthAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool) repository.HealthRepository
func NewHealthEngineRepository ¶ added in v0.17.0
func NewHealthEngineRepository(pool *pgxpool.Pool) repository.HealthRepository
func NewJobRunAPIRepository ¶ added in v0.17.0
func NewJobRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.JobRunAPIRepository
func NewJobRunEngineRepository ¶ added in v0.17.0
func NewJobRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.JobRunEngineRepository
func NewLogAPIRepository ¶ added in v0.17.0
func NewLogAPIRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.LogsAPIRepository
func NewLogEngineRepository ¶ added in v0.17.0
func NewLogEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.LogsEngineRepository
func NewRateLimitEngineRepository ¶ added in v0.19.0
func NewRateLimitEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.RateLimitEngineRepository
func NewSNSRepository ¶ added in v0.15.0
func NewSNSRepository(client *db.PrismaClient, v validator.Validator) repository.SNSRepository
func NewSlackRepository ¶ added in v0.25.0
func NewSlackRepository(client *db.PrismaClient, v validator.Validator) repository.SlackRepository
func NewStepRepository ¶
func NewStepRepository(client *db.PrismaClient, v validator.Validator) repository.StepRepository
func NewStepRunAPIRepository ¶ added in v0.17.0
func NewStepRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRunAPIRepository
func NewStepRunEngineRepository ¶ added in v0.17.0
func NewStepRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRunEngineRepository
func NewStreamEventsEngineRepository ¶ added in v0.19.0
func NewStreamEventsEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StreamEventsEngineRepository
func NewTenantAPIRepository ¶ added in v0.17.0
func NewTenantAPIRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.TenantAPIRepository
func NewTenantAlertingAPIRepository ¶ added in v0.25.0
func NewTenantAlertingAPIRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.TenantAlertingAPIRepository
func NewTenantAlertingEngineRepository ¶ added in v0.25.0
func NewTenantAlertingEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.TenantAlertingEngineRepository
func NewTenantEngineRepository ¶ added in v0.17.0
func NewTenantEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.TenantEngineRepository
func NewTenantInviteRepository ¶
func NewTenantInviteRepository(client *db.PrismaClient, v validator.Validator) repository.TenantInviteRepository
func NewTenantLimitRepository ¶ added in v0.31.0
func NewTenantLimitRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, s *server.ConfigFileRuntime) repository.TenantLimitRepository
func NewTickerRepository ¶
func NewTickerRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.TickerEngineRepository
func NewUserRepository ¶
func NewUserRepository(client *db.PrismaClient, v validator.Validator) repository.UserRepository
func NewUserSessionRepository ¶
func NewUserSessionRepository(client *db.PrismaClient, v validator.Validator) repository.UserSessionRepository
func NewWorkerAPIRepository ¶ added in v0.17.0
func NewWorkerAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkerAPIRepository
func NewWorkerEngineRepository ¶ added in v0.17.0
func NewWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkerEngineRepository
func NewWorkflowEngineRepository ¶ added in v0.17.0
func NewWorkflowEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkflowEngineRepository
func NewWorkflowRepository ¶
func NewWorkflowRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.WorkflowAPIRepository
func NewWorkflowRunEngineRepository ¶ added in v0.17.0
func NewWorkflowRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkflowRunEngineRepository
func NewWorkflowRunRepository ¶
func NewWorkflowRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkflowRunAPIRepository
Types ¶
type PrismaRepositoryOpt ¶
type PrismaRepositoryOpt func(*PrismaRepositoryOpts)
func WithCache ¶ added in v0.17.0
func WithCache(cache cache.Cacheable) PrismaRepositoryOpt
func WithLogger ¶
func WithLogger(l *zerolog.Logger) PrismaRepositoryOpt
func WithMetered ¶ added in v0.31.0
func WithMetered(metered *metered.Metered) PrismaRepositoryOpt
func WithValidator ¶
func WithValidator(v validator.Validator) PrismaRepositoryOpt
type PrismaRepositoryOpts ¶
type PrismaRepositoryOpts struct {
// contains filtered or unexported fields
}
Source Files
¶
- api_token.go
- dispatcher.go
- event.go
- get_group_key_run.go
- github.go
- health.go
- job_run.go
- log.go
- rate_limit.go
- repository.go
- rollback.go
- slack.go
- sns.go
- step.go
- step_run.go
- stream_event.go
- tenant.go
- tenant_alerting.go
- tenant_invite.go
- tenant_limit.go
- ticker.go
- user.go
- user_session.go
- worker.go
- workflow.go
- workflow_run.go
Directories
Click to show internal directories.
Click to hide internal directories.