events

package
v0.0.0-...-baf6593 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Cosmos event attribute values for the subtype attribute for different indexer events.
	// Keep these constants in sync with:
	// https://github.com/furyaprotocol/indexer/blob/master/services/ender/src/lib/types.ts.
	// Ender uses these to maintain a mapping between event type and event proto.
	SubtypeOrderFill        = "order_fill"
	SubtypeSubaccountUpdate = "subaccount_update"
	SubtypeTransfer         = "transfer"
	SubtypeMarket           = "market"
	SubtypeFundingValues    = "funding_values"
	SubtypeStatefulOrder    = "stateful_order"
	SubtypeAsset            = "asset"
	SubtypePerpetualMarket  = "perpetual_market"
	SubtypeLiquidityTier    = "liquidity_tier"
	SubtypeUpdatePerpetual  = "update_perpetual"
	SubtypeUpdateClobPair   = "update_clob_pair"
	SubtypeDeleveraging     = "deleveraging"
	SubtypeTradingReward    = "trading_reward"
)
View Source 
const (
	// Indexer event versions.
	OrderFillEventVersion        uint32 = 1
	SubaccountUpdateEventVersion uint32 = 1
	TransferEventVersion         uint32 = 1
	MarketEventVersion           uint32 = 1
	FundingValuesEventVersion    uint32 = 1
	StatefulOrderEventVersion    uint32 = 1
	AssetEventVersion            uint32 = 1
	PerpetualMarketEventVersion  uint32 = 1
	LiquidityTierEventVersion    uint32 = 1
	UpdatePerpetualEventVersion  uint32 = 1
	UpdateClobPairEventVersion   uint32 = 1
	DeleveragingEventVersion     uint32 = 1
	TradingRewardVersion         uint32 = 1
)

Variables

View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var FundingEventV1_Type_name = map[int32]string{
	0: "TYPE_UNSPECIFIED",
	1: "TYPE_PREMIUM_SAMPLE",
	2: "TYPE_FUNDING_RATE_AND_INDEX",
	3: "TYPE_PREMIUM_VOTE",
}
View Source 
var FundingEventV1_Type_value = map[string]int32{
	"TYPE_UNSPECIFIED":            0,
	"TYPE_PREMIUM_SAMPLE":         1,
	"TYPE_FUNDING_RATE_AND_INDEX": 2,
	"TYPE_PREMIUM_VOTE":           3,
}
View Source 
var OnChainEventSubtypes = []string{
	SubtypeOrderFill,
	SubtypeSubaccountUpdate,
	SubtypeTransfer,
	SubtypeMarket,
	SubtypeFundingValues,
	SubtypeStatefulOrder,
	SubtypeAsset,
	SubtypePerpetualMarket,
	SubtypeLiquidityTier,
	SubtypeUpdatePerpetual,
	SubtypeUpdateClobPair,
	SubtypeDeleveraging,
	SubtypeTradingReward,
}

Functions

This section is empty.

Types

type AddressTradingReward 

type AddressTradingReward struct {
	// The address of the wallet that will receive the trading reward.
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// The amount of trading rewards earned by the address above in denoms. 1e18
	// denoms is equivalent to a single coin.
	DenomAmount github_com_furyaprotocol_v4_chain_protocol_dtypes.SerializableInt `` /* 162-byte string literal not displayed */
}

AddressTradingReward contains info on an instance of an address receiving a reward

func (*AddressTradingReward) Descriptor 

func (*AddressTradingReward) Descriptor() ([]byte, []int)

func (*AddressTradingReward) GetOwner 

func (m *AddressTradingReward) GetOwner() string

func (*AddressTradingReward) Marshal 

func (m *AddressTradingReward) Marshal() (dAtA []byte, err error)

func (*AddressTradingReward) MarshalTo 

func (m *AddressTradingReward) MarshalTo(dAtA []byte) (int, error)

func (*AddressTradingReward) MarshalToSizedBuffer 

func (m *AddressTradingReward) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddressTradingReward) ProtoMessage 

func (*AddressTradingReward) ProtoMessage()

func (*AddressTradingReward) Reset 

func (m *AddressTradingReward) Reset()

func (*AddressTradingReward) Size 

func (m *AddressTradingReward) Size() (n int)

func (*AddressTradingReward) String 

func (m *AddressTradingReward) String() string

func (*AddressTradingReward) Unmarshal 

func (m *AddressTradingReward) Unmarshal(dAtA []byte) error

func (*AddressTradingReward) XXX_DiscardUnknown 

func (m *AddressTradingReward) XXX_DiscardUnknown()

func (*AddressTradingReward) XXX_Marshal 

func (m *AddressTradingReward) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddressTradingReward) XXX_Merge 

func (m *AddressTradingReward) XXX_Merge(src proto.Message)

func (*AddressTradingReward) XXX_Size 

func (m *AddressTradingReward) XXX_Size() int

func (*AddressTradingReward) XXX_Unmarshal 

func (m *AddressTradingReward) XXX_Unmarshal(b []byte) error

type AssetCreateEventV1 

type AssetCreateEventV1 struct {
	// Unique, sequentially-generated.
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The human readable symbol of the `Asset` (e.g. `USDC`, `ATOM`).
	// Must be uppercase, unique and correspond to the canonical symbol of the
	// full coin.
	Symbol string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"`
	// `true` if this `Asset` has a valid `MarketId` value.
	HasMarket bool `protobuf:"varint,3,opt,name=has_market,json=hasMarket,proto3" json:"has_market,omitempty"`
	// The `Id` of the `Market` associated with this `Asset`. It acts as the
	// oracle price for the purposes of calculating collateral
	// and margin requirements.
	MarketId uint32 `protobuf:"varint,4,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The exponent for converting an atomic amount (1 'quantum')
	// to a full coin. For example, if `atomic_resolution = -8`
	// then an `asset_position` with `base_quantums = 1e8` is equivalent to
	// a position size of one full coin.
	AtomicResolution int32 `protobuf:"zigzag32,5,opt,name=atomic_resolution,json=atomicResolution,proto3" json:"atomic_resolution,omitempty"`
}

AssetCreateEventV1 message contains all the information about an new Asset on the dYdX chain.

func NewAssetCreateEvent 

func NewAssetCreateEvent(
	id uint32,
	symbol string,
	hasMarket bool,
	marketId uint32,
	atomicResolution int32,
) *AssetCreateEventV1

NewAssetCreateEvent creates a AssetCreateEvent representing creation of an asset.

func (*AssetCreateEventV1) Descriptor 

func (*AssetCreateEventV1) Descriptor() ([]byte, []int)

func (*AssetCreateEventV1) GetAtomicResolution 

func (m *AssetCreateEventV1) GetAtomicResolution() int32

func (*AssetCreateEventV1) GetHasMarket 

func (m *AssetCreateEventV1) GetHasMarket() bool

func (*AssetCreateEventV1) GetId 

func (m *AssetCreateEventV1) GetId() uint32

func (*AssetCreateEventV1) GetMarketId 

func (m *AssetCreateEventV1) GetMarketId() uint32

func (*AssetCreateEventV1) GetSymbol 

func (m *AssetCreateEventV1) GetSymbol() string

func (*AssetCreateEventV1) Marshal 

func (m *AssetCreateEventV1) Marshal() (dAtA []byte, err error)

func (*AssetCreateEventV1) MarshalTo 

func (m *AssetCreateEventV1) MarshalTo(dAtA []byte) (int, error)

func (*AssetCreateEventV1) MarshalToSizedBuffer 

func (m *AssetCreateEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AssetCreateEventV1) ProtoMessage 

func (*AssetCreateEventV1) ProtoMessage()

func (*AssetCreateEventV1) Reset 

func (m *AssetCreateEventV1) Reset()

func (*AssetCreateEventV1) Size 

func (m *AssetCreateEventV1) Size() (n int)

func (*AssetCreateEventV1) String 

func (m *AssetCreateEventV1) String() string

func (*AssetCreateEventV1) Unmarshal 

func (m *AssetCreateEventV1) Unmarshal(dAtA []byte) error

func (*AssetCreateEventV1) XXX_DiscardUnknown 

func (m *AssetCreateEventV1) XXX_DiscardUnknown()

func (*AssetCreateEventV1) XXX_Marshal 

func (m *AssetCreateEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssetCreateEventV1) XXX_Merge 

func (m *AssetCreateEventV1) XXX_Merge(src proto.Message)

func (*AssetCreateEventV1) XXX_Size 

func (m *AssetCreateEventV1) XXX_Size() int

func (*AssetCreateEventV1) XXX_Unmarshal 

func (m *AssetCreateEventV1) XXX_Unmarshal(b []byte) error

type DeleveragingEventV1 

type DeleveragingEventV1 struct {
	// ID of the subaccount that was liquidated.
	Liquidated v1.IndexerSubaccountId `protobuf:"bytes,1,opt,name=liquidated,proto3" json:"liquidated"`
	// ID of the subaccount that was used to offset the position.
	Offsetting v1.IndexerSubaccountId `protobuf:"bytes,2,opt,name=offsetting,proto3" json:"offsetting"`
	// The ID of the perpetual that was liquidated.
	PerpetualId uint32 `protobuf:"varint,3,opt,name=perpetual_id,json=perpetualId,proto3" json:"perpetual_id,omitempty"`
	// The amount filled between the liquidated and offsetting position, in
	// base quantums.
	FillAmount uint64 `protobuf:"varint,4,opt,name=fill_amount,json=fillAmount,proto3" json:"fill_amount,omitempty"`
	// Fill price of deleveraging event, in USDC quote quantums.
	Price uint64 `protobuf:"varint,5,opt,name=price,proto3" json:"price,omitempty"`
	// `true` if liquidating a short position, `false` otherwise.
	IsBuy bool `protobuf:"varint,6,opt,name=is_buy,json=isBuy,proto3" json:"is_buy,omitempty"`
	// `true` if the deleveraging event is for final settlement, indicating
	// the match occurred at the oracle price rather than bankruptcy price.
	// When this flag is `false`, the fill price is the bankruptcy price
	// of the liquidated subaccount.
	IsFinalSettlement bool `protobuf:"varint,7,opt,name=is_final_settlement,json=isFinalSettlement,proto3" json:"is_final_settlement,omitempty"`
}

DeleveragingEvent message contains all the information for a deleveraging on the dYdX chain. This includes the liquidated/offsetting subaccounts and the amount filled.

func NewDeleveragingEvent 

func NewDeleveragingEvent(
	liquidatedSubaccountId satypes.SubaccountId,
	offsettingSubaccountId satypes.SubaccountId,
	perpetualId uint32,
	fillAmount satypes.BaseQuantums,
	price satypes.BaseQuantums,
	isBuy bool,
) *DeleveragingEventV1

NewDeleveragingEvent creates a DeleveragingEvent representing a deleveraging where a liquidated subaccount's position is offset by another subaccount.

func (*DeleveragingEventV1) Descriptor 

func (*DeleveragingEventV1) Descriptor() ([]byte, []int)

func (*DeleveragingEventV1) GetFillAmount 

func (m *DeleveragingEventV1) GetFillAmount() uint64

func (*DeleveragingEventV1) GetIsBuy 

func (m *DeleveragingEventV1) GetIsBuy() bool

func (*DeleveragingEventV1) GetIsFinalSettlement 

func (m *DeleveragingEventV1) GetIsFinalSettlement() bool

func (*DeleveragingEventV1) GetLiquidated 

func (m *DeleveragingEventV1) GetLiquidated() v1.IndexerSubaccountId

func (*DeleveragingEventV1) GetOffsetting 

func (m *DeleveragingEventV1) GetOffsetting() v1.IndexerSubaccountId

func (*DeleveragingEventV1) GetPerpetualId 

func (m *DeleveragingEventV1) GetPerpetualId() uint32

func (*DeleveragingEventV1) GetPrice 

func (m *DeleveragingEventV1) GetPrice() uint64

func (*DeleveragingEventV1) Marshal 

func (m *DeleveragingEventV1) Marshal() (dAtA []byte, err error)

func (*DeleveragingEventV1) MarshalTo 

func (m *DeleveragingEventV1) MarshalTo(dAtA []byte) (int, error)

func (*DeleveragingEventV1) MarshalToSizedBuffer 

func (m *DeleveragingEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleveragingEventV1) ProtoMessage 

func (*DeleveragingEventV1) ProtoMessage()

func (*DeleveragingEventV1) Reset 

func (m *DeleveragingEventV1) Reset()

func (*DeleveragingEventV1) Size 

func (m *DeleveragingEventV1) Size() (n int)

func (*DeleveragingEventV1) String 

func (m *DeleveragingEventV1) String() string

func (*DeleveragingEventV1) Unmarshal 

func (m *DeleveragingEventV1) Unmarshal(dAtA []byte) error

func (*DeleveragingEventV1) XXX_DiscardUnknown 

func (m *DeleveragingEventV1) XXX_DiscardUnknown()

func (*DeleveragingEventV1) XXX_Marshal 

func (m *DeleveragingEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleveragingEventV1) XXX_Merge 

func (m *DeleveragingEventV1) XXX_Merge(src proto.Message)

func (*DeleveragingEventV1) XXX_Size 

func (m *DeleveragingEventV1) XXX_Size() int

func (*DeleveragingEventV1) XXX_Unmarshal 

func (m *DeleveragingEventV1) XXX_Unmarshal(b []byte) error

type FundingEventV1 

type FundingEventV1 struct {
	// updates is a list of per-market funding updates for all existing perpetual
	// markets. The list is sorted by `perpetualId`s which are unique.
	Updates []FundingUpdateV1 `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates"`
	// type stores the type of funding updates.
	Type FundingEventV1_Type `protobuf:"varint,2,opt,name=type,proto3,enum=furyaprotocol.indexer.events.FundingEventV1_Type" json:"type,omitempty"`
}

