__

package
v0.0.0-...-88bd931 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2021 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_node_proto protoreflect.FileDescriptor
View Source 
var NodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.NodeService",
	HandlerType: (*NodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNodeStatus",
			Handler:    _NodeService_GetNodeStatus_Handler,
		},
		{
			MethodName: "AddTransaction",
			Handler:    _NodeService_AddTransaction_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _NodeService_Publish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListBlocks",
			Handler:       _NodeService_ListBlocks_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _NodeService_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/node.proto",
}

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

Functions

func RegisterNodeServiceServer 

func RegisterNodeServiceServer(s grpc.ServiceRegistrar, srv NodeServiceServer)

Types

type AddPendingTransactionRequest 

type AddPendingTransactionRequest struct {
	Label    string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*AddPendingTransactionRequest) Descriptor deprecated 

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

Deprecated: Use AddPendingTransactionRequest.ProtoReflect.Descriptor instead.

func (*AddPendingTransactionRequest) GetLabel 

func (x *AddPendingTransactionRequest) GetLabel() string

func (*AddPendingTransactionRequest) GetPassword 

func (x *AddPendingTransactionRequest) GetPassword() string

func (*AddPendingTransactionRequest) ProtoMessage 

func (*AddPendingTransactionRequest) ProtoMessage()

func (*AddPendingTransactionRequest) ProtoReflect 

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

func (*AddPendingTransactionRequest) Reset 

func (x *AddPendingTransactionRequest) Reset()

func (*AddPendingTransactionRequest) String 

func (x *AddPendingTransactionRequest) String() string

type AddPendingTransactionResponse 

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

func (*AddPendingTransactionResponse) Descriptor deprecated 

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

Deprecated: Use AddPendingTransactionResponse.ProtoReflect.Descriptor instead.

func (*AddPendingTransactionResponse) ProtoMessage 

func (*AddPendingTransactionResponse) ProtoMessage()

func (*AddPendingTransactionResponse) ProtoReflect 

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

func (*AddPendingTransactionResponse) Reset 

func (x *AddPendingTransactionResponse) Reset()

func (*AddPendingTransactionResponse) String 

func (x *AddPendingTransactionResponse) String() string

type BlockHeaderMessage 

