types

package
v1.51.0 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var OrderUpdateStatus_name = map[int32]string{
	0: "Unspecified",
	1: "Booked",
	2: "Matched",
	3: "Cancelled",
}
View Source 
var OrderUpdateStatus_value = map[string]int32{
	"Unspecified": 0,
	"Booked":      1,
	"Matched":     2,
	"Cancelled":   3,
}

Functions

func RegisterStreamServer 

func RegisterStreamServer(s grpc1.Server, srv StreamServer)

Types

type BankBalance 

type BankBalance struct {
	Account  string                                   `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Balances github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=balances,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"balances"`
}

func (*BankBalance) Descriptor 

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

func (*BankBalance) GetAccount 

func (m *BankBalance) GetAccount() string

func (*BankBalance) GetBalances 

func (m *BankBalance) GetBalances() github_com_cosmos_cosmos_sdk_types.Coins

func (*BankBalance) Marshal 

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

func (*BankBalance) MarshalTo 

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

func (*BankBalance) MarshalToSizedBuffer 

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

func (*BankBalance) ProtoMessage 

func (*BankBalance) ProtoMessage()

func (*BankBalance) Reset 

func (m *BankBalance) Reset()

func (*BankBalance) Size 

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

func (*BankBalance) String 

func (m *BankBalance) String() string

func (*BankBalance) Unmarshal 

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

func (*BankBalance) XXX_DiscardUnknown 

func (m *BankBalance) XXX_DiscardUnknown()

func (*BankBalance) XXX_Marshal 

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

func (*BankBalance) XXX_Merge 

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

func (*BankBalance) XXX_Size 

func (m *BankBalance) XXX_Size() int

func (*BankBalance) XXX_Unmarshal 

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

type BankBalancesFilter 

type BankBalancesFilter struct {
	Accounts []string `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
}

func (*BankBalancesFilter) Descriptor 

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

func (*BankBalancesFilter) GetAccounts 

func (m *BankBalancesFilter) GetAccounts() []string

func (*BankBalancesFilter) Marshal 

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

func (*BankBalancesFilter) MarshalTo 

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

func (*BankBalancesFilter) MarshalToSizedBuffer 

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

func (*BankBalancesFilter) ProtoMessage 

func (*BankBalancesFilter) ProtoMessage()

func (*BankBalancesFilter) Reset 

func (m *BankBalancesFilter) Reset()

func (*BankBalancesFilter) Size 

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

func (*BankBalancesFilter) String 

func (m *BankBalancesFilter) String() string

func (*BankBalancesFilter) Unmarshal 

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

func (*BankBalancesFilter) XXX_DiscardUnknown 

func (m *BankBalancesFilter) XXX_DiscardUnknown()

func (*BankBalancesFilter) XXX_Marshal 

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

func (*BankBalancesFilter) XXX_Merge 

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

func (*BankBalancesFilter) XXX_Size 

func (m *BankBalancesFilter) XXX_Size() int

func (*BankBalancesFilter) XXX_Unmarshal 

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

type DerivativeOrder 

type DerivativeOrder struct {
	MarketId string                     `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	Order    types.DerivativeLimitOrder `protobuf:"bytes,2,opt,name=order,proto3" json:"order"`
	IsMarket bool                       `protobuf:"varint,3,opt,name=is_market,json=isMarket,proto3" json:"is_market,omitempty"`
}

func (*DerivativeOrder) Descriptor 

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

func (*DerivativeOrder) GetIsMarket 

func (m *DerivativeOrder) GetIsMarket() bool

func (*DerivativeOrder) GetMarketId 

func (m *DerivativeOrder) GetMarketId() string

func (*DerivativeOrder) GetOrder 

func (m *DerivativeOrder) GetOrder() types.DerivativeLimitOrder

func (*DerivativeOrder) Marshal 

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

func (*DerivativeOrder) MarshalTo 

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

func (*DerivativeOrder) MarshalToSizedBuffer 

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

func (*DerivativeOrder) ProtoMessage 

func (*DerivativeOrder) ProtoMessage()

func (*DerivativeOrder) Reset 

func (m *DerivativeOrder) Reset()

func (*DerivativeOrder) Size 

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

func (*DerivativeOrder) String 

func (m *DerivativeOrder) String() string

func (*DerivativeOrder) Unmarshal 

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

func (*DerivativeOrder) XXX_DiscardUnknown 

func (m *DerivativeOrder) XXX_DiscardUnknown()

func (*DerivativeOrder) XXX_Marshal 

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

func (*DerivativeOrder) XXX_Merge 

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

func (*DerivativeOrder) XXX_Size 

func (m *DerivativeOrder) XXX_Size() int

func (*DerivativeOrder) XXX_Unmarshal 

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

type DerivativeOrderUpdate 

type DerivativeOrderUpdate struct {
	Status    OrderUpdateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=injective.stream.v1beta1.OrderUpdateStatus" json:"status,omitempty"`
	OrderHash []byte            `protobuf:"bytes,2,opt,name=order_hash,json=orderHash,proto3" json:"order_hash,omitempty"`
	Cid       string            `protobuf:"bytes,3,opt,name=cid,proto3" json:"cid,omitempty"`
	Order     *DerivativeOrder  `protobuf:"bytes,4,opt,name=order,proto3" json:"order,omitempty"`
}

func (*DerivativeOrderUpdate) Descriptor 

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

func (*DerivativeOrderUpdate) GetCid 

func (m *DerivativeOrderUpdate) GetCid() string

func (*DerivativeOrderUpdate) GetOrder 

func (m *DerivativeOrderUpdate) GetOrder() *DerivativeOrder

func (*DerivativeOrderUpdate) GetOrderHash 

func (m *DerivativeOrderUpdate) GetOrderHash() []byte

func (*DerivativeOrderUpdate) GetStatus 

func (m *DerivativeOrderUpdate) GetStatus() OrderUpdateStatus

