postgres

package
v0.73.32-alpha.9 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2025 License: MIT Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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, v validator.Validator, l *zerolog.Logger) repository.DispatcherEngineRepository

func NewEngineRepository 

func NewEngineRepository(pool *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() error)

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, defaultTenantVersion dbsqlc.TenantMajorEngineVersion) 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, 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
}

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.