tokenprice

Documentation

Index

• type Buffer
  • func NewBuffer(price tokens.Pricer, tkns []tokens.Token, threshold float64, ...) Buffer
• type MockBuffer
  • func NewMockBuffer() *MockBuffer
  • func (b *MockBuffer) Price(token tokens.Token) float64
  • func (b *MockBuffer) SetPrice(token tokens.Token, price float64)
  • func (*MockBuffer) Stream(context.Context)

Types

type Buffer

type Buffer interface {
	Price(token tokens.Token) float64
	Stream(ctx context.Context)
}

func NewBuffer

func NewBuffer(price tokens.Pricer, tkns []tokens.Token, threshold float64, ticker ticker.Ticker) 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).

type MockBuffer

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

func NewMockBuffer

func NewMockBuffer() *MockBuffer

func (*MockBuffer) Price

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

func (*MockBuffer) SetPrice

func (b *MockBuffer) SetPrice(token tokens.Token, price float64)

func (*MockBuffer) Stream

func (*MockBuffer) Stream(context.Context)