snpb

type AddLogStreamReplicaRequest struct {
	ClusterID       github_com_kakao_varlog_pkg_types.ClusterID     `` /* 142-byte string literal not displayed */
	StorageNodeID   github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	TopicID         github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID     github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
	StorageNodePath string                                          `protobuf:"bytes,5,opt,name=storage_node_path,json=storageNodePath,proto3" json:"storage_node_path,omitempty"`
}

type AddLogStreamReplicaResponse struct {
	LogStreamReplica LogStreamReplicaMetadataDescriptor `protobuf:"bytes,1,opt,name=log_stream_replica,json=logStreamReplica,proto3" json:"log_stream_replica"`
}

type AppendRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	Payload     [][]byte                                      `protobuf:"bytes,3,rep,name=payload,proto3" json:"payload,omitempty"`
}

type AppendResponse struct {
	Results []AppendResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results"`
}

type AppendResult struct {
	Meta  varlogpb.LogEntryMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta"`
	Error string                `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

type CommitBatchRequest struct {
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	CommitResults []LogStreamCommitResult                         `protobuf:"bytes,2,rep,name=commit_results,json=commitResults,proto3" json:"commit_results"`
}

type CommitBatchResponse struct {
}

type CommitRequest struct {
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	CommitResult  LogStreamCommitResult                           `protobuf:"bytes,2,opt,name=commit_result,json=commitResult,proto3" json:"commit_result"`
}

type CommitResponse struct {
}

type GetMetadataRequest struct {
	ClusterID github_com_kakao_varlog_pkg_types.ClusterID `` /* 142-byte string literal not displayed */
}

type GetMetadataResponse struct {
	StorageNodeMetadata *StorageNodeMetadataDescriptor `protobuf:"bytes,1,opt,name=storage_node_metadata,json=storageNodeMetadata,proto3" json:"storage_node_metadata,omitempty"`
}

type GetReportRequest struct {
}

type GetReportResponse struct {
	StorageNodeID   github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	UncommitReports []LogStreamUncommitReport                       `protobuf:"bytes,2,rep,name=uncommit_reports,json=uncommitReports,proto3" json:"uncommit_reports"`
}

type LogIOClient interface {
	// Append stores a list of log entries to the end of the log stream
	// specified by AppendRequest. The log entries are appended partially; that
	// is, some of the log entries could not be stored due to failures.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: AppendRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - NotFound: The log stream replica specified by the AppendRequest does not
	// exist in the storage node. Note that it does not mean that the log stream
	// does not exist in the cluster.
	// - FailedPrecondition: The log stream may be sealed; thus, clients cannot
	// write the log entry. Clients should unseal the log stream to append a log
	// entry to the log stream.
	// - Unavailable: The storage node is shutting down, or the log stream replica
	// is not primary.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// FIXME: Partial failures are not specified by the gRPC error codes.
	Append(ctx context.Context, opts ...grpc.CallOption) (LogIO_AppendClient, error)
	// Read reads a log entry from the log stream specified by ReadRequest.
	// Deprecated: Use Subscribe or SubscribeTo.
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	// Subscribe reads a range of log entries specified by SubscribeRequest.
	//
	// It returns the following gRPC errors:
	// - NotFound: The log stream replica specified by the SubscribeRequest does
	// not exist in the storage node. Note that it does not mean that the log
	// stream does not exist in the cluster.
	// - Unavailable: The storage node is shutting down.
	// - InvalidArgument: The range is invalid; for example, the beginning of the
	// range is greater than or equal to the end.
	// - OutOfRange: The parts or whole range are already trimmed.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LogIO_SubscribeClient, error)
	// SubscribeTo is similar to Subscribe except that it specifies the range with
	// LLSN.
	SubscribeTo(ctx context.Context, in *SubscribeToRequest, opts ...grpc.CallOption) (LogIO_SubscribeToClient, error)
	TrimDeprecated(ctx context.Context, in *TrimDeprecatedRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// LogStreamReplicaMetadata returns metadata of the log stream replica
	// specified by the LogStreamReplicaMetadataRequest.
	LogStreamReplicaMetadata(ctx context.Context, in *LogStreamReplicaMetadataRequest, opts ...grpc.CallOption) (*LogStreamReplicaMetadataResponse, error)
}

type LogIOServer interface {
	// Append stores a list of log entries to the end of the log stream
	// specified by AppendRequest. The log entries are appended partially; that
	// is, some of the log entries could not be stored due to failures.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: AppendRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - NotFound: The log stream replica specified by the AppendRequest does not
	// exist in the storage node. Note that it does not mean that the log stream
	// does not exist in the cluster.
	// - FailedPrecondition: The log stream may be sealed; thus, clients cannot
	// write the log entry. Clients should unseal the log stream to append a log
	// entry to the log stream.
	// - Unavailable: The storage node is shutting down, or the log stream replica
	// is not primary.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// FIXME: Partial failures are not specified by the gRPC error codes.
	Append(LogIO_AppendServer) error
	// Read reads a log entry from the log stream specified by ReadRequest.
	// Deprecated: Use Subscribe or SubscribeTo.
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	// Subscribe reads a range of log entries specified by SubscribeRequest.
	//
	// It returns the following gRPC errors:
	// - NotFound: The log stream replica specified by the SubscribeRequest does
	// not exist in the storage node. Note that it does not mean that the log
	// stream does not exist in the cluster.
	// - Unavailable: The storage node is shutting down.
	// - InvalidArgument: The range is invalid; for example, the beginning of the
	// range is greater than or equal to the end.
	// - OutOfRange: The parts or whole range are already trimmed.
	Subscribe(*SubscribeRequest, LogIO_SubscribeServer) error
	// SubscribeTo is similar to Subscribe except that it specifies the range with
	// LLSN.
	SubscribeTo(*SubscribeToRequest, LogIO_SubscribeToServer) error
	TrimDeprecated(context.Context, *TrimDeprecatedRequest) (*types.Empty, error)
	// LogStreamReplicaMetadata returns metadata of the log stream replica
	// specified by the LogStreamReplicaMetadataRequest.
	LogStreamReplicaMetadata(context.Context, *LogStreamReplicaMetadataRequest) (*LogStreamReplicaMetadataResponse, error)
}

type LogIO_AppendClient interface {
	Send(*AppendRequest) error
	Recv() (*AppendResponse, error)
	grpc.ClientStream
}

type LogIO_AppendServer interface {
	Send(*AppendResponse) error
	Recv() (*AppendRequest, error)
	grpc.ServerStream
}

type LogIO_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type LogIO_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type LogIO_SubscribeToClient interface {
	Recv() (*SubscribeToResponse, error)
	grpc.ClientStream
}

type LogIO_SubscribeToServer interface {
	Send(*SubscribeToResponse) error
	grpc.ServerStream
}

type LogStreamCommitResult struct {
	// LogStreamID is the identifier for the log stream.
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	// TopicID is the identifier for the topic to which the log stream belongs.
	TopicID github_com_kakao_varlog_pkg_types.TopicID `` /* 134-byte string literal not displayed */
	// CommittedLLSNOffset is the starting LLSN of the commit range.
	CommittedLLSNOffset github_com_kakao_varlog_pkg_types.LLSN `` /* 169-byte string literal not displayed */
	// CommittedGLSNOffset is the starting GLSN of the commit range.
	// If there is no log entry to be committed, the CommittedGLSNOffset should be
	// next to the last committed GLSN.
	CommittedGLSNOffset github_com_kakao_varlog_pkg_types.GLSN `` /* 169-byte string literal not displayed */
	// CommittedGLSNLength is the length of the commit range.
	CommittedGLSNLength uint64 `protobuf:"varint,5,opt,name=committed_glsn_length,json=committedGlsnLength,proto3" json:"committed_glsn_length,omitempty"`
	// Version is a unique number for the commit issued by the metadata
	// repository.
	Version github_com_kakao_varlog_pkg_types.Version `protobuf:"varint,6,opt,name=version,proto3,casttype=github.com/kakao/varlog/pkg/types.Version" json:"version,omitempty"`
	// HighWatermark is the maximum GLSN across all log streams of the topic in a
	// specific commit version.
	HighWatermark github_com_kakao_varlog_pkg_types.GLSN `` /* 149-byte string literal not displayed */
}

type LogStreamMetadataRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
}

type LogStreamMetadataResponse struct {
	LogStreamDescriptor varlogpb.LogStreamDescriptor `protobuf:"bytes,1,opt,name=log_stream_descriptor,json=logStreamDescriptor,proto3" json:"log_stream_descriptor"`
}

type LogStreamReplicaMetadataDescriptor struct {
	varlogpb.LogStreamReplica `protobuf:"bytes,1,opt,name=log_stream_replica,json=logStreamReplica,proto3,embedded=log_stream_replica" json:""`
	// Status is the status of the log stream replica.
	//
	// TODO: Use a separate type to represent the status of the log stream replica
	// rather than `varlogpb.LogStreamStatus` that is shared with the metadata
	// repository.
	Status varlogpb.LogStreamStatus `protobuf:"varint,2,opt,name=status,proto3,enum=varlog.varlogpb.LogStreamStatus" json:"status,omitempty"`
	// Version is the latest version of the commit received from the metadata
	// repository.
	Version github_com_kakao_varlog_pkg_types.Version `protobuf:"varint,3,opt,name=version,proto3,casttype=github.com/kakao/varlog/pkg/types.Version" json:"version,omitempty"`
	// GlobalHighWatermark is the latest high watermark received from the metadata
	// repository.
	GlobalHighWatermark github_com_kakao_varlog_pkg_types.GLSN `` /* 157-byte string literal not displayed */
	// LocalLowWatermark is the first log sequence number in the log stream
	// replica.
	// The LocalLowWatermark becomes higher when the log is truncated by prefix
	// trimming.
	LocalLowWatermark varlogpb.LogSequenceNumber `protobuf:"bytes,5,opt,name=local_low_watermark,json=localLowWatermark,proto3" json:"localLowWatermark"`
	// LocalHighWatermark is the last log sequence number in the log stream
	// replica.
	LocalHighWatermark varlogpb.LogSequenceNumber `protobuf:"bytes,6,opt,name=local_high_watermark,json=localHighWatermark,proto3" json:"localHighWatermark"`
	// Path is the directory where the data for the log stream replica is stored.
	Path             string `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"`
	StorageSizeBytes uint64 `protobuf:"varint,8,opt,name=storage_size_bytes,json=storageSizeBytes,proto3" json:"storage_size_bytes,omitempty"`
	// CreatedTime
	//
	// FIXME: StartTime or UpTime
	CreatedTime time.Time `protobuf:"bytes,9,opt,name=created_time,json=createdTime,proto3,stdtime" json:"createdTime"`
	// UpdatedTime
	//
	// Deprecated:
	UpdatedTime time.Time `protobuf:"bytes,10,opt,name=updated_time,json=updatedTime,proto3,stdtime" json:"updatedTime"`
}

type LogStreamReplicaMetadataRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
}

type LogStreamReplicaMetadataResponse struct {
	LogStreamReplica LogStreamReplicaMetadataDescriptor `protobuf:"bytes,1,opt,name=log_stream_replica,json=logStreamReplica,proto3" json:"log_stream_replica"`
}

type LogStreamReporterClient interface {
	GetReport(ctx context.Context, opts ...grpc.CallOption) (LogStreamReporter_GetReportClient, error)
	Commit(ctx context.Context, opts ...grpc.CallOption) (LogStreamReporter_CommitClient, error)
	CommitBatch(ctx context.Context, opts ...grpc.CallOption) (LogStreamReporter_CommitBatchClient, error)
}

type LogStreamReporterServer interface {
	GetReport(LogStreamReporter_GetReportServer) error
	Commit(LogStreamReporter_CommitServer) error
	CommitBatch(LogStreamReporter_CommitBatchServer) error
}

type LogStreamReporter_CommitBatchClient interface {
	Send(*CommitBatchRequest) error
	CloseAndRecv() (*CommitBatchResponse, error)
	grpc.ClientStream
}

type LogStreamReporter_CommitBatchServer interface {
	SendAndClose(*CommitBatchResponse) error
	Recv() (*CommitBatchRequest, error)
	grpc.ServerStream
}

