events

package
v0.72.11 Latest Latest
Warning

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

Go to latest
Published: Aug 24, 2023 License: MIT Imports: 15 Imported by: 0

README

Event bus

Add a new event

  1. Create a protobuf message to describe your event in the proto folder.
  2. Register your event in BusEventType enum and BusEvent.event message in proto/events.proto.
  3. Generate the code with make proto.
  4. In events/bus.go, create a constant to identify the event and map it to the protobuf enum type BusEventType in variable protoMap and toProto. Give it a name in eventStrings.
  5. In the events folder, create a file my_event.go where the Golang definition of the new event will live:
type MyEvent struct {
	*Base
	o proto.MyEvent
}
  1. Implement the StreamEvent interface on it.
  2. Implement the "FromStream interface on it.
  3. Add the support for this new event into the Service responsible for it.
  4. Update the graphql structures in the data-node in schema.graphql. In particular the BusEventType enum and the Event union

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrUnsupportedEvent = errors.New("unknown payload for event")
	ErrInvalidEventType = errors.New("invalid proto event type")
)

Functions

func GetMarketIDFilter

func GetMarketIDFilter(mID string) func(Event) bool

func GetPartyAndMarketFilter

func GetPartyAndMarketFilter(mID, pID string) func(Event) bool

func GetPartyIDFilter

func GetPartyIDFilter(pID string) func(Event) bool

Types

type Acc

type Acc struct {
	*Base
	// contains filtered or unexported fields
}

func AccountEventFromStream

func AccountEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Acc

func NewAccountEvent

func NewAccountEvent(ctx context.Context, a types.Account) *Acc

func (*Acc) Account

func (a *Acc) Account() ptypes.Account

func (Acc) IsParty

func (a Acc) IsParty(id string) bool

func (Acc) MarketID

func (a Acc) MarketID() string

func (Acc) PartyID

func (a Acc) PartyID() string

func (Acc) Proto

func (a Acc) Proto() ptypes.Account

func (Acc) StreamMessage

func (a Acc) StreamMessage() *eventspb.BusEvent

type Asset

type Asset struct {
	*Base
	// contains filtered or unexported fields
}

func AssetEventFromStream

func AssetEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Asset

func NewAssetEvent

func NewAssetEvent(ctx context.Context, a types.Asset) *Asset

func (*Asset) Asset

func (a *Asset) Asset() proto.Asset

func (Asset) Proto

func (a Asset) Proto() proto.Asset

func (Asset) StreamMessage

func (a Asset) StreamMessage() *eventspb.BusEvent

type Auction

type Auction struct {
	*Base
	// contains filtered or unexported fields
}

func AuctionEventFromStream

func AuctionEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Auction

func NewAuctionEvent

func NewAuctionEvent(ctx context.Context, marketID string, leave bool, start, stop int64, triggers ...types.AuctionTrigger) *Auction

NewAuctionEvent creates a new auction event object.

func (Auction) Auction

func (a Auction) Auction() bool

Auction returns the action performed (either true=leave auction, or false=entering auction).

func (Auction) MarketEvent

func (a Auction) MarketEvent() string

MarketEvent - implement market event interface so we can log this event.

func (Auction) MarketID

func (a Auction) MarketID() string

func (Auction) Proto

func (a Auction) Proto() eventspb.AuctionEvent

Proto wrap event data in a proto message.

func (Auction) StreamMarketMessage

func (a Auction) StreamMarketMessage() *eventspb.BusEvent

StreamMarketMessage - allows for this event to be streamed as just a market event containing just market ID and a string akin to a log message.

func (Auction) StreamMessage

func (a Auction) StreamMessage() *eventspb.BusEvent

StreamMessage returns the BusEvent message for the event stream API.

type Base

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

Base common denominator all event-bus events share.

func (Base) BlockNr

func (b Base) BlockNr() int64

BlockNr returns the current block number.

func (Base) ChainID

func (b Base) ChainID() string

func (Base) CompositeCount added in v0.68.0

func (b Base) CompositeCount() uint64

CompositeCount on the base event will default to 1.

func (Base) Context

func (b Base) Context() context.Context

Context returns context.

func (Base) Sequence

func (b Base) Sequence() uint64

Sequence returns event sequence number.

func (*Base) SetSequenceID

func (b *Base) SetSequenceID(s uint64)

func (Base) TraceID

func (b Base) TraceID() string

TraceID returns the... traceID obviously.

func (Base) TxHash

func (b Base) TxHash() string

func (Base) Type

func (b Base) Type() Type

Type returns the event type.

type BeginBlock added in v0.56.0

type BeginBlock struct {
	*Base
	// contains filtered or unexported fields
}

func BeginBlockEventFromStream added in v0.56.0

func BeginBlockEventFromStream(ctx context.Context, be *eventspb.BusEvent) *BeginBlock

func NewBeginBlock added in v0.56.0

func NewBeginBlock(ctx context.Context, bb eventspb.BeginBlock) *BeginBlock

NewTime returns a new time Update event.

func (BeginBlock) BeginBlock added in v0.56.0

func (b BeginBlock) BeginBlock() eventspb.BeginBlock

Time returns the new blocktime.

func (BeginBlock) Proto added in v0.56.0

func (b BeginBlock) Proto() eventspb.BeginBlock

func (BeginBlock) StreamMessage added in v0.56.0

func (b BeginBlock) StreamMessage() *eventspb.BusEvent

type Checkpoint

type Checkpoint struct {
	*Base
	// contains filtered or unexported fields
}

func CheckpointEventFromStream

func CheckpointEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Checkpoint

func NewCheckpointEvent

func NewCheckpointEvent(ctx context.Context, snap *types.CheckpointState) *Checkpoint

func (Checkpoint) Proto

func (Checkpoint) StreamMessage

func (e Checkpoint) StreamMessage() *eventspb.BusEvent

type DelegationBalance

type DelegationBalance struct {
	*Base
	Party    string
	NodeID   string
	Amount   *num.Uint
	EpochSeq string
}

func DelegationBalanceEventFromStream

func DelegationBalanceEventFromStream(ctx context.Context, be *eventspb.BusEvent) *DelegationBalance

func NewDelegationBalance

func NewDelegationBalance(ctx context.Context, party, nodeID string, amount *num.Uint, epochSeq string) *DelegationBalance

func (DelegationBalance) Proto

func (DelegationBalance) StreamMessage

func (db DelegationBalance) StreamMessage() *eventspb.BusEvent

type Deposit

type Deposit struct {
	*Base
	// contains filtered or unexported fields
}

func DepositEventFromStream

func DepositEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Deposit

func NewDepositEvent

func NewDepositEvent(ctx context.Context, d types.Deposit) *Deposit

func (*Deposit) Deposit

func (d *Deposit) Deposit() proto.Deposit

func (Deposit) IsParty

func (d Deposit) IsParty(id string) bool

func (Deposit) PartyID

func (d Deposit) PartyID() string

func (Deposit) Proto

func (d Deposit) Proto() proto.Deposit

func (Deposit) StreamMessage

func (d Deposit) StreamMessage() *eventspb.BusEvent

type DistressedOrders added in v0.68.0

type DistressedOrders struct {
	*Base
	// contains filtered or unexported fields
}

DistressedOrders contains the market and parties that needed to have their orders closed in order to maintain their open positions on the market.

func DistressedOrdersEventFromStream added in v0.68.0

func DistressedOrdersEventFromStream(ctx context.Context, be *eventspb.BusEvent) *DistressedOrders

func NewDistressedOrdersEvent added in v0.68.0

func NewDistressedOrdersEvent(ctx context.Context, marketID string, parties []string) *DistressedOrders

func (DistressedOrders) IsMarket added in v0.68.0

func (d DistressedOrders) IsMarket(marketID string) bool

