events

package
v0.3.0-rc0 Latest Latest
Warning

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

Go to latest
Published: Sep 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/dydxprotocol/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"
)
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
)

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,
}

Functions

This section is empty.

Types

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 v4 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 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=dydxprotocol.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_dydxprotocol_v4_chain_protocol_dtypes.SerializableInt `` /* 163-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).
	BasePositionNotional uint64 `protobuf:"varint,5,opt,name=base_position_notional,json=basePositionNotional,proto3" json:"base_position_notional,omitempty"`
}

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

func NewLiquidityTierUpsertEvent

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

NewLiquidityTierUpsertEvent creates a LiquidityTierUpsertEvent representing upsert of a liquidity tier.

func (*LiquidityTierUpsertEventV1) Descriptor

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

func (*LiquidityTierUpsertEventV1) GetBasePositionNotional

func (m *LiquidityTierUpsertEventV1) GetBasePositionNotional() uint64

func (*LiquidityTierUpsertEventV1) GetId

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 V4 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 V4 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 V4 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 V4 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 V4 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=dydxprotocol.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 v4 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 (*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 (*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 (*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 (*StatefulOrderEventV1) GetConditionalOrderTriggered

func (*StatefulOrderEventV1) GetEvent

func (m *StatefulOrderEventV1) GetEvent() isStatefulOrderEventV1_Event

func (*StatefulOrderEventV1) GetLongTermOrderPlacement

func (*StatefulOrderEventV1) GetOrderPlace

func (*StatefulOrderEventV1) GetOrderRemoval

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 (*StatefulOrderEventV1_ConditionalOrderPlacement) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_ConditionalOrderPlacement) Size

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) GetOrder

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Marshal

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

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) MarshalTo

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) ProtoMessage

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Reset

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Size

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) String

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) Unmarshal

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 (*StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Size

func (*StatefulOrderEventV1_ConditionalOrderPlacementV1) XXX_Unmarshal

type StatefulOrderEventV1_ConditionalOrderTriggered

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

func (*StatefulOrderEventV1_ConditionalOrderTriggered) MarshalTo

func (*StatefulOrderEventV1_ConditionalOrderTriggered) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_ConditionalOrderTriggered) Size

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) GetTriggeredOrderId

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Marshal

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

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) MarshalTo

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) ProtoMessage

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Reset

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Size

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) String

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) Unmarshal

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 (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Size

func (*StatefulOrderEventV1_ConditionalOrderTriggeredV1) XXX_Unmarshal

type StatefulOrderEventV1_LongTermOrderPlacement

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

func (*StatefulOrderEventV1_LongTermOrderPlacement) MarshalTo

func (*StatefulOrderEventV1_LongTermOrderPlacement) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_LongTermOrderPlacement) Size

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) GetOrder

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Marshal

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

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) MarshalTo

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) ProtoMessage

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Reset

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Size

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) String

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) Unmarshal

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 (*StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Size

func (*StatefulOrderEventV1_LongTermOrderPlacementV1) XXX_Unmarshal

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) GetOrder

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Marshal

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

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) MarshalTo

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) ProtoMessage

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Reset

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Size

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) String

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) Unmarshal

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 (*StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Size

func (*StatefulOrderEventV1_StatefulOrderPlacementV1) XXX_Unmarshal

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=dydxprotocol.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) GetReason

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) GetRemovedOrderId

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Marshal

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

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) MarshalTo

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) MarshalToSizedBuffer

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

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) ProtoMessage

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Reset

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Size

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) String

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) Unmarshal

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 (*StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Size

func (*StatefulOrderEventV1_StatefulOrderRemovalV1) XXX_Unmarshal

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 V4 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 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 V4 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=dydxprotocol.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 v4 chain.

func NewUpdateClobPairEvent added in v0.2.2

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 v4 chain.

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

Jump to

Keyboard shortcuts

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