Documentation ¶
Index ¶
- type ConnectionHolder
- type DepositSchema
- type DepositStorage
- type ExtendedTransferSchema
- type ExtendedTransferStorage
- type MemberSchema
- type MemberStorage
- type MigrationAddressSchema
- type MigrationAddressStorage
- type ObjectSchema
- type ObjectStorage
- type PulseSchema
- type PulseStorage
- type RecordSchema
- type RecordStorage
- type RequestSchema
- type RequestStorage
- type ResultSchema
- type ResultStorage
- type StatisticSchema
- type StatisticStorage
- type TransferSchema
- type TransferStorage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionHolder ¶
type ConnectionHolder struct {
// contains filtered or unexported fields
}
func NewConnectionHolder ¶
func NewConnectionHolder(cfg *configuration.Configuration) *ConnectionHolder
func (*ConnectionHolder) Close ¶
func (h *ConnectionHolder) Close() error
func (*ConnectionHolder) DB ¶
func (h *ConnectionHolder) DB() *pg.DB
type DepositSchema ¶
type DepositSchema struct { EthHash string `sql:",pk"` DepositRef []byte `sql:",notnull"` MemberRef []byte `sql:",notnull"` TransferDate int64 `sql:",notnull"` HoldReleaseDate int64 `sql:",notnull"` Amount string `sql:",notnull"` Balance string `sql:",notnull"` DepositState []byte `sql:",notnull"` // contains filtered or unexported fields }
type DepositStorage ¶
type DepositStorage struct {
// contains filtered or unexported fields
}
func NewDepositStorage ¶
func NewDepositStorage(obs *observability.Observability, db orm.DB) *DepositStorage
func (*DepositStorage) Update ¶
func (s *DepositStorage) Update(model *observer.DepositUpdate) error
type ExtendedTransferSchema ¶
type ExtendedTransferSchema struct { ID uint `sql:",pk_id"` TxID []byte `sql:",unique"` Amount string `sql:",notnull"` Fee string `sql:",notnull"` TransferDate int64 `sql:",notnull"` PulseNum insolar.PulseNumber `sql:",notnull"` Status string `sql:",notnull"` MemberFromRef []byte `sql:",notnull"` MemberToRef []byte `sql:",notnull"` EthHash string `sql:",notnull"` TransferRequestMember []byte TransferRequestWallet []byte TransferRequestAccount []byte AcceptRequestMember []byte AcceptRequestWallet []byte AcceptRequestAccount []byte CalcFeeRequest []byte FeeMemberRequest []byte CostCenterRef []byte FeeMemberRef []byte // contains filtered or unexported fields }
type ExtendedTransferStorage ¶
type ExtendedTransferStorage struct {
// contains filtered or unexported fields
}
func NewExtendedTransferStorage ¶
func NewExtendedTransferStorage(obs *observability.Observability, db orm.DB) *ExtendedTransferStorage
func (*ExtendedTransferStorage) Insert ¶
func (s *ExtendedTransferStorage) Insert(model *observer.ExtendedTransfer) error
type MemberSchema ¶
type MemberStorage ¶
type MemberStorage struct {
// contains filtered or unexported fields
}
func NewMemberStorage ¶
func NewMemberStorage(obs *observability.Observability, db orm.DB) *MemberStorage
type MigrationAddressSchema ¶
type MigrationAddressStorage ¶
type MigrationAddressStorage struct {
// contains filtered or unexported fields
}
func NewMigrationAddressStorage ¶
func NewMigrationAddressStorage(obs *observability.Observability, db orm.DB) *MigrationAddressStorage
func (*MigrationAddressStorage) Insert ¶
func (s *MigrationAddressStorage) Insert(model *observer.MigrationAddress) error
type ObjectSchema ¶
type ObjectStorage ¶
type ObjectStorage struct {
// contains filtered or unexported fields
}
func NewObjectStorage ¶
func NewObjectStorage(obs *observability.Observability, db orm.DB) *ObjectStorage
func (*ObjectStorage) Insert ¶
func (s *ObjectStorage) Insert(model interface{}) error
type PulseSchema ¶
type PulseStorage ¶
type PulseStorage struct {
// contains filtered or unexported fields
}
func NewPulseStorage ¶
func NewPulseStorage(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) *PulseStorage
func (*PulseStorage) Last ¶
func (s *PulseStorage) Last() *observer.Pulse
type RecordSchema ¶
type RecordStorage ¶
type RecordStorage struct {
// contains filtered or unexported fields
}
func NewRecordStorage ¶
func NewRecordStorage(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) *RecordStorage
func (*RecordStorage) Count ¶
func (s *RecordStorage) Count(by insolar.PulseNumber) uint32
func (*RecordStorage) Last ¶
func (s *RecordStorage) Last() *observer.Record
type RequestSchema ¶
type RequestStorage ¶
type RequestStorage struct {
// contains filtered or unexported fields
}
func NewRequestStorage ¶
func NewRequestStorage(obs *observability.Observability, db orm.DB) *RequestStorage
type ResultSchema ¶
type ResultStorage ¶
type ResultStorage struct {
// contains filtered or unexported fields
}
func NewResultStorage ¶
func NewResultStorage(obs *observability.Observability, db orm.DB) *ResultStorage
type StatisticSchema ¶
type StatisticSchema struct { Pulse insolar.PulseNumber `sql:"pulse_num, pk"` Transfers int `sql:"count_transactions, notnull"` TotalTransfers int `sql:"total_transactions, notnull"` TotalMembers int `sql:"total_accounts, notnull"` MaxTransfers int `sql:"max_transactions, notnull"` LastMonthTransfers int `sql:"last_month_transactions, notnull"` Nodes int `sql:",notnull"` // contains filtered or unexported fields }
type StatisticStorage ¶
type StatisticStorage struct {
// contains filtered or unexported fields
}
func NewStatisticStorage ¶
func NewStatisticStorage(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) *StatisticStorage
func (*StatisticStorage) Insert ¶
func (s *StatisticStorage) Insert(model *observer.Statistic) error
func (*StatisticStorage) Last ¶
func (s *StatisticStorage) Last() *observer.Statistic
type TransferSchema ¶
type TransferSchema struct { ID uint `sql:",pk_id"` TxID []byte `sql:",unique"` Amount string `sql:",notnull"` Fee string `sql:",notnull"` TransferDate int64 `sql:",notnull"` PulseNum insolar.PulseNumber `sql:",notnull"` Status string `sql:",notnull"` MemberFromRef []byte `sql:",notnull"` MemberToRef []byte `sql:",notnull"` EthHash string `sql:",notnull"` // contains filtered or unexported fields }
type TransferStorage ¶
type TransferStorage struct {
// contains filtered or unexported fields
}
func NewTransferStorage ¶
func NewTransferStorage(obs *observability.Observability, db orm.DB) *TransferStorage
func (*TransferStorage) Insert ¶
func (s *TransferStorage) Insert(model *observer.DepositTransfer) error
Click to show internal directories.
Click to hide internal directories.