INNER CODE UNIT · Go

func

rwynn/gtm · gtm.go:45

func (t *task) start() {
	defer t.cancel()
	select {
	case <-t.doneC:
		break
	case <-t.stopC:
		break
	}
}

func (t *task) Done() {
	close(t.doneC)
}

const (
	Oplog     OrderingGuarantee = iota // ops sent in oplog order (strong ordering)
	Namespace                          // ops sent in oplog order within a namespace
	Document                           // ops sent in oplog order for a single document

View source record →