func()

in accumulator/batch.go [106:124]


func (b *Batch) RegisterInvocation(
	reqID, functionARN string,
	deadlineMs int64,
	timestamp time.Time,
) {
	b.mu.Lock()
	defer b.mu.Unlock()

	i, ok := b.invocations[reqID]
	if !ok {
		i = &Invocation{}
		b.invocations[reqID] = i
	}
	i.RequestID = reqID
	i.FunctionARN = functionARN
	i.DeadlineMs = deadlineMs
	i.Timestamp = timestamp
	b.currentlyExecutingRequestID = reqID
}