func (*DerivativeOrderUpdate) Marshal 

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

func (*DerivativeOrderUpdate) MarshalTo 

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

func (*DerivativeOrderUpdate) MarshalToSizedBuffer 

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

func (*DerivativeOrderUpdate) ProtoMessage 

func (*DerivativeOrderUpdate) ProtoMessage()

func (*DerivativeOrderUpdate) Reset 

func (m *DerivativeOrderUpdate) Reset()

func (*DerivativeOrderUpdate) Size 

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

func (*DerivativeOrderUpdate) String 

func (m *DerivativeOrderUpdate) String() string

func (*DerivativeOrderUpdate) Unmarshal 

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

func (*DerivativeOrderUpdate) XXX_DiscardUnknown 

func (m *DerivativeOrderUpdate) XXX_DiscardUnknown()

func (*DerivativeOrderUpdate) XXX_Marshal 

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

func (*DerivativeOrderUpdate) XXX_Merge 

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

func (*DerivativeOrderUpdate) XXX_Size 

func (m *DerivativeOrderUpdate) XXX_Size() int

func (*DerivativeOrderUpdate) XXX_Unmarshal 

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

type DerivativeTrade 

type DerivativeTrade struct {
	MarketId            string                      `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	IsBuy               bool                        `protobuf:"varint,2,opt,name=is_buy,json=isBuy,proto3" json:"is_buy,omitempty"`
	ExecutionType       string                      `protobuf:"bytes,3,opt,name=executionType,proto3" json:"executionType,omitempty"`
	SubaccountId        string                      `protobuf:"bytes,4,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	PositionDelta       *types.PositionDelta        `protobuf:"bytes,5,opt,name=position_delta,json=positionDelta,proto3" json:"position_delta,omitempty"`
	Payout              cosmossdk_io_math.LegacyDec `protobuf:"bytes,6,opt,name=payout,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"payout"`
	Fee                 cosmossdk_io_math.LegacyDec `protobuf:"bytes,7,opt,name=fee,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"fee"`
	OrderHash           string                      `protobuf:"bytes,8,opt,name=order_hash,json=orderHash,proto3" json:"order_hash,omitempty"`
	FeeRecipientAddress string                      `protobuf:"bytes,9,opt,name=fee_recipient_address,json=feeRecipientAddress,proto3" json:"fee_recipient_address,omitempty"`
	Cid                 string                      `protobuf:"bytes,10,opt,name=cid,proto3" json:"cid,omitempty"`
	TradeId             string                      `protobuf:"bytes,11,opt,name=trade_id,json=tradeId,proto3" json:"trade_id,omitempty"`
}

func (*DerivativeTrade) Descriptor 

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

func (*DerivativeTrade) GetCid 

func (m *DerivativeTrade) GetCid() string

func (*DerivativeTrade) GetExecutionType 

func (m *DerivativeTrade) GetExecutionType() string

func (*DerivativeTrade) GetFeeRecipientAddress 

func (m *DerivativeTrade) GetFeeRecipientAddress() string

func (*DerivativeTrade) GetIsBuy 

func (m *DerivativeTrade) GetIsBuy() bool

func (*DerivativeTrade) GetMarketId 

func (m *DerivativeTrade) GetMarketId() string

func (*DerivativeTrade) GetOrderHash 

func (m *DerivativeTrade) GetOrderHash() string

func (*DerivativeTrade) GetPositionDelta 

func (m *DerivativeTrade) GetPositionDelta() *types.PositionDelta

func (*DerivativeTrade) GetSubaccountId 

func (m *DerivativeTrade) GetSubaccountId() string

func (*DerivativeTrade) GetTradeId 

func (m *DerivativeTrade) GetTradeId() string

func (*DerivativeTrade) Marshal 

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

func (*DerivativeTrade) MarshalTo 

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

func (*DerivativeTrade) MarshalToSizedBuffer 

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

func (*DerivativeTrade) ProtoMessage 

func (*DerivativeTrade) ProtoMessage()

func (*DerivativeTrade) Reset 

func (m *DerivativeTrade) Reset()

func (*DerivativeTrade) Size 

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

func (*DerivativeTrade) String 

func (m *DerivativeTrade) String() string

func (*DerivativeTrade) Unmarshal 

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

func (*DerivativeTrade) XXX_DiscardUnknown 

func (m *DerivativeTrade) XXX_DiscardUnknown()

func (*DerivativeTrade) XXX_Marshal 

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

func (*DerivativeTrade) XXX_Merge 

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

func (*DerivativeTrade) XXX_Size 

func (m *DerivativeTrade) XXX_Size() int

func (*DerivativeTrade) XXX_Unmarshal 

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

type Empty added in v1.51.0 

type Empty struct {
}

Empty query matches any set of events.

func (Empty) Matches added in v1.51.0 

func (Empty) Matches(tags map[string][]string) (bool, error)

Matches always returns true.

func (Empty) String added in v1.51.0 

func (Empty) String() string

type OraclePrice 

