Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

types

package

Go to main page

Versions in this module

v1

v1.50.1

Jan 25, 2024

v1.50.0

Jan 17, 2024

v1.49.1-rc.1

Jan 11, 2024

v1.49.0

Jan 8, 2024

Changes in this version

+ var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")

+ var OrderUpdateStatus_name = map[int32]string

+ var OrderUpdateStatus_value = map[string]int32

+ func RegisterStreamServer(s grpc1.Server, srv StreamServer)

+ type BankBalance struct

+ Account string

+ Balances github_com_cosmos_cosmos_sdk_types.Coins

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

+ func (*BankBalance) ProtoMessage()

+ func (m *BankBalance) GetAccount() string

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

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

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

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

+ func (m *BankBalance) Reset()

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

+ func (m *BankBalance) String() string

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

+ func (m *BankBalance) XXX_DiscardUnknown()

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

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

+ func (m *BankBalance) XXX_Size() int

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

+ type BankBalancesFilter struct

+ Accounts []string

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

+ func (*BankBalancesFilter) ProtoMessage()

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

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

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

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

+ func (m *BankBalancesFilter) Reset()

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

+ func (m *BankBalancesFilter) String() string

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

+ func (m *BankBalancesFilter) XXX_DiscardUnknown()

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

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

+ func (m *BankBalancesFilter) XXX_Size() int

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

+ type DerivativeOrder struct

+ IsMarket bool

+ MarketId string

+ Order types.DerivativeLimitOrder

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

+ func (*DerivativeOrder) ProtoMessage()

+ func (m *DerivativeOrder) GetIsMarket() bool

+ func (m *DerivativeOrder) GetMarketId() string

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

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

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

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

+ func (m *DerivativeOrder) Reset()

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

+ func (m *DerivativeOrder) String() string

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

+ func (m *DerivativeOrder) XXX_DiscardUnknown()

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

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

+ func (m *DerivativeOrder) XXX_Size() int

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

+ type DerivativeOrderUpdate struct

+ Cid string

+ Order *DerivativeOrder

+ OrderHash []byte

+ Status OrderUpdateStatus

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

+ func (*DerivativeOrderUpdate) ProtoMessage()

+ func (m *DerivativeOrderUpdate) GetCid() string

+ func (m *DerivativeOrderUpdate) GetOrder() *DerivativeOrder

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

+ func (m *DerivativeOrderUpdate) GetStatus() OrderUpdateStatus

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

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

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

+ func (m *DerivativeOrderUpdate) Reset()

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

+ func (m *DerivativeOrderUpdate) String() string

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

+ func (m *DerivativeOrderUpdate) XXX_DiscardUnknown()

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

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

+ func (m *DerivativeOrderUpdate) XXX_Size() int

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

+ type DerivativeTrade struct

+ Cid string

+ ExecutionType string

+ Fee github_com_cosmos_cosmos_sdk_types.Dec

+ FeeRecipientAddress string

+ IsBuy bool

+ MarketId string

+ OrderHash string

+ Payout github_com_cosmos_cosmos_sdk_types.Dec

+ PositionDelta *types.PositionDelta

+ SubaccountId string

+ TradeId string

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

+ func (*DerivativeTrade) ProtoMessage()

+ func (m *DerivativeTrade) GetCid() string

+ func (m *DerivativeTrade) GetExecutionType() string

+ func (m *DerivativeTrade) GetFeeRecipientAddress() string

+ func (m *DerivativeTrade) GetIsBuy() bool

+ func (m *DerivativeTrade) GetMarketId() string

+ func (m *DerivativeTrade) GetOrderHash() string

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

+ func (m *DerivativeTrade) GetSubaccountId() string

+ func (m *DerivativeTrade) GetTradeId() string

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

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

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

+ func (m *DerivativeTrade) Reset()

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

+ func (m *DerivativeTrade) String() string

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

+ func (m *DerivativeTrade) XXX_DiscardUnknown()

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

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

+ func (m *DerivativeTrade) XXX_Size() int

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

+ type OraclePrice struct

+ Price github_com_cosmos_cosmos_sdk_types.Dec

+ Symbol string

+ Type string

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

+ func (*OraclePrice) ProtoMessage()

+ func (m *OraclePrice) GetSymbol() string

+ func (m *OraclePrice) GetType() string

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

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

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

+ func (m *OraclePrice) Reset()

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

+ func (m *OraclePrice) String() string

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

