data

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

type Catalog interface {
	Write(context.Context, ...model.MarketEvent) error
	Query(context.Context, model.DataRequest) (model.DataResponse, error)
}

type ClientHealth struct {
	Venue    model.Venue
	ClientID string
	Health   venue.DataHealth
	Stale    bool
}

type Config struct {
	Bus             *bus.Bus
	Cache           *cache.Cache
	Catalog         Catalog
	ReconnectPolicy RetryPolicy
	StaleAfter      time.Duration
}

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

type Health struct {
	Running        bool
	Clients        int
	Subscriptions  int
	Events         int64
	Requests       int64
	AggregatedBars int64
	StaleClients   int
	LastEventTime  time.Time
	LastError      error
	ClientsHealth  []ClientHealth
}

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

type ReplayCatalog interface {
	Catalog
	Events(context.Context) ([]model.MarketEvent, error)
}

type RetryPolicy struct {
	MaxAttempts int
	Backoff     time.Duration
}