mirror

Documentation

Index

• Variables
• func RegisterConsensusServiceServer(s *grpc.Server, 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() *proto.Timestamp
  • func (x *ConsensusTopicQuery) GetConsensusStartTime() *proto.Timestamp
  • func (x *ConsensusTopicQuery) GetLimit() uint64
  • func (x *ConsensusTopicQuery) GetTopicID() *proto.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() *proto.ConsensusMessageChunkInfo
  • func (x *ConsensusTopicResponse) GetConsensusTimestamp() *proto.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

Variables

var File_proto_mirror_ConsensusService_proto protoreflect.FileDescriptor

Functions

func RegisterConsensusServiceServer

func RegisterConsensusServiceServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewConsensusServiceClient

func NewConsensusServiceClient(cc grpc.ClientConnInterface) ConsensusServiceClient

type ConsensusServiceServer

type ConsensusServiceServer interface {
	SubscribeTopic(*ConsensusTopicQuery, ConsensusService_SubscribeTopicServer) error
}

ConsensusServiceServer is the server API for ConsensusService service.

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 *proto.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 *proto.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 *proto.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() *proto.Timestamp

func (*ConsensusTopicQuery) GetConsensusStartTime

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

func (*ConsensusTopicQuery) GetLimit

func (x *ConsensusTopicQuery) GetLimit() uint64

func (*ConsensusTopicQuery) GetTopicID

func (x *ConsensusTopicQuery) GetTopicID() *proto.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 *proto.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          *proto.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() *proto.ConsensusMessageChunkInfo

func (*ConsensusTopicResponse) GetConsensusTimestamp

func (x *ConsensusTopicResponse) GetConsensusTimestamp() *proto.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 can be embedded to have forward compatible implementations.

func (*UnimplementedConsensusServiceServer) SubscribeTopic

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