steps

package
v0.74.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2024 License: AGPL-3.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Account 

func Account(name string) (types.AccountType, error)

func AccountID 

func AccountID(marketID, partyID, asset string, ty types.AccountType) string

func AuctionTrigger 

func AuctionTrigger(name string) (types.AuctionTrigger, error)

func Bool 

func Bool(rawValue string) (bool, error)

func ClearAllEvents 

func ClearAllEvents(broker *stubs.BrokerStub)

func ClearTradeEvents added in v0.74.0 

func ClearTradeEvents(broker *stubs.BrokerStub) error

func ClearTransferResponseEvents 

func ClearTransferResponseEvents(broker *stubs.BrokerStub)

func CreateNetworkTreasuryAccount added in v0.73.0 

func CreateNetworkTreasuryAccount(col *collateral.Engine, asset string) error

func DebugAccounts 

func DebugAccounts(broker *stubs.BrokerStub, log *logging.Logger)

func DebugAllEvents 

func DebugAllEvents(broker *stubs.BrokerStub, log *logging.Logger)

func DebugAllEventsJSONFile added in v0.74.0 

func DebugAllEventsJSONFile(broker *stubs.BrokerStub, log *logging.Logger, fname string) error

func DebugAuctionEvents 

func DebugAuctionEvents(broker *stubs.BrokerStub, log *logging.Logger)

func DebugLPDetail 

func DebugLPDetail(log *logging.Logger, broker *stubs.BrokerStub)

func DebugLPSTxErrors 

func DebugLPSTxErrors(broker *stubs.BrokerStub, log *logging.Logger)

func DebugLPs 

func DebugLPs(broker *stubs.BrokerStub, log *logging.Logger)

func DebugLastNEvents added in v0.68.0 

func DebugLastNEvents(n int, broker *stubs.BrokerStub, log *logging.Logger)

func DebugLossSocialisationEvents added in v0.73.14 

func DebugLossSocialisationEvents(broker *stubs.BrokerStub, log *logging.Logger) error

func DebugMarketData 

func DebugMarketData(
	exec Execution,
	log *logging.Logger,
	market string,
) error

func DebugNetworkParameter added in v0.73.0 

func DebugNetworkParameter(log *logging.Logger, netParams *netparams.Store, key string) error

func DebugOrders 

func DebugOrders(broker *stubs.BrokerStub, log *logging.Logger)

func DebugTrades 

func DebugTrades(broker *stubs.BrokerStub, log *logging.Logger)

func DebugTransfers 

func DebugTransfers(broker *stubs.BrokerStub, log *logging.Logger)

func DebugTxErrors 

func DebugTxErrors(broker *stubs.BrokerStub, log *logging.Logger)

func DebugVolumesForMarket 

func DebugVolumesForMarket(log *logging.Logger, broker *stubs.BrokerStub, marketID string) error

func DebugVolumesForMarketDetail 

func DebugVolumesForMarketDetail(log *logging.Logger, broker *stubs.BrokerStub, marketID string) error

func Decimal 

func Decimal(rawValue string) (num.Decimal, error)

func EventType 

func EventType(rawValue string) (events.Type, error)

func ExpectingEventsInTheSecenarioSoFar added in v0.68.0 

func ExpectingEventsInTheSecenarioSoFar(broker *stubs.BrokerStub, expected int) error

func ExpectingEventsOverStep added in v0.68.0 

func ExpectingEventsOverStep(broker *stubs.BrokerStub, eventsBeforeStep, expected int) error

func ExpiryStrategy added in v0.72.0 

func ExpiryStrategy(rawValue string) (types.StopOrderExpiryStrategy, error)

func F64 

func F64(rawValue string) (float64, error)

func F64Slice 

func F64Slice(rawValue string, sep string) ([]float64, error)

func I64 

func I64(rawValue string) (int64, error)

func I64Slice 

func I64Slice(rawValue string, sep string) ([]int64, error)

func LiquidityFeeMethodType added in v0.74.0 

func LiquidityFeeMethodType(rawValue string) (types.LiquidityFeeSettings_Method, error)

func LiquidityStatus 

func LiquidityStatus(rawValue string) (types.LiquidityProvisionStatus, error)

func MarketOpeningAuctionPeriodEnds 

func MarketOpeningAuctionPeriodEnds(execEngine Execution, timeStub *stubs.TimeStub, markets []types.Market, marketID string) error

func MarketState 

func MarketState(name string) (types.MarketState, error)

func MarketStateUpdate added in v0.73.0 

func MarketStateUpdate(name string) (types.MarketStateUpdateType, error)

func OracleSpecConditionOperator 

func OracleSpecConditionOperator(name string) (datav1.Condition_Operator, error)

func OracleSpecPropertyType 

func OracleSpecPropertyType(name string) (datav1.PropertyKey_Type, error)

func OracleSpecSettlementDataDecimals added in v0.56.0 

func OracleSpecSettlementDataDecimals(config *market.Config, name string, settlementDP string) error

func OraclesBroadcastDataSignedWithKeys 

func OraclesBroadcastDataSignedWithKeys(
	oracleEngine *spec.Engine,
	timesvc *stubs.TimeStub,
	rawPubKeys string,
	rawProperties *godog.Table,
) error

func OraclesBroadcastDataWithBlockTimeSignedWithKeys added in v0.73.0 

func OraclesBroadcastDataWithBlockTimeSignedWithKeys(
	oracleEngine *spec.Engine,
	timesvc *stubs.TimeStub,
	rawPubKeys string,
	rawProperties *godog.Table,
) error

func OrderStatus 

