Documentation
¶
Index ¶
- Variables
- func DbConnect() (*sqlx.DB, error)
- type Account
- type AccountStore
- func (s *AccountStore) All() ([]*Account, error)
- func (s *AccountStore) CreateAccount(address string) (*Account, error)
- func (s *AccountStore) FindByAddress(address string) (*Account, error)
- func (s *AccountStore) FindById(id int) (*Account, error)
- func (s *AccountStore) FindOrCreateByAddress(address string) (*Account, error)
- type AllEvent
- type AnyEvent
- type BorrowEvent
- type Chain
- type ChainStore
- type DepositEvent
- type Event
- type EventDefn
- type EventStore
- func (s *EventStore) AllByAccount(accountId int) ([]AllEvent, error)
- func (s *EventStore) StoreBorrowEvent(protocolInstanceId int, eventDefinitionId int, txHash string, ...) (int, error)
- func (s *EventStore) StoreDepositEvent(protocolInstanceId int, eventDefinitionId int, txHash string, ...) (int, error)
- func (s *EventStore) StoreLiquidationEvent(protocolInstanceId int, eventDefinitionId int, txHash string, ...) (int, error)
- func (s *EventStore) StoreRepayEvent(protocolInstanceId int, eventDefinitionId int, txHash string, ...) (int, error)
- type EventType
- type LiquidationEvent
- type NewChain
- type NewEventDefn
- type NewProtocol
- type NewProtocolInstance
- type NewScan
- type Protocol
- type ProtocolInstance
- type ProtocolInstanceStore
- func (s *ProtocolInstanceStore) All() ([]*ProtocolInstance, error)
- func (s *ProtocolInstanceStore) CreateProtocolInstance(input NewProtocolInstance) (*ProtocolInstance, error)
- func (s *ProtocolInstanceStore) DeleteByProtocolAndChain(protocolName string, chainName string) error
- func (s *ProtocolInstanceStore) FindById(id int) (*ProtocolInstance, error)
- func (s *ProtocolInstanceStore) FindByProtocolIdAndChainId(protocolId int, chainId int) (*ProtocolInstance, error)
- func (s *ProtocolInstanceStore) FindChainById(id int) (*Chain, error)
- func (s *ProtocolInstanceStore) FindProtocolById(id int) (*Protocol, error)
- func (s *ProtocolInstanceStore) UpdateLastBlockRead(protocolInstanceId int, lastBlock uint) error
- func (s *ProtocolInstanceStore) UpdateProtocolInstance(protocolInstance *ProtocolInstance) (*ProtocolInstance, error)
- type ProtocolStore
- func (s *ProtocolStore) AddEventDefn(protocolName string, topicName string, topicHashHex string, ...) (*EventDefn, error)
- func (s *ProtocolStore) All() ([]*Protocol, error)
- func (s *ProtocolStore) AllByChain(chainId int) ([]*Protocol, error)
- func (s *ProtocolStore) AllEventsByProtocol(id int) ([]*EventDefn, error)
- func (s *ProtocolStore) AllEventsByProtocolAndTopicName(id int, topicName string) ([]*EventDefn, error)
- func (s *ProtocolStore) CreateProtocol(input NewProtocol) (*Protocol, error)
- func (s *ProtocolStore) DeleteByName(name string) error
- func (s *ProtocolStore) FindById(id int) (*Protocol, error)
- func (s *ProtocolStore) FindByName(name string) (*Protocol, error)
- func (s *ProtocolStore) FindEventById(id int) (*EventDefn, error)
- type RepayEvent
- type Stores
- type Token
- type TokenInfo
- type TokenStore
- func (s *TokenStore) All() ([]*Token, error)
- func (s *TokenStore) AllByChain(chainId int) ([]*Token, error)
- func (s *TokenStore) CreateToken(address string, name *string, ticker *string, chainId int) (*Token, error)
- func (s *TokenStore) FindById(id int) (*Token, error)
- func (s *TokenStore) FindByName(name string) (*Token, error)
- func (s *TokenStore) FindOrCreateByAddress(address string, chainId int) (*Token, error)
- func (s *TokenStore) UpdateToken(id int, address string, name string, ticker string, decimals int) (*Token, error)
- type UpdateProtocolInstance
Constants ¶
This section is empty.
Variables ¶
View Source
var AllEventType = []EventType{ EventTypeBorrow, EventTypeRepay, EventTypeLiquidation, EventTypeDeposit, }
Functions ¶
Types ¶
type AccountStore ¶
type AccountStore struct {
// contains filtered or unexported fields
}
func NewAccountStore ¶
func NewAccountStore(db *sqlx.DB) *AccountStore
func (*AccountStore) All ¶
func (s *AccountStore) All() ([]*Account, error)
func (*AccountStore) CreateAccount ¶
func (s *AccountStore) CreateAccount(address string) (*Account, error)
func (*AccountStore) FindByAddress ¶
func (s *AccountStore) FindByAddress(address string) (*Account, error)
func (*AccountStore) FindOrCreateByAddress ¶
func (s *AccountStore) FindOrCreateByAddress(address string) (*Account, error)
type AllEvent ¶
type AllEvent struct { // Common ID int Type EventType ProtocolInstanceId int EventDefinitionId int Txhash string Blocknumber int Index int OccuredAt time.Time // Borrow DepositorAccountId *int AmountDeposited *int DepositTokenId *int // Borrow BorrowerAccountId *int AmountBorrowed *int BorrowTokenId *int // Repay RepayerAccountId *int AmountRepayed *int RepayTokenId *int // Liquidation LiquidatorAccountId *int AmountSeized *int CollateralTokenId *int DebtTokenId *int }
func (AllEvent) AnyEvent ¶
func (e AllEvent) AnyEvent(accountStore *AccountStore, tokenStore *TokenStore) (AnyEvent, error)
type BorrowEvent ¶
type BorrowEvent struct { ID int `json:"id"` Type EventType `json:"type"` Txhash string `json:"txhash"` Blocknumber int `json:"blocknumber"` Index int `json:"index"` OccuredAt time.Time `json:"occuredAt"` Borrower *Account `json:"borrower"` AmountBorrowed int `json:"amountBorrowed"` Token *Token `json:"token"` }
func (BorrowEvent) IsAnyEvent ¶
func (BorrowEvent) IsAnyEvent()
func (BorrowEvent) IsEvent ¶
func (BorrowEvent) IsEvent()
type Chain ¶
type ChainStore ¶
type ChainStore struct {
// contains filtered or unexported fields
}
func NewChainStore ¶
func NewChainStore(db *sqlx.DB) *ChainStore
func (*ChainStore) All ¶
func (s *ChainStore) All() ([]*Chain, error)
func (*ChainStore) CreateChain ¶
func (s *ChainStore) CreateChain(input NewChain) (*Chain, error)
func (*ChainStore) DeleteByName ¶
func (s *ChainStore) DeleteByName(name string) error
func (*ChainStore) FindByName ¶
func (s *ChainStore) FindByName(name string) (*Chain, error)
type DepositEvent ¶
type DepositEvent struct { ID int `json:"id"` Type EventType `json:"type"` Txhash string `json:"txhash"` Blocknumber int `json:"blocknumber"` Index int `json:"index"` OccuredAt time.Time `json:"occuredAt"` Depositor *Account `json:"depositor"` AmountDeposited int `json:"amountDeposited"` Token *Token `json:"token"` }
func (DepositEvent) IsAnyEvent ¶
func (DepositEvent) IsAnyEvent()
func (DepositEvent) IsEvent ¶
func (DepositEvent) IsEvent()
type EventStore ¶
type EventStore struct {
// contains filtered or unexported fields
}
func NewEventStore ¶
func NewEventStore(db *sqlx.DB) *EventStore
func (*EventStore) AllByAccount ¶
func (s *EventStore) AllByAccount(accountId int) ([]AllEvent, error)
func (*EventStore) StoreBorrowEvent ¶
func (*EventStore) StoreDepositEvent ¶
func (*EventStore) StoreLiquidationEvent ¶
func (s *EventStore) StoreLiquidationEvent(protocolInstanceId int, eventDefinitionId int, txHash string, blockNumber int64, index int, occuredAt time.Time, borrowerAccountId int, liquidatorAccountId int, amountRepayed *big.Int, amountSeized *big.Int, debtTokenId int, collateralTokenId int) (int, error)
type EventType ¶
type EventType string
func (EventType) MarshalGQL ¶
func (*EventType) UnmarshalGQL ¶
type LiquidationEvent ¶
type LiquidationEvent struct { ID int `json:"id"` Type EventType `json:"type"` Txhash string `json:"txhash"` Blocknumber int `json:"blocknumber"` Index int `json:"index"` OccuredAt time.Time `json:"occuredAt"` Borrower *Account `json:"borrower"` Liquidator *Account `json:"liquidator"` AmountRepayed int `json:"amountRepayed"` AmountSeized int `json:"amountSeized"` CollateralToken *Token `json:"collateralToken"` DebtToken *Token `json:"debtToken"` }
func (LiquidationEvent) IsAnyEvent ¶
func (LiquidationEvent) IsAnyEvent()
func (LiquidationEvent) IsEvent ¶
func (LiquidationEvent) IsEvent()
type NewEventDefn ¶
type NewProtocol ¶
type NewProtocolInstance ¶
type ProtocolInstance ¶
type ProtocolInstance struct { ID int `json:"id"` Protocol *Protocol Chain *Chain ProtocolID int `json:"protocolId"` ChainID int `json:"chainId"` ContractAddress string `json:"contractAddress"` FirstBlockToRead int `json:"firstBlockToRead"` LastBlockRead int `json:"lastBlockRead"` }
func (*ProtocolInstance) ScanStartBlock ¶
func (pi *ProtocolInstance) ScanStartBlock() int
type ProtocolInstanceStore ¶
type ProtocolInstanceStore struct {
// contains filtered or unexported fields
}
func NewProtocolInstanceStore ¶
func NewProtocolInstanceStore(db *sqlx.DB) *ProtocolInstanceStore
func (*ProtocolInstanceStore) All ¶
func (s *ProtocolInstanceStore) All() ([]*ProtocolInstance, error)
func (*ProtocolInstanceStore) CreateProtocolInstance ¶
func (s *ProtocolInstanceStore) CreateProtocolInstance(input NewProtocolInstance) (*ProtocolInstance, error)
func (*ProtocolInstanceStore) DeleteByProtocolAndChain ¶
func (s *ProtocolInstanceStore) DeleteByProtocolAndChain(protocolName string, chainName string) error
func (*ProtocolInstanceStore) FindById ¶
func (s *ProtocolInstanceStore) FindById(id int) (*ProtocolInstance, error)
func (*ProtocolInstanceStore) FindByProtocolIdAndChainId ¶
func (s *ProtocolInstanceStore) FindByProtocolIdAndChainId(protocolId int, chainId int) (*ProtocolInstance, error)
func (*ProtocolInstanceStore) FindChainById ¶
func (s *ProtocolInstanceStore) FindChainById(id int) (*Chain, error)
func (*ProtocolInstanceStore) FindProtocolById ¶
func (s *ProtocolInstanceStore) FindProtocolById(id int) (*Protocol, error)
func (*ProtocolInstanceStore) UpdateLastBlockRead ¶
func (s *ProtocolInstanceStore) UpdateLastBlockRead(protocolInstanceId int, lastBlock uint) error
func (*ProtocolInstanceStore) UpdateProtocolInstance ¶
func (s *ProtocolInstanceStore) UpdateProtocolInstance(protocolInstance *ProtocolInstance) (*ProtocolInstance, error)
type ProtocolStore ¶
type ProtocolStore struct {
// contains filtered or unexported fields
}
func NewProtocolStore ¶
func NewProtocolStore(db *sqlx.DB) *ProtocolStore
func (*ProtocolStore) AddEventDefn ¶
func (*ProtocolStore) All ¶
func (s *ProtocolStore) All() ([]*Protocol, error)
func (*ProtocolStore) AllByChain ¶
func (s *ProtocolStore) AllByChain(chainId int) ([]*Protocol, error)
func (*ProtocolStore) AllEventsByProtocol ¶
func (s *ProtocolStore) AllEventsByProtocol(id int) ([]*EventDefn, error)
func (*ProtocolStore) AllEventsByProtocolAndTopicName ¶
func (s *ProtocolStore) AllEventsByProtocolAndTopicName(id int, topicName string) ([]*EventDefn, error)
func (*ProtocolStore) CreateProtocol ¶
func (s *ProtocolStore) CreateProtocol(input NewProtocol) (*Protocol, error)
func (*ProtocolStore) DeleteByName ¶
func (s *ProtocolStore) DeleteByName(name string) error
func (*ProtocolStore) FindByName ¶
func (s *ProtocolStore) FindByName(name string) (*Protocol, error)
func (*ProtocolStore) FindEventById ¶
func (s *ProtocolStore) FindEventById(id int) (*EventDefn, error)
type RepayEvent ¶
type RepayEvent struct { ID int `json:"id"` Type EventType `json:"type"` Txhash string `json:"txhash"` Blocknumber int `json:"blocknumber"` Index int `json:"index"` OccuredAt time.Time `json:"occuredAt"` Borrower *Account `json:"borrower"` AmountRepayed int `json:"amountRepayed"` Token *Token `json:"token"` }
func (RepayEvent) IsAnyEvent ¶
func (RepayEvent) IsAnyEvent()
func (RepayEvent) IsEvent ¶
func (RepayEvent) IsEvent()
type Stores ¶
type Stores struct { Protocol *ProtocolStore Chain *ChainStore ProtocolInstance *ProtocolInstanceStore Account *AccountStore Event *EventStore Token *TokenStore // contains filtered or unexported fields }
func GenerateStores ¶
type TokenStore ¶
type TokenStore struct {
// contains filtered or unexported fields
}
func NewTokenStore ¶
func NewTokenStore(db *sqlx.DB) *TokenStore
func (*TokenStore) All ¶
func (s *TokenStore) All() ([]*Token, error)
func (*TokenStore) AllByChain ¶
func (s *TokenStore) AllByChain(chainId int) ([]*Token, error)
func (*TokenStore) CreateToken ¶
func (*TokenStore) FindByName ¶
func (s *TokenStore) FindByName(name string) (*Token, error)
func (*TokenStore) FindOrCreateByAddress ¶
func (s *TokenStore) FindOrCreateByAddress(address string, chainId int) (*Token, error)
func (*TokenStore) UpdateToken ¶
Click to show internal directories.
Click to hide internal directories.