common

Documentation

Index

• Constants
• func GetDealsAndMatchResult(ctx sdk.Context, orderKeeper types.OrderKeeper) ([]*backend.Deal, []*backend.MatchResult, error)
• func GetMatchResults(ctx sdk.Context, orderKeeper types.OrderKeeper) []*backend.MatchResult
• func GetNewOrders(ctx sdk.Context, orderKeeper types.OrderKeeper) []*backend.Order
• func NewPool(redisURL string, redisPass string, logger log.Logger) (*redis.Pool, error)
• func ParseRedisURL(redisURL, requirePass string) (string, string, error)
• type Cache
  • func NewCache() *Cache
  • func (c *Cache) AddNewSwapTokenPair(swapTokenPair *ammswap.SwapTokenPair)
  • func (c *Cache) AddNewTokenPair(tokenPair *types.TokenPair)
  • func (c *Cache) AddSwapInfo(swapInfo *backend.SwapInfo)
  • func (c *Cache) AddTransaction(transaction *backend.Transaction)
  • func (c *Cache) AddUpdatedAccount(acc auth.Account)
  • func (c *Cache) GetNewSwapTokenPairs() []*ammswap.SwapTokenPair
  • func (c *Cache) GetNewTokenPairs() []*types.TokenPair
  • func (c *Cache) GetSwapInfos() []*backend.SwapInfo
  • func (c *Cache) GetTokenPairChanged() bool
  • func (c *Cache) GetTransactions() []*backend.Transaction
  • func (c *Cache) GetUpdatedAccAddress() (accs []sdk.AccAddress)
  • func (c *Cache) Reset()
  • func (c *Cache) SetTokenPairChanged(changed bool)

Constants

const (
	MaxIdle     = 3
	IdleTimeout = 240
)

Functions

func GetDealsAndMatchResult

func GetDealsAndMatchResult(ctx sdk.Context, orderKeeper types.OrderKeeper) ([]*backend.Deal, []*backend.MatchResult, error)

func GetMatchResults

func GetMatchResults(ctx sdk.Context, orderKeeper types.OrderKeeper) []*backend.MatchResult

func GetNewOrders

func GetNewOrders(ctx sdk.Context, orderKeeper types.OrderKeeper) []*backend.Order

func NewPool

func NewPool(redisURL string, redisPass string, logger log.Logger) (*redis.Pool, error)

func ParseRedisURL

func ParseRedisURL(redisURL, requirePass string) (string, string, error)

Use redis URI scheme. URLs should follow the draft IANA specification for the scheme (https://www.iana.org/assignments/uri-schemes/prov/redis). eg. redis://user:password@localhost:6379, redis://localhost:16379 return: address, password, error

Types

type Cache

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

func NewCache

func NewCache() *Cache

func (*Cache) AddNewSwapTokenPair

func (c *Cache) AddNewSwapTokenPair(swapTokenPair *ammswap.SwapTokenPair)

AddNewSwapTokenPairs appends swapTokenPair to cache newSwapTokenPairs

func (*Cache) AddNewTokenPair

func (c *Cache) AddNewTokenPair(tokenPair *types.TokenPair)

AddNewTokenPair adds a new token pair into cache

func (*Cache) AddSwapInfo

func (c *Cache) AddSwapInfo(swapInfo *backend.SwapInfo)

AddSwapInfo appends swapInfo to cache SwapInfos

func (*Cache) AddTransaction

func (c *Cache) AddTransaction(transaction *backend.Transaction)

func (*Cache) AddUpdatedAccount

func (c *Cache) AddUpdatedAccount(acc auth.Account)

func (*Cache) GetNewSwapTokenPairs

func (c *Cache) GetNewSwapTokenPairs() []*ammswap.SwapTokenPair

nolint

func (*Cache) GetNewTokenPairs

func (c *Cache) GetNewTokenPairs() []*types.TokenPair

GetNewTokenPairs returns new token pairs from cache

func (*Cache) GetSwapInfos

func (c *Cache) GetSwapInfos() []*backend.SwapInfo

nolint

func (*Cache) GetTokenPairChanged

func (c *Cache) GetTokenPairChanged() bool

GetTokenPairChanged gets tokenPairChanged

func (*Cache) GetTransactions

func (c *Cache) GetTransactions() []*backend.Transaction

func (*Cache) GetUpdatedAccAddress

func (c *Cache) GetUpdatedAccAddress() (accs []sdk.AccAddress)

func (*Cache) Reset

func (c *Cache) Reset()

Reset temporary cache, called at BeginBlock

func (*Cache) SetTokenPairChanged

func (c *Cache) SetTokenPairChanged(changed bool)

SetTokenPairChanged sets tokenPairChanged