Method Set

compose/batch/batch/store.go:79–90

Set stores checkpoint data for a batch index. Implements compose.CheckPointStore interface.

(_ context.Context, checkPointID string, checkPoint []byte)

// Set stores checkpoint data for a batch index.
// Implements compose.CheckPointStore interface.
func (m *batchBridgeStore) Set(_ context.Context, checkPointID string, checkPoint []byte) error {
	index, err := parseBatchIndex(checkPointID)
	if err != nil {
		return err
	}

	m.mu.Lock()
	defer m.mu.Unlock()

	m.data[index] = checkPoint
	return nil
}