matching

type Base struct {
	Type      LogType
	Sequence  int64
	ProductId int64
	Time      time.Time
}

type Bitmap []byte

type BookOrder struct {
	OrderId int64
	Size    decimal.Decimal
	Funds   decimal.Decimal
	Price   decimal.Decimal
	Side    entities.Side
	Type    entities.OrderType
}

type DoneLog struct {
	Base
	OrderId       int64
	Price         decimal.Decimal
	RemainingSize decimal.Decimal
	Reason        entities.DoneReason
	Side          entities.Side
}

type Engine struct {
	OrderBook *OrderBook

	OrderReader OrderReader

	OrderOffset int64

	OrderCh chan *OffsetOrder

	LogStore LogStore

	LogCh chan Log

	SnapshotReqCh chan *Snapshot

	SnapshotApproveReqCh chan *Snapshot

	SnapshotCh chan *Snapshot

	SnapShotStore SnapshotStore
	// contains filtered or unexported fields
}

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

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

type KafkaOrderReader struct {
	OrderReader *kafka.Reader
}

type Log interface {
	GetSeq() int64
}

type LogObserver interface {
	OnOpenLOg(log *OpenLog, offset int64)

	OnMatchLog(log *MatchLog, offset int64)

	OnDoneLog(log *DoneLog, offset int64)
}

type LogReader interface {
	GetProductId() string
	RegisterObserver(observer LogObserver)

	Run(seq, offset int64)
}

type LogStore interface {
	Store(logs []interface{}) error
}

type LogType string

type MatchLog struct {
	Base
	TradeId      int64
	TakerOrderId int64
	MakerOrderId int64
	Side         entities.Side
	Price        decimal.Decimal
	Size         decimal.Decimal
}

type OffsetOrder struct {
	Offset int64
	Order  *entities.Order
}

type OpenLog struct {
	Base
	OrderId       int64
	RemainingSize decimal.Decimal
	Price         decimal.Decimal
	Side          entities.Side
}

type OrderBook struct {

	// stricly continiously increasing log SEQ, used to write matching log
	LogSeq int64
	// contains filtered or unexported fields
}

type OrderReader interface {
	SetOffset(offset int64) error

	FetchOrder() (offset int64, order *entities.Order, err error)
}

type ReceivedLog struct {
	Base
	OrderId   int64
	Size      decimal.Decimal
	Price     decimal.Decimal
	Side      entities.Side
	OrderType entities.OrderType
}

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

type Snapshot struct {
	OrderBookSnapshot orderBooSnapShot
	OrderOffset       int64
}

type SnapshotStore interface {
	Store(snapshot *Snapshot) error

	GetLatest() (*Snapshot, error)
}

type Window struct {
	Min    int64
	Max    int64
	Cap    int64
	Bitmap Bitmap
}