type OraclePrice struct {
	Symbol string                      `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
	Price  cosmossdk_io_math.LegacyDec `protobuf:"bytes,2,opt,name=price,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"price"`
	Type   string                      `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
}

func (*OraclePrice) Descriptor 

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

func (*OraclePrice) GetSymbol 

func (m *OraclePrice) GetSymbol() string

func (*OraclePrice) GetType 

func (m *OraclePrice) GetType() string

func (*OraclePrice) Marshal 

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

func (*OraclePrice) MarshalTo 

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

func (*OraclePrice) MarshalToSizedBuffer 

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

func (*OraclePrice) ProtoMessage 

func (*OraclePrice) ProtoMessage()

func (*OraclePrice) Reset 

func (m *OraclePrice) Reset()

func (*OraclePrice) Size 

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

func (*OraclePrice) String 

func (m *OraclePrice) String() string

func (*OraclePrice) Unmarshal 

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

func (*OraclePrice) XXX_DiscardUnknown 

func (m *OraclePrice) XXX_DiscardUnknown()

func (*OraclePrice) XXX_Marshal 

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

func (*OraclePrice) XXX_Merge 

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

func (*OraclePrice) XXX_Size 

func (m *OraclePrice) XXX_Size() int

func (*OraclePrice) XXX_Unmarshal 

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

type OraclePriceFilter 

type OraclePriceFilter struct {
	Symbol []string `protobuf:"bytes,1,rep,name=symbol,proto3" json:"symbol,omitempty"`
}

func (*OraclePriceFilter) Descriptor 

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

func (*OraclePriceFilter) GetSymbol 

func (m *OraclePriceFilter) GetSymbol() []string

func (*OraclePriceFilter) Marshal 

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

func (*OraclePriceFilter) MarshalTo 

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

func (*OraclePriceFilter) MarshalToSizedBuffer 

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

func (*OraclePriceFilter) ProtoMessage 

func (*OraclePriceFilter) ProtoMessage()

func (*OraclePriceFilter) Reset 

func (m *OraclePriceFilter) Reset()

func (*OraclePriceFilter) Size 

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

func (*OraclePriceFilter) String 

func (m *OraclePriceFilter) String() string

func (*OraclePriceFilter) Unmarshal 

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

func (*OraclePriceFilter) XXX_DiscardUnknown 

func (m *OraclePriceFilter) XXX_DiscardUnknown()

func (*OraclePriceFilter) XXX_Marshal 

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

func (*OraclePriceFilter) XXX_Merge 

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

func (*OraclePriceFilter) XXX_Size 

func (m *OraclePriceFilter) XXX_Size() int

func (*OraclePriceFilter) XXX_Unmarshal 

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

type OrderUpdateStatus 

type OrderUpdateStatus int32
const (
	OrderUpdateStatus_Unspecified OrderUpdateStatus = 0
	OrderUpdateStatus_Booked      OrderUpdateStatus = 1
	OrderUpdateStatus_Matched     OrderUpdateStatus = 2
	OrderUpdateStatus_Cancelled   OrderUpdateStatus = 3
)

func (OrderUpdateStatus) EnumDescriptor 

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

func (OrderUpdateStatus) String 

func (x OrderUpdateStatus) String() string

type Orderbook 

type Orderbook struct {
	MarketId   string         `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	BuyLevels  []*types.Level `protobuf:"bytes,2,rep,name=buy_levels,json=buyLevels,proto3" json:"buy_levels,omitempty"`
	SellLevels []*types.Level `protobuf:"bytes,3,rep,name=sell_levels,json=sellLevels,proto3" json:"sell_levels,omitempty"`
}

func (*Orderbook) Descriptor 

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

func (*Orderbook) GetBuyLevels 

func (m *Orderbook) GetBuyLevels() []*types.Level

func (*Orderbook) GetMarketId 

func (m *Orderbook) GetMarketId() string

func (*Orderbook) GetSellLevels 

func (m *Orderbook) GetSellLevels() []*types.Level

func (*Orderbook) Marshal 

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

func (*Orderbook) MarshalTo 

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

func (*Orderbook) MarshalToSizedBuffer 

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

func (*Orderbook) ProtoMessage 

func (*Orderbook) ProtoMessage()

func (*Orderbook) Reset 

func (m *Orderbook) Reset()

func (*Orderbook) Size 

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

func (*Orderbook) String 

func (m *Orderbook) String() string

func (*Orderbook) Unmarshal 

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

func (*Orderbook) XXX_DiscardUnknown 

func (m *Orderbook) XXX_DiscardUnknown()

func (*Orderbook) XXX_Marshal 

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

func (*Orderbook) XXX_Merge 

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

func (*Orderbook) XXX_Size 

func (m *Orderbook) XXX_Size() int

func (*Orderbook) XXX_Unmarshal 

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

type OrderbookFilter 

type OrderbookFilter struct {
	MarketIds []string `protobuf:"bytes,1,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
}

func (*OrderbookFilter) Descriptor 

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

func (*OrderbookFilter) GetMarketIds 

func (m *OrderbookFilter) GetMarketIds() []string

func (*OrderbookFilter) Marshal 

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

func (*OrderbookFilter) MarshalTo 

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

func (*OrderbookFilter) MarshalToSizedBuffer 

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

func (*OrderbookFilter) ProtoMessage 

func (*OrderbookFilter) ProtoMessage()

func (*OrderbookFilter) Reset 

func (m *OrderbookFilter) Reset()

func (*OrderbookFilter) Size 

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

func (*OrderbookFilter) String 

func (m *OrderbookFilter) String() string

func (*OrderbookFilter) Unmarshal 

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

func (*OrderbookFilter) XXX_DiscardUnknown 

func (m *OrderbookFilter) XXX_DiscardUnknown()

func (*OrderbookFilter) XXX_Marshal 

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

func (*OrderbookFilter) XXX_Merge 

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

func (*OrderbookFilter) XXX_Size 

func (m *OrderbookFilter) XXX_Size() int

func (*OrderbookFilter) XXX_Unmarshal 

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

type OrderbookUpdate 

type OrderbookUpdate struct {
	Seq       uint64     `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	Orderbook *Orderbook `protobuf:"bytes,2,opt,name=orderbook,proto3" json:"orderbook,omitempty"`
}

func (*OrderbookUpdate) Descriptor 

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

func (*OrderbookUpdate) GetOrderbook 

func (m *OrderbookUpdate) GetOrderbook() *Orderbook

func (*OrderbookUpdate) GetSeq 

func (m *OrderbookUpdate) GetSeq() uint64

func (*OrderbookUpdate) Marshal 

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

func (*OrderbookUpdate) MarshalTo 

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

