File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -17,12 +17,15 @@ type (
1717 // Notice: This API is EXPERIMENTAL and may be changed or removed in a
1818 // later release.
1919 Topic struct {
20+ // TopicReaderStreamLifeCycleEvents
2021 OnReaderReconnect func (startInfo TopicReaderReconnectStartInfo ) func (doneInfo TopicReaderReconnectDoneInfo )
2122 OnReaderReconnectRequest func (info TopicReaderReconnectRequestInfo )
2223
24+ // TopicReaderPartitionEvents
2325 OnReaderPartitionReadStartResponse func (startInfo TopicReaderPartitionReadStartResponseStartInfo ) func (doneInfo TopicReaderPartitionReadStartResponseDoneInfo )
2426 OnReaderPartitionReadStopResponse func (startInfo TopicReaderPartitionReadStopResponseStartInfo ) func (doneInfo TopicReaderPartitionReadStopResponseDoneInfo )
2527
28+ // TopicReaderStreamEvents
2629 OnReaderCommit func (startInfo TopicReaderCommitStartInfo ) func (doneInfo TopicReaderCommitDoneInfo )
2730 OnReaderSendCommitMessage func (startInfo TopicReaderSendCommitMessageStartInfo ) func (doneInfo TopicReaderSendCommitMessageDoneInfo )
2831 OnReaderCommittedNotify func (info TopicReaderCommittedNotifyInfo )
3134 OnReaderError func (info TopicReaderErrorInfo )
3235 OnReaderUpdateToken func (startInfo OnReadUpdateTokenStartInfo ) func (updateTokenInfo OnReadUpdateTokenMiddleTokenReceivedInfo ) func (doneInfo OnReadStreamUpdateTokenDoneInfo )
3336
37+ // TopicReaderMessageEvents
3438 OnReaderSentDataRequest func (startInfo TopicReaderSentDataRequestInfo )
3539 OnReaderReceiveDataResponse func (startInfo TopicReaderReceiveDataResponseStartInfo ) func (doneInfo TopicReaderReceiveDataResponseDoneInfo )
3640 OnReaderReadMessages func (startInfo TopicReaderReadMessagesStartInfo ) func (doneInfo TopicReaderReadMessagesDoneInfo )
You can’t perform that action at this time.
0 commit comments