syncer

Documentation

Index

• Variables
• type Block
• type BlockSyncer
  • func NewBlockSyncer(ctx context.Context, logger logging.Logger, blockSyncerGraphUrl string, ...) *BlockSyncer
  • func (s *BlockSyncer) Init()
  • func (s *BlockSyncer) Run() error
• type MarginAccount
• 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) 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(startTime 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 BlockSyncer

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

func NewBlockSyncer

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

func (*BlockSyncer) Init

func (s *BlockSyncer) Init()

func (*BlockSyncer) Run

func (s *BlockSyncer) Run() error

type MarginAccount

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

type Syncer

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

func NewSyncer

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

func (*Syncer) GetMarkPriceBasedOnBlockNumber

func (s *Syncer) GetMarkPriceBasedOnBlockNumber(blockNumber int64, poolAddr string, perpetualIndex int) (*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(startTime int64) (int64, error)

type User

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