downloaders

Documentation

Index

• Constants
• type Downloader
  • func NewSnapshotDownloader(pairs []common.Pair, snapshotInterval time.Duration, ...) Downloader
  • func NewSnapshotDownloaderTicks(pairs []common.Pair, snapshotInterval int, outChan chan common.Snapshot, ...) Downloader
• type SnapshotDownloader
  • func (s *SnapshotDownloader) Close() error
  • func (s *SnapshotDownloader) Init(enabledExchanges ...string) error
  • func (s *SnapshotDownloader) Run(ctx context.Context) error
  • func (s *SnapshotDownloader) Stop()
• type SnapshotDownloaderConfig

Constants

const (
	DefaultSnapshotInterval = time.Second * 30
)

Types

type Downloader

type Downloader interface {
	Init(enabledExchanges ...string) error
	Run(ctx context.Context) error
	Stop()
	Close() error
}

func NewSnapshotDownloader

func NewSnapshotDownloader(pairs []common.Pair, snapshotInterval time.Duration, outChan chan common.Snapshot, maxSnapshotSize int) Downloader

func NewSnapshotDownloaderTicks

func NewSnapshotDownloaderTicks(pairs []common.Pair, snapshotInterval int, outChan chan common.Snapshot, maxSnapshotSize int) Downloader

type SnapshotDownloader

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

func (*SnapshotDownloader) Close

func (s *SnapshotDownloader) Close() error

func (*SnapshotDownloader) Init

func (s *SnapshotDownloader) Init(enabledExchanges ...string) error

func (*SnapshotDownloader) Run

func (s *SnapshotDownloader) Run(ctx context.Context) error

func (*SnapshotDownloader) Stop

func (s *SnapshotDownloader) Stop()

type SnapshotDownloaderConfig

type SnapshotDownloaderConfig struct {
	ExitOnClose bool
}