FundingEvent message contains a list of per-market funding values. The funding values in the list is of the same type and the types are: which can have one of the following types:

  1. Premium vote: votes on the premium values injected by block proposers.
  2. Premium sample: combined value from all premium votes during a `funding-sample` epoch.
  3. Funding rate and index: final funding rate combining all premium samples during a `funding-tick` epoch and funding index accordingly updated with `funding rate * price`.

func NewFundingRatesAndIndicesEvent 

func NewFundingRatesAndIndicesEvent(
	newFundingRatesAndIndicesForEvent []FundingUpdateV1,
) *FundingEventV1

NewFundingRatesAndIndicesEvent creates a FundingEvent representing a list of new funding rates generated at the end of each `funding-tick` epoch and funding indices accordingly updated with `funding rate * price`.

func NewPremiumSamplesEvent 

func NewPremiumSamplesEvent(
	newSamplesForEvent []FundingUpdateV1,
) *FundingEventV1

NewPremiumSamplesEvent creates a FundingEvent representing a list of new funding premium samples generated at the end of each `funding-sample` epoch.

func (*FundingEventV1) Descriptor 

func (*FundingEventV1) Descriptor() ([]byte, []int)

func (*FundingEventV1) GetType 

func (m *FundingEventV1) GetType() FundingEventV1_Type

func (*FundingEventV1) GetUpdates 

func (m *FundingEventV1) GetUpdates() []FundingUpdateV1

func (*FundingEventV1) Marshal 

func (m *FundingEventV1) Marshal() (dAtA []byte, err error)

func (*FundingEventV1) MarshalTo 

func (m *FundingEventV1) MarshalTo(dAtA []byte) (int, error)

func (*FundingEventV1) MarshalToSizedBuffer 

func (m *FundingEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FundingEventV1) ProtoMessage 

func (*FundingEventV1) ProtoMessage()

func (*FundingEventV1) Reset 

func (m *FundingEventV1) Reset()

func (*FundingEventV1) Size 

func (m *FundingEventV1) Size() (n int)

func (*FundingEventV1) String 

func (m *FundingEventV1) String() string

func (*FundingEventV1) Unmarshal 

func (m *FundingEventV1) Unmarshal(dAtA []byte) error

func (*FundingEventV1) XXX_DiscardUnknown 

func (m *FundingEventV1) XXX_DiscardUnknown()

func (*FundingEventV1) XXX_Marshal 

func (m *FundingEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FundingEventV1) XXX_Merge 

func (m *FundingEventV1) XXX_Merge(src proto.Message)

func (*FundingEventV1) XXX_Size 

func (m *FundingEventV1) XXX_Size() int

func (*FundingEventV1) XXX_Unmarshal 

func (m *FundingEventV1) XXX_Unmarshal(b []byte) error

type FundingEventV1_Type 

type FundingEventV1_Type int32

Type is the type for funding values. 

const (
	// Unspecified type.
	FundingEventV1_TYPE_UNSPECIFIED FundingEventV1_Type = 0
	// Premium sample is the combined value from all premium votes during a
	// `funding-sample` epoch.
	FundingEventV1_TYPE_PREMIUM_SAMPLE FundingEventV1_Type = 1
	// Funding rate is the final funding rate combining all premium samples
	// during a `funding-tick` epoch.
	FundingEventV1_TYPE_FUNDING_RATE_AND_INDEX FundingEventV1_Type = 2
	// TODO(DEC-1513): Investigate whether premium vote values need to be
	// sent to indexer.
	FundingEventV1_TYPE_PREMIUM_VOTE FundingEventV1_Type = 3
)

func (FundingEventV1_Type) EnumDescriptor 

func (FundingEventV1_Type) EnumDescriptor() ([]byte, []int)

func (FundingEventV1_Type) String 

func (x FundingEventV1_Type) String() string

type FundingUpdateV1 

type FundingUpdateV1 struct {
	// The id of the perpetual market.
	PerpetualId uint32 `protobuf:"varint,1,opt,name=perpetual_id,json=perpetualId,proto3" json:"perpetual_id,omitempty"`
	// funding value (in parts-per-million) can be premium vote, premium sample,
	// or funding rate.
	FundingValuePpm int32 `protobuf:"varint,2,opt,name=funding_value_ppm,json=fundingValuePpm,proto3" json:"funding_value_ppm,omitempty"`
	// funding index is required if and only if parent `FundingEvent` type is
	// `TYPE_FUNDING_RATE_AND_INDEX`.
	FundingIndex github_com_furyaprotocol_v4_chain_protocol_dtypes.SerializableInt `` /* 165-byte string literal not displayed */
}

FundingUpdate is used for funding update events and includes a funding value and an optional funding index that correspond to a perpetual market.

func (*FundingUpdateV1) Descriptor 

func (*FundingUpdateV1) Descriptor() ([]byte, []int)

func (*FundingUpdateV1) GetFundingValuePpm 

func (m *FundingUpdateV1) GetFundingValuePpm() int32

func (*FundingUpdateV1) GetPerpetualId 

func (m *FundingUpdateV1) GetPerpetualId() uint32

func (*FundingUpdateV1) Marshal 

func (m *FundingUpdateV1) Marshal() (dAtA []byte, err error)

func (*FundingUpdateV1) MarshalTo 

func (m *FundingUpdateV1) MarshalTo(dAtA []byte) (int, error)

func (*FundingUpdateV1) MarshalToSizedBuffer 

func (m *FundingUpdateV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FundingUpdateV1) ProtoMessage 

func (*FundingUpdateV1) ProtoMessage()

func (*FundingUpdateV1) Reset 

func (m *FundingUpdateV1) Reset()

func (*FundingUpdateV1) Size 

func (m *FundingUpdateV1) Size() (n int)

func (*FundingUpdateV1) String 

func (m *FundingUpdateV1) String() string

func (*FundingUpdateV1) Unmarshal 

func (m *FundingUpdateV1) Unmarshal(dAtA []byte) error

func (*FundingUpdateV1) XXX_DiscardUnknown 

func (m *FundingUpdateV1) XXX_DiscardUnknown()

func (*FundingUpdateV1) XXX_Marshal 

func (m *FundingUpdateV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FundingUpdateV1) XXX_Merge 

func (m *FundingUpdateV1) XXX_Merge(src proto.Message)

func (*FundingUpdateV1) XXX_Size 

func (m *FundingUpdateV1) XXX_Size() int

func (*FundingUpdateV1) XXX_Unmarshal 

func (m *FundingUpdateV1) XXX_Unmarshal(b []byte) error

type LiquidationOrderV1 

type LiquidationOrderV1 struct {
	// ID of the subaccount that was liquidated.
	Liquidated v1.IndexerSubaccountId `protobuf:"bytes,1,opt,name=liquidated,proto3" json:"liquidated"`
	// The ID of the clob pair involved in the liquidation.
	ClobPairId uint32 `protobuf:"varint,2,opt,name=clob_pair_id,json=clobPairId,proto3" json:"clob_pair_id,omitempty"`
	// The ID of the perpetual involved in the liquidation.
	PerpetualId uint32 `protobuf:"varint,3,opt,name=perpetual_id,json=perpetualId,proto3" json:"perpetual_id,omitempty"`
	// The total size of the liquidation order including any unfilled size,
	// in base quantums.
	TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// `true` if liquidating a short position, `false` otherwise.
	IsBuy bool `protobuf:"varint,5,opt,name=is_buy,json=isBuy,proto3" json:"is_buy,omitempty"`
	// The fillable price in subticks.
	// This represents the lower-price-bound for liquidating longs
	// and the upper-price-bound for liquidating shorts.
	// Must be a multiple of ClobPair.SubticksPerTick
	// (where `ClobPair.Id = orderId.ClobPairId`).
	Subticks uint64 `protobuf:"varint,6,opt,name=subticks,proto3" json:"subticks,omitempty"`
}

LiquidationOrder represents the liquidation taker order to be included in a liquidation order fill event.

func (*LiquidationOrderV1) Descriptor 

func (*LiquidationOrderV1) Descriptor() ([]byte, []int)

func (*LiquidationOrderV1) GetClobPairId 

func (m *LiquidationOrderV1) GetClobPairId() uint32

func (*LiquidationOrderV1) GetIsBuy 

func (m *LiquidationOrderV1) GetIsBuy() bool

func (*LiquidationOrderV1) GetLiquidated 

func (m *LiquidationOrderV1) GetLiquidated() v1.IndexerSubaccountId

func (*LiquidationOrderV1) GetPerpetualId 

func (m *LiquidationOrderV1) GetPerpetualId() uint32

func (*LiquidationOrderV1) GetSubticks 

func (m *LiquidationOrderV1) GetSubticks() uint64

func (*LiquidationOrderV1) GetTotalSize 

func (m *LiquidationOrderV1) GetTotalSize() uint64

func (*LiquidationOrderV1) Marshal 

func (m *LiquidationOrderV1) Marshal() (dAtA []byte, err error)

func (*LiquidationOrderV1) MarshalTo 

func (m *LiquidationOrderV1) MarshalTo(dAtA []byte) (int, error)

func (*LiquidationOrderV1) MarshalToSizedBuffer 

func (m *LiquidationOrderV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LiquidationOrderV1) ProtoMessage 

func (*LiquidationOrderV1) ProtoMessage()