func (DistressedOrders) IsParty added in v0.68.0

func (d DistressedOrders) IsParty(partyID string) bool

func (DistressedOrders) MarketID added in v0.68.0

func (d DistressedOrders) MarketID() string

func (DistressedOrders) Parties added in v0.68.0

func (d DistressedOrders) Parties() []string

func (DistressedOrders) Proto added in v0.68.0

func (DistressedOrders) StreamMarketMessage added in v0.68.0

func (d DistressedOrders) StreamMarketMessage() *eventspb.BusEvent

func (DistressedOrders) StreamMessage added in v0.68.0

func (d DistressedOrders) StreamMessage() *eventspb.BusEvent

type DistressedPositions added in v0.71.0

type DistressedPositions struct {
	*Base
	// contains filtered or unexported fields
}

DistressedPositions contains the market and parties that needed to have their orders closed in order to maintain their open positions on the market.

func DistressedPositionsEventFromStream added in v0.71.0

func DistressedPositionsEventFromStream(ctx context.Context, be *eventspb.BusEvent) *DistressedPositions

func NewDistressedPositionsEvent added in v0.71.0

func NewDistressedPositionsEvent(ctx context.Context, marketID string, dParties, sParties []string) *DistressedPositions

func (*DistressedPositions) AddDistressedParties added in v0.71.0

func (d *DistressedPositions) AddDistressedParties(parties ...string)

func (*DistressedPositions) AddSafeParties added in v0.71.0

func (d *DistressedPositions) AddSafeParties(parties ...string)

func (DistressedPositions) DistressedParties added in v0.71.0

func (d DistressedPositions) DistressedParties() []string

func (DistressedPositions) IsDistressedParty added in v0.71.0

func (d DistressedPositions) IsDistressedParty(p string) bool

func (DistressedPositions) IsMarket added in v0.71.0

func (d DistressedPositions) IsMarket(marketID string) bool

func (DistressedPositions) IsParty added in v0.71.0

func (d DistressedPositions) IsParty(partyID string) bool

func (DistressedPositions) IsSafeParty added in v0.71.0

func (d DistressedPositions) IsSafeParty(p string) bool

func (DistressedPositions) MarketID added in v0.71.0

func (d DistressedPositions) MarketID() string

func (DistressedPositions) Proto added in v0.71.0

func (DistressedPositions) SafeParties added in v0.71.0

func (d DistressedPositions) SafeParties() []string

func (DistressedPositions) StreamMarketMessage added in v0.71.0

func (d DistressedPositions) StreamMarketMessage() *eventspb.BusEvent

func (DistressedPositions) StreamMessage added in v0.71.0

func (d DistressedPositions) StreamMessage() *eventspb.BusEvent

type ERC20MultiSigSigner

type ERC20MultiSigSigner struct {
	*Base
	// contains filtered or unexported fields
}

func ERC20MultiSigSignerFromStream

func ERC20MultiSigSignerFromStream(ctx context.Context, be *eventspb.BusEvent) *ERC20MultiSigSigner

func NewERC20MultiSigSigner

func NewERC20MultiSigSigner(ctx context.Context, evt types.SignerEvent) *ERC20MultiSigSigner

func (ERC20MultiSigSigner) ERC20MultiSigSigner

func (s ERC20MultiSigSigner) ERC20MultiSigSigner() eventspb.ERC20MultiSigSignerEvent

func (ERC20MultiSigSigner) Proto

func (ERC20MultiSigSigner) StreamMessage

func (s ERC20MultiSigSigner) StreamMessage() *eventspb.BusEvent

type ERC20MultiSigSignerAdded

type ERC20MultiSigSignerAdded struct {
	*Base
	// contains filtered or unexported fields
}

func ERC20MultiSigSignerAddedFromStream

func ERC20MultiSigSignerAddedFromStream(ctx context.Context, be *eventspb.BusEvent) *ERC20MultiSigSignerAdded

func (ERC20MultiSigSignerAdded) ERC20MultiSigSignerAdded

func (s ERC20MultiSigSignerAdded) ERC20MultiSigSignerAdded() eventspb.ERC20MultiSigSignerAdded

func (ERC20MultiSigSignerAdded) Proto

func (ERC20MultiSigSignerAdded) StreamMessage

func (s ERC20MultiSigSignerAdded) StreamMessage() *eventspb.BusEvent

type ERC20MultiSigSignerRemoved

type ERC20MultiSigSignerRemoved struct {
	*Base
	// contains filtered or unexported fields
}

func ERC20MultiSigSignerRemovedFromStream

func ERC20MultiSigSignerRemovedFromStream(ctx context.Context, be *eventspb.BusEvent) *ERC20MultiSigSignerRemoved

func (ERC20MultiSigSignerRemoved) ERC20MultiSigSignerRemoved

func (s ERC20MultiSigSignerRemoved) ERC20MultiSigSignerRemoved() eventspb.ERC20MultiSigSignerRemoved

func (ERC20MultiSigSignerRemoved) Proto

func (ERC20MultiSigSignerRemoved) StreamMessage

func (s ERC20MultiSigSignerRemoved) StreamMessage() *eventspb.BusEvent

type ERC20MultiSigThresholdSet

type ERC20MultiSigThresholdSet struct {
	*Base
	// contains filtered or unexported fields
}

func ERC20MultiSigThresholdSetFromStream

func ERC20MultiSigThresholdSetFromStream(ctx context.Context, be *eventspb.BusEvent) *ERC20MultiSigThresholdSet

func (ERC20MultiSigThresholdSet) ERC20MultiSigThresholdSet

func (ERC20MultiSigThresholdSet) Proto

func (ERC20MultiSigThresholdSet) StreamMessage

func (s ERC20MultiSigThresholdSet) StreamMessage() *eventspb.BusEvent

type EndBlock added in v0.56.0

type EndBlock struct {
	*Base
	// contains filtered or unexported fields
}

func EndBlockEventFromStream added in v0.56.0

func EndBlockEventFromStream(ctx context.Context, be *eventspb.BusEvent) *EndBlock

func NewEndBlock added in v0.56.0

func NewEndBlock(ctx context.Context, bb eventspb.EndBlock) *EndBlock

NewTime returns a new time Update event.

func (EndBlock) EndBlock added in v0.56.0

func (e EndBlock) EndBlock() eventspb.EndBlock

Time returns the new blocktime.

func (EndBlock) Proto added in v0.56.0

func (e EndBlock) Proto() eventspb.EndBlock

func (EndBlock) StreamMessage added in v0.56.0

func (e EndBlock) StreamMessage() *eventspb.BusEvent

type EpochEvent

type EpochEvent struct {
	*Base
	// contains filtered or unexported fields
}

func EpochEventFromStream

func EpochEventFromStream(ctx context.Context, be *eventspb.BusEvent) *EpochEvent

func NewEpochEvent

func NewEpochEvent(ctx context.Context, e *types.Epoch) *EpochEvent

func (*EpochEvent) Epoch

func (e *EpochEvent) Epoch() *eventspb.EpochEvent

func (EpochEvent) Proto

func (e EpochEvent) Proto() eventspb.EpochEvent

func (EpochEvent) StreamMessage

func (e EpochEvent) StreamMessage() *eventspb.BusEvent

type EthereumKeyRotation

type EthereumKeyRotation struct {
	*Base
	NodeID      string
	OldAddr     string
	NewAddr     string
	BlockHeight uint64
}

EthereumKeyRotation ...

func EthereumKeyRotationEventFromStream

func EthereumKeyRotationEventFromStream(ctx context.Context, be *eventspb.BusEvent) *EthereumKeyRotation

func NewEthereumKeyRotationEvent