func (*OrderbookUpdate) MarshalToSizedBuffer 

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

func (*OrderbookUpdate) ProtoMessage 

func (*OrderbookUpdate) ProtoMessage()

func (*OrderbookUpdate) Reset 

func (m *OrderbookUpdate) Reset()

func (*OrderbookUpdate) Size 

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

func (*OrderbookUpdate) String 

func (m *OrderbookUpdate) String() string

func (*OrderbookUpdate) Unmarshal 

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

func (*OrderbookUpdate) XXX_DiscardUnknown 

func (m *OrderbookUpdate) XXX_DiscardUnknown()

func (*OrderbookUpdate) XXX_Marshal 

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

func (*OrderbookUpdate) XXX_Merge 

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

func (*OrderbookUpdate) XXX_Size 

func (m *OrderbookUpdate) XXX_Size() int

func (*OrderbookUpdate) XXX_Unmarshal 

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

type OrdersFilter 

type OrdersFilter struct {
	SubaccountIds []string `protobuf:"bytes,1,rep,name=subaccount_ids,json=subaccountIds,proto3" json:"subaccount_ids,omitempty"`
	MarketIds     []string `protobuf:"bytes,2,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
}

func (*OrdersFilter) Descriptor 

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

func (*OrdersFilter) GetMarketIds 

func (m *OrdersFilter) GetMarketIds() []string

func (*OrdersFilter) GetSubaccountIds 

func (m *OrdersFilter) GetSubaccountIds() []string

func (*OrdersFilter) Marshal 

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

func (*OrdersFilter) MarshalTo 

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

func (*OrdersFilter) MarshalToSizedBuffer 

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

func (*OrdersFilter) ProtoMessage 

func (*OrdersFilter) ProtoMessage()

func (*OrdersFilter) Reset 

func (m *OrdersFilter) Reset()

func (*OrdersFilter) Size 

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

func (*OrdersFilter) String 

func (m *OrdersFilter) String() string

func (*OrdersFilter) Unmarshal 

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

func (*OrdersFilter) XXX_DiscardUnknown 

func (m *OrdersFilter) XXX_DiscardUnknown()

func (*OrdersFilter) XXX_Marshal 

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

func (*OrdersFilter) XXX_Merge 

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

func (*OrdersFilter) XXX_Size 

func (m *OrdersFilter) XXX_Size() int

func (*OrdersFilter) XXX_Unmarshal 

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

type Position 

type Position struct {
	MarketId               string                      `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	SubaccountId           string                      `protobuf:"bytes,2,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	IsLong                 bool                        `protobuf:"varint,3,opt,name=isLong,proto3" json:"isLong,omitempty"`
	Quantity               cosmossdk_io_math.LegacyDec `protobuf:"bytes,4,opt,name=quantity,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"quantity"`
	EntryPrice             cosmossdk_io_math.LegacyDec `protobuf:"bytes,5,opt,name=entry_price,json=entryPrice,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"entry_price"`
	Margin                 cosmossdk_io_math.LegacyDec `protobuf:"bytes,6,opt,name=margin,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"margin"`
	CumulativeFundingEntry cosmossdk_io_math.LegacyDec `` /* 158-byte string literal not displayed */
}

func (*Position) Descriptor 

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

func (*Position) GetIsLong 

func (m *Position) GetIsLong() bool

func (*Position) GetMarketId 

func (m *Position) GetMarketId() string

func (*Position) GetSubaccountId 

func (m *Position) GetSubaccountId() string

func (*Position) Marshal 

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

func (*Position) MarshalTo 

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

func (*Position) MarshalToSizedBuffer 

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

func (*Position) ProtoMessage 

func (*Position) ProtoMessage()

func (*Position) Reset 

func (m *Position) Reset()

func (*Position) Size 

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

func (*Position) String 

func (m *Position) String() string

func (*Position) Unmarshal 

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

func (*Position) XXX_DiscardUnknown 

func (m *Position) XXX_DiscardUnknown()

func (*Position) XXX_Marshal 

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

func (*Position) XXX_Merge 

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

func (*Position) XXX_Size 

func (m *Position) XXX_Size() int

func (*Position) XXX_Unmarshal 

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

type PositionsFilter 

type PositionsFilter struct {
	SubaccountIds []string `protobuf:"bytes,1,rep,name=subaccount_ids,json=subaccountIds,proto3" json:"subaccount_ids,omitempty"`
	MarketIds     []string `protobuf:"bytes,2,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
}

func (*PositionsFilter) Descriptor 

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

func (*PositionsFilter) GetMarketIds 

func (m *PositionsFilter) GetMarketIds() []string

func (*PositionsFilter) GetSubaccountIds 

func (m *PositionsFilter) GetSubaccountIds() []string

func (*PositionsFilter) Marshal 

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

func (*PositionsFilter) MarshalTo 

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

func (*PositionsFilter) MarshalToSizedBuffer 

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

func (*PositionsFilter) ProtoMessage 

func (*PositionsFilter) ProtoMessage()

func (*PositionsFilter) Reset 

func (m *PositionsFilter) Reset()

func (*PositionsFilter) Size 

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

func (*PositionsFilter) String 

func (m *PositionsFilter) String() string

func (*PositionsFilter) Unmarshal 

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

func (*PositionsFilter) XXX_DiscardUnknown 

func (m *PositionsFilter) XXX_DiscardUnknown()

func (*PositionsFilter) XXX_Marshal 

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

func (*PositionsFilter) XXX_Merge 

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

func (*PositionsFilter) XXX_Size 

func (m *PositionsFilter) XXX_Size() int

func (*PositionsFilter) XXX_Unmarshal 

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

type SpotOrder 

type SpotOrder struct {
	MarketId string               `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	Order    types.SpotLimitOrder `protobuf:"bytes,2,opt,name=order,proto3" json:"order"`
}

func (*SpotOrder) Descriptor 

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

