postgresstore

package
v1.3.12 Latest Latest
Warning

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

 Go to latest Published: May 24, 2023 License: ISC Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ConnMaxLifetime = time.Duration(config.GetEnvAsIntOrDefault("DATABASE_CONN_MAX_LIFETIME_SECONDS", "3600")) * time.Second
View Source 
var DB *gorm.DB

global db

View Source 
var DatabaseHost = config.GetEnvOrDefault("DATABASE_HOST", "corndogs-postgresql")
View Source 
var DatabaseName = config.GetEnvOrDefault("DATABASE_NAME", "localcorndogsdev")
View Source 
var DatabasePassword = config.GetEnvOrDefault("DATABASE_PASSWORD", "localcorndogsdevpass")
View Source 
var DatabasePort = config.GetEnvOrDefault("DATABASE_PORT", "5432")
View Source 
var DatabaseSSLMode = config.GetEnvOrDefault("DATABASE_SSL_MODE", "disable")
View Source 
var DatabaseUser = config.GetEnvOrDefault("DATABASE_USER", "postgres")
View Source 
var MaxIdleConns = config.GetEnvAsIntOrDefault("DATABASE_MAX_IDLE_CONNS", "1")
View Source 
var MaxOpenConns = config.GetEnvAsIntOrDefault("DATABASE_MAX_OPEN_CONNS", "10")

Functions

This section is empty.

Types

type PostgresStore 

type PostgresStore struct{}

func (PostgresStore) CancelTask 

func (s PostgresStore) CancelTask(req *corndogsv1alpha1.CancelTaskRequest) (*corndogsv1alpha1.CancelTaskResponse, error)

func (PostgresStore) CleanUpTimedOut added in v1.1.0 

func (s PostgresStore) CleanUpTimedOut(req *corndogsv1alpha1.CleanUpTimedOutRequest) (*corndogsv1alpha1.CleanUpTimedOutResponse, error)

func (PostgresStore) CompleteTask 

func (s PostgresStore) CompleteTask(req *corndogsv1alpha1.CompleteTaskRequest) (*corndogsv1alpha1.CompleteTaskResponse, error)

func (PostgresStore) GetNextTask 

func (s PostgresStore) GetNextTask(req *corndogsv1alpha1.GetNextTaskRequest) (*corndogsv1alpha1.GetNextTaskResponse, error)

func (PostgresStore) GetQueueAndStateCounts added in v1.3.0 

func (s PostgresStore) GetQueueAndStateCounts(req *corndogsv1alpha1.GetQueueAndStateCountsRequest) (*corndogsv1alpha1.GetQueueAndStateCountsResponse, error)

func (PostgresStore) GetQueueTaskCounts added in v1.3.0 

func (s PostgresStore) GetQueueTaskCounts(req *corndogsv1alpha1.GetQueueTaskCountsRequest) (*corndogsv1alpha1.GetQueueTaskCountsResponse, error)

func (PostgresStore) GetQueues added in v1.3.0 

func (s PostgresStore) GetQueues(req *corndogsv1alpha1.GetQueuesRequest) (*corndogsv1alpha1.GetQueuesResponse, error)

func (PostgresStore) GetTaskStateCounts added in v1.3.0 

func (s PostgresStore) GetTaskStateCounts(req *corndogsv1alpha1.GetTaskStateCountsRequest) (*corndogsv1alpha1.GetTaskStateCountsResponse, error)

func (PostgresStore) Initialize 

func (s PostgresStore) Initialize() (func(), error)

func (PostgresStore) MustGetTaskStateByID 

func (s PostgresStore) MustGetTaskStateByID(req *corndogsv1alpha1.GetTaskStateByIDRequest) (*corndogsv1alpha1.GetTaskStateByIDResponse, error)

func (PostgresStore) SubmitTask 

func (s PostgresStore) SubmitTask(req *corndogsv1alpha1.SubmitTaskRequest) (*corndogsv1alpha1.SubmitTaskResponse, error)

func (PostgresStore) UpdateTask 

func (s PostgresStore) UpdateTask(req *corndogsv1alpha1.UpdateTaskRequest) (*corndogsv1alpha1.UpdateTaskResponse, error)

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.