postgres

package
v1.19.0-beta.1 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountPostgreSQLRepository 

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

AccountPostgreSQLRepository is a Postgresql-specific implementation of the AccountRepository.

func NewAccountPostgreSQLRepository 

func NewAccountPostgreSQLRepository(pc *mpostgres.PostgresConnection) *AccountPostgreSQLRepository

NewAccountPostgreSQLRepository returns a new instance of AccountPostgreSQLRepository using the given Postgres connection.

func (*AccountPostgreSQLRepository) Create 

func (r *AccountPostgreSQLRepository) Create(ctx context.Context, account *a.Account) (*a.Account, error)

Create a new account entity into Postgresql and returns it.

func (*AccountPostgreSQLRepository) Delete 

func (r *AccountPostgreSQLRepository) Delete(ctx context.Context, organizationID, ledgerID, portfolioID, id uuid.UUID) error

Delete removes an Account entity from the database using the provided IDs.

func (*AccountPostgreSQLRepository) Find 

func (r *AccountPostgreSQLRepository) Find(ctx context.Context, organizationID, ledgerID, portfolioID, id uuid.UUID) (*a.Account, error)

Find retrieves an Account entity from the database using the provided ID.

func (*AccountPostgreSQLRepository) FindAll 

func (r *AccountPostgreSQLRepository) FindAll(ctx context.Context, organizationID, ledgerID, portfolioID uuid.UUID, limit, page int) ([]*a.Account, error)

FindAll retrieves an Account entities from the database.

func (*AccountPostgreSQLRepository) FindByAlias added in v1.1.0 

func (r *AccountPostgreSQLRepository) FindByAlias(ctx context.Context, organizationID, ledgerID, portfolioID uuid.UUID, alias string) (bool, error)

FindByAlias find account from the database using Organization and Ledger id and Alias.

func (*AccountPostgreSQLRepository) ListAccountsByAlias added in v1.10.0 

func (r *AccountPostgreSQLRepository) ListAccountsByAlias(ctx context.Context, aliases []string) ([]*a.Account, error)

ListAccountsByAlias list Accounts entity from the database using the provided alias.

func (*AccountPostgreSQLRepository) ListAccountsByIDs added in v1.10.0 

func (r *AccountPostgreSQLRepository) ListAccountsByIDs(ctx context.Context, ids []uuid.UUID) ([]*a.Account, error)

ListAccountsByIDs list Accounts entity from the database using the provided IDs.

func (*AccountPostgreSQLRepository) ListByAlias added in v1.10.0 

func (r *AccountPostgreSQLRepository) ListByAlias(ctx context.Context, organizationID, ledgerID, portfolioID uuid.UUID, alias []string) ([]*a.Account, error)

ListByAlias retrieves Accounts entities from the database using the provided alias.

func (*AccountPostgreSQLRepository) ListByIDs 

func (r *AccountPostgreSQLRepository) ListByIDs(ctx context.Context, organizationID, ledgerID, portfolioID uuid.UUID, ids []uuid.UUID) ([]*a.Account, error)

ListByIDs retrieves Accounts entities from the database using the provided IDs.

func (*AccountPostgreSQLRepository) Update 

func (r *AccountPostgreSQLRepository) Update(ctx context.Context, organizationID, ledgerID, portfolioID, id uuid.UUID, account *a.Account) (*a.Account, error)

Update an Account entity into Postgresql and returns the Account updated.

func (*AccountPostgreSQLRepository) UpdateAccountByID added in v1.10.0 

func (r *AccountPostgreSQLRepository) UpdateAccountByID(ctx context.Context, id uuid.UUID, account *a.Account) (*a.Account, error)

UpdateAccountByID an update Account entity by ID only into Postgresql and returns the Account updated.

type AssetPostgreSQLRepository added in v1.11.0 

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

AssetPostgreSQLRepository is a Postgresql-specific implementation of the AssetRepository.

func NewAssetPostgreSQLRepository added in v1.11.0 

func NewAssetPostgreSQLRepository(pc *mpostgres.PostgresConnection) *AssetPostgreSQLRepository

NewAssetPostgreSQLRepository returns a new instance of AssetPostgreSQLRepository using the given Postgres connection.

func (*AssetPostgreSQLRepository) Create added in v1.11.0 

func (r *AssetPostgreSQLRepository) Create(ctx context.Context, asset *s.Asset) (*s.Asset, error)

Create a new asset entity into Postgresql and returns it.

func (*AssetPostgreSQLRepository) Delete added in v1.11.0 

func (r *AssetPostgreSQLRepository) Delete(ctx context.Context, organizationID, ledgerID, id uuid.UUID) error

Delete removes an Asset entity from the database using the provided IDs.

func (*AssetPostgreSQLRepository) Find added in v1.11.0 

func (r *AssetPostgreSQLRepository) Find(ctx context.Context, organizationID, ledgerID, id uuid.UUID) (*s.Asset, error)

Find retrieves an Asset entity from the database using the provided ID.

func (*AssetPostgreSQLRepository) FindAll added in v1.11.0 