func (*LiquidationOrderV1) Reset 

func (m *LiquidationOrderV1) Reset()

func (*LiquidationOrderV1) Size 

func (m *LiquidationOrderV1) Size() (n int)

func (*LiquidationOrderV1) String 

func (m *LiquidationOrderV1) String() string

func (*LiquidationOrderV1) Unmarshal 

func (m *LiquidationOrderV1) Unmarshal(dAtA []byte) error

func (*LiquidationOrderV1) XXX_DiscardUnknown 

func (m *LiquidationOrderV1) XXX_DiscardUnknown()

func (*LiquidationOrderV1) XXX_Marshal 

func (m *LiquidationOrderV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiquidationOrderV1) XXX_Merge 

func (m *LiquidationOrderV1) XXX_Merge(src proto.Message)

func (*LiquidationOrderV1) XXX_Size 

func (m *LiquidationOrderV1) XXX_Size() int

func (*LiquidationOrderV1) XXX_Unmarshal 

func (m *LiquidationOrderV1) XXX_Unmarshal(b []byte) error

type LiquidityTierUpsertEventV1 

type LiquidityTierUpsertEventV1 struct {
	// Unique id.
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The name of the tier purely for mnemonic purposes, e.g. "Gold".
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The margin fraction needed to open a position.
	// In parts-per-million.
	InitialMarginPpm uint32 `protobuf:"varint,3,opt,name=initial_margin_ppm,json=initialMarginPpm,proto3" json:"initial_margin_ppm,omitempty"`
	// The fraction of the initial-margin that the maintenance-margin is,
	// e.g. 50%. In parts-per-million.
	MaintenanceFractionPpm uint32 `` /* 130-byte string literal not displayed */
	// The maximum position size at which the margin requirements are
	// not increased over the default values. Above this position size,
	// the margin requirements increase at a rate of sqrt(size).
	//
	// Deprecated since v3.x.
	BasePositionNotional uint64 `protobuf:"varint,5,opt,name=base_position_notional,json=basePositionNotional,proto3" json:"base_position_notional,omitempty"` // Deprecated: Do not use.
}

LiquidityTierUpsertEventV1 message contains all the information to create/update a Liquidity Tier on the dYdX chain.

func NewLiquidityTierUpsertEvent 

func NewLiquidityTierUpsertEvent(
	id uint32,
	name string,
	initialMarginPpm uint32,
	maintenanceFractionPpm uint32,
) *LiquidityTierUpsertEventV1

NewLiquidityTierUpsertEvent creates a LiquidityTierUpsertEvent representing upsert of a liquidity tier.

func (*LiquidityTierUpsertEventV1) Descriptor 

func (*LiquidityTierUpsertEventV1) Descriptor() ([]byte, []int)

func (*LiquidityTierUpsertEventV1) GetBasePositionNotional deprecated 

func (m *LiquidityTierUpsertEventV1) GetBasePositionNotional() uint64

Deprecated: Do not use.

func (*LiquidityTierUpsertEventV1) GetId 

func (m *LiquidityTierUpsertEventV1) GetId() uint32

func (*LiquidityTierUpsertEventV1) GetInitialMarginPpm 

func (m *LiquidityTierUpsertEventV1) GetInitialMarginPpm() uint32

func (*LiquidityTierUpsertEventV1) GetMaintenanceFractionPpm 

func (m *LiquidityTierUpsertEventV1) GetMaintenanceFractionPpm() uint32

func (*LiquidityTierUpsertEventV1) GetName 

func (m *LiquidityTierUpsertEventV1) GetName() string

func (*LiquidityTierUpsertEventV1) Marshal 

func (m *LiquidityTierUpsertEventV1) Marshal() (dAtA []byte, err error)

func (*LiquidityTierUpsertEventV1) MarshalTo 

func (m *LiquidityTierUpsertEventV1) MarshalTo(dAtA []byte) (int, error)

func (*LiquidityTierUpsertEventV1) MarshalToSizedBuffer 

func (m *LiquidityTierUpsertEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LiquidityTierUpsertEventV1) ProtoMessage 

func (*LiquidityTierUpsertEventV1) ProtoMessage()

func (*LiquidityTierUpsertEventV1) Reset 

func (m *LiquidityTierUpsertEventV1) Reset()

func (*LiquidityTierUpsertEventV1) Size 

func (m *LiquidityTierUpsertEventV1) Size() (n int)

func (*LiquidityTierUpsertEventV1) String 

func (m *LiquidityTierUpsertEventV1) String() string

func (*LiquidityTierUpsertEventV1) Unmarshal 

func (m *LiquidityTierUpsertEventV1) Unmarshal(dAtA []byte) error

func (*LiquidityTierUpsertEventV1) XXX_DiscardUnknown 

func (m *LiquidityTierUpsertEventV1) XXX_DiscardUnknown()

func (*LiquidityTierUpsertEventV1) XXX_Marshal 

func (m *LiquidityTierUpsertEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiquidityTierUpsertEventV1) XXX_Merge 

func (m *LiquidityTierUpsertEventV1) XXX_Merge(src proto.Message)

func (*LiquidityTierUpsertEventV1) XXX_Size 

func (m *LiquidityTierUpsertEventV1) XXX_Size() int

func (*LiquidityTierUpsertEventV1) XXX_Unmarshal 

func (m *LiquidityTierUpsertEventV1) XXX_Unmarshal(b []byte) error

type MarketBaseEventV1 

type MarketBaseEventV1 struct {
	// String representation of the market pair, e.g. `BTC-USD`
	Pair string `protobuf:"bytes,1,opt,name=pair,proto3" json:"pair,omitempty"`
	// The minimum allowable change in the Price value for a given update.
	// Measured as 1e-6.
	MinPriceChangePpm uint32 `protobuf:"varint,2,opt,name=min_price_change_ppm,json=minPriceChangePpm,proto3" json:"min_price_change_ppm,omitempty"`
}

shared fields between MarketCreateEvent and MarketModifyEvent

func (*MarketBaseEventV1) Descriptor 

func (*MarketBaseEventV1) Descriptor() ([]byte, []int)

func (*MarketBaseEventV1) GetMinPriceChangePpm 

func (m *MarketBaseEventV1) GetMinPriceChangePpm() uint32

func (*MarketBaseEventV1) GetPair 

func (m *MarketBaseEventV1) GetPair() string

func (*MarketBaseEventV1) Marshal 

func (m *MarketBaseEventV1) Marshal() (dAtA []byte, err error)

func (*MarketBaseEventV1) MarshalTo 

func (m *MarketBaseEventV1) MarshalTo(dAtA []byte) (int, error)

func (*MarketBaseEventV1) MarshalToSizedBuffer 

func (m *MarketBaseEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketBaseEventV1) ProtoMessage 

func (*MarketBaseEventV1) ProtoMessage()

func (*MarketBaseEventV1) Reset 

func (m *MarketBaseEventV1) Reset()

func (*MarketBaseEventV1) Size 

func (m *MarketBaseEventV1) Size() (n int)

func (*MarketBaseEventV1) String 

func (m *MarketBaseEventV1) String() string

func (*MarketBaseEventV1) Unmarshal 

func (m *MarketBaseEventV1) Unmarshal(dAtA []byte) error

func (*MarketBaseEventV1) XXX_DiscardUnknown 

func (m *MarketBaseEventV1) XXX_DiscardUnknown()

func (*MarketBaseEventV1) XXX_Marshal 

func (m *MarketBaseEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketBaseEventV1) XXX_Merge 

func (m *MarketBaseEventV1) XXX_Merge(src proto.Message)

func (*MarketBaseEventV1) XXX_Size 

func (m *MarketBaseEventV1) XXX_Size() int

func (*MarketBaseEventV1) XXX_Unmarshal 

func (m *MarketBaseEventV1) XXX_Unmarshal(b []byte) error

type MarketCreateEventV1 

type MarketCreateEventV1 struct {
	Base *MarketBaseEventV1 `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Static value. The exponent of the price.
	// For example if Exponent == -5 then a `exponent_price` of 1,000,000,000
	// represents $10,000. Therefore 10 ^ Exponent represents the smallest
	// price step (in dollars) that can be recorded.
	Exponent int32 `protobuf:"zigzag32,2,opt,name=exponent,proto3" json:"exponent,omitempty"`
}

MarketCreateEvent message contains all the information about a new market on the dYdX chain.

func (*MarketCreateEventV1) Descriptor 

func (*MarketCreateEventV1) Descriptor() ([]byte, []int)

func (*MarketCreateEventV1) GetBase 

func (m *MarketCreateEventV1) GetBase() *MarketBaseEventV1

func (*MarketCreateEventV1) GetExponent 

func (m *MarketCreateEventV1) GetExponent() int32

func (*MarketCreateEventV1) Marshal 

func (m *MarketCreateEventV1) Marshal() (dAtA []byte, err error)

func (*MarketCreateEventV1) MarshalTo 

func (m *MarketCreateEventV1) MarshalTo(dAtA []byte) (int, error)

func (*MarketCreateEventV1) MarshalToSizedBuffer 

func (m *MarketCreateEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketCreateEventV1) ProtoMessage 

func (*MarketCreateEventV1) ProtoMessage()

func (*MarketCreateEventV1) Reset 

func (m *MarketCreateEventV1) Reset()

func (*MarketCreateEventV1) Size 

func (m *MarketCreateEventV1) Size() (n int)

func (*MarketCreateEventV1) String 

func (m *MarketCreateEventV1) String() string

func (*MarketCreateEventV1) Unmarshal 

func (m *MarketCreateEventV1) Unmarshal(dAtA []byte) error

func (*MarketCreateEventV1) XXX_DiscardUnknown 

func (m *MarketCreateEventV1) XXX_DiscardUnknown()

func (*MarketCreateEventV1) XXX_Marshal 

func (m *MarketCreateEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketCreateEventV1) XXX_Merge 

func (m *MarketCreateEventV1) XXX_Merge(src proto.Message)

func (*MarketCreateEventV1) XXX_Size 

func (m *MarketCreateEventV1) XXX_Size() int

func (*MarketCreateEventV1) XXX_Unmarshal 

func (m *MarketCreateEventV1) XXX_Unmarshal(b []byte) error

type MarketEventV1 

type MarketEventV1 struct {
	// market id.
	MarketId uint32 `protobuf:"varint,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// either an event for price update, market creation, or market modification.
	//
	// Types that are valid to be assigned to Event:
	//	*MarketEventV1_PriceUpdate
	//	*MarketEventV1_MarketCreate
	//	*MarketEventV1_MarketModify
	Event isMarketEventV1_Event `protobuf_oneof:"event"`
}

MarketEvent message contains all the information about a market event on the dYdX chain.

func NewMarketCreateEvent 

func NewMarketCreateEvent(
	marketId uint32,
	pair string,
	minPriceChangePpm uint32,
	exponent int32,
) *MarketEventV1

NewMarketCreateEvent creates a MarketEvent representing a new market.

func NewMarketModifyEvent 

func NewMarketModifyEvent(
	marketId uint32,
	pair string,
	minPriceChangePpm uint32,
) *MarketEventV1

NewMarketModifyEvent creates a MarketEvent representing an update to a market.

func NewMarketPriceUpdateEvent 

func NewMarketPriceUpdateEvent(
	marketId uint32,
	priceWithExponent uint64,
) *MarketEventV1

NewMarketPriceUpdateEvent creates a MarketEvent representing an update in the priceWithExponent of a market.

func (*MarketEventV1) Descriptor 

func (*MarketEventV1) Descriptor() ([]byte, []int)

