node

Documentation

Overview

Package node contains functionality for interacting with Vega data nodes.

Index

• type DataNode
  • func NewDataNode(hosts []string, callTimeout time.Duration) *DataNode
  • func (n *DataNode) AssetByID(req *dataapipb.AssetByIDRequest) (response *dataapipb.AssetByIDResponse, err error)
  • func (n *DataNode) DialConnection(ctx context.Context) chan struct{}
  • func (n *DataNode) LastBlockData() (*vegaapipb.LastBlockHeightResponse, error)
  • func (n *DataNode) MarketDataByID(req *dataapipb.MarketDataByIDRequest) (response *dataapipb.MarketDataByIDResponse, err error)
  • func (n *DataNode) Markets(req *dataapipb.MarketsRequest) (response *dataapipb.MarketsResponse, err error)
  • func (n *DataNode) ObserveEventBus(ctx context.Context) (client vegaapipb.CoreService_ObserveEventBusClient, err error)
  • func (n *DataNode) PartyAccounts(req *dataapipb.PartyAccountsRequest) (response *dataapipb.PartyAccountsResponse, err error)
  • func (n *DataNode) PositionsByParty(req *dataapipb.PositionsByPartyRequest) (response *dataapipb.PositionsByPartyResponse, err error)
  • func (n *DataNode) PositionsSubscribe(req *dataapipb.PositionsSubscribeRequest) (client dataapipb.TradingDataService_PositionsSubscribeClient, err error)
  • func (n *DataNode) SubmitTransaction(req *vegaapipb.SubmitTransactionRequest) (response *vegaapipb.SubmitTransactionResponse, err error)
  • func (n *DataNode) Target() string
  • func (n *DataNode) WaitForStateChange(ctx context.Context, state connectivity.State) bool

Types

type DataNode

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

DataNode stores state for a Vega Data node.

func NewDataNode

func NewDataNode(hosts []string, callTimeout time.Duration) *DataNode

NewDataNode returns a new node.

func (*DataNode) AssetByID

func (n *DataNode) AssetByID(req *dataapipb.AssetByIDRequest) (response *dataapipb.AssetByIDResponse, err error)

AssetByID returns the specified asset.

func (*DataNode) DialConnection

func (n *DataNode) DialConnection(ctx context.Context) chan struct{}

func (*DataNode) LastBlockData

func (n *DataNode) LastBlockData() (*vegaapipb.LastBlockHeightResponse, error)

LastBlockData gets the latest blockchain data, height, hash and pow parameters.

func (*DataNode) MarketDataByID

func (n *DataNode) MarketDataByID(req *dataapipb.MarketDataByIDRequest) (response *dataapipb.MarketDataByIDResponse, err error)

MarketDataByID returns market data for the specified market.

func (*DataNode) Markets

func (n *DataNode) Markets(req *dataapipb.MarketsRequest) (response *dataapipb.MarketsResponse, err error)

Markets returns all markets.

func (*DataNode) ObserveEventBus

func (n *DataNode) ObserveEventBus(ctx context.Context) (client vegaapipb.CoreService_ObserveEventBusClient, err error)

ObserveEventBus opens a stream.

func (*DataNode) PartyAccounts

func (n *DataNode) PartyAccounts(req *dataapipb.PartyAccountsRequest) (response *dataapipb.PartyAccountsResponse, err error)

PartyAccounts returns accounts for the given party.

func (*DataNode) PositionsByParty

func (n *DataNode) PositionsByParty(req *dataapipb.PositionsByPartyRequest) (response *dataapipb.PositionsByPartyResponse, err error)

PositionsByParty returns positions for the given party.

func (*DataNode) PositionsSubscribe

func (n *DataNode) PositionsSubscribe(req *dataapipb.PositionsSubscribeRequest) (client dataapipb.TradingDataService_PositionsSubscribeClient, err error)

PositionsSubscribe opens a stream.

func (*DataNode) SubmitTransaction

func (n *DataNode) SubmitTransaction(req *vegaapipb.SubmitTransactionRequest) (response *vegaapipb.SubmitTransactionResponse, err error)

SubmitTransaction submits a signed v2 transaction.

func (*DataNode) Target

func (n *DataNode) Target() string

func (*DataNode) WaitForStateChange

func (n *DataNode) WaitForStateChange(ctx context.Context, state connectivity.State) bool