Documentation
¶
Overview ¶
Package api is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterTradingServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterTradingServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TradingServiceClient) error
- func RegisterTradingServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterTradingServiceServer(s *grpc.Server, srv TradingServiceServer)
- type GetVegaTimeRequest
- func (*GetVegaTimeRequest) Descriptor() ([]byte, []int)
- func (*GetVegaTimeRequest) ProtoMessage()
- func (m *GetVegaTimeRequest) Reset()
- func (m *GetVegaTimeRequest) String() string
- func (this *GetVegaTimeRequest) Validate() error
- func (m *GetVegaTimeRequest) XXX_DiscardUnknown()
- func (m *GetVegaTimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetVegaTimeRequest) XXX_Merge(src proto.Message)
- func (m *GetVegaTimeRequest) XXX_Size() int
- func (m *GetVegaTimeRequest) XXX_Unmarshal(b []byte) error
- type GetVegaTimeResponse
- func (*GetVegaTimeResponse) Descriptor() ([]byte, []int)
- func (m *GetVegaTimeResponse) GetTimestamp() int64
- func (*GetVegaTimeResponse) ProtoMessage()
- func (m *GetVegaTimeResponse) Reset()
- func (m *GetVegaTimeResponse) String() string
- func (this *GetVegaTimeResponse) Validate() error
- func (m *GetVegaTimeResponse) XXX_DiscardUnknown()
- func (m *GetVegaTimeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetVegaTimeResponse) XXX_Merge(src proto.Message)
- func (m *GetVegaTimeResponse) XXX_Size() int
- func (m *GetVegaTimeResponse) XXX_Unmarshal(b []byte) error
- type LastBlockHeightRequest
- func (*LastBlockHeightRequest) Descriptor() ([]byte, []int)
- func (*LastBlockHeightRequest) ProtoMessage()
- func (m *LastBlockHeightRequest) Reset()
- func (m *LastBlockHeightRequest) String() string
- func (this *LastBlockHeightRequest) Validate() error
- func (m *LastBlockHeightRequest) XXX_DiscardUnknown()
- func (m *LastBlockHeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LastBlockHeightRequest) XXX_Merge(src proto.Message)
- func (m *LastBlockHeightRequest) XXX_Size() int
- func (m *LastBlockHeightRequest) XXX_Unmarshal(b []byte) error
- type LastBlockHeightResponse
- func (*LastBlockHeightResponse) Descriptor() ([]byte, []int)
- func (m *LastBlockHeightResponse) GetHeight() uint64
- func (*LastBlockHeightResponse) ProtoMessage()
- func (m *LastBlockHeightResponse) Reset()
- func (m *LastBlockHeightResponse) String() string
- func (this *LastBlockHeightResponse) Validate() error
- func (m *LastBlockHeightResponse) XXX_DiscardUnknown()
- func (m *LastBlockHeightResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LastBlockHeightResponse) XXX_Merge(src proto.Message)
- func (m *LastBlockHeightResponse) XXX_Size() int
- func (m *LastBlockHeightResponse) XXX_Unmarshal(b []byte) error
- type ObserveEventBusRequest
- func (*ObserveEventBusRequest) Descriptor() ([]byte, []int)
- func (m *ObserveEventBusRequest) GetBatchSize() int64
- func (m *ObserveEventBusRequest) GetMarketId() string
- func (m *ObserveEventBusRequest) GetPartyId() string
- func (m *ObserveEventBusRequest) GetType() []v11.BusEventType
- func (*ObserveEventBusRequest) ProtoMessage()
- func (m *ObserveEventBusRequest) Reset()
- func (m *ObserveEventBusRequest) String() string
- func (this *ObserveEventBusRequest) Validate() error
- func (m *ObserveEventBusRequest) XXX_DiscardUnknown()
- func (m *ObserveEventBusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObserveEventBusRequest) XXX_Merge(src proto.Message)
- func (m *ObserveEventBusRequest) XXX_Size() int
- func (m *ObserveEventBusRequest) XXX_Unmarshal(b []byte) error
- type ObserveEventBusResponse
- func (*ObserveEventBusResponse) Descriptor() ([]byte, []int)
- func (m *ObserveEventBusResponse) GetEvents() []*v11.BusEvent
- func (*ObserveEventBusResponse) ProtoMessage()
- func (m *ObserveEventBusResponse) Reset()
- func (m *ObserveEventBusResponse) String() string
- func (this *ObserveEventBusResponse) Validate() error
- func (m *ObserveEventBusResponse) XXX_DiscardUnknown()
- func (m *ObserveEventBusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObserveEventBusResponse) XXX_Merge(src proto.Message)
- func (m *ObserveEventBusResponse) XXX_Size() int
- func (m *ObserveEventBusResponse) XXX_Unmarshal(b []byte) error
- type PropagateChainEventRequest
- func (*PropagateChainEventRequest) Descriptor() ([]byte, []int)
- func (m *PropagateChainEventRequest) GetEvent() []byte
- func (m *PropagateChainEventRequest) GetPubKey() string
- func (m *PropagateChainEventRequest) GetSignature() []byte
- func (*PropagateChainEventRequest) ProtoMessage()
- func (m *PropagateChainEventRequest) Reset()
- func (m *PropagateChainEventRequest) String() string
- func (this *PropagateChainEventRequest) Validate() error
- func (m *PropagateChainEventRequest) XXX_DiscardUnknown()
- func (m *PropagateChainEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PropagateChainEventRequest) XXX_Merge(src proto.Message)
- func (m *PropagateChainEventRequest) XXX_Size() int
- func (m *PropagateChainEventRequest) XXX_Unmarshal(b []byte) error
- type PropagateChainEventResponse
- func (*PropagateChainEventResponse) Descriptor() ([]byte, []int)
- func (m *PropagateChainEventResponse) GetSuccess() bool
- func (*PropagateChainEventResponse) ProtoMessage()
- func (m *PropagateChainEventResponse) Reset()
- func (m *PropagateChainEventResponse) String() string
- func (this *PropagateChainEventResponse) Validate() error
- func (m *PropagateChainEventResponse) XXX_DiscardUnknown()
- func (m *PropagateChainEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PropagateChainEventResponse) XXX_Merge(src proto.Message)
- func (m *PropagateChainEventResponse) XXX_Size() int
- func (m *PropagateChainEventResponse) XXX_Unmarshal(b []byte) error
- type Statistics
- func (*Statistics) Descriptor() ([]byte, []int)
- func (m *Statistics) GetAccountSubscriptions() uint32
- func (m *Statistics) GetAppVersion() string
- func (m *Statistics) GetAppVersionHash() string
- func (m *Statistics) GetAverageOrdersPerBlock() uint64
- func (m *Statistics) GetAverageTxBytes() uint64
- func (m *Statistics) GetBacklogLength() uint64
- func (m *Statistics) GetBlockDuration() uint64
- func (m *Statistics) GetBlockHeight() uint64
- func (m *Statistics) GetCandleSubscriptions() uint32
- func (m *Statistics) GetChainId() string
- func (m *Statistics) GetChainVersion() string
- func (m *Statistics) GetCurrentTime() string
- func (m *Statistics) GetGenesisTime() string
- func (m *Statistics) GetMarketDataSubscriptions() uint32
- func (m *Statistics) GetMarketDepthSubscriptions() uint32
- func (m *Statistics) GetMarketDepthUpdatesSubscriptions() uint32
- func (m *Statistics) GetOrderSubscriptions() uint32
- func (m *Statistics) GetOrdersPerSecond() uint64
- func (m *Statistics) GetPositionsSubscriptions() uint32
- func (m *Statistics) GetStatus() vega.ChainStatus
- func (m *Statistics) GetTotalAmendOrder() uint64
- func (m *Statistics) GetTotalCancelOrder() uint64
- func (m *Statistics) GetTotalCreateOrder() uint64
- func (m *Statistics) GetTotalMarkets() uint64
- func (m *Statistics) GetTotalOrders() uint64
- func (m *Statistics) GetTotalPeers() uint64
- func (m *Statistics) GetTotalTrades() uint64
- func (m *Statistics) GetTradeSubscriptions() uint32
- func (m *Statistics) GetTradesPerSecond() uint64
- func (m *Statistics) GetTxPerBlock() uint64
- func (m *Statistics) GetUptime() string
- func (m *Statistics) GetVegaTime() string
- func (*Statistics) ProtoMessage()
- func (m *Statistics) Reset()
- func (m *Statistics) String() string
- func (this *Statistics) Validate() error
- func (m *Statistics) XXX_DiscardUnknown()
- func (m *Statistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Statistics) XXX_Merge(src proto.Message)
- func (m *Statistics) XXX_Size() int
- func (m *Statistics) XXX_Unmarshal(b []byte) error
- type StatisticsRequest
- func (*StatisticsRequest) Descriptor() ([]byte, []int)
- func (*StatisticsRequest) ProtoMessage()
- func (m *StatisticsRequest) Reset()
- func (m *StatisticsRequest) String() string
- func (this *StatisticsRequest) Validate() error
- func (m *StatisticsRequest) XXX_DiscardUnknown()
- func (m *StatisticsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatisticsRequest) XXX_Merge(src proto.Message)
- func (m *StatisticsRequest) XXX_Size() int
- func (m *StatisticsRequest) XXX_Unmarshal(b []byte) error
- type StatisticsResponse
- func (*StatisticsResponse) Descriptor() ([]byte, []int)
- func (m *StatisticsResponse) GetStatistics() *Statistics
- func (*StatisticsResponse) ProtoMessage()
- func (m *StatisticsResponse) Reset()
- func (m *StatisticsResponse) String() string
- func (this *StatisticsResponse) Validate() error
- func (m *StatisticsResponse) XXX_DiscardUnknown()
- func (m *StatisticsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatisticsResponse) XXX_Merge(src proto.Message)
- func (m *StatisticsResponse) XXX_Size() int
- func (m *StatisticsResponse) XXX_Unmarshal(b []byte) error
- type SubmitTransactionRequest
- func (*SubmitTransactionRequest) Descriptor() ([]byte, []int)
- func (m *SubmitTransactionRequest) GetTx() *v1.Transaction
- func (m *SubmitTransactionRequest) GetType() SubmitTransactionRequest_Type
- func (*SubmitTransactionRequest) ProtoMessage()
- func (m *SubmitTransactionRequest) Reset()
- func (m *SubmitTransactionRequest) String() string
- func (this *SubmitTransactionRequest) Validate() error
- func (m *SubmitTransactionRequest) XXX_DiscardUnknown()
- func (m *SubmitTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubmitTransactionRequest) XXX_Merge(src proto.Message)
- func (m *SubmitTransactionRequest) XXX_Size() int
- func (m *SubmitTransactionRequest) XXX_Unmarshal(b []byte) error
- type SubmitTransactionRequest_Type
- type SubmitTransactionResponse
- func (*SubmitTransactionResponse) Descriptor() ([]byte, []int)
- func (m *SubmitTransactionResponse) GetSuccess() bool
- func (*SubmitTransactionResponse) ProtoMessage()
- func (m *SubmitTransactionResponse) Reset()
- func (m *SubmitTransactionResponse) String() string
- func (this *SubmitTransactionResponse) Validate() error
- func (m *SubmitTransactionResponse) XXX_DiscardUnknown()
- func (m *SubmitTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubmitTransactionResponse) XXX_Merge(src proto.Message)
- func (m *SubmitTransactionResponse) XXX_Size() int
- func (m *SubmitTransactionResponse) XXX_Unmarshal(b []byte) error
- type TradingServiceClient
- type TradingServiceServer
- type TradingService_ObserveEventBusClient
- type TradingService_ObserveEventBusServer
Constants ¶
This section is empty.
Variables ¶
var SubmitTransactionRequest_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "TYPE_ASYNC",
2: "TYPE_SYNC",
3: "TYPE_COMMIT",
}
var SubmitTransactionRequest_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 SubmitTransactionRequest ¶
type SubmitTransactionRequest 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 SubmitTransactionRequest_Type `protobuf:"varint,2,opt,name=type,proto3,enum=api.v1.SubmitTransactionRequest_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 (*SubmitTransactionRequest) Descriptor ¶
func (*SubmitTransactionRequest) Descriptor() ([]byte, []int)
func (*SubmitTransactionRequest) GetTx ¶
func (m *SubmitTransactionRequest) GetTx() *v1.Transaction
func (*SubmitTransactionRequest) GetType ¶
func (m *SubmitTransactionRequest) GetType() SubmitTransactionRequest_Type
func (*SubmitTransactionRequest) ProtoMessage ¶
func (*SubmitTransactionRequest) ProtoMessage()
func (*SubmitTransactionRequest) Reset ¶
func (m *SubmitTransactionRequest) Reset()
func (*SubmitTransactionRequest) String ¶
func (m *SubmitTransactionRequest) String() string
func (*SubmitTransactionRequest) Validate ¶
func (this *SubmitTransactionRequest) Validate() error
func (*SubmitTransactionRequest) XXX_DiscardUnknown ¶
func (m *SubmitTransactionRequest) XXX_DiscardUnknown()
func (*SubmitTransactionRequest) XXX_Marshal ¶
func (m *SubmitTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubmitTransactionRequest) XXX_Merge ¶
func (m *SubmitTransactionRequest) XXX_Merge(src proto.Message)
func (*SubmitTransactionRequest) XXX_Size ¶
func (m *SubmitTransactionRequest) XXX_Size() int
func (*SubmitTransactionRequest) XXX_Unmarshal ¶
func (m *SubmitTransactionRequest) XXX_Unmarshal(b []byte) error
type SubmitTransactionRequest_Type ¶
type SubmitTransactionRequest_Type int32
Blockchain transaction type
const ( SubmitTransactionRequest_TYPE_UNSPECIFIED SubmitTransactionRequest_Type = 0 // The transaction will be submitted without waiting for response SubmitTransactionRequest_TYPE_ASYNC SubmitTransactionRequest_Type = 1 // The transaction will be submitted, and blocking until the // tendermint mempool return a response SubmitTransactionRequest_TYPE_SYNC SubmitTransactionRequest_Type = 2 // The transaction will submitted, and blocking until the tendermint // network will have committed it into a block SubmitTransactionRequest_TYPE_COMMIT SubmitTransactionRequest_Type = 3 )
func (SubmitTransactionRequest_Type) EnumDescriptor ¶
func (SubmitTransactionRequest_Type) EnumDescriptor() ([]byte, []int)
func (SubmitTransactionRequest_Type) String ¶
func (x SubmitTransactionRequest_Type) String() string
type SubmitTransactionResponse ¶
type SubmitTransactionResponse 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 (*SubmitTransactionResponse) Descriptor ¶
func (*SubmitTransactionResponse) Descriptor() ([]byte, []int)
func (*SubmitTransactionResponse) GetSuccess ¶
func (m *SubmitTransactionResponse) GetSuccess() bool
func (*SubmitTransactionResponse) ProtoMessage ¶
func (*SubmitTransactionResponse) ProtoMessage()
func (*SubmitTransactionResponse) Reset ¶
func (m *SubmitTransactionResponse) Reset()
func (*SubmitTransactionResponse) String ¶
func (m *SubmitTransactionResponse) String() string
func (*SubmitTransactionResponse) Validate ¶
func (this *SubmitTransactionResponse) Validate() error
func (*SubmitTransactionResponse) XXX_DiscardUnknown ¶
func (m *SubmitTransactionResponse) XXX_DiscardUnknown()
func (*SubmitTransactionResponse) XXX_Marshal ¶
func (m *SubmitTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubmitTransactionResponse) XXX_Merge ¶
func (m *SubmitTransactionResponse) XXX_Merge(src proto.Message)
func (*SubmitTransactionResponse) XXX_Size ¶
func (m *SubmitTransactionResponse) XXX_Size() int
func (*SubmitTransactionResponse) XXX_Unmarshal ¶
func (m *SubmitTransactionResponse) XXX_Unmarshal(b []byte) error
type TradingServiceClient ¶
type TradingServiceClient interface {
// Submit a signed transaction
SubmitTransaction(ctx context.Context, in *SubmitTransactionRequest, opts ...grpc.CallOption) (*SubmitTransactionResponse, 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
SubmitTransaction(context.Context, *SubmitTransactionRequest) (*SubmitTransactionResponse, 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
}