func NewEthereumKeyRotationEvent(
	ctx context.Context,
	nodeID string,
	oldAddr string,
	newAddr string,
	blockHeight uint64,
) *EthereumKeyRotation

func (EthereumKeyRotation) EthereumKeyRotation

func (kr EthereumKeyRotation) EthereumKeyRotation() eventspb.EthereumKeyRotation

func (EthereumKeyRotation) Proto

func (EthereumKeyRotation) StreamMessage

func (kr EthereumKeyRotation) StreamMessage() *eventspb.BusEvent

type Event

type Event interface {
	Type() Type
	Context() context.Context
	TraceID() string
	TxHash() string
	ChainID() string
	Sequence() uint64
	SetSequenceID(s uint64)
	BlockNr() int64
	StreamMessage() *eventspb.BusEvent
	// used for events like ExpiredOrders. It is used to increment the sequence ID by the number of records
	// this event will produce to ensure history tables using time + sequence number to function properly.
	CompositeCount() uint64
}

Event - the base event interface type, add sequence ID setter here, because the type assertions in broker seem to be a bottleneck. Change its behaviour so as to only set the sequence ID once.

type ExpiredOrders added in v0.68.0

type ExpiredOrders struct {
	*Base
	// contains filtered or unexported fields
}

ExpiredOrders contains the market and parties that needed to have their orders closed in order to maintain their open positions on the market.

func ExpiredOrdersEventFromStream added in v0.68.0

func ExpiredOrdersEventFromStream(ctx context.Context, be *eventspb.BusEvent) *ExpiredOrders

func NewExpiredOrdersEvent added in v0.68.0

func NewExpiredOrdersEvent(ctx context.Context, marketID string, orders []string) *ExpiredOrders

func (ExpiredOrders) CompositeCount added in v0.68.0

func (d ExpiredOrders) CompositeCount() uint64

func (ExpiredOrders) IsMarket added in v0.68.0

func (d ExpiredOrders) IsMarket(marketID string) bool

func (ExpiredOrders) MarketID added in v0.68.0

func (d ExpiredOrders) MarketID() string

func (ExpiredOrders) OrderIDs added in v0.68.0

func (d ExpiredOrders) OrderIDs() []string

func (ExpiredOrders) Proto added in v0.68.0

func (ExpiredOrders) StreamMarketMessage added in v0.68.0

func (d ExpiredOrders) StreamMarketMessage() *eventspb.BusEvent

func (ExpiredOrders) StreamMessage added in v0.68.0

func (d ExpiredOrders) StreamMessage() *eventspb.BusEvent

type FeesTransfer

type FeesTransfer interface {
	// The list of transfers to be made by the collateral
	Transfers() []*types.Transfer
	// The total amount of fees to be paid (all cumulated)
	// per party if all the  transfers are to be executed
	// map is party id -> total amount of fees to be transferred
	TotalFeesAmountPerParty() map[string]*num.Uint
}

FeeTransfer is a transfer initiated after trade occurs.

type KeyRotation

type KeyRotation struct {
	*Base
	NodeID      string
	OldPubKey   string
	NewPubKey   string
	BlockHeight uint64
}

KeyRotation ...

func KeyRotationEventFromStream

func KeyRotationEventFromStream(ctx context.Context, be *eventspb.BusEvent) *KeyRotation

func NewVegaKeyRotationEvent

func NewVegaKeyRotationEvent(
	ctx context.Context,
	nodeID string,
	oldPubKey string,
	newPubKey string,
	blockHeight uint64,
) *KeyRotation

func (KeyRotation) KeyRotation

func (kr KeyRotation) KeyRotation() eventspb.KeyRotation

func (KeyRotation) Proto

func (kr KeyRotation) Proto() eventspb.KeyRotation

func (KeyRotation) StreamMessage

func (kr KeyRotation) StreamMessage() *eventspb.BusEvent

type LedgerMovements added in v0.56.0

type LedgerMovements struct {
	*Base
	// contains filtered or unexported fields
}

func NewLedgerMovements added in v0.56.0

func NewLedgerMovements(ctx context.Context, ledgerMovements []*types.LedgerMovement) *LedgerMovements

NewLedgerMovements returns an event with transfer responses - this is the replacement of the transfer buffer.

func TransferResponseEventFromStream

func TransferResponseEventFromStream(ctx context.Context, be *eventspb.BusEvent) *LedgerMovements

func (*LedgerMovements) IsParty added in v0.56.0

func (t *LedgerMovements) IsParty(id string) bool

func (*LedgerMovements) LedgerMovements added in v0.56.0

func (t *LedgerMovements) LedgerMovements() []*ptypes.LedgerMovement

LedgerMovements returns the actual event payload.

func (*LedgerMovements) Proto added in v0.56.0

func (*LedgerMovements) StreamMessage added in v0.56.0

func (t *LedgerMovements) StreamMessage() *eventspb.BusEvent

type LiquidityProvision

type LiquidityProvision struct {
	*Base
	// contains filtered or unexported fields
}

func LiquidityProvisionEventFromStream

func LiquidityProvisionEventFromStream(ctx context.Context, be *eventspb.BusEvent) *LiquidityProvision

func (LiquidityProvision) IsParty

func (p LiquidityProvision) IsParty(id string) bool

func (LiquidityProvision) LiquidityProvision

func (p LiquidityProvision) LiquidityProvision() *proto.LiquidityProvision

func (LiquidityProvision) MarketID

func (p LiquidityProvision) MarketID() string

func (LiquidityProvision) PartyID

func (p LiquidityProvision) PartyID() string

func (LiquidityProvision) Proto

func (LiquidityProvision) StreamMessage

func (p LiquidityProvision) StreamMessage() *eventspb.BusEvent

type LossSoc

type LossSoc struct {
	*Base
	// contains filtered or unexported fields
}

func LossSocializationEventFromStream

func LossSocializationEventFromStream(ctx context.Context, be *eventspb.BusEvent) *LossSoc

func NewLossSocializationEvent

func NewLossSocializationEvent(ctx context.Context, partyID, marketID string, amount *num.Uint, neg bool, ts int64) *LossSoc

func (LossSoc) Amount

func (l LossSoc) Amount() *num.Int

func (LossSoc) IsParty

func (l LossSoc) IsParty(id string) bool

func (LossSoc) MarketID

func (l LossSoc) MarketID() string

func (LossSoc) Negative

func (l LossSoc) Negative() bool

func (LossSoc) PartyID

func (l LossSoc) PartyID() string

func (LossSoc) Proto

func (LossSoc) StreamMessage

func (l LossSoc) StreamMessage() *eventspb.BusEvent

func (LossSoc) Timestamp

func (l LossSoc) Timestamp() int64

type LossSocialization

type LossSocialization interface {
	MarketID() string
	PartyID() string
	AmountLost() int64
}

LossSocialization ...

type Margin

type Margin interface {
	MarketPosition
	Asset() string
	MarginBalance() *num.Uint
	GeneralBalance() *num.Uint
	BondBalance() *num.Uint
	MarketID() string
	MarginShortFall() *num.Uint
}

Margin is an event with a change to balances after settling e.g. MTM.

type MarginLevels

type MarginLevels struct {
	*Base
	// contains filtered or unexported fields
}

MarginLevels - the margin levels event.

func MarginLevelsEventFromStream

func MarginLevelsEventFromStream(ctx context.Context, be *eventspb.BusEvent) *MarginLevels

func NewMarginLevelsEvent

func NewMarginLevelsEvent(ctx context.Context, l types.MarginLevels) *MarginLevels

func (MarginLevels) Asset

func (m MarginLevels) Asset() string

func (MarginLevels) IsParty

func (m MarginLevels) IsParty(id string) bool

func (MarginLevels) MarginLevels

func (m MarginLevels) MarginLevels() proto.MarginLevels

