metric

Documentation

Index

• func MakePointForVaaCount(vaa *sdk.VAA) (*write.Point, error)
• func MakePointForVaaVolume(params *MakePointForVaaVolumeParams) (*write.Point, error)
• type MakePointForVaaVolumeParams
• type Metric
  • func New(ctx context.Context, influxCli influxdb2.Client, organization string, ...) (*Metric, error)
  • func (m *Metric) Close()
  • func (m *Metric) Push(ctx context.Context, vaa *sdk.VAA) error
• type MetricPushFunc

Functions

func MakePointForVaaCount

func MakePointForVaaCount(vaa *sdk.VAA) (*write.Point, error)

MakePointForVaaCount generates a data point for the VAA count measurement.

Some VAAs will not generate a measurement, so the caller must always check whether the returned point is nil.

func MakePointForVaaVolume

func MakePointForVaaVolume(params *MakePointForVaaVolumeParams) (*write.Point, error)

MakePointForVaaVolume builds the InfluxDB volume metric for a given VAA

Some VAAs will not generate a measurement, so the caller must always check whether the returned point is nil.

Types

type MakePointForVaaVolumeParams

type MakePointForVaaVolumeParams struct {

	// Vaa is the VAA for which we want to compute the volume metric
	Vaa *sdk.VAA

	// TokenPriceFunc returns the price of the given token at the specified timestamp.
	TokenPriceFunc func(symbol domain.Symbol, timestamp time.Time) (decimal.Decimal, error)

	// Logger is an optional parameter, in case the caller wants additional visibility.
	Logger *zap.Logger
}

MakePointForVaaVolumeParams contains input parameters for the function `MakePointForVaaVolume`

type Metric

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

Metric definition.

func New

func New(
	ctx context.Context,
	influxCli influxdb2.Client,
	organization string,
	bucketInifite string,
	bucket30Days string,
	bucket24Hours string,
	notionalCache wormscanNotionalCache.NotionalLocalCacheReadable,
	logger *zap.Logger,
) (*Metric, error)

New create a new *Metric.

func (*Metric) Close

func (m *Metric) Close()

Close influx client.

func (*Metric) Push

func (m *Metric) Push(ctx context.Context, vaa *sdk.VAA) error

Push implement MetricPushFunc definition.

type MetricPushFunc

type MetricPushFunc func(context.Context, *vaa.VAA) error

MetricPushFunc is a function to push metrics