comet

Documentation

Index

• Variables
• type BlockSignersData
• type CometClient
  • func NewCometClient(config *config.CometBFTConfig) *CometClient
  • func (c *CometClient) EarliestBlockHeight(ctx context.Context) (int64, error)
  • func (c *CometClient) GetBlockSigners(block int64) (*BlockSignersData, error)
  • func (c *CometClient) GetBlockSignersRange(fromBlock int64, toBlock int64) ([]BlockSignersData, error)
  • func (c *CometClient) GetLastBlockTxs() ([]CometTx, error)
  • func (c *CometClient) GetLatestBlockSigners() (*BlockSignersData, error)
  • func (c *CometClient) GetTxsForBlock(block int64) ([]CometTx, error)
  • func (c *CometClient) GetTxsForBlockNotFiltered(block int64) ([]CometTx, error)
  • func (c *CometClient) GetTxsForBlockRange(fromBlock int64, toBlock int64) ([]CometTx, error)
  • func (c *CometClient) GetTxsForBlockRangeNotFiltered(fromBlock int64, toBlock int64) ([]CometTx, error)
  • func (c *CometClient) GetValidatorForAddressAtBlock(address string, block int64) (*ValidatorData, error)
  • func (c *CometClient) GetValidators() ([]CometValidators, error)
  • func (c *CometClient) GetValidatorsForBlock(block int64) ([]CometValidators, error)
  • func (c *CometClient) LatestLocalBlockHeight(ctx context.Context) (int64, error)
  • func (c *CometClient) Status(ctx context.Context) (*StatusResponse, error)
• type CometTx
  • func RemoveExcludedTxTypes(txs []CometTx) []CometTx
• type CometValidators
• type StatusResponse
• type StatusSyncInfo
• type ValidatorData

Variables

var (
	ErrMissingSubmitter = errors.New("missing submitter in the comet block")
	ErrMissingCommand   = errors.New("missing command in the comet block")
)

var (
	EXCLUDE_COMMAND_TYPES = []string{
		"Submit Order",
		"Cancel Order",
		"Amend Order",
		"Withdraw",
		"Proposal",
		"Vote on Proposal",

		"Node Signature",
		"Liquidity Provision Order",
		"Cancel LiquidityProvision Order",
		"Amend LiquidityProvision Order",

		"Submit Oracle Data",
		"Delegate",
		"Undelegate",
		"Key Rotate Submission",

		"Transfer Funds",
		"Cancel Transfer Funds",

		"Ethereum Key Rotate Submission",
		"Protocol Upgrade",
	}
)

Types

type BlockSignersData

type BlockSignersData struct {
	Height          int64
	Time            time.Time
	ProposerAddress string
	SignerAddresses []string
}

type CometClient

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

func NewCometClient

func NewCometClient(config *config.CometBFTConfig) *CometClient

func (*CometClient) EarliestBlockHeight

func (c *CometClient) EarliestBlockHeight(ctx context.Context) (int64, error)

func (*CometClient) GetBlockSigners

func (c *CometClient) GetBlockSigners(block int64) (*BlockSignersData, error)

func (*CometClient) GetBlockSignersRange

func (c *CometClient) GetBlockSignersRange(fromBlock int64, toBlock int64) ([]BlockSignersData, error)

func (*CometClient) GetLastBlockTxs

func (c *CometClient) GetLastBlockTxs() ([]CometTx, error)

func (*CometClient) GetLatestBlockSigners

func (c *CometClient) GetLatestBlockSigners() (*BlockSignersData, error)

func (*CometClient) GetTxsForBlock

func (c *CometClient) GetTxsForBlock(block int64) ([]CometTx, error)

func (*CometClient) GetTxsForBlockNotFiltered

func (c *CometClient) GetTxsForBlockNotFiltered(block int64) ([]CometTx, error)

func (*CometClient) GetTxsForBlockRange

func (c *CometClient) GetTxsForBlockRange(fromBlock int64, toBlock int64) ([]CometTx, error)

func (*CometClient) GetTxsForBlockRangeNotFiltered

func (c *CometClient) GetTxsForBlockRangeNotFiltered(fromBlock int64, toBlock int64) ([]CometTx, error)

func (*CometClient) GetValidatorForAddressAtBlock

func (c *CometClient) GetValidatorForAddressAtBlock(address string, block int64) (*ValidatorData, error)

func (*CometClient) GetValidators

func (c *CometClient) GetValidators() ([]CometValidators, error)

func (*CometClient) GetValidatorsForBlock

func (c *CometClient) GetValidatorsForBlock(block int64) ([]CometValidators, error)

func (*CometClient) LatestLocalBlockHeight

func (c *CometClient) LatestLocalBlockHeight(ctx context.Context) (int64, error)

func (*CometClient) Status

func (c *CometClient) Status(ctx context.Context) (*StatusResponse, error)

type CometTx

type CometTx struct {
	Code       int
	Info       *string
	Submitter  string
	Command    string
	Attributes map[string]string
	Height     int64
	HeightIdx  int
}

func RemoveExcludedTxTypes

func RemoveExcludedTxTypes(txs []CometTx) []CometTx

type CometValidators

type CometValidators struct {
	Address          string
	TmPubKey         vega_entities.TendermintPublicKey
	VotingPower      int64
	ProposerPriority int64
	Height           int64
}

type StatusResponse

type StatusResponse struct {
	SyncInfo StatusSyncInfo `json:"sync_info"`
}

type StatusSyncInfo

type StatusSyncInfo struct {
	LatestBlockHash   string    `json:"latest_block_hash"`
	LatestAppHash     string    `json:"latest_app_hash"`
	LatestBlockHeight int64     `json:"latest_block_height"`
	LatestBlockTime   time.Time `json:"latest_block_time"`

	EarliestBlockHash   string    `json:"earliest_block_hash"`
	EarliestAppHash     string    `json:"earliest_app_hash"`
	EarliestBlockHeight int64     `json:"earliest_block_height"`
	EarliestBlockTime   time.Time `json:"earliest_block_time"`
	CatchingUp          bool      `json:"catching_up"`
}

type ValidatorData

type ValidatorData struct {
	Address  string
	TmPubKey vega_entities.TendermintPublicKey
}