func OrderStatus(rawValue string) (types.OrderStatus, error)

func OrderType 

func OrderType(rawValue string) (types.OrderType, error)

func PartiesAmendTheFollowingOrders 

func PartiesAmendTheFollowingOrders(
	broker *stubs.BrokerStub,
	exec Execution,
	table *godog.Table,
) error

func PartiesAmendTheFollowingPeggedIcebergOrders added in v0.73.0 

func PartiesAmendTheFollowingPeggedIcebergOrders(
	broker *stubs.BrokerStub,
	exec Execution,
	ts *stubs.TimeStub,
	table *godog.Table,
) error

func PartiesApplyTheFollowingReferralCode added in v0.73.0 

func PartiesApplyTheFollowingReferralCode(referralEngine *referral.Engine, teamsEngine *teams.Engine, table *godog.Table) error

func PartiesAvailableFeeDiscounts added in v0.74.0 

func PartiesAvailableFeeDiscounts(
	engine *banking.Engine,
	table *godog.Table,
) error

func PartiesCancelAllTheirOrdersForTheMarkets 

func PartiesCancelAllTheirOrdersForTheMarkets(
	broker *stubs.BrokerStub,
	exec Execution,
	table *godog.Table,
) error

func PartiesCancelTheFollowingOrders 

func PartiesCancelTheFollowingOrders(
	broker *stubs.BrokerStub,
	exec Execution,
	table *godog.Table,
) error

func PartiesCancelTheFollowingStopOrders added in v0.72.0 

func PartiesCancelTheFollowingStopOrders(
	broker *stubs.BrokerStub,
	exec Execution,
	table *godog.Table,
) error

func PartiesCancelTransfers 

func PartiesCancelTransfers(
	engine *banking.Engine,
	table *godog.Table,
) error

func PartiesCreateTheFollowingReferralCode added in v0.73.0 

func PartiesCreateTheFollowingReferralCode(referralEngine *referral.Engine, teamsEngine *teams.Engine, table *godog.Table) error

func PartiesDelegateTheFollowingStake 

func PartiesDelegateTheFollowingStake(
	engine *delegation.Engine,
	table *godog.Table,
) error

func PartiesDepositTheFollowingAssets 

func PartiesDepositTheFollowingAssets(
	collateralEngine *collateral.Engine,
	broker *stubs.BrokerStub,
	netDeposits *num.Uint,
	table *godog.Table,
) error

func PartiesHaveTheFollowingProfitAndLoss 

func PartiesHaveTheFollowingProfitAndLoss(
	positionService *plugins.Positions,
	table *godog.Table,
) error

func PartiesPlaceTheFollowingIcebergOrders added in v0.72.0 

func PartiesPlaceTheFollowingIcebergOrders(
	exec Execution,
	ts *stubs.TimeStub,
	table *godog.Table,
) error

func PartiesPlaceTheFollowingOrders 

func PartiesPlaceTheFollowingOrders(
	exec Execution,
	ts *stubs.TimeStub,
	table *godog.Table,
) error

func PartiesPlaceTheFollowingOrdersBlocksApart added in v0.63.0 

func PartiesPlaceTheFollowingOrdersBlocksApart(exec Execution, time *stubs.TimeStub, block *helpers.Block, epochService EpochService, table *godog.Table, blockCount string) error

func PartiesPlaceTheFollowingOrdersWithTicks added in v0.63.0 

func PartiesPlaceTheFollowingOrdersWithTicks(exec Execution, time *stubs.TimeStub, epochService EpochService, table *godog.Table) error

func PartiesPlaceTheFollowingPeggedIcebergOrders added in v0.72.0 

func PartiesPlaceTheFollowingPeggedIcebergOrders(
	exec Execution,
	ts *stubs.TimeStub,
	table *godog.Table,
) error

func PartiesPlaceTheFollowingPeggedOrders 

func PartiesPlaceTheFollowingPeggedOrders(exec Execution, table *godog.Table) error

func PartiesShouldHaveTheFollowingAccountBalances 

func PartiesShouldHaveTheFollowingAccountBalances(
	broker *stubs.BrokerStub,
	table *godog.Table,
) error

func PartiesShouldHaveTheFollowingDelegationBalances 

func PartiesShouldHaveTheFollowingDelegationBalances(
	broker *stubs.BrokerStub,
	table *godog.Table,
	epochSeq string,
) error

func PartiesShouldHaveTheFollowingPositionStatus added in v0.71.0 

func PartiesShouldHaveTheFollowingPositionStatus(
	broker *stubs.BrokerStub,
	market string,
	table *godog.Table,
) error

func PartiesShouldHaveTheFollowingPositionStatusAgg added in v0.71.0 

func PartiesShouldHaveTheFollowingPositionStatusAgg(
	broker *stubs.BrokerStub,
	market string,
	table *godog.Table,
) error

func PartiesShouldHaveTheFollowingStakingAccountBalances 

func PartiesShouldHaveTheFollowingStakingAccountBalances(
	stakingAccounts *stubs.StakingAccountStub,
	table *godog.Table,
) error

func PartiesShouldHaveVestedAccountBalances added in v0.73.0 

func PartiesShouldHaveVestedAccountBalances(broker *stubs.BrokerStub, table *godog.Table) error

func PartiesShouldHaveVestingAccountBalances added in v0.73.0 

func PartiesShouldHaveVestingAccountBalances(broker *stubs.BrokerStub, table *godog.Table) error

func PartiesShouldReceiveTheFollowingReward 

func PartiesShouldReceiveTheFollowingReward(
	broker *stubs.BrokerStub,
	table *godog.Table,
	epochSeq string,
) error