func (*MarketEventV1) GetEvent 

func (m *MarketEventV1) GetEvent() isMarketEventV1_Event

func (*MarketEventV1) GetMarketCreate 

func (m *MarketEventV1) GetMarketCreate() *MarketCreateEventV1

func (*MarketEventV1) GetMarketId 

func (m *MarketEventV1) GetMarketId() uint32

func (*MarketEventV1) GetMarketModify 

func (m *MarketEventV1) GetMarketModify() *MarketModifyEventV1

func (*MarketEventV1) GetPriceUpdate 

func (m *MarketEventV1) GetPriceUpdate() *MarketPriceUpdateEventV1

func (*MarketEventV1) Marshal 

func (m *MarketEventV1) Marshal() (dAtA []byte, err error)

func (*MarketEventV1) MarshalTo 

func (m *MarketEventV1) MarshalTo(dAtA []byte) (int, error)

func (*MarketEventV1) MarshalToSizedBuffer 

func (m *MarketEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketEventV1) ProtoMessage 

func (*MarketEventV1) ProtoMessage()

func (*MarketEventV1) Reset 

func (m *MarketEventV1) Reset()

func (*MarketEventV1) Size 

func (m *MarketEventV1) Size() (n int)

func (*MarketEventV1) String 

func (m *MarketEventV1) String() string

func (*MarketEventV1) Unmarshal 

func (m *MarketEventV1) Unmarshal(dAtA []byte) error

func (*MarketEventV1) XXX_DiscardUnknown 

func (m *MarketEventV1) XXX_DiscardUnknown()

func (*MarketEventV1) XXX_Marshal 

func (m *MarketEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketEventV1) XXX_Merge 

func (m *MarketEventV1) XXX_Merge(src proto.Message)

func (*MarketEventV1) XXX_OneofWrappers 

func (*MarketEventV1) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MarketEventV1) XXX_Size 

func (m *MarketEventV1) XXX_Size() int

func (*MarketEventV1) XXX_Unmarshal 

func (m *MarketEventV1) XXX_Unmarshal(b []byte) error

type MarketEventV1_MarketCreate 

type MarketEventV1_MarketCreate struct {
	MarketCreate *MarketCreateEventV1 `protobuf:"bytes,3,opt,name=market_create,json=marketCreate,proto3,oneof" json:"market_create,omitempty"`
}

func (*MarketEventV1_MarketCreate) MarshalTo 

func (m *MarketEventV1_MarketCreate) MarshalTo(dAtA []byte) (int, error)

func (*MarketEventV1_MarketCreate) MarshalToSizedBuffer 

func (m *MarketEventV1_MarketCreate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketEventV1_MarketCreate) Size 

func (m *MarketEventV1_MarketCreate) Size() (n int)

type MarketEventV1_MarketModify 

type MarketEventV1_MarketModify struct {
	MarketModify *MarketModifyEventV1 `protobuf:"bytes,4,opt,name=market_modify,json=marketModify,proto3,oneof" json:"market_modify,omitempty"`
}

func (*MarketEventV1_MarketModify) MarshalTo 

func (m *MarketEventV1_MarketModify) MarshalTo(dAtA []byte) (int, error)

func (*MarketEventV1_MarketModify) MarshalToSizedBuffer 

func (m *MarketEventV1_MarketModify) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketEventV1_MarketModify) Size 

func (m *MarketEventV1_MarketModify) Size() (n int)

type MarketEventV1_PriceUpdate 

type MarketEventV1_PriceUpdate struct {
	PriceUpdate *MarketPriceUpdateEventV1 `protobuf:"bytes,2,opt,name=price_update,json=priceUpdate,proto3,oneof" json:"price_update,omitempty"`
}

func (*MarketEventV1_PriceUpdate) MarshalTo 

func (m *MarketEventV1_PriceUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketEventV1_PriceUpdate) MarshalToSizedBuffer 

func (m *MarketEventV1_PriceUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketEventV1_PriceUpdate) Size 

func (m *MarketEventV1_PriceUpdate) Size() (n int)

type MarketModifyEventV1 

type MarketModifyEventV1 struct {
	Base *MarketBaseEventV1 `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
}

MarketModifyEvent message contains all the information about a market update on the dYdX chain

func (*MarketModifyEventV1) Descriptor 

func (*MarketModifyEventV1) Descriptor() ([]byte, []int)

func (*MarketModifyEventV1) GetBase 

func (m *MarketModifyEventV1) GetBase() *MarketBaseEventV1

func (*MarketModifyEventV1) Marshal 

func (m *MarketModifyEventV1) Marshal() (dAtA []byte, err error)

func (*MarketModifyEventV1) MarshalTo 

func (m *MarketModifyEventV1) MarshalTo(dAtA []byte) (int, error)

func (*MarketModifyEventV1) MarshalToSizedBuffer 

func (m *MarketModifyEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketModifyEventV1) ProtoMessage 

func (*MarketModifyEventV1) ProtoMessage()

func (*MarketModifyEventV1) Reset 

func (m *MarketModifyEventV1) Reset()

func (*MarketModifyEventV1) Size 

func (m *MarketModifyEventV1) Size() (n int)

func (*MarketModifyEventV1) String 

func (m *MarketModifyEventV1) String() string

func (*MarketModifyEventV1) Unmarshal 

func (m *MarketModifyEventV1) Unmarshal(dAtA []byte) error

func (*MarketModifyEventV1) XXX_DiscardUnknown 

func (m *MarketModifyEventV1) XXX_DiscardUnknown()

func (*MarketModifyEventV1) XXX_Marshal 

func (m *MarketModifyEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketModifyEventV1) XXX_Merge 

func (m *MarketModifyEventV1) XXX_Merge(src proto.Message)

func (*MarketModifyEventV1) XXX_Size 

func (m *MarketModifyEventV1) XXX_Size() int

func (*MarketModifyEventV1) XXX_Unmarshal 

func (m *MarketModifyEventV1) XXX_Unmarshal(b []byte) error

type MarketPriceUpdateEventV1 

type MarketPriceUpdateEventV1 struct {
	// price_with_exponent. Multiply by 10 ^ Exponent to get the human readable
	// price in dollars. For example if `Exponent == -5` then a `exponent_price`
	// of `1,000,000,000` represents “$10,000`.
	PriceWithExponent uint64 `protobuf:"varint,1,opt,name=price_with_exponent,json=priceWithExponent,proto3" json:"price_with_exponent,omitempty"`
}

MarketPriceUpdateEvent message contains all the information about a price update on the dYdX chain.

func (*MarketPriceUpdateEventV1) Descriptor 

func (*MarketPriceUpdateEventV1) Descriptor() ([]byte, []int)

func (*MarketPriceUpdateEventV1) GetPriceWithExponent 

func (m *MarketPriceUpdateEventV1) GetPriceWithExponent() uint64

func (*MarketPriceUpdateEventV1) Marshal 

func (m *MarketPriceUpdateEventV1) Marshal() (dAtA []byte, err error)

func (*MarketPriceUpdateEventV1) MarshalTo 

func (m *MarketPriceUpdateEventV1) MarshalTo(dAtA []byte) (int, error)

func (*MarketPriceUpdateEventV1) MarshalToSizedBuffer 

func (m *MarketPriceUpdateEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketPriceUpdateEventV1) ProtoMessage 

func (*MarketPriceUpdateEventV1) ProtoMessage()

func (*MarketPriceUpdateEventV1) Reset 

func (m *MarketPriceUpdateEventV1) Reset()

func (*MarketPriceUpdateEventV1) Size 

func (m *MarketPriceUpdateEventV1) Size() (n int)

func (*MarketPriceUpdateEventV1) String 

func (m *MarketPriceUpdateEventV1) String() string

func (*MarketPriceUpdateEventV1) Unmarshal 

func (m *MarketPriceUpdateEventV1) Unmarshal(dAtA []byte) error

func (*MarketPriceUpdateEventV1) XXX_DiscardUnknown 

func (m *MarketPriceUpdateEventV1) XXX_DiscardUnknown()

func (*MarketPriceUpdateEventV1) XXX_Marshal 

func (m *MarketPriceUpdateEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketPriceUpdateEventV1) XXX_Merge 

func (m *MarketPriceUpdateEventV1) XXX_Merge(src proto.Message)

func (*MarketPriceUpdateEventV1) XXX_Size 

func (m *MarketPriceUpdateEventV1) XXX_Size() int

func (*MarketPriceUpdateEventV1) XXX_Unmarshal 

func (m *MarketPriceUpdateEventV1) XXX_Unmarshal(b []byte) error

type OrderFillEventV1 

type OrderFillEventV1 struct {
	MakerOrder v1.IndexerOrder `protobuf:"bytes,1,opt,name=maker_order,json=makerOrder,proto3" json:"maker_order"`
	// The type of order fill this event represents.
	//
	// Types that are valid to be assigned to TakerOrder:
	//
	//	*OrderFillEventV1_Order
	//	*OrderFillEventV1_LiquidationOrder
	TakerOrder isOrderFillEventV1_TakerOrder `protobuf_oneof:"taker_order"`
	// Fill amount in base quantums.
	FillAmount uint64 `protobuf:"varint,3,opt,name=fill_amount,json=fillAmount,proto3" json:"fill_amount,omitempty"`
	// Maker fee in USDC quantums.
	MakerFee int64 `protobuf:"zigzag64,5,opt,name=maker_fee,json=makerFee,proto3" json:"maker_fee,omitempty"`
	// Taker fee in USDC quantums. If the taker order is a liquidation, then this
	// represents the special liquidation fee, not the standard taker fee.
	TakerFee int64 `protobuf:"zigzag64,6,opt,name=taker_fee,json=takerFee,proto3" json:"taker_fee,omitempty"`
	// Total filled of the maker order in base quantums.
	TotalFilledMaker uint64 `protobuf:"varint,7,opt,name=total_filled_maker,json=totalFilledMaker,proto3" json:"total_filled_maker,omitempty"`
	// Total filled of the taker order in base quantums.
	TotalFilledTaker uint64 `protobuf:"varint,8,opt,name=total_filled_taker,json=totalFilledTaker,proto3" json:"total_filled_taker,omitempty"`
}

OrderFillEvent message contains all the information from an order match in the dYdX chain. This includes the maker/taker orders that matched and the amount filled.

func NewLiquidationOrderFillEvent 

func NewLiquidationOrderFillEvent(
	makerOrder clobtypes.Order,
	liquidationTakerOrder clobtypes.MatchableOrder,
	fillAmount satypes.BaseQuantums,
	makerFee int64,
	takerFee int64,
	totalFilledMaker satypes.BaseQuantums,
) *OrderFillEventV1

NewLiquidationOrderFillEvent creates a new OrderFillEvent proto message given the maker and liquidation taker orders along with the fill and fee amounts. Panics if the taker order is not a liquidation order. The taker fee here refers to the special liquidation fee, not the standard taker fee.

func NewOrderFillEvent 

func NewOrderFillEvent(
	makerOrder clobtypes.Order,
	takerOrder clobtypes.Order,
	fillAmount satypes.BaseQuantums,
	makerFee int64,
	takerFee int64,
	totalFilledMaker satypes.BaseQuantums,
	totalFilledTaker satypes.BaseQuantums,
) *OrderFillEventV1

NewOrderFillEvent creates a new OrderFillEvent proto message given the maker and taker orders along with the fill and fee amounts. Note: This function does no validation of the input maker/taker orders or the fill amount and assumes all such validation has been done before constructing the event.

func (*OrderFillEventV1) Descriptor 

