pipe

Documentation

Index

• Constants
• func Build(source sourceStage, stages ...InnerStage) <-chan error
• type ConsumerStage
  • func FileStore(root string) ConsumerStage
• type InnerStage
  • func BetStop() InnerStage
  • func BufferedConsumer(consumer ConsumerStage, buffer int) InnerStage
  • func Competitor(api competitorAPI, languages []uof.Lang) InnerStage
  • func Consumer(consumer ConsumerStage) InnerStage
  • func Fixture(api fixtureAPI, languages []uof.Lang, preloadTo time.Time) InnerStage
  • func InnerFileStore(root string) InnerStage
  • func Markets(api marketsAPI, languages []uof.Lang) InnerStage
  • func Player(api playerAPI, languages []uof.Lang) InnerStage
  • func Recovery(api recoveryAPI, producers uof.ProducersChange) InnerStage
  • func Simple(each func(m *uof.Message) error) InnerStage
  • func Stage(looper stageFunc) InnerStage
  • func StageWithSubProcesses(looper stageWithDrainFunc) InnerStage
  • func StageWithSubProcessesSync(looper stageWithDrainFunc) InnerStage

Constants

const ConcurentAPICallsLimit = 16

Number of concurent api calls of one type. For example: no more than x running Player api calls in any point in time.

Functions

func Build

func Build(source sourceStage, stages ...InnerStage) <-chan error

Types

type ConsumerStage

type ConsumerStage func(in <-chan *uof.Message) error

func FileStore

func FileStore(root string) ConsumerStage

type InnerStage

type InnerStage func(<-chan *uof.Message) (<-chan *uof.Message, <-chan error)

func BetStop

func BetStop() InnerStage

BetStop enriches bet stop messages with the list of the marketIDs which should be stopped. In initial message we got list of market groups. In other event messages we have only market ids. To allow client not to need to know the list of all markets to make connection between groups and ids we are here adding to the bet stop message those ids.

func BufferedConsumer

func BufferedConsumer(consumer ConsumerStage, buffer int) InnerStage

func Competitor

func Competitor(api competitorAPI, languages []uof.Lang) InnerStage

func Consumer

func Consumer(consumer ConsumerStage) InnerStage

func Fixture

func Fixture(api fixtureAPI, languages []uof.Lang, preloadTo time.Time) InnerStage

func InnerFileStore

func InnerFileStore(root string) InnerStage

func Markets

func Markets(api marketsAPI, languages []uof.Lang) InnerStage

getting all markets on the start

func Player

func Player(api playerAPI, languages []uof.Lang) InnerStage

func Recovery

func Recovery(api recoveryAPI, producers uof.ProducersChange) InnerStage

func Simple

func Simple(each func(m *uof.Message) error) InnerStage

func Stage

func Stage(looper stageFunc) InnerStage

func StageWithSubProcesses

func StageWithSubProcesses(looper stageWithDrainFunc) InnerStage

func StageWithSubProcessesSync

func StageWithSubProcessesSync(looper stageWithDrainFunc) InnerStage