subscribers

Documentation

Index

• Constants
• func NewSyntheticOrderSubscriber(logger *zap.SugaredLogger) (syntheticorderv1.Subscriber, error)
• type FtxOrderBookSubscriber
  • func NewFtxOrderBookSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (FtxOrderBookSubscriber, error)
• type FtxTradingPairSubscriber
  • func NewFtxTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (FtxTradingPairSubscriber, error)

Constants

const (
	OperationTypeSubscribe   operationType = "subscribe"
	OperationTypeUnsubscribe operationType = "unsubscribe"
)

const (
	ResponseTypeError        responseType = "error"
	ResponseTypeSubscribed   responseType = "subscribed"
	ResponseTypeUnsubscribed responseType = "unsubscribed"
	ResponseTypeInfo         responseType = "info"
	ResponseTypePartial      responseType = "partial"
	ResponseTypeUpdate       responseType = "update"
)

Functions

func NewSyntheticOrderSubscriber

func NewSyntheticOrderSubscriber(logger *zap.SugaredLogger) (syntheticorderv1.Subscriber, error)

Types

type FtxOrderBookSubscriber

type FtxOrderBookSubscriber interface {
	Close()
}

func NewFtxOrderBookSubscriber

func NewFtxOrderBookSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	venueConfig configuration.FtxConfig,
	orderBookPublisher publishers.OrderBookPublisher) (FtxOrderBookSubscriber, error)

type FtxTradingPairSubscriber

type FtxTradingPairSubscriber interface {
}

func NewFtxTradingPairSubscriber

func NewFtxTradingPairSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	venueConfig configuration.FtxConfig,
	jobScheduler *gocron.Scheduler,
	tradingPairRepository repositories.TradingPairRepository) (FtxTradingPairSubscriber, error)