concordium_grpc_api

package module
v0.0.0-...-a09fda4 Latest Latest
Warning

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

Go to latest
Published: Jun 28, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

README

gRPC API

Contributor Covenant

This repository keeps the gRPC protocol definition file and related documentation on the gRPC interface exposed by concordium-node.

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	PeerElement_CatchupStatus_name = map[int32]string{
		0: "UPTODATE",
		1: "PENDING",
		2: "CATCHINGUP",
	}
	PeerElement_CatchupStatus_value = map[string]int32{
		"UPTODATE":   0,
		"PENDING":    1,
		"CATCHINGUP": 2,
	}
)

Enum value maps for PeerElement_CatchupStatus.

View Source
var (
	NodeInfoResponse_IsInBakingCommittee_name = map[int32]string{
		0: "NOT_IN_COMMITTEE",
		1: "ADDED_BUT_NOT_ACTIVE_IN_COMMITTEE",
		2: "ADDED_BUT_WRONG_KEYS",
		3: "ACTIVE_IN_COMMITTEE",
	}
	NodeInfoResponse_IsInBakingCommittee_value = map[string]int32{
		"NOT_IN_COMMITTEE":                  0,
		"ADDED_BUT_NOT_ACTIVE_IN_COMMITTEE": 1,
		"ADDED_BUT_WRONG_KEYS":              2,
		"ACTIVE_IN_COMMITTEE":               3,
	}
)

Enum value maps for NodeInfoResponse_IsInBakingCommittee.

View Source
var File_p2p_rpc_proto protoreflect.FileDescriptor

Functions

func RegisterP2PServer

func RegisterP2PServer(s *grpc.Server, srv P2PServer)

Types

type AccountAddress

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

func (*AccountAddress) Descriptor deprecated

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

Deprecated: Use AccountAddress.ProtoReflect.Descriptor instead.

func (*AccountAddress) GetAccountAddress

func (x *AccountAddress) GetAccountAddress() string

func (*AccountAddress) ProtoMessage

func (*AccountAddress) ProtoMessage()

func (*AccountAddress) ProtoReflect

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

func (*AccountAddress) Reset

func (x *AccountAddress) Reset()

func (*AccountAddress) String

func (x *AccountAddress) String() string

type BlockHash

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

func (*BlockHash) Descriptor deprecated

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

Deprecated: Use BlockHash.ProtoReflect.Descriptor instead.

func (*BlockHash) GetBlockHash

func (x *BlockHash) GetBlockHash() string

func (*BlockHash) ProtoMessage

func (*BlockHash) ProtoMessage()

func (*BlockHash) ProtoReflect

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

func (*BlockHash) Reset

func (x *BlockHash) Reset()

func (*BlockHash) String

func (x *BlockHash) String() string

type BlockHashAndAmount

