tokenprice

Documentation

Index

• func WithThresholdPct(pct float64) func(*Opts)
• func WithTicker(t ticker.Ticker) func(*Opts)
• type Buffer
  • func NewBuffer(price tokens.Pricer, optOrTokens ...any) *Buffer
  • func (b *Buffer) Price(token tokens.Token) float64
  • func (b *Buffer) Stream(ctx context.Context)
• type Opts

Functions

func WithThresholdPct

func WithThresholdPct(pct float64) func(*Opts)

func WithTicker

func WithTicker(t ticker.Ticker) func(*Opts)

Types

type Buffer

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

func NewBuffer

func NewBuffer(price tokens.Pricer, optOrTokens ...any) *Buffer

NewBuffer creates a new token price buffer.

A token price buffer maintains a buffered view of token prices for multiple tokens. Buffered token prices are not updated unless they are outside the threshold percentage. Start steaming token prices with Buffer.Stream(ctx).

func (*Buffer) Price

func (b *Buffer) Price(token tokens.Token) float64

Price returns the buffered price for the given token. If the price is not known, returns 0.

func (*Buffer) Stream

func (b *Buffer) Stream(ctx context.Context)

Stream starts streaming prices for all tokens into the buffer.

type Opts

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