DefaultRepackFunc is used to repack messages after hash by primary key.

DeleteRepackFunc is used to repack messages after hash by primary key.

ExtractCtx extracts trace span from msg.properties.

GetTsMsgFromConsumerMsg get TsMsg from consumer message.

InjectCtx is a method inject span to pulsr message.

InsertRepackFunc is used to repack messages after hash by primary key.

KafkaHealthCheck Perform a health check by retrieving cluster metadata.

MsgSpanFromCtx extracts the span from context.

NewMockFactory creates a new instance of MockFactory.

NewMockMsgStream creates a new instance of MockMsgStream.

NewMqMsgStream is used to generate a new mqMsgStream object.

NewMqTtMsgStream is used to generate a new MqTtMsgStream object.

NewNatsmqFactory create a new nats-mq factory.

NewRocksmqFactory creates a new message stream factory based on rocksmq.

PulsarHealthCheck Perform a health check by retrieving cluster metadata.

unsubscribeChannels create consumer first, and unsubscribe channel through msgStream.close() TODO use streamnative pulsarctl.

AlterIndexMsg is a message pack that contains create index request.

BaseMsg is a basic structure that contains begin timestamp, end timestamp and the position of msgstream.

CommonFactory is a Factory for creating message streams with common logic.

CreateCollectionMsg is a message pack that contains create collection request.

CreateIndexMsg is a message pack that contains create index request.

CreatePartitionMsg is a message pack that contains create partition request.

DataNodeTtMsg is a message pack that contains datanode time tick.

DeleteMsg is a message pack that contains delete request.

DropCollectionMsg is a message pack that contains drop collection request.

DropIndexMsg is a message pack that contains drop index request.

DropPartitionMsg is a message pack that contains drop partition request.

InsertMsg is a message pack that contains insert request.

LoadCollectionMsg is a message pack that contains load collection request.

MockFactory is an autogenerated mock type for the Factory type.

MockFactory_NewMsgStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewMsgStream'.

MockFactory_NewMsgStreamDisposer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewMsgStreamDisposer'.

MockFactory_NewTtMsgStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewTtMsgStream'.

MockMsgStream is an autogenerated mock type for the MsgStream type.

MockMsgStream_AsConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AsConsumer'.

MockMsgStream_AsProducer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AsProducer'.

MockMsgStream_Broadcast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Broadcast'.

MockMsgStream_Chan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Chan'.

MockMsgStream_CheckTopicValid_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckTopicValid'.

MockMsgStream_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'.

MockMsgStream_ForceEnableProduce_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForceEnableProduce'.

MockMsgStream_GetLatestMsgID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestMsgID'.

MockMsgStream_GetProduceChannels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetProduceChannels'.

MockMsgStream_Produce_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Produce'.

MockMsgStream_Seek_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Seek'.

MockMsgStream_SetRepackFunc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetRepackFunc'.

MqTtMsgStream is a msgstream that contains timeticks.

MsgPack represents a batch of msg in msgstream.

PmsFactory is a pulsar msgstream factory that implemented Factory interface(msgstream.go).

ProtoUDFactory is a factory to generate ProtoUnmarshalDispatcher object.

ProtoUnmarshalDispatcher is Unmarshal Dispatcher which used for data of proto type.

ReleaseCollectionMsg is a message pack that contains release collection request.

TimeTickMsg is a message pack that contains time tick only.

///////////////////////////////////////Upsert//////////////////////////////////////////.

MarshalType is an empty interface.

MsgStream is an interface that can be used to produce and consume message on message queue.

TsMsg provides methods to get begin timestamp and end timestamp of a message pack.

UnmarshalDispatcher is an interface contains method Unmarshal.

UnmarshalDispatcherFactory is a factory to generate an object which implement interface UnmarshalDispatcher.

IntPrimaryKey is an alias for short.

MessageID is an alias for short.

MsgPosition is an alias for short.

MsgType is an alias of commonpb.MsgType.

RepackFunc is a function type which used to repack message after hash by primary key.

Timestamp is an alias for short.

UniqueID is an alias for short.

UnmarshalFunc is an interface that has been implemented by each Msg.