postgresstore

Documentation

Index

• Variables
• type PostgresStore
  • func (s PostgresStore) CancelTask(ctx context.Context, req *corndogsv1alpha1.CancelTaskRequest) (*corndogsv1alpha1.CancelTaskResponse, error)
  • func (s PostgresStore) CleanUpTimedOut(ctx context.Context, req *corndogsv1alpha1.CleanUpTimedOutRequest) (*corndogsv1alpha1.CleanUpTimedOutResponse, error)
  • func (s PostgresStore) CompleteTask(ctx context.Context, req *corndogsv1alpha1.CompleteTaskRequest) (*corndogsv1alpha1.CompleteTaskResponse, error)
  • func (s PostgresStore) GetNextTask(ctx context.Context, req *corndogsv1alpha1.GetNextTaskRequest) (*corndogsv1alpha1.GetNextTaskResponse, error)
  • func (s PostgresStore) GetQueueAndStateCounts(ctx context.Context, req *corndogsv1alpha1.GetQueueAndStateCountsRequest) (*corndogsv1alpha1.GetQueueAndStateCountsResponse, error)
  • func (s PostgresStore) GetQueueTaskCounts(ctx context.Context, req *corndogsv1alpha1.GetQueueTaskCountsRequest) (*corndogsv1alpha1.GetQueueTaskCountsResponse, error)
  • func (s PostgresStore) GetQueues(ctx context.Context, req *corndogsv1alpha1.GetQueuesRequest) (*corndogsv1alpha1.GetQueuesResponse, error)
  • func (s PostgresStore) GetTaskStateCounts(ctx context.Context, req *corndogsv1alpha1.GetTaskStateCountsRequest) (*corndogsv1alpha1.GetTaskStateCountsResponse, error)
  • func (s PostgresStore) Initialize() (func(), error)
  • func (s PostgresStore) MustGetTaskStateByID(ctx context.Context, req *corndogsv1alpha1.GetTaskStateByIDRequest) (*corndogsv1alpha1.GetTaskStateByIDResponse, error)
  • func (s PostgresStore) SubmitTask(ctx context.Context, req *corndogsv1alpha1.SubmitTaskRequest) (*corndogsv1alpha1.SubmitTaskResponse, error)
  • func (s PostgresStore) UpdateTask(ctx context.Context, 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 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(ctx context.Context, req *corndogsv1alpha1.CancelTaskRequest) (*corndogsv1alpha1.CancelTaskResponse, error)

func (PostgresStore) CleanUpTimedOut

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

func (PostgresStore) CompleteTask

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

func (PostgresStore) GetNextTask

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

func (PostgresStore) GetQueueAndStateCounts

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

func (PostgresStore) GetQueueTaskCounts

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

func (PostgresStore) GetQueues

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

func (PostgresStore) GetTaskStateCounts

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

func (PostgresStore) Initialize

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

func (PostgresStore) MustGetTaskStateByID

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

func (PostgresStore) SubmitTask

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

func (PostgresStore) UpdateTask

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