func (*SpotOrder) GetMarketId 

func (m *SpotOrder) GetMarketId() string

func (*SpotOrder) GetOrder 

func (m *SpotOrder) GetOrder() types.SpotLimitOrder

func (*SpotOrder) Marshal 

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

func (*SpotOrder) MarshalTo 

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

func (*SpotOrder) MarshalToSizedBuffer 

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

func (*SpotOrder) ProtoMessage 

func (*SpotOrder) ProtoMessage()

func (*SpotOrder) Reset 

func (m *SpotOrder) Reset()

func (*SpotOrder) Size 

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

func (*SpotOrder) String 

func (m *SpotOrder) String() string

func (*SpotOrder) Unmarshal 

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

func (*SpotOrder) XXX_DiscardUnknown 

func (m *SpotOrder) XXX_DiscardUnknown()

func (*SpotOrder) XXX_Marshal 

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

func (*SpotOrder) XXX_Merge 

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

func (*SpotOrder) XXX_Size 

func (m *SpotOrder) XXX_Size() int

func (*SpotOrder) XXX_Unmarshal 

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

type SpotOrderUpdate 

type SpotOrderUpdate struct {
	Status    OrderUpdateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=injective.stream.v1beta1.OrderUpdateStatus" json:"status,omitempty"`
	OrderHash []byte            `protobuf:"bytes,2,opt,name=order_hash,json=orderHash,proto3" json:"order_hash,omitempty"`
	Cid       string            `protobuf:"bytes,3,opt,name=cid,proto3" json:"cid,omitempty"`
	Order     *SpotOrder        `protobuf:"bytes,4,opt,name=order,proto3" json:"order,omitempty"`
}

func (*SpotOrderUpdate) Descriptor 

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

func (*SpotOrderUpdate) GetCid 

func (m *SpotOrderUpdate) GetCid() string

func (*SpotOrderUpdate) GetOrder 

func (m *SpotOrderUpdate) GetOrder() *SpotOrder

func (*SpotOrderUpdate) GetOrderHash 

func (m *SpotOrderUpdate) GetOrderHash() []byte

func (*SpotOrderUpdate) GetStatus 

func (m *SpotOrderUpdate) GetStatus() OrderUpdateStatus

func (*SpotOrderUpdate) Marshal 

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

func (*SpotOrderUpdate) MarshalTo 

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

func (*SpotOrderUpdate) MarshalToSizedBuffer 

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

func (*SpotOrderUpdate) ProtoMessage 

func (*SpotOrderUpdate) ProtoMessage()

func (*SpotOrderUpdate) Reset 

func (m *SpotOrderUpdate) Reset()

func (*SpotOrderUpdate) Size 

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

func (*SpotOrderUpdate) String 

func (m *SpotOrderUpdate) String() string

func (*SpotOrderUpdate) Unmarshal 

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

func (*SpotOrderUpdate) XXX_DiscardUnknown 

func (m *SpotOrderUpdate) XXX_DiscardUnknown()

func (*SpotOrderUpdate) XXX_Marshal 

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

func (*SpotOrderUpdate) XXX_Merge 

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

func (*SpotOrderUpdate) XXX_Size 

func (m *SpotOrderUpdate) XXX_Size() int

func (*SpotOrderUpdate) XXX_Unmarshal 

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

type SpotTrade 

type SpotTrade struct {
	MarketId      string                      `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	IsBuy         bool                        `protobuf:"varint,2,opt,name=is_buy,json=isBuy,proto3" json:"is_buy,omitempty"`
	ExecutionType string                      `protobuf:"bytes,3,opt,name=executionType,proto3" json:"executionType,omitempty"`
	Quantity      cosmossdk_io_math.LegacyDec `protobuf:"bytes,4,opt,name=quantity,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"quantity"`
	Price         cosmossdk_io_math.LegacyDec `protobuf:"bytes,5,opt,name=price,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"price"`
	// bytes32 subaccount ID that executed the trade
	SubaccountId        string                      `protobuf:"bytes,6,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	Fee                 cosmossdk_io_math.LegacyDec `protobuf:"bytes,7,opt,name=fee,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"fee"`
	OrderHash           []byte                      `protobuf:"bytes,8,opt,name=order_hash,json=orderHash,proto3" json:"order_hash,omitempty"`
	FeeRecipientAddress string                      `protobuf:"bytes,9,opt,name=fee_recipient_address,json=feeRecipientAddress,proto3" json:"fee_recipient_address,omitempty"`
	Cid                 string                      `protobuf:"bytes,10,opt,name=cid,proto3" json:"cid,omitempty"`
	TradeId             string                      `protobuf:"bytes,11,opt,name=trade_id,json=tradeId,proto3" json:"trade_id,omitempty"`
}

func (*SpotTrade) Descriptor 

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

func (*SpotTrade) GetCid 

func (m *SpotTrade) GetCid() string

func (*SpotTrade) GetExecutionType 

func (m *SpotTrade) GetExecutionType() string

func (*SpotTrade) GetFeeRecipientAddress 

func (m *SpotTrade) GetFeeRecipientAddress() string

func (*SpotTrade) GetIsBuy 

func (m *SpotTrade) GetIsBuy() bool

func (*SpotTrade) GetMarketId 

func (m *SpotTrade) GetMarketId() string

func (*SpotTrade) GetOrderHash 

func (m *SpotTrade) GetOrderHash() []byte

func (*SpotTrade) GetSubaccountId 

func (m *SpotTrade) GetSubaccountId() string

func (*SpotTrade) GetTradeId 

func (m *SpotTrade) GetTradeId() string

func (*SpotTrade) Marshal 

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

func (*SpotTrade) MarshalTo 

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

func (*SpotTrade) MarshalToSizedBuffer 

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

func (*SpotTrade) ProtoMessage 

func (*SpotTrade) ProtoMessage()

func (*SpotTrade) Reset 