type BlockHashAndAmount struct {
	BlockHash string `protobuf:"bytes,1,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	Amount    uint64 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockHashAndAmount) Descriptor deprecated

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

Deprecated: Use BlockHashAndAmount.ProtoReflect.Descriptor instead.

func (*BlockHashAndAmount) GetAmount

func (x *BlockHashAndAmount) GetAmount() uint64

func (*BlockHashAndAmount) GetBlockHash

func (x *BlockHashAndAmount) GetBlockHash() string

func (*BlockHashAndAmount) ProtoMessage

func (*BlockHashAndAmount) ProtoMessage()

func (*BlockHashAndAmount) ProtoReflect

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

func (*BlockHashAndAmount) Reset

func (x *BlockHashAndAmount) Reset()

func (*BlockHashAndAmount) String

func (x *BlockHashAndAmount) String() string

type BlockHeight

type BlockHeight struct {
	BlockHeight uint64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockHeight) Descriptor deprecated

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

Deprecated: Use BlockHeight.ProtoReflect.Descriptor instead.

func (*BlockHeight) GetBlockHeight

func (x *BlockHeight) GetBlockHeight() uint64

func (*BlockHeight) ProtoMessage

func (*BlockHeight) ProtoMessage()

func (*BlockHeight) ProtoReflect

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

func (*BlockHeight) Reset

func (x *BlockHeight) Reset()

func (*BlockHeight) String

func (x *BlockHeight) String() string

type BoolResponse

type BoolResponse struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolResponse) Descriptor deprecated

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

Deprecated: Use BoolResponse.ProtoReflect.Descriptor instead.

func (*BoolResponse) GetValue

func (x *BoolResponse) GetValue() bool

func (*BoolResponse) ProtoMessage

func (*BoolResponse) ProtoMessage()

func (*BoolResponse) ProtoReflect

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

func (*BoolResponse) Reset

func (x *BoolResponse) Reset()

func (*BoolResponse) String

func (x *BoolResponse) String() string

type BytesResponse

type BytesResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BytesResponse) Descriptor deprecated

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

Deprecated: Use BytesResponse.ProtoReflect.Descriptor instead.

func (*BytesResponse) GetValue

func (x *BytesResponse) GetValue() []byte

func (*BytesResponse) ProtoMessage

func (*BytesResponse) ProtoMessage()

func (*BytesResponse) ProtoReflect

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

func (*BytesResponse) Reset

func (x *BytesResponse) Reset()

func (*BytesResponse) String

func (x *BytesResponse) String() string

type DumpRequest

type DumpRequest struct {
	File string `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Raw  bool   `protobuf:"varint,2,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*DumpRequest) Descriptor deprecated

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

Deprecated: Use DumpRequest.ProtoReflect.Descriptor instead.

func (*DumpRequest) GetFile

func (x *DumpRequest) GetFile() string

func (*DumpRequest) GetRaw

func (x *DumpRequest) GetRaw() bool

func (*DumpRequest) ProtoMessage

func (*DumpRequest) ProtoMessage()

func (*DumpRequest) ProtoReflect

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

func (*DumpRequest) Reset

func (x *DumpRequest) Reset()

func (*DumpRequest) String

func (x *DumpRequest) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type GetAddressInfoRequest

type GetAddressInfoRequest struct {
	BlockHash string `protobuf:"bytes,1,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	Address   string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAddressInfoRequest) Descriptor deprecated

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

Deprecated: Use GetAddressInfoRequest.ProtoReflect.Descriptor instead.

func (*GetAddressInfoRequest) GetAddress

func (x *GetAddressInfoRequest) GetAddress() string

func (*GetAddressInfoRequest) GetBlockHash

func (x *GetAddressInfoRequest) GetBlockHash() string

func (*GetAddressInfoRequest) ProtoMessage

func (*GetAddressInfoRequest) ProtoMessage()

func (*GetAddressInfoRequest) ProtoReflect

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

func (*GetAddressInfoRequest) Reset

func (x *GetAddressInfoRequest) Reset()

func (*GetAddressInfoRequest) String

func (x *GetAddressInfoRequest) String() string

type GetModuleSourceRequest

type GetModuleSourceRequest struct {
	BlockHash string `protobuf:"bytes,1,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	ModuleRef string `protobuf:"bytes,2,opt,name=module_ref,json=moduleRef,proto3" json:"module_ref,omitempty"`
	// contains filtered or unexported fields
}

func (*GetModuleSourceRequest) Descriptor deprecated

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

Deprecated: Use GetModuleSourceRequest.ProtoReflect.Descriptor instead.

func (*GetModuleSourceRequest) GetBlockHash

func (x *GetModuleSourceRequest) GetBlockHash() string

func (*GetModuleSourceRequest) GetModuleRef

func (x *GetModuleSourceRequest) GetModuleRef() string

func (*GetModuleSourceRequest) ProtoMessage

func (*GetModuleSourceRequest) ProtoMessage()

func (*GetModuleSourceRequest) ProtoReflect

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

func (*GetModuleSourceRequest) Reset

func (x *GetModuleSourceRequest) Reset()

func (*GetModuleSourceRequest) String

func (x *GetModuleSourceRequest) String() string

type GetTransactionStatusInBlockRequest

type GetTransactionStatusInBlockRequest struct {
	TransactionHash string `protobuf:"bytes,1,opt,name=transaction_hash,json=transactionHash,proto3" json:"transaction_hash,omitempty"`
	BlockHash       string `protobuf:"bytes,2,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionStatusInBlockRequest) Descriptor deprecated

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

Deprecated: Use GetTransactionStatusInBlockRequest.ProtoReflect.Descriptor instead.

func (*GetTransactionStatusInBlockRequest) GetBlockHash

func (x *GetTransactionStatusInBlockRequest) GetBlockHash() string

func (*GetTransactionStatusInBlockRequest) GetTransactionHash

func (x *GetTransactionStatusInBlockRequest) GetTransactionHash() string

func (*GetTransactionStatusInBlockRequest) ProtoMessage

func (*GetTransactionStatusInBlockRequest) ProtoMessage()

func (*GetTransactionStatusInBlockRequest) ProtoReflect

func (*GetTransactionStatusInBlockRequest) Reset

func (*GetTransactionStatusInBlockRequest) String

type JsonResponse

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

func (*JsonResponse) Descriptor deprecated

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

Deprecated: Use JsonResponse.ProtoReflect.Descriptor instead.

func (*JsonResponse) GetValue

func (x *JsonResponse) GetValue() string

func (*JsonResponse) ProtoMessage

func (*JsonResponse) ProtoMessage()

func (*JsonResponse) ProtoReflect

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

func (*JsonResponse) Reset

func (x *JsonResponse) Reset()

func (*JsonResponse) String

func (x *JsonResponse) String() string

type NetworkChangeRequest

type NetworkChangeRequest struct {
	NetworkId *wrapperspb.Int32Value `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkChangeRequest) Descriptor deprecated

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

Deprecated: Use NetworkChangeRequest.ProtoReflect.Descriptor instead.

func (*NetworkChangeRequest) GetNetworkId

func (x *NetworkChangeRequest) GetNetworkId() *wrapperspb.Int32Value

func (*NetworkChangeRequest) ProtoMessage

func (*NetworkChangeRequest) ProtoMessage()

func (*NetworkChangeRequest) ProtoReflect

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

func (*NetworkChangeRequest) Reset

func (x *NetworkChangeRequest) Reset()

func (*NetworkChangeRequest) String

func (x *NetworkChangeRequest) String() string

type NodeInfoResponse

type NodeInfoResponse struct {
	NodeId                      *wrapperspb.StringValue              `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	CurrentLocaltime            uint64                               `protobuf:"varint,2,opt,name=current_localtime,json=currentLocaltime,proto3" json:"current_localtime,omitempty"`
	PeerType                    string                               `protobuf:"bytes,3,opt,name=peer_type,json=peerType,proto3" json:"peer_type,omitempty"`
	ConsensusBakerRunning       bool                                 `` /* 127-byte string literal not displayed */
	ConsensusRunning            bool                                 `protobuf:"varint,5,opt,name=consensus_running,json=consensusRunning,proto3" json:"consensus_running,omitempty"`
	ConsensusType               string                               `protobuf:"bytes,6,opt,name=consensus_type,json=consensusType,proto3" json:"consensus_type,omitempty"`
	ConsensusBakerCommittee     NodeInfoResponse_IsInBakingCommittee `` /* 186-byte string literal not displayed */
	ConsensusFinalizerCommittee bool                                 `` /* 145-byte string literal not displayed */
	ConsensusBakerId            *wrapperspb.UInt64Value              `protobuf:"bytes,9,opt,name=consensus_baker_id,json=consensusBakerId,proto3" json:"consensus_baker_id,omitempty"`
	// Deprecated: Do not use.
	StagingNetUsername *wrapperspb.StringValue `protobuf:"bytes,50,opt,name=staging_net_username,json=stagingNetUsername,proto3" json:"staging_net_username,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfoResponse) Descriptor deprecated

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

Deprecated: Use NodeInfoResponse.ProtoReflect.Descriptor instead.

func (*NodeInfoResponse) GetConsensusBakerCommittee

func (x *NodeInfoResponse) GetConsensusBakerCommittee() NodeInfoResponse_IsInBakingCommittee

func (*NodeInfoResponse) GetConsensusBakerId

func (x *NodeInfoResponse) GetConsensusBakerId() *wrapperspb.UInt64Value

func (*NodeInfoResponse) GetConsensusBakerRunning

func (x *NodeInfoResponse) GetConsensusBakerRunning() bool

func (*NodeInfoResponse) GetConsensusFinalizerCommittee

func (x *NodeInfoResponse) GetConsensusFinalizerCommittee() bool

func (*NodeInfoResponse) GetConsensusRunning

func (x *NodeInfoResponse) GetConsensusRunning() bool

func (*NodeInfoResponse) GetConsensusType

func (x *NodeInfoResponse) GetConsensusType() string

func (*NodeInfoResponse) GetCurrentLocaltime

func (x *NodeInfoResponse) GetCurrentLocaltime() uint64

func (*NodeInfoResponse) GetNodeId

func (x *NodeInfoResponse) GetNodeId() *wrapperspb.StringValue

func (*NodeInfoResponse) GetPeerType

func (x *NodeInfoResponse) GetPeerType() string

func (*NodeInfoResponse) GetStagingNetUsername deprecated

func (x *NodeInfoResponse) GetStagingNetUsername() *wrapperspb.StringValue

Deprecated: Do not use.

func (*NodeInfoResponse) ProtoMessage

func (*NodeInfoResponse) ProtoMessage()

func (*NodeInfoResponse) ProtoReflect

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

func (*NodeInfoResponse) Reset

func (x *NodeInfoResponse) Reset()

func (*NodeInfoResponse) String

func (x *NodeInfoResponse) String() string

type NodeInfoResponse_IsInBakingCommittee

type NodeInfoResponse_IsInBakingCommittee int32
const (
	NodeInfoResponse_NOT_IN_COMMITTEE                  NodeInfoResponse_IsInBakingCommittee = 0
	NodeInfoResponse_ADDED_BUT_NOT_ACTIVE_IN_COMMITTEE NodeInfoResponse_IsInBakingCommittee = 1
	NodeInfoResponse_ADDED_BUT_WRONG_KEYS              NodeInfoResponse_IsInBakingCommittee = 2
	NodeInfoResponse_ACTIVE_IN_COMMITTEE               NodeInfoResponse_IsInBakingCommittee = 3
)

func (NodeInfoResponse_IsInBakingCommittee) Descriptor

func (NodeInfoResponse_IsInBakingCommittee) Enum

func (NodeInfoResponse_IsInBakingCommittee) EnumDescriptor deprecated

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

Deprecated: Use NodeInfoResponse_IsInBakingCommittee.Descriptor instead.

func (NodeInfoResponse_IsInBakingCommittee) Number

func (NodeInfoResponse_IsInBakingCommittee) String

func (NodeInfoResponse_IsInBakingCommittee) Type

type NumberResponse

type NumberResponse struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*NumberResponse) Descriptor deprecated

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

Deprecated: Use NumberResponse.ProtoReflect.Descriptor instead.

func (*NumberResponse) GetValue

func (x *NumberResponse) GetValue() uint64

func (*NumberResponse) ProtoMessage

func (*NumberResponse) ProtoMessage()

func (*NumberResponse) ProtoReflect

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

func (*NumberResponse) Reset

func (x *NumberResponse) Reset()

func (*NumberResponse) String

func (x *NumberResponse) String() string

type P2PClient

type P2PClient interface {
	//! Suggest to a peer to connect to the submitted peer details.
	//! This, if successful, adds the peer to the list of given addresses.
	PeerConnect(ctx context.Context, in *PeerConnectRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	//! Disconnect from the peer and remove them from the given addresses list
	//! if they are on it. Return if the request was processed successfully.
	PeerDisconnect(ctx context.Context, in *PeerConnectRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	//! Peer uptime in milliseconds
	PeerUptime(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NumberResponse, error)
	//! Peer total number of sent packets
	PeerTotalSent(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NumberResponse, error)
	//! Peer total number of received packets
	PeerTotalReceived(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NumberResponse, error)
	//! Peer client software version
	PeerVersion(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StringResponse, error)
	//! Stats for connected peers
	PeerStats(ctx context.Context, in *PeersRequest, opts ...grpc.CallOption) (*PeerStatsResponse, error)
	//! List of connected peers
	PeerList(ctx context.Context, in *PeersRequest, opts ...grpc.CallOption) (*PeerListResponse, error)
	BanNode(ctx context.Context, in *PeerElement, opts ...grpc.CallOption) (*BoolResponse, error)
	UnbanNode(ctx context.Context, in *PeerElement, opts ...grpc.CallOption) (*BoolResponse, error)
	JoinNetwork(ctx context.Context, in *NetworkChangeRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LeaveNetwork(ctx context.Context, in *NetworkChangeRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	//! Get information about the running Node
	NodeInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NodeInfoResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getconsensusstatus
	GetConsensusStatus(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*JsonResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getblockinfo
	GetBlockInfo(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getancestors
	GetAncestors(ctx context.Context, in *BlockHashAndAmount, opts ...grpc.CallOption) (*JsonResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getbranches
	GetBranches(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*JsonResponse, error)
	//! Get the blocks at the given height
	GetBlocksAtHeight(ctx context.Context, in *BlockHeight, opts ...grpc.CallOption) (*JsonResponse, error)
	//! Submit a local transaction
	SendTransaction(ctx context.Context, in *SendTransactionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	//! Start the baker in the consensus module
	StartBaker(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BoolResponse, error)
	//! Stop the baker in the consensus module
	StopBaker(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BoolResponse, error)
	GetAccountList(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetInstances(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetAccountInfo(ctx context.Context, in *GetAddressInfoRequest, opts ...grpc.CallOption) (*JsonResponse, error)
	GetInstanceInfo(ctx context.Context, in *GetAddressInfoRequest, opts ...grpc.CallOption) (*JsonResponse, error)
	GetRewardStatus(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetBirkParameters(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetModuleList(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetModuleSource(ctx context.Context, in *GetModuleSourceRequest, opts ...grpc.CallOption) (*BytesResponse, error)
	GetIdentityProviders(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetAnonymityRevokers(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetCryptographicParameters(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	GetBannedPeers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PeerListResponse, error)
	Shutdown(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BoolResponse, error)
	DumpStart(ctx context.Context, in *DumpRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	DumpStop(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BoolResponse, error)
	//! Query for the status of a transaction by its hash
	GetTransactionStatus(ctx context.Context, in *TransactionHash, opts ...grpc.CallOption) (*JsonResponse, error)
	//! Query for transactions in a block by its hash
	GetTransactionStatusInBlock(ctx context.Context, in *GetTransactionStatusInBlockRequest, opts ...grpc.CallOption) (*JsonResponse, error)
	//! Query for non-finalized transactions present on an account by the account address
	GetAccountNonFinalizedTransactions(ctx context.Context, in *AccountAddress, opts ...grpc.CallOption) (*JsonResponse, error)
	//! Request a summary for a block by its hash
	GetBlockSummary(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*JsonResponse, error)
	//! Request next nonce information for an account
	GetNextAccountNonce(ctx context.Context, in *AccountAddress, opts ...grpc.CallOption) (*JsonResponse, error)
}

P2PClient is the client API for P2P service.

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

func NewP2PClient

func NewP2PClient(cc grpc.ClientConnInterface) P2PClient

type P2PServer

type P2PServer interface {
	//! Suggest to a peer to connect to the submitted peer details.
	//! This, if successful, adds the peer to the list of given addresses.
	PeerConnect(context.Context, *PeerConnectRequest) (*BoolResponse, error)
	//! Disconnect from the peer and remove them from the given addresses list
	//! if they are on it. Return if the request was processed successfully.
	PeerDisconnect(context.Context, *PeerConnectRequest) (*BoolResponse, error)
	//! Peer uptime in milliseconds
	PeerUptime(context.Context, *Empty) (*NumberResponse, error)
	//! Peer total number of sent packets
	PeerTotalSent(context.Context, *Empty) (*NumberResponse, error)
	//! Peer total number of received packets
	PeerTotalReceived(context.Context, *Empty) (*NumberResponse, error)
	//! Peer client software version
	PeerVersion(context.Context, *Empty) (*StringResponse, error)
	//! Stats for connected peers
	PeerStats(context.Context, *PeersRequest) (*PeerStatsResponse, error)
	//! List of connected peers
	PeerList(context.Context, *PeersRequest) (*PeerListResponse, error)
	BanNode(context.Context, *PeerElement) (*BoolResponse, error)
	UnbanNode(context.Context, *PeerElement) (*BoolResponse, error)
	JoinNetwork(context.Context, *NetworkChangeRequest) (*BoolResponse, error)
	LeaveNetwork(context.Context, *NetworkChangeRequest) (*BoolResponse, error)
	//! Get information about the running Node
	NodeInfo(context.Context, *Empty) (*NodeInfoResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getconsensusstatus
	GetConsensusStatus(context.Context, *Empty) (*JsonResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getblockinfo
	GetBlockInfo(context.Context, *BlockHash) (*JsonResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getancestors
	GetAncestors(context.Context, *BlockHashAndAmount) (*JsonResponse, error)
	//! see https://gitlab.com/Concordium/notes-wiki/wikis/Consensus-queries#getbranches
	GetBranches(context.Context, *Empty) (*JsonResponse, error)
	//! Get the blocks at the given height
	GetBlocksAtHeight(context.Context, *BlockHeight) (*JsonResponse, error)
	//! Submit a local transaction
	SendTransaction(context.Context, *SendTransactionRequest) (*BoolResponse, error)
	//! Start the baker in the consensus module
	StartBaker(context.Context, *Empty) (*BoolResponse, error)
	//! Stop the baker in the consensus module
	StopBaker(context.Context, *Empty) (*BoolResponse, error)
	GetAccountList(context.Context, *BlockHash) (*JsonResponse, error)
	GetInstances(context.Context, *BlockHash) (*JsonResponse, error)
	GetAccountInfo(context.Context, *GetAddressInfoRequest) (*JsonResponse, error)
	GetInstanceInfo(context.Context, *GetAddressInfoRequest) (*JsonResponse, error)
	GetRewardStatus(context.Context, *BlockHash) (*JsonResponse, error)
	GetBirkParameters(context.Context, *BlockHash) (*JsonResponse, error)
	GetModuleList(context.Context, *BlockHash) (*JsonResponse, error)
	GetModuleSource(context.Context, *GetModuleSourceRequest) (*BytesResponse, error)
	GetIdentityProviders(context.Context, *BlockHash) (*JsonResponse, error)
	GetAnonymityRevokers(context.Context, *BlockHash) (*JsonResponse, error)
	GetCryptographicParameters(context.Context, *BlockHash) (*JsonResponse, error)
	GetBannedPeers(context.Context, *Empty) (*PeerListResponse, error)
	Shutdown(context.Context, *Empty) (*BoolResponse, error)
	DumpStart(context.Context, *DumpRequest) (*BoolResponse, error)
	DumpStop(context.Context, *Empty) (*BoolResponse, error)
	//! Query for the status of a transaction by its hash
	GetTransactionStatus(context.Context, *TransactionHash) (*JsonResponse, error)
	//! Query for transactions in a block by its hash
	GetTransactionStatusInBlock(context.Context, *GetTransactionStatusInBlockRequest) (*JsonResponse, error)
	//! Query for non-finalized transactions present on an account by the account address
	GetAccountNonFinalizedTransactions(context.Context, *AccountAddress) (*JsonResponse, error)
	//! Request a summary for a block by its hash
	GetBlockSummary(context.Context, *BlockHash) (*JsonResponse, error)
	//! Request next nonce information for an account
	GetNextAccountNonce(context.Context, *AccountAddress) (*JsonResponse, error)
}

P2PServer is the server API for P2P service.

type PeerConnectRequest

type PeerConnectRequest struct {
	Ip   *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port *wrapperspb.Int32Value  `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerConnectRequest) Descriptor deprecated

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

Deprecated: Use PeerConnectRequest.ProtoReflect.Descriptor instead.

func (*PeerConnectRequest) GetIp

func (*PeerConnectRequest) GetPort

func (*PeerConnectRequest) ProtoMessage

func (*PeerConnectRequest) ProtoMessage()

func (*PeerConnectRequest) ProtoReflect

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

func (*PeerConnectRequest) Reset

func (x *PeerConnectRequest) Reset()

func (*PeerConnectRequest) String

func (x *PeerConnectRequest) String() string

type PeerElement

type PeerElement struct {
	NodeId        *wrapperspb.StringValue   `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Port          *wrapperspb.UInt32Value   `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	Ip            *wrapperspb.StringValue   `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	CatchupStatus PeerElement_CatchupStatus `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PeerElement) Descriptor deprecated

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

Deprecated: Use PeerElement.ProtoReflect.Descriptor instead.

func (*PeerElement) GetCatchupStatus

func (x *PeerElement) GetCatchupStatus() PeerElement_CatchupStatus

func (*PeerElement) GetIp

func (x *PeerElement) GetIp() *wrapperspb.StringValue

func (*PeerElement) GetNodeId

func (x *PeerElement) GetNodeId() *wrapperspb.StringValue

func (*PeerElement) GetPort

func (x *PeerElement) GetPort() *wrapperspb.UInt32Value

func (*PeerElement) ProtoMessage

func (*PeerElement) ProtoMessage()

func (*PeerElement) ProtoReflect

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

func (*PeerElement) Reset

func (x *PeerElement) Reset()

func (*PeerElement) String

func (x *PeerElement) String() string

type PeerElement_CatchupStatus

type PeerElement_CatchupStatus int32
const (
	PeerElement_UPTODATE   PeerElement_CatchupStatus = 0
	PeerElement_PENDING    PeerElement_CatchupStatus = 1
	PeerElement_CATCHINGUP PeerElement_CatchupStatus = 2
)

func (PeerElement_CatchupStatus) Descriptor

func (PeerElement_CatchupStatus) Enum

func (PeerElement_CatchupStatus) EnumDescriptor deprecated

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

Deprecated: Use PeerElement_CatchupStatus.Descriptor instead.

func (PeerElement_CatchupStatus) Number

func (PeerElement_CatchupStatus) String

func (x PeerElement_CatchupStatus) String() string

func (PeerElement_CatchupStatus) Type

type PeerListResponse

type PeerListResponse struct {
	PeerType string         `protobuf:"bytes,1,opt,name=peer_type,json=peerType,proto3" json:"peer_type,omitempty"`
	Peers    []*PeerElement `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerListResponse) Descriptor deprecated

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

Deprecated: Use PeerListResponse.ProtoReflect.Descriptor instead.

func (*PeerListResponse) GetPeerType

func (x *PeerListResponse) GetPeerType() string

func (*PeerListResponse) GetPeers

func (x *PeerListResponse) GetPeers() []*PeerElement

func (*PeerListResponse) ProtoMessage

func (*PeerListResponse) ProtoMessage()

func (*PeerListResponse) ProtoReflect

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

func (*PeerListResponse) Reset

func (x *PeerListResponse) Reset()

func (*PeerListResponse) String

func (x *PeerListResponse) String() string

type PeerStatsResponse

type PeerStatsResponse struct {
	Peerstats []*PeerStatsResponse_PeerStats `protobuf:"bytes,1,rep,name=peerstats,proto3" json:"peerstats,omitempty"`
	AvgBpsIn  uint64                         `protobuf:"varint,2,opt,name=avg_bps_in,json=avgBpsIn,proto3" json:"avg_bps_in,omitempty"`
	AvgBpsOut uint64                         `protobuf:"varint,3,opt,name=avg_bps_out,json=avgBpsOut,proto3" json:"avg_bps_out,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerStatsResponse) Descriptor deprecated

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

Deprecated: Use PeerStatsResponse.ProtoReflect.Descriptor instead.

func (*PeerStatsResponse) GetAvgBpsIn

func (x *PeerStatsResponse) GetAvgBpsIn() uint64

func (*PeerStatsResponse) GetAvgBpsOut

func (x *PeerStatsResponse) GetAvgBpsOut() uint64

func (*PeerStatsResponse) GetPeerstats

func (x *PeerStatsResponse) GetPeerstats() []*PeerStatsResponse_PeerStats

func (*PeerStatsResponse) ProtoMessage

func (*PeerStatsResponse) ProtoMessage()

func (*PeerStatsResponse) ProtoReflect

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

func (*PeerStatsResponse) Reset

func (x *PeerStatsResponse) Reset()

func (*PeerStatsResponse) String

func (x *PeerStatsResponse) String() string

type PeerStatsResponse_PeerStats

type PeerStatsResponse_PeerStats struct {
	NodeId          string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	PacketsSent     uint64 `protobuf:"varint,2,opt,name=packets_sent,json=packetsSent,proto3" json:"packets_sent,omitempty"`
	PacketsReceived uint64 `protobuf:"varint,3,opt,name=packets_received,json=packetsReceived,proto3" json:"packets_received,omitempty"`
	Latency         uint64 `protobuf:"varint,4,opt,name=latency,proto3" json:"latency,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerStatsResponse_PeerStats) Descriptor deprecated

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

Deprecated: Use PeerStatsResponse_PeerStats.ProtoReflect.Descriptor instead.

func (*PeerStatsResponse_PeerStats) GetLatency

func (x *PeerStatsResponse_PeerStats) GetLatency() uint64

func (*PeerStatsResponse_PeerStats) GetNodeId

func (x *PeerStatsResponse_PeerStats) GetNodeId() string

func (*PeerStatsResponse_PeerStats) GetPacketsReceived

func (x *PeerStatsResponse_PeerStats) GetPacketsReceived() uint64

func (*PeerStatsResponse_PeerStats) GetPacketsSent

func (x *PeerStatsResponse_PeerStats) GetPacketsSent() uint64

func (*PeerStatsResponse_PeerStats) ProtoMessage

func (*PeerStatsResponse_PeerStats) ProtoMessage()

func (*PeerStatsResponse_PeerStats) ProtoReflect

func (*PeerStatsResponse_PeerStats) Reset

func (x *PeerStatsResponse_PeerStats) Reset()

func (*PeerStatsResponse_PeerStats) String

func (x *PeerStatsResponse_PeerStats) String() string

type PeersRequest

type PeersRequest struct {
	IncludeBootstrappers bool `protobuf:"varint,1,opt,name=include_bootstrappers,json=includeBootstrappers,proto3" json:"include_bootstrappers,omitempty"`
	// contains filtered or unexported fields
}

func (*PeersRequest) Descriptor deprecated

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

Deprecated: Use PeersRequest.ProtoReflect.Descriptor instead.

func (*PeersRequest) GetIncludeBootstrappers

func (x *PeersRequest) GetIncludeBootstrappers() bool

func (*PeersRequest) ProtoMessage

func (*PeersRequest) ProtoMessage()

func (*PeersRequest) ProtoReflect

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

func (*PeersRequest) Reset

func (x *PeersRequest) Reset()

func (*PeersRequest) String

func (x *PeersRequest) String() string

type SendTransactionRequest

type SendTransactionRequest struct {
	NetworkId uint32 `protobuf:"varint,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	Payload   []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*SendTransactionRequest) Descriptor deprecated

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

Deprecated: Use SendTransactionRequest.ProtoReflect.Descriptor instead.

func (*SendTransactionRequest) GetNetworkId

func (x *SendTransactionRequest) GetNetworkId() uint32

func (*SendTransactionRequest) GetPayload

func (x *SendTransactionRequest) GetPayload() []byte

func (*SendTransactionRequest) ProtoMessage

func (*SendTransactionRequest) ProtoMessage()

func (*SendTransactionRequest) ProtoReflect

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

func (*SendTransactionRequest) Reset

func (x *SendTransactionRequest) Reset()

func (*SendTransactionRequest) String

func (x *SendTransactionRequest) String() string

type StringResponse

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

func (*StringResponse) Descriptor deprecated

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

Deprecated: Use StringResponse.ProtoReflect.Descriptor instead.

func (*StringResponse) GetValue

func (x *StringResponse) GetValue() string

func (*StringResponse) ProtoMessage

func (*StringResponse) ProtoMessage()

func (*StringResponse) ProtoReflect

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

func (*StringResponse) Reset

func (x *StringResponse) Reset()

func (*StringResponse) String

func (x *StringResponse) String() string

type TransactionHash

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

func (*TransactionHash) Descriptor deprecated

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

Deprecated: Use TransactionHash.ProtoReflect.Descriptor instead.

func (*TransactionHash) GetTransactionHash

func (x *TransactionHash) GetTransactionHash() string

func (*TransactionHash) ProtoMessage

func (*TransactionHash) ProtoMessage()

func (*TransactionHash) ProtoReflect

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

func (*TransactionHash) Reset

func (x *TransactionHash) Reset()

func (*TransactionHash) String

func (x *TransactionHash) String() string

type UnimplementedP2PServer

type UnimplementedP2PServer struct {
}

UnimplementedP2PServer can be embedded to have forward compatible implementations.

func (*UnimplementedP2PServer) BanNode

func (*UnimplementedP2PServer) DumpStart

func (*UnimplementedP2PServer) DumpStop

func (*UnimplementedP2PServer) GetAccountInfo

func (*UnimplementedP2PServer) GetAccountList

func (*UnimplementedP2PServer) GetAccountNonFinalizedTransactions

func (*UnimplementedP2PServer) GetAccountNonFinalizedTransactions(context.Context, *AccountAddress) (*JsonResponse, error)

func (*UnimplementedP2PServer) GetAncestors

func (*UnimplementedP2PServer) GetAnonymityRevokers

func (*UnimplementedP2PServer) GetAnonymityRevokers(context.Context, *BlockHash) (*JsonResponse, error)

func (*UnimplementedP2PServer) GetBannedPeers

func (*UnimplementedP2PServer) GetBirkParameters

func (*UnimplementedP2PServer) GetBlockInfo

func (*UnimplementedP2PServer) GetBlockSummary

func (*UnimplementedP2PServer) GetBlocksAtHeight

func (*UnimplementedP2PServer) GetBranches

func (*UnimplementedP2PServer) GetConsensusStatus

func (*UnimplementedP2PServer) GetConsensusStatus(context.Context, *Empty) (*JsonResponse, error)

func (*UnimplementedP2PServer) GetCryptographicParameters

func (*UnimplementedP2PServer) GetCryptographicParameters(context.Context, *BlockHash) (*JsonResponse, error)

func (*UnimplementedP2PServer) GetIdentityProviders

func (*UnimplementedP2PServer) GetIdentityProviders(context.Context, *BlockHash) (*JsonResponse, error)

func (*UnimplementedP2PServer) GetInstanceInfo

func (*UnimplementedP2PServer) GetInstances

func (*UnimplementedP2PServer) GetModuleList

func (*UnimplementedP2PServer) GetModuleSource

func (*UnimplementedP2PServer) GetNextAccountNonce

func (*UnimplementedP2PServer) GetRewardStatus

func (*UnimplementedP2PServer) GetTransactionStatus

func (*UnimplementedP2PServer) GetTransactionStatusInBlock

func (*UnimplementedP2PServer) JoinNetwork

func (*UnimplementedP2PServer) LeaveNetwork

func (*UnimplementedP2PServer) NodeInfo

func (*UnimplementedP2PServer) PeerConnect

func (*UnimplementedP2PServer) PeerDisconnect

func (*UnimplementedP2PServer) PeerList

func (*UnimplementedP2PServer) PeerStats

func (*UnimplementedP2PServer) PeerTotalReceived

func (*UnimplementedP2PServer) PeerTotalReceived(context.Context, *Empty) (*NumberResponse, error)

func (*UnimplementedP2PServer) PeerTotalSent

func (*UnimplementedP2PServer) PeerUptime

func (*UnimplementedP2PServer) PeerVersion

func (*UnimplementedP2PServer) SendTransaction

func (*UnimplementedP2PServer) Shutdown

func (*UnimplementedP2PServer) StartBaker

func (*UnimplementedP2PServer) StopBaker

func (*UnimplementedP2PServer) UnbanNode

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL