gql

package
v0.73.6 Latest Latest
Warning

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

Go to latest
Published: Nov 22, 2023 License: AGPL-3.0 Imports: 43 Imported by: 0

README

GraphQL

The query interface is accessible on http://localhost:3004/.

Types

Dates (time.Time)
  • Serialization type: String

Note Use vegatime.Format(vegatime.UnixNano(myDate)) to properly convert it.

How to's?
Add new GraphQL type
  1. Add the new type in schema.graphql
  2. Add binding between golang model and GraphQL type in gqlgen.yml
  3. Generate the GraphQL model and resolver with make gqlgen
  4. Create a new golang file my_type_resolver.go
  5. Implement the MyTypeResolver interface
    • This interface is located in generated.go
  6. Add a method MyType() on struct VegaResolverRoot in resolvers.go, as follows :
func (r *VegaResolverRoot) MyType() MyTypeResolver {
    return (*myTypeResolver)(r)
}
Add a new query?
  1. Add a new query in schema.graphql in the Query type
  2. Generate the GraphQL model and resolver with make gqlgen
  3. Add a method MyType() on struct myQueryResolver in resolvers.go, as follows :
func (r *myQueryResolver) MyType() types.MyType {
	res, err := r.tradingDataClient.MyType(
		ctx, &protoapi.MyTypeRequest{Id: id},
    )
    if err != nil {
   	    return nil, err
    }
   
   return res.MyType, nil
}

Documentation

Overview

Package gql contains code for running the GraphQL-to-gRPC gateway.

In order to add a new GraphQL endpoint, add an entry to either the `Mutation`, `Query` or `Subscription` sections of `gateway/graphql/schema.graphql`. Example:

# SomeNewEndpoint does something
somenewendpoint(
  # somestring
  someStr: String!,
  # someint
  someInt: Int!
): SomeNewEndpointResponse!

type SomeNewEndpointResponse {
  someAnswer: String!
  someStringList: [String!]
}

Then run `make gqlgen`.

Your new endpoint above will require a `SomeNewEndpointRequest` and `SomeNewEndpointResponse` message to be defined in the trading.proto file. Once this is defined you can run `make proto` to generate the structures required to add the resolvers below. e.g.

	message SomeNewEndpointRequest {
	  string orderID = 1;
	  string referenceID = 2;
 }

 message SomeNewEndpointResponse {
	vega.Order order = 1;
 }

Also a function definition needs to be defined in the trading.proto to show the parameters and return strutures for the new function e.g. rpc SomeNewEndpoint (SomeNewEndpointRequest) returns (SomeNewEndpointResponse)

Next, in `gateway/graphql/resolvers.go`, add the endpoint to the `TradingClient` interface if the new endpoint is a mutation, else add it to TradingDataClient if is it just a query, and add a function implementation, using the function definition from `generated.go`. Example:

type TradingClient interface {
    // ...
    SomeNewEndpoint(context.Context, *api.SomeNewEndpointRequest, ...grpc.CallOption) (*api.SomeNewEndpointResponse, error)
    // ...
}

// <<MQS>> is one of: Mutation, Query, Subscription
func (r *My<<MQS>>Resolver) SomeNewEndpoint(ctx context.Context, someStr string, someInt int64) (*SomeNewEndpointResponse, error) {
    req := &protoapi.SomeNewEndpointRequest{
        // ...
    }

    response, err := r.tradingClient.SomeNewEndpoint(ctx, req)
    if err != nil {
        return nil, err
    }

    return &SomeNewEndpointResponse{/* ... */}, nil
}

Now add the new function to the `trading.go` or `trading_data.go` package to actually perform the work

Lastly, make sure mocks are up to date, then run tests: `make mocks test`

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrNilTradingMode ...
	ErrNilTradingMode = errors.New("nil trading mode")
	// ErrAmbiguousTradingMode ...
	ErrAmbiguousTradingMode = errors.New("more than one trading mode selected")
	// ErrUnimplementedTradingMode ...
	ErrUnimplementedTradingMode = errors.New("unimplemented trading mode")
	// ErrNilProduct ...
	ErrNilProduct = errors.New("nil product")
	// ErrNilRiskModel ...
	ErrNilRiskModel = errors.New("nil risk model")
	// ErrInvalidChange ...
	ErrInvalidChange = errors.New("nil update market, new market and update network")
	// ErrNilAssetSource returned when an asset source is not specified at creation.
	ErrNilAssetSource = errors.New("nil asset source")
	// ErrUnimplementedAssetSource returned when an asset source specified at creation is not recognised.
	ErrUnimplementedAssetSource = errors.New("unimplemented asset source")
	// ErrMultipleProposalChangesSpecified is raised when multiple proposal changes are set
	// (non-null) for a singe proposal terms.
	ErrMultipleProposalChangesSpecified = errors.New("multiple proposal changes specified")
	// ErrMultipleAssetSourcesSpecified is raised when multiple asset source are specified.
	ErrMultipleAssetSourcesSpecified = errors.New("multiple asset sources specified")
	// ErrNilPriceMonitoringParameters ...
	ErrNilPriceMonitoringParameters = errors.New("nil price monitoring parameters")
)
View Source
var (
	// ErrMissingIDOrReference is returned when neither id nor reference has been supplied in the query.
	ErrMissingIDOrReference = errors.New("missing id or reference")
	// ErrMissingNodeID is returned when no node id has been supplied in the query.
	ErrMissingNodeID = errors.New("missing node id")
	// ErrInvalidVotesSubscription is returned if neither proposal ID nor party ID is specified.
	ErrInvalidVotesSubscription = errors.New("invalid subscription, either proposal or party ID required")
	// ErrInvalidProposal is returned when invalid governance data is received by proposal resolver.
	ErrInvalidProposal = errors.New("invalid proposal")
	// ErrInvalidStopOrder is returned when an invalid stop order is received by the stop order resolver.
	ErrInvalidStopOrder = errors.New("invalid stop order")
)
View Source
var ErrUnsupportedProduct = errors.New("unsupported product")
View Source
var ErrUnsupportedProposalTermsChanges = errors.New("unsupported proposal terms changes")
View Source
var ErrUnsupportedTransferKind = errors.New("unsupported transfer kind")

Functions

func NewExecutableSchema

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

Types

type AccountBalanceResolver added in v0.59.0

type AccountBalanceResolver interface {
	Asset(ctx context.Context, obj *v2.AccountBalance) (*vega.Asset, error)

	Market(ctx context.Context, obj *v2.AccountBalance) (*vega.Market, error)
	Party(ctx context.Context, obj *v2.AccountBalance) (*vega.Party, error)
}

type AccountDetailsResolver added in v0.56.0

type AccountDetailsResolver interface {
	PartyID(ctx context.Context, obj *vega.AccountDetails) (*string, error)
}

type AccountEventResolver added in v0.59.0

type AccountEventResolver interface {
	Asset(ctx context.Context, obj *vega.Account) (*vega.Asset, error)

	Market(ctx context.Context, obj *vega.Account) (*vega.Market, error)
	Party(ctx context.Context, obj *vega.Account) (*vega.Party, error)
}

type AccountUpdateResolver added in v0.55.0

type AccountUpdateResolver interface {
	AssetID(ctx context.Context, obj *v2.AccountBalance) (string, error)

	PartyID(ctx context.Context, obj *v2.AccountBalance) (string, error)
}

type AggregatedLedgerEntryResolver added in v0.63.0

type AggregatedLedgerEntryResolver interface {
	VegaTime(ctx context.Context, obj *v2.AggregatedLedgerEntry) (int64, error)
}

type AssetResolver

type AssetResolver interface {
	Name(ctx context.Context, obj *vega.Asset) (string, error)
	Symbol(ctx context.Context, obj *vega.Asset) (string, error)
	Decimals(ctx context.Context, obj *vega.Asset) (int, error)
	Quantum(ctx context.Context, obj *vega.Asset) (string, error)
	Source(ctx context.Context, obj *vega.Asset) (AssetSource, error)

	InfrastructureFeeAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
	GlobalRewardPoolAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
	GlobalInsuranceAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
	NetworkTreasuryAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
	TakerFeeRewardAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
	MakerFeeRewardAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
	LpFeeRewardAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
	MarketProposerRewardAccount(ctx context.Context, obj *vega.Asset) (*v2.AccountBalance, error)
}

type AssetSource

type AssetSource interface {
	IsAssetSource()
}

One of the possible asset sources

func AssetSourceFromProto

func AssetSourceFromProto(pdetails *types.AssetDetails) (AssetSource, error)

type AuctionDuration

type AuctionDuration struct {
	// Duration of the auction in seconds
	DurationSecs int `json:"durationSecs"`
	// Target uncrossing trading volume
	Volume int `json:"volume"`
}

An auction duration is used to configure 3 auction periods: 1. `duration > 0`, `volume == 0`: The auction will last for at least N seconds. 2. `duration == 0`, `volume > 0`: The auction will end once the given volume will match at uncrossing. 3. `duration > 0`, `volume > 0`: The auction will take at least N seconds, but can end sooner if the market can trade a certain volume.

type AuctionEventResolver

type AuctionEventResolver interface {
	AuctionStart(ctx context.Context, obj *v1.AuctionEvent) (int64, error)
	AuctionEnd(ctx context.Context, obj *v1.AuctionEvent) (int64, error)
}

type BenefitTierResolver added in v0.73.0

type BenefitTierResolver interface {
	MinimumEpochs(ctx context.Context, obj *vega.BenefitTier) (int, error)
}

type BuiltinAsset

type BuiltinAsset struct {
	// Maximum amount that can be requested by a party through the built-in asset faucet at a time
	MaxFaucetAmountMint string `json:"maxFaucetAmountMint"`
}

A Vega builtin asset, mostly for testing purpose

func BuiltinAssetFromProto

func BuiltinAssetFromProto(ba *types.BuiltinAsset) *BuiltinAsset

func (BuiltinAsset) IsAssetSource

func (BuiltinAsset) IsAssetSource()

type BusEvent

type BusEvent struct {
	// The ID for this event
	ID string `json:"id"`
	// The block hash
	Block string `json:"block"`
	// The type of event
	Type BusEventType `json:"type"`
	// The payload - the wrapped event
	Event Event `json:"event"`
}

type BusEventType

type BusEventType string

Event types

const (
	// Vega Time has changed
	BusEventTypeTimeUpdate BusEventType = "TimeUpdate"
	// Collateral has deposited in to this Vega network via the bridge
	BusEventTypeDeposit BusEventType = "Deposit"
	// Collateral has been withdrawn from this Vega network via the bridge
	BusEventTypeWithdrawal BusEventType = "Withdrawal"
	// The results from processing at transaction
	BusEventTypeTransactionResult BusEventType = "TransactionResult"
)

func (BusEventType) IsValid

func (e BusEventType) IsValid() bool

func (BusEventType) MarshalGQL

func (e BusEventType) MarshalGQL(w io.Writer)

func (BusEventType) String

func (e BusEventType) String() string

func (*BusEventType) UnmarshalGQL

func (e *BusEventType) UnmarshalGQL(v interface{}) error

type CancelTransferResolver added in v0.72.0

type CancelTransferResolver interface {
	TransferID(ctx context.Context, obj *vega.CancelTransfer) (string, error)
}

type CandleResolver

type CandleResolver interface {
	PeriodStart(ctx context.Context, obj *v2.Candle) (int64, error)
	LastUpdateInPeriod(ctx context.Context, obj *v2.Candle) (int64, error)

	Volume(ctx context.Context, obj *v2.Candle) (string, error)
	Notional(ctx context.Context, obj *v2.Candle) (string, error)
}

type ComplexityRoot