func (m *SpotTrade) Reset()

func (*SpotTrade) Size 

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

func (*SpotTrade) String 

func (m *SpotTrade) String() string

func (*SpotTrade) Unmarshal 

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

func (*SpotTrade) XXX_DiscardUnknown 

func (m *SpotTrade) XXX_DiscardUnknown()

func (*SpotTrade) XXX_Marshal 

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

func (*SpotTrade) XXX_Merge 

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

func (*SpotTrade) XXX_Size 

func (m *SpotTrade) XXX_Size() int

func (*SpotTrade) XXX_Unmarshal 

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

type StreamClient 

type StreamClient interface {
	Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (Stream_StreamClient, error)
}

StreamClient is the client API for Stream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStreamClient 

func NewStreamClient(cc grpc1.ClientConn) StreamClient

type StreamRequest 

type StreamRequest struct {
	BankBalancesFilter         *BankBalancesFilter       `protobuf:"bytes,1,opt,name=bank_balances_filter,json=bankBalancesFilter,proto3" json:"bank_balances_filter,omitempty"`
	SubaccountDepositsFilter   *SubaccountDepositsFilter `` /* 135-byte string literal not displayed */
	SpotTradesFilter           *TradesFilter             `protobuf:"bytes,3,opt,name=spot_trades_filter,json=spotTradesFilter,proto3" json:"spot_trades_filter,omitempty"`
	DerivativeTradesFilter     *TradesFilter             `` /* 129-byte string literal not displayed */
	SpotOrdersFilter           *OrdersFilter             `protobuf:"bytes,5,opt,name=spot_orders_filter,json=spotOrdersFilter,proto3" json:"spot_orders_filter,omitempty"`
	DerivativeOrdersFilter     *OrdersFilter             `` /* 129-byte string literal not displayed */
	SpotOrderbooksFilter       *OrderbookFilter          `protobuf:"bytes,7,opt,name=spot_orderbooks_filter,json=spotOrderbooksFilter,proto3" json:"spot_orderbooks_filter,omitempty"`
	DerivativeOrderbooksFilter *OrderbookFilter          `` /* 141-byte string literal not displayed */
	PositionsFilter            *PositionsFilter          `protobuf:"bytes,9,opt,name=positions_filter,json=positionsFilter,proto3" json:"positions_filter,omitempty"`
	OraclePriceFilter          *OraclePriceFilter        `protobuf:"bytes,10,opt,name=oracle_price_filter,json=oraclePriceFilter,proto3" json:"oracle_price_filter,omitempty"`
}

func NewFullStreamRequest 

func NewFullStreamRequest() *StreamRequest

func (*StreamRequest) Descriptor 

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

func (*StreamRequest) GetBankBalancesFilter 

func (m *StreamRequest) GetBankBalancesFilter() *BankBalancesFilter

func (*StreamRequest) GetDerivativeOrderbooksFilter 

func (m *StreamRequest) GetDerivativeOrderbooksFilter() *OrderbookFilter

func (*StreamRequest) GetDerivativeOrdersFilter 

func (m *StreamRequest) GetDerivativeOrdersFilter() *OrdersFilter

func (*StreamRequest) GetDerivativeTradesFilter 

func (m *StreamRequest) GetDerivativeTradesFilter() *TradesFilter

func (*StreamRequest) GetOraclePriceFilter 

func (m *StreamRequest) GetOraclePriceFilter() *OraclePriceFilter

func (*StreamRequest) GetPositionsFilter 

func (m *StreamRequest) GetPositionsFilter() *PositionsFilter

func (*StreamRequest) GetSpotOrderbooksFilter 

func (m *StreamRequest) GetSpotOrderbooksFilter() *OrderbookFilter

func (*StreamRequest) GetSpotOrdersFilter 

func (m *StreamRequest) GetSpotOrdersFilter() *OrdersFilter

func (*StreamRequest) GetSpotTradesFilter 

func (m *StreamRequest) GetSpotTradesFilter() *TradesFilter

func (*StreamRequest) GetSubaccountDepositsFilter 

func (m *StreamRequest) GetSubaccountDepositsFilter() *SubaccountDepositsFilter

func (*StreamRequest) Marshal 

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

func (*StreamRequest) MarshalTo 

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

func (*StreamRequest) MarshalToSizedBuffer 

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

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) Reset 

func (m *StreamRequest) Reset()

func (*StreamRequest) Size 

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

func (*StreamRequest) String 

func (m *StreamRequest) String() string

func (*StreamRequest) Unmarshal 

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

func (*StreamRequest) Validate 

func (m *StreamRequest) Validate() error

func (*StreamRequest) XXX_DiscardUnknown 

func (m *StreamRequest) XXX_DiscardUnknown()

func (*StreamRequest) XXX_Marshal 

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

func (*StreamRequest) XXX_Merge 

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

func (*StreamRequest) XXX_Size 

func (m *StreamRequest) XXX_Size() int

func (*StreamRequest) XXX_Unmarshal 

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

type StreamResponse 