func (*OrderFillEventV1) Descriptor() ([]byte, []int)

func (*OrderFillEventV1) GetFillAmount 

func (m *OrderFillEventV1) GetFillAmount() uint64

func (*OrderFillEventV1) GetLiquidationOrder 

func (m *OrderFillEventV1) GetLiquidationOrder() *LiquidationOrderV1

func (*OrderFillEventV1) GetMakerFee 

func (m *OrderFillEventV1) GetMakerFee() int64

func (*OrderFillEventV1) GetMakerOrder 

func (m *OrderFillEventV1) GetMakerOrder() v1.IndexerOrder

func (*OrderFillEventV1) GetOrder 

func (m *OrderFillEventV1) GetOrder() *v1.IndexerOrder

func (*OrderFillEventV1) GetTakerFee 

func (m *OrderFillEventV1) GetTakerFee() int64

func (*OrderFillEventV1) GetTakerOrder 

func (m *OrderFillEventV1) GetTakerOrder() isOrderFillEventV1_TakerOrder

func (*OrderFillEventV1) GetTotalFilledMaker 

func (m *OrderFillEventV1) GetTotalFilledMaker() uint64

func (*OrderFillEventV1) GetTotalFilledTaker 

func (m *OrderFillEventV1) GetTotalFilledTaker() uint64

func (*OrderFillEventV1) Marshal 

func (m *OrderFillEventV1) Marshal() (dAtA []byte, err error)

func (*OrderFillEventV1) MarshalTo 

func (m *OrderFillEventV1) MarshalTo(dAtA []byte) (int, error)

func (*OrderFillEventV1) MarshalToSizedBuffer 

func (m *OrderFillEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OrderFillEventV1) ProtoMessage 

func (*OrderFillEventV1) ProtoMessage()

func (*OrderFillEventV1) Reset 

func (m *OrderFillEventV1) Reset()

func (*OrderFillEventV1) Size 

func (m *OrderFillEventV1) Size() (n int)

func (*OrderFillEventV1) String 

func (m *OrderFillEventV1) String() string

func (*OrderFillEventV1) Unmarshal 

func (m *OrderFillEventV1) Unmarshal(dAtA []byte) error

func (*OrderFillEventV1) XXX_DiscardUnknown 

func (m *OrderFillEventV1) XXX_DiscardUnknown()

func (*OrderFillEventV1) XXX_Marshal 

func (m *OrderFillEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderFillEventV1) XXX_Merge 

func (m *OrderFillEventV1) XXX_Merge(src proto.Message)

func (*OrderFillEventV1) XXX_OneofWrappers 

func (*OrderFillEventV1) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OrderFillEventV1) XXX_Size 

func (m *OrderFillEventV1) XXX_Size() int

func (*OrderFillEventV1) XXX_Unmarshal 

func (m *OrderFillEventV1) XXX_Unmarshal(b []byte) error

type OrderFillEventV1_LiquidationOrder 

type OrderFillEventV1_LiquidationOrder struct {
	LiquidationOrder *LiquidationOrderV1 `protobuf:"bytes,4,opt,name=liquidation_order,json=liquidationOrder,proto3,oneof" json:"liquidation_order,omitempty"`
}

func (*OrderFillEventV1_LiquidationOrder) MarshalTo 

func (m *OrderFillEventV1_LiquidationOrder) MarshalTo(dAtA []byte) (int, error)

func (*OrderFillEventV1_LiquidationOrder) MarshalToSizedBuffer 

func (m *OrderFillEventV1_LiquidationOrder) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OrderFillEventV1_LiquidationOrder) Size 

func (m *OrderFillEventV1_LiquidationOrder) Size() (n int)

type OrderFillEventV1_Order 

type OrderFillEventV1_Order struct {
	Order *v1.IndexerOrder `protobuf:"bytes,2,opt,name=order,proto3,oneof" json:"order,omitempty"`
}

func (*OrderFillEventV1_Order) MarshalTo 

func (m *OrderFillEventV1_Order) MarshalTo(dAtA []byte) (int, error)

func (*OrderFillEventV1_Order) MarshalToSizedBuffer 

func (m *OrderFillEventV1_Order) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OrderFillEventV1_Order) Size 

func (m *OrderFillEventV1_Order) Size() (n int)

type PerpetualMarketCreateEventV1 

