data

Documentation

Index

• func NewDataStream(marketID, pubKey, settlementAssetID string, node DataNode, store dataStore, ...) (*data, error)
• func NewMarketStream(node DataNode, walletPubKey string, pauseCh chan types.PauseSignal) *market
• func NewStore() *store
• type DataNode

Functions

func NewDataStream

func NewDataStream(marketID, pubKey, settlementAssetID string, node DataNode, store dataStore, pauseCh chan types.PauseSignal) (*data, error)

func NewMarketStream

func NewMarketStream(node DataNode, walletPubKey string, pauseCh chan types.PauseSignal) *market

func NewStore

func NewStore() *store

Types

type DataNode

type DataNode interface {
	ObserveEventBus(ctx context.Context) (client vegaapipb.CoreService_ObserveEventBusClient, err error)
	PartyAccounts(req *dataapipb.PartyAccountsRequest) (response *dataapipb.PartyAccountsResponse, err error)
	MarketDataByID(req *dataapipb.MarketDataByIDRequest) (response *dataapipb.MarketDataByIDResponse, err error)
	PositionsByParty(req *dataapipb.PositionsByPartyRequest) (response *dataapipb.PositionsByPartyResponse, err error)
	DialConnection(ctx context.Context) chan struct{}
}

DataNode is a Vega Data node