type StreamResponse struct {
	BlockHeight                uint64                   `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockTime                  int64                    `protobuf:"varint,2,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	BankBalances               []*BankBalance           `protobuf:"bytes,3,rep,name=bank_balances,json=bankBalances,proto3" json:"bank_balances,omitempty"`
	SubaccountDeposits         []*SubaccountDeposits    `protobuf:"bytes,4,rep,name=subaccount_deposits,json=subaccountDeposits,proto3" json:"subaccount_deposits,omitempty"`
	SpotTrades                 []*SpotTrade             `protobuf:"bytes,5,rep,name=spot_trades,json=spotTrades,proto3" json:"spot_trades,omitempty"`
	DerivativeTrades           []*DerivativeTrade       `protobuf:"bytes,6,rep,name=derivative_trades,json=derivativeTrades,proto3" json:"derivative_trades,omitempty"`
	SpotOrders                 []*SpotOrderUpdate       `protobuf:"bytes,7,rep,name=spot_orders,json=spotOrders,proto3" json:"spot_orders,omitempty"`
	DerivativeOrders           []*DerivativeOrderUpdate `protobuf:"bytes,8,rep,name=derivative_orders,json=derivativeOrders,proto3" json:"derivative_orders,omitempty"`
	SpotOrderbookUpdates       []*OrderbookUpdate       `protobuf:"bytes,9,rep,name=spot_orderbook_updates,json=spotOrderbookUpdates,proto3" json:"spot_orderbook_updates,omitempty"`
	DerivativeOrderbookUpdates []*OrderbookUpdate       `` /* 142-byte string literal not displayed */
	Positions                  []*Position              `protobuf:"bytes,11,rep,name=positions,proto3" json:"positions,omitempty"`
	OraclePrices               []*OraclePrice           `protobuf:"bytes,12,rep,name=oracle_prices,json=oraclePrices,proto3" json:"oracle_prices,omitempty"`
}

func NewChainStreamResponse 

func NewChainStreamResponse() *StreamResponse

func (*StreamResponse) Descriptor 

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

func (*StreamResponse) GetBankBalances 

func (m *StreamResponse) GetBankBalances() []*BankBalance

func (*StreamResponse) GetBlockHeight 

func (m *StreamResponse) GetBlockHeight() uint64

func (*StreamResponse) GetBlockTime 

func (m *StreamResponse) GetBlockTime() int64

func (*StreamResponse) GetDerivativeOrderbookUpdates 

func (m *StreamResponse) GetDerivativeOrderbookUpdates() []*OrderbookUpdate

func (*StreamResponse) GetDerivativeOrders 

func (m *StreamResponse) GetDerivativeOrders() []*DerivativeOrderUpdate

func (*StreamResponse) GetDerivativeTrades 

func (m *StreamResponse) GetDerivativeTrades() []*DerivativeTrade

func (*StreamResponse) GetOraclePrices 

func (m *StreamResponse) GetOraclePrices() []*OraclePrice

func (*StreamResponse) GetPositions 

func (m *StreamResponse) GetPositions() []*Position

func (*StreamResponse) GetSpotOrderbookUpdates 

func (m *StreamResponse) GetSpotOrderbookUpdates() []*OrderbookUpdate

func (*StreamResponse) GetSpotOrders 

func (m *StreamResponse) GetSpotOrders() []*SpotOrderUpdate

func (*StreamResponse) GetSpotTrades 

func (m *StreamResponse) GetSpotTrades() []*SpotTrade

func (*StreamResponse) GetSubaccountDeposits 

func (m *StreamResponse) GetSubaccountDeposits() []*SubaccountDeposits

func (*StreamResponse) Marshal 

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

func (*StreamResponse) MarshalTo 

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

func (*StreamResponse) MarshalToSizedBuffer 

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

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset 

func (m *StreamResponse) Reset()

func (*StreamResponse) Size 

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

func (*StreamResponse) String 

func (m *StreamResponse) String() string

func (*StreamResponse) Unmarshal 

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

func (*StreamResponse) XXX_DiscardUnknown 

func (m *StreamResponse) XXX_DiscardUnknown()

func (*StreamResponse) XXX_Marshal 

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

func (*StreamResponse) XXX_Merge 

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

func (*StreamResponse) XXX_Size 

func (m *StreamResponse) XXX_Size() int

func (*StreamResponse) XXX_Unmarshal 

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

type StreamResponseMap 

type StreamResponseMap struct {
	BlockHeight                          uint64
	BlockTime                            time.Time
	BankBalancesByAccount                map[string][]*BankBalance
	SpotOrdersBySubaccount               map[string][]*SpotOrderUpdate
	SpotOrdersByMarketID                 map[string][]*SpotOrderUpdate
	DerivativeOrdersBySubaccount         map[string][]*DerivativeOrderUpdate
	DerivativeOrdersByMarketID           map[string][]*DerivativeOrderUpdate
	SpotOrderbookUpdatesByMarketID       map[string][]*OrderbookUpdate
	DerivativeOrderbookUpdatesByMarketID map[string][]*OrderbookUpdate
	SubaccountDepositsBySubaccountID     map[string][]*SubaccountDeposits
	SpotTradesBySubaccount               map[string][]*SpotTrade
	SpotTradesByMarketID                 map[string][]*SpotTrade
	DerivativeTradesBySubaccount         map[string][]*DerivativeTrade
	DerivativeTradesByMarketID           map[string][]*DerivativeTrade
	PositionsBySubaccount                map[string][]*Position
	PositionsByMarketID                  map[string][]*Position
	OraclePriceBySymbol                  map[string][]*OraclePrice
	// contains filtered or unexported fields
}

func NewStreamResponseMap 

func NewStreamResponseMap() *StreamResponseMap

func (*StreamResponseMap) NextTradeEventNumber 

func (m *StreamResponseMap) NextTradeEventNumber() (tradeNumber uint64)

type StreamServer 

type StreamServer interface {
	Stream(*StreamRequest, Stream_StreamServer) error
}

StreamServer is the server API for Stream service.

type Stream_StreamClient 

