Versions in this module Expand all Collapse all v0 v0.2.0 Jul 9, 2021 v0.1.0 Jul 8, 2021 Changes in this version + var ConsensusService_ServiceDesc = grpc.ServiceDesc + var File_ConsensusService_proto protoreflect.FileDescriptor + func RegisterConsensusServiceServer(s grpc.ServiceRegistrar, 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 *services.Timestamp + ConsensusStartTime *services.Timestamp + Limit uint64 + TopicID *services.TopicID + func (*ConsensusTopicQuery) Descriptor() ([]byte, []int) + func (*ConsensusTopicQuery) ProtoMessage() + func (x *ConsensusTopicQuery) GetConsensusEndTime() *services.Timestamp + func (x *ConsensusTopicQuery) GetConsensusStartTime() *services.Timestamp + func (x *ConsensusTopicQuery) GetLimit() uint64 + func (x *ConsensusTopicQuery) GetTopicID() *services.TopicID + func (x *ConsensusTopicQuery) ProtoReflect() protoreflect.Message + func (x *ConsensusTopicQuery) Reset() + func (x *ConsensusTopicQuery) String() string + type ConsensusTopicResponse struct + ChunkInfo *services.ConsensusMessageChunkInfo + ConsensusTimestamp *services.Timestamp + Message []byte + RunningHash []byte + RunningHashVersion uint64 + SequenceNumber uint64 + func (*ConsensusTopicResponse) Descriptor() ([]byte, []int) + func (*ConsensusTopicResponse) ProtoMessage() + func (x *ConsensusTopicResponse) GetChunkInfo() *services.ConsensusMessageChunkInfo + func (x *ConsensusTopicResponse) GetConsensusTimestamp() *services.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 + type UnsafeConsensusServiceServer interface
Go to main page