prisma

Documentation

Index

• func NewAPITokenRepository(client *db.PrismaClient, v validator.Validator) repository.APITokenRepository
• func NewDispatcherRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.DispatcherRepository
• func NewEventRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.EventRepository
• func NewGetGroupKeyRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.GetGroupKeyRunRepository
• func NewJobRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.JobRunRepository
• func NewPrismaRepository(client *db.PrismaClient, pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.Repository
• func NewStepRepository(client *db.PrismaClient, v validator.Validator) repository.StepRepository
• func NewStepRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.StepRunRepository
• func NewTenantInviteRepository(client *db.PrismaClient, v validator.Validator) repository.TenantInviteRepository
• func NewTenantRepository(client *db.PrismaClient, v validator.Validator) repository.TenantRepository
• func NewTickerRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.TickerRepository
• func NewUserRepository(client *db.PrismaClient, v validator.Validator) repository.UserRepository
• func NewUserSessionRepository(client *db.PrismaClient, v validator.Validator) repository.UserSessionRepository
• func NewWorkerRepository(client *db.PrismaClient, v validator.Validator) repository.WorkerRepository
• func NewWorkflowRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.WorkflowRepository
• func NewWorkflowRunRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, ...) repository.WorkflowRunRepository
• type PrismaRepositoryOpt
  • func WithLogger(l *zerolog.Logger) PrismaRepositoryOpt
  • func WithValidator(v validator.Validator) PrismaRepositoryOpt
• type PrismaRepositoryOpts

Functions

func NewAPITokenRepository

func NewAPITokenRepository(client *db.PrismaClient, v validator.Validator) repository.APITokenRepository

func NewDispatcherRepository

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

func NewEventRepository

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

func NewGetGroupKeyRunRepository

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

func NewJobRunRepository

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

func NewPrismaRepository

func NewPrismaRepository(client *db.PrismaClient, pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.Repository

func NewStepRepository

func NewStepRepository(client *db.PrismaClient, v validator.Validator) repository.StepRepository

func NewStepRunRepository

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

func NewTenantInviteRepository

func NewTenantInviteRepository(client *db.PrismaClient, v validator.Validator) repository.TenantInviteRepository

func NewTenantRepository

func NewTenantRepository(client *db.PrismaClient, v validator.Validator) repository.TenantRepository

func NewTickerRepository

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

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 NewWorkerRepository

func NewWorkerRepository(client *db.PrismaClient, v validator.Validator) repository.WorkerRepository

func NewWorkflowRepository

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

func NewWorkflowRunRepository

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

Types

type PrismaRepositoryOpt

type PrismaRepositoryOpt func(*PrismaRepositoryOpts)

func WithLogger

func WithLogger(l *zerolog.Logger) PrismaRepositoryOpt

func WithValidator

func WithValidator(v validator.Validator) PrismaRepositoryOpt

type PrismaRepositoryOpts

type PrismaRepositoryOpts struct {
	// contains filtered or unexported fields
}