+ func (m *OraclePrice) XXX_DiscardUnknown()

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

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

+ func (m *OraclePrice) XXX_Size() int

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

+ type OraclePriceFilter struct

+ Symbol []string

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

+ func (*OraclePriceFilter) ProtoMessage()

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

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

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

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

+ func (m *OraclePriceFilter) Reset()

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

+ func (m *OraclePriceFilter) String() string

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

+ func (m *OraclePriceFilter) XXX_DiscardUnknown()

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

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

+ func (m *OraclePriceFilter) XXX_Size() int

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

+ type OrderUpdateStatus int32

+ const OrderUpdateStatus_Booked

+ const OrderUpdateStatus_Cancelled

+ const OrderUpdateStatus_Matched

+ const OrderUpdateStatus_Unspecified

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

+ func (x OrderUpdateStatus) String() string

+ type Orderbook struct

+ BuyLevels []*types.Level

+ MarketId string

+ SellLevels []*types.Level

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

+ func (*Orderbook) ProtoMessage()

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

+ func (m *Orderbook) GetMarketId() string

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

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

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

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

+ func (m *Orderbook) Reset()

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

+ func (m *Orderbook) String() string

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

+ func (m *Orderbook) XXX_DiscardUnknown()

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

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

+ func (m *Orderbook) XXX_Size() int

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

+ type OrderbookFilter struct

+ MarketIds []string

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

+ func (*OrderbookFilter) ProtoMessage()

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

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

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

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

+ func (m *OrderbookFilter) Reset()

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

+ func (m *OrderbookFilter) String() string

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

+ func (m *OrderbookFilter) XXX_DiscardUnknown()

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

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

+ func (m *OrderbookFilter) XXX_Size() int

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

+ type OrderbookUpdate struct

+ Orderbook *Orderbook

+ Seq uint64

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

+ func (*OrderbookUpdate) ProtoMessage()

+ func (m *OrderbookUpdate) GetOrderbook() *Orderbook

+ func (m *OrderbookUpdate) GetSeq() uint64

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

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

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

+ func (m *OrderbookUpdate) Reset()

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

+ func (m *OrderbookUpdate) String() string

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

+ func (m *OrderbookUpdate) XXX_DiscardUnknown()

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

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

+ func (m *OrderbookUpdate) XXX_Size() int

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

+ type OrdersFilter struct

+ MarketIds []string

+ SubaccountIds []string

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

+ func (*OrdersFilter) ProtoMessage()

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

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

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

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

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

+ func (m *OrdersFilter) Reset()

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

+ func (m *OrdersFilter) String() string

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

+ func (m *OrdersFilter) XXX_DiscardUnknown()

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

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

+ func (m *OrdersFilter) XXX_Size() int

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

+ type Position struct

+ CumulativeFundingEntry github_com_cosmos_cosmos_sdk_types.Dec

+ EntryPrice github_com_cosmos_cosmos_sdk_types.Dec

+ IsLong bool

+ Margin github_com_cosmos_cosmos_sdk_types.Dec

+ MarketId string

+ Quantity github_com_cosmos_cosmos_sdk_types.Dec

+ SubaccountId string

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

+ func (*Position) ProtoMessage()

+ func (m *Position) GetIsLong() bool

+ func (m *Position) GetMarketId() string

+ func (m *Position) GetSubaccountId() string

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

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

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

+ func (m *Position) Reset()

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

+ func (m *Position) String() string

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

+ func (m *Position) XXX_DiscardUnknown()

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

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

+ func (m *Position) XXX_Size() int

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

+ type PositionsFilter struct

+ MarketIds []string

+ SubaccountIds []string

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

+ func (*PositionsFilter) ProtoMessage()

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

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

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

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

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

+ func (m *PositionsFilter) Reset()

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

+ func (m *PositionsFilter) String() string

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

+ func (m *PositionsFilter) XXX_DiscardUnknown()

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

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

+ func (m *PositionsFilter) XXX_Size() int

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

+ type SpotOrder struct

+ MarketId string

+ Order types.SpotLimitOrder

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

+ func (*SpotOrder) ProtoMessage()

+ func (m *SpotOrder) GetMarketId() string

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

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

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

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

+ func (m *SpotOrder) Reset()

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

+ func (m *SpotOrder) String() string

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

+ func (m *SpotOrder) XXX_DiscardUnknown()

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

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

+ func (m *SpotOrder) XXX_Size() int

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

+ type SpotOrderUpdate struct

