streamingpb

type AckedCheckpoint struct {
	MessageId              *commonpb.MessageID `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` // the message id that has been acked.
	LastConfirmedMessageId *commonpb.MessageID ``                                                                                         // the last confirmed message id that has been acked.
	/* 131-byte string literal not displayed */
	TimeTick uint64 `protobuf:"varint,3,opt,name=time_tick,json=timeTick,proto3" json:"time_tick,omitempty"` // the time tick of the message that has been acked.
	// contains filtered or unexported fields
}

type AckedResult struct {
	Channels         []string           `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`                                         // may be pchannel name or vchannel name.
	AckedCheckpoints []*AckedCheckpoint `protobuf:"bytes,2,rep,name=acked_checkpoints,json=ackedCheckpoints,proto3" json:"acked_checkpoints,omitempty"` // always same length with channels, not nil if acked.
	// contains filtered or unexported fields
}

type AssignmentDiscoverRequest struct {

	// Types that are assignable to Command:
	//
	//	*AssignmentDiscoverRequest_ReportError
	//	*AssignmentDiscoverRequest_Close
	Command isAssignmentDiscoverRequest_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

type AssignmentDiscoverRequest_Close struct {
	Close *CloseAssignmentDiscoverRequest `protobuf:"bytes,2,opt,name=close,proto3,oneof"` // close the stream.
}

type AssignmentDiscoverRequest_ReportError struct {
	ReportError *ReportAssignmentErrorRequest `protobuf:"bytes,1,opt,name=report_error,json=reportError,proto3,oneof"` // report streaming error, trigger reassign right now.
}

type AssignmentDiscoverResponse struct {

	// Types that are assignable to Response:
	//
	//	*AssignmentDiscoverResponse_FullAssignment
	//	*AssignmentDiscoverResponse_Close
	Response isAssignmentDiscoverResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type AssignmentDiscoverResponse_Close struct {
	// TODO: may be support partial assignment info in future.
	Close *CloseAssignmentDiscoverResponse `protobuf:"bytes,2,opt,name=close,proto3,oneof"`
}

type AssignmentDiscoverResponse_FullAssignment struct {
	FullAssignment *FullStreamingNodeAssignmentWithVersion `protobuf:"bytes,1,opt,name=full_assignment,json=fullAssignment,proto3,oneof"` // all assignment info.
}

type BroadcastAckRequest struct {

	// Deprecated: Marked as deprecated in streaming.proto.
	BroadcastId uint64 `protobuf:"varint,1,opt,name=broadcast_id,json=broadcastId,proto3" json:"broadcast_id,omitempty"` // broadcast id.
	// Deprecated: Marked as deprecated in streaming.proto.
	Vchannel string                     `protobuf:"bytes,2,opt,name=vchannel,proto3" json:"vchannel,omitempty"` // the vchannel that acked the message.
	Message  *commonpb.ImmutableMessage `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`   // the message that to be acked.
	// contains filtered or unexported fields
}

type BroadcastAckResponse struct {
	// contains filtered or unexported fields
}

type BroadcastRequest struct {
	Message *messagespb.Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // message to be broadcast.
	// contains filtered or unexported fields
}

type BroadcastResponse struct {
	Results     map[string]*ProduceMessageResponseResult `` /* 155-byte string literal not displayed */
	BroadcastId uint64                                   `protobuf:"varint,2,opt,name=broadcast_id,json=broadcastId,proto3" json:"broadcast_id,omitempty"`
	// contains filtered or unexported fields
}

type BroadcastTask struct {
	Message *messagespb.Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`                                             // message to be broadcast.
	State   BroadcastTaskState  `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.streaming.BroadcastTaskState" json:"state,omitempty"` // state of the task.
	// Deprecated: Marked as deprecated in streaming.proto.
	AckedVchannelBitmap []byte             `protobuf:"bytes,3,opt,name=acked_vchannel_bitmap,json=ackedVchannelBitmap,proto3" json:"acked_vchannel_bitmap,omitempty"` // deprecated, use acked_checkpoints instead.
	AckedCheckpoints    []*AckedCheckpoint `protobuf:"bytes,4,rep,name=acked_checkpoints,json=ackedCheckpoints,proto3" json:"acked_checkpoints,omitempty"`            // given vchannels that have been acked, the size of bitmap is same with message.BroadcastHeader().VChannels.
	// contains filtered or unexported fields
}

type BroadcastTaskState int32

type CChannelAssignment struct {
	Meta *CChannelMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type CChannelMeta struct {
	Pchannel string `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"` // the pchannel that control channel locate on.
	// contains filtered or unexported fields
}

type CloseAssignmentDiscoverRequest struct {
	// contains filtered or unexported fields
}

type CloseAssignmentDiscoverResponse struct {
	// contains filtered or unexported fields
}

type CloseConsumerRequest struct {
	// contains filtered or unexported fields
}

type CloseConsumerResponse struct {
	// contains filtered or unexported fields
}

type CloseProducerRequest struct {
	// contains filtered or unexported fields
}

type CloseProducerResponse struct {
	// contains filtered or unexported fields
}

type CloseVChannelConsumerRequest struct {
	ConsumerId int64 `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	// contains filtered or unexported fields
}

type CloseVChannelConsumerResponse struct {
	ConsumerId int64 `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	// contains filtered or unexported fields
}

type CollectionInfoOfVChannel struct {
	CollectionId int64                         `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"` // collection id.
	Partitions   []*PartitionInfoOfVChannel    `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions,omitempty"`                          // partitions.
	Schemas      []*CollectionSchemaOfVChannel `protobuf:"bytes,3,rep,name=schemas,proto3" json:"schemas,omitempty"`                                // The schemas of the vchannel.
	// contains filtered or unexported fields
}

type CollectionSchemaOfVChannel struct {
	Schema             *schemapb.CollectionSchema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`                                                      // The schemas of the vchannel.
	CheckpointTimeTick uint64                     `protobuf:"varint,2,opt,name=checkpoint_time_tick,json=checkpointTimeTick,proto3" json:"checkpoint_time_tick,omitempty"` // The timetick of the schema changed, also the version of the schema.
	State              VChannelSchemaState        `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.streaming.VChannelSchemaState" json:"state,omitempty"`       // The state of the schema.
	// contains filtered or unexported fields
}

type ConsumeMessageReponse struct {
	ConsumerId int64                      `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	Message    *commonpb.ImmutableMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ConsumeRequest struct {

	// Types that are assignable to Request:
	//
	//	*ConsumeRequest_CreateVchannelConsumer
	//	*ConsumeRequest_CreateVchannelConsumers
	//	*ConsumeRequest_CloseVchannel
	//	*ConsumeRequest_Close
	Request isConsumeRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type ConsumeRequest_Close struct {
	Close *CloseConsumerRequest `protobuf:"bytes,4,opt,name=close,proto3,oneof"`
}

type ConsumeRequest_CloseVchannel struct {
	CloseVchannel *CloseVChannelConsumerRequest `protobuf:"bytes,3,opt,name=close_vchannel,json=closeVchannel,proto3,oneof"`
}

type ConsumeRequest_CreateVchannelConsumer struct {
	CreateVchannelConsumer *CreateVChannelConsumerRequest `protobuf:"bytes,1,opt,name=create_vchannel_consumer,json=createVchannelConsumer,proto3,oneof"`
}

type ConsumeRequest_CreateVchannelConsumers struct {
	CreateVchannelConsumers *CreateVChannelConsumersRequest `protobuf:"bytes,2,opt,name=create_vchannel_consumers,json=createVchannelConsumers,proto3,oneof"` // Create multiple vchannel consumers, used for recovery in future.
}

type ConsumeResponse struct {

	// Types that are assignable to Response:
	//
	//	*ConsumeResponse_Create
	//	*ConsumeResponse_Consume
	//	*ConsumeResponse_CreateVchannel
	//	*ConsumeResponse_CreateVchannels
	//	*ConsumeResponse_CloseVchannel
	//	*ConsumeResponse_Close
	Response isConsumeResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type ConsumeResponse_Close struct {
	Close *CloseConsumerResponse `protobuf:"bytes,6,opt,name=close,proto3,oneof"`
}

type ConsumeResponse_CloseVchannel struct {
	CloseVchannel *CloseVChannelConsumerResponse `protobuf:"bytes,5,opt,name=close_vchannel,json=closeVchannel,proto3,oneof"`
}

type ConsumeResponse_Consume struct {
	Consume *ConsumeMessageReponse `protobuf:"bytes,2,opt,name=consume,proto3,oneof"`
}

type ConsumeResponse_Create struct {
	Create *CreateConsumerResponse `protobuf:"bytes,1,opt,name=create,proto3,oneof"`
}

type ConsumeResponse_CreateVchannel struct {
	CreateVchannel *CreateVChannelConsumerResponse `protobuf:"bytes,3,opt,name=create_vchannel,json=createVchannel,proto3,oneof"`
}

type ConsumeResponse_CreateVchannels struct {
	CreateVchannels *CreateVChannelConsumersResponse `protobuf:"bytes,4,opt,name=create_vchannels,json=createVchannels,proto3,oneof"`
}

type CreateConsumerRequest struct {
	Pchannel *PChannelInfo `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"`
	// contains filtered or unexported fields
}

type CreateConsumerResponse struct {

	// Deprecated: Marked as deprecated in streaming.proto.
	WalName string `protobuf:"bytes,1,opt,name=wal_name,json=walName,proto3" json:"wal_name,omitempty"` // wal name at server side.
	// A unique consumer id on streamingnode for this
	// consumer in streamingnode lifetime.
	ConsumerServerId int64 `protobuf:"varint,2,opt,name=consumer_server_id,json=consumerServerId,proto3" json:"consumer_server_id,omitempty"`
	// contains filtered or unexported fields
}

type CreateProducerRequest struct {
	Pchannel *PChannelInfo `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"`
	// contains filtered or unexported fields
}

type CreateProducerResponse struct {

	// Deprecated: Marked as deprecated in streaming.proto.
	WalName          string `protobuf:"bytes,1,opt,name=wal_name,json=walName,proto3" json:"wal_name,omitempty"`                               // wal name at server side.
	ProducerServerId int64  `protobuf:"varint,2,opt,name=producer_server_id,json=producerServerId,proto3" json:"producer_server_id,omitempty"` // A unique producer server id on streamingnode
	// contains filtered or unexported fields
}

type CreateVChannelConsumerRequest struct {
	Vchannel       string           `protobuf:"bytes,1,opt,name=vchannel,proto3" json:"vchannel,omitempty"`
	DeliverPolicy  *DeliverPolicy   `protobuf:"bytes,2,opt,name=deliver_policy,json=deliverPolicy,proto3" json:"deliver_policy,omitempty"`    // deliver policy.
	DeliverFilters []*DeliverFilter `protobuf:"bytes,3,rep,name=deliver_filters,json=deliverFilters,proto3" json:"deliver_filters,omitempty"` // deliver filter.
	// contains filtered or unexported fields
}

type CreateVChannelConsumerResponse struct {

	// Types that are assignable to Response:
	//
	//	*CreateVChannelConsumerResponse_ConsumerId
	//	*CreateVChannelConsumerResponse_Error
	Response isCreateVChannelConsumerResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type CreateVChannelConsumerResponse_ConsumerId struct {
	ConsumerId int64 `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3,oneof"`
}

type CreateVChannelConsumerResponse_Error struct {
	Error *StreamingError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type CreateVChannelConsumersRequest struct {
	CreateVchannels []*CreateVChannelConsumerRequest `protobuf:"bytes,1,rep,name=create_vchannels,json=createVchannels,proto3" json:"create_vchannels,omitempty"`
	// contains filtered or unexported fields
}

type CreateVChannelConsumersResponse struct {
	CreateVchannels []*CreateVChannelConsumerResponse `protobuf:"bytes,1,rep,name=create_vchannels,json=createVchannels,proto3" json:"create_vchannels,omitempty"`
	// contains filtered or unexported fields
}

type DeliverFilter struct {

	// Types that are assignable to Filter:
	//
	//	*DeliverFilter_TimeTickGt
	//	*DeliverFilter_TimeTickGte
	//	*DeliverFilter_MessageType
	Filter isDeliverFilter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

type DeliverFilterMessageType struct {

	// deliver message with message type.
	MessageTypes []messagespb.MessageType `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DeliverFilterTimeTickGT struct {
	TimeTick uint64 `protobuf:"varint,1,opt,name=time_tick,json=timeTick,proto3" json:"time_tick,omitempty"` // deliver message with time tick greater than this value.
	// contains filtered or unexported fields
}

type DeliverFilterTimeTickGTE struct {
	TimeTick uint64 `protobuf:"varint,1,opt,name=time_tick,json=timeTick,proto3" json:"time_tick,omitempty"` // deliver message with time tick greater than or
	// contains filtered or unexported fields
}

type DeliverFilter_MessageType struct {
	MessageType *DeliverFilterMessageType `protobuf:"bytes,3,opt,name=message_type,json=messageType,proto3,oneof"`
}

type DeliverFilter_TimeTickGt struct {
	TimeTickGt *DeliverFilterTimeTickGT `protobuf:"bytes,1,opt,name=time_tick_gt,json=timeTickGt,proto3,oneof"`
}

type DeliverFilter_TimeTickGte struct {
	TimeTickGte *DeliverFilterTimeTickGTE `protobuf:"bytes,2,opt,name=time_tick_gte,json=timeTickGte,proto3,oneof"`
}

type DeliverPolicy struct {

	// Types that are assignable to Policy:
	//
	//	*DeliverPolicy_All
	//	*DeliverPolicy_Latest
	//	*DeliverPolicy_StartFrom
	//	*DeliverPolicy_StartAfter
	Policy isDeliverPolicy_Policy `protobuf_oneof:"policy"`
	// contains filtered or unexported fields
}

type DeliverPolicy_All struct {
	All *emptypb.Empty `protobuf:"bytes,1,opt,name=all,proto3,oneof"` // deliver all messages.
}

type DeliverPolicy_Latest struct {
	Latest *emptypb.Empty `protobuf:"bytes,2,opt,name=latest,proto3,oneof"` // deliver the latest message.
}

type DeliverPolicy_StartAfter struct {
	StartAfter *commonpb.MessageID `protobuf:"bytes,4,opt,name=start_after,json=startAfter,proto3,oneof"` // deliver message after this message id. (startAfter, ...]
}

type DeliverPolicy_StartFrom struct {
	StartFrom *commonpb.MessageID `protobuf:"bytes,3,opt,name=start_from,json=startFrom,proto3,oneof"` // deliver message from this message id. [startFrom, ...]
}

type FullStreamingNodeAssignmentWithVersion struct {
	Version                *VersionPair                     `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Assignments            []*StreamingNodeAssignment       `protobuf:"bytes,2,rep,name=assignments,proto3" json:"assignments,omitempty"`
	Cchannel               *CChannelAssignment              `protobuf:"bytes,3,opt,name=cchannel,proto3" json:"cchannel,omitempty"` // Where the control channel located.
	ReplicateConfiguration *commonpb.ReplicateConfiguration ``                                                                      /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetReplicateCheckpointRequest struct {
	Pchannel *PChannelInfo `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"`
	// contains filtered or unexported fields
}

type GetReplicateCheckpointResponse struct {
	Checkpoint *commonpb.ReplicateCheckpoint `protobuf:"bytes,1,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	// contains filtered or unexported fields
}

type PChannelAccessMode int32

type PChannelAssignmentLog struct {
	Term       int64              `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // term when server assigned.
	Node       *StreamingNodeInfo `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`  // streaming node that the channel is assigned to.
	AccessMode PChannelAccessMode ``                                                               // access mode of the channel.
	/* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PChannelInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`  // channel name
	Term int64  `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"` // A monotonic increasing term, every time the channel is
	// recovered or moved to another streamingnode, the term
	// will increase by meta server.
	AccessMode PChannelAccessMode `` // access mode of the channel.
	/* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PChannelMeta struct {
	Channel                    *PChannelInfo            `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`                                            // keep the meta info that current assigned to.
	Node                       *StreamingNodeInfo       `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`                                                  // nil if channel is not uninitialized.
	State                      PChannelMetaState        `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.streaming.PChannelMetaState" json:"state,omitempty"` // state of the channel.
	Histories                  []*PChannelAssignmentLog `protobuf:"bytes,4,rep,name=histories,proto3" json:"histories,omitempty"`                                        // keep the meta info assignment log that used to be assigned to.
	LastAssignTimestampSeconds uint64                   ``                                                                                                               // The last assigned timestamp in seconds.
	/* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PChannelMetaState int32

type PartitionInfoOfVChannel struct {
	PartitionId int64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` // partition id.
	// contains filtered or unexported fields
}

type ProduceMessageRequest struct {
	RequestId int64               `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // request id for reply.
	Message   *messagespb.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                       // message to be sent.
	// contains filtered or unexported fields
}

type ProduceMessageResponse struct {
	RequestId int64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are assignable to Response:
	//
	//	*ProduceMessageResponse_Result
	//	*ProduceMessageResponse_Error
	Response isProduceMessageResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type ProduceMessageResponseResult struct {
	Id              *commonpb.MessageID    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                                    // the offset of the message in the channel.
	Timetick        uint64                 `protobuf:"varint,2,opt,name=timetick,proto3" json:"timetick,omitempty"`                                       // the timetick of that message sent.
	TxnContext      *messagespb.TxnContext `protobuf:"bytes,3,opt,name=txnContext,proto3" json:"txnContext,omitempty"`                                    // the txn context of the message.
	Extra           *anypb.Any             `protobuf:"bytes,4,opt,name=extra,proto3" json:"extra,omitempty"`                                              // the extra message.
	LastConfirmedId *commonpb.MessageID    `protobuf:"bytes,5,opt,name=last_confirmed_id,json=lastConfirmedId,proto3" json:"last_confirmed_id,omitempty"` // the last confirmed message id.
	// contains filtered or unexported fields
}

type ProduceMessageResponse_Error struct {
	Error *StreamingError `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type ProduceMessageResponse_Result struct {
	Result *ProduceMessageResponseResult `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type ProduceRequest struct {

	// Types that are assignable to Request:
	//
	//	*ProduceRequest_Produce
	//	*ProduceRequest_Close
	Request isProduceRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type ProduceRequest_Close struct {
	Close *CloseProducerRequest `protobuf:"bytes,2,opt,name=close,proto3,oneof"`
}

type ProduceRequest_Produce struct {
	Produce *ProduceMessageRequest `protobuf:"bytes,1,opt,name=produce,proto3,oneof"`
}

type ProduceResponse struct {

	// Types that are assignable to Response:
	//
	//	*ProduceResponse_Create
	//	*ProduceResponse_Produce
	//	*ProduceResponse_Close
	Response isProduceResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type ProduceResponse_Close struct {
	Close *CloseProducerResponse `protobuf:"bytes,3,opt,name=close,proto3,oneof"`
}

type ProduceResponse_Create struct {
	Create *CreateProducerResponse `protobuf:"bytes,1,opt,name=create,proto3,oneof"`
}

type ProduceResponse_Produce struct {
	Produce *ProduceMessageResponse `protobuf:"bytes,2,opt,name=produce,proto3,oneof"`
}

type ReplicateConfigurationMeta struct {
	ReplicateConfiguration *commonpb.ReplicateConfiguration ``                                                                                               /* 127-byte string literal not displayed */
	AckedResult            *AckedResult                     `protobuf:"bytes,2,opt,name=acked_result,json=ackedResult,proto3" json:"acked_result,omitempty"` // a acked helper to help managing the consuming of PutReplicateConfigMessageV2 message at coordinator.
	// contains filtered or unexported fields
}

type ReplicatePChannelMeta struct {
	SourceChannelName     string                        `protobuf:"bytes,1,opt,name=source_channel_name,json=sourceChannelName,proto3" json:"source_channel_name,omitempty"`
	TargetChannelName     string                        `protobuf:"bytes,2,opt,name=target_channel_name,json=targetChannelName,proto3" json:"target_channel_name,omitempty"`
	TargetCluster         *commonpb.MilvusCluster       `protobuf:"bytes,3,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"`
	InitializedCheckpoint *commonpb.ReplicateCheckpoint `protobuf:"bytes,4,opt,name=initialized_checkpoint,json=initializedCheckpoint,proto3" json:"initialized_checkpoint,omitempty"`
	// contains filtered or unexported fields
}

type ReportAssignmentErrorRequest struct {
	Pchannel *PChannelInfo   `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"` // channel
	Err      *StreamingError `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`           // error happend on log node
	// contains filtered or unexported fields
}

type SegmentAssignmentMeta struct {
	CollectionId       int64                  `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId        int64                  `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	SegmentId          int64                  `protobuf:"varint,3,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	Vchannel           string                 `protobuf:"bytes,4,opt,name=vchannel,proto3" json:"vchannel,omitempty"`
	State              SegmentAssignmentState `protobuf:"varint,5,opt,name=state,proto3,enum=milvus.proto.streaming.SegmentAssignmentState" json:"state,omitempty"`
	Stat               *SegmentAssignmentStat `protobuf:"bytes,6,opt,name=stat,proto3" json:"stat,omitempty"`
	StorageVersion     int64                  `protobuf:"varint,7,opt,name=storage_version,json=storageVersion,proto3" json:"storage_version,omitempty"`               // only available if level is L1 or Legacy.
	CheckpointTimeTick uint64                 `protobuf:"varint,8,opt,name=checkpoint_time_tick,json=checkpointTimeTick,proto3" json:"checkpoint_time_tick,omitempty"` // The timetick of checkpoint, the meta already see the message at this timetick.
	// contains filtered or unexported fields
}

type SegmentAssignmentStat struct {
	MaxBinarySize         uint64 `protobuf:"varint,1,opt,name=max_binary_size,json=maxBinarySize,proto3" json:"max_binary_size,omitempty"`
	ModifiedRows          uint64 `protobuf:"varint,2,opt,name=modified_rows,json=modifiedRows,proto3" json:"modified_rows,omitempty"`
	ModifiedBinarySize    uint64 `protobuf:"varint,3,opt,name=modified_binary_size,json=modifiedBinarySize,proto3" json:"modified_binary_size,omitempty"`
	CreateTimestamp       int64  `protobuf:"varint,4,opt,name=create_timestamp,json=createTimestamp,proto3" json:"create_timestamp,omitempty"`
	LastModifiedTimestamp int64  `` /* 127-byte string literal not displayed */
	BinlogCounter         uint64 `protobuf:"varint,6,opt,name=binlog_counter,json=binlogCounter,proto3" json:"binlog_counter,omitempty"`
	CreateSegmentTimeTick uint64 `` // The timetick of create segment message in wal.
	/* 129-byte string literal not displayed */
	Level   datapb.SegmentLevel `protobuf:"varint,8,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"` // The level of the segment, only L0 or L1.
	MaxRows uint64              `protobuf:"varint,9,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`                  // The max rows of the segment.
	// contains filtered or unexported fields
}