internal

Documentation

Index

• func Logger(l *zap.Logger) func(next http.Handler) http.Handler
• type DataFeedAPI
  • func NewDataFeedAPI(interrupt <-chan struct{}, logger *zap.Logger, storage *state.Storage, ...) *DataFeedAPI
  • func (a *DataFeedAPI) Done() <-chan struct{}
• type Importer
  • func NewImporter(interrupt <-chan struct{}, scheme byte, storage *state.Storage, ...) *Importer
  • func (im *Importer) Import(n string) error
• type Synchronizer
  • func NewSynchronizer(interrupt <-chan struct{}, storage *state.Storage, scheme byte, ...) (*Synchronizer, error)
  • func (s *Synchronizer) Done() <-chan struct{}

Functions

func Logger

func Logger(l *zap.Logger) func(next http.Handler) http.Handler

Logger is a middleware that logs the start and end of each request, along with some useful data about what was requested, what the response status was, and how long it took to return.

Types

type DataFeedAPI

type DataFeedAPI struct {
	Storage *state.Storage
	Symbols *data.Symbols
	// contains filtered or unexported fields
}

func NewDataFeedAPI

func NewDataFeedAPI(interrupt <-chan struct{}, logger *zap.Logger, storage *state.Storage, address string, symbols *data.Symbols) *DataFeedAPI

func (*DataFeedAPI) Done

func (a *DataFeedAPI) Done() <-chan struct{}

type Importer

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

func NewImporter

func NewImporter(interrupt <-chan struct{}, scheme byte, storage *state.Storage, matchers []crypto.PublicKey) *Importer

func (*Importer) Import

func (im *Importer) Import(n string) error

type Synchronizer

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

func NewSynchronizer

func NewSynchronizer(interrupt <-chan struct{}, storage *state.Storage, scheme byte, matchers []crypto.PublicKey, node string, interval time.Duration, lag int, symbols *data.Symbols) (*Synchronizer, error)

func (*Synchronizer) Done

func (s *Synchronizer) Done() <-chan struct{}