TimeOffsetOf constructs an OffsetRequest which asks for a partition offset at a given time.
(partition int, at time.Time)
| 31 | // TimeOffsetOf constructs an OffsetRequest which asks for a partition offset |
| 32 | // at a given time. |
| 33 | func TimeOffsetOf(partition int, at time.Time) OffsetRequest { |
| 34 | return OffsetRequest{Partition: partition, Timestamp: timestamp(at)} |
| 35 | } |
| 36 | |
| 37 | // PartitionOffsets carries information about offsets available in a topic |
| 38 | // partition. |
nothing calls this directly
no test coverage detected