+ Cid string

+ Order *SpotOrder

+ OrderHash []byte

+ Status OrderUpdateStatus

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

+ func (*SpotOrderUpdate) ProtoMessage()

+ func (m *SpotOrderUpdate) GetCid() string

+ func (m *SpotOrderUpdate) GetOrder() *SpotOrder

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

+ func (m *SpotOrderUpdate) GetStatus() OrderUpdateStatus

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

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

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

+ func (m *SpotOrderUpdate) Reset()

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

+ func (m *SpotOrderUpdate) String() string

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

+ func (m *SpotOrderUpdate) XXX_DiscardUnknown()

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

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

+ func (m *SpotOrderUpdate) XXX_Size() int

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

+ type SpotTrade struct

+ Cid string

+ ExecutionType string

+ Fee github_com_cosmos_cosmos_sdk_types.Dec

+ FeeRecipientAddress string

+ IsBuy bool

+ MarketId string

+ OrderHash []byte

+ Price github_com_cosmos_cosmos_sdk_types.Dec

+ Quantity github_com_cosmos_cosmos_sdk_types.Dec

+ SubaccountId string

+ TradeId string

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

+ func (*SpotTrade) ProtoMessage()

+ func (m *SpotTrade) GetCid() string

+ func (m *SpotTrade) GetExecutionType() string

+ func (m *SpotTrade) GetFeeRecipientAddress() string

+ func (m *SpotTrade) GetIsBuy() bool

+ func (m *SpotTrade) GetMarketId() string

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

+ func (m *SpotTrade) GetSubaccountId() string

+ func (m *SpotTrade) GetTradeId() string

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

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

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

+ func (m *SpotTrade) Reset()

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

+ func (m *SpotTrade) String() string

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

+ func (m *SpotTrade) XXX_DiscardUnknown()

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

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

+ func (m *SpotTrade) XXX_Size() int

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

+ type StreamClient interface

