cache

Documentation

Index

• type AccumTagged
• type MemoryCache
  • func New() *MemoryCache
  • func (m *MemoryCache) AddPoolEvent(tx types.PoolTxEvent)
  • func (m *MemoryCache) AddUserBalance(chainId types.ChainId, user types.EthAddress, token types.EthAddress)
  • func (m *MemoryCache) LatestBlock(chainId types.ChainId) int64
  • func (m *MemoryCache) MaterializeKnockoutBook(loc types.BookLocation) *model.KnockoutSaga
  • func (m *MemoryCache) MaterializeKnockoutPos(loc types.PositionLocation) *model.KnockoutSubplot
  • func (m *MemoryCache) MaterializePoolLiqCurve(loc types.PoolLocation) *model.LiquidityCurve
  • func (m *MemoryCache) MaterializePoolTradingHist(loc types.PoolLocation) *model.PoolTradingHistory
  • func (m *MemoryCache) MaterializePosition(loc types.PositionLocation) *model.PositionTracker
  • func (m *MemoryCache) RetrieveAllPositions() map[types.PositionLocation]*model.PositionTracker
  • func (m *MemoryCache) RetrieveChainAccums(chainId types.ChainId) []AccumTagged
  • func (m *MemoryCache) RetrievePoolAccum(loc types.PoolLocation) model.AccumPoolStats
  • func (m *MemoryCache) RetrievePoolAccumBefore(loc types.PoolLocation, histTime int) model.AccumPoolStats
  • func (m *MemoryCache) RetrievePoolAccumSeries(loc types.PoolLocation, startTime int, endTime int) (model.AccumPoolStats, []model.AccumPoolStats)
  • func (m *MemoryCache) RetrievePoolLimits(loc types.PoolLocation) map[types.PositionLocation]*model.KnockoutSubplot
  • func (m *MemoryCache) RetrievePoolLiqCurve(loc types.PoolLocation) (float64, []*model.LiquidityBump)
  • func (m *MemoryCache) RetrievePoolPositions(loc types.PoolLocation) map[types.PositionLocation]*model.PositionTracker
  • func (m *MemoryCache) RetrievePoolSet() []types.PoolLocation
  • func (m *MemoryCache) RetrieveUserBalances(chainId types.ChainId, user types.EthAddress) []types.EthAddress
  • func (m *MemoryCache) RetrieveUserLimits(chainId types.ChainId, user types.EthAddress) map[types.PositionLocation]*model.KnockoutSubplot
  • func (m *MemoryCache) RetrieveUserPoolLimits(user types.EthAddress, pool types.PoolLocation) map[types.PositionLocation]*model.KnockoutSubplot
  • func (m *MemoryCache) RetrieveUserPoolPositions(user types.EthAddress, pool types.PoolLocation) map[types.PositionLocation]*model.PositionTracker
  • func (m *MemoryCache) RetrieveUserPositions(chainId types.ChainId, user types.EthAddress) map[types.PositionLocation]*model.PositionTracker
  • func (m *MemoryCache) RetrieveUserTxs(chainId types.ChainId, user types.EthAddress) []types.PoolTxEvent
  • func (m *MemoryCache) RetrivePoolTxs(pool types.PoolLocation) []types.PoolTxEvent
• type RWLockMap
• type RWLockMapArray
• type RWLockMapMap

Types

type AccumTagged

type AccumTagged struct {
	model.AccumPoolStats
	types.PoolLocation
}

type MemoryCache

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

func New

func New() *MemoryCache

func (*MemoryCache) AddPoolEvent

func (m *MemoryCache) AddPoolEvent(tx types.PoolTxEvent)

func (*MemoryCache) AddUserBalance

func (m *MemoryCache) AddUserBalance(chainId types.ChainId, user types.EthAddress, token types.EthAddress)

func (*MemoryCache) LatestBlock

func (m *MemoryCache) LatestBlock(chainId types.ChainId) int64

func (*MemoryCache) MaterializeKnockoutBook

func (m *MemoryCache) MaterializeKnockoutBook(loc types.BookLocation) *model.KnockoutSaga

