api

package
v0.42.0-pre4 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2021 License: MIT Imports: 17 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var SubmitTransactionV2Request_Type_name = map[int32]string{
	0: "TYPE_UNSPECIFIED",
	1: "TYPE_ASYNC",
	2: "TYPE_SYNC",
	3: "TYPE_COMMIT",
}
View Source 
var SubmitTransactionV2Request_Type_value = map[string]int32{
	"TYPE_UNSPECIFIED": 0,
	"TYPE_ASYNC":       1,
	"TYPE_SYNC":        2,
	"TYPE_COMMIT":      3,
}

Functions

func RegisterTradingServiceHandler 

func RegisterTradingServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterTradingServiceHandler registers the http handlers for service TradingService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTradingServiceHandlerClient 

func RegisterTradingServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TradingServiceClient) error

RegisterTradingServiceHandlerClient registers the http handlers for service TradingService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TradingServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TradingServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TradingServiceClient" to call the correct interceptors.

func RegisterTradingServiceHandlerFromEndpoint 

func RegisterTradingServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTradingServiceHandlerFromEndpoint is same as RegisterTradingServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTradingServiceServer 

func RegisterTradingServiceServer(s *grpc.Server, srv TradingServiceServer)

Types

type GetVegaTimeRequest 

type GetVegaTimeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the current time of the vega network

func (*GetVegaTimeRequest) Descriptor 

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

func (*GetVegaTimeRequest) ProtoMessage 

func (*GetVegaTimeRequest) ProtoMessage()

func (*GetVegaTimeRequest) Reset 

func (m *GetVegaTimeRequest) Reset()

func (*GetVegaTimeRequest) String 

func (m *GetVegaTimeRequest) String() string

func (*GetVegaTimeRequest) Validate 

func (this *GetVegaTimeRequest) Validate() error

func (*GetVegaTimeRequest) XXX_DiscardUnknown 

func (m *GetVegaTimeRequest) XXX_DiscardUnknown()

func (*GetVegaTimeRequest) XXX_Marshal 

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

func (*GetVegaTimeRequest) XXX_Merge 

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

func (*GetVegaTimeRequest) XXX_Size 

func (m *GetVegaTimeRequest) XXX_Size() int

func (*GetVegaTimeRequest) XXX_Unmarshal 

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

type GetVegaTimeResponse 

