notional

Documentation

Overview

Package notional contains the logic to get the notional value of assets

Index

• func NoopNotifier() notify
• type HistoryNotionalJob
  • func NewHistoryNotionalJob(api *coingecko.CoinGeckoAPI, db *mongo.Database, p2pNetwork string, ...) *HistoryNotionalJob
  • func (h *HistoryNotionalJob) Run(ctx context.Context) error
• type IndexingTimestamps
• type NotionalJob
  • func NewNotionalJob(api *coingecko.CoingeckoAPI, cacheClient *redis.Client, cachePrefix string, ...) *NotionalJob
  • func (j *NotionalJob) Run() error
• type PriceUpdate

Functions

func NoopNotifier

func NoopNotifier() notify

Types

type HistoryNotionalJob

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

func NewHistoryNotionalJob

func NewHistoryNotionalJob(api *coingecko.CoinGeckoAPI, db *mongo.Database, p2pNetwork string, requestLimitTimeSeconds int, days string, logger *zap.Logger) *HistoryNotionalJob

func (*HistoryNotionalJob) Run

func (h *HistoryNotionalJob) Run(ctx context.Context) error

type IndexingTimestamps

type IndexingTimestamps struct {
	IndexedAt time.Time `bson:"indexedAt"`
}

type NotionalJob

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

NotionalJob is the job to get the notional value of assets.

func NewNotionalJob

func NewNotionalJob(api *coingecko.CoingeckoAPI, cacheClient *redis.Client, cachePrefix string, cacheChannel string,
	tokenProvider *domain.TokenProvider, notify notify, logger *zap.Logger) *NotionalJob

NewNotionalJob creates a new notional job.

func (*NotionalJob) Run

func (j *NotionalJob) Run() error

Run runs the notional job.

type PriceUpdate

type PriceUpdate struct {
	ID          string    `bson:"_id" json:"id"`
	CoingeckoID string    `bson:"coingeckoId" json:"coingeckoId"`
	Price       string    `bson:"price" json:"price"`
	Datetime    time.Time `bson:"dateTime" json:"dateTime"`
	UpdatedAt   time.Time `bson:"updatedAt" json:"updatedAt"`
}