worker

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartMatchingLogMaker

func StartMatchingLogMaker()

Types

type BillExecutor

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

func NewBillExecutor

func NewBillExecutor() *BillExecutor

func (*BillExecutor) Start

func (s *BillExecutor) Start()

type FillExecutor

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

func NewFillExecutor

func NewFillExecutor() *FillExecutor

func (*FillExecutor) Start

func (s *FillExecutor) Start()

type FillMaker

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

func NewFillMaker

func NewFillMaker(logReader matching.LogReader) *FillMaker

func (*FillMaker) OnDoneLog

func (t *FillMaker) OnDoneLog(log *matching.DoneLog, offset int64)

func (*FillMaker) OnMatchLog

func (t *FillMaker) OnMatchLog(log *matching.MatchLog, offset int64)

func (*FillMaker) OnOpenLog

func (t *FillMaker) OnOpenLog(log *matching.OpenLog, offset int64)

func (*FillMaker) Start

func (t *FillMaker) Start()

type TickMaker

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

func NewTickMaker

func NewTickMaker(productId string, logReader matching.LogReader) *TickMaker

func (*TickMaker) OnDoneLog

func (t *TickMaker) OnDoneLog(log *matching.DoneLog, offset int64)

func (*TickMaker) OnMatchLog

func (t *TickMaker) OnMatchLog(log *matching.MatchLog, offset int64)

func (*TickMaker) OnOpenLog

func (t *TickMaker) OnOpenLog(log *matching.OpenLog, offset int64)

func (*TickMaker) Start

func (t *TickMaker) Start()

type TradeMaker

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

func NewTradeMaker

func NewTradeMaker(logReader matching.LogReader) *TradeMaker

func (*TradeMaker) OnDoneLog

func (t *TradeMaker) OnDoneLog(log *matching.DoneLog, offset int64)

func (*TradeMaker) OnMatchLog

func (t *TradeMaker) OnMatchLog(log *matching.MatchLog, offset int64)

func (*TradeMaker) OnOpenLog

func (t *TradeMaker) OnOpenLog(log *matching.OpenLog, offset int64)

func (*TradeMaker) Start

func (t *TradeMaker) Start()

Jump to

Keyboard shortcuts

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