func PartiesSubmitLiquidityProvision 

func PartiesSubmitLiquidityProvision(exec Execution, table *godog.Table) error

func PartiesSubmitRecurringTransfers 

func PartiesSubmitRecurringTransfers(
	engine *banking.Engine,
	table *godog.Table,
) error

func PartiesSubmitTransfers 

func PartiesSubmitTransfers(
	engine *banking.Engine,
	table *godog.Table,
) error

func PartiesTransferToStakingAccount 

func PartiesTransferToStakingAccount(
	stakingAccountStub *stubs.StakingAccountStub,
	broker *stubs.BrokerStub,
	table *godog.Table,
	epoch string,
) error

func PartiesUndelegateTheFollowingStake 

func PartiesUndelegateTheFollowingStake(
	engine *delegation.Engine,
	table *godog.Table,
) error

func PartiesWithdrawFromStakingAccount 

func PartiesWithdrawFromStakingAccount(
	stakingAccountStub *stubs.StakingAccountStub,
	broker *stubs.BrokerStub,
	table *godog.Table,
) error

func PartiesWithdrawTheFollowingAssets 

func PartiesWithdrawTheFollowingAssets(
	collateral *collateral.Engine,
	broker *stubs.BrokerStub,
	netDeposits *num.Uint,
	table *godog.Table,
) error

func PartyAddsTheFollowingIcebergOrdersToABatch added in v0.72.0 

func PartyAddsTheFollowingIcebergOrdersToABatch(party string, exec Execution, time *stubs.TimeStub, table *godog.Table) error

func PartyAddsTheFollowingOrdersToABatch added in v0.72.0 

func PartyAddsTheFollowingOrdersToABatch(party string, exec Execution, time *stubs.TimeStub, table *godog.Table) error

func PartyCancelsAllTheirStopOrders added in v0.72.0 

func PartyCancelsAllTheirStopOrders(
	exec Execution,
	partyID string,
) error

func PartyCancelsAllTheirStopOrdersForTheMarket added in v0.72.0 

func PartyCancelsAllTheirStopOrdersForTheMarket(
	exec Execution,
	partyID string,
	marketID string,
) error

func PartyCancelsTheirLiquidityProvision 

func PartyCancelsTheirLiquidityProvision(exec Execution, marketID, party string) error

func PartyHasTheFollowingDiscountFactor added in v0.73.0 

func PartyHasTheFollowingDiscountFactor(party, discountFactor string, vde *volumediscount.Engine) error

func PartyHasTheFollowingTakerNotional added in v0.73.0 

func PartyHasTheFollowingTakerNotional(party, notional string, vde *volumediscount.Engine) error

func PartyShouldHaveGeneralAccountBalanceForAsset 

func PartyShouldHaveGeneralAccountBalanceForAsset(
	broker *stubs.BrokerStub,
	party, asset, rawBalance string,
) error

func PartyShouldHaveHoldingAccountBalanceForAsset added in v0.73.0 

func PartyShouldHaveHoldingAccountBalanceForAsset(
	broker *stubs.BrokerStub,
	party, asset, rawBalance string,
) error

func PartyShouldHaveOneAccountPerAsset 

func PartyShouldHaveOneAccountPerAsset(
	broker *stubs.BrokerStub,
	owner string,
) error

func PartyShouldHaveOneMarginAccountPerMarket 

func PartyShouldHaveOneMarginAccountPerMarket(
	broker *stubs.BrokerStub,
	owner string,
) error

func PartyShouldHaveVestedAccountBalanceForAsset added in v0.73.0 

func PartyShouldHaveVestedAccountBalanceForAsset(
	broker *stubs.BrokerStub,
	party, asset, rawBalance string,
) error

func PartyShouldHaveVestingAccountBalanceForAsset added in v0.73.0 

func PartyShouldHaveVestingAccountBalanceForAsset(
	broker *stubs.BrokerStub,
	party, asset, rawBalance string,
) error

func PartyStartsABatchInstruction added in v0.72.0 

func PartyStartsABatchInstruction(party string, exec Execution) error

func PartySubmitsTheirBatchInstruction added in v0.72.0 

func PartySubmitsTheirBatchInstruction(party string, exec Execution) error

func PositionStatus added in v0.71.0 

func PositionStatus(rawValue string) (proto.PositionStatus, error)

func RegisterAsset 

func RegisterAsset(tbl *godog.Table, asset *stubs.AssetStub, col *collateral.Engine) error

func RewardAccountBalanceForAssetShouldMatch 

func RewardAccountBalanceForAssetShouldMatch(
	broker *stubs.BrokerStub,
	accountType, asset, rawBalance string,
) error

func Side 

func Side(rawValue string) (types.Side, error)

func StopOrderStatus added in v0.72.0 

func StopOrderStatus(rawValue string) (types.StopOrderStatus, error)

func StrSlice 

func StrSlice(value string, sep string) []string

func TIF 

func TIF(rawValue string) (types.OrderTimeInForce, error)

func TheAccumulatedInfrastructureFeesShouldBeForTheMarket 

func TheAccumulatedInfrastructureFeesShouldBeForTheMarket(
	broker *stubs.BrokerStub,
	amountStr, asset string,
) error

func TheAccumulatedLiquidityFeesShouldBeForTheMarket 

func TheAccumulatedLiquidityFeesShouldBeForTheMarket(
	broker *stubs.BrokerStub,
	amountStr, market string,
) error

func TheActivityStreaksShouldBe added in v0.73.0 

