syncer

Documentation

Index

• Variables
• type Block
• type MarginAccount
• type MarkPrice
• type Syncer
  • func NewSyncer(ctx context.Context, logger logging.Logger, mai3GraphUrl string, ...) *Syncer
  • func (s *Syncer) GetMarkPriceBasedOnBlockNumber(blockNumber int64, poolAddr string, perpetualIndex int) (*decimal.Decimal, error)
  • func (s *Syncer) GetMarkPrices(bn int64) (map[string]*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) Init()
  • func (s *Syncer) Run() error
  • func (s *Syncer) TimestampToBlockNumber(timestamp int64) (int64, error)
• type User

Variables

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

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

var Transport = &http.Transport{
	DialContext: (&net.Dialer{
		Timeout: 500 * time.Millisecond,
	}).DialContext,
	TLSHandshakeTimeout: 1000 * time.Millisecond,
	MaxIdleConns:        100,
	IdleConnTimeout:     30 * time.Second,
}

Types

type Block

type Block struct {
	ID        string `json:"id"`
	Number    string `json:"number"`
	Timestamp string `json:"timestamp"`
}

type MarginAccount

type MarginAccount struct {
	ID       string          `json:"id"`
	Position decimal.Decimal `json:"position"`
}

type MarkPrice

type MarkPrice struct {
	ID    string           `json:"id"`
	Price *decimal.Decimal `json:"price"`
}

type Syncer

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

func NewSyncer

func NewSyncer(
	ctx context.Context, logger logging.Logger, mai3GraphUrl string, blockGraphUrl string,
) *Syncer

func (*Syncer) GetMarkPriceBasedOnBlockNumber

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

func (*Syncer) GetMarkPrices

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

func (*Syncer) GetPoolAddrIndexUserID

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

func (*Syncer) GetUsersBasedOnBlockNumber

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

func (*Syncer) Init

func (s *Syncer) Init()

func (*Syncer) Run

func (s *Syncer) Run() error

func (*Syncer) TimestampToBlockNumber

func (s *Syncer) TimestampToBlockNumber(timestamp int64) (int64, error)

TimestampToBlockNumber which is the closest but less than or equal to timestamp

type User

type User struct {
	ID             string          `json:"id"`
	StakedMCB      decimal.Decimal `json:"stakedMCB"`
	TotalFee       decimal.Decimal `json:"totalFee"`
	UnlockMCBTime  int64           `json:"unlockMCBTime"`
	MarginAccounts []*MarginAccount
}