type LogStreamReporter_CommitClient interface {
	Send(*CommitRequest) error
	CloseAndRecv() (*CommitResponse, error)
	grpc.ClientStream
}

type LogStreamReporter_CommitServer interface {
	SendAndClose(*CommitResponse) error
	Recv() (*CommitRequest, error)
	grpc.ServerStream
}

type LogStreamReporter_GetReportClient interface {
	Send(*GetReportRequest) error
	Recv() (*GetReportResponse, error)
	grpc.ClientStream
}

type LogStreamReporter_GetReportServer interface {
	Send(*GetReportResponse) error
	Recv() (*GetReportRequest, error)
	grpc.ServerStream
}

type LogStreamUncommitReport struct {
	LogStreamID           github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	UncommittedLLSNOffset github_com_kakao_varlog_pkg_types.LLSN        `` /* 175-byte string literal not displayed */
	UncommittedLLSNLength uint64                                        `` /* 127-byte string literal not displayed */
	Version               github_com_kakao_varlog_pkg_types.Version     `protobuf:"varint,4,opt,name=version,proto3,casttype=github.com/kakao/varlog/pkg/types.Version" json:"version,omitempty"`
	HighWatermark         github_com_kakao_varlog_pkg_types.GLSN        `` /* 149-byte string literal not displayed */
}