func TheActivityStreaksShouldBe(broker *stubs.BrokerStub, epochStr string, table *godog.Table) error

func TheAuctionTradedVolumeAndPriceShouldBe 

func TheAuctionTradedVolumeAndPriceShouldBe(broker *stubs.BrokerStub, volume, price string, now time.Time) error

TheAuctionTradedVolumeAndPriceShouldBe pass in time at which the trades should happen in case there are previous trades in the broker stub.

func TheAverageBlockDurationIs 

func TheAverageBlockDurationIs(block *helpers.Block, dur string) error

func TheAverageBlockDurationWithVariance 

func TheAverageBlockDurationWithVariance(block *helpers.Block, dur, variance string) error

func TheCompositePriceOracleSpec added in v0.74.0 

func TheCompositePriceOracleSpec(config *market.Config, keys string, table *godog.Table) error

func TheCumulatedBalanceForAllAccountsShouldBeWorth 

func TheCumulatedBalanceForAllAccountsShouldBeWorth(broker *stubs.BrokerStub, rawAmount string) error

func TheCurrentEpochIs added in v0.73.0 

func TheCurrentEpochIs(broker *stubs.BrokerStub, epoch string) error

func TheFeesConfiguration 

func TheFeesConfiguration(config *market.Config, name string, table *godog.Table) error

func TheFollowingEventsShouldBeEmitted 

func TheFollowingEventsShouldBeEmitted(broker *stubs.BrokerStub, table *godog.Table) error

func TheFollowingEventsShouldNotBeEmitted added in v0.58.0 

func TheFollowingEventsShouldNotBeEmitted(broker *stubs.BrokerStub, table *godog.Table) error

func TheFollowingLPEventsShouldBeEmitted 

func TheFollowingLPEventsShouldBeEmitted(broker *stubs.BrokerStub, table *godog.Table) error

func TheFollowingNetworkParametersAreSet 

func TheFollowingNetworkParametersAreSet(netParams *netparams.Store, table *godog.Table) error

func TheFollowingNetworkTradesShouldBeExecuted 

func TheFollowingNetworkTradesShouldBeExecuted(broker *stubs.BrokerStub, table *godog.Table) error

func TheFollowingOrdersShouldBeRejected 

func TheFollowingOrdersShouldBeRejected(broker *stubs.BrokerStub, table *godog.Table) error

func TheFollowingOrdersShouldBeStopped 

func TheFollowingOrdersShouldBeStopped(broker *stubs.BrokerStub, table *godog.Table) error

func TheFollowingTeamsWithRefereesAreCreated added in v0.73.0 

func TheFollowingTeamsWithRefereesAreCreated(
	col *collateral.Engine,
	broker *stubs.BrokerStub,
	netDeposits *num.Uint,
	referralEngine *referral.Engine,
	teamsEngine *teams.Engine,
	table *godog.Table,
) error

func TheFollowingTradesShouldBeExecuted 

func TheFollowingTradesShouldBeExecuted(
	broker *stubs.BrokerStub,
	table *godog.Table,
) error

func TheFollowingTransfersShouldHappen 

func TheFollowingTransfersShouldHappen(
	broker *stubs.BrokerStub,
	table *godog.Table,
) error

func TheGlobalInsuranceBalanceShouldBeForTheAsset added in v0.73.0 

func TheGlobalInsuranceBalanceShouldBeForTheAsset(
	broker *stubs.BrokerStub,
	rawAmount, asset string,
) error

func TheIcebergOrdersShouldHaveTheFollowingStates added in v0.72.0 

func TheIcebergOrdersShouldHaveTheFollowingStates(broker *stubs.BrokerStub, table *godog.Table) error

func TheInsurancePoolBalanceShouldBeForTheMarket 

func TheInsurancePoolBalanceShouldBeForTheMarket(
	broker *stubs.BrokerStub,
	rawAmount, market string,
) error

func TheLPLiquidityBondBalanceShouldBeForTheMarket added in v0.73.0 

func TheLPLiquidityBondBalanceShouldBeForTheMarket(
	broker *stubs.BrokerStub,
	party, rawAmount, market string,
) error

func TheLPLiquidityFeeBalanceShouldBeForTheMarket added in v0.73.0 

func TheLPLiquidityFeeBalanceShouldBeForTheMarket(
	broker *stubs.BrokerStub,
	party, rawAmount, market string,
) error

func TheLastStateUpdateShouldBeForMarket added in v0.72.0 

func TheLastStateUpdateShouldBeForMarket(
	broker *stubs.BrokerStub,
	market, expectedMarketStateStr string,
) error

func TheLiquidationStrategies added in v0.74.0 

func TheLiquidationStrategies(config *market.Config, table *godog.Table) error

func TheLiquidityFeeFactorShouldForTheMarket 

func TheLiquidityFeeFactorShouldForTheMarket(
	broker *stubs.BrokerStub,
	feeStr, market string,
) error

func TheLiquidityMonitoring added in v0.57.0 

func TheLiquidityMonitoring(config *market.Config, table *godog.Table) error

func TheLiquidityProviderFeeSharesForTheMarketShouldBe 

func TheLiquidityProviderFeeSharesForTheMarketShouldBe(engine Execution, marketID string, table *godog.Table) error

func TheLiquidityProvisionsShouldHaveTheFollowingStates 

func TheLiquidityProvisionsShouldHaveTheFollowingStates(broker *stubs.BrokerStub, table *godog.Table) error

func TheLiquiditySLAPArams added in v0.73.0 

func TheLiquiditySLAPArams(config *market.Config, name string, table *godog.Table) error

func TheLogNormalRiskModel 