func (r *AssetPostgreSQLRepository) FindAll(ctx context.Context, organizationID, ledgerID uuid.UUID, limit, page int) ([]*s.Asset, error)

FindAll retrieves Asset entities from the database.

func (*AssetPostgreSQLRepository) FindByNameOrCode added in v1.11.0 

func (r *AssetPostgreSQLRepository) FindByNameOrCode(ctx context.Context, organizationID, ledgerID uuid.UUID, name, code string) (bool, error)

FindByNameOrCode retrieves Asset entities by name or code from the database.

func (*AssetPostgreSQLRepository) ListByIDs added in v1.11.0 

func (r *AssetPostgreSQLRepository) ListByIDs(ctx context.Context, organizationID, ledgerID uuid.UUID, ids []uuid.UUID) ([]*s.Asset, error)

ListByIDs retrieves Assets entities from the database using the provided IDs.

func (*AssetPostgreSQLRepository) Update added in v1.11.0 

func (r *AssetPostgreSQLRepository) Update(ctx context.Context, organizationID, ledgerID, id uuid.UUID, asset *s.Asset) (*s.Asset, error)

Update an Asset entity into Postgresql and returns the Asset updated.

type LedgerPostgreSQLRepository 

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

LedgerPostgreSQLRepository is a Postgresql-specific implementation of the LedgerRepository.

func NewLedgerPostgreSQLRepository 

func NewLedgerPostgreSQLRepository(pc *mpostgres.PostgresConnection) *LedgerPostgreSQLRepository

NewLedgerPostgreSQLRepository returns a new instance of LedgerPostgresRepository using the given Postgres connection.

func (*LedgerPostgreSQLRepository) Create 

func (r *LedgerPostgreSQLRepository) Create(ctx context.Context, ledger *l.Ledger) (*l.Ledger, error)

Create a new Ledger entity into Postgresql and returns it.

func (*LedgerPostgreSQLRepository) Delete 

func (r *LedgerPostgreSQLRepository) Delete(ctx context.Context, organizationID, id uuid.UUID) error

Delete removes a Ledger entity from the database using the provided ID.

func (*LedgerPostgreSQLRepository) Find 

func (r *LedgerPostgreSQLRepository) Find(ctx context.Context, organizationID, id uuid.UUID) (*l.Ledger, error)

Find retrieves a Ledger entity from the database using the provided ID.

func (*LedgerPostgreSQLRepository) FindAll 

func (r *LedgerPostgreSQLRepository) FindAll(ctx context.Context, organizationID uuid.UUID, limit, page int) ([]*l.Ledger, error)

FindAll retrieves Ledgers entities from the database.

func (*LedgerPostgreSQLRepository) ListByIDs 

func (r *LedgerPostgreSQLRepository) ListByIDs(ctx context.Context, organizationID uuid.UUID, ids []uuid.UUID) ([]*l.Ledger, error)

ListByIDs retrieves Ledgers entities from the database using the provided IDs.

func (*LedgerPostgreSQLRepository) Update 

func (r *LedgerPostgreSQLRepository) Update(ctx context.Context, organizationID, id uuid.UUID, ledger *l.Ledger) (*l.Ledger, error)

Update a Ledger entity into Postgresql and returns the Ledger updated.

type OrganizationPostgreSQLRepository 

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

OrganizationPostgreSQLRepository is a Postgresql-specific implementation of the OrganizationRepository.

func NewOrganizationPostgreSQLRepository 

func NewOrganizationPostgreSQLRepository(pc *mpostgres.PostgresConnection) *OrganizationPostgreSQLRepository

NewOrganizationPostgreSQLRepository returns a new instance of OrganizationPostgresRepository using the given Postgres connection.

func (*OrganizationPostgreSQLRepository) Create 

func (r *OrganizationPostgreSQLRepository) Create(ctx context.Context, organization *o.Organization) (*o.Organization, error)

Create inserts a new Organization entity into Postgresql and returns the created Organization.

func (*OrganizationPostgreSQLRepository) Delete 

func (r *OrganizationPostgreSQLRepository) Delete(ctx context.Context, id uuid.UUID) error

Delete removes an Organization entity from the database using the provided ID.

func (*OrganizationPostgreSQLRepository) Find 

func (r *OrganizationPostgreSQLRepository) Find(ctx context.Context, id uuid.UUID) (*o.Organization, error)

Find retrieves an Organization entity from the database using the provided ID.

func (*OrganizationPostgreSQLRepository) FindAll 

func (r *OrganizationPostgreSQLRepository) FindAll(ctx context.Context, limit, page int) ([]*o.Organization, error)

FindAll retrieves Organizations entities from the database.

func (*OrganizationPostgreSQLRepository) ListByIDs 

func (r *OrganizationPostgreSQLRepository) ListByIDs(ctx context.Context, ids []uuid.UUID) ([]*o.Organization, error)

ListByIDs retrieves Organizations entities from the database using the provided IDs.

func (*OrganizationPostgreSQLRepository) Update 