type PerpetualMarketCreateEventV1 struct {
	// Unique Perpetual id.
	// Defined in perpetuals.perpetual
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Unique clob pair Id associated with this perpetual market
	// Defined in clob.clob_pair
	ClobPairId uint32 `protobuf:"varint,2,opt,name=clob_pair_id,json=clobPairId,proto3" json:"clob_pair_id,omitempty"`
	// The name of the `Perpetual` (e.g. `BTC-USD`).
	// Defined in perpetuals.perpetual
	Ticker string `protobuf:"bytes,3,opt,name=ticker,proto3" json:"ticker,omitempty"`
	// Unique id of market param associated with this perpetual market.
	// Defined in perpetuals.perpetual
	MarketId uint32 `protobuf:"varint,4,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Status of the CLOB
	Status v1.ClobPairStatus `protobuf:"varint,5,opt,name=status,proto3,enum=furyaprotocol.indexer.protocol.v1.ClobPairStatus" json:"status,omitempty"`
	// `10^Exponent` gives the number of QuoteQuantums traded per BaseQuantum
	// per Subtick.
	// Defined in clob.clob_pair
	QuantumConversionExponent int32 `` /* 141-byte string literal not displayed */
	// The exponent for converting an atomic amount (`size = 1`)
	// to a full coin. For example, if `AtomicResolution = -8`
	// then a `PerpetualPosition` with `size = 1e8` is equivalent to
	// a position size of one full coin.
	// Defined in perpetuals.perpetual
	AtomicResolution int32 `protobuf:"zigzag32,7,opt,name=atomic_resolution,json=atomicResolution,proto3" json:"atomic_resolution,omitempty"`
	// Defines the tick size of the orderbook by defining how many subticks
	// are in one tick. That is, the subticks of any valid order must be a
	// multiple of this value. Generally this value should start `>= 100`to
	// allow room for decreasing it.
	// Defined in clob.clob_pair
	SubticksPerTick uint32 `protobuf:"varint,8,opt,name=subticks_per_tick,json=subticksPerTick,proto3" json:"subticks_per_tick,omitempty"`
	// Minimum increment in the size of orders on the CLOB, in base quantums.
	// Defined in clob.clob_pair
	StepBaseQuantums uint64 `protobuf:"varint,9,opt,name=step_base_quantums,json=stepBaseQuantums,proto3" json:"step_base_quantums,omitempty"`
	// The liquidity_tier that this perpetual is associated with.
	// Defined in perpetuals.perpetual
	LiquidityTier uint32 `protobuf:"varint,10,opt,name=liquidity_tier,json=liquidityTier,proto3" json:"liquidity_tier,omitempty"`
}

PerpetualMarketCreateEventV1 message contains all the information about a new Perpetual Market on the dYdX chain.

func NewPerpetualMarketCreateEvent 

func NewPerpetualMarketCreateEvent(
	id uint32,
	clobPairId uint32,
	ticker string,
	marketId uint32,
	status types.ClobPair_Status,
	quantumConversionExponent int32,
	atomicResolution int32,
	subticksPerTick uint32,
	stepBaseQuantums uint64,
	liquidityTier uint32,
) *PerpetualMarketCreateEventV1

NewPerpetualMarketCreateEvent creates a PerpetualMarketCreateEvent representing creation of a perpetual market.

func (*PerpetualMarketCreateEventV1) Descriptor 

func (*PerpetualMarketCreateEventV1) Descriptor() ([]byte, []int)

func (*PerpetualMarketCreateEventV1) GetAtomicResolution 

func (m *PerpetualMarketCreateEventV1) GetAtomicResolution() int32

func (*PerpetualMarketCreateEventV1) GetClobPairId 

func (m *PerpetualMarketCreateEventV1) GetClobPairId() uint32

func (*PerpetualMarketCreateEventV1) GetId 

func (m *PerpetualMarketCreateEventV1) GetId() uint32

func (*PerpetualMarketCreateEventV1) GetLiquidityTier 

func (m *PerpetualMarketCreateEventV1) GetLiquidityTier() uint32

func (*PerpetualMarketCreateEventV1) GetMarketId 

func (m *PerpetualMarketCreateEventV1) GetMarketId() uint32

func (*PerpetualMarketCreateEventV1) GetQuantumConversionExponent 

func (m *PerpetualMarketCreateEventV1) GetQuantumConversionExponent() int32

func (*PerpetualMarketCreateEventV1) GetStatus 

func (m *PerpetualMarketCreateEventV1) GetStatus() v1.ClobPairStatus

func (*PerpetualMarketCreateEventV1) GetStepBaseQuantums 

func (m *PerpetualMarketCreateEventV1) GetStepBaseQuantums() uint64

func (*PerpetualMarketCreateEventV1) GetSubticksPerTick 

func (m *PerpetualMarketCreateEventV1) GetSubticksPerTick() uint32

func (*PerpetualMarketCreateEventV1) GetTicker 

func (m *PerpetualMarketCreateEventV1) GetTicker() string

func (*PerpetualMarketCreateEventV1) Marshal 

func (m *PerpetualMarketCreateEventV1) Marshal() (dAtA []byte, err error)

func (*PerpetualMarketCreateEventV1) MarshalTo 

func (m *PerpetualMarketCreateEventV1) MarshalTo(dAtA []byte) (int, error)

func (*PerpetualMarketCreateEventV1) MarshalToSizedBuffer 

func (m *PerpetualMarketCreateEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PerpetualMarketCreateEventV1) ProtoMessage 

func (*PerpetualMarketCreateEventV1) ProtoMessage()

func (*PerpetualMarketCreateEventV1) Reset 

func (m *PerpetualMarketCreateEventV1) Reset()

func (*PerpetualMarketCreateEventV1) Size 

func (m *PerpetualMarketCreateEventV1) Size() (n int)

func (*PerpetualMarketCreateEventV1) String 

func (m *PerpetualMarketCreateEventV1) String() string

func (*PerpetualMarketCreateEventV1) Unmarshal 

func (m *PerpetualMarketCreateEventV1) Unmarshal(dAtA []byte) error

func (*PerpetualMarketCreateEventV1) XXX_DiscardUnknown 

func (m *PerpetualMarketCreateEventV1) XXX_DiscardUnknown()

func (*PerpetualMarketCreateEventV1) XXX_Marshal 

func (m *PerpetualMarketCreateEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PerpetualMarketCreateEventV1) XXX_Merge 

func (m *PerpetualMarketCreateEventV1) XXX_Merge(src proto.Message)

func (*PerpetualMarketCreateEventV1) XXX_Size 

func (m *PerpetualMarketCreateEventV1) XXX_Size() int

func (*PerpetualMarketCreateEventV1) XXX_Unmarshal 

func (m *PerpetualMarketCreateEventV1) XXX_Unmarshal(b []byte) error

type SourceOfFunds 

type SourceOfFunds struct {
	//	one of below
	//
	// - a subaccount ID
	// - a wallet address
	//
	// Types that are valid to be assigned to Source:
	//
	//	*SourceOfFunds_SubaccountId
	//	*SourceOfFunds_Address
	Source isSourceOfFunds_Source `protobuf_oneof:"source"`
}

SourceOfFunds is the source of funds in a transfer event.

func (*SourceOfFunds) Descriptor 

func (*SourceOfFunds) Descriptor() ([]byte, []int)

func (*SourceOfFunds) GetAddress 

func (m *SourceOfFunds) GetAddress() string

func (*SourceOfFunds) GetSource 

func (m *SourceOfFunds) GetSource() isSourceOfFunds_Source

func (*SourceOfFunds) GetSubaccountId 

func (m *SourceOfFunds) GetSubaccountId() *v1.IndexerSubaccountId

func (*SourceOfFunds) Marshal 

func (m *SourceOfFunds) Marshal() (dAtA []byte, err error)

func (*SourceOfFunds) MarshalTo 

func (m *SourceOfFunds) MarshalTo(dAtA []byte) (int, error)

func (*SourceOfFunds) MarshalToSizedBuffer 

func (m *SourceOfFunds) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SourceOfFunds) ProtoMessage 

func (*SourceOfFunds) ProtoMessage()

func (*SourceOfFunds) Reset 

func (m *SourceOfFunds) Reset()

func (*SourceOfFunds) Size 

func (m *SourceOfFunds) Size() (n int)

func (*SourceOfFunds) String 

func (m *SourceOfFunds) String() string

func (*SourceOfFunds) Unmarshal 

func (m *SourceOfFunds) Unmarshal(dAtA []byte) error

func (*SourceOfFunds) XXX_DiscardUnknown 

func (m *SourceOfFunds) XXX_DiscardUnknown()

func (*SourceOfFunds) XXX_Marshal 

func (m *SourceOfFunds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SourceOfFunds) XXX_Merge 

func (m *SourceOfFunds) XXX_Merge(src proto.Message)

func (*SourceOfFunds) XXX_OneofWrappers 

func (*SourceOfFunds) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SourceOfFunds) XXX_Size 

func (m *SourceOfFunds) XXX_Size() int

func (*SourceOfFunds) XXX_Unmarshal 

func (m *SourceOfFunds) XXX_Unmarshal(b []byte) error

type SourceOfFunds_Address 

type SourceOfFunds_Address struct {
	Address string `protobuf:"bytes,2,opt,name=address,proto3,oneof" json:"address,omitempty"`
}

func (*SourceOfFunds_Address) MarshalTo 

func (m *SourceOfFunds_Address) MarshalTo(dAtA []byte) (int, error)

func (*SourceOfFunds_Address) MarshalToSizedBuffer 

func (m *SourceOfFunds_Address) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SourceOfFunds_Address) Size 

func (m *SourceOfFunds_Address) Size() (n int)

type SourceOfFunds_SubaccountId 

type SourceOfFunds_SubaccountId struct {
	SubaccountId *v1.IndexerSubaccountId `protobuf:"bytes,1,opt,name=subaccount_id,json=subaccountId,proto3,oneof" json:"subaccount_id,omitempty"`
}

func (*SourceOfFunds_SubaccountId) MarshalTo 

func (m *SourceOfFunds_SubaccountId) MarshalTo(dAtA []byte) (int, error)

func (*SourceOfFunds_SubaccountId) MarshalToSizedBuffer 

func (m *SourceOfFunds_SubaccountId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SourceOfFunds_SubaccountId) Size 

func (m *SourceOfFunds_SubaccountId) Size() (n int)

type StatefulOrderEventV1 

type StatefulOrderEventV1 struct {
	// The type of event that this StatefulOrderEvent contains.
	//
	// Types that are valid to be assigned to Event:
	//
	//	*StatefulOrderEventV1_OrderPlace
	//	*StatefulOrderEventV1_OrderRemoval
	//	*StatefulOrderEventV1_ConditionalOrderPlacement
	//	*StatefulOrderEventV1_ConditionalOrderTriggered
	//	*StatefulOrderEventV1_LongTermOrderPlacement
	Event isStatefulOrderEventV1_Event `protobuf_oneof:"event"`
}

StatefulOrderEvent message contains information about a change to a stateful order. Currently, this is either the placement of a long-term order, the placement or triggering of a conditional order, or the removal of a stateful order.

func NewConditionalOrderPlacementEvent 

func NewConditionalOrderPlacementEvent(
	order clobtypes.Order,
) *StatefulOrderEventV1

func NewConditionalOrderTriggeredEvent 

func NewConditionalOrderTriggeredEvent(
	orderId clobtypes.OrderId,
) *StatefulOrderEventV1

func NewLongTermOrderPlacementEvent 

func NewLongTermOrderPlacementEvent(
	order clobtypes.Order,
) *StatefulOrderEventV1

func NewStatefulOrderRemovalEvent 

func NewStatefulOrderRemovalEvent(
	removedOrderId clobtypes.OrderId,
	reason shared.OrderRemovalReason,
) *StatefulOrderEventV1

func (*StatefulOrderEventV1) Descriptor 

func (*StatefulOrderEventV1) Descriptor() ([]byte, []int)

func (*StatefulOrderEventV1) GetConditionalOrderPlacement 

func (m *StatefulOrderEventV1) GetConditionalOrderPlacement() *StatefulOrderEventV1_ConditionalOrderPlacementV1

func (*StatefulOrderEventV1) GetConditionalOrderTriggered 

func (m *StatefulOrderEventV1) GetConditionalOrderTriggered() *StatefulOrderEventV1_ConditionalOrderTriggeredV1

func (*StatefulOrderEventV1) GetEvent 

func (m *StatefulOrderEventV1) GetEvent() isStatefulOrderEventV1_Event

func (*StatefulOrderEventV1) GetLongTermOrderPlacement 

func (m *StatefulOrderEventV1) GetLongTermOrderPlacement() *StatefulOrderEventV1_LongTermOrderPlacementV1

func (*StatefulOrderEventV1) GetOrderPlace 

func (m *StatefulOrderEventV1) GetOrderPlace() *StatefulOrderEventV1_StatefulOrderPlacementV1

func (*StatefulOrderEventV1) GetOrderRemoval 

func (m *StatefulOrderEventV1) GetOrderRemoval() *StatefulOrderEventV1_StatefulOrderRemovalV1

func (*StatefulOrderEventV1) Marshal 

func (m *StatefulOrderEventV1) Marshal() (dAtA []byte, err error)

func (*StatefulOrderEventV1) MarshalTo 

func (m *StatefulOrderEventV1) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1) ProtoMessage 

func (*StatefulOrderEventV1) ProtoMessage()

func (*StatefulOrderEventV1) Reset 

func (m *StatefulOrderEventV1) Reset()

func (*StatefulOrderEventV1) Size 

func (m *StatefulOrderEventV1) Size() (n int)

func (*StatefulOrderEventV1) String 

func (m *StatefulOrderEventV1) String() string

func (*StatefulOrderEventV1) Unmarshal 

func (m *StatefulOrderEventV1) Unmarshal(dAtA []byte) error

func (*StatefulOrderEventV1) XXX_DiscardUnknown 

func (m *StatefulOrderEventV1) XXX_DiscardUnknown()

func (*StatefulOrderEventV1) XXX_Marshal 

func (m *StatefulOrderEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatefulOrderEventV1) XXX_Merge 

func (m *StatefulOrderEventV1) XXX_Merge(src proto.Message)

func (*StatefulOrderEventV1) XXX_OneofWrappers 

func (*StatefulOrderEventV1) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StatefulOrderEventV1) XXX_Size 

func (m *StatefulOrderEventV1) XXX_Size() int

func (*StatefulOrderEventV1) XXX_Unmarshal 

func (m *StatefulOrderEventV1) XXX_Unmarshal(b []byte) error

type StatefulOrderEventV1_ConditionalOrderPlacement 

type StatefulOrderEventV1_ConditionalOrderPlacement struct {
	ConditionalOrderPlacement *StatefulOrderEventV1_ConditionalOrderPlacementV1 `` /* 144-byte string literal not displayed */
}

func (*StatefulOrderEventV1_ConditionalOrderPlacement) MarshalTo 

func (m *StatefulOrderEventV1_ConditionalOrderPlacement) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderPlacement) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_ConditionalOrderPlacement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderPlacement) Size 

func (m *StatefulOrderEventV1_ConditionalOrderPlacement) Size() (n int)

type StatefulOrderEventV1_ConditionalOrderPlacementV1 

type StatefulOrderEventV1_ConditionalOrderPlacementV1 struct {
	Order *v1.IndexerOrder `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
}

A conditional order placement contains an order. The order is newly-placed and untriggered when this event is emitted.

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Descriptor 

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Descriptor() ([]byte, []int)

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) GetOrder 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) GetOrder() *v1.IndexerOrder

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Marshal 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) Marshal() (dAtA []byte, err error)

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) MarshalTo 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) ProtoMessage 

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) ProtoMessage()

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Reset 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) Reset()

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Size 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) Size() (n int)

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) String 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) String() string

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Unmarshal 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) Unmarshal(dAtA []byte) error

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_DiscardUnknown 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_DiscardUnknown()

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Marshal 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Merge 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Merge(src proto.Message)

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Size 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Size() int

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Unmarshal 

func (m *StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Unmarshal(b []byte) error

type StatefulOrderEventV1_ConditionalOrderTriggered 

type StatefulOrderEventV1_ConditionalOrderTriggered struct {
	ConditionalOrderTriggered *StatefulOrderEventV1_ConditionalOrderTriggeredV1 `` /* 144-byte string literal not displayed */
}

func (*StatefulOrderEventV1_ConditionalOrderTriggered) MarshalTo 

func (m *StatefulOrderEventV1_ConditionalOrderTriggered) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderTriggered) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_ConditionalOrderTriggered) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderTriggered) Size 

func (m *StatefulOrderEventV1_ConditionalOrderTriggered) Size() (n int)

type StatefulOrderEventV1_ConditionalOrderTriggeredV1 

type StatefulOrderEventV1_ConditionalOrderTriggeredV1 struct {
	TriggeredOrderId *v1.IndexerOrderId `protobuf:"bytes,1,opt,name=triggered_order_id,json=triggeredOrderId,proto3" json:"triggered_order_id,omitempty"`
}

A conditional order trigger event contains an order id and is emitted when an order is triggered.

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Descriptor 

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Descriptor() ([]byte, []int)

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) GetTriggeredOrderId 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) GetTriggeredOrderId() *v1.IndexerOrderId

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Marshal 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) Marshal() (dAtA []byte, err error)

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) MarshalTo 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) ProtoMessage 

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) ProtoMessage()

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Reset 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) Reset()

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Size 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) Size() (n int)

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) String 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) String() string

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Unmarshal 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) Unmarshal(dAtA []byte) error

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_DiscardUnknown 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_DiscardUnknown()

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Marshal 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Merge 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Merge(src proto.Message)

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Size 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Size() int

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Unmarshal 

func (m *StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Unmarshal(b []byte) error

type StatefulOrderEventV1_LongTermOrderPlacement 

type StatefulOrderEventV1_LongTermOrderPlacement struct {
	LongTermOrderPlacement *StatefulOrderEventV1_LongTermOrderPlacementV1 `` /* 137-byte string literal not displayed */
}

func (*StatefulOrderEventV1_LongTermOrderPlacement) MarshalTo 

func (m *StatefulOrderEventV1_LongTermOrderPlacement) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_LongTermOrderPlacement) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_LongTermOrderPlacement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_LongTermOrderPlacement) Size 

func (m *StatefulOrderEventV1_LongTermOrderPlacement) Size() (n int)

type StatefulOrderEventV1_LongTermOrderPlacementV1 

