Documentation
¶
Index ¶
- func NewAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, cf *server.ConfigFileRuntime, ...) (repository.APIRepository, func() error, error)
- func NewAPITokenRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.APITokenRepository
- func NewBulkSemaphoreReleaser(shared *sharedRepository, conf buffer.ConfigFileBuffer) (*buffer.TenantBufferManager[semaphoreReleaseOpts, pgtype.UUID], error)
- func NewDispatcherRepository(pool *pgxpool.Pool, essentialPool *pgxpool.Pool, v validator.Validator, ...) repository.DispatcherEngineRepository
- func NewEngineRepository(pool *pgxpool.Pool, essentialPool *pgxpool.Pool, cf *server.ConfigFileRuntime, ...) (func() error, repository.EngineRepository, error)
- 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(shared *sharedRepository, m *metered.Metered, ...) 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(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRepository
- func NewStepRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.StepRunAPIRepository
- func NewStepRunEngineRepository(shared *sharedRepository, cf *server.ConfigFileRuntime, rlCache *cache.Cache, ...) *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, l *zerolog.Logger, 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, essentialPool *pgxpool.Pool, v validator.Validator, ...) 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(shared *sharedRepository, m *metered.Metered, cf *server.ConfigFileRuntime, ...) repository.WorkflowRunEngineRepository
- func NewWorkflowRunRepository(client *db.PrismaClient, shared *sharedRepository, m *metered.Metered, ...) 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, cf *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) (repository.APIRepository, func() error, error)
func NewAPITokenRepository ¶
func NewAPITokenRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.APITokenRepository
func NewBulkSemaphoreReleaser ¶ added in v0.52.12
func NewBulkSemaphoreReleaser(shared *sharedRepository, conf buffer.ConfigFileBuffer) (*buffer.TenantBufferManager[semaphoreReleaseOpts, pgtype.UUID], error)
func NewDispatcherRepository ¶
func NewDispatcherRepository(pool *pgxpool.Pool, essentialPool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.DispatcherEngineRepository
func NewEngineRepository ¶
func NewEngineRepository(pool *pgxpool.Pool, essentialPool *pgxpool.Pool, cf *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) (func() error, repository.EngineRepository, error)
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(shared *sharedRepository, m *metered.Metered, bufferConf buffer.ConfigFileBuffer) 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(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRepository
func NewStepRunAPIRepository ¶
func NewStepRunAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRunAPIRepository
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, l *zerolog.Logger, 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 NewWorkflowRepository ¶
func NewWorkflowRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.WorkflowAPIRepository
func NewWorkflowRunEngineRepository ¶
func NewWorkflowRunEngineRepository(shared *sharedRepository, m *metered.Metered, cf *server.ConfigFileRuntime, cbs ...repository.TenantScopedCallback[*dbsqlc.WorkflowRun]) repository.WorkflowRunEngineRepository
func NewWorkflowRunRepository ¶
func NewWorkflowRunRepository(client *db.PrismaClient, shared *sharedRepository, m *metered.Metered, cf *server.ConfigFileRuntime) 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
- buffer_queue_step_run.go
- buffer_release_semaphores.go
- buffer_step_run_events.go
- buffer_step_run_status.go
- buffer_user_events.go
- buffer_workflow_run_create.go
- dispatcher.go
- event.go
- get_group_key_run.go
- health.go
- job_run.go
- log.go
- rate_limit.go
- repository.go
- scheduler.go
- scheduler_assignment.go
- scheduler_lease.go
- scheduler_queue.go
- scheduler_rate_limit.go
- security_check.go
- shared.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.