func TheLogNormalRiskModel(config *market.Config, name string, table *godog.Table) error

func TheLossSocialisationAmountsAre added in v0.73.14 

func TheLossSocialisationAmountsAre(broker *stubs.BrokerStub, table *godog.Table) error

func TheMarginCalculator 

func TheMarginCalculator(config *market.Config, name string, table *godog.Table) error

func TheMarkPriceAlgoShouldBeForMarket added in v0.74.0 

func TheMarkPriceAlgoShouldBeForMarket(
	broker *stubs.BrokerStub,
	market, expectedMarkPriceAlgo string,
) error

func TheMarkPriceForTheMarketIs 

func TheMarkPriceForTheMarketIs(
	exec Execution,
	market, markPriceStr string,
) error

func TheMarketDataShouldBe 

func TheMarketDataShouldBe(engine Execution, mID string, data *godog.Table) error

func TheMarketStateIsUpdatedTo added in v0.73.0 

func TheMarketStateIsUpdatedTo(exec Execution, data *godog.Table) error

func TheMarketStateShouldBeForMarket 

func TheMarketStateShouldBeForMarket(
	engine Execution,
	market, expectedMarketStateStr string,
) error

func TheMarkets 

func TheMarkets(
	config *market.Config,
	executionEngine Execution,
	collateralEngine *collateral.Engine,
	netparams *netparams.Store,
	now time.Time,
	table *godog.Table,
) ([]types.Market, error)

func TheMarketsUpdated added in v0.57.0 

func TheMarketsUpdated(
	config *market.Config,
	executionEngine Execution,
	existing []types.Market,
	netparams *netparams.Store,
	table *godog.Table,
) ([]types.Market, error)

func TheNetworkMovesAheadDurationWithBlocks 

func TheNetworkMovesAheadDurationWithBlocks(exec Execution, block *helpers.Block, ts *stubs.TimeStub, delta, dur string) error

func TheNetworkMovesAheadNBlocks 

func TheNetworkMovesAheadNBlocks(exec Execution, block *helpers.Block, time *stubs.TimeStub, n string, epochService EpochService) error

func TheNetworkMovesAheadNEpochs added in v0.73.0 

func TheNetworkMovesAheadNEpochs(broker *stubs.BrokerStub, block *helpers.Block, exec Execution, epochService EpochService, ts *stubs.TimeStub, epochs string) error

func TheNetworkMovesAheadToTheNextEpoch added in v0.73.0 

func TheNetworkMovesAheadToTheNextEpoch(broker *stubs.BrokerStub, block *helpers.Block, exec Execution, epochService EpochService, ts *stubs.TimeStub) error

func TheNetworkTreasuryBalanceShouldBeForTheAsset 

func TheNetworkTreasuryBalanceShouldBeForTheAsset(
	broker *stubs.BrokerStub,
	rawAmount, asset string,
) error

func TheOpenInterestShouldBeForTheMarket 

func TheOpenInterestShouldBeForTheMarket(engine Execution, marketID string, wantOpenInterest string) error

func TheOracleSpec 

func TheOracleSpec(config *market.Config, name string, specType string, rawPubKeys string, table *godog.Table) error

func TheOrderBookOfMarketShouldHaveTheFollowingVolumes 

func TheOrderBookOfMarketShouldHaveTheFollowingVolumes(broker *stubs.BrokerStub, marketID string, table *godog.Table) error

func TheOrdersShouldHaveTheFollowingStates 

func TheOrdersShouldHaveTheFollowingStates(broker *stubs.BrokerStub, table *godog.Table) error

func TheOrdersShouldHaveTheFollowingStatus 

func TheOrdersShouldHaveTheFollowingStatus(broker *stubs.BrokerStub, table *godog.Table) error

func ThePartiesShouldHaveTheFollowingMarginLevels 

func ThePartiesShouldHaveTheFollowingMarginLevels(
	broker *stubs.BrokerStub,
	table *godog.Table,
) error

func ThePartiesUpdateMarginMode added in v0.74.0 

func ThePartiesUpdateMarginMode(
	execution Execution,
	table *godog.Table,
) error

func ThePeggedOrdersShouldHaveTheFollowingStates 

func ThePeggedOrdersShouldHaveTheFollowingStates(broker *stubs.BrokerStub, table *godog.Table) error

func ThePerpsOracleSpec added in v0.73.0 

func ThePerpsOracleSpec(config *market.Config, keys string, table *godog.Table) error

func ThePriceMonitoring 

func ThePriceMonitoring(config *market.Config, name string, table *godog.Table) error

func ThePriceMonitoringBoundsForTheMarketShouldBe 

func ThePriceMonitoringBoundsForTheMarketShouldBe(engine Execution, marketID string, table *godog.Table) error

func TheProductDataShouldBe added in v0.74.0 

func TheProductDataShouldBe(engine Execution, mID string, data *godog.Table) error

func TheReferralBenefitTiersConfiguration added in v0.73.0 

func TheReferralBenefitTiersConfiguration(config *referralcfg.Config, name string, table *godog.Table) error

func TheReferralProgram added in v0.73.0 

func TheReferralProgram(referralProgramConfig *referralcfg.Config, referralProgramEngine *referral.Engine, table *godog.Table) error

func TheReferralSetStatsShouldBe added in v0.73.0 

func TheReferralSetStatsShouldBe(broker *stubs.BrokerStub, code, epochStr, volumeStr string, table *godog.Table) error

func TheReferralStakingTiersConfiguration added in v0.73.0 

func TheReferralStakingTiersConfiguration(config *referralcfg.Config, name string, table *godog.Table) error