type GetVegaTimeResponse struct {
	// Timestamp representation of current VegaTime as represented in
	// Nanoseconds since the epoch, for example `1580473859111222333` corresponds to `2020-01-31T12:30:59.111222333Z`
	Timestamp            int64    `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for the current consensus coordinated time on the Vega network, referred to as "VegaTime"

func (*GetVegaTimeResponse) Descriptor 

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

func (*GetVegaTimeResponse) GetTimestamp 

func (m *GetVegaTimeResponse) GetTimestamp() int64

func (*GetVegaTimeResponse) ProtoMessage 

func (*GetVegaTimeResponse) ProtoMessage()

func (*GetVegaTimeResponse) Reset 

func (m *GetVegaTimeResponse) Reset()

func (*GetVegaTimeResponse) String 

func (m *GetVegaTimeResponse) String() string

func (*GetVegaTimeResponse) Validate 

func (this *GetVegaTimeResponse) Validate() error

func (*GetVegaTimeResponse) XXX_DiscardUnknown 

func (m *GetVegaTimeResponse) XXX_DiscardUnknown()

func (*GetVegaTimeResponse) XXX_Marshal 

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

func (*GetVegaTimeResponse) XXX_Merge 

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

func (*GetVegaTimeResponse) XXX_Size 

func (m *GetVegaTimeResponse) XXX_Size() int

func (*GetVegaTimeResponse) XXX_Unmarshal 

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

type LastBlockHeightRequest 

type LastBlockHeightRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A request to get the height of the very last block processed by tendermint

func (*LastBlockHeightRequest) Descriptor 

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

func (*LastBlockHeightRequest) ProtoMessage 

func (*LastBlockHeightRequest) ProtoMessage()

func (*LastBlockHeightRequest) Reset 

func (m *LastBlockHeightRequest) Reset()

func (*LastBlockHeightRequest) String 

func (m *LastBlockHeightRequest) String() string

func (*LastBlockHeightRequest) Validate 

func (this *LastBlockHeightRequest) Validate() error

func (*LastBlockHeightRequest) XXX_DiscardUnknown 

func (m *LastBlockHeightRequest) XXX_DiscardUnknown()

func (*LastBlockHeightRequest) XXX_Marshal 

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

func (*LastBlockHeightRequest) XXX_Merge 

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

func (*LastBlockHeightRequest) XXX_Size 

func (m *LastBlockHeightRequest) XXX_Size() int

func (*LastBlockHeightRequest) XXX_Unmarshal 

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

type LastBlockHeightResponse 

type LastBlockHeightResponse struct {
	Height               uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A response with the height of the last block processed by tendermint

func (*LastBlockHeightResponse) Descriptor 

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

func (*LastBlockHeightResponse) GetHeight 

func (m *LastBlockHeightResponse) GetHeight() uint64

func (*LastBlockHeightResponse) ProtoMessage 

func (*LastBlockHeightResponse) ProtoMessage()

func (*LastBlockHeightResponse) Reset 

func (m *LastBlockHeightResponse) Reset()

func (*LastBlockHeightResponse) String 

func (m *LastBlockHeightResponse) String() string

func (*LastBlockHeightResponse) Validate 

func (this *LastBlockHeightResponse) Validate() error

func (*LastBlockHeightResponse) XXX_DiscardUnknown 

func (m *LastBlockHeightResponse) XXX_DiscardUnknown()

func (*LastBlockHeightResponse) XXX_Marshal 

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

func (*LastBlockHeightResponse) XXX_Merge 

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

func (*LastBlockHeightResponse) XXX_Size 

func (m *LastBlockHeightResponse) XXX_Size() int

func (*LastBlockHeightResponse) XXX_Unmarshal 

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

type ObserveEventBusRequest 

type ObserveEventBusRequest struct {
	// One or more types of event, required field
	Type []v11.BusEventType `protobuf:"varint,1,rep,packed,name=type,proto3,enum=vega.events.v1.BusEventType" json:"type,omitempty"`
	// Market identifier, optional field
	MarketId string `protobuf:"bytes,2,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Party identifier, optional field
	PartyId string `protobuf:"bytes,3,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	// Batch size, optional field -
	// If not specified, any events received will be sent immediately. If the client is not ready
	// for the next data-set, data may be dropped a number of times, and eventually the stream is closed.
	// if specified, the first batch will be sent when ready. To receive the next set of events, the client
	// must write an `ObserveEventBatch` message on the stream to flush the buffer.
	// If no message is received in 5 seconds, the stream is closed.
	// Default: 0, send any and all events when they are available.
	BatchSize            int64    `protobuf:"varint,4,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to subscribe to a stream of one or more event types from the Vega event bus

func (*ObserveEventBusRequest) Descriptor 

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

func (*ObserveEventBusRequest) GetBatchSize 

func (m *ObserveEventBusRequest) GetBatchSize() int64

func (*ObserveEventBusRequest) GetMarketId 

func (m *ObserveEventBusRequest) GetMarketId() string

func (*ObserveEventBusRequest) GetPartyId 

func (m *ObserveEventBusRequest) GetPartyId() string

func (*ObserveEventBusRequest) GetType 

func (m *ObserveEventBusRequest) GetType() []v11.BusEventType

func (*ObserveEventBusRequest) ProtoMessage 

func (*ObserveEventBusRequest) ProtoMessage()

func (*ObserveEventBusRequest) Reset 

func (m *ObserveEventBusRequest) Reset()

func (*ObserveEventBusRequest) String 

func (m *ObserveEventBusRequest) String() string

func (*ObserveEventBusRequest) Validate 

func (this *ObserveEventBusRequest) Validate() error

func (*ObserveEventBusRequest) XXX_DiscardUnknown 

func (m *ObserveEventBusRequest) XXX_DiscardUnknown()

func (*ObserveEventBusRequest) XXX_Marshal 

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

func (*ObserveEventBusRequest) XXX_Merge 

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

func (*ObserveEventBusRequest) XXX_Size 

func (m *ObserveEventBusRequest) XXX_Size() int

func (*ObserveEventBusRequest) XXX_Unmarshal 

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

type ObserveEventBusResponse 

type ObserveEventBusResponse struct {
	// One or more events
	Events               []*v11.BusEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Response to a subscribed stream of events from the Vega event bus

func (*ObserveEventBusResponse) Descriptor 

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

func (*ObserveEventBusResponse) GetEvents 

func (m *ObserveEventBusResponse) GetEvents() []*v11.BusEvent

func (*ObserveEventBusResponse) ProtoMessage 

func (*ObserveEventBusResponse) ProtoMessage()

func (*ObserveEventBusResponse) Reset 

func (m *ObserveEventBusResponse) Reset()

func (*ObserveEventBusResponse) String 

func (m *ObserveEventBusResponse) String() string

func (*ObserveEventBusResponse) Validate 

func (this *ObserveEventBusResponse) Validate() error

func (*ObserveEventBusResponse) XXX_DiscardUnknown 

func (m *ObserveEventBusResponse) XXX_DiscardUnknown()

func (*ObserveEventBusResponse) XXX_Marshal 

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

func (*ObserveEventBusResponse) XXX_Merge 

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

func (*ObserveEventBusResponse) XXX_Size 

func (m *ObserveEventBusResponse) XXX_Size() int

func (*ObserveEventBusResponse) XXX_Unmarshal 

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

type PropagateChainEventRequest 

type PropagateChainEventRequest struct {
	// Chain event
	Event []byte `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// Public key
	PubKey string `protobuf:"bytes,2,opt,name=pub_key,json=pubKey,proto3" json:"pub_key,omitempty"`
	// Signature
	Signature            []byte   `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for a new event sent by the blockchain queue to be propagated on Vega

func (*PropagateChainEventRequest) Descriptor 

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

func (*PropagateChainEventRequest) GetEvent added in v0.42.0 

func (m *PropagateChainEventRequest) GetEvent() []byte

func (*PropagateChainEventRequest) GetPubKey 

func (m *PropagateChainEventRequest) GetPubKey() string

func (*PropagateChainEventRequest) GetSignature 

func (m *PropagateChainEventRequest) GetSignature() []byte

func (*PropagateChainEventRequest) ProtoMessage 

func (*PropagateChainEventRequest) ProtoMessage()

func (*PropagateChainEventRequest) Reset 

func (m *PropagateChainEventRequest) Reset()

func (*PropagateChainEventRequest) String 

func (m *PropagateChainEventRequest) String() string

func (*PropagateChainEventRequest) Validate 

func (this *PropagateChainEventRequest) Validate() error

func (*PropagateChainEventRequest) XXX_DiscardUnknown 

func (m *PropagateChainEventRequest) XXX_DiscardUnknown()

func (*PropagateChainEventRequest) XXX_Marshal 

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

func (*PropagateChainEventRequest) XXX_Merge 

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

func (*PropagateChainEventRequest) XXX_Size 

func (m *PropagateChainEventRequest) XXX_Size() int

func (*PropagateChainEventRequest) XXX_Unmarshal 

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

type PropagateChainEventResponse 

type PropagateChainEventResponse struct {
	// Success will be true if the event was accepted by the node,
	// **Important** - success does not mean that the event is confirmed by consensus
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for a new event sent by the blockchain queue to be propagated on Vega

func (*PropagateChainEventResponse) Descriptor 

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

func (*PropagateChainEventResponse) GetSuccess 

func (m *PropagateChainEventResponse) GetSuccess() bool

func (*PropagateChainEventResponse) ProtoMessage 

func (*PropagateChainEventResponse) ProtoMessage()

func (*PropagateChainEventResponse) Reset 

func (m *PropagateChainEventResponse) Reset()

func (*PropagateChainEventResponse) String 

func (m *PropagateChainEventResponse) String() string

func (*PropagateChainEventResponse) Validate 

func (this *PropagateChainEventResponse) Validate() error

func (*PropagateChainEventResponse) XXX_DiscardUnknown 

func (m *PropagateChainEventResponse) XXX_DiscardUnknown()

func (*PropagateChainEventResponse) XXX_Marshal 

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

func (*PropagateChainEventResponse) XXX_Merge 

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

func (*PropagateChainEventResponse) XXX_Size 

func (m *PropagateChainEventResponse) XXX_Size() int

func (*PropagateChainEventResponse) XXX_Unmarshal 

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

type Statistics added in v0.42.0 

type Statistics struct {
	// Current block height as reported by the Vega blockchain
	BlockHeight uint64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// Current backlog length (number of transactions) that are waiting to be included in a block
	BacklogLength uint64 `protobuf:"varint,2,opt,name=backlog_length,json=backlogLength,proto3" json:"backlog_length,omitempty"`
	// Total number of connected peers to this node
	TotalPeers uint64 `protobuf:"varint,3,opt,name=total_peers,json=totalPeers,proto3" json:"total_peers,omitempty"`
	// Genesis block date and time formatted in ISO-8601 datetime format with nanosecond precision
	GenesisTime string `protobuf:"bytes,4,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"`
	// Current system date and time formatted in ISO-8601 datetime format with nanosecond precision
	CurrentTime string `protobuf:"bytes,5,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"`
	// Current Vega date and time formatted in ISO-8601 datetime format with nanosecond precision
	VegaTime string `protobuf:"bytes,6,opt,name=vega_time,json=vegaTime,proto3" json:"vega_time,omitempty"`
	// Status of the connection to the Vega blockchain
	// - See [`ChainStatus`](#vega.ChainStatus)
	Status vega.ChainStatus `protobuf:"varint,7,opt,name=status,proto3,enum=vega.ChainStatus" json:"status,omitempty"`
	// Transactions per block
	TxPerBlock uint64 `protobuf:"varint,8,opt,name=tx_per_block,json=txPerBlock,proto3" json:"tx_per_block,omitempty"`
	// Average transaction size in bytes
	AverageTxBytes uint64 `protobuf:"varint,9,opt,name=average_tx_bytes,json=averageTxBytes,proto3" json:"average_tx_bytes,omitempty"`
	// Average orders per block
	AverageOrdersPerBlock uint64 `` /* 130-byte string literal not displayed */
	// Trades emitted per second
	TradesPerSecond uint64 `protobuf:"varint,11,opt,name=trades_per_second,json=tradesPerSecond,proto3" json:"trades_per_second,omitempty"`
	// Orders processed per second
	OrdersPerSecond uint64 `protobuf:"varint,12,opt,name=orders_per_second,json=ordersPerSecond,proto3" json:"orders_per_second,omitempty"`
	// Total markets on this Vega network
	TotalMarkets uint64 `protobuf:"varint,13,opt,name=total_markets,json=totalMarkets,proto3" json:"total_markets,omitempty"`
	// Total number of order amendments since genesis (on all markets)
	TotalAmendOrder uint64 `protobuf:"varint,16,opt,name=total_amend_order,json=totalAmendOrder,proto3" json:"total_amend_order,omitempty"`
	// Total number of order cancellations since genesis (on all markets)
	TotalCancelOrder uint64 `protobuf:"varint,17,opt,name=total_cancel_order,json=totalCancelOrder,proto3" json:"total_cancel_order,omitempty"`
	// Total number of order submissions since genesis (on all markets)
	TotalCreateOrder uint64 `protobuf:"varint,18,opt,name=total_create_order,json=totalCreateOrder,proto3" json:"total_create_order,omitempty"`
	// Total number of orders processed since genesis (on all markets)
	TotalOrders uint64 `protobuf:"varint,19,opt,name=total_orders,json=totalOrders,proto3" json:"total_orders,omitempty"`
	// Total number of trades emitted since genesis (on all markets)
	TotalTrades uint64 `protobuf:"varint,20,opt,name=total_trades,json=totalTrades,proto3" json:"total_trades,omitempty"`
	// Current number of stream subscribers to order data
	OrderSubscriptions uint32 `protobuf:"varint,21,opt,name=order_subscriptions,json=orderSubscriptions,proto3" json:"order_subscriptions,omitempty"`
	// Current number of stream subscribers to trade data
	TradeSubscriptions uint32 `protobuf:"varint,22,opt,name=trade_subscriptions,json=tradeSubscriptions,proto3" json:"trade_subscriptions,omitempty"`
	// Current number of stream subscribers to candle-stick data
	CandleSubscriptions uint32 `protobuf:"varint,23,opt,name=candle_subscriptions,json=candleSubscriptions,proto3" json:"candle_subscriptions,omitempty"`
	// Current number of stream subscribers to market depth data
	MarketDepthSubscriptions uint32 `` /* 137-byte string literal not displayed */
	// Current number of stream subscribers to positions data
	PositionsSubscriptions uint32 `` /* 129-byte string literal not displayed */
	// Current number of stream subscribers to account data
	AccountSubscriptions uint32 `protobuf:"varint,26,opt,name=account_subscriptions,json=accountSubscriptions,proto3" json:"account_subscriptions,omitempty"`
	// Current number of stream subscribers to market data
	MarketDataSubscriptions uint32 `` /* 134-byte string literal not displayed */
	// The version hash of the Vega node software
	AppVersionHash string `protobuf:"bytes,28,opt,name=app_version_hash,json=appVersionHash,proto3" json:"app_version_hash,omitempty"`
	// The version of the Vega node software
	AppVersion string `protobuf:"bytes,29,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"`
	// The version of the underlying Vega blockchain
	ChainVersion string `protobuf:"bytes,30,opt,name=chain_version,json=chainVersion,proto3" json:"chain_version,omitempty"`
	// Current block duration, in nanoseconds
	BlockDuration uint64 `protobuf:"varint,31,opt,name=block_duration,json=blockDuration,proto3" json:"block_duration,omitempty"`
	// Total uptime for this node formatted in ISO-8601 datetime format with nanosecond precision
	Uptime string `protobuf:"bytes,32,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// Unique identifier for the underlying Vega blockchain
	ChainId string `protobuf:"bytes,33,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// Current number of stream subscribers to market depth update data
	MarketDepthUpdatesSubscriptions uint32   `` /* 160-byte string literal not displayed */
	XXX_NoUnkeyedLiteral            struct{} `json:"-"`
	XXX_unrecognized                []byte   `json:"-"`
	XXX_sizecache                   int32    `json:"-"`
}

Vega domain specific statistics as reported by the node the caller is connected to

func (*Statistics) Descriptor added in v0.42.0 

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

func (*Statistics) GetAccountSubscriptions added in v0.42.0 

func (m *Statistics) GetAccountSubscriptions() uint32

func (*Statistics) GetAppVersion added in v0.42.0 

func (m *Statistics) GetAppVersion() string

func (*Statistics) GetAppVersionHash added in v0.42.0 

func (m *Statistics) GetAppVersionHash() string

func (*Statistics) GetAverageOrdersPerBlock added in v0.42.0 

func (m *Statistics) GetAverageOrdersPerBlock() uint64

func (*Statistics) GetAverageTxBytes added in v0.42.0 

func (m *Statistics) GetAverageTxBytes() uint64

func (*Statistics) GetBacklogLength added in v0.42.0 

func (m *Statistics) GetBacklogLength() uint64

func (*Statistics) GetBlockDuration added in v0.42.0 

func (m *Statistics) GetBlockDuration() uint64

func (*Statistics) GetBlockHeight added in v0.42.0 

func (m *Statistics) GetBlockHeight() uint64

func (*Statistics) GetCandleSubscriptions added in v0.42.0 

func (m *Statistics) GetCandleSubscriptions() uint32

func (*Statistics) GetChainId added in v0.42.0 

func (m *Statistics) GetChainId() string

func (*Statistics) GetChainVersion added in v0.42.0 

func (m *Statistics) GetChainVersion() string

func (*Statistics) GetCurrentTime added in v0.42.0 

func (m *Statistics) GetCurrentTime() string

func (*Statistics) GetGenesisTime added in v0.42.0 

func (m *Statistics) GetGenesisTime() string

func (*Statistics) GetMarketDataSubscriptions added in v0.42.0 

func (m *Statistics) GetMarketDataSubscriptions() uint32

func (*Statistics) GetMarketDepthSubscriptions added in v0.42.0 

func (m *Statistics) GetMarketDepthSubscriptions() uint32

func (*Statistics) GetMarketDepthUpdatesSubscriptions added in v0.42.0 

func (m *Statistics) GetMarketDepthUpdatesSubscriptions() uint32

func (*Statistics) GetOrderSubscriptions added in v0.42.0 

func (m *Statistics) GetOrderSubscriptions() uint32

func (*Statistics) GetOrdersPerSecond added in v0.42.0 

func (m *Statistics) GetOrdersPerSecond() uint64

func (*Statistics) GetPositionsSubscriptions added in v0.42.0 

func (m *Statistics) GetPositionsSubscriptions() uint32

func (*Statistics) GetStatus added in v0.42.0 

func (m *Statistics) GetStatus() vega.ChainStatus

func (*Statistics) GetTotalAmendOrder added in v0.42.0 

func (m *Statistics) GetTotalAmendOrder() uint64

func (*Statistics) GetTotalCancelOrder added in v0.42.0 

func (m *Statistics) GetTotalCancelOrder() uint64

func (*Statistics) GetTotalCreateOrder added in v0.42.0 

func (m *Statistics) GetTotalCreateOrder() uint64

func (*Statistics) GetTotalMarkets added in v0.42.0 

func (m *Statistics) GetTotalMarkets() uint64

func (*Statistics) GetTotalOrders added in v0.42.0 

func (m *Statistics) GetTotalOrders() uint64

func (*Statistics) GetTotalPeers added in v0.42.0 

func (m *Statistics) GetTotalPeers() uint64

func (*Statistics) GetTotalTrades added in v0.42.0 

func (m *Statistics) GetTotalTrades() uint64

func (*Statistics) GetTradeSubscriptions added in v0.42.0 

func (m *Statistics) GetTradeSubscriptions() uint32

func (*Statistics) GetTradesPerSecond added in v0.42.0 

func (m *Statistics) GetTradesPerSecond() uint64

func (*Statistics) GetTxPerBlock added in v0.42.0 

func (m *Statistics) GetTxPerBlock() uint64

func (*Statistics) GetUptime added in v0.42.0 

func (m *Statistics) GetUptime() string

func (*Statistics) GetVegaTime added in v0.42.0 

func (m *Statistics) GetVegaTime() string

func (*Statistics) ProtoMessage added in v0.42.0 

func (*Statistics) ProtoMessage()

func (*Statistics) Reset added in v0.42.0 

func (m *Statistics) Reset()

func (*Statistics) String added in v0.42.0 

func (m *Statistics) String() string

func (*Statistics) Validate added in v0.42.0 

func (this *Statistics) Validate() error

func (*Statistics) XXX_DiscardUnknown added in v0.42.0 

func (m *Statistics) XXX_DiscardUnknown()

func (*Statistics) XXX_Marshal added in v0.42.0 

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

func (*Statistics) XXX_Merge added in v0.42.0 

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

func (*Statistics) XXX_Size added in v0.42.0 

func (m *Statistics) XXX_Size() int

func (*Statistics) XXX_Unmarshal added in v0.42.0 

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

type StatisticsRequest 

type StatisticsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A a request for statistics about the Vega network

func (*StatisticsRequest) Descriptor 

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

func (*StatisticsRequest) ProtoMessage 

func (*StatisticsRequest) ProtoMessage()

func (*StatisticsRequest) Reset 

func (m *StatisticsRequest) Reset()

func (*StatisticsRequest) String 

func (m *StatisticsRequest) String() string

func (*StatisticsRequest) Validate 

func (this *StatisticsRequest) Validate() error

func (*StatisticsRequest) XXX_DiscardUnknown 

func (m *StatisticsRequest) XXX_DiscardUnknown()

func (*StatisticsRequest) XXX_Marshal 

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

func (*StatisticsRequest) XXX_Merge 

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

func (*StatisticsRequest) XXX_Size 

func (m *StatisticsRequest) XXX_Size() int

func (*StatisticsRequest) XXX_Unmarshal 

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

type StatisticsResponse 

type StatisticsResponse struct {
	Statistics           *Statistics `protobuf:"bytes,1,opt,name=statistics,proto3" json:"statistics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StatisticsResponse) Descriptor 

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

func (*StatisticsResponse) GetStatistics 

func (m *StatisticsResponse) GetStatistics() *Statistics

func (*StatisticsResponse) ProtoMessage 

func (*StatisticsResponse) ProtoMessage()

func (*StatisticsResponse) Reset 

func (m *StatisticsResponse) Reset()

func (*StatisticsResponse) String 

func (m *StatisticsResponse) String() string

func (*StatisticsResponse) Validate 

func (this *StatisticsResponse) Validate() error

func (*StatisticsResponse) XXX_DiscardUnknown 

func (m *StatisticsResponse) XXX_DiscardUnknown()

func (*StatisticsResponse) XXX_Marshal 

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

func (*StatisticsResponse) XXX_Merge 

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

func (*StatisticsResponse) XXX_Size 

func (m *StatisticsResponse) XXX_Size() int

func (*StatisticsResponse) XXX_Unmarshal 

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

type SubmitTransactionV2Request 

type SubmitTransactionV2Request struct {
	// A bundle of signed payload and signature, to form a transaction that will be submitted to the Vega blockchain
	Tx *v1.Transaction `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Type of transaction request, for example ASYNC, meaning the transaction will be submitted and not block on a response
	Type                 SubmitTransactionV2Request_Type `protobuf:"varint,2,opt,name=type,proto3,enum=api.v1.SubmitTransactionV2Request_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Request for submitting a transaction v2 on Vega

func (*SubmitTransactionV2Request) Descriptor 

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

func (*SubmitTransactionV2Request) GetTx 

func (m *SubmitTransactionV2Request) GetTx() *v1.Transaction

func (*SubmitTransactionV2Request) GetType 

func (m *SubmitTransactionV2Request) GetType() SubmitTransactionV2Request_Type

func (*SubmitTransactionV2Request) ProtoMessage 

func (*SubmitTransactionV2Request) ProtoMessage()

func (*SubmitTransactionV2Request) Reset 

func (m *SubmitTransactionV2Request) Reset()

func (*SubmitTransactionV2Request) String 

func (m *SubmitTransactionV2Request) String() string

func (*SubmitTransactionV2Request) Validate 

func (this *SubmitTransactionV2Request) Validate() error

func (*SubmitTransactionV2Request) XXX_DiscardUnknown 

func (m *SubmitTransactionV2Request) XXX_DiscardUnknown()

func (*SubmitTransactionV2Request) XXX_Marshal 

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

func (*SubmitTransactionV2Request) XXX_Merge 

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

func (*SubmitTransactionV2Request) XXX_Size 

func (m *SubmitTransactionV2Request) XXX_Size() int

func (*SubmitTransactionV2Request) XXX_Unmarshal 

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

type SubmitTransactionV2Request_Type 

type SubmitTransactionV2Request_Type int32

Blockchain transaction type 

const (
	SubmitTransactionV2Request_TYPE_UNSPECIFIED SubmitTransactionV2Request_Type = 0
	// The transaction will be submitted without waiting for response
	SubmitTransactionV2Request_TYPE_ASYNC SubmitTransactionV2Request_Type = 1
	// The transaction will be submitted, and blocking until the
	// tendermint mempool return a response
	SubmitTransactionV2Request_TYPE_SYNC SubmitTransactionV2Request_Type = 2
	// The transaction will submitted, and blocking until the tendermint
	// network will have committed it into a block
	SubmitTransactionV2Request_TYPE_COMMIT SubmitTransactionV2Request_Type = 3
)

func (SubmitTransactionV2Request_Type) EnumDescriptor 

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

func (SubmitTransactionV2Request_Type) String 

func (x SubmitTransactionV2Request_Type) String() string

type SubmitTransactionV2Response 

type SubmitTransactionV2Response struct {
	// Success will be true if the transaction was accepted by the node,
	// **Important** - success does not mean that the event is confirmed by consensus
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for submitting a transaction v2 on Vega

func (*SubmitTransactionV2Response) Descriptor 

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

func (*SubmitTransactionV2Response) GetSuccess 

func (m *SubmitTransactionV2Response) GetSuccess() bool

func (*SubmitTransactionV2Response) ProtoMessage 

func (*SubmitTransactionV2Response) ProtoMessage()

func (*SubmitTransactionV2Response) Reset 

func (m *SubmitTransactionV2Response) Reset()

func (*SubmitTransactionV2Response) String 

func (m *SubmitTransactionV2Response) String() string

func (*SubmitTransactionV2Response) Validate 

func (this *SubmitTransactionV2Response) Validate() error

func (*SubmitTransactionV2Response) XXX_DiscardUnknown 

func (m *SubmitTransactionV2Response) XXX_DiscardUnknown()

func (*SubmitTransactionV2Response) XXX_Marshal 

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

func (*SubmitTransactionV2Response) XXX_Merge 

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

func (*SubmitTransactionV2Response) XXX_Size 

func (m *SubmitTransactionV2Response) XXX_Size() int

func (*SubmitTransactionV2Response) XXX_Unmarshal 

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

type TradingServiceClient 

type TradingServiceClient interface {
	// Submit a signed transaction (v2)
	SubmitTransactionV2(ctx context.Context, in *SubmitTransactionV2Request, opts ...grpc.CallOption) (*SubmitTransactionV2Response, error)
	// Propagate a chain event
	PropagateChainEvent(ctx context.Context, in *PropagateChainEventRequest, opts ...grpc.CallOption) (*PropagateChainEventResponse, error)
	// Get Statistics on Vega
	Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
	// Get the height of the last tendermint block
	LastBlockHeight(ctx context.Context, in *LastBlockHeightRequest, opts ...grpc.CallOption) (*LastBlockHeightResponse, error)
	// Get Time
	GetVegaTime(ctx context.Context, in *GetVegaTimeRequest, opts ...grpc.CallOption) (*GetVegaTimeResponse, error)
	// Subscribe to a stream of events from the core
	ObserveEventBus(ctx context.Context, opts ...grpc.CallOption) (TradingService_ObserveEventBusClient, error)
}

TradingServiceClient is the client API for TradingService service.

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

func NewTradingServiceClient 

func NewTradingServiceClient(cc *grpc.ClientConn) TradingServiceClient

type TradingServiceServer 

type TradingServiceServer interface {
	// Submit a signed transaction (v2)
	SubmitTransactionV2(context.Context, *SubmitTransactionV2Request) (*SubmitTransactionV2Response, error)
	// Propagate a chain event
	PropagateChainEvent(context.Context, *PropagateChainEventRequest) (*PropagateChainEventResponse, error)
	// Get Statistics on Vega
	Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
	// Get the height of the last tendermint block
	LastBlockHeight(context.Context, *LastBlockHeightRequest) (*LastBlockHeightResponse, error)
	// Get Time
	GetVegaTime(context.Context, *GetVegaTimeRequest) (*GetVegaTimeResponse, error)
	// Subscribe to a stream of events from the core
	ObserveEventBus(TradingService_ObserveEventBusServer) error
}

TradingServiceServer is the server API for TradingService service.

type TradingService_ObserveEventBusClient added in v0.42.0 

type TradingService_ObserveEventBusClient interface {
	Send(*ObserveEventBusRequest) error
	Recv() (*ObserveEventBusResponse, error)
	grpc.ClientStream
}

type TradingService_ObserveEventBusServer added in v0.42.0 

type TradingService_ObserveEventBusServer interface {
	Send(*ObserveEventBusResponse) error
	Recv() (*ObserveEventBusRequest, error)
	grpc.ServerStream
}

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.