func (MarginLevels) MarketID

func (m MarginLevels) MarketID() string

func (MarginLevels) PartyID

func (m MarginLevels) PartyID() string

func (MarginLevels) Proto

func (m MarginLevels) Proto() proto.MarginLevels

func (MarginLevels) StreamMessage

func (m MarginLevels) StreamMessage() *eventspb.BusEvent

type MarketCreated

type MarketCreated struct {
	*Base
	// contains filtered or unexported fields
}

func MarketCreatedEventFromStream

func MarketCreatedEventFromStream(ctx context.Context, be *eventspb.BusEvent) *MarketCreated

func NewMarketCreatedEvent

func NewMarketCreatedEvent(ctx context.Context, m types.Market) *MarketCreated

func (MarketCreated) Market

func (m MarketCreated) Market() proto.Market

func (MarketCreated) MarketEvent

func (m MarketCreated) MarketEvent() string

MarketEvent -> is needs to be logged as a market event.

func (MarketCreated) MarketID

func (m MarketCreated) MarketID() string

func (MarketCreated) MarketProto

func (m MarketCreated) MarketProto() eventspb.MarketEvent

func (MarketCreated) Proto

func (m MarketCreated) Proto() proto.Market

func (MarketCreated) StreamMarketMessage

func (m MarketCreated) StreamMarketMessage() *eventspb.BusEvent

func (MarketCreated) StreamMessage

func (m MarketCreated) StreamMessage() *eventspb.BusEvent

type MarketData

type MarketData struct {
	*Base
	// contains filtered or unexported fields
}

func MarketDataEventFromStream

func MarketDataEventFromStream(ctx context.Context, be *eventspb.BusEvent) *MarketData

func NewMarketDataEvent

func NewMarketDataEvent(ctx context.Context, md types.MarketData) *MarketData

func (MarketData) MarketData

func (m MarketData) MarketData() proto.MarketData

func (MarketData) MarketID

func (m MarketData) MarketID() string

func (MarketData) Proto

func (m MarketData) Proto() proto.MarketData

func (MarketData) StreamMessage

func (m MarketData) StreamMessage() *eventspb.BusEvent

type MarketPosition

type MarketPosition interface {
	Party() string
	Size() int64
	Buy() int64
	Sell() int64
	Price() *num.Uint
	BuySumProduct() *num.Uint
	SellSumProduct() *num.Uint
	VWBuy() *num.Uint
	VWSell() *num.Uint
}

MarketPosition is an event with a change to a position.

type MarketTick

type MarketTick struct {
	*Base
	// contains filtered or unexported fields
}

func MarketTickEventFromStream

func MarketTickEventFromStream(ctx context.Context, be *eventspb.BusEvent) *MarketTick

func NewMarketTick

func NewMarketTick(ctx context.Context, id string, t time.Time) *MarketTick

func (MarketTick) MarketEvent

func (m MarketTick) MarketEvent() string

func (MarketTick) MarketID

func (m MarketTick) MarketID() string

func (MarketTick) MarketProto

func (m MarketTick) MarketProto() eventspb.MarketEvent

func (MarketTick) Proto

func (m MarketTick) Proto() eventspb.MarketTick

func (MarketTick) StreamMarketMessage

func (m MarketTick) StreamMarketMessage() *eventspb.BusEvent

func (MarketTick) StreamMessage

func (m MarketTick) StreamMessage() *eventspb.BusEvent

func (MarketTick) Time

func (m MarketTick) Time() time.Time

type MarketUpdated

type MarketUpdated struct {
	*Base
	// contains filtered or unexported fields
}

func MarketUpdatedEventFromStream

func MarketUpdatedEventFromStream(ctx context.Context, be *eventspb.BusEvent) *MarketUpdated

func NewMarketUpdatedEvent

func NewMarketUpdatedEvent(ctx context.Context, m types.Market) *MarketUpdated

func (MarketUpdated) Market

func (m MarketUpdated) Market() proto.Market

func (MarketUpdated) MarketEvent

func (m MarketUpdated) MarketEvent() string

MarketEvent -> is needs to be logged as a market event.

func (MarketUpdated) MarketID

func (m MarketUpdated) MarketID() string

func (MarketUpdated) MarketProto

func (m MarketUpdated) MarketProto() eventspb.MarketEvent

func (MarketUpdated) Proto

func (m MarketUpdated) Proto() proto.Market

func (MarketUpdated) StreamMarketMessage

func (m MarketUpdated) StreamMarketMessage() *eventspb.BusEvent

func (MarketUpdated) StreamMessage

func (m MarketUpdated) StreamMessage() *eventspb.BusEvent

type NetworkLimits

type NetworkLimits struct {
	*Base
	// contains filtered or unexported fields
}

func NetworkLimitsEventFromStream

func NetworkLimitsEventFromStream(ctx context.Context, be *eventspb.BusEvent) *NetworkLimits

func NewNetworkLimitsEvent

func NewNetworkLimitsEvent(ctx context.Context, limits *proto.NetworkLimits) *NetworkLimits

func (*NetworkLimits) NetworkLimits

func (n *NetworkLimits) NetworkLimits() *proto.NetworkLimits

func (NetworkLimits) Proto

func (n NetworkLimits) Proto() *proto.NetworkLimits

func (NetworkLimits) StreamMessage

func (n NetworkLimits) StreamMessage() *eventspb.BusEvent

type NetworkParameter

type NetworkParameter struct {
	*Base
	// contains filtered or unexported fields
}

func NetworkParameterEventFromStream

func NetworkParameterEventFromStream(ctx context.Context, be *eventspb.BusEvent) *NetworkParameter

func NewNetworkParameterEvent

func NewNetworkParameterEvent(ctx context.Context, key, value string) *NetworkParameter

func (*NetworkParameter) NetworkParameter

func (n *NetworkParameter) NetworkParameter() proto.NetworkParameter

func (NetworkParameter) Proto

func (NetworkParameter) StreamMessage

func (n NetworkParameter) StreamMessage() *eventspb.BusEvent

type NodeSignature

type NodeSignature struct {
	*Base
	// contains filtered or unexported fields
}

NodeSignature ...

func NewNodeSignatureEvent

func NewNodeSignatureEvent(ctx context.Context, e commandspb.NodeSignature) *NodeSignature

func NodeSignatureEventFromStream

func NodeSignatureEventFromStream(ctx context.Context, be *eventspb.BusEvent) *NodeSignature

func (NodeSignature) NodeSignature

func (n NodeSignature) NodeSignature() commandspb.NodeSignature

func (NodeSignature) Proto

func (NodeSignature) StreamMessage

func (n NodeSignature) StreamMessage() *eventspb.BusEvent

type OracleData

type OracleData struct {
	*Base
	// contains filtered or unexported fields
}

func NewOracleDataEvent

func NewOracleDataEvent(ctx context.Context, spec vegapb.OracleData) *OracleData

func OracleDataEventFromStream

func OracleDataEventFromStream(ctx context.Context, be *eventspb.BusEvent) *OracleData

func (*OracleData) OracleData

func (o *OracleData) OracleData() vegapb.OracleData

func (OracleData) Proto

func (o OracleData) Proto() vegapb.OracleData

func (OracleData) StreamMessage

func (o OracleData) StreamMessage() *eventspb.BusEvent

type OracleSpec

type OracleSpec struct {
	*Base
	// contains filtered or unexported fields
}

func NewOracleSpecEvent

func NewOracleSpecEvent(ctx context.Context, spec vegapb.OracleSpec) *OracleSpec

func OracleSpecEventFromStream

func OracleSpecEventFromStream(ctx context.Context, be *eventspb.BusEvent) *OracleSpec

func (*OracleSpec) OracleSpec

func (o *OracleSpec) OracleSpec() vegapb.OracleSpec

