Versions in this module Expand all Collapse all v0 v0.0.1 Nov 1, 2023 Changes in this version + const BLOCK_SUFFIX + const NATIVE_TOKEN + const PAIR_SUFFIX + const TOKEN + func GetBlockFolderPath(chainId string) []string + func GetPairFolderPath(chainId string) []string + func NewLcdClient(baseUrl string, c httpClient) lcdClient + type AssetInfo struct + NativeToken ... + Token ... + func (assets *AssetInfo) GetInfo() *AssetInfoWithType + type AssetInfoWithType struct + DenomOrAddress string + Type string + type BlockTxsDTO struct + BlockId int64 + Txs []TxDTO + func FakeBlockDto() BlockTxsDTO + type BlockTxsRaw struct + BlockId int64 + Txs []TxRaw + type DataStore interface + AddCustomInterfaceRegistry func(...func(codectypes.InterfaceRegistry)) + ChangeLatestBlock func(int64, ...string) error + GetBlockByHeight func(int64) (*tendermintType.Block, error) + GetBlockTxsFromBlockData func(*tendermintType.Block) (*BlockTxsRaw, error) + GetBlockTxsFromHeight func(int64) (*BlockTxsRaw, error) + GetChainId func() string + GetCurrentPairsList func(int64) (*PairListDTO, error) + GetCurrentPoolStatusOfAllPairs func(int64) (*PoolInfoList, error) + GetCurrentPoolStatusOfUnitPair func(int64, string) (*PoolInfoDTO, error) + GetLatestProcessedBlockNumber func(...string) (int64, error) + GetNodeSyncedHeight func() (int64, error) + GetPoolStatusOfAllPairsByHeight func(int64, ...string) (*PoolInfoList, error) + GetPoolStatusOfUnitPairByHeight func(int64, string, ...string) (*PoolInfoDTO, error) + SetNewQueryClientFunc func(func(cc grpc1.ClientConn) wasm.QueryClient) + SetNewS3ClientFunc func(func() (s3client.S3ClientInterface, error)) + SetNewServiceClientFunc func(func(cc grpc1.ClientConn) txtypes.ServiceClient) + UploadBlockBinary func(int64, []byte, ...string) error + UploadPoolInfoBinary func(int64, []byte, ...string) error + func New(c configs.Config, serviceDesc grpcConn.ServiceDesc, lcd lcdClient) (DataStore, error) + type PairListDTO struct + Pairs map[string]UnitPairDTO + type PairListResponse struct + Pairs []UnitPair + type PoolAssetInfo struct + Amount *cosmossdk.Int + Info AssetInfo + func (pool *PoolAssetInfo) GetInfo() *PoolAssetInfoWithType + type PoolAssetInfoWithType struct + Amount *cosmossdk.Int + Info *AssetInfoWithType + type PoolInfo struct + Assets [2]PoolAssetInfo + TotalShare *cosmossdk.Int + func (pool *PoolInfo) Convert() *PoolInfoDTO + type PoolInfoDTO struct + Assets [2]PoolAssetInfoWithType + TotalShare *cosmossdk.Int + type PoolInfoList struct + Pairs map[string]PoolInfoDTO + func FakePoolInfoList() PoolInfoList + type ReadStore interface + GetBlockByHeight func(height uint64) (*BlockTxsDTO, error) + GetLatestHeight func() (uint64, error) + GetPoolStatusOfAllPairsByHeight func(uint64) (*PoolInfoList, error) + func NewReadStore(chainId string, s3Client s3client.S3ClientInterface) ReadStore + func NewReadStoreWithGrpc(chainId string, store DataStore) ReadStore + type ReadStoreMock struct + func (m *ReadStoreMock) GetBlockByHeight(height uint64) (*BlockTxsDTO, error) + func (m *ReadStoreMock) GetLatestHeight() (uint64, error) + func (m *ReadStoreMock) GetPoolStatusOfAllPairsByHeight(uint64) (*PoolInfoList, error) + type TxDTO struct + Code uint32 + Codespace string + Data string + Events []abcitypes.Event + GasUsed string + GasWanted string + Height string + Info string + Logs cosmossdk.ABCIMessageLogs + RawLog string + Timestamp string + Tx *codectypes.Any + TxHash string + type TxRaw struct + TxContent *txtypes.GetTxResponse + TxHash string + func (tx *TxRaw) MarshalJSON() ([]byte, error) + func (tx *TxRaw) ToString() (string, error) + type UnitPair struct + AssetDecimals [2]uint + AssetInfo [2]AssetInfo + ContractAddr string + LiquidityToken string + func (pair *UnitPair) Convert() *UnitPairDTO + type UnitPairDTO struct + AssetDecimals [2]uint + AssetInfo [2]AssetInfoWithType + ContractAddr string + LiquidityToken string