+ Stream func(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (Stream_StreamClient, error)

+ func NewStreamClient(cc grpc1.ClientConn) StreamClient

+ type StreamRequest struct

+ BankBalancesFilter *BankBalancesFilter

+ DerivativeOrderbooksFilter *OrderbookFilter

+ DerivativeOrdersFilter *OrdersFilter

+ DerivativeTradesFilter *TradesFilter

+ OraclePriceFilter *OraclePriceFilter

+ PositionsFilter *PositionsFilter

+ SpotOrderbooksFilter *OrderbookFilter

+ SpotOrdersFilter *OrdersFilter

+ SpotTradesFilter *TradesFilter

+ SubaccountDepositsFilter *SubaccountDepositsFilter

+ func NewFullStreamRequest() *StreamRequest

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

+ func (*StreamRequest) ProtoMessage()

+ func (m *StreamRequest) GetBankBalancesFilter() *BankBalancesFilter

+ func (m *StreamRequest) GetDerivativeOrderbooksFilter() *OrderbookFilter

+ func (m *StreamRequest) GetDerivativeOrdersFilter() *OrdersFilter

+ func (m *StreamRequest) GetDerivativeTradesFilter() *TradesFilter

+ func (m *StreamRequest) GetOraclePriceFilter() *OraclePriceFilter

+ func (m *StreamRequest) GetPositionsFilter() *PositionsFilter

+ func (m *StreamRequest) GetSpotOrderbooksFilter() *OrderbookFilter

+ func (m *StreamRequest) GetSpotOrdersFilter() *OrdersFilter

+ func (m *StreamRequest) GetSpotTradesFilter() *TradesFilter

+ func (m *StreamRequest) GetSubaccountDepositsFilter() *SubaccountDepositsFilter

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

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

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

+ func (m *StreamRequest) Reset()

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

+ func (m *StreamRequest) String() string

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

+ func (m *StreamRequest) Validate() error

+ func (m *StreamRequest) XXX_DiscardUnknown()

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

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

+ func (m *StreamRequest) XXX_Size() int

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

+ type StreamResponse struct

+ BankBalances []*BankBalance

+ BlockHeight uint64

+ BlockTime int64

+ DerivativeOrderbookUpdates []*OrderbookUpdate

+ DerivativeOrders []*DerivativeOrderUpdate

+ DerivativeTrades []*DerivativeTrade

+ OraclePrices []*OraclePrice

+ Positions []*Position

+ SpotOrderbookUpdates []*OrderbookUpdate

+ SpotOrders []*SpotOrderUpdate

+ SpotTrades []*SpotTrade

+ SubaccountDeposits []*SubaccountDeposits

+ func NewChainStreamResponse() *StreamResponse

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

+ func (*StreamResponse) ProtoMessage()

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

+ func (m *StreamResponse) GetBlockHeight() uint64

+ func (m *StreamResponse) GetBlockTime() int64

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

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

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

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

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

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

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

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

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

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

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

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

+ func (m *StreamResponse) Reset()

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

+ func (m *StreamResponse) String() string

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

+ func (m *StreamResponse) XXX_DiscardUnknown()

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

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

+ func (m *StreamResponse) XXX_Size() int

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

+ type StreamResponseMap struct

+ BankBalancesByAccount map[string][]*BankBalance

+ BlockHeight uint64

+ BlockTime time.Time

+ DerivativeOrderbookUpdatesByMarketID map[string][]*OrderbookUpdate

+ DerivativeOrdersByMarketID map[string][]*DerivativeOrderUpdate

+ DerivativeOrdersBySubaccount map[string][]*DerivativeOrderUpdate

+ DerivativeTradesByMarketID map[string][]*DerivativeTrade

+ DerivativeTradesBySubaccount map[string][]*DerivativeTrade

+ OraclePriceBySymbol map[string][]*OraclePrice

+ PositionsByMarketID map[string][]*Position

+ PositionsBySubaccount map[string][]*Position

+ SpotOrderbookUpdatesByMarketID map[string][]*OrderbookUpdate

+ SpotOrdersByMarketID map[string][]*SpotOrderUpdate

+ SpotOrdersBySubaccount map[string][]*SpotOrderUpdate

+ SpotTradesByMarketID map[string][]*SpotTrade

+ SpotTradesBySubaccount map[string][]*SpotTrade

+ SubaccountDepositsBySubaccountID map[string][]*SubaccountDeposits

+ func NewStreamResponseMap() *StreamResponseMap

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

+ type StreamServer interface

+ Stream func(*StreamRequest, Stream_StreamServer) error

+ type Stream_StreamClient interface

+ Recv func() (*StreamResponse, error)

+ type Stream_StreamServer interface

+ Send func(*StreamResponse) error

+ type SubaccountDeposit struct

+ Denom string

+ Deposit types.Deposit

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

+ func (*SubaccountDeposit) ProtoMessage()

+ func (m *SubaccountDeposit) GetDenom() string

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

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

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

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

+ func (m *SubaccountDeposit) Reset()

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

+ func (m *SubaccountDeposit) String() string

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

+ func (m *SubaccountDeposit) XXX_DiscardUnknown()

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

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

+ func (m *SubaccountDeposit) XXX_Size() int

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

+ type SubaccountDeposits struct

+ Deposits []SubaccountDeposit

+ SubaccountId string

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

+ func (*SubaccountDeposits) ProtoMessage()

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

+ func (m *SubaccountDeposits) GetSubaccountId() string

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

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

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

+ func (m *SubaccountDeposits) Reset()

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

+ func (m *SubaccountDeposits) String() string

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

+ func (m *SubaccountDeposits) XXX_DiscardUnknown()

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

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

+ func (m *SubaccountDeposits) XXX_Size() int

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

+ type SubaccountDepositsFilter struct

+ SubaccountIds []string

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

+ func (*SubaccountDepositsFilter) ProtoMessage()

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

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

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

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

+ func (m *SubaccountDepositsFilter) Reset()

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

+ func (m *SubaccountDepositsFilter) String() string

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

+ func (m *SubaccountDepositsFilter) XXX_DiscardUnknown()

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

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

+ func (m *SubaccountDepositsFilter) XXX_Size() int

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

+ type TradesFilter struct

+ MarketIds []string

+ SubaccountIds []string

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

+ func (*TradesFilter) ProtoMessage()

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

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

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

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

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

+ func (m *TradesFilter) Reset()

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

+ func (m *TradesFilter) String() string

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

+ func (m *TradesFilter) XXX_DiscardUnknown()

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

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

+ func (m *TradesFilter) XXX_Size() int

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

+ type UnimplementedStreamServer struct

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

v1.49.0-rc3.1

Dec 28, 2023

v1.49.0-rc3

Dec 28, 2023

v1.49.0-rc2.1

Dec 8, 2023

v1.49.0-rc2

Nov 28, 2023

v1.49.0-rc1

Nov 7, 2023