postgres

Documentation

Index

• func NewAPIRepository(pool *pgxpool.Pool, cf *server.ConfigFileRuntime, fs ...PostgresRepositoryOpt) (repository.APIRepository, func() error, error)
• func NewAPITokenRepository(shared *sharedRepository, 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 NewEntitlementRepository(pool *pgxpool.Pool, s *server.ConfigFileRuntime, fs ...PostgresRepositoryOpt) repository.EntitlementsRepository
• func NewEventAPIRepository(shared *sharedRepository) 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(shared *sharedRepository) repository.HealthRepository
• func NewHealthEngineRepository(pool *pgxpool.Pool) repository.HealthRepository
• func NewJobRunAPIRepository(shared *sharedRepository) repository.JobRunAPIRepository
• func NewJobRunEngineRepository(shared *sharedRepository) 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 NewMessageQueueRepository(shared *sharedRepository) *messageQueueRepository
• func NewRateLimitEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.RateLimitEngineRepository
• func NewSNSRepository(shared *sharedRepository) repository.SNSRepository
• func NewSecurityCheckRepository(shared *sharedRepository) repository.SecurityCheckRepository
• func NewSlackRepository(shared *sharedRepository) repository.SlackRepository
• func NewStepRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.StepRepository
• func NewStepRunAPIRepository(shared *sharedRepository) 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(shared *sharedRepository, cache cache.Cacheable) repository.TenantAPIRepository
• func NewTenantAlertingRepository(shared *sharedRepository, cache cache.Cacheable) repository.TenantAlertingRepository
• func NewTenantEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger, ...) repository.TenantEngineRepository
• func NewTenantInviteRepository(shared *sharedRepository) 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(shared *sharedRepository) repository.UserRepository
• func NewUserSessionRepository(shared *sharedRepository) repository.UserSessionRepository
• func NewWebhookWorkerEngineRepository(pool *pgxpool.Pool, v validator.Validator, l *zerolog.Logger) repository.WebhookWorkerEngineRepository
• func NewWebhookWorkerRepository(shared *sharedRepository) repository.WebhookWorkerRepository
• func NewWorkerAPIRepository(shared *sharedRepository, m *metered.Metered) repository.WorkerAPIRepository
• func NewWorkerEngineRepository(pool *pgxpool.Pool, essentialPool *pgxpool.Pool, v validator.Validator, ...) repository.WorkerEngineRepository
• func NewWorkflowEngineRepository(shared *sharedRepository, m *metered.Metered, cache cache.Cacheable) repository.WorkflowEngineRepository
• func NewWorkflowRepository(shared *sharedRepository) repository.WorkflowAPIRepository
• func NewWorkflowRunEngineRepository(shared *sharedRepository, m *metered.Metered, cf *server.ConfigFileRuntime, ...) repository.WorkflowRunEngineRepository
• func NewWorkflowRunRepository(shared *sharedRepository, m *metered.Metered, cf *server.ConfigFileRuntime) repository.WorkflowRunAPIRepository
• func UniqueSet[T any](i []T, keyFunc func(T) string) map[string]struct{}
• type PostgresRepositoryOpt
  • func WithCache(cache cache.Cacheable) PostgresRepositoryOpt
  • func WithLogger(l *zerolog.Logger) PostgresRepositoryOpt
  • func WithLogsAPIRepository(newLogsAPI repository.LogsAPIRepository) PostgresRepositoryOpt
  • func WithLogsEngineRepository(newLogsEngine repository.LogsEngineRepository) PostgresRepositoryOpt
  • func WithMetered(metered *metered.Metered) PostgresRepositoryOpt
  • func WithValidator(v validator.Validator) PostgresRepositoryOpt
• type PostgresRepositoryOpts

Functions

func NewAPIRepository

func NewAPIRepository(pool *pgxpool.Pool, cf *server.ConfigFileRuntime, fs ...PostgresRepositoryOpt) (repository.APIRepository, func() error, error)

