graph

Documentation

Index

• Constants
• type AsyncGofer
  • func NewAsyncGofer(graph map[gofer.Pair]nodes.Aggregator, feeder *feeder.Feeder, ...) (*AsyncGofer, error)
  • func (a *AsyncGofer) Start(ctx context.Context) error
  • func (a *AsyncGofer) Wait() chan error
• type ErrPairNotFound
  • func (e ErrPairNotFound) Error() string
• type Gofer
  • func NewGofer(graph map[gofer.Pair]nodes.Aggregator, feeder *feeder.Feeder) *Gofer
  • func (g *Gofer) Models(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Model, error)
  • func (g *Gofer) Pairs() ([]gofer.Pair, error)
  • func (g *Gofer) Price(pair gofer.Pair) (*gofer.Price, error)
  • func (g *Gofer) Prices(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Price, error)

Constants

const LoggerTag = "ASYNC_GOFER"

Types

type AsyncGofer

type AsyncGofer struct {
	*Gofer
	// contains filtered or unexported fields
}

AsyncGofer implements the gofer.Gofer interface. It works just like Gofer but allows updating prices asynchronously.

func NewAsyncGofer

func NewAsyncGofer(
	graph map[gofer.Pair]nodes.Aggregator,
	feeder *feeder.Feeder,
	nodes []nodes.Node,
	logger log.Logger,
) (*AsyncGofer, error)

NewAsyncGofer returns a new AsyncGofer instance.

func (*AsyncGofer) Start

func (a *AsyncGofer) Start(ctx context.Context) error

Start starts asynchronous price updater.

func (*AsyncGofer) Wait

func (a *AsyncGofer) Wait() chan error

Wait waits until the context is canceled or until an error occurs.

type ErrPairNotFound

type ErrPairNotFound struct {
	Pair gofer.Pair
}

func (ErrPairNotFound) Error

func (e ErrPairNotFound) Error() string

type Gofer

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

Gofer implements the gofer.Gofer interface. It uses a graph structure to calculate pairs prices.

func NewGofer

func NewGofer(graph map[gofer.Pair]nodes.Aggregator, feeder *feeder.Feeder) *Gofer

NewGofer returns a new Gofer instance. If the Feeder is not nil, then prices are automatically updated when the Price or Prices methods are called. Otherwise, prices have to be updated externally.

func (*Gofer) Models

func (g *Gofer) Models(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Model, error)

Models implements the gofer.Gofer interface.

func (*Gofer) Pairs

func (g *Gofer) Pairs() ([]gofer.Pair, error)

Pairs implements the gofer.Gofer interface.

func (*Gofer) Price

func (g *Gofer) Price(pair gofer.Pair) (*gofer.Price, error)

Price implements the gofer.Gofer interface.

func (*Gofer) Prices

func (g *Gofer) Prices(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Price, error)

Prices implements the gofer.Gofer interface.