type ManagementClient interface {
	// GetMetadata returns the metadata of the storage node. It produces a gRPC
	// Unavailable error if the storage node is shutting down.
	GetMetadata(ctx context.Context, in *GetMetadataRequest, opts ...grpc.CallOption) (*GetMetadataResponse, error)
	// AddLogStreamReplica adds a new log stream replica to a storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - ResourceExhausted: The number of log stream replicas in the storage node
	// reaches the upper limit.
	// - Canceled: The client canceled the request.
	// DeadlineExceeded: The client's timeout has expired.
	AddLogStreamReplica(ctx context.Context, in *AddLogStreamReplicaRequest, opts ...grpc.CallOption) (*AddLogStreamReplicaResponse, error)
	// RemoveLogStream removes a log stream replica from the storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// TODO: It should be renamed to RemoveLogStreamReplica to represent its
	// purpose precisely.
	RemoveLogStream(ctx context.Context, in *RemoveLogStreamRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Seal changes the status of the log stream replica to LogStreamStatusSealing
	// or LogStreamStatusSealed.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: SealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Seal(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error)
	// Unseal changes the status of the log stream replica to
	// LogStreamStatusRunning.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: UnsealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Unseal(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Sync duplicates log entries from the source log stream replica to the
	// destination log stream replica.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	// Trim removes prefix log entries from each log stream replica in the topic.
	Trim(ctx context.Context, in *TrimRequest, opts ...grpc.CallOption) (*TrimResponse, error)
}

type ManagementServer interface {
	// GetMetadata returns the metadata of the storage node. It produces a gRPC
	// Unavailable error if the storage node is shutting down.
	GetMetadata(context.Context, *GetMetadataRequest) (*GetMetadataResponse, error)
	// AddLogStreamReplica adds a new log stream replica to a storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - ResourceExhausted: The number of log stream replicas in the storage node
	// reaches the upper limit.
	// - Canceled: The client canceled the request.
	// DeadlineExceeded: The client's timeout has expired.
	AddLogStreamReplica(context.Context, *AddLogStreamReplicaRequest) (*AddLogStreamReplicaResponse, error)
	// RemoveLogStream removes a log stream replica from the storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// TODO: It should be renamed to RemoveLogStreamReplica to represent its
	// purpose precisely.
	RemoveLogStream(context.Context, *RemoveLogStreamRequest) (*types.Empty, error)
	// Seal changes the status of the log stream replica to LogStreamStatusSealing
	// or LogStreamStatusSealed.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: SealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Seal(context.Context, *SealRequest) (*SealResponse, error)
	// Unseal changes the status of the log stream replica to
	// LogStreamStatusRunning.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: UnsealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Unseal(context.Context, *UnsealRequest) (*types.Empty, error)
	// Sync duplicates log entries from the source log stream replica to the
	// destination log stream replica.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	// Trim removes prefix log entries from each log stream replica in the topic.
	Trim(context.Context, *TrimRequest) (*TrimResponse, error)
}

type ReadRequest struct {
	GLSN        github_com_kakao_varlog_pkg_types.GLSN        `protobuf:"varint,1,opt,name=glsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"glsn,omitempty"`
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
}

type ReadResponse struct {
	GLSN    github_com_kakao_varlog_pkg_types.GLSN `protobuf:"varint,1,opt,name=glsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"glsn,omitempty"`
	LLSN    github_com_kakao_varlog_pkg_types.LLSN `protobuf:"varint,2,opt,name=llsn,proto3,casttype=github.com/kakao/varlog/pkg/types.LLSN" json:"llsn,omitempty"`
	Payload []byte                                 `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

type RemoveLogStreamRequest struct {
	ClusterID     github_com_kakao_varlog_pkg_types.ClusterID     `` /* 142-byte string literal not displayed */
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	TopicID       github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID   github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
}

type ReplicateRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	LLSN        []github_com_kakao_varlog_pkg_types.LLSN      `protobuf:"varint,3,rep,packed,name=llsn,proto3,casttype=github.com/kakao/varlog/pkg/types.LLSN" json:"llsn,omitempty"`
	Data        [][]byte                                      `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
}

type ReplicateResponse struct {
}

type ReplicatorClient interface {
	Replicate(ctx context.Context, opts ...grpc.CallOption) (Replicator_ReplicateClient, error)
	// SyncInit tells the source replica's log entries range to the destination
	// replica. According to the range sent by the request of SyncInit, the
	// destination replica can decide whether it is necessary to copy log entries
	// from the source and even delete stale ones.
	//
	// To be a source replica, the status of the log stream replica must be
	// SEALED, which indicates that the log stream replica has all the log entries
	// that the metadata repository has committed. To be a destination replica,
	// the status of the log stream replica must be SEALING which means that the
	// log stream replica does not have all log entries yet.
	//
	// To represent log entry ranges, each request and response of SyncInit embeds
	// a field of type SyncRange. The source replica sends a range of overall log
	// entries to the destination replica; that is, the FirstLLSN of SyncRange is
	// the local low watermark, and the LastLLSN of it is the local high
	// watermark. There are several cases in the destination replica:
	//
	// - The destination replica already has log entries and the commit context,
	// which are the same as the source replica: No synchronization is necessary.
	// The destination replica should reply with a SyncInitResponse having the
	// FirstLLSN and the LastLLSN as InvalidLLSNs.
	// - The destination replica's local high watermark is equal to the LastLLSN.
	// However, it does not have the corresponding commit context that contains
	// the last log entry: It means that only copying the commit context from the
	// source to the destination is necessary. The destination should reply with a
	// SyncInitResponse having a larger FirstLLSN than the LastLLSN.
	// - The destination replica's local high watermark is lower than the LastLLSN
	// of SyncInitRequest: Some log entries should be cloned from the source to
	// the destination. The destination replica should reply with a
	// SyncInitResponse denoting the missing range.
	//
	// A destination replica sometimes should remove log entries according to the
	// SyncRange in the request, usually when the source replica has trimmed the
	// log entries.
	//
	// When a source replica has no log entries due to Trim, the source replica
	// can invoke SyncInit with InvalidLLSNs for FirstLLSN and LastLLSN of
	// SyncRange. Destination replica should remove their stale log entries and
	// receive a commit context from the source replica.
	//
	// TODO: Use the gRPC error code instead of setting particular values for the
	// SyncRange to avoid ambiguity.
	SyncInit(ctx context.Context, in *SyncInitRequest, opts ...grpc.CallOption) (*SyncInitResponse, error)
	// SyncReplicate
	//
	// Deprecated: Use SyncReplicateStream
	SyncReplicate(ctx context.Context, in *SyncReplicateRequest, opts ...grpc.CallOption) (*SyncReplicateResponse, error)
	// SyncReplicateStream copies log entries between replicas in a log stream.
	SyncReplicateStream(ctx context.Context, opts ...grpc.CallOption) (Replicator_SyncReplicateStreamClient, error)
}

type ReplicatorServer interface {
	Replicate(Replicator_ReplicateServer) error
	// SyncInit tells the source replica's log entries range to the destination
	// replica. According to the range sent by the request of SyncInit, the
	// destination replica can decide whether it is necessary to copy log entries
	// from the source and even delete stale ones.
	//
	// To be a source replica, the status of the log stream replica must be
	// SEALED, which indicates that the log stream replica has all the log entries
	// that the metadata repository has committed. To be a destination replica,
	// the status of the log stream replica must be SEALING which means that the
	// log stream replica does not have all log entries yet.
	//
	// To represent log entry ranges, each request and response of SyncInit embeds
	// a field of type SyncRange. The source replica sends a range of overall log
	// entries to the destination replica; that is, the FirstLLSN of SyncRange is
	// the local low watermark, and the LastLLSN of it is the local high
	// watermark. There are several cases in the destination replica:
	//
	// - The destination replica already has log entries and the commit context,
	// which are the same as the source replica: No synchronization is necessary.
	// The destination replica should reply with a SyncInitResponse having the
	// FirstLLSN and the LastLLSN as InvalidLLSNs.
	// - The destination replica's local high watermark is equal to the LastLLSN.
	// However, it does not have the corresponding commit context that contains
	// the last log entry: It means that only copying the commit context from the
	// source to the destination is necessary. The destination should reply with a
	// SyncInitResponse having a larger FirstLLSN than the LastLLSN.
	// - The destination replica's local high watermark is lower than the LastLLSN
	// of SyncInitRequest: Some log entries should be cloned from the source to
	// the destination. The destination replica should reply with a
	// SyncInitResponse denoting the missing range.
	//
	// A destination replica sometimes should remove log entries according to the
	// SyncRange in the request, usually when the source replica has trimmed the
	// log entries.
	//
	// When a source replica has no log entries due to Trim, the source replica
	// can invoke SyncInit with InvalidLLSNs for FirstLLSN and LastLLSN of
	// SyncRange. Destination replica should remove their stale log entries and
	// receive a commit context from the source replica.
	//
	// TODO: Use the gRPC error code instead of setting particular values for the
	// SyncRange to avoid ambiguity.
	SyncInit(context.Context, *SyncInitRequest) (*SyncInitResponse, error)
	// SyncReplicate
	//
	// Deprecated: Use SyncReplicateStream
	SyncReplicate(context.Context, *SyncReplicateRequest) (*SyncReplicateResponse, error)
	// SyncReplicateStream copies log entries between replicas in a log stream.
	SyncReplicateStream(Replicator_SyncReplicateStreamServer) error
}