func (*MemoryCache) MaterializeKnockoutPos

func (m *MemoryCache) MaterializeKnockoutPos(loc types.PositionLocation) *model.KnockoutSubplot

func (*MemoryCache) MaterializePoolLiqCurve

func (m *MemoryCache) MaterializePoolLiqCurve(loc types.PoolLocation) *model.LiquidityCurve

func (*MemoryCache) MaterializePoolTradingHist

func (m *MemoryCache) MaterializePoolTradingHist(loc types.PoolLocation) *model.PoolTradingHistory

func (*MemoryCache) MaterializePosition

func (m *MemoryCache) MaterializePosition(loc types.PositionLocation) *model.PositionTracker

func (*MemoryCache) RetrieveAllPositions

func (m *MemoryCache) RetrieveAllPositions() map[types.PositionLocation]*model.PositionTracker

func (*MemoryCache) RetrieveChainAccums

func (m *MemoryCache) RetrieveChainAccums(chainId types.ChainId) []AccumTagged

func (*MemoryCache) RetrievePoolAccum

func (m *MemoryCache) RetrievePoolAccum(loc types.PoolLocation) model.AccumPoolStats

func (*MemoryCache) RetrievePoolAccumBefore

func (m *MemoryCache) RetrievePoolAccumBefore(loc types.PoolLocation, histTime int) model.AccumPoolStats

func (*MemoryCache) RetrievePoolAccumSeries

func (m *MemoryCache) RetrievePoolAccumSeries(loc types.PoolLocation, startTime int, endTime int) (model.AccumPoolStats, []model.AccumPoolStats)

func (*MemoryCache) RetrievePoolLimits

func (m *MemoryCache) RetrievePoolLimits(loc types.PoolLocation) map[types.PositionLocation]*model.KnockoutSubplot

func (*MemoryCache) RetrievePoolLiqCurve

func (m *MemoryCache) RetrievePoolLiqCurve(loc types.PoolLocation) (float64, []*model.LiquidityBump)

func (*MemoryCache) RetrievePoolPositions

func (m *MemoryCache) RetrievePoolPositions(loc types.PoolLocation) map[types.PositionLocation]*model.PositionTracker

func (*MemoryCache) RetrievePoolSet

func (m *MemoryCache) RetrievePoolSet() []types.PoolLocation

func (*MemoryCache) RetrieveUserBalances

func (m *MemoryCache) RetrieveUserBalances(chainId types.ChainId, user types.EthAddress) []types.EthAddress

func (*MemoryCache) RetrieveUserLimits

func (m *MemoryCache) RetrieveUserLimits(
	chainId types.ChainId,
	user types.EthAddress) map[types.PositionLocation]*model.KnockoutSubplot

func (*MemoryCache) RetrieveUserPoolLimits

func (m *MemoryCache) RetrieveUserPoolLimits(user types.EthAddress, pool types.PoolLocation) map[types.PositionLocation]*model.KnockoutSubplot

func (*MemoryCache) RetrieveUserPoolPositions

func (m *MemoryCache) RetrieveUserPoolPositions(user types.EthAddress, pool types.PoolLocation) map[types.PositionLocation]*model.PositionTracker

func (*MemoryCache) RetrieveUserPositions

func (m *MemoryCache) RetrieveUserPositions(
	chainId types.ChainId,
	user types.EthAddress) map[types.PositionLocation]*model.PositionTracker

func (*MemoryCache) RetrieveUserTxs

func (m *MemoryCache) RetrieveUserTxs(chainId types.ChainId, user types.EthAddress) []types.PoolTxEvent

func (*MemoryCache) RetrivePoolTxs

func (m *MemoryCache) RetrivePoolTxs(pool types.PoolLocation) []types.PoolTxEvent

type RWLockMap

type RWLockMap[Key comparable, Val any] struct {
	// contains filtered or unexported fields
}

type RWLockMapArray

type RWLockMapArray[Key comparable, Val any] struct {
	// contains filtered or unexported fields
}

type RWLockMapMap

type RWLockMapMap[Key comparable, KeyInner comparable, Val any] struct {
	// contains filtered or unexported fields
}