Searched refs:AddToContext (Results 1 – 25 of 112) sorted by relevance
12345
117 return a.assignmentClient.AssignPartitions(a.metadata.AddToContext(ctx))
139 return c.cursorClient.StreamingCommitCursor(c.metadata.AddToContext(ctx))
118 return c.cursorClient.StreamingCommitCursor(c.metadata.AddToContext(ctx))
117 return c.cursorClient.StreamingCommitCursor(c.metadata.AddToContext(ctx))
136 return a.assignmentClient.AssignPartitions(a.metadata.AddToContext(ctx))