type ComplexityRoot struct {
	AccountBalance struct {
		Asset   func(childComplexity int) int
		Balance func(childComplexity int) int
		Market  func(childComplexity int) int
		Party   func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	AccountDetails struct {
		AssetId  func(childComplexity int) int
		MarketId func(childComplexity int) int
		PartyID  func(childComplexity int) int
		Type     func(childComplexity int) int
	}

	AccountEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	AccountEvent struct {
		Asset   func(childComplexity int) int
		Balance func(childComplexity int) int
		Market  func(childComplexity int) int
		Party   func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	AccountUpdate struct {
		AssetID  func(childComplexity int) int
		Balance  func(childComplexity int) int
		MarketId func(childComplexity int) int
		PartyID  func(childComplexity int) int
		Type     func(childComplexity int) int
	}

	AccountsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	AggregatedBalance struct {
		AccountType func(childComplexity int) int
		AssetId     func(childComplexity int) int
		Balance     func(childComplexity int) int
		MarketId    func(childComplexity int) int
		PartyId     func(childComplexity int) int
		Timestamp   func(childComplexity int) int
	}

	AggregatedBalanceConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	AggregatedBalanceEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	AggregatedLedgerEntriesConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	AggregatedLedgerEntriesEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	AggregatedLedgerEntry struct {
		AssetId             func(childComplexity int) int
		FromAccountBalance  func(childComplexity int) int
		FromAccountMarketId func(childComplexity int) int
		FromAccountPartyId  func(childComplexity int) int
		FromAccountType     func(childComplexity int) int
		Quantity            func(childComplexity int) int
		ToAccountBalance    func(childComplexity int) int
		ToAccountMarketId   func(childComplexity int) int
		ToAccountPartyId    func(childComplexity int) int
		ToAccountType       func(childComplexity int) int
		TransferType        func(childComplexity int) int
		VegaTime            func(childComplexity int) int
	}

	Asset struct {
		Decimals                    func(childComplexity int) int
		GlobalInsuranceAccount      func(childComplexity int) int
		GlobalRewardPoolAccount     func(childComplexity int) int
		Id                          func(childComplexity int) int
		InfrastructureFeeAccount    func(childComplexity int) int
		LpFeeRewardAccount          func(childComplexity int) int
		MakerFeeRewardAccount       func(childComplexity int) int
		MarketProposerRewardAccount func(childComplexity int) int
		Name                        func(childComplexity int) int
		NetworkTreasuryAccount      func(childComplexity int) int
		Quantum                     func(childComplexity int) int
		Source                      func(childComplexity int) int
		Status                      func(childComplexity int) int
		Symbol                      func(childComplexity int) int
		TakerFeeRewardAccount       func(childComplexity int) int
	}

	AssetEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	AssetsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	AuctionDuration struct {
		DurationSecs func(childComplexity int) int
		Volume       func(childComplexity int) int
	}

	AuctionEvent struct {
		AuctionEnd       func(childComplexity int) int
		AuctionStart     func(childComplexity int) int
		ExtensionTrigger func(childComplexity int) int
		Leave            func(childComplexity int) int
		MarketId         func(childComplexity int) int
		OpeningAuction   func(childComplexity int) int
		Trigger          func(childComplexity int) int
	}

	BenefitTier struct {
		MinimumEpochs                     func(childComplexity int) int
		MinimumRunningNotionalTakerVolume func(childComplexity int) int
		ReferralDiscountFactor            func(childComplexity int) int
		ReferralRewardFactor              func(childComplexity int) int
	}

	BuiltinAsset struct {
		MaxFaucetAmountMint func(childComplexity int) int
	}

	BusEvent struct {
		Block func(childComplexity int) int
		Event func(childComplexity int) int
		ID    func(childComplexity int) int
		Type  func(childComplexity int) int
	}

	CancelTransfer struct {
		TransferID func(childComplexity int) int
	}

	Candle struct {
		Close              func(childComplexity int) int
		High               func(childComplexity int) int
		LastUpdateInPeriod func(childComplexity int) int
		Low                func(childComplexity int) int
		Notional           func(childComplexity int) int
		Open               func(childComplexity int) int
		PeriodStart        func(childComplexity int) int
		Volume             func(childComplexity int) int
	}

	CandleDataConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	CandleEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	Condition struct {
		Operator func(childComplexity int) int
		Value    func(childComplexity int) int
	}

	ContinuousTrading struct {
		TickSize func(childComplexity int) int
	}

	CoreSnapshotConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	CoreSnapshotData struct {
		BlockHash       func(childComplexity int) int
		BlockHeight     func(childComplexity int) int
		VegaCoreVersion func(childComplexity int) int
	}

	CoreSnapshotEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	CurrentReferralProgram struct {
		BenefitTiers          func(childComplexity int) int
		EndOfProgramTimestamp func(childComplexity int) int
		EndedAt               func(childComplexity int) int
		Id                    func(childComplexity int) int
		StakingTiers          func(childComplexity int) int
		Version               func(childComplexity int) int
		WindowLength          func(childComplexity int) int
	}

	Data struct {
		BroadcastAt    func(childComplexity int) int
		Data           func(childComplexity int) int
		MatchedSpecIds func(childComplexity int) int
		MetaData       func(childComplexity int) int
		Signers        func(childComplexity int) int
	}

	DataSourceDefinition struct {
		SourceType func(childComplexity int) int
	}

	DataSourceDefinitionExternal struct {
		SourceType func(childComplexity int) int
	}

	DataSourceDefinitionInternal struct {
		SourceType func(childComplexity int) int
	}

	DataSourceSpec struct {
		CreatedAt func(childComplexity int) int
		Data      func(childComplexity int) int
		ID        func(childComplexity int) int
		Status    func(childComplexity int) int
		UpdatedAt func(childComplexity int) int
	}

	DataSourceSpecConfiguration struct {
		Filters func(childComplexity int) int
		Signers func(childComplexity int) int
	}

	DataSourceSpecConfigurationTime struct {
		Conditions func(childComplexity int) int
	}

	DataSourceSpecConfigurationTimeTrigger struct {
		Conditions func(childComplexity int) int
		Triggers   func(childComplexity int) int
	}

	DataSourceSpecPerpetualBinding struct {
		SettlementDataProperty     func(childComplexity int) int
		SettlementScheduleProperty func(childComplexity int) int
	}

	DataSourceSpecToFutureBinding struct {
		SettlementDataProperty     func(childComplexity int) int
		TradingTerminationProperty func(childComplexity int) int
	}

	Delegation struct {
		Amount func(childComplexity int) int
		Epoch  func(childComplexity int) int
		Node   func(childComplexity int) int
		Party  func(childComplexity int) int
	}

	DelegationEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	DelegationsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	Deposit struct {
		Amount            func(childComplexity int) int
		Asset             func(childComplexity int) int
		CreatedTimestamp  func(childComplexity int) int
		CreditedTimestamp func(childComplexity int) int
		Id                func(childComplexity int) int
		Party             func(childComplexity int) int
		Status            func(childComplexity int) int
		TxHash            func(childComplexity int) int
	}

	DepositEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	DepositsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	DiscreteTrading struct {
		Duration func(childComplexity int) int
		TickSize func(childComplexity int) int
	}

	DispatchStrategy struct {
		DispatchMetric                                 func(childComplexity int) int
		DispatchMetricAssetID                          func(childComplexity int) int
		DistributionStrategy                           func(childComplexity int) int
		EntityScope                                    func(childComplexity int) int
		IndividualScope                                func(childComplexity int) int
		LockPeriod                                     func(childComplexity int) int
		MarketIdsInScope                               func(childComplexity int) int
		NTopPerformers                                 func(childComplexity int) int
		NotionalTimeWeightedAveragePositionRequirement func(childComplexity int) int
		RankTable                                      func(childComplexity int) int
		StakingRequirement                             func(childComplexity int) int
		TeamScope                                      func(childComplexity int) int
		WindowLength                                   func(childComplexity int) int
	}

	ERC20 struct {
		ContractAddress   func(childComplexity int) int
		LifetimeLimit     func(childComplexity int) int
		WithdrawThreshold func(childComplexity int) int
	}

	ERC20MultiSigSignerAddedBundle struct {
		EpochSeq   func(childComplexity int) int
		NewSigner  func(childComplexity int) int
		Nonce      func(childComplexity int) int
		Signatures func(childComplexity int) int
		Submitter  func(childComplexity int) int
		Timestamp  func(childComplexity int) int
	}

	ERC20MultiSigSignerAddedBundleEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ERC20MultiSigSignerAddedConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ERC20MultiSigSignerRemovedBundle struct {
		EpochSeq   func(childComplexity int) int
		Nonce      func(childComplexity int) int
		OldSigner  func(childComplexity int) int
		Signatures func(childComplexity int) int
		Submitter  func(childComplexity int) int
		Timestamp  func(childComplexity int) int
	}

	ERC20MultiSigSignerRemovedBundleEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ERC20MultiSigSignerRemovedConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ERC20SetAssetLimitsBundle struct {
		AssetSource   func(childComplexity int) int
		LifetimeLimit func(childComplexity int) int
		Nonce         func(childComplexity int) int
		Signatures    func(childComplexity int) int
		Threshold     func(childComplexity int) int
		VegaAssetID   func(childComplexity int) int
	}

	ETHAddress struct {
		Address func(childComplexity int) int
	}

	Entities struct {
		Accounts                          func(childComplexity int) int
		Assets                            func(childComplexity int) int
		BalanceChanges                    func(childComplexity int) int
		Delegations                       func(childComplexity int) int
		Deposits                          func(childComplexity int) int
		Erc20MultiSigSignerAddedBundles   func(childComplexity int) int
		Erc20MultiSigSignerRemovedBundles func(childComplexity int) int
		EthereumKeyRotations              func(childComplexity int) int
		KeyRotations                      func(childComplexity int) int
		LedgerEntries                     func(childComplexity int) int
		LiquidityProvisions               func(childComplexity int) int
		MarginLevels                      func(childComplexity int) int
		Markets                           func(childComplexity int) int
		NetworkParameters                 func(childComplexity int) int
		NodeSignatures                    func(childComplexity int) int
		Nodes                             func(childComplexity int) int
		OracleData                        func(childComplexity int) int
		OracleSpecs                       func(childComplexity int) int
		Orders                            func(childComplexity int) int
		Parties                           func(childComplexity int) int
		Positions                         func(childComplexity int) int
		Proposals                         func(childComplexity int) int
		ProtocolUpgradeProposals          func(childComplexity int) int
		Rewards                           func(childComplexity int) int
		Trades                            func(childComplexity int) int
		Transfers                         func(childComplexity int) int
		Votes                             func(childComplexity int) int
		Withdrawals                       func(childComplexity int) int
	}

	Epoch struct {
		DelegationsConnection func(childComplexity int, partyID *string, nodeID *string, pagination *v2.Pagination) int
		ID                    func(childComplexity int) int
		Timestamps            func(childComplexity int) int
		ValidatorsConnection  func(childComplexity int, pagination *v2.Pagination) int
	}

	EpochData struct {
		Offline func(childComplexity int) int
		Online  func(childComplexity int) int
		Total   func(childComplexity int) int
	}

	EpochParticipation struct {
		Epoch        func(childComplexity int) int
		Offline      func(childComplexity int) int
		Online       func(childComplexity int) int
		TotalRewards func(childComplexity int) int
	}

	EpochRewardSummary struct {
		Amount     func(childComplexity int) int
		AssetId    func(childComplexity int) int
		Epoch      func(childComplexity int) int
		MarketId   func(childComplexity int) int
		RewardType func(childComplexity int) int
	}

	EpochRewardSummaryConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	EpochRewardSummaryEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	EpochTimestamps struct {
		End        func(childComplexity int) int
		Expiry     func(childComplexity int) int
		FirstBlock func(childComplexity int) int
		LastBlock  func(childComplexity int) int
		Start      func(childComplexity int) int
	}

	Erc20ListAssetBundle struct {
		AssetSource func(childComplexity int) int
		Nonce       func(childComplexity int) int
		Signatures  func(childComplexity int) int
		VegaAssetID func(childComplexity int) int
	}

	Erc20WithdrawalApproval struct {
		Amount        func(childComplexity int) int
		AssetSource   func(childComplexity int) int
		Creation      func(childComplexity int) int
		Nonce         func(childComplexity int) int
		Signatures    func(childComplexity int) int
		TargetAddress func(childComplexity int) int
	}

	Erc20WithdrawalDetails struct {
		ReceiverAddress func(childComplexity int) int
	}

	EthCallSpec struct {
		Abi                   func(childComplexity int) int
		Address               func(childComplexity int) int
		Args                  func(childComplexity int) int
		Filters               func(childComplexity int) int
		Method                func(childComplexity int) int
		Normalisers           func(childComplexity int) int
		RequiredConfirmations func(childComplexity int) int
		Trigger               func(childComplexity int) int
	}

	EthCallTrigger struct {
		Trigger func(childComplexity int) int
	}

	EthTimeTrigger struct {
		Every   func(childComplexity int) int
		Initial func(childComplexity int) int
		Until   func(childComplexity int) int
	}

	EthereumEvent struct {
		ContractID func(childComplexity int) int
		Event      func(childComplexity int) int
	}

	EthereumKeyRotation struct {
		BlockHeight func(childComplexity int) int
		NewAddress  func(childComplexity int) int
		NodeId      func(childComplexity int) int
		OldAddress  func(childComplexity int) int
	}

	EthereumKeyRotationEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	EthereumKeyRotationsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ExternalData struct {
		Data func(childComplexity int) int
	}

	ExternalDataSourceSpec struct {
		Spec func(childComplexity int) int
	}

	FeeEstimate struct {
		Fees           func(childComplexity int) int
		TotalFeeAmount func(childComplexity int) int
	}

	FeeFactors struct {
		InfrastructureFee func(childComplexity int) int
		LiquidityFee      func(childComplexity int) int
		MakerFee          func(childComplexity int) int
	}

	Fees struct {
		Factors func(childComplexity int) int
	}

	FeesStats struct {
		AssetID                  func(childComplexity int) int
		Epoch                    func(childComplexity int) int
		MakerFeesGenerated       func(childComplexity int) int
		MarketID                 func(childComplexity int) int
		RefereesDiscountApplied  func(childComplexity int) int
		ReferrerRewardsGenerated func(childComplexity int) int
		TotalMakerFeesReceived   func(childComplexity int) int
		TotalRewardsReceived     func(childComplexity int) int
		VolumeDiscountApplied    func(childComplexity int) int
	}

	FeesStatsForParty struct {
		AssetId                 func(childComplexity int) int
		RefereesDiscountApplied func(childComplexity int) int
		TotalMakerFeesReceived  func(childComplexity int) int
		TotalRewardsReceived    func(childComplexity int) int
		VolumeDiscountApplied   func(childComplexity int) int
	}

	Filter struct {
		Conditions func(childComplexity int) int
		Key        func(childComplexity int) int
	}

	FundingPayment struct {
		Amount           func(childComplexity int) int
		FundingPeriodSeq func(childComplexity int) int
		MarketId         func(childComplexity int) int
		PartyId          func(childComplexity int) int
		Timestamp        func(childComplexity int) int
	}

	FundingPaymentConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	FundingPaymentEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	FundingPeriod struct {
		EndTime        func(childComplexity int) int
		ExternalTwap   func(childComplexity int) int
		FundingPayment func(childComplexity int) int
		FundingRate    func(childComplexity int) int
		InternalTwap   func(childComplexity int) int
		MarketId       func(childComplexity int) int
		Seq            func(childComplexity int) int
		StartTime      func(childComplexity int) int
	}

	FundingPeriodConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	FundingPeriodDataPoint struct {
		DataPointSource func(childComplexity int) int
		MarketId        func(childComplexity int) int
		Price           func(childComplexity int) int
		Seq             func(childComplexity int) int
		Timestamp       func(childComplexity int) int
		Twap            func(childComplexity int) int
	}

	FundingPeriodDataPointConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	FundingPeriodDataPointEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	FundingPeriodEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	Future struct {
		DataSourceSpecBinding               func(childComplexity int) int
		DataSourceSpecForSettlementData     func(childComplexity int) int
		DataSourceSpecForTradingTermination func(childComplexity int) int
		QuoteName                           func(childComplexity int) int
		SettlementAsset                     func(childComplexity int) int
	}

	FutureProduct struct {
		DataSourceSpecBinding               func(childComplexity int) int
		DataSourceSpecForSettlementData     func(childComplexity int) int
		DataSourceSpecForTradingTermination func(childComplexity int) int
		QuoteName                           func(childComplexity int) int
		SettlementAsset                     func(childComplexity int) int
	}

	HistorySegment struct {
		FromHeight       func(childComplexity int) int
		HistorySegmentId func(childComplexity int) int
		ToHeight         func(childComplexity int) int
	}

	IcebergOrder struct {
		MinimumVisibleSize func(childComplexity int) int
		PeakSize           func(childComplexity int) int
		ReservedRemaining  func(childComplexity int) int
	}

	Instrument struct {
		Code     func(childComplexity int) int
		Id       func(childComplexity int) int
		Metadata func(childComplexity int) int
		Name     func(childComplexity int) int
		Product  func(childComplexity int) int
	}

	InstrumentConfiguration struct {
		Code          func(childComplexity int) int
		FutureProduct func(childComplexity int) int
		Name          func(childComplexity int) int
		Product       func(childComplexity int) int
	}

	InstrumentMetadata struct {
		Tags func(childComplexity int) int
	}

	InternalTimeTrigger struct {
		Every   func(childComplexity int) int
		Initial func(childComplexity int) int
	}

	KeyRotation struct {
		BlockHeight func(childComplexity int) int
		NewPubKey   func(childComplexity int) int
		NodeId      func(childComplexity int) int
		OldPubKey   func(childComplexity int) int
	}

	KeyRotationConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	KeyRotationEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	LedgerEntry struct {
		Amount             func(childComplexity int) int
		FromAccountBalance func(childComplexity int) int
		FromAccountID      func(childComplexity int) int
		Timestamp          func(childComplexity int) int
		ToAccountBalance   func(childComplexity int) int
		ToAccountID        func(childComplexity int) int
		Type               func(childComplexity int) int
	}

	LiquidationEstimate struct {
		BestCase  func(childComplexity int) int
		WorstCase func(childComplexity int) int
	}

	LiquidationPrice struct {
		IncludingBuyOrders  func(childComplexity int) int
		IncludingSellOrders func(childComplexity int) int
		OpenVolumeOnly      func(childComplexity int) int
	}

	LiquidityMonitoringParameters struct {
		AuctionExtensionSecs  func(childComplexity int) int
		TargetStakeParameters func(childComplexity int) int
		TriggeringRatio       func(childComplexity int) int
	}

	LiquidityOrder struct {
		Offset     func(childComplexity int) int
		Proportion func(childComplexity int) int
		Reference  func(childComplexity int) int
	}

	LiquidityOrderReference struct {
		LiquidityOrder func(childComplexity int) int
		Order          func(childComplexity int) int
	}

	LiquidityProvider struct {
		FeeShare func(childComplexity int) int
		MarketId func(childComplexity int) int
		PartyId  func(childComplexity int) int
		SLA      func(childComplexity int) int
	}

	LiquidityProviderConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	LiquidityProviderEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	LiquidityProviderFeeShare struct {
		AverageEntryValuation func(childComplexity int) int
		AverageScore          func(childComplexity int) int
		EquityLikeShare       func(childComplexity int) int
		Party                 func(childComplexity int) int
		VirtualStake          func(childComplexity int) int
	}

	LiquidityProviderSLA struct {
		CurrentEpochFractionOfTimeOnBook func(childComplexity int) int
		HysteresisPeriodFeePenalties     func(childComplexity int) int
		LastEpochBondPenalty             func(childComplexity int) int
		LastEpochFeePenalty              func(childComplexity int) int
		LastEpochFractionOfTimeOnBook    func(childComplexity int) int
		NotionalVolumeBuys               func(childComplexity int) int
		NotionalVolumeSells              func(childComplexity int) int
		Party                            func(childComplexity int) int
		RequiredLiquidity                func(childComplexity int) int
	}

	LiquidityProvision struct {
		Buys             func(childComplexity int) int
		CommitmentAmount func(childComplexity int) int
		CreatedAt        func(childComplexity int) int
		Fee              func(childComplexity int) int
		Id               func(childComplexity int) int
		Market           func(childComplexity int) int
		Party            func(childComplexity int) int
		Reference        func(childComplexity int) int
		Sells            func(childComplexity int) int
		Status           func(childComplexity int) int
		UpdatedAt        func(childComplexity int) int
		Version          func(childComplexity int) int
	}

	LiquidityProvisionUpdate struct {
		Buys             func(childComplexity int) int
		CommitmentAmount func(childComplexity int) int
		CreatedAt        func(childComplexity int) int
		Fee              func(childComplexity int) int
		Id               func(childComplexity int) int
		MarketId         func(childComplexity int) int
		PartyId          func(childComplexity int) int
		Reference        func(childComplexity int) int
		Sells            func(childComplexity int) int
		Status           func(childComplexity int) int
		UpdatedAt        func(childComplexity int) int
		Version          func(childComplexity int) int
	}

	LiquidityProvisionWithPending struct {
		Current func(childComplexity int) int
		Pending func(childComplexity int) int
	}

	LiquidityProvisionWithPendingEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	LiquidityProvisionsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	LiquidityProvisionsEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	LiquidityProvisionsWithPendingConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	LiquiditySLAParameters struct {
		CommitmentMinTimeFraction   func(childComplexity int) int
		PerformanceHysteresisEpochs func(childComplexity int) int
		PriceRange                  func(childComplexity int) int
		SlaCompetitionFactor        func(childComplexity int) int
	}

	LogNormalModelParams struct {
		Mu    func(childComplexity int) int
		R     func(childComplexity int) int
		Sigma func(childComplexity int) int
	}

	LogNormalRiskModel struct {
		Params                func(childComplexity int) int
		RiskAversionParameter func(childComplexity int) int
		Tau                   func(childComplexity int) int
	}

	LossSocialization struct {
		Amount   func(childComplexity int) int
		MarketID func(childComplexity int) int
		PartyID  func(childComplexity int) int
	}

	MakerFeesGenerated struct {
		MakerFeesPaid func(childComplexity int) int
		Taker         func(childComplexity int) int
	}

	MarginCalculator struct {
		ScalingFactors func(childComplexity int) int
	}

	MarginConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	MarginEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	MarginEstimate struct {
		BestCase  func(childComplexity int) int
		WorstCase func(childComplexity int) int
	}

	MarginLevels struct {
		Asset                  func(childComplexity int) int
		CollateralReleaseLevel func(childComplexity int) int
		InitialLevel           func(childComplexity int) int
		MaintenanceLevel       func(childComplexity int) int
		Market                 func(childComplexity int) int
		Party                  func(childComplexity int) int
		SearchLevel            func(childComplexity int) int
		Timestamp              func(childComplexity int) int
	}

	MarginLevelsUpdate struct {
		Asset                  func(childComplexity int) int
		CollateralReleaseLevel func(childComplexity int) int
		InitialLevel           func(childComplexity int) int
		MaintenanceLevel       func(childComplexity int) int
		MarketId               func(childComplexity int) int
		PartyId                func(childComplexity int) int
		SearchLevel            func(childComplexity int) int
		Timestamp              func(childComplexity int) int
	}

	Market struct {
		AccountsConnection            func(childComplexity int, partyID *string, pagination *v2.Pagination) int
		CandlesConnection             func(childComplexity int, since string, to *string, interval vega.Interval, pagination *v2.Pagination) int
		Data                          func(childComplexity int) int
		DecimalPlaces                 func(childComplexity int) int
		Depth                         func(childComplexity int, maxDepth *int) int
		Fees                          func(childComplexity int) int
		Id                            func(childComplexity int) int
		InsurancePoolFraction         func(childComplexity int) int
		LinearSlippageFactor          func(childComplexity int) int
		LiquidityMonitoringParameters func(childComplexity int) int
		LiquidityProvisions           func(childComplexity int, partyID *string, live *bool, pagination *v2.Pagination) int
		LiquidityProvisionsConnection func(childComplexity int, partyID *string, live *bool, pagination *v2.Pagination) int
		LiquiditySLAParameters        func(childComplexity int) int
		MarketTimestamps              func(childComplexity int) int
		OpeningAuction                func(childComplexity int) int
		OrdersConnection              func(childComplexity int, pagination *v2.Pagination, filter *OrderByPartyIdsFilter) int
		ParentMarketId                func(childComplexity int) int
		PositionDecimalPlaces         func(childComplexity int) int
		PriceMonitoringSettings       func(childComplexity int) int
		Proposal                      func(childComplexity int) int
		QuadraticSlippageFactor       func(childComplexity int) int
		RiskFactors                   func(childComplexity int) int
		State                         func(childComplexity int) int
		SuccessorMarketId             func(childComplexity int) int
		TradableInstrument            func(childComplexity int) int
		TradesConnection              func(childComplexity int, dateRange *v2.DateRange, pagination *v2.Pagination) int
		TradingMode                   func(childComplexity int) int
	}

	MarketConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	MarketData struct {
		AuctionEnd                func(childComplexity int) int
		AuctionStart              func(childComplexity int) int
		BestBidPrice              func(childComplexity int) int
		BestBidVolume             func(childComplexity int) int
		BestOfferPrice            func(childComplexity int) int
		BestOfferVolume           func(childComplexity int) int
		BestStaticBidPrice        func(childComplexity int) int
		BestStaticBidVolume       func(childComplexity int) int
		BestStaticOfferPrice      func(childComplexity int) int
		BestStaticOfferVolume     func(childComplexity int) int
		Commitments               func(childComplexity int) int
		ExtensionTrigger          func(childComplexity int) int
		IndicativePrice           func(childComplexity int) int
		IndicativeVolume          func(childComplexity int) int
		LastTradedPrice           func(childComplexity int) int
		LiquidityProviderFeeShare func(childComplexity int) int
		LiquidityProviderSLA      func(childComplexity int) int
		MarkPrice                 func(childComplexity int) int
		Market                    func(childComplexity int) int
		MarketGrowth              func(childComplexity int) int
		MarketState               func(childComplexity int) int
		MarketTradingMode         func(childComplexity int) int
		MarketValueProxy          func(childComplexity int) int
		MidPrice                  func(childComplexity int) int
		NextMarkToMarket          func(childComplexity int) int
		OpenInterest              func(childComplexity int) int
		PriceMonitoringBounds     func(childComplexity int) int
		ProductData               func(childComplexity int) int
		StaticMidPrice            func(childComplexity int) int
		SuppliedStake             func(childComplexity int) int
		TargetStake               func(childComplexity int) int
		Timestamp                 func(childComplexity int) int
		Trigger                   func(childComplexity int) int
	}

	MarketDataCommitments struct {
		Buys  func(childComplexity int) int
		Sells func(childComplexity int) int
	}

	MarketDataConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	MarketDataEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	MarketDepth struct {
		Buy            func(childComplexity int) int
		LastTrade      func(childComplexity int) int
		Market         func(childComplexity int) int
		Sell           func(childComplexity int) int
		SequenceNumber func(childComplexity int) int
	}

	MarketDepthTrade struct {
		ID    func(childComplexity int) int
		Price func(childComplexity int) int
		Size  func(childComplexity int) int
	}

	MarketDepthUpdate struct {
		Buy                    func(childComplexity int) int
		Market                 func(childComplexity int) int
		PreviousSequenceNumber func(childComplexity int) int
		Sell                   func(childComplexity int) int
		SequenceNumber         func(childComplexity int) int
	}

	MarketEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	MarketEvent struct {
		MarketID func(childComplexity int) int
		Payload  func(childComplexity int) int
	}

	MarketTick struct {
		MarketID func(childComplexity int) int
		Time     func(childComplexity int) int
	}

	MarketTimestamps struct {
		Close    func(childComplexity int) int
		Open     func(childComplexity int) int
		Pending  func(childComplexity int) int
		Proposed func(childComplexity int) int
	}

	NetworkLimits struct {
		CanProposeAsset          func(childComplexity int) int
		CanProposeMarket         func(childComplexity int) int
		GenesisLoaded            func(childComplexity int) int
		ProposeAssetEnabled      func(childComplexity int) int
		ProposeAssetEnabledFrom  func(childComplexity int) int
		ProposeMarketEnabled     func(childComplexity int) int
		ProposeMarketEnabledFrom func(childComplexity int) int
	}

	NetworkParameter struct {
		Key   func(childComplexity int) int
		Value func(childComplexity int) int
	}

	NetworkParameterEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	NetworkParametersConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	NewAsset struct {
		Decimals func(childComplexity int) int
		Name     func(childComplexity int) int
		Quantum  func(childComplexity int) int
		Source   func(childComplexity int) int
		Symbol   func(childComplexity int) int
	}

	NewFreeform struct {
		DoNotUse func(childComplexity int) int
	}

	NewMarket struct {
		DecimalPlaces                 func(childComplexity int) int
		Instrument                    func(childComplexity int) int
		LinearSlippageFactor          func(childComplexity int) int
		LiquidityMonitoringParameters func(childComplexity int) int
		LiquiditySLAParameters        func(childComplexity int) int
		Metadata                      func(childComplexity int) int
		PositionDecimalPlaces         func(childComplexity int) int
		PriceMonitoringParameters     func(childComplexity int) int
		QuadraticSlippageFactor       func(childComplexity int) int
		RiskParameters                func(childComplexity int) int
		SuccessorConfiguration        func(childComplexity int) int
	}

	NewSpotMarket struct {
		DecimalPlaces             func(childComplexity int) int
		Instrument                func(childComplexity int) int
		LiquiditySLAParams        func(childComplexity int) int
		Metadata                  func(childComplexity int) int
		PositionDecimalPlaces     func(childComplexity int) int
		PriceMonitoringParameters func(childComplexity int) int
		RiskParameters            func(childComplexity int) int
		TargetStakeParameters     func(childComplexity int) int
	}

	NewTransfer struct {
		Amount            func(childComplexity int) int
		Asset             func(childComplexity int) int
		Destination       func(childComplexity int) int
		DestinationType   func(childComplexity int) int
		FractionOfBalance func(childComplexity int) int
		Kind              func(childComplexity int) int
		Source            func(childComplexity int) int
		SourceType        func(childComplexity int) int
		TransferType      func(childComplexity int) int
	}

	Node struct {
		AvatarUrl             func(childComplexity int) int
		DelegationsConnection func(childComplexity int, partyID *string, pagination *v2.Pagination) int
		EpochData             func(childComplexity int) int
		EthereumAddress       func(childComplexity int) int
		Id                    func(childComplexity int) int
		InfoUrl               func(childComplexity int) int
		Location              func(childComplexity int) int
		Name                  func(childComplexity int) int
		PendingStake          func(childComplexity int) int
		PubKey                func(childComplexity int) int
		RankingScore          func(childComplexity int) int
		RewardScore           func(childComplexity int) int
		StakedByDelegates     func(childComplexity int) int
		StakedByOperator      func(childComplexity int) int
		StakedTotal           func(childComplexity int) int
		Status                func(childComplexity int) int
		TmPubKey              func(childComplexity int) int
	}

	NodeBasic struct {
		AvatarUrl       func(childComplexity int) int
		EthereumAddress func(childComplexity int) int
		Id              func(childComplexity int) int
		InfoUrl         func(childComplexity int) int
		Location        func(childComplexity int) int
		Name            func(childComplexity int) int
		PubKey          func(childComplexity int) int
		Status          func(childComplexity int) int
		TmPubKey        func(childComplexity int) int
	}

	NodeData struct {
		ErsatzNodes     func(childComplexity int) int
		InactiveNodes   func(childComplexity int) int
		PendingNodes    func(childComplexity int) int
		StakedTotal     func(childComplexity int) int
		TendermintNodes func(childComplexity int) int
		TotalNodes      func(childComplexity int) int
		Uptime          func(childComplexity int) int
	}

	NodeEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	NodeSet struct {
		Demoted  func(childComplexity int) int
		Inactive func(childComplexity int) int
		Maximum  func(childComplexity int) int
		Promoted func(childComplexity int) int
		Total    func(childComplexity int) int
	}

	NodeSignature struct {
		Id        func(childComplexity int) int
		Kind      func(childComplexity int) int
		Signature func(childComplexity int) int
	}

	NodeSignatureEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	NodeSignaturesConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	NodesConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	Normaliser struct {
		Expression func(childComplexity int) int
		Name       func(childComplexity int) int
	}

	ObservableLiquidityProviderFeeShare struct {
		AverageEntryValuation func(childComplexity int) int
		AverageScore          func(childComplexity int) int
		EquityLikeShare       func(childComplexity int) int
		PartyID               func(childComplexity int) int
	}

	ObservableLiquidityProviderSLA struct {
		CurrentEpochFractionOfTimeOnBook func(childComplexity int) int
		HysteresisPeriodFeePenalties     func(childComplexity int) int
		LastEpochBondPenalty             func(childComplexity int) int
		LastEpochFeePenalty              func(childComplexity int) int
		LastEpochFractionOfTimeOnBook    func(childComplexity int) int
		NotionalVolumeBuys               func(childComplexity int) int
		NotionalVolumeSells              func(childComplexity int) int
		Party                            func(childComplexity int) int
		RequiredLiquidity                func(childComplexity int) int
	}

	ObservableMarketData struct {
		AuctionEnd                func(childComplexity int) int
		AuctionStart              func(childComplexity int) int
		BestBidPrice              func(childComplexity int) int
		BestBidVolume             func(childComplexity int) int
		BestOfferPrice            func(childComplexity int) int
		BestOfferVolume           func(childComplexity int) int
		BestStaticBidPrice        func(childComplexity int) int
		BestStaticBidVolume       func(childComplexity int) int
		BestStaticOfferPrice      func(childComplexity int) int
		BestStaticOfferVolume     func(childComplexity int) int
		ExtensionTrigger          func(childComplexity int) int
		IndicativePrice           func(childComplexity int) int
		IndicativeVolume          func(childComplexity int) int
		LastTradedPrice           func(childComplexity int) int
		LiquidityProviderFeeShare func(childComplexity int) int
		LiquidityProviderSLA      func(childComplexity int) int
		MarkPrice                 func(childComplexity int) int
		MarketGrowth              func(childComplexity int) int
		MarketID                  func(childComplexity int) int
		MarketState               func(childComplexity int) int
		MarketTradingMode         func(childComplexity int) int
		MarketValueProxy          func(childComplexity int) int
		MidPrice                  func(childComplexity int) int
		NextMarkToMarket          func(childComplexity int) int
		OpenInterest              func(childComplexity int) int
		PriceMonitoringBounds     func(childComplexity int) int
		ProductData               func(childComplexity int) int
		StaticMidPrice            func(childComplexity int) int
		SuppliedStake             func(childComplexity int) int
		TargetStake               func(childComplexity int) int
		Timestamp                 func(childComplexity int) int
		Trigger                   func(childComplexity int) int
	}

	ObservableMarketDepth struct {
		Buy            func(childComplexity int) int
		LastTrade      func(childComplexity int) int
		MarketId       func(childComplexity int) int
		Sell           func(childComplexity int) int
		SequenceNumber func(childComplexity int) int
	}

	ObservableMarketDepthUpdate struct {
		Buy                    func(childComplexity int) int
		MarketId               func(childComplexity int) int
		PreviousSequenceNumber func(childComplexity int) int
		Sell                   func(childComplexity int) int
		SequenceNumber         func(childComplexity int) int
	}

	OneOffGovernanceTransfer struct {
		DeliverOn func(childComplexity int) int
	}

	OneOffTransfer struct {
		DeliverOn func(childComplexity int) int
	}

	OracleData struct {
		ExternalData func(childComplexity int) int
	}

	OracleDataConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	OracleDataEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	OracleSpec struct {
		DataConnection func(childComplexity int, pagination *v2.Pagination) int
		DataSourceSpec func(childComplexity int) int
	}

	OracleSpecEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	OracleSpecsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	Order struct {
		CreatedAt          func(childComplexity int) int
		ExpiresAt          func(childComplexity int) int
		IcebergOrder       func(childComplexity int) int
		Id                 func(childComplexity int) int
		LiquidityProvision func(childComplexity int) int
		Market             func(childComplexity int) int
		Party              func(childComplexity int) int
		PeggedOrder        func(childComplexity int) int
		PostOnly           func(childComplexity int) int
		Price              func(childComplexity int) int
		ReduceOnly         func(childComplexity int) int
		Reference          func(childComplexity int) int
		RejectionReason    func(childComplexity int) int
		Remaining          func(childComplexity int) int
		Side               func(childComplexity int) int
		Size               func(childComplexity int) int
		Status             func(childComplexity int) int
		TimeInForce        func(childComplexity int) int
		TradesConnection   func(childComplexity int, dateRange *v2.DateRange, pagination *v2.Pagination) int
		Type               func(childComplexity int) int
		UpdatedAt          func(childComplexity int) int
		Version            func(childComplexity int) int
	}

	OrderConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	OrderEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	OrderEstimate struct {
		Fee            func(childComplexity int) int
		MarginLevels   func(childComplexity int) int
		TotalFeeAmount func(childComplexity int) int
	}

	OrderSubmission struct {
		ExpiresAt    func(childComplexity int) int
		IcebergOrder func(childComplexity int) int
		MarketId     func(childComplexity int) int
		PeggedOrder  func(childComplexity int) int
		PostOnly     func(childComplexity int) int
		Price        func(childComplexity int) int
		ReduceOnly   func(childComplexity int) int
		Reference    func(childComplexity int) int
		Side         func(childComplexity int) int
		Size         func(childComplexity int) int
		TimeInForce  func(childComplexity int) int
		Type         func(childComplexity int) int
	}

	OrderUpdate struct {
		CreatedAt            func(childComplexity int) int
		ExpiresAt            func(childComplexity int) int
		IcebergOrder         func(childComplexity int) int
		Id                   func(childComplexity int) int
		LiquidityProvisionId func(childComplexity int) int
		MarketId             func(childComplexity int) int
		PartyId              func(childComplexity int) int
		PeggedOrder          func(childComplexity int) int
		Price                func(childComplexity int) int
		Reference            func(childComplexity int) int
		RejectionReason      func(childComplexity int) int
		Remaining            func(childComplexity int) int
		Side                 func(childComplexity int) int
		Size                 func(childComplexity int) int
		Status               func(childComplexity int) int
		TimeInForce          func(childComplexity int) int
		Type                 func(childComplexity int) int
		UpdatedAt            func(childComplexity int) int
		Version              func(childComplexity int) int
	}

	PageInfo struct {
		EndCursor       func(childComplexity int) int
		HasNextPage     func(childComplexity int) int
		HasPreviousPage func(childComplexity int) int
		StartCursor     func(childComplexity int) int
	}

	PaidLiquidityFees struct {
		AssetID          func(childComplexity int) int
		Epoch            func(childComplexity int) int
		FeesPaidPerParty func(childComplexity int) int
		MarketID         func(childComplexity int) int
		TotalFeesPaid    func(childComplexity int) int
	}

	PaidLiquidityFeesConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	PaidLiquidityFeesEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	Party struct {
		AccountsConnection            func(childComplexity int, marketID *string, assetID *string, typeArg *vega.AccountType, pagination *v2.Pagination) int
		ActivityStreak                func(childComplexity int, epoch *int) int
		DelegationsConnection         func(childComplexity int, nodeID *string, pagination *v2.Pagination) int
		DepositsConnection            func(childComplexity int, dateRange *v2.DateRange, pagination *v2.Pagination) int
		Id                            func(childComplexity int) int
		LiquidityProvisions           func(childComplexity int, marketID *string, reference *string, live *bool, pagination *v2.Pagination) int
		LiquidityProvisionsConnection func(childComplexity int, marketID *string, reference *string, live *bool, pagination *v2.Pagination) int
		MarginsConnection             func(childComplexity int, marketID *string, pagination *v2.Pagination) int
		OrdersConnection              func(childComplexity int, pagination *v2.Pagination, filter *OrderByMarketIdsFilter) int
		PositionsConnection           func(childComplexity int, market *string, pagination *v2.Pagination) int
		ProposalsConnection           func(childComplexity int, proposalType *v2.ListGovernanceDataRequest_Type, inState *vega.Proposal_State, pagination *v2.Pagination) int
		RewardSummaries               func(childComplexity int, assetID *string) int
		RewardsConnection             func(childComplexity int, assetID *string, pagination *v2.Pagination, fromEpoch *int, toEpoch *int) int
		StakingSummary                func(childComplexity int, pagination *v2.Pagination) int
		TradesConnection              func(childComplexity int, marketID *string, dataRange *v2.DateRange, pagination *v2.Pagination) int
		TransfersConnection           func(childComplexity int, direction *TransferDirection, pagination *v2.Pagination, isReward *bool) int
		VestingBalancesSummary        func(childComplexity int, assetID *string) int
		VestingStats                  func(childComplexity int) int
		VotesConnection               func(childComplexity int, pagination *v2.Pagination) int
		WithdrawalsConnection         func(childComplexity int, dateRange *v2.DateRange, pagination *v2.Pagination) int
	}

	PartyActivityStreak struct {
		ActiveFor                    func(childComplexity int) int
		Epoch                        func(childComplexity int) int
		InactiveFor                  func(childComplexity int) int
		IsActive                     func(childComplexity int) int
		OpenVolume                   func(childComplexity int) int
		RewardDistributionMultiplier func(childComplexity int) int
		RewardVestingMultiplier      func(childComplexity int) int
		TradedVolume                 func(childComplexity int) int
	}

	PartyAmount struct {
		Amount  func(childComplexity int) int
		PartyID func(childComplexity int) int
	}

	PartyConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	PartyEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	PartyLockedBalance struct {
		Asset      func(childComplexity int) int
		Balance    func(childComplexity int) int
		UntilEpoch func(childComplexity int) int
	}

	PartyStake struct {
		CurrentStakeAvailable func(childComplexity int) int
		Linkings              func(childComplexity int) int
	}

	PartyVestingBalance struct {
		Asset   func(childComplexity int) int
		Balance func(childComplexity int) int
	}

	PartyVestingBalancesSummary struct {
		Epoch           func(childComplexity int) int
		LockedBalances  func(childComplexity int) int
		VestingBalances func(childComplexity int) int
	}

	PartyVestingStats struct {
		EpochSeq              func(childComplexity int) int
		QuantumBalance        func(childComplexity int) int
		RewardBonusMultiplier func(childComplexity int) int
	}

	PeggedOrder struct {
		Offset    func(childComplexity int) int
		Reference func(childComplexity int) int
	}

	Perpetual struct {
		ClampLowerBound                     func(childComplexity int) int
		ClampUpperBound                     func(childComplexity int) int
		DataSourceSpecBinding               func(childComplexity int) int
		DataSourceSpecForSettlementData     func(childComplexity int) int
		DataSourceSpecForSettlementSchedule func(childComplexity int) int
		InterestRate                        func(childComplexity int) int
		MarginFundingFactor                 func(childComplexity int) int
		QuoteName                           func(childComplexity int) int
		SettlementAsset                     func(childComplexity int) int
	}

	PerpetualData struct {
		ExternalTwap   func(childComplexity int) int
		FundingPayment func(childComplexity int) int
		FundingRate    func(childComplexity int) int
		InternalTwap   func(childComplexity int) int
	}

	PerpetualProduct struct {
		ClampLowerBound                     func(childComplexity int) int
		ClampUpperBound                     func(childComplexity int) int
		DataSourceSpecBinding               func(childComplexity int) int
		DataSourceSpecForSettlementData     func(childComplexity int) int
		DataSourceSpecForSettlementSchedule func(childComplexity int) int
		InterestRate                        func(childComplexity int) int
		MarginFundingFactor                 func(childComplexity int) int
		QuoteName                           func(childComplexity int) int
		SettlementAsset                     func(childComplexity int) int
	}

	Position struct {
		AverageEntryPrice       func(childComplexity int) int
		LossSocializationAmount func(childComplexity int) int
		MarginsConnection       func(childComplexity int, pagination *v2.Pagination) int
		Market                  func(childComplexity int) int
		OpenVolume              func(childComplexity int) int
		Party                   func(childComplexity int) int
		PositionStatus          func(childComplexity int) int
		RealisedPnl             func(childComplexity int) int
		UnrealisedPnl           func(childComplexity int) int
		UpdatedAt               func(childComplexity int) int
	}

	PositionConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	PositionEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	PositionEstimate struct {
		Liquidation func(childComplexity int) int
		Margin      func(childComplexity int) int
	}

	PositionResolution struct {
		Closed     func(childComplexity int) int
		Distressed func(childComplexity int) int
		MarkPrice  func(childComplexity int) int
		MarketID   func(childComplexity int) int
	}

	PositionUpdate struct {
		AverageEntryPrice       func(childComplexity int) int
		LossSocializationAmount func(childComplexity int) int
		MarketId                func(childComplexity int) int
		OpenVolume              func(childComplexity int) int
		PartyId                 func(childComplexity int) int
		PositionStatus          func(childComplexity int) int
		RealisedPnl             func(childComplexity int) int
		UnrealisedPnl           func(childComplexity int) int
		UpdatedAt               func(childComplexity int) int
	}

	PriceLevel struct {
		NumberOfOrders func(childComplexity int) int
		Price          func(childComplexity int) int
		Volume         func(childComplexity int) int
	}

	PriceMonitoringBounds struct {
		MaxValidPrice  func(childComplexity int) int
		MinValidPrice  func(childComplexity int) int
		ReferencePrice func(childComplexity int) int
		Trigger        func(childComplexity int) int
	}

	PriceMonitoringParameters struct {
		Triggers func(childComplexity int) int
	}

	PriceMonitoringSettings struct {
		Parameters func(childComplexity int) int
	}

	PriceMonitoringTrigger struct {
		AuctionExtensionSecs func(childComplexity int) int
		HorizonSecs          func(childComplexity int) int
		Probability          func(childComplexity int) int
	}

	Property struct {
		Name  func(childComplexity int) int
		Value func(childComplexity int) int
	}

	PropertyKey struct {
		Name                func(childComplexity int) int
		NumberDecimalPlaces func(childComplexity int) int
		Type                func(childComplexity int) int
	}

	Proposal struct {
		Datetime                func(childComplexity int) int
		ErrorDetails            func(childComplexity int) int
		ID                      func(childComplexity int) int
		Party                   func(childComplexity int) int
		Rationale               func(childComplexity int) int
		Reference               func(childComplexity int) int
		RejectionReason         func(childComplexity int) int
		RequiredLpMajority      func(childComplexity int) int
		RequiredLpParticipation func(childComplexity int) int
		RequiredMajority        func(childComplexity int) int
		RequiredParticipation   func(childComplexity int) int
		State                   func(childComplexity int) int
		Terms                   func(childComplexity int) int
		Votes                   func(childComplexity int) int
	}

	ProposalDetail struct {
		Datetime                func(childComplexity int) int
		ErrorDetails            func(childComplexity int) int
		Id                      func(childComplexity int) int
		Party                   func(childComplexity int) int
		Rationale               func(childComplexity int) int
		Reference               func(childComplexity int) int
		RejectionReason         func(childComplexity int) int
		RequiredLpMajority      func(childComplexity int) int
		RequiredLpParticipation func(childComplexity int) int
		RequiredMajority        func(childComplexity int) int
		RequiredParticipation   func(childComplexity int) int
		State                   func(childComplexity int) int
		Terms                   func(childComplexity int) int
	}

	ProposalEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ProposalRationale struct {
		Description func(childComplexity int) int
		Title       func(childComplexity int) int
	}

	ProposalTerms struct {
		Change             func(childComplexity int) int
		ClosingDatetime    func(childComplexity int) int
		EnactmentDatetime  func(childComplexity int) int
		ValidationDatetime func(childComplexity int) int
	}

	ProposalVote struct {
		ProposalID func(childComplexity int) int
		Vote       func(childComplexity int) int
	}

	ProposalVoteConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ProposalVoteEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ProposalVoteSide struct {
		TotalEquityLikeShareWeight func(childComplexity int) int
		TotalNumber                func(childComplexity int) int
		TotalTokens                func(childComplexity int) int
		TotalWeight                func(childComplexity int) int
		Votes                      func(childComplexity int) int
	}

	ProposalVotes struct {
		No  func(childComplexity int) int
		Yes func(childComplexity int) int
	}

	ProposalsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ProtocolUpgradeProposal struct {
		Approvers          func(childComplexity int) int
		Status             func(childComplexity int) int
		UpgradeBlockHeight func(childComplexity int) int
		VegaReleaseTag     func(childComplexity int) int
	}

	ProtocolUpgradeProposalConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ProtocolUpgradeProposalEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ProtocolUpgradeStatus struct {
		Ready func(childComplexity int) int
	}

	PubKey struct {
		Key func(childComplexity int) int
	}

	Query struct {
		Asset                              func(childComplexity int, id string) int
		AssetsConnection                   func(childComplexity int, id *string, pagination *v2.Pagination) int
		BalanceChanges                     func(childComplexity int, filter *v2.AccountFilter, dateRange *v2.DateRange, pagination *v2.Pagination) int
		CoreSnapshots                      func(childComplexity int, pagination *v2.Pagination) int
		CurrentReferralProgram             func(childComplexity int) int
		CurrentVolumeDiscountProgram       func(childComplexity int) int
		Deposit                            func(childComplexity int, id string) int
		Deposits                           func(childComplexity int, dateRange *v2.DateRange, pagination *v2.Pagination) int
		Entities                           func(childComplexity int, txHash string) int
		Epoch                              func(childComplexity int, id *string, block *string) int
		EpochRewardSummaries               func(childComplexity int, filter *v2.RewardSummaryFilter, pagination *v2.Pagination) int
		Erc20ListAssetBundle               func(childComplexity int, assetID string) int
		Erc20MultiSigSignerAddedBundles    func(childComplexity int, nodeID string, submitter *string, epochSeq *string, pagination *v2.Pagination) int
		Erc20MultiSigSignerRemovedBundles  func(childComplexity int, nodeID string, submitter *string, epochSeq *string, pagination *v2.Pagination) int
		Erc20SetAssetLimitsBundle          func(childComplexity int, proposalID string) int
		Erc20WithdrawalApproval            func(childComplexity int, withdrawalID string) int
		EstimateFees                       func(childComplexity int, marketID string, partyID string, price *string, size string, side vega.Side, timeInForce vega.Order_TimeInForce, expiration *int64, typeArg vega.Order_Type) int
		EstimateOrder                      func(childComplexity int, marketID string, partyID string, price *string, size string, side vega.Side, timeInForce vega.Order_TimeInForce, expiration *int64, typeArg vega.Order_Type) int
		EstimatePosition                   func(childComplexity int, marketID string, openVolume string, orders []*OrderInfo, collateralAvailable *string, scaleLiquidationPriceToMarketDecimals *bool) int
		EthereumKeyRotations               func(childComplexity int, nodeID *string) int
		FeesStats                          func(childComplexity int, marketID *string, assetID *string, epoch *int, partyID *string) int
		FeesStatsForParty                  func(childComplexity int, partyID string, assetID *string, fromEpoch *int, toEpoch *int) int
		FundingPayments                    func(childComplexity int, partyID string, marketID *string, pagination *v2.Pagination) int
		FundingPeriodDataPoints            func(childComplexity int, marketID string, dateRange *v2.DateRange, source *v1.FundingPeriodDataPoint_Source, pagination *v2.Pagination) int
		FundingPeriods                     func(childComplexity int, marketID string, dateRange *v2.DateRange, pagination *v2.Pagination) int
		GetMarketDataHistoryConnectionByID func(childComplexity int, id string, start *int64, end *int64, pagination *v2.Pagination) int
		KeyRotationsConnection             func(childComplexity int, id *string, pagination *v2.Pagination) int
		LastBlockHeight                    func(childComplexity int) int
		LedgerEntries                      func(childComplexity int, filter *v2.LedgerEntryFilter, dateRange *v2.DateRange, pagination *v2.Pagination) int
		LiquidityProviders                 func(childComplexity int, partyID *string, marketID *string, pagination *v2.Pagination) int
		Market                             func(childComplexity int, id string) int
		MarketsConnection                  func(childComplexity int, id *string, pagination *v2.Pagination, includeSettled *bool) int
		MostRecentHistorySegment           func(childComplexity int) int
		NetworkLimits                      func(childComplexity int) int
		NetworkParameter                   func(childComplexity int, key string) int
		NetworkParametersConnection        func(childComplexity int, pagination *v2.Pagination) int
		Node                               func(childComplexity int, id string) int
		NodeData                           func(childComplexity int) int
		NodeSignaturesConnection           func(childComplexity int, resourceID string, pagination *v2.Pagination) int
		NodesConnection                    func(childComplexity int, pagination *v2.Pagination) int
		OracleDataBySpecConnection         func(childComplexity int, oracleSpecID string, pagination *v2.Pagination) int
		OracleDataConnection               func(childComplexity int, pagination *v2.Pagination) int
		OracleSpec                         func(childComplexity int, oracleSpecID string) int
		OracleSpecsConnection              func(childComplexity int, pagination *v2.Pagination) int
		OrderByID                          func(childComplexity int, id string, version *int) int
		OrderByReference                   func(childComplexity int, reference string) int
		OrderVersionsConnection            func(childComplexity int, orderID *string, pagination *v2.Pagination) int
		PaidLiquidityFees                  func(childComplexity int, marketID *string, assetID *string, epoch *int, partyIDs []string) int
		PartiesConnection                  func(childComplexity int, id *string, pagination *v2.Pagination) int
		Party                              func(childComplexity int, id string) int
		Positions                          func(childComplexity int, filter *v2.PositionsFilter, pagination *v2.Pagination) int
		Proposal                           func(childComplexity int, id *string, reference *string) int
		ProposalsConnection                func(childComplexity int, proposalType *v2.ListGovernanceDataRequest_Type, inState *vega.Proposal_State, pagination *v2.Pagination) int
		ProtocolUpgradeProposals           func(childComplexity int, inState *v1.ProtocolUpgradeProposalStatus, approvedBy *string, pagination *v2.Pagination) int
		ProtocolUpgradeStatus              func(childComplexity int) int
		ReferralSetReferees                func(childComplexity int, id *string, referrer *string, referee *string, pagination *v2.Pagination, aggregationEpochs *int) int
		ReferralSetStats                   func(childComplexity int, setID *string, epoch *int, partyID *string, pagination *v2.Pagination) int
		ReferralSets                       func(childComplexity int, id *string, referrer *string, referee *string, pagination *v2.Pagination) int
		Statistics                         func(childComplexity int) int
		StopOrder                          func(childComplexity int, id string) int
		StopOrders                         func(childComplexity int, filter *v2.StopOrderFilter, pagination *v2.Pagination) int
		SuccessorMarkets                   func(childComplexity int, marketID string, fullHistory *bool, pagination *v2.Pagination) int
		TeamRefereeHistory                 func(childComplexity int, referee string, pagination *v2.Pagination) int
		TeamReferees                       func(childComplexity int, teamID string, pagination *v2.Pagination) int
		Teams                              func(childComplexity int, teamID *string, partyID *string, pagination *v2.Pagination) int
		Trades                             func(childComplexity int, filter *TradesFilter, pagination *v2.Pagination, dateRange *v2.DateRange) int
		Transfer                           func(childComplexity int, id string) int
		TransfersConnection                func(childComplexity int, partyID *string, direction *TransferDirection, pagination *v2.Pagination, isReward *bool) int
		VolumeDiscountStats                func(childComplexity int, epoch *int, partyID *string, pagination *v2.Pagination) int
		Withdrawal                         func(childComplexity int, id string) int
		Withdrawals                        func(childComplexity int, dateRange *v2.DateRange, pagination *v2.Pagination) int
	}

	RankTable struct {
		ShareRatio func(childComplexity int) int
		StartRank  func(childComplexity int) int
	}

	RankingScore struct {
		PerformanceScore func(childComplexity int) int
		PreviousStatus   func(childComplexity int) int
		RankingScore     func(childComplexity int) int
		StakeScore       func(childComplexity int) int
		Status           func(childComplexity int) int
		VotingPower      func(childComplexity int) int
	}

	RecurringGovernanceTransfer struct {
		DispatchStrategy func(childComplexity int) int
		EndEpoch         func(childComplexity int) int
		StartEpoch       func(childComplexity int) int
	}

	RecurringTransfer struct {
		DispatchStrategy func(childComplexity int) int
		EndEpoch         func(childComplexity int) int
		Factor           func(childComplexity int) int
		StartEpoch       func(childComplexity int) int
	}

	ReferralProgram struct {
		BenefitTiers          func(childComplexity int) int
		EndOfProgramTimestamp func(childComplexity int) int
		Id                    func(childComplexity int) int
		StakingTiers          func(childComplexity int) int
		Version               func(childComplexity int) int
		WindowLength          func(childComplexity int) int
	}

	ReferralSet struct {
		CreatedAt func(childComplexity int) int
		Id        func(childComplexity int) int
		Referrer  func(childComplexity int) int
		UpdatedAt func(childComplexity int) int
	}

	ReferralSetConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ReferralSetEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ReferralSetReferee struct {
		AtEpoch                         func(childComplexity int) int
		JoinedAt                        func(childComplexity int) int
		RefereeID                       func(childComplexity int) int
		ReferralSetId                   func(childComplexity int) int
		TotalRefereeGeneratedRewards    func(childComplexity int) int
		TotalRefereeNotionalTakerVolume func(childComplexity int) int
	}

	ReferralSetRefereeConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ReferralSetRefereeEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ReferralSetStats struct {
		AtEpoch                               func(childComplexity int) int
		DiscountFactor                        func(childComplexity int) int
		EpochNotionalTakerVolume              func(childComplexity int) int
		PartyId                               func(childComplexity int) int
		ReferralSetRunningNotionalTakerVolume func(childComplexity int) int
		ReferrerTakerVolume                   func(childComplexity int) int
		RewardFactor                          func(childComplexity int) int
		RewardsFactorMultiplier               func(childComplexity int) int
		RewardsMultiplier                     func(childComplexity int) int
		WasEligible                           func(childComplexity int) int
	}

	ReferralSetStatsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	ReferralSetStatsEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	ReferrerRewardsGenerated struct {
		GeneratedReward func(childComplexity int) int
		ReferrerID      func(childComplexity int) int
	}

	Reward struct {
		Amount            func(childComplexity int) int
		Asset             func(childComplexity int) int
		Epoch             func(childComplexity int) int
		LockedUntilEpoch  func(childComplexity int) int
		MarketId          func(childComplexity int) int
		Party             func(childComplexity int) int
		PercentageOfTotal func(childComplexity int) int
		ReceivedAt        func(childComplexity int) int
		RewardType        func(childComplexity int) int
	}

	RewardEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	RewardScore struct {
		MultisigScore     func(childComplexity int) int
		NormalisedScore   func(childComplexity int) int
		PerformanceScore  func(childComplexity int) int
		RawValidatorScore func(childComplexity int) int
		ValidatorScore    func(childComplexity int) int
		ValidatorStatus   func(childComplexity int) int
	}

	RewardSummary struct {
		Amount            func(childComplexity int) int
		Asset             func(childComplexity int) int
		RewardsConnection func(childComplexity int, assetID *string, pagination *v2.Pagination) int
	}

	RewardSummaryConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	RewardSummaryEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	RewardsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	RiskFactor struct {
		Long   func(childComplexity int) int
		Market func(childComplexity int) int
		Short  func(childComplexity int) int
	}

	ScalingFactors struct {
		CollateralRelease func(childComplexity int) int
		InitialMargin     func(childComplexity int) int
		SearchLevel       func(childComplexity int) int
	}

	SettleDistressed struct {
		Margin   func(childComplexity int) int
		MarketID func(childComplexity int) int
		PartyID  func(childComplexity int) int
		Price    func(childComplexity int) int
	}

	SettlePosition struct {
		MarketID         func(childComplexity int) int
		PartyID          func(childComplexity int) int
		Price            func(childComplexity int) int
		TradeSettlements func(childComplexity int) int
	}

	Signer struct {
		Signer func(childComplexity int) int
	}

	SimpleRiskModel struct {
		Params func(childComplexity int) int
	}

	SimpleRiskModelParams struct {
		FactorLong  func(childComplexity int) int
		FactorShort func(childComplexity int) int
	}

	Spot struct {
		BaseAsset  func(childComplexity int) int
		Name       func(childComplexity int) int
		QuoteAsset func(childComplexity int) int
	}

	SpotProduct struct {
		BaseAsset  func(childComplexity int) int
		Name       func(childComplexity int) int
		QuoteAsset func(childComplexity int) int
	}

	StakeLinking struct {
		Amount      func(childComplexity int) int
		BlockHeight func(childComplexity int) int
		FinalizedAt func(childComplexity int) int
		Id          func(childComplexity int) int
		Party       func(childComplexity int) int
		Status      func(childComplexity int) int
		Timestamp   func(childComplexity int) int
		TxHash      func(childComplexity int) int
		Type        func(childComplexity int) int
	}

	StakeLinkingEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	StakesConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	StakingSummary struct {
		CurrentStakeAvailable func(childComplexity int) int
		Linkings              func(childComplexity int, pagination *v2.Pagination) int
	}

	StakingTier struct {
		MinimumStakedTokens      func(childComplexity int) int
		ReferralRewardMultiplier func(childComplexity int) int
	}

	Statistics struct {
		AppVersion            func(childComplexity int) int
		AppVersionHash        func(childComplexity int) int
		AverageOrdersPerBlock func(childComplexity int) int
		AverageTxBytes        func(childComplexity int) int
		BacklogLength         func(childComplexity int) int
		BlockDuration         func(childComplexity int) int
		BlockHash             func(childComplexity int) int
		BlockHeight           func(childComplexity int) int
		ChainId               func(childComplexity int) int
		ChainVersion          func(childComplexity int) int
		CurrentTime           func(childComplexity int) int
		EventCount            func(childComplexity int) int
		EventsPerSecond       func(childComplexity int) int
		GenesisTime           func(childComplexity int) int
		OrdersPerSecond       func(childComplexity int) int
		Status                func(childComplexity int) int
		TotalAmendOrder       func(childComplexity int) int
		TotalCancelOrder      func(childComplexity int) int
		TotalCreateOrder      func(childComplexity int) int
		TotalMarkets          func(childComplexity int) int
		TotalOrders           func(childComplexity int) int
		TotalPeers            func(childComplexity int) int
		TotalTrades           func(childComplexity int) int
		TradesPerSecond       func(childComplexity int) int
		TxPerBlock            func(childComplexity int) int
		Uptime                func(childComplexity int) int
		VegaTime              func(childComplexity int) int
	}

	StopOrder struct {
		CreatedAt        func(childComplexity int) int
		ExpiresAt        func(childComplexity int) int
		ExpiryStrategy   func(childComplexity int) int
		ID               func(childComplexity int) int
		MarketID         func(childComplexity int) int
		OcoLinkID        func(childComplexity int) int
		Order            func(childComplexity int) int
		PartyID          func(childComplexity int) int
		RejectionReason  func(childComplexity int) int
		Status           func(childComplexity int) int
		Submission       func(childComplexity int) int
		Trigger          func(childComplexity int) int
		TriggerDirection func(childComplexity int) int
		UpdatedAt        func(childComplexity int) int
	}

	StopOrderConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	StopOrderEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	StopOrderPrice struct {
		Price func(childComplexity int) int
	}

	StopOrderTrailingPercentOffset struct {
		TrailingPercentOffset func(childComplexity int) int
	}

	Subscription struct {
		Accounts            func(childComplexity int, marketID *string, partyID *string, assetID *string, typeArg *vega.AccountType) int
		BusEvents           func(childComplexity int, types []BusEventType, marketID *string, partyID *string, batchSize int) int
		Candles             func(childComplexity int, marketID string, interval vega.Interval) int
		LiquidityProvisions func(childComplexity int, partyID *string, marketID *string) int
		Margins             func(childComplexity int, partyID string, marketID *string) int
		MarketsData         func(childComplexity int, marketIds []string) int
		MarketsDepth        func(childComplexity int, marketIds []string) int
		MarketsDepthUpdate  func(childComplexity int, marketIds []string) int
		Orders              func(childComplexity int, filter *OrderByMarketAndPartyIdsFilter) int
		Positions           func(childComplexity int, partyID *string, marketID *string) int
		Proposals           func(childComplexity int, partyID *string) int
		Trades              func(childComplexity int, marketID *string, partyID *string) int
		TradesStream        func(childComplexity int, filter TradesSubscriptionFilter) int
		Votes               func(childComplexity int, proposalID *string, partyID *string) int
	}

	SuccessorConfiguration struct {
		InsurancePoolFraction func(childComplexity int) int
		ParentMarketId        func(childComplexity int) int
	}

	SuccessorMarket struct {
		Market    func(childComplexity int) int
		Proposals func(childComplexity int) int
	}

	SuccessorMarketConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	SuccessorMarketEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	TargetStakeParameters struct {
		ScalingFactor func(childComplexity int) int
		TimeWindow    func(childComplexity int) int
	}

	Team struct {
		AvatarUrl      func(childComplexity int) int
		Closed         func(childComplexity int) int
		CreatedAt      func(childComplexity int) int
		CreatedAtEpoch func(childComplexity int) int
		Name           func(childComplexity int) int
		Referrer       func(childComplexity int) int
		TeamId         func(childComplexity int) int
		TeamUrl        func(childComplexity int) int
	}

	TeamConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	TeamEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	TeamReferee struct {
		JoinedAt      func(childComplexity int) int
		JoinedAtEpoch func(childComplexity int) int
		Referee       func(childComplexity int) int
		TeamId        func(childComplexity int) int
	}

	TeamRefereeConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	TeamRefereeEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	TeamRefereeHistory struct {
		JoinedAt      func(childComplexity int) int
		JoinedAtEpoch func(childComplexity int) int
		TeamId        func(childComplexity int) int
	}

	TeamRefereeHistoryConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	TeamRefereeHistoryEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	TimeUpdate struct {
		Timestamp func(childComplexity int) int
	}

	TradableInstrument struct {
		Instrument       func(childComplexity int) int
		MarginCalculator func(childComplexity int) int
		RiskModel        func(childComplexity int) int
	}

	Trade struct {
		Aggressor          func(childComplexity int) int
		BuyOrder           func(childComplexity int) int
		Buyer              func(childComplexity int) int
		BuyerAuctionBatch  func(childComplexity int) int
		BuyerFee           func(childComplexity int) int
		CreatedAt          func(childComplexity int) int
		Id                 func(childComplexity int) int
		Market             func(childComplexity int) int
		Price              func(childComplexity int) int
		SellOrder          func(childComplexity int) int
		Seller             func(childComplexity int) int
		SellerAuctionBatch func(childComplexity int) int
		SellerFee          func(childComplexity int) int
		Size               func(childComplexity int) int
		Type               func(childComplexity int) int
	}

	TradeConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	TradeEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	TradeFee struct {
		InfrastructureFee                 func(childComplexity int) int
		InfrastructureFeeReferralDiscount func(childComplexity int) int
		InfrastructureFeeVolumeDiscount   func(childComplexity int) int
		LiquidityFee                      func(childComplexity int) int
		LiquidityFeeReferralDiscount      func(childComplexity int) int
		LiquidityFeeVolumeDiscount        func(childComplexity int) int
		MakerFee                          func(childComplexity int) int
		MakerFeeReferralDiscount          func(childComplexity int) int
		MakerFeeVolumeDiscount            func(childComplexity int) int
	}

	TradeSettlement struct {
		Price func(childComplexity int) int
		Size  func(childComplexity int) int
	}

	TradeUpdate struct {
		Aggressor          func(childComplexity int) int
		BuyOrder           func(childComplexity int) int
		BuyerAuctionBatch  func(childComplexity int) int
		BuyerFee           func(childComplexity int) int
		BuyerID            func(childComplexity int) int
		CreatedAt          func(childComplexity int) int
		Id                 func(childComplexity int) int
		MarketId           func(childComplexity int) int
		Price              func(childComplexity int) int
		SellOrder          func(childComplexity int) int
		SellerAuctionBatch func(childComplexity int) int
		SellerFee          func(childComplexity int) int
		SellerID           func(childComplexity int) int
		Size               func(childComplexity int) int
		Type               func(childComplexity int) int
	}

	TransactionResult struct {
		Error   func(childComplexity int) int
		Hash    func(childComplexity int) int
		PartyId func(childComplexity int) int
		Status  func(childComplexity int) int
	}

	TransactionSubmitted struct {
		Success func(childComplexity int) int
	}

	Transfer struct {
		Amount          func(childComplexity int) int
		Asset           func(childComplexity int) int
		From            func(childComplexity int) int
		FromAccountType func(childComplexity int) int
		Id              func(childComplexity int) int
		Kind            func(childComplexity int) int
		Reason          func(childComplexity int) int
		Reference       func(childComplexity int) int
		Status          func(childComplexity int) int
		Timestamp       func(childComplexity int) int
		To              func(childComplexity int) int
		ToAccountType   func(childComplexity int) int
	}

	TransferBalance struct {
		Account func(childComplexity int) int
		Balance func(childComplexity int) int
	}

	TransferConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	TransferEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	TransferFee struct {
		Amount     func(childComplexity int) int
		Epoch      func(childComplexity int) int
		TransferID func(childComplexity int) int
	}

	TransferNode struct {
		Fees     func(childComplexity int) int
		Transfer func(childComplexity int) int
	}

	TransferResponse struct {
		Balances  func(childComplexity int) int
		Transfers func(childComplexity int) int
	}

	TransferResponses struct {
		Responses func(childComplexity int) int
	}

	UpdateAsset struct {
		AssetId func(childComplexity int) int
		Quantum func(childComplexity int) int
		Source  func(childComplexity int) int
	}

	UpdateERC20 struct {
		LifetimeLimit     func(childComplexity int) int
		WithdrawThreshold func(childComplexity int) int
	}

	UpdateFutureProduct struct {
		DataSourceSpecBinding               func(childComplexity int) int
		DataSourceSpecForSettlementData     func(childComplexity int) int
		DataSourceSpecForTradingTermination func(childComplexity int) int
		QuoteName                           func(childComplexity int) int
	}

	UpdateInstrumentConfiguration struct {
		Code    func(childComplexity int) int
		Product func(childComplexity int) int
	}

	UpdateMarket struct {
		MarketId                  func(childComplexity int) int
		UpdateMarketConfiguration func(childComplexity int) int
	}

	UpdateMarketConfiguration struct {
		Instrument                    func(childComplexity int) int
		LinearSlippageFactor          func(childComplexity int) int
		LiquidityMonitoringParameters func(childComplexity int) int
		LiquiditySlaParameters        func(childComplexity int) int
		Metadata                      func(childComplexity int) int
		PriceMonitoringParameters     func(childComplexity int) int
		QuadraticSlippageFactor       func(childComplexity int) int
		RiskParameters                func(childComplexity int) int
	}

	UpdateMarketLogNormalRiskModel struct {
		LogNormal func(childComplexity int) int
	}

	UpdateMarketSimpleRiskModel struct {
		Simple func(childComplexity int) int
	}

	UpdateMarketState struct {
		Market     func(childComplexity int) int
		Price      func(childComplexity int) int
		UpdateType func(childComplexity int) int
	}

	UpdateNetworkParameter struct {
		NetworkParameter func(childComplexity int) int
	}

	UpdatePerpetualProduct struct {
		ClampLowerBound                     func(childComplexity int) int
		ClampUpperBound                     func(childComplexity int) int
		DataSourceSpecBinding               func(childComplexity int) int
		DataSourceSpecForSettlementData     func(childComplexity int) int
		DataSourceSpecForSettlementSchedule func(childComplexity int) int
		InterestRate                        func(childComplexity int) int
		MarginFundingFactor                 func(childComplexity int) int
		QuoteName                           func(childComplexity int) int
	}

	UpdateReferralProgram struct {
		BenefitTiers          func(childComplexity int) int
		EndOfProgramTimestamp func(childComplexity int) int
		StakingTiers          func(childComplexity int) int
		WindowLength          func(childComplexity int) int
	}

	UpdateSpotMarket struct {
		MarketId                      func(childComplexity int) int
		UpdateSpotMarketConfiguration func(childComplexity int) int
	}

	UpdateSpotMarketConfiguration struct {
		LiquiditySLAParams        func(childComplexity int) int
		Metadata                  func(childComplexity int) int
		PriceMonitoringParameters func(childComplexity int) int
		RiskParameters            func(childComplexity int) int
		TargetStakeParameters     func(childComplexity int) int
	}

	UpdateVolumeDiscountProgram struct {
		BenefitTiers          func(childComplexity int) int
		EndOfProgramTimestamp func(childComplexity int) int
		WindowLength          func(childComplexity int) int
	}

	VolumeBenefitTier struct {
		MinimumRunningNotionalTakerVolume func(childComplexity int) int
		VolumeDiscountFactor              func(childComplexity int) int
	}

	VolumeDiscountProgram struct {
		BenefitTiers          func(childComplexity int) int
		EndOfProgramTimestamp func(childComplexity int) int
		EndedAt               func(childComplexity int) int
		Id                    func(childComplexity int) int
		Version               func(childComplexity int) int
		WindowLength          func(childComplexity int) int
	}

	VolumeDiscountStats struct {
		AtEpoch        func(childComplexity int) int
		DiscountFactor func(childComplexity int) int
		PartyId        func(childComplexity int) int
		RunningVolume  func(childComplexity int) int
	}

	VolumeDiscountStatsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	VolumeDiscountStatsEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	Vote struct {
		Datetime               func(childComplexity int) int
		EquityLikeShareWeight  func(childComplexity int) int
		GovernanceTokenBalance func(childComplexity int) int
		GovernanceTokenWeight  func(childComplexity int) int
		Party                  func(childComplexity int) int
		ProposalId             func(childComplexity int) int
		Value                  func(childComplexity int) int
	}

	VoteConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}

	VoteEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	Withdrawal struct {
		Amount             func(childComplexity int) int
		Asset              func(childComplexity int) int
		CreatedTimestamp   func(childComplexity int) int
		Details            func(childComplexity int) int
		Id                 func(childComplexity int) int
		Party              func(childComplexity int) int
		Ref                func(childComplexity int) int
		Status             func(childComplexity int) int
		TxHash             func(childComplexity int) int
		WithdrawnTimestamp func(childComplexity int) int
	}

	WithdrawalEdge struct {
		Cursor func(childComplexity int) int
		Node   func(childComplexity int) int
	}

	WithdrawalsConnection struct {
		Edges    func(childComplexity int) int
		PageInfo func(childComplexity int) int
	}
}

type Condition added in v0.73.0

type Condition struct {
	// The type of comparison to make on the value.
	Operator v1.Condition_Operator `json:"operator"`
	// The value to compare against.
	Value *string `json:"value"`
}

Condition describes the condition that must be validated by the data source engine

type Config

type Config struct {
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type ContinuousTrading

type ContinuousTrading struct {
	// Size of an increment in price in terms of the quote currency
	TickSize string `json:"tickSize"`
}

A mode where Vega tries to execute orders as soon as they are received

type CoreProxyServiceClient

type CoreProxyServiceClient interface {
	vegaprotoapi.CoreServiceClient
}

CoreProxyServiceClient ...

type CoreSnapshotDataResolver added in v0.65.0

type CoreSnapshotDataResolver interface {
	BlockHeight(ctx context.Context, obj *v1.CoreSnapshotData) (string, error)

	VegaCoreVersion(ctx context.Context, obj *v1.CoreSnapshotData) (string, error)
}

type CurrentReferralProgramResolver added in v0.73.0

type CurrentReferralProgramResolver interface {
	Version(ctx context.Context, obj *v2.ReferralProgram) (int, error)

	WindowLength(ctx context.Context, obj *v2.ReferralProgram) (int, error)
}

type Data added in v0.61.0

type Data struct {
	// signers is the list of public keys/ETH addresses that signed the data
	Signers []*Signer `json:"signers"`
	// properties contains all the properties sent by a data source
	Data     []*v1.Property `json:"data"`
	MetaData []*v1.Property `json:"metaData"`
	// List of all the data specs that matched this source data.
	// When the array is empty, it means no data spec matched this source data.
	MatchedSpecIds []string `json:"matchedSpecIds"`
	// RFC3339Nano formatted date and time for when the data was broadcast to the markets
	// with a matching data spec.
	// It has no value when the source data does not match any data spec.
	BroadcastAt int64 `json:"broadcastAt"`
}

A data source contains the data sent by a data source

type DataSourceDefinitionExternalResolver added in v0.72.0

type DataSourceDefinitionExternalResolver interface {
	SourceType(ctx context.Context, obj *vega.DataSourceDefinitionExternal) (ExternalDataSourceKind, error)
}

type DataSourceDefinitionInternalResolver added in v0.72.0

type DataSourceDefinitionInternalResolver interface {
	SourceType(ctx context.Context, obj *vega.DataSourceDefinitionInternal) (InternalDataSourceKind, error)
}

type DataSourceDefinitionResolver added in v0.72.0

type DataSourceDefinitionResolver interface {
	SourceType(ctx context.Context, obj *vega.DataSourceDefinition) (DataSourceKind, error)
}

type DataSourceKind added in v0.62.0

type DataSourceKind interface {
	IsDataSourceKind()
}

type DataSourceSpec added in v0.61.0

type DataSourceSpec struct {
	// ID is a hash generated from the DataSourceSpec data.
	ID string `json:"id"`
	// RFC3339Nano creation date time
	CreatedAt int64 `json:"createdAt"`
	// RFC3339Nano last updated timestamp
	UpdatedAt *int64                     `json:"updatedAt"`
	Data      *vega.DataSourceDefinition `json:"data"`
	// Status describes the status of the data source spec
	Status DataSourceSpecStatus `json:"status"`
}

An data source specification describes the data source data that a product (or a risk model) wants to get from the oracle engine.

type DataSourceSpecConfigurationResolver added in v0.61.0

type DataSourceSpecConfigurationResolver interface {
	Signers(ctx context.Context, obj *vega.DataSourceSpecConfiguration) ([]*Signer, error)
	Filters(ctx context.Context, obj *vega.DataSourceSpecConfiguration) ([]*Filter, error)
}

type DataSourceSpecConfigurationTimeResolver added in v0.73.0

type DataSourceSpecConfigurationTimeResolver interface {
	Conditions(ctx context.Context, obj *vega.DataSourceSpecConfigurationTime) ([]*Condition, error)
}

type DataSourceSpecConfigurationTimeTriggerResolver added in v0.73.0

type DataSourceSpecConfigurationTimeTriggerResolver interface {
	Conditions(ctx context.Context, obj *vega.DataSourceSpecConfigurationTimeTrigger) ([]*Condition, error)
}

type DataSourceSpecStatus added in v0.61.0

type DataSourceSpecStatus string

Describes the status of the data spec

const (
	// Describes an active data spec
	DataSourceSpecStatusStatusActive DataSourceSpecStatus = "STATUS_ACTIVE"
	// Describes a data spec that is not listening to data
	// anymore
	DataSourceSpecStatusStatusDeactivated DataSourceSpecStatus = "STATUS_DEACTIVATED"
)

func (DataSourceSpecStatus) IsValid added in v0.61.0

func (e DataSourceSpecStatus) IsValid() bool

func (DataSourceSpecStatus) MarshalGQL added in v0.61.0

func (e DataSourceSpecStatus) MarshalGQL(w io.Writer)

func (DataSourceSpecStatus) String added in v0.61.0

func (e DataSourceSpecStatus) String() string

func (*DataSourceSpecStatus) UnmarshalGQL added in v0.61.0

func (e *DataSourceSpecStatus) UnmarshalGQL(v interface{}) error

type DateRangeResolver added in v0.55.0

type DateRangeResolver interface {
	Start(ctx context.Context, obj *v2.DateRange, data *int64) error
	End(ctx context.Context, obj *v2.DateRange, data *int64) error
}

type DelegationResolver

type DelegationResolver interface {
	Party(ctx context.Context, obj *vega.Delegation) (*vega.Party, error)
	Node(ctx context.Context, obj *vega.Delegation) (*vega.Node, error)
	Epoch(ctx context.Context, obj *vega.Delegation) (int, error)
}

type DepositResolver

type DepositResolver interface {
	Party(ctx context.Context, obj *vega.Deposit) (*vega.Party, error)

	Asset(ctx context.Context, obj *vega.Deposit) (*vega.Asset, error)
}

type DirectiveRoot

type DirectiveRoot struct {
}

type DiscreteTrading

type DiscreteTrading struct {
	// Duration of the discrete trading batch in nanoseconds. Maximum 1 month.
	Duration int `json:"duration"`
	// Size of an increment in price in terms of the quote currency
	TickSize string `json:"tickSize"`
}

Frequent batch auctions trading mode

type DispatchStrategyResolver added in v0.73.0

type DispatchStrategyResolver interface {
	DispatchMetric(ctx context.Context, obj *vega.DispatchStrategy) (vega.DispatchMetric, error)
	DispatchMetricAssetID(ctx context.Context, obj *vega.DispatchStrategy) (string, error)
	MarketIdsInScope(ctx context.Context, obj *vega.DispatchStrategy) ([]string, error)

	WindowLength(ctx context.Context, obj *vega.DispatchStrategy) (int, error)
	LockPeriod(ctx context.Context, obj *vega.DispatchStrategy) (int, error)
}

type ERC20MultiSigSignerAddedBundleEdge added in v0.55.0

type ERC20MultiSigSignerAddedBundleEdge struct {
	Node   *v2.ERC20MultiSigSignerAddedBundle `json:"node"`
	Cursor string                             `json:"cursor"`
}

type ERC20MultiSigSignerAddedBundleResolver added in v0.71.0

type ERC20MultiSigSignerAddedBundleResolver interface {
	Timestamp(ctx context.Context, obj *v2.ERC20MultiSigSignerAddedBundle) (string, error)
}

type ERC20MultiSigSignerAddedConnection added in v0.55.0

type ERC20MultiSigSignerAddedConnection struct {
	Edges    []*ERC20MultiSigSignerAddedBundleEdge `json:"edges"`
	PageInfo *v2.PageInfo                          `json:"pageInfo"`
}

Response for the signature bundle to add a particular validator to the signer list of the multisig contract

type ERC20MultiSigSignerRemovedBundleEdge added in v0.55.0

type ERC20MultiSigSignerRemovedBundleEdge struct {
	Node   *v2.ERC20MultiSigSignerRemovedBundle `json:"node"`
	Cursor string                               `json:"cursor"`
}

type ERC20MultiSigSignerRemovedBundleResolver added in v0.71.0

type ERC20MultiSigSignerRemovedBundleResolver interface {
	Timestamp(ctx context.Context, obj *v2.ERC20MultiSigSignerRemovedBundle) (string, error)
}

type ERC20MultiSigSignerRemovedConnection added in v0.55.0

type ERC20MultiSigSignerRemovedConnection struct {
	// The list of signer bundles for that validator
	Edges []*ERC20MultiSigSignerRemovedBundleEdge `json:"edges"`
	// The pagination information
	PageInfo *v2.PageInfo `json:"pageInfo"`
}

Response for the signature bundle to remove a particular validator from the signer list of the multisig contract

type ERC20SetAssetLimitsBundle added in v0.55.0

type ERC20SetAssetLimitsBundle struct {
	// The address of the asset on ethereum
	AssetSource string `json:"assetSource"`
	// The ID of the vega asset
	VegaAssetID string `json:"vegaAssetId"`
	// The nonce, which is actually the internal reference for the proposal
	Nonce string `json:"nonce"`
	// The lifetime limit deposit for this asset
	LifetimeLimit string `json:"lifetimeLimit"`
	// The threshold withdraw for this asset
	Threshold string `json:"threshold"`
	// The signatures bundle as hex encoded data, forward by 0x
	// e.g: 0x + sig1 + sig2 + ... + sixN
	Signatures string `json:"signatures"`
}

Response for the signature bundle to update the token limits (maxLifetimeDeposit and withdrawThreshold) for a given ERC20 token (already allowlisted) in the collateral bridge

type ETHAddress added in v0.61.0

type ETHAddress struct {
	Address *string `json:"address"`
}

func (ETHAddress) IsSignerKind added in v0.61.0

func (ETHAddress) IsSignerKind()

type EpochParticipation

type EpochParticipation struct {
	Epoch *vega.Epoch `json:"epoch"`
	// RFC3339 timestamp
	Offline *int64 `json:"offline"`
	// RFC3339 timestamp
	Online *int64 `json:"online"`
	// Total amount rewarded for participation in the given epoch
	TotalRewards *float64 `json:"totalRewards"`
}

Summary of a node's rewards for a given epoch

type EpochResolver

type EpochResolver interface {
	ID(ctx context.Context, obj *vega.Epoch) (string, error)

	ValidatorsConnection(ctx context.Context, obj *vega.Epoch, pagination *v2.Pagination) (*v2.NodesConnection, error)
	DelegationsConnection(ctx context.Context, obj *vega.Epoch, partyID *string, nodeID *string, pagination *v2.Pagination) (*v2.DelegationsConnection, error)
}

type EpochRewardSummaryResolver added in v0.65.0

type EpochRewardSummaryResolver interface {
	Epoch(ctx context.Context, obj *vega.EpochRewardSummary) (int, error)

	RewardType(ctx context.Context, obj *vega.EpochRewardSummary) (vega.AccountType, error)
}

type EpochTimestampsResolver

type EpochTimestampsResolver interface {
	Start(ctx context.Context, obj *vega.EpochTimestamps) (*int64, error)
	Expiry(ctx context.Context, obj *vega.EpochTimestamps) (*int64, error)
	End(ctx context.Context, obj *vega.EpochTimestamps) (*int64, error)
	FirstBlock(ctx context.Context, obj *vega.EpochTimestamps) (string, error)
	LastBlock(ctx context.Context, obj *vega.EpochTimestamps) (*string, error)
}

type Erc20

type Erc20 struct {
	// The address of the ERC20 contract
	ContractAddress string `json:"contractAddress"`
	// The lifetime limits deposit per address
	// Note: this is a temporary measure that can be changed by governance
	LifetimeLimit string `json:"lifetimeLimit"`
	// The maximum you can withdraw instantly. All withdrawals over the threshold will be delayed by the withdrawal delay.
	// There is no limit on the size of a withdrawal
	// Note: this is a temporary measure that can be changed by governance
	WithdrawThreshold string `json:"withdrawThreshold"`
}

An asset originated from an Ethereum ERC20 Token

func ERC20FromProto

func ERC20FromProto(ea *types.ERC20) *Erc20

func (Erc20) IsAssetSource

func (Erc20) IsAssetSource()

type Erc20ListAssetBundle added in v0.55.0

type Erc20ListAssetBundle struct {
	// The source asset in the ethereum network
	AssetSource string `json:"assetSource"`
	// The ID of the vega asset
	VegaAssetID string `json:"vegaAssetId"`
	// The nonce to be used in the request
	Nonce string `json:"nonce"`
	// Signature aggregate from the nodes, in the following format:
	// 0x + sig1 + sig2 + ... + sigN
	Signatures string `json:"signatures"`
}

Response for the signature bundle to allowlist an ERC20 token in the collateral bridge

type Erc20WithdrawalApproval

type Erc20WithdrawalApproval struct {
	// The source asset in the ethereum network
	AssetSource string `json:"assetSource"`
	// The amount to be withdrawn
	Amount string `json:"amount"`
	// The nonce to be used in the request
	Nonce string `json:"nonce"`
	// Signature aggregate from the nodes, in the following format:
	// 0x + sig1 + sig2 + ... + sigN
	Signatures string `json:"signatures"`
	// The target address that will receive the funds
	TargetAddress string `json:"targetAddress"`
	// RFC3339Nano timestamp at which the withdrawal was created
	Creation string `json:"creation"`
}

All the data related to the approval of a withdrawal from the network

type Erc20WithdrawalDetails

type Erc20WithdrawalDetails struct {
	// The ethereum address of the receiver of the asset funds
	ReceiverAddress string `json:"receiverAddress"`
}

Specific details for an erc20 withdrawal

func (Erc20WithdrawalDetails) IsWithdrawalDetails

func (Erc20WithdrawalDetails) IsWithdrawalDetails()

type EthCallSpecResolver added in v0.73.0

type EthCallSpecResolver interface {
	Abi(ctx context.Context, obj *vega.EthCallSpec) ([]string, error)

	Args(ctx context.Context, obj *vega.EthCallSpec) ([]string, error)
	Trigger(ctx context.Context, obj *vega.EthCallSpec) (*EthCallTrigger, error)
	RequiredConfirmations(ctx context.Context, obj *vega.EthCallSpec) (int, error)
	Normalisers(ctx context.Context, obj *vega.EthCallSpec) ([]*Normaliser, error)
	Filters(ctx context.Context, obj *vega.EthCallSpec) ([]*Filter, error)
}

type EthCallTrigger added in v0.73.0

type EthCallTrigger struct {
	Trigger TriggerKind `json:"trigger"`
}

EthCallTrigger is the type of trigger used to make calls to Ethereum network.

type EthTimeTrigger added in v0.73.0

type EthTimeTrigger struct {
	// Trigger when the Ethereum time is greater or equal to this time, in Unix seconds.
	Initial *int64 `json:"initial"`
	// Repeat the call every n seconds after the initial call. If no time for
	// initial call was specified, begin repeating immediately.
	Every *int `json:"every"`
	// If repeating, stop once Ethereum time is greater than this time, in Unix
	// seconds. If not set, then repeat indefinitely.
	Until *int64 `json:"until"`
}

Trigger for an Ethereum call based on the Ethereum block timestamp. Can be one-off or repeating.

func (EthTimeTrigger) IsTriggerKind added in v0.73.0

func (EthTimeTrigger) IsTriggerKind()

type EthereumEvent

type EthereumEvent struct {
	// The ID of the ethereum contract to use (string)
	ContractID string `json:"contractId"`
	// Name of the Ethereum event to listen to. (string)
	Event string `json:"event"`
}

An Ethereum data source

func (EthereumEvent) IsOracle

func (EthereumEvent) IsOracle()

type EthereumKeyRotationResolver

type EthereumKeyRotationResolver interface {
	BlockHeight(ctx context.Context, obj *v1.EthereumKeyRotation) (string, error)
}

type Event

type Event interface {
	IsEvent()
}

Union type for wrapped events in stream PROPOSAL is mapped to governance data, something to keep in mind

type ExternalData added in v0.61.0

type ExternalData struct {
	Data *Data `json:"data"`
}

type ExternalDataSourceKind added in v0.62.0

type ExternalDataSourceKind interface {
	IsExternalDataSourceKind()
}

type ExternalDataSourceSpec added in v0.61.0

type ExternalDataSourceSpec struct {
	Spec *DataSourceSpec `json:"spec"`
}

externalDataSourceSpec is the type that wraps the DataSourceSpec type in order to be further used/extended by the OracleSpec

type FeeEstimate added in v0.71.0

type FeeEstimate struct {
	// The estimated fees if the order was to trade
	Fees *TradeFee `json:"fees"`
	// The total estimated amount of fees if the order was to trade
	TotalFeeAmount string `json:"totalFeeAmount"`
}

An estimate of the fee to be paid for the order

type FeesStatsResolver added in v0.73.0

type FeesStatsResolver interface {
	MarketID(ctx context.Context, obj *v1.FeesStats) (string, error)
	AssetID(ctx context.Context, obj *v1.FeesStats) (string, error)
	Epoch(ctx context.Context, obj *v1.FeesStats) (int, error)
}

type Filter added in v0.73.0

type Filter struct {
	// key is the data source data property key targeted by the filter.
	Key *PropertyKey `json:"key"`
	// The conditions that should be matched by the data to be
	// considered of interest.
	Conditions []*Condition `json:"conditions"`
}

Filter describes the conditions under which oracle data is considered of interest or not.

type FundingPaymentResolver added in v0.73.0

type FundingPaymentResolver interface {
	FundingPeriodSeq(ctx context.Context, obj *v2.FundingPayment) (int, error)
}

type FundingPeriodDataPointResolver added in v0.73.0

type FundingPeriodDataPointResolver interface {
	Seq(ctx context.Context, obj *v1.FundingPeriodDataPoint) (int, error)
	DataPointSource(ctx context.Context, obj *v1.FundingPeriodDataPoint) (*v1.FundingPeriodDataPoint_Source, error)
}

type FundingPeriodResolver added in v0.73.0

type FundingPeriodResolver interface {
	Seq(ctx context.Context, obj *v1.FundingPeriod) (int, error)
	StartTime(ctx context.Context, obj *v1.FundingPeriod) (int64, error)
	EndTime(ctx context.Context, obj *v1.FundingPeriod) (*int64, error)
}

type FutureProductResolver

type FutureProductResolver interface {
	SettlementAsset(ctx context.Context, obj *vega.FutureProduct) (*vega.Asset, error)
}

type FutureResolver

type FutureResolver interface {
	SettlementAsset(ctx context.Context, obj *vega.Future) (*vega.Asset, error)

	DataSourceSpecForSettlementData(ctx context.Context, obj *vega.Future) (*DataSourceSpec, error)
	DataSourceSpecForTradingTermination(ctx context.Context, obj *vega.Future) (*DataSourceSpec, error)
}

type GovernanceTransferKind added in v0.72.0

type GovernanceTransferKind interface {
	IsGovernanceTransferKind()
}

type GovernanceTransferType added in v0.72.0

type GovernanceTransferType string
const (
	// Default value, always invalid
	GovernanceTransferTypeGovernanceTransferTypeUnspecified GovernanceTransferType = "GOVERNANCE_TRANSFER_TYPE_UNSPECIFIED"
	// Transfers the specified amount or does not transfer anything
	GovernanceTransferTypeGovernanceTransferTypeAllOrNothing GovernanceTransferType = "GOVERNANCE_TRANSFER_TYPE_ALL_OR_NOTHING"
	// Transfers the specified amount or the max allowable amount if this is less than the specified amount
	GovernanceTransferTypeGovernanceTransferTypeBestEffort GovernanceTransferType = "GOVERNANCE_TRANSFER_TYPE_BEST_EFFORT"
)

func (GovernanceTransferType) IsValid added in v0.72.0

func (e GovernanceTransferType) IsValid() bool

func (GovernanceTransferType) MarshalGQL added in v0.72.0

func (e GovernanceTransferType) MarshalGQL(w io.Writer)

func (GovernanceTransferType) String added in v0.72.0

func (e GovernanceTransferType) String() string

func (*GovernanceTransferType) UnmarshalGQL added in v0.72.0

func (e *GovernanceTransferType) UnmarshalGQL(v interface{}) error

type GraphServer

type GraphServer struct {
	gateway.Config
	// contains filtered or unexported fields
}

GraphServer is the graphql server.

func New

func New(
	log *logging.Logger,
	config gateway.Config,
	vegaPaths paths.Paths,
) (*GraphServer, error)

New returns a new instance of the grapqhl server.

func (*GraphServer) ReloadConf

func (g *GraphServer) ReloadConf(cfg gateway.Config)

ReloadConf update the internal configuration of the graphql server.

func (*GraphServer) Start

func (g *GraphServer) Start() (http.Handler, error)

Start starts the server in order receive http request.

type IcebergOrderResolver added in v0.72.0

type IcebergOrderResolver interface {
	PeakSize(ctx context.Context, obj *vega.IcebergOrder) (string, error)
	MinimumVisibleSize(ctx context.Context, obj *vega.IcebergOrder) (string, error)
	ReservedRemaining(ctx context.Context, obj *vega.IcebergOrder) (string, error)
}

type InstrumentConfigurationResolver

type InstrumentConfigurationResolver interface {
	FutureProduct(ctx context.Context, obj *vega.InstrumentConfiguration) (*vega.FutureProduct, error)
	Product(ctx context.Context, obj *vega.InstrumentConfiguration) (ProductConfiguration, error)
}

type InstrumentResolver

type InstrumentResolver interface {
	Product(ctx context.Context, obj *vega.Instrument) (Product, error)
}

type InternalDataSourceKind added in v0.62.0

type InternalDataSourceKind interface {
	IsInternalDataSourceKind()
}

type KeyRotationResolver

type KeyRotationResolver interface {
	BlockHeight(ctx context.Context, obj *v1.KeyRotation) (string, error)
}

type LedgerEntryResolver added in v0.71.0

type LedgerEntryResolver interface {
	FromAccountID(ctx context.Context, obj *vega.LedgerEntry) (*vega.AccountDetails, error)
	ToAccountID(ctx context.Context, obj *vega.LedgerEntry) (*vega.AccountDetails, error)
}

type LiquidityMonitoringParameters

type LiquidityMonitoringParameters struct {
	// Specifies parameters related to target stake calculation
	TargetStakeParameters *TargetStakeParameters `json:"targetStakeParameters"`
	// Specifies the triggering ratio for entering liquidity auction
	TriggeringRatio string `json:"triggeringRatio"`
	// Specifies by how many seconds an auction should be extended if leaving the auction were to trigger a liquidity auction
	AuctionExtensionSecs int `json:"auctionExtensionSecs"`
}

Configuration of a market liquidity monitoring parameters

type LiquidityOrderReferenceResolver

type LiquidityOrderReferenceResolver interface {
	Order(ctx context.Context, obj *vega.LiquidityOrderReference) (*vega.Order, error)
}

type LiquidityProviderFeeShare

type LiquidityProviderFeeShare struct {
	// The liquidity provider party ID
	Party *vega.Party `json:"party"`
	// The share owned by this liquidity provider
	EquityLikeShare string `json:"equityLikeShare"`
	// The average entry valuation of the liquidity provider for the market
	AverageEntryValuation string `json:"averageEntryValuation"`
	// The average liquidity score
	AverageScore string `json:"averageScore"`
	// The virtual stake for this liquidity provider
	VirtualStake string `json:"virtualStake"`
}

The equity like share of liquidity fee for each liquidity provider

type LiquidityProviderResolver added in v0.73.0

type LiquidityProviderResolver interface {
	FeeShare(ctx context.Context, obj *v2.LiquidityProvider) (*LiquidityProviderFeeShare, error)
	SLA(ctx context.Context, obj *v2.LiquidityProvider) (*LiquidityProviderSLA, error)
}

type LiquidityProviderSLA added in v0.73.0

type LiquidityProviderSLA struct {
	// The liquidity provider party ID
	Party *vega.Party `json:"party"`
	// Indicates how often LP meets the commitment during the current epoch.
	CurrentEpochFractionOfTimeOnBook string `json:"currentEpochFractionOfTimeOnBook"`
	// Indicates how often LP met the commitment in the previous epoch.
	LastEpochFractionOfTimeOnBook string `json:"lastEpochFractionOfTimeOnBook"`
	// Indicates the fee penalty amount applied in the previous epoch.
	LastEpochFeePenalty string `json:"lastEpochFeePenalty"`
	// Indicates the bond penalty amount applied in the previous epoch.
	LastEpochBondPenalty string `json:"lastEpochBondPenalty"`
	// Determines how the fee penalties from past epochs affect future fee revenue.
	HysteresisPeriodFeePenalties []string `json:"hysteresisPeriodFeePenalties"`
	// Represents the total amount of funds LP must supply. The amount to be supplied is in the market’s settlement currency, spread on both buy and sell sides of the order book within a defined range.
	RequiredLiquidity string `json:"requiredLiquidity"`
	// Notional volume of orders within the range provided on the buy side of the book.
	NotionalVolumeBuys string `json:"notionalVolumeBuys"`
	// Notional volume of orders within the range provided on the sell side of the book.
	NotionalVolumeSells string `json:"notionalVolumeSells"`
}

The SLA statistics for each liquidity provider

type LiquidityProvisionResolver

type LiquidityProvisionResolver interface {
	Party(ctx context.Context, obj *vega.LiquidityProvision) (*vega.Party, error)

	Market(ctx context.Context, obj *vega.LiquidityProvision) (*vega.Market, error)

	Version(ctx context.Context, obj *vega.LiquidityProvision) (string, error)
}

type LiquidityProvisionUpdateResolver added in v0.55.0

type LiquidityProvisionUpdateResolver interface {
	Version(ctx context.Context, obj *vega.LiquidityProvision) (string, error)
}

type LiquiditySLAParametersResolver added in v0.73.0

type LiquiditySLAParametersResolver interface {
	PerformanceHysteresisEpochs(ctx context.Context, obj *vega.LiquiditySLAParameters) (int, error)
}

type LossSocialization

type LossSocialization struct {
	// The market ID where loss socialization happened
	MarketID string `json:"marketId"`
	// The party that was part of the loss socialization
	PartyID string `json:"partyId"`
	// The amount lost
	Amount string `json:"amount"`
}

type MarginLevelsResolver

type MarginLevelsResolver interface {
	Market(ctx context.Context, obj *vega.MarginLevels) (*vega.Market, error)
	Asset(ctx context.Context, obj *vega.MarginLevels) (*vega.Asset, error)
	Party(ctx context.Context, obj *vega.MarginLevels) (*vega.Party, error)
	MaintenanceLevel(ctx context.Context, obj *vega.MarginLevels) (string, error)

	InitialLevel(ctx context.Context, obj *vega.MarginLevels) (string, error)
}

type MarginLevelsUpdateResolver added in v0.55.0

type MarginLevelsUpdateResolver interface {
	MaintenanceLevel(ctx context.Context, obj *vega.MarginLevels) (string, error)

	InitialLevel(ctx context.Context, obj *vega.MarginLevels) (string, error)
}

type MarketDataCommitments

type MarketDataCommitments struct {
	// A set of liquidity sell orders to meet the liquidity provision obligation.
	Sells []*vega.LiquidityOrderReference `json:"sells"`
	// A set of liquidity buy orders to meet the liquidity provision obligation.
	Buys []*vega.LiquidityOrderReference `json:"buys"`
}

The liquidity commitments for this market

type MarketDataResolver

type MarketDataResolver interface {
	Market(ctx context.Context, obj *vega.MarketData) (*vega.Market, error)

	BestBidVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	BestOfferVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	BestStaticBidVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	BestStaticOfferVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	OpenInterest(ctx context.Context, obj *vega.MarketData) (string, error)
	AuctionEnd(ctx context.Context, obj *vega.MarketData) (*string, error)
	AuctionStart(ctx context.Context, obj *vega.MarketData) (*string, error)

	IndicativeVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	Commitments(ctx context.Context, obj *vega.MarketData) (*MarketDataCommitments, error)
	PriceMonitoringBounds(ctx context.Context, obj *vega.MarketData) ([]*PriceMonitoringBounds, error)

	LiquidityProviderFeeShare(ctx context.Context, obj *vega.MarketData) ([]*LiquidityProviderFeeShare, error)
	LiquidityProviderSLA(ctx context.Context, obj *vega.MarketData) ([]*LiquidityProviderSLA, error)
	NextMarkToMarket(ctx context.Context, obj *vega.MarketData) (string, error)

	ProductData(ctx context.Context, obj *vega.MarketData) (ProductData, error)
}

type MarketDepthResolver

type MarketDepthResolver interface {
	Market(ctx context.Context, obj *vega.MarketDepth) (*vega.Market, error)

	LastTrade(ctx context.Context, obj *vega.MarketDepth) (*vega.Trade, error)
	SequenceNumber(ctx context.Context, obj *vega.MarketDepth) (string, error)
}

type MarketDepthTrade

type MarketDepthTrade struct {
	// ID of the trade for the given market (if available)
	ID string `json:"id"`
	// Price of the trade
	Price string `json:"price"`
	// Size of the trade
	Size string `json:"size"`
}

type MarketDepthUpdateResolver

type MarketDepthUpdateResolver interface {
	Market(ctx context.Context, obj *vega.MarketDepthUpdate) (*vega.Market, error)

	SequenceNumber(ctx context.Context, obj *vega.MarketDepthUpdate) (string, error)
	PreviousSequenceNumber(ctx context.Context, obj *vega.MarketDepthUpdate) (string, error)
}

type MarketEvent

type MarketEvent struct {
	// The market ID
	MarketID string `json:"marketId"`
	// The message - market events are used for logging
	Payload string `json:"payload"`
}

type MarketLogEvent

type MarketLogEvent interface {
	GetMarketID() string
	GetPayload() string
}

type MarketResolver

type MarketResolver interface {
	DecimalPlaces(ctx context.Context, obj *vega.Market) (int, error)

	OpeningAuction(ctx context.Context, obj *vega.Market) (*AuctionDuration, error)
	PriceMonitoringSettings(ctx context.Context, obj *vega.Market) (*PriceMonitoringSettings, error)
	LiquidityMonitoringParameters(ctx context.Context, obj *vega.Market) (*LiquidityMonitoringParameters, error)

	Proposal(ctx context.Context, obj *vega.Market) (*vega.GovernanceData, error)
	OrdersConnection(ctx context.Context, obj *vega.Market, pagination *v2.Pagination, filter *OrderByPartyIdsFilter) (*v2.OrderConnection, error)
	AccountsConnection(ctx context.Context, obj *vega.Market, partyID *string, pagination *v2.Pagination) (*v2.AccountsConnection, error)
	TradesConnection(ctx context.Context, obj *vega.Market, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.TradeConnection, error)
	Depth(ctx context.Context, obj *vega.Market, maxDepth *int) (*vega.MarketDepth, error)
	CandlesConnection(ctx context.Context, obj *vega.Market, since string, to *string, interval vega.Interval, pagination *v2.Pagination) (*v2.CandleDataConnection, error)
	Data(ctx context.Context, obj *vega.Market) (*vega.MarketData, error)
	LiquidityProvisions(ctx context.Context, obj *vega.Market, partyID *string, live *bool, pagination *v2.Pagination) (*v2.LiquidityProvisionsWithPendingConnection, error)
	LiquidityProvisionsConnection(ctx context.Context, obj *vega.Market, partyID *string, live *bool, pagination *v2.Pagination) (*v2.LiquidityProvisionsConnection, error)

	RiskFactors(ctx context.Context, obj *vega.Market) (*vega.RiskFactor, error)

	LiquiditySLAParameters(ctx context.Context, obj *vega.Market) (*vega.LiquiditySLAParameters, error)
}

type MarketTick

type MarketTick struct {
	// The market ID
	MarketID string `json:"marketId"`
	// The block time
	Time string `json:"time"`
}

type MarketUpdateType added in v0.73.0

type MarketUpdateType string
const (
	// Default value, always invalid
	MarketUpdateTypeMarketStateUpdateTypeUnspecified MarketUpdateType = "MARKET_STATE_UPDATE_TYPE_UNSPECIFIED"
	// Terminate the market
	MarketUpdateTypeMarketStateUpdateTypeTerminate MarketUpdateType = "MARKET_STATE_UPDATE_TYPE_TERMINATE"
	// Suspend the market
	MarketUpdateTypeMarketStateUpdateTypeSuspend MarketUpdateType = "MARKET_STATE_UPDATE_TYPE_SUSPEND"
	// Resume a suspended market
	MarketUpdateTypeMarketStateUpdateTypeResume MarketUpdateType = "MARKET_STATE_UPDATE_TYPE_RESUME"
)

func (MarketUpdateType) IsValid added in v0.73.0

func (e MarketUpdateType) IsValid() bool

func (MarketUpdateType) MarshalGQL added in v0.73.0

func (e MarketUpdateType) MarshalGQL(w io.Writer)

func (MarketUpdateType) String added in v0.73.0

func (e MarketUpdateType) String() string

func (*MarketUpdateType) UnmarshalGQL added in v0.73.0

func (e *MarketUpdateType) UnmarshalGQL(v interface{}) error

type NewAssetResolver

type NewAssetResolver interface {
	Name(ctx context.Context, obj *vega.NewAsset) (string, error)
	Symbol(ctx context.Context, obj *vega.NewAsset) (string, error)
	Decimals(ctx context.Context, obj *vega.NewAsset) (int, error)
	Quantum(ctx context.Context, obj *vega.NewAsset) (string, error)
	Source(ctx context.Context, obj *vega.NewAsset) (AssetSource, error)
}

type NewFreeformResolver

type NewFreeformResolver interface {
	DoNotUse(ctx context.Context, obj *vega.NewFreeform) (*bool, error)
}

type NewMarketResolver

type NewMarketResolver interface {
	Instrument(ctx context.Context, obj *vega.NewMarket) (*vega.InstrumentConfiguration, error)
	DecimalPlaces(ctx context.Context, obj *vega.NewMarket) (int, error)
	RiskParameters(ctx context.Context, obj *vega.NewMarket) (RiskModel, error)
	Metadata(ctx context.Context, obj *vega.NewMarket) ([]string, error)
	PriceMonitoringParameters(ctx context.Context, obj *vega.NewMarket) (*PriceMonitoringParameters, error)
	LiquidityMonitoringParameters(ctx context.Context, obj *vega.NewMarket) (*LiquidityMonitoringParameters, error)
	PositionDecimalPlaces(ctx context.Context, obj *vega.NewMarket) (int, error)
	LinearSlippageFactor(ctx context.Context, obj *vega.NewMarket) (string, error)
	QuadraticSlippageFactor(ctx context.Context, obj *vega.NewMarket) (string, error)
	SuccessorConfiguration(ctx context.Context, obj *vega.NewMarket) (*vega.SuccessorConfiguration, error)
	LiquiditySLAParameters(ctx context.Context, obj *vega.NewMarket) (*vega.LiquiditySLAParameters, error)
}

type NewSpotMarketResolver added in v0.73.0

type NewSpotMarketResolver interface {
	Instrument(ctx context.Context, obj *vega.NewSpotMarket) (*vega.InstrumentConfiguration, error)
	DecimalPlaces(ctx context.Context, obj *vega.NewSpotMarket) (int, error)
	Metadata(ctx context.Context, obj *vega.NewSpotMarket) ([]string, error)
	PriceMonitoringParameters(ctx context.Context, obj *vega.NewSpotMarket) (*PriceMonitoringParameters, error)
	TargetStakeParameters(ctx context.Context, obj *vega.NewSpotMarket) (*TargetStakeParameters, error)
	RiskParameters(ctx context.Context, obj *vega.NewSpotMarket) (RiskModel, error)
	PositionDecimalPlaces(ctx context.Context, obj *vega.NewSpotMarket) (int, error)
	LiquiditySLAParams(ctx context.Context, obj *vega.NewSpotMarket) (*vega.LiquiditySLAParameters, error)
}

type NewTransferResolver added in v0.72.0

type NewTransferResolver interface {
	Source(ctx context.Context, obj *vega.NewTransfer) (string, error)
	SourceType(ctx context.Context, obj *vega.NewTransfer) (vega.AccountType, error)
	Destination(ctx context.Context, obj *vega.NewTransfer) (string, error)
	DestinationType(ctx context.Context, obj *vega.NewTransfer) (vega.AccountType, error)
	Asset(ctx context.Context, obj *vega.NewTransfer) (*vega.Asset, error)
	FractionOfBalance(ctx context.Context, obj *vega.NewTransfer) (string, error)
	Amount(ctx context.Context, obj *vega.NewTransfer) (string, error)
	TransferType(ctx context.Context, obj *vega.NewTransfer) (GovernanceTransferType, error)
	Kind(ctx context.Context, obj *vega.NewTransfer) (GovernanceTransferKind, error)
}

type NodeDataResolver

type NodeDataResolver interface {
	TendermintNodes(ctx context.Context, obj *vega.NodeData) (*NodeSet, error)
	ErsatzNodes(ctx context.Context, obj *vega.NodeData) (*NodeSet, error)
	PendingNodes(ctx context.Context, obj *vega.NodeData) (*NodeSet, error)
	Uptime(ctx context.Context, obj *vega.NodeData) (float64, error)
}

type NodeResolver

type NodeResolver interface {
	DelegationsConnection(ctx context.Context, obj *vega.Node, partyID *string, pagination *v2.Pagination) (*v2.DelegationsConnection, error)
}

type NodeSet added in v0.63.0

type NodeSet struct {
	// Total number of nodes in the node set
	Total int `json:"total"`
	// Number of nodes in the node set that had a performance score of 0 at the end of the last epoch
	Inactive int `json:"inactive"`
	// IDs of the nodes that were promoted into this node set at the start of the epoch
	Promoted []string `json:"promoted"`
	// IDs of the nodes that were demoted into this node set at the start of the epoch
	Demoted []string `json:"demoted"`
	// Total number of nodes allowed in the node set
	Maximum *int `json:"maximum"`
}

Details on the collection of nodes for particular validator status

type NodeSignatureResolver

type NodeSignatureResolver interface {
	Signature(ctx context.Context, obj *v11.NodeSignature) (*string, error)
}

type Normaliser added in v0.73.0

type Normaliser struct {
	Name       string `json:"name"`
	Expression string `json:"expression"`
}

Normaliser to convert the data returned from the contract method into a standard format.

type ObservableLiquidityProviderFeeShare

type ObservableLiquidityProviderFeeShare struct {
	// The liquidity provider party ID
	PartyID string `json:"partyId"`
	// The share owned by this liquidity provider (float)
	EquityLikeShare string `json:"equityLikeShare"`
	// The average entry valuation of the liquidity provider for the market
	AverageEntryValuation string `json:"averageEntryValuation"`
	// The average liquidity score
	AverageScore string `json:"averageScore"`
}

The equity like share of liquidity fee for each liquidity provider

type ObservableLiquidityProviderSLA added in v0.73.0

type ObservableLiquidityProviderSLA struct {
	// The liquidity provider party ID
	Party string `json:"party"`
	// Indicates how often LP meets the commitment during the current epoch.
	CurrentEpochFractionOfTimeOnBook string `json:"currentEpochFractionOfTimeOnBook"`
	// Indicates how often LP meets the commitment during last epoch.
	LastEpochFractionOfTimeOnBook string `json:"lastEpochFractionOfTimeOnBook"`
	// Indicates the fee penalty amount applied in the previous epoch.
	LastEpochFeePenalty string `json:"lastEpochFeePenalty"`
	// Indicates the bond penalty amount applied in the previous epoch.
	LastEpochBondPenalty string `json:"lastEpochBondPenalty"`
	// Determines how the fee penalties from past epochs affect future fee revenue.
	HysteresisPeriodFeePenalties []string `json:"hysteresisPeriodFeePenalties"`
	// Represents the total amount of funds LP must supply. The amount to be supplied is in the market’s settlement currency, spread on both buy and sell sides of the order book within a defined range.
	RequiredLiquidity string `json:"requiredLiquidity"`
	// Notional volume of orders within the range provided on the buy side of the book.
	NotionalVolumeBuys string `json:"notionalVolumeBuys"`
	// Notional volume of orders within the range provided on the sell side of the book.
	NotionalVolumeSells string `json:"notionalVolumeSells"`
}

The SLA statistics for each liquidity provider

type ObservableMarketDataResolver

type ObservableMarketDataResolver interface {
	MarketID(ctx context.Context, obj *vega.MarketData) (string, error)

	BestBidVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	BestOfferVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	BestStaticBidVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	BestStaticOfferVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	OpenInterest(ctx context.Context, obj *vega.MarketData) (string, error)
	AuctionEnd(ctx context.Context, obj *vega.MarketData) (*string, error)
	AuctionStart(ctx context.Context, obj *vega.MarketData) (*string, error)

	IndicativeVolume(ctx context.Context, obj *vega.MarketData) (string, error)

	PriceMonitoringBounds(ctx context.Context, obj *vega.MarketData) ([]*PriceMonitoringBounds, error)

	LiquidityProviderFeeShare(ctx context.Context, obj *vega.MarketData) ([]*ObservableLiquidityProviderFeeShare, error)
	LiquidityProviderSLA(ctx context.Context, obj *vega.MarketData) ([]*ObservableLiquidityProviderSLA, error)
	NextMarkToMarket(ctx context.Context, obj *vega.MarketData) (string, error)

	ProductData(ctx context.Context, obj *vega.MarketData) (ProductData, error)
}

type ObservableMarketDepthResolver

type ObservableMarketDepthResolver interface {
	LastTrade(ctx context.Context, obj *vega.MarketDepth) (*MarketDepthTrade, error)
	SequenceNumber(ctx context.Context, obj *vega.MarketDepth) (string, error)
}

type ObservableMarketDepthUpdateResolver

type ObservableMarketDepthUpdateResolver interface {
	SequenceNumber(ctx context.Context, obj *vega.MarketDepthUpdate) (string, error)
	PreviousSequenceNumber(ctx context.Context, obj *vega.MarketDepthUpdate) (string, error)
}

type Oracle

type Oracle interface {
	IsOracle()
}

type OracleDataResolver

type OracleDataResolver interface {
	ExternalData(ctx context.Context, obj *vega.OracleData) (*ExternalData, error)
}

type OracleSpecResolver

type OracleSpecResolver interface {
	DataSourceSpec(ctx context.Context, obj *vega.OracleSpec) (*ExternalDataSourceSpec, error)
	DataConnection(ctx context.Context, obj *vega.OracleSpec, pagination *v2.Pagination) (*v2.OracleDataConnection, error)
}

type OrderByMarketAndPartyIdsFilter added in v0.70.0

type OrderByMarketAndPartyIdsFilter struct {
	Order     *v2.OrderFilter `json:"order"`
	MarketIds []string        `json:"marketIds"`
	PartyIds  []string        `json:"partyIds"`
}

type OrderByMarketIdsFilter added in v0.70.0

type OrderByMarketIdsFilter struct {
	Order     *v2.OrderFilter `json:"order"`
	MarketIds []string        `json:"marketIds"`
}

type OrderByPartyIdsFilter added in v0.70.0

type OrderByPartyIdsFilter struct {
	Order    *v2.OrderFilter `json:"order"`
	PartyIds []string        `json:"partyIds"`
}

type OrderEstimate

type OrderEstimate struct {
	// The estimated fee if the order was to trade
	Fee *TradeFee `json:"fee"`
	// The total estimated amount of fee if the order was to trade
	TotalFeeAmount string `json:"totalFeeAmount"`
	// The margin requirement for this order
	MarginLevels *vega.MarginLevels `json:"marginLevels"`
}

An estimate of the fee to be paid by the order

type OrderFilterResolver added in v0.63.0

type OrderFilterResolver interface {
	Status(ctx context.Context, obj *v2.OrderFilter, data []vega.Order_Status) error

	TimeInForce(ctx context.Context, obj *v2.OrderFilter, data []vega.Order_TimeInForce) error
}

type OrderInfo added in v0.71.0

type OrderInfo struct {
	// Whether the order is to buy or sell
	Side vega.Side `json:"side"`
	// Price for the order
	Price string `json:"price"`
	// Number of units remaining of the total that have not yet been bought or sold (uint64)
	Remaining string `json:"remaining"`
	// Boolean indicating a market order
	IsMarketOrder bool `json:"isMarketOrder"`
}

Basic description of an order

type OrderResolver

type OrderResolver interface {
	Market(ctx context.Context, obj *vega.Order) (*vega.Market, error)
	Size(ctx context.Context, obj *vega.Order) (string, error)
	Remaining(ctx context.Context, obj *vega.Order) (string, error)
	Party(ctx context.Context, obj *vega.Order) (*vega.Party, error)

	TradesConnection(ctx context.Context, obj *vega.Order, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.TradeConnection, error)

	RejectionReason(ctx context.Context, obj *vega.Order) (*vega.OrderError, error)
	Version(ctx context.Context, obj *vega.Order) (string, error)

	LiquidityProvision(ctx context.Context, obj *vega.Order) (*vega.LiquidityProvision, error)
}

type OrderSubmissionResolver added in v0.72.0

type OrderSubmissionResolver interface {
	Size(ctx context.Context, obj *v11.OrderSubmission) (string, error)

	IcebergOrder(ctx context.Context, obj *v11.OrderSubmission) (*vega.IcebergOrder, error)
}

type OrderUpdateResolver added in v0.55.0

type OrderUpdateResolver interface {
	Size(ctx context.Context, obj *vega.Order) (string, error)
	Remaining(ctx context.Context, obj *vega.Order) (string, error)

	RejectionReason(ctx context.Context, obj *vega.Order) (*vega.OrderError, error)
	Version(ctx context.Context, obj *vega.Order) (string, error)
}

type PaidLiquidityFeesResolver added in v0.73.0

type PaidLiquidityFeesResolver interface {
	MarketID(ctx context.Context, obj *v1.PaidLiquidityFeesStats) (string, error)
	AssetID(ctx context.Context, obj *v1.PaidLiquidityFeesStats) (string, error)
	Epoch(ctx context.Context, obj *v1.PaidLiquidityFeesStats) (int, error)
}

type PartyActivityStreakResolver added in v0.73.0

type PartyActivityStreakResolver interface {
	ActiveFor(ctx context.Context, obj *v1.PartyActivityStreak) (int, error)
	InactiveFor(ctx context.Context, obj *v1.PartyActivityStreak) (int, error)

	RewardDistributionMultiplier(ctx context.Context, obj *v1.PartyActivityStreak) (string, error)
	RewardVestingMultiplier(ctx context.Context, obj *v1.PartyActivityStreak) (string, error)
	Epoch(ctx context.Context, obj *v1.PartyActivityStreak) (int, error)
}

type PartyAmountResolver added in v0.73.0

type PartyAmountResolver interface {
	PartyID(ctx context.Context, obj *v1.PartyAmount) (string, error)
}

type PartyLockedBalanceResolver added in v0.73.0

type PartyLockedBalanceResolver interface {
	Asset(ctx context.Context, obj *v1.PartyLockedBalance) (*vega.Asset, error)

	UntilEpoch(ctx context.Context, obj *v1.PartyLockedBalance) (int, error)
}

type PartyResolver

type PartyResolver interface {
	OrdersConnection(ctx context.Context, obj *vega.Party, pagination *v2.Pagination, filter *OrderByMarketIdsFilter) (*v2.OrderConnection, error)
	TradesConnection(ctx context.Context, obj *vega.Party, marketID *string, dataRange *v2.DateRange, pagination *v2.Pagination) (*v2.TradeConnection, error)
	AccountsConnection(ctx context.Context, obj *vega.Party, marketID *string, assetID *string, typeArg *vega.AccountType, pagination *v2.Pagination) (*v2.AccountsConnection, error)
	PositionsConnection(ctx context.Context, obj *vega.Party, market *string, pagination *v2.Pagination) (*v2.PositionConnection, error)
	MarginsConnection(ctx context.Context, obj *vega.Party, marketID *string, pagination *v2.Pagination) (*v2.MarginConnection, error)
	ProposalsConnection(ctx context.Context, obj *vega.Party, proposalType *v2.ListGovernanceDataRequest_Type, inState *vega.Proposal_State, pagination *v2.Pagination) (*v2.GovernanceDataConnection, error)
	VotesConnection(ctx context.Context, obj *vega.Party, pagination *v2.Pagination) (*ProposalVoteConnection, error)
	WithdrawalsConnection(ctx context.Context, obj *vega.Party, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.WithdrawalsConnection, error)
	DepositsConnection(ctx context.Context, obj *vega.Party, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.DepositsConnection, error)
	LiquidityProvisions(ctx context.Context, obj *vega.Party, marketID *string, reference *string, live *bool, pagination *v2.Pagination) (*v2.LiquidityProvisionsWithPendingConnection, error)
	LiquidityProvisionsConnection(ctx context.Context, obj *vega.Party, marketID *string, reference *string, live *bool, pagination *v2.Pagination) (*v2.LiquidityProvisionsConnection, error)
	DelegationsConnection(ctx context.Context, obj *vega.Party, nodeID *string, pagination *v2.Pagination) (*v2.DelegationsConnection, error)
	StakingSummary(ctx context.Context, obj *vega.Party, pagination *v2.Pagination) (*StakingSummary, error)
	RewardsConnection(ctx context.Context, obj *vega.Party, assetID *string, pagination *v2.Pagination, fromEpoch *int, toEpoch *int) (*v2.RewardsConnection, error)
	RewardSummaries(ctx context.Context, obj *vega.Party, assetID *string) ([]*vega.RewardSummary, error)
	TransfersConnection(ctx context.Context, obj *vega.Party, direction *TransferDirection, pagination *v2.Pagination, isReward *bool) (*v2.TransferConnection, error)
	ActivityStreak(ctx context.Context, obj *vega.Party, epoch *int) (*v1.PartyActivityStreak, error)
	VestingBalancesSummary(ctx context.Context, obj *vega.Party, assetID *string) (*v2.GetVestingBalancesSummaryResponse, error)
	VestingStats(ctx context.Context, obj *vega.Party) (*v2.GetPartyVestingStatsResponse, error)
}

type PartyStakeResolver

type PartyStakeResolver interface {
	Linkings(ctx context.Context, obj *v2.GetStakeResponse) ([]*v1.StakeLinking, error)
}

type PartyVestingBalanceResolver added in v0.73.0

type PartyVestingBalanceResolver interface {
	Asset(ctx context.Context, obj *v1.PartyVestingBalance) (*vega.Asset, error)
}

type PartyVestingBalancesSummaryResolver added in v0.73.0

type PartyVestingBalancesSummaryResolver interface {
	Epoch(ctx context.Context, obj *v2.GetVestingBalancesSummaryResponse) (*int, error)
}

type PartyVestingStatsResolver added in v0.73.0

type PartyVestingStatsResolver interface {
	EpochSeq(ctx context.Context, obj *v2.GetPartyVestingStatsResponse) (int, error)
}

type PerpetualProductResolver added in v0.73.0

type PerpetualProductResolver interface {
	SettlementAsset(ctx context.Context, obj *vega.PerpetualProduct) (*vega.Asset, error)
}

type PerpetualResolver added in v0.73.0

type PerpetualResolver interface {
	SettlementAsset(ctx context.Context, obj *vega.Perpetual) (*vega.Asset, error)

	DataSourceSpecForSettlementSchedule(ctx context.Context, obj *vega.Perpetual) (*DataSourceSpec, error)
	DataSourceSpecForSettlementData(ctx context.Context, obj *vega.Perpetual) (*DataSourceSpec, error)
}

type PositionEstimate added in v0.71.0

type PositionEstimate struct {
	// Margin level range estimate for the specified position
	Margin *v2.MarginEstimate `json:"margin"`
	// Liquidation price range estimate for the specified position. Only populated if available collateral was specified in the request
	Liquidation *v2.LiquidationEstimate `json:"liquidation"`
}

Response for the estimate of the margin level and, if available, collateral was provided in the request, liquidation price for the specified position

type PositionResolution

type PositionResolution struct {
	// The market ID where position resolution happened
	MarketID string `json:"marketId"`
	// Number of distressed parties on market
	Distressed int `json:"distressed"`
	// Number of parties closed out
	Closed int `json:"closed"`
	// The mark price at which parties were distressed/closed out
	MarkPrice string `json:"markPrice"`
}

type PositionResolver

type PositionResolver interface {
	Market(ctx context.Context, obj *vega.Position) (*vega.Market, error)
	Party(ctx context.Context, obj *vega.Position) (*vega.Party, error)
	OpenVolume(ctx context.Context, obj *vega.Position) (string, error)

	LossSocializationAmount(ctx context.Context, obj *vega.Position) (string, error)

	MarginsConnection(ctx context.Context, obj *vega.Position, pagination *v2.Pagination) (*v2.MarginConnection, error)
}

type PositionUpdateResolver added in v0.56.0

type PositionUpdateResolver interface {
	OpenVolume(ctx context.Context, obj *vega.Position) (string, error)

	LossSocializationAmount(ctx context.Context, obj *vega.Position) (string, error)
}

type PriceLevelResolver

type PriceLevelResolver interface {
	Volume(ctx context.Context, obj *vega.PriceLevel) (string, error)
	NumberOfOrders(ctx context.Context, obj *vega.PriceLevel) (string, error)
}

type PriceMonitoringBounds

type PriceMonitoringBounds struct {
	// Minimum price that isn't currently breaching the specified price monitoring trigger
	MinValidPrice string `json:"minValidPrice"`
	// Maximum price that isn't currently breaching the specified price monitoring trigger
	MaxValidPrice string `json:"maxValidPrice"`
	// Price monitoring trigger associated with the bounds
	Trigger *PriceMonitoringTrigger `json:"trigger"`
	// Reference price used to calculate the valid price range
	ReferencePrice string `json:"referencePrice"`
}

Range of valid prices and the associated price monitoring trigger

type PriceMonitoringParameters

type PriceMonitoringParameters struct {
	// The list of triggers for this price monitoring
	Triggers []*PriceMonitoringTrigger `json:"triggers"`
}

PriceMonitoringParameters holds a list of triggers

type PriceMonitoringSettings

type PriceMonitoringSettings struct {
	// Specified a set of PriceMonitoringParameters to be use for price monitoring purposes
	Parameters *PriceMonitoringParameters `json:"parameters"`
}

Configuration of a market price monitoring auctions triggers

func PriceMonitoringSettingsFromProto

func PriceMonitoringSettingsFromProto(ppmst *types.PriceMonitoringSettings) (*PriceMonitoringSettings, error)

type PriceMonitoringTrigger

type PriceMonitoringTrigger struct {
	// Price monitoring projection horizon τ in seconds (> 0).
	HorizonSecs int `json:"horizonSecs"`
	// Price monitoring probability level p. (>0 and < 1)
	Probability float64 `json:"probability"`
	// Price monitoring auction extension duration in seconds should the price
	// breach its theoretical level over the specified horizon at the specified
	// probability level (> 0)
	AuctionExtensionSecs int `json:"auctionExtensionSecs"`
}

PriceMonitoringTrigger holds together price projection horizon τ, probability level p, and auction extension duration

func PriceMonitoringTriggerFromProto

func PriceMonitoringTriggerFromProto(ppmt *types.PriceMonitoringTrigger) (*PriceMonitoringTrigger, error)

type Product

type Product interface {
	IsProduct()
}

type ProductConfiguration added in v0.73.0

type ProductConfiguration interface {
	IsProductConfiguration()
}

type ProductData added in v0.73.0

type ProductData interface {
	IsProductData()
}

type PropertyKey added in v0.73.0

type PropertyKey struct {
	// The name of the property.
	Name *string `json:"name"`
	// The type of the property.
	Type v1.PropertyKey_Type `json:"type"`
	// An optional decimal place to be applied on the provided value.
	// Valid only for PropertyType of type DECIMAL, INTEGER.
	NumberDecimalPlaces *int `json:"numberDecimalPlaces"`
}

PropertyKey describes the property key contained in a source data.

type ProposalChange

type ProposalChange interface {
	IsProposalChange()
}

type ProposalDetailResolver added in v0.71.0

type ProposalDetailResolver interface {
	Party(ctx context.Context, obj *vega.Proposal) (*vega.Party, error)

	Datetime(ctx context.Context, obj *vega.Proposal) (int64, error)

	RejectionReason(ctx context.Context, obj *vega.Proposal) (*vega.ProposalError, error)

	RequiredLpMajority(ctx context.Context, obj *vega.Proposal) (*string, error)
	RequiredLpParticipation(ctx context.Context, obj *vega.Proposal) (*string, error)
}

type ProposalResolver

type ProposalResolver interface {
	ID(ctx context.Context, obj *vega.GovernanceData) (*string, error)
	Reference(ctx context.Context, obj *vega.GovernanceData) (string, error)
	Party(ctx context.Context, obj *vega.GovernanceData) (*vega.Party, error)
	State(ctx context.Context, obj *vega.GovernanceData) (vega.Proposal_State, error)
	Datetime(ctx context.Context, obj *vega.GovernanceData) (int64, error)
	Rationale(ctx context.Context, obj *vega.GovernanceData) (*vega.ProposalRationale, error)
	Terms(ctx context.Context, obj *vega.GovernanceData) (*vega.ProposalTerms, error)
	Votes(ctx context.Context, obj *vega.GovernanceData) (*ProposalVotes, error)
	RejectionReason(ctx context.Context, obj *vega.GovernanceData) (*vega.ProposalError, error)
	ErrorDetails(ctx context.Context, obj *vega.GovernanceData) (*string, error)
	RequiredMajority(ctx context.Context, obj *vega.GovernanceData) (string, error)
	RequiredParticipation(ctx context.Context, obj *vega.GovernanceData) (string, error)
	RequiredLpMajority(ctx context.Context, obj *vega.GovernanceData) (*string, error)
	RequiredLpParticipation(ctx context.Context, obj *vega.GovernanceData) (*string, error)
}

type ProposalTermsResolver

type ProposalTermsResolver interface {
	ClosingDatetime(ctx context.Context, obj *vega.ProposalTerms) (int64, error)
	EnactmentDatetime(ctx context.Context, obj *vega.ProposalTerms) (*int64, error)
	ValidationDatetime(ctx context.Context, obj *vega.ProposalTerms) (*int64, error)
	Change(ctx context.Context, obj *vega.ProposalTerms) (ProposalChange, error)
}

type ProposalVote

type ProposalVote struct {
	// Cast vote
	Vote *vega.Vote `json:"vote"`
	// Proposal ID the vote is cast on
	ProposalID string `json:"proposalId"`
}

func ProposalVoteFromProto

func ProposalVoteFromProto(v *types.Vote) *ProposalVote

ProposalVoteFromProto ...

type ProposalVoteConnection

type ProposalVoteConnection struct {
	// The proposal votes in this connection
	Edges []*ProposalVoteEdge `json:"edges"`
	// The pagination information
	PageInfo *v2.PageInfo `json:"pageInfo"`
}

Connection type for retrieving cursor-based paginated proposal vote information

type ProposalVoteEdge

type ProposalVoteEdge struct {
	// The proposal vote
	Node *ProposalVote `json:"node"`
	// The cursor for this proposal vote
	Cursor *string `json:"cursor"`
}

Edge type containing the proposal vote and cursor information returned by a ProposalVoteConnection

type ProposalVoteSide

type ProposalVoteSide struct {
	// All votes cast for this side
	Votes []*vega.Vote `json:"votes"`
	// Total number of votes cast for this side
	TotalNumber string `json:"totalNumber"`
	// Total weight of governance token from the votes cast for this side
	TotalWeight string `json:"totalWeight"`
	// Total number of governance tokens from the votes cast for this side
	TotalTokens string `json:"totalTokens"`
	// Total equity like share weight for this side (only for UpdateMarket Proposals)
	TotalEquityLikeShareWeight string `json:"totalEquityLikeShareWeight"`
}

type ProposalVotes

type ProposalVotes struct {
	// Yes votes cast for this proposal
	Yes *ProposalVoteSide `json:"yes"`
	// No votes cast for this proposal
	No *ProposalVoteSide `json:"no"`
}

type ProtocolUpgradeProposalResolver added in v0.61.0

type ProtocolUpgradeProposalResolver interface {
	UpgradeBlockHeight(ctx context.Context, obj *v1.ProtocolUpgradeEvent) (string, error)
}

type ProtocolUpgradeStatus added in v0.59.0

type ProtocolUpgradeStatus struct {
	Ready bool `json:"ready"`
}

Indicator showing whether the data-node is ready for the protocol upgrade to begin.

type PubKey added in v0.61.0

type PubKey struct {
	Key *string `json:"key"`
}

func (PubKey) IsSignerKind added in v0.61.0

func (PubKey) IsSignerKind()

type QueryResolver

type QueryResolver interface {
	Asset(ctx context.Context, id string) (*vega.Asset, error)
	AssetsConnection(ctx context.Context, id *string, pagination *v2.Pagination) (*v2.AssetsConnection, error)
	BalanceChanges(ctx context.Context, filter *v2.AccountFilter, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.AggregatedBalanceConnection, error)
	CurrentReferralProgram(ctx context.Context) (*v2.ReferralProgram, error)
	CurrentVolumeDiscountProgram(ctx context.Context) (*v2.VolumeDiscountProgram, error)
	CoreSnapshots(ctx context.Context, pagination *v2.Pagination) (*v2.CoreSnapshotConnection, error)
	Deposit(ctx context.Context, id string) (*vega.Deposit, error)
	Deposits(ctx context.Context, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.DepositsConnection, error)
	Entities(ctx context.Context, txHash string) (*v2.ListEntitiesResponse, error)
	Epoch(ctx context.Context, id *string, block *string) (*vega.Epoch, error)
	EpochRewardSummaries(ctx context.Context, filter *v2.RewardSummaryFilter, pagination *v2.Pagination) (*v2.EpochRewardSummaryConnection, error)
	Erc20ListAssetBundle(ctx context.Context, assetID string) (*Erc20ListAssetBundle, error)
	Erc20MultiSigSignerAddedBundles(ctx context.Context, nodeID string, submitter *string, epochSeq *string, pagination *v2.Pagination) (*ERC20MultiSigSignerAddedConnection, error)
	Erc20MultiSigSignerRemovedBundles(ctx context.Context, nodeID string, submitter *string, epochSeq *string, pagination *v2.Pagination) (*ERC20MultiSigSignerRemovedConnection, error)
	Erc20SetAssetLimitsBundle(ctx context.Context, proposalID string) (*ERC20SetAssetLimitsBundle, error)
	Erc20WithdrawalApproval(ctx context.Context, withdrawalID string) (*Erc20WithdrawalApproval, error)
	EstimateOrder(ctx context.Context, marketID string, partyID string, price *string, size string, side vega.Side, timeInForce vega.Order_TimeInForce, expiration *int64, typeArg vega.Order_Type) (*OrderEstimate, error)
	EstimateFees(ctx context.Context, marketID string, partyID string, price *string, size string, side vega.Side, timeInForce vega.Order_TimeInForce, expiration *int64, typeArg vega.Order_Type) (*FeeEstimate, error)
	EstimatePosition(ctx context.Context, marketID string, openVolume string, orders []*OrderInfo, collateralAvailable *string, scaleLiquidationPriceToMarketDecimals *bool) (*PositionEstimate, error)
	EthereumKeyRotations(ctx context.Context, nodeID *string) (*v2.EthereumKeyRotationsConnection, error)
	FundingPeriods(ctx context.Context, marketID string, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.FundingPeriodConnection, error)
	FundingPeriodDataPoints(ctx context.Context, marketID string, dateRange *v2.DateRange, source *v1.FundingPeriodDataPoint_Source, pagination *v2.Pagination) (*v2.FundingPeriodDataPointConnection, error)
	FundingPayments(ctx context.Context, partyID string, marketID *string, pagination *v2.Pagination) (*v2.FundingPaymentConnection, error)
	GetMarketDataHistoryConnectionByID(ctx context.Context, id string, start *int64, end *int64, pagination *v2.Pagination) (*v2.MarketDataConnection, error)
	LedgerEntries(ctx context.Context, filter *v2.LedgerEntryFilter, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.AggregatedLedgerEntriesConnection, error)
	LiquidityProviders(ctx context.Context, partyID *string, marketID *string, pagination *v2.Pagination) (*v2.LiquidityProviderConnection, error)
	KeyRotationsConnection(ctx context.Context, id *string, pagination *v2.Pagination) (*v2.KeyRotationConnection, error)
	LastBlockHeight(ctx context.Context) (string, error)
	Market(ctx context.Context, id string) (*vega.Market, error)
	MarketsConnection(ctx context.Context, id *string, pagination *v2.Pagination, includeSettled *bool) (*v2.MarketConnection, error)
	MostRecentHistorySegment(ctx context.Context) (*v2.HistorySegment, error)
	NetworkLimits(ctx context.Context) (*vega.NetworkLimits, error)
	NetworkParameter(ctx context.Context, key string) (*vega.NetworkParameter, error)
	NetworkParametersConnection(ctx context.Context, pagination *v2.Pagination) (*v2.NetworkParameterConnection, error)
	Node(ctx context.Context, id string) (*vega.Node, error)
	NodeData(ctx context.Context) (*vega.NodeData, error)
	NodesConnection(ctx context.Context, pagination *v2.Pagination) (*v2.NodesConnection, error)
	NodeSignaturesConnection(ctx context.Context, resourceID string, pagination *v2.Pagination) (*v2.NodeSignaturesConnection, error)
	OracleDataBySpecConnection(ctx context.Context, oracleSpecID string, pagination *v2.Pagination) (*v2.OracleDataConnection, error)
	OracleDataConnection(ctx context.Context, pagination *v2.Pagination) (*v2.OracleDataConnection, error)
	OracleSpec(ctx context.Context, oracleSpecID string) (*vega.OracleSpec, error)
	OracleSpecsConnection(ctx context.Context, pagination *v2.Pagination) (*v2.OracleSpecsConnection, error)
	OrderByID(ctx context.Context, id string, version *int) (*vega.Order, error)
	OrderByReference(ctx context.Context, reference string) (*vega.Order, error)
	OrderVersionsConnection(ctx context.Context, orderID *string, pagination *v2.Pagination) (*v2.OrderConnection, error)
	PartiesConnection(ctx context.Context, id *string, pagination *v2.Pagination) (*v2.PartyConnection, error)
	Party(ctx context.Context, id string) (*vega.Party, error)
	Positions(ctx context.Context, filter *v2.PositionsFilter, pagination *v2.Pagination) (*v2.PositionConnection, error)
	Proposal(ctx context.Context, id *string, reference *string) (*vega.GovernanceData, error)
	ProposalsConnection(ctx context.Context, proposalType *v2.ListGovernanceDataRequest_Type, inState *vega.Proposal_State, pagination *v2.Pagination) (*v2.GovernanceDataConnection, error)
	ProtocolUpgradeStatus(ctx context.Context) (*ProtocolUpgradeStatus, error)
	ProtocolUpgradeProposals(ctx context.Context, inState *v1.ProtocolUpgradeProposalStatus, approvedBy *string, pagination *v2.Pagination) (*v2.ProtocolUpgradeProposalConnection, error)
	ReferralSets(ctx context.Context, id *string, referrer *string, referee *string, pagination *v2.Pagination) (*v2.ReferralSetConnection, error)
	FeesStats(ctx context.Context, marketID *string, assetID *string, epoch *int, partyID *string) (*v1.FeesStats, error)
	FeesStatsForParty(ctx context.Context, partyID string, assetID *string, fromEpoch *int, toEpoch *int) ([]*v2.FeesStatsForParty, error)
	ReferralSetReferees(ctx context.Context, id *string, referrer *string, referee *string, pagination *v2.Pagination, aggregationEpochs *int) (*v2.ReferralSetRefereeConnection, error)
	ReferralSetStats(ctx context.Context, setID *string, epoch *int, partyID *string, pagination *v2.Pagination) (*v2.ReferralSetStatsConnection, error)
	Statistics(ctx context.Context) (*v12.Statistics, error)
	StopOrder(ctx context.Context, id string) (*v1.StopOrderEvent, error)
	StopOrders(ctx context.Context, filter *v2.StopOrderFilter, pagination *v2.Pagination) (*v2.StopOrderConnection, error)
	SuccessorMarkets(ctx context.Context, marketID string, fullHistory *bool, pagination *v2.Pagination) (*v2.SuccessorMarketConnection, error)
	Teams(ctx context.Context, teamID *string, partyID *string, pagination *v2.Pagination) (*v2.TeamConnection, error)
	TeamReferees(ctx context.Context, teamID string, pagination *v2.Pagination) (*v2.TeamRefereeConnection, error)
	TeamRefereeHistory(ctx context.Context, referee string, pagination *v2.Pagination) (*v2.TeamRefereeHistoryConnection, error)
	Trades(ctx context.Context, filter *TradesFilter, pagination *v2.Pagination, dateRange *v2.DateRange) (*v2.TradeConnection, error)
	TransfersConnection(ctx context.Context, partyID *string, direction *TransferDirection, pagination *v2.Pagination, isReward *bool) (*v2.TransferConnection, error)
	Transfer(ctx context.Context, id string) (*v1.Transfer, error)
	VolumeDiscountStats(ctx context.Context, epoch *int, partyID *string, pagination *v2.Pagination) (*v2.VolumeDiscountStatsConnection, error)
	Withdrawal(ctx context.Context, id string) (*vega.Withdrawal, error)
	Withdrawals(ctx context.Context, dateRange *v2.DateRange, pagination *v2.Pagination) (*v2.WithdrawalsConnection, error)
	PaidLiquidityFees(ctx context.Context, marketID *string, assetID *string, epoch *int, partyIDs []string) (*v2.PaidLiquidityFeesConnection, error)
}

type RankingScoreResolver

type RankingScoreResolver interface {
	VotingPower(ctx context.Context, obj *vega.RankingScore) (string, error)
}

type RecurringGovernanceTransferResolver added in v0.72.0

type RecurringGovernanceTransferResolver interface {
	StartEpoch(ctx context.Context, obj *v1.RecurringGovernanceTransfer) (int, error)
	EndEpoch(ctx context.Context, obj *v1.RecurringGovernanceTransfer) (*int, error)
}

type RecurringTransferResolver

type RecurringTransferResolver interface {
	StartEpoch(ctx context.Context, obj *v1.RecurringTransfer) (int, error)
	EndEpoch(ctx context.Context, obj *v1.RecurringTransfer) (*int, error)
}

type ReferralProgramResolver added in v0.73.0

type ReferralProgramResolver interface {
	Version(ctx context.Context, obj *vega.ReferralProgram) (int, error)

	WindowLength(ctx context.Context, obj *vega.ReferralProgram) (int, error)
}

type ReferralSetRefereeResolver added in v0.73.0

type ReferralSetRefereeResolver interface {
	RefereeID(ctx context.Context, obj *v2.ReferralSetReferee) (string, error)

	AtEpoch(ctx context.Context, obj *v2.ReferralSetReferee) (int, error)
}

type ReferralSetStatsResolver added in v0.73.0

type ReferralSetStatsResolver interface {
	AtEpoch(ctx context.Context, obj *v2.ReferralSetStats) (int, error)
}

type ReferrerRewardsGeneratedResolver added in v0.73.0

type ReferrerRewardsGeneratedResolver interface {
	ReferrerID(ctx context.Context, obj *v1.ReferrerRewardsGenerated) (string, error)
}

type ResolverRoot

type ResolverRoot interface {
	AccountBalance() AccountBalanceResolver
	AccountDetails() AccountDetailsResolver
	AccountEvent() AccountEventResolver
	AccountUpdate() AccountUpdateResolver
	AggregatedLedgerEntry() AggregatedLedgerEntryResolver
	Asset() AssetResolver
	AuctionEvent() AuctionEventResolver
	BenefitTier() BenefitTierResolver
	CancelTransfer() CancelTransferResolver
	Candle() CandleResolver
	CoreSnapshotData() CoreSnapshotDataResolver
	CurrentReferralProgram() CurrentReferralProgramResolver
	DataSourceDefinition() DataSourceDefinitionResolver
	DataSourceDefinitionExternal() DataSourceDefinitionExternalResolver
	DataSourceDefinitionInternal() DataSourceDefinitionInternalResolver
	DataSourceSpecConfiguration() DataSourceSpecConfigurationResolver
	DataSourceSpecConfigurationTime() DataSourceSpecConfigurationTimeResolver
	DataSourceSpecConfigurationTimeTrigger() DataSourceSpecConfigurationTimeTriggerResolver
	Delegation() DelegationResolver
	Deposit() DepositResolver
	DispatchStrategy() DispatchStrategyResolver
	ERC20MultiSigSignerAddedBundle() ERC20MultiSigSignerAddedBundleResolver
	ERC20MultiSigSignerRemovedBundle() ERC20MultiSigSignerRemovedBundleResolver
	Epoch() EpochResolver
	EpochRewardSummary() EpochRewardSummaryResolver
	EpochTimestamps() EpochTimestampsResolver
	EthCallSpec() EthCallSpecResolver
	EthereumKeyRotation() EthereumKeyRotationResolver
	FeesStats() FeesStatsResolver
	FundingPayment() FundingPaymentResolver
	FundingPeriod() FundingPeriodResolver
	FundingPeriodDataPoint() FundingPeriodDataPointResolver
	Future() FutureResolver
	FutureProduct() FutureProductResolver
	IcebergOrder() IcebergOrderResolver
	Instrument() InstrumentResolver
	InstrumentConfiguration() InstrumentConfigurationResolver
	KeyRotation() KeyRotationResolver
	LedgerEntry() LedgerEntryResolver
	LiquidityOrderReference() LiquidityOrderReferenceResolver
	LiquidityProvider() LiquidityProviderResolver
	LiquidityProvision() LiquidityProvisionResolver
	LiquidityProvisionUpdate() LiquidityProvisionUpdateResolver
	LiquiditySLAParameters() LiquiditySLAParametersResolver
	MarginLevels() MarginLevelsResolver
	MarginLevelsUpdate() MarginLevelsUpdateResolver
	Market() MarketResolver
	MarketData() MarketDataResolver
	MarketDepth() MarketDepthResolver
	MarketDepthUpdate() MarketDepthUpdateResolver
	NewAsset() NewAssetResolver
	NewFreeform() NewFreeformResolver
	NewMarket() NewMarketResolver
	NewSpotMarket() NewSpotMarketResolver
	NewTransfer() NewTransferResolver
	Node() NodeResolver
	NodeData() NodeDataResolver
	NodeSignature() NodeSignatureResolver
	ObservableMarketData() ObservableMarketDataResolver
	ObservableMarketDepth() ObservableMarketDepthResolver
	ObservableMarketDepthUpdate() ObservableMarketDepthUpdateResolver
	OracleData() OracleDataResolver
	OracleSpec() OracleSpecResolver
	Order() OrderResolver
	OrderSubmission() OrderSubmissionResolver
	OrderUpdate() OrderUpdateResolver
	PaidLiquidityFees() PaidLiquidityFeesResolver
	Party() PartyResolver
	PartyActivityStreak() PartyActivityStreakResolver
	PartyAmount() PartyAmountResolver
	PartyLockedBalance() PartyLockedBalanceResolver
	PartyStake() PartyStakeResolver
	PartyVestingBalance() PartyVestingBalanceResolver
	PartyVestingBalancesSummary() PartyVestingBalancesSummaryResolver
	PartyVestingStats() PartyVestingStatsResolver
	Perpetual() PerpetualResolver
	PerpetualProduct() PerpetualProductResolver
	Position() PositionResolver
	PositionUpdate() PositionUpdateResolver
	PriceLevel() PriceLevelResolver
	Proposal() ProposalResolver
	ProposalDetail() ProposalDetailResolver
	ProposalTerms() ProposalTermsResolver
	ProtocolUpgradeProposal() ProtocolUpgradeProposalResolver
	Query() QueryResolver
	RankingScore() RankingScoreResolver
	RecurringGovernanceTransfer() RecurringGovernanceTransferResolver
	RecurringTransfer() RecurringTransferResolver
	ReferralProgram() ReferralProgramResolver
	ReferralSetReferee() ReferralSetRefereeResolver
	ReferralSetStats() ReferralSetStatsResolver
	ReferrerRewardsGenerated() ReferrerRewardsGeneratedResolver
	Reward() RewardResolver
	RewardSummary() RewardSummaryResolver
	Spot() SpotResolver
	SpotProduct() SpotProductResolver
	StakeLinking() StakeLinkingResolver
	Statistics() StatisticsResolver
	StopOrder() StopOrderResolver
	Subscription() SubscriptionResolver
	Team() TeamResolver
	TeamReferee() TeamRefereeResolver
	TeamRefereeHistory() TeamRefereeHistoryResolver
	TradableInstrument() TradableInstrumentResolver
	Trade() TradeResolver
	TradeUpdate() TradeUpdateResolver
	TransactionResult() TransactionResultResolver
	Transfer() TransferResolver
	TransferNode() TransferNodeResolver
	UpdateAsset() UpdateAssetResolver
	UpdateMarket() UpdateMarketResolver
	UpdateMarketConfiguration() UpdateMarketConfigurationResolver
	UpdateMarketState() UpdateMarketStateResolver
	UpdateNetworkParameter() UpdateNetworkParameterResolver
	UpdateReferralProgram() UpdateReferralProgramResolver
	UpdateSpotMarket() UpdateSpotMarketResolver
	UpdateSpotMarketConfiguration() UpdateSpotMarketConfigurationResolver
	UpdateVolumeDiscountProgram() UpdateVolumeDiscountProgramResolver
	VolumeDiscountProgram() VolumeDiscountProgramResolver
	VolumeDiscountStats() VolumeDiscountStatsResolver
	Vote() VoteResolver
	Withdrawal() WithdrawalResolver
	DateRange() DateRangeResolver
	OrderFilter() OrderFilterResolver
	RewardSummaryFilter() RewardSummaryFilterResolver
	StopOrderFilter() StopOrderFilterResolver
}

type RewardResolver

type RewardResolver interface {
	Asset(ctx context.Context, obj *vega.Reward) (*vega.Asset, error)

	RewardType(ctx context.Context, obj *vega.Reward) (vega.AccountType, error)
	Party(ctx context.Context, obj *vega.Reward) (*vega.Party, error)
	Epoch(ctx context.Context, obj *vega.Reward) (*vega.Epoch, error)

	LockedUntilEpoch(ctx context.Context, obj *vega.Reward) (*vega.Epoch, error)
}

type RewardSummaryConnection

type RewardSummaryConnection struct {
	// List of reward summaries available for the connection
	Edges []*RewardSummaryEdge `json:"edges"`
	// Page information for the connection
	PageInfo *v2.PageInfo `json:"pageInfo"`
}

Connection type for retrieving cursor-based paginated reward summary information

type RewardSummaryEdge

type RewardSummaryEdge struct {
	// The reward summary
	Node *vega.RewardSummary `json:"node"`
	// Cursor identifying the reward summary
	Cursor string `json:"cursor"`
}

Edge type containing the reward summary and cursor information returned by a RewardSummaryConnection

type RewardSummaryFilterResolver added in v0.68.0

type RewardSummaryFilterResolver interface {
	FromEpoch(ctx context.Context, obj *v2.RewardSummaryFilter, data *int) error
	ToEpoch(ctx context.Context, obj *v2.RewardSummaryFilter, data *int) error
}

type RewardSummaryResolver

type RewardSummaryResolver interface {
	Asset(ctx context.Context, obj *vega.RewardSummary) (*vega.Asset, error)

	RewardsConnection(ctx context.Context, obj *vega.RewardSummary, assetID *string, pagination *v2.Pagination) (*v2.RewardsConnection, error)
}

type RiskModel

type RiskModel interface {
	IsRiskModel()
}

type SettleDistressed

type SettleDistressed struct {
	// The market in which a position was closed out
	MarketID string `json:"marketId"`
	// The party that was closed out
	PartyID string `json:"partyId"`
	// The margin taken from distressed party
	Margin string `json:"margin"`
	// The price at which the position was closed out
	Price string `json:"price"`
}

type SettlePosition

type SettlePosition struct {
	// The market in which a position was settled
	MarketID string `json:"marketId"`
	// The party who settled a position
	PartyID string `json:"partyId"`
	// The settle price
	Price string `json:"price"`
	// The trades that were settled to close the overall position
	TradeSettlements []*TradeSettlement `json:"tradeSettlements"`
}

type Signer added in v0.61.0

type Signer struct {
	Signer SignerKind `json:"signer"`
}

Signer is the authorized signature used for the data.

type SignerKind added in v0.61.0

type SignerKind interface {
	IsSignerKind()
}

type SpotProductResolver added in v0.73.0

type SpotProductResolver interface {
	BaseAsset(ctx context.Context, obj *vega.SpotProduct) (*vega.Asset, error)
	QuoteAsset(ctx context.Context, obj *vega.SpotProduct) (*vega.Asset, error)
}

type SpotResolver added in v0.73.0

type SpotResolver interface {
	BaseAsset(ctx context.Context, obj *vega.Spot) (*vega.Asset, error)
	QuoteAsset(ctx context.Context, obj *vega.Spot) (*vega.Asset, error)
}

type StakeLinkingResolver

type StakeLinkingResolver interface {
	Timestamp(ctx context.Context, obj *v1.StakeLinking) (int64, error)
	Party(ctx context.Context, obj *v1.StakeLinking) (*vega.Party, error)

	BlockHeight(ctx context.Context, obj *v1.StakeLinking) (string, error)
}

type StakingSummary

type StakingSummary struct {
	// The stake currently available for the party
	CurrentStakeAvailable string `json:"currentStakeAvailable"`
	// The list of all stake link/unlink for the party
	Linkings *v2.StakesConnection `json:"linkings"`
}

All staking information related to a Party. Contains the current recognised balance by the network and all the StakeLink/Unlink seen by the network

type StatisticsResolver

type StatisticsResolver interface {
	BlockHeight(ctx context.Context, obj *v12.Statistics) (string, error)

	BacklogLength(ctx context.Context, obj *v12.Statistics) (string, error)
	TotalPeers(ctx context.Context, obj *v12.Statistics) (string, error)
	GenesisTime(ctx context.Context, obj *v12.Statistics) (int64, error)
	CurrentTime(ctx context.Context, obj *v12.Statistics) (int64, error)

	VegaTime(ctx context.Context, obj *v12.Statistics) (int64, error)
	Status(ctx context.Context, obj *v12.Statistics) (string, error)
	TxPerBlock(ctx context.Context, obj *v12.Statistics) (string, error)
	AverageTxBytes(ctx context.Context, obj *v12.Statistics) (string, error)
	AverageOrdersPerBlock(ctx context.Context, obj *v12.Statistics) (string, error)
	TradesPerSecond(ctx context.Context, obj *v12.Statistics) (string, error)
	OrdersPerSecond(ctx context.Context, obj *v12.Statistics) (string, error)
	TotalMarkets(ctx context.Context, obj *v12.Statistics) (string, error)
	TotalAmendOrder(ctx context.Context, obj *v12.Statistics) (string, error)
	TotalCancelOrder(ctx context.Context, obj *v12.Statistics) (string, error)
	TotalCreateOrder(ctx context.Context, obj *v12.Statistics) (string, error)
	TotalOrders(ctx context.Context, obj *v12.Statistics) (string, error)
	TotalTrades(ctx context.Context, obj *v12.Statistics) (string, error)
	EventCount(ctx context.Context, obj *v12.Statistics) (string, error)
	EventsPerSecond(ctx context.Context, obj *v12.Statistics) (string, error)

	BlockDuration(ctx context.Context, obj *v12.Statistics) (string, error)
}

type StopOrderFilterResolver added in v0.72.0

type StopOrderFilterResolver interface {
	Parties(ctx context.Context, obj *v2.StopOrderFilter, data []string) error
	Markets(ctx context.Context, obj *v2.StopOrderFilter, data []string) error
	Status(ctx context.Context, obj *v2.StopOrderFilter, data []vega.StopOrder_Status) error
	ExpiryStrategy(ctx context.Context, obj *v2.StopOrderFilter, data []vega.StopOrder_ExpiryStrategy) error
}

type StopOrderPrice added in v0.72.0

type StopOrderPrice struct {
	Price string `json:"price"`
}

Price at which a stop order will trigger

func (StopOrderPrice) IsStopOrderTrigger added in v0.72.0

func (StopOrderPrice) IsStopOrderTrigger()

type StopOrderResolver added in v0.72.0

type StopOrderResolver interface {
	ID(ctx context.Context, obj *v1.StopOrderEvent) (string, error)
	OcoLinkID(ctx context.Context, obj *v1.StopOrderEvent) (*string, error)
	ExpiresAt(ctx context.Context, obj *v1.StopOrderEvent) (*int64, error)
	ExpiryStrategy(ctx context.Context, obj *v1.StopOrderEvent) (*vega.StopOrder_ExpiryStrategy, error)
	TriggerDirection(ctx context.Context, obj *v1.StopOrderEvent) (vega.StopOrder_TriggerDirection, error)
	Status(ctx context.Context, obj *v1.StopOrderEvent) (vega.StopOrder_Status, error)
	CreatedAt(ctx context.Context, obj *v1.StopOrderEvent) (int64, error)
	UpdatedAt(ctx context.Context, obj *v1.StopOrderEvent) (*int64, error)
	PartyID(ctx context.Context, obj *v1.StopOrderEvent) (string, error)
	MarketID(ctx context.Context, obj *v1.StopOrderEvent) (string, error)
	Trigger(ctx context.Context, obj *v1.StopOrderEvent) (StopOrderTrigger, error)

	Order(ctx context.Context, obj *v1.StopOrderEvent) (*vega.Order, error)
	RejectionReason(ctx context.Context, obj *v1.StopOrderEvent) (*vega.StopOrder_RejectionReason, error)
}

type StopOrderTrailingPercentOffset added in v0.72.0

type StopOrderTrailingPercentOffset struct {
	TrailingPercentOffset string `json:"trailingPercentOffset"`
}

Percentage movement in the price at which a stop order will trigger.

func (StopOrderTrailingPercentOffset) IsStopOrderTrigger added in v0.72.0

func (StopOrderTrailingPercentOffset) IsStopOrderTrigger()

type StopOrderTrigger added in v0.72.0

type StopOrderTrigger interface {
	IsStopOrderTrigger()
}

type SubscriptionResolver

type SubscriptionResolver interface {
	Accounts(ctx context.Context, marketID *string, partyID *string, assetID *string, typeArg *vega.AccountType) (<-chan []*v2.AccountBalance, error)
	BusEvents(ctx context.Context, types []BusEventType, marketID *string, partyID *string, batchSize int) (<-chan []*BusEvent, error)
	Candles(ctx context.Context, marketID string, interval vega.Interval) (<-chan *v2.Candle, error)
	LiquidityProvisions(ctx context.Context, partyID *string, marketID *string) (<-chan []*vega.LiquidityProvision, error)
	Margins(ctx context.Context, partyID string, marketID *string) (<-chan *vega.MarginLevels, error)
	MarketsData(ctx context.Context, marketIds []string) (<-chan []*vega.MarketData, error)
	MarketsDepth(ctx context.Context, marketIds []string) (<-chan []*vega.MarketDepth, error)
	MarketsDepthUpdate(ctx context.Context, marketIds []string) (<-chan []*vega.MarketDepthUpdate, error)
	Orders(ctx context.Context, filter *OrderByMarketAndPartyIdsFilter) (<-chan []*vega.Order, error)
	Positions(ctx context.Context, partyID *string, marketID *string) (<-chan []*vega.Position, error)
	Proposals(ctx context.Context, partyID *string) (<-chan *vega.GovernanceData, error)
	Trades(ctx context.Context, marketID *string, partyID *string) (<-chan []*vega.Trade, error)
	TradesStream(ctx context.Context, filter TradesSubscriptionFilter) (<-chan []*vega.Trade, error)
	Votes(ctx context.Context, proposalID *string, partyID *string) (<-chan *ProposalVote, error)
}

type TargetStakeParameters

type TargetStakeParameters struct {
	// Specifies length of time window expressed in seconds for target stake calculation
	TimeWindow int `json:"timeWindow"`
	// Specifies scaling factors used in target stake calculation
	ScalingFactor float64 `json:"scalingFactor"`
}

TargetStakeParameters contains parameters used in target stake calculation

type TeamRefereeHistoryResolver added in v0.73.0

type TeamRefereeHistoryResolver interface {
	JoinedAtEpoch(ctx context.Context, obj *v2.TeamRefereeHistory) (int, error)
}

type TeamRefereeResolver added in v0.73.0

type TeamRefereeResolver interface {
	JoinedAtEpoch(ctx context.Context, obj *v2.TeamReferee) (int, error)
}

type TeamResolver added in v0.73.0

type TeamResolver interface {
	CreatedAtEpoch(ctx context.Context, obj *v2.Team) (int, error)
}

type TimeUpdate

type TimeUpdate struct {
	// RFC3339Nano time of new block time
	Timestamp int64 `json:"timestamp"`
}

func (TimeUpdate) IsEvent

func (TimeUpdate) IsEvent()

type TradableInstrumentResolver

type TradableInstrumentResolver interface {
	RiskModel(ctx context.Context, obj *vega.TradableInstrument) (RiskModel, error)
}

type TradeFee

type TradeFee struct {
	// The maker fee, paid by the aggressive party to the other party (the one who had an order in the book)
	MakerFee string `json:"makerFee"`
	// The infrastructure fee, a fee paid to the validators to maintain the Vega network
	InfrastructureFee string `json:"infrastructureFee"`
	// The fee paid to the liquidity providers that committed liquidity to the market
	LiquidityFee string `json:"liquidityFee"`
	// Referral discount on maker fees for the trade
	MakerFeeReferralDiscount *string `json:"makerFeeReferralDiscount"`
	// Volume discount on maker fees for the trade
	MakerFeeVolumeDiscount *string `json:"makerFeeVolumeDiscount"`
	// Referral discount on infrastructure fees for the trade
	InfrastructureFeeReferralDiscount *string `json:"infrastructureFeeReferralDiscount"`
	// Volume discount on infrastructure fees for the trade
	InfrastructureFeeVolumeDiscount *string `json:"infrastructureFeeVolumeDiscount"`
	// Referral discount on liquidity fees for the trade
	LiquidityFeeReferralDiscount *string `json:"liquidityFeeReferralDiscount"`
	// Volume discount on liquidity fees for the trade
	LiquidityFeeVolumeDiscount *string `json:"liquidityFeeVolumeDiscount"`
}

The fee paid by the party when a trade occurs

type TradeResolver

type TradeResolver interface {
	Market(ctx context.Context, obj *vega.Trade) (*vega.Market, error)

	Buyer(ctx context.Context, obj *vega.Trade) (*vega.Party, error)
	Seller(ctx context.Context, obj *vega.Trade) (*vega.Party, error)

	Size(ctx context.Context, obj *vega.Trade) (string, error)
	CreatedAt(ctx context.Context, obj *vega.Trade) (int64, error)

	BuyerFee(ctx context.Context, obj *vega.Trade) (*TradeFee, error)
	SellerFee(ctx context.Context, obj *vega.Trade) (*TradeFee, error)
	BuyerAuctionBatch(ctx context.Context, obj *vega.Trade) (*int, error)
	SellerAuctionBatch(ctx context.Context, obj *vega.Trade) (*int, error)
}

type TradeSettlement

type TradeSettlement struct {
	// The size of the trade
	Size int `json:"size"`
	// The price of the trade
	Price string `json:"price"`
}

type TradeUpdateResolver added in v0.55.0

type TradeUpdateResolver interface {
	BuyerID(ctx context.Context, obj *vega.Trade) (string, error)
	SellerID(ctx context.Context, obj *vega.Trade) (string, error)

	Size(ctx context.Context, obj *vega.Trade) (string, error)
	CreatedAt(ctx context.Context, obj *vega.Trade) (int64, error)

	BuyerFee(ctx context.Context, obj *vega.Trade) (*TradeFee, error)
	SellerFee(ctx context.Context, obj *vega.Trade) (*TradeFee, error)
	BuyerAuctionBatch(ctx context.Context, obj *vega.Trade) (*int, error)
	SellerAuctionBatch(ctx context.Context, obj *vega.Trade) (*int, error)
}

type TradesFilter added in v0.71.0

type TradesFilter struct {
	PartyIds  []string `json:"partyIds"`
	MarketIds []string `json:"marketIds"`
	OrderIds  []string `json:"orderIds"`
}

Filter to apply to the trade connection query

type TradesSubscriptionFilter added in v0.71.0

type TradesSubscriptionFilter struct {
	PartyIds  []string `json:"partyIds"`
	MarketIds []string `json:"marketIds"`
}

Filter to apply to the trade subscription request

type TradingDataServiceClientV2

type TradingDataServiceClientV2 interface {
	v2.TradingDataServiceClient
}

type TransactionResultResolver added in v0.58.0

type TransactionResultResolver interface {
	Error(ctx context.Context, obj *v1.TransactionResult) (*string, error)
}

type TransactionSubmitted

type TransactionSubmitted struct {
	Success bool `json:"success"`
}

type TransferBalance

type TransferBalance struct {
	// Account involved in transfer
	Account *vega.AccountDetails `json:"account"`
	// The new balance of the account
	Balance string `json:"balance"`
}

type TransferDirection

type TransferDirection string

Filter type for specifying the types of transfers to filter for

const (
	TransferDirectionTo       TransferDirection = "To"
	TransferDirectionFrom     TransferDirection = "From"
	TransferDirectionToOrFrom TransferDirection = "ToOrFrom"
)

func (TransferDirection) IsValid

func (e TransferDirection) IsValid() bool

func (TransferDirection) MarshalGQL

func (e TransferDirection) MarshalGQL(w io.Writer)

func (TransferDirection) String

func (e TransferDirection) String() string

func (*TransferDirection) UnmarshalGQL

func (e *TransferDirection) UnmarshalGQL(v interface{}) error

type TransferFee added in v0.73.0

type TransferFee struct {
	// Transfer ID of the transfer for which the fee was paid
	TransferID string `json:"transferId"`
	// The fee amount
	Amount string `json:"amount"`
	// The epoch when this fee was paid
	Epoch int `json:"epoch"`
}

A transfer fee record

type TransferKind

type TransferKind interface {
	IsTransferKind()
}

type TransferNodeResolver added in v0.73.0

type TransferNodeResolver interface {
	Fees(ctx context.Context, obj *v2.TransferNode) ([]*TransferFee, error)
}

type TransferResolver

type TransferResolver interface {
	Asset(ctx context.Context, obj *v1.Transfer) (*vega.Asset, error)

	Kind(ctx context.Context, obj *v1.Transfer) (TransferKind, error)
}

type TransferResponse

type TransferResponse struct {
	// The ledger entries and balances resulting from a transfer request
	Transfers []*vega.LedgerEntry `json:"transfers"`
	// The balances of accounts involved in the transfer
	Balances []*TransferBalance `json:"balances"`
}

type TransferResponses

type TransferResponses struct {
	// A group of transfer responses - events from core
	Responses []*TransferResponse `json:"responses"`
}

type TriggerKind added in v0.73.0

type TriggerKind interface {
	IsTriggerKind()
}

type UpdateAssetResolver

type UpdateAssetResolver interface {
	Quantum(ctx context.Context, obj *vega.UpdateAsset) (string, error)
	Source(ctx context.Context, obj *vega.UpdateAsset) (UpdateAssetSource, error)
}

type UpdateAssetSource

type UpdateAssetSource interface {
	IsUpdateAssetSource()
}

One of the possible asset sources for update assets proposals

func UpdateAssetSourceFromProto

func UpdateAssetSourceFromProto(pdetails *types.AssetDetailsUpdate) (UpdateAssetSource, error)

type UpdateErc20

type UpdateErc20 struct {
	// The lifetime limits deposit per address
	// Note: this is a temporary measure that can be changed by governance
	LifetimeLimit string `json:"lifetimeLimit"`
	// The maximum you can withdraw instantly. All withdrawals over the threshold will be delayed by the withdrawal delay.
	// There is no limit on the size of a withdrawal
	// Note: this is a temporary measure that can be changed by governance
	WithdrawThreshold string `json:"withdrawThreshold"`
}

An asset originated from an Ethereum ERC20 Token

func UpdateERC20FromProto

func UpdateERC20FromProto(ea *types.ERC20Update) *UpdateErc20

func (UpdateErc20) IsUpdateAssetSource

func (UpdateErc20) IsUpdateAssetSource()

type UpdateInstrumentConfiguration

type UpdateInstrumentConfiguration struct {
	Code    string                     `json:"code"`
	Product UpdateProductConfiguration `json:"product"`
}

type UpdateMarketConfigurationResolver

type UpdateMarketConfigurationResolver interface {
	Instrument(ctx context.Context, obj *vega.UpdateMarketConfiguration) (*UpdateInstrumentConfiguration, error)

	PriceMonitoringParameters(ctx context.Context, obj *vega.UpdateMarketConfiguration) (*PriceMonitoringParameters, error)
	LiquidityMonitoringParameters(ctx context.Context, obj *vega.UpdateMarketConfiguration) (*LiquidityMonitoringParameters, error)
	RiskParameters(ctx context.Context, obj *vega.UpdateMarketConfiguration) (UpdateMarketRiskParameters, error)
}

type UpdateMarketResolver

type UpdateMarketResolver interface {
	UpdateMarketConfiguration(ctx context.Context, obj *vega.UpdateMarket) (*vega.UpdateMarketConfiguration, error)
}

type UpdateMarketRiskParameters

type UpdateMarketRiskParameters interface {
	IsUpdateMarketRiskParameters()
}

type UpdateMarketStateResolver added in v0.73.0

type UpdateMarketStateResolver interface {
	Market(ctx context.Context, obj *vega.UpdateMarketState) (*vega.Market, error)
	UpdateType(ctx context.Context, obj *vega.UpdateMarketState) (MarketUpdateType, error)
	Price(ctx context.Context, obj *vega.UpdateMarketState) (*string, error)
}

type UpdateNetworkParameterResolver

type UpdateNetworkParameterResolver interface {
	NetworkParameter(ctx context.Context, obj *vega.UpdateNetworkParameter) (*vega.NetworkParameter, error)
}

type UpdateProductConfiguration added in v0.73.0

type UpdateProductConfiguration interface {
	IsUpdateProductConfiguration()
}

type UpdateReferralProgramResolver added in v0.73.0

type UpdateReferralProgramResolver interface {
	BenefitTiers(ctx context.Context, obj *vega.UpdateReferralProgram) ([]*vega.BenefitTier, error)
	EndOfProgramTimestamp(ctx context.Context, obj *vega.UpdateReferralProgram) (int64, error)
	WindowLength(ctx context.Context, obj *vega.UpdateReferralProgram) (int, error)
	StakingTiers(ctx context.Context, obj *vega.UpdateReferralProgram) ([]*vega.StakingTier, error)
}

type UpdateSpotMarketConfigurationResolver added in v0.73.0

type UpdateSpotMarketConfigurationResolver interface {
	PriceMonitoringParameters(ctx context.Context, obj *vega.UpdateSpotMarketConfiguration) (*PriceMonitoringParameters, error)
	TargetStakeParameters(ctx context.Context, obj *vega.UpdateSpotMarketConfiguration) (*TargetStakeParameters, error)
	RiskParameters(ctx context.Context, obj *vega.UpdateSpotMarketConfiguration) (RiskModel, error)
	LiquiditySLAParams(ctx context.Context, obj *vega.UpdateSpotMarketConfiguration) (*vega.LiquiditySLAParameters, error)
}

type UpdateSpotMarketResolver added in v0.73.0

type UpdateSpotMarketResolver interface {
	UpdateSpotMarketConfiguration(ctx context.Context, obj *vega.UpdateSpotMarket) (*vega.UpdateSpotMarketConfiguration, error)
}

type UpdateVolumeDiscountProgramResolver added in v0.73.0

type UpdateVolumeDiscountProgramResolver interface {
	BenefitTiers(ctx context.Context, obj *vega.UpdateVolumeDiscountProgram) ([]*vega.VolumeBenefitTier, error)
	EndOfProgramTimestamp(ctx context.Context, obj *vega.UpdateVolumeDiscountProgram) (int64, error)
	WindowLength(ctx context.Context, obj *vega.UpdateVolumeDiscountProgram) (int, error)
}

type VegaResolverRoot

type VegaResolverRoot struct {
	gateway.Config
	// contains filtered or unexported fields
}

VegaResolverRoot is the root resolver for all graphql types.

func NewResolverRoot

func NewResolverRoot(
	log *logging.Logger,
	config gateway.Config,
	tradingClient CoreProxyServiceClient,
	tradingDataClientV2 TradingDataServiceClientV2,
) *VegaResolverRoot

NewResolverRoot instantiate a graphql root resolver.

func (*VegaResolverRoot) AccountBalance added in v0.59.0

func (r *VegaResolverRoot) AccountBalance() AccountBalanceResolver

Account returns the accounts resolver.

func (*VegaResolverRoot) AccountDetails added in v0.56.0

func (r *VegaResolverRoot) AccountDetails() AccountDetailsResolver

Account returns the accounts resolver.

func (*VegaResolverRoot) AccountEvent added in v0.59.0

func (r *VegaResolverRoot) AccountEvent() AccountEventResolver

Account returns the accounts resolver.

func (*VegaResolverRoot) AccountUpdate added in v0.55.0

func (r *VegaResolverRoot) AccountUpdate() AccountUpdateResolver

func (*VegaResolverRoot) AggregatedLedgerEntry added in v0.63.0

func (r *VegaResolverRoot) AggregatedLedgerEntry() AggregatedLedgerEntryResolver

func (*VegaResolverRoot) Asset

func (r *VegaResolverRoot) Asset() AssetResolver

Asset ...

func (*VegaResolverRoot) AuctionEvent

func (r *VegaResolverRoot) AuctionEvent() AuctionEventResolver

func (*VegaResolverRoot) BenefitTier added in v0.73.0

func (r *VegaResolverRoot) BenefitTier() BenefitTierResolver

func (*VegaResolverRoot) CancelTransfer added in v0.72.0

func (r *VegaResolverRoot) CancelTransfer() CancelTransferResolver

func (*VegaResolverRoot) Candle

func (r *VegaResolverRoot) Candle() CandleResolver

Candle returns the candles resolver.

func (*VegaResolverRoot) CoreSnapshotData added in v0.65.0

func (r *VegaResolverRoot) CoreSnapshotData() CoreSnapshotDataResolver

func (*VegaResolverRoot) CurrentReferralProgram added in v0.73.0

func (r *VegaResolverRoot) CurrentReferralProgram() CurrentReferralProgramResolver

func (*VegaResolverRoot) DataSourceDefinition added in v0.72.0

func (r *VegaResolverRoot) DataSourceDefinition() DataSourceDefinitionResolver

func (*VegaResolverRoot) DataSourceDefinitionExternal added in v0.72.0

func (r *VegaResolverRoot) DataSourceDefinitionExternal() DataSourceDefinitionExternalResolver

func (*VegaResolverRoot) DataSourceDefinitionInternal added in v0.72.0

func (r *VegaResolverRoot) DataSourceDefinitionInternal() DataSourceDefinitionInternalResolver

func (*VegaResolverRoot) DataSourceSpecConfiguration added in v0.61.0

func (r *VegaResolverRoot) DataSourceSpecConfiguration() DataSourceSpecConfigurationResolver

func (*VegaResolverRoot) DataSourceSpecConfigurationTime added in v0.73.0

func (r *VegaResolverRoot) DataSourceSpecConfigurationTime() DataSourceSpecConfigurationTimeResolver

func (*VegaResolverRoot) DataSourceSpecConfigurationTimeTrigger added in v0.73.0

func (r *VegaResolverRoot) DataSourceSpecConfigurationTimeTrigger() DataSourceSpecConfigurationTimeTriggerResolver

func (*VegaResolverRoot) DateRange added in v0.55.0

func (r *VegaResolverRoot) DateRange() DateRangeResolver

func (*VegaResolverRoot) Delegation

func (r *VegaResolverRoot) Delegation() DelegationResolver

func (*VegaResolverRoot) Deposit

func (r *VegaResolverRoot) Deposit() DepositResolver

Deposit ...

func (*VegaResolverRoot) DispatchStrategy added in v0.73.0

func (r *VegaResolverRoot) DispatchStrategy() DispatchStrategyResolver

func (*VegaResolverRoot) ERC20MultiSigSignerAddedBundle added in v0.71.0

func (r *VegaResolverRoot) ERC20MultiSigSignerAddedBundle() ERC20MultiSigSignerAddedBundleResolver

func (*VegaResolverRoot) ERC20MultiSigSignerRemovedBundle added in v0.71.0

func (r *VegaResolverRoot) ERC20MultiSigSignerRemovedBundle() ERC20MultiSigSignerRemovedBundleResolver

func (*VegaResolverRoot) Epoch

func (r *VegaResolverRoot) Epoch() EpochResolver

func (*VegaResolverRoot) EpochRewardSummary added in v0.65.0

func (r *VegaResolverRoot) EpochRewardSummary() EpochRewardSummaryResolver

func (*VegaResolverRoot) EpochTimestamps

func (r *VegaResolverRoot) EpochTimestamps() EpochTimestampsResolver

func (*VegaResolverRoot) EthCallSpec added in v0.73.0

func (r *VegaResolverRoot) EthCallSpec() EthCallSpecResolver

func (*VegaResolverRoot) EthereumKeyRotation

func (r *VegaResolverRoot) EthereumKeyRotation() EthereumKeyRotationResolver

func (*VegaResolverRoot) FeesStats added in v0.73.0

func (r *VegaResolverRoot) FeesStats() FeesStatsResolver

func (*VegaResolverRoot) FundingPayment added in v0.73.0

func (r *VegaResolverRoot) FundingPayment() FundingPaymentResolver

func (*VegaResolverRoot) FundingPeriod added in v0.73.0

func (r *VegaResolverRoot) FundingPeriod() FundingPeriodResolver

func (*VegaResolverRoot) FundingPeriodDataPoint added in v0.73.0

func (r *VegaResolverRoot) FundingPeriodDataPoint() FundingPeriodDataPointResolver

func (*VegaResolverRoot) Future

func (r *VegaResolverRoot) Future() FutureResolver

func (*VegaResolverRoot) FutureProduct

func (r *VegaResolverRoot) FutureProduct() FutureProductResolver

func (*VegaResolverRoot) IcebergOrder added in v0.72.0

func (r *VegaResolverRoot) IcebergOrder() IcebergOrderResolver

func (*VegaResolverRoot) Instrument

func (r *VegaResolverRoot) Instrument() InstrumentResolver

func (*VegaResolverRoot) InstrumentConfiguration

func (r *VegaResolverRoot) InstrumentConfiguration() InstrumentConfigurationResolver

func (*VegaResolverRoot) KeyRotation

func (r *VegaResolverRoot) KeyRotation() KeyRotationResolver

func (*VegaResolverRoot) LedgerEntry added in v0.71.0

func (r *VegaResolverRoot) LedgerEntry() LedgerEntryResolver

func (*VegaResolverRoot) LiquidityOrderReference

func (r *VegaResolverRoot) LiquidityOrderReference() LiquidityOrderReferenceResolver

func (*VegaResolverRoot) LiquidityProvider added in v0.73.0

func (r *VegaResolverRoot) LiquidityProvider() LiquidityProviderResolver

func (*VegaResolverRoot) LiquidityProvision

func (r *VegaResolverRoot) LiquidityProvision() LiquidityProvisionResolver

func (*VegaResolverRoot) LiquidityProvisionUpdate added in v0.55.0

func (r *VegaResolverRoot) LiquidityProvisionUpdate() LiquidityProvisionUpdateResolver

func (*VegaResolverRoot) LiquiditySLAParameters added in v0.73.0

func (r *VegaResolverRoot) LiquiditySLAParameters() LiquiditySLAParametersResolver

func (*VegaResolverRoot) MarginLevels

func (r *VegaResolverRoot) MarginLevels() MarginLevelsResolver

MarginLevels returns the market levels resolver.

func (*VegaResolverRoot) MarginLevelsUpdate added in v0.55.0

func (r *VegaResolverRoot) MarginLevelsUpdate() MarginLevelsUpdateResolver

MarginLevelsUpdate returns the market levels resolver.

func (*VegaResolverRoot) Market

func (r *VegaResolverRoot) Market() MarketResolver

Market returns the markets resolver.

func (*VegaResolverRoot) MarketData

func (r *VegaResolverRoot) MarketData() MarketDataResolver

MarketData returns the market data resolver.

func (*VegaResolverRoot) MarketDepth

func (r *VegaResolverRoot) MarketDepth() MarketDepthResolver

MarketDepth returns the market depth resolver.

func (*VegaResolverRoot) MarketDepthUpdate

func (r *VegaResolverRoot) MarketDepthUpdate() MarketDepthUpdateResolver

MarketDepthUpdate returns the market depth update resolver.

func (*VegaResolverRoot) NewAsset

func (r *VegaResolverRoot) NewAsset() NewAssetResolver

func (*VegaResolverRoot) NewFreeform

func (r *VegaResolverRoot) NewFreeform() NewFreeformResolver

func (*VegaResolverRoot) NewMarket

func (r *VegaResolverRoot) NewMarket() NewMarketResolver

func (*VegaResolverRoot) NewSpotMarket added in v0.73.0

func (r *VegaResolverRoot) NewSpotMarket() NewSpotMarketResolver

func (*VegaResolverRoot) NewTransfer added in v0.72.0

func (r *VegaResolverRoot) NewTransfer() NewTransferResolver

func (*VegaResolverRoot) Node

func (r *VegaResolverRoot) Node() NodeResolver

func (*VegaResolverRoot) NodeData

func (r *VegaResolverRoot) NodeData() NodeDataResolver

func (*VegaResolverRoot) NodeSignature

func (r *VegaResolverRoot) NodeSignature() NodeSignatureResolver

NodeSignature ...

func (*VegaResolverRoot) ObservableMarketData

func (r *VegaResolverRoot) ObservableMarketData() ObservableMarketDataResolver

func (*VegaResolverRoot) ObservableMarketDepth

func (r *VegaResolverRoot) ObservableMarketDepth() ObservableMarketDepthResolver

func (*VegaResolverRoot) ObservableMarketDepthUpdate

func (r *VegaResolverRoot) ObservableMarketDepthUpdate() ObservableMarketDepthUpdateResolver

func (*VegaResolverRoot) OracleData

func (r *VegaResolverRoot) OracleData() OracleDataResolver

func (*VegaResolverRoot) OracleSpec

func (r *VegaResolverRoot) OracleSpec() OracleSpecResolver

func (*VegaResolverRoot) Order

func (r *VegaResolverRoot) Order() OrderResolver

Order returns the order resolver.

func (*VegaResolverRoot) OrderFilter added in v0.63.0

func (r *VegaResolverRoot) OrderFilter() OrderFilterResolver

func (*VegaResolverRoot) OrderSubmission added in v0.72.0

func (r *VegaResolverRoot) OrderSubmission() OrderSubmissionResolver

func (*VegaResolverRoot) OrderUpdate added in v0.55.0

func (r *VegaResolverRoot) OrderUpdate() OrderUpdateResolver

OrderUpdate returns the order resolver.

func (*VegaResolverRoot) PaidLiquidityFees added in v0.73.0

func (r *VegaResolverRoot) PaidLiquidityFees() PaidLiquidityFeesResolver

func (*VegaResolverRoot) Party

func (r *VegaResolverRoot) Party() PartyResolver

Party returns the parties resolver.

func (*VegaResolverRoot) PartyActivityStreak added in v0.73.0

func (r *VegaResolverRoot) PartyActivityStreak() PartyActivityStreakResolver

func (*VegaResolverRoot) PartyAmount added in v0.73.0

func (r *VegaResolverRoot) PartyAmount() PartyAmountResolver

func (*VegaResolverRoot) PartyLockedBalance added in v0.73.0

func (r *VegaResolverRoot) PartyLockedBalance() PartyLockedBalanceResolver

func (*VegaResolverRoot) PartyStake

func (r *VegaResolverRoot) PartyStake() PartyStakeResolver

func (*VegaResolverRoot) PartyVestingBalance added in v0.73.0

func (r *VegaResolverRoot) PartyVestingBalance() PartyVestingBalanceResolver

func (*VegaResolverRoot) PartyVestingBalancesSummary added in v0.73.0

func (r *VegaResolverRoot) PartyVestingBalancesSummary() PartyVestingBalancesSummaryResolver

func (*VegaResolverRoot) PartyVestingStats added in v0.73.0

func (r *VegaResolverRoot) PartyVestingStats() PartyVestingStatsResolver

func (*VegaResolverRoot) Perpetual added in v0.73.0

func (r *VegaResolverRoot) Perpetual() PerpetualResolver

func (*VegaResolverRoot) PerpetualProduct added in v0.73.0

func (r *VegaResolverRoot) PerpetualProduct() PerpetualProductResolver

func (*VegaResolverRoot) Position

func (r *VegaResolverRoot) Position() PositionResolver

Position returns the positions resolver.

func (*VegaResolverRoot) PositionUpdate added in v0.56.0

func (r *VegaResolverRoot) PositionUpdate() PositionUpdateResolver

PositionUpdate returns the positionUpdate resolver.

func (*VegaResolverRoot) PriceLevel

func (r *VegaResolverRoot) PriceLevel() PriceLevelResolver

PriceLevel returns the price levels resolver.

func (*VegaResolverRoot) Proposal

func (r *VegaResolverRoot) Proposal() ProposalResolver

Proposal returns the proposal resolver.

func (*VegaResolverRoot) ProposalDetail added in v0.71.0

func (r *VegaResolverRoot) ProposalDetail() ProposalDetailResolver

ProposalDetail returns the Proposal detail resolver.

func (*VegaResolverRoot) ProposalTerms

func (r *VegaResolverRoot) ProposalTerms() ProposalTermsResolver

func (*VegaResolverRoot) ProtocolUpgradeProposal added in v0.61.0

func (r *VegaResolverRoot) ProtocolUpgradeProposal() ProtocolUpgradeProposalResolver

func (*VegaResolverRoot) Query

func (r *VegaResolverRoot) Query() QueryResolver

Query returns the query resolver.

func (*VegaResolverRoot) RankingScore

func (r *VegaResolverRoot) RankingScore() RankingScoreResolver

func (*VegaResolverRoot) RecurringGovernanceTransfer added in v0.72.0

func (r *VegaResolverRoot) RecurringGovernanceTransfer() RecurringGovernanceTransferResolver

func (*VegaResolverRoot) RecurringTransfer

func (r *VegaResolverRoot) RecurringTransfer() RecurringTransferResolver

func (*VegaResolverRoot) ReferralProgram added in v0.73.0

func (r *VegaResolverRoot) ReferralProgram() ReferralProgramResolver

func (*VegaResolverRoot) ReferralSetReferee added in v0.73.0

func (r *VegaResolverRoot) ReferralSetReferee() ReferralSetRefereeResolver

func (*VegaResolverRoot) ReferralSetStats added in v0.73.0

func (r *VegaResolverRoot) ReferralSetStats() ReferralSetStatsResolver

func (*VegaResolverRoot) ReferrerRewardsGenerated added in v0.73.0

func (r *VegaResolverRoot) ReferrerRewardsGenerated() ReferrerRewardsGeneratedResolver

func (*VegaResolverRoot) Reward

func (r *VegaResolverRoot) Reward() RewardResolver

func (*VegaResolverRoot) RewardSummary

func (r *VegaResolverRoot) RewardSummary() RewardSummaryResolver

func (*VegaResolverRoot) RewardSummaryFilter added in v0.68.0

func (r *VegaResolverRoot) RewardSummaryFilter() RewardSummaryFilterResolver

RewardSummaryFilter returns RewardSummaryFilterResolver implementation.

func (*VegaResolverRoot) Spot added in v0.73.0

func (r *VegaResolverRoot) Spot() SpotResolver

func (*VegaResolverRoot) SpotProduct added in v0.73.0

func (r *VegaResolverRoot) SpotProduct() SpotProductResolver

func (*VegaResolverRoot) StakeLinking

func (r *VegaResolverRoot) StakeLinking() StakeLinkingResolver

func (*VegaResolverRoot) Statistics

func (r *VegaResolverRoot) Statistics() StatisticsResolver

func (*VegaResolverRoot) StopOrder added in v0.72.0

func (r *VegaResolverRoot) StopOrder() StopOrderResolver

func (*VegaResolverRoot) StopOrderFilter added in v0.72.0

func (r *VegaResolverRoot) StopOrderFilter() StopOrderFilterResolver

func (*VegaResolverRoot) Subscription

func (r *VegaResolverRoot) Subscription() SubscriptionResolver

Subscription returns the subscriptions resolver.

func (*VegaResolverRoot) Team added in v0.73.0

func (r *VegaResolverRoot) Team() TeamResolver

func (*VegaResolverRoot) TeamReferee added in v0.73.0

func (r *VegaResolverRoot) TeamReferee() TeamRefereeResolver

func (*VegaResolverRoot) TeamRefereeHistory added in v0.73.0

func (r *VegaResolverRoot) TeamRefereeHistory() TeamRefereeHistoryResolver

func (*VegaResolverRoot) TradableInstrument

func (r *VegaResolverRoot) TradableInstrument() TradableInstrumentResolver

func (*VegaResolverRoot) Trade

func (r *VegaResolverRoot) Trade() TradeResolver

Trade returns the trades resolver.

func (*VegaResolverRoot) TradeUpdate added in v0.55.0

func (r *VegaResolverRoot) TradeUpdate() TradeUpdateResolver

func (*VegaResolverRoot) TransactionResult added in v0.58.0

func (r *VegaResolverRoot) TransactionResult() TransactionResultResolver

func (*VegaResolverRoot) Transfer

func (r *VegaResolverRoot) Transfer() TransferResolver

func (*VegaResolverRoot) TransferNode added in v0.73.0

func (r *VegaResolverRoot) TransferNode() TransferNodeResolver

func (*VegaResolverRoot) UpdateAsset

func (r *VegaResolverRoot) UpdateAsset() UpdateAssetResolver

func (*VegaResolverRoot) UpdateMarket

func (r *VegaResolverRoot) UpdateMarket() UpdateMarketResolver

func (*VegaResolverRoot) UpdateMarketConfiguration

func (r *VegaResolverRoot) UpdateMarketConfiguration() UpdateMarketConfigurationResolver

func (*VegaResolverRoot) UpdateMarketState added in v0.73.0

func (r *VegaResolverRoot) UpdateMarketState() UpdateMarketStateResolver

func (*VegaResolverRoot) UpdateNetworkParameter

func (r *VegaResolverRoot) UpdateNetworkParameter() UpdateNetworkParameterResolver

func (*VegaResolverRoot) UpdateReferralProgram added in v0.73.0

func (r *VegaResolverRoot) UpdateReferralProgram() UpdateReferralProgramResolver

func (*VegaResolverRoot) UpdateSpotMarket added in v0.73.0

func (r *VegaResolverRoot) UpdateSpotMarket() UpdateSpotMarketResolver

func (*VegaResolverRoot) UpdateSpotMarketConfiguration added in v0.73.0

func (r *VegaResolverRoot) UpdateSpotMarketConfiguration() UpdateSpotMarketConfigurationResolver

func (*VegaResolverRoot) UpdateVolumeDiscountProgram added in v0.73.0

func (r *VegaResolverRoot) UpdateVolumeDiscountProgram() UpdateVolumeDiscountProgramResolver

func (*VegaResolverRoot) VolumeDiscountProgram added in v0.73.0

func (r *VegaResolverRoot) VolumeDiscountProgram() VolumeDiscountProgramResolver

func (*VegaResolverRoot) VolumeDiscountStats added in v0.73.0

func (r *VegaResolverRoot) VolumeDiscountStats() VolumeDiscountStatsResolver

func (*VegaResolverRoot) Vote

func (r *VegaResolverRoot) Vote() VoteResolver

func (*VegaResolverRoot) Withdrawal

func (r *VegaResolverRoot) Withdrawal() WithdrawalResolver

Withdrawal ...

type VolumeDiscountProgramResolver added in v0.73.0

type VolumeDiscountProgramResolver interface {
	Version(ctx context.Context, obj *v2.VolumeDiscountProgram) (int, error)

	WindowLength(ctx context.Context, obj *v2.VolumeDiscountProgram) (int, error)
}

type VolumeDiscountStatsResolver added in v0.73.0

type VolumeDiscountStatsResolver interface {
	AtEpoch(ctx context.Context, obj *v2.VolumeDiscountStats) (int, error)
}

type VoteResolver

type VoteResolver interface {
	Party(ctx context.Context, obj *vega.Vote) (*vega.Party, error)
	Datetime(ctx context.Context, obj *vega.Vote) (int64, error)

	GovernanceTokenBalance(ctx context.Context, obj *vega.Vote) (string, error)
	GovernanceTokenWeight(ctx context.Context, obj *vega.Vote) (string, error)
	EquityLikeShareWeight(ctx context.Context, obj *vega.Vote) (string, error)
}

type WithdrawalDetails

type WithdrawalDetails interface {
	IsWithdrawalDetails()
}

type WithdrawalResolver

type WithdrawalResolver interface {
	Party(ctx context.Context, obj *vega.Withdrawal) (*vega.Party, error)

	Asset(ctx context.Context, obj *vega.Withdrawal) (*vega.Asset, error)

	TxHash(ctx context.Context, obj *vega.Withdrawal) (*string, error)
	Details(ctx context.Context, obj *vega.Withdrawal) (WithdrawalDetails, error)
}

Source Files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL