Function newMemoryCheckpointStore

compose/batch/main.go:475–479

()

}

func newMemoryCheckpointStore() *memoryCheckpointStore {
	return &memoryCheckpointStore{
		data: make(map[string][]byte),
	}
}

func (m *memoryCheckpointStore) Get(_ context.Context, id string) ([]byte, bool, error) {
	m.mu.RLock()