type StatefulOrderEventV1_LongTermOrderPlacementV1 struct {
	Order *v1.IndexerOrder `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
}

A long term order placement contains an order.

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Descriptor 

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Descriptor() ([]byte, []int)

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) GetOrder 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) GetOrder() *v1.IndexerOrder

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Marshal 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) Marshal() (dAtA []byte, err error)

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) MarshalTo 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) ProtoMessage 

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) ProtoMessage()

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Reset 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) Reset()

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Size 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) Size() (n int)

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) String 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) String() string

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Unmarshal 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) Unmarshal(dAtA []byte) error

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_DiscardUnknown 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_DiscardUnknown()

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Marshal 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Merge 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Merge(src proto.Message)

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Size 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Size() int

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Unmarshal 

func (m *StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Unmarshal(b []byte) error

type StatefulOrderEventV1_OrderPlace 

type StatefulOrderEventV1_OrderPlace struct {
	OrderPlace *StatefulOrderEventV1_StatefulOrderPlacementV1 `protobuf:"bytes,1,opt,name=order_place,json=orderPlace,proto3,oneof" json:"order_place,omitempty"`
}

func (*StatefulOrderEventV1_OrderPlace) MarshalTo 

func (m *StatefulOrderEventV1_OrderPlace) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_OrderPlace) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_OrderPlace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_OrderPlace) Size 

func (m *StatefulOrderEventV1_OrderPlace) Size() (n int)

type StatefulOrderEventV1_OrderRemoval 

type StatefulOrderEventV1_OrderRemoval struct {
	OrderRemoval *StatefulOrderEventV1_StatefulOrderRemovalV1 `protobuf:"bytes,4,opt,name=order_removal,json=orderRemoval,proto3,oneof" json:"order_removal,omitempty"`
}

func (*StatefulOrderEventV1_OrderRemoval) MarshalTo 

func (m *StatefulOrderEventV1_OrderRemoval) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_OrderRemoval) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_OrderRemoval) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_OrderRemoval) Size 

func (m *StatefulOrderEventV1_OrderRemoval) Size() (n int)

type StatefulOrderEventV1_StatefulOrderPlacementV1 

type StatefulOrderEventV1_StatefulOrderPlacementV1 struct {
	Order *v1.IndexerOrder `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
}

A stateful order placement contains an order.

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Descriptor 

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Descriptor() ([]byte, []int)

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) GetOrder 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) GetOrder() *v1.IndexerOrder

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Marshal 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) Marshal() (dAtA []byte, err error)

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) MarshalTo 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) ProtoMessage 

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) ProtoMessage()

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Reset 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) Reset()

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Size 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) Size() (n int)

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) String 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) String() string

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Unmarshal 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) Unmarshal(dAtA []byte) error

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_DiscardUnknown 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_DiscardUnknown()

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Marshal 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Merge 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Merge(src proto.Message)

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Size 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Size() int

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Unmarshal 

func (m *StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Unmarshal(b []byte) error

type StatefulOrderEventV1_StatefulOrderRemovalV1 

type StatefulOrderEventV1_StatefulOrderRemovalV1 struct {
	RemovedOrderId *v1.IndexerOrderId        `protobuf:"bytes,1,opt,name=removed_order_id,json=removedOrderId,proto3" json:"removed_order_id,omitempty"`
	Reason         shared.OrderRemovalReason `protobuf:"varint,2,opt,name=reason,proto3,enum=furyaprotocol.indexer.shared.OrderRemovalReason" json:"reason,omitempty"`
}

A stateful order removal contains the id of an order that was already placed and is now removed and the reason for the removal.

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Descriptor 

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Descriptor() ([]byte, []int)

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) GetReason 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) GetReason() shared.OrderRemovalReason

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) GetRemovedOrderId 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) GetRemovedOrderId() *v1.IndexerOrderId

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Marshal 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) Marshal() (dAtA []byte, err error)

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) MarshalTo 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) MarshalTo(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) MarshalToSizedBuffer 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) ProtoMessage 

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) ProtoMessage()

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Reset 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) Reset()

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Size 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) Size() (n int)

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) String 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) String() string

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Unmarshal 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) Unmarshal(dAtA []byte) error

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_DiscardUnknown 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_DiscardUnknown()

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Marshal 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Merge 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Merge(src proto.Message)

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Size 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Size() int

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Unmarshal 

