stats

Documentation

Index

• type NTTMedian
  • func NewNTTMedian(influxCli influxdb2.Client, org string, bucketInfiniteRetention string, ...) *NTTMedian
  • func (j *NTTMedian) Run(ctx context.Context) error
• type NTTTopAddressJob
  • func NewNTTTopAddressJob(influxCli influxdb2.Client, org string, bucketInfiniteRetention string, ...) *NTTTopAddressJob
  • func (j *NTTTopAddressJob) Run(ctx context.Context) error
• type NTTTopHolderJob
  • func NewNTTTopHolderJob(c *resty.Client, arkhamUrl, arkhamApiKey, solanaUrl string, ...) *NTTTopHolderJob
  • func (j *NTTTopHolderJob) Run(ctx context.Context) error

Types

type NTTMedian

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

func NewNTTMedian

func NewNTTMedian(influxCli influxdb2.Client, org string, bucketInfiniteRetention string,
	cacheClient cache.Cache, logger *zap.Logger) *NTTMedian

NewNTTMedian creates a new NTTMedian.

func (*NTTMedian) Run

func (j *NTTMedian) Run(ctx context.Context) error

Run runs the ntt median job.

type NTTTopAddressJob

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

func NewNTTTopAddressJob

func NewNTTTopAddressJob(influxCli influxdb2.Client, org string, bucketInfiniteRetention string,
	cacheClient cache.Cache, logger *zap.Logger) *NTTTopAddressJob

NewNTTTopAddressJob creates a new NttTopAddressJob.

func (*NTTTopAddressJob) Run

func (j *NTTTopAddressJob) Run(ctx context.Context) error

Run runs the transfer report job.

type NTTTopHolderJob

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

func NewNTTTopHolderJob

func NewNTTTopHolderJob(c *resty.Client,
	arkhamUrl, arkhamApiKey, solanaUrl string,
	cacheClient cache.Cache,
	tokenProvider *domain.TokenProvider,
	notionalCache notional.NotionalLocalCacheReadable,
	log *zap.Logger) *NTTTopHolderJob

func (*NTTTopHolderJob) Run

func (j *NTTTopHolderJob) Run(ctx context.Context) error