Versions in this module Expand all Collapse all v0 v0.0.2 Dec 21, 2022 v0.0.1 Dec 21, 2022 Changes in this version + var File_system_proto protoreflect.FileDescriptor + var System_ServiceDesc = grpc.ServiceDesc + func RegisterSystemServer(s grpc.ServiceRegistrar, srv SystemServer) + type BlockByNumberRequest struct + Number uint64 + func (*BlockByNumberRequest) Descriptor() ([]byte, []int) + func (*BlockByNumberRequest) ProtoMessage() + func (x *BlockByNumberRequest) GetNumber() uint64 + func (x *BlockByNumberRequest) ProtoReflect() protoreflect.Message + func (x *BlockByNumberRequest) Reset() + func (x *BlockByNumberRequest) String() string + type BlockResponse struct + Data []byte + func (*BlockResponse) Descriptor() ([]byte, []int) + func (*BlockResponse) ProtoMessage() + func (x *BlockResponse) GetData() []byte + func (x *BlockResponse) ProtoReflect() protoreflect.Message + func (x *BlockResponse) Reset() + func (x *BlockResponse) String() string + type BlockchainEvent struct + Added []*BlockchainEvent_Header + Removed []*BlockchainEvent_Header + func (*BlockchainEvent) Descriptor() ([]byte, []int) + func (*BlockchainEvent) ProtoMessage() + func (x *BlockchainEvent) GetAdded() []*BlockchainEvent_Header + func (x *BlockchainEvent) GetRemoved() []*BlockchainEvent_Header + func (x *BlockchainEvent) ProtoReflect() protoreflect.Message + func (x *BlockchainEvent) Reset() + func (x *BlockchainEvent) String() string + type BlockchainEvent_Header struct + Hash string + Number int64 + func (*BlockchainEvent_Header) Descriptor() ([]byte, []int) + func (*BlockchainEvent_Header) ProtoMessage() + func (x *BlockchainEvent_Header) GetHash() string + func (x *BlockchainEvent_Header) GetNumber() int64 + func (x *BlockchainEvent_Header) ProtoReflect() protoreflect.Message + func (x *BlockchainEvent_Header) Reset() + func (x *BlockchainEvent_Header) String() string + type ExportEvent struct + Data []byte + From uint64 + Latest uint64 + To uint64 + func (*ExportEvent) Descriptor() ([]byte, []int) + func (*ExportEvent) ProtoMessage() + func (x *ExportEvent) GetData() []byte + func (x *ExportEvent) GetFrom() uint64 + func (x *ExportEvent) GetLatest() uint64 + func (x *ExportEvent) GetTo() uint64 + func (x *ExportEvent) ProtoReflect() protoreflect.Message + func (x *ExportEvent) Reset() + func (x *ExportEvent) String() string + type ExportRequest struct + From uint64 + To uint64 + func (*ExportRequest) Descriptor() ([]byte, []int) + func (*ExportRequest) ProtoMessage() + func (x *ExportRequest) GetFrom() uint64 + func (x *ExportRequest) GetTo() uint64 + func (x *ExportRequest) ProtoReflect() protoreflect.Message + func (x *ExportRequest) Reset() + func (x *ExportRequest) String() string + type Peer struct + Addrs []string + Id string + Protocols []string + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (x *Peer) GetAddrs() []string + func (x *Peer) GetId() string + func (x *Peer) GetProtocols() []string + func (x *Peer) ProtoReflect() protoreflect.Message + func (x *Peer) Reset() + func (x *Peer) String() string + type PeersAddRequest struct + Id string + func (*PeersAddRequest) Descriptor() ([]byte, []int) + func (*PeersAddRequest) ProtoMessage() + func (x *PeersAddRequest) GetId() string + func (x *PeersAddRequest) ProtoReflect() protoreflect.Message + func (x *PeersAddRequest) Reset() + func (x *PeersAddRequest) String() string + type PeersAddResponse struct + Message string + func (*PeersAddResponse) Descriptor() ([]byte, []int) + func (*PeersAddResponse) ProtoMessage() + func (x *PeersAddResponse) GetMessage() string + func (x *PeersAddResponse) ProtoReflect() protoreflect.Message + func (x *PeersAddResponse) Reset() + func (x *PeersAddResponse) String() string + type PeersListResponse struct + Peers []*Peer + func (*PeersListResponse) Descriptor() ([]byte, []int) + func (*PeersListResponse) ProtoMessage() + func (x *PeersListResponse) GetPeers() []*Peer + func (x *PeersListResponse) ProtoReflect() protoreflect.Message + func (x *PeersListResponse) Reset() + func (x *PeersListResponse) String() string + type PeersStatusRequest struct + Id string + func (*PeersStatusRequest) Descriptor() ([]byte, []int) + func (*PeersStatusRequest) ProtoMessage() + func (x *PeersStatusRequest) GetId() string + func (x *PeersStatusRequest) ProtoReflect() protoreflect.Message + func (x *PeersStatusRequest) Reset() + func (x *PeersStatusRequest) String() string + type ServerStatus struct + Current *ServerStatus_Block + Genesis string + Network int64 + P2PAddr string + func (*ServerStatus) Descriptor() ([]byte, []int) + func (*ServerStatus) ProtoMessage() + func (x *ServerStatus) GetCurrent() *ServerStatus_Block + func (x *ServerStatus) GetGenesis() string + func (x *ServerStatus) GetNetwork() int64 + func (x *ServerStatus) GetP2PAddr() string + func (x *ServerStatus) ProtoReflect() protoreflect.Message + func (x *ServerStatus) Reset() + func (x *ServerStatus) String() string + type ServerStatus_Block struct + Hash string + Number int64 + func (*ServerStatus_Block) Descriptor() ([]byte, []int) + func (*ServerStatus_Block) ProtoMessage() + func (x *ServerStatus_Block) GetHash() string + func (x *ServerStatus_Block) GetNumber() int64 + func (x *ServerStatus_Block) ProtoReflect() protoreflect.Message + func (x *ServerStatus_Block) Reset() + func (x *ServerStatus_Block) String() string + type SystemClient interface + BlockByNumber func(ctx context.Context, in *BlockByNumberRequest, opts ...grpc.CallOption) (*BlockResponse, error) + Export func(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (System_ExportClient, error) + GetStatus func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServerStatus, error) + PeersAdd func(ctx context.Context, in *PeersAddRequest, opts ...grpc.CallOption) (*PeersAddResponse, error) + PeersList func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersListResponse, error) + PeersStatus func(ctx context.Context, in *PeersStatusRequest, opts ...grpc.CallOption) (*Peer, error) + Subscribe func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (System_SubscribeClient, error) + func NewSystemClient(cc grpc.ClientConnInterface) SystemClient + type SystemServer interface + BlockByNumber func(context.Context, *BlockByNumberRequest) (*BlockResponse, error) + Export func(*ExportRequest, System_ExportServer) error + GetStatus func(context.Context, *emptypb.Empty) (*ServerStatus, error) + PeersAdd func(context.Context, *PeersAddRequest) (*PeersAddResponse, error) + PeersList func(context.Context, *emptypb.Empty) (*PeersListResponse, error) + PeersStatus func(context.Context, *PeersStatusRequest) (*Peer, error) + Subscribe func(*emptypb.Empty, System_SubscribeServer) error + type System_ExportClient interface + Recv func() (*ExportEvent, error) + type System_ExportServer interface + Send func(*ExportEvent) error + type System_SubscribeClient interface + Recv func() (*BlockchainEvent, error) + type System_SubscribeServer interface + Send func(*BlockchainEvent) error + type UnimplementedSystemServer struct + func (UnimplementedSystemServer) BlockByNumber(context.Context, *BlockByNumberRequest) (*BlockResponse, error) + func (UnimplementedSystemServer) Export(*ExportRequest, System_ExportServer) error + func (UnimplementedSystemServer) GetStatus(context.Context, *emptypb.Empty) (*ServerStatus, error) + func (UnimplementedSystemServer) PeersAdd(context.Context, *PeersAddRequest) (*PeersAddResponse, error) + func (UnimplementedSystemServer) PeersList(context.Context, *emptypb.Empty) (*PeersListResponse, error) + func (UnimplementedSystemServer) PeersStatus(context.Context, *PeersStatusRequest) (*Peer, error) + func (UnimplementedSystemServer) Subscribe(*emptypb.Empty, System_SubscribeServer) error + type UnsafeSystemServer interface