postgresql

Documentation

Index

• type PostgreSQL
  • func NewPostgreSQL() (*PostgreSQL, error)
  • func (p *PostgreSQL) GetAccessibleManagedClusters(ctx context.Context, tableName string, filterClause string) (map[string]set.Set, error)
  • func (p *PostgreSQL) Stop()
  • func (p *PostgreSQL) UpdateLabelForManagedClusters(ctx context.Context, tableName string, labelKey string, labelValue string, ...) error

Types

type PostgreSQL

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

PostgreSQL abstracts PostgreSQL client.

func NewPostgreSQL

func NewPostgreSQL() (*PostgreSQL, error)

NewPostgreSQL creates a new instance of PostgreSQL object.

func (*PostgreSQL) GetAccessibleManagedClusters

func (p *PostgreSQL) GetAccessibleManagedClusters(ctx context.Context, tableName string,
	filterClause string,
) (map[string]set.Set, error)

GetAccessibleManagedClusters gets a map of hub -> set { managed-clusters } that are accessible with the given filter clause (WHERE ...).

func (*PostgreSQL) Stop

func (p *PostgreSQL) Stop()

Stop stops PostgreSQL and closes the connection pool.

func (*PostgreSQL) UpdateLabelForManagedClusters

func (p *PostgreSQL) UpdateLabelForManagedClusters(ctx context.Context, tableName string, labelKey string,
	labelValue string, hubToManagedClustersMap map[string]set.Set,
) error

UpdateLabelForManagedClusters receives a map of hub -> set of managed clusters and updates their labels to be appended by the given label

If the operation fails, hubToManagedClustersMap will contain un-synced entries only.