prisma

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 NewDispatcherRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.DispatcherEngineRepository
• func NewEngineRepository(pool *pgxpool.Pool, cf *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) (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(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) (repository.EventEngineRepository, func() error, error)
• 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(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) (*stepRunEngineRepository, func() error, error)
• 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(stepRunRepository *stepRunEngineRepository, pool *pgxpool.Pool, ...) (repository.WorkflowRunEngineRepository, func() error, error)
• func NewWorkflowRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) (repository.WorkflowRunAPIRepository, func() error, error)
• func UniqueSet[T any](i []T, keyFunc func(T) string) map[string]struct{}
• type PrismaRepositoryOpt
  • func WithCache(cache cache.Cacheable) PrismaRepositoryOpt
  • func WithLogger(l *zerolog.Logger) PrismaRepositoryOpt
  • func WithMetered(metered *metered.Metered) PrismaRepositoryOpt
  • func WithValidator(v validator.Validator) PrismaRepositoryOpt
• type PrismaRepositoryOpts

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 NewDispatcherRepository

func NewDispatcherRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.DispatcherEngineRepository

func NewEngineRepository

func NewEngineRepository(pool *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(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) (repository.EventEngineRepository, func() error, error)

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

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 NewStepRunEngineRepository

func NewStepRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cf *server.ConfigFileRuntime, rlCache *cache.Cache, queueCache *cache.Cache) (*stepRunEngineRepository, func() error, error)

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

func NewWebhookWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.WebhookWorkerEngineRepository

func NewWebhookWorkerRepository

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, cache cache.Cacheable) repository.WorkflowEngineRepository

func NewWorkflowRepository

func NewWorkflowRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.WorkflowAPIRepository

func NewWorkflowRunEngineRepository

func NewWorkflowRunEngineRepository(stepRunRepository *stepRunEngineRepository, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered, cf *server.ConfigFileRuntime, cbs ...repository.Callback[*dbsqlc.WorkflowRun]) (repository.WorkflowRunEngineRepository, func() error, error)

func NewWorkflowRunRepository

func NewWorkflowRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered, cf *server.ConfigFileRuntime) (repository.WorkflowRunAPIRepository, func() error, error)

func UniqueSet

func UniqueSet[T any](i []T, keyFunc func(T) string) map[string]struct{}

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
}