func (r *OrganizationPostgreSQLRepository) Update(ctx context.Context, id uuid.UUID, organization *o.Organization) (*o.Organization, error)

Update an Organization entity into Postgresql and returns the Organization updated.

type PortfolioPostgreSQLRepository 

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

PortfolioPostgreSQLRepository is a Postgresql-specific implementation of the PortfolioRepository.

func NewPortfolioPostgreSQLRepository 

func NewPortfolioPostgreSQLRepository(pc *mpostgres.PostgresConnection) *PortfolioPostgreSQLRepository

NewPortfolioPostgreSQLRepository returns a new instance of PortfolioPostgreSQLRepository using the given Postgres connection.

func (*PortfolioPostgreSQLRepository) Create 

func (r *PortfolioPostgreSQLRepository) Create(ctx context.Context, portfolio *p.Portfolio) (*p.Portfolio, error)

Create a new portfolio entity into Postgresql and returns it.

func (*PortfolioPostgreSQLRepository) Delete 

func (r *PortfolioPostgreSQLRepository) Delete(ctx context.Context, organizationID, ledgerID, id uuid.UUID) error

Delete removes a Portfolio entity from the database using the provided IDs.

func (*PortfolioPostgreSQLRepository) Find 

func (r *PortfolioPostgreSQLRepository) Find(ctx context.Context, organizationID, ledgerID, id uuid.UUID) (*p.Portfolio, error)

Find retrieves a Portfolio entity from the database using the provided ID.

func (*PortfolioPostgreSQLRepository) FindAll 

func (r *PortfolioPostgreSQLRepository) FindAll(ctx context.Context, organizationID, ledgerID uuid.UUID, limit, page int) ([]*p.Portfolio, error)

FindAll retrieves Portfolio entities from the database.

func (*PortfolioPostgreSQLRepository) FindByIDEntity 

func (r *PortfolioPostgreSQLRepository) FindByIDEntity(ctx context.Context, organizationID, ledgerID, entityID uuid.UUID) (*p.Portfolio, error)

FindByIDEntity find portfolio from the database using the Entity id.

func (*PortfolioPostgreSQLRepository) ListByIDs 

func (r *PortfolioPostgreSQLRepository) ListByIDs(ctx context.Context, organizationID, ledgerID uuid.UUID, ids []uuid.UUID) ([]*p.Portfolio, error)

ListByIDs retrieves Portfolios entities from the database using the provided IDs.

func (*PortfolioPostgreSQLRepository) Update 

func (r *PortfolioPostgreSQLRepository) Update(ctx context.Context, organizationID, ledgerID, id uuid.UUID, portfolio *p.Portfolio) (*p.Portfolio, error)

Update a Portfolio entity into Postgresql and returns the Portfolio updated.

type ProductPostgreSQLRepository 

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

ProductPostgreSQLRepository is a Postgresql-specific implementation of the Repository.

func NewProductPostgreSQLRepository 

func NewProductPostgreSQLRepository(pc *mpostgres.PostgresConnection) *ProductPostgreSQLRepository

NewProductPostgreSQLRepository returns a new instance of ProductPostgreSQLRepository using the given Postgres connection.

func (*ProductPostgreSQLRepository) Create 

func (p *ProductPostgreSQLRepository) Create(ctx context.Context, product *r.Product) (*r.Product, error)

Create a new product entity into Postgresql and returns it.

func (*ProductPostgreSQLRepository) Delete 

func (p *ProductPostgreSQLRepository) Delete(ctx context.Context, organizationID, ledgerID, id uuid.UUID) error

Delete removes a Product entity from the database using the provided IDs.

func (*ProductPostgreSQLRepository) Find 

func (p *ProductPostgreSQLRepository) Find(ctx context.Context, organizationID, ledgerID, id uuid.UUID) (*r.Product, error)

Find retrieves a Product entity from the database using the provided ID.

func (*ProductPostgreSQLRepository) FindAll 

func (p *ProductPostgreSQLRepository) FindAll(ctx context.Context, organizationID, ledgerID uuid.UUID, limit, page int) ([]*r.Product, error)

FindAll retrieves Product entities from the database.

func (*ProductPostgreSQLRepository) FindByIDs 

func (p *ProductPostgreSQLRepository) FindByIDs(ctx context.Context, organizationID, ledgerID uuid.UUID, ids []uuid.UUID) ([]*r.Product, error)

FindByIDs retrieves Products entities from the database using the provided IDs.

func (*ProductPostgreSQLRepository) FindByName 

func (p *ProductPostgreSQLRepository) FindByName(ctx context.Context, organizationID, ledgerID uuid.UUID, name string) (bool, error)

FindByName find product from the database using Organization and Ledger id and Name.

func (*ProductPostgreSQLRepository) Update 

func (p *ProductPostgreSQLRepository) Update(ctx context.Context, organizationID, ledgerID, id uuid.UUID, prd *r.Product) (*r.Product, error)

Update a Product entity into Postgresql and returns the Product updated.

Source Files

View all Source files

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.