func NewAPITokenRepository

func NewAPITokenRepository(shared *sharedRepository, cache cache.Cacheable) repository.APITokenRepository

func NewBulkSemaphoreReleaser

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 ...PostgresRepositoryOpt) (func() error, repository.EngineRepository, error)

func NewEntitlementRepository

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

func NewEventAPIRepository

func NewEventAPIRepository(shared *sharedRepository) 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(shared *sharedRepository) repository.HealthRepository

func NewHealthEngineRepository

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

func NewJobRunAPIRepository

func NewJobRunAPIRepository(shared *sharedRepository) repository.JobRunAPIRepository

func NewJobRunEngineRepository

func NewJobRunEngineRepository(shared *sharedRepository) 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 NewMessageQueueRepository

func NewMessageQueueRepository(shared *sharedRepository) *messageQueueRepository

func NewRateLimitEngineRepository

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

func NewSNSRepository

func NewSNSRepository(shared *sharedRepository) repository.SNSRepository

func NewSecurityCheckRepository

func NewSecurityCheckRepository(shared *sharedRepository) repository.SecurityCheckRepository

func NewSlackRepository

func NewSlackRepository(shared *sharedRepository) repository.SlackRepository

func NewStepRepository

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

func NewStepRunAPIRepository

func NewStepRunAPIRepository(shared *sharedRepository) repository.StepRunAPIRepository

func NewStepRunEngineRepository

func NewStepRunEngineRepository(shared *sharedRepository, cf *server.ConfigFileRuntime, rlCache *cache.Cache, queueCache *cache.Cache) *stepRunEngineRepository

func NewStreamEventsEngineRepository

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

func NewTenantAPIRepository

func NewTenantAPIRepository(shared *sharedRepository, cache cache.Cacheable) repository.TenantAPIRepository

func NewTenantAlertingRepository

func NewTenantAlertingRepository(shared *sharedRepository, cache cache.Cacheable) repository.TenantAlertingRepository

func NewTenantEngineRepository

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

func NewTenantInviteRepository

func NewTenantInviteRepository(shared *sharedRepository) 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(shared *sharedRepository) repository.UserRepository

func NewUserSessionRepository

func NewUserSessionRepository(shared *sharedRepository) repository.UserSessionRepository

func NewWebhookWorkerEngineRepository

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

func NewWebhookWorkerRepository

func NewWebhookWorkerRepository(shared *sharedRepository) repository.WebhookWorkerRepository

func NewWorkerAPIRepository

func NewWorkerAPIRepository(shared *sharedRepository, m *metered.Metered) repository.WorkerAPIRepository

func NewWorkerEngineRepository

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

func NewWorkflowEngineRepository

func NewWorkflowEngineRepository(shared *sharedRepository, m *metered.Metered, cache cache.Cacheable) repository.WorkflowEngineRepository

func NewWorkflowRepository

func NewWorkflowRepository(shared *sharedRepository) 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(shared *sharedRepository, m *metered.Metered, cf *server.ConfigFileRuntime) repository.WorkflowRunAPIRepository

func UniqueSet

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

Types

type PostgresRepositoryOpt

type PostgresRepositoryOpt func(*PostgresRepositoryOpts)

func WithCache

func WithCache(cache cache.Cacheable) PostgresRepositoryOpt

func WithLogger

func WithLogger(l *zerolog.Logger) PostgresRepositoryOpt

func WithLogsAPIRepository

func WithLogsAPIRepository(newLogsAPI repository.LogsAPIRepository) PostgresRepositoryOpt

func WithLogsEngineRepository

func WithLogsEngineRepository(newLogsEngine repository.LogsEngineRepository) PostgresRepositoryOpt

func WithMetered

func WithMetered(metered *metered.Metered) PostgresRepositoryOpt

func WithValidator

func WithValidator(v validator.Validator) PostgresRepositoryOpt

type PostgresRepositoryOpts

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