mirror

type AddressBookQuery struct {

	// *
	// The ID of the address book file on the network. Can be either 0.0.101 or 0.0.102.
	FileId *services.FileID `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	// *
	// The maximum number of node addresses to receive before stopping. If not set or set to zero it will return all node addresses in the database.
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

type ConsensusTopicQuery struct {

	// *
	// A required topic ID to retrieve messages for.
	TopicID *services.TopicID `protobuf:"bytes,1,opt,name=topicID,proto3" json:"topicID,omitempty"`
	// *
	// 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
}

type ConsensusTopicResponse struct {

	// *
	// The time at which the transaction reached consensus
	ConsensusTimestamp *services.Timestamp `protobuf:"bytes,1,opt,name=consensusTimestamp,proto3" json:"consensusTimestamp,omitempty"`
	// *
	// 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"`
	// *
	// The running hash (SHA384) of every message.
	RunningHash []byte `protobuf:"bytes,3,opt,name=runningHash,proto3" json:"runningHash,omitempty"`
	// *
	// Starts at 1 for first submitted message. Incremented on each submitted message.
	SequenceNumber uint64 `protobuf:"varint,4,opt,name=sequenceNumber,proto3" json:"sequenceNumber,omitempty"`
	// *
	// Version of the SHA-384 digest used to update the running hash.
	RunningHashVersion uint64 `protobuf:"varint,5,opt,name=runningHashVersion,proto3" json:"runningHashVersion,omitempty"`
	// *
	// Optional information of the current chunk in a fragmented message.
	ChunkInfo *services.ConsensusMessageChunkInfo `protobuf:"bytes,6,opt,name=chunkInfo,proto3" json:"chunkInfo,omitempty"`
	// contains filtered or unexported fields
}

type NetworkServiceClient interface {
	// Query for an address book and return its nodes. The nodes are returned in ascending order by node ID. The
	// response is not guaranteed to be a byte-for-byte equivalent to the NodeAddress in the Hedera file on
	// the network since it is reconstructed from a normalized database table.
	GetNodes(ctx context.Context, in *AddressBookQuery, opts ...grpc.CallOption) (NetworkService_GetNodesClient, error)
}

type NetworkServiceServer interface {
	// Query for an address book and return its nodes. The nodes are returned in ascending order by node ID. The
	// response is not guaranteed to be a byte-for-byte equivalent to the NodeAddress in the Hedera file on
	// the network since it is reconstructed from a normalized database table.
	GetNodes(*AddressBookQuery, NetworkService_GetNodesServer) error
	// contains filtered or unexported methods
}

type NetworkService_GetNodesClient interface {
	Recv() (*services.NodeAddress, error)
	grpc.ClientStream
}

type NetworkService_GetNodesServer interface {
	Send(*services.NodeAddress) error
	grpc.ServerStream
}

type UnimplementedConsensusServiceServer struct {
}

type UnimplementedNetworkServiceServer struct {
}

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

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