func (m *StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Unmarshal(b []byte) error

type SubaccountUpdateEventV1 

type SubaccountUpdateEventV1 struct {
	SubaccountId *v1.IndexerSubaccountId `protobuf:"bytes,1,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// updated_perpetual_positions will each be for unique perpetuals.
	UpdatedPerpetualPositions []*v1.IndexerPerpetualPosition `` /* 138-byte string literal not displayed */
	// updated_asset_positions will each be for unique assets.
	UpdatedAssetPositions []*v1.IndexerAssetPosition `` /* 126-byte string literal not displayed */
}

SubaccountUpdateEvent message contains information about an update to a subaccount in the dYdX chain. This includes the list of updated perpetual and asset positions for the subaccount. Note: This event message will contain all the updates to a subaccount at the end of a block which is why multiple asset/perpetual position updates may exist.

func NewSubaccountUpdateEvent 

func NewSubaccountUpdateEvent(
	subaccountId *satypes.SubaccountId,
	updatedPerpetualPositions []*satypes.PerpetualPosition,
	updatedAssetPositions []*satypes.AssetPosition,
	fundingPayments map[uint32]dtypes.SerializableInt,
) *SubaccountUpdateEventV1

NewSubaccountUpdateEvent creates a SubaccountUpdateEvent representing a subaccount update containing its updated perpetual/asset positions.

func (*SubaccountUpdateEventV1) Descriptor 

func (*SubaccountUpdateEventV1) Descriptor() ([]byte, []int)

func (*SubaccountUpdateEventV1) GetSubaccountId 

func (m *SubaccountUpdateEventV1) GetSubaccountId() *v1.IndexerSubaccountId

func (*SubaccountUpdateEventV1) GetUpdatedAssetPositions 

func (m *SubaccountUpdateEventV1) GetUpdatedAssetPositions() []*v1.IndexerAssetPosition

func (*SubaccountUpdateEventV1) GetUpdatedPerpetualPositions 

func (m *SubaccountUpdateEventV1) GetUpdatedPerpetualPositions() []*v1.IndexerPerpetualPosition

func (*SubaccountUpdateEventV1) Marshal 

func (m *SubaccountUpdateEventV1) Marshal() (dAtA []byte, err error)

func (*SubaccountUpdateEventV1) MarshalTo 

func (m *SubaccountUpdateEventV1) MarshalTo(dAtA []byte) (int, error)

func (*SubaccountUpdateEventV1) MarshalToSizedBuffer 

func (m *SubaccountUpdateEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubaccountUpdateEventV1) ProtoMessage 

func (*SubaccountUpdateEventV1) ProtoMessage()

func (*SubaccountUpdateEventV1) Reset 

func (m *SubaccountUpdateEventV1) Reset()

func (*SubaccountUpdateEventV1) Size 

func (m *SubaccountUpdateEventV1) Size() (n int)

func (*SubaccountUpdateEventV1) String 

func (m *SubaccountUpdateEventV1) String() string

func (*SubaccountUpdateEventV1) Unmarshal 

func (m *SubaccountUpdateEventV1) Unmarshal(dAtA []byte) error

func (*SubaccountUpdateEventV1) XXX_DiscardUnknown 

func (m *SubaccountUpdateEventV1) XXX_DiscardUnknown()

func (*SubaccountUpdateEventV1) XXX_Marshal 

func (m *SubaccountUpdateEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubaccountUpdateEventV1) XXX_Merge 

func (m *SubaccountUpdateEventV1) XXX_Merge(src proto.Message)

func (*SubaccountUpdateEventV1) XXX_Size 

func (m *SubaccountUpdateEventV1) XXX_Size() int

func (*SubaccountUpdateEventV1) XXX_Unmarshal 

func (m *SubaccountUpdateEventV1) XXX_Unmarshal(b []byte) error

type TradingRewardsEventV1 

type TradingRewardsEventV1 struct {
	// The list of all trading rewards in the block.
	TradingRewards []*AddressTradingReward `protobuf:"bytes,1,rep,name=trading_rewards,json=tradingRewards,proto3" json:"trading_rewards,omitempty"`
}

TradingRewardsEventV1 is communicates all trading rewards for all accounts that receive trade rewards in the block.

func (*TradingRewardsEventV1) Descriptor 

func (*TradingRewardsEventV1) Descriptor() ([]byte, []int)

func (*TradingRewardsEventV1) GetTradingRewards 

func (m *TradingRewardsEventV1) GetTradingRewards() []*AddressTradingReward

func (*TradingRewardsEventV1) Marshal 

func (m *TradingRewardsEventV1) Marshal() (dAtA []byte, err error)

func (*TradingRewardsEventV1) MarshalTo 

func (m *TradingRewardsEventV1) MarshalTo(dAtA []byte) (int, error)

func (*TradingRewardsEventV1) MarshalToSizedBuffer 

func (m *TradingRewardsEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TradingRewardsEventV1) ProtoMessage 

func (*TradingRewardsEventV1) ProtoMessage()

func (*TradingRewardsEventV1) Reset 

func (m *TradingRewardsEventV1) Reset()

func (*TradingRewardsEventV1) Size 

func (m *TradingRewardsEventV1) Size() (n int)

func (*TradingRewardsEventV1) String 

func (m *TradingRewardsEventV1) String() string

func (*TradingRewardsEventV1) Unmarshal 

func (m *TradingRewardsEventV1) Unmarshal(dAtA []byte) error

func (*TradingRewardsEventV1) XXX_DiscardUnknown 

func (m *TradingRewardsEventV1) XXX_DiscardUnknown()

func (*TradingRewardsEventV1) XXX_Marshal 

func (m *TradingRewardsEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TradingRewardsEventV1) XXX_Merge 

func (m *TradingRewardsEventV1) XXX_Merge(src proto.Message)

func (*TradingRewardsEventV1) XXX_Size 

func (m *TradingRewardsEventV1) XXX_Size() int

func (*TradingRewardsEventV1) XXX_Unmarshal 

func (m *TradingRewardsEventV1) XXX_Unmarshal(b []byte) error

type TransferEventV1 

type TransferEventV1 struct {
	SenderSubaccountId    *v1.IndexerSubaccountId `protobuf:"bytes,1,opt,name=sender_subaccount_id,json=senderSubaccountId,proto3" json:"sender_subaccount_id,omitempty"`
	RecipientSubaccountId *v1.IndexerSubaccountId `` /* 126-byte string literal not displayed */
	// Id of the asset transfered.
	AssetId uint32 `protobuf:"varint,3,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	// The amount of asset in quantums to transfer.
	Amount uint64 `protobuf:"varint,4,opt,name=amount,proto3" json:"amount,omitempty"`
	// The sender is one of below
	// - a subaccount ID (in transfer and withdraw events).
	// - a wallet address (in deposit events).
	Sender *SourceOfFunds `protobuf:"bytes,5,opt,name=sender,proto3" json:"sender,omitempty"`
	// The recipient is one of below
	// - a subaccount ID (in transfer and deposit events).
	// - a wallet address (in withdraw events).
	Recipient *SourceOfFunds `protobuf:"bytes,6,opt,name=recipient,proto3" json:"recipient,omitempty"`
}

TransferEvent message contains all the information about a transfer, deposit-to-subaccount, or withdraw-from-subaccount on the dYdX chain. When a subaccount is involved, a SubaccountUpdateEvent message will be produced with the updated asset positions.

func NewDepositEvent 

func NewDepositEvent(
	senderAddress string,
	recipientSubaccountId satypes.SubaccountId,
	assetId uint32,
	amount satypes.BaseQuantums,
) *TransferEventV1

NewDepositEvent creates a DepositEvent representing a deposit of an asset from a sender wallet address to a recipient subaccount.

func NewTransferEvent 

func NewTransferEvent(
	senderSubaccountId satypes.SubaccountId,
	recipientSubaccountId satypes.SubaccountId,
	assetId uint32,
	amount satypes.BaseQuantums,
) *TransferEventV1

NewTransferEvent creates a TransferEvent representing a transfer of an asset between a sender and recipient subaccount.

func NewWithdrawEvent 

func NewWithdrawEvent(
	senderSubaccountId satypes.SubaccountId,
	recipientAddress string,
	assetId uint32,
	amount satypes.BaseQuantums,
) *TransferEventV1

NewWithdrawEvent creates a WithdrawEvent representing a withdrawal of an asset from a sender subaccount to a recipient wallet address.

func (*TransferEventV1) Descriptor 

func (*TransferEventV1) Descriptor() ([]byte, []int)

func (*TransferEventV1) GetAmount 

func (m *TransferEventV1) GetAmount() uint64

func (*TransferEventV1) GetAssetId 

func (m *TransferEventV1) GetAssetId() uint32

func (*TransferEventV1) GetRecipient 

func (m *TransferEventV1) GetRecipient() *SourceOfFunds

func (*TransferEventV1) GetRecipientSubaccountId 

func (m *TransferEventV1) GetRecipientSubaccountId() *v1.IndexerSubaccountId

func (*TransferEventV1) GetSender 

func (m *TransferEventV1) GetSender() *SourceOfFunds

func (*TransferEventV1) GetSenderSubaccountId 

func (m *TransferEventV1) GetSenderSubaccountId() *v1.IndexerSubaccountId

func (*TransferEventV1) Marshal 

func (m *TransferEventV1) Marshal() (dAtA []byte, err error)

func (*TransferEventV1) MarshalTo 

func (m *TransferEventV1) MarshalTo(dAtA []byte) (int, error)

func (*TransferEventV1) MarshalToSizedBuffer 

func (m *TransferEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransferEventV1) ProtoMessage 

func (*TransferEventV1) ProtoMessage()

func (*TransferEventV1) Reset 

func (m *TransferEventV1) Reset()

func (*TransferEventV1) Size 

func (m *TransferEventV1) Size() (n int)

func (*TransferEventV1) String 

func (m *TransferEventV1) String() string

func (*TransferEventV1) Unmarshal 

func (m *TransferEventV1) Unmarshal(dAtA []byte) error

func (*TransferEventV1) XXX_DiscardUnknown 

func (m *TransferEventV1) XXX_DiscardUnknown()

func (*TransferEventV1) XXX_Marshal 

func (m *TransferEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransferEventV1) XXX_Merge 

func (m *TransferEventV1) XXX_Merge(src proto.Message)

func (*TransferEventV1) XXX_Size 

func (m *TransferEventV1) XXX_Size() int

func (*TransferEventV1) XXX_Unmarshal 

func (m *TransferEventV1) XXX_Unmarshal(b []byte) error

type UpdateClobPairEventV1 

type UpdateClobPairEventV1 struct {
	// Unique clob pair Id associated with this perpetual market
	// Defined in clob.clob_pair
	ClobPairId uint32 `protobuf:"varint,1,opt,name=clob_pair_id,json=clobPairId,proto3" json:"clob_pair_id,omitempty"`
	// Status of the CLOB
	Status v1.ClobPairStatus `protobuf:"varint,2,opt,name=status,proto3,enum=furyaprotocol.indexer.protocol.v1.ClobPairStatus" json:"status,omitempty"`
	// `10^Exponent` gives the number of QuoteQuantums traded per BaseQuantum
	// per Subtick.
	// Defined in clob.clob_pair
	QuantumConversionExponent int32 `` /* 141-byte string literal not displayed */
	// Defines the tick size of the orderbook by defining how many subticks
	// are in one tick. That is, the subticks of any valid order must be a
	// multiple of this value. Generally this value should start `>= 100`to
	// allow room for decreasing it.
	// Defined in clob.clob_pair
	SubticksPerTick uint32 `protobuf:"varint,4,opt,name=subticks_per_tick,json=subticksPerTick,proto3" json:"subticks_per_tick,omitempty"`
	// Minimum increment in the size of orders on the CLOB, in base quantums.
	// Defined in clob.clob_pair
	StepBaseQuantums uint64 `protobuf:"varint,5,opt,name=step_base_quantums,json=stepBaseQuantums,proto3" json:"step_base_quantums,omitempty"`
}

UpdateClobPairEventV1 message contains all the information about an update to a clob pair on the dYdX chain.

func NewUpdateClobPairEvent 

func NewUpdateClobPairEvent(
	clobPairId types.ClobPairId,
	status types.ClobPair_Status,
	quantumConversionExponent int32,
	subticksPerTick types.SubticksPerTick,
	stepBaseQuantums satypes.BaseQuantums,
) *UpdateClobPairEventV1

NewUpdateClobPairEvent creates a UpdateClobPairEventV1 representing an update of a clob pair.

func (*UpdateClobPairEventV1) Descriptor 

func (*UpdateClobPairEventV1) Descriptor() ([]byte, []int)

func (*UpdateClobPairEventV1) GetClobPairId 

func (m *UpdateClobPairEventV1) GetClobPairId() uint32

func (*UpdateClobPairEventV1) GetQuantumConversionExponent 

func (m *UpdateClobPairEventV1) GetQuantumConversionExponent() int32

func (*UpdateClobPairEventV1) GetStatus 

func (m *UpdateClobPairEventV1) GetStatus() v1.ClobPairStatus

func (*UpdateClobPairEventV1) GetStepBaseQuantums 

func (m *UpdateClobPairEventV1) GetStepBaseQuantums() uint64

func (*UpdateClobPairEventV1) GetSubticksPerTick 

func (m *UpdateClobPairEventV1) GetSubticksPerTick() uint32

func (*UpdateClobPairEventV1) Marshal 

func (m *UpdateClobPairEventV1) Marshal() (dAtA []byte, err error)

func (*UpdateClobPairEventV1) MarshalTo 

func (m *UpdateClobPairEventV1) MarshalTo(dAtA []byte) (int, error)

func (*UpdateClobPairEventV1) MarshalToSizedBuffer 

func (m *UpdateClobPairEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateClobPairEventV1) ProtoMessage 

func (*UpdateClobPairEventV1) ProtoMessage()

func (*UpdateClobPairEventV1) Reset 

func (m *UpdateClobPairEventV1) Reset()

func (*UpdateClobPairEventV1) Size 

func (m *UpdateClobPairEventV1) Size() (n int)

func (*UpdateClobPairEventV1) String 

func (m *UpdateClobPairEventV1) String() string

func (*UpdateClobPairEventV1) Unmarshal 

func (m *UpdateClobPairEventV1) Unmarshal(dAtA []byte) error

func (*UpdateClobPairEventV1) XXX_DiscardUnknown 

func (m *UpdateClobPairEventV1) XXX_DiscardUnknown()

func (*UpdateClobPairEventV1) XXX_Marshal 

func (m *UpdateClobPairEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateClobPairEventV1) XXX_Merge 

func (m *UpdateClobPairEventV1) XXX_Merge(src proto.Message)

func (*UpdateClobPairEventV1) XXX_Size 

func (m *UpdateClobPairEventV1) XXX_Size() int

func (*UpdateClobPairEventV1) XXX_Unmarshal 

func (m *UpdateClobPairEventV1) XXX_Unmarshal(b []byte) error

type UpdatePerpetualEventV1 

type UpdatePerpetualEventV1 struct {
	// Unique Perpetual id.
	// Defined in perpetuals.perpetual
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The name of the `Perpetual` (e.g. `BTC-USD`).
	// Defined in perpetuals.perpetual
	Ticker string `protobuf:"bytes,2,opt,name=ticker,proto3" json:"ticker,omitempty"`
	// Unique id of market param associated with this perpetual market.
	// Defined in perpetuals.perpetual
	MarketId uint32 `protobuf:"varint,3,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The exponent for converting an atomic amount (`size = 1`)
	// to a full coin. For example, if `AtomicResolution = -8`
	// then a `PerpetualPosition` with `size = 1e8` is equivalent to
	// a position size of one full coin.
	// Defined in perpetuals.perpetual
	AtomicResolution int32 `protobuf:"zigzag32,4,opt,name=atomic_resolution,json=atomicResolution,proto3" json:"atomic_resolution,omitempty"`
	// The liquidity_tier that this perpetual is associated with.
	// Defined in perpetuals.perpetual
	LiquidityTier uint32 `protobuf:"varint,5,opt,name=liquidity_tier,json=liquidityTier,proto3" json:"liquidity_tier,omitempty"`
}

UpdatePerpetualEventV1 message contains all the information about an update to a perpetual on the dYdX chain.

func NewUpdatePerpetualEventV1 

func NewUpdatePerpetualEventV1(
	id uint32,
	ticker string,
	marketId uint32,
	atomicResolution int32,
	liquidityTier uint32,
) *UpdatePerpetualEventV1

NewUpdatePerpetualEventV1 creates a UpdatePerpetualEventV1 representing update of a perpetual.

func (*UpdatePerpetualEventV1) Descriptor 

func (*UpdatePerpetualEventV1) Descriptor() ([]byte, []int)

func (*UpdatePerpetualEventV1) GetAtomicResolution 

func (m *UpdatePerpetualEventV1) GetAtomicResolution() int32

func (*UpdatePerpetualEventV1) GetId 

func (m *UpdatePerpetualEventV1) GetId() uint32

func (*UpdatePerpetualEventV1) GetLiquidityTier 

func (m *UpdatePerpetualEventV1) GetLiquidityTier() uint32

func (*UpdatePerpetualEventV1) GetMarketId 

func (m *UpdatePerpetualEventV1) GetMarketId() uint32

func (*UpdatePerpetualEventV1) GetTicker 

func (m *UpdatePerpetualEventV1) GetTicker() string

func (*UpdatePerpetualEventV1) Marshal 

func (m *UpdatePerpetualEventV1) Marshal() (dAtA []byte, err error)

func (*UpdatePerpetualEventV1) MarshalTo 

func (m *UpdatePerpetualEventV1) MarshalTo(dAtA []byte) (int, error)

func (*UpdatePerpetualEventV1) MarshalToSizedBuffer 

func (m *UpdatePerpetualEventV1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdatePerpetualEventV1) ProtoMessage 

func (*UpdatePerpetualEventV1) ProtoMessage()

func (*UpdatePerpetualEventV1) Reset 

func (m *UpdatePerpetualEventV1) Reset()

func (*UpdatePerpetualEventV1) Size 

func (m *UpdatePerpetualEventV1) Size() (n int)

func (*UpdatePerpetualEventV1) String 

func (m *UpdatePerpetualEventV1) String() string

func (*UpdatePerpetualEventV1) Unmarshal 

func (m *UpdatePerpetualEventV1) Unmarshal(dAtA []byte) error

func (*UpdatePerpetualEventV1) XXX_DiscardUnknown 

func (m *UpdatePerpetualEventV1) XXX_DiscardUnknown()

func (*UpdatePerpetualEventV1) XXX_Marshal 

func (m *UpdatePerpetualEventV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePerpetualEventV1) XXX_Merge 

func (m *UpdatePerpetualEventV1) XXX_Merge(src proto.Message)

func (*UpdatePerpetualEventV1) XXX_Size 

func (m *UpdatePerpetualEventV1) XXX_Size() int

func (*UpdatePerpetualEventV1) XXX_Unmarshal 

func (m *UpdatePerpetualEventV1) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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