feeder

Documentation

Index

• Variables
• type Feeder
  • func NewFeeder(eventStream types.EventStream, priceProvider types.PriceProvider, ...) *Feeder
  • func (f *Feeder) Close()
  • func (f *Feeder) Run()

Variables

var (
	InitTimeout = 15 * time.Second
)

Types

type Feeder

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

Feeder is the price feeder.

func NewFeeder

func NewFeeder(eventStream types.EventStream, priceProvider types.PriceProvider, pricePoster types.PricePoster, logger zerolog.Logger) *Feeder

func (*Feeder) Close

func (f *Feeder) Close()

func (*Feeder) Run

func (f *Feeder) Run()

Run instantiates a new Feeder instance.