func (OracleSpec) Proto

func (o OracleSpec) Proto() vegapb.OracleSpec

func (OracleSpec) StreamMessage

func (o OracleSpec) StreamMessage() *eventspb.BusEvent

type Order

type Order struct {
	*Base
	// contains filtered or unexported fields
}

func NewOrderEvent

func NewOrderEvent(ctx context.Context, o *types.Order) *Order

func OrderEventFromStream

func OrderEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Order

func (Order) IsParty

func (o Order) IsParty(id string) bool

func (Order) MarketID

func (o Order) MarketID() string

func (*Order) Order

func (o *Order) Order() *ptypes.Order

func (Order) PartyID

func (o Order) PartyID() string

func (Order) Proto

func (o Order) Proto() ptypes.Order

func (Order) StreamMessage

func (o Order) StreamMessage() *eventspb.BusEvent

type Party

type Party struct {
	*Base
	// contains filtered or unexported fields
}

func NewPartyEvent

func NewPartyEvent(ctx context.Context, p proto.Party) *Party

func PartyEventFromStream

func PartyEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Party

func (Party) IsParty

func (p Party) IsParty(id string) bool

func (*Party) Party

func (p *Party) Party() proto.Party

func (Party) Proto

func (p Party) Proto() proto.Party

func (Party) StreamMessage

func (p Party) StreamMessage() *eventspb.BusEvent

type PosRes

type PosRes struct {
	*Base
	// contains filtered or unexported fields
}

func NewPositionResolution

func NewPositionResolution(ctx context.Context, distressed, closed int, markPrice *num.Uint, marketID string) *PosRes

func PositionResolutionEventFromStream

func PositionResolutionEventFromStream(ctx context.Context, be *eventspb.BusEvent) *PosRes

func (PosRes) Closed

func (p PosRes) Closed() int

func (PosRes) Distressed

func (p PosRes) Distressed() int

func (PosRes) MarkPrice

func (p PosRes) MarkPrice() *num.Uint

func (PosRes) MarketEvent

func (p PosRes) MarketEvent() string

MarketEvent implement the MarketEvent interface.

func (PosRes) MarketID

func (p PosRes) MarketID() string

func (PosRes) MarketProto

func (p PosRes) MarketProto() eventspb.MarketEvent

func (PosRes) Proto

func (PosRes) StreamMarketMessage

func (p PosRes) StreamMarketMessage() *eventspb.BusEvent

func (PosRes) StreamMessage

func (p PosRes) StreamMessage() *eventspb.BusEvent

type PositionState

type PositionState struct {
	*Base
	// contains filtered or unexported fields
}

func NewPositionStateEvent

func NewPositionStateEvent(ctx context.Context, mp MarketPosition, marketID string) *PositionState

func PositionStateEventFromStream

func PositionStateEventFromStream(ctx context.Context, be *eventspb.BusEvent) *PositionState

func (PositionState) IsParty

func (s PositionState) IsParty(id string) bool

func (PositionState) MarketID

func (s PositionState) MarketID() string

func (PositionState) PartyID

func (s PositionState) PartyID() string

func (PositionState) PotentialBuys

func (s PositionState) PotentialBuys() int64

func (PositionState) PotentialSells

func (s PositionState) PotentialSells() int64

func (PositionState) Proto

func (PositionState) Size

func (s PositionState) Size() int64

func (PositionState) StreamMessage

func (s PositionState) StreamMessage() *eventspb.BusEvent

func (PositionState) VWBuyPrice

func (s PositionState) VWBuyPrice() *num.Uint

func (PositionState) VWSellPrice

func (s PositionState) VWSellPrice() *num.Uint

type Proposal

type Proposal struct {
	*Base
	// contains filtered or unexported fields
}

func NewProposalEvent

func NewProposalEvent(ctx context.Context, p types.Proposal) *Proposal

func ProposalEventFromStream

func ProposalEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Proposal

func (Proposal) IsParty

func (p Proposal) IsParty(id string) bool

func (*Proposal) PartyID

func (p *Proposal) PartyID() string

PartyID - for combined subscriber, communal interface.

func (*Proposal) Proposal

func (p *Proposal) Proposal() proto.Proposal

func (*Proposal) ProposalID

func (p *Proposal) ProposalID() string

ProposalID - for combined subscriber, communal interface.

func (Proposal) Proto

func (p Proposal) Proto() proto.Proposal

func (Proposal) StreamMessage

func (p Proposal) StreamMessage() *eventspb.BusEvent

type ProtocolUpgradeDataNodeReady added in v0.65.0

type ProtocolUpgradeDataNodeReady struct {
	*Base
	// contains filtered or unexported fields
}

func NewProtocolUpgradeDataNodeReady added in v0.65.0

func NewProtocolUpgradeDataNodeReady(ctx context.Context, lastBlockHeight int64) *ProtocolUpgradeDataNodeReady

func ProtocolUpgradeDataNodeReadyEventFromStream added in v0.65.0

func ProtocolUpgradeDataNodeReadyEventFromStream(ctx context.Context, be *eventspb.BusEvent) *ProtocolUpgradeDataNodeReady

func (ProtocolUpgradeDataNodeReady) Proto added in v0.65.0

func (ProtocolUpgradeDataNodeReady) StreamMessage added in v0.65.0

func (b ProtocolUpgradeDataNodeReady) StreamMessage() *eventspb.BusEvent

type ProtocolUpgradeProposalEvent

type ProtocolUpgradeProposalEvent struct {
	*Base
	UpgradeBlockHeight uint64
	VegaReleaseTag     string
	AcceptedBy         []string
	ProposalStatus     eventspb.ProtocolUpgradeProposalStatus
}

func NewProtocolUpgradeProposalEvent

func NewProtocolUpgradeProposalEvent(ctx context.Context, upgradeBlockHeight uint64, vegaReleaseTag string, acceptedBy []string, status eventspb.ProtocolUpgradeProposalStatus) *ProtocolUpgradeProposalEvent

func ProtocolUpgradeProposalEventFromStream

func ProtocolUpgradeProposalEventFromStream(ctx context.Context, be *eventspb.BusEvent) *ProtocolUpgradeProposalEvent

func (ProtocolUpgradeProposalEvent) Proto

func (ProtocolUpgradeProposalEvent) ProtocolUpgradeProposalEvent

func (pup ProtocolUpgradeProposalEvent) ProtocolUpgradeProposalEvent() eventspb.ProtocolUpgradeEvent

func (ProtocolUpgradeProposalEvent) StreamMessage

func (pup ProtocolUpgradeProposalEvent) StreamMessage() *eventspb.BusEvent

type ProtocolUpgradeStarted added in v0.56.0

type ProtocolUpgradeStarted struct {
	*Base
	// contains filtered or unexported fields
}

func NewProtocolUpgradeStarted added in v0.56.0

func NewProtocolUpgradeStarted(ctx context.Context, bb eventspb.ProtocolUpgradeStarted) *ProtocolUpgradeStarted

NewProtocolUpgradeStarted returns a new time Update event.

func ProtocolUpgradeStartedEventFromStream added in v0.56.0

func ProtocolUpgradeStartedEventFromStream(ctx context.Context, be *eventspb.BusEvent) *ProtocolUpgradeStarted

func (ProtocolUpgradeStarted) Proto added in v0.56.0

func (ProtocolUpgradeStarted) ProtocolUpgradeStarted added in v0.56.0

func (b ProtocolUpgradeStarted) ProtocolUpgradeStarted() eventspb.ProtocolUpgradeStarted

func (ProtocolUpgradeStarted) StreamMessage added in v0.56.0

func (b ProtocolUpgradeStarted) StreamMessage() *eventspb.BusEvent

type RewardPayout

