v1

package
v0.63.1 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2022 License: MIT Imports: 19 Imported by: 7

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	SubmitTransactionRequest_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_ASYNC",
		2: "TYPE_SYNC",
		3: "TYPE_COMMIT",
	}
	SubmitTransactionRequest_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_ASYNC":       1,
		"TYPE_SYNC":        2,
		"TYPE_COMMIT":      3,
	}
)

Enum value maps for SubmitTransactionRequest_Type.

View Source 
var (
	SubmitRawTransactionRequest_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_ASYNC",
		2: "TYPE_SYNC",
		3: "TYPE_COMMIT",
	}
	SubmitRawTransactionRequest_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_ASYNC":       1,
		"TYPE_SYNC":        2,
		"TYPE_COMMIT":      3,
	}
)

Enum value maps for SubmitRawTransactionRequest_Type.

View Source 
var CoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vega.api.v1.CoreService",
	HandlerType: (*CoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitTransaction",
			Handler:    _CoreService_SubmitTransaction_Handler,
		},
		{
			MethodName: "PropagateChainEvent",
			Handler:    _CoreService_PropagateChainEvent_Handler,
		},
		{
			MethodName: "Statistics",
			Handler:    _CoreService_Statistics_Handler,
		},
		{
			MethodName: "LastBlockHeight",
			Handler:    _CoreService_LastBlockHeight_Handler,
		},
		{
			MethodName: "GetVegaTime",
			Handler:    _CoreService_GetVegaTime_Handler,
		},
		{
			MethodName: "SubmitRawTransaction",
			Handler:    _CoreService_SubmitRawTransaction_Handler,
		},
		{
			MethodName: "CheckTransaction",
			Handler:    _CoreService_CheckTransaction_Handler,
		},
		{
			MethodName: "CheckRawTransaction",
			Handler:    _CoreService_CheckRawTransaction_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ObserveEventBus",
			Handler:       _CoreService_ObserveEventBus_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "vega/api/v1/core.proto",
}

CoreService_ServiceDesc is the grpc.ServiceDesc for CoreService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var CoreStateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vega.api.v1.CoreStateService",
	HandlerType: (*CoreStateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListAccounts",
			Handler:    _CoreStateService_ListAccounts_Handler,
		},
		{
			MethodName: "ListAssets",
			Handler:    _CoreStateService_ListAssets_Handler,
		},
		{
			MethodName: "ListNetworkParameters",
			Handler:    _CoreStateService_ListNetworkParameters_Handler,
		},
		{
			MethodName: "ListNetworkLimits",
			Handler:    _CoreStateService_ListNetworkLimits_Handler,
		},
		{
			MethodName: "ListParties",
			Handler:    _CoreStateService_ListParties_Handler,
		},
		{
			MethodName: "ListValidators",
			Handler:    _CoreStateService_ListValidators_Handler,
		},
		{
			MethodName: "ListMarkets",
			Handler:    _CoreStateService_ListMarkets_Handler,
		},
		{
			MethodName: "ListProposals",
			Handler:    _CoreStateService_ListProposals_Handler,
		},
		{
			MethodName: "ListMarketsData",
			Handler:    _CoreStateService_ListMarketsData_Handler,
		},
		{
			MethodName: "ListVotes",
			Handler:    _CoreStateService_ListVotes_Handler,
		},
		{
			MethodName: "ListPartiesStake",
			Handler:    _CoreStateService_ListPartiesStake_Handler,
		},
		{
			MethodName: "ListDelegations",
			Handler:    _CoreStateService_ListDelegations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vega/api/v1/corestate.proto",
}

CoreStateService_ServiceDesc is the grpc.ServiceDesc for CoreStateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_vega_api_v1_core_proto protoreflect.FileDescriptor
View Source 
var File_vega_api_v1_corestate_proto protoreflect.FileDescriptor

Functions

func RegisterCoreServiceHandler 

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

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

func RegisterCoreServiceHandlerClient 

func RegisterCoreServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CoreServiceClient) error

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

func RegisterCoreServiceHandlerFromEndpoint 

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

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

func RegisterCoreServiceHandlerServer 

func RegisterCoreServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CoreServiceServer) error

RegisterCoreServiceHandlerServer registers the http handlers for service CoreService to "mux". UnaryRPC :call CoreServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterCoreServiceHandlerFromEndpoint instead.

func RegisterCoreServiceServer 

func RegisterCoreServiceServer(s grpc.ServiceRegistrar, srv CoreServiceServer)

func RegisterCoreStateServiceHandler 

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

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

func RegisterCoreStateServiceHandlerClient 

func RegisterCoreStateServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CoreStateServiceClient) error

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

func RegisterCoreStateServiceHandlerFromEndpoint 

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

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

func RegisterCoreStateServiceHandlerServer 

func RegisterCoreStateServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CoreStateServiceServer) error

RegisterCoreStateServiceHandlerServer registers the http handlers for service CoreStateService to "mux". UnaryRPC :call CoreStateServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterCoreStateServiceHandlerFromEndpoint instead.

func RegisterCoreStateServiceServer 

func RegisterCoreStateServiceServer(s grpc.ServiceRegistrar, srv CoreStateServiceServer)

Types

type Account 

