INNER CODE UNIT · Go

opDataReady

rwynn/gtm · gtm.go:993

func opDataReady(op *Op, o *Options) (ready bool) {
	if o.UpdateDataAsDelta {
		ready = true
	} else if o.Ordering == AnyOrder {
		ready = !op.IsUpdate()
	}
	return
}

func TailOps(ctx *OpCtx, client *mongo.Client, channels []OpChan, o *Options) error {
	defer ctx.allWg.Done()
	var cursor *mongo.Cursor
	var err error
	var cts primitive.Timestamp
	if o.After != nil {
		cts, _ = o.After(client, o)
	} else {
		cts, _ = LastOpTimestamp(client, o)

View source record →