syncer

Nov 24, 2021

Changes in this version

+ func GetFeeValue(accounts []*mai3.MarginAccount) (totalFee, daoFee, totalFeeFactor, daoFeeFactor decimal.Decimal)

+ func GetOIValue(accounts []*mai3.MarginAccount, blockNumbers int64, ...) (oi decimal.Decimal, err error)

type Syncer

+ func (s *Syncer) GetMultiChainInfo(timestamp int64) (multiBNs []int64, multiUsers [][]mai3.User, ...)

Nov 16, 2021

Changes in this version

type MockBlockGraph1

+ func (mockBlock *MockBlockGraph1) GetLatestBlockNumberAndTS() (int64, int64, error)

Nov 11, 2021

Changes in this version

type MockBlockGraph1

+ func (mockBlock *MockBlockGraph1) GetTimestampWithBN(blockNumber int64) (int64, error)

Nov 10, 2021

Changes in this version

type MockBlockGraph1

+ func (mockBlock *MockBlockGraph1) GetLatestBlockNumber() (int64, error)

Oct 28, 2021

Changes in this version

+ func GetOIFeeValue(accounts []*mai3.MarginAccount, blockNumbers int64, ...) (oi, totalFee, daoFee decimal.Decimal, err error)

type MockMAI3Graph1

+ func (mockMAI3 *MockMAI3Graph1) InSATSInverseContractWhiteList(perpID string) (bool, string)

type MockMAI3Graph2

+ func (mockMAI3 *MockMAI3Graph2) InSATSInverseContractWhiteList(perpID string) (bool, string)

Oct 27, 2021

Changes in this version

+ func GetRemainMinutes(timestamp int64, epoch *mining.Schedule) decimal.Decimal

Oct 25, 2021

Changes in this version

+ var TEST_ERROR = errors.New("test error")

+ type MockBlockGraph1 struct

+ func NewMockBlockGraph1() *MockBlockGraph1

+ func (mockBlock *MockBlockGraph1) GetBlockNumberWithTS(timestamp int64) (int64, error)

+ type MockMAI3Graph1 struct

+ func NewMockMAI3Graph1() *MockMAI3Graph1

+ func (mockMAI3 *MockMAI3Graph1) GetMarkPriceWithBlockNumberAddrIndex(blockNumber int64, poolAddr string, perpIndex int) (decimal.Decimal, error)

+ func (mockMAI3 *MockMAI3Graph1) GetMarkPrices(blockNumber int64) (map[string]decimal.Decimal, error)

+ func (mockMAI3 *MockMAI3Graph1) GetPerpIDWithUSDBased(symbol string) (string, error)

+ func (mockMAI3 *MockMAI3Graph1) GetUsersBasedOnBlockNumber(blockNumber int64) ([]mai3.User, error)

+ func (mockMAI3 *MockMAI3Graph1) InBTCInverseContractWhiteList(perpID string) (bool, string)

+ func (mockMAI3 *MockMAI3Graph1) InETHInverseContractWhiteList(perpID string) (bool, string)

+ type MockMAI3Graph2 struct

+ func NewMockMAI3Graph2() *MockMAI3Graph2

+ func (mockMAI3 *MockMAI3Graph2) GetMarkPriceWithBlockNumberAddrIndex(blockNumber int64, poolAddr string, perpIndex int) (decimal.Decimal, error)

+ func (mockMAI3 *MockMAI3Graph2) GetMarkPrices(blockNumber int64) (map[string]decimal.Decimal, error)

+ func (mockMAI3 *MockMAI3Graph2) GetPerpIDWithUSDBased(symbol string) (string, error)

+ func (mockMAI3 *MockMAI3Graph2) GetUsersBasedOnBlockNumber(blockNumber int64) ([]mai3.User, error)

+ func (mockMAI3 *MockMAI3Graph2) InBTCInverseContractWhiteList(perpID string) (bool, string)

+ func (mockMAI3 *MockMAI3Graph2) InETHInverseContractWhiteList(perpID string) (bool, string)

+ type MockMultiBlockGraphs struct

+ func NewMockMultiBlockGraphsMultiChain() *MockMultiBlockGraphs