type RewardPayout struct {
	*Base
	Party                   string
	EpochSeq                string
	Asset                   string
	Market                  string
	PercentageOfTotalReward string
	Amount                  *num.Uint
	Timestamp               int64
	RewardType              types.AccountType
}

func NewRewardPayout

func NewRewardPayout(ctx context.Context, timestamp int64, party, epochSeq string, asset string, amount *num.Uint, percentageOfTotalReward num.Decimal, rewardType types.AccountType, market string) *RewardPayout

func RewardPayoutEventFromStream

func RewardPayoutEventFromStream(ctx context.Context, be *eventspb.BusEvent) *RewardPayout

func (RewardPayout) Proto

func (RewardPayout) RewardPayoutEvent

func (rp RewardPayout) RewardPayoutEvent() eventspb.RewardPayoutEvent

func (RewardPayout) StreamMessage

func (rp RewardPayout) StreamMessage() *eventspb.BusEvent

type Risk

type Risk interface {
	Margin
	Amount() *num.Uint
	Transfer() *types.Transfer // I know, it's included in the Transfer interface, but this is to make it clear that this particular func is masked at this level
	MarginLevels() *types.MarginLevels
}

Risk is an event that summarizes everything and an eventual update to margin account.

type RiskFactor

type RiskFactor struct {
	*Base
	// contains filtered or unexported fields
}

func NewRiskFactorEvent

func NewRiskFactorEvent(ctx context.Context, r types.RiskFactor) *RiskFactor

func RiskFactorEventFromStream

func RiskFactorEventFromStream(ctx context.Context, be *eventspb.BusEvent) *RiskFactor

func (RiskFactor) MarketID

func (r RiskFactor) MarketID() string

func (RiskFactor) Proto

func (r RiskFactor) Proto() proto.RiskFactor

func (*RiskFactor) RiskFactor

func (r *RiskFactor) RiskFactor() proto.RiskFactor

func (RiskFactor) StreamMessage

func (r RiskFactor) StreamMessage() *eventspb.BusEvent

type SettleDistressed

type SettleDistressed struct {
	*Base
	// contains filtered or unexported fields
}

func NewSettleDistressed

func NewSettleDistressed(ctx context.Context, partyID, marketID string, price, margin *num.Uint, ts int64) *SettleDistressed

func SettleDistressedEventFromStream

func SettleDistressedEventFromStream(ctx context.Context, be *eventspb.BusEvent) *SettleDistressed

func (SettleDistressed) IsParty

func (s SettleDistressed) IsParty(id string) bool

func (SettleDistressed) Margin

func (s SettleDistressed) Margin() *num.Uint

func (SettleDistressed) MarketID

func (s SettleDistressed) MarketID() string

func (SettleDistressed) PartyID

func (s SettleDistressed) PartyID() string

func (SettleDistressed) Price

func (s SettleDistressed) Price() *num.Uint

func (SettleDistressed) Proto

func (SettleDistressed) StreamMessage

func (s SettleDistressed) StreamMessage() *eventspb.BusEvent

func (SettleDistressed) Timestamp

func (s SettleDistressed) Timestamp() int64

type SettleMarket added in v0.56.0

type SettleMarket struct {
	*Base
	// contains filtered or unexported fields
}

func NewMarketSettled added in v0.56.0

func NewMarketSettled(ctx context.Context, marketID string, ts int64, settledPrice *num.Uint, positionFactor num.Decimal) *SettleMarket

func SettleMarketEventFromStream added in v0.56.0

func SettleMarketEventFromStream(ctx context.Context, be *eventspb.BusEvent) *SettleMarket

func (SettleMarket) MarketID added in v0.56.0

func (m SettleMarket) MarketID() string

func (SettleMarket) PartyID added in v0.56.0

func (m SettleMarket) PartyID() string

PartyID will return an empty string as this is only required to satisfy an interface for identifying events that can affect positions in the data-node.

func (SettleMarket) PositionFactor added in v0.56.0

func (m SettleMarket) PositionFactor() num.Decimal

func (SettleMarket) Proto added in v0.56.0

func (m SettleMarket) Proto() *eventspb.SettleMarket

func (SettleMarket) SettledPrice added in v0.56.0

func (m SettleMarket) SettledPrice() *num.Uint

func (SettleMarket) StreamMessage added in v0.56.0

func (m SettleMarket) StreamMessage() *eventspb.BusEvent

func (SettleMarket) Timestamp added in v0.56.0

func (m SettleMarket) Timestamp() int64

type SettlePos

type SettlePos struct {
	*Base
	// contains filtered or unexported fields
}

func NewSettlePositionEvent

func NewSettlePositionEvent(ctx context.Context, partyID, marketID string, price *num.Uint, trades []TradeSettlement, ts int64, positionFactor num.Decimal) *SettlePos

func SettlePositionEventFromStream

func SettlePositionEventFromStream(ctx context.Context, be *eventspb.BusEvent) *SettlePos

func (SettlePos) IsParty

func (s SettlePos) IsParty(id string) bool

func (SettlePos) MarketID

func (s SettlePos) MarketID() string

func (SettlePos) PartyID

func (s SettlePos) PartyID() string

func (SettlePos) PositionFactor

func (s SettlePos) PositionFactor() num.Decimal

func (SettlePos) Price

func (s SettlePos) Price() *num.Uint

func (SettlePos) Proto

func (s SettlePos) Proto() eventspb.SettlePosition

func (SettlePos) StreamMessage

func (s SettlePos) StreamMessage() *eventspb.BusEvent

func (SettlePos) Timestamp

func (s SettlePos) Timestamp() int64

func (SettlePos) Trades

func (s SettlePos) Trades() []TradeSettlement

type SettlePosition

type SettlePosition interface {
	MarketID() string
	Trades() []TradeSettlement
	Margin() (uint64, bool)
	Party() string
	Price() uint64
}

SettlePosition is an event that the settlement buffer will propagate through the system used by the plugins (currently only the positions API).

type SnapshotTakenEvent added in v0.65.0

type SnapshotTakenEvent struct {
	*Base
	SnapshotBlockHeight  uint64
	SnapshotBlockHash    string
	VegaCoreVersion      string
	ProtocolUpgradeBlock bool
}

func NewSnapshotEventEvent added in v0.65.0

func NewSnapshotEventEvent(ctx context.Context, blockHeight uint64, blockHash string, protocolUpgradeBlock bool) *SnapshotTakenEvent

func SnapthostTakenEventFromStream added in v0.65.0

func SnapthostTakenEventFromStream(ctx context.Context, be *eventspb.BusEvent) *SnapshotTakenEvent

func (SnapshotTakenEvent) Proto added in v0.65.0

func (SnapshotTakenEvent) SnapshotTakenEvent added in v0.65.0

func (ste SnapshotTakenEvent) SnapshotTakenEvent() eventspb.CoreSnapshotData

func (SnapshotTakenEvent) StreamMessage added in v0.65.0

func (ste SnapshotTakenEvent) StreamMessage() *eventspb.BusEvent

type StakeLinking

type StakeLinking struct {
	*Base
	// contains filtered or unexported fields
}

func NewStakeLinking

func NewStakeLinking(ctx context.Context, evt types.StakeLinking) *StakeLinking

func StakeLinkingFromStream

func StakeLinkingFromStream(ctx context.Context, be *eventspb.BusEvent) *StakeLinking

func (StakeLinking) Proto

func (StakeLinking) StakeLinking

func (s StakeLinking) StakeLinking() eventspb.StakeLinking

func (StakeLinking) StreamMessage

func (s StakeLinking) StreamMessage() *eventspb.BusEvent

type StateVar

type StateVar struct {
	*Base
	ID      string
	EventID string
	State   string
}

StateVar is an event for tracking consensus in floating point state variables.

