tree 234bc16088b5501f8c4425ffb6f8c81e8b9228db
parent 8e3c306a4f000e911c634338b1428c22fa6c4040
author tmdiep <tmdiep@google.com> 1604547400 +1100
committer GitHub <noreply@github.com> 1604547400 +1100
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJfo3NICRBK7hj4Ov3rIwAAdHIIALJiJbQss/LEfdLqs986RNQl
 yYkdkgi1qe5y+SR2E9NXeqh2PONboyazCbnoLHbeEU3iF0HpE/djvNLsoS+QJj76
 9ZqqFlKjTVtZkk5Z3vWgkjRuNvt2nO+/ciYMhKkHc1nbL+zwY0ARHX34Lwx+428e
 Lp/v3F57W6uAyAPanGZFZbGjDdj/2P28nhKVuFeITO/ocIr4iC2DlIpzDqkuJc0Z
 98yLYCJRhbEl5hQ8k8Cf2lHvPctA/kdqFR4TSXRvVSGdJJySlhYRQfPC6mHsUxwK
 3FboipHoSSUt/8oihgiQa0fo5CUXgD5KJ4d/8hU+gtgfmjqghdBctUUz7Z3uJgw=
 =Aku7
 -----END PGP SIGNATURE-----
 

feat(pubsublite): Trackers for acks and commit cursor (#3137)

These are similar to their Java counterparts with the following differences:
- ackConsumer is similar to AckReplyConsumer.
- ackTracker is equivalent to AckSetTrackerImpl. It maintains a single ordered queue of unacked offsets and stores the desired commit offset in ackedPrefixOffset.
- commitCursorTracker is equivalent to CommitState. It maintains the last commit offset confirmed by the server and a queue of unacknowledged committed offsets.