datanode

Documentation

Index

• Variables
• type AccountFunds
• type DataNode
  • func New(hosts []string, callTimeout time.Duration, logger *zap.Logger) *DataNode
  • func (n *DataNode) ERC20AssetWithAddress(ctx context.Context, address string) (*vega.AssetDetails, *vega.ERC20, error)
  • func (n *DataNode) GeneralAccountBalance(ctx context.Context, partyID, assetID string) (*big.Int, error)
  • func (n *DataNode) GetAllMarketsWithState(ctx context.Context, states []vega.Market_State) ([]*vega.Market, error)
  • func (n *DataNode) GetCurrentEpoch(ctx context.Context) (*vega.Epoch, error)
  • func (n *DataNode) GetCurrentReferralProgram(ctx context.Context) (*v2.ReferralProgram, error)
  • func (n *DataNode) GetCurrentVolumeDiscountProgram(ctx context.Context) (*dataapipb.VolumeDiscountProgram, error)
  • func (n *DataNode) GetGovernanceData(ctx context.Context, req *dataapipb.GetGovernanceDataRequest) (*dataapipb.GetGovernanceDataResponse, error)
  • func (n *DataNode) GetPartyTotalStake(ctx context.Context, partyId string) (*big.Int, error)
  • func (n *DataNode) LastNetworkHistorySegment(ctx context.Context) (*dataapipb.HistorySegment, error)
  • func (n *DataNode) ListAccounts(ctx context.Context, partyID string, accountType vega.AccountType, ...) ([]AccountFunds, error)
  • func (n *DataNode) ListAssets(ctx context.Context) (map[string]*vega.AssetDetails, error)
  • func (n *DataNode) ListCoreSnapshots(ctx context.Context) ([]vegaeventspb.CoreSnapshotData, error)
  • func (n *DataNode) ListDelegations(req *dataapipb.ListDelegationsRequest) (*dataapipb.ListDelegationsResponse, error)
  • func (n *DataNode) ListGovernanceData(ctx context.Context, req *dataapipb.ListGovernanceDataRequest) (*dataapipb.ListGovernanceDataResponse, error)
  • func (n *DataNode) ListMarkets(ctx context.Context) ([]*vega.Market, error)
  • func (n *DataNode) ListNetworkParameters(ctx context.Context) (*types.NetworkParams, error)
  • func (n *DataNode) ListProtocolUpgradeProposals(ctx context.Context) ([]vegaeventspb.ProtocolUpgradeEvent, error)
  • func (n *DataNode) ListReferralSetReferees(ctx context.Context) (map[string]v2.ReferralSetReferee, error)
  • func (n *DataNode) ListReferralSets(ctx context.Context) (map[string]*v2.ReferralSet, error)
  • func (n *DataNode) ListVotes(ctx context.Context, req *dataapipb.ListVotesRequest) (*dataapipb.ListVotesResponse, error)

Variables

var ActiveMarkets = []vega.Market_State{
	vega.Market_STATE_ACTIVE,
	vega.Market_STATE_SUSPENDED,
	vega.Market_STATE_PENDING,
}

var ErrAssetNotFound = errors.New("asset not found")

Types

type AccountFunds

type AccountFunds struct {
	Balance     *big.Int
	PartyId     string
	AccountType vega.AccountType
	AssetId     string
}

type DataNode

type DataNode struct {
	*core.Client
}

DataNode stores state for a Vega Data node.

func New

func New(hosts []string, callTimeout time.Duration, logger *zap.Logger) *DataNode

New returns a new node.

func (*DataNode) ERC20AssetWithAddress

func (n *DataNode) ERC20AssetWithAddress(ctx context.Context, address string) (*vega.AssetDetails, *vega.ERC20, error)

func (*DataNode) GeneralAccountBalance

func (n *DataNode) GeneralAccountBalance(ctx context.Context, partyID, assetID string) (*big.Int, error)

func (*DataNode) GetAllMarketsWithState

func (n *DataNode) GetAllMarketsWithState(ctx context.Context, states []vega.Market_State) ([]*vega.Market, error)

func (*DataNode) GetCurrentEpoch

func (n *DataNode) GetCurrentEpoch(ctx context.Context) (*vega.Epoch, error)

func (*DataNode) GetCurrentReferralProgram

func (n *DataNode) GetCurrentReferralProgram(ctx context.Context) (*v2.ReferralProgram, error)

func (*DataNode) GetCurrentVolumeDiscountProgram

func (n *DataNode) GetCurrentVolumeDiscountProgram(ctx context.Context) (*dataapipb.VolumeDiscountProgram, error)

func (*DataNode) GetGovernanceData

func (n *DataNode) GetGovernanceData(ctx context.Context, req *dataapipb.GetGovernanceDataRequest) (*dataapipb.GetGovernanceDataResponse, error)

func (*DataNode) GetPartyTotalStake

func (n *DataNode) GetPartyTotalStake(ctx context.Context, partyId string) (*big.Int, error)

func (*DataNode) LastNetworkHistorySegment

func (n *DataNode) LastNetworkHistorySegment(ctx context.Context) (*dataapipb.HistorySegment, error)

func (*DataNode) ListAccounts

func (n *DataNode) ListAccounts(ctx context.Context, partyID string, accountType vega.AccountType, assetID *string) ([]AccountFunds, error)

func (*DataNode) ListAssets

func (n *DataNode) ListAssets(ctx context.Context) (map[string]*vega.AssetDetails, error)

func (*DataNode) ListCoreSnapshots

func (n *DataNode) ListCoreSnapshots(ctx context.Context) ([]vegaeventspb.CoreSnapshotData, error)

func (*DataNode) ListDelegations

func (n *DataNode) ListDelegations(req *dataapipb.ListDelegationsRequest) (*dataapipb.ListDelegationsResponse, error)

ListDelegations returns delegations for the given party.

func (*DataNode) ListGovernanceData

func (n *DataNode) ListGovernanceData(ctx context.Context, req *dataapipb.ListGovernanceDataRequest) (*dataapipb.ListGovernanceDataResponse, error)

func (*DataNode) ListMarkets

func (n *DataNode) ListMarkets(ctx context.Context) ([]*vega.Market, error)

func (*DataNode) ListNetworkParameters

func (n *DataNode) ListNetworkParameters(ctx context.Context) (*types.NetworkParams, error)

func (*DataNode) ListProtocolUpgradeProposals

func (n *DataNode) ListProtocolUpgradeProposals(ctx context.Context) ([]vegaeventspb.ProtocolUpgradeEvent, error)

func (*DataNode) ListReferralSetReferees

func (n *DataNode) ListReferralSetReferees(ctx context.Context) (map[string]v2.ReferralSetReferee, error)

func (*DataNode) ListReferralSets

func (n *DataNode) ListReferralSets(ctx context.Context) (map[string]*v2.ReferralSet, error)

func (*DataNode) ListVotes

func (n *DataNode) ListVotes(ctx context.Context, req *dataapipb.ListVotesRequest) (*dataapipb.ListVotesResponse, error)