func NewStateVarEvent

func NewStateVarEvent(ctx context.Context, ID, eventID, state string) *StateVar

func StateVarEventFromStream

func StateVarEventFromStream(ctx context.Context, be *eventspb.BusEvent) *StateVar

func (StateVar) Proto

func (sv StateVar) Proto() eventspb.StateVar

func (StateVar) StreamMessage

func (sv StateVar) StreamMessage() *eventspb.BusEvent

type StopOrder added in v0.72.0

type StopOrder struct {
	*Base
	// contains filtered or unexported fields
}

func NewStopOrderEvent added in v0.72.0

func NewStopOrderEvent(ctx context.Context, so *types.StopOrder) *StopOrder

func StopOrderEventFromStream added in v0.72.0

func StopOrderEventFromStream(ctx context.Context, be *eventspb.BusEvent) *StopOrder

func (StopOrder) StopOrder added in v0.72.0

func (o StopOrder) StopOrder() *eventspb.StopOrderEvent

func (StopOrder) StreamMessage added in v0.72.0

func (o StopOrder) StreamMessage() *eventspb.BusEvent

type Time

type Time struct {
	*Base
	// contains filtered or unexported fields
}

Time event indicating a change in block time (ie time update).

func NewTime

func NewTime(ctx context.Context, t time.Time) *Time

NewTime returns a new time Update event.

func TimeEventFromStream

func TimeEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Time

func (Time) Proto

func (t Time) Proto() eventspb.TimeUpdate

func (Time) StreamMessage

func (t Time) StreamMessage() *eventspb.BusEvent

func (Time) Time

func (t Time) Time() time.Time

Time returns the new blocktime.

type Trade

type Trade struct {
	*Base
	// contains filtered or unexported fields
}

func NewTradeEvent

func NewTradeEvent(ctx context.Context, t types.Trade) *Trade

func TradeEventFromStream

func TradeEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Trade

func (Trade) IsParty

func (t Trade) IsParty(id string) bool

func (Trade) MarketID

func (t Trade) MarketID() string

func (Trade) Proto

func (t Trade) Proto() ptypes.Trade

func (Trade) StreamMessage

func (t Trade) StreamMessage() *eventspb.BusEvent

func (*Trade) Trade

func (t *Trade) Trade() ptypes.Trade

type TradeSettlement

type TradeSettlement interface {
	Size() int64
	Price() *num.Uint
	MarketPrice() *num.Uint
}

TradeSettlement Part of the SettlePosition interface -> traces trades as they happened.

type TransactionResult added in v0.58.0

type TransactionResult struct {
	*Base
	// contains filtered or unexported fields
}

func NewTransactionResultEventFailure added in v0.58.0

func NewTransactionResultEventFailure(
	ctx context.Context,
	hash, party string,
	err error,
	tx interface{},
) *TransactionResult

func NewTransactionResultEventSuccess added in v0.58.0

func NewTransactionResultEventSuccess(
	ctx context.Context,
	hash, party string,
	tx interface{},
) *TransactionResult

func TransactionResultEventFromStream added in v0.58.0

func TransactionResultEventFromStream(ctx context.Context, be *eventspb.BusEvent) *TransactionResult

func (TransactionResult) IsParty added in v0.58.0

func (t TransactionResult) IsParty(id string) bool

func (TransactionResult) Proto added in v0.58.0

func (TransactionResult) StreamMessage added in v0.58.0

func (t TransactionResult) StreamMessage() *eventspb.BusEvent

type Transfer

type Transfer interface {
	MarketPosition
	Transfer() *types.Transfer
}

Transfer is an event passed on by settlement engine, contains position and the resulting transfer for the collateral engine to use. We need MarketPosition because we can't loose the long/short status of the open positions.

type TransferFunds

type TransferFunds struct {
	*Base
	// contains filtered or unexported fields
}

Transfer ...

func NewGovTransferFundsEvent added in v0.72.0

func NewGovTransferFundsEvent(
	ctx context.Context,
	t *types.GovernanceTransfer,
	amount *num.Uint,
) *TransferFunds

func NewGovTransferFundsEventWithReason added in v0.72.0

func NewGovTransferFundsEventWithReason(
	ctx context.Context,
	t *types.GovernanceTransfer,
	amount *num.Uint,
	reason string,
) *TransferFunds

func NewOneOffTransferFundsEvent

func NewOneOffTransferFundsEvent(
	ctx context.Context,
	t *types.OneOffTransfer,
) *TransferFunds

func NewOneOffTransferFundsEventWithReason added in v0.59.0

func NewOneOffTransferFundsEventWithReason(
	ctx context.Context,
	t *types.OneOffTransfer,
	reason string,
) *TransferFunds

func NewRecurringTransferFundsEvent

func NewRecurringTransferFundsEvent(
	ctx context.Context,
	t *types.RecurringTransfer,
) *TransferFunds

func NewRecurringTransferFundsEventWithReason added in v0.59.0

func NewRecurringTransferFundsEventWithReason(
	ctx context.Context,
	t *types.RecurringTransfer,
	reason string,
) *TransferFunds

func TransferFundsEventFromStream

func TransferFundsEventFromStream(ctx context.Context, be *eventspb.BusEvent) *TransferFunds

func (TransferFunds) PartyID

func (t TransferFunds) PartyID() string

func (TransferFunds) Proto

func (t TransferFunds) Proto() eventspb.Transfer

func (TransferFunds) StreamMessage

func (t TransferFunds) StreamMessage() *eventspb.BusEvent

func (TransferFunds) TransferFunds

func (t TransferFunds) TransferFunds() eventspb.Transfer

type TxErr

type TxErr struct {
	*Base
	// contains filtered or unexported fields
}

func NewTxErrEvent

func NewTxErrEvent(ctx context.Context, err error, partyID string, tx interface{}, cmd string) *TxErr

func TxErrEventFromStream

func TxErrEventFromStream(ctx context.Context, be *eventspb.BusEvent) *TxErr

func (TxErr) IsParty

func (t TxErr) IsParty(id string) bool

func (TxErr) Proto

func (t TxErr) Proto() eventspb.TxErrorEvent

func (TxErr) StreamMessage

func (t TxErr) StreamMessage() *eventspb.BusEvent

type Type

type Type int
const (
	// All event type -> used by subscribers to just receive all events, has no actual corresponding event payload.
	All Type = iota
	// other event types that DO have corresponding event types.
	TimeUpdate
	LedgerMovementsEvent
	PositionResolution
	MarketEvent // this event is not used for any specific event, but by subscribers that aggregate all market events (e.g. for logging)
	OrderEvent
	LiquidityProvisionEvent
	AccountEvent
	PartyEvent
	TradeEvent
	MarginLevelsEvent
	ProposalEvent
	VoteEvent
	MarketDataEvent
	NodeSignatureEvent
	LossSocializationEvent
	SettlePositionEvent
	SettleDistressedEvent
	MarketCreatedEvent
	MarketUpdatedEvent
	AssetEvent
	MarketTickEvent
	AuctionEvent
	WithdrawalEvent
	DepositEvent
	RiskFactorEvent
	NetworkParameterEvent
	TxErrEvent
	OracleSpecEvent
	OracleDataEvent
	EpochUpdate
	DelegationBalanceEvent
	StakeLinkingEvent
	ValidatorUpdateEvent
	RewardPayoutEvent
	CheckpointEvent
	ValidatorScoreEvent
	KeyRotationEvent
	StateVarEvent
	NetworkLimitsEvent
	TransferEvent
	ValidatorRankingEvent
	ERC20MultiSigThresholdSetEvent
	ERC20MultiSigSignerEvent
	ERC20MultiSigSignerAddedEvent
	ERC20MultiSigSignerRemovedEvent
	PositionStateEvent
	EthereumKeyRotationEvent
	ProtocolUpgradeEvent
	BeginBlockEvent
	EndBlockEvent
	ProtocolUpgradeStartedEvent
	SettleMarketEvent
	TransactionResultEvent
	CoreSnapshotEvent
	ProtocolUpgradeDataNodeReadyEvent
	DistressedOrdersClosedEvent
	ExpiredOrdersEvent
	DistressedPositionsEvent
	StopOrderEvent
)

