File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -39,8 +39,8 @@ Go client for [RabbitMQ Stream Queues](https://github.com/rabbitmq/rabbitmq-serv
39
39
* [Handle Close](#handle-close)
40
40
* [Reliable Producer and Reliable Consumer](#reliable-producer-and-reliable-consumer)
41
41
* [Super Stream](#super-stream)
42
- [ Performance test tool] ( #performance-test-tool )
43
- * [ Performance test tool Docker] ( #performance-test-tool-docker )
42
+ - [ Performance test tool] ( #performance-test-tool )
43
+ * [ Performance test tool Docker] ( #performance-test-tool-docker )
44
44
- [ Build form source] ( #build-form-source )
45
45
- [ Project status] ( #project-status )
46
46
Original file line number Diff line number Diff line change @@ -50,7 +50,8 @@ type CPartitionClose struct {
50
50
}
51
51
52
52
// CPartitionContext is an interface that is used to expose partition information and methods
53
- // to the user. The user can use the PPartitionContext to reconnect a partition to the SuperStreamConsumer
53
+ // to the user. The user can use the CPartitionContext to reconnect a partition to the SuperStreamConsumer
54
+ // Specifying the offset to start from
54
55
type CPartitionContext interface {
55
56
ConnectPartition (partition string , offset OffsetSpecification ) error
56
57
}
You can’t perform that action at this time.
0 commit comments