+ func NewMockMultiBlockGraphsOneChain() *MockMultiBlockGraphs

+ func (mockMultiBlocks *MockMultiBlockGraphs) GetMultiBlockNumberWithTS(timestamp int64) ([]int64, error)

+ type MockMultiMAI3Graphs struct

+ func NewMockMultiMAI3GraphsMultiChain() *MockMultiMAI3Graphs

+ func NewMockMultiMAI3GraphsOneChain() *MockMultiMAI3Graphs

+ func (mockMultiMAI3Graphs *MockMultiMAI3Graphs) GetMai3GraphInterface(index int) (mai3.GraphInterface, error)

+ func (mockMultiMAI3Graphs *MockMultiMAI3Graphs) GetMultiMarkPrices(blockNumbers []int64) (map[string]decimal.Decimal, error)

+ func (mockMultiMAI3Graphs *MockMultiMAI3Graphs) GetMultiUsersBasedOnMultiBlockNumbers(blockNumbers []int64) ([][]mai3.User, error)

Oct 2, 2021

Changes in this version

+ var ErrNotInEpoch = errors.New("not in epoch period")

type Syncer

+ func (s *Syncer) SetDefaultEpoch() int64

Sep 30, 2021

Changes in this version

+ var PROGRESS_SNAPSHOT = "user_info.snapshot"

Sep 30, 2021

Changes in this version

+ var INVERSE_CONTRACT_WHITELIST = map[string]bool

Sep 28, 2021

Changes in this version

+ var PROGRESS_INIT_FEE = "user_info.init_fee"

+ var PROGRESS_SYNC_STATE = "user_info"

Sep 28, 2021

Changes in this version

+ type MarkPrice struct

+ ID string

+ Price *decimal.Decimal

Sep 28, 2021

Changes in this version

type Syncer

+ func (s *Syncer) GetMarkPrices(bn int64) (map[string]*decimal.Decimal, error)

type User

+ UnlockMCBTime int64

Sep 26, 2021

Changes in this version

type Syncer

+ func (s *Syncer) GetFee(id string, blockNumber int64) decimal.Decimal

Sep 26, 2021

Changes in this version

type Syncer

+ func (s *Syncer) GetEpoch() error

Sep 26, 2021

Changes in this version

+ var EMPTY_SCHEDULE = errors.New("empty schedule")

+ var NOT_IN_EPOCH = errors.New("not in epoch period")

Sep 26, 2021

Changes in this version

+ var EPOCH_ERROR = errors.New("failed to get epoch from schedule db")

+ var Transport = &http.Transport

+ type Block struct

+ ID string

+ Number string

+ Timestamp string

+ type BlockSyncer struct

+ func NewBlockSyncer(ctx context.Context, logger logging.Logger, blockSyncerGraphUrl string, ...) *BlockSyncer

+ func (s *BlockSyncer) Init()

+ func (s *BlockSyncer) Run() error

+ type MarginAccount struct

+ ID string

+ Position decimal.Decimal

type Syncer

+ func (s *Syncer) GetMarkPriceBasedOnBlockNumber(blockNumber int64, poolAddr string, perpetualIndex int) (*decimal.Decimal, error)

+ func (s *Syncer) GetPoolAddrIndexUserID(marginAccountID string) (poolAddr, userId string, perpetualIndex int, err error)

+ func (s *Syncer) GetUsersBasedOnBlockNumber(blockNumber int64) ([]User, error)

+ func (s *Syncer) TimestampToBlockNumber(startTime int64) (int64, error)

+ func (s Syncer) Init()

+ type User struct

+ ID string

+ MarginAccounts []*MarginAccount

+ StakedMCB decimal.Decimal

+ TotalFee decimal.Decimal

Sep 24, 2021

Changes in this version

+ type Aligner struct

+ func NewAligner(ctx context.Context, logger logging.Logger, feeUrl string, oiUrl string, ...) *Aligner

+ type Syncer struct

+ func NewSyncer(ctx context.Context, logger logging.Logger, feeUrl string, oiUrl string, ...) (*Syncer, error)

+ func (f *Syncer) Run() error