prisma

package
v0.33.0-alpha.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 14, 2024 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAPIRepository added in v0.17.0 

func NewAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.APIRepository

func NewAPITokenRepository added in v0.7.0 

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 added in v0.17.0 

func NewEngineRepository(pool *pgxpool.Pool, fs ...PrismaRepositoryOpt) repository.EngineRepository

func NewEngineTokenRepository added in v0.17.0 

func NewEngineTokenRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.EngineTokenRepository

func NewEntitlementRepository added in v0.31.0 

func NewEntitlementRepository(pool *pgxpool.Pool, s *server.ConfigFileRuntime, fs ...PrismaRepositoryOpt) repository.EntitlementsRepository

func NewEventAPIRepository added in v0.17.0 

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

func NewEventEngineRepository added in v0.17.0 

func NewEventEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.EventEngineRepository

func NewGetGroupKeyRunRepository added in v0.8.0 

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

func NewGithubRepository added in v0.11.0 

func NewGithubRepository(client *db.PrismaClient, v validator.Validator) repository.GithubRepository

func NewHealthAPIRepository added in v0.17.0 

func NewHealthAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool) repository.HealthRepository

func NewHealthEngineRepository added in v0.17.0 

func NewHealthEngineRepository(pool *pgxpool.Pool) repository.HealthRepository

func NewJobRunAPIRepository added in v0.17.0 

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

func NewJobRunEngineRepository added in v0.17.0 

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

func NewLogAPIRepository added in v0.17.0 

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

func NewLogEngineRepository added in v0.17.0 

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

func NewRateLimitEngineRepository added in v0.19.0 

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

func NewSNSRepository added in v0.15.0 

func NewSNSRepository(client *db.PrismaClient, v validator.Validator) repository.SNSRepository

func NewSlackRepository added in v0.25.0 

func NewSlackRepository(client *db.PrismaClient, v validator.Validator) repository.SlackRepository

func NewStepRepository 

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

func NewStepRunAPIRepository added in v0.17.0 

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

func NewStepRunEngineRepository added in v0.17.0 

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

func NewStreamEventsEngineRepository added in v0.19.0 

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

func NewTenantAPIRepository added in v0.17.0 

func NewTenantAPIRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.TenantAPIRepository

func NewTenantAlertingAPIRepository added in v0.25.0 

func NewTenantAlertingAPIRepository(client *db.PrismaClient, v validator.Validator, cache cache.Cacheable) repository.TenantAlertingAPIRepository

func NewTenantAlertingEngineRepository added in v0.25.0 

func NewTenantAlertingEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, cache cache.Cacheable) repository.TenantAlertingEngineRepository

func NewTenantEngineRepository added in v0.17.0 

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 added in v0.31.0 

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 NewWebhookWorkerRepository 

func NewWebhookWorkerRepository(db *db.PrismaClient, v validator.Validator, l *zerolog.Logger) repository.WebhookWorkerRepository

func NewWorkerAPIRepository added in v0.17.0 

func NewWorkerAPIRepository(client *db.PrismaClient, pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkerAPIRepository

func NewWorkerEngineRepository added in v0.17.0 

func NewWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) repository.WorkerEngineRepository

func NewWorkflowEngineRepository added in v0.17.0 

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 added in v0.17.0 

func NewWorkflowRunEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, m *metered.Metered) 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 added in v0.17.0 

func WithCache(cache cache.Cacheable) PrismaRepositoryOpt

func WithLogger 

func WithLogger(l *zerolog.Logger) PrismaRepositoryOpt

func WithMetered added in v0.31.0 

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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.