()
| 142 | } |
| 143 | |
| 144 | func (o *Oracle) currentState() *pb.OracleDelta { |
| 145 | o.AssertRLock() |
| 146 | resp := &pb.OracleDelta{} |
| 147 | for start, commit := range o.commits { |
| 148 | resp.Txns = append(resp.Txns, |
| 149 | &pb.TxnStatus{StartTs: start, CommitTs: commit}) |
| 150 | } |
| 151 | resp.MaxAssigned = o.maxAssigned |
| 152 | return resp |
| 153 | } |
| 154 | |
| 155 | func (o *Oracle) newSubscriber() (<-chan pb.OracleDelta, int) { |
| 156 | o.Lock() |
no test coverage detected