mirror

Oct 29, 2024

Changes in this version

+ var File_mirror_consensus_service_proto protoreflect.FileDescriptor

+ var File_mirror_mirror_network_service_proto protoreflect.FileDescriptor

+ var NetworkService_ServiceDesc = grpc.ServiceDesc

+ func RegisterNetworkServiceServer(s grpc.ServiceRegistrar, srv NetworkServiceServer)

+ type AddressBookQuery struct

+ FileId *services.FileID

+ Limit int32

+ func (*AddressBookQuery) Descriptor() ([]byte, []int)

+ func (*AddressBookQuery) ProtoMessage()

+ func (x *AddressBookQuery) GetFileId() *services.FileID

+ func (x *AddressBookQuery) GetLimit() int32

+ func (x *AddressBookQuery) ProtoReflect() protoreflect.Message

+ func (x *AddressBookQuery) Reset()

+ func (x *AddressBookQuery) String() string

+ type NetworkServiceClient interface

+ GetNodes func(ctx context.Context, in *AddressBookQuery, opts ...grpc.CallOption) (NetworkService_GetNodesClient, error)

+ func NewNetworkServiceClient(cc grpc.ClientConnInterface) NetworkServiceClient

+ type NetworkServiceServer interface

+ GetNodes func(*AddressBookQuery, NetworkService_GetNodesServer) error

+ type NetworkService_GetNodesClient interface

+ Recv func() (*services.NodeAddress, error)

+ type NetworkService_GetNodesServer interface

+ Send func(*services.NodeAddress) error

+ type UnimplementedNetworkServiceServer struct

+ func (UnimplementedNetworkServiceServer) GetNodes(*AddressBookQuery, NetworkService_GetNodesServer) error

+ type UnsafeNetworkServiceServer interface

Sep 2, 2021

Changes in this version

+ var File_proto_mirror_consensus_service_proto protoreflect.FileDescriptor

Jul 22, 2021

Changes in this version

+ var ConsensusService_ServiceDesc = grpc.ServiceDesc

+ type UnsafeConsensusServiceServer interface

Nov 30, 2020

Changes in this version

+ var File_proto_mirror_ConsensusService_proto protoreflect.FileDescriptor

+ func RegisterConsensusServiceServer(s *grpc.Server, srv ConsensusServiceServer)

+ type ConsensusServiceClient interface

+ SubscribeTopic func(ctx context.Context, in *ConsensusTopicQuery, opts ...grpc.CallOption) (ConsensusService_SubscribeTopicClient, error)

+ func NewConsensusServiceClient(cc grpc.ClientConnInterface) ConsensusServiceClient

+ type ConsensusServiceServer interface

+ SubscribeTopic func(*ConsensusTopicQuery, ConsensusService_SubscribeTopicServer) error

+ type ConsensusService_SubscribeTopicClient interface

+ Recv func() (*ConsensusTopicResponse, error)

+ type ConsensusService_SubscribeTopicServer interface

+ Send func(*ConsensusTopicResponse) error

+ type ConsensusTopicQuery struct

+ ConsensusEndTime *proto1.Timestamp

+ ConsensusStartTime *proto1.Timestamp

+ Limit uint64

+ TopicID *proto1.TopicID

+ func (*ConsensusTopicQuery) Descriptor() ([]byte, []int)

+ func (*ConsensusTopicQuery) ProtoMessage()

+ func (x *ConsensusTopicQuery) GetConsensusEndTime() *proto1.Timestamp

+ func (x *ConsensusTopicQuery) GetConsensusStartTime() *proto1.Timestamp

+ func (x *ConsensusTopicQuery) GetLimit() uint64

+ func (x *ConsensusTopicQuery) GetTopicID() *proto1.TopicID

+ func (x *ConsensusTopicQuery) ProtoReflect() protoreflect.Message

+ func (x *ConsensusTopicQuery) Reset()

+ func (x *ConsensusTopicQuery) String() string

+ type ConsensusTopicResponse struct

+ ChunkInfo *proto1.ConsensusMessageChunkInfo

+ ConsensusTimestamp *proto1.Timestamp

+ Message []byte

+ RunningHash []byte

+ RunningHashVersion uint64

+ SequenceNumber uint64

+ func (*ConsensusTopicResponse) Descriptor() ([]byte, []int)

+ func (*ConsensusTopicResponse) ProtoMessage()

+ func (x *ConsensusTopicResponse) GetChunkInfo() *proto1.ConsensusMessageChunkInfo

+ func (x *ConsensusTopicResponse) GetConsensusTimestamp() *proto1.Timestamp

+ func (x *ConsensusTopicResponse) GetMessage() []byte

+ func (x *ConsensusTopicResponse) GetRunningHash() []byte

+ func (x *ConsensusTopicResponse) GetRunningHashVersion() uint64

+ func (x *ConsensusTopicResponse) GetSequenceNumber() uint64

+ func (x *ConsensusTopicResponse) ProtoReflect() protoreflect.Message

+ func (x *ConsensusTopicResponse) Reset()

+ func (x *ConsensusTopicResponse) String() string

+ type UnimplementedConsensusServiceServer struct

+ func (*UnimplementedConsensusServiceServer) SubscribeTopic(*ConsensusTopicQuery, ConsensusService_SubscribeTopicServer) error