prisma

Documentation

Index

• func NewDispatcherRepository(client *db.PrismaClient, v validator.Validator) repository.DispatcherRepository
• func NewEventRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator) repository.EventRepository
• func NewJobRunRepository(client *db.PrismaClient, 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 NewTenantRepository(client *db.PrismaClient, v validator.Validator) repository.TenantRepository
• func NewTickerRepository(client *db.PrismaClient, 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 WithValidator(v validator.Validator) PrismaRepositoryOpt
• type PrismaRepositoryOpts

Functions

func NewDispatcherRepository

func NewDispatcherRepository(client *db.PrismaClient, v validator.Validator) repository.DispatcherRepository

func NewEventRepository

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

func NewJobRunRepository

func NewJobRunRepository(client *db.PrismaClient, v validator.Validator) 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) repository.StepRunRepository

func NewTenantRepository

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

func NewTickerRepository

func NewTickerRepository(client *db.PrismaClient, v validator.Validator) 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) repository.WorkflowRepository

func NewWorkflowRunRepository

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

Types

type PrismaRepositoryOpt

type PrismaRepositoryOpt func(*PrismaRepositoryOpts)

func WithValidator

func WithValidator(v validator.Validator) PrismaRepositoryOpt

type PrismaRepositoryOpts

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