func TheSettlementAccountShouldHaveBalanceForMarket 

func TheSettlementAccountShouldHaveBalanceForMarket(
	broker *stubs.BrokerStub,
	amountStr, market string,
) error

func TheSimpleRiskModel 

func TheSimpleRiskModel(config *market.Config, name string, table *godog.Table) error

func TheSpotMarkets added in v0.73.0 

func TheSpotMarkets(config *market.Config, executionEngine Execution, collateralEngine *collateral.Engine, netparams *netparams.Store, now time.Time, table *godog.Table) ([]types.Market, error)

func TheSpotMarketsUpdated added in v0.73.0 

func TheSpotMarketsUpdated(
	config *market.Config,
	executionEngine Execution,
	existing []types.Market,
	netparams *netparams.Store,
	table *godog.Table,
) ([]types.Market, error)

func TheStopOrdersShouldHaveTheFollowingStates added in v0.72.0 

func TheStopOrdersShouldHaveTheFollowingStates(broker *stubs.BrokerStub, table *godog.Table) error

func TheSuccesorMarketIsEnacted added in v0.72.0 

func TheSuccesorMarketIsEnacted(sID string, markets []types.Market, exec Execution) error

func TheSuppliedStakeShouldBeForTheMarket 

func TheSuppliedStakeShouldBeForTheMarket(engine Execution, marketID string, wantSuppliedStake string) error

func TheTargetStakeShouldBeForMarket 

func TheTargetStakeShouldBeForMarket(engine Execution, marketID string, wantTargetStake string) error

func TheTeamHasTheFollowingMembers added in v0.73.0 

func TheTeamHasTheFollowingMembers(teamsEngine *teams.Engine, team string, table *godog.Table) error

func TheTradingModeShouldBeForMarket 

func TheTradingModeShouldBeForMarket(
	engine Execution,
	market, tradingModeStr string,
) error

func TheValidators 

func TheValidators(
	topology *stubs.TopologyStub,
	stakingAcountStub *stubs.StakingAccountStub,
	delegtionEngine *delegation.Engine,
	table *godog.Table,
) error

func TheVestingStatsShouldBe added in v0.73.0 

func TheVestingStatsShouldBe(broker *stubs.BrokerStub, epochStr string, table *godog.Table) error

func TheVolumeDiscountStatsShouldBe added in v0.73.0 

func TheVolumeDiscountStatsShouldBe(broker *stubs.BrokerStub, epochStr string, table *godog.Table) error

func Time 

func Time(rawTime string) (time.Time, error)

func TimeIsUpdatedTo 

func TimeIsUpdatedTo(exec Execution, timeService *stubs.TimeStub, newTime string)

func TotalOfEventsShouldBeEmitted 

func TotalOfEventsShouldBeEmitted(broker *stubs.BrokerStub, eventCounter int) error

func TradingMode 

func TradingMode(name string) (types.MarketTradingMode, error)

func U64 

func U64(value string) (uint64, error)

func U64Slice 

func U64Slice(rawValue, sep string) ([]uint64, error)

func Uint 

func Uint(value string) (*num.Uint, error)

func UpdateAsset added in v0.74.0 

func UpdateAsset(tbl *godog.Table, asset *stubs.AssetStub, col *collateral.Engine) error

func ValidatorsShouldHaveTheFollowingScores 

func ValidatorsShouldHaveTheFollowingScores(
	broker *stubs.BrokerStub,
	table *godog.Table,
	epoch string,
) error

func VolumeDiscountProgram added in v0.73.0 

func VolumeDiscountProgram(
	vde *volumediscount.Engine,
	tiers map[string][]*types.VolumeBenefitTier,
	table *godog.Table,
) error

func VolumeDiscountProgramTiers added in v0.73.0 

func VolumeDiscountProgramTiers(
	tiers map[string][]*types.VolumeBenefitTier,
	volumeDiscountTierName string,
	table *godog.Table,
) error

Types

type CancelOrderError 

type CancelOrderError struct {
	Err error
	// contains filtered or unexported fields
}

func (CancelOrderError) Error 

func (c CancelOrderError) Error() string

func (*CancelOrderError) Unwrap 

func (c *CancelOrderError) Unwrap() error

type EpochService 

type EpochService interface {
	OnBlockEnd(ctx context.Context)
}

type ErrStack 

type ErrStack []error

func (ErrStack) Error 

func (e ErrStack) Error() string

Error so we print out the wrong matches line by line.

type ErroneousRow 

type ErroneousRow interface {
	ExpectError() bool
	Error() string
	Reference() string
}

type Execution 

type Execution interface {
	GetMarketData(mktID string) (types.MarketData, error)
	GetMarketState(mktID string) (types.MarketState, error)
	AmendOrder(ctx context.Context, amendment *types.OrderAmendment, party string) (*types.OrderConfirmation, error)
	CancelOrder(ctx context.Context, cancel *types.OrderCancellation, party string) ([]*types.OrderCancellationConfirmation, error)
	CancelStopOrder(ctx context.Context, cancel *types.StopOrdersCancellation, party string) error
	SubmitOrder(ctx context.Context, submission *types.OrderSubmission, party string) (*types.OrderConfirmation, error)
	SubmitStopOrder(ctx context.Context, submission *types.StopOrdersSubmission, party string) (*types.OrderConfirmation, error)
	SubmitLiquidityProvision(ctx context.Context, submission *types.LiquidityProvisionSubmission, party string, lpID string,
		deterministicID string) error
	AmendLiquidityProvision(ctx context.Context, amendment *types.LiquidityProvisionAmendment, party string) error
	CancelLiquidityProvision(ctx context.Context, cancel *types.LiquidityProvisionCancellation, party string) error
	SubmitSpotMarket(ctx context.Context, marketConfig *types.Market, proposer string, oos time.Time) error
	SubmitMarket(ctx context.Context, marketConfig *types.Market, proposer string, oos time.Time) error
	StartOpeningAuction(ctx context.Context, marketID string) error
	UpdateMarket(ctx context.Context, marketConfig *types.Market) error
	UpdateSpotMarket(ctx context.Context, marketConfig *types.Market) error
	BlockEnd(ctx context.Context)
	GetMarket(parentID string, settled bool) (types.Market, bool)
	SucceedMarket(ctx context.Context, successor, parent string) error

	// even though the batch processing is done above the execution engine, from the feature test point of view
	// it is part of the execution engine
	StartBatch(party string) error
	AddSubmitOrderToBatch(submission *types.OrderSubmission, party string) error
	ProcessBatch(ctx context.Context, party string) error
	OnEpochEvent(ctx context.Context, epoch types.Epoch)
	UpdateMarketState(ctx context.Context, changes *types.MarketStateUpdateConfiguration) error
	UpdateMarginMode(ctx context.Context, party, marketID string, marginMode types.MarginMode, marginFactor num.Decimal) error
}

the interface for execution engine. The execution engine itself will be wrapped so to use it in steps, we'll need to use an interface.

type LPEventWrapper 

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

func (LPEventWrapper) CommitmentAmount 

func (l LPEventWrapper) CommitmentAmount() *num.Uint

func (LPEventWrapper) Final 

func (l LPEventWrapper) Final() bool

func (LPEventWrapper) ID 

func (l LPEventWrapper) ID() string

func (LPEventWrapper) Party 

func (l LPEventWrapper) Party() string

func (LPEventWrapper) Version 

func (l LPEventWrapper) Version() uint64

type LPUpdate 

type LPUpdate struct {
	MarketID         string
	CommitmentAmount *num.Uint
	Fee              num.Decimal
	Reference        string
	LpType           string
	Err              string
}

type MappedMD 

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

type Only added in v0.71.0 

type Only string
const (
	None   Only = ""
	Post   Only = "post"
	Reduce Only = "reduce"
)

type OrderAmendmentError 

type OrderAmendmentError struct {
	OrderAmendment types.OrderAmendment
	OrderReference string
	Err            error
}

func (OrderAmendmentError) Error 

func (o OrderAmendmentError) Error() string

type ProductDataWrapper added in v0.74.0 

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

func (ProductDataWrapper) ExternalTWAP added in v0.74.0 

func (f ProductDataWrapper) ExternalTWAP() string

func (ProductDataWrapper) FundingPayment added in v0.74.0 

func (f ProductDataWrapper) FundingPayment() (string, bool)

func (ProductDataWrapper) FundingRate added in v0.74.0 

func (f ProductDataWrapper) FundingRate() (string, bool)

func (ProductDataWrapper) InternalCompositePrice added in v0.74.0 

func (f ProductDataWrapper) InternalCompositePrice() (string, bool)

func (ProductDataWrapper) InternalTWAP added in v0.74.0 

func (f ProductDataWrapper) InternalTWAP() string

func (ProductDataWrapper) PriceType added in v0.74.0 

func (f ProductDataWrapper) PriceType() (vega.CompositePriceType, bool)

type RowWrapper 

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

func ParseTable 

func ParseTable(dt *godog.Table) []RowWrapper

ParseTable parses the table without verifying its integrity. Prefer the use of StrictParseTable().

func StrictParseFirstRow 

func StrictParseFirstRow(table *godog.Table, required, optional []string) RowWrapper

StrictParseFirstRow parses and verifies, table integrity and returns only the first row. This is suitable of table that act more as object than actual table.

func StrictParseTable 

func StrictParseTable(dt *godog.Table, required, optional []string) []RowWrapper

StrictParseTable parses and verifies the table integrity.

func (RowWrapper) Bool 

func (r RowWrapper) Bool(name string) bool

func (RowWrapper) Decimal 

func (r RowWrapper) Decimal(name string) num.Decimal

func (RowWrapper) DecimalB added in v0.73.0 

func (r RowWrapper) DecimalB(name string) (num.Decimal, bool)

func (RowWrapper) Duration 

func (r RowWrapper) Duration(name string) time.Duration

func (RowWrapper) DurationSec 

func (r RowWrapper) DurationSec(name string) time.Duration

func (RowWrapper) F64 

func (r RowWrapper) F64(name string) float64

func (RowWrapper) F64Slice 

func (r RowWrapper) F64Slice(name, sep string) []float64

func (RowWrapper) HasColumn 

func (r RowWrapper) HasColumn(name string) bool

func (RowWrapper) I64 

func (r RowWrapper) I64(name string) int64

func (RowWrapper) I64B 

func (r RowWrapper) I64B(name string) (int64, bool)

I64B does the same as U64B, but returns a bool indicating whether or not the column was set.

func (RowWrapper) I64Slice 

func (r RowWrapper) I64Slice(name, sep string) []int64

func (RowWrapper) MarkPriceType added in v0.74.0 

func (r RowWrapper) MarkPriceType() types.CompositePriceType

func (RowWrapper) MaybeU64 added in v0.74.0 

func (r RowWrapper) MaybeU64(name string) *uint64

func (RowWrapper) MaybeUint 

func (r RowWrapper) MaybeUint(name string) *num.Uint

