feeder

Documentation

Index

• type Service
  • func NewService(feederSvc ports.PriceFeeder, repoManager ports.RepoManager) (*Service, error)
  • func (s *Service) AddPriceFeed(ctx context.Context, market ports.Market, source, ticker string) (string, error)
  • func (s *Service) Close()
  • func (s *Service) GetPriceFeed(ctx context.Context, id string) (ports.PriceFeedInfo, error)
  • func (s *Service) ListPriceFeeds(ctx context.Context) ([]ports.PriceFeedInfo, error)
  • func (s *Service) ListSources(ctx context.Context) []string
  • func (s *Service) RemovePriceFeed(ctx context.Context, id string) error
  • func (s *Service) StartPriceFeed(ctx context.Context, id string) error
  • func (s *Service) StopPriceFeed(ctx context.Context, id string) error
  • func (s *Service) UpdatePriceFeed(ctx context.Context, id, source, ticker string) error

Types

type Service

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

func NewService

func NewService(
	feederSvc ports.PriceFeeder, repoManager ports.RepoManager,
) (*Service, error)

func (*Service) AddPriceFeed

func (s *Service) AddPriceFeed(
	ctx context.Context, market ports.Market, source, ticker string,
) (string, error)

func (*Service) Close

func (s *Service) Close()

func (*Service) GetPriceFeed

func (s *Service) GetPriceFeed(
	ctx context.Context, id string,
) (ports.PriceFeedInfo, error)

func (*Service) ListPriceFeeds

func (s *Service) ListPriceFeeds(
	ctx context.Context,
) ([]ports.PriceFeedInfo, error)

func (*Service) ListSources

func (s *Service) ListSources(ctx context.Context) []string

func (*Service) RemovePriceFeed

func (s *Service) RemovePriceFeed(ctx context.Context, id string) error

func (*Service) StartPriceFeed

func (s *Service) StartPriceFeed(ctx context.Context, id string) error

func (*Service) StopPriceFeed

func (s *Service) StopPriceFeed(ctx context.Context, id string) error

func (*Service) UpdatePriceFeed

func (s *Service) UpdatePriceFeed(
	ctx context.Context, id, source, ticker string,
) error