service

Documentation

Index

• type DeliveryManager
  • func NewDeliveryService(serviceConfig *config.ServiceConfig, ...) DeliveryManager
• type DeliveryService
  • func (s *DeliveryService) GetDataChannel(symbol string) (<-chan *domain.Depth, error)
  • func (s *DeliveryService) GetSymbols() []string
  • func (s *DeliveryService) RunProviders(wg *sync.WaitGroup) (context.Context, context.CancelFunc)

Types

type DeliveryManager

type DeliveryManager interface {
	// GetSymbols returns the set of available symbols.
	GetSymbols() []string
	// GetDataChannel returns the channel into which data about the specified character is written.
	GetDataChannel(symbol string) (<-chan *domain.Depth, error)
	// RunProviders launches providers.
	RunProviders(wg *sync.WaitGroup) (context.Context, context.CancelFunc)
}

DeliveryManager defines an interface for working with providers who collect order books.

func NewDeliveryService

func NewDeliveryService(serviceConfig *config.ServiceConfig, deliveryProvider delivery.DepthDeliveryProvider) DeliveryManager

type DeliveryService

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

DeliveryService implement DeliveryManager

func (*DeliveryService) GetDataChannel

func (s *DeliveryService) GetDataChannel(symbol string) (<-chan *domain.Depth, error)

GetDataChannel returns the channel into which data about the specified character is written.

func (*DeliveryService) GetSymbols

func (s *DeliveryService) GetSymbols() []string

GetSymbols returns the set of available symbols.

func (*DeliveryService) RunProviders

func (s *DeliveryService) RunProviders(wg *sync.WaitGroup) (context.Context, context.CancelFunc)

RunProviders launches providers.