func MarketEvents

func MarketEvents() []Type

MarketEvents return all the possible market events.

func ProtoToInternal

func ProtoToInternal(pTypes ...eventspb.BusEventType) ([]Type, error)

ProtoToInternal converts the proto message enum to our internal constants we're not using a map to de-duplicate the event types here, so we can exploit duplicating the same event to control the internal subscriber channel buffer.

func TryFromString

func TryFromString(s string) (*Type, bool)

TryFromString tries to parse a raw string into an event type, false indicates that.

func (Type) String

func (t Type) String() string

String get string representation of event type.

func (Type) ToProto

func (t Type) ToProto() eventspb.BusEventType

type ValidatorRanking

type ValidatorRanking struct {
	*Base
	NodeID           string
	EpochSeq         string
	StakeScore       string
	PerformanceScore string
	Ranking          string
	PreviousStatus   string
	Status           string
	TMVotingPower    int
}

func NewValidatorRanking

func NewValidatorRanking(ctx context.Context, epochSeq, nodeID, stakeScore, performanceScore, ranking, previousStatus, status string, votingPower int) *ValidatorRanking

func ValidatorRankingEventFromStream

func ValidatorRankingEventFromStream(ctx context.Context, be *eventspb.BusEvent) *ValidatorRanking

func (ValidatorRanking) Proto

func (ValidatorRanking) StreamMessage

func (vr ValidatorRanking) StreamMessage() *eventspb.BusEvent

func (ValidatorRanking) ValidatorRankingEvent

func (vr ValidatorRanking) ValidatorRankingEvent() eventspb.ValidatorRankingEvent

type ValidatorScore

type ValidatorScore struct {
	*Base
	NodeID               string
	EpochSeq             string
	ValidatorScore       string
	NormalisedScore      string
	RawValidatorScore    string
	ValidatorPerformance string
	MultisigScore        string
	ValidatorStatus      string
}

func NewValidatorScore

func NewValidatorScore(ctx context.Context, nodeID, epochSeq string, score, normalisedScore, rawValidatorScore,
	validatorPerformance num.Decimal, multisigScore num.Decimal, validatorStatus string,
) *ValidatorScore

func ValidatorScoreEventFromStream

func ValidatorScoreEventFromStream(ctx context.Context, be *eventspb.BusEvent) *ValidatorScore

func (ValidatorScore) Proto

func (ValidatorScore) StreamMessage

func (vd ValidatorScore) StreamMessage() *eventspb.BusEvent

func (ValidatorScore) ValidatorScoreEvent

func (vd ValidatorScore) ValidatorScoreEvent() eventspb.ValidatorScoreEvent

type ValidatorUpdate

type ValidatorUpdate struct {
	*Base
	// contains filtered or unexported fields
}

ValidatorUpdate ...

func NewValidatorUpdateEvent

func NewValidatorUpdateEvent(
	ctx context.Context,
	nodeID string,
	vegaPubKey string,
	vegaPubKeyIndex uint32,
	ethAddress string,
	tmPubKey string,
	infoURL string,
	country string,
	name string,
	avatarURL string,
	fromEpoch uint64,
	added bool,
	epochSeq uint64,
) *ValidatorUpdate

func ValidatorUpdateEventFromStream

func ValidatorUpdateEventFromStream(ctx context.Context, be *eventspb.BusEvent) *ValidatorUpdate

func (ValidatorUpdate) AvatarURL

func (vu ValidatorUpdate) AvatarURL() string

AvatarURL return an URL to the validator avatar for UI purpose.

func (ValidatorUpdate) Country

func (vu ValidatorUpdate) Country() string

Country returns country code of node's location.

func (ValidatorUpdate) EthereumAddress

func (vu ValidatorUpdate) EthereumAddress() string

EthereumAddress returns validator's ethereum address.

func (ValidatorUpdate) InfoURL

func (vu ValidatorUpdate) InfoURL() string

InfoURL returns an url with information about validator node.

func (ValidatorUpdate) Name

func (vu ValidatorUpdate) Name() string

Name return the name of the validator.

func (ValidatorUpdate) NodeID

func (vu ValidatorUpdate) NodeID() string

NodeID returns nodes ID.

func (ValidatorUpdate) Proto

func (ValidatorUpdate) StreamMessage

func (vu ValidatorUpdate) StreamMessage() *eventspb.BusEvent

func (ValidatorUpdate) TendermintPublicKey

func (vu ValidatorUpdate) TendermintPublicKey() string

TendermintPublicKey returns Tendermint nodes public key.

func (ValidatorUpdate) ValidatorUpdate

func (vu ValidatorUpdate) ValidatorUpdate() eventspb.ValidatorUpdate

func (ValidatorUpdate) VegaPublicKey

func (vu ValidatorUpdate) VegaPublicKey() string

VegaPublicKey returns validator's vega public key.

func (ValidatorUpdate) VegaPublicKeyIndex

func (vu ValidatorUpdate) VegaPublicKeyIndex() uint32

VegaPublicKey returns validator's vega public key index.

type Vote

type Vote struct {
	*Base
	// contains filtered or unexported fields
}

func NewVoteEvent

func NewVoteEvent(ctx context.Context, v types.Vote) *Vote

func VoteEventFromStream

func VoteEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Vote

func (Vote) IsParty

func (v Vote) IsParty(id string) bool

IsParty - used in event stream API filter.

func (*Vote) PartyID

func (v *Vote) PartyID() string

PartyID - return the PartyID for subscribers' convenience.

func (*Vote) ProposalID

func (v *Vote) ProposalID() string

ProposalID get the proposal ID, part of the interface for event subscribers.

func (Vote) Proto

func (v Vote) Proto() proto.Vote

func (Vote) StreamMessage

func (v Vote) StreamMessage() *eventspb.BusEvent

func (*Vote) TotalGovernanceTokenBalance

func (v *Vote) TotalGovernanceTokenBalance() string

TotalGovernanceTokenBalance returns the total balance of token used for this vote.

func (*Vote) TotalGovernanceTokenWeight

func (v *Vote) TotalGovernanceTokenWeight() string

TotalGovernanceTokenWeight returns the total weight of token used for this vote.

func (*Vote) Value

func (v *Vote) Value() proto.Vote_Value

Value - return a Y/N value, makes subscribers easier to implement.

func (*Vote) Vote

func (v *Vote) Vote() proto.Vote

Vote get the vote object.

type Withdrawal

type Withdrawal struct {
	*Base
	// contains filtered or unexported fields
}

func NewWithdrawalEvent

func NewWithdrawalEvent(ctx context.Context, w types.Withdrawal) *Withdrawal

func WithdrawalEventFromStream

func WithdrawalEventFromStream(ctx context.Context, be *eventspb.BusEvent) *Withdrawal

func (Withdrawal) IsParty

func (w Withdrawal) IsParty(id string) bool

func (Withdrawal) PartyID

func (w Withdrawal) PartyID() string

func (Withdrawal) Proto

func (w Withdrawal) Proto() proto.Withdrawal

func (Withdrawal) StreamMessage

func (w Withdrawal) StreamMessage() *eventspb.BusEvent

func (*Withdrawal) Withdrawal

func (w *Withdrawal) Withdrawal() proto.Withdrawal

Jump to

Keyboard shortcuts

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