Help us shape the future of Go! Take the 2026 Go Developer Survey

postgres

package
v0.73.58 Latest Latest
Warning

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

 Go to latest Published: Nov 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, l *zerolog.Logger) 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.