type BlockHeaderMessage struct {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Time   uint64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Number uint64 `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"`
	Nonce  uint32 `protobuf:"varint,4,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Miner  string `protobuf:"bytes,5,opt,name=miner,proto3" json:"miner,omitempty"`
	Pow    int32  `protobuf:"varint,6,opt,name=pow,proto3" json:"pow,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockHeaderMessage) Descriptor deprecated 

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

Deprecated: Use BlockHeaderMessage.ProtoReflect.Descriptor instead.

func (*BlockHeaderMessage) GetMiner 

func (x *BlockHeaderMessage) GetMiner() string

func (*BlockHeaderMessage) GetNonce 

func (x *BlockHeaderMessage) GetNonce() uint32

func (*BlockHeaderMessage) GetNumber 

func (x *BlockHeaderMessage) GetNumber() uint64

func (*BlockHeaderMessage) GetParent 

func (x *BlockHeaderMessage) GetParent() string

func (*BlockHeaderMessage) GetPow 

func (x *BlockHeaderMessage) GetPow() int32

func (*BlockHeaderMessage) GetTime 

func (x *BlockHeaderMessage) GetTime() uint64

func (*BlockHeaderMessage) ProtoMessage 

func (*BlockHeaderMessage) ProtoMessage()

func (*BlockHeaderMessage) ProtoReflect 

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

func (*BlockHeaderMessage) Reset 

func (x *BlockHeaderMessage) Reset()

func (*BlockHeaderMessage) String 

func (x *BlockHeaderMessage) String() string

type BlockResponse 

type BlockResponse struct {
	BlockHeader *BlockHeaderMessage   `protobuf:"bytes,1,opt,name=blockHeader,proto3" json:"blockHeader,omitempty"`
	Txs         []*TransactionMessage `protobuf:"bytes,2,rep,name=txs,proto3" json:"txs,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockResponse) Descriptor deprecated 

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

Deprecated: Use BlockResponse.ProtoReflect.Descriptor instead.

func (*BlockResponse) GetBlockHeader 

func (x *BlockResponse) GetBlockHeader() *BlockHeaderMessage

func (*BlockResponse) GetTxs 

func (x *BlockResponse) GetTxs() []*TransactionMessage

func (*BlockResponse) ProtoMessage 

func (*BlockResponse) ProtoMessage()

func (*BlockResponse) ProtoReflect 

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

func (*BlockResponse) Reset 

func (x *BlockResponse) Reset()

func (*BlockResponse) String 

func (x *BlockResponse) String() string

type ChannelData 

type ChannelData struct {
	Data  string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	From  string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelData) Descriptor deprecated 

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

Deprecated: Use ChannelData.ProtoReflect.Descriptor instead.

func (*ChannelData) GetData 

func (x *ChannelData) GetData() string

func (*ChannelData) GetFrom 

func (x *ChannelData) GetFrom() string

func (*ChannelData) GetTopic 

func (x *ChannelData) GetTopic() string

func (*ChannelData) ProtoMessage 

func (*ChannelData) ProtoMessage()

func (*ChannelData) ProtoReflect 

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

func (*ChannelData) Reset 

func (x *ChannelData) Reset()

func (*ChannelData) String 

func (x *ChannelData) String() string

type JoinChannelRequest 

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

func (*JoinChannelRequest) Descriptor deprecated 

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

Deprecated: Use JoinChannelRequest.ProtoReflect.Descriptor instead.

func (*JoinChannelRequest) GetTxHash 

func (x *JoinChannelRequest) GetTxHash() string

func (*JoinChannelRequest) ProtoMessage 

func (*JoinChannelRequest) ProtoMessage()

func (*JoinChannelRequest) ProtoReflect 

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

func (*JoinChannelRequest) Reset 

func (x *JoinChannelRequest) Reset()

func (*JoinChannelRequest) String 

func (x *JoinChannelRequest) String() string

type ListBlocksRequest 

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

func (*ListBlocksRequest) Descriptor deprecated 

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

Deprecated: Use ListBlocksRequest.ProtoReflect.Descriptor instead.

func (*ListBlocksRequest) GetFromBlock 

func (x *ListBlocksRequest) GetFromBlock() string

func (*ListBlocksRequest) ProtoMessage 

func (*ListBlocksRequest) ProtoMessage()

func (*ListBlocksRequest) ProtoReflect 

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

func (*ListBlocksRequest) Reset 

func (x *ListBlocksRequest) Reset()

func (*ListBlocksRequest) String 

func (x *ListBlocksRequest) String() string

type ListKnownPeersRequest 

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

func (*ListKnownPeersRequest) Descriptor deprecated 

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

Deprecated: Use ListKnownPeersRequest.ProtoReflect.Descriptor instead.

func (*ListKnownPeersRequest) ProtoMessage 

func (*ListKnownPeersRequest) ProtoMessage()

func (*ListKnownPeersRequest) ProtoReflect 

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

func (*ListKnownPeersRequest) Reset 

func (x *ListKnownPeersRequest) Reset()

func (*ListKnownPeersRequest) String 

func (x *ListKnownPeersRequest) String() string

type ListKnownPeersResponse 

type ListKnownPeersResponse struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ip          string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port        uint64 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	IsBootstrap bool   `protobuf:"varint,4,opt,name=isBootstrap,proto3" json:"isBootstrap,omitempty"`
	Address     string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKnownPeersResponse) Descriptor deprecated 

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

Deprecated: Use ListKnownPeersResponse.ProtoReflect.Descriptor instead.

func (*ListKnownPeersResponse) GetAddress 

func (x *ListKnownPeersResponse) GetAddress() string

func (*ListKnownPeersResponse) GetIp 

func (x *ListKnownPeersResponse) GetIp() string

func (*ListKnownPeersResponse) GetIsBootstrap 

func (x *ListKnownPeersResponse) GetIsBootstrap() bool

func (*ListKnownPeersResponse) GetName 

func (x *ListKnownPeersResponse) GetName() string

func (*ListKnownPeersResponse) GetPort 

func (x *ListKnownPeersResponse) GetPort() uint64

func (*ListKnownPeersResponse) ProtoMessage 

func (*ListKnownPeersResponse) ProtoMessage()

func (*ListKnownPeersResponse) ProtoReflect 

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

func (*ListKnownPeersResponse) Reset 

func (x *ListKnownPeersResponse) Reset()

func (*ListKnownPeersResponse) String 

func (x *ListKnownPeersResponse) String() string

type ListPendingTransactionsRequest 

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

func (*ListPendingTransactionsRequest) Descriptor deprecated 

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

Deprecated: Use ListPendingTransactionsRequest.ProtoReflect.Descriptor instead.

func (*ListPendingTransactionsRequest) ProtoMessage 

func (*ListPendingTransactionsRequest) ProtoMessage()

func (*ListPendingTransactionsRequest) ProtoReflect 

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

func (*ListPendingTransactionsRequest) Reset 

func (x *ListPendingTransactionsRequest) Reset()

func (*ListPendingTransactionsRequest) String 

func (x *ListPendingTransactionsRequest) String() string

type NodeInfoRequest 

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

func (*NodeInfoRequest) Descriptor deprecated 

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

Deprecated: Use NodeInfoRequest.ProtoReflect.Descriptor instead.

func (*NodeInfoRequest) ProtoMessage 

func (*NodeInfoRequest) ProtoMessage()

func (*NodeInfoRequest) ProtoReflect 

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

func (*NodeInfoRequest) Reset 

func (x *NodeInfoRequest) Reset()

func (*NodeInfoRequest) String 

func (x *NodeInfoRequest) String() string

type NodeInfoResponse 

type NodeInfoResponse struct {
	Address       string   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Balance       float32  `protobuf:"fixed32,2,opt,name=balance,proto3" json:"balance,omitempty"`
	Subscriptions []string `protobuf:"bytes,3,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	Channels      []string `protobuf:"bytes,4,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfoResponse) Descriptor deprecated 

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

Deprecated: Use NodeInfoResponse.ProtoReflect.Descriptor instead.

func (*NodeInfoResponse) GetAddress 

func (x *NodeInfoResponse) GetAddress() string

func (*NodeInfoResponse) GetBalance 

func (x *NodeInfoResponse) GetBalance() float32

func (*NodeInfoResponse) GetChannels 

func (x *NodeInfoResponse) GetChannels() []string

func (*NodeInfoResponse) GetSubscriptions 

func (x *NodeInfoResponse) GetSubscriptions() []string

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 NodeServiceClient 

type NodeServiceClient interface {
	// Obtains a node's name
	GetNodeStatus(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfoResponse, error)
	// // read/write to known peers
	// rpc ListKnownPeers(ListKnownPeersRequest) returns (stream ListKnownPeersResponse) {}
	// // read/write blocks
	ListBlocks(ctx context.Context, in *ListBlocksRequest, opts ...grpc.CallOption) (NodeService_ListBlocksClient, error)
	// add pending transaction
	AddTransaction(ctx context.Context, in *AddPendingTransactionRequest, opts ...grpc.CallOption) (*AddPendingTransactionResponse, error)
	Subscribe(ctx context.Context, in *JoinChannelRequest, opts ...grpc.CallOption) (NodeService_SubscribeClient, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
}

NodeServiceClient is the client API for NodeService 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 NewNodeServiceClient 

func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient

type NodeServiceServer 

type NodeServiceServer interface {
	// Obtains a node's name
	GetNodeStatus(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)
	// // read/write to known peers
	// rpc ListKnownPeers(ListKnownPeersRequest) returns (stream ListKnownPeersResponse) {}
	// // read/write blocks
	ListBlocks(*ListBlocksRequest, NodeService_ListBlocksServer) error
	// add pending transaction
	AddTransaction(context.Context, *AddPendingTransactionRequest) (*AddPendingTransactionResponse, error)
	Subscribe(*JoinChannelRequest, NodeService_SubscribeServer) error
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	// contains filtered or unexported methods
}

NodeServiceServer is the server API for NodeService service. All implementations must embed UnimplementedNodeServiceServer for forward compatibility

type NodeService_ListBlocksClient 

type NodeService_ListBlocksClient interface {
	Recv() (*BlockResponse, error)
	grpc.ClientStream
}

type NodeService_ListBlocksServer 

type NodeService_ListBlocksServer interface {
	Send(*BlockResponse) error
	grpc.ServerStream
}

type NodeService_SubscribeClient 

type NodeService_SubscribeClient interface {
	Recv() (*ChannelData, error)
	grpc.ClientStream
}

type NodeService_SubscribeServer 

type NodeService_SubscribeServer interface {
	Send(*ChannelData) error
	grpc.ServerStream
}

type PendingTransactionResponse 

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

func (*PendingTransactionResponse) Descriptor deprecated 

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

Deprecated: Use PendingTransactionResponse.ProtoReflect.Descriptor instead.

func (*PendingTransactionResponse) GetSignedTx 

func (x *PendingTransactionResponse) GetSignedTx() []byte

func (*PendingTransactionResponse) ProtoMessage 

func (*PendingTransactionResponse) ProtoMessage()

func (*PendingTransactionResponse) ProtoReflect 

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

func (*PendingTransactionResponse) Reset 

func (x *PendingTransactionResponse) Reset()

func (*PendingTransactionResponse) String 

func (x *PendingTransactionResponse) String() string

type PublishRequest 

type PublishRequest struct {
	TxHash  string `protobuf:"bytes,1,opt,name=txHash,proto3" json:"txHash,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetMessage 

func (x *PublishRequest) GetMessage() string

func (*PublishRequest) GetTxHash 

func (x *PublishRequest) GetTxHash() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishResponse 

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

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetMessage 

func (x *PublishResponse) GetMessage() string

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

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

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type TransactionMessage 

type TransactionMessage struct {
	Author    string `protobuf:"bytes,1,opt,name=author,proto3" json:"author,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Nonce     string `protobuf:"bytes,4,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Time      string `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	Signature string `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
	Hash      string `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionMessage) Descriptor deprecated 

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

Deprecated: Use TransactionMessage.ProtoReflect.Descriptor instead.

func (*TransactionMessage) GetAuthor 

func (x *TransactionMessage) GetAuthor() string

func (*TransactionMessage) GetHash 

func (x *TransactionMessage) GetHash() string

func (*TransactionMessage) GetNonce 

func (x *TransactionMessage) GetNonce() string

func (*TransactionMessage) GetSignature 

func (x *TransactionMessage) GetSignature() string

func (*TransactionMessage) GetTime 

func (x *TransactionMessage) GetTime() string

func (*TransactionMessage) GetTopic 

func (x *TransactionMessage) GetTopic() string

func (*TransactionMessage) ProtoMessage 

func (*TransactionMessage) ProtoMessage()

func (*TransactionMessage) ProtoReflect 

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

func (*TransactionMessage) Reset 

func (x *TransactionMessage) Reset()

func (*TransactionMessage) String 

func (x *TransactionMessage) String() string

type UnimplementedNodeServiceServer 

type UnimplementedNodeServiceServer struct {
}

UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServiceServer) AddTransaction 

func (UnimplementedNodeServiceServer) AddTransaction(context.Context, *AddPendingTransactionRequest) (*AddPendingTransactionResponse, error)

func (UnimplementedNodeServiceServer) GetNodeStatus 

func (UnimplementedNodeServiceServer) GetNodeStatus(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)

func (UnimplementedNodeServiceServer) ListBlocks 

func (UnimplementedNodeServiceServer) ListBlocks(*ListBlocksRequest, NodeService_ListBlocksServer) error

func (UnimplementedNodeServiceServer) Publish 

func (UnimplementedNodeServiceServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

func (UnimplementedNodeServiceServer) Subscribe 

func (UnimplementedNodeServiceServer) Subscribe(*JoinChannelRequest, NodeService_SubscribeServer) error

type UnsafeNodeServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.