Lines Matching defs:committer

42 type committer struct {  struct
44 	cursorClient *vkit.CursorClient
45 	subscription subscriptionPartition
46 	initialReq   *pb.StreamingCommitCursorRequest
47 	metadata     pubsubMetadata
50 	stream        *retryableStream
51 	acks          *ackTracker
52 	cursorTracker *commitCursorTracker
53 	pollCommits   *periodicTask
55 	abstractService
88 func (c *committer) Start() {
100 func (c *committer) Stop() {
108 func (c *committer) Terminate() {
116 func (c *committer) newStream(ctx context.Context) (grpc.ClientStream, error) {
120 func (c *committer) initialRequest() (interface{}, initialResponseRequired) {
124 func (c *committer) validateInitialResponse(response interface{}) error {
132 func (c *committer) onStreamStatusChange(status streamStatus) {
153 func (c *committer) onResponse(response interface{}) {
181 func (c *committer) commitOffsetToStream() {
187 func (c *committer) unsafeCommitOffsetToStream() {
205 func (c *committer) unsafeInitiateShutdown(targetStatus serviceStatus, err error) {
222 func (c *committer) unsafeCheckDone() {
230 func (c *committer) unsafeOnTerminated() {