postgres

Documentation

Index

• type ClientExposureDetailStorageImpl
  • func (s *ClientExposureDetailStorageImpl) FindAll(ctx context.Context) ([]*java2go.ClientExposure, error)
  • func (s *ClientExposureDetailStorageImpl) FindAllByClientId(ctx context.Context, clientId int64) ([]*java2go.ClientExposure, error)
  • func (s *ClientExposureDetailStorageImpl) FindByClientIdAndExposureCurrency(ctx context.Context, clientId int64, exposureCurrency string) (*java2go.ClientExposure, error)
  • func (s *ClientExposureDetailStorageImpl) Save(ctx context.Context, detail *java2go.ClientExposure) error
• type ClientExposureStorageImpl
  • func (s *ClientExposureStorageImpl) FindByClientId(ctx context.Context, clientId int64) (*java2go.ClientExposure, error)
  • func (s *ClientExposureStorageImpl) Save(ctx context.Context, exposure *java2go.ClientExposure) error
• type CurrencyRateStorageImpl
  • func (s *CurrencyRateStorageImpl) FindAll(ctx context.Context) ([]*java2go.CurrencyRate, error)
  • func (s *CurrencyRateStorageImpl) FindByBaseCurrencyAndQuotedCurrency(ctx context.Context, baseCurrency, quotedCurrency string) (*java2go.CurrencyRate, error)
  • func (s *CurrencyRateStorageImpl) SaveRate(ctx context.Context, rate *java2go.CurrencyRate) error
• type DealStorageImpl
  • func (p *DealStorageImpl) FindAll(ctx context.Context) ([]*java2go.Deal, error)
  • func (p *DealStorageImpl) FindAllByClientId(ctx context.Context, clientId int64) ([]*java2go.Deal, error)
  • func (p *DealStorageImpl) SaveDeal(ctx context.Context, deal *java2go.Deal) error
• type PgPool
  • func (p *PgPool) Init()

Types

type ClientExposureDetailStorageImpl

type ClientExposureDetailStorageImpl struct {
	Postgres *PgPool
}

func (*ClientExposureDetailStorageImpl) FindAll

func (s *ClientExposureDetailStorageImpl) FindAll(ctx context.Context) ([]*java2go.ClientExposure, error)

func (*ClientExposureDetailStorageImpl) FindAllByClientId

func (s *ClientExposureDetailStorageImpl) FindAllByClientId(ctx context.Context, clientId int64) ([]*java2go.ClientExposure, error)

func (*ClientExposureDetailStorageImpl) FindByClientIdAndExposureCurrency

func (s *ClientExposureDetailStorageImpl) FindByClientIdAndExposureCurrency(ctx context.Context, clientId int64, exposureCurrency string) (*java2go.ClientExposure, error)

func (*ClientExposureDetailStorageImpl) Save

func (s *ClientExposureDetailStorageImpl) Save(ctx context.Context, detail *java2go.ClientExposure) error

type ClientExposureStorageImpl

type ClientExposureStorageImpl struct {
	Postgres *PgPool
}

func (*ClientExposureStorageImpl) FindByClientId

func (s *ClientExposureStorageImpl) FindByClientId(ctx context.Context, clientId int64) (*java2go.ClientExposure, error)

func (*ClientExposureStorageImpl) Save

func (s *ClientExposureStorageImpl) Save(ctx context.Context, exposure *java2go.ClientExposure) error

type CurrencyRateStorageImpl

type CurrencyRateStorageImpl struct {
	Postgres *PgPool
}

func (*CurrencyRateStorageImpl) FindAll

func (s *CurrencyRateStorageImpl) FindAll(ctx context.Context) ([]*java2go.CurrencyRate, error)

func (*CurrencyRateStorageImpl) FindByBaseCurrencyAndQuotedCurrency

func (s *CurrencyRateStorageImpl) FindByBaseCurrencyAndQuotedCurrency(ctx context.Context, baseCurrency, quotedCurrency string) (*java2go.CurrencyRate, error)

func (*CurrencyRateStorageImpl) SaveRate

func (s *CurrencyRateStorageImpl) SaveRate(ctx context.Context, rate *java2go.CurrencyRate) error

type DealStorageImpl

type DealStorageImpl struct {
	Postgres *PgPool
}

func (*DealStorageImpl) FindAll

func (p *DealStorageImpl) FindAll(ctx context.Context) ([]*java2go.Deal, error)

func (*DealStorageImpl) FindAllByClientId

func (p *DealStorageImpl) FindAllByClientId(ctx context.Context, clientId int64) ([]*java2go.Deal, error)

func (*DealStorageImpl) SaveDeal

func (p *DealStorageImpl) SaveDeal(ctx context.Context, deal *java2go.Deal) error

type PgPool

type PgPool struct {
	Host     string
	Port     int
	Username string
	Password string
	Database string
	Schema   string
	DbPool   *pgxpool.Pool
}

func (*PgPool) Init

func (p *PgPool) Init()