subscribers

package
v0.0.0-...-fe50809 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 1, 2023 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	OperationTypeSubscribe   operationType = "subscribe"
	OperationTypeUnsubscribe operationType = "unsubscribe"
)
View Source
const (
	ResponseTypeError        responseType = "error"
	ResponseTypeSubscribed   responseType = "subscribed"
	ResponseTypeUnsubscribed responseType = "unsubscribed"
	ResponseTypeInfo         responseType = "info"
	ResponseTypePartial      responseType = "partial"
	ResponseTypeUpdate       responseType = "update"
)

Variables

This section is empty.

Functions

func NewSyntheticOrderSubscriber

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

Types

type GeminiOrderBookSubscriber

type GeminiOrderBookSubscriber interface {
	Close()
}

func NewGeminiOrderBookSubscriber

func NewGeminiOrderBookSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	apiClient client.ApiClient,
	venueConfig configuration.GeminiConfig,
	orderBookPublisher publishers.OrderBookPublisher) (GeminiOrderBookSubscriber, error)

type GeminiTradingPairSubscriber

type GeminiTradingPairSubscriber interface {
}

func NewGeminiTradingPairSubscriber

func NewGeminiTradingPairSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	venueConfig configuration.GeminiConfig,
	jobScheduler *gocron.Scheduler,
	tradingPairRepository repositories.TradingPairRepository) (GeminiTradingPairSubscriber, error)

Directories

Path Synopsis
Package mock_subscribers is a generated GoMock package.
Package mock_subscribers is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL