Versions in this module Expand all Collapse all v1 v1.0.0 Jun 16, 2026 Changes in this version + var ErrUnknownVenue = errors.New("unknown venue") + func Register(v model.Venue, ctor Constructor) + type AccountCapabilities struct + Snapshot bool + type Adapter interface + Capabilities func() DeclaredCapabilities + Close func(context.Context) error + Data func() DataClient + Execution func() ExecutionClient + Instruments func() InstrumentProvider + Venue func() model.Venue + func Open(ctx context.Context, v model.Venue, cfg map[string]string) (Adapter, error) + type Constructor func(context.Context, map[string]string) (Adapter, error) + type DataClient interface + ClientID func() string + Connect func(context.Context) error + Disconnect func(context.Context) error + FetchOrderBook func(context.Context, model.InstrumentID, int) (model.OrderBook, error) + FetchTicker func(context.Context, model.InstrumentID) (model.Ticker, error) + Health func() DataHealth + Instruments func() InstrumentProvider + Venue func() model.Venue + type DataHealth struct + Connected bool + InstrumentReady bool + LastError error + LastEventTime time.Time + type DeclaredCapabilities struct + Account AccountCapabilities + Execution ExecutionCapabilities + Instruments bool + MarketData MarketDataCapabilities + Venue model.Venue + type ExecutionCapabilities struct + Cancel bool + FillReports bool + MassStatus bool + Modify bool + OrderLists bool + OrderReports bool + PositionReports bool + PrivateStream bool + Query bool + Resubscribe bool + Submit bool + type ExecutionClient interface + AccountID func() model.AccountID + CancelOrder func(context.Context, model.CancelOrder) (model.OrderStatusReport, error) + Connect func(context.Context) error + Disconnect func(context.Context) error + Events func() <-chan model.ExecutionEvent + GenerateOrderStatusReports func(context.Context, model.InstrumentID) ([]model.OrderStatusReport, error) + Health func() ExecutionHealth + QueryAccount func(context.Context) (model.AccountSnapshot, error) + SubmitOrder func(context.Context, model.SubmitOrder) (model.OrderStatusReport, error) + Venue func() model.Venue + type ExecutionHealth struct + AccountReady bool + Connected bool + LastError error + LastEventTime time.Time + type ExecutionMassStatusGenerator interface + GenerateExecutionMassStatus func(context.Context, model.GenerateExecutionMassStatus) (model.ExecutionMassStatus, error) + type ExecutionResubscriber interface + ResubscribeExecution func(context.Context) error + type FillReportGenerator interface + GenerateFillReports func(context.Context, model.InstrumentID) ([]model.FillReport, error) + type FundingRateProvider interface + FetchFundingRate func(context.Context, model.InstrumentID) (model.FundingRate, error) + type InstrumentProvider interface + Get func(model.InstrumentID) (model.Instrument, bool) + List func() []model.Instrument + LoadAll func(context.Context) error + type MarketDataCapabilities struct + Bars bool + FundingRateStream bool + FundingRates bool + OrderBook bool + OrderBookStream bool + QuoteTicks bool + Snapshots bool + Streams bool + Ticker bool + TickerStream bool + TradeTicks bool + type OrderListSubmitter interface + SubmitOrderList func(context.Context, model.SubmitOrderList) ([]model.OrderStatusReport, error) + type OrderModifier interface + ModifyOrder func(context.Context, model.ModifyOrder) (model.OrderStatusReport, error) + type OrderQuerier interface + QueryOrder func(context.Context, model.QueryOrder) (model.OrderStatusReport, error) + type PositionStatusReportGenerator interface + GeneratePositionStatusReports func(context.Context, model.InstrumentID) ([]model.PositionStatusReport, error) + type Registry struct + func NewRegistry() *Registry + func (r *Registry) Open(ctx context.Context, venue model.Venue, cfg map[string]string) (Adapter, error) + func (r *Registry) Register(venue model.Venue, ctor Constructor) + type StreamingDataClient interface + Events func() <-chan model.MarketEvent + SubscribeMarketData func(context.Context, model.SubscribeMarketData) error + UnsubscribeMarketData func(context.Context, model.SubscribeMarketData) error
Go to main page