datagateway

Documentation

Index

• Constants
• func HandleRedisErr(err error, action, key string) error
• type DebugDataGateway
• type MockDataGatewayENS
  • func (s *MockDataGatewayENS) DelENS(ctx context.Context, ens *entity.ENS) error
  • func (s *MockDataGatewayENS) GetENS(ctx context.Context, ensID string) (*entity.ENS, error)
  • func (s *MockDataGatewayENS) GetENSes(context.Context) ([]*entity.ENS, error)
  • func (s *MockDataGatewayENS) SetENS(ctx context.Context, ens *entity.ENS) error
  • func (s *MockDataGatewayENS) WriteLogs() []WriteLog
• type MockDataGatewayPoolFactory
  • func (s *MockDataGatewayPoolFactory) DelPool(ctx context.Context, pool *entity.Uniswapv3PoolCreated) error
  • func (s *MockDataGatewayPoolFactory) GetPool(ctx context.Context, lpAddress common.Address) (*entity.Uniswapv3PoolCreated, error)
  • func (s *MockDataGatewayPoolFactory) GetPools(ctx context.Context) ([]*entity.Uniswapv3PoolCreated, error)
  • func (s *MockDataGatewayPoolFactory) SetPool(ctx context.Context, pool *entity.Uniswapv3PoolCreated) error
  • func (s *MockDataGatewayPoolFactory) WriteLogs() []WriteLog
• type RedisClient
• type RepositoryENS
  • func NewEnsDataGateway(redisCli *redis.Client) RepositoryENS
  • func NewMockDataGatewayENS() RepositoryENS
• type RepositoryPoolFactory
  • func NewDataGatewayPoolFactory(redisCli *redis.Client) RepositoryPoolFactory
  • func NewMockDataGatewayPoolFactory() RepositoryPoolFactory
• type WriteLog
  • func (s WriteLog) Unmarshal() (string, string, uint64, common.Hash, error)

Constants

const EnsRedisKey = "demo:ens"

Use Redis Hash Map to store entity.ENS, with ID as field (sub-key)

const PoolFactoryRedisKey = "demo:poolfactory"

Functions

func HandleRedisErr

func HandleRedisErr(err error, action, key string) error

wraps it with superwather.ErrRecordNotFound.

Types

type DebugDataGateway

type DebugDataGateway interface {
	WriteLogs() []WriteLog
}

type MockDataGatewayENS

type MockDataGatewayENS struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*MockDataGatewayENS) DelENS

func (s *MockDataGatewayENS) DelENS(ctx context.Context, ens *entity.ENS) error

func (*MockDataGatewayENS) GetENS

func (s *MockDataGatewayENS) GetENS(ctx context.Context, ensID string) (*entity.ENS, error)

func (*MockDataGatewayENS) GetENSes

func (s *MockDataGatewayENS) GetENSes(context.Context) ([]*entity.ENS, error)

func (*MockDataGatewayENS) SetENS

func (s *MockDataGatewayENS) SetENS(ctx context.Context, ens *entity.ENS) error

func (*MockDataGatewayENS) WriteLogs

func (s *MockDataGatewayENS) WriteLogs() []WriteLog

type MockDataGatewayPoolFactory

type MockDataGatewayPoolFactory struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*MockDataGatewayPoolFactory) DelPool

func (s *MockDataGatewayPoolFactory) DelPool(
	ctx context.Context,
	pool *entity.Uniswapv3PoolCreated,
) error

func (*MockDataGatewayPoolFactory) GetPool

func (s *MockDataGatewayPoolFactory) GetPool(
	ctx context.Context,
	lpAddress common.Address,
) (
	*entity.Uniswapv3PoolCreated,
	error,
)

func (*MockDataGatewayPoolFactory) GetPools

func (s *MockDataGatewayPoolFactory) GetPools(ctx context.Context) ([]*entity.Uniswapv3PoolCreated, error)

func (*MockDataGatewayPoolFactory) SetPool

func (s *MockDataGatewayPoolFactory) SetPool(
	ctx context.Context,
	pool *entity.Uniswapv3PoolCreated,
) error

func (*MockDataGatewayPoolFactory) WriteLogs

func (s *MockDataGatewayPoolFactory) WriteLogs() []WriteLog

type RedisClient

type RedisClient interface {
	Set(context.Context, string, interface{}, time.Duration) *redis.StatusCmd
	Get(ctx context.Context, key string) *redis.StringCmd
	Close() error
}

type RepositoryENS

type RepositoryENS interface {
	SetENS(context.Context, *entity.ENS) error
	GetENS(context.Context, string) (*entity.ENS, error)
	GetENSes(context.Context) ([]*entity.ENS, error)
	DelENS(context.Context, *entity.ENS) error
}

func NewEnsDataGateway

func NewEnsDataGateway(redisCli *redis.Client) RepositoryENS

func NewMockDataGatewayENS

func NewMockDataGatewayENS() RepositoryENS

type RepositoryPoolFactory

type RepositoryPoolFactory interface {
	SetPool(context.Context, *entity.Uniswapv3PoolCreated) error
	GetPool(context.Context, common.Address) (*entity.Uniswapv3PoolCreated, error)
	GetPools(context.Context) ([]*entity.Uniswapv3PoolCreated, error)
	DelPool(context.Context, *entity.Uniswapv3PoolCreated) error
}

func NewDataGatewayPoolFactory

func NewDataGatewayPoolFactory(redisCli *redis.Client) RepositoryPoolFactory

func NewMockDataGatewayPoolFactory

func NewMockDataGatewayPoolFactory() RepositoryPoolFactory

type WriteLog

type WriteLog string

func (WriteLog) Unmarshal

func (s WriteLog) Unmarshal() (string, string, uint64, common.Hash, error)

For demotest code