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, queuePool *pgxpool.Pool, cf *server.ConfigFileRuntime, ...) 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 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 NewSecurityCheckRepository(client *db.PrismaClient, pool *pgxpool.Pool) repository.SecurityCheckRepository
- 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(pool *pgxpool.Pool, client *db.PrismaClient, v validator.Validator, ...) 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 NewWebhookWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.WebhookWorkerEngineRepository
- func NewWebhookWorkerRepository(client *db.PrismaClient, v validator.Validator) repository.WebhookWorkerRepository
- 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
- func UniqueSet[T any](i []T, keyFunc func(T) string) map[string]struct{}
- type PrismaRepositoryOpt
- type PrismaRepositoryOpts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAPIRepository ¶
func NewAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.APIRepository
func NewAPITokenRepository ¶
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 ¶
func NewEngineRepository(pool *pgxpool.Pool, queuePool *pgxpool.Pool, cf *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) repository.EngineRepository
func NewEngineTokenRepository ¶
func NewEngineTokenRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.EngineTokenRepository
func NewEntitlementRepository ¶
func NewEntitlementRepository(pool *pgxpool.Pool, s *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) repository.EntitlementsRepository
func NewEventAPIRepository ¶
func NewEventAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.EventAPIRepository
func NewEventEngineRepository ¶
func NewEventEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.EventEngineRepository
func NewGetGroupKeyRunRepository ¶
func NewGetGroupKeyRunRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.GetGroupKeyRunEngineRepository
func NewHealthAPIRepository ¶
func NewHealthAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool) repository.HealthRepository
func NewHealthEngineRepository ¶
func NewHealthEngineRepository(pool *pgxpool.Pool) repository.HealthRepository
func NewJobRunAPIRepository ¶
func NewJobRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.JobRunAPIRepository
func NewJobRunEngineRepository ¶
func NewJobRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.JobRunEngineRepository
func NewLogAPIRepository ¶
func NewLogAPIRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.LogsAPIRepository
func NewLogEngineRepository ¶
func NewLogEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.LogsEngineRepository
func NewRateLimitEngineRepository ¶
func NewRateLimitEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.RateLimitEngineRepository
func NewSNSRepository ¶
func NewSNSRepository(client *db.PrismaClient, v validator.Validator) repository.SNSRepository
func NewSecurityCheckRepository ¶ added in v0.34.2
func NewSecurityCheckRepository(client *db.PrismaClient, pool *pgxpool.Pool) repository.SecurityCheckRepository
func NewSlackRepository ¶
func NewSlackRepository(client *db.PrismaClient, v validator.Validator) repository.SlackRepository
func NewStepRepository ¶
func NewStepRepository(client *db.PrismaClient, v validator.Validator) repository.StepRepository
func NewStepRunAPIRepository ¶
func NewStepRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRunAPIRepository
func NewStepRunEngineRepository ¶
func NewStepRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cf *server.ConfigFileRuntime) repository.StepRunEngineRepository
func NewStreamEventsEngineRepository ¶
func NewStreamEventsEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StreamEventsEngineRepository
func NewTenantAPIRepository ¶
func NewTenantAPIRepository(pool *pgxpool.Pool, client *db.PrismaClient, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.TenantAPIRepository
func NewTenantAlertingAPIRepository ¶
func NewTenantAlertingAPIRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.TenantAlertingAPIRepository
func NewTenantAlertingEngineRepository ¶
func NewTenantAlertingEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.TenantAlertingEngineRepository
func NewTenantEngineRepository ¶
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 ¶
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 NewWebhookWorkerEngineRepository ¶ added in v0.34.0
func NewWebhookWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.WebhookWorkerEngineRepository
func NewWebhookWorkerRepository ¶ added in v0.34.0
func NewWebhookWorkerRepository(client *db.PrismaClient, v validator.Validator) repository.WebhookWorkerRepository
func NewWorkerAPIRepository ¶
func NewWorkerAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkerAPIRepository
func NewWorkerEngineRepository ¶
func NewWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkerEngineRepository
func NewWorkflowEngineRepository ¶
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 ¶
func NewWorkflowRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered, cbs ...repository.Callback[*dbsqlc.WorkflowRun]) 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 ¶
func WithCache(cache cache.Cacheable) PrismaRepositoryOpt
func WithLogger ¶
func WithLogger(l *zerolog.Logger) PrismaRepositoryOpt
func WithMetered ¶
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
- health.go
- job_run.go
- log.go
- rate_limit.go
- repository.go
- rollback.go
- security_check.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
- webhook_worker.go
- webhook_worker_api.go
- worker.go
- workflow.go
- workflow_run.go
Directories
Click to show internal directories.
Click to hide internal directories.