mirror

Documentation

Index

• Variables
• func RegisterConsensusServiceServer(s grpc.ServiceRegistrar, srv ConsensusServiceServer)
• type ConsensusServiceClient
  • func NewConsensusServiceClient(cc grpc.ClientConnInterface) ConsensusServiceClient
• type ConsensusServiceServer
• type ConsensusService_SubscribeTopicClient
• type ConsensusService_SubscribeTopicServer
• type ConsensusTopicQuery
  • func (*ConsensusTopicQuery) Descriptor() ([]byte, []int)
  • func (x *ConsensusTopicQuery) GetConsensusEndTime() *services.Timestamp
  • func (x *ConsensusTopicQuery) GetConsensusStartTime() *services.Timestamp
  • func (x *ConsensusTopicQuery) GetLimit() uint64
  • func (x *ConsensusTopicQuery) GetTopicID() *services.TopicID
  • func (*ConsensusTopicQuery) ProtoMessage()
  • func (x *ConsensusTopicQuery) ProtoReflect() protoreflect.Message
  • func (x *ConsensusTopicQuery) Reset()
  • func (x *ConsensusTopicQuery) String() string
• type ConsensusTopicResponse
  • func (*ConsensusTopicResponse) Descriptor() ([]byte, []int)
  • 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 (*ConsensusTopicResponse) ProtoMessage()
  • func (x *ConsensusTopicResponse) ProtoReflect() protoreflect.Message
  • func (x *ConsensusTopicResponse) Reset()
  • func (x *ConsensusTopicResponse) String() string
• type UnimplementedConsensusServiceServer
  • func (UnimplementedConsensusServiceServer) SubscribeTopic(*ConsensusTopicQuery, ConsensusService_SubscribeTopicServer) error
• type UnsafeConsensusServiceServer

Variables

var ConsensusService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.hedera.mirror.api.proto.ConsensusService",
	HandlerType: (*ConsensusServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "subscribeTopic",
			Handler:       _ConsensusService_SubscribeTopic_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ConsensusService.proto",
}

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

var File_ConsensusService_proto protoreflect.FileDescriptor

Functions

func RegisterConsensusServiceServer

func RegisterConsensusServiceServer(s grpc.ServiceRegistrar, srv ConsensusServiceServer)

Types

type ConsensusServiceClient

type ConsensusServiceClient interface {
	SubscribeTopic(ctx context.Context, in *ConsensusTopicQuery, opts ...grpc.CallOption) (ConsensusService_SubscribeTopicClient, error)
}

ConsensusServiceClient is the client API for ConsensusService 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 NewConsensusServiceClient

func NewConsensusServiceClient(cc grpc.ClientConnInterface) ConsensusServiceClient

type ConsensusServiceServer

type ConsensusServiceServer interface {
	SubscribeTopic(*ConsensusTopicQuery, ConsensusService_SubscribeTopicServer) error
	// contains filtered or unexported methods
}

ConsensusServiceServer is the server API for ConsensusService service. All implementations must embed UnimplementedConsensusServiceServer for forward compatibility

type ConsensusService_SubscribeTopicClient

type ConsensusService_SubscribeTopicClient interface {
	Recv() (*ConsensusTopicResponse, error)
	grpc.ClientStream
}

type ConsensusService_SubscribeTopicServer

type ConsensusService_SubscribeTopicServer interface {
	Send(*ConsensusTopicResponse) error
	grpc.ServerStream
}

type ConsensusTopicQuery

type ConsensusTopicQuery struct {
	TopicID *services.TopicID `protobuf:"bytes,1,opt,name=topicID,proto3" json:"topicID,omitempty"` // A required topic ID to retrieve messages for.
	// Include messages which reached consensus on or after this time. Defaults to current time if not set.
	ConsensusStartTime *services.Timestamp `protobuf:"bytes,2,opt,name=consensusStartTime,proto3" json:"consensusStartTime,omitempty"`
	// Include messages which reached consensus before this time. If not set it will receive indefinitely.
	ConsensusEndTime *services.Timestamp `protobuf:"bytes,3,opt,name=consensusEndTime,proto3" json:"consensusEndTime,omitempty"`
	// The maximum number of messages to receive before stopping. If not set or set to zero it will return messages
	// indefinitely.
	Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsensusTopicQuery) Descriptor

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

