Documentation ¶
Index ¶
- Variables
- func RegisterBankServer(s grpc.ServiceRegistrar, srv BankServer)
- func RegisterBlockchainSyncServer(s grpc.ServiceRegistrar, srv BlockchainSyncServer)
- func RegisterDiscoveryServer(s grpc.ServiceRegistrar, srv DiscoveryServer)
- func RegisterIdentityServer(s grpc.ServiceRegistrar, srv IdentityServer)
- func RegisterJobQueueServiceServer(s grpc.ServiceRegistrar, srv JobQueueServiceServer)
- type BankClient
- type BankInfo
- func (*BankInfo) Descriptor() ([]byte, []int)deprecated
- func (x *BankInfo) GetAddress() string
- func (x *BankInfo) GetDefaultCoin() *CurrencyInfo
- func (x *BankInfo) GetMinter() *MinterBurner
- func (x *BankInfo) GetSwappers() []*Swapper
- func (x *BankInfo) GetTimestamp() *timestamppb.Timestamp
- func (*BankInfo) ProtoMessage()
- func (x *BankInfo) ProtoReflect() protoreflect.Message
- func (x *BankInfo) Reset()
- func (x *BankInfo) String() string
- type BankServer
- type Bank_GetTxQueueElementsClient
- type Bank_GetTxQueueElementsServer
- type Block
- func (*Block) Descriptor() ([]byte, []int)deprecated
- func (x *Block) GetBlockId() string
- func (x *Block) GetHead() *BlockHeader
- func (x *Block) GetNonce() uint32
- func (x *Block) GetValidatorAddr() string
- func (*Block) ProtoMessage()
- func (x *Block) ProtoReflect() protoreflect.Message
- func (x *Block) Reset()
- func (x *Block) String() string
- type BlockHeader
- func (*BlockHeader) Descriptor() ([]byte, []int)deprecated
- func (x *BlockHeader) GetBlockStates() []BlockStates
- func (x *BlockHeader) GetBlockType() BlockType
- func (x *BlockHeader) GetChainId() string
- func (x *BlockHeader) GetCreationTx() string
- func (x *BlockHeader) GetHash() string
- func (x *BlockHeader) GetHeight() uint64
- func (x *BlockHeader) GetIndex() uint64
- func (x *BlockHeader) GetMerkleRoot() []byte
- func (x *BlockHeader) GetNumTx() int64
- func (x *BlockHeader) GetNumber() int32
- func (x *BlockHeader) GetParentHash() string
- func (x *BlockHeader) GetReceiptsMerkleRoot() []byte
- func (x *BlockHeader) GetSize() int64
- func (x *BlockHeader) GetTimestamp() *timestamppb.Timestamp
- func (x *BlockHeader) GetTxMerkleRoot() []byte
- func (x *BlockHeader) GetVersion() string
- func (*BlockHeader) ProtoMessage()
- func (x *BlockHeader) ProtoReflect() protoreflect.Message
- func (x *BlockHeader) Reset()
- func (x *BlockHeader) String() string
- type BlockHeadersRequest
- func (*BlockHeadersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BlockHeadersRequest) GetAll() bool
- func (x *BlockHeadersRequest) GetFrom() uint32
- func (x *BlockHeadersRequest) GetGenesisHash() string
- func (x *BlockHeadersRequest) GetNetworkId() string
- func (x *BlockHeadersRequest) GetVersion() string
- func (*BlockHeadersRequest) ProtoMessage()
- func (x *BlockHeadersRequest) ProtoReflect() protoreflect.Message
- func (x *BlockHeadersRequest) Reset()
- func (x *BlockHeadersRequest) String() string
- type BlockHeadersResponse
- func (*BlockHeadersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BlockHeadersResponse) GetBlockHeaders() []*BlockHeader
- func (x *BlockHeadersResponse) GetError() bool
- func (x *BlockHeadersResponse) GetSuccess() bool
- func (*BlockHeadersResponse) ProtoMessage()
- func (x *BlockHeadersResponse) ProtoReflect() protoreflect.Message
- func (x *BlockHeadersResponse) Reset()
- func (x *BlockHeadersResponse) String() string
- type BlockStates
- func (BlockStates) Descriptor() protoreflect.EnumDescriptor
- func (x BlockStates) Enum() *BlockStates
- func (BlockStates) EnumDescriptor() ([]byte, []int)deprecated
- func (x BlockStates) Number() protoreflect.EnumNumber
- func (x BlockStates) String() string
- func (BlockStates) Type() protoreflect.EnumType
- type BlockType
- type Blockchain
- func (*Blockchain) Descriptor() ([]byte, []int)deprecated
- func (x *Blockchain) GetBlockchainHead() *Block
- func (x *Blockchain) GetBlocks() []*Block
- func (x *Blockchain) GetChainId() string
- func (x *Blockchain) GetGenesisHash() string
- func (x *Blockchain) GetMerkleRoot() string
- func (x *Blockchain) GetNetworkId() uint32
- func (x *Blockchain) GetNumBlocks() int32
- func (x *Blockchain) GetNumTx() int32
- func (x *Blockchain) GetValidators() []*Validator
- func (x *Blockchain) GetVersion() string
- func (*Blockchain) ProtoMessage()
- func (x *Blockchain) ProtoReflect() protoreflect.Message
- func (x *Blockchain) Reset()
- func (x *Blockchain) String() string
- type BlockchainSyncClient
- type BlockchainSyncRequest
- func (*BlockchainSyncRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BlockchainSyncRequest) GetGenesisHash() string
- func (x *BlockchainSyncRequest) GetNetworkId() string
- func (x *BlockchainSyncRequest) GetVersion() string
- func (*BlockchainSyncRequest) ProtoMessage()
- func (x *BlockchainSyncRequest) ProtoReflect() protoreflect.Message
- func (x *BlockchainSyncRequest) Reset()
- func (x *BlockchainSyncRequest) String() string
- type BlockchainSyncResponse
- func (*BlockchainSyncResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BlockchainSyncResponse) GetBlocks() []*Block
- func (x *BlockchainSyncResponse) GetError() bool
- func (x *BlockchainSyncResponse) GetSuccess() bool
- func (*BlockchainSyncResponse) ProtoMessage()
- func (x *BlockchainSyncResponse) ProtoReflect() protoreflect.Message
- func (x *BlockchainSyncResponse) Reset()
- func (x *BlockchainSyncResponse) String() string
- type BlockchainSyncServer
- type BlockchainSync_RequestBlockHeadersClient
- type BlockchainSync_RequestBlockHeadersServer
- type BlockchainSync_RequestBlockchainSyncClient
- type BlockchainSync_RequestBlockchainSyncServer
- type ByeMsg
- type CurrencyInfo
- func (*CurrencyInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CurrencyInfo) GetAvailable() uint64
- func (x *CurrencyInfo) GetCirculating() uint64
- func (x *CurrencyInfo) GetCoinbase() string
- func (x *CurrencyInfo) GetMaxAvailable() uint64
- func (x *CurrencyInfo) GetName() string
- func (x *CurrencyInfo) GetNetwork() []byte
- func (x *CurrencyInfo) GetSignature() string
- func (x *CurrencyInfo) GetSymbol() string
- func (x *CurrencyInfo) GetValueUsd() uint64
- func (*CurrencyInfo) ProtoMessage()
- func (x *CurrencyInfo) ProtoReflect() protoreflect.Message
- func (x *CurrencyInfo) Reset()
- func (x *CurrencyInfo) String() string
- type DefaultCurrencyRequest
- func (*DefaultCurrencyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DefaultCurrencyRequest) GetAddress() string
- func (x *DefaultCurrencyRequest) GetFrom() string
- func (x *DefaultCurrencyRequest) GetName() string
- func (x *DefaultCurrencyRequest) GetNetwork() []byte
- func (x *DefaultCurrencyRequest) GetSymbol() string
- func (*DefaultCurrencyRequest) ProtoMessage()
- func (x *DefaultCurrencyRequest) ProtoReflect() protoreflect.Message
- func (x *DefaultCurrencyRequest) Reset()
- func (x *DefaultCurrencyRequest) String() string
- type DefaultCurrencyResponse
- func (*DefaultCurrencyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DefaultCurrencyResponse) GetResponse() *CurrencyInfo
- func (x *DefaultCurrencyResponse) GetTo() string
- func (*DefaultCurrencyResponse) ProtoMessage()
- func (x *DefaultCurrencyResponse) ProtoReflect() protoreflect.Message
- func (x *DefaultCurrencyResponse) Reset()
- func (x *DefaultCurrencyResponse) String() string
- type DiscoveryClient
- type DiscoveryServer
- type Fees
- type FindPeersReq
- func (*FindPeersReq) Descriptor() ([]byte, []int)deprecated
- func (x *FindPeersReq) GetCount() int64
- func (x *FindPeersReq) GetKey() string
- func (*FindPeersReq) ProtoMessage()
- func (x *FindPeersReq) ProtoReflect() protoreflect.Message
- func (x *FindPeersReq) Reset()
- func (x *FindPeersReq) String() string
- type FindPeersResp
- type IdentityClient
- type IdentityServer
- type JobDetails
- func (*JobDetails) Descriptor() ([]byte, []int)deprecated
- func (x *JobDetails) GetCreatedAt() *timestamppb.Timestamp
- func (x *JobDetails) GetJobId() string
- func (x *JobDetails) GetPartitionFromUuid() []byte
- func (x *JobDetails) GetPartitionToUuid() []byte
- func (*JobDetails) ProtoMessage()
- func (x *JobDetails) ProtoReflect() protoreflect.Message
- func (x *JobDetails) Reset()
- func (x *JobDetails) String() string
- type JobQueueServiceClient
- type JobQueueServiceServer
- type JobQueueService_JobStreamClient
- type JobQueueService_JobStreamServer
- type JobStreamRequest
- func (*JobStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (m *JobStreamRequest) GetPayload() isJobStreamRequest_Payload
- func (x *JobStreamRequest) GetRelayMessage() *RelayMessage
- func (x *JobStreamRequest) GetState() *State
- func (*JobStreamRequest) ProtoMessage()
- func (x *JobStreamRequest) ProtoReflect() protoreflect.Message
- func (x *JobStreamRequest) Reset()
- func (x *JobStreamRequest) String() string
- type JobStreamRequest_RelayMessage
- type JobStreamRequest_State
- type JobStreamResponse
- func (*JobStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobStreamResponse) GetJobDetails() *JobDetails
- func (m *JobStreamResponse) GetPayload() isJobStreamResponse_Payload
- func (x *JobStreamResponse) GetRelayMessage() *RelayMessage
- func (x *JobStreamResponse) GetState() *State
- func (*JobStreamResponse) ProtoMessage()
- func (x *JobStreamResponse) ProtoReflect() protoreflect.Message
- func (x *JobStreamResponse) Reset()
- func (x *JobStreamResponse) String() string
- type JobStreamResponse_JobDetails
- type JobStreamResponse_RelayMessage
- type JobStreamResponse_State
- type MinterBurner
- func (*MinterBurner) Descriptor() ([]byte, []int)deprecated
- func (x *MinterBurner) GetAddress() string
- func (x *MinterBurner) GetTotalBurned() uint64
- func (x *MinterBurner) GetTotalMinted() uint64
- func (*MinterBurner) ProtoMessage()
- func (x *MinterBurner) ProtoReflect() protoreflect.Message
- func (x *MinterBurner) Reset()
- func (x *MinterBurner) String() string
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetAddress() string
- func (x *Node) GetId() string
- func (x *Node) GetLastSeen() *timestamppb.Timestamp
- func (x *Node) GetStake() uint64
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type Payload
- type RelayMessage
- func (*RelayMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RelayMessage) GetDestination() string
- func (x *RelayMessage) GetMessage() *anypb.Any
- func (*RelayMessage) ProtoMessage()
- func (x *RelayMessage) ProtoReflect() protoreflect.Message
- func (x *RelayMessage) Reset()
- func (x *RelayMessage) String() string
- type RequestTxQueueElements
- func (*RequestTxQueueElements) Descriptor() ([]byte, []int)deprecated
- func (x *RequestTxQueueElements) GetFrom() string
- func (x *RequestTxQueueElements) GetStatus() TxStatus
- func (*RequestTxQueueElements) ProtoMessage()
- func (x *RequestTxQueueElements) ProtoReflect() protoreflect.Message
- func (x *RequestTxQueueElements) Reset()
- func (x *RequestTxQueueElements) String() string
- type State
- func (*State) Descriptor() ([]byte, []int)deprecated
- func (x *State) GetActiveInState() int64
- func (x *State) GetAggregatorValues() map[string]*anypb.Any
- func (x *State) GetType() State_Type
- func (*State) ProtoMessage()
- func (x *State) ProtoReflect() protoreflect.Message
- func (x *State) Reset()
- func (x *State) String() string
- type State_Type
- type Status
- func (*Status) Descriptor() ([]byte, []int)deprecated
- func (x *Status) GetChain() int64
- func (x *Status) GetGenesis() string
- func (x *Status) GetKeys() []*Status_Key
- func (x *Status) GetMetadata() map[string]string
- func (*Status) ProtoMessage()
- func (x *Status) ProtoReflect() protoreflect.Message
- func (x *Status) Reset()
- func (x *Status) String() string
- type Status_Key
- type Swapper
- func (*Swapper) Descriptor() ([]byte, []int)deprecated
- func (x *Swapper) GetAddress() string
- func (x *Swapper) GetBridgeAddress() string
- func (x *Swapper) GetCanSwap() []*CurrencyInfo
- func (x *Swapper) GetContractAddress() string
- func (*Swapper) ProtoMessage()
- func (x *Swapper) ProtoReflect() protoreflect.Message
- func (x *Swapper) Reset()
- func (x *Swapper) String() string
- type TransactionInfo
- func (*TransactionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionInfo) GetInputs() []*TxInput
- func (x *TransactionInfo) GetOutputs() []*TxOutput
- func (x *TransactionInfo) GetScripts() []string
- func (x *TransactionInfo) GetTxStatus() TxStatus
- func (x *TransactionInfo) GetValidators() []string
- func (*TransactionInfo) ProtoMessage()
- func (x *TransactionInfo) ProtoReflect() protoreflect.Message
- func (x *TransactionInfo) Reset()
- func (x *TransactionInfo) String() string
- type Tx
- func (*Tx) Descriptor() ([]byte, []int)deprecated
- func (x *Tx) GetAmount() uint64
- func (x *Tx) GetContractAddress() string
- func (x *Tx) GetCurrency() *CurrencyInfo
- func (x *Tx) GetFees() uint64
- func (x *Tx) GetFrom() string
- func (x *Tx) GetMerkleRoot() []byte
- func (x *Tx) GetNonce() int64
- func (x *Tx) GetNotes() string
- func (x *Tx) GetRef() string
- func (x *Tx) GetSignatures() []string
- func (x *Tx) GetTo() string
- func (x *Tx) GetTxId() string
- func (*Tx) ProtoMessage()
- func (x *Tx) ProtoReflect() protoreflect.Message
- func (x *Tx) Reset()
- func (x *Tx) String() string
- type TxInput
- func (*TxInput) Descriptor() ([]byte, []int)deprecated
- func (x *TxInput) GetCurrency() *CurrencyInfo
- func (x *TxInput) GetFrom() string
- func (x *TxInput) GetSpent() bool
- func (x *TxInput) GetTo() string
- func (x *TxInput) GetTxType() TxReqType
- func (x *TxInput) GetValue() uint64
- func (*TxInput) ProtoMessage()
- func (x *TxInput) ProtoReflect() protoreflect.Message
- func (x *TxInput) Reset()
- func (x *TxInput) String() string
- type TxOutput
- func (*TxOutput) Descriptor() ([]byte, []int)deprecated
- func (x *TxOutput) GetAddress() string
- func (x *TxOutput) GetFees() *Fees
- func (x *TxOutput) GetInput() *TxInput
- func (x *TxOutput) GetTxId() string
- func (x *TxOutput) GetValue() uint64
- func (*TxOutput) ProtoMessage()
- func (x *TxOutput) ProtoReflect() protoreflect.Message
- func (x *TxOutput) Reset()
- func (x *TxOutput) String() string
- type TxQueue
- type TxQueueElement
- func (*TxQueueElement) Descriptor() ([]byte, []int)deprecated
- func (x *TxQueueElement) GetNonce() int64
- func (x *TxQueueElement) GetTransaction() *Tx
- func (x *TxQueueElement) GetTxStatus() TxStatus
- func (*TxQueueElement) ProtoMessage()
- func (x *TxQueueElement) ProtoReflect() protoreflect.Message
- func (x *TxQueueElement) Reset()
- func (x *TxQueueElement) String() string
- type TxReqType
- type TxRequest
- func (*TxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TxRequest) GetFromAddress() string
- func (x *TxRequest) GetRequestType() TxReqType
- func (*TxRequest) ProtoMessage()
- func (x *TxRequest) ProtoReflect() protoreflect.Message
- func (x *TxRequest) Reset()
- func (x *TxRequest) String() string
- type TxSendAmountRequest
- func (*TxSendAmountRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TxSendAmountRequest) GetAmount() uint64
- func (x *TxSendAmountRequest) GetRequest() *TxRequest
- func (x *TxSendAmountRequest) GetSignature() string
- func (x *TxSendAmountRequest) GetTo() string
- func (*TxSendAmountRequest) ProtoMessage()
- func (x *TxSendAmountRequest) ProtoReflect() protoreflect.Message
- func (x *TxSendAmountRequest) Reset()
- func (x *TxSendAmountRequest) String() string
- type TxStatus
- type UnimplementedBankServer
- func (UnimplementedBankServer) GetCurrencyInfo(context.Context, *DefaultCurrencyRequest) (*DefaultCurrencyResponse, error)
- func (UnimplementedBankServer) GetTxQueueElements(*RequestTxQueueElements, Bank_GetTxQueueElementsServer) error
- func (UnimplementedBankServer) SendTransaction(context.Context, *TxSendAmountRequest) (*TransactionInfo, error)
- type UnimplementedBlockchainSyncServer
- type UnimplementedDiscoveryServer
- type UnimplementedIdentityServer
- type UnimplementedJobQueueServiceServer
- type UnsafeBankServer
- type UnsafeBlockchainSyncServer
- type UnsafeDiscoveryServer
- type UnsafeIdentityServer
- type UnsafeJobQueueServiceServer
- type Validator
Constants ¶
This section is empty.
Variables ¶
var ( TxStatus_name = map[int32]string{ 0: "Submitted", 1: "Pending", 2: "Created", 3: "InQueue", 4: "WaitingConfirmations", 5: "Confirming", 6: "Confirmed", 7: "Cancelled", } TxStatus_value = map[string]int32{ "Submitted": 0, "Pending": 1, "Created": 2, "InQueue": 3, "WaitingConfirmations": 4, "Confirming": 5, "Confirmed": 6, "Cancelled": 7, } )
Enum value maps for TxStatus.
var ( TxReqType_name = map[int32]string{ 0: "SendAmount", 1: "ContentHash", 2: "TxInfo", 3: "TxReceipt", 4: "Contract", 5: "TxStatuses", } TxReqType_value = map[string]int32{ "SendAmount": 0, "ContentHash": 1, "TxInfo": 2, "TxReceipt": 3, "Contract": 4, "TxStatuses": 5, } )
Enum value maps for TxReqType.
var ( BlockType_name = map[int32]string{ 0: "DEFAULT", 1: "GENESIS", 2: "SPECIAL", 3: "CHAIN_DATA", 4: "NEW_EPOCH", } BlockType_value = map[string]int32{ "DEFAULT": 0, "GENESIS": 1, "SPECIAL": 2, "CHAIN_DATA": 3, "NEW_EPOCH": 4, } )
Enum value maps for BlockType.
var ( BlockStates_name = map[int32]string{ 0: "NEW", 1: "PENDING_VALIDATION", 2: "VALID", 3: "PENDING_SIGNATURES", 4: "SIGNED", 5: "FINALIZED", 6: "ACCEPT_TX", } BlockStates_value = map[string]int32{ "NEW": 0, "PENDING_VALIDATION": 1, "VALID": 2, "PENDING_SIGNATURES": 3, "SIGNED": 4, "FINALIZED": 5, "ACCEPT_TX": 6, } )
Enum value maps for BlockStates.
var ( State_Type_name = map[int32]string{ 0: "TYPE_INVALID_UNSPECIFIED", 1: "TYPE_PRE", 2: "TYPE_POST", 3: "TYPE_POST_KEEP_RUNNING", 4: "TYPE_EXECUTED_GRAPH", 5: "TYPE_PERSISTED_RESULTS", 6: "TYPE_COMPLETED_JOB", } State_Type_value = map[string]int32{ "TYPE_INVALID_UNSPECIFIED": 0, "TYPE_PRE": 1, "TYPE_POST": 2, "TYPE_POST_KEEP_RUNNING": 3, "TYPE_EXECUTED_GRAPH": 4, "TYPE_PERSISTED_RESULTS": 5, "TYPE_COMPLETED_JOB": 6, } )
Enum value maps for State_Type.
var Bank_ServiceDesc = grpc.ServiceDesc{ ServiceName: "quantos.pkg.v1.Bank", HandlerType: (*BankServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetCurrencyInfo", Handler: _Bank_GetCurrencyInfo_Handler, }, { MethodName: "SendTransaction", Handler: _Bank_SendTransaction_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetTxQueueElements", Handler: _Bank_GetTxQueueElements_Handler, ServerStreams: true, }, }, Metadata: "quantos/pkg/v1/bank.proto", }
Bank_ServiceDesc is the grpc.ServiceDesc for Bank service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var BlockchainSync_ServiceDesc = grpc.ServiceDesc{ ServiceName: "quantos.pkg.v1.BlockchainSync", HandlerType: (*BlockchainSyncServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "RequestBlockchainSync", Handler: _BlockchainSync_RequestBlockchainSync_Handler, ServerStreams: true, }, { StreamName: "RequestBlockHeaders", Handler: _BlockchainSync_RequestBlockHeaders_Handler, ServerStreams: true, }, }, Metadata: "quantos/pkg/v1/blockchain.proto", }
BlockchainSync_ServiceDesc is the grpc.ServiceDesc for BlockchainSync service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Discovery_ServiceDesc = grpc.ServiceDesc{ ServiceName: "quantos.pkg.v1.Discovery", HandlerType: (*DiscoveryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FindPeers", Handler: _Discovery_FindPeers_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "quantos/pkg/v1/discovery.proto", }
Discovery_ServiceDesc is the grpc.ServiceDesc for Discovery service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_quantos_pkg_v1_bank_proto protoreflect.FileDescriptor
var File_quantos_pkg_v1_blockchain_proto protoreflect.FileDescriptor
var File_quantos_pkg_v1_discovery_proto protoreflect.FileDescriptor
var File_quantos_pkg_v1_identity_proto protoreflect.FileDescriptor
var File_quantos_pkg_v1_jobqueue_proto protoreflect.FileDescriptor
var Identity_ServiceDesc = grpc.ServiceDesc{ ServiceName: "quantos.pkg.v1.Identity", HandlerType: (*IdentityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Hello", Handler: _Identity_Hello_Handler, }, { MethodName: "Bye", Handler: _Identity_Bye_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "quantos/pkg/v1/identity.proto", }
Identity_ServiceDesc is the grpc.ServiceDesc for Identity service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var JobQueueService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.v1.JobQueueService", HandlerType: (*JobQueueServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "JobStream", Handler: _JobQueueService_JobStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "quantos/pkg/v1/jobqueue.proto", }
JobQueueService_ServiceDesc is the grpc.ServiceDesc for JobQueueService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterBankServer ¶
func RegisterBankServer(s grpc.ServiceRegistrar, srv BankServer)
func RegisterBlockchainSyncServer ¶
func RegisterBlockchainSyncServer(s grpc.ServiceRegistrar, srv BlockchainSyncServer)
func RegisterDiscoveryServer ¶
func RegisterDiscoveryServer(s grpc.ServiceRegistrar, srv DiscoveryServer)
func RegisterIdentityServer ¶
func RegisterIdentityServer(s grpc.ServiceRegistrar, srv IdentityServer)
func RegisterJobQueueServiceServer ¶
func RegisterJobQueueServiceServer(s grpc.ServiceRegistrar, srv JobQueueServiceServer)
Types ¶
type BankClient ¶
type BankClient interface { GetCurrencyInfo(ctx context.Context, in *DefaultCurrencyRequest, opts ...grpc.CallOption) (*DefaultCurrencyResponse, error) SendTransaction(ctx context.Context, in *TxSendAmountRequest, opts ...grpc.CallOption) (*TransactionInfo, error) GetTxQueueElements(ctx context.Context, in *RequestTxQueueElements, opts ...grpc.CallOption) (Bank_GetTxQueueElementsClient, error) }
BankClient is the client API for Bank 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 NewBankClient ¶
func NewBankClient(cc grpc.ClientConnInterface) BankClient
type BankInfo ¶
type BankInfo struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` DefaultCoin *CurrencyInfo `protobuf:"bytes,2,opt,name=default_coin,json=defaultCoin,proto3" json:"default_coin,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Minter *MinterBurner `protobuf:"bytes,4,opt,name=minter,proto3" json:"minter,omitempty"` Swappers []*Swapper `protobuf:"bytes,5,rep,name=swappers,proto3" json:"swappers,omitempty"` // contains filtered or unexported fields }
func (*BankInfo) Descriptor
deprecated
func (*BankInfo) GetAddress ¶
func (*BankInfo) GetDefaultCoin ¶
func (x *BankInfo) GetDefaultCoin() *CurrencyInfo
func (*BankInfo) GetMinter ¶
func (x *BankInfo) GetMinter() *MinterBurner
func (*BankInfo) GetSwappers ¶
func (*BankInfo) GetTimestamp ¶
func (x *BankInfo) GetTimestamp() *timestamppb.Timestamp
func (*BankInfo) ProtoMessage ¶
func (*BankInfo) ProtoMessage()
func (*BankInfo) ProtoReflect ¶
func (x *BankInfo) ProtoReflect() protoreflect.Message
type BankServer ¶
type BankServer interface { GetCurrencyInfo(context.Context, *DefaultCurrencyRequest) (*DefaultCurrencyResponse, error) SendTransaction(context.Context, *TxSendAmountRequest) (*TransactionInfo, error) GetTxQueueElements(*RequestTxQueueElements, Bank_GetTxQueueElementsServer) error }
BankServer is the server API for Bank service. All implementations should embed UnimplementedBankServer for forward compatibility
type Bank_GetTxQueueElementsClient ¶
type Bank_GetTxQueueElementsClient interface { Recv() (*TxQueueElement, error) grpc.ClientStream }
type Bank_GetTxQueueElementsServer ¶
type Bank_GetTxQueueElementsServer interface { Send(*TxQueueElement) error grpc.ServerStream }
type Block ¶
type Block struct { BlockId string `protobuf:"bytes,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` Head *BlockHeader `protobuf:"bytes,2,opt,name=head,proto3" json:"head,omitempty"` Nonce uint32 `protobuf:"varint,4,opt,name=nonce,proto3" json:"nonce,omitempty"` ValidatorAddr string `protobuf:"bytes,5,opt,name=ValidatorAddr,proto3" json:"ValidatorAddr,omitempty"` // contains filtered or unexported fields }
func (*Block) Descriptor
deprecated
func (*Block) GetBlockId ¶
func (*Block) GetHead ¶
func (x *Block) GetHead() *BlockHeader
func (*Block) GetValidatorAddr ¶
func (*Block) ProtoMessage ¶
func (*Block) ProtoMessage()
func (*Block) ProtoReflect ¶
func (x *Block) ProtoReflect() protoreflect.Message
type BlockHeader ¶
type BlockHeader struct { BlockType BlockType `protobuf:"varint,1,opt,name=block_type,json=blockType,proto3,enum=quantos.pkg.v1.BlockType" json:"block_type,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Height uint64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"` ChainId string `protobuf:"bytes,4,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` Hash string `protobuf:"bytes,6,opt,name=hash,proto3" json:"hash,omitempty"` ParentHash string `protobuf:"bytes,7,opt,name=parent_hash,json=parentHash,proto3" json:"parent_hash,omitempty"` MerkleRoot []byte `protobuf:"bytes,8,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"` TxMerkleRoot []byte `protobuf:"bytes,9,opt,name=tx_merkle_root,json=txMerkleRoot,proto3" json:"tx_merkle_root,omitempty"` ReceiptsMerkleRoot []byte `protobuf:"bytes,10,opt,name=receipts_merkle_root,json=receiptsMerkleRoot,proto3" json:"receipts_merkle_root,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Number int32 `protobuf:"varint,12,opt,name=number,proto3" json:"number,omitempty"` Size int64 `protobuf:"varint,13,opt,name=size,proto3" json:"size,omitempty"` NumTx int64 `protobuf:"varint,14,opt,name=num_tx,json=numTx,proto3" json:"num_tx,omitempty"` CreationTx string `protobuf:"bytes,15,opt,name=creation_tx,json=creationTx,proto3" json:"creation_tx,omitempty"` BlockStates []BlockStates `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
func (*BlockHeader) Descriptor
deprecated
func (*BlockHeader) Descriptor() ([]byte, []int)
Deprecated: Use BlockHeader.ProtoReflect.Descriptor instead.
func (*BlockHeader) GetBlockStates ¶
func (x *BlockHeader) GetBlockStates() []BlockStates
func (*BlockHeader) GetBlockType ¶
func (x *BlockHeader) GetBlockType() BlockType
func (*BlockHeader) GetChainId ¶
func (x *BlockHeader) GetChainId() string
func (*BlockHeader) GetCreationTx ¶
func (x *BlockHeader) GetCreationTx() string
func (*BlockHeader) GetHash ¶
func (x *BlockHeader) GetHash() string
func (*BlockHeader) GetHeight ¶
func (x *BlockHeader) GetHeight() uint64
func (*BlockHeader) GetIndex ¶
func (x *BlockHeader) GetIndex() uint64
func (*BlockHeader) GetMerkleRoot ¶
func (x *BlockHeader) GetMerkleRoot() []byte
func (*BlockHeader) GetNumTx ¶
func (x *BlockHeader) GetNumTx() int64
func (*BlockHeader) GetNumber ¶
func (x *BlockHeader) GetNumber() int32
func (*BlockHeader) GetParentHash ¶
func (x *BlockHeader) GetParentHash() string
func (*BlockHeader) GetReceiptsMerkleRoot ¶
func (x *BlockHeader) GetReceiptsMerkleRoot() []byte
func (*BlockHeader) GetSize ¶
func (x *BlockHeader) GetSize() int64
func (*BlockHeader) GetTimestamp ¶
func (x *BlockHeader) GetTimestamp() *timestamppb.Timestamp
func (*BlockHeader) GetTxMerkleRoot ¶
func (x *BlockHeader) GetTxMerkleRoot() []byte
func (*BlockHeader) GetVersion ¶
func (x *BlockHeader) GetVersion() string
func (*BlockHeader) ProtoMessage ¶
func (*BlockHeader) ProtoMessage()
func (*BlockHeader) ProtoReflect ¶
func (x *BlockHeader) ProtoReflect() protoreflect.Message
func (*BlockHeader) Reset ¶
func (x *BlockHeader) Reset()
func (*BlockHeader) String ¶
func (x *BlockHeader) String() string
type BlockHeadersRequest ¶
type BlockHeadersRequest struct { NetworkId string `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` GenesisHash string `protobuf:"bytes,3,opt,name=genesis_hash,json=genesisHash,proto3" json:"genesis_hash,omitempty"` All bool `protobuf:"varint,4,opt,name=all,proto3" json:"all,omitempty"` From uint32 `protobuf:"varint,5,opt,name=from,proto3" json:"from,omitempty"` // contains filtered or unexported fields }
func (*BlockHeadersRequest) Descriptor
deprecated
func (*BlockHeadersRequest) Descriptor() ([]byte, []int)
Deprecated: Use BlockHeadersRequest.ProtoReflect.Descriptor instead.
func (*BlockHeadersRequest) GetAll ¶
func (x *BlockHeadersRequest) GetAll() bool
func (*BlockHeadersRequest) GetFrom ¶
func (x *BlockHeadersRequest) GetFrom() uint32
func (*BlockHeadersRequest) GetGenesisHash ¶
func (x *BlockHeadersRequest) GetGenesisHash() string
func (*BlockHeadersRequest) GetNetworkId ¶
func (x *BlockHeadersRequest) GetNetworkId() string
func (*BlockHeadersRequest) GetVersion ¶
func (x *BlockHeadersRequest) GetVersion() string
func (*BlockHeadersRequest) ProtoMessage ¶
func (*BlockHeadersRequest) ProtoMessage()
func (*BlockHeadersRequest) ProtoReflect ¶
func (x *BlockHeadersRequest) ProtoReflect() protoreflect.Message
func (*BlockHeadersRequest) Reset ¶
func (x *BlockHeadersRequest) Reset()
func (*BlockHeadersRequest) String ¶
func (x *BlockHeadersRequest) String() string
type BlockHeadersResponse ¶
type BlockHeadersResponse struct { Error bool `protobuf:"varint,1,opt,name=error,proto3" json:"error,omitempty"` Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` BlockHeaders []*BlockHeader `protobuf:"bytes,3,rep,name=block_headers,json=blockHeaders,proto3" json:"block_headers,omitempty"` // contains filtered or unexported fields }
func (*BlockHeadersResponse) Descriptor
deprecated
func (*BlockHeadersResponse) Descriptor() ([]byte, []int)
Deprecated: Use BlockHeadersResponse.ProtoReflect.Descriptor instead.
func (*BlockHeadersResponse) GetBlockHeaders ¶
func (x *BlockHeadersResponse) GetBlockHeaders() []*BlockHeader
func (*BlockHeadersResponse) GetError ¶
func (x *BlockHeadersResponse) GetError() bool
func (*BlockHeadersResponse) GetSuccess ¶
func (x *BlockHeadersResponse) GetSuccess() bool
func (*BlockHeadersResponse) ProtoMessage ¶
func (*BlockHeadersResponse) ProtoMessage()
func (*BlockHeadersResponse) ProtoReflect ¶
func (x *BlockHeadersResponse) ProtoReflect() protoreflect.Message
func (*BlockHeadersResponse) Reset ¶
func (x *BlockHeadersResponse) Reset()
func (*BlockHeadersResponse) String ¶
func (x *BlockHeadersResponse) String() string
type BlockStates ¶
type BlockStates int32
const ( BlockStates_NEW BlockStates = 0 BlockStates_PENDING_VALIDATION BlockStates = 1 BlockStates_VALID BlockStates = 2 BlockStates_PENDING_SIGNATURES BlockStates = 3 BlockStates_SIGNED BlockStates = 4 BlockStates_FINALIZED BlockStates = 5 BlockStates_ACCEPT_TX BlockStates = 6 )
func (BlockStates) Descriptor ¶
func (BlockStates) Descriptor() protoreflect.EnumDescriptor
func (BlockStates) Enum ¶
func (x BlockStates) Enum() *BlockStates
func (BlockStates) EnumDescriptor
deprecated
func (BlockStates) EnumDescriptor() ([]byte, []int)
Deprecated: Use BlockStates.Descriptor instead.
func (BlockStates) Number ¶
func (x BlockStates) Number() protoreflect.EnumNumber
func (BlockStates) String ¶
func (x BlockStates) String() string
func (BlockStates) Type ¶
func (BlockStates) Type() protoreflect.EnumType
type BlockType ¶
type BlockType int32
func (BlockType) Descriptor ¶
func (BlockType) Descriptor() protoreflect.EnumDescriptor
func (BlockType) EnumDescriptor
deprecated
func (BlockType) Number ¶
func (x BlockType) Number() protoreflect.EnumNumber
func (BlockType) Type ¶
func (BlockType) Type() protoreflect.EnumType
type Blockchain ¶
type Blockchain struct { NetworkId uint32 `protobuf:"varint,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` ChainId string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` Version string `protobuf:"bytes,10,opt,name=version,proto3" json:"version,omitempty"` GenesisHash string `protobuf:"bytes,3,opt,name=genesis_hash,json=genesisHash,proto3" json:"genesis_hash,omitempty"` MerkleRoot string `protobuf:"bytes,4,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"` Blocks []*Block `protobuf:"bytes,5,rep,name=blocks,proto3" json:"blocks,omitempty"` NumBlocks int32 `protobuf:"varint,6,opt,name=num_blocks,json=numBlocks,proto3" json:"num_blocks,omitempty"` NumTx int32 `protobuf:"varint,7,opt,name=num_tx,json=numTx,proto3" json:"num_tx,omitempty"` BlockchainHead *Block `protobuf:"bytes,8,opt,name=blockchain_head,json=blockchainHead,proto3" json:"blockchain_head,omitempty"` Validators []*Validator `protobuf:"bytes,9,rep,name=validators,proto3" json:"validators,omitempty"` // contains filtered or unexported fields }
func (*Blockchain) Descriptor
deprecated
func (*Blockchain) Descriptor() ([]byte, []int)
Deprecated: Use Blockchain.ProtoReflect.Descriptor instead.
func (*Blockchain) GetBlockchainHead ¶
func (x *Blockchain) GetBlockchainHead() *Block
func (*Blockchain) GetBlocks ¶
func (x *Blockchain) GetBlocks() []*Block
func (*Blockchain) GetChainId ¶
func (x *Blockchain) GetChainId() string
func (*Blockchain) GetGenesisHash ¶
func (x *Blockchain) GetGenesisHash() string
func (*Blockchain) GetMerkleRoot ¶
func (x *Blockchain) GetMerkleRoot() string
func (*Blockchain) GetNetworkId ¶
func (x *Blockchain) GetNetworkId() uint32
func (*Blockchain) GetNumBlocks ¶
func (x *Blockchain) GetNumBlocks() int32
func (*Blockchain) GetNumTx ¶
func (x *Blockchain) GetNumTx() int32
func (*Blockchain) GetValidators ¶
func (x *Blockchain) GetValidators() []*Validator
func (*Blockchain) GetVersion ¶
func (x *Blockchain) GetVersion() string
func (*Blockchain) ProtoMessage ¶
func (*Blockchain) ProtoMessage()
func (*Blockchain) ProtoReflect ¶
func (x *Blockchain) ProtoReflect() protoreflect.Message
func (*Blockchain) Reset ¶
func (x *Blockchain) Reset()
func (*Blockchain) String ¶
func (x *Blockchain) String() string
type BlockchainSyncClient ¶
type BlockchainSyncClient interface { RequestBlockchainSync(ctx context.Context, in *BlockchainSyncRequest, opts ...grpc.CallOption) (BlockchainSync_RequestBlockchainSyncClient, error) RequestBlockHeaders(ctx context.Context, in *BlockHeadersRequest, opts ...grpc.CallOption) (BlockchainSync_RequestBlockHeadersClient, error) }
BlockchainSyncClient is the client API for BlockchainSync 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 NewBlockchainSyncClient ¶
func NewBlockchainSyncClient(cc grpc.ClientConnInterface) BlockchainSyncClient
type BlockchainSyncRequest ¶
type BlockchainSyncRequest struct { NetworkId string `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` GenesisHash string `protobuf:"bytes,3,opt,name=genesis_hash,json=genesisHash,proto3" json:"genesis_hash,omitempty"` // contains filtered or unexported fields }
func (*BlockchainSyncRequest) Descriptor
deprecated
func (*BlockchainSyncRequest) Descriptor() ([]byte, []int)
Deprecated: Use BlockchainSyncRequest.ProtoReflect.Descriptor instead.
func (*BlockchainSyncRequest) GetGenesisHash ¶
func (x *BlockchainSyncRequest) GetGenesisHash() string
func (*BlockchainSyncRequest) GetNetworkId ¶
func (x *BlockchainSyncRequest) GetNetworkId() string
func (*BlockchainSyncRequest) GetVersion ¶
func (x *BlockchainSyncRequest) GetVersion() string
func (*BlockchainSyncRequest) ProtoMessage ¶
func (*BlockchainSyncRequest) ProtoMessage()
func (*BlockchainSyncRequest) ProtoReflect ¶
func (x *BlockchainSyncRequest) ProtoReflect() protoreflect.Message
func (*BlockchainSyncRequest) Reset ¶
func (x *BlockchainSyncRequest) Reset()
func (*BlockchainSyncRequest) String ¶
func (x *BlockchainSyncRequest) String() string
type BlockchainSyncResponse ¶
type BlockchainSyncResponse struct { Error bool `protobuf:"varint,1,opt,name=error,proto3" json:"error,omitempty"` Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` Blocks []*Block `protobuf:"bytes,3,rep,name=blocks,proto3" json:"blocks,omitempty"` // contains filtered or unexported fields }
func (*BlockchainSyncResponse) Descriptor
deprecated
func (*BlockchainSyncResponse) Descriptor() ([]byte, []int)
Deprecated: Use BlockchainSyncResponse.ProtoReflect.Descriptor instead.
func (*BlockchainSyncResponse) GetBlocks ¶
func (x *BlockchainSyncResponse) GetBlocks() []*Block
func (*BlockchainSyncResponse) GetError ¶
func (x *BlockchainSyncResponse) GetError() bool
func (*BlockchainSyncResponse) GetSuccess ¶
func (x *BlockchainSyncResponse) GetSuccess() bool
func (*BlockchainSyncResponse) ProtoMessage ¶
func (*BlockchainSyncResponse) ProtoMessage()
func (*BlockchainSyncResponse) ProtoReflect ¶
func (x *BlockchainSyncResponse) ProtoReflect() protoreflect.Message
func (*BlockchainSyncResponse) Reset ¶
func (x *BlockchainSyncResponse) Reset()
func (*BlockchainSyncResponse) String ¶
func (x *BlockchainSyncResponse) String() string
type BlockchainSyncServer ¶
type BlockchainSyncServer interface { RequestBlockchainSync(*BlockchainSyncRequest, BlockchainSync_RequestBlockchainSyncServer) error RequestBlockHeaders(*BlockHeadersRequest, BlockchainSync_RequestBlockHeadersServer) error }
BlockchainSyncServer is the server API for BlockchainSync service. All implementations should embed UnimplementedBlockchainSyncServer for forward compatibility
type BlockchainSync_RequestBlockHeadersClient ¶
type BlockchainSync_RequestBlockHeadersClient interface { Recv() (*BlockHeadersResponse, error) grpc.ClientStream }
type BlockchainSync_RequestBlockHeadersServer ¶
type BlockchainSync_RequestBlockHeadersServer interface { Send(*BlockHeadersResponse) error grpc.ServerStream }
type BlockchainSync_RequestBlockchainSyncClient ¶
type BlockchainSync_RequestBlockchainSyncClient interface { Recv() (*BlockchainSyncResponse, error) grpc.ClientStream }
type BlockchainSync_RequestBlockchainSyncServer ¶
type BlockchainSync_RequestBlockchainSyncServer interface { Send(*BlockchainSyncResponse) error grpc.ServerStream }
type ByeMsg ¶
type ByeMsg struct { Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*ByeMsg) Descriptor
deprecated
func (*ByeMsg) ProtoMessage ¶
func (*ByeMsg) ProtoMessage()
func (*ByeMsg) ProtoReflect ¶
func (x *ByeMsg) ProtoReflect() protoreflect.Message
type CurrencyInfo ¶
type CurrencyInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Symbol string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"` Coinbase string `protobuf:"bytes,3,opt,name=coinbase,proto3" json:"coinbase,omitempty"` Circulating uint64 `protobuf:"varint,4,opt,name=circulating,proto3" json:"circulating,omitempty"` Available uint64 `protobuf:"varint,5,opt,name=available,proto3" json:"available,omitempty"` MaxAvailable uint64 `protobuf:"varint,6,opt,name=max_available,json=maxAvailable,proto3" json:"max_available,omitempty"` ValueUsd uint64 `protobuf:"varint,7,opt,name=value_usd,json=valueUsd,proto3" json:"value_usd,omitempty"` Signature string `protobuf:"bytes,8,opt,name=signature,proto3" json:"signature,omitempty"` Network []byte `protobuf:"bytes,9,opt,name=network,proto3" json:"network,omitempty"` // contains filtered or unexported fields }
func (*CurrencyInfo) Descriptor
deprecated
func (*CurrencyInfo) Descriptor() ([]byte, []int)
Deprecated: Use CurrencyInfo.ProtoReflect.Descriptor instead.
func (*CurrencyInfo) GetAvailable ¶
func (x *CurrencyInfo) GetAvailable() uint64
func (*CurrencyInfo) GetCirculating ¶
func (x *CurrencyInfo) GetCirculating() uint64
func (*CurrencyInfo) GetCoinbase ¶
func (x *CurrencyInfo) GetCoinbase() string
func (*CurrencyInfo) GetMaxAvailable ¶
func (x *CurrencyInfo) GetMaxAvailable() uint64
func (*CurrencyInfo) GetName ¶
func (x *CurrencyInfo) GetName() string
func (*CurrencyInfo) GetNetwork ¶
func (x *CurrencyInfo) GetNetwork() []byte
func (*CurrencyInfo) GetSignature ¶
func (x *CurrencyInfo) GetSignature() string
func (*CurrencyInfo) GetSymbol ¶
func (x *CurrencyInfo) GetSymbol() string
func (*CurrencyInfo) GetValueUsd ¶
func (x *CurrencyInfo) GetValueUsd() uint64
func (*CurrencyInfo) ProtoMessage ¶
func (*CurrencyInfo) ProtoMessage()
func (*CurrencyInfo) ProtoReflect ¶
func (x *CurrencyInfo) ProtoReflect() protoreflect.Message
func (*CurrencyInfo) Reset ¶
func (x *CurrencyInfo) Reset()
func (*CurrencyInfo) String ¶
func (x *CurrencyInfo) String() string
type DefaultCurrencyRequest ¶
type DefaultCurrencyRequest struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Symbol string `protobuf:"bytes,3,opt,name=symbol,proto3" json:"symbol,omitempty"` Address string `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"` Network []byte `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"` // contains filtered or unexported fields }
func (*DefaultCurrencyRequest) Descriptor
deprecated
func (*DefaultCurrencyRequest) Descriptor() ([]byte, []int)
Deprecated: Use DefaultCurrencyRequest.ProtoReflect.Descriptor instead.
func (*DefaultCurrencyRequest) GetAddress ¶
func (x *DefaultCurrencyRequest) GetAddress() string
func (*DefaultCurrencyRequest) GetFrom ¶
func (x *DefaultCurrencyRequest) GetFrom() string
func (*DefaultCurrencyRequest) GetName ¶
func (x *DefaultCurrencyRequest) GetName() string
func (*DefaultCurrencyRequest) GetNetwork ¶
func (x *DefaultCurrencyRequest) GetNetwork() []byte
func (*DefaultCurrencyRequest) GetSymbol ¶
func (x *DefaultCurrencyRequest) GetSymbol() string
func (*DefaultCurrencyRequest) ProtoMessage ¶
func (*DefaultCurrencyRequest) ProtoMessage()
func (*DefaultCurrencyRequest) ProtoReflect ¶
func (x *DefaultCurrencyRequest) ProtoReflect() protoreflect.Message
func (*DefaultCurrencyRequest) Reset ¶
func (x *DefaultCurrencyRequest) Reset()
func (*DefaultCurrencyRequest) String ¶
func (x *DefaultCurrencyRequest) String() string
type DefaultCurrencyResponse ¶
type DefaultCurrencyResponse struct { To string `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"` Response *CurrencyInfo `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
func (*DefaultCurrencyResponse) Descriptor
deprecated
func (*DefaultCurrencyResponse) Descriptor() ([]byte, []int)
Deprecated: Use DefaultCurrencyResponse.ProtoReflect.Descriptor instead.
func (*DefaultCurrencyResponse) GetResponse ¶
func (x *DefaultCurrencyResponse) GetResponse() *CurrencyInfo
func (*DefaultCurrencyResponse) GetTo ¶
func (x *DefaultCurrencyResponse) GetTo() string
func (*DefaultCurrencyResponse) ProtoMessage ¶
func (*DefaultCurrencyResponse) ProtoMessage()
func (*DefaultCurrencyResponse) ProtoReflect ¶
func (x *DefaultCurrencyResponse) ProtoReflect() protoreflect.Message
func (*DefaultCurrencyResponse) Reset ¶
func (x *DefaultCurrencyResponse) Reset()
func (*DefaultCurrencyResponse) String ¶
func (x *DefaultCurrencyResponse) String() string
type DiscoveryClient ¶
type DiscoveryClient interface {
FindPeers(ctx context.Context, in *FindPeersReq, opts ...grpc.CallOption) (*FindPeersResp, error)
}
DiscoveryClient is the client API for Discovery 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 NewDiscoveryClient ¶
func NewDiscoveryClient(cc grpc.ClientConnInterface) DiscoveryClient
type DiscoveryServer ¶
type DiscoveryServer interface {
FindPeers(context.Context, *FindPeersReq) (*FindPeersResp, error)
}
DiscoveryServer is the server API for Discovery service. All implementations should embed UnimplementedDiscoveryServer for forward compatibility
type Fees ¶
type Fees struct { TxSize int64 `protobuf:"varint,2,opt,name=tx_size,json=txSize,proto3" json:"tx_size,omitempty"` Total uint64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` Paid bool `protobuf:"varint,4,opt,name=paid,proto3" json:"paid,omitempty"` // contains filtered or unexported fields }
func (*Fees) Descriptor
deprecated
func (*Fees) ProtoMessage ¶
func (*Fees) ProtoMessage()
func (*Fees) ProtoReflect ¶
func (x *Fees) ProtoReflect() protoreflect.Message
type FindPeersReq ¶
type FindPeersReq struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*FindPeersReq) Descriptor
deprecated
func (*FindPeersReq) Descriptor() ([]byte, []int)
Deprecated: Use FindPeersReq.ProtoReflect.Descriptor instead.
func (*FindPeersReq) GetCount ¶
func (x *FindPeersReq) GetCount() int64
func (*FindPeersReq) GetKey ¶
func (x *FindPeersReq) GetKey() string
func (*FindPeersReq) ProtoMessage ¶
func (*FindPeersReq) ProtoMessage()
func (*FindPeersReq) ProtoReflect ¶
func (x *FindPeersReq) ProtoReflect() protoreflect.Message
func (*FindPeersReq) Reset ¶
func (x *FindPeersReq) Reset()
func (*FindPeersReq) String ¶
func (x *FindPeersReq) String() string
type FindPeersResp ¶
type FindPeersResp struct { Nodes []string `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` // contains filtered or unexported fields }
func (*FindPeersResp) Descriptor
deprecated
func (*FindPeersResp) Descriptor() ([]byte, []int)
Deprecated: Use FindPeersResp.ProtoReflect.Descriptor instead.
func (*FindPeersResp) GetNodes ¶
func (x *FindPeersResp) GetNodes() []string
func (*FindPeersResp) ProtoMessage ¶
func (*FindPeersResp) ProtoMessage()
func (*FindPeersResp) ProtoReflect ¶
func (x *FindPeersResp) ProtoReflect() protoreflect.Message
func (*FindPeersResp) Reset ¶
func (x *FindPeersResp) Reset()
func (*FindPeersResp) String ¶
func (x *FindPeersResp) String() string
type IdentityClient ¶
type IdentityClient interface { Hello(ctx context.Context, in *Status, opts ...grpc.CallOption) (*Status, error) Bye(ctx context.Context, in *ByeMsg, opts ...grpc.CallOption) (*emptypb.Empty, error) }
IdentityClient is the client API for Identity 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 NewIdentityClient ¶
func NewIdentityClient(cc grpc.ClientConnInterface) IdentityClient
type IdentityServer ¶
type IdentityServer interface { Hello(context.Context, *Status) (*Status, error) Bye(context.Context, *ByeMsg) (*emptypb.Empty, error) }
IdentityServer is the server API for Identity service. All implementations should embed UnimplementedIdentityServer for forward compatibility
type JobDetails ¶
type JobDetails struct { // A unique ID for the job. JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // The creation time for the job. CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // The [from, to) UUID range assigned to the worker. Note that from is // inclusive and to is exclusive. PartitionFromUuid []byte `protobuf:"bytes,3,opt,name=partition_from_uuid,json=partitionFromUuid,proto3" json:"partition_from_uuid,omitempty"` PartitionToUuid []byte `protobuf:"bytes,4,opt,name=partition_to_uuid,json=partitionToUuid,proto3" json:"partition_to_uuid,omitempty"` // contains filtered or unexported fields }
JobDetails describes a job assigned by a master node to a worker.
func (*JobDetails) Descriptor
deprecated
func (*JobDetails) Descriptor() ([]byte, []int)
Deprecated: Use JobDetails.ProtoReflect.Descriptor instead.
func (*JobDetails) GetCreatedAt ¶
func (x *JobDetails) GetCreatedAt() *timestamppb.Timestamp
func (*JobDetails) GetJobId ¶
func (x *JobDetails) GetJobId() string
func (*JobDetails) GetPartitionFromUuid ¶
func (x *JobDetails) GetPartitionFromUuid() []byte
func (*JobDetails) GetPartitionToUuid ¶
func (x *JobDetails) GetPartitionToUuid() []byte
func (*JobDetails) ProtoMessage ¶
func (*JobDetails) ProtoMessage()
func (*JobDetails) ProtoReflect ¶
func (x *JobDetails) ProtoReflect() protoreflect.Message
func (*JobDetails) Reset ¶
func (x *JobDetails) Reset()
func (*JobDetails) String ¶
func (x *JobDetails) String() string
type JobQueueServiceClient ¶
type JobQueueServiceClient interface {
JobStream(ctx context.Context, opts ...grpc.CallOption) (JobQueueService_JobStreamClient, error)
}
JobQueueServiceClient is the client API for JobQueueService 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 NewJobQueueServiceClient ¶
func NewJobQueueServiceClient(cc grpc.ClientConnInterface) JobQueueServiceClient
type JobQueueServiceServer ¶
type JobQueueServiceServer interface {
JobStream(JobQueueService_JobStreamServer) error
}
JobQueueServiceServer is the server API for JobQueueService service. All implementations should embed UnimplementedJobQueueServiceServer for forward compatibility
type JobQueueService_JobStreamClient ¶
type JobQueueService_JobStreamClient interface { Send(*JobStreamRequest) error Recv() (*JobStreamResponse, error) grpc.ClientStream }
type JobQueueService_JobStreamServer ¶
type JobQueueService_JobStreamServer interface { Send(*JobStreamResponse) error Recv() (*JobStreamRequest, error) grpc.ServerStream }
type JobStreamRequest ¶
type JobStreamRequest struct { // Types that are assignable to Payload: // *JobStreamRequest_State // *JobStreamRequest_RelayMessage Payload isJobStreamRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*JobStreamRequest) Descriptor
deprecated
func (*JobStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use JobStreamRequest.ProtoReflect.Descriptor instead.
func (*JobStreamRequest) GetPayload ¶
func (m *JobStreamRequest) GetPayload() isJobStreamRequest_Payload
func (*JobStreamRequest) GetRelayMessage ¶
func (x *JobStreamRequest) GetRelayMessage() *RelayMessage
func (*JobStreamRequest) GetState ¶
func (x *JobStreamRequest) GetState() *State
func (*JobStreamRequest) ProtoMessage ¶
func (*JobStreamRequest) ProtoMessage()
func (*JobStreamRequest) ProtoReflect ¶
func (x *JobStreamRequest) ProtoReflect() protoreflect.Message
func (*JobStreamRequest) Reset ¶
func (x *JobStreamRequest) Reset()
func (*JobStreamRequest) String ¶
func (x *JobStreamRequest) String() string
type JobStreamRequest_RelayMessage ¶
type JobStreamRequest_RelayMessage struct {
RelayMessage *RelayMessage `protobuf:"bytes,2,opt,name=relay_message,json=relayMessage,proto3,oneof"`
}
type JobStreamRequest_State ¶
type JobStreamRequest_State struct {
State *State `protobuf:"bytes,1,opt,name=state,proto3,oneof"`
}
type JobStreamResponse ¶
type JobStreamResponse struct { // Types that are assignable to Payload: // *JobStreamResponse_JobDetails // *JobStreamResponse_State // *JobStreamResponse_RelayMessage Payload isJobStreamResponse_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*JobStreamResponse) Descriptor
deprecated
func (*JobStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use JobStreamResponse.ProtoReflect.Descriptor instead.
func (*JobStreamResponse) GetJobDetails ¶
func (x *JobStreamResponse) GetJobDetails() *JobDetails
func (*JobStreamResponse) GetPayload ¶
func (m *JobStreamResponse) GetPayload() isJobStreamResponse_Payload
func (*JobStreamResponse) GetRelayMessage ¶
func (x *JobStreamResponse) GetRelayMessage() *RelayMessage
func (*JobStreamResponse) GetState ¶
func (x *JobStreamResponse) GetState() *State
func (*JobStreamResponse) ProtoMessage ¶
func (*JobStreamResponse) ProtoMessage()
func (*JobStreamResponse) ProtoReflect ¶
func (x *JobStreamResponse) ProtoReflect() protoreflect.Message
func (*JobStreamResponse) Reset ¶
func (x *JobStreamResponse) Reset()
func (*JobStreamResponse) String ¶
func (x *JobStreamResponse) String() string
type JobStreamResponse_JobDetails ¶
type JobStreamResponse_JobDetails struct {
JobDetails *JobDetails `protobuf:"bytes,1,opt,name=job_details,json=jobDetails,proto3,oneof"`
}
type JobStreamResponse_RelayMessage ¶
type JobStreamResponse_RelayMessage struct {
RelayMessage *RelayMessage `protobuf:"bytes,3,opt,name=relay_message,json=relayMessage,proto3,oneof"`
}
type JobStreamResponse_State ¶
type JobStreamResponse_State struct {
State *State `protobuf:"bytes,2,opt,name=state,proto3,oneof"`
}
type MinterBurner ¶
type MinterBurner struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` TotalMinted uint64 `protobuf:"varint,2,opt,name=total_minted,json=totalMinted,proto3" json:"total_minted,omitempty"` TotalBurned uint64 `protobuf:"varint,3,opt,name=total_burned,json=totalBurned,proto3" json:"total_burned,omitempty"` // contains filtered or unexported fields }
func (*MinterBurner) Descriptor
deprecated
func (*MinterBurner) Descriptor() ([]byte, []int)
Deprecated: Use MinterBurner.ProtoReflect.Descriptor instead.
func (*MinterBurner) GetAddress ¶
func (x *MinterBurner) GetAddress() string
func (*MinterBurner) GetTotalBurned ¶
func (x *MinterBurner) GetTotalBurned() uint64
func (*MinterBurner) GetTotalMinted ¶
func (x *MinterBurner) GetTotalMinted() uint64
func (*MinterBurner) ProtoMessage ¶
func (*MinterBurner) ProtoMessage()
func (*MinterBurner) ProtoReflect ¶
func (x *MinterBurner) ProtoReflect() protoreflect.Message
func (*MinterBurner) Reset ¶
func (x *MinterBurner) Reset()
func (*MinterBurner) String ¶
func (x *MinterBurner) String() string
type Node ¶
type Node struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Stake uint64 `protobuf:"varint,2,opt,name=stake,proto3" json:"stake,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` LastSeen *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"` // contains filtered or unexported fields }
func (*Node) Descriptor
deprecated
func (*Node) GetAddress ¶
func (*Node) GetLastSeen ¶
func (x *Node) GetLastSeen() *timestamppb.Timestamp
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type Payload ¶
type Payload struct { Payload [][]byte `protobuf:"bytes,1,rep,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
func (*Payload) Descriptor
deprecated
func (*Payload) GetPayload ¶
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type RelayMessage ¶
type RelayMessage struct { // The message destination UUID. Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"` // The serialized message contents. Message *anypb.Any `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*RelayMessage) Descriptor
deprecated
func (*RelayMessage) Descriptor() ([]byte, []int)
Deprecated: Use RelayMessage.ProtoReflect.Descriptor instead.
func (*RelayMessage) GetDestination ¶
func (x *RelayMessage) GetDestination() string
func (*RelayMessage) GetMessage ¶
func (x *RelayMessage) GetMessage() *anypb.Any
func (*RelayMessage) ProtoMessage ¶
func (*RelayMessage) ProtoMessage()
func (*RelayMessage) ProtoReflect ¶
func (x *RelayMessage) ProtoReflect() protoreflect.Message
func (*RelayMessage) Reset ¶
func (x *RelayMessage) Reset()
func (*RelayMessage) String ¶
func (x *RelayMessage) String() string
type RequestTxQueueElements ¶
type RequestTxQueueElements struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Status TxStatus `protobuf:"varint,2,opt,name=status,proto3,enum=quantos.pkg.v1.TxStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*RequestTxQueueElements) Descriptor
deprecated
func (*RequestTxQueueElements) Descriptor() ([]byte, []int)
Deprecated: Use RequestTxQueueElements.ProtoReflect.Descriptor instead.
func (*RequestTxQueueElements) GetFrom ¶
func (x *RequestTxQueueElements) GetFrom() string
func (*RequestTxQueueElements) GetStatus ¶
func (x *RequestTxQueueElements) GetStatus() TxStatus
func (*RequestTxQueueElements) ProtoMessage ¶
func (*RequestTxQueueElements) ProtoMessage()
func (*RequestTxQueueElements) ProtoReflect ¶
func (x *RequestTxQueueElements) ProtoReflect() protoreflect.Message
func (*RequestTxQueueElements) Reset ¶
func (x *RequestTxQueueElements) Reset()
func (*RequestTxQueueElements) String ¶
func (x *RequestTxQueueElements) String() string
type State ¶
type State struct { Type State_Type `protobuf:"varint,1,opt,name=type,proto3,enum=proto.v1.State_Type" json:"type,omitempty"` // Workers use this field to submit their local aggregator delta values wen // reaching the POST step. The master collects the deltas, aggregates them to // its own aggregator values and broadcasts the global aggregator values in // the response. Workers must then *overwrite* their local aggregator values // with the values provided by the master. AggregatorValues map[string]*anypb.Any `` /* 197-byte string literal not displayed */ // Workers use this field to submit their local active-in-step count when // reaching the POST_KEEP_RUNNING step. The step response broadcasted by // the master uses the same field to specify the global active-in-step count // that the workers should pass to the graph executor callbacks. ActiveInState int64 `protobuf:"varint,3,opt,name=active_in_state,json=activeInState,proto3" json:"active_in_state,omitempty"` // contains filtered or unexported fields }
func (*State) Descriptor
deprecated
func (*State) GetActiveInState ¶
func (*State) GetType ¶
func (x *State) GetType() State_Type
func (*State) ProtoMessage ¶
func (*State) ProtoMessage()
func (*State) ProtoReflect ¶
func (x *State) ProtoReflect() protoreflect.Message
type State_Type ¶
type State_Type int32
Type of Job State
const ( State_TYPE_INVALID_UNSPECIFIED State_Type = 0 // This step corresponds to the PRE step of the executor callback. State_TYPE_PRE State_Type = 1 // This step corresponds to the POST step of the executor callback. State_TYPE_POST State_Type = 2 // This step corresponds to the POST_KEEP_RUNNING step of the executor // callback. State_TYPE_POST_KEEP_RUNNING State_Type = 3 // This step indicates to the master that the worker has successfully // completed the graph execution and is ready to perist the computation // results. State_TYPE_EXECUTED_GRAPH State_Type = 4 // This step indicates to the master that the worker has successfully // persisted the computation results. State_TYPE_PERSISTED_RESULTS State_Type = 5 // This step indicates to the master that the worker has completed the job. State_TYPE_COMPLETED_JOB State_Type = 6 )
func (State_Type) Descriptor ¶
func (State_Type) Descriptor() protoreflect.EnumDescriptor
func (State_Type) Enum ¶
func (x State_Type) Enum() *State_Type
func (State_Type) EnumDescriptor
deprecated
func (State_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use State_Type.Descriptor instead.
func (State_Type) Number ¶
func (x State_Type) Number() protoreflect.EnumNumber
func (State_Type) String ¶
func (x State_Type) String() string
func (State_Type) Type ¶
func (State_Type) Type() protoreflect.EnumType
type Status ¶
type Status struct { Metadata map[string]string `` /* 157-byte string literal not displayed */ Keys []*Status_Key `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"` Chain int64 `protobuf:"varint,3,opt,name=chain,proto3" json:"chain,omitempty"` Genesis string `protobuf:"bytes,4,opt,name=genesis,proto3" json:"genesis,omitempty"` // contains filtered or unexported fields }
func (*Status) Descriptor
deprecated
func (*Status) GetGenesis ¶
func (*Status) GetKeys ¶
func (x *Status) GetKeys() []*Status_Key
func (*Status) GetMetadata ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type Status_Key ¶
type Status_Key struct { Signature string `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Status_Key) Descriptor
deprecated
func (*Status_Key) Descriptor() ([]byte, []int)
Deprecated: Use Status_Key.ProtoReflect.Descriptor instead.
func (*Status_Key) GetMessage ¶
func (x *Status_Key) GetMessage() string
func (*Status_Key) GetSignature ¶
func (x *Status_Key) GetSignature() string
func (*Status_Key) ProtoMessage ¶
func (*Status_Key) ProtoMessage()
func (*Status_Key) ProtoReflect ¶
func (x *Status_Key) ProtoReflect() protoreflect.Message
func (*Status_Key) Reset ¶
func (x *Status_Key) Reset()
func (*Status_Key) String ¶
func (x *Status_Key) String() string
type Swapper ¶
type Swapper struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` BridgeAddress string `protobuf:"bytes,2,opt,name=bridge_address,json=bridgeAddress,proto3" json:"bridge_address,omitempty"` ContractAddress string `protobuf:"bytes,3,opt,name=contract_address,json=contractAddress,proto3" json:"contract_address,omitempty"` CanSwap []*CurrencyInfo `protobuf:"bytes,4,rep,name=can_swap,json=canSwap,proto3" json:"can_swap,omitempty"` // contains filtered or unexported fields }
func (*Swapper) Descriptor
deprecated
func (*Swapper) GetAddress ¶
func (*Swapper) GetBridgeAddress ¶
func (*Swapper) GetCanSwap ¶
func (x *Swapper) GetCanSwap() []*CurrencyInfo
func (*Swapper) GetContractAddress ¶
func (*Swapper) ProtoMessage ¶
func (*Swapper) ProtoMessage()
func (*Swapper) ProtoReflect ¶
func (x *Swapper) ProtoReflect() protoreflect.Message
type TransactionInfo ¶
type TransactionInfo struct { Inputs []*TxInput `protobuf:"bytes,1,rep,name=inputs,proto3" json:"inputs,omitempty"` Outputs []*TxOutput `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"` TxStatus TxStatus `protobuf:"varint,3,opt,name=tx_status,json=txStatus,proto3,enum=quantos.pkg.v1.TxStatus" json:"tx_status,omitempty"` Validators []string `protobuf:"bytes,4,rep,name=validators,proto3" json:"validators,omitempty"` Scripts []string `protobuf:"bytes,5,rep,name=scripts,proto3" json:"scripts,omitempty"` // contains filtered or unexported fields }
func (*TransactionInfo) Descriptor
deprecated
func (*TransactionInfo) Descriptor() ([]byte, []int)
Deprecated: Use TransactionInfo.ProtoReflect.Descriptor instead.
func (*TransactionInfo) GetInputs ¶
func (x *TransactionInfo) GetInputs() []*TxInput
func (*TransactionInfo) GetOutputs ¶
func (x *TransactionInfo) GetOutputs() []*TxOutput
func (*TransactionInfo) GetScripts ¶
func (x *TransactionInfo) GetScripts() []string
func (*TransactionInfo) GetTxStatus ¶
func (x *TransactionInfo) GetTxStatus() TxStatus
func (*TransactionInfo) GetValidators ¶
func (x *TransactionInfo) GetValidators() []string
func (*TransactionInfo) ProtoMessage ¶
func (*TransactionInfo) ProtoMessage()
func (*TransactionInfo) ProtoReflect ¶
func (x *TransactionInfo) ProtoReflect() protoreflect.Message
func (*TransactionInfo) Reset ¶
func (x *TransactionInfo) Reset()
func (*TransactionInfo) String ¶
func (x *TransactionInfo) String() string
type Tx ¶
type Tx struct { Amount uint64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"` From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` Fees uint64 `protobuf:"varint,4,opt,name=fees,proto3" json:"fees,omitempty"` TxId string `protobuf:"bytes,5,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` Signatures []string `protobuf:"bytes,6,rep,name=signatures,proto3" json:"signatures,omitempty"` MerkleRoot []byte `protobuf:"bytes,7,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"` ContractAddress string `protobuf:"bytes,8,opt,name=contract_address,json=contractAddress,proto3" json:"contract_address,omitempty"` Notes string `protobuf:"bytes,9,opt,name=notes,proto3" json:"notes,omitempty"` Ref string `protobuf:"bytes,10,opt,name=ref,proto3" json:"ref,omitempty"` Currency *CurrencyInfo `protobuf:"bytes,11,opt,name=currency,proto3" json:"currency,omitempty"` Nonce int64 `protobuf:"varint,12,opt,name=nonce,proto3" json:"nonce,omitempty"` // contains filtered or unexported fields }
func (*Tx) Descriptor
deprecated
func (*Tx) GetContractAddress ¶
func (*Tx) GetCurrency ¶
func (x *Tx) GetCurrency() *CurrencyInfo
func (*Tx) GetMerkleRoot ¶
func (*Tx) GetSignatures ¶
func (*Tx) ProtoMessage ¶
func (*Tx) ProtoMessage()
func (*Tx) ProtoReflect ¶
func (x *Tx) ProtoReflect() protoreflect.Message
type TxInput ¶
type TxInput struct { TxType TxReqType `protobuf:"varint,1,opt,name=tx_type,json=txType,proto3,enum=quantos.pkg.v1.TxReqType" json:"tx_type,omitempty"` From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` Value uint64 `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"` To string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"` Currency *CurrencyInfo `protobuf:"bytes,5,opt,name=currency,proto3" json:"currency,omitempty"` Spent bool `protobuf:"varint,6,opt,name=spent,proto3" json:"spent,omitempty"` // contains filtered or unexported fields }
func (*TxInput) Descriptor
deprecated
func (*TxInput) GetCurrency ¶
func (x *TxInput) GetCurrency() *CurrencyInfo
func (*TxInput) ProtoMessage ¶
func (*TxInput) ProtoMessage()
func (*TxInput) ProtoReflect ¶
func (x *TxInput) ProtoReflect() protoreflect.Message
type TxOutput ¶
type TxOutput struct { TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Value uint64 `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"` Fees *Fees `protobuf:"bytes,4,opt,name=fees,proto3" json:"fees,omitempty"` Input *TxInput `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"` // contains filtered or unexported fields }
func (*TxOutput) Descriptor
deprecated
func (*TxOutput) GetAddress ¶
func (*TxOutput) ProtoMessage ¶
func (*TxOutput) ProtoMessage()
func (*TxOutput) ProtoReflect ¶
func (x *TxOutput) ProtoReflect() protoreflect.Message
type TxQueue ¶
type TxQueue struct { ValidatorPool []string `protobuf:"bytes,1,rep,name=validatorPool,proto3" json:"validatorPool,omitempty"` Elements []*TxQueueElement `protobuf:"bytes,2,rep,name=elements,proto3" json:"elements,omitempty"` // contains filtered or unexported fields }
func (*TxQueue) Descriptor
deprecated
func (*TxQueue) GetElements ¶
func (x *TxQueue) GetElements() []*TxQueueElement
func (*TxQueue) GetValidatorPool ¶
func (*TxQueue) ProtoMessage ¶
func (*TxQueue) ProtoMessage()
func (*TxQueue) ProtoReflect ¶
func (x *TxQueue) ProtoReflect() protoreflect.Message
type TxQueueElement ¶
type TxQueueElement struct { Nonce int64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"` Transaction *Tx `protobuf:"bytes,2,opt,name=transaction,proto3" json:"transaction,omitempty"` TxStatus TxStatus `protobuf:"varint,3,opt,name=tx_status,json=txStatus,proto3,enum=quantos.pkg.v1.TxStatus" json:"tx_status,omitempty"` // contains filtered or unexported fields }
func (*TxQueueElement) Descriptor
deprecated
func (*TxQueueElement) Descriptor() ([]byte, []int)
Deprecated: Use TxQueueElement.ProtoReflect.Descriptor instead.
func (*TxQueueElement) GetNonce ¶
func (x *TxQueueElement) GetNonce() int64
func (*TxQueueElement) GetTransaction ¶
func (x *TxQueueElement) GetTransaction() *Tx
func (*TxQueueElement) GetTxStatus ¶
func (x *TxQueueElement) GetTxStatus() TxStatus
func (*TxQueueElement) ProtoMessage ¶
func (*TxQueueElement) ProtoMessage()
func (*TxQueueElement) ProtoReflect ¶
func (x *TxQueueElement) ProtoReflect() protoreflect.Message
func (*TxQueueElement) Reset ¶
func (x *TxQueueElement) Reset()
func (*TxQueueElement) String ¶
func (x *TxQueueElement) String() string
type TxReqType ¶
type TxReqType int32
func (TxReqType) Descriptor ¶
func (TxReqType) Descriptor() protoreflect.EnumDescriptor
func (TxReqType) EnumDescriptor
deprecated
func (TxReqType) Number ¶
func (x TxReqType) Number() protoreflect.EnumNumber
func (TxReqType) Type ¶
func (TxReqType) Type() protoreflect.EnumType
type TxRequest ¶
type TxRequest struct { FromAddress string `protobuf:"bytes,1,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"` RequestType TxReqType `protobuf:"varint,2,opt,name=request_type,json=requestType,proto3,enum=quantos.pkg.v1.TxReqType" json:"request_type,omitempty"` // contains filtered or unexported fields }
func (*TxRequest) Descriptor
deprecated
func (*TxRequest) GetFromAddress ¶
func (*TxRequest) GetRequestType ¶
func (*TxRequest) ProtoMessage ¶
func (*TxRequest) ProtoMessage()
func (*TxRequest) ProtoReflect ¶
func (x *TxRequest) ProtoReflect() protoreflect.Message
type TxSendAmountRequest ¶
type TxSendAmountRequest struct { Request *TxRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Amount uint64 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"` To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` Signature string `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*TxSendAmountRequest) Descriptor
deprecated
func (*TxSendAmountRequest) Descriptor() ([]byte, []int)
Deprecated: Use TxSendAmountRequest.ProtoReflect.Descriptor instead.
func (*TxSendAmountRequest) GetAmount ¶
func (x *TxSendAmountRequest) GetAmount() uint64
func (*TxSendAmountRequest) GetRequest ¶
func (x *TxSendAmountRequest) GetRequest() *TxRequest
func (*TxSendAmountRequest) GetSignature ¶
func (x *TxSendAmountRequest) GetSignature() string
func (*TxSendAmountRequest) GetTo ¶
func (x *TxSendAmountRequest) GetTo() string
func (*TxSendAmountRequest) ProtoMessage ¶
func (*TxSendAmountRequest) ProtoMessage()
func (*TxSendAmountRequest) ProtoReflect ¶
func (x *TxSendAmountRequest) ProtoReflect() protoreflect.Message
func (*TxSendAmountRequest) Reset ¶
func (x *TxSendAmountRequest) Reset()
func (*TxSendAmountRequest) String ¶
func (x *TxSendAmountRequest) String() string
type TxStatus ¶
type TxStatus int32
func (TxStatus) Descriptor ¶
func (TxStatus) Descriptor() protoreflect.EnumDescriptor
func (TxStatus) EnumDescriptor
deprecated
func (TxStatus) Number ¶
func (x TxStatus) Number() protoreflect.EnumNumber
func (TxStatus) Type ¶
func (TxStatus) Type() protoreflect.EnumType
type UnimplementedBankServer ¶
type UnimplementedBankServer struct { }
UnimplementedBankServer should be embedded to have forward compatible implementations.
func (UnimplementedBankServer) GetCurrencyInfo ¶
func (UnimplementedBankServer) GetCurrencyInfo(context.Context, *DefaultCurrencyRequest) (*DefaultCurrencyResponse, error)
func (UnimplementedBankServer) GetTxQueueElements ¶
func (UnimplementedBankServer) GetTxQueueElements(*RequestTxQueueElements, Bank_GetTxQueueElementsServer) error
func (UnimplementedBankServer) SendTransaction ¶
func (UnimplementedBankServer) SendTransaction(context.Context, *TxSendAmountRequest) (*TransactionInfo, error)
type UnimplementedBlockchainSyncServer ¶
type UnimplementedBlockchainSyncServer struct { }
UnimplementedBlockchainSyncServer should be embedded to have forward compatible implementations.
func (UnimplementedBlockchainSyncServer) RequestBlockHeaders ¶
func (UnimplementedBlockchainSyncServer) RequestBlockHeaders(*BlockHeadersRequest, BlockchainSync_RequestBlockHeadersServer) error
func (UnimplementedBlockchainSyncServer) RequestBlockchainSync ¶
func (UnimplementedBlockchainSyncServer) RequestBlockchainSync(*BlockchainSyncRequest, BlockchainSync_RequestBlockchainSyncServer) error
type UnimplementedDiscoveryServer ¶
type UnimplementedDiscoveryServer struct { }
UnimplementedDiscoveryServer should be embedded to have forward compatible implementations.
func (UnimplementedDiscoveryServer) FindPeers ¶
func (UnimplementedDiscoveryServer) FindPeers(context.Context, *FindPeersReq) (*FindPeersResp, error)
type UnimplementedIdentityServer ¶
type UnimplementedIdentityServer struct { }
UnimplementedIdentityServer should be embedded to have forward compatible implementations.
type UnimplementedJobQueueServiceServer ¶
type UnimplementedJobQueueServiceServer struct { }
UnimplementedJobQueueServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedJobQueueServiceServer) JobStream ¶
func (UnimplementedJobQueueServiceServer) JobStream(JobQueueService_JobStreamServer) error
type UnsafeBankServer ¶
type UnsafeBankServer interface {
// contains filtered or unexported methods
}
UnsafeBankServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BankServer will result in compilation errors.
type UnsafeBlockchainSyncServer ¶
type UnsafeBlockchainSyncServer interface {
// contains filtered or unexported methods
}
UnsafeBlockchainSyncServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BlockchainSyncServer will result in compilation errors.
type UnsafeDiscoveryServer ¶
type UnsafeDiscoveryServer interface {
// contains filtered or unexported methods
}
UnsafeDiscoveryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DiscoveryServer will result in compilation errors.
type UnsafeIdentityServer ¶
type UnsafeIdentityServer interface {
// contains filtered or unexported methods
}
UnsafeIdentityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IdentityServer will result in compilation errors.
type UnsafeJobQueueServiceServer ¶
type UnsafeJobQueueServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobQueueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobQueueServiceServer will result in compilation errors.
type Validator ¶
type Validator struct { Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // contains filtered or unexported fields }
func (*Validator) Descriptor
deprecated
func (*Validator) ProtoMessage ¶
func (*Validator) ProtoMessage()
func (*Validator) ProtoReflect ¶
func (x *Validator) ProtoReflect() protoreflect.Message