postgresstore

Documentation

Index

• Variables
• type PostgresStore
  • func (s PostgresStore) CancelTask(req *corndogsv1alpha1.CancelTaskRequest) (*corndogsv1alpha1.CancelTaskResponse, error)
  • func (s PostgresStore) CompleteTask(req *corndogsv1alpha1.CompleteTaskRequest) (*corndogsv1alpha1.CompleteTaskResponse, error)
  • func (s PostgresStore) GetNextTask(req *corndogsv1alpha1.GetNextTaskRequest) (*corndogsv1alpha1.GetNextTaskResponse, error)
  • func (s PostgresStore) Initialize() (func(), error)
  • func (s PostgresStore) MustGetTaskStateByID(req *corndogsv1alpha1.GetTaskStateByIDRequest) *corndogsv1alpha1.GetTaskStateByIDResponse
  • func (s PostgresStore) SubmitTask(req *corndogsv1alpha1.SubmitTaskRequest) (*corndogsv1alpha1.SubmitTaskResponse, error)
  • func (s PostgresStore) UpdateTask(req *corndogsv1alpha1.UpdateTaskRequest) (*corndogsv1alpha1.UpdateTaskResponse, error)

Variables

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

var DB *gorm.DB

global db

var DatabaseHost = config.GetEnvOrDefault("DATABASE_HOST", "corndogs-postgresql")

var DatabaseName = config.GetEnvOrDefault("DATABASE_NAME", "localcorndogsdev")

var DatabasePassword = config.GetEnvOrDefault("DATABASE_PASSWORD", "localcorndogsdevpass")

var DatabasePort = config.GetEnvOrDefault("DATABASE_PORT", "5432")

var DatabaseSSLMode = config.GetEnvOrDefault("DATABASE_SSL_MODE", "disable")

var DatabaseUser = config.GetEnvOrDefault("DATABASE_USER", "postgres")

var DefaultWorkingSuffix = "-working"

var MaxIdleConns = config.GetEnvAsIntOrDefault("DATABASE_MAX_IDLE_CONNS", "1")

var MaxOpenConns = config.GetEnvAsIntOrDefault("DATABASE_MAX_OPEN_CONNS", "10")

Types

type PostgresStore

type PostgresStore struct{}

func (PostgresStore) CancelTask

func (s PostgresStore) CancelTask(req *corndogsv1alpha1.CancelTaskRequest) (*corndogsv1alpha1.CancelTaskResponse, 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) Initialize

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

func (PostgresStore) MustGetTaskStateByID

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

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)