type Account struct {
	Party   string `protobuf:"bytes,1,opt,name=party,proto3" json:"party,omitempty"`
	Market  string `protobuf:"bytes,2,opt,name=market,proto3" json:"market,omitempty"`
	Balance string `protobuf:"bytes,3,opt,name=balance,proto3" json:"balance,omitempty"`
	Asset   string `protobuf:"bytes,5,opt,name=asset,proto3" json:"asset,omitempty"`
	Type    string `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Account) Descriptor deprecated 

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

Deprecated: Use Account.ProtoReflect.Descriptor instead.

func (*Account) GetAsset 

func (x *Account) GetAsset() string

func (*Account) GetBalance 

func (x *Account) GetBalance() string

func (*Account) GetMarket 

func (x *Account) GetMarket() string

func (*Account) GetParty 

func (x *Account) GetParty() string

func (*Account) GetType 

func (x *Account) GetType() string

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) ProtoReflect 

func (x *Account) ProtoReflect() protoreflect.Message

func (*Account) Reset 

func (x *Account) Reset()

func (*Account) String 

func (x *Account) String() string

type CheckRawTransactionRequest 

type CheckRawTransactionRequest struct {

	// A bundle of signed payload and signature marshalled into a byte array, to form a transaction that would be submitted to the Vega blockchain
	Tx []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// contains filtered or unexported fields
}

Request for checking a version agnostic transaction on Vega

func (*CheckRawTransactionRequest) Descriptor deprecated 

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

Deprecated: Use CheckRawTransactionRequest.ProtoReflect.Descriptor instead.

func (*CheckRawTransactionRequest) GetTx 

func (x *CheckRawTransactionRequest) GetTx() []byte

func (*CheckRawTransactionRequest) ProtoMessage 

func (*CheckRawTransactionRequest) ProtoMessage()

func (*CheckRawTransactionRequest) ProtoReflect 

func (x *CheckRawTransactionRequest) ProtoReflect() protoreflect.Message

func (*CheckRawTransactionRequest) Reset 

func (x *CheckRawTransactionRequest) Reset()

func (*CheckRawTransactionRequest) String 

func (x *CheckRawTransactionRequest) String() string

type CheckRawTransactionResponse 

type CheckRawTransactionResponse struct {

	// Success will be true if the transaction was checked by the node
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Check code result
	Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// Gas wanted for transaction
	GasWanted int64 `protobuf:"varint,3,opt,name=gas_wanted,json=gasWanted,proto3" json:"gas_wanted,omitempty"`
	// Gas used for transaction
	GasUsed int64 `protobuf:"varint,4,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	// Data for details
	Data string `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// Transaction log
	Log string `protobuf:"bytes,6,opt,name=log,proto3" json:"log,omitempty"`
	// Informations about the transaction
	Info string `protobuf:"bytes,7,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

Response for checking a version agnostic transaction on Vega

func (*CheckRawTransactionResponse) Descriptor deprecated 

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

Deprecated: Use CheckRawTransactionResponse.ProtoReflect.Descriptor instead.

func (*CheckRawTransactionResponse) GetCode 

func (x *CheckRawTransactionResponse) GetCode() uint32

func (*CheckRawTransactionResponse) GetData added in v0.63.0 

func (x *CheckRawTransactionResponse) GetData() string

func (*CheckRawTransactionResponse) GetGasUsed 

func (x *CheckRawTransactionResponse) GetGasUsed() int64

func (*CheckRawTransactionResponse) GetGasWanted 

func (x *CheckRawTransactionResponse) GetGasWanted() int64

func (*CheckRawTransactionResponse) GetInfo added in v0.63.0 

func (x *CheckRawTransactionResponse) GetInfo() string

func (*CheckRawTransactionResponse) GetLog added in v0.63.0 

func (x *CheckRawTransactionResponse) GetLog() string

func (*CheckRawTransactionResponse) GetSuccess 

func (x *CheckRawTransactionResponse) GetSuccess() bool

func (*CheckRawTransactionResponse) ProtoMessage 

func (*CheckRawTransactionResponse) ProtoMessage()

func (*CheckRawTransactionResponse) ProtoReflect 

func (x *CheckRawTransactionResponse) ProtoReflect() protoreflect.Message

func (*CheckRawTransactionResponse) Reset 

func (x *CheckRawTransactionResponse) Reset()

func (*CheckRawTransactionResponse) String 

func (x *CheckRawTransactionResponse) String() string

type CheckTransactionRequest 

type CheckTransactionRequest struct {

	// A bundle of signed payload and signature, to form a transaction that would be submitted to the Vega blockchain
	Tx *v1.Transaction `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// contains filtered or unexported fields
}

Request for checking a transaction v2 on Vega

func (*CheckTransactionRequest) Descriptor deprecated 

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

Deprecated: Use CheckTransactionRequest.ProtoReflect.Descriptor instead.

func (*CheckTransactionRequest) GetTx 

func (x *CheckTransactionRequest) GetTx() *v1.Transaction

func (*CheckTransactionRequest) ProtoMessage 

func (*CheckTransactionRequest) ProtoMessage()

func (*CheckTransactionRequest) ProtoReflect 

func (x *CheckTransactionRequest) ProtoReflect() protoreflect.Message

func (*CheckTransactionRequest) Reset 

func (x *CheckTransactionRequest) Reset()

func (*CheckTransactionRequest) String 

func (x *CheckTransactionRequest) String() string

type CheckTransactionResponse 

type CheckTransactionResponse struct {

	// Success will be true if the transaction was checked by the node
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Check code result
	Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// Gas wanted for transaction
	GasWanted int64 `protobuf:"varint,3,opt,name=gas_wanted,json=gasWanted,proto3" json:"gas_wanted,omitempty"`
	// Gas used for transaction
	GasUsed int64 `protobuf:"varint,4,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	// Data for details
	Data string `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// Transaction log
	Log string `protobuf:"bytes,6,opt,name=log,proto3" json:"log,omitempty"`
	// Informations about the transaction
	Info string `protobuf:"bytes,7,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckTransactionResponse) Descriptor deprecated 

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

Deprecated: Use CheckTransactionResponse.ProtoReflect.Descriptor instead.

func (*CheckTransactionResponse) GetCode 

func (x *CheckTransactionResponse) GetCode() uint32

func (*CheckTransactionResponse) GetData added in v0.63.0 

func (x *CheckTransactionResponse) GetData() string

func (*CheckTransactionResponse) GetGasUsed 

func (x *CheckTransactionResponse) GetGasUsed() int64

func (*CheckTransactionResponse) GetGasWanted 

func (x *CheckTransactionResponse) GetGasWanted() int64

func (*CheckTransactionResponse) GetInfo added in v0.63.0 

func (x *CheckTransactionResponse) GetInfo() string

func (*CheckTransactionResponse) GetLog added in v0.63.0 

func (x *CheckTransactionResponse) GetLog() string

func (*CheckTransactionResponse) GetSuccess 

func (x *CheckTransactionResponse) GetSuccess() bool

func (*CheckTransactionResponse) ProtoMessage 

func (*CheckTransactionResponse) ProtoMessage()

func (*CheckTransactionResponse) ProtoReflect 

func (x *CheckTransactionResponse) ProtoReflect() protoreflect.Message

func (*CheckTransactionResponse) Reset 

func (x *CheckTransactionResponse) Reset()

func (*CheckTransactionResponse) String 

func (x *CheckTransactionResponse) String() string

type CoreServiceClient 

type CoreServiceClient interface {
	// Submit Transaction
	//
	// Submit a signed transaction
	SubmitTransaction(ctx context.Context, in *SubmitTransactionRequest, opts ...grpc.CallOption) (*SubmitTransactionResponse, error)
	// Chain event
	//
	// Propagate a chain event
	PropagateChainEvent(ctx context.Context, in *PropagateChainEventRequest, opts ...grpc.CallOption) (*PropagateChainEventResponse, error)
	// Statistics
	//
	// Get Statistics on Vega
	Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
	// Blockchain height
	//
	// Get the height of the last tendermint block
	LastBlockHeight(ctx context.Context, in *LastBlockHeightRequest, opts ...grpc.CallOption) (*LastBlockHeightResponse, error)
	// Vega time
	//
	// 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) (CoreService_ObserveEventBusClient, error)
	// Submit raw transaction
	//
	// Submit a version agnostic signed transaction
	SubmitRawTransaction(ctx context.Context, in *SubmitRawTransactionRequest, opts ...grpc.CallOption) (*SubmitRawTransactionResponse, error)
	// Check transaction
	//
	// Check a signed transaction
	CheckTransaction(ctx context.Context, in *CheckTransactionRequest, opts ...grpc.CallOption) (*CheckTransactionResponse, error)
	// Check raw transaction
	//
	// Check a raw signed transaction
	CheckRawTransaction(ctx context.Context, in *CheckRawTransactionRequest, opts ...grpc.CallOption) (*CheckRawTransactionResponse, error)
}

CoreServiceClient is the client API for CoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCoreServiceClient 

func NewCoreServiceClient(cc grpc.ClientConnInterface) CoreServiceClient

type CoreServiceServer 

type CoreServiceServer interface {
	// Submit Transaction
	//
	// Submit a signed transaction
	SubmitTransaction(context.Context, *SubmitTransactionRequest) (*SubmitTransactionResponse, error)
	// Chain event
	//
	// Propagate a chain event
	PropagateChainEvent(context.Context, *PropagateChainEventRequest) (*PropagateChainEventResponse, error)
	// Statistics
	//
	// Get Statistics on Vega
	Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
	// Blockchain height
	//
	// Get the height of the last tendermint block
	LastBlockHeight(context.Context, *LastBlockHeightRequest) (*LastBlockHeightResponse, error)
	// Vega time
	//
	// Get Time
	GetVegaTime(context.Context, *GetVegaTimeRequest) (*GetVegaTimeResponse, error)
	// Subscribe to a stream of events from the core
	ObserveEventBus(CoreService_ObserveEventBusServer) error
	// Submit raw transaction
	//
	// Submit a version agnostic signed transaction
	SubmitRawTransaction(context.Context, *SubmitRawTransactionRequest) (*SubmitRawTransactionResponse, error)
	// Check transaction
	//
	// Check a signed transaction
	CheckTransaction(context.Context, *CheckTransactionRequest) (*CheckTransactionResponse, error)
	// Check raw transaction
	//
	// Check a raw signed transaction
	CheckRawTransaction(context.Context, *CheckRawTransactionRequest) (*CheckRawTransactionResponse, error)
	// contains filtered or unexported methods
}

CoreServiceServer is the server API for CoreService service. All implementations must embed UnimplementedCoreServiceServer for forward compatibility

type CoreService_ObserveEventBusClient 

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

type CoreService_ObserveEventBusServer 

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

type CoreStateServiceClient 

type CoreStateServiceClient interface {
	// Accounts list
	//
	// Return a list of accounts
	ListAccounts(ctx context.Context, in *ListAccountsRequest, opts ...grpc.CallOption) (*ListAccountsResponse, error)
	// Assets list
	//
	// Return a list of assets
	ListAssets(ctx context.Context, in *ListAssetsRequest, opts ...grpc.CallOption) (*ListAssetsResponse, error)
	// Network parameters list
	//
	// Return a list of network paramters
	ListNetworkParameters(ctx context.Context, in *ListNetworkParametersRequest, opts ...grpc.CallOption) (*ListNetworkParametersResponse, error)
	// Network limits list
	//
	// Return a list of network limits
	ListNetworkLimits(ctx context.Context, in *ListNetworkLimitsRequest, opts ...grpc.CallOption) (*ListNetworkLimitsResponse, error)
	// Parties list
	//
	// Return a list of parties
	ListParties(ctx context.Context, in *ListPartiesRequest, opts ...grpc.CallOption) (*ListPartiesResponse, error)
	// Validators list
	//
	// Return a list of validators
	ListValidators(ctx context.Context, in *ListValidatorsRequest, opts ...grpc.CallOption) (*ListValidatorsResponse, error)
	// Markets list
	//
	// Return a list of markets
	ListMarkets(ctx context.Context, in *ListMarketsRequest, opts ...grpc.CallOption) (*ListMarketsResponse, error)
	// Proposals list
	//
	// Return a list of proposals
	ListProposals(ctx context.Context, in *ListProposalsRequest, opts ...grpc.CallOption) (*ListProposalsResponse, error)
	// Markets data list
	//
	// Return a list of markets data
	ListMarketsData(ctx context.Context, in *ListMarketsDataRequest, opts ...grpc.CallOption) (*ListMarketsDataResponse, error)
	// Votes list
	//
	// Return a list of votes
	ListVotes(ctx context.Context, in *ListVotesRequest, opts ...grpc.CallOption) (*ListVotesResponse, error)
	// Parties stake list
	//
	// Return a list of parties stake
	ListPartiesStake(ctx context.Context, in *ListPartiesStakeRequest, opts ...grpc.CallOption) (*ListPartiesStakeResponse, error)
	// Delegations list
	//
	// Return a list of delegations
	ListDelegations(ctx context.Context, in *ListDelegationsRequest, opts ...grpc.CallOption) (*ListDelegationsResponse, error)
}

CoreStateServiceClient is the client API for CoreStateService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCoreStateServiceClient 

func NewCoreStateServiceClient(cc grpc.ClientConnInterface) CoreStateServiceClient

type CoreStateServiceServer 

type CoreStateServiceServer interface {
	// Accounts list
	//
	// Return a list of accounts
	ListAccounts(context.Context, *ListAccountsRequest) (*ListAccountsResponse, error)
	// Assets list
	//
	// Return a list of assets
	ListAssets(context.Context, *ListAssetsRequest) (*ListAssetsResponse, error)
	// Network parameters list
	//
	// Return a list of network paramters
	ListNetworkParameters(context.Context, *ListNetworkParametersRequest) (*ListNetworkParametersResponse, error)
	// Network limits list
	//
	// Return a list of network limits
	ListNetworkLimits(context.Context, *ListNetworkLimitsRequest) (*ListNetworkLimitsResponse, error)
	// Parties list
	//
	// Return a list of parties
	ListParties(context.Context, *ListPartiesRequest) (*ListPartiesResponse, error)
	// Validators list
	//
	// Return a list of validators
	ListValidators(context.Context, *ListValidatorsRequest) (*ListValidatorsResponse, error)
	// Markets list
	//
	// Return a list of markets
	ListMarkets(context.Context, *ListMarketsRequest) (*ListMarketsResponse, error)
	// Proposals list
	//
	// Return a list of proposals
	ListProposals(context.Context, *ListProposalsRequest) (*ListProposalsResponse, error)
	// Markets data list
	//
	// Return a list of markets data
	ListMarketsData(context.Context, *ListMarketsDataRequest) (*ListMarketsDataResponse, error)
	// Votes list
	//
	// Return a list of votes
	ListVotes(context.Context, *ListVotesRequest) (*ListVotesResponse, error)
	// Parties stake list
	//
	// Return a list of parties stake
	ListPartiesStake(context.Context, *ListPartiesStakeRequest) (*ListPartiesStakeResponse, error)
	// Delegations list
	//
	// Return a list of delegations
	ListDelegations(context.Context, *ListDelegationsRequest) (*ListDelegationsResponse, error)
	// contains filtered or unexported methods
}

CoreStateServiceServer is the server API for CoreStateService service. All implementations must embed UnimplementedCoreStateServiceServer for forward compatibility

type GetVegaTimeRequest 

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

Request for the current time of the vega network

func (*GetVegaTimeRequest) Descriptor deprecated 

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

Deprecated: Use GetVegaTimeRequest.ProtoReflect.Descriptor instead.

func (*GetVegaTimeRequest) ProtoMessage 

func (*GetVegaTimeRequest) ProtoMessage()

func (*GetVegaTimeRequest) ProtoReflect 

func (x *GetVegaTimeRequest) ProtoReflect() protoreflect.Message

func (*GetVegaTimeRequest) Reset 

func (x *GetVegaTimeRequest) Reset()

func (*GetVegaTimeRequest) String 

func (x *GetVegaTimeRequest) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*GetVegaTimeResponse) Descriptor deprecated 

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

Deprecated: Use GetVegaTimeResponse.ProtoReflect.Descriptor instead.

func (*GetVegaTimeResponse) GetTimestamp 

func (x *GetVegaTimeResponse) GetTimestamp() int64

func (*GetVegaTimeResponse) ProtoMessage 

func (*GetVegaTimeResponse) ProtoMessage()

func (*GetVegaTimeResponse) ProtoReflect 

func (x *GetVegaTimeResponse) ProtoReflect() protoreflect.Message

func (*GetVegaTimeResponse) Reset 

func (x *GetVegaTimeResponse) Reset()

func (*GetVegaTimeResponse) String 

func (x *GetVegaTimeResponse) String() string

type LastBlockHeightRequest 

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

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

func (*LastBlockHeightRequest) Descriptor deprecated 

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

Deprecated: Use LastBlockHeightRequest.ProtoReflect.Descriptor instead.

func (*LastBlockHeightRequest) ProtoMessage 

func (*LastBlockHeightRequest) ProtoMessage()

func (*LastBlockHeightRequest) ProtoReflect 

func (x *LastBlockHeightRequest) ProtoReflect() protoreflect.Message

func (*LastBlockHeightRequest) Reset 

func (x *LastBlockHeightRequest) Reset()

func (*LastBlockHeightRequest) String 

func (x *LastBlockHeightRequest) String() string

type LastBlockHeightResponse 

type LastBlockHeightResponse struct {

	// last block height
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// last block hash
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// supported proof of work hash function
	SpamPowHashFunction string `protobuf:"bytes,3,opt,name=spam_pow_hash_function,json=spamPowHashFunction,proto3" json:"spam_pow_hash_function,omitempty"`
	// the difficulty of the proof of work (target number of zeros)
	SpamPowDifficulty uint32 `protobuf:"varint,4,opt,name=spam_pow_difficulty,json=spamPowDifficulty,proto3" json:"spam_pow_difficulty,omitempty"`
	// supported proof of work number of blocks behind current height allowed
	SpamPowNumberOfPastBlocks uint32 `` /* 145-byte string literal not displayed */
	// allowed number of transactions per block
	SpamPowNumberOfTxPerBlock uint32 `` /* 147-byte string literal not displayed */
	// is increasing difficulty allowed for using the same height for more than `spam_pow_number_of_past_blocks` transactions
	SpamPowIncreasingDifficulty bool `` /* 147-byte string literal not displayed */
	// the network chain id from which the block comes from
	ChainId string `protobuf:"bytes,8,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// contains filtered or unexported fields
}

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

func (*LastBlockHeightResponse) Descriptor deprecated 

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

Deprecated: Use LastBlockHeightResponse.ProtoReflect.Descriptor instead.

func (*LastBlockHeightResponse) GetChainId 

func (x *LastBlockHeightResponse) GetChainId() string

func (*LastBlockHeightResponse) GetHash 

func (x *LastBlockHeightResponse) GetHash() string

func (*LastBlockHeightResponse) GetHeight 

func (x *LastBlockHeightResponse) GetHeight() uint64

func (*LastBlockHeightResponse) GetSpamPowDifficulty 

func (x *LastBlockHeightResponse) GetSpamPowDifficulty() uint32

func (*LastBlockHeightResponse) GetSpamPowHashFunction 

func (x *LastBlockHeightResponse) GetSpamPowHashFunction() string

func (*LastBlockHeightResponse) GetSpamPowIncreasingDifficulty 

func (x *LastBlockHeightResponse) GetSpamPowIncreasingDifficulty() bool

func (*LastBlockHeightResponse) GetSpamPowNumberOfPastBlocks 

func (x *LastBlockHeightResponse) GetSpamPowNumberOfPastBlocks() uint32

func (*LastBlockHeightResponse) GetSpamPowNumberOfTxPerBlock 

func (x *LastBlockHeightResponse) GetSpamPowNumberOfTxPerBlock() uint32

func (*LastBlockHeightResponse) ProtoMessage 

func (*LastBlockHeightResponse) ProtoMessage()

func (*LastBlockHeightResponse) ProtoReflect 

func (x *LastBlockHeightResponse) ProtoReflect() protoreflect.Message

func (*LastBlockHeightResponse) Reset 

func (x *LastBlockHeightResponse) Reset()

func (*LastBlockHeightResponse) String 

func (x *LastBlockHeightResponse) String() string

type ListAccountsRequest 

type ListAccountsRequest struct {
	Party  string `protobuf:"bytes,1,opt,name=party,proto3" json:"party,omitempty"`
	Market string `protobuf:"bytes,2,opt,name=market,proto3" json:"market,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAccountsRequest) Descriptor deprecated 

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

Deprecated: Use ListAccountsRequest.ProtoReflect.Descriptor instead.

func (*ListAccountsRequest) GetMarket 

func (x *ListAccountsRequest) GetMarket() string

func (*ListAccountsRequest) GetParty 

func (x *ListAccountsRequest) GetParty() string

func (*ListAccountsRequest) ProtoMessage 

func (*ListAccountsRequest) ProtoMessage()

func (*ListAccountsRequest) ProtoReflect 

func (x *ListAccountsRequest) ProtoReflect() protoreflect.Message

func (*ListAccountsRequest) Reset 

func (x *ListAccountsRequest) Reset()

func (*ListAccountsRequest) String 

func (x *ListAccountsRequest) String() string

type ListAccountsResponse 

type ListAccountsResponse struct {
	Accounts []*Account `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAccountsResponse) Descriptor deprecated 

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

Deprecated: Use ListAccountsResponse.ProtoReflect.Descriptor instead.

func (*ListAccountsResponse) GetAccounts 

func (x *ListAccountsResponse) GetAccounts() []*Account

func (*ListAccountsResponse) ProtoMessage 

func (*ListAccountsResponse) ProtoMessage()

func (*ListAccountsResponse) ProtoReflect 

func (x *ListAccountsResponse) ProtoReflect() protoreflect.Message

func (*ListAccountsResponse) Reset 

func (x *ListAccountsResponse) Reset()

func (*ListAccountsResponse) String 

func (x *ListAccountsResponse) String() string

type ListAssetsRequest 

type ListAssetsRequest struct {
	Asset string `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"` // optional ID
	// contains filtered or unexported fields
}

func (*ListAssetsRequest) Descriptor deprecated 

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

Deprecated: Use ListAssetsRequest.ProtoReflect.Descriptor instead.

func (*ListAssetsRequest) GetAsset 

func (x *ListAssetsRequest) GetAsset() string

func (*ListAssetsRequest) ProtoMessage 

func (*ListAssetsRequest) ProtoMessage()

func (*ListAssetsRequest) ProtoReflect 

func (x *ListAssetsRequest) ProtoReflect() protoreflect.Message

func (*ListAssetsRequest) Reset 

func (x *ListAssetsRequest) Reset()

func (*ListAssetsRequest) String 

func (x *ListAssetsRequest) String() string

type ListAssetsResponse 

type ListAssetsResponse struct {
	Assets []*vega.Asset `protobuf:"bytes,1,rep,name=assets,proto3" json:"assets,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAssetsResponse) Descriptor deprecated 

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

Deprecated: Use ListAssetsResponse.ProtoReflect.Descriptor instead.

func (*ListAssetsResponse) GetAssets 

func (x *ListAssetsResponse) GetAssets() []*vega.Asset

func (*ListAssetsResponse) ProtoMessage 

func (*ListAssetsResponse) ProtoMessage()

func (*ListAssetsResponse) ProtoReflect 

func (x *ListAssetsResponse) ProtoReflect() protoreflect.Message

func (*ListAssetsResponse) Reset 

func (x *ListAssetsResponse) Reset()

func (*ListAssetsResponse) String 

func (x *ListAssetsResponse) String() string

type ListDelegationsRequest 

type ListDelegationsRequest struct {
	Party    string `protobuf:"bytes,1,opt,name=party,proto3" json:"party,omitempty"`
	Node     string `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	EpochSeq string `protobuf:"bytes,3,opt,name=epoch_seq,json=epochSeq,proto3" json:"epoch_seq,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDelegationsRequest) Descriptor deprecated 

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

Deprecated: Use ListDelegationsRequest.ProtoReflect.Descriptor instead.

func (*ListDelegationsRequest) GetEpochSeq 

func (x *ListDelegationsRequest) GetEpochSeq() string

func (*ListDelegationsRequest) GetNode 

func (x *ListDelegationsRequest) GetNode() string

func (*ListDelegationsRequest) GetParty 

func (x *ListDelegationsRequest) GetParty() string

func (*ListDelegationsRequest) ProtoMessage 

func (*ListDelegationsRequest) ProtoMessage()

func (*ListDelegationsRequest) ProtoReflect 

func (x *ListDelegationsRequest) ProtoReflect() protoreflect.Message

func (*ListDelegationsRequest) Reset 

func (x *ListDelegationsRequest) Reset()

func (*ListDelegationsRequest) String 

func (x *ListDelegationsRequest) String() string

type ListDelegationsResponse 

type ListDelegationsResponse struct {
	Delegations []*vega.Delegation `protobuf:"bytes,1,rep,name=delegations,proto3" json:"delegations,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDelegationsResponse) Descriptor deprecated 

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

Deprecated: Use ListDelegationsResponse.ProtoReflect.Descriptor instead.

func (*ListDelegationsResponse) GetDelegations 

func (x *ListDelegationsResponse) GetDelegations() []*vega.Delegation

func (*ListDelegationsResponse) ProtoMessage 

func (*ListDelegationsResponse) ProtoMessage()

func (*ListDelegationsResponse) ProtoReflect 

func (x *ListDelegationsResponse) ProtoReflect() protoreflect.Message

func (*ListDelegationsResponse) Reset 

func (x *ListDelegationsResponse) Reset()

func (*ListDelegationsResponse) String 

func (x *ListDelegationsResponse) String() string

type ListMarketsDataRequest 

type ListMarketsDataRequest struct {
	Market string `protobuf:"bytes,1,opt,name=market,proto3" json:"market,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMarketsDataRequest) Descriptor deprecated 

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

Deprecated: Use ListMarketsDataRequest.ProtoReflect.Descriptor instead.

func (*ListMarketsDataRequest) GetMarket 

func (x *ListMarketsDataRequest) GetMarket() string

func (*ListMarketsDataRequest) ProtoMessage 

func (*ListMarketsDataRequest) ProtoMessage()

func (*ListMarketsDataRequest) ProtoReflect 

func (x *ListMarketsDataRequest) ProtoReflect() protoreflect.Message

func (*ListMarketsDataRequest) Reset 

func (x *ListMarketsDataRequest) Reset()

func (*ListMarketsDataRequest) String 

func (x *ListMarketsDataRequest) String() string

type ListMarketsDataResponse 

type ListMarketsDataResponse struct {
	MarketsData []*vega.MarketData `protobuf:"bytes,1,rep,name=markets_data,json=marketsData,proto3" json:"markets_data,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMarketsDataResponse) Descriptor deprecated 

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

Deprecated: Use ListMarketsDataResponse.ProtoReflect.Descriptor instead.

func (*ListMarketsDataResponse) GetMarketsData 

func (x *ListMarketsDataResponse) GetMarketsData() []*vega.MarketData

func (*ListMarketsDataResponse) ProtoMessage 

func (*ListMarketsDataResponse) ProtoMessage()

func (*ListMarketsDataResponse) ProtoReflect 

func (x *ListMarketsDataResponse) ProtoReflect() protoreflect.Message

func (*ListMarketsDataResponse) Reset 

func (x *ListMarketsDataResponse) Reset()

func (*ListMarketsDataResponse) String 

func (x *ListMarketsDataResponse) String() string

type ListMarketsRequest 

type ListMarketsRequest struct {
	Market string `protobuf:"bytes,1,opt,name=market,proto3" json:"market,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMarketsRequest) Descriptor deprecated 

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

Deprecated: Use ListMarketsRequest.ProtoReflect.Descriptor instead.

func (*ListMarketsRequest) GetMarket 

func (x *ListMarketsRequest) GetMarket() string

func (*ListMarketsRequest) ProtoMessage 

func (*ListMarketsRequest) ProtoMessage()

func (*ListMarketsRequest) ProtoReflect 

func (x *ListMarketsRequest) ProtoReflect() protoreflect.Message

func (*ListMarketsRequest) Reset 

func (x *ListMarketsRequest) Reset()

func (*ListMarketsRequest) String 

func (x *ListMarketsRequest) String() string

type ListMarketsResponse 

type ListMarketsResponse struct {
	Markets []*vega.Market `protobuf:"bytes,1,rep,name=markets,proto3" json:"markets,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMarketsResponse) Descriptor deprecated 

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

Deprecated: Use ListMarketsResponse.ProtoReflect.Descriptor instead.

func (*ListMarketsResponse) GetMarkets 

func (x *ListMarketsResponse) GetMarkets() []*vega.Market

func (*ListMarketsResponse) ProtoMessage 

func (*ListMarketsResponse) ProtoMessage()

func (*ListMarketsResponse) ProtoReflect 

func (x *ListMarketsResponse) ProtoReflect() protoreflect.Message

func (*ListMarketsResponse) Reset 

func (x *ListMarketsResponse) Reset()

func (*ListMarketsResponse) String 

func (x *ListMarketsResponse) String() string

type ListNetworkLimitsRequest 

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

func (*ListNetworkLimitsRequest) Descriptor deprecated 

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

Deprecated: Use ListNetworkLimitsRequest.ProtoReflect.Descriptor instead.

func (*ListNetworkLimitsRequest) ProtoMessage 

func (*ListNetworkLimitsRequest) ProtoMessage()

func (*ListNetworkLimitsRequest) ProtoReflect 

func (x *ListNetworkLimitsRequest) ProtoReflect() protoreflect.Message

func (*ListNetworkLimitsRequest) Reset 

func (x *ListNetworkLimitsRequest) Reset()

func (*ListNetworkLimitsRequest) String 

func (x *ListNetworkLimitsRequest) String() string

type ListNetworkLimitsResponse 

type ListNetworkLimitsResponse struct {
	NetworkLimits *vega.NetworkLimits `protobuf:"bytes,1,opt,name=network_limits,json=networkLimits,proto3" json:"network_limits,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNetworkLimitsResponse) Descriptor deprecated 

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

Deprecated: Use ListNetworkLimitsResponse.ProtoReflect.Descriptor instead.

func (*ListNetworkLimitsResponse) GetNetworkLimits 

func (x *ListNetworkLimitsResponse) GetNetworkLimits() *vega.NetworkLimits

func (*ListNetworkLimitsResponse) ProtoMessage 

func (*ListNetworkLimitsResponse) ProtoMessage()

func (*ListNetworkLimitsResponse) ProtoReflect 

func (x *ListNetworkLimitsResponse) ProtoReflect() protoreflect.Message

func (*ListNetworkLimitsResponse) Reset 

func (x *ListNetworkLimitsResponse) Reset()

func (*ListNetworkLimitsResponse) String 

func (x *ListNetworkLimitsResponse) String() string

type ListNetworkParametersRequest 

type ListNetworkParametersRequest struct {
	NetworkParameterKey string `protobuf:"bytes,1,opt,name=network_parameter_key,json=networkParameterKey,proto3" json:"network_parameter_key,omitempty"` // optional parameter key
	// contains filtered or unexported fields
}

func (*ListNetworkParametersRequest) Descriptor deprecated 

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

Deprecated: Use ListNetworkParametersRequest.ProtoReflect.Descriptor instead.

func (*ListNetworkParametersRequest) GetNetworkParameterKey 

func (x *ListNetworkParametersRequest) GetNetworkParameterKey() string

func (*ListNetworkParametersRequest) ProtoMessage 

func (*ListNetworkParametersRequest) ProtoMessage()

func (*ListNetworkParametersRequest) ProtoReflect 

func (x *ListNetworkParametersRequest) ProtoReflect() protoreflect.Message

func (*ListNetworkParametersRequest) Reset 

func (x *ListNetworkParametersRequest) Reset()

func (*ListNetworkParametersRequest) String 

func (x *ListNetworkParametersRequest) String() string

type ListNetworkParametersResponse 

type ListNetworkParametersResponse struct {
	NetworkParameters []*vega.NetworkParameter `protobuf:"bytes,1,rep,name=network_parameters,json=networkParameters,proto3" json:"network_parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNetworkParametersResponse) Descriptor deprecated 

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

Deprecated: Use ListNetworkParametersResponse.ProtoReflect.Descriptor instead.

func (*ListNetworkParametersResponse) GetNetworkParameters 

func (x *ListNetworkParametersResponse) GetNetworkParameters() []*vega.NetworkParameter

func (*ListNetworkParametersResponse) ProtoMessage 

func (*ListNetworkParametersResponse) ProtoMessage()

func (*ListNetworkParametersResponse) ProtoReflect 

func (x *ListNetworkParametersResponse) ProtoReflect() protoreflect.Message

func (*ListNetworkParametersResponse) Reset 

func (x *ListNetworkParametersResponse) Reset()

func (*ListNetworkParametersResponse) String 

func (x *ListNetworkParametersResponse) String() string

type ListPartiesRequest 

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

func (*ListPartiesRequest) Descriptor deprecated 

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

Deprecated: Use ListPartiesRequest.ProtoReflect.Descriptor instead.

func (*ListPartiesRequest) ProtoMessage 

func (*ListPartiesRequest) ProtoMessage()

func (*ListPartiesRequest) ProtoReflect 

func (x *ListPartiesRequest) ProtoReflect() protoreflect.Message

func (*ListPartiesRequest) Reset 

func (x *ListPartiesRequest) Reset()

func (*ListPartiesRequest) String 

func (x *ListPartiesRequest) String() string

type ListPartiesResponse 

type ListPartiesResponse struct {
	Parties []*vega.Party `protobuf:"bytes,1,rep,name=parties,proto3" json:"parties,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPartiesResponse) Descriptor deprecated 

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

Deprecated: Use ListPartiesResponse.ProtoReflect.Descriptor instead.

func (*ListPartiesResponse) GetParties 

func (x *ListPartiesResponse) GetParties() []*vega.Party

func (*ListPartiesResponse) ProtoMessage 

func (*ListPartiesResponse) ProtoMessage()

func (*ListPartiesResponse) ProtoReflect 

func (x *ListPartiesResponse) ProtoReflect() protoreflect.Message

func (*ListPartiesResponse) Reset 

func (x *ListPartiesResponse) Reset()

func (*ListPartiesResponse) String 

func (x *ListPartiesResponse) String() string

type ListPartiesStakeRequest 

type ListPartiesStakeRequest struct {
	Party string `protobuf:"bytes,1,opt,name=party,proto3" json:"party,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPartiesStakeRequest) Descriptor deprecated 

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

Deprecated: Use ListPartiesStakeRequest.ProtoReflect.Descriptor instead.

func (*ListPartiesStakeRequest) GetParty 

func (x *ListPartiesStakeRequest) GetParty() string

func (*ListPartiesStakeRequest) ProtoMessage 

func (*ListPartiesStakeRequest) ProtoMessage()

func (*ListPartiesStakeRequest) ProtoReflect 

func (x *ListPartiesStakeRequest) ProtoReflect() protoreflect.Message

func (*ListPartiesStakeRequest) Reset 

func (x *ListPartiesStakeRequest) Reset()

func (*ListPartiesStakeRequest) String 

func (x *ListPartiesStakeRequest) String() string

type ListPartiesStakeResponse 

type ListPartiesStakeResponse struct {
	PartiesStake []*PartyStake `protobuf:"bytes,1,rep,name=parties_stake,json=partiesStake,proto3" json:"parties_stake,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPartiesStakeResponse) Descriptor deprecated 

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

Deprecated: Use ListPartiesStakeResponse.ProtoReflect.Descriptor instead.

func (*ListPartiesStakeResponse) GetPartiesStake 

func (x *ListPartiesStakeResponse) GetPartiesStake() []*PartyStake

func (*ListPartiesStakeResponse) ProtoMessage 

func (*ListPartiesStakeResponse) ProtoMessage()

func (*ListPartiesStakeResponse) ProtoReflect 

func (x *ListPartiesStakeResponse) ProtoReflect() protoreflect.Message

func (*ListPartiesStakeResponse) Reset 

func (x *ListPartiesStakeResponse) Reset()

func (*ListPartiesStakeResponse) String 

func (x *ListPartiesStakeResponse) String() string

type ListProposalsRequest 

type ListProposalsRequest struct {
	Proposal string `protobuf:"bytes,1,opt,name=proposal,proto3" json:"proposal,omitempty"` // optional ID
	Proposer string `protobuf:"bytes,2,opt,name=proposer,proto3" json:"proposer,omitempty"` // optional party
	// contains filtered or unexported fields
}

func (*ListProposalsRequest) Descriptor deprecated 

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

Deprecated: Use ListProposalsRequest.ProtoReflect.Descriptor instead.

func (*ListProposalsRequest) GetProposal 

func (x *ListProposalsRequest) GetProposal() string

func (*ListProposalsRequest) GetProposer 

func (x *ListProposalsRequest) GetProposer() string

func (*ListProposalsRequest) ProtoMessage 

func (*ListProposalsRequest) ProtoMessage()

func (*ListProposalsRequest) ProtoReflect 

func (x *ListProposalsRequest) ProtoReflect() protoreflect.Message

func (*ListProposalsRequest) Reset 

func (x *ListProposalsRequest) Reset()

func (*ListProposalsRequest) String 

func (x *ListProposalsRequest) String() string

type ListProposalsResponse 

type ListProposalsResponse struct {
	Proposals []*vega.Proposal `protobuf:"bytes,1,rep,name=proposals,proto3" json:"proposals,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProposalsResponse) Descriptor deprecated 

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

Deprecated: Use ListProposalsResponse.ProtoReflect.Descriptor instead.

func (*ListProposalsResponse) GetProposals 

func (x *ListProposalsResponse) GetProposals() []*vega.Proposal

func (*ListProposalsResponse) ProtoMessage 

func (*ListProposalsResponse) ProtoMessage()

func (*ListProposalsResponse) ProtoReflect 

func (x *ListProposalsResponse) ProtoReflect() protoreflect.Message

func (*ListProposalsResponse) Reset 

func (x *ListProposalsResponse) Reset()

func (*ListProposalsResponse) String 

func (x *ListProposalsResponse) String() string

type ListValidatorsRequest 

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

func (*ListValidatorsRequest) Descriptor deprecated 

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

Deprecated: Use ListValidatorsRequest.ProtoReflect.Descriptor instead.

func (*ListValidatorsRequest) ProtoMessage 

func (*ListValidatorsRequest) ProtoMessage()

func (*ListValidatorsRequest) ProtoReflect 

func (x *ListValidatorsRequest) ProtoReflect() protoreflect.Message

func (*ListValidatorsRequest) Reset 

func (x *ListValidatorsRequest) Reset()

func (*ListValidatorsRequest) String 

func (x *ListValidatorsRequest) String() string

type ListValidatorsResponse 

type ListValidatorsResponse struct {
	Validators []*v1.ValidatorUpdate `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators,omitempty"`
	// contains filtered or unexported fields
}

func (*ListValidatorsResponse) Descriptor deprecated 

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

Deprecated: Use ListValidatorsResponse.ProtoReflect.Descriptor instead.

func (*ListValidatorsResponse) GetValidators 

func (x *ListValidatorsResponse) GetValidators() []*v1.ValidatorUpdate

func (*ListValidatorsResponse) ProtoMessage 

func (*ListValidatorsResponse) ProtoMessage()

func (*ListValidatorsResponse) ProtoReflect 

func (x *ListValidatorsResponse) ProtoReflect() protoreflect.Message

func (*ListValidatorsResponse) Reset 

func (x *ListValidatorsResponse) Reset()

func (*ListValidatorsResponse) String 

func (x *ListValidatorsResponse) String() string

type ListVotesRequest 

type ListVotesRequest struct {
	Proposal string `protobuf:"bytes,1,opt,name=proposal,proto3" json:"proposal,omitempty"`
	Party    string `protobuf:"bytes,2,opt,name=party,proto3" json:"party,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVotesRequest) Descriptor deprecated 

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

Deprecated: Use ListVotesRequest.ProtoReflect.Descriptor instead.

func (*ListVotesRequest) GetParty 

func (x *ListVotesRequest) GetParty() string

func (*ListVotesRequest) GetProposal 

func (x *ListVotesRequest) GetProposal() string

func (*ListVotesRequest) ProtoMessage 

func (*ListVotesRequest) ProtoMessage()

func (*ListVotesRequest) ProtoReflect 

func (x *ListVotesRequest) ProtoReflect() protoreflect.Message

func (*ListVotesRequest) Reset 

func (x *ListVotesRequest) Reset()

func (*ListVotesRequest) String 

func (x *ListVotesRequest) String() string

type ListVotesResponse 

type ListVotesResponse struct {
	Votes []*vega.Vote `protobuf:"bytes,1,rep,name=votes,proto3" json:"votes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVotesResponse) Descriptor deprecated 

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

Deprecated: Use ListVotesResponse.ProtoReflect.Descriptor instead.

func (*ListVotesResponse) GetVotes 

func (x *ListVotesResponse) GetVotes() []*vega.Vote

func (*ListVotesResponse) ProtoMessage 

func (*ListVotesResponse) ProtoMessage()

func (*ListVotesResponse) ProtoReflect 

func (x *ListVotesResponse) ProtoReflect() protoreflect.Message

func (*ListVotesResponse) Reset 

func (x *ListVotesResponse) Reset()

func (*ListVotesResponse) String 

func (x *ListVotesResponse) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*ObserveEventBusRequest) Descriptor deprecated 

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

Deprecated: Use ObserveEventBusRequest.ProtoReflect.Descriptor instead.

func (*ObserveEventBusRequest) GetBatchSize 

func (x *ObserveEventBusRequest) GetBatchSize() int64

func (*ObserveEventBusRequest) GetMarketId 

func (x *ObserveEventBusRequest) GetMarketId() string

func (*ObserveEventBusRequest) GetPartyId 

func (x *ObserveEventBusRequest) GetPartyId() string

func (*ObserveEventBusRequest) GetType 

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

func (*ObserveEventBusRequest) ProtoMessage 

func (*ObserveEventBusRequest) ProtoMessage()

func (*ObserveEventBusRequest) ProtoReflect 

func (x *ObserveEventBusRequest) ProtoReflect() protoreflect.Message

func (*ObserveEventBusRequest) Reset 

func (x *ObserveEventBusRequest) Reset()

func (*ObserveEventBusRequest) String 

func (x *ObserveEventBusRequest) String() string

type ObserveEventBusResponse 

type ObserveEventBusResponse struct {

	// One or more events
	Events []*v11.BusEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ObserveEventBusResponse) Descriptor deprecated 

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

Deprecated: Use ObserveEventBusResponse.ProtoReflect.Descriptor instead.

func (*ObserveEventBusResponse) GetEvents 

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

func (*ObserveEventBusResponse) ProtoMessage 

func (*ObserveEventBusResponse) ProtoMessage()

func (*ObserveEventBusResponse) ProtoReflect 

func (x *ObserveEventBusResponse) ProtoReflect() protoreflect.Message

func (*ObserveEventBusResponse) Reset 

func (x *ObserveEventBusResponse) Reset()

func (*ObserveEventBusResponse) String 

func (x *ObserveEventBusResponse) String() string

type PartyStake 

type PartyStake struct {
	Party                 string             `protobuf:"bytes,1,opt,name=party,proto3" json:"party,omitempty"`
	CurrentStakeAvailable string             `` /* 126-byte string literal not displayed */
	StakeLinkings         []*v1.StakeLinking `protobuf:"bytes,3,rep,name=stake_linkings,json=stakeLinkings,proto3" json:"stake_linkings,omitempty"`
	// contains filtered or unexported fields
}

func (*PartyStake) Descriptor deprecated 

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

Deprecated: Use PartyStake.ProtoReflect.Descriptor instead.

func (*PartyStake) GetCurrentStakeAvailable 

func (x *PartyStake) GetCurrentStakeAvailable() string

func (*PartyStake) GetParty 

func (x *PartyStake) GetParty() string

func (*PartyStake) GetStakeLinkings 

func (x *PartyStake) GetStakeLinkings() []*v1.StakeLinking

func (*PartyStake) ProtoMessage 

func (*PartyStake) ProtoMessage()

func (*PartyStake) ProtoReflect 

func (x *PartyStake) ProtoReflect() protoreflect.Message

func (*PartyStake) Reset 

func (x *PartyStake) Reset()

func (*PartyStake) String 

func (x *PartyStake) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*PropagateChainEventRequest) Descriptor deprecated 

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

Deprecated: Use PropagateChainEventRequest.ProtoReflect.Descriptor instead.

func (*PropagateChainEventRequest) GetEvent 

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

func (*PropagateChainEventRequest) GetPubKey 

func (x *PropagateChainEventRequest) GetPubKey() string

func (*PropagateChainEventRequest) GetSignature 

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

func (*PropagateChainEventRequest) ProtoMessage 

func (*PropagateChainEventRequest) ProtoMessage()

func (*PropagateChainEventRequest) ProtoReflect 

func (x *PropagateChainEventRequest) ProtoReflect() protoreflect.Message

func (*PropagateChainEventRequest) Reset 

func (x *PropagateChainEventRequest) Reset()

func (*PropagateChainEventRequest) String 

func (x *PropagateChainEventRequest) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*PropagateChainEventResponse) Descriptor deprecated 

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

Deprecated: Use PropagateChainEventResponse.ProtoReflect.Descriptor instead.

func (*PropagateChainEventResponse) GetSuccess 

func (x *PropagateChainEventResponse) GetSuccess() bool

func (*PropagateChainEventResponse) ProtoMessage 

func (*PropagateChainEventResponse) ProtoMessage()

func (*PropagateChainEventResponse) ProtoReflect 

func (x *PropagateChainEventResponse) ProtoReflect() protoreflect.Message

func (*PropagateChainEventResponse) Reset 

func (x *PropagateChainEventResponse) Reset()

func (*PropagateChainEventResponse) String 

func (x *PropagateChainEventResponse) String() string

type Statistics 

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 */
	// Current block hash
	BlockHash string `protobuf:"bytes,35,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	// Current epoch
	EpochSeq uint64 `protobuf:"varint,36,opt,name=epoch_seq,json=epochSeq,proto3" json:"epoch_seq,omitempty"`
	// Epoch start time
	EpochStartTime string `protobuf:"bytes,37,opt,name=epoch_start_time,json=epochStartTime,proto3" json:"epoch_start_time,omitempty"`
	// Epoch expected end time
	EpochExpiryTime string `protobuf:"bytes,38,opt,name=epoch_expiry_time,json=epochExpiryTime,proto3" json:"epoch_expiry_time,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Statistics) Descriptor deprecated 

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

Deprecated: Use Statistics.ProtoReflect.Descriptor instead.

func (*Statistics) GetAccountSubscriptions 

func (x *Statistics) GetAccountSubscriptions() uint32

func (*Statistics) GetAppVersion 

func (x *Statistics) GetAppVersion() string

func (*Statistics) GetAppVersionHash 

func (x *Statistics) GetAppVersionHash() string

func (*Statistics) GetAverageOrdersPerBlock 

func (x *Statistics) GetAverageOrdersPerBlock() uint64

func (*Statistics) GetAverageTxBytes 

func (x *Statistics) GetAverageTxBytes() uint64

func (*Statistics) GetBacklogLength 

func (x *Statistics) GetBacklogLength() uint64

func (*Statistics) GetBlockDuration 

func (x *Statistics) GetBlockDuration() uint64

func (*Statistics) GetBlockHash 

func (x *Statistics) GetBlockHash() string

func (*Statistics) GetBlockHeight 

func (x *Statistics) GetBlockHeight() uint64

func (*Statistics) GetCandleSubscriptions 

func (x *Statistics) GetCandleSubscriptions() uint32

func (*Statistics) GetChainId 

func (x *Statistics) GetChainId() string

func (*Statistics) GetChainVersion 

func (x *Statistics) GetChainVersion() string

func (*Statistics) GetCurrentTime 

func (x *Statistics) GetCurrentTime() string

func (*Statistics) GetEpochExpiryTime added in v0.59.0 

func (x *Statistics) GetEpochExpiryTime() string

func (*Statistics) GetEpochSeq added in v0.59.0 

func (x *Statistics) GetEpochSeq() uint64

func (*Statistics) GetEpochStartTime added in v0.59.0 

func (x *Statistics) GetEpochStartTime() string

func (*Statistics) GetGenesisTime 

func (x *Statistics) GetGenesisTime() string

func (*Statistics) GetMarketDataSubscriptions 

func (x *Statistics) GetMarketDataSubscriptions() uint32

func (*Statistics) GetMarketDepthSubscriptions 

func (x *Statistics) GetMarketDepthSubscriptions() uint32

func (*Statistics) GetMarketDepthUpdatesSubscriptions 

func (x *Statistics) GetMarketDepthUpdatesSubscriptions() uint32

func (*Statistics) GetOrderSubscriptions 

func (x *Statistics) GetOrderSubscriptions() uint32

func (*Statistics) GetOrdersPerSecond 

func (x *Statistics) GetOrdersPerSecond() uint64

func (*Statistics) GetPositionsSubscriptions 

func (x *Statistics) GetPositionsSubscriptions() uint32

func (*Statistics) GetStatus 

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

func (*Statistics) GetTotalAmendOrder 

func (x *Statistics) GetTotalAmendOrder() uint64

func (*Statistics) GetTotalCancelOrder 

func (x *Statistics) GetTotalCancelOrder() uint64

func (*Statistics) GetTotalCreateOrder 

func (x *Statistics) GetTotalCreateOrder() uint64

func (*Statistics) GetTotalMarkets 

func (x *Statistics) GetTotalMarkets() uint64

func (*Statistics) GetTotalOrders 

func (x *Statistics) GetTotalOrders() uint64

func (*Statistics) GetTotalPeers 

func (x *Statistics) GetTotalPeers() uint64

func (*Statistics) GetTotalTrades 

func (x *Statistics) GetTotalTrades() uint64

func (*Statistics) GetTradeSubscriptions 

func (x *Statistics) GetTradeSubscriptions() uint32

func (*Statistics) GetTradesPerSecond 

func (x *Statistics) GetTradesPerSecond() uint64

func (*Statistics) GetTxPerBlock 

func (x *Statistics) GetTxPerBlock() uint64

func (*Statistics) GetUptime 

func (x *Statistics) GetUptime() string

func (*Statistics) GetVegaTime 

func (x *Statistics) GetVegaTime() string

func (*Statistics) ProtoMessage 

func (*Statistics) ProtoMessage()

func (*Statistics) ProtoReflect 

func (x *Statistics) ProtoReflect() protoreflect.Message

func (*Statistics) Reset 

func (x *Statistics) Reset()

func (*Statistics) String 

func (x *Statistics) String() string

type StatisticsRequest 

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

A a request for statistics about the Vega network

func (*StatisticsRequest) Descriptor deprecated 

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

Deprecated: Use StatisticsRequest.ProtoReflect.Descriptor instead.

func (*StatisticsRequest) ProtoMessage 

func (*StatisticsRequest) ProtoMessage()

func (*StatisticsRequest) ProtoReflect 

func (x *StatisticsRequest) ProtoReflect() protoreflect.Message

func (*StatisticsRequest) Reset 

func (x *StatisticsRequest) Reset()

func (*StatisticsRequest) String 

func (x *StatisticsRequest) String() string

type StatisticsResponse 

type StatisticsResponse struct {
	Statistics *Statistics `protobuf:"bytes,1,opt,name=statistics,proto3" json:"statistics,omitempty"`
	// contains filtered or unexported fields
}

func (*StatisticsResponse) Descriptor deprecated 

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

Deprecated: Use StatisticsResponse.ProtoReflect.Descriptor instead.

func (*StatisticsResponse) GetStatistics 

func (x *StatisticsResponse) GetStatistics() *Statistics

func (*StatisticsResponse) ProtoMessage 

func (*StatisticsResponse) ProtoMessage()

func (*StatisticsResponse) ProtoReflect 

func (x *StatisticsResponse) ProtoReflect() protoreflect.Message

func (*StatisticsResponse) Reset 

func (x *StatisticsResponse) Reset()

func (*StatisticsResponse) String 

func (x *StatisticsResponse) String() string

type SubmitRawTransactionRequest 

type SubmitRawTransactionRequest struct {

	// A bundle of signed payload and signature marshalled into a byte array, to form a transaction that will be submitted to the Vega blockchain
	Tx []byte `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 SubmitRawTransactionRequest_Type `protobuf:"varint,2,opt,name=type,proto3,enum=vega.api.v1.SubmitRawTransactionRequest_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Request for submitting a version agnostic transaction on Vega

func (*SubmitRawTransactionRequest) Descriptor deprecated 

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

Deprecated: Use SubmitRawTransactionRequest.ProtoReflect.Descriptor instead.

func (*SubmitRawTransactionRequest) GetTx 

func (x *SubmitRawTransactionRequest) GetTx() []byte

func (*SubmitRawTransactionRequest) GetType 

func (x *SubmitRawTransactionRequest) GetType() SubmitRawTransactionRequest_Type

func (*SubmitRawTransactionRequest) ProtoMessage 

func (*SubmitRawTransactionRequest) ProtoMessage()

func (*SubmitRawTransactionRequest) ProtoReflect 

func (x *SubmitRawTransactionRequest) ProtoReflect() protoreflect.Message

func (*SubmitRawTransactionRequest) Reset 

func (x *SubmitRawTransactionRequest) Reset()

func (*SubmitRawTransactionRequest) String 

func (x *SubmitRawTransactionRequest) String() string

type SubmitRawTransactionRequest_Type 

type SubmitRawTransactionRequest_Type int32

Blockchain transaction type 

const (
	SubmitRawTransactionRequest_TYPE_UNSPECIFIED SubmitRawTransactionRequest_Type = 0
	// The transaction will be submitted without waiting for response
	SubmitRawTransactionRequest_TYPE_ASYNC SubmitRawTransactionRequest_Type = 1
	// The transaction will be submitted, and blocking until the
	// tendermint mempool return a response
	SubmitRawTransactionRequest_TYPE_SYNC SubmitRawTransactionRequest_Type = 2
	// The transaction will submitted, and blocking until the tendermint
	// network will have committed it into a block
	SubmitRawTransactionRequest_TYPE_COMMIT SubmitRawTransactionRequest_Type = 3
)

func (SubmitRawTransactionRequest_Type) Descriptor 

func (SubmitRawTransactionRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (SubmitRawTransactionRequest_Type) Enum 

func (x SubmitRawTransactionRequest_Type) Enum() *SubmitRawTransactionRequest_Type

func (SubmitRawTransactionRequest_Type) EnumDescriptor deprecated 

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

Deprecated: Use SubmitRawTransactionRequest_Type.Descriptor instead.

func (SubmitRawTransactionRequest_Type) Number 

func (x SubmitRawTransactionRequest_Type) Number() protoreflect.EnumNumber

func (SubmitRawTransactionRequest_Type) String 

func (x SubmitRawTransactionRequest_Type) String() string

func (SubmitRawTransactionRequest_Type) Type 

func (SubmitRawTransactionRequest_Type) Type() protoreflect.EnumType

type SubmitRawTransactionResponse 

type SubmitRawTransactionResponse 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"`
	// Hash of the transaction, if accepted
	TxHash string `protobuf:"bytes,2,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	Code   uint32 `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	Data   string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Log    string `protobuf:"bytes,5,opt,name=log,proto3" json:"log,omitempty"`
	Height int64  `protobuf:"varint,6,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

Response for submitting a version agnostic transaction on Vega

func (*SubmitRawTransactionResponse) Descriptor deprecated 

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

Deprecated: Use SubmitRawTransactionResponse.ProtoReflect.Descriptor instead.

func (*SubmitRawTransactionResponse) GetCode 

func (x *SubmitRawTransactionResponse) GetCode() uint32

func (*SubmitRawTransactionResponse) GetData 

func (x *SubmitRawTransactionResponse) GetData() string

func (*SubmitRawTransactionResponse) GetHeight 

func (x *SubmitRawTransactionResponse) GetHeight() int64

func (*SubmitRawTransactionResponse) GetLog 

func (x *SubmitRawTransactionResponse) GetLog() string

func (*SubmitRawTransactionResponse) GetSuccess 

func (x *SubmitRawTransactionResponse) GetSuccess() bool

func (*SubmitRawTransactionResponse) GetTxHash 

func (x *SubmitRawTransactionResponse) GetTxHash() string

func (*SubmitRawTransactionResponse) ProtoMessage 

func (*SubmitRawTransactionResponse) ProtoMessage()

func (*SubmitRawTransactionResponse) ProtoReflect 

func (x *SubmitRawTransactionResponse) ProtoReflect() protoreflect.Message

func (*SubmitRawTransactionResponse) Reset 

func (x *SubmitRawTransactionResponse) Reset()

func (*SubmitRawTransactionResponse) String 

func (x *SubmitRawTransactionResponse) String() string

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=vega.api.v1.SubmitTransactionRequest_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Request for submitting a transaction v2 on Vega

func (*SubmitTransactionRequest) Descriptor deprecated 

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

Deprecated: Use SubmitTransactionRequest.ProtoReflect.Descriptor instead.

func (*SubmitTransactionRequest) GetTx 

func (x *SubmitTransactionRequest) GetTx() *v1.Transaction

func (*SubmitTransactionRequest) GetType 

func (x *SubmitTransactionRequest) GetType() SubmitTransactionRequest_Type

func (*SubmitTransactionRequest) ProtoMessage 

func (*SubmitTransactionRequest) ProtoMessage()

func (*SubmitTransactionRequest) ProtoReflect 

func (x *SubmitTransactionRequest) ProtoReflect() protoreflect.Message

func (*SubmitTransactionRequest) Reset 

func (x *SubmitTransactionRequest) Reset()

func (*SubmitTransactionRequest) String 

func (x *SubmitTransactionRequest) String() string

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) Descriptor 

func (SubmitTransactionRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (SubmitTransactionRequest_Type) Enum 

func (x SubmitTransactionRequest_Type) Enum() *SubmitTransactionRequest_Type

func (SubmitTransactionRequest_Type) EnumDescriptor deprecated 

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

Deprecated: Use SubmitTransactionRequest_Type.Descriptor instead.

func (SubmitTransactionRequest_Type) Number 

func (x SubmitTransactionRequest_Type) Number() protoreflect.EnumNumber

func (SubmitTransactionRequest_Type) String 

func (x SubmitTransactionRequest_Type) String() string

func (SubmitTransactionRequest_Type) Type 

func (SubmitTransactionRequest_Type) Type() protoreflect.EnumType

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"`
	// Hash of the transaction, if accepted
	TxHash string `protobuf:"bytes,2,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// Result code success if unsucessful
	Code uint32 `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	// Data for details
	Data string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Log  string `protobuf:"bytes,5,opt,name=log,proto3" json:"log,omitempty"`
	// Height for commit
	Height int64 `protobuf:"varint,6,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

Response for submitting a transaction v2 on Vega

func (*SubmitTransactionResponse) Descriptor deprecated 

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

Deprecated: Use SubmitTransactionResponse.ProtoReflect.Descriptor instead.

func (*SubmitTransactionResponse) GetCode 

func (x *SubmitTransactionResponse) GetCode() uint32

func (*SubmitTransactionResponse) GetData 

func (x *SubmitTransactionResponse) GetData() string

func (*SubmitTransactionResponse) GetHeight 

func (x *SubmitTransactionResponse) GetHeight() int64

func (*SubmitTransactionResponse) GetLog 

func (x *SubmitTransactionResponse) GetLog() string

func (*SubmitTransactionResponse) GetSuccess 

func (x *SubmitTransactionResponse) GetSuccess() bool

func (*SubmitTransactionResponse) GetTxHash 

func (x *SubmitTransactionResponse) GetTxHash() string

func (*SubmitTransactionResponse) ProtoMessage 

func (*SubmitTransactionResponse) ProtoMessage()

func (*SubmitTransactionResponse) ProtoReflect 

func (x *SubmitTransactionResponse) ProtoReflect() protoreflect.Message

func (*SubmitTransactionResponse) Reset 

func (x *SubmitTransactionResponse) Reset()

func (*SubmitTransactionResponse) String 

func (x *SubmitTransactionResponse) String() string

type UnimplementedCoreServiceServer 

type UnimplementedCoreServiceServer struct {
}

UnimplementedCoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCoreServiceServer) CheckRawTransaction 

func (UnimplementedCoreServiceServer) CheckRawTransaction(context.Context, *CheckRawTransactionRequest) (*CheckRawTransactionResponse, error)

func (UnimplementedCoreServiceServer) CheckTransaction 

func (UnimplementedCoreServiceServer) CheckTransaction(context.Context, *CheckTransactionRequest) (*CheckTransactionResponse, error)

func (UnimplementedCoreServiceServer) GetVegaTime 

func (UnimplementedCoreServiceServer) GetVegaTime(context.Context, *GetVegaTimeRequest) (*GetVegaTimeResponse, error)

func (UnimplementedCoreServiceServer) LastBlockHeight 

func (UnimplementedCoreServiceServer) LastBlockHeight(context.Context, *LastBlockHeightRequest) (*LastBlockHeightResponse, error)

func (UnimplementedCoreServiceServer) ObserveEventBus 

func (UnimplementedCoreServiceServer) ObserveEventBus(CoreService_ObserveEventBusServer) error

func (UnimplementedCoreServiceServer) PropagateChainEvent 

func (UnimplementedCoreServiceServer) PropagateChainEvent(context.Context, *PropagateChainEventRequest) (*PropagateChainEventResponse, error)

func (UnimplementedCoreServiceServer) Statistics 

func (UnimplementedCoreServiceServer) Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)

func (UnimplementedCoreServiceServer) SubmitRawTransaction 

func (UnimplementedCoreServiceServer) SubmitRawTransaction(context.Context, *SubmitRawTransactionRequest) (*SubmitRawTransactionResponse, error)

func (UnimplementedCoreServiceServer) SubmitTransaction 

func (UnimplementedCoreServiceServer) SubmitTransaction(context.Context, *SubmitTransactionRequest) (*SubmitTransactionResponse, error)

type UnimplementedCoreStateServiceServer 

type UnimplementedCoreStateServiceServer struct {
}

UnimplementedCoreStateServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCoreStateServiceServer) ListAccounts 

func (UnimplementedCoreStateServiceServer) ListAccounts(context.Context, *ListAccountsRequest) (*ListAccountsResponse, error)

func (UnimplementedCoreStateServiceServer) ListAssets 

func (UnimplementedCoreStateServiceServer) ListAssets(context.Context, *ListAssetsRequest) (*ListAssetsResponse, error)

func (UnimplementedCoreStateServiceServer) ListDelegations 

func (UnimplementedCoreStateServiceServer) ListDelegations(context.Context, *ListDelegationsRequest) (*ListDelegationsResponse, error)

func (UnimplementedCoreStateServiceServer) ListMarkets 

func (UnimplementedCoreStateServiceServer) ListMarkets(context.Context, *ListMarketsRequest) (*ListMarketsResponse, error)

func (UnimplementedCoreStateServiceServer) ListMarketsData 

func (UnimplementedCoreStateServiceServer) ListMarketsData(context.Context, *ListMarketsDataRequest) (*ListMarketsDataResponse, error)

func (UnimplementedCoreStateServiceServer) ListNetworkLimits 

func (UnimplementedCoreStateServiceServer) ListNetworkLimits(context.Context, *ListNetworkLimitsRequest) (*ListNetworkLimitsResponse, error)

func (UnimplementedCoreStateServiceServer) ListNetworkParameters 

func (UnimplementedCoreStateServiceServer) ListNetworkParameters(context.Context, *ListNetworkParametersRequest) (*ListNetworkParametersResponse, error)

func (UnimplementedCoreStateServiceServer) ListParties 

func (UnimplementedCoreStateServiceServer) ListParties(context.Context, *ListPartiesRequest) (*ListPartiesResponse, error)

func (UnimplementedCoreStateServiceServer) ListPartiesStake 

func (UnimplementedCoreStateServiceServer) ListPartiesStake(context.Context, *ListPartiesStakeRequest) (*ListPartiesStakeResponse, error)

func (UnimplementedCoreStateServiceServer) ListProposals 

func (UnimplementedCoreStateServiceServer) ListProposals(context.Context, *ListProposalsRequest) (*ListProposalsResponse, error)

func (UnimplementedCoreStateServiceServer) ListValidators 

func (UnimplementedCoreStateServiceServer) ListValidators(context.Context, *ListValidatorsRequest) (*ListValidatorsResponse, error)

func (UnimplementedCoreStateServiceServer) ListVotes 

func (UnimplementedCoreStateServiceServer) ListVotes(context.Context, *ListVotesRequest) (*ListVotesResponse, error)

type UnsafeCoreServiceServer 

type UnsafeCoreServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCoreServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CoreServiceServer will result in compilation errors.

type UnsafeCoreStateServiceServer 

type UnsafeCoreStateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCoreStateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CoreStateServiceServer will result in compilation errors.

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.