repository

Documentation

Index

• func CreateConnectionString(cfg config.PostgresConfig) string
• type RepoPostgres
  • func NewECRepo(ctx context.Context, cfg *config.ECConfig) (*RepoPostgres, error)
  • func (s *RepoPostgres) GetAllApplications(ctx context.Context) ([]*dao.ApplicationDAOInfo, error)
  • func (s *RepoPostgres) GetAllPartitions(ctx context.Context) ([]*dao.PartitionInfo, error)
  • func (s *RepoPostgres) GetAllQueues(ctx context.Context) ([]*dao.PartitionQueueDAOInfo, error)
  • func (s *RepoPostgres) GetApplicationsHistory(ctx context.Context) ([]*dao.ApplicationHistoryDAOInfo, error)
  • func (s *RepoPostgres) GetAppsPerPartitionPerQueue(ctx context.Context, partition, queue string) ([]*dao.ApplicationDAOInfo, error)
  • func (s *RepoPostgres) GetContainersHistory(ctx context.Context) ([]*dao.ContainerHistoryDAOInfo, error)
  • func (s *RepoPostgres) GetNodeUtilizations(ctx context.Context) ([]*dao.PartitionNodesUtilDAOInfo, error)
  • func (s RepoPostgres) GetNodesPerPartition(ctx context.Context, partition string) ([]*dao.NodeDAOInfo, error)
  • func (s RepoPostgres) GetQueuesPerPartition(ctx context.Context, parition string) ([]*dao.PartitionQueueDAOInfo, error)
  • func (s *RepoPostgres) InsertNodeUtilizations(ctx context.Context, u uuid.UUID, nus *[]dao.PartitionNodesUtilDAOInfo) error
  • func (s *RepoPostgres) Setup(ctx context.Context)
  • func (s *RepoPostgres) UpdateHistory(ctx context.Context, apps []*dao.ApplicationHistoryDAOInfo, ...) error
  • func (s *RepoPostgres) UpsertApplications(ctx context.Context, apps []*dao.ApplicationDAOInfo) error
  • func (s *RepoPostgres) UpsertNodes(ctx context.Context, nodes []*dao.NodeDAOInfo, partition string) error
  • func (s *RepoPostgres) UpsertPartitions(ctx context.Context, partitions []*dao.PartitionInfo) error
  • func (s *RepoPostgres) UpsertQueues(ctx context.Context, queues []dao.PartitionQueueDAOInfo) error

Functions

func CreateConnectionString

func CreateConnectionString(cfg config.PostgresConfig) string

Types

type RepoPostgres

type RepoPostgres struct {
	// contains filtered or unexported fields
}

func NewECRepo

func NewECRepo(ctx context.Context, cfg *config.ECConfig) (*RepoPostgres, error)

func (*RepoPostgres) GetAllApplications

func (s *RepoPostgres) GetAllApplications(ctx context.Context) ([]*dao.ApplicationDAOInfo, error)

func (*RepoPostgres) GetAllPartitions

func (s *RepoPostgres) GetAllPartitions(ctx context.Context) ([]*dao.PartitionInfo, error)

func (*RepoPostgres) GetAllQueues

func (s *RepoPostgres) GetAllQueues(ctx context.Context) ([]*dao.PartitionQueueDAOInfo, error)

func (*RepoPostgres) GetApplicationsHistory

func (s *RepoPostgres) GetApplicationsHistory(ctx context.Context) ([]*dao.ApplicationHistoryDAOInfo, error)

func (*RepoPostgres) GetAppsPerPartitionPerQueue

func (s *RepoPostgres) GetAppsPerPartitionPerQueue(ctx context.Context, partition, queue string) ([]*dao.ApplicationDAOInfo, error)

func (*RepoPostgres) GetContainersHistory

func (s *RepoPostgres) GetContainersHistory(ctx context.Context) ([]*dao.ContainerHistoryDAOInfo, error)

func (*RepoPostgres) GetNodeUtilizations

func (s *RepoPostgres) GetNodeUtilizations(ctx context.Context) ([]*dao.PartitionNodesUtilDAOInfo, error)

func (RepoPostgres) GetNodesPerPartition

func (s RepoPostgres) GetNodesPerPartition(ctx context.Context, partition string) ([]*dao.NodeDAOInfo, error)

func (RepoPostgres) GetQueuesPerPartition

func (s RepoPostgres) GetQueuesPerPartition(ctx context.Context, parition string) ([]*dao.PartitionQueueDAOInfo, error)

func (*RepoPostgres) InsertNodeUtilizations

func (s *RepoPostgres) InsertNodeUtilizations(ctx context.Context, u uuid.UUID, nus *[]dao.PartitionNodesUtilDAOInfo) error

func (*RepoPostgres) Setup

func (s *RepoPostgres) Setup(ctx context.Context)

Set up the DB for use, create tables

func (*RepoPostgres) UpdateHistory

func (s *RepoPostgres) UpdateHistory(ctx context.Context, apps []*dao.ApplicationHistoryDAOInfo, containers []*dao.ContainerHistoryDAOInfo) error

func (*RepoPostgres) UpsertApplications

func (s *RepoPostgres) UpsertApplications(ctx context.Context, apps []*dao.ApplicationDAOInfo) error

func (*RepoPostgres) UpsertNodes

func (s *RepoPostgres) UpsertNodes(ctx context.Context, nodes []*dao.NodeDAOInfo, partition string) error

func (*RepoPostgres) UpsertPartitions

func (s *RepoPostgres) UpsertPartitions(ctx context.Context, partitions []*dao.PartitionInfo) error

func (*RepoPostgres) UpsertQueues

func (s *RepoPostgres) UpsertQueues(ctx context.Context, queues []dao.PartitionQueueDAOInfo) error