type Stream_StreamClient interface {
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type Stream_StreamServer 

type Stream_StreamServer interface {
	Send(*StreamResponse) error
	grpc.ServerStream
}

type SubaccountDeposit 

type SubaccountDeposit struct {
	Denom   string        `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	Deposit types.Deposit `protobuf:"bytes,2,opt,name=deposit,proto3" json:"deposit"`
}

func (*SubaccountDeposit) Descriptor 

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

func (*SubaccountDeposit) GetDenom 

func (m *SubaccountDeposit) GetDenom() string

func (*SubaccountDeposit) GetDeposit 

func (m *SubaccountDeposit) GetDeposit() types.Deposit

func (*SubaccountDeposit) Marshal 

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

func (*SubaccountDeposit) MarshalTo 

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

func (*SubaccountDeposit) MarshalToSizedBuffer 

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

func (*SubaccountDeposit) ProtoMessage 

func (*SubaccountDeposit) ProtoMessage()

func (*SubaccountDeposit) Reset 

func (m *SubaccountDeposit) Reset()

func (*SubaccountDeposit) Size 

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

func (*SubaccountDeposit) String 

func (m *SubaccountDeposit) String() string

func (*SubaccountDeposit) Unmarshal 

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

func (*SubaccountDeposit) XXX_DiscardUnknown 

func (m *SubaccountDeposit) XXX_DiscardUnknown()

func (*SubaccountDeposit) XXX_Marshal 

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

func (*SubaccountDeposit) XXX_Merge 

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

func (*SubaccountDeposit) XXX_Size 

func (m *SubaccountDeposit) XXX_Size() int

func (*SubaccountDeposit) XXX_Unmarshal 

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

type SubaccountDeposits 

type SubaccountDeposits struct {
	SubaccountId string              `protobuf:"bytes,1,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	Deposits     []SubaccountDeposit `protobuf:"bytes,2,rep,name=deposits,proto3" json:"deposits"`
}

func (*SubaccountDeposits) Descriptor 

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

func (*SubaccountDeposits) GetDeposits 

func (m *SubaccountDeposits) GetDeposits() []SubaccountDeposit

func (*SubaccountDeposits) GetSubaccountId 

func (m *SubaccountDeposits) GetSubaccountId() string

func (*SubaccountDeposits) Marshal 

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

func (*SubaccountDeposits) MarshalTo 

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

func (*SubaccountDeposits) MarshalToSizedBuffer 

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

func (*SubaccountDeposits) ProtoMessage 

func (*SubaccountDeposits) ProtoMessage()

func (*SubaccountDeposits) Reset 

func (m *SubaccountDeposits) Reset()

func (*SubaccountDeposits) Size 

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

func (*SubaccountDeposits) String 

func (m *SubaccountDeposits) String() string

func (*SubaccountDeposits) Unmarshal 

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

func (*SubaccountDeposits) XXX_DiscardUnknown 

func (m *SubaccountDeposits) XXX_DiscardUnknown()

func (*SubaccountDeposits) XXX_Marshal 

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

func (*SubaccountDeposits) XXX_Merge 

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

func (*SubaccountDeposits) XXX_Size 

func (m *SubaccountDeposits) XXX_Size() int

func (*SubaccountDeposits) XXX_Unmarshal 

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

type SubaccountDepositsFilter 

type SubaccountDepositsFilter struct {
	SubaccountIds []string `protobuf:"bytes,1,rep,name=subaccount_ids,json=subaccountIds,proto3" json:"subaccount_ids,omitempty"`
}

func (*SubaccountDepositsFilter) Descriptor 

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

func (*SubaccountDepositsFilter) GetSubaccountIds 

func (m *SubaccountDepositsFilter) GetSubaccountIds() []string

func (*SubaccountDepositsFilter) Marshal 

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

func (*SubaccountDepositsFilter) MarshalTo 

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

func (*SubaccountDepositsFilter) MarshalToSizedBuffer 

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

func (*SubaccountDepositsFilter) ProtoMessage 

func (*SubaccountDepositsFilter) ProtoMessage()

func (*SubaccountDepositsFilter) Reset 

func (m *SubaccountDepositsFilter) Reset()

func (*SubaccountDepositsFilter) Size 

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

func (*SubaccountDepositsFilter) String 

func (m *SubaccountDepositsFilter) String() string

func (*SubaccountDepositsFilter) Unmarshal 

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

func (*SubaccountDepositsFilter) XXX_DiscardUnknown 

func (m *SubaccountDepositsFilter) XXX_DiscardUnknown()

func (*SubaccountDepositsFilter) XXX_Marshal 

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

func (*SubaccountDepositsFilter) XXX_Merge 

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

func (*SubaccountDepositsFilter) XXX_Size 

func (m *SubaccountDepositsFilter) XXX_Size() int

func (*SubaccountDepositsFilter) XXX_Unmarshal 

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

type TradesFilter 

type TradesFilter struct {
	SubaccountIds []string `protobuf:"bytes,1,rep,name=subaccount_ids,json=subaccountIds,proto3" json:"subaccount_ids,omitempty"`
	MarketIds     []string `protobuf:"bytes,2,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
}

func (*TradesFilter) Descriptor 

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

func (*TradesFilter) GetMarketIds 

func (m *TradesFilter) GetMarketIds() []string

func (*TradesFilter) GetSubaccountIds 

func (m *TradesFilter) GetSubaccountIds() []string

func (*TradesFilter) Marshal 

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

func (*TradesFilter) MarshalTo 

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

func (*TradesFilter) MarshalToSizedBuffer 

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

func (*TradesFilter) ProtoMessage 

func (*TradesFilter) ProtoMessage()

func (*TradesFilter) Reset 

func (m *TradesFilter) Reset()

func (*TradesFilter) Size 

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

func (*TradesFilter) String 

func (m *TradesFilter) String() string

func (*TradesFilter) Unmarshal 

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

func (*TradesFilter) XXX_DiscardUnknown 

func (m *TradesFilter) XXX_DiscardUnknown()

func (*TradesFilter) XXX_Marshal 

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

func (*TradesFilter) XXX_Merge 

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

func (*TradesFilter) XXX_Size 

func (m *TradesFilter) XXX_Size() int

func (*TradesFilter) XXX_Unmarshal 

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

type UnimplementedStreamServer 

type UnimplementedStreamServer struct {
}

UnimplementedStreamServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamServer) Stream 

func (*UnimplementedStreamServer) Stream(req *StreamRequest, srv Stream_StreamServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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