Deprecated: Use ConsensusTopicQuery.ProtoReflect.Descriptor instead.

func (*ConsensusTopicQuery) GetConsensusEndTime

func (x *ConsensusTopicQuery) GetConsensusEndTime() *services.Timestamp

func (*ConsensusTopicQuery) GetConsensusStartTime

func (x *ConsensusTopicQuery) GetConsensusStartTime() *services.Timestamp

func (*ConsensusTopicQuery) GetLimit

func (x *ConsensusTopicQuery) GetLimit() uint64

func (*ConsensusTopicQuery) GetTopicID

func (x *ConsensusTopicQuery) GetTopicID() *services.TopicID

func (*ConsensusTopicQuery) ProtoMessage

func (*ConsensusTopicQuery) ProtoMessage()

func (*ConsensusTopicQuery) ProtoReflect

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

func (*ConsensusTopicQuery) Reset

func (x *ConsensusTopicQuery) Reset()

func (*ConsensusTopicQuery) String

func (x *ConsensusTopicQuery) String() string

type ConsensusTopicResponse

type ConsensusTopicResponse struct {
	ConsensusTimestamp *services.Timestamp `protobuf:"bytes,1,opt,name=consensusTimestamp,proto3" json:"consensusTimestamp,omitempty"` // The time at which the transaction reached consensus
	// The message body originally in the ConsensusSubmitMessageTransactionBody. Message size will be less than 6KiB.
	Message            []byte                              `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	RunningHash        []byte                              `protobuf:"bytes,3,opt,name=runningHash,proto3" json:"runningHash,omitempty"`                // The running hash (SHA384) of every message.
	SequenceNumber     uint64                              `protobuf:"varint,4,opt,name=sequenceNumber,proto3" json:"sequenceNumber,omitempty"`         // Starts at 1 for first submitted message. Incremented on each submitted message.
	RunningHashVersion uint64                              `protobuf:"varint,5,opt,name=runningHashVersion,proto3" json:"runningHashVersion,omitempty"` // Version of the SHA-384 digest used to update the running hash.
	ChunkInfo          *services.ConsensusMessageChunkInfo `protobuf:"bytes,6,opt,name=chunkInfo,proto3" json:"chunkInfo,omitempty"`                    // Optional information of the current chunk in a fragmented message.
	// contains filtered or unexported fields
}

func (*ConsensusTopicResponse) Descriptor

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

Deprecated: Use ConsensusTopicResponse.ProtoReflect.Descriptor instead.

func (*ConsensusTopicResponse) GetChunkInfo

func (x *ConsensusTopicResponse) GetChunkInfo() *services.ConsensusMessageChunkInfo

func (*ConsensusTopicResponse) GetConsensusTimestamp

func (x *ConsensusTopicResponse) GetConsensusTimestamp() *services.Timestamp

func (*ConsensusTopicResponse) GetMessage

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

func (*ConsensusTopicResponse) GetRunningHash

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

func (*ConsensusTopicResponse) GetRunningHashVersion

func (x *ConsensusTopicResponse) GetRunningHashVersion() uint64

func (*ConsensusTopicResponse) GetSequenceNumber

func (x *ConsensusTopicResponse) GetSequenceNumber() uint64

func (*ConsensusTopicResponse) ProtoMessage

func (*ConsensusTopicResponse) ProtoMessage()

func (*ConsensusTopicResponse) ProtoReflect

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

func (*ConsensusTopicResponse) Reset

func (x *ConsensusTopicResponse) Reset()

func (*ConsensusTopicResponse) String

func (x *ConsensusTopicResponse) String() string

type UnimplementedConsensusServiceServer

type UnimplementedConsensusServiceServer struct{}

UnimplementedConsensusServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConsensusServiceServer) SubscribeTopic

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

type UnsafeConsensusServiceServer

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

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