Method ReadOffset

conn.go:896–898

ReadOffset returns the offset of the first message with a timestamp equal or greater to t.

(t time.Time)

// ReadOffset returns the offset of the first message with a timestamp equal or
// greater to t.
func (c *Conn) ReadOffset(t time.Time) (int64, error) {
	return c.readOffset(timestamp(t))
}

// ReadFirstOffset returns the first offset available on the connection.
func (c *Conn) ReadFirstOffset() (int64, error) {