mvc

Dec 12, 2023

Changes in this version

+ type AtomicIngester interface

+ ProcessBlock func(ctx sdk.Context, tx Tx) error

+ SetLogger func(log.Logger)

+ type ChainInfoRepository interface

+ GetLatestHeight func(ctx context.Context) (uint64, error)

+ GetLatestHeightRetrievalTime func(ctx context.Context) (time.Time, error)

+ StoreLatestHeight func(ctx context.Context, tx Tx, height uint64) error

+ StoreLatestHeightRetrievalTime func(ctx context.Context, time time.Time) error

+ type ChainInfoUsecase interface

+ GetLatestHeight func(ctx context.Context) (uint64, error)

+ type PoolsRepository interface

+ ClearAllPools func(ctx context.Context, tx Tx) error

+ GetAllPools func(context.Context) ([]domain.PoolI, error)

+ GetPools func(ctx context.Context, poolIDs map[uint64]struct{}) (map[uint64]domain.PoolI, error)

+ GetTickModelForPools func(ctx context.Context, pools []uint64) (map[uint64]domain.TickModel, error)

+ StorePools func(ctx context.Context, tx Tx, pools []domain.PoolI) error

+ type PoolsUsecase interface

+ GetAllPools func(ctx context.Context) ([]domain.PoolI, error)

+ GetPool func(ctx context.Context, poolID uint64) (domain.PoolI, error)

+ GetRoutesFromCandidates func(ctx context.Context, candidateRoutes route.CandidateRoutes, ...) ([]route.RouteImpl, error)

+ GetTickModelMap func(ctx context.Context, poolIDs []uint64) (map[uint64]domain.TickModel, error)

+ type RedisTx struct

+ func NewRedisTx(pipeliner redis.Pipeliner) *RedisTx

+ func (rt *RedisTx) AsRedisTx() (*RedisTx, error)

+ func (rt *RedisTx) ClearAll(ctx context.Context) error

+ func (rt *RedisTx) Exec(ctx context.Context) error

+ func (rt *RedisTx) GetPipeliner(ctx context.Context) (redis.Pipeliner, error)

+ func (rt *RedisTx) IsActive() bool

+ type RouterRepository interface

+ GetAllTakerFees func(ctx context.Context) (domain.TakerFeeMap, error)

+ GetRoutes func(ctx context.Context, denom0, denom1 string) (route.CandidateRoutes, error)

+ GetTakerFee func(ctx context.Context, denom0, denom1 string) (osmomath.Dec, error)

+ SetRoutes func(ctx context.Context, denom0, denom1 string, routes route.CandidateRoutes) error

+ SetRoutesTx func(ctx context.Context, tx Tx, denom0, denom1 string, ...) error

+ SetTakerFee func(ctx context.Context, tx Tx, denom0, denom1 string, takerFee osmomath.Dec) error

+ type RouterUsecase interface

+ GetBestSingleRouteQuote func(ctx context.Context, tokenIn sdk.Coin, tokenOutDenom string) (domain.Quote, error)

+ GetCachedCandidateRoutes func(ctx context.Context, tokenInDenom, tokenOutDenom string) (route.CandidateRoutes, error)

+ GetCandidateRoutes func(ctx context.Context, tokenInDenom, tokenOutDenom string) (route.CandidateRoutes, error)

+ GetCustomQuote func(ctx context.Context, tokenIn sdk.Coin, tokenOutDenom string, poolIDs []uint64) (domain.Quote, error)

+ GetOptimalQuote func(ctx context.Context, tokenIn sdk.Coin, tokenOutDenom string) (domain.Quote, error)

+ GetTakerFee func(ctx context.Context, poolID uint64) ([]domain.TakerFeeForPair, error)

+ StoreRouterStateFiles func(ctx context.Context) error

+ type Tx interface

+ AsRedisTx func() (*RedisTx, error)

+ ClearAll func(ctx context.Context) error

+ Exec func(context.Context) error

+ IsActive func() bool

+ type TxManager interface

+ StartTx func() Tx