func (RowWrapper) MustAccount 

func (r RowWrapper) MustAccount(name string) types.AccountType

func (RowWrapper) MustAuctionTrigger 

func (r RowWrapper) MustAuctionTrigger(name string) types.AuctionTrigger

func (RowWrapper) MustBool 

func (r RowWrapper) MustBool(name string) bool

func (RowWrapper) MustDecimal 

func (r RowWrapper) MustDecimal(name string) num.Decimal

func (RowWrapper) MustDuration 

func (r RowWrapper) MustDuration(name string) time.Duration

func (RowWrapper) MustDurationSec 

func (r RowWrapper) MustDurationSec(name string) time.Duration

func (RowWrapper) MustDurationSec2 added in v0.72.3 

func (r RowWrapper) MustDurationSec2(name string) time.Duration

func (RowWrapper) MustDurationStr 

func (r RowWrapper) MustDurationStr(name string) time.Duration

func (RowWrapper) MustEventType 

func (r RowWrapper) MustEventType(name string) events.Type

func (RowWrapper) MustExpiryStrategy added in v0.72.0 

func (r RowWrapper) MustExpiryStrategy(name string) types.StopOrderExpiryStrategy

func (RowWrapper) MustF64 

func (r RowWrapper) MustF64(name string) float64

func (RowWrapper) MustF64Slice 

func (r RowWrapper) MustF64Slice(name, sep string) []float64

func (RowWrapper) MustI64 

func (r RowWrapper) MustI64(name string) int64

func (RowWrapper) MustI64Slice 

func (r RowWrapper) MustI64Slice(name, sep string) []int64

func (RowWrapper) MustInt added in v0.73.14 

func (r RowWrapper) MustInt(name string) *num.Int

func (RowWrapper) MustLiquidityStatus 

func (r RowWrapper) MustLiquidityStatus(name string) types.LiquidityProvisionStatus

func (RowWrapper) MustMarketUpdateState added in v0.73.0 

func (r RowWrapper) MustMarketUpdateState(name string) types.MarketStateUpdateType

func (RowWrapper) MustOracleSpecConditionOperator 

func (r RowWrapper) MustOracleSpecConditionOperator(name string) datav1.Condition_Operator

func (RowWrapper) MustOracleSpecPropertyType 

func (r RowWrapper) MustOracleSpecPropertyType(name string) datav1.PropertyKey_Type

func (RowWrapper) MustOrderStatus 

func (r RowWrapper) MustOrderStatus(name string) types.OrderStatus

func (RowWrapper) MustOrderType 

func (r RowWrapper) MustOrderType(name string) types.OrderType

func (RowWrapper) MustPeggedReference 

func (r RowWrapper) MustPeggedReference(name string) types.PeggedReference

func (RowWrapper) MustPositionStatus added in v0.71.0 

func (r RowWrapper) MustPositionStatus(name string) proto.PositionStatus

func (RowWrapper) MustSide 

func (r RowWrapper) MustSide(name string) types.Side

func (RowWrapper) MustSizeOverrideSetting added in v0.74.0 

func (r RowWrapper) MustSizeOverrideSetting(name string) types.StopOrderSizeOverrideSetting

func (RowWrapper) MustStopOrderStatus added in v0.72.0 

func (r RowWrapper) MustStopOrderStatus(name string) types.StopOrderStatus

func (RowWrapper) MustStr 

func (r RowWrapper) MustStr(name string) string

func (RowWrapper) MustStrSlice 

func (r RowWrapper) MustStrSlice(name, sep string) []string

func (RowWrapper) MustTIF 

func (r RowWrapper) MustTIF(name string) types.OrderTimeInForce

func (RowWrapper) MustTime 

func (r RowWrapper) MustTime(name string) time.Time

func (RowWrapper) MustTradingMode 

func (r RowWrapper) MustTradingMode(name string) types.MarketTradingMode

func (RowWrapper) MustU32 

func (r RowWrapper) MustU32(name string) uint32

func (RowWrapper) MustU64 

func (r RowWrapper) MustU64(name string) uint64

func (RowWrapper) MustU64Slice 

func (r RowWrapper) MustU64Slice(name, sep string) []uint64

func (RowWrapper) MustUint 

func (r RowWrapper) MustUint(name string) *num.Uint

func (RowWrapper) Str 

func (r RowWrapper) Str(name string) string

func (RowWrapper) StrB 

func (r RowWrapper) StrB(name string) (string, bool)

StrB does the same as Str, but returns a bool indicating whether or not the column was set.

func (RowWrapper) StrSlice 

func (r RowWrapper) StrSlice(name, sep string) []string

func (RowWrapper) Time 

func (r RowWrapper) Time(name string) time.Time

func (RowWrapper) U32 

func (r RowWrapper) U32(name string) uint32

func (RowWrapper) U64 

func (r RowWrapper) U64(name string) uint64

func (RowWrapper) U64B 

func (r RowWrapper) U64B(name string) (uint64, bool)

U64B does the same as U64, but returns a bool indicating whether or not the column was set.

func (RowWrapper) U64Slice 

func (r RowWrapper) U64Slice(name, sep string) []uint64

func (RowWrapper) Uint 

func (r RowWrapper) Uint(name string) *num.Uint

type SubmitOrderError 

type SubmitOrderError struct {
	Err error
	// contains filtered or unexported fields
}

func (SubmitOrderError) Error 

func (s SubmitOrderError) Error() string

func (*SubmitOrderError) Unwrap 

func (s *SubmitOrderError) Unwrap() error

Source Files

View all Source files

Directories

Path Synopsis
defaults

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.